Rev 7293 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed
Rev | Author | Line No. | Line |
---|---|---|---|
7281 | leency | 1 | //===================================================// |
2 | // // |
||
3 | // HTTP // |
||
4 | // // |
||
5 | //===================================================// |
||
6058 | leency | 6 | |
7281 | leency | 7 | struct _http |
8 | { |
||
9 | dword url; |
||
10 | dword transfer; |
||
11 | dword content_length; |
||
12 | dword content_received; |
||
13 | dword status_code; |
||
14 | dword receive_result; |
||
15 | dword content_pointer; |
||
7282 | leency | 16 | char redirect_url[4096*3]; |
17 | char finaladress[4096*3]; |
||
7281 | leency | 18 | |
19 | dword get(); |
||
20 | void free(); |
||
21 | void receive(); |
||
22 | bool handle_redirect(); |
||
23 | }; |
||
24 | |||
25 | dword _http::get(dword _url) |
||
26 | { |
||
27 | url = _url; |
||
28 | http_get stdcall (url, 0, 0, #accept_language); |
||
29 | transfer = EAX; |
||
30 | return transfer; |
||
31 | } |
||
32 | |||
33 | void _http::free() |
||
34 | { |
||
35 | http_free stdcall (transfer); |
||
36 | transfer=0; |
||
37 | } |
||
38 | |||
39 | void _http::receive() |
||
40 | { |
||
41 | http_receive stdcall (transfer); |
||
42 | receive_result = EAX; |
||
43 | |||
7282 | leency | 44 | EDI = transfer; |
45 | if (!EAX) { |
||
46 | status_code = EDI.http_msg.status; |
||
47 | content_pointer = EDI.http_msg.content_ptr; |
||
48 | } |
||
49 | content_length = EDI.http_msg.content_length; |
||
50 | content_received = EDI.http_msg.content_received; |
||
7281 | leency | 51 | |
52 | } |
||
53 | |||
54 | bool _http::handle_redirect() |
||
55 | { |
||
7282 | leency | 56 | dword redirect; |
7281 | leency | 57 | http_find_header_field stdcall (transfer, "location\0"); |
58 | if (EAX!=0) { |
||
59 | ESI = EAX; |
||
60 | EDI = #redirect_url; |
||
61 | do { |
||
62 | $lodsb; |
||
63 | $stosb; |
||
64 | } while (AL != 0) && (AL != 13) && (AL != 10); |
||
65 | DSBYTE[EDI-1]='\0'; |
||
66 | get_absolute_url(#finaladress, url, #redirect_url); |
||
67 | strcpy(url, #finaladress); |
||
68 | return true; |
||
69 | } |
||
70 | return false; |
||
71 | } |
||
72 | |||
73 | //===================================================// |
||
74 | // // |
||
75 | // DOWNLOADER // |
||
76 | // // |
||
77 | //===================================================// |
||
78 | |||
79 | |||
6058 | leency | 80 | enum { |
81 | STATE_NOT_STARTED, |
||
82 | STATE_IN_PROGRESS, |
||
83 | STATE_COMPLETED |
||
84 | }; |
||
85 | |||
86 | struct DOWNLOADER { |
||
7281 | leency | 87 | _http httpd; |
6058 | leency | 88 | dword bufpointer, bufsize, url; |
7281 | leency | 89 | int state; |
6058 | leency | 90 | dword Start(); |
91 | void Stop(); |
||
7282 | leency | 92 | bool MonitorProgress(); |
7283 | leency | 93 | }; |
6058 | leency | 94 | |
95 | dword DOWNLOADER::Start(dword _url) |
||
96 | { |
||
97 | url = _url; |
||
98 | state = STATE_IN_PROGRESS; |
||
7281 | leency | 99 | httpd.get(url); |
7293 | leency | 100 | if (!httpd.transfer) Stop(); |
7281 | leency | 101 | return httpd.transfer; |
6058 | leency | 102 | } |
103 | |||
104 | void DOWNLOADER::Stop() |
||
105 | { |
||
106 | state = STATE_NOT_STARTED; |
||
7281 | leency | 107 | if (httpd.transfer!=0) |
6058 | leency | 108 | { |
7281 | leency | 109 | EAX = httpd.transfer; |
6058 | leency | 110 | EAX = EAX.http_msg.content_ptr; // get pointer to data |
111 | $push EAX // save it on the stack |
||
7281 | leency | 112 | http_free stdcall (httpd.transfer); // abort connection |
6058 | leency | 113 | $pop EAX |
7281 | leency | 114 | free(EAX); // free data |
115 | httpd.transfer=0; |
||
6058 | leency | 116 | bufsize = 0; |
7281 | leency | 117 | bufpointer = free(bufpointer); |
6058 | leency | 118 | } |
7282 | leency | 119 | httpd.content_received = httpd.content_length = 0; |
6058 | leency | 120 | } |
121 | |||
7282 | leency | 122 | bool DOWNLOADER::MonitorProgress() |
6058 | leency | 123 | { |
7281 | leency | 124 | if (httpd.transfer <= 0) return false; |
7282 | leency | 125 | httpd.receive(); |
126 | if (!httpd.content_length) httpd.content_length = httpd.content_received * 20; |
||
6058 | leency | 127 | |
7282 | leency | 128 | if (httpd.receive_result == 0) { |
7281 | leency | 129 | if (httpd.status_code >= 300) && (httpd.status_code < 400) |
6058 | leency | 130 | { |
7281 | leency | 131 | httpd.handle_redirect(); |
132 | strcpy(url, httpd.url); |
||
7282 | leency | 133 | get_absolute_url(#httpd.finaladress, url, #httpd.redirect_url); |
6058 | leency | 134 | Stop(); |
7282 | leency | 135 | Start(#httpd.finaladress); |
136 | url = #httpd.finaladress; |
||
6058 | leency | 137 | return false; |
138 | } |
||
7282 | leency | 139 | state = STATE_COMPLETED; |
140 | bufpointer = httpd.content_pointer; |
||
141 | bufsize = httpd.content_received; |
||
142 | httpd.free(); |
||
6058 | leency | 143 | } |
144 | return true; |
||
145 | } |
||
146 | |||
147 | |||
148 | /*===================================== |
||
149 | == == |
||
7281 | leency | 150 | == CHECK PATH TYPE == |
6058 | leency | 151 | == == |
152 | =====================================*/ |
||
153 | |||
154 | |||
155 | int check_is_the_adress_local(dword _in) |
||
156 | { |
||
157 | if (ESBYTE[_in]!='/') return false; |
||
158 | _in++; |
||
159 | if(!strncmp(_in,"rd/",3)) return true; |
||
160 | if(!strncmp(_in,"fd/",3)) return true; |
||
6216 | leency | 161 | if(!strncmp(_in,"hd",2)) return true; |
162 | if(!strncmp(_in,"bd",2)) return true; |
||
163 | if(!strncmp(_in,"cd",2)) return true; |
||
6058 | leency | 164 | if(!strncmp(_in,"sys/",4)) return true; |
165 | if(!strncmp(_in,"tmp/",4)) return true; |
||
6216 | leency | 166 | if(!strncmp(_in,"usbhd",5)) return true; |
7422 | leency | 167 | if(!strncmp(_in,"kolibrios",9)) return true; |
6058 | leency | 168 | return false; |
169 | } |
||
170 | |||
171 | int check_is_the_url_absolute(dword _in) |
||
172 | { |
||
173 | if(!strncmp(_in,"ftp:",4)) return true; |
||
174 | if(!strncmp(_in,"http:",5)) return true; |
||
175 | if(!strncmp(_in,"https:",6)) return true; |
||
176 | if(!strncmp(_in,"mailto:",7)) return true; |
||
177 | if(check_is_the_adress_local(_in)) return true; |
||
178 | return false; |
||
179 | } |
||
180 | |||
181 | void get_absolute_url(dword _rez, _base, _new) |
||
182 | { |
||
183 | int i; |
||
184 | //case: ./valera.html |
||
185 | if (!strncmp(_new,"./", 2)) _new+=2; |
||
186 | //case: http://site.name |
||
187 | if (check_is_the_url_absolute(_new)) { |
||
188 | strcpy(_rez, _new); |
||
189 | goto _GET_ABSOLUTE_URL_END; |
||
190 | } |
||
191 | //case: /valera.html |
||
192 | if (ESBYTE[_new] == '/') //remove everything after site domain name |
||
193 | { |
||
194 | strcpy(_rez, _base); |
||
195 | i = strchr(_rez+8,'/'); |
||
196 | if (i<1) i=strlen(_rez)+_rez; |
||
197 | strcpy(i, _new); |
||
198 | goto _GET_ABSOLUTE_URL_END; |
||
199 | } |
||
200 | //case: ../../valera.html |
||
201 | strcpy(_rez, _base); |
||
202 | ESBYTE[ strrchr(_rez,'/') + _rez -1 ] = '\0'; //remove name |
||
203 | while (!strncmp(_new,"../",3)) |
||
204 | { |
||
205 | _new += 3; |
||
206 | ESBYTE[ strrchr(_rez,'/') + _rez -1 ] = '\0'; |
||
207 | } |
||
208 | //case: valera.html |
||
209 | chrcat(_rez, '/'); |
||
210 | strcat(_rez, _new); |
||
211 | _GET_ABSOLUTE_URL_END: |
||
212 | while (i=strstr(_rez, "&")) strcpy(i+1, i+5); |
||
213 | }1)>>=> |