Add DTFluxRaceResult Module. A Tab to manage RaceResult with a WebConsole interface

Resources/DTFluxRaceResult16x16.svg

@@ -0,0 +1,41 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<!-- Created with Inkscape (http://www.inkscape.org/) -->
+
+<svg
+   width="512"
+   height="512"
+   viewBox="0 0 512 512"
+   version="1.1"
+   id="svg1"
+   xml:space="preserve"
+   inkscape:export-filename="RaceResult.icone16x16.svg"
+   inkscape:export-xdpi="96"
+   inkscape:export-ydpi="96"
+   sodipodi:docname="RaceResult.icone16x16.svg"
+   xmlns:inkscape="http://www.inkscape.org/namespaces/inkscape"
+   xmlns:sodipodi="http://sodipodi.sourceforge.net/DTD/sodipodi-0.dtd"
+   xmlns="http://www.w3.org/2000/svg"
+   xmlns:svg="http://www.w3.org/2000/svg"><sodipodi:namedview
+     id="namedview1"
+     pagecolor="#505050"
+     bordercolor="#eeeeee"
+     borderopacity="1"
+     inkscape:showpageshadow="0"
+     inkscape:pageopacity="0"
+     inkscape:pagecheckerboard="0"
+     inkscape:deskcolor="#505050"
+     inkscape:document-units="px" /><defs
+     id="defs1" /><g
+     inkscape:label="Calque 1"
+     inkscape:groupmode="layer"
+     id="layer1"
+     transform="translate(3.0517578e-5)"><rect
+       style="fill:#e22c2b;fill-opacity:1;stroke:none;stroke-width:1;stroke-linecap:round;stroke-linejoin:miter;stroke-dasharray:none;stroke-opacity:1;paint-order:markers fill stroke"
+       id="rect1"
+       width="512"
+       height="512"
+       x="-3.0517578e-05"
+       y="0" /><path
+       style="fill:none;stroke:#ffffff;stroke-width:15;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1;paint-order:markers fill stroke"
+       d="m 154.64305,277.08769 -1.3605,-151.92206 146.48007,103.3977 v 184.12046 l 54.87334,-50.79185 V 199.53942 L 215.41187,92.967228 V 328.78654 Z"
+       id="path1" /></g></svg>

Source/DTFluxAPIStatus/DTFluxAPIStatus.Build.cs

@@ -31,7 +31,6 @@ public class DTFluxAPIStatus : ModuleRules
 				"DTFluxCoreSubsystem",
 				"InputCore",
 				"OutputLog",
-				"ToolMenus",
 			}
 		);
 	}

Source/DTFluxAPIStatus/Private/DTFluxAPIStatusModule.cpp

@@ -14,9 +14,9 @@ FText DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::StatusTabDisplayName = FText::
 
 void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::StartupModule()
 {
-	FDTFluxStatusStyle::RegisterStyle();
 	InitMenuExtension();
 	RegisterStatusTab();
+	FDTFluxStatusStyle::RegisterStyle();
 }
 
 
@@ -25,108 +25,44 @@ void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::StartupModule()
 
 void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::InitMenuExtension()
 {
-	// FLevelEditorModule& LevelEditorModule =
+	FLevelEditorModule& LevelEditorModule =
-	// 	FModuleManager::LoadModuleChecked<FLevelEditorModule>(TEXT("LevelEditor"));
+		FModuleManager::LoadModuleChecked<FLevelEditorModule>(TEXT("LevelEditor"));
-	// // FDTFluxAPIModule& DTFluxApi =
+	// FDTFluxAPIModule& DTFluxApi =
-	// // 	FModuleManager::LoadModuleChecked<FDTFluxAPIModule>(TEXT("DTFluxAPI"));
+	// 	FModuleManager::LoadModuleChecked<FDTFluxAPIModule>(TEXT("DTFluxAPI"));
-	// const TSharedPtr<FExtender> MenuExtender = MakeShareable(new FExtender());
+	const TSharedPtr<FExtender> MenuExtender = MakeShareable(new FExtender());
-	//
-	// MenuExtender->AddMenuBarExtension(
-	// 	"Help",
-	// 	EExtensionHook::Before,
-	// 	nullptr,
-	// 	FMenuBarExtensionDelegate::CreateRaw(this, &FDTFluxAPIStatusModule::AddMenu)
-	// 	);
-	// LevelEditorModule.GetMenuExtensibilityManager()->AddExtender(MenuExtender);
 
-	UToolMenus::RegisterStartupCallback(
+	MenuExtender->AddMenuBarExtension(
-		FSimpleMulticastDelegate::FDelegate::CreateRaw(this, &FDTFluxAPIStatusModule::RegisterMenus)
+		"Help",
-	);
+		EExtensionHook::Before,
-
+		nullptr,
-}
+		FMenuBarExtensionDelegate::CreateRaw(this, &FDTFluxAPIStatusModule::AddMenu)
-
-void FDTFluxAPIStatusModule::RegisterMenus()
-{
-	UE_LOG(logDTFluxStatus, Warning, TEXT("Creating DTFlux menu"));
-    
-	// 1. Enregistrer le menu DTFlux
-	UToolMenu* DTFluxMenu = UToolMenus::Get()->RegisterMenu("DTFlux.MainMenu");
-	if (DTFluxMenu)
-	{
-		CreateSubmenu(DTFluxMenu);
-	}
-    
-	// 2. Ajouter ce menu à la barre principale
-	if (UToolMenu* MainMenu = UToolMenus::Get()->ExtendMenu("MainFrame.MainMenu"))
-	{
-		FToolMenuSection& DTFluxMenuSection = MainMenu->FindOrAddSection("DTFlux");
-		DTFluxMenuSection.Label = FText::FromString("DTFlux");
-        
-		DTFluxMenuSection.AddSubMenu(
-			"DTFluxSubmenu",
-			FText::FromString("DTFlux"),
-			FText::FromString("DTFlux API Tools"),
-			FNewToolMenuDelegate::CreateLambda([](UToolMenu* Menu)
-			{
-				// Référencer le menu enregistré
-				if (UToolMenu* RegisteredMenu = UToolMenus::Get()->FindMenu("DTFlux.MainMenu"))
-				{
-					// Copier la structure du menu enregistré
-					for (const FToolMenuSection& Section : RegisteredMenu->Sections)
-					{
-						Menu->Sections.Add(Section);
-					}
-				}
-			}),
-			false,
-			FSlateIcon(FAppStyle::GetAppStyleSetName(), "LevelEditor.Tab.Icon")
 		);
-	}
+	LevelEditorModule.GetMenuExtensibilityManager()->AddExtender(MenuExtender);
+
 
 }
 
-void FDTFluxAPIStatusModule::CreateSubmenu(UToolMenu* Menu)
+void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::AddMenu(FMenuBarBuilder& MenuBarBuilder)
 {
-	FToolMenuSection& DTFluxAPISection = Menu->FindOrAddSection("DTFluxAPI");
+	MenuBarBuilder.AddPullDownMenu(
-	DTFluxAPISection.Label = FText::FromString("DTFlux API");
+		FText::FromString("DTFlux"),
-	// Cette section est vide pour le moment, prête pour de futurs boutons
+		FText::FromString("DTFlux API Tools"),
-
+		FNewMenuDelegate::CreateRaw(this, &FDTFluxAPIStatusModule::FillMenu)
-	
+		);
-	// Section 2 : Tools
-	FToolMenuSection& ToolsSection = Menu->FindOrAddSection("Tools");
-	ToolsSection.Label = FText::FromString("Tools");
-
-    
-	// Ajouter le bouton Status dans la section Tools
-	DTFluxAPISection.AddMenuEntry(
-		"DTFluxStatus",
-		FText::FromString("DTFlux Status"),
-		FText::FromString("Launch DTFlux Status Control Panel"),
-		FSlateIcon(FDTFluxStatusStyle::GetStyleSetName(), "LevelEditor.Tab.Icon"),
-		FUIAction(FExecuteAction::CreateRaw(this, &FDTFluxAPIStatusModule::OnButtonClicked))
-	);
 }
 
-// void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::AddMenu(FMenuBarBuilder& MenuBarBuilder)
+void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::FillMenu(FMenuBuilder& MenuBuilder)
-// {
+{
-// 	MenuBarBuilder.AddPullDownMenu(
+	MenuBuilder.BeginSection(NAME_None, FText::FromString("DTFlux API"));
-// 		FText::FromString("DTFlux"),
+	MenuBuilder.AddMenuEntry(
-// 		FText::FromString("DTFlux API Tools"),
+	FText::FromString("Status"),
-// 		FNewMenuDelegate::CreateRaw(this, &FDTFluxAPIStatusModule::FillMenu)
+	FText::FromString("Launch DTFlux Status"),
-// 		);
+	FSlateIcon(FDTFluxStatusStyle::GetStyleSetName(), "LevelEditor.Tab.Icon"),
-// }
+	FExecuteAction::CreateRaw(this, &FDTFluxAPIStatusModule::OnButtonClicked)
+	);
+	MenuBuilder.EndSection();
 	
-// void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::FillMenu(FMenuBuilder& MenuBuilder)
+}
-// {
-// 	MenuBuilder.BeginSection(NAME_None, FText::FromString("DTFlux API"));
-// 	MenuBuilder.AddMenuEntry(
-// 	FText::FromString("Status"),
-// 	FText::FromString("Launch DTFlux Status"),
-// 	FSlateIcon(FDTFluxStatusStyle::GetStyleSetName(), "LevelEditor.Tab.Icon"),
-// 	FExecuteAction::CreateRaw(this, &FDTFluxAPIStatusModule::OnButtonClicked)
-// 	);
-// 	MenuBuilder.EndSection();
-// }
 
 void DTFLUXAPISTATUS_API FDTFluxAPIStatusModule::OnButtonClicked()
 {

Source/DTFluxAPIStatus/Private/DTFluxStatusWidget.cpp

@@ -416,7 +416,7 @@ FSlateColor SDTFluxStatusWidget::GetComboItemRankingColor(const TSharedPtr<FComb
 
 FReply SDTFluxStatusWidget::OnRankingButtonClicked() const
 {
-	if (DTFluxCore)
+	if (DTFluxNetwork)
 	{
 		// Exemple d'envoi de requête basée sur la sélection
 		int ForContest = SelectedContestComboBoxItem.IsValid() ? SelectedContestComboBoxItem->ContestId : -1;
@@ -432,19 +432,13 @@ FReply SDTFluxStatusWidget::OnRankingButtonClicked() const
 		if (ForStage == -1)
 		{
 			UE_LOG(logDTFluxStatus, Warning, TEXT("Stage not selected !!!! Requesting contest Ranking"));
-			DTFluxCore->TrackedRequestContestRankings({ForContest});
+			RequestType = EDTFluxApiDataType::ContestRanking;
+			DTFluxNetwork->SendRequest(RequestType, ForContest);
 			return FReply::Handled();
 		}
-		if (ForSplit == -1)
+		RequestType = ForSplit == -1 ? EDTFluxApiDataType::StageRanking : EDTFluxApiDataType::SplitRanking;
-		{
-			UE_LOG(logDTFluxStatus, Warning, TEXT("Split not selected !!!! Requesting stage Ranking"));
-			FDTFluxStageKey StageKey = {ForContest, ForStage};
-			DTFluxCore->TrackedRequestStageRankings({StageKey});
-			return FReply::Handled();
-		}
-		FDTFluxSplitKey SplitKey = {ForContest, ForStage, ForSplit};
-		DTFluxCore->TrackedRequestSplitRankings({SplitKey});
 		UE_LOG(logDTFluxStatus, Warning, TEXT("Requesting %s Ranking"), *UEnum::GetValueAsString(RequestType));
+		DTFluxNetwork->SendRequest(RequestType, ForContest, ForStage, ForSplit);
 	}
 
 	return FReply::Handled();

Source/DTFluxAPIStatus/Private/styles/DTFluxStatusStyle.cpp

@@ -13,7 +13,7 @@ TSharedPtr<ISlateStyle> FDTFluxStatusStyle::StyleSet = nullptr;
 
 void FDTFluxStatusStyle::RegisterStyle()
 {
-	if (StyleSet.IsValid()) return;
+	if(StyleSet.IsValid()) return;
 
 	StyleSet = Create();
 	FSlateStyleRegistry::RegisterSlateStyle(*StyleSet);
@@ -21,12 +21,14 @@ void FDTFluxStatusStyle::RegisterStyle()
 
 void FDTFluxStatusStyle::UnregisterStyle()
 {
-	if (StyleSet.IsValid())
+	if(StyleSet.IsValid())
 	{
 		FSlateStyleRegistry::UnRegisterSlateStyle(*StyleSet);
 		ensure(StyleSet.IsUnique());
 		StyleSet.Reset();
 	}
+
+	
 }
 
 void FDTFluxStatusStyle::ReloadTextures()
@@ -36,8 +38,9 @@ void FDTFluxStatusStyle::ReloadTextures()
 TSharedPtr<ISlateStyle> FDTFluxStatusStyle::Create()
 {
 	TSharedPtr<FSlateStyleSet> Style = MakeShareable(new FSlateStyleSet("DTFluxAPIStatusStyle"));
-	Style->SetContentRoot(IPluginManager::Get().FindPlugin("DTFluxAPI")->GetBaseDir() / TEXT("Resources"));
+	Style->SetContentRoot(IPluginManager::Get().FindPlugin("DTFluxAPI")->GetBaseDir()/TEXT("Resources"));
 
-	Style->Set("LevelEditor.Tab.Icon", new IMAGE_BRUSH_SVG("DTFluxServerStatusWhite", FVector2d(16)));
+	Style->Set("LevelEditor.Tab.Icon", new IMAGE_BRUSH_SVG("DTFluxServerStatusWhite", FVector2d(16)) );
 	return Style;
 }
+

Source/DTFluxAPIStatus/Public/DTFluxAPIStatusModule.h

@@ -13,11 +13,10 @@ public:
 
 #pragma region MenuExtention
     void InitMenuExtension();
-    void RegisterMenus();
+    void AddMenu(FMenuBarBuilder& MenuBarBuilder);
-    void CreateSubmenu(UToolMenu* Menu);
+    void FillMenu(FMenuBuilder& MenuBuilder);
-    // void AddMenu(FMenuBarBuilder& MenuBarBuilder);
-    // void FillMenu(FMenuBuilder& MenuBuilder);
     void OnButtonClicked();
+    // void OnWsEvent(TEnumAsByte<EDTFluxWsStatus> WsResponseEvent) const;
 #pragma endregion
 
 #pragma region EditorTab
@@ -26,6 +25,7 @@ public:
 private:
     static FName StatusTabId;
     static FText StatusTabDisplayName;
+
     TSharedPtr<class SDTFluxStatusWidget> StatusWidget;
 #pragma endregion
 };

Source/DTFluxCoreSubsystem/Private/DTFluxCoreSubsystem.cpp

@@ -10,7 +10,6 @@
 #include "FileHelpers.h"
 #include "Assets/DTFluxModelAsset.h"
 #include "Subsystems/DTFluxNetworkSubsystem.h"
-#include "Struct/DTFluxServerResponseStruct.h"
 #include "UObject/SavePackage.h"
 
 void UDTFluxCoreSubsystem::Initialize(FSubsystemCollectionBase& Collection)
@@ -33,7 +32,7 @@ void UDTFluxCoreSubsystem::Initialize(FSubsystemCollectionBase& Collection)
 	{
 		RegisterDelegates();
 	}
-	PursuitManager = NewObject<UDTFluxPursuitManager>(this);
+	PursuitManager = NewObject<UDTFluxPursuitManager>();
 }
 
 void UDTFluxCoreSubsystem::Deinitialize()
@@ -53,84 +52,6 @@ void UDTFluxCoreSubsystem::SaveDataStorage()
 	}
 }
 
-void UDTFluxCoreSubsystem::ProcessTrackedResponse(FDTFluxServerResponse& InResponse)
-{
-	switch (InResponse.GetResponseType())
-	{
-	case EDTFluxApiDataType::ContestRanking:
-		{
-			FDTFluxContestRankings Rankings;
-			if (InResponse.ParseContestRanking(Rankings))
-			{
-				ProcessContestRanking(Rankings);
-				UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("ContestRanking added for Contest %s"),
-				       *Rankings.ContestName);
-			}
-			else
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("Unable to parse ContestRanking"));
-			}
-			break;
-		}
-	case EDTFluxApiDataType::StageRanking:
-		{
-			FDTFluxStageRankings Rankings;
-			if (InResponse.ParseStageRanking(Rankings))
-			{
-				ProcessStageRanking(Rankings);
-				UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("ContestRanking added for Stage %i of Contest %i"),
-				       Rankings.StageId, Rankings.ContestId);
-			}
-			else
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("Unable to parse StageRanking"));
-			}
-			break;
-		}
-	case EDTFluxApiDataType::SplitRanking:
-		{
-			FDTFluxSplitRankings Rankings;
-			if (InResponse.ParseSplitRanking(Rankings))
-			{
-				ProcessSplitRanking(Rankings);
-				UE_LOG(logDTFluxCoreSubsystem, Warning,
-				       TEXT("ContestRanking added for Split %i of Stage %i of Contest %i"),
-				       Rankings.SplitId, Rankings.StageId, Rankings.ContestId);
-			}
-			else
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("Unable to parse SplitRanking"));
-			}
-			break;
-		}
-	case EDTFluxApiDataType::RaceData:
-		{
-			FDTFluxRaceData RaceData;
-			if (InResponse.ParseRaceData(RaceData))
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("RaceDataDefinition added for Contest %s"),
-				       *RaceData.Datas[0].Name);
-				ProcessRaceData(RaceData);
-			}
-			break;
-		}
-	case EDTFluxApiDataType::TeamList:
-		{
-			FDTFluxTeamListDefinition TeamList;
-			if (InResponse.ParseTeamList(TeamList))
-			{
-				ProcessTeamList(TeamList);
-				UE_LOG(logDTFluxCoreSubsystem, Log, TEXT("Process TeamList"))
-			}
-			break;
-		}
-	default:
-		UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("Unknown DataType %s"),
-		       *UEnum::GetValueAsString(InResponse.GetResponseType()));
-		break;
-	}
-}
-
 void UDTFluxCoreSubsystem::RegisterDelegates()
 {
 	if (NetworkSubsystem)
@@ -163,6 +84,9 @@ void UDTFluxCoreSubsystem::RegisterDelegates()
 			&UDTFluxCoreSubsystem::ProcessSplitRanking
 		);
 
