SessionService.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "IMessageContext.h"
#include "IMessageBus.h"
#include "ISessionService.h"
#include "MessageEndpoint.h"
 
struct FSessionServiceLogSubscribe;
struct FSessionServiceLogUnsubscribe;
struct FSessionServicePing;
 
 
class FSessionService
    : public FOutputDevice
    , public ISessionService
{
public:
 
    FSessionService(const TSharedRef<IMessageBus, ESPMode::ThreadSafe>& InMessageBus);
 
    virtual ~FSessionService();
 
public:
 
    //~ FOutputDevice interface
 
    virtual void Serialize(const TCHAR* Data, ELogVerbosity::Type Verbosity, const class FName& Category) override
    {
        SendLog(Data, Verbosity, Category);
    }
 
public:
 
    //~ ISessionService interface
 
    virtual bool IsRunning() override
    {
        return MessageEndpoint.IsValid();
    }
 
    virtual bool Start() override;
    virtual void Stop() override;
 
protected:
 
    void SendLog(const TCHAR* Data, ELogVerbosity::Type Verbosity = ELogVerbosity::Log, const class FName& Category = "Log");
 
    void SendNotification(const TCHAR* NotificationText, const FMessageAddress& Recipient);
 
    void SendPong(const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context, const FString& UserName);
 
private:
 
    void HandleMessageEndpointShutdown();
 
    void HandleSessionLogSubscribeMessage(const FSessionServiceLogSubscribe& Message, const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context);
 
    void HandleSessionLogUnsubscribeMessage(const FSessionServiceLogUnsubscribe& Message, const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context);
 
    void HandleSessionPingMessage(const FSessionServicePing& Message, const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context);
 
private:
 
    TArray<FMessageAddress> LogSubscribers;
 
    FCriticalSection LogSubscribersLock;
 
    TWeakPtr<IMessageBus, ESPMode::ThreadSafe> MessageBusPtr;
 
    TSharedPtr<FMessageEndpoint, ESPMode::ThreadSafe> MessageEndpoint;
 
    bool IsInSendLog;
};