finish implementing CreateWorkerAnswer

ServiceStack · Mar 25, 2024 · d281b2c · d281b2c
1 parent 4bc9705
commit d281b2c
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 1 deletion.
diff --git a/MyApp.ServiceInterface/BackgroundMqServices.cs b/MyApp.ServiceInterface/BackgroundMqServices.cs
@@ -73,7 +73,24 @@ public async Task Any(DbWrites request)
                 StartedDate = DateTime.UtcNow,
                 Worker = startJob.Worker,
                 WorkerIp = startJob.WorkerIp,
-            });
+            }, x => x.PostId == startJob.Id);
+        }
+
+        if (request.CompleteJobIds?.Count > 0)
+        {
+            await Db.UpdateOnlyAsync(() => new PostJob {
+                    Body = null,
+                    CompletedDate = DateTime.UtcNow,
+                }, 
+                x => request.CompleteJobIds.Contains(x.PostId));
+        }
+
+        if (request.AnswerAddedToPost != null)
+        {
+            await Db.UpdateAddAsync(() => new Post
+            {
+                AnswerCount = 1,
+            }, x => x.Id == request.AnswerAddedToPost.Value);
         }
     }
 

diff --git a/MyApp.ServiceInterface/QuestionServices.cs b/MyApp.ServiceInterface/QuestionServices.cs
@@ -60,6 +60,23 @@ public async Task<object> Any(AskQuestion request)
 
     public async Task Any(CreateWorkerAnswer request)
     {
+        var json = request.Json;
+        if (string.IsNullOrEmpty(json))
+        {
+            var file = base.Request!.Files.FirstOrDefault();
+            if (file != null)
+            {
+                using var reader = new StreamReader(file.InputStream);
+                json = await reader.ReadToEndAsync();
+            }
+        }
+
+        json = json?.Trim();
+        if (string.IsNullOrEmpty(json))
+            throw new ArgumentException("Json is required", nameof(request.Json));
+        if (!json.StartsWith('{'))
+            throw new ArgumentException("Invalid Json", nameof(request.Json));
+
         if (request.PostJobId != null)
         {
             MessageProducer.Publish(new DbWrites {