+		// ⚠️ ATTENTION : Vous avez un doublon ici !
+		// NetworkSubsystem->OnReceivedTeamUpdate().BindUFunction(this, "ProcessTeamList");
+
 		NetworkSubsystem->OnReceivedTeamStatusUpdate().BindUObject(
 			this,
 			&UDTFluxCoreSubsystem::ProcessTeamStatusUpdate
@@ -227,24 +151,21 @@ void UDTFluxCoreSubsystem::ProcessContestRanking(const FDTFluxContestRankings& C
 	DataStorage->AddContestRanking(NewContestRankings);
 	UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("ContestRankings added for Contest %s"),
 	       *NewContestRankings.ContestName);
-	if (bShouldKeepRankings)
+	SaveDataStorage();
-	{
-		SaveDataStorage();
-	}
 }
 
 void UDTFluxCoreSubsystem::ProcessStageRanking(const FDTFluxStageRankings& StageRankings)
 {
 	UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("Received StageRankings with %i Items"), StageRankings.Rankings.Num());
 	DataStorage->UpdateOrCreateStageRanking(StageRankings);
-	if (bShouldKeepRankings) { SaveDataStorage(); }
+	SaveDataStorage();
 }
 
 void UDTFluxCoreSubsystem::ProcessSplitRanking(const FDTFluxSplitRankings& SplitRankings)
 {
 	UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("Received SplitRanking with %i Items"), SplitRankings.Rankings.Num());
 	DataStorage->UpdateOrCreateSplitRanking(SplitRankings);
-	if (bShouldKeepRankings) { SaveDataStorage(); }
+	SaveDataStorage();
 }
 
 void UDTFluxCoreSubsystem::ProcessTeamStatusUpdate(const FDTFluxTeamStatusUpdate& NewParticipantStatus)
@@ -284,182 +205,64 @@ void UDTFluxCoreSubsystem::SendRequest(const FString& Message)
 	}
 }
 
-bool UDTFluxCoreSubsystem::GetContestRankings(const int ContestId,
+void UDTFluxCoreSubsystem::SendTeamListRequest()
-                                              FDTFluxContestRankings& OutContestRankings)
-{
-	if (DataStorage->ContestRankings.Contains(ContestId))
-	{
-		OutContestRankings = DataStorage->ContestRankings[ContestId];
-		return true;
-	}
-	if (NetworkSubsystem)
-	{
-		TArray<int> TackedContestIds = {ContestId};
-		TrackedRequestContestRankings(TackedContestIds);
-		return false;
-	}
-	UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("NetworkSubsystem unavailable"));
-	return false;
-}
-
-bool UDTFluxCoreSubsystem::GetStageRankings(const int ContestId, const int StageId,
-                                            FDTFluxStageRankings& OutStageRankings)
-{
-	return GetStageRankingsWithKey(FDTFluxStageKey(ContestId, StageId), OutStageRankings);
-}
-
-bool UDTFluxCoreSubsystem::GetSplitRankings(const int ContestId, const int StageId, const int SplitId,
-                                            FDTFluxSplitRankings& OutSplitRankings)
-{
-	return GetSplitRankingsWithKey(FDTFluxSplitKey(ContestId, StageId, SplitId), OutSplitRankings);
-}
-
-bool UDTFluxCoreSubsystem::GetStageRankingsWithKey(const FDTFluxStageKey StageKey,
-                                                   FDTFluxStageRankings& OutStageRankings, const bool bShouldUseCached)
-{
-	//We Have the data
-	if (DataStorage->StageRankings.Contains(StageKey) && bShouldUseCached)
-	{
-		OutStageRankings = DataStorage->StageRankings[StageKey];
-		return true;
-	}
-	else
-	{
-		if (NetworkSubsystem)
-		{
-			TArray<FDTFluxStageKey> TackedStageKeys = {StageKey};
-			TrackedRequestStageRankings(TackedStageKeys);
-			OutStageRankings = FDTFluxStageRankings();
-			return false;
-		}
-		UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("NetworkSubsystem unavailable"))
-	}
-	return false;
-}
-
-bool UDTFluxCoreSubsystem::GetSplitRankingsWithKey(const FDTFluxSplitKey SplitKey,
-                                                   FDTFluxSplitRankings& OutSplitRankings, const bool bShouldUseCached)
-{
-	//We Have the data
-	if (DataStorage->SplitRankings.Contains(SplitKey) && bShouldUseCached)
-	{
-		OutSplitRankings = DataStorage->SplitRankings[SplitKey];
-		return true;
-	}
-	else
-	{
-		if (NetworkSubsystem)
-		{
-			TArray<FDTFluxSplitKey> TackedSplitKey = {SplitKey};
-			TrackedRequestSplitRankings(TackedSplitKey);
-			OutSplitRankings = FDTFluxSplitRankings();
-			return false;
-		}
-		UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("NetworkSubsystem unavailable"))
-		return false;
-	}
-}
-
-TArray<FGuid> UDTFluxCoreSubsystem::TrackedRequestContestRankings(const TArray<int> ForContests)
 {
 	if (NetworkSubsystem)
 	{
-		TArray<FGuid> RequestIds;
+		NetworkSubsystem->SendRequest(EDTFluxRequestType::TeamList);
-		FOnDTFluxRequestSuccess OnSuccess = FOnDTFluxRequestSuccess::CreateLambda(
-			[this](const FDTFluxTrackedRequest& Request)
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Log, TEXT("ContestRanking Request %s %s Success"),
-				       *Request.RequestId.ToString(), *UEnum::GetValueAsString(Request.RequestType));
-				if (Request.ParsedResponse.IsSet())
-				{
-					ProcessTrackedResponse(*Request.ParsedResponse.GetValue());
-				}
-			});
-
-		FOnDTFluxRequestError OnError = FOnDTFluxRequestError::CreateLambda(
-			[this](const FDTFluxTrackedRequest& InReq, const FString& InError)
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Log, TEXT("ContestRanking Request [%s] Error %s"),
-				       *InReq.RequestId.ToString(), *InError);
-			});
-		// if Contest is not ended 
-		for (auto ContestId : ForContests)
-		{
-			FGuid ContestRequest = NetworkSubsystem->SendTrackedRequestWithCallbacks(EDTFluxApiDataType::ContestRanking,
-				ContestId, -1, -1, OnSuccess, OnError);
-			RequestIds.Add(ContestRequest);
-		}
-		return RequestIds;
 	}
-	return TArray<FGuid>();
 }
 
-TArray<FGuid> UDTFluxCoreSubsystem::TrackedRequestStageRankings(const TArray<FDTFluxStageKey> ForStages)
+void UDTFluxCoreSubsystem::SendRaceDataRequest()
 {
 	if (NetworkSubsystem)
 	{
-		TArray<FGuid> RequestIds;
+		NetworkSubsystem->SendRequest(EDTFluxRequestType::RaceData);
-		FOnDTFluxRequestSuccess OnSuccess = FOnDTFluxRequestSuccess::CreateLambda(
-			[this](const FDTFluxTrackedRequest& Request)
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("Stage Request %s %s Success"),
-				       *Request.RequestId.ToString(), *UEnum::GetValueAsString(Request.RequestType));
-				if (Request.ParsedResponse.IsSet())
-				{
-					ProcessTrackedResponse(*Request.ParsedResponse.GetValue());
-				}
-			});
-
-		FOnDTFluxRequestError OnError = FOnDTFluxRequestError::CreateLambda(
-			[this](const FDTFluxTrackedRequest& InReq, const FString& InError)
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("StageRanking Request [%s] Error %s"),
-				       *InReq.RequestId.ToString(), *InError);
-			});
-		// if Contest is not ended 
-		for (auto StageKey : ForStages)
-		{
-			FGuid ContestRequest = NetworkSubsystem->SendTrackedRequestWithCallbacks(EDTFluxApiDataType::StageRanking,
-				StageKey.ContestId, StageKey.StageId, -1, OnSuccess, OnError);
-			RequestIds.Add(ContestRequest);
-		}
-		return RequestIds;
 	}
-	return TArray<FGuid>();
 }
 
-TArray<FGuid> UDTFluxCoreSubsystem::TrackedRequestSplitRankings(const TArray<FDTFluxSplitKey> ForSplits)
+void UDTFluxCoreSubsystem::SendContestRankingRequest(int InContestId)
 {
 	if (NetworkSubsystem)
 	{
-		TArray<FGuid> RequestIds;
+		NetworkSubsystem->SendRequest(EDTFluxRequestType::ContestRanking, InContestId);
-		FOnDTFluxRequestSuccess OnSuccess = FOnDTFluxRequestSuccess::CreateLambda(
-			[this](const FDTFluxTrackedRequest& Request)
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("Stage Request %s %s Success"),
-				       *Request.RequestId.ToString(), *UEnum::GetValueAsString(Request.RequestType));
-				if (Request.ParsedResponse.IsSet())
-				{
-					ProcessTrackedResponse(*Request.ParsedResponse.GetValue());
-				}
-			});
-
-		FOnDTFluxRequestError OnError = FOnDTFluxRequestError::CreateLambda(
-			[this](const FDTFluxTrackedRequest& InReq, const FString& InError)
-			{
-				UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("StageRanking Request [%s] Error %s"),
-				       *InReq.RequestId.ToString(), *InError);
-			});
-		// if Contest is not ended 
-		for (auto SplitKey : ForSplits)
-		{
-			FGuid ContestRequest = NetworkSubsystem->SendTrackedRequestWithCallbacks(EDTFluxApiDataType::SplitRanking,
-				SplitKey.ContestId, SplitKey.StageId, SplitKey.SplitId, OnSuccess, OnError);
-			RequestIds.Add(ContestRequest);
-		}
-		return RequestIds;
 	}
-	return TArray<FGuid>();
+}
+
+void UDTFluxCoreSubsystem::SendStageRankingRequest(int InContestId, int InStageId, bool bShouldIncludeSplitRanking)
+{
+	// TODO Implement this
+}
+
+void UDTFluxCoreSubsystem::RequestAllStageRankingOfContest(int InContestId, int InStageId,
+                                                           bool bShouldIncludeSplitRanking)
+{
+	// TODO Implement this
+}
+
+void UDTFluxCoreSubsystem::SendSplitRankingRequest(int InContestId, int InStageId, int InSplitId)
+{
+	// TODO Implement this
+}
+
+void UDTFluxCoreSubsystem::RequestAllSplitRankingOfContest(int InContestId, int InStageId)
+{
+	// TODO Implement this
+}
+
+FDTFluxStageRankings UDTFluxCoreSubsystem::GetStageRankings(FDTFluxStageKey StageKey)
+{
+	if (DataStorage->StageRankings.Contains(StageKey))
+	{
+		return DataStorage->StageRankings[StageKey];
+	}
+	UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("Cannot find StageRankings for key [%s]"), *StageKey.GetDisplayName());
+	return FDTFluxStageRankings();
+}
+
+void UDTFluxCoreSubsystem::RequestAllSplitRankingOfStage(int InContestId, int InStageId, int InSplitId)
+{
+	// TODO Implement this
 }
 
 const FDTFluxParticipant UDTFluxCoreSubsystem::GetParticipant(int InBib)
@@ -471,6 +274,11 @@ const FDTFluxParticipant UDTFluxCoreSubsystem::GetParticipant(int InBib)
 	return FDTFluxParticipant();
 }
 
+void UDTFluxCoreSubsystem::RefreshStorage()
+{
+	// TODO Implement this
+}
+
 TArray<int> UDTFluxCoreSubsystem::GetCurrentContestsId()
 {
 	return GetContestsIdForTime(FDateTime::Now());
@@ -481,7 +289,7 @@ TArray<FDTFluxContest> UDTFluxCoreSubsystem::GetCurrentContests()
 	return GetContestsForTime(FDateTime::Now());
 }
 
-TArray<int> UDTFluxCoreSubsystem::GetContestsIdForTime(const FDateTime Time) const
+TArray<int> UDTFluxCoreSubsystem::GetContestsIdForTime(const FDateTime Time)
 {
 	TArray<int> Contests;
 	for (const auto& Pair : DataStorage->Contests)
@@ -539,3 +347,22 @@ TArray<FDTFluxContest> UDTFluxCoreSubsystem::GetContests()
 	}
 	return TArray<FDTFluxContest>();
 }
+
+void UDTFluxCoreSubsystem::LaunchPursuitSequenceFor(const TArray<int> ContestIds)
+{
+	TArray<FDTFluxContest> Contests = TArray<FDTFluxContest>();
+	for (const auto& ContestId : ContestIds)
+	{
+		FDTFluxContest Contest;
+		GetContestForId(ContestId, Contest);
+		Contests.Add(Contest);
+		if (PursuitManager)
+		{
+			PursuitManager->LaunchPursuitSequenceFor(Contests);
+		}
+		else
+		{
+			UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("PursuitManager is null"));
+		}
+	}
+}

Source/DTFluxCoreSubsystem/Private/DTFluxPursuitManager.cpp

@@ -3,9 +3,6 @@
 
 #include "DTFluxPursuitManager.h"
 
-#include <ImportExport.h>
-
-#include "DTFluxCoreSubsystem.h"
 #include "DTFluxCoreSubsystemModule.h"
 
 UDTFluxPursuitManager::UDTFluxPursuitManager(const FObjectInitializer& ObjectInitializer):
@@ -13,96 +10,78 @@ UDTFluxPursuitManager::UDTFluxPursuitManager(const FObjectInitializer& ObjectIni
 {
 }
 
-void UDTFluxPursuitManager::InitPursuit(const TArray<int> InContestIds, const int MaxSimultaneousPursuit)
+// TODO : Add way to pass MaxSimultaneousPursuit and MassStartDelay
+// For now it's done in UPROPERTIES
+void UDTFluxPursuitManager::LaunchPursuitSequenceFor(const TArray<FDTFluxContest> InContests)
 {
-	CoreSubsystem = Cast<UDTFluxCoreSubsystem>(GetOuter());
+	if (InitSubSystems())
-	if (!CoreSubsystem)
 	{
-		UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("CoreSubsystem is not Available !!!"));
+		for (const auto Contest : InContests)
-		return;
-	}
-	AllRankings.Reset();
-	for (const auto& ContestId : InContestIds)
-	{
-		FDTFluxContest Contest;
-		if (CoreSubsystem->GetContestForId(ContestId, Contest))
 		{
-			BindRankings();
+			FRequestData RequestData;
-			FDTFluxStageKey StageKey = FDTFluxStageKey(ContestId, Contest.GetLastStageId());
+			RequestData.ContestId = Contest.ContestId;
-			FDTFluxStageRankings TempStageRankings;
+			uint8 StageId = Contest.Stages.Last().StageId;
-			//Obtenir les ranking Frais.
+			FGuid Guid = NetworkSubsystem->SendTrackedRequestWithCallback(EDTFluxApiDataType::StageRanking,
-			CoreSubsystem->GetStageRankingsWithKey(StageKey, TempStageRankings, false);
+			                                                              Contest.ContestId, StageId, -1,
-			PendingStageRanking.Add(StageKey, false);
+			                                                              FOnDTFluxTrackedRequestResponse::CreateUObject(
+				                                                              this,
+				                                                              &UDTFluxPursuitManager::OnRequestResponse),
+			                                                              FOnDTFluxTrackedRequestTimeout::CreateUObject(
+				                                                              this,
+				                                                              &UDTFluxPursuitManager::OnRequestTimeoutResponse),
+			                                                              FOnDTFluxRequestResponseError::CreateUObject(
+				                                                              this,
+				                                                              &UDTFluxPursuitManager::OnRequestError));
+
+			RequestData.RequestIds.Add(Guid);
+			PendingRequestData.Add(RequestData);
 		}
 	}
 }
 
-void UDTFluxPursuitManager::SetPursuitInfoIsMassStart(FDTFluxPursuitGroup NextFocusGroup)
+void UDTFluxPursuitManager::OnRequestResponse(const FGuid& RequestId, FDTFluxServerResponse& Response)
 {
-	for (auto& Pursuit : NextFocusGroup.PursuitGroup)
+	UE_LOG(logDTFluxCoreSubsystem, Log,
+	       TEXT("UDTFluxPursuitManager::OnRequestResponse() Received Ranking For Stage %i"), Response.StageID)
+	UE_LOG(logDTFluxCoreSubsystem, Log, TEXT("Response is %s"), *UEnum::GetValueAsString(Response.GetResponseType()))
+	//check if request
+	if (Response.GetResponseType() == EDTFluxApiDataType::StageRanking)
 	{
-		Pursuit.bIsMassStart = Pursuit.StartTime >= MassStartTime;
+		FDTFluxStageRankings Rankings;
-	}
+		FRequestData FoundData;
-}
+		if (Response.ParseStageRankingResponse(Rankings))
-
-void UDTFluxPursuitManager::GetPursuit(TArray<FDTFluxPursuitInfo>& OutPursuitFocusNext,
-                                       TArray<FDTFluxPursuitInfo>& OutPursuitNext, bool& BIsFocusTruncate,
-                                       const int MaxSimultaneousPursuit)
-{
-	if (MaxSimultaneousPursuit <= 0)
-	{
-		UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("MaxSimultaneousPursuit must be > 0"));
-		OutPursuitFocusNext = TArray<FDTFluxPursuitInfo>();
-		OutPursuitNext = TArray<FDTFluxPursuitInfo>();
-		BIsFocusTruncate = false;
-		return;
-	}
-	if (bIsSequenceDone && MaxSimultaneousPursuit <= 0)
-	{
-		OutPursuitFocusNext = TArray<FDTFluxPursuitInfo>();
-		OutPursuitNext = TArray<FDTFluxPursuitInfo>();
-		BIsFocusTruncate = false;
-		return;
-	}
-	OutPursuitFocusNext.Reset();
-	OutPursuitNext.Reset();
-	if (!GroupedPursuit.IsEmpty())
-	{
-		FDTFluxPursuitGroup NextFocusGroup = GroupedPursuit[0];
-		GroupedPursuit.RemoveAt(0);
-		SetPursuitInfoIsMassStart(NextFocusGroup);
-		OutPursuitFocusNext = NextFocusGroup.PursuitGroup;
-		bFocusIsTruncate = NextFocusGroup.PursuitGroup.Num() > 1;
-		for (int RemainingPursuitNum = MaxSimultaneousPursuit - 1; RemainingPursuitNum != 0;)
 		{
-			if (!GroupedPursuit.IsEmpty())
+			for (auto& PendingReq : PendingRequestData)
 			{
-				FDTFluxPursuitGroup NextGroup = GroupedPursuit[0];
+				// Check for a matching PendingReq
-				SetPursuitInfoIsMassStart(NextGroup);
+				if (PendingReq.IsWaitingFor(RequestId, Rankings))
-				if (NextGroup.PursuitGroup.Num() >= RemainingPursuitNum)
 				{
-					// extract the number we need
+					FoundData = PendingReq;
-					for (int i = 0; i < RemainingPursuitNum; i++)
+					// A request Is Terminated
-					{
+					UE_LOG(logDTFluxCoreSubsystem, Log,
-						FDTFluxPursuitInfo Pursuit = NextGroup.PursuitGroup[0];
+					       TEXT("UDTFluxPursuitManager::OnRequestResponse() Ranking for Stage %i is complete"),
-						OutPursuitNext.Add(Pursuit);
+					       Response.StageID)
-					}
 					break;
 				}
-				else
-				{
-					OutPursuitNext.Append(NextGroup.PursuitGroup);
-					RemainingPursuitNum -= NextGroup.PursuitGroup.Num();
-				}
 			}
-			else
+			if (InitPursuit(FoundData))
 			{
-				break;
+				OnPursuitSequenceReady.Broadcast(NextFocusPursuits, NextFocusPursuits, bFocusIsTruncate);
 			}
 		}
 	}
 }
 
