OpenAIProvider.h

// OpenAI, Copyright LifeEXE. All Rights Reserved.
 
/*
 ___       ___  ________ _______
|\  \     |\  \|\  _____\\  ___ \
\ \  \    \ \  \ \  \__/\ \   __/|
 \ \  \    \ \  \ \   __\\ \  \_|/__
  \ \  \____\ \  \ \  \_| \ \  \_|\ \
   \ \_______\ \__\ \__\   \ \_______\
    \|_______|\|__|\|__|    \|_______|
 
 
 
 _______      ___    ___ _______
|\  ___ \    |\  \  /  /|\  ___ \
\ \   __/|   \ \  \/  / | \   __/|
 \ \  \_|/__  \ \    / / \ \  \_|/__
  \ \  \_|\ \  /     \/   \ \  \_|\ \
   \ \_______\/  /\   \    \ \_______\
    \|_______/__/ /\ __\    \|_______|
             |__|/ \|__|
*/
 
#pragma once
 
#include "CoreMinimal.h"
#include "HTTP.h"
#include "Delegates.h"
#include "Types/AllTypesHeader.h"
#include "FuncLib/OpenAIFuncLib.h"
#include "FuncLib/JsonFuncLib.h"
#include "Provider/JsonParsers/ChatParser.h"
#include "Provider/JsonParsers/FineTuningParser.h"
#include "Provider/JsonParsers/EvalParser.h"
#include "Provider/JsonParsers/VectorStoreParser.h"
#include "Provider/JsonParsers/ChatKitParser.h"
#include "JsonObjectConverter.h"
#include "OpenAIProvider.generated.h"
 
class FJsonObject;
 
namespace OpenAI
{
class IAPI;
}
 
UCLASS()
class OPENAI_API UOpenAIProvider : public UObject
{
    GENERATED_BODY()
 
public:
    UOpenAIProvider();
 
    void SetAPI(const TSharedPtr<OpenAI::IAPI>& API);
 
public:
    void ListModels(const FOpenAIAuth& Auth);

    void RetrieveModel(const FString& ModelName, const FOpenAIAuth& Auth);

    void DeleteFineTunedModel(const FString& ModelID, const FOpenAIAuth& Auth);

    void CreateCompletion(const FCompletion& Completion, const FOpenAIAuth& Auth);

    void CreateChatCompletion(const FChatCompletion& Completion, const FOpenAIAuth& Auth);

    void CreateImage(const FOpenAIImage& Image, const FOpenAIAuth& Auth);

    void CreateImageEdit(const FOpenAIImageEdit& ImageEdit, const FOpenAIAuth& Auth);

    void CreateImageVariation(const FOpenAIImageVariation& ImageVariation, const FOpenAIAuth& Auth);

    void CreateEmbeddings(const FEmbeddings& Embeddings, const FOpenAIAuth& Auth);

    void CreateSpeech(const FSpeech& Speech, const FOpenAIAuth& Auth);

    void CreateAudioTranscription(const FAudioTranscription& AudioTranscription, const FOpenAIAuth& Auth);

    void CreateVoice(const FCreateVoice& CreateVoice, const FOpenAIAuth& Auth);

    void CreateAudioTranslation(const FAudioTranslation& AudioTranslation, const FOpenAIAuth& Auth);

    void ListFiles(const FListFilesParams& ListFilesParams, const FOpenAIAuth& Auth);

    void UploadFile(const FUploadFile& UploadFile, const FOpenAIAuth& Auth);

    void DeleteFile(const FString& FileID, const FOpenAIAuth& Auth);

    void RetrieveFile(const FString& FileID, const FOpenAIAuth& Auth);

    void RetrieveFileContent(const FString& FileID, const FOpenAIAuth& Auth);

    void CreateModerations(const FModerations& Moderations, const FOpenAIAuth& Auth);

    void CreateFineTuningJob(const FFineTuningJob& FineTuningJob, const FOpenAIAuth& Auth);

    void ListFineTuningJobs(const FOpenAIAuth& Auth, const FFineTuningQueryParameters& FineTuningQueryParameters = {});

