Subversion Repositories Kolibri OS

#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