+void UDTFluxPursuitManager::OnRequestTimeoutResponse(const FGuid& RequestId, const FString& TimeoutMessage)
+{
+	UE_LOG(logDTFluxCoreSubsystem, Warning, TEXT("Request Timeout [%s]"), *TimeoutMessage);
+}
+
+void UDTFluxPursuitManager::OnRequestError(const FGuid& RequestId, const FString& ErrorMessage)
+{
+	UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("Request Error [%s]"), *ErrorMessage);
+}
+
 bool UDTFluxPursuitManager::InitSubSystems()
 {
 	if (NetworkSubsystem)
@@ -113,64 +92,22 @@ bool UDTFluxPursuitManager::InitSubSystems()
 	return NetworkSubsystem != nullptr;
 }
 
-bool UDTFluxPursuitManager::BindRankings()
+bool UDTFluxPursuitManager::InitPursuit(FRequestData Data)
 {
-	if (CoreSubsystem)
+	//Clean Data
-	{
+	NextFocusPursuits.Empty();
-		if (!bIsRankingBounded)
+	NextPursuits.Empty();
-		{
+	PursuitGrouped.Empty();
-			CoreSubsystem->OnRequestedStageRankings.AddDynamic(this, &UDTFluxPursuitManager::OnRankingsReceived);
+	TArray<FDTFluxDetailedRankingItem> AllRankings;
-			bIsRankingBounded = true;
-		}
-		return bIsRankingBounded;
-	}
-	UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("CoreSubsystem is not Available !!!"));
-	return bIsRankingBounded = false;
-}
-
-void UDTFluxPursuitManager::UnbindRankings()
-{
-	if (CoreSubsystem)
-	{
-		if (bIsRankingBounded)
-		{
-			CoreSubsystem->OnRequestedStageRankings.RemoveDynamic(this, &UDTFluxPursuitManager::OnRankingsReceived);
-			bIsRankingBounded = false;
-			return;
-		}
-	}
-	bIsRankingBounded = false;
-	UE_LOG(logDTFluxCoreSubsystem, Error, TEXT("CoreSubsystem is not Available !!!"));
-}
-
-void UDTFluxPursuitManager::OnRankingsReceived(const FDTFluxStageKey NewStageKey,
-                                               const FDTFluxStageRankings NewStageRankings)
-{
-	if (PendingStageRanking.Contains(NewStageKey))
-	{
-		PendingStageRanking.Remove(NewStageKey);
-		AllRankings.Add(NewStageRankings);
-		if (PendingStageRanking.IsEmpty())
-		{
-			//everything is ready to go compute and start
-			UnbindRankings();
-			LaunchPursuitSequence();
-		}
-	}
-}
-
-bool UDTFluxPursuitManager::LaunchPursuitSequence()
-{
-	GroupedPursuit.Empty();
 	TArray<FDTFluxPursuitInfo> AllPursuits;
 	TMap<FDateTime, FDTFluxPursuitGroup> TempGroups;
-	bIsSequenceDone = false;
+
 	// Full the Array Of Rankings
-	for (auto& Ranking : AllRankings)
+	for (auto& KeyPair : Data.StageRankings)
 	{
-		for (auto StageRanking : Ranking.Rankings)
+		for (auto StageRanking : KeyPair.Value.Rankings)
 		{
-			int ContestId = Ranking.ContestId;
+			int ContestId = KeyPair.Value.ContestId;
 			FDTFluxPursuitInfo PursuitInfo;
 			PursuitInfo.StartTime = StageRanking.StartTime;
 			PursuitInfo.Bib = StageRanking.Bib;
@@ -178,6 +115,11 @@ bool UDTFluxPursuitManager::LaunchPursuitSequence()
 			AllPursuits.Add(PursuitInfo);
 		}
 	}
+	// Sort Rankings
+	// AllPursuits.Sort([](const FDTFluxPursuitInfo& A, const FDTFluxPursuitInfo& B) {
+	// 	return A.StartTime < B.StartTime;
+	// });
+
 	for (auto& Pursuit : AllPursuits)
 	{
 		if (TempGroups.Contains(Pursuit.StartTime))
@@ -196,37 +138,15 @@ bool UDTFluxPursuitManager::LaunchPursuitSequence()
 	{
 		return A < B;
 	});
-	TMap<FDateTime, int> StartTimeFrequency;
+	PursuitGrouped.Reserve(TempGroups.Num());
-	int32 MaxFrequency = 0;
-	GroupedPursuit.Reserve(TempGroups.Num());
 	for (const auto& Pair : TempGroups)
 	{
-		if (Pair.Value.StartTimeGlobal != FDateTime::MinValue() && Pair.Value.StartTimeGlobal != FDateTime::MaxValue())
+		PursuitGrouped.Add(Pair.Value);
-		{
-			StartTimeFrequency.FindOrAdd(Pair.Value.StartTimeGlobal)++;
-			const FDateTime& PropertyValue = Pair.Value.StartTimeGlobal; // Votre propriété
-			int32& Count = StartTimeFrequency.FindOrAdd(PropertyValue, 0);
-			Count++;
-			if (Count > MaxFrequency)
-			{
-				MaxFrequency = Count;
-				MassStartTime = PropertyValue;
-			}
-		}
-		GroupedPursuit.Add(Pair.Value);
 	}
 
-	GroupedPursuit.Sort([](const FDTFluxPursuitGroup& A, const FDTFluxPursuitGroup& B)
+	PursuitGrouped.Sort([](const FDTFluxPursuitGroup& A, const FDTFluxPursuitGroup& B)
 	{
 		return A.StartTimeGlobal < B.StartTimeGlobal;
 	});
-
-	TArray<FDTFluxPursuitInfo> FocusPursuits;
-	TArray<FDTFluxPursuitInfo> NextPursuits;
-	bool bIsFocusTruncate = false;
-
-	GetPursuit(FocusPursuits, NextPursuits, bIsFocusTruncate);
-	FPursuitStaterData PursuitData = FPursuitStaterData(FocusPursuits, NextPursuits, MassStartTime, bIsFocusTruncate);
-	CoreSubsystem->OnPursuitSequenceReady.Broadcast(PursuitData);
 	return true;
 }

Source/DTFluxCoreSubsystem/Public/DTFluxCoreSubsystem.h

@@ -2,7 +2,6 @@
 
 #include "CoreMinimal.h"
 #include "Containers/Deque.h"
-#include "Types/Struct/FDTFluxPursuitInfo.h"
 #include "Subsystems/EngineSubsystem.h"
 #include "Types/Struct/DTFluxRaceDataStructs.h"
 #include "Types/Struct/DTFluxTeamListStruct.h"
@@ -15,119 +14,88 @@ class UDTFluxNetworkSubsystem;
 /** Forward Decl */
 class UDTFluxModelAsset;
 class UDTFluxPursuitManager;
-struct FDTFluxServerResponse;
-
-USTRUCT(BlueprintType)
-struct FPursuitStaterData
-{
-	GENERATED_BODY()
-
-public:
-	FPursuitStaterData() = default;
-
-	FPursuitStaterData(const TArray<FDTFluxPursuitInfo>& InPursuitFocusNext,
-	                   const TArray<FDTFluxPursuitInfo>& InPursuitNext, const FDateTime& InMassStartTime,
-	                   const bool InIsFocusTruncate)
-		: PursuitFocusNext(InPursuitFocusNext), PursuitNext(InPursuitNext), MassStartTime(InMassStartTime),
-		  bIsFocusTruncate(InIsFocusTruncate)
-	{
-	};
-
-	UPROPERTY(BlueprintReadOnly, Category="DTFlux|Pursuit")
-	TArray<FDTFluxPursuitInfo> PursuitFocusNext = TArray<FDTFluxPursuitInfo>();
-	UPROPERTY(BlueprintReadOnly, Category="DTFlux|Pursuit")
-	TArray<FDTFluxPursuitInfo> PursuitNext = TArray<FDTFluxPursuitInfo>();
-	UPROPERTY(BlueprintReadOnly, Category="DTFlux|Pursuit")
-	FDateTime MassStartTime = FDateTime::MinValue();
-	UPROPERTY(BlueprintReadOnly, Category="DTFlux|Pursuit")
-	bool bIsFocusTruncate = false;
-};
-
-
-DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnPursuitSequenceReady, const FPursuitStaterData, PursuitInfoSequenceItem);
 
 /**
  * 
  */
-UCLASS(BlueprintType, meta=(DisplayName="DTFlux Core Subsystem"))
+UCLASS()
 class DTFLUXCORESUBSYSTEM_API UDTFluxCoreSubsystem : public UEngineSubsystem
 {
 	GENERATED_BODY()
 
 public:
-	DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnSplitRankings, FDTFluxSplitRankings, SplitRankings);
+	DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnSplitRankings, FDTFluxSplitRankings&, SplitRankings);
 
 	UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
 	FOnSplitRankings OnSplitRankings;
-	DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnStageRankings, FDTFluxStageRankings, StageRankings);
+
+	DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnStageRankings, FDTFluxStageRankings&, StageRankings);
 
 	UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
 	FOnStageRankings OnStageRankings;
-	DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnContestRankings, FDTFluxContestRankings, ContestRankings);
+
+	DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnContestRankings, FDTFluxContestRankings&, ContestRankings);
 
 	UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
 	FOnContestRankings OnContestRankings;
+
 	DECLARE_DYNAMIC_MULTICAST_DELEGATE(FOnTeamList);
 
 	UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
 	FOnTeamList OnTeamList;
+
 	DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnTeamStatusUpdate, FDTFluxParticipant, TeamUpdated);
 
 	UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
 	FOnTeamStatusUpdate OnTeamStatusUpdate;
 
-	DECLARE_DYNAMIC_MULTICAST_DELEGATE_TwoParams(FOnRequestedStageRankings, const FDTFluxStageKey, StageKey,
+	DECLARE_DELEGATE_TwoParams(FOnRequestedStageRankings, const FDTFluxStageKey&, const FDTFluxContestRankings&);
-	                                             const FDTFluxStageRankings, StageRankings);
-
-	UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
 	FOnRequestedStageRankings OnRequestedStageRankings;
+	//
+	// DECLARE_DYNAMIC_MULTICAST_DELEGATE_TwoParams(FOnTeamUpdate, FDateTime, ReceivedAt, FDTFluxParticipant, TeamUpdatedList);
+	// UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
+	// FOnTeamUpdate OnTeamUpdate;
 
-	UPROPERTY(BlueprintAssignable, Category="DTFlux|Core Subsystem")
-	FOnPursuitSequenceReady OnPursuitSequenceReady;
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	bool GetContestRankings(const int ContestId, FDTFluxContestRankings& OutContestRankings);
+	void SendTeamListRequest();
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	bool GetStageRankings(const int ContestId, const int StageId, FDTFluxStageRankings& OutStageRankings);
+	void SendRaceDataRequest();
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	bool GetSplitRankings(const int ContestId, const int StageId, const int SplitId,
+	void SendContestRankingRequest(int InContestId);
-	                      FDTFluxSplitRankings& OutSplitRankings);
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	bool GetStageRankingsWithKey(const FDTFluxStageKey StageKey, FDTFluxStageRankings& OutStageRankings,
+	void SendStageRankingRequest(int InContestId, int InStageId, bool bShouldIncludeSplitRanking = true);
-	                             const bool bShouldUseCached = true);
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	bool GetSplitRankingsWithKey(const FDTFluxSplitKey SplitKey, FDTFluxSplitRankings& OutSplitRankings,
+	void RequestAllStageRankingOfContest(int InContestId, int InStageId, bool bShouldIncludeSplitRanking = true);
-	                             const bool bShouldUseCached = true);
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	TArray<FGuid> TrackedRequestContestRankings(const TArray<int> ForContests);
+	void SendSplitRankingRequest(int InContestId, int InStageId, int InSplitId);
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	TArray<FGuid> TrackedRequestStageRankings(const TArray<FDTFluxStageKey> ForStages);
+	void RequestAllSplitRankingOfContest(int InContestId, int InStageId);
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	TArray<FGuid> TrackedRequestSplitRankings(const TArray<FDTFluxSplitKey> ForSplits);
+	FDTFluxStageRankings GetStageRankings(FDTFluxStageKey StageKey);
 
-	UPROPERTY(BlueprintReadOnly, Category="DTFlux|Core Subsystem")
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	UDTFluxPursuitManager* PursuitManager = nullptr;
+	void RequestAllSplitRankingOfStage(int InContestId, int InStageId, int InSplitId);
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
 	const FDTFluxParticipant GetParticipant(int InBib);
 
-	//TODO : this must be a ProjectSetting
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
-	UPROPERTY(BlueprintReadOnly, Category="DTFlux|Core Subsystem")
+	void RefreshStorage();
-	bool bShouldKeepRankings = true;
 
 	UFUNCTION()
 	TArray<int> GetCurrentContestsId();
 	UFUNCTION()
 	TArray<FDTFluxContest> GetCurrentContests();
 	UFUNCTION()
-	TArray<int> GetContestsIdForTime(const FDateTime Time) const;
+	TArray<int> GetContestsIdForTime(const FDateTime Time);
 	UFUNCTION()
 	bool GetContestForId(const int Id, FDTFluxContest& OutContest);
 	UFUNCTION()
@@ -138,20 +106,24 @@ public:
 	UFUNCTION()
 	TArray<FDTFluxContest> GetContests();
 
+
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
+	void LaunchPursuitSequenceFor(const TArray<int> ContestIds);
+
 protected:
 	// ~Subsystem Interface
 	virtual void Initialize(FSubsystemCollectionBase& Collection) override;
 	virtual void Deinitialize() override;
 	// ~Subsystem Interface
+
+	UPROPERTY()
+	UDTFluxPursuitManager* PursuitManager = nullptr;
+
 	UFUNCTION()
 	void SaveDataStorage();
-	UFUNCTION()
-	void ProcessTrackedResponse(FDTFluxServerResponse& InResponse);
 
 private:
 	UDTFluxNetworkSubsystem* NetworkSubsystem = nullptr;
-	UPROPERTY()
-	UDTFluxModelAsset* DataStorage = nullptr;
 
 	UFUNCTION()
 	void ProcessRaceData(const FDTFluxRaceData& RaceDataDefinition);
@@ -173,4 +145,8 @@ private:
 	void SendRequest(const FString& Message);
 	UFUNCTION()
 	void RegisterDelegates();
+
+
+	UPROPERTY()
+	UDTFluxModelAsset* DataStorage = nullptr;
 };

Source/DTFluxCoreSubsystem/Public/DTFluxPursuitManager.h

@@ -8,8 +8,6 @@
 #include "DTFluxPursuitManager.generated.h"
 
 
-class UDTFluxCoreSubsystem;
-
 USTRUCT()
 struct FRequestData
 {
@@ -29,7 +27,7 @@ struct FRequestData
 	FRequestData() = default;
 
 	FRequestData(const TArray<FGuid>& InRequestIds, const TMap<FGuid, FDTFluxStageRankings>& InStageRankings)
-		: RequestIds(InRequestIds), StageRankings(InStageRankings), ContestId(-1)
+		: RequestIds(InRequestIds), StageRankings(InStageRankings)
 	{
 	};
 
@@ -65,6 +63,9 @@ struct FDTFluxPursuitGroup
 	bool bIsFocus = false;
 };
 
