Jasper Wallace / Tiny-HTTPD

more handlers

Dependents:   bandwidth-meter-net mbedRail24v

Fork of Tiny-HTTPD by ban4jp -

HTTPD.h@1:5f009a651656, 2014-02-01 (annotated)

Committer:
ban4jp
Date:
Sat Feb 01 15:46:26 2014 +0000
Revision:
1:5f009a651656
Parent:
0:d18dff347122
Child:
2:905fe8dfebd6
Deleted RTOS support. (for low memory platforms.)

Who changed what in which revision?

UserRevisionLine numberNew contents of line
okini3939 0:d18dff347122 1 /* Copyright (C) 2013 Hiroshi Suga, MIT License
okini3939 0:d18dff347122 2 *
okini3939 0:d18dff347122 3 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
okini3939 0:d18dff347122 4 * and associated documentation files (the "Software"), to deal in the Software without restriction,
okini3939 0:d18dff347122 5 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
okini3939 0:d18dff347122 6 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
okini3939 0:d18dff347122 7 * furnished to do so, subject to the following conditions:
okini3939 0:d18dff347122 8 *
okini3939 0:d18dff347122 9 * The above copyright notice and this permission notice shall be included in all copies or
okini3939 0:d18dff347122 10 * substantial portions of the Software.
okini3939 0:d18dff347122 11 *
okini3939 0:d18dff347122 12 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
okini3939 0:d18dff347122 13 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
okini3939 0:d18dff347122 14 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
okini3939 0:d18dff347122 15 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
okini3939 0:d18dff347122 16 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
okini3939 0:d18dff347122 17 */
okini3939 0:d18dff347122 18
okini3939 0:d18dff347122 19 #ifndef HTTPD_H
okini3939 0:d18dff347122 20 #define HTTPD_H
okini3939 0:d18dff347122 21
okini3939 0:d18dff347122 22 #include "mbed.h"
ban4jp 1:5f009a651656 23 //#include "rtos.h"
ban4jp 1:5f009a651656 24 //#include "EthernetInterface.h"
ban4jp 1:5f009a651656 25 #include "TCPSocketServer.h"
okini3939 0:d18dff347122 26 #include "CBuffer.h"
okini3939 0:d18dff347122 27
okini3939 0:d18dff347122 28 //#define DEBUG
okini3939 0:d18dff347122 29
okini3939 0:d18dff347122 30 #define HTTPD_PORT 80
ban4jp 1:5f009a651656 31 //#define HTTPD_MAX_CLIENTS 2
ban4jp 1:5f009a651656 32 #define HTTPD_MAX_CLIENTS 1
okini3939 0:d18dff347122 33 #define HTTPD_KEEPALIVE 10
okini3939 0:d18dff347122 34 #define HTTPD_TIMEOUT 15000
okini3939 0:d18dff347122 35 #define HTTPD_MAX_HANDLES 10
okini3939 0:d18dff347122 36
okini3939 0:d18dff347122 37 #define HTTPD_CMD_SIZE 100
okini3939 0:d18dff347122 38 #define HTTPD_BUF_SIZE 256
okini3939 0:d18dff347122 39 #define HTTPD_STACK_SIZE (1024 * 6)
okini3939 0:d18dff347122 40 //#define HTTPD_ENABLE_CLOSER
okini3939 0:d18dff347122 41
okini3939 0:d18dff347122 42 //Debug is disabled by default
okini3939 0:d18dff347122 43 #if defined(DEBUG) and (!defined(TARGET_LPC11U24))
okini3939 0:d18dff347122 44 #define DBG(x, ...) std::printf("[DBG]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 45 #define WARN(x, ...) std::printf("[WARN]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 46 #define ERR(x, ...) std::printf("[ERR]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 47 #define INFO(x, ...) std::printf("[INFO]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 48 #else
okini3939 0:d18dff347122 49 #define DBG(x, ...)
okini3939 0:d18dff347122 50 #define WARN(x, ...)
okini3939 0:d18dff347122 51 #define ERR(x, ...)
okini3939 0:d18dff347122 52 #define INFO(x, ...)
okini3939 0:d18dff347122 53 #endif
okini3939 0:d18dff347122 54
okini3939 0:d18dff347122 55
okini3939 0:d18dff347122 56 class HTTPD {
okini3939 0:d18dff347122 57 public:
okini3939 0:d18dff347122 58
okini3939 0:d18dff347122 59 enum Request {
okini3939 0:d18dff347122 60 REQ_HTTPGET,
okini3939 0:d18dff347122 61 REQ_HTTPPOST,
okini3939 0:d18dff347122 62 REQ_PUT,
okini3939 0:d18dff347122 63 };
okini3939 0:d18dff347122 64
okini3939 0:d18dff347122 65 enum Mode {
okini3939 0:d18dff347122 66 MODE_REQUEST,
okini3939 0:d18dff347122 67 MODE_REQSTR,
okini3939 0:d18dff347122 68 MODE_HEADER,
okini3939 0:d18dff347122 69 MODE_BODY,
okini3939 0:d18dff347122 70 MODE_ENTER,
okini3939 0:d18dff347122 71 MODE_ERROR,
okini3939 0:d18dff347122 72 MODE_WEBSOCKET,
okini3939 0:d18dff347122 73 MODE_WEBSOCKET_MASK,
okini3939 0:d18dff347122 74 MODE_WEBSOCKET_BODY,
okini3939 0:d18dff347122 75 MODE_WEBSOCKET_ENTER,
okini3939 0:d18dff347122 76 };
okini3939 0:d18dff347122 77
okini3939 0:d18dff347122 78 struct STATE {
ban4jp 1:5f009a651656 79 //Thread *thread;
okini3939 0:d18dff347122 80 TCPSocketConnection *client;
okini3939 0:d18dff347122 81 volatile Request req;
okini3939 0:d18dff347122 82 volatile Mode mode;
okini3939 0:d18dff347122 83 CircBuffer <char>*buf;
okini3939 0:d18dff347122 84 char uri[HTTPD_CMD_SIZE];
okini3939 0:d18dff347122 85 char *filename;
okini3939 0:d18dff347122 86 char *querystring;
okini3939 0:d18dff347122 87 int enter;
okini3939 0:d18dff347122 88 int length;
okini3939 0:d18dff347122 89 int n;
okini3939 0:d18dff347122 90 int keepalive;
okini3939 0:d18dff347122 91 int websocket;
okini3939 0:d18dff347122 92 char *websocket_key;
okini3939 0:d18dff347122 93 int websocket_opcode;
okini3939 0:d18dff347122 94 int websocket_flg;
okini3939 0:d18dff347122 95 char websocket_mask[4];
okini3939 0:d18dff347122 96 int websocket_payload;
okini3939 0:d18dff347122 97 int (*sendws)(int id, const char *buf, int len, const char *mask);
okini3939 0:d18dff347122 98 };
okini3939 0:d18dff347122 99
okini3939 0:d18dff347122 100 HTTPD ();
okini3939 0:d18dff347122 101
okini3939 0:d18dff347122 102 int start (int port = HTTPD_PORT);
ban4jp 1:5f009a651656 103 void poll ();
okini3939 0:d18dff347122 104
okini3939 0:d18dff347122 105 // --- HTTPD_req.cpp ---
okini3939 0:d18dff347122 106 void httpdError (int id, int err);
okini3939 0:d18dff347122 107
okini3939 0:d18dff347122 108 // --- HTTPD_ws.cpp ---
okini3939 0:d18dff347122 109 static int sendWebsocket (int id, const char *buf, int len, const char *mask = NULL);
okini3939 0:d18dff347122 110
okini3939 0:d18dff347122 111 // --- HTTPD_util.cpp ---
okini3939 0:d18dff347122 112 char *getUri (int id);
okini3939 0:d18dff347122 113 char *getFilename (int id);
okini3939 0:d18dff347122 114 char *getQueryString (int id);
okini3939 0:d18dff347122 115 int send (int id, const char *body, int len, const char *header = NULL);
okini3939 0:d18dff347122 116 int receive (int id, char *buf, int len);
okini3939 0:d18dff347122 117 int attach (const char *uri, const char *dir);
okini3939 0:d18dff347122 118 int attach (const char *uri, void (*funcCgi)(int id));
okini3939 0:d18dff347122 119 int base64encode (const char *input, int length, char *output, int len);
okini3939 0:d18dff347122 120 int urlencode (const char *str, char *buf, int len);
okini3939 0:d18dff347122 121 int urldecode (const char *str, char *buf, int len);
okini3939 0:d18dff347122 122
okini3939 0:d18dff347122 123 static HTTPD * getInstance() {
okini3939 0:d18dff347122 124 return _inst;
okini3939 0:d18dff347122 125 };
okini3939 0:d18dff347122 126
okini3939 0:d18dff347122 127 private :
okini3939 0:d18dff347122 128 static HTTPD *_inst;
ban4jp 1:5f009a651656 129 //Thread *_daemon;
okini3939 0:d18dff347122 130 TCPSocketServer _server;
okini3939 0:d18dff347122 131
okini3939 0:d18dff347122 132 #ifdef HTTPD_ENABLE_CLOSER
okini3939 0:d18dff347122 133 struct STATE _state[HTTPD_MAX_CLIENTS + 1];
okini3939 0:d18dff347122 134 #else
okini3939 0:d18dff347122 135 struct STATE _state[HTTPD_MAX_CLIENTS];
okini3939 0:d18dff347122 136 #endif
okini3939 0:d18dff347122 137
okini3939 0:d18dff347122 138 struct HANDLER {
okini3939 0:d18dff347122 139 char *uri;
okini3939 0:d18dff347122 140 char *dir;
okini3939 0:d18dff347122 141 void (*funcCgi)(int id);
okini3939 0:d18dff347122 142 } _handler[HTTPD_MAX_HANDLES];
okini3939 0:d18dff347122 143
okini3939 0:d18dff347122 144 int _handler_count;
okini3939 0:d18dff347122 145
okini3939 0:d18dff347122 146 static void daemon (void const *arg);
okini3939 0:d18dff347122 147 static void child (void const *arg);
okini3939 0:d18dff347122 148 static void closer (void const *arg);
okini3939 0:d18dff347122 149
okini3939 0:d18dff347122 150 // --- HTTPD_req.cpp ---
okini3939 0:d18dff347122 151 int httpdFile (int id, char *dir);
okini3939 0:d18dff347122 152 void recvData (int id, char c);
okini3939 0:d18dff347122 153 int parseRequest (int id);
okini3939 0:d18dff347122 154 int parseHeader (int id);
okini3939 0:d18dff347122 155 void reqContentLength (int id, const char *buf);
okini3939 0:d18dff347122 156 void reqConnection (int id, const char *buf);
okini3939 0:d18dff347122 157 void reqUpgrade (int id, const char *buf);
okini3939 0:d18dff347122 158 void reqWebSocketVersion (int id, const char *buf);
okini3939 0:d18dff347122 159 void reqWebSocketKey (int id, const char *buf);
okini3939 0:d18dff347122 160
okini3939 0:d18dff347122 161 // --- HTTPD_ws.cpp ---
okini3939 0:d18dff347122 162 void recvWS (int id, char c);
okini3939 0:d18dff347122 163 int parseWebsocket (int id);
okini3939 0:d18dff347122 164 int acceptWebsocket (int id);
okini3939 0:d18dff347122 165
okini3939 0:d18dff347122 166 // --- HTTPD_util.cpp ---
okini3939 0:d18dff347122 167 int getHandler (const char *uri);
okini3939 0:d18dff347122 168 char *mimetype (char *file);
okini3939 0:d18dff347122 169 int strnicmp (const char *p1, const char *p2, int n);
okini3939 0:d18dff347122 170 int from_hex (int ch);
okini3939 0:d18dff347122 171 int to_hex (int code);
okini3939 0:d18dff347122 172 };
okini3939 0:d18dff347122 173
okini3939 0:d18dff347122 174 #endif