client.h

#pragma once
 
/************************************************************************************************
 * @file   client.h
 *
 * @brief  Header file defining the Client class
 *
 * @date   2025-01-04
 * @author Aryan Kashem
 ************************************************************************************************/
 
/* Standard library Headers */
#include <atomic>
#include <functional>
#include <queue>
#include <string>
 
/* Inter-component Headers */
#include <arpa/inet.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
#include <sys/socket.h>
#include <unistd.h>
 
/* Intra-component Headers */
 
class Client {
 private:
  using messageCallback = std::function<void(Client *client, std::string &)>;
  using connectCallback = std::function<void(Client *client)>;
 
  static constexpr size_t MAX_BUFFER_SIZE = 256; 
  pthread_t m_receiverThreadId;       
  pthread_t m_processMessageThreadId; 
  pthread_mutex_t m_mutex;            
  sem_t m_messageSemaphore;           
  messageCallback m_messageCallback; 
  connectCallback m_connectCallback; 
  std::atomic<bool> m_isConnected{ false }; 
  std::queue<std::string> m_messageQueue; 
  int m_clientSocket;                 
  std::string m_host;                 
  int m_port;                         
  struct sockaddr_in m_serverAddress; 
 public:
  Client(const std::string &host, int port, messageCallback messageCallback, connectCallback connectCallback);
 
  ~Client();
 
  void receiverProcedure();
 
  void processMessagesProcedure();
 
  void connectServer();
 
  void disconnectServer();
 
  bool isConnected() const;
 
  void sendMessage(const std::string &message);
};