1 files changed, 92 insertions, 0 deletions
diff --git a/src/uscxml/server/HTTPServer.h b/src/uscxml/server/HTTPServer.h
new file mode 100644
index 0000000..597c749
--- /dev/null
+++ b/src/uscxml/server/HTTPServer.h
@@ -0,0 +1,92 @@
+#ifndef HTTPSERVER_H_AIH108EG
+#define HTTPSERVER_H_AIH108EG
+
+#include <string>
+#include <map>
+
+#include <event2/http.h>
+
+#include "uscxml/concurrency/tinythread.h"
+
+namespace uscxml {
+
+class HTTPServlet;
+  
+class HTTPServer {
+public:
+  class Request {
+  public:
+    Request() : curlReq(NULL) {}
+    std::string type;
+    std::map<std::string, std::string> headers;
+    std::string content;
+    std::string remoteHost;
+    unsigned short remotePort;
+    std::string httpMajor;
+    std::string httpMinor;
+    std::string uri;
+    struct evhttp_request* curlReq;
+  };
+
+  class Reply {
+  public:
+    Reply(Request req) : status(200), type(req.type), curlReq(req.curlReq) {}
+    int status;
+    std::string type;
+    std::map<std::string, std::string> headers;
+    std::string content;
+    struct evhttp_request* curlReq;
+  };
+
+  struct CallbackData {
+		HTTPServlet* servlet;
+		evhttp_request* httpReq;
+	};
+
+  static HTTPServer* getInstance(int port = 8080);
+  static void reply(const Reply& reply);
+  
+  static bool registerServlet(const std::string& path, HTTPServlet* servlet); ///< Register a servlet, returns false if path is already taken
+	static void unregisterServlet(HTTPServlet* servlet);
+
+private:
+	HTTPServer(unsigned short port);
+	~HTTPServer();
+
+	void start();
+	void stop();
+	static void run(void* instance);
+
+	void determineAddress();
+  
+	static void httpRecvReqCallback(struct evhttp_request *req, void *callbackData);
+
+	std::map<std::string, HTTPServlet*> _servlets;
+	typedef std::map<std::string, HTTPServlet*>::iterator servlet_iter_t;
+
+	struct event_base* _base;
+	struct evhttp* _http;
+	struct evhttp_bound_socket* _handle;
+
+	unsigned short _port;
+	std::string _address;
+
+	static HTTPServer* _instance;
+	
+	static tthread::recursive_mutex _instanceMutex;
+	tthread::thread* _thread;
+	tthread::recursive_mutex _mutex;
+	bool _isRunning;
+
+	friend class HTTPServlet;
+};
+
+class HTTPServlet {
+public:
+  virtual void httpRecvRequest(const HTTPServer::Request& request) = 0;
+  virtual void setURL(const std::string& url) = 0; /// Called by the server with the actual URL
+};
+
+}
+
+#endif /* end of include guard: HTTPSERVER_H_AIH108EG */