XmppPingStrophe.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "Containers/Queue.h"
#include "XmppConnection.h"
#include "Containers/Queue.h"
#include "Containers/Ticker.h"
#include "HAL/ThreadSafeBool.h"
 
class FXmppConnectionStrophe;
class FStropheStanza;
 
#if WITH_XMPP_STROPHE
 
struct FXmppPingReceivedInfo
{
public:
    FXmppUserJid FromJid;
    FString PingId;
 
public:
    FXmppPingReceivedInfo()
    {
    }
 
    FXmppPingReceivedInfo(FXmppUserJid&& InFromJid, FString&& InPingId)
        : FromJid(MoveTemp(InFromJid))
        , PingId(MoveTemp(InPingId))
    {
    }
};
 
class FXmppPingStrophe
    : public FTSTickerObjectBase
{
public:
    // FXmppPingStrophe
    FXmppPingStrophe(FXmppConnectionStrophe& InConnectionManager);
    virtual ~FXmppPingStrophe();
 
    // FTSTickerObjectBase
    virtual bool Tick(float DeltaTime) override;
 
    void OnDisconnect();
    void OnReconnect();
 
    bool ReceiveStanza(const FStropheStanza& IncomingStanza);
 
    void ResetPingTimer();
 
    void ResetPongTimer();
 
protected:
    bool HandlePingStanza(const FStropheStanza& PingStanza);
 
    void ReplyToPing(FXmppPingReceivedInfo&& ReceivedPing);
 
    void SendClientPing();
 
    void CheckXmppPongTimeout(float DeltaTime);
 
    void CleanupMessages();
 
private:
    FXmppConnectionStrophe& ConnectionManager;
 
    TQueue<FXmppPingReceivedInfo> IncomingPings;
 
    float TimeSinceLastClientPing;
 
    bool bWaitingForPong;
 
    float SecondsSinceLastServerPong;
 
    FThreadSafeBool bHasReceievedServerPong;
 
    int32 MissedPongs;
};
 
#endif