http_server.h

Go to the documentation of this file.

#pragma once
 
#include <uwebsockets/App.h>
 
#include <atomic>
#include <expected>
#include <functional>
#include <future>
#include <string>
#include <thread>
#include <vector>
 
#include "api/web_api.h"
#include "game_loop.h"  // GameLoopHealth (returned by the GET /api/game-loop callback)
 
namespace mm::node {
class DeviceManager;
class MonitoringManager;
}  // namespace mm::node
 
class HttpServer {
 public:
  using InitDeviceManagerFn =
      std::function<std::expected<void, std::string>(std::string driver, std::string adapter)>;
 
  using GetLogFn = std::function<std::vector<std::string>()>;
 
  using RefreshCertFn = std::function<std::expected<void, std::string>()>;
 
  using GetGameLoopHealthFn = std::function<GameLoopHealth()>;
 
  using SetGameLoopPeriodFn = std::function<std::expected<void, std::string>(uint32_t periodUs)>;
 
  struct Config {
    uint16_t port = 61447;  
    std::string certFile;   
    std::string keyFile;    
    std::string version;    
    std::string
        startedConfig;  
    InitDeviceManagerFn
        initDeviceManager;      
    GetLogFn getLog;            
    RefreshCertFn refreshCert;  
    GetGameLoopHealthFn
        getGameLoopHealth;  
    SetGameLoopPeriodFn
        setGameLoopPeriod;  
    std::string corsOrigin{"https://motion-master.synapticon.com"};
  };
 
  HttpServer(Config config, mm::node::DeviceManager& deviceManager,
             mm::node::MonitoringManager& monitoringManager);
 
  ~HttpServer();
 
  bool start();
 
  void stop();
 
  void addRoutes(mm::api::RegisterRoutesFn module);
 
 private:
  void run();
 
  Config config_;
  mm::node::DeviceManager& deviceManager_;
  mm::node::MonitoringManager& monitoringManager_;
  std::vector<mm::api::RegisterRoutesFn> routeModules_;
  std::atomic<bool> running_{false};
  std::thread thread_;
  std::atomic<uWS::Loop*> loop_{nullptr};
  std::atomic<uWS::SSLApp*> app_{nullptr};
  std::promise<bool> listenResult_;
};