XmppMessagesStrophe.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "XmppMessages.h"
 
#include "Containers/Ticker.h"
#include "Containers/Queue.h"
 
#if WITH_XMPP_STROPHE
 
class FXmppConnectionStrophe;
class FStropheStanza;
 
class FXmppMessagesStrophe
    : public IXmppMessages
    , public FTSTickerObjectBase
{
public:
    // FXmppMessagesStrophe
    FXmppMessagesStrophe(FXmppConnectionStrophe& InConnectionManager);
    ~FXmppMessagesStrophe();
 
    // XMPP Thread
    bool ReceiveStanza(const FStropheStanza& IncomingStanza);
    bool HandleMessageStanza(const FStropheStanza& IncomingStanza);
    bool HandleMessageErrorStanza(const FStropheStanza& ErrorStanza);
 
    // Game Thread
    void OnDisconnect();
    void OnReconnect();
 
    // IXmppMessages
    virtual bool SendMessage(const FXmppUserJid& RecipientId, const FString& Type, const FString& Payload, bool bPayloadIsSerializedJson = false) override;
    virtual bool SendMessage(const FXmppUserJid& RecipientId, const FString& Type, const TSharedRef<class FJsonObject>& Payload) override;
    virtual FOnXmppMessageReceived& OnReceiveMessage() override { return OnMessageReceivedDelegate; }
 
    // FTSTickerObjectBase
    virtual bool Tick(float DeltaTime) override;
 
protected:
    void OnMessageReceived(TUniquePtr<FXmppMessage>&& Message);
 
    void CleanupMessages();
 
protected:
    FXmppConnectionStrophe& ConnectionManager;
 
    TQueue<TUniquePtr<FXmppMessage>> IncomingMessages;
 
    FOnXmppMessageReceived OnMessageReceivedDelegate;
};
 
#endif