source/http/server.h

   1 #ifndef MSP_HTTP_SERVER_H_
   2 #define MSP_HTTP_SERVER_H_
   3
   4 #include <msp/core/refptr.h>
   5 #include <msp/io/eventdispatcher.h>
   6 #include <msp/net/streamserversocket.h>
   7 #include <msp/time/timedelta.h>
   8
   9 namespace Msp {
  10 namespace Http {
  11
  12 class Request;
  13 class Response;
  14
  15 class Server
  16 {
  17 public:
  18         sigc::signal<void, const Request &, Response &> signal_request;
  19
  20 private:
  21         struct Client
  22         {
  23                 RefPtr<Net::StreamSocket> sock;
  24                 std::string in_buf;
  25                 Request *request = 0;
  26                 Response *response = 0;
  27                 bool keepalive = false;
  28                 bool async = false;
  29                 bool stale = false;
  30
  31                 Client(RefPtr<Net::StreamSocket>);
  32                 ~Client();
  33         };
  34
  35         Net::StreamServerSocket sock;
  36         std::list<Client> clients;
  37         std::map<Response *, Client *> responses;
  38         IO::EventDispatcher *event_disp = 0;
  39
  40 public:
  41         Server();
  42         Server(unsigned);
  43         ~Server();
  44
  45         void listen(unsigned);
  46         unsigned get_port() const;
  47         void use_event_dispatcher(IO::EventDispatcher *);
  48         void delay_response(Response &);
  49         void submit_response(Response &);
  50         void cancel_keepalive(Response &);
  51         void close_connections(const Time::TimeDelta &);
  52 private:
  53         void data_available();
  54         void client_data_available(Client &);
  55         void send_response(Client &, Response &);
  56         void client_end_of_file(Client &);
  57         Client &get_client_by_response(Response &);
  58 };
  59
  60 } // namespace Http
  61 } // namespace Msp
  62
  63 #endif