    void ListFineTuningEvents(
        const FString& FineTuningJobID, const FOpenAIAuth& Auth, const FFineTuningQueryParameters& FineTuningQueryParameters = {});

    void ListFineTuningCheckpoints(
        const FString& FineTuningJobID, const FOpenAIAuth& Auth, const FFineTuningQueryParameters& FineTuningQueryParameters = {});

    void RetrieveFineTuningJob(const FString& FineTuningJobID, const FOpenAIAuth& Auth);

    void CancelFineTuningJob(const FString& FineTuneID, const FOpenAIAuth& Auth);
    void PauseFineTuningJob(const FString& FineTuneID, const FOpenAIAuth& Auth);
    void ResumeFineTuningJob(const FString& FineTuneID, const FOpenAIAuth& Auth);

    void CreateBatch(const FCreateBatch& CreateBatch, const FOpenAIAuth& Auth);

    void RetrieveBatch(const FString& BatchId, const FOpenAIAuth& Auth);

    void CancelBatch(const FString& BatchId, const FOpenAIAuth& Auth);

    void ListBatch(const FListBatch& ListBatch, const FOpenAIAuth& Auth);

    void CreateUpload(const FCreateUpload& CreateUpload, const FOpenAIAuth& Auth);

    void AddUploadPart(const FString& UploadId, const FAddUploadPart& AddUploadPart, const FOpenAIAuth& Auth);

    void CompleteUpload(const FString& UploadId, const FCompleteUpload& CompleteUpload, const FOpenAIAuth& Auth);

    void CancelUpload(const FString& UploadId, const FOpenAIAuth& Auth);

    void CreateAssistant(const FCreateAssistant& CreateAssistant, const FOpenAIAuth& Auth);

    void ListAssistants(const FListAssistants& ListAssistants, const FOpenAIAuth& Auth);

    void RetrieveAssistant(const FString& AssistantId, const FOpenAIAuth& Auth);

    void ModifyAssistant(const FString& AssistantId, const FModifyAssistant& ModifyAssistant, const FOpenAIAuth& Auth);

    void DeleteAssistant(const FString& AssistantId, const FOpenAIAuth& Auth);

    void CreateVideo(const FCreateVideo& CreateVideo, const FOpenAIAuth& Auth);

    void RetrieveVideo(const FString& VideoId, const FOpenAIAuth& Auth);

    void ListVideos(const FListVideos& ListVideos, const FOpenAIAuth& Auth);

    void DeleteVideo(const FString& VideoId, const FOpenAIAuth& Auth);

    void RemixVideo(const FString& VideoId, const FRemixVideo& RemixVideo, const FOpenAIAuth& Auth);

    void DownloadVideoContent(const FString& VideoId, const FDownloadVideoContent& DownloadVideoContent, const FOpenAIAuth& Auth);

    void CreateEval(const FCreateEval& CreateEval, const FOpenAIAuth& Auth);

    void ListEvals(const FEvalQueryParams& QueryParams, const FOpenAIAuth& Auth);

    void RetrieveEval(const FString& EvalId, const FOpenAIAuth& Auth);

    void UpdateEval(const FString& EvalId, const FUpdateEval& UpdateEval, const FOpenAIAuth& Auth);

    void DeleteEval(const FString& EvalId, const FOpenAIAuth& Auth);

    void CreateVectorStore(const FCreateVectorStore& CreateVectorStore, const FOpenAIAuth& Auth);

    void ListVectorStores(const FVectorStoreQueryParams& QueryParams, const FOpenAIAuth& Auth);

    void RetrieveVectorStore(const FString& VectorStoreId, const FOpenAIAuth& Auth);

    void UpdateVectorStore(const FString& VectorStoreId, const FUpdateVectorStore& UpdateVectorStore, const FOpenAIAuth& Auth);

    void DeleteVectorStore(const FString& VectorStoreId, const FOpenAIAuth& Auth);

    void CreateVectorStoreFile(const FString& VectorStoreId, const FString& FileId, const FOpenAIAuth& Auth);

