SubscriptionContext.hpp

#pragma once
 
#include "util/Taggable.hpp"
#include "web/SubscriptionContextInterface.hpp"
#include "web/interface/Concepts.hpp"
#include "web/interface/ConnectionBase.hpp"
 
#include <boost/signals2/variadic_signal.hpp>
 
#include <atomic>
#include <cstdint>
#include <memory>
#include <string>
 
namespace web {

class SubscriptionContext : public SubscriptionContextInterface {
    std::weak_ptr<ConnectionBase> connection_;
    boost::signals2::signal<void(SubscriptionContextInterface*)> onDisconnect_;
    std::atomic_uint32_t apiSubVersion_ = 0;
 
public:
    SubscriptionContext(
        util::TagDecoratorFactory const& factory,
        std::shared_ptr<ConnectionBase> connection
    );

    ~SubscriptionContext() override;

    void
    send(std::shared_ptr<std::string> message) override;

    void
    onDisconnect(OnDisconnectSlot const& slot) override;

    void
    setApiSubversion(uint32_t value) override;

    [[nodiscard]] uint32_t
    apiSubversion() const override;
};
 
}  // namespace web