DiarkisGroupBase.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/group.h"
#include "diarkis/network/tcp.h"
#include "diarkis/network/udp.h"
#include "logging/LoggerFactory.h"
#include "protocol.h"
 
using namespace Diarkis::Modules;
 
class DIARKIS_API DiarkisGroupBase
{
   public:
    DiarkisGroupBase();
 
    virtual ~DiarkisGroupBase();
 
    virtual void SetupTcpGroup(const std::shared_ptr<IDiarkisTcp>& tcp, const std::shared_ptr<LoggerFactory>& loggerFactory, bool bRetry);
 
    virtual void SetupUdpGroup(const std::shared_ptr<IDiarkisUdp>& udp, const std::shared_ptr<LoggerFactory>& loggerFactory, bool bRetry);
 
    virtual void SendCreateGroup(bool allowEmpty, bool join, uint16_t ttl);
 
    virtual void SendJoinGroup(const char* groupID, const uint8_t* message, size_t messageSize);
 
    virtual void SendJoinGroup(const std::string& groupID, const std::vector<uint8_t>& message);
 
    virtual void SendRandomJoinGroup(uint16_t ttl, const uint8_t* message, size_t messageSize, uint32_t interval, bool allowEmpty = false);
 
    virtual void SendRandomJoinGroup(uint16_t ttl, const std::vector<uint8_t>& message, uint32_t interval, bool allowEmpty = false);
 
    virtual void SendLeaveGroup(const char* groupID, const uint8_t* message, size_t messageSize);
 
    virtual void SendLeaveGroup(const std::string& groupID, const std::vector<uint8_t>& message);
 
    virtual void SendLeaveGroup(const uint8_t* message, size_t messageSize);
 
    virtual void SendLeaveGroup(const std::vector<uint8_t>& message);
 
    virtual void SendBroadcastToGroup(const uint8_t* payload, size_t payloadSize, bool reliable);
 
    virtual void SendBroadcastToGroup(const std::vector<uint8_t>& payload, bool reliable);
 
    virtual void SendBroadcastToGroup(const char* groupID, const uint8_t* payload, size_t payloadSize, bool reliable);
 
    virtual void SendBroadcastToGroup(const std::string& groupID, const std::vector<uint8_t>& payload, bool reliable);
 
    bool IsJoin();
 
    bool IsFail();
 
    Diarkis::StdString GetGroupID();
 
   protected:
    virtual void OnGroupCreation(DiarkisTransportType transportType, const DiarkisGroupEventArgs& e);
 
    virtual void OnGroupJoin(DiarkisTransportType transportType, const DiarkisGroupEventArgs& e);
 
    virtual void OnGroupLeave(DiarkisTransportType transportType, const DiarkisGroupEventArgs& e);
 
    virtual void OnGroupMemberJoin(DiarkisTransportType transportType, const DiarkisPayloadEventArgs& e);
 
    virtual void OnGroupMemberLeave(DiarkisTransportType transportType, const DiarkisPayloadEventArgs& e);
 
    virtual void OnGroupMemberBroadcast(DiarkisTransportType transportType, const DiarkisPayloadEventArgs& e);
 
    std::shared_ptr<IDiarkisTcp> tcp_;
 
    std::shared_ptr<IDiarkisUdp> udp_;
 
    std::shared_ptr<IDiarkisGroup> group_;
 
    std::shared_ptr<IDiarkisLogger> logger_;
 
    Diarkis::StdVector<std::function<void()>> eventUnsubscriptions_;
 
    Diarkis::StdString groupID_;
 
    Diarkis::StdString groupMessage_;
 
    Diarkis::StdString messageFromUid_;
 
    ConnectState groupConnect_;
};