http.c@ 117

Visit:

Last change on this file since 117 was 104, checked in by Nishi, on Sep 20, 2024 at 12:16:52 AM
format, and fix platform
Property svn:keywords set to `Id`
File size: 7.0 KB

Rev	Line
[16]	1	/* $Id: http.c 104 2024-09-19 15:16:52Z nishi $ */
	2
	3	#define SOURCE
	4
[43]	5	#include "../config.h"
	6
[16]	7	#include "tw_http.h"
	8
	9	#include "tw_server.h"
	10
	11	#include <cm_log.h>
	12	#include <cm_string.h>
	13
	14	#include <stdbool.h>
	15	#include <stdlib.h>
[17]	16	#include <string.h>
[16]	17
[17]	18	#ifdef __MINGW32__
	19	#include <winsock2.h>
	20	#else
	21	#include <sys/select.h>
	22	#endif
	23
[16]	24	void tw_free_request(struct tw_http_request* req) {
	25	if(req->method != NULL) free(req->method);
	26	if(req->path != NULL) free(req->path);
[20]	27	if(req->query != NULL) free(req->query);
[16]	28	if(req->headers != NULL) {
	29	int i;
	30	for(i = 0; req->headers[i] != NULL; i++) free(req->headers[i]);
	31	free(req->headers);
	32	}
	33	if(req->body != NULL) free(req->body);
	34	if(req->version != NULL) free(req->version);
[64]	35
	36	req->method = NULL;
	37	req->path = NULL;
	38	req->query = NULL;
	39	req->headers = NULL;
	40	req->body = NULL;
	41	req->version = NULL;
[16]	42	}
	43
	44	int tw_http_parse(SSL* ssl, int sock, struct tw_http_request* req) {
	45	char buffer[512];
	46	char cbuf[2];
	47	int phase = 0;
	48	fd_set fds;
	49
	50	bool bad = false;
	51
	52	cbuf[1] = 0;
	53
	54	req->method = NULL;
	55	req->path = NULL;
[20]	56	req->query = NULL;
[16]	57	req->headers = NULL;
	58	req->body = NULL;
	59	req->version = NULL;
	60
	61	char* header = malloc(1);
	62	header[0] = 0;
	63	int nl = 0;
	64
	65	while(1) {
	66	FD_ZERO(&fds);
	67	FD_SET(sock, &fds);
	68	struct timeval tv;
	69	tv.tv_sec = 5;
	70	tv.tv_usec = 0;
[43]	71	#ifndef NO_SSL
[23]	72	if(ssl == NULL \|\| !SSL_has_pending(ssl)) {
[43]	73	#endif
[88]	74	#ifdef __HAIKU__
	75	int n = select(32, &fds, NULL, NULL, &tv);
	76	#else
[104]	77	int n = select(FD_SETSIZE, &fds, NULL, NULL, &tv);
[88]	78	#endif
[22]	79	if(n <= 0) {
[46]	80	cm_log("HTTP", "Timeout, disconncting");
[22]	81	free(header);
	82	tw_free_request(req);
	83	return -1;
	84	}
[43]	85	#ifndef NO_SSL
[22]	86	}
[43]	87	#endif
[16]	88	int len = tw_read(ssl, sock, buffer, 512);
[70]	89	if(len <= 0) {
[64]	90	bad = true;
	91	break;
	92	}
[16]	93	int i;
	94	for(i = 0; i < len; i++) {
	95	char c = buffer[i];
	96	if(phase == 0) {
	97	if(c == ' ') {
	98	if(req->method == NULL) {
	99	tw_free_request(req);
	100	bad = true;
	101	goto getout;
	102	} else {
	103	phase++;
	104	}
	105	} else {
	106	if(req->method == NULL) {
	107	req->method = malloc(1);
	108	req->method[0] = 0;
	109	}
	110	cbuf[0] = c;
	111	char* tmp = req->method;
	112	req->method = cm_strcat(tmp, cbuf);
	113	free(tmp);
	114	}
	115	} else if(phase == 1) {
	116	if(c == ' ') {
	117	if(req->path == NULL) {
	118	tw_free_request(req);
	119	bad = true;
	120	goto getout;
	121	} else {
	122	phase++;
	123	}
	124	} else {
	125	if(req->path == NULL) {
	126	req->path = malloc(1);
	127	req->path[0] = 0;
	128	}
	129	cbuf[0] = c;
	130	char* tmp = req->path;
	131	req->path = cm_strcat(tmp, cbuf);
	132	free(tmp);
	133	}
	134	} else if(phase == 2) {
	135	if(c == '\n') {
	136	if(req->version == NULL) {
	137	tw_free_request(req);
	138	bad = true;
	139	goto getout;
	140	} else {
	141	/* We have Method, Path, Version now */
	142
	143	if(strcmp(req->version, "HTTP/1.1") != 0 && strcmp(req->version, "HTTP/1.0") != 0) {
	144	cm_log("HTTP", "Bad HTTP Version");
	145	bad = true;
	146	goto getout;
	147	}
	148
	149	int j;
	150	char* p = malloc(1);
	151	p[0] = 0;
	152	for(j = 0; req->path[j] != 0; j++) {
	153	if(req->path[j] == '/') {
	154	cbuf[0] = '/';
	155	for(; req->path[j] != 0 && req->path[j] == '/'; j++)
	156	;
	157	j--;
	158	} else {
	159	cbuf[0] = req->path[j];
	160	}
	161	char* tmp = p;
	162	p = cm_strcat(tmp, cbuf);
	163	free(tmp);
	164	}
	165	free(req->path);
	166	req->path = p;
	167
	168	int incr = 0;
	169	p = malloc(1);
	170	p[0] = 0;
	171	for(j = 0;; j++) {
	172	if(req->path[j] == '/' \|\| req->path[j] == 0) {
	173	char oldc = req->path[j];
	174	cbuf[0] = oldc;
	175	req->path[j] = 0;
	176
	177	char* pth = req->path + incr;
	178
	179	if(strcmp(pth, "..") == 0) {
	180	int k;
	181	if(p[strlen(p) - 1] == '/') p[strlen(p) - 1] = 0;
	182	for(k = strlen(p) - 1; k >= 0; k--) {
	183	if(p[k] == '/') {
	184	p[k + 1] = 0;
	185	break;
	186	}
	187	}
	188	if(strlen(p) == 0) {
	189	free(p);
	190	p = cm_strdup("/");
	191	}
	192	} else if(strcmp(pth, ".") == 0) {
	193	} else {
	194	char* tmp = p;
	195	p = cm_strcat3(tmp, pth, cbuf);
	196	free(tmp);
	197	}
	198
	199	incr = j + 1;
	200	if(oldc == 0) break;
	201	}
	202	}
	203	free(req->path);
	204	req->path = p;
	205
	206	cm_log("HTTP", "Request: %s %s %s", req->method, req->path, req->version);
	207
	208	phase++;
	209	}
	210	} else if(c != '\r') {
	211	if(req->version == NULL) {
	212	req->version = malloc(1);
	213	req->version[0] = 0;
	214	}
	215	cbuf[0] = c;
	216	char* tmp = req->version;
	217	req->version = cm_strcat(tmp, cbuf);
	218	free(tmp);
	219	}
	220	} else if(phase == 3) {
	221	if(c == '\n') {
	222	nl++;
	223	if(nl == 2) {
	224	phase++;
	225	goto getout;
	226	} else {
	227	if(req->headers == NULL) {
	228	req->headers = malloc(sizeof(*req->headers));
	229	req->headers[0] = NULL;
	230	}
	231	int j;
	232	for(j = 0; header[j] != 0; j++) {
	233	if(header[j] == ':') {
	234	header[j] = 0;
	235	j++;
	236	for(; header[j] != 0 && (header[j] == ' ' \|\| header[j] == '\t'); j++)
	237	;
	238	char* kv = header;
	239	char* vv = header + j;
	240
	241	char** old = req->headers;
	242	int k;
	243	for(k = 0; old[k] != NULL; k++)
	244	;
	245	req->headers = malloc(sizeof(req->headers) (k + 3));
	246	for(k = 0; old[k] != NULL; k++) req->headers[k] = old[k];
	247	req->headers[k] = cm_strdup(kv);
	248	req->headers[k + 1] = cm_strdup(vv);
	249	req->headers[k + 2] = NULL;
	250	free(old);
	251
	252	cm_log("HTTP", "Header: %s: %s", kv, vv);
	253
	254	break;
	255	}
	256	}
	257	free(header);
	258	header = malloc(1);
	259	header[0] = 0;
	260	}
	261	} else if(c != '\r') {
	262	nl = 0;
	263	cbuf[0] = c;
	264	char* tmp = header;
	265	header = cm_strcat(tmp, cbuf);
	266	free(tmp);
	267	}
	268	}
	269	}
	270	}
	271	getout:
	272	free(header);
	273	if(bad) {
	274	tw_free_request(req);
	275	return 1;
	276	}
[20]	277	char* result = malloc(1);
	278	result[0] = 0;
	279	int i;
	280	for(i = 0; req->path[i] != 0; i++) {
	281	if(req->path[i] == '?') {
	282	req->path[i] = 0;
	283	req->query = cm_strdup(req->path + i + 1);
	284	break;
	285	}
	286	}
	287	for(i = 0; req->path[i] != 0; i++) {
	288	if(req->path[i] == '%') {
	289	if(req->path[i + 1] == 0) continue;
	290	cbuf[0] = cm_hex(req->path + i + 1, 2);
[70]	291	if(cbuf[0] != '\\') {
	292	char* tmp = result;
	293	result = cm_strcat(tmp, cbuf);
	294	free(tmp);
	295	}
[20]	296	i += 2;
[70]	297	} else if(req->path[i] != '\\') {
[20]	298	cbuf[0] = req->path[i];
	299	char* tmp = result;
	300	result = cm_strcat(tmp, cbuf);
	301	free(tmp);
	302	}
	303	}
	304	free(req->path);
	305	req->path = result;
[69]	306
	307	int incr = 0;
	308	char* p = malloc(1);
	309	p[0] = 0;
	310	int j;
	311	for(j = 0;; j++) {
	312	if(req->path[j] == '/' \|\| req->path[j] == 0) {
	313	char oldc = req->path[j];
	314	cbuf[0] = oldc;
	315	req->path[j] = 0;
	316
	317	char* pth = req->path + incr;
	318
	319	if(strcmp(pth, "..") == 0) {
	320	int k;
	321	if(p[strlen(p) - 1] == '/') p[strlen(p) - 1] = 0;
	322	for(k = strlen(p) - 1; k >= 0; k--) {
	323	if(p[k] == '/') {
	324	p[k + 1] = 0;
	325	break;
	326	}
	327	}
	328	if(strlen(p) == 0) {
	329	free(p);
	330	p = cm_strdup("/");
	331	}
	332	} else if(strcmp(pth, ".") == 0) {
[70]	333	} else {
[69]	334	char* tmp = p;
	335	p = cm_strcat3(tmp, pth, cbuf);
	336	free(tmp);
	337	}
	338
	339	incr = j + 1;
	340	if(oldc == 0) break;
	341	}
	342	}
	343	free(req->path);
	344	req->path = p;
[16]	345	return 0;
	346	}

Note: See TracBrowser for help on using the repository browser.

source: Main/trunk/Server/http.c@ 117

Download in other formats: