WebSVN – Tewi – Diff – /trunk/Server/http.c

-/* $Id: http.c 187 2024-09-28 00:07:34Z nishi $ */
+/* $Id: http.c 212 2024-10-02 17:44:55Z nishi $ */
 #define SOURCE
 #include "../config.h"
 #include <stdbool.h>
 #include <stdlib.h>
 #include <string.h>
-#ifdef __MINGW32__
+#if defined(__MINGW32__) || defined(_MSC_VER)
 #include <winsock2.h>
 #else
 #ifdef USE_POLL
 #ifdef __PPU__
 #include <net/poll.h>
 int tw_http_parse(SSL* ssl, int sock, struct tw_http_request* req) {
 	char buffer[512];
 	char cbuf[2];
 	int phase = 0;
+	char* header;
+	int nl;
 #ifdef USE_POLL
 	struct pollfd pollfds[1];
 	pollfds[0].fd = sock;
 	pollfds[0].events = POLLIN | POLLPRI;
 	req->query = NULL;
 	req->headers = NULL;
 	req->body = NULL;
 	req->version = NULL;
-	char* header = malloc(1);
+	header = malloc(1);
 	header[0] = 0;
-	int nl = 0;
+	nl = 0;
 	while(1) {
+		int i;
+		int len;
+			int n;
 #ifndef USE_POLL
+		struct timeval tv;
 		FD_ZERO(&fds);
 		FD_SET(sock, &fds);
-		struct timeval tv;
 		tv.tv_sec = 5;
 		tv.tv_usec = 0;
 #endif
 #ifndef NO_SSL
 		if(ssl == NULL || !SSL_has_pending(ssl)) {
 #endif
 #ifdef USE_POLL
-			int n = poll(pollfds, 1, 5000);
+			n = poll(pollfds, 1, 5000);
 #else
 #ifdef __HAIKU__
-		int n = select(32, &fds, NULL, NULL, &tv);
+		n = select(32, &fds, NULL, NULL, &tv);
 #else
-		int n = select(FD_SETSIZE, &fds, NULL, NULL, &tv);
+		n = select(FD_SETSIZE, &fds, NULL, NULL, &tv);
 #endif
 #endif
 			if(n <= 0) {
 				cm_log("HTTP", "Timeout, disconnecting");
 				free(header);
 				return -1;
+			}
 #ifndef NO_SSL
+		}
 #endif
-		int len = tw_read(ssl, sock, buffer, 512);
+		len = tw_read(ssl, sock, buffer, 512);
 		if(len <= 0) {
 			bad = true;
 			break;
+		}
-		int i;
 		for(i = 0; i < len; i++) {
 			char c = buffer[i];
 			if(phase == 0) {
 				if(c == ' ') {
 					if(req->method == NULL) {
 						goto getout;
 					} else {
 						phase++;
+					}
 				} else {
+					char* tmp;
 					if(req->method == NULL) {
 						req->method = malloc(1);
 						req->method[0] = 0;
+					}
 					cbuf[0] = c;
-					char* tmp = req->method;
+					tmp = req->method;
 					req->method = cm_strcat(tmp, cbuf);
 					free(tmp);
+				}
 			} else if(phase == 1) {
 				if(c == ' ') {
 						goto getout;
 					} else {
 						phase++;
+					}
 				} else {
+					char* tmp;
 					if(req->path == NULL) {
 						req->path = malloc(1);
 						req->path[0] = 0;
+					}
 					cbuf[0] = c;
-					char* tmp = req->path;
+					tmp = req->path;
 					req->path = cm_strcat(tmp, cbuf);
 					free(tmp);
+				}
 			} else if(phase == 2) {
 				if(c == '\n') {
 						tw_free_request(req);
 						bad = true;
 						goto getout;
 					} else {
 						/* We have Method, Path, Version now */
+						int j;
+						char* p;
+						int incr;
 						if(strcmp(req->version, "HTTP/1.1") != 0 && strcmp(req->version, "HTTP/1.0") != 0) {
 							cm_log("HTTP", "Bad HTTP Version");
 							bad = true;
 							goto getout;
+						}
-						int j;
-						char* p = malloc(1);
+						p = malloc(1);
 						p[0] = 0;
 						for(j = 0; req->path[j] != 0; j++) {
+							char* tmp;
 							if(req->path[j] == '/') {
 								cbuf[0] = '/';
 								for(; req->path[j] != 0 && req->path[j] == '/'; j++)
+									;
 								j--;
 							} else {
 								cbuf[0] = req->path[j];
+							}
-							char* tmp = p;
+							tmp = p;
 							p = cm_strcat(tmp, cbuf);
 							free(tmp);
+						}
 						free(req->path);
 						req->path = p;
-						int incr = 0;
+						incr = 0;
 						p = malloc(1);
 						p[0] = 0;
 						for(j = 0;; j++) {
 							if(req->path[j] == '/' || req->path[j] == 0) {
 								char oldc = req->path[j];
+								char* pth;
 								cbuf[0] = oldc;
 								req->path[j] = 0;
-								char* pth = req->path + incr;
+								pth = req->path + incr;
 								if(strcmp(pth, "..") == 0) {
 									int k;
 									if(p[strlen(p) - 1] == '/') p[strlen(p) - 1] = 0;
 									for(k = strlen(p) - 1; k >= 0; k--) {
 						cm_log("HTTP", "Request: %s %s %s", req->method, req->path, req->version);
 						phase++;
+					}
 				} else if(c != '\r') {
+					char* tmp;
 					if(req->version == NULL) {
 						req->version = malloc(1);
 						req->version[0] = 0;
+					}
 					cbuf[0] = c;
-					char* tmp = req->version;
+					tmp = req->version;
 					req->version = cm_strcat(tmp, cbuf);
 					free(tmp);
+				}
 			} else if(phase == 3) {
 				if(c == '\n') {
 					nl++;
 					if(nl == 2) {
 						phase++;
 						goto getout;
 					} else {
+						int j;
 						if(req->headers == NULL) {
 							req->headers = malloc(sizeof(*req->headers));
 							req->headers[0] = NULL;
+						}
-						int j;
 						for(j = 0; header[j] != 0; j++) {
 							if(header[j] == ':') {
+								char* kv;
+								char* vv;
+								char** old;
+								int k;
 								header[j] = 0;
 								j++;
 								for(; header[j] != 0 && (header[j] == ' ' || header[j] == '\t'); j++)
+									;
-								char* kv = header;
+								kv = header;
-								char* vv = header + j;
+								vv = header + j;
-								char** old = req->headers;
+								old = req->headers;
-								int k;
 								for(k = 0; old[k] != NULL; k++)
+									;
 								req->headers = malloc(sizeof(*req->headers) * (k + 3));
 								for(k = 0; old[k] != NULL; k++) req->headers[k] = old[k];
 								req->headers[k] = cm_strdup(kv);
 						free(header);
 						header = malloc(1);
 						header[0] = 0;
+					}
 				} else if(c != '\r') {
+					char* tmp;
 					nl = 0;
 					cbuf[0] = c;
-					char* tmp = header;
+					tmp = header;
 					header = cm_strcat(tmp, cbuf);
 					free(tmp);
+				}
+			}
+		}
 	free(header);
 	if(bad) {
 		tw_free_request(req);
 		return 1;
+	}
+	{
-	char* result = malloc(1);
+		char* result = malloc(1);
-	result[0] = 0;
+		int i;
-	int i;
+		int j;
+		int incr;
+		char* p;
+		result[0] = 0;
-	for(i = 0; req->path[i] != 0; i++) {
+		for(i = 0; req->path[i] != 0; i++) {
-		if(req->path[i] == '?') {
+			if(req->path[i] == '?') {
-			req->path[i] = 0;
+				req->path[i] = 0;
-			req->query = cm_strdup(req->path + i + 1);
+				req->query = cm_strdup(req->path + i + 1);
-			break;
+				break;
+			}
+		}
-	}
-	for(i = 0; req->path[i] != 0; i++) {
+		for(i = 0; req->path[i] != 0; i++) {
-		if(req->path[i] == '%') {
+			if(req->path[i] == '%') {
-			if(req->path[i + 1] == 0) continue;
+				if(req->path[i + 1] == 0) continue;
-			cbuf[0] = cm_hex(req->path + i + 1, 2);
+				cbuf[0] = cm_hex(req->path + i + 1, 2);
-			if(cbuf[0] != '\\') {
+				if(cbuf[0] != '\\') {
-				char* tmp = result;
+					char* tmp = result;
+					result = cm_strcat(tmp, cbuf);
+					free(tmp);
+				}
+				i += 2;
+			} else if(req->path[i] != '\\') {
+				char* tmp;
+				cbuf[0] = req->path[i];
+				tmp = result;
 				result = cm_strcat(tmp, cbuf);
 				free(tmp);
+			}
-			i += 2;
-		} else if(req->path[i] != '\\') {
-			cbuf[0] = req->path[i];
-			char* tmp = result;
-			result = cm_strcat(tmp, cbuf);
-			free(tmp);
+		}
-	}
-	free(req->path);
+		free(req->path);
-	req->path = result;
+		req->path = result;
-	int incr = 0;
+		incr = 0;
-	char* p = malloc(1);
+		p = malloc(1);
-	p[0] = 0;
+		p[0] = 0;
-	int j;
-	for(j = 0;; j++) {
+		for(j = 0;; j++) {
-		if(req->path[j] == '/' || req->path[j] == 0) {
+			if(req->path[j] == '/' || req->path[j] == 0) {
-			char oldc = req->path[j];
+				char oldc = req->path[j];
+				char* pth;
-			cbuf[0] = oldc;
+				cbuf[0] = oldc;
-			req->path[j] = 0;
+				req->path[j] = 0;
-			char* pth = req->path + incr;
+				pth = req->path + incr;
-			if(strcmp(pth, "..") == 0) {
+				if(strcmp(pth, "..") == 0) {
-				int k;
+					int k;
-				if(p[strlen(p) - 1] == '/') p[strlen(p) - 1] = 0;
+					if(p[strlen(p) - 1] == '/') p[strlen(p) - 1] = 0;
-				for(k = strlen(p) - 1; k >= 0; k--) {
+					for(k = strlen(p) - 1; k >= 0; k--) {
-					if(p[k] == '/') {
+						if(p[k] == '/') {
-						p[k + 1] = 0;
+							p[k + 1] = 0;
-						break;
+							break;
+						}
+					}
+					if(strlen(p) == 0) {
+						free(p);
+						p = cm_strdup("/");
+					}
+				} else if(strcmp(pth, ".") == 0) {
+				} else {
+					char* tmp = p;
+					p = cm_strcat3(tmp, pth, cbuf);
+					free(tmp);
+				}
-				if(strlen(p) == 0) {
-					free(p);
-					p = cm_strdup("/");
-				}
-			} else if(strcmp(pth, ".") == 0) {
-			} else {
-				char* tmp = p;
+				incr = j + 1;
-				p = cm_strcat3(tmp, pth, cbuf);
-				free(tmp);
+				if(oldc == 0) break;
+			}
-			incr = j + 1;
-			if(oldc == 0) break;
+		}
+		free(req->path);
+		req->path = p;
+		return 0;
+	}
-	free(req->path);
-	req->path = p;
-	return 0;
+}

Subversion Repositories Tewi

(root)/trunk/Server/http.c – Rev 187 → 212