/******************************************************************
*  $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;
}