channel.h

#ifndef CHANNEL_H
#define CHANNEL_H

#include <unordered_map>
#include <mutex>
#include <deque>
#include "iroom.h"
#include "server/storage/database.h"
#include "server/log/logger.h"

class Channel : public IRoom
{
public:
    Channel(identifier_t room, database_ptr db) : channel_id(room)
    {
        if (db == nullptr) {
            BOOST_LOG_TRIVIAL(info) << "Failed to load history. Database pointer is nullptr.";
        } else {
            history_room = db->get_history(channel_id);
            BOOST_LOG_TRIVIAL(info) << "Create channel_id=" << channel_id;
        }
    }

    virtual void join(subscriber_ptr subscriber) override;
    
    virtual void leave(subscriber_ptr subscriber) override;
    
    virtual void notification(text_response_ptr response) override;


    virtual identifier_t get_room_id() const override { return channel_id; }

    ~Channel() {
        for(auto it:subscribers) {
            leave(it.second);
        }
    }
private:
    std::mutex mutex_subs;
    std::unordered_map<identifier_t, subscriber_ptr> subscribers;


    const identifier_t channel_id;

    std::deque<text_response_ptr> history_room;
};

using channel_ptr = std::shared_ptr<Channel>;
#endif // CHANNEL_H