server.h

#ifndef SERVER_H
#define SERVER_H

#include <boost/asio.hpp>
#include <memory>

#include "connection/connection_manager.h"

using boost::asio::ip::tcp;

class Server {
public:
    Server(int32_t port, database_ptr _db):
        endpoint(boost::asio::ip::tcp::v4(), port),
        acceptor(io_service, endpoint),
        db(_db),
        connect_manager(db)
    {
        scan_acception();
    }

    void run() {
        io_service.run();
    }

private:
    boost::asio::io_service io_service;
    boost::asio::ip::tcp::endpoint endpoint;
    boost::asio::ip::tcp::acceptor acceptor;
    database_ptr db;

    ConnectionManager connect_manager;
private:
    void scan_acception() {
        acceptor.async_accept([this](const boost::system::error_code& error, tcp::socket sock) {
            if (!error) {
                connect_manager.get_connection(std::move(sock))->start();
            }
            scan_acception();
        });
    }

};

#endif // SERVER_H