base_server.h

#pragma once
 
#include <sys/socket.h>
#include <netinet/in.h>
#include "log.h"
#include "base/path_finder.h"
#include "continuous_path_finder.h"
#include <netinet/in.h>
#include "iostream"
#include <sys/socket.h>
#include <unistd.h>
#include <chrono>
#include <thread>
#include "base/path_finder.h"
#include "continuous_path_finder.h"
#include <json/value.h>
#include <json/reader.h>
#include <semaphore.h>
#include <csignal>
 
class BaseServer {
public:
 
    static void initLinuxServerSocket();
 
    void mainLoop();
 
    virtual void init(int port, int maxClients, int delay);
 
    virtual void processCommand(int clientSocket, int command, Json::Value jsonData) = 0;
 
    virtual void onSocketConnected(int clientSocket) = 0;
 
    void processRequests(int clientSocket);
 
    void stop() { _terminated = true; }
 
    int acceptNewSocket() {
        return accept(_serverFD, (struct sockaddr *) &_address, (socklen_t *) &_addrLen);
    }
 
    int getServerFd() const { return _serverFD; }
 
    const sockaddr_in &getAddress() const { return _address; }
 
protected:
    sem_t _sem;
 
private:
 
    struct sockaddr_in _address;
    int _port;
    int _addrLen;
    int _serverFD;
    int _delay;
    bool _terminated;
    std::string _commandBuf;
 
};