+DECLARE_DYNAMIC_MULTICAST_DELEGATE_ThreeParams(FOnPursuitSequenceReady, const TArray<FDTFluxPursuitInfo>,
+                                               NextFocusPursuits,
+                                               const TArray<FDTFluxPursuitInfo>, NextPursuit, bool, bIsTrtuncate);
 
 /**
  * 
@@ -77,58 +78,56 @@ class DTFLUXCORESUBSYSTEM_API UDTFluxPursuitManager : public UObject
 public:
 	UDTFluxPursuitManager(const FObjectInitializer& ObjectInitializer);
 
+	UPROPERTY(BlueprintReadOnly, VisibleAnywhere)
+	TArray<FDTFluxPursuitInfo> NextFocusPursuits;
+
+	UPROPERTY(BlueprintReadOnly, VisibleAnywhere)
+	TArray<FDTFluxPursuitInfo> NextPursuits;
 
 	UPROPERTY(BlueprintReadOnly, VisibleAnywhere)
 	bool bFocusIsTruncate = false;
+	//
+	// UPROPERTY()
+	// TArray<FDTFluxStage> TargetStages;
 
 	UPROPERTY()
-	int PursuitMaxSimultaneousPursuit = 7;
+	int MaxSimultaneousPursuit = 7;
-
 	UPROPERTY(BlueprintReadWrite, EditAnywhere, Category="DTFlux|Pursuit",
 		meta=(ClampMin="1", ClampMax="60", UIMin="0", UIMax="60"))
 	int MassStartDelay = 10;
 
 	UPROPERTY()
-	FDateTime MassStartTime = FDateTime::MinValue();
+	TArray<FDTFluxPursuitGroup> PursuitGrouped;
-
-	UPROPERTY()
-	TArray<FDTFluxPursuitGroup> GroupedPursuit;
 
 	UPROPERTY()
 	int CurrentIndex = -1;
 
+	UPROPERTY(BlueprintCallable, Category="DTFlux|Pursuit")
+	FOnPursuitSequenceReady OnPursuitSequenceReady;
+
 
 	UFUNCTION(BlueprintCallable, Category="DTFlux|Pursuit", meta=(Keywords="pursuit, launch, poursuite"))
-	void InitPursuit(const TArray<int> InContestIds, const int MaxSimultaneousPursuit = 7);
+	void LaunchPursuitSequenceFor(const TArray<FDTFluxContest> InContests);
 
-	UFUNCTION(BlueprintCallable, Category="DTFlux|Pursuit", meta=(Keywords="pursuit, launch, poursuite"))
+	UFUNCTION()
-	void GetPursuit(TArray<FDTFluxPursuitInfo>& OutPursuitFocusNext, TArray<FDTFluxPursuitInfo>& OutPursuitNext,
+	void OnRequestResponse(const FGuid& RequestId, FDTFluxServerResponse& Response);
-	                bool& BIsFocusTruncate, const int MaxSimultaneousPursuit = 7);
+
+	UFUNCTION()
+	void OnRequestTimeoutResponse(const FGuid& RequestId, const FString& TimeoutMessage);
+
+	UFUNCTION()
+	void OnRequestError(const FGuid& RequestId, const FString& ErrorMessage);
 
 	UFUNCTION()
 	bool InitSubSystems();
 
-	UFUNCTION()
+private:
-	bool BindRankings();
+	TArray<FRequestData> PendingRequestData;
 
+public:
 	UFUNCTION()
-	void UnbindRankings();
+	bool InitPursuit(FRequestData Data);
-
-	UFUNCTION()
-	void OnRankingsReceived(const FDTFluxStageKey NewStageKey, const FDTFluxStageRankings NewStageRankings);
 
 private:
-	TMap<FDTFluxStageKey, bool> PendingStageRanking;
-	TArray<FDTFluxStageRankings> AllRankings;
-	UDTFluxCoreSubsystem* CoreSubsystem = nullptr;
 	UDTFluxNetworkSubsystem* NetworkSubsystem = nullptr;
-
-	UPROPERTY()
-	bool bIsSequenceDone = true;
-	UPROPERTY()
-	bool bIsRankingBounded = false;
-	UFUNCTION()
-	void SetPursuitInfoIsMassStart(FDTFluxPursuitGroup NextFocusGroup);
-	UFUNCTION()
-	bool LaunchPursuitSequence();
 };

Source/DTFluxNetwork/Private/DTFluxAsyncParser.cpp

@@ -1,318 +0,0 @@
-#include "DTFluxAsyncParser.h"
-
-#include "DTFluxNetworkModule.h"
-#include "Struct/DTFluxServerResponseStruct.h"
-#include "Async/AsyncWork.h"
-
-// ================================================================================================
-// IMPLÉMENTATION DE LA TÂCHE DE PARSING
-// ================================================================================================
-
-DECLARE_STATS_GROUP(TEXT("DTFlux"), STATGROUP_DTFlux, STATCAT_Advanced);
-
-DECLARE_CYCLE_STAT(TEXT("DTFlux Parsing Task"), STAT_FDTFluxParsingTask, STATGROUP_DTFlux);
-DECLARE_CYCLE_STAT(TEXT("DTFlux Parsing Task DoWork"), STAT_FDTFluxParsingTask_DoWork, STATGROUP_DTFlux);
-
-FDTFluxParsingTask::FDTFluxParsingTask(
-	const FGuid& InRequestId,
-	const FString& InRawJsonData,
-	FOnParsingCompleted InOnCompleted,
-	FOnParsingFailed InOnFailed
-)
-	: RequestId(InRequestId)
-	  , RawJsonData(InRawJsonData)
-	  , OnCompleted(InOnCompleted)
-	  , OnFailed(InOnFailed)
-	  , StartTime(FPlatformTime::Seconds())
-{
-}
-
-void FDTFluxParsingTask::DoTask(ENamedThreads::Type CurrentThread, const FGraphEventRef& MyCompletionGraphEvent)
-{
-	SCOPE_CYCLE_COUNTER(STAT_FDTFluxParsingTask_DoWork);
-
-	UE_LOG(logDTFluxNetwork, VeryVerbose, TEXT("Starting async parsing for request %s"), *RequestId.ToString());
-
-	TSharedPtr<FDTFluxServerResponse> ParsedResponse;
-	bool bParsingSuccess = false;
-	FString ErrorMessage;
-
-	try
-	{
-		// === PARSING SUR LE THREAD WORKER ===
-
-		EDTFluxResponseStatus Status;
-		ParsedResponse = MakeShared<FDTFluxServerResponse>(RawJsonData, Status, false); // Pas de logs sur worker thread
-
-		if (Status == EDTFluxResponseStatus::Success)
-		{
-			bParsingSuccess = true;
-			UE_LOG(logDTFluxNetwork, VeryVerbose, TEXT("Async parsing successful for request %s"),
-			       *RequestId.ToString());
-		}
-		else
-		{
-			ErrorMessage = FString::Printf(TEXT("Parsing failed with status: %s"),
-			                               *UEnum::GetValueAsString(Status));
-			UE_LOG(logDTFluxNetwork, Warning, TEXT("Async parsing failed for request %s: %s"),
-			       *RequestId.ToString(), *ErrorMessage);
-		}
-	}
-	catch (const std::exception& e)
-	{
-		ErrorMessage = FString::Printf(TEXT("Exception during parsing: %s"), ANSI_TO_TCHAR(e.what()));
-		UE_LOG(logDTFluxNetwork, Error, TEXT("Exception during async parsing for request %s: %s"),
-		       *RequestId.ToString(), *ErrorMessage);
-	}
-	catch (...)
-	{
-		ErrorMessage = TEXT("Unknown exception during parsing");
-		UE_LOG(logDTFluxNetwork, Error, TEXT("Unknown exception during async parsing for request %s"),
-		       *RequestId.ToString());
-	}
-
-	const float ParsingTime = (FPlatformTime::Seconds() - StartTime) * 1000.0f; // En millisecondes
-
-	// === PROGRAMMER LA CALLBACK SUR LE MAIN THREAD ===
-
-	FFunctionGraphTask::CreateAndDispatchWhenReady(
-		[this, ParsedResponse, bParsingSuccess, ErrorMessage, ParsingTime]()
-		{
-			// Cette lambda s'exécute sur le main thread
-			if (bParsingSuccess && ParsedResponse.IsValid())
-			{
-				OnCompleted.ExecuteIfBound(RequestId, ParsedResponse, true);
-			}
-			else
-			{
-				OnFailed.ExecuteIfBound(RequestId, ErrorMessage);
-			}
-		},
-		TStatId(),
-		nullptr,
-		ENamedThreads::GameThread // Forcer l'exécution sur le main thread
-	);
-}
-
-// ================================================================================================
-// IMPLÉMENTATION DU PARSER ASYNCHRONE
-// ================================================================================================
-
-FDTFluxAsyncParser::FDTFluxAsyncParser()
-{
-	UE_LOG(logDTFluxNetwork, Log, TEXT("AsyncParser initialized"));
-}
-
-FDTFluxAsyncParser::~FDTFluxAsyncParser()
-{
-	CancelAllParsing();
-	UE_LOG(logDTFluxNetwork, Log, TEXT("AsyncParser destroyed"));
-}
-
-void FDTFluxAsyncParser::ParseResponseAsync(
-	const FGuid& RequestId,
-	const FString& RawJsonData,
-	FOnParsingCompleted OnCompleted,
-	FOnParsingFailed OnFailed)
-{
-	if (RawJsonData.IsEmpty())
-	{
-		OnFailed.ExecuteIfBound(RequestId, TEXT("Empty JSON data"));
-		return;
-	}
-	UE_LOG(logDTFluxNetwork, Verbose, TEXT("Starting async parsing for request %s"), *RequestId.ToString());
-
-	// Créer la tâche de parsing
-	FGraphEventRef Task = FFunctionGraphTask::CreateAndDispatchWhenReady(
-		[RequestId, RawJsonData, OnCompleted, OnFailed]()
-		{
-			// Ce code s'exécute sur le worker thread
-			const double StartTime = FPlatformTime::Seconds();
-
-			TSharedPtr<FDTFluxServerResponse> ParsedResponse;
-			bool bParsingSuccess = false;
-			FString ErrorMessage;
-
-			try
-			{
-				EDTFluxResponseStatus Status;
-				ParsedResponse = MakeShared<FDTFluxServerResponse>(RawJsonData, Status, false);
-
-				if (Status == EDTFluxResponseStatus::Success)
-				{
-					bParsingSuccess = true;
-				}
-				else
-				{
-					ErrorMessage = FString::Printf(TEXT("Parsing failed with status: %s"),
-					                               *UEnum::GetValueAsString(Status));
-				}
-			}
-			catch (const std::exception& e)
-			{
-				ErrorMessage = FString::Printf(TEXT("Exception during parsing: %s"), ANSI_TO_TCHAR(e.what()));
-			}
-			catch (...)
-			{
-				ErrorMessage = TEXT("Unknown exception during parsing");
-			}
-
-			const float ParsingTime = (FPlatformTime::Seconds() - StartTime) * 1000.0f;
-			FFunctionGraphTask::CreateAndDispatchWhenReady(
-				[RequestId, ParsedResponse, bParsingSuccess, ErrorMessage, OnCompleted, OnFailed]()
-				{
-					// Cette lambda s'exécute sur le main thread
-					if (bParsingSuccess && ParsedResponse.IsValid())
-					{
-						OnCompleted.ExecuteIfBound(RequestId, ParsedResponse, true);
-					}
-					else
-					{
-						OnFailed.ExecuteIfBound(RequestId, ErrorMessage);
-					}
-				},
-				TStatId(),
-				nullptr,
-				ENamedThreads::GameThread // Forcer main thread
-			);
-		},
-		TStatId(),
-		nullptr,
-		ENamedThreads::AnyBackgroundThreadNormalTask
-	);
-
-	// Tracker la tâche
-	{
-		FScopeLock Lock(&TasksLock);
-		ActiveTasks.Add(Task);
-	}
-
-	UE_LOG(logDTFluxNetwork, Verbose, TEXT("Queued async parsing task for request %s"), *RequestId.ToString());
-}
-
-TSharedPtr<FDTFluxServerResponse> FDTFluxAsyncParser::ParseResponseSync(
-	const FString& RawJsonData,
-	float TimeoutSeconds)
-{
-	if (RawJsonData.IsEmpty())
-	{
-		return nullptr;
-	}
-
-	// Variables pour la synchronisation
-	TSharedPtr<FDTFluxServerResponse> Result;
-	std::atomic<bool> bCompleted{false};
-
-	// Lancer le parsing async avec callback sync
-	FOnParsingCompleted OnCompleted = FOnParsingCompleted::CreateLambda(
-		[&Result, &bCompleted](const FGuid& RequestId, TSharedPtr<FDTFluxServerResponse> ParsedResponse, bool bSuccess)
-		{
-			if (bSuccess)
-			{
-				Result = ParsedResponse;
-			}
-			bCompleted.store(true);
-		}
-	);
-
-	FOnParsingFailed OnFailed = FOnParsingFailed::CreateLambda(
-		[&bCompleted](const FGuid& RequestId, const FString& ErrorMessage)
-		{
-			UE_LOG(logDTFluxNetwork, Warning, TEXT("Sync parsing failed: %s"), *ErrorMessage);
-			bCompleted.store(true);
-		}
-	);
-
-	FGuid TempId = FGuid::NewGuid();
-	ParseResponseAsync(TempId, RawJsonData, OnCompleted, OnFailed);
-
-	// Attendre avec timeout
-	const double StartTime = FPlatformTime::Seconds();
-	while (!bCompleted.load() && (FPlatformTime::Seconds() - StartTime) < TimeoutSeconds)
-	{
-		FPlatformProcess::Sleep(0.001f); // 1ms
-	}
-
-	return Result;
-}
-
-void FDTFluxAsyncParser::CancelAllParsing()
-{
-	FScopeLock Lock(&TasksLock);
-
-	for (const FGraphEventRef& Task : ActiveTasks)
-	{
-		// Note: On ne peut pas vraiment "cancel" une tâche TaskGraph en cours,
-		// mais on peut marquer qu'on ne veut plus les résultats
-	}
-
-	ActiveTasks.Empty();
-	UE_LOG(logDTFluxNetwork, Log, TEXT("Cancelled all pending parsing tasks"));
-}
-
-FDTFluxAsyncParser::FParsingStats FDTFluxAsyncParser::GetStats() const
-{
-	FScopeLock StatsLock_Local(&StatsLock);
-	FScopeLock TasksLock_Local(&TasksLock);
-
-	FParsingStats Stats;
-	Stats.TasksInProgress = ActiveTasks.Num();
-	Stats.TasksCompleted = TasksCompletedCount;
-	Stats.TasksFailed = TasksFailedCount;
-
-	if (ParsingTimes.Num() > 0)
-	{
-		float Sum = 0.0f;
-		for (float Time : ParsingTimes)
-		{
-			Sum += Time;
-		}
-		Stats.AverageParsingTimeMs = Sum / ParsingTimes.Num();
-	}
-
-	return Stats;
-}
-
-void FDTFluxAsyncParser::ResetStats()
-{
-	FScopeLock Lock(&StatsLock);
-	TasksCompletedCount = 0;
-	TasksFailedCount = 0;
-	ParsingTimes.Empty();
-}
-
-void FDTFluxAsyncParser::OnTaskCompleted(bool bSuccess, float ParsingTimeMs)
-{
-	FScopeLock Lock(&StatsLock);
-
-	if (bSuccess)
-	{
-		TasksCompletedCount++;
-	}
-	else
-	{
-		TasksFailedCount++;
-	}
-
-	ParsingTimes.Add(ParsingTimeMs);
-
-	// Garder seulement les 100 derniers temps pour la moyenne
-	if (ParsingTimes.Num() > 100)
-	{
-		ParsingTimes.RemoveAt(0);
-	}
-}
-
-void FDTFluxAsyncParser::CleanupCompletedTasks()
-{
-	FScopeLock Lock(&TasksLock);
-
-	for (auto It = ActiveTasks.CreateIterator(); It; ++It)
-	{
-		const FGraphEventRef& Task = *It;
-		if (Task.IsValid() && Task->IsComplete())
-		{
-			It.RemoveCurrent(); // Supprime l'élément actuel de manière sécurisée
-		}
-	}
-}

Source/DTFluxNetwork/Private/Struct/DTFluxServerResponseStruct.cpp

@@ -1,7 +1,6 @@
-#include "Struct/DTFluxServerResponseStruct.h"
+#pragma  once
-#include "DTFluxNetworkModule.h"
-#include "Types/Objects/UDTFluxParticipantFactory.h"
 
+#include "Struct/DTFluxServerResponseStruct.h"
 
 // === IMPLÉMENTATION DES CONSTRUCTEURS ===
 
@@ -195,7 +194,7 @@ FString FDTFluxServerResponse::ToDebugString() const
 		*UEnum::GetValueAsString(ParsingStatus), *Type, Code, ContestID, StageID, SplitID, *ReceivedAt.ToString());
 }
 
-bool FDTFluxServerResponse::ParseTeamList(FDTFluxTeamListDefinition& OutTeamList)
+bool FDTFluxServerResponse::ParseTeamListResponse(FDTFluxTeamListDefinition& OutTeamList)
 {
 	ParsingStatus = EDTFluxResponseStatus::Unset;
 	if (!ValidateResponseType(TEXT("team-list")))
@@ -257,9 +256,9 @@ bool FDTFluxServerResponse::ParseTeamList(FDTFluxTeamListDefinition& OutTeamList
 	return false;
 }
 
-bool FDTFluxServerResponse::ParseTeamUpdate(FDTFluxTeamListDefinition& OutTeamUpdate)
+bool FDTFluxServerResponse::ParseTeamUpdateResponse(FDTFluxTeamListDefinition& OutTeamUpdate)
 {
-	return ParseTeamList(OutTeamUpdate);
+	return ParseTeamListResponse(OutTeamUpdate);
 }
 
 bool FDTFluxServerResponse::ParseRaceData(FDTFluxRaceData& OutRaceData)
@@ -369,7 +368,7 @@ bool FDTFluxServerResponse::ParseContestRanking(FDTFluxContestRankings& OutConte
 	return true;
 }
 
-bool FDTFluxServerResponse::ParseStageRanking(FDTFluxStageRankings& OutStageRankings)
+bool FDTFluxServerResponse::ParseStageRankingResponse(FDTFluxStageRankings& OutStageRankings)
 {
 	// UE_LOG(logDTFluxNetwork, Log, TEXT("Response is stage-ranking type %s"), *RawMessage);
 	if (!ValidateResponseType(TEXT("stage-ranking")))
@@ -397,7 +396,7 @@ bool FDTFluxServerResponse::ParseStageRanking(FDTFluxStageRankings& OutStageRank
 	return true;
 }
 
-bool FDTFluxServerResponse::ParseSplitRanking(FDTFluxSplitRankings& OutSplitRankings)
+bool FDTFluxServerResponse::ParseSplitRankingResponse(FDTFluxSplitRankings& OutSplitRankings)
 {
 	if (!ValidateResponseType(TEXT("stage-ranking")) || SplitID == -1)
 	{
@@ -428,7 +427,7 @@ bool FDTFluxServerResponse::ParseSplitRanking(FDTFluxSplitRankings& OutSplitRank
 	return true;
 }
 
-bool FDTFluxServerResponse::ParseStatusUpdate(FDTFluxTeamStatusUpdate& OutStatusUpdate)
+bool FDTFluxServerResponse::ParseStatusUpdateResponse(FDTFluxTeamStatusUpdate& OutStatusUpdate)
 {
 	if (!ValidateResponseType(TEXT("status-update")))
 	{
@@ -449,7 +448,7 @@ bool FDTFluxServerResponse::ParseStatusUpdate(FDTFluxTeamStatusUpdate& OutStatus
 	return true;
 }
 
-bool FDTFluxServerResponse::ParseSplitSensor(TArray<FDTFluxSplitSensorInfo>& OutSplitSensorInfos)
+bool FDTFluxServerResponse::ParseSplitSensorResponse(TArray<FDTFluxSplitSensorInfo>& OutSplitSensorInfos)
 {
 	if (!ValidateResponseType(TEXT("split-sensor")))
 	{

Source/DTFluxNetwork/Public/DTFluxAsyncParser.h

@@ -1,171 +0,0 @@
-// ================================================================================================
-// DTFluxAsyncParser.h - Async Response Parser
-// ================================================================================================
-#pragma once
-
-#include "CoreMinimal.h"
-#include "HAL/CriticalSection.h"
-#include "Async/TaskGraphInterfaces.h"
-#include "Struct/DTFluxServerResponseStruct.h"
-
-// Forward declarations
-
-// ================================================================================================
-// DELEGATES POUR LE PARSING ASYNCHRONE
-// ================================================================================================
-
-DECLARE_DELEGATE_ThreeParams(FOnParsingCompleted, const FGuid& /*RequestId*/,
-                             TSharedPtr<FDTFluxServerResponse> /*ParsedResponse*/, bool /*bSuccess*/);
-DECLARE_DELEGATE_TwoParams(FOnParsingFailed, const FGuid& /*RequestId*/, const FString& /*ErrorMessage*/);
-
-// ================================================================================================
-// ASYNC PARSER - Délégation du parsing avec TaskGraph
-// ================================================================================================
-
-/**
- * Gestionnaire centralisé pour le parsing asynchrone des réponses JSON
- * Utilise le TaskGraph d'Unreal Engine pour déléguer le parsing sur des worker threads
- */
-class DTFLUXNETWORK_API FDTFluxAsyncParser
-{
-public:
-	FDTFluxAsyncParser();
-	~FDTFluxAsyncParser();
-
-	// === INTERFACE PUBLIQUE ===
-
-	/**
-	 * Lancer le parsing asynchrone d'une réponse JSON
-	 * @param RequestId - ID de la requête pour le suivi
-	 * @param RawJsonData - Données JSON brutes à parser
-	 * @param OnCompleted - Callback appelé en cas de succès (sur main thread)
-	 * @param OnFailed - Callback appelé en cas d'échec (sur main thread)
-	 */
-	void ParseResponseAsync(
-		const FGuid& RequestId,
-		const FString& RawJsonData,
-		FOnParsingCompleted OnCompleted,
-		FOnParsingFailed OnFailed = FOnParsingFailed()
-	);
-
-	/**
-	 * Parsing synchrone avec timeout (pour les cas urgents)
-	 * @param RawJsonData - Données JSON à parser
-	 * @param TimeoutSeconds - Timeout maximum pour le parsing
-	 * @return Réponse parsée ou nullptr en cas d'échec
-	 */
-	TSharedPtr<FDTFluxServerResponse> ParseResponseSync(
-		const FString& RawJsonData,
-		float TimeoutSeconds = 1.0f
-	);
-
-	/**
-	 * Annuler toutes les tâches de parsing en attente
-	 */
-	void CancelAllParsing();
-
-	// === STATISTIQUES ===
-
-	/**
-	 * Statistiques de performance du parsing
-	 */
-	struct FParsingStats
-	{
-		int32 TasksInProgress = 0; // Tâches actuellement en cours
-		int32 TasksCompleted = 0; // Tâches terminées avec succès
-		int32 TasksFailed = 0; // Tâches échouées
-		float AverageParsingTimeMs = 0.0f; // Temps moyen de parsing en ms
-	};
-
-	/**
-	 * Obtenir les statistiques de parsing
-	 */
-	FParsingStats GetStats() const;
-
-	/**
-	 * Réinitialiser les statistiques
-	 */
-	void ResetStats();
-
-private:
-	// === TRACKING DES TÂCHES ===
-	mutable FCriticalSection TasksLock;
-	TSet<FGraphEventRef> ActiveTasks;
-
-	// === STATISTIQUES ===
-	mutable FCriticalSection StatsLock;
-	mutable int32 TasksCompletedCount = 0;
-	mutable int32 TasksFailedCount = 0;
-	mutable TArray<float> ParsingTimes; // Historique des temps de parsing
-
-	// === MÉTHODES PRIVÉES ===
-
-	/**
-	 * Callback appelé quand une tâche se termine
-	 * @param bSuccess - Succès ou échec de la tâche
-	 * @param ParsingTimeMs - Temps de parsing en millisecondes
-	 */
-	void OnTaskCompleted(bool bSuccess, float ParsingTimeMs);
-
-	/**
-	 * Nettoyer les tâches terminées de la liste active
-	 */
-	void CleanupCompletedTasks();
-};
-
-// ================================================================================================
-// TÂCHE DE PARSING POUR LE TASKGRAPH
-// ================================================================================================
-
-/**
- * Tâche de parsing JSON exécutée sur un thread worker
- * Compatible avec le TaskGraph d'Unreal Engine
- */
-class FDTFluxParsingTask
-{
-public:
-	FDTFluxParsingTask(
-		const FGuid& InRequestId,
-		const FString& InRawJsonData,
-		FOnParsingCompleted InOnCompleted,
-		FOnParsingFailed InOnFailed
-	);
-
-	// === INTERFACE TASK GRAPH ===
-
-	FORCEINLINE TStatId GetStatId() const
-	{
-		RETURN_QUICK_DECLARE_CYCLE_STAT(FDTFluxParsingTask, STATGROUP_TaskGraphTasks);
-	}
-
-	static FORCEINLINE TStatId GetStatId_DoWork()
-	{
-		RETURN_QUICK_DECLARE_CYCLE_STAT(FDTFluxParsingTask_DoWork, STATGROUP_TaskGraphTasks);
-	}
-
-	static FORCEINLINE ENamedThreads::Type GetDesiredThread()
-	{
-		// Exécuter sur un thread worker (pas le main thread)
-		return ENamedThreads::AnyBackgroundThreadNormalTask;
-	}
-
-	static FORCEINLINE ESubsequentsMode::Type GetSubsequentsMode()
-	{
-		return ESubsequentsMode::TrackSubsequents;
-	}
-
-	// === EXÉCUTION DE LA TÂCHE ===
-
-	/**
-	 * Méthode principale d'exécution de la tâche
-	 * Appelée automatiquement par le TaskGraph sur un worker thread
-	 */
-	void DoTask(ENamedThreads::Type CurrentThread, const FGraphEventRef& MyCompletionGraphEvent);
-
-private:
-	FGuid RequestId;
-	FString RawJsonData;
-	FOnParsingCompleted OnCompleted;
-	FOnParsingFailed OnFailed;
-	double StartTime;
-};

