DiarkisSessionBase.h

Go to the documentation of this file.

// © 2019-2024 Diarkis Inc. All rights reserved.
 
#pragma once
 
#include <functional>
#include "diarkis/common.h"
#include "diarkis/modules/session.h"
#include "diarkis/network/tcp.h"
#include "diarkis/network/udp.h"
#include "logging/LoggerFactory.h"
#include "protocol.h"
 
using namespace Diarkis::Modules;
 
class DiarkisSessionBase
{
   public:
    DiarkisSessionBase();
 
    virtual ~DiarkisSessionBase();
 
    virtual void SetupUdpSession(const std::shared_ptr<IDiarkisUdp>& udp, const std::shared_ptr<LoggerFactory>& loggerFactory, bool bRetry);
 
    virtual void SetupTcpSession(const std::shared_ptr<IDiarkisTcp>& tcp, const std::shared_ptr<LoggerFactory>& loggerFactory, bool bRetry);
 
    bool HasSession(uint8_t sessionType) const;
 
    virtual void SendCreate(uint8_t sessionType, uint8_t maxMembers, uint8_t ttl);
 
    virtual void SendInvite(uint8_t sessionType, const char** uids, size_t uidsCount);
 
    virtual void SendInvite(uint8_t sessionType, const std::vector<std::string>& uids);
 
    virtual void SendInvite(uint8_t sessionType, const char** uids, size_t uidsCount, const uint8_t* message, size_t messageSize);
 
    virtual void SendInvite(uint8_t sessionType, const std::vector<std::string>& uids, const std::string& message);
 
    virtual void SendInvite(uint8_t sessionType, const char** uids, size_t uidsCount, const char* message);
 
    virtual void SendBroadcast(uint8_t sessionType, const uint8_t* message, size_t messageSize);
 
    virtual void SendBroadcast(uint8_t sessionType, const std::string& message);
 
    virtual void SendBroadcast(uint8_t sessionType, const char* message);
 
    virtual void SendMessageTo(uint8_t sessionType, const char** uids, size_t uidsCount, const uint8_t* message, size_t messageSize);
 
    virtual void SendMessageTo(uint8_t sessionType, const char** uids, size_t uidsCount, const char* message);
 
    virtual void SendMessageTo(uint8_t sessionType, const std::vector<std::string>& memberIDs, const std::string& message);
 
    virtual void SendGetSessionInfoBySessionType(uint8_t sessionType);
 
    virtual void SendGetSessionInfoBySessionID(const char* sessionID);
 
    virtual void SendGetSessionInfoBySessionID(const std::string& sessionID);
 
    Diarkis::StdString GetSessionID(uint8_t sessionType) const;
 
    virtual void SendKick(uint8_t sessionType, const char* userID);
 
    virtual void SendKick(uint8_t sessionType, const std::string& userID);
 
    virtual void SendJoin(uint8_t sessionType, const char* sessionID);
 
    virtual void SendJoin(uint8_t sessionType, const std::string& sessionID);
 
    virtual void SendLeave(uint8_t sessionType);
 
    void SetUserID(const char* userID);
 
    void SetUserID(const std::string& userID);
 
    Diarkis::StdString GetUserID() const;
 
   protected:
    virtual void OnSessionCreateResponse(const DiarkisSessionCreateResponseEventArgs& e);
 
    virtual void OnSessionInvite(const DiarkisSessionInviteEventArgs& e);
 
    virtual void OnSessionJoin(const DiarkisSessionNotificationEventArgs& e);
 
    virtual void OnSessionLeave(const DiarkisSessionNotificationEventArgs& e);
 
    virtual void OnSessionBroadcast(const DiarkisSessionNotificationEventArgs& e);
 
    virtual void OnSessionMessageTo(const DiarkisSessionNotificationEventArgs& e);
 
    virtual void OnSessionInfo(const DiarkisSessionInfoEventArgs& e);
 
    virtual void OnSessionKick(const DiarkisSessionNotificationEventArgs& e);
 
    virtual void OnSessionInviteResponse(const DiarkisSessionResponseEventArgs& e);
 
    virtual void OnSessionKickResponse(const DiarkisSessionResponseEventArgs& e);
 
    virtual void OnSessionJoinResponse(const DiarkisSessionResponseEventArgs& e);
 
    virtual void OnSessionMessageToResponse(const DiarkisSessionResponseEventArgs& e);
 
    virtual void OnSessionBroadcastResponse(const DiarkisSessionResponseEventArgs& e);
 
    virtual void OnSessionLeaveResponse(const DiarkisSessionResponseEventArgs& e);
 
    std::shared_ptr<IDiarkisUdp> udp_;
 
    std::shared_ptr<IDiarkisTcp> tcp_;
 
    std::shared_ptr<IDiarkisSession> session_;
 
    std::shared_ptr<IDiarkisLogger> logger_;
 
    Diarkis::StdVector<std::function<void()>> eventUnsubscriptions_;
};