forked from KolibriOS/kolibrios
264 lines
6.7 KiB
C
264 lines
6.7 KiB
C
#ifndef INCLUDE_LIBHTTP_H
|
|
#define INCLUDE_LIBHTTP_H
|
|
|
|
#ifndef INCLUDE_KOLIBRI_H
|
|
#include "../lib/kolibri.h"
|
|
#endif
|
|
|
|
#ifdef __COFF__
|
|
extern dword http_get;
|
|
extern dword http_head;
|
|
extern dword http_post;
|
|
extern dword http_find_header_field;
|
|
extern dword http_send;
|
|
extern dword http_receive;
|
|
extern dword http_disconnect;
|
|
extern dword http_free;
|
|
extern dword http_escape;
|
|
extern dword http_unescape;
|
|
#else
|
|
#ifndef INCLUDE_DLL_H
|
|
#include "../lib/dll.h"
|
|
#endif
|
|
|
|
dword libHTTP = #alibHTTP;
|
|
char alibHTTP[] = "/sys/lib/http.obj";
|
|
|
|
dword http_lib_init = #aHTTPinit;
|
|
dword http_get = #aHTTPget;
|
|
dword http_head = #aHTTPhead;
|
|
dword http_post = #aHTTPpost;
|
|
dword http_find_header_field = #aFHF;
|
|
dword http_send = #aHTTPsend;
|
|
dword http_receive = #aHTTPreceive;
|
|
dword http_disconnect = #aHTTPdisconnect;
|
|
dword http_free = #aHTTPfree;
|
|
dword uri_escape = #aURIescape;
|
|
dword uri_unescape = #aURIunescape;
|
|
$DD 2 dup 0
|
|
|
|
char aHTTPinit[] = "lib_init";
|
|
char aHTTPget[] = "get";
|
|
char aHTTPhead[] = "head";
|
|
char aHTTPpost[] = "post";
|
|
char aFHF[] = "find_header_field";
|
|
char aHTTPsend[] = "send";
|
|
char aHTTPreceive[] = "receive";
|
|
char aHTTPdisconnect[] = "disconnect";
|
|
char aHTTPfree[] = "free";
|
|
char aURIescape[] = "escape";
|
|
char aURIunescape[] = "unescape";
|
|
#endif
|
|
|
|
// status flags
|
|
#define FLAG_HTTP11 1 << 0
|
|
#define FLAG_GOT_HEADER 1 << 1
|
|
#define FLAG_GOT_ALL_DATA 1 << 2
|
|
#define FLAG_CONTENT_LENGTH 1 << 3
|
|
#define FLAG_CHUNKED 1 << 4
|
|
#define FLAG_CONNECTED 1 << 5
|
|
|
|
// user flags
|
|
#define FLAG_KEEPALIVE 1 << 8
|
|
#define FLAG_MULTIBUFF 1 << 9
|
|
|
|
// error flags
|
|
#define FLAG_INVALID_HEADER 1 << 16
|
|
#define FLAG_NO_RAM 1 << 17
|
|
#define FLAG_SOCKET_ERROR 1 << 18
|
|
#define FLAG_TIMEOUT_ERROR 1 << 19
|
|
#define FLAG_TRANSFER_FAILED 1 << 20
|
|
|
|
struct http_msg{
|
|
dword socket;
|
|
dword flags;
|
|
dword write_ptr;
|
|
dword buffer_length;
|
|
dword chunk_ptr;
|
|
dword timestamp;
|
|
dword status;
|
|
dword header_length;
|
|
dword content_ptr;
|
|
dword content_length;
|
|
dword content_received;
|
|
char http_header;
|
|
};
|
|
|
|
|
|
#define URL_SIZE 4000
|
|
//===================================================//
|
|
// //
|
|
// HTTP //
|
|
// //
|
|
//===================================================//
|
|
|
|
struct _http
|
|
{
|
|
dword cur_url;
|
|
dword transfer;
|
|
dword content_length;
|
|
dword content_received;
|
|
dword status_code;
|
|
dword receive_result;
|
|
dword content_pointer;
|
|
|
|
dword get();
|
|
bool stop();
|
|
void hfree();
|
|
void receive();
|
|
dword header_field();
|
|
};
|
|
|
|
dword _http::get(dword _url)
|
|
{
|
|
cur_url = _url;
|
|
if (streqrp(cur_url, "http://gate.aspero.pro/?site=")) cur_url += 29;
|
|
http_get stdcall (_url, 0, 0, #accept_language);
|
|
transfer = EAX;
|
|
return EAX;
|
|
}
|
|
|
|
void _http::hfree()
|
|
{
|
|
http_free stdcall (transfer);
|
|
transfer=0;
|
|
}
|
|
|
|
bool _http::stop()
|
|
{
|
|
if (transfer)
|
|
{
|
|
/*
|
|
EAX = transfer;
|
|
EAX = EAX.http_msg.content_ptr; // get pointer to data
|
|
$push EAX // save it on the stack
|
|
http_free stdcall (transfer); // abort connection
|
|
$pop EAX
|
|
free(EAX); // free data
|
|
transfer=0;
|
|
*/
|
|
hfree();
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
void _http::receive()
|
|
{
|
|
http_receive stdcall (transfer);
|
|
receive_result = EAX;
|
|
|
|
EDI = transfer;
|
|
if (!EAX) {
|
|
status_code = EDI.http_msg.status;
|
|
content_pointer = EDI.http_msg.content_ptr;
|
|
}
|
|
content_length = EDI.http_msg.content_length;
|
|
content_received = EDI.http_msg.content_received;
|
|
}
|
|
|
|
:dword _http::header_field(dword _header_field, _dst, _size)
|
|
{
|
|
http_find_header_field stdcall (transfer, _header_field);
|
|
if (EAX!=0) {
|
|
ESI = EAX;
|
|
EDI = _dst;
|
|
EDX = _size;
|
|
do {
|
|
$lodsb;
|
|
$stosb;
|
|
$dec edx
|
|
} while (AL != 0) && (AL != 13) && (AL != 10) && (EDX>0);
|
|
DSBYTE[EDI-1]='\0';
|
|
return _dst;
|
|
}
|
|
return NULL;
|
|
}
|
|
|
|
|
|
//===================================================//
|
|
// //
|
|
// CHECK PATH TYPE //
|
|
// //
|
|
//===================================================//
|
|
|
|
:int check_is_the_adress_local(dword _in)
|
|
{
|
|
if (ESBYTE[_in]!='/') return false;
|
|
_in++;
|
|
if(!strncmp(_in,"rd/",3)) return true;
|
|
if(!strncmp(_in,"fd/",3)) return true;
|
|
if(!strncmp(_in,"hd",2)) return true;
|
|
if(!strncmp(_in,"bd",2)) return true;
|
|
if(!strncmp(_in,"cd",2)) return true;
|
|
if(!strncmp(_in,"sys/",4)) return true;
|
|
if(!strncmp(_in,"tmp",3)) return true;
|
|
if(!strncmp(_in,"usbhd",5)) return true;
|
|
if(!strncmp(_in,"kolibrios",9)) return true;
|
|
return false;
|
|
}
|
|
|
|
:int check_is_the_url_absolute(dword _in)
|
|
{
|
|
if(!strncmp(_in,"ftp:",4)) return true;
|
|
if(!strncmp(_in,"http:",5)) return true;
|
|
if(!strncmp(_in,"https:",6)) return true;
|
|
if(!strncmp(_in,"mailto:",7)) return true;
|
|
if(!strncmp(_in,"tel:",4)) return true;
|
|
if(!strncmp(_in,"#",1)) return true;
|
|
if(!strncmp(_in,"WebView:",8)) return true;
|
|
if(check_is_the_adress_local(_in)) return true;
|
|
return false;
|
|
}
|
|
|
|
:dword get_absolute_url(dword new_URL, base_URL)
|
|
{
|
|
int i;
|
|
dword orig_URL = new_URL;
|
|
char newurl[URL_SIZE+1];
|
|
strcpy(#newurl, base_URL);
|
|
|
|
while (i=strstr(new_URL, "&")) strcpy(i+1, i+5);
|
|
|
|
if (check_is_the_url_absolute(new_URL)) return new_URL;
|
|
|
|
switch(ESBYTE[new_URL]) {
|
|
case '.':
|
|
new_URL++;
|
|
if (ESBYTE[new_URL] == '/') {
|
|
new_URL++;
|
|
}
|
|
else if (ESBYTE[new_URL] == '.') && (ESBYTE[new_URL+1] == '/') {
|
|
_GO_UP:
|
|
new_URL+=2;
|
|
newurl[strrchr(#newurl, '/')-1] = '\0';
|
|
}
|
|
goto _DEFAULT;
|
|
case '?':
|
|
strchr(#newurl+8, '?'); //returns EAX
|
|
if (EAX) ESBYTE[EAX] = '\0';
|
|
strchr(#newurl+8, '/'); //returns EAX
|
|
if (!EAX) chrcat(#newurl, '/');
|
|
break;
|
|
case '/':
|
|
new_URL++;
|
|
if (ESBYTE[new_URL] == '/') {
|
|
strcpy(#newurl, "http:/");
|
|
break;
|
|
}
|
|
EAX = strchr(#newurl+8, '/');
|
|
if (EAX) ESBYTE[EAX] = '\0';
|
|
default:
|
|
_DEFAULT:
|
|
EAX = strrchr(#newurl, '/');
|
|
if (newurl[EAX-2]!='/') newurl[EAX] = '\0';
|
|
if (!strncmp(new_URL,"../",3)) goto _GO_UP;
|
|
if (newurl[strlen(#newurl)-1]!='/') strncat(#newurl, "/", URL_SIZE);
|
|
}
|
|
strncat(#newurl, new_URL, URL_SIZE);
|
|
strncpy(orig_URL, #newurl, URL_SIZE);
|
|
return orig_URL;
|
|
}
|
|
|
|
|
|
#endif |