Source/DTFluxNetwork/Public/DTFluxQueuedManager.h

@@ -1,444 +1,66 @@
-// ================================================================================================
+// Fill out your copyright notice in the Description page of Project Settings.
-// DTFluxRequestManager.h - Gestionnaire C++ optimisé avec cache, timeout et retry
-// ================================================================================================
 
 #pragma once
 
 #include "CoreMinimal.h"
+#include "UObject/Object.h"
+#include "Containers/Queue.h"
 #include "Tickable.h"
-#include "HAL/CriticalSection.h"
+#include "Struct/DTFluxRequestStructs.h"
 #include "Struct/DTFluxServerResponseStruct.h"
 #include "Types/Enum/DTFluxCoreEnum.h"
 #include "DTFluxQueuedManager.generated.h"
 
-class FDTFluxAsyncParser;
+DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnRequestTimedOut, const FDTFluxQueuedRequest&, TimedOutRequest);
-
-
-// ================================================================================================
-// ENUMS ET STRUCTURES POUR LES REQUÊTES
-// ================================================================================================
-
-UENUM(BlueprintType)
-enum class EDTFluxRequestState : uint8
-{
-	Pending UMETA(DisplayName = "Pending"),
-	Sent UMETA(DisplayName = "Sent"),
-	Completed UMETA(DisplayName = "Completed"),
-	Failed UMETA(DisplayName = "Failed"),
-	TimedOut UMETA(DisplayName = "TimedOut"),
-	Cached UMETA(DisplayName = "Cached"),
-	Retrying UMETA(DisplayName = "Retrying")
-};
-
-USTRUCT(BlueprintType)
-struct DTFLUXNETWORK_API FDTFluxRequestConfig
-{
-	GENERATED_BODY()
-
-	UPROPERTY(EditAnywhere, BlueprintReadWrite)
-	float TimeoutSeconds = 5.0f;
-
-	UPROPERTY(EditAnywhere, BlueprintReadWrite)
-	int32 MaxRetries = 3;
-
-	UPROPERTY(EditAnywhere, BlueprintReadWrite)
-	float RetryBackoffMultiplier = 1.5f;
-
-	UPROPERTY(EditAnywhere, BlueprintReadWrite)
-	bool bEnableCache = true;
-
-	UPROPERTY(EditAnywhere, BlueprintReadWrite)
-	float CacheValiditySeconds = 60.0f;
-};
-
-USTRUCT(BlueprintType)
-struct DTFLUXNETWORK_API FDTFluxTrackedRequest
-{
-	GENERATED_BODY()
-
-	// === IDENTIFICATION ===
-	UPROPERTY(BlueprintReadOnly)
-	FGuid RequestId = FGuid::NewGuid();
-
-	UPROPERTY(BlueprintReadOnly)
-	EDTFluxApiDataType RequestType = EDTFluxApiDataType::None;
-
-	UPROPERTY(BlueprintReadOnly)
-	int32 ContestId = -1;
-
-	UPROPERTY(BlueprintReadOnly)
-	int32 StageId = -1;
-
-	UPROPERTY(BlueprintReadOnly)
-	int32 SplitId = -1;
-
-	// === ÉTAT ET TIMING ===
-	UPROPERTY(BlueprintReadOnly)
-	EDTFluxRequestState State = EDTFluxRequestState::Pending;
-
-	UPROPERTY(BlueprintReadOnly)
-	FDateTime CreatedAt = FDateTime::Now();
-
-	UPROPERTY(BlueprintReadOnly)
-	FDateTime SentAt = FDateTime::MinValue();
-
-	UPROPERTY(BlueprintReadOnly)
-	FDateTime CompletedAt = FDateTime::MinValue();
-
-	UPROPERTY(BlueprintReadOnly)
-	FDateTime LastAttemptTime = FDateTime::Now();
-
-	// === CONFIGURATION ===
-	FDTFluxRequestConfig Config;
-
-	// === RETRY LOGIC ===
-	UPROPERTY(BlueprintReadOnly)
-	int32 CurrentRetries = 0;
-
-	// === DONNÉES DE RÉPONSE ===
-	UPROPERTY(BlueprintReadOnly)
-	FString RawResponseData;
-
-	// Réponse parsée (lazy loading)
-	mutable TOptional<TSharedPtr<FDTFluxServerResponse>> ParsedResponse;
-
-	UPROPERTY(BlueprintReadOnly)
-	bool bIsResponseParsed = false;
-
-	UPROPERTY(BlueprintReadOnly)
-	FString LastErrorMessage;
-
-	// === MÉTHODES UTILITAIRES ===
-
-	bool HasTimedOut() const;
-	bool CanRetry() const;
-	bool IsCacheValid() const;
-	float GetRetryDelay() const;
-	bool Matches(EDTFluxApiDataType InType, int32 InContestId = -1, int32 InStageId = -1, int32 InSplitId = -1) const;
-	FString GetCacheKey() const;
-	void SetRawResponse(const FString& RawData);
-	FString Serialize() const;
-};
-
-// ================================================================================================
-// DELEGATES POUR LES CALLBACKS
-// ================================================================================================
-
-DECLARE_DELEGATE_OneParam(FOnDTFluxRequestSuccess, const FDTFluxTrackedRequest&);
-DECLARE_DELEGATE_TwoParams(FOnDTFluxRequestError, const FDTFluxTrackedRequest&, const FString& /*ErrorMessage*/);
-
-DECLARE_MULTICAST_DELEGATE_TwoParams(FOnRequestStateChangedNative, const FGuid& /*RequestId*/,
-                                     EDTFluxRequestState& /*NewState*/);
-DECLARE_MULTICAST_DELEGATE_OneParam(FOnRequestCompletedNative, const FDTFluxTrackedRequest& /*CompletedRequest*/);
-DECLARE_MULTICAST_DELEGATE_OneParam(FOnRequestFailedNative, const FDTFluxTrackedRequest& /*FailedRequest*/);
-
-// ================================================================================================
-// REQUEST MANAGER - Classe C++ principale avec SmartPointers
-// ================================================================================================
 
 /**
- * Gestionnaire de requêtes trackées avec cache, timeout, retry et parsing asynchrone
+ * @brief Classe Tickable gérant les requêtes WebSockets qui ne sont pas traçables nativement par l'API.
- * Implémentation C++ pure avec SmartPointers pour des performances optimales
+ * Cette classe utilise TQueue pour gérer efficacement les requêtes en attente et vérifie leur état dans le tick.
  */
