Update/fix tests.

Author: rkistner

packages/powersync/test/bucket_storage_test.dart

@@ -675,7 +675,7 @@ void main() {
           ]));
     });
 
-    test('should revert a failing update', () async {
+    test('should revert a failing insert', () async {
       await bucketStorage.saveSyncData(SyncDataBatch([
         SyncBucketData(
           bucket: 'bucket1',
@@ -688,7 +688,7 @@ void main() {
           writeCheckpoint: '3',
           checksums: [BucketChecksum(bucket: 'bucket1', checksum: 6)]));
 
-      // Local save
+      // Local insert, later rejected by server
       db.execute('INSERT INTO assets(id, description) VALUES(?, ?)',
           ['O3', 'inserted']);
       final batch = bucketStorage.getCrudBatch();
@@ -725,7 +725,7 @@ void main() {
           writeCheckpoint: '3',
           checksums: [BucketChecksum(bucket: 'bucket1', checksum: 6)]));
 
-      // Local save
+      // Local delete, later rejected by server
       db.execute('DELETE FROM assets WHERE id = ?', ['O2']);
 
       expect(db.select('SELECT description FROM assets WHERE id = \'O2\''),
@@ -750,7 +750,7 @@ void main() {
           ]));
     });
 
-    test('should revert a failing insert', () async {
+    test('should revert a failing update', () async {
       await bucketStorage.saveSyncData(SyncDataBatch([
         SyncBucketData(
           bucket: 'bucket1',
@@ -763,11 +763,15 @@ void main() {
           writeCheckpoint: '3',
           checksums: [BucketChecksum(bucket: 'bucket1', checksum: 6)]));
 
-      // Local save
-      db.execute('DELETE FROM assets WHERE id = ?', ['O2']);
+      // Local update, later rejected by server
+      db.execute(
+          'UPDATE assets SET description = ? WHERE id = ?', ['updated', 'O2']);
 
-      expect(db.select('SELECT description FROM assets WHERE id = \'O2\''),
-          equals([]));
+      expect(
+          db.select('SELECT description FROM assets WHERE id = \'O2\''),
+          equals([
+            {'description': 'updated'}
+          ]));
       // Simulate a permissions error when uploading - data should be preserved.
       final batch = bucketStorage.getCrudBatch();
       await batch!.complete();

packages/powersync/test/offline_online_test.dart

@@ -1,3 +1,5 @@
+import 'dart:convert';
+
 import 'package:powersync/powersync.dart';
 import 'package:test/test.dart';
 
@@ -113,16 +115,27 @@ void main() {
         await tx.execute('DELETE FROM local_assets');
       });
 
+      final crud = (await db.getAll('SELECT data FROM ps_crud ORDER BY id'))
+          .map((d) => jsonDecode(d['data']))
+          .toList();
       expect(
-          await db.getAll('SELECT data FROM ps_crud ORDER BY id'),
+          crud,
           equals([
             {
-              'data':
-                  '{"op":"PUT","type":"customers","id":"$customerId","data":{"name":"test customer","email":"test@example.org"}}'
+              "op": "PUT",
+              "type": "customers",
+              "id": customerId,
+              "data": {"email": "test@example.org", "name": "test customer"}
             },
             {
-              'data':
-                  '{"op":"PUT","type":"assets","id":"$assetId","data":{"user_id":"$userId","customer_id":"$customerId","description":"test."}}'
+              "op": "PUT",
+              "type": "assets",
+              "id": assetId,
+              "data": {
+                "user_id": userId,
+                "customer_id": customerId,
+                "description": "test."
+              }
             }
           ]));
     });