DiarkisTcpBase.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/network/tcp.h"
#include "logging/LoggerFactory.h"
#include "protocol.h"
 
class DIARKIS_API DiarkisTcpBase
{
   public:
    DiarkisTcpBase();
 
    virtual ~DiarkisTcpBase();
 
    virtual void Setup(const std::shared_ptr<LoggerFactory>& loggerFactory);
 
    bool Connect(const char* endpoint, const char* clientKey, const struct AuthInfo* auth);
 
    bool Connect(const std::string& endpoint, const std::string& clientKey, const struct AuthInfo* auth);
 
    bool Connect(const std::string& endpoint,
                 const std::string& clientKey,
                 const std::vector<uint8_t>& sid,
                 const std::vector<uint8_t>& key,
                 const std::vector<uint8_t>& iv,
                 const std::vector<uint8_t>& mackey);
 
    bool IsConnected();
 
    void Disconnect();
 
    void Update();
 
    void SetSchedulerAddNotifyEvent(std::function<void()> notifyEventFunc);
 
    bool IsOffline();
 
    std::shared_ptr<IDiarkisTcp> Get();
 
    bool SendHeartbeat(void);
 
    bool SendMigrate(void);
 
   protected:
    virtual void OnConnect(const DiarkisConnectionEventArgs& args);
 
    virtual void OnDisconnect(bool isReconnect);
 
    virtual void OnOffline();
 
    virtual void OnResponse(const DiarkisResponseEventArgs& args, DiarkisTransportType tt);
 
    virtual void OnPush(const DiarkisPushEventArgs& args, DiarkisTransportType tt);
 
    virtual void OnHeartbeat();
 
    virtual void OnNotification(const DiarkisPushEventArgs& args);
 
    std::shared_ptr<IDiarkisTcp> tcp_;
 
    std::shared_ptr<IDiarkisLogger> logger_;
 
    Diarkis::StdVector<std::function<void()>> eventUnsubscriptions_;
 
    std::function<void()> schedulerAddNotifyEventFunc_;
 
    bool bOffline_;
};