ServerPP.h

Go to the documentation of this file.

 
#ifndef _SERVER_H
#define _SERVER_H
 
#include "Channel.h"
#include <unordered_map>
#include <unordered_set>
#include <sstream>
#include <iostream>
#include <KISS.h>
#include "ClientPP.h"
#include <filesystem>

 
class ServerPP {
public:  
    ServerPP(std::string address, int port, std::string separator, IP_Type ipType = IP_Type::IPv4, bool useCiphering = true, const std::string& publicKeyFile = "", const std::string& privateKeyFile = "");

    ~ServerPP();

    void start();
    
    void stop();
    
    void plug(std::shared_ptr<Channel> channel, ChannelType type);
    
    void unplug(const std::string& key);
    
    std::vector<std::string> getChannelKeys();

    void setChannelState(const std::string& key, const ChannelState& state);

    void kicked(const std::string& clientID);
 
private: 
    std::unique_ptr<KeyExchangeInterface> kxInterface;

    std::unordered_map<std::string, std::pair<ChannelType, std::shared_ptr<Channel>>> channels;

    std::unordered_map<std::string, std::stop_source> stopSources;

    std::unordered_map<std::string, std::shared_ptr<ClientPP>> clients;
   
    std::stop_source stopTag;

    Server *serverTCP, *serverUDP;

    std::string address;

    int port;

    IP_Type ipType;
    
    std::string separator;
    
    bool useCiphering;

    std::jthread runThread;

    std::vector<std::jthread> channelsThreads;

    void process(ServerEvent& event, const ConnType& connType);

    void run(std::stop_token st);
    
};
 
#endif //_SERVER_H