test for table not in schema scenario

Author: simolus3

crates/core/src/schema/mod.rs

@@ -159,7 +159,7 @@ fn raw_table_migration(
                 // Generate an INSERT INTO ps_untyped with a SELECT source transforming existing
                 // rows into JSON objects.
                 let mut buffer = SqlBuffer::new();
-                let fragment = table_columns_to_json_object(&local_table_name, &as_schema_table)?;
+                let fragment = table_columns_to_json_object(local_table_name, &as_schema_table)?;
                 buffer.push_str("INSERT INTO ps_untyped (type, id, data) SELECT ?, id, ");
                 buffer.push_str(&fragment);
                 buffer.push_str(" FROM ");

dart/test/schema_test.dart

@@ -392,6 +392,20 @@ END''',
             {'id': 'bar', 'hello': 'again'},
           ]);
         });
+
+        test('errors when table is not in schema', () {
+          db.execute('SELECT powersync_replace_schema(?)', [
+            json.encode(singleRawTableSchema(
+                {'name': syncName, 'table_name': 'greetings'})),
+          ]);
+
+          db.execute('BEGIN');
+          expect(
+            () => db.execute('SELECT powersync_raw_table_migrate(?, ?)',
+                ['create', 'unknown_table']),
+            throwsA(isA<SqliteException>()),
+          );
+        });
       });
 
       test('drop', () {
@@ -421,6 +435,7 @@ END''',
           {'type': 'synced_table', 'id': 'id_0', 'data': '{"hello":"first"}'},
           {'type': 'synced_table', 'id': 'id_1', 'data': '{"hello":"second"}'},
         ]);
+        expect(db.select('select * from greetings'), isEmpty);
       });
 
       test('crud triggers are not invoked during migration', () {