ClientListener.h

Go to the documentation of this file.

/*
 * Deskflow -- mouse and keyboard sharing utility
 * SPDX-FileCopyrightText: (C) 2025 Deskflow Developers
 * SPDX-FileCopyrightText: (C) 2012 - 2016 Symless Ltd.
 * SPDX-FileCopyrightText: (C) 2004 Chris Schoeneman
 * SPDX-License-Identifier: GPL-2.0-only WITH LicenseRef-OpenSSL-Exception
 */
 
#pragma once
 
#include "net/SecurityLevel.h"
#include "server/Config.h"
 
#include <deque>
#include <memory>
#include <set>
 
class ClientProxy;
class ClientProxyUnknown;
class NetworkAddress;
class IListenSocket;
class ISocketFactory;
class Server;
class IEventQueue;
class IDataSocket;
 
class ClientListener
{
public:
  // The factories are adopted.
  ClientListener(
      const NetworkAddress &, std::unique_ptr<ISocketFactory> socketFactory, IEventQueue *events,
      SecurityLevel securityLevel
  );
  ClientListener(ClientListener const &) = delete;
  ClientListener(ClientListener &&) = delete;
  ~ClientListener();
 
  ClientListener &operator=(ClientListener const &) = delete;
  ClientListener &operator=(ClientListener &&) = delete;


 
  void setServer(Server *server);





  ClientProxy *getNextClient();

  Server *getServer()
  {
    return m_server;
  }

 
private:
  // client connection event handlers
  void handleClientConnecting();
  void handleClientAccepted(IDataSocket *socket);
  void handleUnknownClient(ClientProxyUnknown *unknownClient);
  void handleClientDisconnected(ClientProxy *client);
 
  void cleanupListenSocket();
  void cleanupClientSockets();
  void start();
  void stop();
  void removeUnknownClient(ClientProxyUnknown *unknownClient);
 
private:
  using NewClients = std::set<ClientProxyUnknown *>;
  using WaitingClients = std::deque<ClientProxy *>;
  using ClientSockets = std::set<IDataSocket *>;
 
  IListenSocket *m_listen;
  std::unique_ptr<ISocketFactory> m_socketFactory;
  NewClients m_newClients;
  WaitingClients m_waitingClients;
  Server *m_server = nullptr;
  IEventQueue *m_events;
  SecurityLevel m_securityLevel;
  ClientSockets m_clientSockets;
  NetworkAddress m_address;
};