fix

src/SlimData/Endpoints.cs

@@ -5,6 +5,10 @@
 
 namespace SlimData;
 
+
+[MemoryPackable]
+public partial record QueueItemStatus(string Id, int HttpCode);
+
 public class Endpoints
 {
     public delegate Task RespondDelegate(IRaftCluster cluster, SlimPersistentState provider,
@@ -178,9 +182,6 @@ public static async Task ListLeftPushCommand(SlimPersistentState provider, strin
         await cluster.ReplicateAsync(logEntry, source.Token);
     }
 
-    [MemoryPackable]
-    public partial record QueueItemStatus(string Id, int HttpCode);
-
     public static Task ListSetQueueItemStatus(HttpContext context)
     {
         return DoAsync(context, async (cluster, provider, source) =>

src/SlimData/ListItems.cs

@@ -1,5 +1,4 @@
-using System.Text.Json.Serialization;
-using MemoryPack;
+using MemoryPack;
 
 namespace SlimData;
 

src/SlimFaas/Database/DatabaseMockService.cs

@@ -105,7 +105,7 @@ public Task<long> ListLengthAsync(string key)
         return Task.FromResult<long>(list.Count);
     }
 
-    public async Task ListSetQueueItemStatus(string key, List<Endpoints.QueueItemStatus> queueItemStatus)
+    public async Task ListSetQueueItemStatus(string key, List<QueueItemStatus> queueItemStatus)
     {
         await Task.Delay(100);
     }

src/SlimFaas/Database/IDatabaseService.cs

@@ -11,5 +11,5 @@ public interface IDatabaseService
     Task ListLeftPushAsync(string key, byte[] field);
     Task<IList<QueueData>> ListRightPopAsync(string key, int count = 1);
     Task<long> ListLengthAsync(string key);
-    Task ListSetQueueItemStatus(string key, List<Endpoints.QueueItemStatus> queueItemStatus);
+    Task ListSetQueueItemStatus(string key, List<QueueItemStatus> queueItemStatus);
 }

src/SlimFaas/Database/ISlimFaasQueue.cs

@@ -6,6 +6,6 @@ public interface ISlimFaasQueue
 {
     Task EnqueueAsync(string key, byte[] message);
     Task<IList<QueueData>> DequeueAsync(string key, long count = 1);
-    Task ListSetQueueItemStatusAsync(string key, List<Endpoints.QueueItemStatus> queueItemStatus);
+    Task ListSetQueueItemStatusAsync(string key, List<QueueItemStatus> queueItemStatus);
     public Task<long> CountAsync(string key);
 }

src/SlimFaas/Database/SlimDataService.cs

@@ -166,12 +166,12 @@ private async Task<IList<QueueData>> DoListRightPopAsync(string key, int count =
         }
     }
 
-    public async Task ListSetQueueItemStatus(string key, List<Endpoints.QueueItemStatus> queueItemStatus)
+    public async Task ListSetQueueItemStatus(string key, List<QueueItemStatus> queueItemStatus)
     {
         await Retry.Do(() => DoListSetQueueItemStatus(key, queueItemStatus), _retryInterval, logger, MaxAttemptCount);
     }
 
-    private async Task DoListSetQueueItemStatus(string key, List<Endpoints.QueueItemStatus> queueItemStatus)
+    private async Task DoListSetQueueItemStatus(string key, List<QueueItemStatus> queueItemStatus)
     {
 
         EndPoint endpoint = await GetAndWaitForLeader();

src/SlimFaas/Database/SlimFaasQueue.cs

@@ -17,7 +17,7 @@ public async Task<IList<QueueData>> DequeueAsync(string key, long count = 1)
         return data;
     }
 
-    public async Task ListSetQueueItemStatusAsync(string key, List<Endpoints.QueueItemStatus> queueItemStatus) => await databaseService.ListSetQueueItemStatus($"{KeyPrefix}{key}", queueItemStatus);
+    public async Task ListSetQueueItemStatusAsync(string key, List<QueueItemStatus> queueItemStatus) => await databaseService.ListSetQueueItemStatus($"{KeyPrefix}{key}", queueItemStatus);
 
     public async Task<long> CountAsync(string key) => await databaseService.ListLengthAsync($"{KeyPrefix}{key}");
 }

src/SlimFaas/SlimWorker.cs

@@ -139,7 +139,7 @@ private async Task<int> ManageProcessingTasksAsync(ISlimFaasQueue slimFaasQueue,
         {
             processingTasks.Add(functionDeployment, new List<RequestToWait>());
         }
-        var queueItemStatusList = new List<Endpoints.QueueItemStatus>();
+        var queueItemStatusList = new List<QueueItemStatus>();
         List<RequestToWait> httpResponseMessagesToDelete = new();
         foreach (RequestToWait processing in processingTasks[functionDeployment])
         {
@@ -160,11 +160,11 @@ private async Task<int> ManageProcessingTasksAsync(ISlimFaasQueue slimFaasQueue,
                     processing.CustomRequest.Method, processing.CustomRequest.Path, processing.CustomRequest.Query,
                     httpResponseMessage.StatusCode);
                 httpResponseMessagesToDelete.Add(processing);
-                queueItemStatusList.Add(new Endpoints.QueueItemStatus(processing.id, statusCode));
+                queueItemStatusList.Add(new QueueItemStatus(processing.id, statusCode));
             }
             catch (Exception e)
             {
-                queueItemStatusList.Add(new Endpoints.QueueItemStatus(processing.id, 500));
+                queueItemStatusList.Add(new QueueItemStatus(processing.id, 500));
                 httpResponseMessagesToDelete.Add(processing);
                 logger.LogWarning("Request Error: {Message} {StackTrace}", e.Message, e.StackTrace);
                 historyHttpService.SetTickLastCall(functionDeployment, DateTime.UtcNow.Ticks);

tests/SlimFaas.Tests/SlimProxyMiddlewareTests.cs

@@ -77,7 +77,7 @@ internal class MemorySlimFaasQueue : ISlimFaasQueue
 
     public Task<long> CountAsync(string key) => throw new NotImplementedException();
 
-    public Task ListSetQueueItemStatusAsync(string key, List<Endpoints.QueueItemStatus> queueItemStatus) => throw new NotImplementedException();
+    public Task ListSetQueueItemStatusAsync(string key, List<QueueItemStatus> queueItemStatus) => throw new NotImplementedException();
 
     public async Task EnqueueAsync(string key, byte[] message) => await Task.Delay(100);
 }