IXWebSocket/ixwebsocket/IXWebSocketServer.h

/*
 *  IXWebSocketServer.h
 *  Author: Benjamin Sergeant
 *  Copyright (c) 2018 Machine Zone, Inc. All rights reserved.
 */

#pragma once

#include <utility> // pair
#include <string>
#include <set>
#include <thread>
#include <mutex>
#include <functional>
#include <memory>
#include <condition_variable>

#include "IXWebSocket.h"

namespace ix 
{
    using OnConnectionCallback = std::function<void(std::shared_ptr<WebSocket>)>;

    class WebSocketServer {
    public:
        WebSocketServer(int port = WebSocketServer::kDefaultPort,
                        const std::string& host = WebSocketServer::kDefaultHost,
                        int backlog = WebSocketServer::kDefaultTcpBacklog,
                        size_t maxConnections = WebSocketServer::kDefaultMaxConnections,
                        int handshakeTimeoutSecs = WebSocketServer::kDefaultHandShakeTimeoutSecs);
        virtual ~WebSocketServer();

        void setOnConnectionCallback(const OnConnectionCallback& callback);
        void start();
        void wait();
        void stop();

        std::pair<bool, std::string> listen();

        // Get all the connected clients
        std::set<std::shared_ptr<WebSocket>> getClients();

    private:
        // Member variables
        int _port;
        std::string _host;
        int _backlog;
        size_t _maxConnections;
        int _handshakeTimeoutSecs;

        OnConnectionCallback _onConnectionCallback;

        // socket for accepting connections
        int _serverFd;

        std::mutex _clientsMutex;
        std::set<std::shared_ptr<WebSocket>> _clients;

        std::mutex _logMutex;

        std::atomic<bool> _stop;
        std::thread _thread;

        std::condition_variable _conditionVariable;
        std::mutex _conditionVariableMutex;

        const static int kDefaultPort;
        const static std::string kDefaultHost;
        const static int kDefaultTcpBacklog;
        const static size_t kDefaultMaxConnections;
        const static int kDefaultHandShakeTimeoutSecs;

        // Methods
        void run();
        void handleConnection(int fd);
        size_t getConnectedClientsCount();

        // Logging
        void logError(const std::string& str);
        void logInfo(const std::string& str);
    };
}