WebSVN – Kolibri OS – Blame – /programs/develop/libraries/http/http.asm

Rev	Author	Line No.	Line
4158	hidnplayr	1	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
		2	;; ;;
4541	hidnplayr	3	;; Copyright (C) KolibriOS team 2004-2014. All rights reserved. ;;
4158	hidnplayr	4	;; Distributed under terms of the GNU General Public License ;;
		5	;; ;;
		6	;; HTTP library for KolibriOS ;;
		7	;; ;;
		8	;; Written by hidnplayr@kolibrios.org ;;
4233	hidnplayr	9	;; Proxy code written by CleverMouse ;;
4158	hidnplayr	10	;; ;;
		11	;; GNU GENERAL PUBLIC LICENSE ;;
		12	;; Version 2, June 1991 ;;
		13	;; ;;
		14	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
		15
		16	; references:
		17	; "HTTP made really easy", http://www.jmarshall.com/easy/http/
		18	; "Hypertext Transfer Protocol -- HTTP/1.1", http://tools.ietf.org/html/rfc2616
		19
		20
		21	URLMAXLEN = 65535
4541	hidnplayr	22	BUFFERSIZE = 8192
4690	hidnplayr	23	TIMEOUT = 500 ; in 1/100 s
4158	hidnplayr	24
		25	__DEBUG__ = 1
		26	__DEBUG_LEVEL__ = 1
		27
		28
		29	format MS COFF
		30
		31	public @EXPORT as 'EXPORTS'
		32
		33	include '../../../struct.inc'
		34	include '../../../proc32.inc'
		35	include '../../../macros.inc'
		36	purge section,mov,add,sub
		37	include '../../../debug-fdo.inc'
		38
		39	include '../../../network.inc'
		40	include 'http.inc'
		41
		42	virtual at 0
		43	http_msg http_msg
		44	end virtual
		45
		46	macro copy_till_zero {
4241	hidnplayr	47	local .copyloop, .copydone
		48	.copyloop:
4158	hidnplayr	49	lodsb
		50	test al, al
4241	hidnplayr	51	jz .copydone
4158	hidnplayr	52	stosb
4241	hidnplayr	53	jmp .copyloop
		54	.copydone:
4158	hidnplayr	55	}
		56
4167	hidnplayr	57	macro HTTP_init_buffer buffer, socketnum {
		58
		59	mov eax, buffer
		60	push socketnum
		61	popd [eax + http_msg.socket]
4541	hidnplayr	62	lea esi, [eax + http_msg.http_header]
4205	hidnplayr	63	mov [eax + http_msg.flags], FLAG_CONNECTED
4167	hidnplayr	64	mov [eax + http_msg.write_ptr], esi
4541	hidnplayr	65	mov [eax + http_msg.buffer_length], BUFFERSIZE - http_msg.http_header
4167	hidnplayr	66	mov [eax + http_msg.chunk_ptr], 0
		67
		68	mov [eax + http_msg.status], 0
		69	mov [eax + http_msg.header_length], 0
4541	hidnplayr	70	mov [eax + http_msg.content_ptr], 0
4167	hidnplayr	71	mov [eax + http_msg.content_length], 0
4168	hidnplayr	72	mov [eax + http_msg.content_received], 0
4206	hidnplayr	73
		74	push eax ebp
		75	mov ebp, eax
4690	hidnplayr	76	mcall 26, 9
4206	hidnplayr	77	mov [ebp + http_msg.timestamp], eax
		78	pop ebp eax
4167	hidnplayr	79	}
		80
4158	hidnplayr	81	section '.flat' code readable align 16
		82
		83	;;===========================================================================;;
		84	lib_init: ;//////////////////////////////////////////////////////////////////;;
		85	;;---------------------------------------------------------------------------;;
		86	;? Library entry point (called after library load) ;;
		87	;;---------------------------------------------------------------------------;;
		88	;> eax = pointer to memory allocation routine ;;
		89	;> ebx = pointer to memory freeing routine ;;
		90	;> ecx = pointer to memory reallocation routine ;;
		91	;> edx = pointer to library loading routine ;;
		92	;;---------------------------------------------------------------------------;;
4209	hidnplayr	93	;< eax = 1 (fail) / 0 (ok) ;;
4158	hidnplayr	94	;;===========================================================================;;
		95	mov [mem.alloc], eax
		96	mov [mem.free], ebx
		97	mov [mem.realloc], ecx
		98	mov [dll.load], edx
		99
		100	invoke dll.load, @IMPORT
4209	hidnplayr	101	test eax, eax
		102	jnz .error
4158	hidnplayr	103
		104	; load proxy settings
4216	hidnplayr	105	pusha
4158	hidnplayr	106	invoke ini.get_str, inifile, sec_proxy, key_proxy, proxyAddr, 256, proxyAddr
		107	invoke ini.get_int, inifile, sec_proxy, key_proxyport, 80
		108	mov [proxyPort], eax
		109	invoke ini.get_str, inifile, sec_proxy, key_user, proxyUser, 256, proxyUser
		110	invoke ini.get_str, inifile, sec_proxy, key_password, proxyPassword, 256, proxyPassword
4216	hidnplayr	111	popa
4158	hidnplayr	112
4212	hidnplayr	113	DEBUGF 1, "HTTP library: init OK\n"
4158	hidnplayr	114	xor eax, eax
		115	ret
		116
4209	hidnplayr	117	.error:
4212	hidnplayr	118	DEBUGF 1, "ERROR loading libraries\n"
4158	hidnplayr	119	xor eax, eax
4209	hidnplayr	120	inc eax
4158	hidnplayr	121	ret
		122
		123
		124
		125
		126	;;================================================================================================;;
4221	hidnplayr	127	proc HTTP_get URL, add_header ;///////////////////////////////////////////////////////////////////;;
4158	hidnplayr	128	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	129	;? Initiates a HTTP connection, using 'GET' method. ;;
4158	hidnplayr	130	;;------------------------------------------------------------------------------------------------;;
4221	hidnplayr	131	;> URL = pointer to ASCIIZ URL ;;
		132	;> add_header = pointer to additional header parameters (ASCIIZ), or null for none. ;;
4158	hidnplayr	133	;;------------------------------------------------------------------------------------------------;;
		134	;< eax = 0 (error) / buffer ptr ;;
		135	;;================================================================================================;;
		136	locals
		137	hostname dd ?
		138	pageaddr dd ?
		139	sockaddr dd ?
		140	socketnum dd ?
		141	buffer dd ?
4167	hidnplayr	142	port dd ?
4158	hidnplayr	143	endl
		144
4216	hidnplayr	145	pusha
		146
4158	hidnplayr	147	; split the URL into hostname and pageaddr
		148	stdcall parse_url, [URL]
		149	test eax, eax
		150	jz .error
		151	mov [hostname], eax
		152	mov [pageaddr], ebx
4221	hidnplayr	153	mov [port], ecx
4158	hidnplayr	154
4167	hidnplayr	155	; Connect to the other side.
		156	stdcall open_connection, [hostname], [port]
4158	hidnplayr	157	test eax, eax
4167	hidnplayr	158	jz .error
		159	mov [socketnum], eax
4158	hidnplayr	160
4167	hidnplayr	161	; Create the HTTP request.
		162	invoke mem.alloc, BUFFERSIZE
4158	hidnplayr	163	test eax, eax
		164	jz .error
4167	hidnplayr	165	mov [buffer], eax
		166	mov edi, eax
4541	hidnplayr	167	DEBUGF 1, "Buffer allocated: 0x%x\n", eax
4158	hidnplayr	168
4167	hidnplayr	169	mov esi, str_get
		170	copy_till_zero
4158	hidnplayr	171
4233	hidnplayr	172	; If we are using a proxy, send complete URL, otherwise send only page address.
		173	cmp [proxyAddr], 0
		174	je .no_proxy
		175	mov esi, str_http ; prepend 'http://'
		176	copy_till_zero
		177	mov esi, [hostname]
		178	copy_till_zero
		179	.no_proxy:
4167	hidnplayr	180	mov esi, [pageaddr]
		181	copy_till_zero
4158	hidnplayr	182
4167	hidnplayr	183	mov esi, str_http11
		184	mov ecx, str_http11.length
		185	rep movsb
		186
		187	mov esi, [hostname]
		188	copy_till_zero
		189
4241	hidnplayr	190	cmp byte[proxyUser], 0
		191	je @f
		192	call append_proxy_auth_header
		193	@@:
		194
		195	mov ax, 0x0a0d
		196	stosw
		197
4221	hidnplayr	198	mov esi, [add_header]
		199	test esi, esi
		200	jz @f
		201	copy_till_zero
		202	@@:
		203
