Support 0.4.0 for C_SHARP sync implementation.

Author: Chriztiaan

PowerSync.Common.IntegrationTests/PowerSync.Common.IntegrationTests.csproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net9.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <IsPackable>false</IsPackable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="coverlet.collector" Version="6.0.2" />
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.12.0" />
+    <PackageReference Include="xunit" Version="2.9.2" />
+    <PackageReference Include="xunit.runner.visualstudio" Version="2.8.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Using Include="Xunit" />
+  </ItemGroup>
+
+</Project>

PowerSync/PowerSync.Common/Client/Sync/Bucket/SqliteBucketStorage.cs

@@ -111,7 +111,7 @@ await db.WriteTransaction(async tx =>
             foreach (var b in batch.Buckets)
             {
                 var result = await tx.Execute("INSERT INTO powersync_operations(op, data) VALUES(?, ?)",
-                    ["save", JsonConvert.SerializeObject(new { buckets = new[] { b.ToJSON() } })]);
+                    ["save", JsonConvert.SerializeObject(new { buckets = new[] { JsonConvert.DeserializeObject(b.ToJSON()) } })]);
                 logger.LogDebug("saveSyncData {message}", JsonConvert.SerializeObject(result));
                 count += b.Data.Length;
             }

PowerSync/PowerSync.Common/Client/Sync/Bucket/SyncDataBucket.cs

@@ -9,14 +9,14 @@ public class SyncDataBucketJSON
     [JsonProperty("bucket")]
     public string Bucket { get; set; } = null!;
 
-    [JsonProperty("has_more")]
-    public bool? HasMore { get; set; }
+    // [JsonProperty("has_more")]
+    // public bool? HasMore { get; set; }
 
-    [JsonProperty("after")]
-    public string? After { get; set; }
+    // [JsonProperty("after")]
+    // public string? After { get; set; }
 
-    [JsonProperty("next_after")]
-    public string? NextAfter { get; set; }
+    // [JsonProperty("next_after")]
+    // public string? NextAfter { get; set; }
 
     [JsonProperty("data")]
     public List<object> Data { get; set; } = [];
@@ -25,15 +25,16 @@ public class SyncDataBucketJSON
 public class SyncDataBucket(
     string bucket,
     OplogEntry[] data,
-    bool hasMore,
-    string? after = null,
-    string? nextAfter = null)
+    bool hasMore = false
+    // string? after = null,
+    // string? nextAfter = null
+    )
 {
     public string Bucket { get; private set; } = bucket;
     public OplogEntry[] Data { get; private set; } = data;
-    public bool HasMore { get; private set; } = hasMore;
-    public string? After { get; private set; } = after;
-    public string? NextAfter { get; private set; } = nextAfter;
+
+    // public string? After { get; private set; } = after;
+    // public string? NextAfter { get; private set; } = nextAfter;
 
     public static SyncDataBucket FromRow(SyncDataBucketJSON row)
     {
@@ -46,10 +47,10 @@ public static SyncDataBucket FromRow(SyncDataBucketJSON row)
 
         return new SyncDataBucket(
             row.Bucket,
-            dataEntries,
-            row.HasMore ?? false,
-            row.After,
-            row.NextAfter
+            dataEntries
+        // row.HasMore ?? false,
+        // row.After,
+        // row.NextAfter
         );
     }
 
@@ -63,9 +64,9 @@ public string ToJSON()
         var jsonObject = new SyncDataBucketJSON
         {
             Bucket = Bucket,
-            HasMore = HasMore,
-            After = After,
-            NextAfter = NextAfter,
+            // HasMore = HasMore,
+            // After = After,
+            // NextAfter = NextAfter,
             Data = dataObjects
         };
 

Tools/Setup/Setup.cs

@@ -7,7 +7,7 @@
 
 public class PowerSyncSetup
 {
-    private const string VERSION = "0.3.14";
+    private const string VERSION = "0.4.0";
     private const string GITHUB_BASE_URL = $"https://github.com/powersync-ja/powersync-sqlite-core/releases/download/v{VERSION}";
     private const string MAVEN_BASE_URL = $"https://repo1.maven.org/maven2/co/powersync/powersync-sqlite-core/{VERSION}";