Replace CreateFlagCommand with lock

ServiceStack · Aug 20, 2024 · 2f21b84 · 2f21b84
1 parent ce51ebc
commit 2f21b84
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 23 deletions.
diff --git a/MyApp.ServiceInterface/AiServerServices.cs b/MyApp.ServiceInterface/AiServerServices.cs
@@ -17,7 +17,6 @@ public class AiServerServices(ILogger<AiServerServices> log,
     QuestionsProvider questions, 
     RendererCache rendererCache, 
     WorkerAnswerNotifier answerNotifier,
-    ICommandExecutor executor,
     IBackgroundJobs jobs) : Service
 {
     public async Task<object> Any(CreateAnswersForModels request)

diff --git a/MyApp.ServiceInterface/App/CreateFlagCommand.cs b/MyApp.ServiceInterface/App/CreateFlagCommand.cs
diff --git a/MyApp.ServiceInterface/UserServices.cs b/MyApp.ServiceInterface/UserServices.cs
@@ -324,15 +324,19 @@ public async Task<object> Any(FlagContent request)
             return HttpError.NotFound("Does not exist");
 
         var userName = Request.GetClaimsPrincipal().GetUserName();
-        jobs.RunCommand<CreateFlagCommand>(new Flag {
-            PostId = postId,
-            RefId = request.RefId,
-            UserName = userName,
-            Type = request.Type,
-            Reason = request.Reason,
-            RemoteIp = Request?.RemoteIp,
-            CreatedDate = DateTime.UtcNow,
-        });
+        lock (Locks.AppDb)
+        {
+            Db.Insert(new Flag
+            {
+                PostId = postId,
+                RefId = request.RefId,
+                UserName = userName,
+                Type = request.Type,
+                Reason = request.Reason,
+                RemoteIp = Request?.RemoteIp,
+                CreatedDate = DateTime.UtcNow,
+            });
+        }
         return new FlagContent();
     }
 }