4167	hidnplayr	204	mov esi, str_close
		205	mov ecx, str_close.length
		206	rep movsb
		207
		208	mov byte[edi], 0
		209	DEBUGF 1, "Request:\n%s", [buffer]
		210
4222	hidnplayr	211	; Free unused memory
		212	push edi
		213	invoke mem.free, [pageaddr]
		214	invoke mem.free, [hostname]
		215	pop esi
		216
4167	hidnplayr	217	; Send the request
		218	sub esi, [buffer] ; length
		219	xor edi, edi ; flags
		220	mcall send, [socketnum], [buffer]
4158	hidnplayr	221	test eax, eax
		222	jz .error
4167	hidnplayr	223	DEBUGF 1, "Request has been sent to server.\n"
4158	hidnplayr	224
4167	hidnplayr	225	HTTP_init_buffer [buffer], [socketnum]
		226
4216	hidnplayr	227	popa
		228	mov eax, [buffer] ; return buffer ptr
		229	ret
4167	hidnplayr	230
		231	.error:
		232	DEBUGF 1, "Error!\n"
4216	hidnplayr	233	popa
4167	hidnplayr	234	xor eax, eax ; return 0 = error
		235	ret
		236
		237	endp
		238
		239
		240
		241	;;================================================================================================;;
4221	hidnplayr	242	proc HTTP_head URL, add_header ;//////////////////////////////////////////////////////////////////;;
4167	hidnplayr	243	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	244	;? Initiates a HTTP connection, using 'HEAD' method. ;;
4541	hidnplayr	245	;? This will only return HTTP header and status, no content ;;
4167	hidnplayr	246	;;------------------------------------------------------------------------------------------------;;
4221	hidnplayr	247	;> URL = pointer to ASCIIZ URL ;;
		248	;> add_header = pointer to additional header parameters (ASCIIZ), or null for none. ;;
4167	hidnplayr	249	;;------------------------------------------------------------------------------------------------;;
		250	;< eax = 0 (error) / buffer ptr ;;
		251	;;================================================================================================;;
		252	locals
		253	hostname dd ?
		254	pageaddr dd ?
		255	sockaddr dd ?
		256	socketnum dd ?
		257	buffer dd ?
		258	port dd ?
		259	endl
		260
4216	hidnplayr	261	pusha
4167	hidnplayr	262	; split the URL into hostname and pageaddr
		263	stdcall parse_url, [URL]
4158	hidnplayr	264	test eax, eax
4167	hidnplayr	265	jz .error
		266	mov [hostname], eax
		267	mov [pageaddr], ebx
4221	hidnplayr	268	mov [port], ecx
4158	hidnplayr	269
4167	hidnplayr	270	; Connect to the other side.
		271	stdcall open_connection, [hostname], [port]
		272	test eax, eax
		273	jz .error
		274	mov [socketnum], eax
		275
4158	hidnplayr	276	; Create the HTTP request.
		277	invoke mem.alloc, BUFFERSIZE
		278	test eax, eax
		279	jz .error
		280	mov [buffer], eax
4167	hidnplayr	281	mov edi, eax
4158	hidnplayr	282	DEBUGF 1, "Buffer has been allocated.\n"
		283
4167	hidnplayr	284	mov esi, str_head
4158	hidnplayr	285	copy_till_zero
		286
4233	hidnplayr	287	; If we are using a proxy, send complete URL, otherwise send only page address.
		288	cmp [proxyAddr], 0
		289	je .no_proxy
		290	mov esi, str_http ; prepend 'http://'
		291	copy_till_zero
		292	mov esi, [hostname]
		293	copy_till_zero
		294	.no_proxy:
4167	hidnplayr	295	mov esi, [pageaddr]
		296	copy_till_zero
		297
4158	hidnplayr	298	mov esi, str_http11
		299	mov ecx, str_http11.length
		300	rep movsb
		301
		302	mov esi, [hostname]
		303	copy_till_zero
		304
4241	hidnplayr	305	cmp byte[proxyUser], 0
		306	je @f
		307	call append_proxy_auth_header
		308	@@:
		309
		310	mov ax, 0x0a0d
		311	stosw
		312
4221	hidnplayr	313	mov esi, [add_header]
		314	test esi, esi
		315	jz @f
		316	copy_till_zero
		317	@@:
		318
4158	hidnplayr	319	mov esi, str_close
		320	mov ecx, str_close.length
		321	rep movsb
		322
		323	mov byte[edi], 0
		324	DEBUGF 1, "Request:\n%s", [buffer]
		325
4222	hidnplayr	326
		327	; Free unused memory
		328	push edi
		329	invoke mem.free, [pageaddr]
		330	invoke mem.free, [hostname]
		331	pop esi
		332
4167	hidnplayr	333	; Send the request
4158	hidnplayr	334	sub esi, [buffer] ; length
		335	xor edi, edi ; flags
		336	mcall send, [socketnum], [buffer]
		337	test eax, eax
		338	jz .error
		339	DEBUGF 1, "Request has been sent to server.\n"
		340
4167	hidnplayr	341	HTTP_init_buffer [buffer], [socketnum]
4158	hidnplayr	342
4216	hidnplayr	343	popa
		344	mov eax, [buffer]
4167	hidnplayr	345	ret ; return buffer ptr
4158	hidnplayr	346
4167	hidnplayr	347	.error:
		348	DEBUGF 1, "Error!\n"
4216	hidnplayr	349	popa
4167	hidnplayr	350	xor eax, eax ; return 0 = error
		351	ret
		352
		353	endp
		354
		355
		356	;;================================================================================================;;
4221	hidnplayr	357	proc HTTP_post URL, add_header, content_type, content_length ;////////////////////////////////////;;
4167	hidnplayr	358	;;------------------------------------------------------------------------------------------------;;
4541	hidnplayr	359	;? Initiates a HTTP connection, using 'POST' method. ;;
		360	;? This method is used to send data to the HTTP server ;;
4167	hidnplayr	361	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	362	;> URL = pointer to ASCIIZ URL ;;
4221	hidnplayr	363	;> add_header = pointer to additional header parameters (ASCIIZ), or null for none. ;;
4202	hidnplayr	364	;> content_type = pointer to ASCIIZ string containing content type ;;
		365	;> content_length = length of content (in bytes) ;;
4167	hidnplayr	366	;;------------------------------------------------------------------------------------------------;;
		367	;< eax = 0 (error) / buffer ptr ;;
		368	;;================================================================================================;;
		369	locals
		370	hostname dd ?
		371	pageaddr dd ?
		372	sockaddr dd ?
		373	socketnum dd ?
		374	buffer dd ?
		375	port dd ?
		376	endl
		377
4216	hidnplayr	378	pusha
4167	hidnplayr	379	; split the URL into hostname and pageaddr
		380	stdcall parse_url, [URL]
		381	test eax, eax
		382	jz .error
		383	mov [hostname], eax
		384	mov [pageaddr], ebx
4221	hidnplayr	385	mov [port], ecx
4167	hidnplayr	386
		387	; Connect to the other side.
		388	stdcall open_connection, [hostname], [port]
		389	test eax, eax
		390	jz .error
		391	mov [socketnum], eax
		392
		393	; Create the HTTP request.
		394	invoke mem.alloc, BUFFERSIZE
		395	test eax, eax
		396	jz .error
		397	mov [buffer], eax
		398	mov edi, eax
		399	DEBUGF 1, "Buffer has been allocated.\n"
		400
		401	mov esi, str_post
		402	copy_till_zero
		403
4233	hidnplayr	404	; If we are using a proxy, send complete URL, otherwise send only page address.
		405	cmp [proxyAddr], 0
		406	je .no_proxy
		407	mov esi, str_http ; prepend 'http://'
		408	copy_till_zero
		409	mov esi, [hostname]
		410	copy_till_zero
		411	.no_proxy:
4167	hidnplayr	412	mov esi, [pageaddr]
		413	copy_till_zero
		414
		415	mov esi, str_http11
		416	mov ecx, str_http11.length
		417	rep movsb
		418
		419	mov esi, [hostname]
		420	copy_till_zero
		421
		422	mov esi, str_post_cl
		423	mov ecx, str_post_cl.length
		424	rep movsb
		425
		426	mov eax, [content_length]
4233	hidnplayr	427	call eax_ascii_dec
4167	hidnplayr	428
		429	mov esi, str_post_ct
		430	mov ecx, str_post_ct.length
		431	rep movsb
		432
		433	mov esi, [content_type]
4221	hidnplayr	434	copy_till_zero
4167	hidnplayr	435
4241	hidnplayr	436	cmp byte[proxyUser], 0
		437	je @f
		438	call append_proxy_auth_header
		439	@@:
		440
		441	mov ax, 0x0a0d
		442	stosw
		443