    void ListVectorStoreFiles(const FString& VectorStoreId, const FVectorStoreFileQueryParams& QueryParams, const FOpenAIAuth& Auth);

    void RetrieveVectorStoreFile(const FString& VectorStoreId, const FString& FileId, const FOpenAIAuth& Auth);

    void DeleteVectorStoreFile(const FString& VectorStoreId, const FString& FileId, const FOpenAIAuth& Auth);

    void CreateVectorStoreFileBatch(const FString& VectorStoreId, const FCreateVectorStoreFileBatch& CreateBatch, const FOpenAIAuth& Auth);

    void RetrieveVectorStoreFileBatch(const FString& VectorStoreId, const FString& BatchId, const FOpenAIAuth& Auth);

    void CancelVectorStoreFileBatch(const FString& VectorStoreId, const FString& BatchId, const FOpenAIAuth& Auth);

    void SearchVectorStore(const FString& VectorStoreId, const FVectorStoreSearch& Search, const FOpenAIAuth& Auth);

    void CreateChatKitSession(const FCreateChatKitSession& CreateSession, const FOpenAIAuth& Auth);

    void CancelChatKitSession(const FString& SessionId, const FOpenAIAuth& Auth);

    void ListChatKitThreads(const FListChatKitThreads& ListThreads, const FOpenAIAuth& Auth);

    void RetrieveChatKitThread(const FString& ThreadId, const FOpenAIAuth& Auth);

    void DeleteChatKitThread(const FString& ThreadId, const FOpenAIAuth& Auth);

    void ListChatKitThreadItems(const FString& ThreadId, const FListChatKitThreadItems& ListItems, const FOpenAIAuth& Auth);

    void CreateSkill(const FCreateSkill& CreateSkill, const FOpenAIAuth& Auth);

    void ListSkills(const FListSkillsParams& ListParams, const FOpenAIAuth& Auth);

    void RetrieveSkill(const FString& SkillId, const FOpenAIAuth& Auth);

    void UpdateSkill(const FString& SkillId, const FUpdateSkill& UpdateSkill, const FOpenAIAuth& Auth);

    void DeleteSkill(const FString& SkillId, const FOpenAIAuth& Auth);

    void RetrieveSkillContent(const FString& SkillId, const FOpenAIAuth& Auth);

    void CreateSkillVersion(const FString& SkillId, const FCreateSkillVersion& CreateVersion, const FOpenAIAuth& Auth);

    void ListSkillVersions(const FString& SkillId, const FListSkillVersionsParams& ListParams, const FOpenAIAuth& Auth);

    void RetrieveSkillVersion(const FString& SkillId, const FString& Version, const FOpenAIAuth& Auth);

    void DeleteSkillVersion(const FString& SkillId, const FString& Version, const FOpenAIAuth& Auth);

    void RetrieveSkillVersionContent(const FString& SkillId, const FString& Version, const FOpenAIAuth& Auth);

    void CreateRealtimeClientSecret(const FCreateRealtimeClientSecret& CreateSecret, const FOpenAIAuth& Auth);

    void RealtimeAcceptCall(const FString& CallId, const FRealtimeAcceptCall& AcceptCall, const FOpenAIAuth& Auth);

    void RealtimeHangupCall(const FString& CallId, const FOpenAIAuth& Auth);

    void RealtimeReferCall(const FString& CallId, const FRealtimeReferCall& ReferCall, const FOpenAIAuth& Auth);

    void RealtimeRejectCall(const FString& CallId, const FRealtimeRejectCall& RejectCall, const FOpenAIAuth& Auth);

    void SetLogEnabled(bool LogEnabled) { bLogEnabled = LogEnabled; }
 
#define DEFINE_EVENT_GETTER(Name)          \
public:                                    \
    FOn##Name& On##Name() { return Name; } \
                                           \
private:                                   \
    FOn##Name Name;
 
public:
    FOnRequestError& OnRequestError() { return RequestError; };
 
#define DECLARE_HTTP_CALLBACK(Callback) virtual void Callback(FHttpRequestPtr Request, FHttpResponsePtr Response, bool WasSuccessful);
#define DECLARE_HTTP_CALLBACK_PROGRESS(Callback) virtual void Callback(FHttpRequestPtr Request, uint64 BytesSent, uint64 BytesReceived);
 
