source/http/client.h

   1 #ifndef MSP_HTTP_CLIENT_H_
   2 #define MSP_HTTP_CLIENT_H_
   3
   4 #include <string>
   5 #include <sigc++/signal.h>
   6 #include <msp/io/eventdispatcher.h>
   7 #include <msp/net/resolve.h>
   8 #include <msp/net/streamsocket.h>
   9
  10 namespace Msp {
  11 namespace Http {
  12
  13 class Request;
  14 class Response;
  15
  16 class Client
  17 {
  18 public:
  19         sigc::signal<void, const Response &> signal_response_complete;
  20         sigc::signal<void, const std::exception &> signal_socket_error;
  21
  22 private:
  23         struct ResolveListener: public sigc::trackable
  24         {
  25                 Client &client;
  26
  27                 ResolveListener(Client &);
  28
  29                 void address_resolved(unsigned, const Net::SockAddr &);
  30                 void resolve_failed(unsigned, const std::exception &);
  31         };
  32
  33         Net::StreamSocket *sock = 0;
  34         IO::EventDispatcher *event_disp = 0;
  35         Net::Resolver *resolver = 0;
  36         ResolveListener *resolve_listener = 0;
  37         unsigned resolve_tag = 0;
  38         std::string user_agent = "libmspnet/1.0";
  39         Request *request = 0;
  40         Response *response = 0;
  41         std::string in_buf;
  42
  43         Client(const Client &);
  44         Client &operator=(const Client &);
  45 public:
  46         ~Client();
  47
  48         void use_event_dispatcher(IO::EventDispatcher *);
  49         void use_resolver(Net::Resolver *);
  50         void set_user_agent(const std::string &);
  51         void start_request(const Request &);
  52         const Response *get_url(const std::string &);
  53         void tick();
  54         void wait_response();
  55         void abort();
  56         const Request *get_request() const { return request; }
  57         const Response *get_response() const { return response; }
  58 private:
  59         void address_resolved(unsigned, const Net::SockAddr &);
  60         void resolve_failed(unsigned, const std::exception &);
  61         void connect_finished(const std::exception *);
  62         void data_available();
  63 };
  64
  65 } // namespace Http
  66 } // namespace Msp
  67
  68 #endif