Cleanup tests

Author: LucDeCaf

Tests/PowerSync/PowerSync.Common.Tests/Client/PowerSyncDatabaseTests.cs

@@ -167,7 +167,7 @@ await db.WriteTransaction(async tx =>
             await tx.Rollback();
         });
 
-        var result = await db.GetAll<IdResult>("SELECT id FROM assets");
+        var result = await db.GetAll("SELECT * FROM assets");
         Assert.Empty(result);
     }
 
@@ -189,7 +189,7 @@ await db.WriteTransaction(async tx =>
             exceptionThrown = true;
         }
 
-        var result = await db.GetAll<IdResult>("SELECT id FROM assets");
+        var result = await db.GetAll("SELECT * FROM assets");
         Assert.Empty(result);
         Assert.True(exceptionThrown);
     }
@@ -214,10 +214,10 @@ await db.WriteTransaction(async tx =>
         {
             await tx.Execute("INSERT INTO assets(id) VALUES(?)", ["O6"]);
 
-            var txQuery = await tx.GetAll<IdResult>("SELECT id FROM assets");
+            var txQuery = await tx.GetAll("SELECT * FROM assets");
             Assert.Single(txQuery);
 
-            var dbQuery = await db.GetAll<IdResult>("SELECT id FROM assets");
+            var dbQuery = await db.GetAll("SELECT * FROM assets");
             Assert.Empty(dbQuery);
         });
     }
@@ -483,15 +483,15 @@ await db.WriteTransaction(async tx =>
         });
 
         // Try and read while the write transaction is still open
-        var result = await db.GetAll<IdResult>("SELECT id FROM assets");
+        var result = await db.GetAll("SELECT * FROM assets");
         Assert.Single(result); // The transaction is not commited yet, we should only read 1 asset
 
         // Let the transaction complete
         tcs.SetResult(true);
         await transactionTask;
 
         // Read again after the transaction is committed
-        var afterTx = await db.GetAll<IdResult>("SELECT id FROM assets");
+        var afterTx = await db.GetAll("SELECT * FROM assets");
         Assert.Equal(2, afterTx.Length);
     }
 

Tests/PowerSync/PowerSync.Common.Tests/Client/Sync/CRUDTests.cs

@@ -160,7 +160,7 @@ public async Task IgnoreEmptyUpdateTest()
     [Fact]
     public async Task Insert_RecordCrudEntryTest()
     {
-        var initialRows = await db.GetAll<object>("SELECT * FROM ps_crud");
+        var initialRows = await db.GetAll("SELECT * FROM ps_crud");
         Assert.Empty(initialRows);
 
         await db.Execute("INSERT INTO assets(id, description) VALUES(?, ?)", [testId, "test"]);
@@ -200,7 +200,7 @@ public async Task InsertOrReplaceTest()
         // Replace existing entry
         await db.Execute("INSERT OR REPLACE INTO assets(id, description) VALUES(?, ?)", [testId, "test2"]);
 
-        var crudEntry = await db.Get<CrudEntryDataResult>("SELECT data FROM ps_crud ORDER BY id");
+        var crudEntry = await db.Get<CrudEntryJSON>("SELECT data FROM ps_crud ORDER BY id");
 
         Assert.Equal(
             JsonConvert.SerializeObject(new
@@ -210,7 +210,7 @@ public async Task InsertOrReplaceTest()
                 type = "assets",
                 data = new { description = "test2" }
             }),
-            crudEntry.data
+            crudEntry.Data
         );
 
         var assetCount = await db.Get<CountResult>("SELECT count(*) as count FROM assets");
@@ -310,7 +310,7 @@ public async Task InsertOnlyTablesTest()
 
         await insertOnlyDb.Init();
 
-        var initialCrudRows = await insertOnlyDb.GetAll<object>("SELECT * FROM ps_crud");
+        var initialCrudRows = await insertOnlyDb.GetAll("SELECT * FROM ps_crud");
         Assert.Empty(initialCrudRows);
 
         await insertOnlyDb.Execute("INSERT INTO logs(id, level, content) VALUES(?, ?, ?)", [testId, "INFO", "test log"]);
@@ -328,7 +328,7 @@ public async Task InsertOnlyTablesTest()
             crudEntry.Data
         );
 
-        var logRows = await insertOnlyDb.GetAll<object>("SELECT * FROM logs");
+        var logRows = await insertOnlyDb.GetAll("SELECT * FROM logs");
         Assert.Empty(logRows);
 
         var tx = await insertOnlyDb.GetNextCrudTransaction();
@@ -424,7 +424,7 @@ await db.Execute("UPDATE assets SET description = ?, quantity = CAST(quantity AS
     [Fact]
     public async Task TransactionGroupingTest()
     {
-        var initialCrudRows = await db.GetAll<object>("SELECT * FROM ps_crud");
+        var initialCrudRows = await db.GetAll("SELECT * FROM ps_crud");
         Assert.Empty(initialCrudRows);
 
         await db.WriteTransaction(async (tx) =>