LRSD stephane / Mbed 2 deprecated WEBserverv3

Dependencies:   mbed

Committer:
geiineuville
Date:
Thu Sep 08 08:57:21 2011 +0000
Revision:
0:9cf1d79ebe04
v0 v1 v2   \"v3\"

Who changed what in which revision?

UserRevisionLine numberNew contents of line
geiineuville 0:9cf1d79ebe04 1 #ifndef HTTPSERVER_H
geiineuville 0:9cf1d79ebe04 2 #define HTTPSERVER_H
geiineuville 0:9cf1d79ebe04 3
geiineuville 0:9cf1d79ebe04 4 #include "TCPConnection.h"
geiineuville 0:9cf1d79ebe04 5 #include "TCPListener.h"
geiineuville 0:9cf1d79ebe04 6 #include "NetServer.h"
geiineuville 0:9cf1d79ebe04 7
geiineuville 0:9cf1d79ebe04 8 #include <map>
geiineuville 0:9cf1d79ebe04 9 #include <set>
geiineuville 0:9cf1d79ebe04 10 #include <list>
geiineuville 0:9cf1d79ebe04 11
geiineuville 0:9cf1d79ebe04 12 #define HTTP_MAX_EMPTYPOLLS 100
geiineuville 0:9cf1d79ebe04 13 #define GET 4
geiineuville 0:9cf1d79ebe04 14 #define POST 5
geiineuville 0:9cf1d79ebe04 15
geiineuville 0:9cf1d79ebe04 16 //extern unsigned int gconnections;
geiineuville 0:9cf1d79ebe04 17
geiineuville 0:9cf1d79ebe04 18 using namespace std;
geiineuville 0:9cf1d79ebe04 19
geiineuville 0:9cf1d79ebe04 20 namespace mbed {
geiineuville 0:9cf1d79ebe04 21
geiineuville 0:9cf1d79ebe04 22 class HTTPServer;
geiineuville 0:9cf1d79ebe04 23 class HTTPHandler;
geiineuville 0:9cf1d79ebe04 24 class HTTPConnection;
geiineuville 0:9cf1d79ebe04 25
geiineuville 0:9cf1d79ebe04 26 /**
geiineuville 0:9cf1d79ebe04 27 * A simple HASH function to reduce the size of stored Header Fields
geiineuville 0:9cf1d79ebe04 28 * TODO: Make the Hash case insensetive.
geiineuville 0:9cf1d79ebe04 29 */
geiineuville 0:9cf1d79ebe04 30 unsigned int hash(unsigned char *str);
geiineuville 0:9cf1d79ebe04 31
geiineuville 0:9cf1d79ebe04 32 /**
geiineuville 0:9cf1d79ebe04 33 * The Status of an HTTP Request
geiineuville 0:9cf1d79ebe04 34 * Nedded for HTTPHandler subclasses to define there reults in the HTTPHandler:init Method.
geiineuville 0:9cf1d79ebe04 35 */
geiineuville 0:9cf1d79ebe04 36 enum HTTPStatus {
geiineuville 0:9cf1d79ebe04 37 HTTP_OK = 200,
geiineuville 0:9cf1d79ebe04 38 HTTP_BadRequest = 400,
geiineuville 0:9cf1d79ebe04 39 HTTP_Unauthorized = 401,
geiineuville 0:9cf1d79ebe04 40 HTTP_Forbidden = 403,
geiineuville 0:9cf1d79ebe04 41 HTTP_NotFound = 404,
geiineuville 0:9cf1d79ebe04 42 HTTP_MethodNotAllowed = 405,
geiineuville 0:9cf1d79ebe04 43 HTTP_InternalServerError = 500,
geiineuville 0:9cf1d79ebe04 44 HTTP_NotImplemented = 501,
geiineuville 0:9cf1d79ebe04 45 };
geiineuville 0:9cf1d79ebe04 46
geiineuville 0:9cf1d79ebe04 47 /**
geiineuville 0:9cf1d79ebe04 48 * The result of a chunk of data used for the HTTPHandler Methodes data and send
geiineuville 0:9cf1d79ebe04 49 */
geiineuville 0:9cf1d79ebe04 50 enum HTTPHandle {
geiineuville 0:9cf1d79ebe04 51 /** Execution Succeeded but more data expected. */
geiineuville 0:9cf1d79ebe04 52 HTTP_Success = 600,
geiineuville 0:9cf1d79ebe04 53
geiineuville 0:9cf1d79ebe04 54 /** Running out of memory waiting for memory */
geiineuville 0:9cf1d79ebe04 55 HTTP_SenderMemory = 601,
geiineuville 0:9cf1d79ebe04 56
geiineuville 0:9cf1d79ebe04 57
geiineuville 0:9cf1d79ebe04 58 /** Execution Succeeded and no more data expected. */
geiineuville 0:9cf1d79ebe04 59 HTTP_SuccessEnded = 700,
geiineuville 0:9cf1d79ebe04 60
geiineuville 0:9cf1d79ebe04 61 /** Execution failed. Close conection*/
geiineuville 0:9cf1d79ebe04 62 HTTP_Failed = 701,
geiineuville 0:9cf1d79ebe04 63
geiineuville 0:9cf1d79ebe04 64 /** This module will deliver the data. */
geiineuville 0:9cf1d79ebe04 65 HTTP_Deliver = 800,
geiineuville 0:9cf1d79ebe04 66
geiineuville 0:9cf1d79ebe04 67 /** This module has add header fields to the request. */
geiineuville 0:9cf1d79ebe04 68 HTTP_AddFields = 801,
geiineuville 0:9cf1d79ebe04 69 };
geiineuville 0:9cf1d79ebe04 70
geiineuville 0:9cf1d79ebe04 71 /**
geiineuville 0:9cf1d79ebe04 72 * A parent object for a data storage container for all HTTPHandler objects.
geiineuville 0:9cf1d79ebe04 73 */
geiineuville 0:9cf1d79ebe04 74 class HTTPData {
geiineuville 0:9cf1d79ebe04 75 public:
geiineuville 0:9cf1d79ebe04 76 HTTPData() {}
geiineuville 0:9cf1d79ebe04 77 virtual ~HTTPData() {}
geiineuville 0:9cf1d79ebe04 78 };
geiineuville 0:9cf1d79ebe04 79
geiineuville 0:9cf1d79ebe04 80 /**
geiineuville 0:9cf1d79ebe04 81 * A HTTPHandler will serve the requested data if there is an object of a
geiineuville 0:9cf1d79ebe04 82 * child class from HTTPHandler which is registert to an matching prefix.
geiineuville 0:9cf1d79ebe04 83 * To see how to implement your own HTTPHandler classes have a look at
geiineuville 0:9cf1d79ebe04 84 * HTTPRPC HTTPStaticPage and HTTPFileSystemHandler.
geiineuville 0:9cf1d79ebe04 85 */
geiineuville 0:9cf1d79ebe04 86 class HTTPHandler {
geiineuville 0:9cf1d79ebe04 87 public:
geiineuville 0:9cf1d79ebe04 88 HTTPHandler(const char *prefix) : _prefix(prefix) {};
geiineuville 0:9cf1d79ebe04 89 virtual ~HTTPHandler() {
geiineuville 0:9cf1d79ebe04 90 delete _prefix;
geiineuville 0:9cf1d79ebe04 91 };
geiineuville 0:9cf1d79ebe04 92
geiineuville 0:9cf1d79ebe04 93 protected:
geiineuville 0:9cf1d79ebe04 94 /**
geiineuville 0:9cf1d79ebe04 95 * Register needed header fields by the HTTPServer.
geiineuville 0:9cf1d79ebe04 96 * Because of memory size the server will throw away all request header fields which are not registert.
geiineuville 0:9cf1d79ebe04 97 * Register the fields you need in your implementation of this method.
geiineuville 0:9cf1d79ebe04 98 */
geiineuville 0:9cf1d79ebe04 99 virtual void reg(HTTPServer *) {};
geiineuville 0:9cf1d79ebe04 100
geiineuville 0:9cf1d79ebe04 101 /**
geiineuville 0:9cf1d79ebe04 102 * This Method returns if you will deliver the requested page or not.
geiineuville 0:9cf1d79ebe04 103 * It will only executed if the prefix is matched by the URL.
geiineuville 0:9cf1d79ebe04 104 * If you want to add something to the headerfiles use this method and return HTTP_AddFields. See HTTPFields
geiineuville 0:9cf1d79ebe04 105 * This would be the right method to implement an Auth Handler.
geiineuville 0:9cf1d79ebe04 106 */
geiineuville 0:9cf1d79ebe04 107 virtual HTTPHandle action(HTTPConnection *) const {return HTTP_Deliver;}
geiineuville 0:9cf1d79ebe04 108
geiineuville 0:9cf1d79ebe04 109 /**
geiineuville 0:9cf1d79ebe04 110 * If action returned HTTP_Deliver.
geiineuville 0:9cf1d79ebe04 111 * This function will be executed and it means your handler will be deliver the requested data.
geiineuville 0:9cf1d79ebe04 112 * In this method is the right place to allocate the needed space for your request data and to prepare the sended Header.
geiineuville 0:9cf1d79ebe04 113 */
geiineuville 0:9cf1d79ebe04 114 virtual HTTPStatus init(HTTPConnection *) const {return HTTP_NotFound;}
geiineuville 0:9cf1d79ebe04 115
geiineuville 0:9cf1d79ebe04 116 /**
geiineuville 0:9cf1d79ebe04 117 * If data from a post request is arrived for an request you accepted this function will be executed with the data.
geiineuville 0:9cf1d79ebe04 118 * @param data A pointer to the received data.
geiineuville 0:9cf1d79ebe04 119 * @param len The length of the received data.
geiineuville 0:9cf1d79ebe04 120 * @return Return an HTTPHandle. For example HTTP_SuccessEnded if you received all your needed data and want to close the conection (normally not the case).
geiineuville 0:9cf1d79ebe04 121 */
geiineuville 0:9cf1d79ebe04 122 virtual HTTPHandle data(HTTPConnection *, void *data, int len) const {return HTTP_SuccessEnded;}
geiineuville 0:9cf1d79ebe04 123
geiineuville 0:9cf1d79ebe04 124 /**
geiineuville 0:9cf1d79ebe04 125 * If tere is new space in the sendbuffer this function is executed. You can send maximal Bytes of data.
geiineuville 0:9cf1d79ebe04 126 * @return Return an HTTPHandle. For example HTTP_SuccessEnded if you send out all your data and you want to close the connection.
geiineuville 0:9cf1d79ebe04 127 */
geiineuville 0:9cf1d79ebe04 128 virtual HTTPHandle send(HTTPConnection *, int) const {return HTTP_SuccessEnded;}
geiineuville 0:9cf1d79ebe04 129
geiineuville 0:9cf1d79ebe04 130 /**
geiineuville 0:9cf1d79ebe04 131 * returns the Prefix from the HTTPHandler
geiineuville 0:9cf1d79ebe04 132 */
geiineuville 0:9cf1d79ebe04 133 const char *getPrefix() const {return _prefix;}
geiineuville 0:9cf1d79ebe04 134
geiineuville 0:9cf1d79ebe04 135 const char *_prefix;
geiineuville 0:9cf1d79ebe04 136
geiineuville 0:9cf1d79ebe04 137 friend HTTPServer;
geiineuville 0:9cf1d79ebe04 138 friend HTTPConnection;
geiineuville 0:9cf1d79ebe04 139 };
geiineuville 0:9cf1d79ebe04 140
geiineuville 0:9cf1d79ebe04 141 /**
geiineuville 0:9cf1d79ebe04 142 * For every incomming connection we have a HTTPConnection object which will handle the requests of this connection.
geiineuville 0:9cf1d79ebe04 143 */
geiineuville 0:9cf1d79ebe04 144 class HTTPConnection : public TCPConnection {
geiineuville 0:9cf1d79ebe04 145 public:
geiineuville 0:9cf1d79ebe04 146 /**
geiineuville 0:9cf1d79ebe04 147 * Constructs a new connection object from a server.
geiineuville 0:9cf1d79ebe04 148 * It just need the server object to contact the handlers
geiineuville 0:9cf1d79ebe04 149 * and the tcp connection pcb.
geiineuville 0:9cf1d79ebe04 150 * @param parent The server which created the connection.
geiineuville 0:9cf1d79ebe04 151 * @param pcb The pcb object NetServers internal representation of an TCP Connection
geiineuville 0:9cf1d79ebe04 152 */
geiineuville 0:9cf1d79ebe04 153 HTTPConnection(HTTPServer *parent, struct tcp_pcb *pcb);
geiineuville 0:9cf1d79ebe04 154 /**
geiineuville 0:9cf1d79ebe04 155 * Default destructor. Simple cleanup.
geiineuville 0:9cf1d79ebe04 156 */
geiineuville 0:9cf1d79ebe04 157 virtual ~HTTPConnection();
geiineuville 0:9cf1d79ebe04 158
geiineuville 0:9cf1d79ebe04 159 /**
geiineuville 0:9cf1d79ebe04 160 * Get the requested url.
geiineuville 0:9cf1d79ebe04 161 * Only set if a request ist received.
geiineuville 0:9cf1d79ebe04 162 */
geiineuville 0:9cf1d79ebe04 163 char *getURL() const { return _request_url; }
geiineuville 0:9cf1d79ebe04 164
geiineuville 0:9cf1d79ebe04 165 /**
geiineuville 0:9cf1d79ebe04 166 * Gets a string of set fields to send with the answere header.
geiineuville 0:9cf1d79ebe04 167 */
geiineuville 0:9cf1d79ebe04 168 const char *getHeaderFields() const { return (_request_headerfields)?_request_headerfields:""; }
geiineuville 0:9cf1d79ebe04 169
geiineuville 0:9cf1d79ebe04 170 /**
geiineuville 0:9cf1d79ebe04 171 * Gets the length of the anwere in bytes. This is requiered for the HTTP Header.
geiineuville 0:9cf1d79ebe04 172 * It should be set over setLength by an HTTPHandler in the init() method.
geiineuville 0:9cf1d79ebe04 173 */
geiineuville 0:9cf1d79ebe04 174 const int &getLength() const { return _request_length; }
geiineuville 0:9cf1d79ebe04 175
geiineuville 0:9cf1d79ebe04 176 /**
geiineuville 0:9cf1d79ebe04 177 * Gets POST or GET or 0 depends on wether ther is a request and what type is requested.
geiineuville 0:9cf1d79ebe04 178 */
geiineuville 0:9cf1d79ebe04 179 const char &getType() const { return _request_type; }
geiineuville 0:9cf1d79ebe04 180
geiineuville 0:9cf1d79ebe04 181 /**
geiineuville 0:9cf1d79ebe04 182 * Gets a value from a header field of the request header.
geiineuville 0:9cf1d79ebe04 183 * But you must have registerd this headerfield by the HTTPServer before.
geiineuville 0:9cf1d79ebe04 184 * Use the HTTPHandler::reg() method for the registration of important header fields for your Handler.
geiineuville 0:9cf1d79ebe04 185 */
geiineuville 0:9cf1d79ebe04 186 const char *getField(char *key) const;
geiineuville 0:9cf1d79ebe04 187
geiineuville 0:9cf1d79ebe04 188 /**
geiineuville 0:9cf1d79ebe04 189 * For internal usage. Adds an header field value to its hash.
geiineuville 0:9cf1d79ebe04 190 * If it was registered You can see the Value with the getField method
geiineuville 0:9cf1d79ebe04 191 */
geiineuville 0:9cf1d79ebe04 192 void addField(char *key, char *value);
geiineuville 0:9cf1d79ebe04 193
geiineuville 0:9cf1d79ebe04 194 /**
geiineuville 0:9cf1d79ebe04 195 * Sets the result length for an request shoud be set in an HTTPHandler.init() call.
geiineuville 0:9cf1d79ebe04 196 * This Value will be send with the response header before the first chunk of data is send.
geiineuville 0:9cf1d79ebe04 197 */
geiineuville 0:9cf1d79ebe04 198 void setLength(const int &value) { _request_length = value; }
geiineuville 0:9cf1d79ebe04 199
geiineuville 0:9cf1d79ebe04 200 /**
geiineuville 0:9cf1d79ebe04 201 * Set the response header field to a value.
geiineuville 0:9cf1d79ebe04 202 * Should be used in the HTTPHandler::init() method.
geiineuville 0:9cf1d79ebe04 203 * For example if you want to set caching methods.
geiineuville 0:9cf1d79ebe04 204 */
geiineuville 0:9cf1d79ebe04 205 void setHeaderFields(char *value) { _request_headerfields = value; }
geiineuville 0:9cf1d79ebe04 206
geiineuville 0:9cf1d79ebe04 207 /** Indicates that if a request is received the header is incomplete until now. */
geiineuville 0:9cf1d79ebe04 208 bool request_incomplete;
geiineuville 0:9cf1d79ebe04 209
geiineuville 0:9cf1d79ebe04 210 /** If an request is complete HTTPHandler:init will be called and can store here its connection data. */
geiineuville 0:9cf1d79ebe04 211 HTTPData *data;
geiineuville 0:9cf1d79ebe04 212
geiineuville 0:9cf1d79ebe04 213 /** The handler which handles the current request. Depends on the prefix of the URL. */
geiineuville 0:9cf1d79ebe04 214 HTTPHandler *request_handler;
geiineuville 0:9cf1d79ebe04 215
geiineuville 0:9cf1d79ebe04 216 /** The status of the request. Will be set as result of HTTPHandler::init. */
geiineuville 0:9cf1d79ebe04 217 HTTPStatus request_status;
geiineuville 0:9cf1d79ebe04 218
geiineuville 0:9cf1d79ebe04 219 /** The HTTTPServer which created this connection. */
geiineuville 0:9cf1d79ebe04 220 HTTPServer *parent;
geiineuville 0:9cf1d79ebe04 221 private:
geiineuville 0:9cf1d79ebe04 222 virtual void err(err_t err);
geiineuville 0:9cf1d79ebe04 223 virtual err_t poll();
geiineuville 0:9cf1d79ebe04 224 virtual err_t sent(u16_t len);
geiineuville 0:9cf1d79ebe04 225 virtual err_t recv(struct pbuf *q, err_t err);
geiineuville 0:9cf1d79ebe04 226
geiineuville 0:9cf1d79ebe04 227 /** We will not make any DNS requests. */
geiineuville 0:9cf1d79ebe04 228 virtual void dnsreply(const char *, struct ip_addr *) {}
geiineuville 0:9cf1d79ebe04 229
geiineuville 0:9cf1d79ebe04 230 /** If a request is finished it will be deleted with this method. Simple cleanup. */
geiineuville 0:9cf1d79ebe04 231 void deleteRequest();
geiineuville 0:9cf1d79ebe04 232
geiineuville 0:9cf1d79ebe04 233 /** Call the handler to send the next chunk of data. */
geiineuville 0:9cf1d79ebe04 234 void send();
geiineuville 0:9cf1d79ebe04 235
geiineuville 0:9cf1d79ebe04 236 /** Call the handler if we received new data. */
geiineuville 0:9cf1d79ebe04 237 void store(void *d, struct pbuf *p);
geiineuville 0:9cf1d79ebe04 238
geiineuville 0:9cf1d79ebe04 239 /**
geiineuville 0:9cf1d79ebe04 240 * If a request header is not complete we can colect needed header fields.
geiineuville 0:9cf1d79ebe04 241 * This happens in here.
geiineuville 0:9cf1d79ebe04 242 */
geiineuville 0:9cf1d79ebe04 243 void getFields(struct pbuf **q, char **d);
geiineuville 0:9cf1d79ebe04 244
geiineuville 0:9cf1d79ebe04 245 char *_request_url;
geiineuville 0:9cf1d79ebe04 246 char _request_type;
geiineuville 0:9cf1d79ebe04 247 char *_request_headerfields;
geiineuville 0:9cf1d79ebe04 248 map<unsigned int, char *> _request_fields;
geiineuville 0:9cf1d79ebe04 249 int _request_length;
geiineuville 0:9cf1d79ebe04 250 char *_request_arg_key;
geiineuville 0:9cf1d79ebe04 251 char *_request_arg_value;
geiineuville 0:9cf1d79ebe04 252 char _request_arg_state;
geiineuville 0:9cf1d79ebe04 253
geiineuville 0:9cf1d79ebe04 254 unsigned int emptypolls; // Last time for timeout
geiineuville 0:9cf1d79ebe04 255 unsigned int _timeout_max;
geiineuville 0:9cf1d79ebe04 256 };
geiineuville 0:9cf1d79ebe04 257
geiineuville 0:9cf1d79ebe04 258 /* Class HTTPServer
geiineuville 0:9cf1d79ebe04 259 * An object of this class is an HTTPServer instance and will anwere requests on a given port.
geiineuville 0:9cf1d79ebe04 260 * It will deliver HTTP pages
geiineuville 0:9cf1d79ebe04 261 */
geiineuville 0:9cf1d79ebe04 262 class HTTPServer : public TCPListener {
geiineuville 0:9cf1d79ebe04 263 public:
geiineuville 0:9cf1d79ebe04 264
geiineuville 0:9cf1d79ebe04 265 /* Constructor: HTTPServer
geiineuville 0:9cf1d79ebe04 266 * Creates an HTTPServer object. You might want to initialise the network server befor.
geiineuville 0:9cf1d79ebe04 267 * If you dont do it it will be happen by the first post or get request you make.
geiineuville 0:9cf1d79ebe04 268 *
geiineuville 0:9cf1d79ebe04 269 * To initialize the network server on creation of the HTTPServer object it's possible to parse some arguments:
geiineuville 0:9cf1d79ebe04 270 * Variables:
geiineuville 0:9cf1d79ebe04 271 * hostname - A host name for the device. Might take a while to appear in the network,
geiineuville 0:9cf1d79ebe04 272 * depends on the network infrastructure. Furthermore in most cases you have
geiineuville 0:9cf1d79ebe04 273 * to add your domainname after the host name to address the device.
geiineuville 0:9cf1d79ebe04 274 * Default is NULL.
geiineuville 0:9cf1d79ebe04 275 * ip - The device ipaddress or ip_addr_any for dhcp. Default is ip_addr_any
geiineuville 0:9cf1d79ebe04 276 * nm - The device netmask or ip_addr_any for dhcp. Default is ip_addr_any.
geiineuville 0:9cf1d79ebe04 277 * gw - The device gateway or ip_addr_any for dhcp. Default is ip_addr_any.
geiineuville 0:9cf1d79ebe04 278 * dns - The device first dns server ip or ip_addr_any for dhcp. Default is ip_addr_any.
geiineuville 0:9cf1d79ebe04 279 *
geiineuville 0:9cf1d79ebe04 280 * Example:
geiineuville 0:9cf1d79ebe04 281 * > HTTPServer http; // Simple DHCP, brings up the TCP/IP stack on bind(). Default prot is port 80.
geiineuville 0:9cf1d79ebe04 282 * > HTTPServer http(8080); // Port is here 8080.
geiineuville 0:9cf1d79ebe04 283 *
geiineuville 0:9cf1d79ebe04 284 * > HTTPServer http("worf"); // Brings up the device with DHCP and sets the host name "worf"
geiineuville 0:9cf1d79ebe04 285 * > // The device will be available under worf.<your local domain>
geiineuville 0:9cf1d79ebe04 286 * > // for example worf.1-2-3-4.dynamic.sky.com
geiineuville 0:9cf1d79ebe04 287 *
geiineuville 0:9cf1d79ebe04 288 * > HTTPServer http("wolf", // Brings up the device with static IP address and domain name.
geiineuville 0:9cf1d79ebe04 289 * > IPv4(192,168,0,44), // IPv4 is a helper function which allows to rtype ipaddresses direct
geiineuville 0:9cf1d79ebe04 290 * > IPv4(255,255,255,0), // as numbers in C++.
geiineuville 0:9cf1d79ebe04 291 * > IPv4(192,168,0,1), // the device address is set to 192.168.0.44, netmask 255.255.255.0
geiineuville 0:9cf1d79ebe04 292 * > IPv4(192,168,0,1) // default gateway is 192.168.0.1 and dns to 192.168.0.1 as well.
geiineuville 0:9cf1d79ebe04 293 * > 8080); // And port is on 8080. Default port is 80.
geiineuville 0:9cf1d79ebe04 294 */
geiineuville 0:9cf1d79ebe04 295
geiineuville 0:9cf1d79ebe04 296 HTTPServer(const char *hostname, struct ip_addr ip = ip_addr_any, struct ip_addr nm = ip_addr_any, struct ip_addr gw = ip_addr_any, struct ip_addr dns = ip_addr_any, unsigned short port = 80);
geiineuville 0:9cf1d79ebe04 297 HTTPServer(unsigned short port = 80);
geiineuville 0:9cf1d79ebe04 298
geiineuville 0:9cf1d79ebe04 299 /* Destructor: ~HTTPServer
geiineuville 0:9cf1d79ebe04 300 * Destroys the HTTPServer and all open connections.
geiineuville 0:9cf1d79ebe04 301 */
geiineuville 0:9cf1d79ebe04 302 virtual ~HTTPServer() {
geiineuville 0:9cf1d79ebe04 303 fields.clear();
geiineuville 0:9cf1d79ebe04 304 _handler.clear();
geiineuville 0:9cf1d79ebe04 305 }
geiineuville 0:9cf1d79ebe04 306
geiineuville 0:9cf1d79ebe04 307 /* Function: addHandler
geiineuville 0:9cf1d79ebe04 308 * Add a new content handler to handle requests.
geiineuville 0:9cf1d79ebe04 309 * Content handler are URL prefix specific.
geiineuville 0:9cf1d79ebe04 310 * Have a look at HTTPRPC and HTTPFileSystemHandler for examples.
geiineuville 0:9cf1d79ebe04 311 */
geiineuville 0:9cf1d79ebe04 312 virtual void addHandler(HTTPHandler *handler) {
geiineuville 0:9cf1d79ebe04 313 _handler.push_back(handler);
geiineuville 0:9cf1d79ebe04 314 handler->reg(this);
geiineuville 0:9cf1d79ebe04 315 }
geiineuville 0:9cf1d79ebe04 316
geiineuville 0:9cf1d79ebe04 317 /* Function registerField
geiineuville 0:9cf1d79ebe04 318 * Register needed header fields to filter from a request header.
geiineuville 0:9cf1d79ebe04 319 * Should be called from HTTPHandler::reg()
geiineuville 0:9cf1d79ebe04 320 */
geiineuville 0:9cf1d79ebe04 321 virtual void registerField(char *name) {
geiineuville 0:9cf1d79ebe04 322 fields.insert(hash((unsigned char *)name));
geiineuville 0:9cf1d79ebe04 323 }
geiineuville 0:9cf1d79ebe04 324
geiineuville 0:9cf1d79ebe04 325 /* Function isField
geiineuville 0:9cf1d79ebe04 326 * A short lookup if the headerfield is registerd.
geiineuville 0:9cf1d79ebe04 327 */
geiineuville 0:9cf1d79ebe04 328 virtual bool isField(unsigned long h) const {
geiineuville 0:9cf1d79ebe04 329 return fields.find(h) != fields.end();
geiineuville 0:9cf1d79ebe04 330 }
geiineuville 0:9cf1d79ebe04 331
geiineuville 0:9cf1d79ebe04 332 /* Function: poll
geiineuville 0:9cf1d79ebe04 333 * You have to call this method at least every 250ms to let the http server run.
geiineuville 0:9cf1d79ebe04 334 * But I would recomend to call this function as fast as possible.
geiineuville 0:9cf1d79ebe04 335 * This function is directly coupled to the answere time of your HTTPServer instance.
geiineuville 0:9cf1d79ebe04 336 */
geiineuville 0:9cf1d79ebe04 337 inline static void poll() {
geiineuville 0:9cf1d79ebe04 338 NetServer::poll();
geiineuville 0:9cf1d79ebe04 339 }
geiineuville 0:9cf1d79ebe04 340
geiineuville 0:9cf1d79ebe04 341 /* Function: timeout
geiineuville 0:9cf1d79ebe04 342 * Sets the timout for a HTTP request.
geiineuville 0:9cf1d79ebe04 343 * The timout is the time wich is allowed to spent between two incomming TCP packets.
geiineuville 0:9cf1d79ebe04 344 * If the time is passed the connection will be closed.
geiineuville 0:9cf1d79ebe04 345 */
geiineuville 0:9cf1d79ebe04 346 void timeout(int value) {
geiineuville 0:9cf1d79ebe04 347 _timeout_max = value;
geiineuville 0:9cf1d79ebe04 348 }
geiineuville 0:9cf1d79ebe04 349
geiineuville 0:9cf1d79ebe04 350 /* Function timeout
geiineuville 0:9cf1d79ebe04 351 * Returns the timout to use it in HTTPHandlers and HTTPConnections
geiineuville 0:9cf1d79ebe04 352 */
geiineuville 0:9cf1d79ebe04 353 int timeout() {
geiineuville 0:9cf1d79ebe04 354 return _timeout_max;
geiineuville 0:9cf1d79ebe04 355 }
geiineuville 0:9cf1d79ebe04 356 private:
geiineuville 0:9cf1d79ebe04 357 /**
geiineuville 0:9cf1d79ebe04 358 * Pick up the right handler to deliver the response.
geiineuville 0:9cf1d79ebe04 359 */
geiineuville 0:9cf1d79ebe04 360 virtual HTTPHandler *handle(HTTPConnection *con) const {
geiineuville 0:9cf1d79ebe04 361 for(list<HTTPHandler *>::const_iterator iter = _handler.begin();
geiineuville 0:9cf1d79ebe04 362 iter != _handler.end(); iter++) {
geiineuville 0:9cf1d79ebe04 363 if(strncmp((*iter)->getPrefix(), con->getURL(), strlen((*iter)->getPrefix()))==0) {
geiineuville 0:9cf1d79ebe04 364 HTTPHandler *handler = *iter;
geiineuville 0:9cf1d79ebe04 365 if(handler->action(con)==HTTP_Deliver) {
geiineuville 0:9cf1d79ebe04 366 return *iter;
geiineuville 0:9cf1d79ebe04 367 }
geiineuville 0:9cf1d79ebe04 368 }
geiineuville 0:9cf1d79ebe04 369 }
geiineuville 0:9cf1d79ebe04 370 return NULL;
geiineuville 0:9cf1d79ebe04 371 }
geiineuville 0:9cf1d79ebe04 372
geiineuville 0:9cf1d79ebe04 373 /**
geiineuville 0:9cf1d79ebe04 374 * Accept an incomming connection and fork a HTTPConnection if we have enought memory.
geiineuville 0:9cf1d79ebe04 375 */
geiineuville 0:9cf1d79ebe04 376 virtual err_t accept(struct tcp_pcb *pcb, err_t err) {
geiineuville 0:9cf1d79ebe04 377 LWIP_UNUSED_ARG(err);
geiineuville 0:9cf1d79ebe04 378 HTTPConnection *con = new HTTPConnection(this, pcb);
geiineuville 0:9cf1d79ebe04 379 // printf("New Connection opend. Now are %u connections open\n", ++gconnections);
geiineuville 0:9cf1d79ebe04 380 if(con == NULL) {
geiineuville 0:9cf1d79ebe04 381 printf("http_accept: Out of memory\n");
geiineuville 0:9cf1d79ebe04 382 return ERR_MEM;
geiineuville 0:9cf1d79ebe04 383 }
geiineuville 0:9cf1d79ebe04 384 con->set_poll_interval(1);
geiineuville 0:9cf1d79ebe04 385 tcp_setprio(pcb, TCP_PRIO_MIN);
geiineuville 0:9cf1d79ebe04 386 return ERR_OK;
geiineuville 0:9cf1d79ebe04 387 }
geiineuville 0:9cf1d79ebe04 388
geiineuville 0:9cf1d79ebe04 389 /** The registerd request header fields */
geiineuville 0:9cf1d79ebe04 390 set<unsigned int> fields;
geiineuville 0:9cf1d79ebe04 391
geiineuville 0:9cf1d79ebe04 392 /** A List of all registered handler. */
geiineuville 0:9cf1d79ebe04 393 list<HTTPHandler *> _handler;
geiineuville 0:9cf1d79ebe04 394
geiineuville 0:9cf1d79ebe04 395 int _timeout_max;
geiineuville 0:9cf1d79ebe04 396
geiineuville 0:9cf1d79ebe04 397 friend HTTPConnection;
geiineuville 0:9cf1d79ebe04 398 };
geiineuville 0:9cf1d79ebe04 399
geiineuville 0:9cf1d79ebe04 400 };
geiineuville 0:9cf1d79ebe04 401
geiineuville 0:9cf1d79ebe04 402 #include "HTTPRPC.h"
geiineuville 0:9cf1d79ebe04 403 #include "HTTPFS.h"
geiineuville 0:9cf1d79ebe04 404 #include "HTTPFields.h"
geiineuville 0:9cf1d79ebe04 405
geiineuville 0:9cf1d79ebe04 406 #endif /* HTTP_H */