-class DTFLUXNETWORK_API FDTFluxQueuedRequestManager : public FTickableGameObject
+UCLASS()
+class DTFLUXNETWORK_API UDTFluxQueuedManager : public UObject, public FTickableGameObject
 {
+	GENERATED_BODY()
+
 public:
-	FDTFluxQueuedRequestManager();
+	/** Constructeur par défaut */
-	virtual ~FDTFluxQueuedRequestManager();
+	UDTFluxQueuedManager();
-
+	virtual ~UDTFluxQueuedManager() override;
-	// === LIFECYCLE ===
+	void Initialize();
-
+	FGuid QueueRequest(EDTFluxRequestType RequestType, int32 ContestId = -1, int32 StageId = -1, int32 SplitId = -1,
-	/**
+	                   const FString& RawMessage = "");
-	 * Initialiser le gestionnaire de requêtes
+	bool MarkRequestAsError(const FGuid& TargetRequestGuid);
-	 * @param DefaultConfig Configuration par défaut pour les nouvelles requêtes
+	bool MarkRequestAsResponded(const FGuid& TargetRequestGuid);
-	 */
+	bool MarkRequestAsResponded(const FDTFluxQueuedRequest& TargetRequest);
-	void Initialize(const FDTFluxRequestConfig& DefaultConfig = FDTFluxRequestConfig());
+	bool IsRequestPending(FGuid& OutRequestId, EDTFluxRequestType RequestType, int32 ContestId = -1, int32 StageId = -1,
-
+	                      int32 SplitId = -1);
-	/**
+	FDTFluxQueuedRequest* GetRequestPending(EDTFluxRequestType RequestType, int32 ContestId = -1, int32 StageId = -1,
-	 * Arrêter le gestionnaire et nettoyer toutes les ressources
+	                                        int32 SplitId = -1);
-	 */
+	const FDTFluxQueuedRequest* GetRequest(const FGuid& SearchedGuid);
-	void Shutdown();
+	int32 GetPendingRequestCount();
-
+	int32 CleanupTimedOutRequests();
-	/**
+	int32 CleanCashedRequests();
-	 * Vérifier si le gestionnaire est initialisé
-	 */
-	bool IsInitialized() const { return bIsInitialized.load(); }
-
-	// === CRÉATION DE REQUÊTES ===
-
-	/**
-	 * Créer une nouvelle requête trackée
-	 * @param RequestType Type de requête (ContestRanking, StageRanking, etc.)
-	 * @param ContestId ID du contest (-1 si non applicable)
-	 * @param StageId ID du stage (-1 si non applicable)  
-	 * @param SplitId ID du split (-1 si non applicable)
-	 * @param CustomConfig Configuration spécifique pour cette requête
-	 * @return GUID de la requête créée
-	 */
-	FGuid CreateTrackedRequest(
-		EDTFluxApiDataType RequestType,
-		int32 ContestId = -1,
-		int32 StageId = -1,
-		int32 SplitId = -1,
-		const FDTFluxRequestConfig& CustomConfig = FDTFluxRequestConfig()
-	);
-
-	/**
-	 * Créer une requête trackée avec callbacks C++
-	 * @param RequestType Type de requête
-	 * @param ContestId ID du contest
-	 * @param StageId ID du stage
-	 * @param SplitId ID du split
-	 * @param OnSuccess Callback appelé en cas de succès
-	 * @param OnError Callback appelé en cas d'erreur
-	 * @param CustomConfig Configuration spécifique
-	 * @return GUID de la requête créée
-	 */
-	FGuid CreateTrackedRequestWithCallbacks(
-		EDTFluxApiDataType RequestType,
-		int32 ContestId,
-		int32 StageId,
-		int32 SplitId,
-		FOnDTFluxRequestSuccess OnSuccess,
-		FOnDTFluxRequestError OnError,
-		const FDTFluxRequestConfig& CustomConfig = FDTFluxRequestConfig()
-	);
-
-	// === GESTION DES REQUÊTES ===
-
-	/**
-	 * Marquer une requête comme envoyée
-	 */
-	bool MarkRequestAsSent(const FGuid& RequestId);
-
-	/**
-	 * Compléter une requête avec la réponse reçue
-	 * @param RequestId ID de la requête
-	 * @param RawResponseData Données JSON brutes de la réponse
-	 * @param bUseAsyncParsing Utiliser le parsing asynchrone (recommandé)
-	 */
-	bool CompleteRequest(const FGuid& RequestId, const FString& RawResponseData, bool bUseAsyncParsing = true);
-
-	/**
-	 * Marquer une requête comme échouée
-	 */
-	bool FailRequest(const FGuid& RequestId, const FString& ErrorMessage);
-
-	/**
-	 * Relancer une requête (si retry possible)
-	 */
-	bool RetryRequest(const FGuid& RequestId);
-
-	// === RECHERCHE ET CACHE ===
-
-	/**
-	 * Chercher une requête en attente correspondant aux critères
-	 */
-	bool FindPendingRequest(
-		FGuid& OutRequestId,
-		EDTFluxApiDataType RequestType,
-		int32 ContestId = -1,
-		int32 StageId = -1,
-		int32 SplitId = -1
-	) const;
-
-	/**
-	 * Récupérer une réponse depuis le cache (données brutes)
-	 */
-	bool GetFromCache(
-		EDTFluxApiDataType RequestType,
-		FString& OutRawResponse,
-		int32 ContestId = -1,
-		int32 StageId = -1,
-		int32 SplitId = -1
-	) const;
-
-	/**
-	 * Récupérer une réponse parsée depuis le cache
-	 */
-	bool GetParsedFromCache(
-		EDTFluxApiDataType RequestType,
-		TSharedPtr<FDTFluxServerResponse>& OutResponse,
-		int32 ContestId = -1,
-		int32 StageId = -1,
-		int32 SplitId = -1
-	) const;
-
-	// === ACCESSEURS ===
-
-	/**
-	 * Récupérer une requête par son ID
-	 */
-	bool GetRequest(const FGuid& RequestId, FDTFluxTrackedRequest& OutRequest) const;
-
-	/**
-	 * Récupérer un pointeur vers une requête (plus efficace)
-	 */
-	const FDTFluxTrackedRequest* GetRequestPtr(const FGuid& RequestId) const;
-
-	/**
-	 * Récupérer toutes les requêtes dans un état donné
-	 */
-	TArray<FDTFluxTrackedRequest> GetRequestsByState(EDTFluxRequestState State) const;
-
-	/**
-	 * Compter les requêtes dans un état donné
-	 */
-	int32 GetRequestCount(EDTFluxRequestState State = EDTFluxRequestState::Pending) const;
-
-	// === STATISTIQUES ===
-
-	/**
-	 * Statistiques complètes du gestionnaire de requêtes
-	 */
-	struct FRequestStatistics
-	{
-		int32 Pending = 0;
-		int32 Cached = 0;
-		int32 Completed = 0;
-		int32 Failed = 0;
-		int32 TotalRequests = 0;
-		int32 CacheHits = 0;
-		int32 CacheMisses = 0;
-		float HitRate = 0.0f;
-	};
-
-	FRequestStatistics GetStatistics() const;
-
-	// === NETTOYAGE ===
-
-	/**
-	 * Nettoyer les entrées de cache expirées
-	 * @return Nombre d'entrées supprimées
-	 */
-	int32 CleanupExpiredCache();
-
-	/**
-	 * Nettoyer les requêtes terminées anciennes
-	 * @param OlderThanSeconds Supprimer les requêtes plus anciennes que ce délai
-	 * @return Nombre de requêtes supprimées
-	 */
-	int32 CleanupCompletedRequests(float OlderThanSeconds = 300.0f);
-
-	/**
-	 * Vider toutes les requêtes et le cache
-	 */
 	void ClearAllRequests();
+	// bool TryProcessResponse(const FDTFluxServerResponse& Response);
 
-	// === EVENTS ===
+	// Interface FTickableGameObject
-
-	FOnRequestStateChangedNative OnRequestStateChanged;
-	FOnRequestCompletedNative OnRequestCompleted;
-	FOnRequestFailedNative OnRequestFailed;
-
-	// === INTERFACE TICKABLE ===
-
 	virtual void Tick(float DeltaTime) override;
-	virtual bool IsTickable() const override { return true; };
+	virtual bool IsTickable() const override;
-
+	virtual TStatId GetStatId() const override;
-	virtual TStatId GetStatId() const override
-	{
-		RETURN_QUICK_DECLARE_CYCLE_STAT(FDTFluxQueuedRequestManager, STATGROUP_Tickables);
-	};
 	virtual bool IsTickableWhenPaused() const override { return true; }
 	virtual bool IsTickableInEditor() const override { return true; }
+	// Interface ~FTickableGameObject
 
-	// === ACCESSEUR POUR LE PARSER (debug/stats) ===
+
-	const FDTFluxAsyncParser* GetAsyncParser() const { return AsyncParser.Get(); }
+	UPROPERTY(BlueprintAssignable, Category = "DTFlux|Network")
+	FOnRequestTimedOut OnRequestTimedOut;
 
 private:
-	// === CONFIGURATION ===
+	TQueue<FDTFluxQueuedRequest, EQueueMode::Mpsc> PendingRequestsQueue;
-	FDTFluxRequestConfig DefaultConfig;
+	TQueue<FDTFluxQueuedRequest, EQueueMode::Mpsc> CompletedRequestsQueue;
-	std::atomic<bool> bIsInitialized{false};
+	TQueue<FDTFluxQueuedRequest, EQueueMode::Mpsc> TimedOutRequestsQueue;
 
-	// === TIMING POUR LE TICK ===
+	bool bIsInitialized;
-	float TimeSinceLastTimeoutCheck = 0.0f;
+	float CheckInterval;
-	float TimeSinceLastCacheCleanup = 0.0f;
+	float TimeSinceLastCheck;
-	float TimeSinceLastRetryCheck = 0.0f;
-
-	static constexpr float TimeoutCheckInterval = 1.0f;
-	static constexpr float CacheCleanupInterval = 30.0f;
-	static constexpr float RetryCheckInterval = 0.5f;
-
-	// === STOCKAGE THREAD-SAFE ===
-	mutable FCriticalSection RequestsLock;
-	TMap<FGuid, TSharedPtr<FDTFluxTrackedRequest>> AllRequests;
-	TMap<FString, FGuid> CacheKeyToRequestId;
-
-	// === CALLBACKS C++ ===
-	mutable FCriticalSection CallbacksLock;
-	TMap<FGuid, FOnDTFluxRequestSuccess> SuccessCallbacks;
-	TMap<FGuid, FOnDTFluxRequestError> ErrorCallbacks;
-
-	// === MÉTRIQUES ===
-	mutable FCriticalSection MetricsLock;
-	mutable int32 TotalRequests = 0;
-	mutable int32 CacheHits = 0;
-	mutable int32 CacheMisses = 0;
-
-
-	// === PARSER ASYNCHRONE ===
-	TUniquePtr<FDTFluxAsyncParser> AsyncParser;
-
-	// === MÉTHODES PRIVÉES ===
-
-	/**
-	 * Changer l'état d'une requête et notifier les observers
-	 */
-	void ChangeRequestState(TSharedPtr<FDTFluxTrackedRequest> Request, EDTFluxRequestState NewState);
-
-	/**
-	 * Traiter les requêtes en timeout (appelé périodiquement)
-	 */
-	void ProcessTimeouts();
-
-	/**
-	 * Traiter les requêtes à relancer (appelé périodiquement)
-	 */
-	void ProcessRetries();
-
-	/**
-	 * Nettoyer le cache périodiquement
-	 */
-	void ProcessCacheCleanup();
-
-	/**
-	 * Déclencher les callbacks pour une requête
-	 */
-	void TriggerCallbacks(const FDTFluxTrackedRequest& Request);
-
-	/**
-	 * Nettoyer les callbacks d'une requête
-	 */
-	void CleanupCallbacks(const FGuid& RequestId);
-
-	/**
-	 * Enregistrer un hit cache dans les métriques
-	 */
-	void RecordCacheHit() const;
-
-	/**
-	 * Enregistrer un miss cache dans les métriques
-	 */
-	void RecordCacheMiss() const;
-
-
-	// === CALLBACKS POUR LE PARSING ASYNCHRONE ===
-
-	/**
-	 * Callback appelé quand le parsing asynchrone réussit
-	 */
-	void OnParsingCompleted(const FGuid& RequestId, TSharedPtr<FDTFluxServerResponse> ParsedResponse, bool bSuccess);
-
-	/**
-	 * Callback appelé quand le parsing asynchrone échoue
-	 */
-	void OnParsingFailed(const FGuid& RequestId, const FString& ErrorMessage);
-
-	// === UTILITAIRES STATIQUES ===
-
-	/**
-	 * Générer une clé de cache unique pour une requête
-	 */
-	static FString GenerateCacheKey(EDTFluxApiDataType RequestType, int32 ContestId, int32 StageId, int32 SplitId);
 };

Source/DTFluxNetwork/Public/Struct/DTFluxServerResponseStruct.h

@@ -4,11 +4,13 @@
 
 #include "CoreMinimal.h"
 #include "UObject/Object.h"
+#include "DTFluxNetworkModule.h"
 #include "DTFluxRaceDataServerResponse.h"
 #include "DTFluxRankingServerResponse.h"
 #include "DTFluxSplitSensorServerResponse.h"
 #include "JsonObjectConverter.h"
 #include "Types/Enum/DTFluxCoreEnum.h"
+#include "Types/Objects/UDTFluxParticipantFactory.h"
 #include "Types/Struct/DTFluxRaceDataStructs.h"
 #include "Types/Struct/DTFluxRankingStructs.h"
 #include "Types/Struct/DTFluxSplitSensor.h"
@@ -83,14 +85,14 @@ public:
 
 	EDTFluxResponseStatus TryParse(bool bLogErrors = true);
 
-	bool ParseTeamList(FDTFluxTeamListDefinition& OutTeamList);
+	bool ParseTeamListResponse(FDTFluxTeamListDefinition& OutTeamList);
-	bool ParseTeamUpdate(FDTFluxTeamListDefinition& OutTeamUpdate);
+	bool ParseTeamUpdateResponse(FDTFluxTeamListDefinition& OutTeamUpdate);
 	bool ParseRaceData(FDTFluxRaceData& OutRaceData);
 	bool ParseContestRanking(FDTFluxContestRankings& OutContestRankings);
-	bool ParseStageRanking(FDTFluxStageRankings& OutStageRankings);
+	bool ParseStageRankingResponse(FDTFluxStageRankings& OutStageRankings);
-	bool ParseSplitRanking(FDTFluxSplitRankings& OutSplitRankings);
+	bool ParseSplitRankingResponse(FDTFluxSplitRankings& OutSplitRankings);
-	bool ParseStatusUpdate(FDTFluxTeamStatusUpdate& OutStatusUpdate);
+	bool ParseStatusUpdateResponse(FDTFluxTeamStatusUpdate& OutStatusUpdate);
-	bool ParseSplitSensor(TArray<FDTFluxSplitSensorInfo>& OutSplitSensorInfos);
+	bool ParseSplitSensorResponse(TArray<FDTFluxSplitSensorInfo>& OutSplitSensorInfos);
 
 
 	// === MÉTHODES UTILITAIRES ===

Source/DTFluxNetwork/Public/Subsystems/DTFluxNetworkSubsystem.h

@@ -1,54 +1,41 @@
-// ================================================================================================
+// Fill out your copyright notice in the Description page of Project Settings.
-// DTFluxNetworkSubsystem.h - Interface UObject avec compatibilité Blueprint
-// ================================================================================================
 
 #pragma once
 
 #include "CoreMinimal.h"
+#include "DTFluxQueuedManager.h"
+#include "Struct/DTFluxServerResponseStruct.h"
 #include "Subsystems/EngineSubsystem.h"
 #include "Types/DTFluxNetworkSettingsTypes.h"
 #include "Types/Enum/DTFluxCoreEnum.h"
-#include "DTFluxQueuedManager.h"
+#include "Types/Struct/DTFluxRaceDataStructs.h"
+#include "Types/Struct/DTFluxRankingStructs.h"
+#include "Types/Struct/DTFluxSplitSensor.h"
+#include "Types/Struct/DTFluxTeamListStruct.h"
 #include "DTFluxNetworkSubsystem.generated.h"
 
-// Forward declarations
+
 class FDTFluxWebSocketClient;
-class FDTFluxQueuedRequestManager;
+class UDTFluxQueuedManager;
-
 typedef TSharedPtr<FDTFluxWebSocketClient> FDTFluxWebSocketClientSP;
+class FDTFluxHttpClient;
+typedef TSharedPtr<FDTFluxHttpClient> FDTFluxHttpClientSP;
 
-// ================================================================================================
-// DELEGATES BLUEPRINT POUR LES REQUÊTES TRACKÉES
-// ================================================================================================
 
+// Delegates pour les requêtes avec callback
+DECLARE_DELEGATE_TwoParams(FOnDTFluxRequestResponseError, const FGuid&, const FString&);
+DECLARE_DELEGATE_TwoParams(FOnDTFluxTrackedRequestResponse, const FGuid&, FDTFluxServerResponse&);
+DECLARE_DELEGATE_TwoParams(FOnDTFluxTrackedRequestTimeout, const FGuid&, const FString& /*ErrorMessage*/);
+// Delegates Blueprint pour les requêtes avec tracking
 DECLARE_DYNAMIC_MULTICAST_DELEGATE_ThreeParams(FOnDTFluxTrackedRequestCompleted, const FGuid&, RequestId,
                                                EDTFluxApiDataType, RequestType, const FString&, ResponseData);
 
 DECLARE_DYNAMIC_MULTICAST_DELEGATE_ThreeParams(FOnDTFluxTrackedRequestFailed, const FGuid&, RequestId,
                                                EDTFluxApiDataType, RequestType, const FString&, ErrorMessage);
 
-// ================================================================================================
-// DELEGATES LEGACY POUR LA COMPATIBILITÉ
-// ================================================================================================
-
-DECLARE_DELEGATE_OneParam(FOnRaceDataReceived, const FDTFluxRaceData& /*RaceDataDefinition*/);
-DECLARE_DELEGATE_OneParam(FOnTeamListReceived, const FDTFluxTeamListDefinition& /*TeamListDefinition*/);
-DECLARE_DELEGATE_OneParam(FOnStageRankingReceived, const FDTFluxStageRankings& /*StageRankings*/);
-DECLARE_DELEGATE_OneParam(FOnSplitRankingReceived, const FDTFluxSplitRankings& /*SplitRankings*/);
-DECLARE_DELEGATE_OneParam(FOnContestRankingReceived, const FDTFluxContestRankings& /*ContestRankings*/);
-DECLARE_DELEGATE_OneParam(FOnSplitSensorReceived, const FDTFluxSplitSensorInfo& /*SplitSensorInfo*/);
-DECLARE_DELEGATE_OneParam(FOnTeamUpdateReceived, const FDTFluxTeamListDefinition& /*ParticipantToUpdate*/);
-DECLARE_DELEGATE_OneParam(FOnTeamStatusUpdateReceived, const FDTFluxTeamStatusUpdate& /*TeamToUpdate*/);
-
-DECLARE_DYNAMIC_MULTICAST_DELEGATE(FOnWebSocketConnected);
-
-// ================================================================================================
-// NETWORK SUBSYSTEM - Interface UObject avec compatibilité Blueprint
-// ================================================================================================
 
 /**
- * Subsystem réseau DTFlux avec support complet des requêtes trackées et compatibilité legacy
+ * 
- * Combine l'efficacité du RequestManager C++ avec l'interface Blueprint UObject
  */
 UCLASS(Blueprintable)
 class DTFLUXNETWORK_API UDTFluxNetworkSubsystem : public UEngineSubsystem
@@ -56,236 +43,180 @@ class DTFLUXNETWORK_API UDTFluxNetworkSubsystem : public UEngineSubsystem
 	GENERATED_BODY()
 
 public:
-	// === ÉTAT DE CONNEXION ===
+	UPROPERTY()
-	UPROPERTY(BlueprintReadOnly, Category = "DTFlux|Network")
 	EDTFluxConnectionStatus WsStatus = EDTFluxConnectionStatus::Unset;
 
-	// === CONNEXION WEBSOCKET (Legacy) ===
+	DECLARE_DYNAMIC_MULTICAST_DELEGATE(FOnWebSocketConnected);
 
-	/**
+	UPROPERTY(BlueprintAssignable, Category="DTFlux|Network")
-	 * Se connecter au serveur WebSocket
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Network")
-	void Connect();
-
-	/**
-	 * Se déconnecter du serveur WebSocket
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Network")
-	void Disconnect();
-
-	/**
-	 * Reconnecter au serveur WebSocket
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Network")
-	void Reconnect();
-
-	// === REQUÊTES TRACKÉES (Nouveau système optimisé) ===
-
-	/**
-	 * Envoyer une requête trackée avec cache, timeout et retry
-	 * @param RequestType Type de requête (ContestRanking, StageRanking, etc.)
-	 * @param ContestId ID du contest (-1 si non applicable)
-	 * @param StageId ID du stage (-1 si non applicable)
-	 * @param SplitId ID du split (-1 si non applicable)
-	 * @param TimeoutSeconds Timeout en secondes
-	 * @param MaxRetries Nombre maximum de tentatives
-	 * @param bEnableCache Activer le cache pour cette requête
-	 * @return GUID de la requête pour le suivi
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Tracked Requests")
-	FGuid SendTrackedRequest(
-		EDTFluxApiDataType RequestType,
-		int32 ContestId = -1,
-		int32 StageId = -1,
-		int32 SplitId = -1,
-		float TimeoutSeconds = 5.0f,
-		int32 MaxRetries = 3,
-		bool bEnableCache = true
-	);
-
-	/**
-	 * Envoyer une requête trackée avec callbacks C++ (non Blueprint)
-	 * @param RequestType Type de requête
-	 * @param ContestId ID du contest
-	 * @param StageId ID du stage
-	 * @param SplitId ID du split
-	 * @param OnSuccess Callback appelé en cas de succès
-	 * @param OnError Callback appelé en cas d'erreur
-	 * @param TimeoutSeconds Timeout en secondes
-	 * @param MaxRetries Nombre maximum de tentatives
-	 * @param bEnableCache Activer le cache
-	 * @return GUID de la requête
-	 */
-	FGuid SendTrackedRequestWithCallbacks(
-		EDTFluxApiDataType RequestType,
-		int32 ContestId,
-		int32 StageId,
-		int32 SplitId,
-		FOnDTFluxRequestSuccess& OnSuccess,
-		FOnDTFluxRequestError& OnError,
-		float TimeoutSeconds = 5.0f,
-		int32 MaxRetries = 3,
-		bool bEnableCache = true
-	);
-
-	// === ACCESSEURS BLUEPRINT POUR LES REQUÊTES TRACKÉES ===
-
-	/**
-	 * Récupérer une requête trackée par son ID
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Tracked Requests")
-	bool GetTrackedRequest(const FGuid& RequestId, FDTFluxTrackedRequest& OutRequest) const;
-
-	/**
-	 * Vérifier si une requête a reçu une réponse
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Tracked Requests")
-	bool HasRequestReceivedResponse(const FGuid& RequestId) const;
-
-	/**
-	 * Récupérer les données de réponse d'une requête
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Tracked Requests")
-	FString GetRequestResponseData(const FGuid& RequestId) const;
-
-	/**
-	 * Vérifier si une requête similaire est en attente
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Tracked Requests")
-	bool IsRequestPending(EDTFluxApiDataType RequestType, int32 ContestId = -1, int32 StageId = -1,
-	                      int32 SplitId = -1) const;
-
-	/**
-	 * Compter le nombre de requêtes en attente
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Tracked Requests")
-	int32 GetPendingRequestCount() const;
-
-	/**
-	 * Récupérer les statistiques du gestionnaire de requêtes
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Tracked Requests")
-	void GetRequestStatistics(int32& OutPending, int32& OutCached, int32& OutCompleted, int32& OutFailed,
-	                          float& OutHitRate) const;
-
-	// === REQUÊTES LEGACY (Compatibilité totale) ===
-
-	/**
-	 * Envoyer une requête en mode legacy (pour compatibilité)
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Legacy")
-	void SendRequest(const EDTFluxApiDataType RequestType, int InContestId = -1, int InStageId = -1,
-	                 int InSplitId = -1);
-
-	/**
-	 * Envoyer un message brut via WebSocket
-	 */
-	UFUNCTION(BlueprintCallable, Category = "DTFlux|Network")
-	void SendMessage(const FString& Message);
-
-	// === EVENTS BLUEPRINT ===
-
-	/**
-	 * Event déclenché lors de la connexion WebSocket
-	 */
-	UPROPERTY(BlueprintAssignable, Category = "DTFlux|Network")
 	FOnWebSocketConnected OnWebSocketConnected;
 
-	/**
+	DECLARE_DELEGATE_OneParam(FOnRaceDataReceived, const FDTFluxRaceData& /*RaceDataDefinition*/);
-	 * Event déclenché quand une requête trackée se termine avec succès
-	 */
-	UPROPERTY(BlueprintAssignable, Category = "DTFlux|Tracked Requests")
-	FOnDTFluxTrackedRequestCompleted OnTrackedRequestCompleted;
-
-	/**
-	 * Event déclenché quand une requête trackée échoue
-	 */
-	UPROPERTY(BlueprintAssignable, Category = "DTFlux|Tracked Requests")
-	FOnDTFluxTrackedRequestFailed OnTrackedRequestFailed;
-
-	// === DELEGATES LEGACY (Compatibilité totale) ===
-
 	FOnRaceDataReceived OnRaceDataReceived;
+
+	FOnRaceDataReceived& OnReceivedRaceData()
+	{
+		return OnRaceDataReceived;
+	};
+
+	// === DELEGATES POUR LES DONNÉES REÇUES (PUSH) ===
+	DECLARE_DELEGATE_OneParam(FOnTeamListReceived, const FDTFluxTeamListDefinition& /*TeamListDefinition*/);
 	FOnTeamListReceived OnTeamListReceived;
+
+	FOnTeamListReceived& OnReceivedTeamList()
+	{
+		return OnTeamListReceived;
+	};
+
+	DECLARE_DELEGATE_OneParam(FOnStageRankingReceived, const FDTFluxStageRankings& /*StageRankings*/);
 	FOnStageRankingReceived OnStageRankingReceived;
+
+	FOnStageRankingReceived& OnReceivedStageRanking()
+	{
+		return OnStageRankingReceived;
+	}
+
+	DECLARE_DELEGATE_OneParam(FOnSplitRankingReceived, const FDTFluxSplitRankings& /*SplitRankings*/);
 	FOnSplitRankingReceived OnSplitRankingReceived;
+
+	FOnSplitRankingReceived& OnReceivedSplitRanking()
+	{
+		return OnSplitRankingReceived;
+	}
+
+	DECLARE_DELEGATE_OneParam(FOnContestRankingReceived, const FDTFluxContestRankings& /*ContestRankings*/);
 	FOnContestRankingReceived OnContestRankingReceived;
