http_client.hh

Go to the documentation of this file.

#ifndef __OPERATOR_HTTPCLIENT_HH_
#define __OPERATOR_HTTPCLIENT_HH_

#include "client.hh"
#include "structs.hh"
#include "http.hh"

#include <memory>
#include <string>
#include <vector>
#include <map>
#include <istream>

namespace Operator {
  namespace Client {
    class HTTPClientAPI {
    public:
      HTTPClientAPI(HTTP::Adapter &, const std::string &server);

      void versions(const callback_t<const std::vector<std::string> &> &callback);

      void login(const std::string &username, const std::string &password, const callback_t<const std::string&,const std::string&> &callback);

      void loginWith3PID(const std::string &medium, const std::string &address, const std::string &password, const callback_t<const std::string&,const std::string&> &);

      void loginWithToken(const std::string &token);

      void registerAccount(const std::string &username, const std::string &password, const callback_t<std::string,std::string> &);

      void logout(const callback_t<> &);

      bool isLoggedIn() const {
        return !token.empty();
      }

      const std::string &getToken() const {
        return token;
      }

      void sync(const std::string &since, const std::string &filter, bool full_state, std::string set_presence, size_t timeout, const callback_t<const std::string &, nlohmann::json, nlohmann::json> &);

      void roomMessages(const std::string &roomId, const std::string &from, const std::string &to, const std::string &dir, int limit, const callback_t<const std::string &, const std::string &, const std::vector<nlohmann::json> &> &);

      void sendMessage(const std::string &roomId, const std::string &eventType, const std::string &txnId, const nlohmann::json &content, const callback_t<const std::string &> &);
    protected:
      HTTP::Adapter &adapter;
      std::string baseurl;
    private:
      mutable std::string token;

      void handleLogin(std::unique_ptr<Error::Error>, short code, const HTTP::headers_t &, std::unique_ptr<std::istream>, callback_t<const std::string&,const std::string&>) throw ();
      void handleLogout(std::unique_ptr<Error::Error>, short code, const HTTP::headers_t &, std::unique_ptr<std::istream>, callback_t<>) throw ();
    };

    class HTTPClient : public Client {
    public:
      HTTPClient(HTTP::Adapter &adapter, const std::string &server);

      void login(const std::string &username, const std::string &password, const callback_t<const std::string &,const std::string &> &callback = noop_callback<const std::string &,const std::string &>);
      void loginWith3PID(const std::string &medium, const std::string &address, const std::string &password, const callback_t<const std::string &,const std::string &> &callback = noop_callback<const std::string &,const std::string &>);
      void loginWithToken(const std::string &token) {
        client.loginWithToken(token);
        trigger(Event::Login("", ""));
      }

      void logout(const callback_t<> &callback = noop_callback<>);

      bool isLoggedIn() const { return client.isLoggedIn(); }

      void startClient();
      void stopClient();

      void sendMessage(const Event::MessageEvent &, const callback_t<const std::string &> & = noop_callback<const std::string &>);
    protected:
      HTTPClientAPI client;
    private:
      void handleSync(std::shared_ptr<Error::Error>, const std::string &, nlohmann::json, nlohmann::json) throw ();
      callback_t<const std::string &, nlohmann::json, nlohmann::json> handleSync_ptr;
      std::function<void (const Event::Event &)> trigger_ptr;
      std::function<void (const std::string &, std::shared_ptr<Error::Error>, const std::string &)> triggerError_ptr;

      bool sync_pending;
      bool sync_active;
      std::string next_batch;
      unsigned int txn_counter;

    };
  }
}

#endif // __OPERATOR_HTTPCLIENT_HH_