NetworkConnectionToClient.hpp

#pragma once
 
#include "NetworkConnection.hpp"
#include "Transport.hpp"
#include "Compression.hpp"
 
namespace KapMirror {
    class NetworkConnectionToClient : public NetworkConnection {
      private:
        int connectionId;
 
      public:
        explicit NetworkConnectionToClient(int _connectionId) : connectionId(_connectionId) {}
 
        int getConnectionId() override { return connectionId; }
 
        void disconnect() override { Transport::activeTransport->serverDisconnect(connectionId); }
 
        void sendToTransport(const std::shared_ptr<ArraySegment<byte>>& data) override {
            std::shared_ptr<ArraySegment<byte>> dataToSend = data;
            if (Compression::activeCompression != nullptr) {
                dataToSend = Compression::activeCompression->compress(data);
            }
            Transport::activeTransport->serverSend(connectionId, dataToSend);
        }
    };
} // namespace KapMirror