ws_server.h

Go to the documentation of this file.

#pragma once
 
#include <uwebsockets/App.h>
 
#include <atomic>
#include <cstdint>
#include <future>
#include <string>
#include <thread>
#include <unordered_set>
 
class WebSocketServer {
 public:
  struct Config {
    std::string bindAddress{"127.0.0.1"};
    uint16_t port = 62281;  
    std::string certFile;   
    std::string keyFile;    
  };
 
  explicit WebSocketServer(Config config);
 
  ~WebSocketServer();
 
  bool start();
 
  void stop();
 
  void broadcast(std::string json);
 
  void publish(std::string topic, std::string json);
 
 private:
  struct WsData {};
 
  void run();
 
  Config config_;
  std::atomic<bool> running_{false};
  std::thread thread_;
  std::atomic<uWS::Loop*> loop_{nullptr};
  std::atomic<uWS::SSLApp*> app_{nullptr};
  std::unordered_set<uWS::WebSocket<true, true, WsData>*> connections_;
  std::promise<bool> listenResult_;
};