DataArrayTcpServer.h

/*
Copyright (c) 2026 Alexandr Kuzmuk
 
This file is part of the AsyncFw project. Licensed under the MIT License.
See {Link: LICENSE file https://mit-license.org} in the project root for full license information.
*/
 
#pragma once
 
#include "../core/TlsContext.h"
#include "ListenSocket.h"
#include "DataArrayAbstractTcp.h"
 
namespace AsyncFw {
class ListenSocket;
class DataArrayTcpServer : public DataArrayAbstractTcp {
public:
  DataArrayTcpServer(const std::string & = "TcpServer");
  void quit() override;
  bool listen(const std::string &address, uint16_t port);
  void close();
  void setAlwaysConnect(const std::vector<std::string> &list);
  bool listening();
  void tlsSetup(const TlsContext &data) { tlsData = data; }
 
private:
  class Thread : public DataArrayAbstractTcp::Thread {
    friend class DataArrayTcpServer;
 
  public:
    inline DataArrayTcpServer *server() { return static_cast<DataArrayTcpServer *>(pool); }
 
  private:
    using DataArrayAbstractTcp::Thread::Thread;
    void createSocket(int, bool);
  };
  std::unique_ptr<ListenSocket> listener;
 
  bool incomingConnection(int, const std::string &);
  std::vector<std::string> alwaysConnect_;
  TlsContext tlsData;
};
}  // namespace AsyncFw