XmppModule.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "Containers/Array.h"
#include "Containers/Map.h"
#include "Containers/Set.h"
#include "Containers/Ticker.h"
#include "Containers/UnrealString.h"
#include "CoreMinimal.h"
#include "Delegates/Delegate.h"
#include "HAL/Platform.h"
#include "Misc/CoreMisc.h"
#include "Modules/ModuleInterface.h"
#include "Templates/SharedPointer.h"
#include "XmppConnection.h"
#include "XmppMultiUserChat.h"
 
class Error;
class FOutputDevice;
class IXmppConnection;
class UWorld;
 
class FXmppModule :
    public IModuleInterface, public FSelfRegisteringExec, public FTSTickerObjectBase
{
 
protected:
 
    // FSelfRegisteringExec
 
    XMPP_API virtual bool Exec_Runtime(UWorld* InWorld, const TCHAR* Cmd, FOutputDevice& Ar) override;
 
public:
 
    XMPP_API bool HandleXmppCommand( const TCHAR* Cmd, FOutputDevice& Ar );
 
    // FXmppModule
 
    static XMPP_API FXmppModule& Get();
 
    static XMPP_API bool IsAvailable();
 
    XMPP_API TSharedRef<class IXmppConnection> CreateConnection(const FString& UserId);
 
    XMPP_API TSharedPtr<class IXmppConnection> GetConnection(const FString& UserId) const;
 
    XMPP_API void RemoveConnection(const FString& UserId);
 
    XMPP_API void ProcessPendingRemovals();
 
    XMPP_API void RemoveConnection(const TSharedRef<class IXmppConnection>& Connection);
 
    inline bool IsXmppEnabled() const
    {
        return bEnabled;
    }
 
    // FTSTickerObjectBase
    XMPP_API virtual bool Tick(float DeltaTime) override;
 
    DECLARE_EVENT_TwoParams(FXmppModule, FOnXmppConnectionAcquired, const TSharedRef<IXmppConnection>& /*XmppConnection*/, const FString& /*SystemName*/);
    FOnXmppConnectionAcquired OnXmppConnectionAcquired;
 
    DECLARE_EVENT_TwoParams(FXmppModule, FOnXmppConnectionRelinquished, const TSharedRef<IXmppConnection>& /*XmppConnection*/, const FString& /*SystemName*/);
    FOnXmppConnectionRelinquished OnXmppConnectionRelinquished;
 
    DECLARE_MULTICAST_DELEGATE_OneParam(FOnXmppConnectionCreated, const TSharedRef<IXmppConnection>& /*NewConnection*/);
    FOnXmppConnectionCreated OnXmppConnectionCreated;
 
 
private:
 
    // IModuleInterface
 
    XMPP_API void OnXmppRoomCreated(const TSharedRef<IXmppConnection>& Connection, bool bSuccess, const FXmppRoomId& RoomId, const FString& Error);
    XMPP_API void OnXmppRoomConfigured(const TSharedRef<IXmppConnection>& Connection, bool bSuccess, const FXmppRoomId& RoomId, const FString& Error);
 
    XMPP_API virtual void StartupModule() override;
    
    XMPP_API virtual void ShutdownModule() override;
 
    XMPP_API void CleanupConnection(const TSharedRef<class IXmppConnection>& Connection);
 
    bool bEnabled;
    static XMPP_API FXmppModule* Singleton;
 
    TMap<FString, TSharedRef<class IXmppConnection>> ActiveConnections;
    TSet<TSharedPtr<IXmppConnection>> PendingRemovals;
    TArray<TSharedRef<class IXmppConnection>> PendingDeleteConnections;
};