4221	hidnplayr	444	mov esi, [add_header]
		445	test esi, esi
		446	jz @f
		447	copy_till_zero
		448	@@:
		449
4167	hidnplayr	450	mov esi, str_close
		451	mov ecx, str_close.length
		452	rep movsb
		453
		454	mov byte[edi], 0
		455	DEBUGF 1, "Request:\n%s", [buffer]
		456
4222	hidnplayr	457	; Free unused memory
		458	push edi
		459	invoke mem.free, [pageaddr]
		460	invoke mem.free, [hostname]
		461	pop esi
		462
4167	hidnplayr	463	; Send the request
		464	sub esi, [buffer] ; length
		465	xor edi, edi ; flags
		466	mcall send, [socketnum], [buffer]
		467	test eax, eax
		468	jz .error
		469	DEBUGF 1, "Request has been sent to server.\n"
		470
		471	HTTP_init_buffer [buffer], [socketnum]
4206	hidnplayr	472
4216	hidnplayr	473	popa
		474	mov eax, [buffer]
4158	hidnplayr	475	ret ; return buffer ptr
		476
		477	.error:
		478	DEBUGF 1, "Error!\n"
4216	hidnplayr	479	popa
4158	hidnplayr	480	xor eax, eax ; return 0 = error
		481	ret
		482
		483	endp
		484
		485
		486
		487	;;================================================================================================;;
		488	proc HTTP_process identifier ;////////////////////////////////////////////////////////////////////;;
		489	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	490	;? Receive data from the server, parse headers and put data in receive buffer. ;;
		491	;? To complete a transfer, this procedure must be called over and over again untill it returns 0. ;;
4158	hidnplayr	492	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	493	;> identifier = pointer to buffer containing http_msg struct. ;;
4158	hidnplayr	494	;;------------------------------------------------------------------------------------------------;;
		495	;< eax = -1 (not finished) / 0 finished ;;
		496	;;================================================================================================;;
4690	hidnplayr	497
4158	hidnplayr	498	pusha
		499	mov ebp, [identifier]
4162	hidnplayr	500
4209	hidnplayr	501	; If the connection is closed, return immediately
4205	hidnplayr	502	test [ebp + http_msg.flags], FLAG_CONNECTED
		503	jz .connection_closed
		504
4162	hidnplayr	505	; Receive some data
4158	hidnplayr	506	mcall recv, [ebp + http_msg.socket], [ebp + http_msg.write_ptr], \
		507	[ebp + http_msg.buffer_length], MSG_DONTWAIT
		508	cmp eax, 0xffffffff
		509	je .check_socket
4220	hidnplayr	510
		511	test eax, eax
		512	jz .server_closed
4158	hidnplayr	513	DEBUGF 1, "Received %u bytes\n", eax
		514
4209	hidnplayr	515	; Update timestamp
4206	hidnplayr	516	push eax
4690	hidnplayr	517	mcall 26, 9
4206	hidnplayr	518	mov [ebp + http_msg.timestamp], eax
		519	pop eax
		520
4162	hidnplayr	521	; Update pointers
4158	hidnplayr	522	mov edi, [ebp + http_msg.write_ptr]
		523	add [ebp + http_msg.write_ptr], eax
		524	sub [ebp + http_msg.buffer_length], eax
4162	hidnplayr	525
		526	; If data is chunked, combine chunks into contiguous data.
		527	test [ebp + http_msg.flags], FLAG_CHUNKED
		528	jnz .chunk_loop
		529
4212	hidnplayr	530	; Did we detect the (final) header yet?
4158	hidnplayr	531	test [ebp + http_msg.flags], FLAG_GOT_HEADER
		532	jnz .header_parsed
		533
4690	hidnplayr	534	;--------------------------------------------------------------
		535	;
		536	; Header parsing code begins here
		537	;
		538
4212	hidnplayr	539	; We havent found the (final) header yet, search for it..
		540	.scan_again:
		541	; eax = total number of bytes received so far
		542	mov eax, [ebp + http_msg.write_ptr]
4541	hidnplayr	543	sub eax, http_msg.http_header
4212	hidnplayr	544	sub eax, ebp
		545	sub eax, [ebp + http_msg.header_length]
		546	; edi is ptr to begin of header
4541	hidnplayr	547	lea edi, [ebp + http_msg.http_header]
4212	hidnplayr	548	add edi, [ebp + http_msg.header_length]
		549	; put it in esi for next proc too
		550	mov esi, edi
		551	sub eax, 3
4690	hidnplayr	552	jle .need_more_data_for_header
4212	hidnplayr	553	.scan_loop:
4158	hidnplayr	554	; scan for end of header (empty line)
		555	cmp dword[edi], 0x0a0d0a0d ; end of header
		556	je .end_of_header
4212	hidnplayr	557	cmp word[edi+2], 0x0a0a ; notice the use of offset + 2, to calculate header length correctly :)
4158	hidnplayr	558	je .end_of_header
		559	inc edi
		560	dec eax
4212	hidnplayr	561	jnz .scan_loop
4690	hidnplayr	562	jmp .need_more_data_for_header
4158	hidnplayr	563
		564	.end_of_header:
4541	hidnplayr	565	add edi, 4 - http_msg.http_header
4158	hidnplayr	566	sub edi, ebp
4212	hidnplayr	567	mov [ebp + http_msg.header_length], edi ; If this isnt the final header, we'll use this as an offset to find real header.
4158	hidnplayr	568	DEBUGF 1, "Header length: %u\n", edi
		569
4690	hidnplayr	570	; Ok, we have found the header
4212	hidnplayr	571	cmp dword[esi], 'HTTP'
4690	hidnplayr	572	jne .err_header
4212	hidnplayr	573	cmp dword[esi+4], '/1.0'
4158	hidnplayr	574	je .http_1.0
4212	hidnplayr	575	cmp dword[esi+4], '/1.1'
4690	hidnplayr	576	jne .err_header
4158	hidnplayr	577	or [ebp + http_msg.flags], FLAG_HTTP11
		578	.http_1.0:
4212	hidnplayr	579	cmp byte[esi+8], ' '
4690	hidnplayr	580	jne .err_header
4158	hidnplayr	581
4212	hidnplayr	582	add esi, 9
4158	hidnplayr	583	xor eax, eax
		584	xor ebx, ebx
		585	mov ecx, 3
		586	.statusloop:
		587	lodsb
		588	sub al, '0'
4690	hidnplayr	589	jb .err_header
4158	hidnplayr	590	cmp al, 9
4690	hidnplayr	591	ja .err_header
4158	hidnplayr	592	lea ebx, [ebx + 4*ebx]
		593	shl ebx, 1
		594	add ebx, eax
		595	dec ecx
		596	jnz .statusloop
4212	hidnplayr	597
4690	hidnplayr	598	; Ignore "100 - Continue" lines
4212	hidnplayr	599	cmp ebx, 100
		600	je .scan_again
		601
		602	DEBUGF 1, "Status: %u\n", ebx
4158	hidnplayr	603	mov [ebp + http_msg.status], ebx
4212	hidnplayr	604	or [ebp + http_msg.flags], FLAG_GOT_HEADER
4158	hidnplayr	605
		606	; Now, convert all header names to lowercase.
		607	; This way, it will be much easier to find certain header fields, later on.
4541	hidnplayr	608	lea esi, [ebp + http_msg.http_header]
4158	hidnplayr	609	mov ecx, [ebp + http_msg.header_length]
		610	.need_newline:
		611	inc esi
		612	dec ecx
		613	jz .convert_done
		614	cmp byte[esi], 10
		615	jne .need_newline
4690	hidnplayr	616	; We have found a newline
		617	; A line beginning with space or tabs has no header fields.
4158	hidnplayr	618	inc esi
		619	dec ecx
		620	jz .convert_done
		621	cmp byte[esi], ' '
		622	je .need_newline
		623	cmp byte[esi], 9 ; horizontal tab
		624	je .need_newline
		625	jmp .convert_loop
		626	.next_char:
		627	inc esi
		628	dec ecx
		629	jz .convert_done
		630	.convert_loop:
		631	cmp byte[esi], ':'
		632	je .need_newline
		633	cmp byte[esi], 'A'
		634	jb .next_char
		635	cmp byte[esi], 'Z'
		636	ja .next_char
		637	or byte[esi], 0x20 ; convert to lowercase
		638	jmp .next_char
		639	.convert_done:
		640	mov byte[esi-1], 0
4541	hidnplayr	641	lea esi, [ebp + http_msg.http_header]
4158	hidnplayr	642	DEBUGF 1, "Header names converted to lowercase:\n%s\n", esi
		643
		644	; Check for content-length header field.
