connection.h

#ifndef CONNECTION_H
#define CONNECTION_H

#include <memory>
#include <deque>
#include <mutex>
#include "server/connection/isubscriber.h"
#include "server/channel/channels_manager.h"
#include "protocol/protocol.h"
#include "server/log/logger.h"

class Connection : public ISubscriber, public std::enable_shared_from_this<Connection>
{
public:
    explicit Connection(boost::asio::ip::tcp::socket&& _socket, database_ptr _db):
        socket(std::move(_socket)),
        db(_db),
        busy(true)

    {
        BOOST_LOG_TRIVIAL(info) << "new connection from " << socket.remote_endpoint().address().to_string()
                                << ":" << socket.remote_endpoint().port();
    }

    void reuse(boost::asio::ip::tcp::socket&& _socket) override;

    virtual void start() override {
        BOOST_LOG_TRIVIAL(info) << "Connection start read_request_header().";
        read_request_header();
   }

    virtual void sendme(text_response_ptr response) override;

    virtual identifier_t get_client_id() const override {
        return client_id;
    }

    virtual const std::string& get_login() const override { return login; }

    virtual bool is_busy() const noexcept override { return busy; }
    virtual void set_busy(bool flag = true) noexcept override { busy = flag; }

    virtual void free_connection() override;

    ~Connection() {
         free_connection();
    }
private:

    boost::asio::ip::tcp::socket socket;
    std::mutex mtx_sock;
    std::deque<response_ptr> packets_to_client;

    identifier_t client_id;
    std::string login;
    std::string password;

    database_ptr db;
    std::atomic<bool> busy;

private:
    void read_request_header();

    void read_request_body(registr_request_ptr);

    void read_request_body(autor_request_ptr);

    void read_request_body(text_request_ptr);

    void read_request_body(join_room_request_ptr);

    void send_response_header();

    void send_response_data();

    identifier_t generate_client_id() {
        static identifier_t id = 0;
        return ++id;
    }
};

using connection_ptr = std::shared_ptr<Connection>;

#endif // CONNECTION_H