    DEFINE_EVENT_GETTER(ListModelsCompleted)
    DEFINE_EVENT_GETTER(RetrieveModelCompleted)
    DEFINE_EVENT_GETTER(CreateCompletionCompleted)
    DEFINE_EVENT_GETTER(CreateCompletionStreamCompleted)
    DEFINE_EVENT_GETTER(CreateCompletionStreamProgresses)
    DEFINE_EVENT_GETTER(CreateChatCompletionCompleted)
    DEFINE_EVENT_GETTER(CreateChatCompletionStreamCompleted)
    DEFINE_EVENT_GETTER(CreateChatCompletionStreamProgresses)
    DEFINE_EVENT_GETTER(CreateImageCompleted)
    DEFINE_EVENT_GETTER(CreateImageEditCompleted)
    DEFINE_EVENT_GETTER(CreateImageVariationCompleted)
    DEFINE_EVENT_GETTER(CreateEmbeddingsCompleted)
    DEFINE_EVENT_GETTER(CreateSpeechCompleted)
    DEFINE_EVENT_GETTER(CreateAudioTranscriptionCompleted)
    DEFINE_EVENT_GETTER(CreateAudioTranscriptionVerboseCompleted)
    DEFINE_EVENT_GETTER(CreateAudioTranslationCompleted)
    DEFINE_EVENT_GETTER(CreateVoiceCompleted)
    DEFINE_EVENT_GETTER(ListFilesCompleted)
    DEFINE_EVENT_GETTER(UploadFileCompleted)
    DEFINE_EVENT_GETTER(DeleteFileCompleted)
    DEFINE_EVENT_GETTER(RetrieveFileCompleted)
    DEFINE_EVENT_GETTER(RetrieveFileContentCompleted)
    DEFINE_EVENT_GETTER(CreateFineTuningJobCompleted)
    DEFINE_EVENT_GETTER(ListFineTuningJobsCompleted)
    DEFINE_EVENT_GETTER(ListFineTuningEventsCompleted)
    DEFINE_EVENT_GETTER(ListFineTuningCheckpointsCompleted)
    DEFINE_EVENT_GETTER(DeleteFineTunedModelCompleted)
    DEFINE_EVENT_GETTER(CreateModerationsCompleted)
    DEFINE_EVENT_GETTER(RetrieveFineTuningJobCompleted)
    DEFINE_EVENT_GETTER(CancelFineTuningJobCompleted)
    DEFINE_EVENT_GETTER(PauseFineTuningJobCompleted)
    DEFINE_EVENT_GETTER(ResumeFineTuningJobCompleted)
    DEFINE_EVENT_GETTER(ListBatchCompleted)
    DEFINE_EVENT_GETTER(CreateBatchCompleted)
    DEFINE_EVENT_GETTER(RetrieveBatchCompleted)
    DEFINE_EVENT_GETTER(CancelBatchCompleted)
    DEFINE_EVENT_GETTER(CreateUploadCompleted)
    DEFINE_EVENT_GETTER(AddUploadPartCompleted)
    DEFINE_EVENT_GETTER(CompleteUploadCompleted)
    DEFINE_EVENT_GETTER(CancelUploadCompleted)
    DEFINE_EVENT_GETTER(CreateAssistantCompleted)
    DEFINE_EVENT_GETTER(ListAssistantsCompleted)
    DEFINE_EVENT_GETTER(RetrieveAssistantCompleted)
    DEFINE_EVENT_GETTER(ModifyAssistantCompleted)
    DEFINE_EVENT_GETTER(DeleteAssistantCompleted)
    DEFINE_EVENT_GETTER(CreateVideoCompleted)
    DEFINE_EVENT_GETTER(RetrieveVideoCompleted)
    DEFINE_EVENT_GETTER(ListVideosCompleted)
    DEFINE_EVENT_GETTER(DeleteVideoCompleted)
    DEFINE_EVENT_GETTER(RemixVideoCompleted)
    DEFINE_EVENT_GETTER(DownloadVideoContentCompleted)
    DEFINE_EVENT_GETTER(CreateEvalCompleted)
    DEFINE_EVENT_GETTER(ListEvalsCompleted)
    DEFINE_EVENT_GETTER(RetrieveEvalCompleted)
    DEFINE_EVENT_GETTER(UpdateEvalCompleted)
    DEFINE_EVENT_GETTER(DeleteEvalCompleted)
 
