Populating trunk

git-svn-id: http://svncommunity.digium.com/svn/astmanproxy/trunk@26 f02b47b9-160a-0410-81a6-dc3441afb0ec

1 files changed, 137 insertions, 0 deletions

diff --git a/http.c b/http.c
new file mode 100644
index 0000000..6b5580d
--- /dev/null
+++ b/http.c
@@ -0,0 +1,137 @@
+/* Asterisk Manager Proxy
+   Copyright (c) 2005 David C. Troy <dave@popvox.com>
+
+   This program is free software, distributed under the terms of
+   the GNU General Public License.
+
+   HTTP Input Handler
+*/
+
+#include "astmanproxy.h"
+
+int ParseHTTPInput(char *buf, struct message *m) {
+    char *n, *v;
+
+    /* just an empty block; go home
+    if ( !(*buf) )
+        return 0; */
+
+    /* initialize message block */
+    memset(m, 0, sizeof (struct message) );
+
+    n = buf;
+    while ( (v = strstr(n, "=")) ) {
+       v += 1;
+       debugmsg("n: %s, v: %s", n, v);
+       strncat(m->headers[m->hdrcount], n, v-n-1);
+       strcat(m->headers[m->hdrcount], ": ");
+
+       if ( (n = strstr(v, "&")) ) {
+          n += 1;
+       } else {
+          n = (v + strlen(v) + 1);
+       }
+       strncat(m->headers[m->hdrcount], v, n-v-1);
+       debugmsg("got hdr: %s", m->headers[m->hdrcount]);
+       m->hdrcount++;
+    }
+
+    return (m->hdrcount > 0);
+}
+
+int BuildHTTPHeader(char *hdr) {
+
+
+    time_t t;
+    struct tm tm;
+    char date[80];
+
+    time(&t);
+    localtime_r(&t, &tm);
+    strftime(date, sizeof(date), "%a, %d %b %Y %H:%M:%S %z", &tm);
+
+    sprintf(hdr,
+       "HTTP/1.1 200 OK\r\n"
+       "Date: %s\r\n"
+       "Content-Type: text/xml\r\n"
+       "Connection: close\r\n"
+       "Server: %s/%s\r\n\r\n",
+       date, PROXY_BANNER, PROXY_VERSION);
+
+    return 0;
+}
+
+int _read(struct mansession *s, struct message *m) {
+
+    /* Note: No single line may be longer than MAX_LEN/s->inbuf, as per get_input */
+    /* No HTTP Input may be longer than BUFSIZE */
+
+    char line[MAX_LEN], method[10], formdata[MAX_LEN], header[MAX_LEN];
+    int res, clength = 0;
+
+    if (s->inputcomplete)
+        return 0;
+
+    memset(method, 0, sizeof method);
+    memset(formdata, 0, sizeof formdata);
+
+    /* for http, don't do get_input forever */
+    for (;;) {
+        memset(line, 0, sizeof line);
+        res = get_input(s, line);
+
+        if (res > 0) {
+            if (*line == '\0' ) {
+                if (*method == '\0')
+                    break;
+                else {
+                    if ( !strcasecmp(method, "POST") ) {
+                        pthread_mutex_lock(&s->lock);
+                        strncpy(formdata, s->inbuf, clength);
+                        /* Move remaining data back to the front */
+                        memmove(s->inbuf, s->inbuf + clength+1, s->inlen - clength);
+                        s->inlen -= clength;
+                        pthread_mutex_unlock(&s->lock);
+                    }
+                    debugmsg("method: %s", method);
+                    debugmsg("clength: %d", clength);
+                    debugmsg("formdata: %s", formdata);
+                    debugmsg("s->inbuf: %s", s->inbuf);
+                    debugmsg("s->inlen: %d", s->inlen);
+
+                    BuildHTTPHeader(header);
+                    pthread_mutex_lock(&s->lock);
+                    s->inputcomplete = 1;
+                    write(s->fd, header, strlen(header));
+                    pthread_mutex_unlock(&s->lock);
+                    debugmsg("header: %s", header);
+
+                    /* now, let's transform and copy into a standard message block */
+                    res = ParseHTTPInput(formdata, m);
+                    return res;
+                }
+            } else {
+                debugmsg("Got http: %s", line);
+                /* Do meaningful things here */
+                if ( !strncmp(line,"POST",4) ) {
+                    strncpy(method, line, 4);
+                } else if ( !strncmp(line,"GET",3) ) {
+                    /* GET /?Action=Ping&ActionID=Foo HTTP/1.1 */
+                    strncpy(method, line, 3);
+                    memcpy(formdata, line+6, strstr(line, " HTTP")-line-6);
+                } else if ( !strncasecmp(line, "Content-Length: ", 16) ) {
+                    clength = atoi(line+16);
+                }
+            }
+        } else if (res < 0)
+            return res;
+    }
+
+    return -1;
+}
+
+int _autodisconnect() {
+    return 1;
+}
+
+/* We do not define a _write or _onconnect method */