XmppConnectionStrophe.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "XmppConnection.h"
#include "XmppStrophe/StropheConnection.h"
#include "XmppStrophe/XmppStropheThread.h"
#include "XmppStrophe/StropheWebsocketConnection.h"
 
#include "Containers/Ticker.h"
 
#if WITH_XMPP_STROPHE
 
using FXmppMessagesStrophePtr = TSharedPtr<class FXmppMessagesStrophe, ESPMode::ThreadSafe>;
using FXmppMultiUserChatStrophePtr = TSharedPtr<class FXmppMultiUserChatStrophe, ESPMode::ThreadSafe>;
using FXmppPingStrophePtr = TSharedPtr<class FXmppPingStrophe, ESPMode::ThreadSafe>;
using FXmppPresenceStrophePtr = TSharedPtr<class FXmppPresenceStrophe, ESPMode::ThreadSafe>;
using FXmppPrivateChatStrophePtr = TSharedPtr<class FXmppPrivateChatStrophe, ESPMode::ThreadSafe>;
using FXmppPubSubStrophePtr = TSharedPtr<class FXmppPubSubStrophe, ESPMode::ThreadSafe>;
 
class FStropheContext;
class FStropheError;
 
class FXmppConnectionStrophe
    : public IXmppConnection
    , public FTSTickerObjectBase
{
    friend FXmppStropheThread;
 
public:
    // FXmppConnectionStrophe
    explicit FXmppConnectionStrophe();
    virtual ~FXmppConnectionStrophe();
    FXmppConnectionStrophe(const FXmppConnectionStrophe& Other) = delete;
    FXmppConnectionStrophe(FXmppConnectionStrophe&& Other) = delete;
    FXmppConnectionStrophe& operator=(const FXmppConnectionStrophe& Other) = delete;
    FXmppConnectionStrophe& operator=(FXmppConnectionStrophe&& Other) = delete;
 
    // Game Thread methods
 
    // IXmppConnection
    virtual void SetServer(const FXmppServer& NewServerConfiguration) override;
    virtual const FXmppServer& GetServer() const override;
 
    virtual void Login(const FString& UserId, const FString& Auth) override;
    virtual void Logout() override;
 
    virtual EXmppLoginStatus::Type GetLoginStatus() const override;
 
    virtual const FXmppUserJid& GetUserJid() const override;
 
    virtual FOnXmppLoginComplete& OnLoginComplete() override { return OnXmppLoginCompleteDelegate; }
    virtual FOnXmppLoginChanged& OnLoginChanged() override { return OnXmppLoginChangedDelegate; }
    virtual FOnXmppLogoutComplete& OnLogoutComplete() override { return OnXmppLogoutCompleteDelegate; }
    virtual FOnXmppStanzaSent& OnStanzaSent() override { return OnXmppStanzaSentDelegate; }
    virtual FOnXmppStanzaReceived& OnStanzaReceived() override { return OnXmppStanzaReceivedDelegate; }
 
    virtual IXmppMessagesPtr Messages() override;
    virtual IXmppMultiUserChatPtr MultiUserChat() override;
    virtual IXmppPresencePtr Presence() override;
    virtual IXmppChatPtr PrivateChat() override;
    virtual IXmppPubSubPtr PubSub() override;
 
    virtual void DumpState() const override;
 
    // FTSTickerObjectBase
    virtual bool Tick(float DeltaTime) override;
 
    bool SendStanza(FStropheStanza&& Stanza);
 
    void StartXmppThread(const FXmppUserJid& ConnectionUser, const FString& ConnectionAuth);
    void StopXmppThread();
 
    // XMPP Thread methods
 
    void ReceiveConnectionStateChange(EStropheConnectionEvent Event, bool bQueue = true);
    void ReceiveConnectionError(const FStropheError& Error, EStropheConnectionEvent Event);
    void ReceiveStanza(const FStropheStanza& Stanza);
    void QueueNewLoginStatus(EXmppLoginStatus::Type NewStatus);
    void ProcessLoginStatusChange(EXmppLoginStatus::Type NewLoginStatus);
 
    const FStropheContext& GetContext() const { return StropheContext; }
 
    const FString& GetMucDomain() const { return MucDomain; }
 
private:
    void ReconnectLogin();
 
protected:
    FStropheContext StropheContext;
 
    TUniquePtr<FXmppStropheThread> StropheThread;
 
    TUniquePtr<FStropheWebsocketConnection> WebsocketConnection;
 
    TAtomic<EXmppLoginStatus::Type> LoginStatus;
 
    TQueue<EXmppLoginStatus::Type> IncomingLoginStatusChanges;
 
    FXmppServer ServerConfiguration;
 
    FXmppUserJid UserJid;
 
    FString MucDomain;
 
    FThreadSafeBool RequestLogout;
 
    FOnXmppLoginComplete OnXmppLoginCompleteDelegate;
    FOnXmppLoginChanged OnXmppLoginChangedDelegate;
    FOnXmppLogoutComplete OnXmppLogoutCompleteDelegate;
 
    FOnXmppStanzaReceived OnXmppStanzaReceivedDelegate;
    FOnXmppStanzaSent OnXmppStanzaSentDelegate;
 
    FXmppMessagesStrophePtr MessagesStrophe;
    FXmppMultiUserChatStrophePtr MultiUserChatStrophe;
    FXmppPingStrophePtr PingStrophe;
    FXmppPresenceStrophePtr PresenceStrophe;
    FXmppPrivateChatStrophePtr PrivateChatStrophe;
    FXmppPubSubStrophePtr PubSubStrophe;
};
 
#endif