    DEFINE_EVENT_GETTER(CreateVectorStoreCompleted)
    DEFINE_EVENT_GETTER(ListVectorStoresCompleted)
    DEFINE_EVENT_GETTER(RetrieveVectorStoreCompleted)
    DEFINE_EVENT_GETTER(UpdateVectorStoreCompleted)
    DEFINE_EVENT_GETTER(DeleteVectorStoreCompleted)
    DEFINE_EVENT_GETTER(CreateVectorStoreFileCompleted)
    DEFINE_EVENT_GETTER(ListVectorStoreFilesCompleted)
    DEFINE_EVENT_GETTER(RetrieveVectorStoreFileCompleted)
    DEFINE_EVENT_GETTER(DeleteVectorStoreFileCompleted)
    DEFINE_EVENT_GETTER(CreateVectorStoreFileBatchCompleted)
    DEFINE_EVENT_GETTER(RetrieveVectorStoreFileBatchCompleted)
    DEFINE_EVENT_GETTER(CancelVectorStoreFileBatchCompleted)
    DEFINE_EVENT_GETTER(SearchVectorStoreCompleted)
 
    DEFINE_EVENT_GETTER(CreateChatKitSessionCompleted)
    DEFINE_EVENT_GETTER(CancelChatKitSessionCompleted)
    DEFINE_EVENT_GETTER(ListChatKitThreadsCompleted)
    DEFINE_EVENT_GETTER(RetrieveChatKitThreadCompleted)
    DEFINE_EVENT_GETTER(DeleteChatKitThreadCompleted)
    DEFINE_EVENT_GETTER(ListChatKitThreadItemsCompleted)
 
    DEFINE_EVENT_GETTER(CreateSkillCompleted)
    DEFINE_EVENT_GETTER(ListSkillsCompleted)
    DEFINE_EVENT_GETTER(RetrieveSkillCompleted)
    DEFINE_EVENT_GETTER(UpdateSkillCompleted)
    DEFINE_EVENT_GETTER(DeleteSkillCompleted)
    DEFINE_EVENT_GETTER(RetrieveSkillContentCompleted)
    DEFINE_EVENT_GETTER(CreateSkillVersionCompleted)
    DEFINE_EVENT_GETTER(ListSkillVersionsCompleted)
    DEFINE_EVENT_GETTER(RetrieveSkillVersionCompleted)
    DEFINE_EVENT_GETTER(DeleteSkillVersionCompleted)
    DEFINE_EVENT_GETTER(RetrieveSkillVersionContentCompleted)
 
    DEFINE_EVENT_GETTER(CreateRealtimeClientSecretCompleted)
    DEFINE_EVENT_GETTER(RealtimeAcceptCallCompleted)
    DEFINE_EVENT_GETTER(RealtimeHangupCallCompleted)
    DEFINE_EVENT_GETTER(RealtimeReferCallCompleted)
    DEFINE_EVENT_GETTER(RealtimeRejectCallCompleted)
 
private:
    TSharedPtr<OpenAI::IAPI> API;
    bool bLogEnabled{true};
    FOnRequestError RequestError;
 
#define DECLARE_HTTP_CALLBACK(Callback) virtual void Callback(FHttpRequestPtr Request, FHttpResponsePtr Response, bool WasSuccessful);
#define DECLARE_HTTP_CALLBACK_PROGRESS(Callback) virtual void Callback(FHttpRequestPtr Request, uint64 BytesSent, uint64 BytesReceived);
 