4222	hidnplayr	645	stdcall HTTP_find_header_field, ebp, str_cl
4158	hidnplayr	646	test eax, eax
		647	jz .no_content
		648	or [ebp + http_msg.flags], FLAG_CONTENT_LENGTH
		649
		650	xor edx, edx
		651	.cl_loop:
		652	movzx ebx, byte[eax]
		653	inc eax
		654	cmp bl, 10
		655	je .cl_ok
		656	cmp bl, 13
		657	je .cl_ok
		658	cmp bl, ' '
		659	je .cl_ok
		660	sub bl, '0'
4690	hidnplayr	661	jb .err_header
4158	hidnplayr	662	cmp bl, 9
4690	hidnplayr	663	ja .err_header
4158	hidnplayr	664	lea edx, [edx + edx4] ; edx = edx10
		665	shl edx, 1 ;
		666	add edx, ebx
		667	jmp .cl_loop
		668
		669	.cl_ok:
		670	mov [ebp + http_msg.content_length], edx
		671	DEBUGF 1, "Content-length: %u\n", edx
		672
4541	hidnplayr	673	test edx, edx
		674	jz .got_all_data
4158	hidnplayr	675
4541	hidnplayr	676	call alloc_contentbuff
		677	test eax, eax
4690	hidnplayr	678	jz .err_no_ram
4541	hidnplayr	679	xor eax, eax
		680	jmp .header_parsed
4203	hidnplayr	681
4158	hidnplayr	682	.no_content:
		683	DEBUGF 1, "Content-length not found.\n"
		684
		685	; We didnt find 'content-length', maybe server is using chunked transfer encoding?
		686	; Try to find 'transfer-encoding' header.
4222	hidnplayr	687	stdcall HTTP_find_header_field, ebp, str_te
4158	hidnplayr	688	test eax, eax
4541	hidnplayr	689	jnz .ct_hdr_found
4158	hidnplayr	690
4541	hidnplayr	691	.not_chunked:
		692	mov edx, BUFFERSIZE
		693	call alloc_contentbuff
		694	test eax, eax
4690	hidnplayr	695	jz .err_no_ram
4541	hidnplayr	696	xor eax, eax
		697	jmp .header_parsed
		698
		699	.ct_hdr_found:
4158	hidnplayr	700	mov ebx, dword[eax]
4162	hidnplayr	701	or ebx, 0x20202020
4158	hidnplayr	702	cmp ebx, 'chun'
4220	hidnplayr	703	jne .not_chunked
4158	hidnplayr	704	mov ebx, dword[eax+4]
4162	hidnplayr	705	or ebx, 0x00202020
		706	and ebx, 0x00ffffff
4158	hidnplayr	707	cmp ebx, 'ked'
4220	hidnplayr	708	jne .not_chunked
4158	hidnplayr	709
		710	or [ebp + http_msg.flags], FLAG_CHUNKED
		711	DEBUGF 1, "Transfer type is: chunked\n"
		712
4541	hidnplayr	713	mov edx, BUFFERSIZE
		714	call alloc_contentbuff
		715	test eax, eax
4690	hidnplayr	716	jz .err_no_ram
4541	hidnplayr	717
4158	hidnplayr	718	; Set chunk pointer where first chunk should begin.
4541	hidnplayr	719	mov eax, [ebp + http_msg.content_ptr]
4158	hidnplayr	720	mov [ebp + http_msg.chunk_ptr], eax
		721
4690	hidnplayr	722	;--------------------------------------------------------------
		723	;
		724	; Chunk parsing code begins here
		725	;
		726
4162	hidnplayr	727	.chunk_loop:
4158	hidnplayr	728	mov ecx, [ebp + http_msg.write_ptr]
		729	sub ecx, [ebp + http_msg.chunk_ptr]
4690	hidnplayr	730	jbe .need_more_data_chunked
		731
4202	hidnplayr	732	; Chunkline starts here, convert the ASCII hex number into ebx
4158	hidnplayr	733	mov esi, [ebp + http_msg.chunk_ptr]
4690	hidnplayr	734	DEBUGF 1, "Chunkline begins at 0x%x\n", esi
		735
4158	hidnplayr	736	xor ebx, ebx
4690	hidnplayr	737	cmp byte[esi], 0x0d
		738	jne .chunk_hex_loop
		739	dec ecx
		740	jz .need_more_data_chunked
		741	inc esi
		742	cmp byte[esi], 0x0a
		743	jne .chunk_hex_loop
		744	dec ecx
		745	jz .need_more_data_chunked
		746	inc esi
		747	.chunk_hex_loop:
4158	hidnplayr	748	lodsb
		749	sub al, '0'
4690	hidnplayr	750	jb .chunk_hex_end
4158	hidnplayr	751	cmp al, 9
		752	jbe .chunk_hex
4162	hidnplayr	753	sub al, 'A' - '0' - 10
4690	hidnplayr	754	jb .chunk_hex_end
4162	hidnplayr	755	cmp al, 15
4158	hidnplayr	756	jbe .chunk_hex
		757	sub al, 'a' - 'A'
4162	hidnplayr	758	cmp al, 15
4690	hidnplayr	759	ja .chunk_hex_end
4158	hidnplayr	760	.chunk_hex:
		761	shl ebx, 4
		762	add bl, al
4690	hidnplayr	763	dec ecx
		764	jnz .chunk_hex_loop
		765	jmp .need_more_data_chunked
		766	.chunk_hex_end:
		767	; Chunkline ends with a CR LF or simply LF
4541	hidnplayr	768	dec esi
4202	hidnplayr	769	.end_of_chunkline?:
4541	hidnplayr	770	lodsb
4690	hidnplayr	771	cmp al, 10 ; chunkline must always end with LF
4158	hidnplayr	772	je .end_of_chunkline
4690	hidnplayr	773	dec ecx
		774	jnz .end_of_chunkline?
		775	xor eax, eax
		776	jmp .need_more_data_chunked ; chunkline is incomplete, request more data
4158	hidnplayr	777	.end_of_chunkline:
4690	hidnplayr	778	DEBUGF 1, "Chunk of 0x%x bytes\n", ebx
4541	hidnplayr	779	; If chunk size is 0, all chunks have been received.
		780	test ebx, ebx
		781	jz .got_all_data_chunked
4690	hidnplayr	782	; Calculate how many data bytes we have received already
4541	hidnplayr	783	mov ecx, [ebp + http_msg.write_ptr]
4690	hidnplayr	784	sub ecx, [ebp + http_msg.chunk_ptr] ; ecx is now number of received data bytes
		785	; Update content_received counter
		786	add [ebp + http_msg.content_received], ecx
		787	; Calculate new write ptr
		788	mov edx, esi
		789	sub edx, [ebp + http_msg.chunk_ptr] ; edx is now length of chunkline
		790	sub [ebp + http_msg.write_ptr], edx
4162	hidnplayr	791	; Realloc buffer, make it 'chunksize' bigger.
4690	hidnplayr	792	lea edx, [ebx + BUFFERSIZE]
		793	mov [ebp + http_msg.buffer_length], edx ; remaining space in new buffer
		794	add edx, [ebp + http_msg.write_ptr]
		795	sub edx, [ebp + http_msg.content_ptr]
		796	DEBUGF 1, "Resizing buffer 0x%x, it will now be %u bytes\n", [ebp + http_msg.content_ptr], edx
		797	invoke mem.realloc, [ebp + http_msg.content_ptr], edx
4541	hidnplayr	798	DEBUGF 1, "New buffer = 0x%x\n", eax
4162	hidnplayr	799	or eax, eax
4690	hidnplayr	800	jz .err_no_ram
		801	call recalculate_pointers ; Because it's possible that buffer begins on another address now
		802	add esi, eax ; recalculate esi too!
		803	; Remove chunk header (aka chunkline) from the buffer by shifting all received data after chunkt_ptr to the left
4541	hidnplayr	804	mov edi, [ebp + http_msg.chunk_ptr]
4690	hidnplayr	805	rep movsb
		806	; Update chunk ptr to point to next chunk
4541	hidnplayr	807	add [ebp + http_msg.chunk_ptr], ebx
4690	hidnplayr	808	; Set number of received bytes to 0, we already updated content_received
4541	hidnplayr	809	xor eax, eax
4162	hidnplayr	810	jmp .chunk_loop
4158	hidnplayr	811
4690	hidnplayr	812	;--------------------------------------------------------------
		813	;
		814	; end of proc code begins here
		815	;
		816
4162	hidnplayr	817	.header_parsed:
4690	hidnplayr	818	; Header was already parsed and connection isnt chunked.
		819	; Update content_received
4168	hidnplayr	820	add [ebp + http_msg.content_received], eax
4690	hidnplayr	821	; If we received content-length parameter, check if we received all the data
4220	hidnplayr	822	test [ebp + http_msg.flags], FLAG_CONTENT_LENGTH
4690	hidnplayr	823	jz @f
4217	hidnplayr	824	mov eax, [ebp + http_msg.content_received]
		825	cmp eax, [ebp + http_msg.content_length]
