tcp.h

Go to the documentation of this file.

// © 2019-2024 Diarkis Inc. All rights reserved.
 
#pragma once
 
#include <cstdint>
#include <functional>
 
#include "diarkis/common.h"
#include "diarkis/logging/LoggerFactory.h"
#include "diarkis/network/eventArgs.h"
#include "diarkis/network/transport.h"
#include "diarkis/system/Event.h"
#include "diarkis/system/result.h"
 
#define DIARKIS_TCP_DEFAULT_HEARTBEAT_INTERVAL 5000
 
#if defined(__GNUC__) && !defined(__clang__)
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wattributes"
#endif
 
// ADD NAMESPACE NAME TAG
namespace Diarkis
{
namespace Network
{
enum class DIARKIS_EXPORT DiarkisTcpConnectionState : std::uint8_t;
 
enum class DiarkisTcpConnectionState : std::uint8_t
{
    NOT_CONNECTED = 0,
    CONNECTING,
    CONNECTED,
    DISCONNECTING,
    BROKEN
};
#if defined(__GNUC__) && !defined(__clang__)
#pragma GCC diagnostic pop
#endif
 
DIARKIS_EXPORT std::ostream& operator<<(std::ostream&, DiarkisTcpConnectionState);
 
class IDiarkisTcp : public IDiarkisTransport
{
   public:
    virtual ~IDiarkisTcp() {}
 
    virtual std::shared_ptr<IDiarkisEvent<const DiarkisTcpConnectionStateChangedEventArgs&>> GetConnectionStateChangedEvent() = 0;
 
    virtual std::shared_ptr<IDiarkisEvent<void*>> GetHeartbeatEvent() = 0;
 
    virtual Diarkis::System::Result SetHeartbeatInterval(size_t heartbeatInterval) = 0;
 
    virtual Diarkis::System::Result SetNoDelay(bool noDelay) = 0;
 
    virtual DiarkisTcpConnectionState GetState() const = 0;
 
    virtual Diarkis::StdString GetLocalAddress() = 0;
 
    virtual Diarkis::System::Result Connect(const Diarkis::StdString& unresolvedAddress,
                                            uint16_t port,
                                            int32_t perConnectionTimeoutMs) = 0;
 
    virtual Diarkis::System::Result ConnectDualMode(const Diarkis::StdString& unresolvedAddress,
                                                    uint16_t port,
                                                    int32_t perConnectionTimeoutMs) = 0;
 
    virtual Diarkis::System::Result Send(uint8_t version, uint16_t command, const uint8_t* payload, size_t payloadSize) = 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;
 
    using IDiarkisTransport::Connect;
    using IDiarkisTransport::ConnectDualMode;
 
    virtual Diarkis::System::Result SendHeartbeat() = 0;
 
    virtual Diarkis::System::Result Migrate() = 0;
 
    virtual Diarkis::System::Result Migrate(const Diarkis::StdString& serverType) = 0;
 
    virtual void SetRoomID(const Diarkis::StdString& id) = 0;
    virtual const Diarkis::StdString& GetRoomID() = 0;
};
 
DIARKIS_EXPORT IDiarkisTcp* DiarkisCreateTcp(size_t heartbeatInterval = 5000);
 
}  // namespace Network
}  // namespace Diarkis
   // ADD NAMESPACE } TAG