    DECLARE_HTTP_CALLBACK(OnListModelsCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveModelCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateCompletionCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateCompletionStreamCompleted)
    DECLARE_HTTP_CALLBACK_PROGRESS(OnCreateCompletionStreamProgress)
    DECLARE_HTTP_CALLBACK(OnCreateChatCompletionCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateChatCompletionStreamCompleted)
    DECLARE_HTTP_CALLBACK_PROGRESS(OnCreateChatCompletionStreamProgress)
    DECLARE_HTTP_CALLBACK(OnCreateImageCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateImageEditCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateImageVariationCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateEmbeddingsCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateSpeechCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateAudioTranscriptionCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateAudioTranslationCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateVoiceCompleted)
    DECLARE_HTTP_CALLBACK(OnListFilesCompleted)
    DECLARE_HTTP_CALLBACK(OnUploadFileCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteFileCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveFileCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveFileContentCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteFineTunedModelCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateModerationsCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateFineTuningJobCompleted)
    DECLARE_HTTP_CALLBACK(OnListFineTuningJobsCompleted)
    DECLARE_HTTP_CALLBACK(OnListFineTuningEventsCompleted)
    DECLARE_HTTP_CALLBACK(OnListFineTuningCheckpointsCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveFineTuningJobCompleted)
    DECLARE_HTTP_CALLBACK(OnCancelFineTuningJobCompleted)
    DECLARE_HTTP_CALLBACK(OnPauseFineTuningJobCompleted)
    DECLARE_HTTP_CALLBACK(OnResumeFineTuningJobCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateBatchCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveBatchCompleted)
    DECLARE_HTTP_CALLBACK(OnCancelBatchCompleted)
    DECLARE_HTTP_CALLBACK(OnListBatchCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateUploadCompleted)
    DECLARE_HTTP_CALLBACK(OnAddUploadPartCompleted)
    DECLARE_HTTP_CALLBACK(OnCompleteUploadCompleted)
    DECLARE_HTTP_CALLBACK(OnCancelUploadCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateAssistantCompleted)
    DECLARE_HTTP_CALLBACK(OnListAssistantsCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveAssistantCompleted)
    DECLARE_HTTP_CALLBACK(OnModifyAssistantCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteAssistantCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateVideoCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveVideoCompleted)
    DECLARE_HTTP_CALLBACK(OnListVideosCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteVideoCompleted)
    DECLARE_HTTP_CALLBACK(OnRemixVideoCompleted)
    DECLARE_HTTP_CALLBACK(OnDownloadVideoContentCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateEvalCompleted)
    DECLARE_HTTP_CALLBACK(OnListEvalsCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveEvalCompleted)
    DECLARE_HTTP_CALLBACK(OnUpdateEvalCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteEvalCompleted)
 
    DECLARE_HTTP_CALLBACK(OnCreateVectorStoreCompleted)
    DECLARE_HTTP_CALLBACK(OnListVectorStoresCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveVectorStoreCompleted)
    DECLARE_HTTP_CALLBACK(OnUpdateVectorStoreCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteVectorStoreCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateVectorStoreFileCompleted)
    DECLARE_HTTP_CALLBACK(OnListVectorStoreFilesCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveVectorStoreFileCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteVectorStoreFileCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateVectorStoreFileBatchCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveVectorStoreFileBatchCompleted)
    DECLARE_HTTP_CALLBACK(OnCancelVectorStoreFileBatchCompleted)
    DECLARE_HTTP_CALLBACK(OnSearchVectorStoreCompleted)
 
    DECLARE_HTTP_CALLBACK(OnCreateChatKitSessionCompleted)
    DECLARE_HTTP_CALLBACK(OnCancelChatKitSessionCompleted)
    DECLARE_HTTP_CALLBACK(OnListChatKitThreadsCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveChatKitThreadCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteChatKitThreadCompleted)
    DECLARE_HTTP_CALLBACK(OnListChatKitThreadItemsCompleted)
 
