Merge pull request #558 from ipax77/dev

ipax77 · web-flow · commit 5c709624e0e9 · 2025-12-09T10:00:04.000+01:00
fix upload decode service
diff --git a/src/dsstats.api/Hubs/UploadHub.cs b/src/dsstats.api/Hubs/UploadHub.cs
@@ -25,7 +25,7 @@ public async Task DecodeRequest(Guid guid)
 
         decodeService.DecodeFinished += decodeEventHandler;
 
-        var timeoutTask = Task.Delay(20000);
+        var timeoutTask = Task.Delay(25000);
 
         var completedTask = await Task.WhenAny(completionSource.Task, timeoutTask);
 
@@ -67,7 +67,7 @@ public async Task DecodeRawRequest(Guid guid)
 
         decodeService.DecodeRawFinished += decodeEventHandler;
 
-        var timeoutTask = Task.Delay(20000);
+        var timeoutTask = Task.Delay(25000);
 
         var completedTask = await Task.WhenAny(completionSource.Task, timeoutTask);
 
diff --git a/src/dsstats.api/dsstats.api.sln b/src/dsstats.api/dsstats.api.sln
@@ -0,0 +1,24 @@
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.5.2.0
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "dsstats.api", "dsstats.api.csproj", "{97694AC4-1EFB-7B86-C32A-B24CC6D5BEC9}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{97694AC4-1EFB-7B86-C32A-B24CC6D5BEC9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{97694AC4-1EFB-7B86-C32A-B24CC6D5BEC9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{97694AC4-1EFB-7B86-C32A-B24CC6D5BEC9}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{97694AC4-1EFB-7B86-C32A-B24CC6D5BEC9}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {CDB63AA8-0210-44C7-9269-7B4C2F35E5DA}
+	EndGlobalSection
+EndGlobal
diff --git a/src/dsstats.decode/DecodeService.cs b/src/dsstats.decode/DecodeService.cs
@@ -43,7 +43,7 @@ private async Task<int> SaveAndQueueFiles(Guid guid, List<IFormFile> files, bool
             logger.LogInformation("Saved uploaded replay to temp: {path}", tempPath);
 
             // Prepare job
-            var job = new ReplayJob(Guid.NewGuid(), tempPath, "", inHouse);
+            var job = new ReplayJob(guid, tempPath, "", inHouse);
             
             // Try enqueue
             if (!replayQueue.TryEnqueue(job))
@@ -53,7 +53,7 @@ private async Task<int> SaveAndQueueFiles(Guid guid, List<IFormFile> files, bool
             }
         }
 
-        return replayQueue.QueueLength;
+        return 1;
     }
 
     public static ReplayMetadata GetMetaData(Sc2Replay replay)

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ private async Task<int> SaveAndQueueFiles(Guid guid, List<IFormFile> files, bool`
`43`	`43`	`logger.LogInformation("Saved uploaded replay to temp: {path}", tempPath);`
`44`	`44`
`45`	`45`	`// Prepare job`
`46`		`- var job = new ReplayJob(Guid.NewGuid(), tempPath, "", inHouse);`
	`46`	`+ var job = new ReplayJob(guid, tempPath, "", inHouse);`
`47`	`47`
`48`	`48`	`// Try enqueue`
`49`	`49`	`if (!replayQueue.TryEnqueue(job))`
`@@ -53,7 +53,7 @@ private async Task<int> SaveAndQueueFiles(Guid guid, List<IFormFile> files, bool`
`53`	`53`	`}`
`54`	`54`	`}`
`55`	`55`
`56`		`- return replayQueue.QueueLength;`
	`56`	`+ return 1;`
`57`	`57`	`}`
`58`	`58`
`59`	`59`	`public static ReplayMetadata GetMetaData(Sc2Replay replay)`