transport.h

Go to the documentation of this file.

// © 2019-2024 Diarkis Inc. All rights reserved.
 
#pragma once
 
#include <functional>
#include <ostream>
 
#include "diarkis/common.h"
#include "diarkis/system/Component.h"
#include "diarkis/logging/LoggerFactory.h"
#include "diarkis/system/Event.h"
#include "diarkis/network/eventArgs.h"
#include "diarkis/network/network.h"
#include "diarkis/system/result.h"
 
using namespace Diarkis;
 
// ADD NAMESPACE NAME TAG
namespace Diarkis { namespace Network
{
enum class DiarkisTransportType: std::uint8_t
{
    TCP = 1,
    UDP
};
 
DIARKIS_EXPORT std::ostream &operator<<(std::ostream& os, const DiarkisTransportType type);
 
class DIARKIS_EXPORT IDiarkisTransport : public IDiarkisComponent
{
    public:
        virtual ~IDiarkisTransport() { }
 
        virtual void SetLoggerFactory(std::shared_ptr<IDiarkisLoggerFactory> loggerFactory) = 0;
 
        virtual DiarkisTransportType GetType() const = 0;
 
        virtual std::shared_ptr<IDiarkisEvent<const DiarkisConnectionEventArgs&>> GetConnectedEvent() = 0;
        virtual std::shared_ptr<IDiarkisEvent<bool>> GetDisconnectedEvent() = 0;
        virtual std::shared_ptr<IDiarkisEvent<const DiarkisResponseEventArgs&>> GetResponseEvent() = 0;
        virtual std::shared_ptr<IDiarkisEvent<const DiarkisPushEventArgs&>> GetPushEvent() = 0;
        virtual std::shared_ptr<IDiarkisEvent<void*>> GetOfflineEvent() = 0;
        virtual std::shared_ptr<IDiarkisEvent<void*>> GetRoomOfflineEvent() = 0;
        virtual std::shared_ptr<IDiarkisEvent<const DiarkisPushEventArgs&>> GetNotificationEvent() = 0;
 
        virtual Diarkis::System::Result SetClientKey(const Diarkis::StdString& clientKey) = 0;
        virtual Diarkis::System::Result SetClientKey(const char* clientKey) = 0;
 
        virtual Diarkis::System::Result SetSessionID(const Diarkis::StdVector<uint8_t>& sid, bool bypassConnectionStateCheck = false) = 0;
        virtual Diarkis::System::Result SetSessionID(const uint8_t* sid_, size_t sidBuf, bool bypassConnectionStateCheck = false) = 0;
 
        virtual Diarkis::System::Result SetEncryptionKeys(const Diarkis::StdVector<uint8_t>& key, const Diarkis::StdVector<uint8_t>& iv, const Diarkis::StdVector<uint8_t>& mackey, bool bypassConnectionStateCheck = false) = 0;
        virtual Diarkis::System::Result SetEncryptionKeys(const struct Credentials* cred, size_t len, bool bypassConnectionStateCheck = false) = 0;
 
 
        virtual bool IsConnected() const = 0;
 
        virtual Diarkis::System::Result Connect(const Diarkis::StdString& unresolvedAddress, uint16_t port, uint16_t timeOut = 3000) = 0;
        virtual Diarkis::System::Result Connect(const char* unresolvedAddress, uint16_t port, uint16_t timeOut = 3000) = 0;
 
        virtual Diarkis::System::Result ConnectDualMode(const Diarkis::StdString& unresolvedAddress, uint16_t port, uint16_t timeOut = 3000) = 0;
 
        virtual Diarkis::System::Result Reconnect(const Diarkis::StdString& unresolvedAddress, uint16_t port, uint16_t timeOut = 3000) = 0;
        virtual Diarkis::System::Result Disconnect() = 0;
 
        virtual Diarkis::StdString GetServerEndPoint(bool useResolvedAddress = true) = 0;
 
        virtual Diarkis::System::Result Send(uint8_t version, uint16_t command, const uint8_t* payload, size_t payloadLength) = 0;
 
        virtual Diarkis::System::Result Send(uint8_t version, uint16_t command, const Diarkis::StdVector<uint8_t>& payload) = 0;
 
        virtual Diarkis::System::Result RSend(uint8_t version, uint16_t command, const uint8_t* payload, size_t payloadSize) = 0;
 
        virtual Diarkis::System::Result RSend(uint8_t version, uint16_t command, const Diarkis::StdVector<uint8_t>& payload) = 0;
};
}}
// ADD NAMESPACE } TAG