    DECLARE_HTTP_CALLBACK(OnCreateSkillCompleted)
    DECLARE_HTTP_CALLBACK(OnListSkillsCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveSkillCompleted)
    DECLARE_HTTP_CALLBACK(OnUpdateSkillCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteSkillCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveSkillContentCompleted)
    DECLARE_HTTP_CALLBACK(OnCreateSkillVersionCompleted)
    DECLARE_HTTP_CALLBACK(OnListSkillVersionsCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveSkillVersionCompleted)
    DECLARE_HTTP_CALLBACK(OnDeleteSkillVersionCompleted)
    DECLARE_HTTP_CALLBACK(OnRetrieveSkillVersionContentCompleted)
 
    DECLARE_HTTP_CALLBACK(OnCreateRealtimeClientSecretCompleted)
    DECLARE_HTTP_CALLBACK(OnRealtimeAcceptCallCompleted)
    DECLARE_HTTP_CALLBACK(OnRealtimeHangupCallCompleted)
    DECLARE_HTTP_CALLBACK(OnRealtimeReferCallCompleted)
    DECLARE_HTTP_CALLBACK(OnRealtimeRejectCallCompleted)
 
    void ProcessRequest(FHttpRequestRef HttpRequest);
 
    bool Success(FHttpResponsePtr Response, bool WasSuccessful);
    void Log(const FString& Info) const;
    void LogResponse(FHttpResponsePtr Response) const;
    void LogError(const FString& ErrorText) const;
 
    template <typename OutStructType>
    FString SerializeRequest(const OutStructType& OutStruct) const
    {
        TSharedPtr<FJsonObject> Json = FJsonObjectConverter::UStructToJsonObject(OutStruct);
        UJsonFuncLib::RemoveEmptyArrays(Json);
        FString RequestBodyStr;
        UJsonFuncLib::JsonToString(Json, RequestBodyStr);
        return RequestBodyStr;
    }
 
    FHttpRequestRef MakeRequestHeaders(const FOpenAIAuth& Auth) const;
    FOpenAIResponseMetadata GetResponseHeaders(FHttpResponsePtr Response) const;
 
