diff options
Diffstat (limited to 'nanohttp/nanohttp-request.c')
| -rwxr-xr-x | nanohttp/nanohttp-request.c | 284 |
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; +} + + + + |