server.h

#pragma once
 
/************************************************************************************************
 * @file   server.h
 *
 * @brief  Header file defining the Server class
 *
 * @date   2025-01-04
 * @author Aryan Kashem
 ************************************************************************************************/
 
/* Standard library Headers */
#include <atomic>
#include <functional>
#include <memory>
#include <unordered_map>
#include <vector>
 
/* Inter-component Headers */
#include <arpa/inet.h>
#include <pthread.h>
#include <sys/epoll.h>
 
/* Intra-component Headers */
#include "client_connection.h"
 
class Server {
 private:
  using messageCallback = std::function<void(Server *srv, ClientConnection *src, std::string &)>;
  using connectCallback = std::function<void(Server *srv, ClientConnection *src)>;
 
  static const constexpr unsigned int MAX_SERVER_EPOLL_EVENTS = 64U; 
  static const constexpr size_t MAX_CLIENT_READ_SIZE = 256U;         
  pthread_t m_listenNewClientsId; 
  pthread_t m_epollClientsId;     
  pthread_mutex_t m_mutex;        
  messageCallback m_messageCallback; 
  connectCallback m_connectCallback; 
  std::unordered_map<std::string, ClientConnection *> m_connections; 
  std::atomic<bool> m_serverListening; 
  int m_listenPort;                   
  int m_listeningSocket;              
  struct sockaddr_in m_serverAddress; 
  int m_epollFd;                                             
  struct epoll_event m_epollEvents[MAX_SERVER_EPOLL_EVENTS]; 
 public:
  Server();
 
  ~Server();
 
  void listenNewClientsProcedure();
 
  void epollClientsProcedure();
 
  void stop();
 
  void listenClients(int port, messageCallback messageCallback, connectCallback connectCallback);
 
  void messageReceived(ClientConnection *client, std::string &message);
 
  void sendMessage(ClientConnection *client, const std::string &message);
 
  void broadcastMessage(const std::string &message);
 
  void updateClientName(ClientConnection *client, std::string newName);
 
  void removeClient(ClientConnection *client);
 
  ClientConnection *getClientByName(std::string &clientName);
 
  void dumpClientList();
};