Cleanup, added more helpers for test NodeClient.

Author: Chriztiaan

PowerSync/PowerSync.Common/Client/PowerSyncDatabase.cs

@@ -80,8 +80,6 @@ public interface IPowerSyncDatabase : IEventStream<PowerSyncDBEvent>
 
 public class PowerSyncDatabase : EventStream<PowerSyncDBEvent>, IPowerSyncDatabase
 {
-    private static readonly int FULL_SYNC_PRIORITY = 2147483647;
-
     public IDBAdapter Database;
     private Schema schema;
 

Tests/PowerSync/PowerSync.Common.IntegrationTests/NodeClient.cs

@@ -32,6 +32,7 @@ public Task<string> CreateList(string id, string name)
     {
         return CreateItem("lists", id, name);
     }
+
     async Task<string> CreateItem(string table, string id, string name)
     {
         var data = new Dictionary<string, object>
@@ -74,6 +75,55 @@ public Task<string> DeleteList(string id)
         return DeleteItem("lists", id);
     }
 
+    public Task<string> CreateTodo(string id, string listId, string description)
+    {
+        return CreateTodoItem("todos", id, listId, description);
+    }
+
+    async Task<string> CreateTodoItem(string table, string id, string listId, string description)
+    {
+        var data = new Dictionary<string, object>
+        {
+            { "created_at", DateTime.UtcNow.ToString("yyyy-MM-dd HH:mm:ss") },
+            { "description", description },
+            { "list_id", listId },
+            { "created_by", _userId },
+            { "completed", 0 },
+        };
+
+        var batch = new[]
+        {
+            new
+            {
+                op = UpdateType.PUT.ToString(),
+                table = table,
+                id = id,
+                data = data
+            }
+        };
+
+        var payload = JsonSerializer.Serialize(new { batch });
+        var content = new StringContent(payload, Encoding.UTF8, "application/json");
+
+        HttpResponseMessage response = await _httpClient.PostAsync($"{_backendUrl}/api/data", content);
+
+        if (!response.IsSuccessStatusCode)
+        {
+            Console.WriteLine(await response.Content.ReadAsStringAsync());
+            throw new Exception(
+                $"Failed to create todo. Status: {response.StatusCode}, " +
+                $"Response: {await response.Content.ReadAsStringAsync()}"
+            );
+        }
+
+        return await response.Content.ReadAsStringAsync();
+    }
+
+    public Task<string> DeleteTodo(string id)
+    {
+        return DeleteItem("todos", id);
+    }
+
     async Task<string> DeleteItem(string table, string id)
     {
         var batch = new[]

Tests/PowerSync/PowerSync.Common.IntegrationTests/SyncIntegrationTests.cs

@@ -1,8 +1,4 @@
-using Newtonsoft.Json;
 using PowerSync.Common.Client;
-using System.Data.Common;
-using System.Diagnostics;
-using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using PowerSync.Common.Client.Sync.Stream;
 
@@ -14,6 +10,8 @@ public class SyncIntegrationTests : IAsyncLifetime
 {
     private record ListResult(string id, string name, string owner_id, string created_at);
 
+    private record TodoResult(string id, string list_id, string content, string owner_id, string created_at);
+
     private string userId = Uuid();
 
     private NodeClient nodeClient = default!;
@@ -253,7 +251,7 @@ await db.Execute("insert into lists (id, name, owner_id, created_at) values (uui
     //             try
     //             {
     //                 Console.WriteLine("Total: " + update.StatusChanged.DownloadProgress()?.TotalOperations + " Downloaded: " + update.StatusChanged.DownloadProgress()?.DownloadedOperations);
-    //                 Console.WriteLine("Synced: " + Math.Round((decimal)(update.StatusChanged.DownloadProgress()?.DownloadedFraction * 100)) + "%");
+    //                 Console.WriteLine("Synced: " + Math.Round((decimal)((update.StatusChanged.DownloadProgress()?.DownloadedFraction ?? 0) * 100)) + "%");
 
     //             }
     //             catch (Exception ex)
@@ -267,6 +265,7 @@ await db.Execute("insert into lists (id, name, owner_id, created_at) values (uui
     //     await db.Connect(connector);
     //     await db.WaitForFirstSync();
 
+
     //     clearListener.Dispose();
     //     await db.DisconnectAndClear();
     //     await db.Close();