Switching over and testing rust sync stream. Wip.

Author: Chriztiaan

PowerSync/PowerSync.Common/Client/PowerSyncDatabase.cs

@@ -85,8 +85,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;
 
@@ -246,7 +244,7 @@ protected async Task UpdateHasSynced()
         {
             var parsedDate = DateTime.Parse(result.last_synced_at + "Z");
 
-            if (result.priority == FULL_SYNC_PRIORITY)
+            if (result.priority == SyncProgress.FULL_SYNC_PRIORITY)
             {
                 // This lowest-possible priority represents a complete sync.
                 lastCompleteSync = parsedDate;

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

@@ -435,13 +435,14 @@ public async Task SetTargetCheckpoint(Checkpoint checkpoint)
         await Task.CompletedTask;
     }
 
-    record ControlResult(string? value);
+    record ControlResult(string? r);
     public async Task<string> Control(string op, object? payload)
     {
         return await db.WriteTransaction(async tx =>
         {
-              var result = await tx.Get<ControlResult>("SELECT powersync_control(?, ?)", [op, payload]);
-              return "5";
+              var result = await tx.Get<ControlResult>("SELECT powersync_control(?, ?) AS r", [op, payload]);
+              Console.WriteLine(result.r);
+              return result.r;
         }); 
     }
 }

PowerSync/PowerSync.Common/Client/Sync/Stream/CoreInstructions.cs

@@ -94,7 +94,7 @@ public class InstructionConverter : JsonConverter<Instruction>
     public override Instruction ReadJson(JsonReader reader, Type objectType, Instruction? existingValue, bool hasExistingValue, JsonSerializer serializer)
     {
         var jsonObject = JObject.Load(reader);
-
+        Console.WriteLine("Meep" + jsonObject.ToString());
         if (jsonObject.ContainsKey("LogLine"))
             return jsonObject["LogLine"]!.ToObject<LogLine>(serializer)!;
         if (jsonObject.ContainsKey("UpdateSyncStatus"))
@@ -109,7 +109,7 @@ public override Instruction ReadJson(JsonReader reader, Type objectType, Instruc
             return new FlushFileSystem();
         if (jsonObject.ContainsKey("DidCompleteSync"))
             return new DidCompleteSync();
-
+        Console.WriteLine("Throwing on" + jsonObject.ToString());
         throw new JsonSerializationException("Unknown Instruction type.");
     }