+
+	FOnContestRankingReceived& OnReceivedContestRanking()
+	{
+		return OnContestRankingReceived;
+	};
+
+	// === DELEGATES POUR LES DONNÉES REÇUES (PULL) ===
+	DECLARE_DELEGATE_OneParam(FOnSplitSensorReceived, const FDTFluxSplitSensorInfo& /*ContestRankings*/);
 	FOnSplitSensorReceived OnSplitSensorReceived;
+
+	FOnSplitSensorReceived& OnReceivedSplitSensor()
+	{
+		return OnSplitSensorReceived;
+	};
+
+	DECLARE_DELEGATE_OneParam(FOnTeamUpdateReceived, const FDTFluxTeamListDefinition& /*ParticipantToUpdate*/);
 	FOnTeamUpdateReceived OnTeamUpdateReceived;
+
+	FOnTeamUpdateReceived& OnReceivedTeamUpdate()
+	{
+		return OnTeamUpdateReceived;
+	};
+
+	DECLARE_DELEGATE_OneParam(FOnTeamStatusUpdateReceived, const FDTFluxTeamStatusUpdate& /*TeamToUpdate*/);
 	FOnTeamStatusUpdateReceived OnTeamStatusUpdateReceived;
 
-	// Accesseurs pour la compatibilité legacy
+	FOnTeamStatusUpdateReceived& OnReceivedTeamStatusUpdate()
-	FOnRaceDataReceived& OnReceivedRaceData() { return OnRaceDataReceived; }
+	{
-	FOnTeamListReceived& OnReceivedTeamList() { return OnTeamListReceived; }
+		return OnTeamStatusUpdateReceived;
-	FOnStageRankingReceived& OnReceivedStageRanking() { return OnStageRankingReceived; }
+	};
-	FOnSplitRankingReceived& OnReceivedSplitRanking() { return OnSplitRankingReceived; }
-	FOnContestRankingReceived& OnReceivedContestRanking() { return OnContestRankingReceived; }
-	FOnSplitSensorReceived& OnReceivedSplitSensor() { return OnSplitSensorReceived; }
-	FOnTeamUpdateReceived& OnReceivedTeamUpdate() { return OnTeamUpdateReceived; }
-	FOnTeamStatusUpdateReceived& OnReceivedTeamStatusUpdate() { return OnTeamStatusUpdateReceived; }
 
-	// === ACCESSEUR PUBLIC POUR LE REQUEST MANAGER ===
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Network")
+	void Connect();
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Network")
+	void Disconnect();
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Network")
+	void Reconnect();
 
-	/**
+
-	 * Accéder au gestionnaire de requêtes (pour usage avancé)
+	// === REQUÊTES AVEC QUEUE ET TRACKING ===
-	 */
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Tracked Requests")
-	TSharedPtr<FDTFluxQueuedRequestManager> GetRequestManager() const { return RequestManager; }
+	FGuid SendTrackedRequest(EDTFluxApiDataType RequestType, int32 ContestId = -1, int32 StageId = -1,
+	                         int32 SplitId = -1, float TimeoutSeconds = 30.0f);
+
+	FGuid SendTrackedRequestWithCallback(EDTFluxApiDataType RequestType, int32 ContestId, int32 StageId, int32 SplitId,
+	                                     FOnDTFluxTrackedRequestResponse OnCompleted,
+	                                     FOnDTFluxTrackedRequestTimeout OnTimeout,
+	                                     TOptional<FOnDTFluxRequestResponseError> OnError = TOptional<
+		                                     FOnDTFluxRequestResponseError>(),
+	                                     float TimeoutSeconds = 30.0f);
+
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Tracked Requests")
+	bool GetTrackedRequest(const FGuid& RequestId, FDTFluxQueuedRequest& OutRequest) const;
+	const FDTFluxQueuedRequest* GetTrackedRequestPtr(const FGuid& RequestId) const;
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Tracked Requests", CallInEditor)
+	bool HasRequestReceivedResponse(const FGuid& RequestId) const;
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Tracked Requests")
+	FString GetRequestResponseData(const FGuid& RequestId) const;
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Tracked Requests")
+	bool IsRequestPending(EDTFluxApiDataType RequestType, int32 ContestId = -1, int32 StageId = -1,
+	                      int32 SplitId = -1) const;
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Tracked Requests")
+	int32 GetPendingRequestCount() const;
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Tracked Requests")
+	UDTFluxQueuedManager* GetQueueManager() const;
+
+	// === EVENTS BLUEPRINT POUR LE TRACKING ===
+	UPROPERTY(BlueprintAssignable, Category="DTFlux|Tracked Requests")
+	FOnDTFluxTrackedRequestCompleted OnTrackedRequestCompleted;
+	UPROPERTY(BlueprintAssignable, Category="DTFlux|Tracked Requests")
+	FOnDTFluxTrackedRequestFailed OnTrackedRequestFailed;
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Core Subsystem")
+
+	// === REQUÊTES DIRECTES (LEGACY) ===
+	void SendRequest(const EDTFluxApiDataType RequestType, int InContestId = -1, int InStageId = -1,
+	                 int InSplitId = -1);
+	UFUNCTION(BlueprintCallable, Category="DTFlux|Network")
+	void SendMessage(const FString& Message);
 
 protected:
-	// === LIFECYCLE DU SUBSYSTEM ===
+	// ~Subsystem Interface
 	virtual void Initialize(FSubsystemCollectionBase& Collection) override;
 	virtual void Deinitialize() override;
+	// ~Subsystem Interface
+
 
 private:
 	// === CONFIGURATION ===
 	FDTFluxWsSettings WsSettings;
+	FDTFluxHttpSettings HttpSettings;
+
+	UPROPERTY()
+	UDTFluxQueuedManager* QueueManager;
+
+	// === MAPPING DES CALLBACKS C++ ===
+	TMap<FGuid, FOnDTFluxTrackedRequestResponse> PendingCallbacks;
+	TMap<FGuid, FOnDTFluxTrackedRequestTimeout> PendingTimeoutCallbacks;
+	TMap<FGuid, FOnDTFluxRequestResponseError> PendingErrorCallbacks;
 
 	// === CLIENTS RÉSEAU ===
 	FDTFluxWebSocketClientSP WsClient = nullptr;
+	FDTFluxHttpClientSP HttpClient = nullptr;
 
-	// === REQUEST MANAGER C++ ===
+	// === MÉTHODES DE CONFIGURATION ===
-	TSharedPtr<FDTFluxQueuedRequestManager> RequestManager;
+	UFUNCTION()
+	void WsSettingsChanged(const FDTFluxWsSettings& NewWsSettings);
+	UFUNCTION()
+	void HttpSettingsChanged(const FDTFluxHttpSettings& NewHttpSettings);
+	void ReconnectWs(const FName WsClientId);
+	void ReconnectHttp(const FName WsClientId);
 
 	// === GESTION DES ÉVÉNEMENTS WEBSOCKET ===
 	void RegisterWebSocketEvents();
 	void UnregisterWebSocketEvents();
+
 	void OnWebSocketConnected_Subsystem();
 	void OnWebSocketConnectionError_Subsystem(const FString& Error);
 	void OnWebSocketClosedEvent_Subsystem(int32 StatusCode, const FString& Reason, bool bWasClean);
-	void OnWebSocketMessageEvent_Subsystem(const FString& MessageString);
-	void OnWebSocketMessageSentEvent_Subsystem(const FString& MessageSent);
 
-	// Handles pour les événements WebSocket
 	FDelegateHandle OnWsConnectedEventDelegateHandle;
 	FDelegateHandle OnWsConnectionErrorEventDelegateHandle;
 	FDelegateHandle OnWsClosedEventDelegateHandle;
 	FDelegateHandle OnWsMessageEventDelegateHandle;
 	FDelegateHandle OnWsMessageSentEventDelegateHandle;
 
-	// === PARSING ET TRAITEMENT DES RÉPONSES ===
+	// === GESTION DES ÉVÉNEMENTS HTTP ===
+	void RegisterHttpEvents();
+	void UnregisterHttpEvents();
 
-	/**
+	// === PARSING DES RÉPONSES ===
-	 * Essayer de matcher une réponse à une requête trackée
+	void ParseTeamListResponse(FDTFluxServerResponse& ServerResponse);
-	 * @param MessageString Message JSON reçu
-	 * @return true si la réponse correspond à une requête trackée
-	 */
-	bool TryMatchResponseToQueuedRequest(const FString& MessageString);
-
-	/**
-	 * Traiter une réponse en mode legacy
-	 * @param MessageString Message JSON à traiter
-	 */
-	void ProcessLegacyResponse(const FString& MessageString);
-
-	/**
-	 * Traiter une réponse déjà parsée
-	 * @param ParsedResponse Réponse parsée à traiter
-	 */
-	void ProcessParsedResponse(TSharedPtr<FDTFluxServerResponse> ParsedResponse);
-
-	// === MÉTHODES DE PARSING LEGACY (pour compatibilité) ===
-	void ParseTeamListResponse(FDTFluxServerResponse& Response);
 	void ParseRaceData(FDTFluxServerResponse& Response);
 	void ParseContestRanking(FDTFluxServerResponse& Response);
 	void ParseStageRankingResponse(FDTFluxServerResponse& Response);
@@ -294,45 +225,19 @@ private:
 	void ParseSplitSensorResponse(FDTFluxServerResponse& Response);
 	EDTFluxResponseStatus ProcessPushMessage(FDTFluxServerResponse& Response);
 
-	// === CALLBACKS POUR LE REQUEST MANAGER ===
+	void Parse(FDTFluxServerResponse& Response);
+	void OnWebSocketMessageEvent_Subsystem(const FString& MessageString);
+	void OnWebSocketMessageSentEvent_Subsystem(const FString& MessageSent);
+	bool CleanRequestCallbacks(const FGuid& RequestId);
 
-	/**
+	// === GESTION DES REQUÊTES TRACKÉES ===
-	 * Callback appelé quand une requête trackée se termine
-	 */
-	void OnRequestCompleted_Internal(const FDTFluxTrackedRequest& CompletedRequest);
-
-	/**
-	 * Callback appelé quand une requête trackée échoue
-	 */
-	void OnRequestFailed_Internal(const FDTFluxTrackedRequest& FailedRequest);
-
-	// === CONFIGURATION DYNAMIQUE ===
-
-	/**
-	 * Callback appelé quand les paramètres WebSocket changent
-	 */
 	UFUNCTION()
-	void WsSettingsChanged(const FDTFluxWsSettings& NewWsSettings);
+	void OnRequestTimedOut_Internal(const FDTFluxQueuedRequest& TimedOutRequest);
-
+	bool TryMatchResponseToQueuedRequest(FDTFluxServerResponse& Response);
-	/**
+	void CompleteTrackedRequest(const FGuid& RequestId, const FString& ResponseData, EDTFluxRequestType RequestType);
-	 * Reconnecter le client WebSocket
+	void FailTrackedRequest(const FGuid& RequestId, const FString& ErrorMessage, EDTFluxRequestType RequestType);
-	 */
+	void SendQueuedRequest(const FDTFluxQueuedRequest& QueuedRequest);
-	void ReconnectWs(const FName WsClientId);
 
 	// === UTILITAIRES ===
-
-	/**
-	 * Construire une adresse WebSocket complète
-	 */
 	static FString ConstructWsAddress(const FString& Address, const FString& Path, const int& Port);
-
-	/**
-	 * Envoyer une requête trackée via le réseau
-	 */
-	void SendQueuedRequest(const FDTFluxTrackedRequest& QueuedRequest);
-
-	/**
-	 * Déterminer si on doit utiliser le parsing asynchrone
-	 */
-	bool ShouldUseAsyncParsing(const FString& JsonData) const;
 };

Source/DTFluxRaceResult/DTFluxRaceResult.Build.cs

@@ -0,0 +1,34 @@
+using UnrealBuildTool;
+
+public class DTFluxRaceResult : ModuleRules
+{
+    public DTFluxRaceResult(ReadOnlyTargetRules Target) : base(Target)
+    {
+        PCHUsage = ModuleRules.PCHUsageMode.UseExplicitOrSharedPCHs;
+
+        PublicDependencyModuleNames.AddRange(
+            new string[]
+            {
+                "Core"
+            }
+        );
+
+        PrivateDependencyModuleNames.AddRange(
+            new string[]
+            {
+                "CoreUObject",
+                "Engine",
+                "Slate",
+                "SlateCore",
+                "DTFluxProjectSettings",
+                "UMG",
+                "WebBrowser",
+                "Projects",
+                "ToolMenus",
+                "HTTP",
+                "JsonUtilities",
+                "Json"
+            }
+        );
+    }
+}

Source/DTFluxRaceResult/Private/DTFluxRaceResultModule.cpp

@@ -0,0 +1,161 @@
+#include "DTFluxRaceResultModule.h"
+
+#include "LevelEditor.h"
+#include "Widget/SDTFluxRaceResultWidget.h"
+#include "Widget/Style/DTFluxRaceResultStyle.h"
+
+#define LOCTEXT_NAMESPACE "FDTFluxRaceResultModule"
+
+DEFINE_LOG_CATEGORY(logDTFluxRaceResult)
+
+FName DTFLUXRACERESULT_API FDTFluxRaceResult::RaceResultTabId = "DTFluxRaceResult";
+FText DTFLUXRACERESULT_API FDTFluxRaceResult::RaceResultTabDisplayName = FText::FromString(TEXT("DTFlux RaceResult"));
+
+
+void DTFLUXRACERESULT_API FDTFluxRaceResult::StartupModule()
+{
+	UE_LOG(logDTFluxRaceResult, Warning, TEXT("DTFluxRaceResult Module Started"))
+	FDTFluxRaceResultStyle::RegisterStyle();
+	InitMenuExtension();
+	RegisterRaceResultTab();
+}
+
+#pragma region MenuExtension
+
+
+void DTFLUXRACERESULT_API FDTFluxRaceResult::InitMenuExtension()
+{
+	UToolMenus::RegisterStartupCallback(
+		FSimpleMulticastDelegate::FDelegate::CreateRaw(this,
+		                                               &FDTFluxRaceResult::RegisterMenuExtensions));
+}
+
+
+void DTFLUXRACERESULT_API FDTFluxRaceResult::RegisterMenuExtensions()
+{
+    
+	// Étendre le menu enregistré
+	if (UToolMenu* DTFluxMenu = UToolMenus::Get()->ExtendMenu("DTFlux.MainMenu"))
+	{
+		FToolMenuSection& ToolsSection = DTFluxMenu->FindOrAddSection("Tools");
+		ToolsSection.AddMenuEntry(
+			"DTFluxRaceResult",
+			FText::FromString("RaceResult"),
+			FText::FromString("Launch DTFlux RaceResult Control Panel"),
+			FSlateIcon(FDTFluxRaceResultStyle::GetStyleSetName(), "LevelEditor.Tab.IconRaceResult"),
+			FUIAction(FExecuteAction::CreateRaw(this, &FDTFluxRaceResult::OnButtonClicked))
+		);
+	}
+	
+}
+
+void FDTFluxRaceResult::CreateSubmenu(UToolMenu* Menu)
+{
+	// Section 2 : Tools
+	FToolMenuSection& ToolsSection = Menu->FindOrAddSection("Tools");
+	ToolsSection.Label = FText::FromString("Tools");
+	ToolsSection.AddMenuEntry(
+		"DTFluxRaceResult",
+		FText::FromString("RaceResult"),
+		FText::FromString("Launch Race Result WebAdmin Console"),
+		FSlateIcon(FDTFluxRaceResultStyle::GetStyleSetName(), "LevelEditor.Tab.IconRaceResult"),
+		// Adaptez selon votre icône
+		FUIAction(FExecuteAction::CreateRaw(this, &FDTFluxRaceResult::OnButtonClicked))
+	);
+}
+
+void DTFLUXRACERESULT_API FDTFluxRaceResult::OnButtonClicked()
+{
+	FGlobalTabmanager::Get()->TryInvokeTab(RaceResultTabId);
+	UE_LOG(LogTemp, Log, TEXT("Race Result Launched"))
+}
+
+#pragma endregion EditorTab
+
+#pragma region
+void DTFLUXRACERESULT_API FDTFluxRaceResult::RegisterRaceResultTab()
+{
+	FTabSpawnerEntry& SpawnerEntry =
+		FGlobalTabmanager::Get()->RegisterNomadTabSpawner(
+			                        RaceResultTabId,
+			                        FOnSpawnTab::CreateRaw(this, &FDTFluxRaceResult::OnSpawnTab)
+		                        )
+		                        .SetDisplayName(RaceResultTabDisplayName)
+		                        .SetTooltipText(FText::FromString(TEXT("Race Result Control Panel")));
+}
+
+TSharedRef<SDockTab> DTFLUXRACERESULT_API FDTFluxRaceResult::OnSpawnTab(const FSpawnTabArgs& SpawnTabArgs)
+{
+	return
+			SNew(
+				SDockTab
+			)
+			.TabRole(ETabRole::NomadTab)
+			// .ShouldAutosize(true)
+			[
+				SNew(SDTFluxRaceResultWidget)
+			];
+}
+
+#pragma endregion
+void DTFLUXRACERESULT_API FDTFluxRaceResult::ShutdownModule()
+{
+	FGlobalTabmanager::Get()->UnregisterNomadTabSpawner(RaceResultTabId);
+	FDTFluxRaceResultStyle::UnregisterStyle();
+}
+
+
+//
+// // Dans votre code de debug
+// void DTFLUXRACERESULT_API FDTFluxRaceResult::DebugMenus()
+// {
+// 	UToolMenus* ToolMenus = UToolMenus::Get();
+// 	if (ToolMenus)
+// 	{
+// 		TArray<FName> MenuNames;
+// 		ToolMenus->GetAllMenuNames(MenuNames);
+//         
+// 		UE_LOG(logDTFluxRaceResult, Warning, TEXT("=== ALL AVAILABLE MENUS ==="));
+// 		for (const FName& MenuName : MenuNames)
+// 		{
+// 			UE_LOG(logDTFluxRaceResult, Warning, TEXT("Menu: %s"), *MenuName.ToString());
+//             
+// 			// Obtenir les sections de chaque menu
+// 			UToolMenu* Menu = ToolMenus->FindMenu(MenuName);
+// 			if (Menu)
+// 			{
+// 				for (const FToolMenuSection& Section : Menu->Sections)
+// 				{
+// 					UE_LOG(logDTFluxRaceResult, Warning, TEXT("  Section: %s"), *Section.Name.ToString());
+// 				}
+// 			}
+// 		}
+// 		UE_LOG(logDTFluxRaceResult, Warning, TEXT("=== END MENU LIST ==="));
+// 	}
+// }
+
+
+// void DTFLUXRACERESULT_API FDTFluxRaceResult::AddMenu(FMenuBarBuilder& MenuBarBuilder)
+// {
+// 	MenuBarBuilder.AddPullDownMenu(
+// 		FText::FromString("DTFlux"),
+// 		FText::FromString("DTFlux API Tools"),
+// 		FNewMenuDelegate::CreateRaw(this, &FDTFluxRaceResult::FillMenu)
+// 		);
+// }
+
+// void DTFLUXRACERESULT_API FDTFluxRaceResult::FillMenu(FMenuBuilder& MenuBuilder)
+// {
+// 	MenuBuilder.AddMenuEntry(
+// 	FText::FromString("RaceResult ControlPanel"),
+// 	FText::FromString("Launch RaceResult Control Panel"),
+// 	FSlateIcon(FDTFluxRaceResultStyle::GetStyleSetName(), "LevelEditor.Tab.IconRaceResult"),
+// 	FExecuteAction::CreateRaw(this, &FDTFluxRaceResult::OnButtonClicked)
+// 	);
+// 	MenuBuilder.EndSection();
+// }
+
+
+#undef LOCTEXT_NAMESPACE
+
+IMPLEMENT_MODULE(FDTFluxRaceResult, DTFluxRaceResult)

