ssgx_http_t_server.h

Go to the documentation of this file.

#ifndef SSGXLIB_SSGX_HTTP_T_SERVER_H
#define SSGXLIB_SSGX_HTTP_T_SERVER_H
 
#include <mutex>
#include <string>
#include <unordered_map>
 
#include "ssgx_http_t_filter.h"
#include "ssgx_http_t_structs.h"
 
namespace ssgx {
namespace http_t {
class Server {
 
  public:
    Server() = default;
 
    ~Server();
    void SetTimeOut(uint64_t timeout_seconds);
 
    void SetMaxThreads(uint64_t max_threads);
 
    void SetMaxQueued(uint64_t max_queued);
 
    void Listen(const std::string& url);
    void AddFilter(std::unique_ptr<Filter>&& filter);
    bool Start();
 
    void Stop();
 
    void Get(const std::string& path,
             const std::function<void(ssgx::http_t::Request&, ssgx::http_t::Response&)>& handler);
 
    void Post(const std::string& path,
              const std::function<void(ssgx::http_t::Request&, ssgx::http_t::Response&)>& handler);
 
  private:
    void RegisterHandler(const std::string& method, const std::string& path,
                         const std::function<void(ssgx::http_t::Request&, ssgx::http_t::Response&)>& handler);
 
    void Process(const std::string& method, const std::string& path, ssgx::http_t::Request& req,
                 ssgx::http_t::Response& resp);
 
    std::function<void(ssgx::http_t::Request&, ssgx::http_t::Response&)> GetHandler(const std::string& method,
                                                                                    const std::string& method_path);
 
    friend void ServerProcessBridge(Server* srv, const std::string& method, const std::string& path,
                                    ssgx::http_t::Request& req, ssgx::http_t::Response& resp);
 
  private:
    std::string url_;
    std::string server_id_;
    uint64_t timeout_seconds_ = 60;
    uint64_t max_threads_ = 4;
    uint64_t max_queued_ = 64;
    bool is_stopped_ = true;
 
    // key = "{method}_{path}"
    // map<key, handler>
    std::mutex key_handler_map_mutex_;
    std::unordered_map<std::string, std::function<void(ssgx::http_t::Request&, ssgx::http_t::Response&)>>
        key_handler_map_;
 
    FilterChain filter_chain_;
};
} // namespace http_t
} // namespace ssgx
 
#endif // SSGXLIB_SSGX_HTTP_T_SERVER_H