    template <typename OutStructType>
    FHttpRequestRef MakeRequest(const OutStructType& OutStruct, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const
    {
        auto HttpRequest = MakeRequestHeaders(Auth);
        HttpRequest->SetURL(URL);
        HttpRequest->SetVerb(Method);
 
        const FString Content = SerializeRequest(OutStruct);
        Log(FString("Content: ").Append(Content));
 
        const FString PostprocessedContent = UJsonFuncLib::RemoveOptionalValuesThatNotSet(Content);
        Log(FString("Postprocessed content was set as: ").Append(PostprocessedContent));
 
        HttpRequest->SetContentAsString(PostprocessedContent);
        return HttpRequest;
    }
    // specializations
    FHttpRequestRef MakeRequest(const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(
        const FChatCompletion& ChatCompletion, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(
        const FFineTuningJob& FineTuningJob, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(const FCreateEval& CreateEval, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(const FUpdateEval& UpdateEval, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(
        const FCreateVectorStore& CreateVectorStore, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(
        const FUpdateVectorStore& UpdateVectorStore, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(
        const FCreateVectorStoreFileBatch& CreateBatch, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(const FVectorStoreSearch& Search, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(const FCreateSkill& CreateSkill, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
    FHttpRequestRef MakeRequest(
        const FCreateSkillVersion& CreateVersion, const FString& URL, const FString& Method, const FOpenAIAuth& Auth) const;
 
    template <typename ParsedResponseType, typename DelegateType>
    void HandleResponse(FHttpResponsePtr Response, bool WasSuccessful, DelegateType& Delegate)
    {
        if (!Success(Response, WasSuccessful)) return;
 
        const FString Content = Response.IsValid() ? Response->GetContentAsString() : FString{};
        const FString ResponseURL = Response.IsValid() ? Response->GetURL() : FString{};
 
        ParsedResponseType ParsedResponse;
        if (UJsonFuncLib::ParseJSONToStruct(Content, &ParsedResponse))
        {
            Delegate.Broadcast(ParsedResponse, GetResponseHeaders(Response));
        }
        else
        {
            LogError(FString::Format(TEXT("JSON deserialization error: {0}"), {Content}));
            RequestError.Broadcast(ResponseURL, Content);
        }
    }
 
    virtual TSharedRef<IHttpRequest, ESPMode::ThreadSafe> CreateRequest() const { return FHttpModule::Get().CreateRequest(); }
 
private:
    void SetOptional(TSharedPtr<FJsonObject> RequestBody, const TOptional<FString>& Param, const FString& ParamName);
    void SetOptional(TSharedPtr<FJsonObject> RequestBody, const TOptional<bool>& Param, const FString& ParamName);
    void SetOptional(TSharedPtr<FJsonObject> RequestBody, const TOptional<TArray<float>>& Param, const FString& ParamName);
 
    template <typename NumberType>
    void SetOptional(TSharedPtr<FJsonObject> RequestBody, const TOptional<NumberType>& Param, const FString& ParamName)
    {
        if (!Param.IsSet()) return;
        RequestBody->SetNumberField(ParamName, Param.GetValue());
    }
 
private:
    TTuple<FString, FString> GetErrorData(FHttpRequestPtr Request, FHttpResponsePtr Response) const;
 
    template <typename ResponseType>
    bool ParseStreamRequest(FHttpResponsePtr Response, TArray<ResponseType>& Responses)
    {
        if (!Response.IsValid()) return false;
 
        TArray<FString> StringArray;
        Response->GetContentAsString().ParseIntoArrayLines(StringArray);
 
        for (auto& String : StringArray)
        {
            bool LastString{false};
            if (OpenAI::ChatParser::CleanChunkResponseString(String, LastString))
            {
                if (LastString)
                {
                    break;
                }
                ResponseType ParsedResponse;
                if (!UJsonFuncLib::ParseJSONToStruct(String, &ParsedResponse)) continue;
 
                Responses.Add(ParsedResponse);
            }
        }
        return true;
    }
 
    template <typename ResponseType, typename DelegateType>
    void OnStreamProgress(FHttpRequestPtr Request, uint64 BytesSent, uint64 BytesReceived, DelegateType& Delegate)
    {
        const auto& Response = Request->GetResponse();
        TArray<ResponseType> ParsedResponses;
 
        if (ParseStreamRequest(Response, ParsedResponses))
        {
            LogResponse(Response);
            Delegate.Broadcast(ParsedResponses, GetResponseHeaders(Response));
        }
        else if (Response.IsValid())
        {
            LogError(Response->GetContentAsString());
            // RequestError.Broadcast(Response->GetURL(), Response->GetContentAsString());
        }
        else if (BytesReceived == 0)
        {
            // UE_5.3: on some reason OnRequestProgress() sends first time with Request = nullptr
            // BytesReceived = 0 in this case, empty initial call ?
            // Remove error message from log because nothing bad happened
        }
        else
        {
            LogError(FString::Format(TEXT("JSON deserialization error BytesSent:{0} BytesReceived:{1}"), {BytesSent, BytesReceived}));
        }
    }
 
    template <typename ResponseType, typename DelegateType>
    void OnStreamCompleted(FHttpRequestPtr Request, FHttpResponsePtr Response, bool WasSuccessful, DelegateType& Delegate)
    {
        if (!WasSuccessful)
        {
            const auto& [URL, Content] = GetErrorData(Request, Response);
            LogError(Content);
            RequestError.Broadcast(URL, Content);
            return;
        }
 
        TArray<ResponseType> ParsedResponses;
        if (ParseStreamRequest(Response, ParsedResponses))
        {
            LogResponse(Response);
            Delegate.Broadcast(ParsedResponses, GetResponseHeaders(Response));
        }
        else
        {
            const FString Content = Response.IsValid() ? Response->GetContentAsString() : FString{};
            const FString ResponseURL = Response.IsValid() ? Response->GetURL() : FString{};
 
            LogError(FString::Format(TEXT("JSON deserialization error: {0}"), {Content}));
            LogError(Content);
            RequestError.Broadcast(ResponseURL, Content);
        }
    }
};