http.c@ 16

Visit:

Last change on this file since 16 was 16, checked in by Nishi, on Sep 14, 2024 at 12:09:52 AM
can parse http now
Property svn:keywords set to `Id`
File size: 5.1 KB

Line
1	/* $Id: http.c 16 2024-09-13 15:09:52Z nishi $ */
2
3	#define SOURCE
4
5	#include "tw_http.h"
6
7	#include "tw_server.h"
8
9	#include <cm_log.h>
10	#include <cm_string.h>
11
12	#include <stdbool.h>
13	#include <stdlib.h>
14	#include <sys/socket.h>
15
16	void tw_free_request(struct tw_http_request* req) {
17	if(req->method != NULL) free(req->method);
18	if(req->path != NULL) free(req->path);
19	if(req->headers != NULL) {
20	int i;
21	for(i = 0; req->headers[i] != NULL; i++) free(req->headers[i]);
22	free(req->headers);
23	}
24	if(req->body != NULL) free(req->body);
25	if(req->version != NULL) free(req->version);
26	}
27
28	int tw_http_parse(SSL* ssl, int sock, struct tw_http_request* req) {
29	char buffer[512];
30	char cbuf[2];
31	int phase = 0;
32	fd_set fds;
33
34	bool bad = false;
35
36	cbuf[1] = 0;
37
38	req->method = NULL;
39	req->path = NULL;
40	req->headers = NULL;
41	req->body = NULL;
42	req->version = NULL;
43
44	char* header = malloc(1);
45	header[0] = 0;
46	int nl = 0;
47
48	while(1) {
49	FD_ZERO(&fds);
50	FD_SET(sock, &fds);
51	struct timeval tv;
52	tv.tv_sec = 5;
53	tv.tv_usec = 0;
54	int n = select(FD_SETSIZE, &fds, NULL, NULL, &tv);
55	if(n == 0) break;
56	int len = tw_read(ssl, sock, buffer, 512);
57	if(len <= 0) break;
58	int i;
59	for(i = 0; i < len; i++) {
60	char c = buffer[i];
61	if(phase == 0) {
62	if(c == ' ') {
63	if(req->method == NULL) {
64	tw_free_request(req);
65	bad = true;
66	goto getout;
67	} else {
68	phase++;
69	}
70	} else {
71	if(req->method == NULL) {
72	req->method = malloc(1);
73	req->method[0] = 0;
74	}
75	cbuf[0] = c;
76	char* tmp = req->method;
77	req->method = cm_strcat(tmp, cbuf);
78	free(tmp);
79	}
80	} else if(phase == 1) {
81	if(c == ' ') {
82	if(req->path == NULL) {
83	tw_free_request(req);
84	bad = true;
85	goto getout;
86	} else {
87	phase++;
88	}
89	} else {
90	if(req->path == NULL) {
91	req->path = malloc(1);
92	req->path[0] = 0;
93	}
94	cbuf[0] = c;
95	char* tmp = req->path;
96	req->path = cm_strcat(tmp, cbuf);
97	free(tmp);
98	}
99	} else if(phase == 2) {
100	if(c == '\n') {
101	if(req->version == NULL) {
102	tw_free_request(req);
103	bad = true;
104	goto getout;
105	} else {
106	/* We have Method, Path, Version now */
107
108	if(strcmp(req->version, "HTTP/1.1") != 0 && strcmp(req->version, "HTTP/1.0") != 0) {
109	cm_log("HTTP", "Bad HTTP Version");
110	bad = true;
111	goto getout;
112	}
113
114	int j;
115	char* p = malloc(1);
116	p[0] = 0;
117	for(j = 0; req->path[j] != 0; j++) {
118	if(req->path[j] == '/') {
119	cbuf[0] = '/';
120	for(; req->path[j] != 0 && req->path[j] == '/'; j++)
121	;
122	j--;
123	} else {
124	cbuf[0] = req->path[j];
125	}
126	char* tmp = p;
127	p = cm_strcat(tmp, cbuf);
128	free(tmp);
129	}
130	free(req->path);
131	req->path = p;
132
133	int incr = 0;
134	p = malloc(1);
135	p[0] = 0;
136	for(j = 0;; j++) {
137	if(req->path[j] == '/' \|\| req->path[j] == 0) {
138	char oldc = req->path[j];
139	cbuf[0] = oldc;
140	req->path[j] = 0;
141
142	char* pth = req->path + incr;
143
144	if(strcmp(pth, "..") == 0) {
145	int k;
146	if(p[strlen(p) - 1] == '/') p[strlen(p) - 1] = 0;
147	for(k = strlen(p) - 1; k >= 0; k--) {
148	if(p[k] == '/') {
149	p[k + 1] = 0;
150	break;
151	}
152	}
153	if(strlen(p) == 0) {
154	free(p);
155	p = cm_strdup("/");
156	}
157	} else if(strcmp(pth, ".") == 0) {
158	} else {
159	char* tmp = p;
160	p = cm_strcat3(tmp, pth, cbuf);
161	free(tmp);
162	}
163
164	incr = j + 1;
165	if(oldc == 0) break;
166	}
167	}
168	free(req->path);
169	req->path = p;
170
171	cm_log("HTTP", "Request: %s %s %s", req->method, req->path, req->version);
172
173	phase++;
174	}
175	} else if(c != '\r') {
176	if(req->version == NULL) {
177	req->version = malloc(1);
178	req->version[0] = 0;
179	}
180	cbuf[0] = c;
181	char* tmp = req->version;
182	req->version = cm_strcat(tmp, cbuf);
183	free(tmp);
184	}
185	} else if(phase == 3) {
186	if(c == '\n') {
187	nl++;
188	if(nl == 2) {
189	phase++;
190	goto getout;
191	} else {
192	if(req->headers == NULL) {
193	req->headers = malloc(sizeof(*req->headers));
194	req->headers[0] = NULL;
195	}
196	int j;
197	for(j = 0; header[j] != 0; j++) {
198	if(header[j] == ':') {
199	header[j] = 0;
200	j++;
201	for(; header[j] != 0 && (header[j] == ' ' \|\| header[j] == '\t'); j++)
202	;
203	char* kv = header;
204	char* vv = header + j;
205
206	char** old = req->headers;
207	int k;
208	for(k = 0; old[k] != NULL; k++)
209	;
210	req->headers = malloc(sizeof(req->headers) (k + 3));
211	for(k = 0; old[k] != NULL; k++) req->headers[k] = old[k];
212	req->headers[k] = cm_strdup(kv);
213	req->headers[k + 1] = cm_strdup(vv);
214	req->headers[k + 2] = NULL;
215	free(old);
216
217	cm_log("HTTP", "Header: %s: %s", kv, vv);
218
219	break;
220	}
221	}
222	free(header);
223	header = malloc(1);
224	header[0] = 0;
225	}
226	} else if(c != '\r') {
227	nl = 0;
228	cbuf[0] = c;
229	char* tmp = header;
230	header = cm_strcat(tmp, cbuf);
231	free(tmp);
232	}
233	}
234	}
235	}
236	getout:
237	free(header);
238	if(bad) {
239	tw_free_request(req);
240	return 1;
241	}
242	return 0;
243	}

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

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

Download in other formats: