VoxtaApiResponseHandler.h

Go to the documentation of this file.

// Copyright(c) 2025 grrimgrriefer & DZnnah, see LICENSE for details.
 
#pragma once
 
#include "CoreMinimal.h"
#include "VoxtaDefines.h"
 
class FSignalRValue;
struct ServerResponseBase;
struct ServerResponseWelcome;
struct ServerResponseCharacterList;
struct ServerResponseContextUpdated;
struct ServerResponseChatStarted;
struct ServerResponseChatMessageStart;
struct ServerResponseChatMessageChunk;
struct ServerResponseChatMessageEnd;
struct ServerResponseChatMessageCancelled;
struct ServerResponseChatUpdate;
struct ServerResponseChatClosed;
struct ServerResponseSpeechTranscription;
struct ServerResponseError;
struct ServerResponseChatSessionError;
struct ServerResponseConfiguration;

class VoxtaApiResponseHandler
{
#pragma region public API
public:
    static const TSet<FString> IGNORED_MESSAGE_TYPES;

    static TUniquePtr<ServerResponseBase> GetResponseData(
        const TMap<FString, FSignalRValue>& serverResponseData);
#pragma endregion
 
#pragma region VoxtaServer response deserialize handlers
private:
    static const TMap<FString, TFunction<TUniquePtr<ServerResponseBase>(const TMap<FString, FSignalRValue>&)>> HANDLERS;

    static TUniquePtr<ServerResponseWelcome> GetWelcomeResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseCharacterList> GetCharacterListLoadedResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseContextUpdated> GetContextUpdatedResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatStarted> GetChatStartedResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatMessageStart> GetReplyStartResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatMessageChunk> GetReplyChunkResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatMessageEnd> GetReplyEndResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatMessageCancelled> GetReplyCancelledResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatUpdate> GetChatUpdateResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatClosed> GetChatClosedResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseSpeechTranscription> GetSpeechRecognitionPartial(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseSpeechTranscription> GetSpeechRecognitionEnd(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseError> GetErrorResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseChatSessionError> GetChatSessionErrorResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static TUniquePtr<ServerResponseConfiguration> GetConfigurationResponse(
        const TMap<FString, FSignalRValue>& serverResponseData);

    static void ProcessContextData(const TMap<FString, FSignalRValue>& contextMainObject, FString& outContextValue);

    template<typename T>
    static TUniquePtr<ServerResponseBase> WrapHandler(TUniquePtr<T>(*handler)(const TMap<FString, FSignalRValue>&),
        const TMap<FString, FSignalRValue>& data)
    {
        return handler(data);   
    }
#pragma endregion
 
private:
    static FGuid GetStringAsGuid(const FSignalRValue& input);

    static FGuid GetStringAsGuid(const FString& input);
};