Adopt golden tests

Author: simolus3

crates/core/src/migrations.rs

@@ -12,7 +12,7 @@ use crate::error::{PSResult, SQLiteError};
 use crate::fix035::apply_v035_fix;
 use crate::sync::bucket_priority::BucketPriority;
 
-pub const LATEST_VERSION: i32 = 9;
+pub const LATEST_VERSION: i32 = 10;
 
 pub fn powersync_migrate(
     ctx: *mut sqlite::context,
@@ -370,5 +370,22 @@ json_object('sql', 'DELETE FROM ps_migration WHERE id >= 9')
         local_db.exec_safe(stmt).into_db_result(local_db)?;
     }
 
+    if current_version < 10 && target_version >= 10 {
+        let stmt = "\
+PRAGMA writable_schema = ON;
+UPDATE sqlite_schema SET sql = replace(sql, 'data TEXT', 'data ANY') WHERE name = 'ps_oplog';
+PRAGMA writable_schema = RESET;
+
+INSERT INTO ps_migration(id, down_migrations) VALUES(10, json_array(
+json_object('sql', 'PRAGMA writable_schema = ON'),
+json_object('sql', 'UPDATE sqlite_schema SET sql = replace(sql, ''data ANY'', ''data TEXT'') WHERE name = ''ps_oplog'''),
+json_object('sql', 'PRAGMA writable_schema = RESET'),
+json_object('sql', 'DELETE FROM ps_migration WHERE id >= 10')
+));
+";
+
+        local_db.exec_safe(stmt).into_db_result(local_db)?;
+    }
+
     Ok(())
 }

crates/core/src/sync/line.rs

@@ -100,7 +100,6 @@ pub struct OplogEntry<'a> {
     pub object_type: Option<&'a str>,
     #[serde(default, borrow)]
     pub subkey: Option<&'a str>,
-    // TODO: BSON?
     #[serde(default, borrow)]
     pub data: Option<OplogData<'a>>,
 }

dart/pubspec.lock

@@ -210,7 +210,7 @@ packages:
     source: hosted
     version: "0.12.17"
   meta:
-    dependency: transitive
+    dependency: "direct dev"
     description:
       name: meta
       sha256: e3641ec5d63ebf0d9b41bd43201a66e3fc79a65db5f61fc181f04cd27aab950c

dart/pubspec.yaml

@@ -13,3 +13,4 @@ dev_dependencies:
   sqlite3_test: ^0.1.1
   fake_async: ^1.3.3
   convert: ^3.1.2
+  meta: ^1.16.0

dart/test/goldens/simple_iteration.json

@@ -0,0 +1,143 @@
+[
+  {
+    "operation": "start",
+    "data": null,
+    "output": [
+      {
+        "UpdateSyncStatus": {
+          "status": {
+            "connected": false,
+            "connecting": true,
+            "priority_status": [],
+            "downloading": null
+          }
+        }
+      },
+      {
+        "EstablishSyncStream": {
+          "request": {
+            "buckets": [],
+            "include_checksum": true,
+            "raw_data": true,
+            "client_id": "test-test-test-test",
+            "parameters": null
+          }
+        }
+      }
+    ]
+  },
+  {
+    "operation": "line_text",
+    "data": {
+      "checkpoint": {
+        "last_op_id": "1",
+        "write_checkpoint": null,
+        "buckets": [
+          {
+            "bucket": "a",
+            "checksum": 0,
+            "priority": 3,
+            "count": 1
+          }
+        ]
+      }
+    },
+    "output": [
+      {
+        "UpdateSyncStatus": {
+          "status": {
+            "connected": true,
+            "connecting": false,
+            "priority_status": [],
+            "downloading": {
+              "buckets": {
+                "a": {
+                  "priority": 3,
+                  "at_last": 0,
+                  "since_last": 0,
+                  "target_count": 1
+                }
+              }
+            }
+          }
+        }
+      }
+    ]
+  },
+  {
+    "operation": "line_text",
+    "data": {
+      "data": {
+        "bucket": "a",
+        "has_more": false,
+        "after": null,
+        "next_after": null,
+        "data": [
+          {
+            "op_id": "1",
+            "op": "PUT",
+            "object_type": "items",
+            "object_id": "1",
+            "checksum": 0,
+            "data": {
+              "col": "hi"
+            }
+          }
+        ]
+      }
+    },
+    "output": [
+      {
+        "UpdateSyncStatus": {
+          "status": {
+            "connected": true,
+            "connecting": false,
+            "priority_status": [],
+            "downloading": {
+              "buckets": {
+                "a": {
+                  "priority": 3,
+                  "at_last": 0,
+                  "since_last": 1,
+                  "target_count": 1
+                }
+              }
+            }
+          }
+        }
+      }
+    ]
+  },
+  {
+    "operation": "line_text",
+    "data": {
+      "checkpoint_complete": {
+        "last_op_id": "1"
+      }
+    },
+    "output": [
+      {
+        "LogLine": {
+          "severity": "DEBUG",
+          "line": "Validated checkpoint"
+        }
+      },
+      {
+        "UpdateSyncStatus": {
+          "status": {
+            "connected": true,
+            "connecting": false,
+            "priority_status": [
+              {
+                "priority": 3,
+                "last_synced_at": 1740819600,
+                "has_synced": true
+              }
+            ],
+            "downloading": null
+          }
+        }
+      }
+    ]
+  }
+]

dart/test/goldens/starting_stream.json

@@ -0,0 +1,29 @@
+[
+  {
+    "operation": "start",
+    "data": null,
+    "output": [
+      {
+        "UpdateSyncStatus": {
+          "status": {
+            "connected": false,
+            "connecting": true,
+            "priority_status": [],
+            "downloading": null
+          }
+        }
+      },
+      {
+        "EstablishSyncStream": {
+          "request": {
+            "buckets": [],
+            "include_checksum": true,
+            "raw_data": true,
+            "client_id": "test-test-test-test",
+            "parameters": null
+          }
+        }
+      }
+    ]
+  }
+]