4168	hidnplayr	826	jae .got_all_data
4690	hidnplayr	827	@@:
		828	cmp [ebp + http_msg.buffer_length], 0
		829	je .buffer_full
		830	; Need more data
		831	popa
		832	xor eax, eax
		833	dec eax
		834	ret
4212	hidnplayr	835
4690	hidnplayr	836	.buffer_full:
		837	; Lets make it bigger..
4220	hidnplayr	838	mov eax, [ebp + http_msg.write_ptr]
		839	add eax, BUFFERSIZE
4541	hidnplayr	840	sub eax, [ebp + http_msg.content_ptr]
		841	invoke mem.realloc, [ebp + http_msg.content_ptr], eax
4220	hidnplayr	842	or eax, eax
4690	hidnplayr	843	jz .err_no_ram
4541	hidnplayr	844	call recalculate_pointers
4220	hidnplayr	845	mov [ebp + http_msg.buffer_length], BUFFERSIZE
4690	hidnplayr	846	; Need more data
		847	popa
		848	xor eax, eax
		849	dec eax
		850	ret
4220	hidnplayr	851
4690	hidnplayr	852	.need_more_data_for_header:
		853	cmp [ebp + http_msg.buffer_length], 0
		854	je .err_header ; It's just too damn long!
		855	; Need more data
4162	hidnplayr	856	popa
		857	xor eax, eax
		858	dec eax
		859	ret
4158	hidnplayr	860
4162	hidnplayr	861	.need_more_data_chunked:
4690	hidnplayr	862	; We only got a partial chunk, or need more chunks, update content_received and request more data
4168	hidnplayr	863	add [ebp + http_msg.content_received], eax
4158	hidnplayr	864	popa
		865	xor eax, eax
		866	dec eax
		867	ret
		868
4162	hidnplayr	869	.got_all_data_chunked:
4690	hidnplayr	870	; Woohoo, we got all the chunked data, calculate total number of bytes received.
4162	hidnplayr	871	mov eax, [ebp + http_msg.chunk_ptr]
4541	hidnplayr	872	sub eax, [ebp + http_msg.content_ptr]
4162	hidnplayr	873	mov [ebp + http_msg.content_length], eax
4168	hidnplayr	874	mov [ebp + http_msg.content_received], eax
4158	hidnplayr	875	.got_all_data:
4217	hidnplayr	876	DEBUGF 1, "We got all the data! (%u bytes)\n", [ebp + http_msg.content_received]
4205	hidnplayr	877	or [ebp + http_msg.flags], FLAG_GOT_ALL_DATA
		878	and [ebp + http_msg.flags], not FLAG_CONNECTED
4158	hidnplayr	879	mcall close, [ebp + http_msg.socket]
		880	popa
		881	xor eax, eax
		882	ret
		883
4690	hidnplayr	884	;--------------------------------------------------------------
		885	;
		886	; error handeling code begins here
		887	;
		888
4158	hidnplayr	889	.check_socket:
		890	cmp ebx, EWOULDBLOCK
4690	hidnplayr	891	jne .err_socket
		892	mcall 26, 9
		893	sub eax, [ebp + http_msg.timestamp]
		894	cmp eax, TIMEOUT
		895	ja .err_timeout
		896	; Need more data
		897	popa
		898	xor eax, eax
		899	dec eax
		900	ret
4158	hidnplayr	901
4220	hidnplayr	902	.server_closed:
		903	DEBUGF 1, "server closed connection, transfer complete?\n"
		904	test [ebp + http_msg.flags], FLAG_GOT_HEADER
4690	hidnplayr	905	jz .err_server_closed
4220	hidnplayr	906	test [ebp + http_msg.flags], FLAG_CONTENT_LENGTH
		907	jz .got_all_data
4690	hidnplayr	908	.err_server_closed:
4220	hidnplayr	909	pop eax
		910	DEBUGF 1, "ERROR: server closed connection unexpectedly\n"
		911	or [ebp + http_msg.flags], FLAG_TRANSFER_FAILED
4690	hidnplayr	912	jmp .abort
4220	hidnplayr	913
4690	hidnplayr	914	.err_header:
4203	hidnplayr	915	pop eax
4158	hidnplayr	916	DEBUGF 1, "ERROR: invalid header\n"
		917	or [ebp + http_msg.flags], FLAG_INVALID_HEADER
4690	hidnplayr	918	jmp .abort
4158	hidnplayr	919
4690	hidnplayr	920	.err_no_ram:
4158	hidnplayr	921	DEBUGF 1, "ERROR: out of RAM\n"
		922	or [ebp + http_msg.flags], FLAG_NO_RAM
4690	hidnplayr	923	jmp .abort
4206	hidnplayr	924
4690	hidnplayr	925	.err_timeout:
		926	DEBUGF 1, "ERROR: timeout\n"
		927	or [ebp + http_msg.flags], FLAG_TIMEOUT_ERROR
		928	jmp .abort
		929
		930	.err_socket:
4206	hidnplayr	931	DEBUGF 1, "ERROR: socket error %u\n", ebx
		932	or [ebp + http_msg.flags], FLAG_SOCKET_ERROR
4690	hidnplayr	933	.abort:
4205	hidnplayr	934	and [ebp + http_msg.flags], not FLAG_CONNECTED
		935	mcall close, [ebp + http_msg.socket]
4206	hidnplayr	936	.connection_closed:
4158	hidnplayr	937	popa
		938	xor eax, eax
		939	ret
		940
		941	endp
		942
		943
4541	hidnplayr	944	alloc_contentbuff:
4158	hidnplayr	945
4541	hidnplayr	946	; Allocate content buffer
		947	invoke mem.alloc, edx
		948	or eax, eax
		949	jz .no_ram
4205	hidnplayr	950
4541	hidnplayr	951	DEBUGF 1, "Content buffer allocated: 0x%x\n", eax
		952
		953	; Copy already received content into content buffer
		954	mov edi, eax
		955	lea esi, [ebp + http_msg.http_header]
		956	add esi, [ebp + http_msg.header_length]
		957	mov ecx, [ebp + http_msg.write_ptr]
		958	sub ecx, esi
		959	mov ebx, ecx
		960	rep movsb
		961
		962	; Update pointers to point to new buffer
		963	mov [ebp + http_msg.content_ptr], eax
		964	mov [ebp + http_msg.content_received], ebx
		965	sub edx, ebx
		966	mov [ebp + http_msg.buffer_length], edx
		967	add eax, ebx
		968	mov [ebp + http_msg.write_ptr], eax
		969
		970	; Shrink header buffer
		971	mov eax, http_msg.http_header
		972	add eax, [ebp + http_msg.header_length]
		973	invoke mem.realloc, ebp, eax
		974	or eax, eax
		975	.no_ram:
		976
		977	ret
		978
		979
		980
		981	recalculate_pointers:
		982
		983	sub eax, [ebp + http_msg.content_ptr]
		984	jz .done
		985	add [ebp + http_msg.content_ptr], eax
		986	add [ebp + http_msg.write_ptr], eax
		987	add [ebp + http_msg.chunk_ptr], eax
		988
		989	.done:
		990	ret
		991
		992
		993
		994
4158	hidnplayr	995	;;================================================================================================;;
4205	hidnplayr	996	proc HTTP_free identifier ;///////////////////////////////////////////////////////////////////////;;
		997	;;------------------------------------------------------------------------------------------------;;
		998	;? Free the http_msg structure ;;
		999	;;------------------------------------------------------------------------------------------------;;
		1000	;> identifier = pointer to buffer containing http_msg struct. ;;
		1001	;;------------------------------------------------------------------------------------------------;;
		1002	;< none ;;
		1003	;;================================================================================================;;
4541	hidnplayr	1004	DEBUGF 1, "HTTP_free: 0x%x\n", [identifier]
4205	hidnplayr	1005	pusha
		1006	mov ebp, [identifier]
		1007
		1008	test [ebp + http_msg.flags], FLAG_CONNECTED
		1009	jz .not_connected
		1010
		1011	and [ebp + http_msg.flags], not FLAG_CONNECTED
		1012	mcall close, [ebp + http_msg.socket]
		1013
		1014	.not_connected:
		1015	invoke mem.free, ebp
		1016
		1017	popa
		1018	ret
		1019
		1020	endp
		1021
		1022
		1023
		1024	;;================================================================================================;;
		1025	proc HTTP_stop identifier ;///////////////////////////////////////////////////////////////////////;;
		1026	;;------------------------------------------------------------------------------------------------;;
		1027	;? Stops the open connection ;;
		1028	;;------------------------------------------------------------------------------------------------;;
		1029	;> identifier = pointer to buffer containing http_msg struct. ;;
		1030	;;------------------------------------------------------------------------------------------------;;
		1031	;< none ;;
		1032	;;================================================================================================;;
		1033
		1034	pusha
		1035	mov ebp, [identifier]
		1036
		1037	and [ebp + http_msg.flags], not FLAG_CONNECTED
		1038	mcall close, [ebp + http_msg.socket]
		1039
		1040	popa
		1041	ret
		1042
		1043	endp
		1044
		1045
		1046
		1047	;;================================================================================================;;
