ConnectionBase.hpp

#pragma once
 
#include "util/Taggable.hpp"
#include "web/SubscriptionContextInterface.hpp"
 
#include <boost/beast/http.hpp>
#include <boost/beast/http/status.hpp>
#include <boost/signals2.hpp>
#include <boost/signals2/variadic_signal.hpp>
 
#include <memory>
#include <stdexcept>
#include <string>
#include <utility>
 
namespace web {
 
namespace http = boost::beast::http;

struct ConnectionBase : public util::Taggable {
protected:
    boost::system::error_code ec_;
    bool isAdmin_ = false;
    std::string clientIp_;
 
public:
    bool upgraded = false;

    ConnectionBase(util::TagDecoratorFactory const& tagFactory, std::string ip)
        : Taggable(tagFactory), clientIp_(std::move(ip))
    {
    }

    virtual void
    send(std::string&& msg, http::status status = http::status::ok) = 0;

    virtual void
    send([[maybe_unused]] std::shared_ptr<std::string> msg)
    {
        throw std::logic_error("web server can not send the shared payload");
    }

    virtual void
    sendSlowDown(std::string const& request) = 0;
    virtual SubscriptionContextPtr
    makeSubscriptionContext(util::TagDecoratorFactory const& factory) = 0;

    bool
    dead()
    {
        return ec_ != boost::system::error_code{};
    }

    [[nodiscard]] bool
    isAdmin() const
    {
        return isAdmin_;
    }

    [[nodiscard]] std::string const&
    clientIp() const
    {
        return clientIp_;
    }
};
}  // namespace web