Source/DTFluxRaceResult/Private/Widget/SDTFluxRaceResultWidget.cpp

@@ -0,0 +1,283 @@
+// Fill out your copyright notice in the Description page of Project Settings.
+
+
+#include "Widget/SDTFluxRaceResultWidget.h"
+
+#include "DTFluxRaceResultModule.h"
+#include "HttpModule.h"
+#include "IWebBrowserCookieManager.h"
+#include "IWebBrowserWindow.h"
+#include "SlateOptMacros.h"
+#include "WebBrowserModule.h"
+#include "Interfaces/IHttpRequest.h"
+#include "Interfaces/IHttpResponse.h"
+
+BEGIN_SLATE_FUNCTION_BUILD_OPTIMIZATION
+
+void SDTFluxRaceResultWidget::Construct(const FArguments& InArgs)
+{
+
+	FWebBrowserInitSettings browserInitSettings = FWebBrowserInitSettings();
+	
+	IWebBrowserModule::Get().CustomInitialize(browserInitSettings);
+	WindowSettings.InitialURL = TEXT("about:blank");
+	WindowSettings.BrowserFrameRate = 25;
+
+	if (IWebBrowserModule::IsAvailable() && IWebBrowserModule::Get().IsWebModuleAvailable())
+	{
+		IWebBrowserSingleton* WebBrowserSingleton = IWebBrowserModule::Get().GetSingleton();
+		Browser = WebBrowserSingleton->CreateBrowserWindow(WindowSettings);
+		// Browser->OnLoadUrl().BindRaw(this, &SDTFluxRaceResultWidget::OnLoadOverride);
+		
+	}
+
+	
+	ChildSlot
+	[
+		SNew(SBox)
+		.Padding(5.0f)
+		[
+			SNew(SBorder)
+			.BorderImage(FCoreStyle::Get().GetBrush("ToolPanel.GroupBorder"))
+			[
+				SNew(SVerticalBox)
+				+ SVerticalBox::Slot()
+				[
+					SAssignNew(WebBrowser, SWebBrowser, Browser)
+					.ShowControls(true)
+					.SupportsTransparency(true)
+					.OnUrlChanged(this, &SDTFluxRaceResultWidget::OnUrlChanged)
+					.OnBeforeNavigation(this, &SDTFluxRaceResultWidget::OnBeforeNavigation)
+					.OnLoadCompleted(FSimpleDelegate::CreateRaw(this, &SDTFluxRaceResultWidget::OnLoadCompleted))
+					.OnLoadError(FSimpleDelegate::CreateRaw(this, &SDTFluxRaceResultWidget::OnLoadError))
+					.OnLoadStarted(FSimpleDelegate::CreateRaw(this, &SDTFluxRaceResultWidget::OnLoadStarted))
+					.ShowErrorMessage(true)
+					.ShowAddressBar(true)
+				]
+			]
+		]
+	];
+	
+}
+
+void SDTFluxRaceResultWidget::OnCookieSet(bool bSuccess)
+{
+}
+
+
+void SDTFluxRaceResultWidget::LoadContentViaHTTP()
+{
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("Loading initial content via HTTP: %s"), *RaceResultUrl);
+	LoadSpecificURL(RaceResultUrl);
+}
+
+
+void SDTFluxRaceResultWidget::LoadSpecificURL(const FString& Url)
+{
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("Loading via HTTP: %s"), *Url);
+    
+	// Créer la requête HTTP
+	TSharedRef<IHttpRequest, ESPMode::ThreadSafe> Request = FHttpModule::Get().CreateRequest();
+    
+	// Ajouter l'authentification Basic pour TOUTES les requêtes
+	FString Credentials = Username + TEXT(":") + Password;
+	FString EncodedCredentials = FBase64::Encode(Credentials);
+    
+	Request->SetURL(Url);
+	Request->SetVerb("GET");
+	Request->SetHeader("Authorization", "Basic " + EncodedCredentials);
+	Request->SetHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36");
+	Request->SetHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8");
+	Request->SetHeader("Accept-Language", "en-US,en;q=0.5");
+	Request->SetHeader("Accept-Encoding", "gzip, deflate");
+	Request->SetHeader("Connection", "keep-alive");
+    
+	Request->OnProcessRequestComplete().BindRaw(this, &SDTFluxRaceResultWidget::OnHTTPContentLoaded);
+	Request->ProcessRequest();
+    
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("HTTP request sent with Basic Auth"));
+}
+
+void SDTFluxRaceResultWidget::OnHTTPContentLoaded(TSharedPtr<IHttpRequest> Request,
+	TSharedPtr<IHttpResponse> HttpResponse, bool bWasSuccessful)
+{
+	if (bWasSuccessful && HttpResponse.IsValid())
+	{
+		int32 ResponseCode = HttpResponse->GetResponseCode();
+		UE_LOG(logDTFluxRaceResult, Log, TEXT("HTTP Response Code: %d"), ResponseCode);
+        
+		if (ResponseCode == 200)
+		{
+			FString Content = HttpResponse->GetContentAsString();
+			UE_LOG(logDTFluxRaceResult, Log, TEXT("Content loaded successfully, size: %d characters"), Content.Len());
+            
+			// Traiter le contenu HTML
+			FString ProcessedContent = ProcessHTMLContent(Content, Request->GetURL());
+            
+			// Charger le contenu dans le browser via LoadString
+			if (Browser.IsValid())
+			{
+				Browser->LoadString(ProcessedContent, Request->GetURL());
+				UE_LOG(logDTFluxRaceResult, Log, TEXT("Content loaded into browser"));
+			}
+		}
+		else if (ResponseCode == 401)
+		{
+			UE_LOG(logDTFluxRaceResult, Error, TEXT("Authentication failed - 401 Unauthorized. Check your credentials."));
+		}
+		else if (ResponseCode == 403)
+		{
+			UE_LOG(logDTFluxRaceResult, Error, TEXT("Access forbidden - 403 Forbidden"));
+		}
+		else if (ResponseCode == 404)
+		{
+			UE_LOG(logDTFluxRaceResult, Error, TEXT("Page not found - 404 Not Found"));
+		}
+		else
+		{
+			UE_LOG(logDTFluxRaceResult, Error, TEXT("HTTP request failed with code: %d"), ResponseCode);
+		}
+	}
+	else
+	{
+		UE_LOG(logDTFluxRaceResult, Error, TEXT("HTTP request failed completely"));
+	}
+}
+
+void SDTFluxRaceResultWidget::OnLoadOverride()
+{
+}
+
+
+void SDTFluxRaceResultWidget::OnUrlChanged(const FText& NewUrl)
+{
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("URL changed to: %s"), *NewUrl.ToString());
+}
+
+FString SDTFluxRaceResultWidget::ProcessHTMLContent(const FString& Content, const FString& BaseUrl)
+{
+	FString ProcessedContent = Content;
+    
+	// Extraire le domaine de base
+	FString BaseDomain = ExtractDomain(BaseUrl);
+    
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("Processing HTML content, base domain: %s"), *BaseDomain);
+    
+	// Convertir tous les liens relatifs en liens absolus
+	ProcessedContent = ProcessedContent.Replace(TEXT("src=\"/"), *FString::Printf(TEXT("src=\"%s/"), *BaseDomain));
+	ProcessedContent = ProcessedContent.Replace(TEXT("href=\"/"), *FString::Printf(TEXT("href=\"%s/"), *BaseDomain));
+	ProcessedContent = ProcessedContent.Replace(TEXT("src='/"), *FString::Printf(TEXT("src='%s/"), *BaseDomain));
+	ProcessedContent = ProcessedContent.Replace(TEXT("href='/"), *FString::Printf(TEXT("href='%s/"), *BaseDomain));
+    
+	// Gérer les liens relatifs avec ./
+	ProcessedContent = ProcessedContent.Replace(TEXT("src=\"./"), *FString::Printf(TEXT("src=\"%s/"), *BaseDomain));
+	ProcessedContent = ProcessedContent.Replace(TEXT("href=\"./"), *FString::Printf(TEXT("href=\"%s/"), *BaseDomain));
+    
+	// Ajouter une balise base pour aider avec les liens relatifs restants
+	FString BaseTag = FString::Printf(TEXT("<base href=\"%s/\">"), *BaseDomain);
+	if (ProcessedContent.Contains(TEXT("<head>")))
+	{
+		FString HeadReplacement = TEXT("<head>") + BaseTag;
+		ProcessedContent = ProcessedContent.Replace(TEXT("<head>"), *HeadReplacement);
+	}
+	else if (ProcessedContent.Contains(TEXT("<HEAD>")))
+	{
+		FString HeadReplacement = TEXT("<HEAD>") + BaseTag;
+		ProcessedContent = ProcessedContent.Replace(TEXT("<HEAD>"), *HeadReplacement);
+	}
+    
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("HTML content processed"));
+	return ProcessedContent;
+}
+
+
+FString SDTFluxRaceResultWidget::ExtractDomain(const FString& Url)
+{
+	FString Domain = Url;
+    
+	// Enlever le protocole
+	if (Url.StartsWith(TEXT("https://")))
+	{
+		Domain = Url.Mid(8);
+	}
+	else if (Url.StartsWith(TEXT("http://")))
+	{
+		Domain = Url.Mid(7);
+	}
+    
+	// Trouver le premier slash (début du path)
+	int32 SlashIndex;
+	if (Domain.FindChar(TEXT('/'), SlashIndex))
+	{
+		Domain = Url.Left(Url.Len() - (Domain.Len() - SlashIndex));
+	}
+    
+	// Enlever le port si présent
+	FString DomainPart = Domain;
+	if (Domain.StartsWith(TEXT("https://")))
+	{
+		DomainPart = Domain.Mid(8);
+	}
+	else if (Domain.StartsWith(TEXT("http://")))
+	{
+		DomainPart = Domain.Mid(7);
+	}
+    
+	int32 ColonIndex;
+	if (DomainPart.FindChar(TEXT(':'), ColonIndex))
+	{
+		Domain = Domain.Left(Domain.Len() - (DomainPart.Len() - ColonIndex));
+	}
+    
+	return Domain;
+}
+
+bool SDTFluxRaceResultWidget::OnBeforeNavigation(const FString& Url, const FWebNavigationRequest& Request)
+{
+
+		UE_LOG(logDTFluxRaceResult, Log, TEXT("Loading via HTTP: %s"), *Url);
+    
+		TSharedRef<IHttpRequest, ESPMode::ThreadSafe> HTTPRequest = FHttpModule::Get().CreateRequest();
+    
+		// Authentification pour toutes les requêtes
+		FString Credentials = Username + TEXT(":") + Password;
+		FString EncodedCredentials = FBase64::Encode(Credentials);
+    
+		HTTPRequest->SetURL(RaceResultUrl);
+		HTTPRequest->SetVerb("GET");
+		HTTPRequest->SetHeader("Authorization", "Basic " + EncodedCredentials);
+		HTTPRequest->SetHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36");
+		HTTPRequest->SetHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
+    
+		HTTPRequest->OnProcessRequestComplete().BindRaw(this, &SDTFluxRaceResultWidget::OnHTTPContentLoaded);
+		HTTPRequest->ProcessRequest();
+
+	return true;
+}
+
+void SDTFluxRaceResultWidget::OnLoadCompleted()
+{
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("Load Completed"));
+
+}
+
+void SDTFluxRaceResultWidget::OnLoadStarted()
+{
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("Load Started"));
+}
+
+void SDTFluxRaceResultWidget::OnLoadError()
+{
+	UE_LOG(logDTFluxRaceResult, Log, TEXT("Load Error"));
+}
+
+void SDTFluxRaceResultWidget::OnBeforeResourceLoad(FString Url, FString ResourceType, FContextRequestHeaders& AdditionalHeaders, const bool AllowUserCredentials)
+{
+}
+
+void SDTFluxRaceResultWidget::SetupBasicAuth()
+{
+	
+}
+
+END_SLATE_FUNCTION_BUILD_OPTIMIZATION

Source/DTFluxRaceResult/Private/Widget/Style/DTFluxRaceResultStyle.cpp

@@ -0,0 +1,47 @@
+// Fill out your copyright notice in the Description page of Project Settings.
+
+
+#include "Widget/Style/DTFluxRaceResultStyle.h"
+
+
+#include "Interfaces/IPluginManager.h"
+#include "Styling/SlateStyleRegistry.h"
+#include "Styling/SlateStyleMacros.h"
+
+#define RootToContentDir Style->RootToContentDir
+
+TSharedPtr<ISlateStyle> FDTFluxRaceResultStyle::StyleSet = nullptr;
+
+void FDTFluxRaceResultStyle::RegisterStyle()
+{
+	if(StyleSet.IsValid()) return;
+
+	StyleSet = Create();
+	FSlateStyleRegistry::RegisterSlateStyle(*StyleSet);
+}
+
+void FDTFluxRaceResultStyle::UnregisterStyle()
+{
+	if(StyleSet.IsValid())
+	{
+		FSlateStyleRegistry::UnRegisterSlateStyle(*StyleSet);
+		ensure(StyleSet.IsUnique());
+		StyleSet.Reset();
+	}
+
+	
+}
+
+void FDTFluxRaceResultStyle::ReloadTextures()
+{
+}
+
+TSharedPtr<ISlateStyle> FDTFluxRaceResultStyle::Create()
+{
+	TSharedPtr<FSlateStyleSet> Style = MakeShareable(new FSlateStyleSet("DTFluxRaceResultStyle"));
+	Style->SetContentRoot(IPluginManager::Get().FindPlugin("DTFluxAPI")->GetBaseDir()/TEXT("Resources"));
+
+	Style->Set("LevelEditor.Tab.IconRaceResult", new IMAGE_BRUSH_SVG("DTFluxRaceResult16x16", FVector2d(16)) );
+	return Style;
+}
+

Source/DTFluxRaceResult/Public/DTFluxRaceResultModule.h

@@ -0,0 +1,33 @@
+#pragma once
+
+#include "CoreMinimal.h"
+#include "Modules/ModuleManager.h"
+
+DTFLUXRACERESULT_API DECLARE_LOG_CATEGORY_EXTERN(logDTFluxRaceResult, All, All);
+
+class DTFLUXRACERESULT_API FDTFluxRaceResult : public IModuleInterface
+{
+public:
+    virtual void StartupModule() override;
+    virtual void ShutdownModule() override;
+
+#pragma region MenuExtention
+    void RegisterMenuExtensions();
+    void InitMenuExtension();
+    void CreateSubmenu(UToolMenu* Menu);
+
+    // void AddMenu(FMenuBarBuilder& MenuBarBuilder);
+    // void FillMenu(FMenuBuilder& MenuBuilder);
+    void OnButtonClicked();
+#pragma endregion
+
+#pragma region EditorTab
+    void RegisterRaceResultTab();
+    TSharedRef<SDockTab> OnSpawnTab(const FSpawnTabArgs& SpawnTabArgs);
+private:
+    // static void DebugMenus();
+    static FName RaceResultTabId;
+    static FText RaceResultTabDisplayName;
+    TSharedPtr<class SDTFluxRaceResultWidget> RaceResultWidget;
+#pragma endregion
+};

Source/DTFluxRaceResult/Public/Widget/SDTFluxRaceResultWidget.h

@@ -0,0 +1,54 @@
+// Fill out your copyright notice in the Description page of Project Settings.
+
+#pragma once
+
+#include "CoreMinimal.h"
+#include "SWebBrowser.h"
+#include "Widgets/SCompoundWidget.h"
+
+class IHttpResponse;
+class IHttpRequest;
+/**
+ * 
+ */
+class DTFLUXRACERESULT_API SDTFluxRaceResultWidget : public SCompoundWidget
+{
+public:
+	SLATE_BEGIN_ARGS(SDTFluxRaceResultWidget)
+		{
+		}
+
+	SLATE_END_ARGS()
+
+	/** Constructs this widget with InArgs */
+	void Construct(const FArguments& InArgs);
+	void OnCookieSet(bool bSuccess);
+	void LoadSpecificURL(const FString& Url);
+	void LoadContentViaHTTP();
+
+private:
+	TSharedPtr<SWebBrowser> WebBrowser;
+	TSharedPtr<IWebBrowserWindow> Browser;
+	TSharedPtr<IWebBrowserAdapter> BrowserAdapter;
+	FCreateBrowserWindowSettings WindowSettings;
+	
+	void OnUrlChanged(const FText& NewUrl);
+	FString ProcessHTMLContent(const FString& Content, const FString& BaseUrl);
+	FString ExtractDomain(const FString& Url);
+	void OnHTTPContentLoaded(TSharedPtr<IHttpRequest> Request, TSharedPtr<IHttpResponse> HttpResponse, bool bWasSuccessful);
+	bool OnBeforeNavigation(const FString& Url, const FWebNavigationRequest& Request);
+	void OnLoadCompleted();
+	void OnLoadStarted();
+	void OnLoadError();
+
+	void OnLoadOverride();
+	
+	void OnBeforeResourceLoad(FString Url, FString ResourceType, FContextRequestHeaders& AdditionalHeaders, const bool AllowUserCredentials);
+
+	FString RaceResultUrl = "https://raceresult.tds-france.com";
+	FString Username = "sporkrono";
+	FString Password = "Notre 3ème décennie d'action pour le climat";
+	
+
+	void SetupBasicAuth();
+};

Source/DTFluxRaceResult/Public/Widget/Style/DTFluxRaceResultStyle.h

@@ -0,0 +1,34 @@
+// Fill out your copyright notice in the Description page of Project Settings.
+
+#pragma once
+
+#include "CoreMinimal.h"
+#include "Styling/ISlateStyle.h"
+
+
+/**
+ * 
+ */
+class DTFLUXRACERESULT_API FDTFluxRaceResultStyle
+{
+
+public:
+	static void RegisterStyle();
+	static void UnregisterStyle();
+
+	static void ReloadTextures();
+
+	static const ISlateStyle& Get()
+	{
+		return *StyleSet;
+	}
+
+	static const FName& GetStyleSetName()
+	{
+		return StyleSet->GetStyleSetName();
+	}
+
+private:
+	static TSharedPtr<ISlateStyle> Create();
+	static TSharedPtr<ISlateStyle> StyleSet;
+};