4222	hidnplayr	1048	proc HTTP_find_header_field identifier, headername ;//////////////////////////////////////////////;;
4158	hidnplayr	1049	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1050	;? Find a header field in the received HTTP header ;;
4158	hidnplayr	1051	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1052	;> identifier = ptr to http_msg struct ;;
		1053	;> headername = ptr to ASCIIZ string containg field you want to find (must be in lowercase) ;;
4158	hidnplayr	1054	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1055	;< eax = 0 (error) / ptr to content of the HTTP header field ;;
4158	hidnplayr	1056	;;================================================================================================;;
		1057	push ebx ecx edx esi edi
		1058
		1059	DEBUGF 1, "Find header field: %s\n", [headername]
		1060
		1061	mov ebx, [identifier]
4202	hidnplayr	1062	test [ebx + http_msg.flags], FLAG_GOT_HEADER
		1063	jz .fail
		1064
4541	hidnplayr	1065	lea edx, [ebx + http_msg.http_header]
4158	hidnplayr	1066	mov ecx, edx
		1067	add ecx, [ebx + http_msg.header_length]
		1068
		1069	.restart:
		1070	mov esi, [headername]
		1071	mov edi, edx
		1072	.loop:
		1073	cmp edi, ecx
		1074	jae .fail
		1075	lodsb
		1076	scasb
		1077	je .loop
		1078	test al, al
		1079	jz .done?
		1080	.next:
		1081	inc edx
		1082	jmp .restart
		1083
		1084	.not_done:
		1085	inc edi
		1086	.done?:
		1087	cmp byte[edi-1], ':'
		1088	je .almost_done
		1089	cmp byte[edi-1], ' '
		1090	je .not_done
		1091	cmp byte[edi-1], 9 ; tab
		1092	je .not_done
		1093
		1094	jmp .next
		1095
		1096	.almost_done: ; FIXME: buffer overflow?
		1097	dec edi
		1098	DEBUGF 1, "Found header field\n"
		1099	.spaceloop:
		1100	inc edi
		1101	cmp byte[edi], ' '
		1102	je .spaceloop
		1103	cmp byte[edi], 9 ; tab
		1104	je .spaceloop
		1105
		1106	mov eax, edi
		1107	pop edi esi edx ecx ebx
		1108	ret
		1109
		1110	.fail:
		1111	pop edi esi edx ecx ebx
		1112	xor eax, eax
		1113	ret
		1114
		1115	endp
		1116
		1117
		1118
4209	hidnplayr	1119	;;================================================================================================;;
		1120	proc URI_escape URI ;/////////////////////////////////////////////////////////////////////////////;;
		1121	;;------------------------------------------------------------------------------------------------;;
		1122	;? ;;
		1123	;;------------------------------------------------------------------------------------------------;;
		1124	;> URI = ptr to ASCIIZ URI ;;
		1125	;;------------------------------------------------------------------------------------------------;;
		1126	;< eax = 0 (error) / ptr to ASCIIZ URI ;;
		1127	;;================================================================================================;;
4202	hidnplayr	1128
4209	hidnplayr	1129	pusha
4205	hidnplayr	1130
4209	hidnplayr	1131	invoke mem.alloc, URLMAXLEN
		1132	test eax, eax
		1133	jz .error
		1134	mov [esp + 7 * 4], eax ; return ptr in eax
		1135	mov esi, [URI]
		1136	mov edi, eax
		1137	xor ebx, ebx
		1138	xor ecx, ecx
		1139	.loop:
		1140	lodsb
		1141	test al, al
		1142	jz .done
		1143
		1144	mov cl, al
		1145	and cl, 0x1f
		1146	mov bl, al
		1147	shr bl, 5
		1148	bt dword[bits_must_escape + ebx], ecx
		1149	jc .escape
		1150
		1151	stosb
		1152	jmp .loop
		1153
		1154	.escape:
		1155	mov al, '%'
		1156	stosb
		1157	mov bl, byte[esi-1]
		1158	shr bl, 4
		1159	mov al, byte[str_hex + ebx]
		1160	stosb
		1161	mov bl, byte[esi-1]
		1162	and bl, 0x0f
		1163	mov al, byte[str_hex + ebx]
		1164	stosb
		1165	jmp .loop
		1166
		1167
		1168	.done:
		1169	stosb
		1170
		1171	popa
		1172	ret
		1173
		1174	.error:
		1175	popa
		1176	xor eax, eax
		1177	ret
		1178
		1179	endp
		1180
		1181
		1182
4167	hidnplayr	1183	;;================================================================================================;;
4209	hidnplayr	1184	proc URI_unescape URI ;///////////////////////////////////////////////////////////////////////////;;
		1185	;;------------------------------------------------------------------------------------------------;;
		1186	;? ;;
		1187	;;------------------------------------------------------------------------------------------------;;
		1188	;> URI = ptr to ASCIIZ URI ;;
		1189	;;------------------------------------------------------------------------------------------------;;
		1190	;< eax = 0 (error) / ptr to ASCIIZ URI ;;
		1191	;;================================================================================================;;
		1192
		1193	pusha
		1194
		1195	invoke mem.alloc, URLMAXLEN
		1196	test eax, eax
		1197	jz .error
		1198	mov [esp + 7 * 4], eax ; return ptr in eax
		1199	mov esi, [URI]
		1200	mov edi, eax
		1201	.loop:
		1202	lodsb
		1203	test al, al
		1204	jz .done
		1205
		1206	cmp al, '%'
		1207	je .unescape
		1208
		1209	stosb
		1210	jmp .loop
		1211
		1212	.unescape:
		1213	xor ebx, ebx
		1214	xor ecx, ecx
		1215	.unescape_nibble:
		1216	lodsb
		1217	sub al, '0'
		1218	jb .fail
		1219	cmp al, 9
		1220	jbe .nibble_ok
		1221	sub al, 'A' - '0' - 10
		1222	jb .fail
		1223	cmp al, 15
		1224	jbe .nibble_ok
		1225	sub al, 'a' - 'A'
		1226	cmp al, 15
		1227	ja .fail
		1228	.nibble_ok:
		1229	shl bl, 8
		1230	or bl, al
		1231	dec ecx
		1232	jc .unescape_nibble
		1233	mov al, bl
		1234	stosb
		1235	jmp .loop
		1236
		1237	.fail:
		1238	DEBUGF 1, "ERROR: invalid URI!\n"
		1239	jmp .loop
		1240
		1241	.done:
		1242	stosb
		1243
		1244	popa
		1245	ret
		1246
		1247	.error:
		1248	popa
		1249	xor eax, eax
		1250	ret
		1251
		1252	endp
		1253
		1254
		1255
		1256
		1257
		1258	;;================================================================================================;;
4202	hidnplayr	1259	;;////////////////////////////////////////////////////////////////////////////////////////////////;;
		1260	;;================================================================================================;;
		1261	;! Internal procedures section ;;
4220	hidnplayr	1262	;; ;;
		1263	;; NOTICE: These procedures do not follow stdcall conventions and thus may destroy any register. ;;
4202	hidnplayr	1264	;;================================================================================================;;
		1265	;;////////////////////////////////////////////////////////////////////////////////////////////////;;
		1266	;;================================================================================================;;
		1267
		1268
		1269
		1270
		1271	;;================================================================================================;;
4167	hidnplayr	1272	proc open_connection hostname, port ;/////////////////////////////////////////////////////////////;;
		1273	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1274	;? Connects to a HTTP server ;;
4167	hidnplayr	1275	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1276	;> hostname = ptr to ASCIIZ hostname ;;
		1277	;> port = port (x86 byte order) ;;
4167	hidnplayr	1278	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1279	;< eax = 0 (error) / socketnum ;;
4167	hidnplayr	1280	;;================================================================================================;;
4158	hidnplayr	1281
4167	hidnplayr	1282	locals
		1283	sockaddr dd ?
		1284	socketnum dd ?
		1285	endl
		1286
4233	hidnplayr	1287	cmp [proxyAddr], 0
		1288	je .no_proxy
		1289
		1290	mov [hostname], proxyAddr
		1291
		1292	push [proxyPort]
		1293	pop [port]
		1294	.no_proxy:
		1295
