Transport.hpp

#pragma once
 
#include "ArraySegment.hpp"
#include "Platform.hpp"
#include "KapMirror/Experimental/Core/Action.hpp"
#include <functional>
#include <memory>
 
namespace KapMirror {
    class Transport {
      public:
        virtual ~Transport() = default;
 
        virtual bool clientConnected() = 0;
 
        virtual void clientConnect(const std::string& ip, int port) = 0;
 
        virtual void clientDisconnect() = 0;
 
        virtual void clientSend(const std::shared_ptr<ArraySegment<byte>>& data) = 0;
 
        virtual void clientEarlyUpdate() = 0;
 
        virtual void serverStart(int port) = 0;
 
        virtual void serverStop() = 0;
 
        virtual void serverSend(int connectionId, const std::shared_ptr<ArraySegment<byte>>& data) = 0;
 
        virtual void serverDisconnect(int connectionId) = 0;
 
        virtual void serverEarlyUpdate() = 0;
 
      public:
        static std::shared_ptr<Transport> activeTransport;
 
        Experimental::Action<void(Transport&)> onClientConnected;
        Experimental::Action<void(Transport&)> onClientDisconnected;
        Experimental::Action<void(Transport&, const std::shared_ptr<ArraySegment<byte>>&)> onClientDataReceived;
        Experimental::Action<void(Transport&, const std::shared_ptr<ArraySegment<byte>>&)> onClientDataSent;
 
        Experimental::Action<void(Transport&, int)> onServerConnected;
        Experimental::Action<void(Transport&, int)> onServerDisconnected;
        Experimental::Action<void(Transport&, int, const std::shared_ptr<ArraySegment<byte>>&)> onServerDataReceived;
        Experimental::Action<void(Transport&, int, const std::shared_ptr<ArraySegment<byte>>&)> onServerDataSent;
    };
} // namespace KapMirror