tcp_server.h

Go to the documentation of this file.

// Copyright (c) Space-ng, inc. All rights reserved.
 
#pragma once
 
#include "sol3/net/connection_handler.h"
#include "sol3/net/framer.h"
#include "sol3/net/msg/tcp_server_config.h"
#include "sol3/net/tcp_connection.h"
#include "sol3/net/tcp_telemetry.h"
 
#include <boost/asio/io_context.hpp>
 
#include <cstdint>
#include <memory>
 
namespace sol3::net {
 
// Interface for a TCP server.
class ITcpServer {
 public:
  virtual ~ITcpServer() = default;
  virtual void start(std::weak_ptr<IConnectionHandler> weak_handler) = 0;
  virtual void stop() = 0;
  virtual void broadcast(uint8_t const* data, size_t n) = 0;
  virtual void sendTo(
      TcpConnectionId connection_id, uint8_t const* data, size_t n) = 0;
  virtual void requestRead(TcpConnectionId connection_id) = 0;
  virtual TcpTelemetry& telemetry() = 0;
  virtual msg::TcpServerConfigT const& config() const = 0;
 
  static std::shared_ptr<ITcpServer> make(
      boost::asio::io_context& io,
      msg::TcpServerConfigT const& config,
      std::unique_ptr<IFramer>&& framer);
};
 
}  // namespace sol3::net