4167	hidnplayr	1296	; Resolve the hostname
		1297	DEBUGF 1, "Resolving hostname\n"
		1298	push esp ; reserve stack place
		1299	push esp ; fourth parameter
		1300	push 0 ; third parameter
		1301	push 0 ; second parameter
		1302	push [hostname]
		1303	call [getaddrinfo]
		1304	pop esi
		1305	test eax, eax
		1306	jnz .error1
		1307
		1308	; getaddrinfo returns addrinfo struct, make the pointer to sockaddr struct
		1309	mov esi, [esi + addrinfo.ai_addr]
		1310	mov [sockaddr], esi
		1311	mov eax, [esi + sockaddr_in.sin_addr]
		1312	test eax, eax
		1313	jz .error2
		1314
		1315	DEBUGF 1, "Server ip=%u.%u.%u.%u\n", \
		1316	[esi + sockaddr_in.sin_addr]:1, [esi + sockaddr_in.sin_addr + 1]:1, \
		1317	[esi + sockaddr_in.sin_addr + 2]:1, [esi + sockaddr_in.sin_addr + 3]:1
		1318
		1319	mov [esi + sockaddr_in.sin_family], AF_INET4
		1320	mov eax, [port]
		1321	xchg al, ah
		1322	mov [esi + sockaddr_in.sin_port], ax
		1323
		1324	; Connect to the server.
		1325	mcall socket, AF_INET4, SOCK_STREAM, 0
		1326	test eax, eax
		1327	jz .error2
		1328	mov [socketnum], eax
		1329	DEBUGF 1, "Socket: 0x%x\n", eax
		1330
		1331	mcall connect, [socketnum], [sockaddr], 18
		1332	test eax, eax
		1333	jnz .error2
		1334	DEBUGF 1, "Socket is now connected.\n"
		1335
		1336	; free allocated memory
		1337	push [sockaddr]
		1338	call [freeaddrinfo]
		1339
		1340	mov eax, [socketnum]
		1341	ret
		1342
		1343	.error2:
		1344
		1345	; free allocated memory
		1346	push [sockaddr]
		1347	call [freeaddrinfo]
		1348
		1349	.error1:
		1350	xor eax, eax
		1351	ret
		1352
		1353	endp
		1354
		1355
4158	hidnplayr	1356	;;================================================================================================;;
		1357	proc parse_url URL ;//////////////////////////////////////////////////////////////////////////////;;
		1358	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1359	;? Split a given URL into hostname and pageaddr ;;
4158	hidnplayr	1360	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1361	;> URL = ptr to ASCIIZ URL ;;
4158	hidnplayr	1362	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1363	;< eax = 0 (error) / ptr to ASCIIZ hostname ;;
		1364	;< ebx = ptr to ASCIIZ pageaddr ;;
4233	hidnplayr	1365	;< ecx = port number ;;
4158	hidnplayr	1366	;;================================================================================================;;
		1367
		1368	locals
		1369	urlsize dd ?
		1370	hostname dd ?
		1371	pageaddr dd ?
4233	hidnplayr	1372	port dd ?
4158	hidnplayr	1373	endl
		1374
4161	hidnplayr	1375	DEBUGF 1, "parsing URL: %s\n", [URL]
4158	hidnplayr	1376
		1377	; remove any leading protocol text
		1378	mov esi, [URL]
		1379	mov ecx, URLMAXLEN
		1380	mov ax, '//'
		1381	.loop1:
		1382	cmp byte[esi], 0 ; end of URL?
		1383	je .url_ok ; yep, so not found
		1384	cmp [esi], ax
		1385	je .skip_proto
		1386	inc esi
		1387	dec ecx
		1388	jnz .loop1
4233	hidnplayr	1389	jmp .invalid
4158	hidnplayr	1390
		1391	.skip_proto:
		1392	inc esi ; skip the two '/'
		1393	inc esi
		1394	mov [URL], esi ; update pointer so it skips protocol
		1395	jmp .loop1 ; we still need to find the length of the URL
		1396
		1397	.url_ok:
		1398	sub esi, [URL] ; calculate total length of URL
		1399	mov [urlsize], esi
		1400
		1401
		1402	; now look for page delimiter - it's a '/' character
		1403	mov ecx, esi ; URL length
		1404	mov edi, [URL]
		1405	mov al, '/'
		1406	repne scasb
4161	hidnplayr	1407	jne @f
4158	hidnplayr	1408	dec edi ; return one char, '/' must be part of the pageaddr
		1409	inc ecx ;
4161	hidnplayr	1410	@@:
4158	hidnplayr	1411	push ecx edi ; remember the pointer and length of pageaddr
		1412
4222	hidnplayr	1413
4233	hidnplayr	1414	; Create new buffer and put hostname in it.
4158	hidnplayr	1415	mov ecx, edi
		1416	sub ecx, [URL]
		1417	inc ecx ; we will add a 0 byte at the end
		1418	invoke mem.alloc, ecx
		1419	or eax, eax
		1420	jz .no_mem
		1421
		1422	mov [hostname], eax ; copy hostname to buffer
		1423	mov edi, eax
		1424	mov esi, [URL]
		1425	dec ecx
		1426	rep movsb
		1427	xor al, al
		1428	stosb
		1429
4233	hidnplayr	1430	; Check if user provided a port, and convert it if so.
		1431	mov esi, [hostname]
		1432	mov [port], 80 ; default port if user didnt provide one
		1433	.portloop:
		1434	lodsb
		1435	test al, al
		1436	jz .no_port
		1437	cmp al, ':'
		1438	jne .portloop
		1439
		1440	push esi
		1441	call ascii_dec_ebx
		1442	pop edi
		1443	cmp byte[esi-1], 0
		1444	jne .invalid
		1445	cmp [proxyAddr], 0 ; remove port number from hostname
		1446	jne @f ; unless when we are using proxy
		1447	mov byte[edi-1], 0
		1448	@@:
		1449	test ebx, ebx
		1450	je .invalid
		1451	cmp ebx, 0xffff
		1452	ja .invalid
		1453	mov [port], ebx
		1454	.no_port:
		1455
		1456
		1457	; Did user provide a pageaddr?
4161	hidnplayr	1458	mov [pageaddr], str_slash ; assume there is no pageaddr
4158	hidnplayr	1459	pop esi ecx
		1460	test ecx, ecx
		1461	jz .no_page
4233	hidnplayr	1462
		1463	; Create new buffer and put pageaddr into it.
4158	hidnplayr	1464	inc ecx ; we will add a 0 byte at the end
		1465	invoke mem.alloc, ecx
		1466	or eax, eax
		1467	jz .no_mem
		1468
		1469	mov [pageaddr], eax ; copy pageaddr to buffer
		1470	mov edi, eax
		1471	dec ecx
		1472	rep movsb
		1473	xor al, al
		1474	stosb
4233	hidnplayr	1475
4158	hidnplayr	1476	.no_page:
		1477	mov eax, [hostname]
		1478	mov ebx, [pageaddr]
4233	hidnplayr	1479	mov ecx, [port]
4158	hidnplayr	1480
		1481	DEBUGF 1, "hostname: %s\n", eax
		1482	DEBUGF 1, "pageaddr: %s\n", ebx
4221	hidnplayr	1483	DEBUGF 1, "port: %u\n", ecx
4158	hidnplayr	1484
		1485	ret
		1486
		1487	.no_mem:
4233	hidnplayr	1488	DEBUGF 1, "Out of memory!\n"
4158	hidnplayr	1489	xor eax, eax
		1490	ret
		1491
4233	hidnplayr	1492	.invalid:
		1493	DEBUGF 1, "Invalid URL!\n"
		1494	xor eax, eax
		1495	ret
		1496
4158	hidnplayr	1497	endp
		1498
		1499
4233	hidnplayr	1500
		1501
		1502
