Server.hxx

Go to the documentation of this file.

#pragma once
 
#include "../../services/ISubject.hxx"
#include "../../services/Event.hxx"
#include "../../core/include/RepositoryManager.hxx"
#include "RemoteProtocol.hxx"
 
#include <boost/asio.hpp>
#include <memory>
#include <string>
#include <thread>
#include <vector>
#include <atomic>
#include <unordered_set>
#include <mutex>

namespace svcs::server {
 
using namespace svcs::core;
using namespace svcs::services;
 
using boost::asio::ip::tcp;

class Server {
public:
    Server(boost::asio::io_context& io_context,
           unsigned short port,
           std::shared_ptr<RepositoryManager> repo_manager,
           std::shared_ptr<ISubject> event_bus);

    ~Server();

    bool start();

    void stop();

    bool isRunning() const;

    unsigned short getPort() const;

    size_t getActiveConnections() const;
 
private:
    void startAccept();

    void handleAccept(std::shared_ptr<tcp::socket> socket, const boost::system::error_code& error);

    void spawnClientHandler(std::shared_ptr<tcp::socket> socket);

    void handleClient(std::shared_ptr<tcp::socket> socket);

    std::string determineServiceType(std::shared_ptr<tcp::socket> socket);


    bool executeProtocol(std::shared_ptr<tcp::socket> socket, const std::string& service_type);

    void removeClientConnection(std::shared_ptr<tcp::socket> socket);

    void notifyServerEvent(const std::string& message) const;

    void notifyClientConnection(const std::string& message) const;

    void notifyServerError(const std::string& message) const;
 
private:
    boost::asio::io_context& io_context_;

    tcp::acceptor acceptor_;

    std::shared_ptr<RepositoryManager> repository_manager_;

    std::shared_ptr<ISubject> event_bus_;

    std::atomic<bool> is_running_;

    std::unordered_set<std::shared_ptr<tcp::socket>> active_connections_;

    mutable std::mutex connections_mutex_;
};
 
}