initial import

1 files changed, 284 insertions, 0 deletions

diff --git a/nanohttp/nanohttp-request.c b/nanohttp/nanohttp-request.c
new file mode 100755
index 0000000..bed59f2
--- /dev/null
+++ b/nanohttp/nanohttp-request.c
@@ -0,0 +1,284 @@
+/******************************************************************
+*  $Id: nanohttp-request.c,v 1.1 2004/10/15 13:30:42 snowdrop Exp $
+*
+* CSOAP Project:  A http client/server library in C
+* Copyright (C) 2003  Ferhat Ayaz
+*
+* This library is free software; you can redistribute it and/or
+* modify it under the terms of the GNU Library General Public
+* License as published by the Free Software Foundation; either
+* version 2 of the License, or (at your option) any later version.
+*
+* This library is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+* Library General Public License for more details.
+*
+* You should have received a copy of the GNU Library General Public
+* License along with this library; if not, write to the
+* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+* Boston, MA  02111-1307, USA.
+*
+* Email: ayaz@jprogrammer.net
+******************************************************************/
+
+#include <nanohttp/nanohttp-common.h>
+#include <nanohttp/nanohttp-request.h>
+
+#ifdef MEM_DEBUG
+#include <utils/alloc.h>
+#endif
+
+/* request stuff */
+
+
+static
+hrequest_t *hrequest_new()
+{
+	hrequest_t * req = (hrequest_t *) malloc(sizeof(hrequest_t));
+
+	req->method = HTTP_REQUEST_GET;
+	req->version = HTTP_1_1;
+	req->query = NULL;
+	req->header = NULL;
+	req->in = NULL;
+	req->attachments = NULL;
+	req->content_type = NULL;
+
+}
+
+static
+hrequest_t     *
+_hrequest_parse_header(char *data)
+{
+	hrequest_t     *req;
+	hpair_t        *hpair = NULL, *qpair = NULL, *tmppair = NULL;
+
+	char           *tmp;
+	char           *tmp2;
+	char           *saveptr;
+	char           *saveptr2;
+	char           *saveptr3;
+	char           *result;
+	char           *key;
+	char           *value;
+	char           *opt_key;
+	char           *opt_value;
+	int             firstline = 1;
+
+	req = hrequest_new();
+	tmp = data;
+
+	for (;;) {
+		result = (char *) strtok_r(tmp, "\r\n", &saveptr);
+		tmp = saveptr;
+
+		if (result == NULL)
+			break;
+
+		if (firstline) {
+			firstline = 0;
+			tmp2 = result;
+
+			/* parse [GET|POST] [PATH] [SPEC] */
+			key = (char *) strtok_r(tmp2, " ", &saveptr2);
+
+			/* save method (get or post) */
+			tmp2 = saveptr2;
+			if (key != NULL) {
+			  if (!strcmp(key, "POST"))
+			    req->method = HTTP_REQUEST_POST;
+			  else
+			    req->method = HTTP_REQUEST_GET;
+			}
+			/* below is key the path and tmp2 the spec */
+			key = (char *) strtok_r(tmp2, " ", &saveptr2);
+
+			/* save version */
+			tmp2 = saveptr2;
+			if (tmp2 != NULL) {
+				/*req->spec = (char *) malloc(strlen(tmp2) + 1);
+				strcpy(req->spec, tmp2);
+				*/
+				if (!strcmp(tmp2, "HTTP/1.0"))
+				  req-> version = HTTP_1_0;
+				else
+				  req-> version = HTTP_1_1;
+			}
+			/*
+			 * parse and save path+query parse:
+			 * /path/of/target?key1=value1&key2=value2...
+			 */
+
+			if (key != NULL) {
+				tmp2 = key;
+				key = (char *) strtok_r(tmp2, "?", &saveptr2);
+				tmp2 = saveptr2;
+
+				/* save path */
+				/*req->path = (char *) malloc(strlen(key) + 1);*/
+				strncpy(req->path, key, REQUEST_MAX_PATH_SIZE);
+
+				/* parse options */
+				for (;;) {
+					key = (char *) strtok_r(tmp2, "&", &saveptr2);
+					tmp2 = saveptr2;
+
+					if (key == NULL)
+						break;
+
+					opt_key = (char *) strtok_r(key, "=", &saveptr3);
+					opt_value = saveptr3;
+
+					if (opt_value == NULL)
+						opt_value = "";
+
+					/* create option pair */
+					if (opt_key != NULL) {
+						tmppair = (hpair_t *) malloc(sizeof(hpair_t));
+
+						if (req->query == NULL) {
+							req->query = qpair = tmppair;
+						} else {
+							qpair->next = tmppair;
+							qpair = tmppair;
+						}
+
+						/* fill hpairnode_t struct */
+						qpair->next = NULL;
+						qpair->key = (char *) malloc(strlen(opt_key) + 1);
+						qpair->value = (char *) malloc(strlen(opt_value) + 1);
+
+						strcpy(qpair->key, opt_key);
+						strcpy(qpair->value, opt_value);
+
+					}
+				}
+			}
+		} else {
+
+			/* parse "key: value" */
+		/*	tmp2 = result;
+			key = (char *) strtok_r(tmp2, ": ", &saveptr2);
+			value = saveptr2;*/
+
+			/* create pair */
+/*			tmppair = (hpair_t *) malloc(sizeof(hpair_t));*/
+      tmppair = hpairnode_parse(result, ":", NULL);
+
+			if (req->header == NULL) {
+				req->header = hpair = tmppair;
+			} else {
+				hpair->next = tmppair;
+				hpair = tmppair;
+			}
+
+			/* fill pairnode_t struct */
+			/*
+			hpair->next = NULL;
+			hpair->key = (char *) malloc(strlen(key) + 1);
+			hpair->value = (char *) malloc(strlen(value) + 1);
+
+			strcpy(hpair->key, key);
+			strcpy(hpair->value, value);
+			*/
+		}
+	}
+	
+  /* Check Content-type */
+  tmp = hpairnode_get(req->header, HEADER_CONTENT_TYPE);
+  if (tmp != NULL)
+    req->content_type = content_type_new(tmp);
+
+	return req;
+}
+
+
+void 
+hrequest_free(hrequest_t * req)
+{
+	if (req == NULL)
+		return;
+
+
+	hpairnode_free_deep(req->header);
+	hpairnode_free_deep(req->query);
+
+	if (req->in)
+	 http_input_stream_free(req->in);
+
+  if (req->content_type)
+    content_type_free(req->content_type);
+
+  if (req->attachments)
+    attachments_free(req->attachments);
+
+  free(req);
+}
+
+
+hrequest_t *
+hrequest_new_from_socket(hsocket_t sock)
+{
+  int              i=0, status;
+  hrequest_t      *req;
+  char             buffer[MAX_HEADER_SIZE+1];
+  attachments_t  *mimeMessage;
+
+  /* Read header */
+  while (i<MAX_HEADER_SIZE)
+  {
+    status = hsocket_read(sock, &(buffer[i]), 1, 1);
+    if (status == -1)
+    {
+        log_error1("Socket read error");
+        return NULL;
+    }
+
+    buffer[i+1] = '\0'; /* for strmp */
+
+    if (i > 3)
+    {
+        if (!strcmp(&(buffer[i-1]), "\n\n") ||
+            !strcmp(&(buffer[i-2]), "\n\r\n"))
+            break;
+    }
+    i++;
+  }
+
+  /* Create response */
+  req = _hrequest_parse_header(buffer);
+  if (req == NULL)
+  {
+    log_error1("Header parse error");
+    return NULL;
+  }
+
+  /* Create input stream */
+  req->in = http_input_stream_new(sock, req->header);
+
+  /* Check for MIME message */
+  if ((req->content_type && 
+      !strcmp(req->content_type->type, "multipart/related")))
+  {
+    status = mime_get_attachments(req->content_type, req->in, &mimeMessage);
+    if (status != H_OK)
+    {
+      /* TODO (#1#): Handle error */
+      hrequest_free(req);
+      return NULL;            
+    }
+    else
+    {
+      req->attachments = mimeMessage;
+      req->in = http_input_stream_new_from_file(mimeMessage->root_part->filename);
+    }
+  }
+     
+
+  return req;
+}
+
+
+
+