initial import

2 files changed, 456 insertions, 0 deletions

diff --git a/nanohttp/nanohttp-server.c b/nanohttp/nanohttp-server.c
new file mode 100644
index 0000000..e739267
--- /dev/null
+++ b/nanohttp/nanohttp-server.c
@@ -0,0 +1,380 @@
+/******************************************************************
+ *  $Id: nanohttp-server.c,v 1.1 2004/01/21 12:15:30 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-server.h>
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include <time.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+
+typedef struct tag_conndata
+{
+  hsocket_t sock;
+}conndata_t;
+
+/* ----------------------------------------------------- 
+ nano httpd internally globals
+----------------------------------------------------- */
+static int _httpd_port = 10000;
+static hsocket_t _httpd_socket;
+static hservice_t *_httpd_services_head = NULL;
+static hservice_t *_httpd_services_tail = NULL;
+
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_init
+----------------------------------------------------- */
+int httpd_init(int argc, char *argv[])
+{
+  int i, status;
+
+  /* write argument information */
+  log_verbose1("Arguments:");  
+  for (i=0;i<argc;i++)
+    log_verbose3("argv[%i] = '%s'\n", i, SAVE_STR(argv[i]));
+
+  /* initialize from arguments */
+  for (i=0;i<argc;i++) {
+    if (!strcmp(argv[i], NHTTPD_ARG_PORT) && i < argc-1) {
+      _httpd_port = atoi(argv[i+1]);
+    }
+  }
+
+  log_debug2("socket bind to port '%d'\n", _httpd_port);
+
+  /* init built-in services */
+  /*
+    httpd_register("/httpd/list", service_list);
+  */
+
+  /* create socket */
+  hsocket_init(&_httpd_socket);
+  status = hsocket_bind(&_httpd_socket, _httpd_port);
+
+  return status;
+}
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_register
+----------------------------------------------------- */
+
+int httpd_register(const char* ctx,  httpd_service func)
+{
+  hservice_t* service;
+  log_debug3("register service:t(%p):%s", service, SAVE_STR(ctx));
+
+  service = (hservice_t*)malloc(sizeof(hservice_t));
+  service->next = NULL;
+  service->func = func;
+  strcpy(service->ctx, ctx);
+  
+  if (_httpd_services_head == NULL) {
+    _httpd_services_head = _httpd_services_tail = service;
+  } else {
+    _httpd_services_tail->next = service;
+    _httpd_services_tail = service;
+  }
+
+  return 1;
+}
+
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_services
+----------------------------------------------------- */
+hservice_t *httpd_services()
+{
+  return _httpd_services_head;
+}
+
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_find_service
+----------------------------------------------------- */
+static hservice_t *httpd_find_service(const char* ctx) 
+{
+  hservice_t *cur = _httpd_services_head;
+
+  while (cur != NULL) {
+    if (!strcmp(cur->ctx, ctx)) {
+      return cur;
+    }
+    cur = cur->next;
+  }
+
+  return NULL;
+}
+
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_response_set_content_type
+----------------------------------------------------- */
+void httpd_response_set_content_type(httpd_conn_t *res, 
+				     const char* content_type)
+{
+  strncpy(res->content_type, content_type, 25);
+}
+
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_response_send_header
+----------------------------------------------------- */
+int httpd_send_header(httpd_conn_t *res, 
+		      int code, const char* text, 
+		      hpair_t *pair)
+{
+  struct tm stm;
+  time_t nw;
+  char buffer[255];
+  char header[1024];
+  hpair_t *cur;
+  int status;
+
+  /* set status code */
+  sprintf(header, "HTTP/1.1 %d %s\r\n", code, text);
+
+  /* set date */
+  nw = time(NULL);
+  localtime_r(&nw, &stm);
+  strftime(buffer, 255, "Date: %a, %d %b %y %T GMT", &stm);
+  strcat(header, buffer);
+  strcat(header, "\r\n");
+  
+  /* set content-type */
+  if (res->content_type[0] == '\0') {
+    strcat(header, "Content-Type: text/html\r\n");
+  } else {
+    sprintf(buffer, "Content-Type: %s\r\n", res->content_type);
+    strcat(header, buffer);
+  }
+
+  /* set server name */
+  strcat(header, "Server: Nano HTTPD library\r\n");
+
+  /* set connection status */
+  strcat(header, "Connection: close\r\n");
+
+  /* add pairs */
+  cur = pair;
+  while (cur != NULL) {
+    sprintf(buffer, "%s: %s\r\n", cur->key, cur->value);
+    strcat(header, buffer);
+    cur = cur->next;
+  }
+
+  /* set end of header */
+  strcat(header, "\r\n");
+
+  /* send header */
+  status = hsocket_nsend(res->sock, header, strlen(header));
+  
+  return status;
+}
+
+
+int httpd_send_internal_error(httpd_conn_t *conn, const char* errmsg)
+{
+  const char *template =
+    "<html><body><h3>Error!</h3><hr> Message: '%s' </body></html>\r\n";
+
+  char buffer[4064];
+  sprintf(buffer, template, errmsg);
+  httpd_send_header(conn, 500, "INTERNAL", NULL);
+  return send(conn->sock, buffer, strlen(buffer), 0);
+}
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_request_print
+----------------------------------------------------- */
+static void httpd_request_print(hrequest_t *req) 
+{
+  hpair_t *pair;
+
+  printf("++++++ Request +++++++++\n");
+  printf(" Method : '%s'\n", req->method);
+  printf(" Path   : '%s'\n", req->path);
+  printf(" Spec   : '%s'\n", req->spec);
+  printf(" Parsed query string :\n");
+
+  pair = req->query;
+  while (pair != NULL) {
+    printf(" %s = '%s'\n", pair->key, pair->value);
+    pair = pair->next;
+  }
+  printf("++++++++++++++++++++++++\n");
+  
+}
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_session_main
+----------------------------------------------------- */
+static void* httpd_session_main(void *data)
+{
+  conndata_t *conn = (conndata_t*)data;
+  const char *msg = "SESSION 1.0\n";
+  int len = strlen(msg);
+  char buffer[256]; /* temp buffer for recv() */
+  char header[4064]; /* received header */
+  int total; /* result from recv() */
+  int hindex; /* searching end of header */
+  int headerreached =0; /* whether reach header "\n\n" */
+  hrequest_t* req = NULL; /* only for test */
+  httpd_conn_t *rconn;
+  hservice_t* service = NULL;
+
+  header[0] = '\0';
+  len = 0;
+
+
+  log_debug1("starting httpd_session_main()\n");
+
+  /*send(conn->sock, msg, len, 0);*/
+
+  while (!headerreached) {
+    /*printf("receiving ...\n");*/
+    total = recv(conn->sock, buffer, 255, 0);
+    if (total==0) break;
+    buffer[total]='\0';
+    /*printf("'%s'\n", buffer);*/
+
+    /* search end of header */
+    
+    for (hindex=0;hindex<total-3;hindex++) {
+      if (!strncmp(&buffer[hindex],"\r\n\r\n",4)) {
+	break;
+      }
+    }
+
+    if (hindex==total-3) {
+      hindex = total;
+    } else {
+      headerreached = 1;
+    }
+
+    len += hindex;
+    strncat(header, buffer, hindex);
+    header[len]='\0';
+  }
+
+  printf("=== HEADER ===\n%s\n============\n", header);
+  /* call the service */
+  req = hrequest_new_from_buffer(header);
+  httpd_request_print(req);
+  rconn = (httpd_conn_t*)malloc(sizeof(httpd_conn_t));
+  rconn->sock = conn->sock;
+  rconn->content_type[0] = '\0';
+
+  service = httpd_find_service(req->path);
+  if (service != NULL) {
+    log_verbose2("service '%s' found\n", req->path);
+    if (service->func != NULL) {
+      service->func(rconn, req);
+    } else {
+      sprintf(buffer, 
+	      "service '%s' not registered properly (func == NULL)", 
+	      req->path);
+      log_verbose1(buffer);
+      httpd_send_internal_error(rconn, buffer);
+    }
+  } else {
+    sprintf(buffer, "service '%s' not found", req->path);
+      log_verbose1(buffer);
+      httpd_send_internal_error(rconn, buffer);
+  }
+
+  close(conn->sock);
+
+  /*  httpd_response_free(res);*/
+  hrequest_free(req);
+  
+  pthread_exit(NULL);
+} 
+
+
+/* ----------------------------------------------------- 
+ FUNCTION: httpd_run
+----------------------------------------------------- */
+
+int httpd_run()
+{
+  conndata_t *conn;
+  pthread_t tid;
+  hsocket_t sockfd;
+  int err;
+  fd_set fds;
+  struct timeval timeout;
+  
+  log_debug1("starting run routine\n");
+
+  timeout.tv_sec = 1;
+  timeout.tv_usec = 0;
+
+  /* listen to port */
+  err = hsocket_listen(_httpd_socket,15);
+  if (err  != HSOCKET_OK) {
+    log_error2("httpd_run(): '%d'\n", err);
+    return err;
+  }
+
+
+  log_debug2("listening to port '%d'\n", _httpd_port);
+  
+
+  /*  fcntl(_httpd_socket, F_SETFL, O_NONBLOCK);*/
+
+  while (1) {
+    
+    /*FD_ZERO(&fds);
+    FD_SET(_httpd_socket, &fds);
+
+    select(1, &fds, NULL, NULL, &timeout);
+
+    while ( (FD_ISSET(_httpd_socket, &fds)))
+      select(1, &fds, NULL, NULL, &timeout);
+    */   
+    
+  
+    if (hsocket_accept(_httpd_socket, &sockfd) != HSOCKET_OK) {
+      continue;
+    }
+
+
+     conn = (conndata_t*)malloc(sizeof(conndata_t));
+     conn->sock = sockfd;
+
+     err = pthread_create(&tid, NULL, httpd_session_main, conn); 
+     if (err) {
+       printf("Error creating thread: ('%d')\n", err);
+     }
+  }
+
+  return 0;
+}
+
+
diff --git a/nanohttp/nanohttp-server.h b/nanohttp/nanohttp-server.h
new file mode 100644
index 0000000..e246f25
--- /dev/null
+++ b/nanohttp/nanohttp-server.h
@@ -0,0 +1,76 @@
+/******************************************************************
+ *  $Id: nanohttp-server.h,v 1.1 2004/01/21 12:15:30 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
+ ******************************************************************/
+#ifndef NANO_HTTP_SERVER_H 
+#define NANO_HTTP_SERVER_H 
+
+
+#include <nanohttp/nanohttp-common.h>
+#include <nanohttp/nanohttp-socket.h>
+
+
+#define NHTTPD_ARG_PORT "-NHTTPport"
+
+typedef struct httpd_conn
+{
+  hsocket_t sock;
+  char content_type[25];
+}httpd_conn_t;
+
+
+/*
+  Service callback
+ */
+typedef void (*httpd_service)(httpd_conn_t*, hrequest_t*);
+
+
+/*
+ * Service representation object
+ */
+typedef struct tag_hservice
+{
+  char ctx[255];
+  httpd_service func;
+  struct tag_hservice *next;
+}hservice_t;
+
+
+
+/*
+  Begin  httpd_* function set
+ */
+int httpd_init(int argc, char *argv[]);
+int httpd_register(const char* ctx,  httpd_service service);
+int httpd_run();
+void httpd_destroy();
+
+hservice_t *httpd_services();
+
+int httpd_send_header(httpd_conn_t *res, 
+		      int code, const char* text, 
+		      hpair_t *pair);
+
+
+
+#endif
+