Program Listing for File RTSocket.hpp

↰ Return to documentation for file (include/input/linux/RT/RTSocket.hpp)

#pragma once
#include "Common_Features.hpp"
#include "Input_State.hpp"
#include "OneTimeSysSetup.hpp"
#include "PDJE_Input_Device_Data.hpp"
#include "RTEvent.hpp"
#include "nlohmann/json_fwd.hpp"
#include <cstddef>
#include <fcntl.h>
#include <filesystem>
#include <functional>

#include <optional>

#include <string>
#include <sys/epoll.h>
#include <sys/mman.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>

#include <nlohmann/json.hpp>

using nj            = nlohmann::json;
using data_body     = std::vector<std::string>;
using regi_function = std::function<int(const data_body &)>;
namespace fs        = std::filesystem;
struct RT_ID {
    int host_socket = -1;
};

class RTSocket {
  private:
    RTEvent                                       *rtev;
    std::unordered_map<std::string, regi_function> functionRegistry;
    std::unordered_map<int, std::function<void()>> errorHandler;
    std::optional<OneTimeSysSetup>                 setups;
    RT_ID                                          importants;

    int
    ParseMsg(const std::string &raw_json_msg);

    int
    SocketOpen(const std::string &socket_path);

    int
    SocketClose();

    void
    RegisterFunctions();

    DEV_LIST
    ListDevices();

  public:
    std::unordered_map<std::string, fs::path> stored_dev_path;
    void
    SendMsg(const std::string &msg);
    int
    Communication();

    RTSocket(const std::string &socket_path, RTEvent *ptr);
    ~RTSocket();
    std::string ErrMsg;
};