4202	hidnplayr	1503	;;================================================================================================;;
4233	hidnplayr	1504	proc append_proxy_auth_header ;///////////////////////////////////////////////////////////////////;;
4202	hidnplayr	1505	;;------------------------------------------------------------------------------------------------;;
4233	hidnplayr	1506	;? Appends the proxy authentication header ;;
		1507	;;------------------------------------------------------------------------------------------------;;
		1508	;> / ;;
		1509	;;------------------------------------------------------------------------------------------------;;
		1510	;< / ;;
		1511	;;================================================================================================;;
		1512	mov esi, str_proxy_auth
		1513	mov ecx, str_proxy_auth.length
		1514	rep movsb
		1515	; base64-encode string :
		1516	mov esi, proxyUser
		1517
		1518	apah000:
		1519	lodsb
		1520	test al, al
		1521	jz apah001
		1522	call encode_base64_byte
		1523	jmp apah000
		1524
		1525	apah001:
		1526	mov al, ':'
		1527	call encode_base64_byte
		1528	mov esi, proxyPassword
		1529
		1530	apah002:
		1531	lodsb
		1532	test al, al
		1533	jz apah003
		1534	call encode_base64_byte
		1535	jmp apah002
		1536
		1537	apah003:
		1538	call encode_base64_final
		1539	ret
		1540
		1541	encode_base64_byte:
		1542	inc ecx
		1543	shl edx, 8
		1544	mov dl, al
		1545	cmp ecx, 3
		1546	je ebb001
		1547	ret
		1548
		1549	ebb001:
		1550	shl edx, 8
		1551	inc ecx
		1552
		1553	ebb002:
		1554	rol edx, 6
		1555	xor eax, eax
		1556	xchg al, dl
		1557	mov al, [base64_table+eax]
		1558	stosb
		1559	loop ebb002
		1560	ret
		1561
		1562	encode_base64_final:
		1563	mov al, 0
		1564	test ecx, ecx
		1565	jz ebf000
		1566	call encode_base64_byte
		1567	test ecx, ecx
		1568	jz ebf001
		1569	call encode_base64_byte
		1570	mov byte [edi-2], '='
		1571
		1572	ebf001:
		1573	mov byte [edi-1], '='
		1574
		1575	ebf000:
		1576	ret
		1577
		1578	endp
		1579
		1580
		1581	;;================================================================================================;;
		1582	proc eax_ascii_dec ;//////////////////////////////////////////////////////////////////////////////;;
		1583	;;------------------------------------------------------------------------------------------------;;
4202	hidnplayr	1584	;? Convert eax to ASCII decimal number ;;
		1585	;;------------------------------------------------------------------------------------------------;;
		1586	;> eax = number ;;
		1587	;> edi = ptr where to write ASCII decimal number ;;
		1588	;;------------------------------------------------------------------------------------------------;;
		1589	;< / ;;
		1590	;;================================================================================================;;
4158	hidnplayr	1591
4168	hidnplayr	1592	push -'0'
4167	hidnplayr	1593	mov ecx, 10
		1594	.loop:
		1595	xor edx, edx
		1596	div ecx
		1597	add dl, '0'
4168	hidnplayr	1598	push edx
4167	hidnplayr	1599	test eax, eax
		1600	jnz .loop
4158	hidnplayr	1601
4168	hidnplayr	1602	.loop2:
		1603	pop eax
		1604	add al, '0'
		1605	jz .done
		1606	stosb
		1607	jmp .loop2
		1608	.done:
		1609
4167	hidnplayr	1610	ret
4158	hidnplayr	1611
4202	hidnplayr	1612	endp
4167	hidnplayr	1613
4202	hidnplayr	1614
4158	hidnplayr	1615	;;================================================================================================;;
4233	hidnplayr	1616	proc ascii_dec_ebx ;//////////////////////////////////////////////////////////////////////////////;;
		1617	;;------------------------------------------------------------------------------------------------;;
		1618	;? Convert ASCII decimal number to ebx ;;
		1619	;;------------------------------------------------------------------------------------------------;;
		1620	;> esi = ptr where to read ASCII decimal number ;;
		1621	;;------------------------------------------------------------------------------------------------;;
		1622	;> ebx = number ;;
		1623	;;================================================================================================;;
		1624
		1625	xor eax, eax
		1626	xor ebx, ebx
		1627	.loop:
		1628	lodsb
		1629	sub al, '0'
		1630	jb .done
		1631	cmp al, 9
		1632	ja .done
		1633	lea ebx, [ebx + 4*ebx]
		1634	shl ebx, 1
		1635	add ebx, eax
		1636	jmp .loop
		1637	.done:
		1638
		1639	ret
		1640
		1641	endp
		1642
		1643
		1644	;;================================================================================================;;
4158	hidnplayr	1645	;;////////////////////////////////////////////////////////////////////////////////////////////////;;
		1646	;;================================================================================================;;
		1647	;! Imported functions section ;;
		1648	;;================================================================================================;;
		1649	;;////////////////////////////////////////////////////////////////////////////////////////////////;;
		1650	;;================================================================================================;;
		1651
		1652
		1653	align 16
		1654	@IMPORT:
		1655
		1656	library \
		1657	libini, 'libini.obj', \
		1658	network, 'network.obj'
		1659
		1660	import libini, \
		1661	ini.get_str, 'ini_get_str', \
		1662	ini.get_int, 'ini_get_int'
		1663
		1664	import network,\
		1665	getaddrinfo, 'getaddrinfo',\
		1666	freeaddrinfo, 'freeaddrinfo',\
		1667	inet_ntoa, 'inet_ntoa'
		1668
		1669	;;===========================================================================;;
		1670	;;///////////////////////////////////////////////////////////////////////////;;
		1671	;;===========================================================================;;
		1672	;! Exported functions section ;;
		1673	;;===========================================================================;;
		1674	;;///////////////////////////////////////////////////////////////////////////;;
		1675	;;===========================================================================;;
		1676
		1677
		1678	align 4
		1679	@EXPORT:
		1680	export \
		1681	lib_init , 'lib_init' , \
		1682	0x00010001 , 'version' , \
		1683	HTTP_get , 'get' , \
4167	hidnplayr	1684	HTTP_head , 'head' , \
		1685	HTTP_post , 'post' , \
4222	hidnplayr	1686	HTTP_find_header_field , 'find_header_field' , \
4205	hidnplayr	1687	HTTP_process , 'process' , \
		1688	HTTP_free , 'free' , \
4209	hidnplayr	1689	HTTP_stop , 'stop' , \
		1690	URI_escape , 'escape' , \
		1691	URI_unescape , 'unescape'
4158	hidnplayr	1692
		1693	; HTTP_put , 'put' , \
		1694	; HTTP_delete , 'delete' , \
		1695	; HTTP_trace , 'trace' , \
		1696	; HTTP_connect , 'connect' , \
		1697
		1698
		1699
		1700	section '.data' data readable writable align 16
		1701
		1702	inifile db '/sys/settings/network.ini', 0
		1703
		1704	sec_proxy:
		1705	key_proxy db 'proxy', 0
		1706	key_proxyport db 'port', 0
		1707	key_user db 'user', 0
		1708	key_password db 'password', 0
		1709
		1710	str_http11 db ' HTTP/1.1', 13, 10, 'Host: '
		1711	.length = $ - str_http11
4167	hidnplayr	1712	str_post_cl db 13, 10, 'Content-Length: '
		1713	.length = $ - str_post_cl
		1714	str_post_ct db 13, 10, 'Content-Type: '
		1715	.length = $ - str_post_ct
4158	hidnplayr	1716	str_proxy_auth db 13, 10, 'Proxy-Authorization: Basic '
		1717	.length = $ - str_proxy_auth
4241	hidnplayr	1718	str_close db 'User-Agent: KolibriOS libHTTP/1.0', 13, 10, 'Connection: Close', 13, 10, 13, 10
		1719	.length = $ - str_close
4158	hidnplayr	1720
4233	hidnplayr	1721	str_http db 'http://', 0
		1722
4158	hidnplayr	1723	base64_table db 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz'
		1724	db '0123456789+/'
		1725
		1726	str_cl db 'content-length', 0
4161	hidnplayr	1727	str_slash db '/', 0
4158	hidnplayr	1728	str_te db 'transfer-encoding', 0
4167	hidnplayr	1729	str_get db 'GET ', 0
		1730	str_head db 'HEAD ', 0
		1731	str_post db 'POST ', 0
4158	hidnplayr	1732
4209	hidnplayr	1733	bits_must_escape:
		1734	dd 0xffffffff ; 00-1F
		1735	dd 1 shl 0 + 1 shl 2 + 1 shl 3 + 1 shl 5 + 1 shl 28 + 1 shl 30 ; "#%<>
		1736	dd 1 shl 27 + 1 shl 28 + 1 shl 29 + 1 shl 30 ;[\]^
		1737	dd 1 shl 0 + 1 shl 27 + 1 shl 28 + 1 shl 29 + 1 shl 31 ;`{\|} DEL
		1738
		1739	dd 0xffffffff
		1740	dd 0xffffffff
		1741	dd 0xffffffff
		1742	dd 0xffffffff
		1743
		1744	str_hex:
		1745	db '0123456789ABCDEF'
		1746
4158	hidnplayr	1747	include_debug_strings
		1748
		1749	; uninitialized data
		1750	mem.alloc dd ?
		1751	mem.free dd ?
		1752	mem.realloc dd ?
		1753	dll.load dd ?
		1754
		1755	proxyAddr rb 256
		1756	proxyUser rb 256
		1757	proxyPassword rb 256
		1758	proxyPort dd ?

Subversion Repositories Kolibri OS

(root)/programs/develop/libraries/http/http.asm – Rev 4690