Update identifier and improved upsert detection

donderjoekel · Sep 11, 2024 · 994d67e · 994d67e
1 parent 771dac8
commit 994d67e
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 5 deletions.
diff --git a/Media/Jobs/UploadMediaJob.cs b/Media/Jobs/UploadMediaJob.cs
@@ -39,11 +39,15 @@ public async Task ExecuteAsync(int recordId, string identifier, string ghostData
         }
     }
 
-    public static void Schedule(IJobScheduler jobScheduler, int recordId, string ghostData, string screenshotData)
+    public static void Schedule(IJobScheduler jobScheduler,
+        int userId,
+        int recordId,
+        string ghostData,
+        string screenshotData)
     {
         jobScheduler.Enqueue<UploadMediaJob>(
             recordId,
-            recordId.ToString() + "-" + Guid.NewGuid(),
+            $"{userId}-{recordId}-{Guid.NewGuid()}",
             ghostData,
             screenshotData);
     }

diff --git a/Media/MediaService.cs b/Media/MediaService.cs
@@ -79,7 +79,7 @@ public async Task<Result<string>> UploadGhost(int recordId, string b64, string i
         }
 
         RecordMedia recordMedia = _repository.Upsert(
-            recordId,
+            media => media.IdRecord == recordId,
             () => new RecordMedia
             {
                 IdRecord = recordId,
@@ -108,7 +108,7 @@ public async Task<Result<string>> UploadScreenshot(int recordId, string b64, str
         }
 
         RecordMedia recordMedia = _repository.Upsert(
-            recordId,
+            media => media.IdRecord == recordId,
             () => new RecordMedia
             {
                 IdRecord = recordId,

diff --git a/Records/RecordsService.cs b/Records/RecordsService.cs
@@ -82,7 +82,7 @@ public Result Submit(ulong steamId, RecordResource resource)
                 DateCreated = now,
             });
 
-        UploadMediaJob.Schedule(_jobScheduler, record.Id, resource.GhostData, resource.ScreenshotData);
+        UploadMediaJob.Schedule(_jobScheduler, user.Id, record.Id, resource.GhostData, resource.ScreenshotData);
         ProcessPersonalBestJob.Schedule(_jobScheduler, record.Id, record.IdUser, record.IdLevel);
         ProcessWorldRecordJob.Schedule(_jobScheduler, record.Id, record.IdLevel);
         return Result.Ok();