Migrate tests

Author: simolus3

modules/module-postgres/test/src/wal_stream.test.ts

@@ -325,6 +325,42 @@ bucket_definitions:
     }
   });
 
+  test('old date format', async () => {
+    await using context = await WalStreamTestContext.open(factory);
+    await context.updateSyncRules(BASIC_SYNC_RULES);
+
+    const { pool } = context;
+    await pool.query(`DROP TABLE IF EXISTS test_data`);
+    await pool.query(`CREATE TABLE test_data(id text primary key, description timestamptz);`);
+
+    await context.initializeReplication();
+    await pool.query(`INSERT INTO test_data(id, description) VALUES ('t1', '2025-09-10 15:17:14+02')`);
+
+    let data = await context.getBucketData('global[]');
+    expect(data).toMatchObject([putOp('test_data', { id: 't1', description: '2025-09-10 13:17:14Z' })]);
+  });
+
+  test('new date format', async () => {
+    await using context = await WalStreamTestContext.open(factory);
+    await context.updateSyncRules(`
+streams:
+  stream:
+    query: SELECT id, * FROM "test_data"
+
+config:
+  edition: 2
+`);
+    const { pool } = context;
+    await pool.query(`DROP TABLE IF EXISTS test_data`);
+    await pool.query(`CREATE TABLE test_data(id text primary key, description timestamptz);`);
+
+    await context.initializeReplication();
+    await pool.query(`INSERT INTO test_data(id, description) VALUES ('t1', '2025-09-10 15:17:14+02')`);
+
+    const data = await context.getBucketData('1#stream|0[]');
+    expect(data).toMatchObject([putOp('test_data', { id: 't1', description: '2025-09-10T13:17:14.000000Z' })]);
+  });
+
   test('custom types', async () => {
     await using context = await WalStreamTestContext.open(factory);
 

packages/service-core-tests/src/tests/register-data-storage-data-tests.ts

@@ -1,11 +1,4 @@
-import {
-  BucketDataBatchOptions,
-  getUuidReplicaIdentityBson,
-  OplogEntry,
-  SaveOptions,
-  storage
-} from '@powersync/service-core';
-import { DateTimeValue } from '@powersync/service-sync-rules';
+import { BucketDataBatchOptions, getUuidReplicaIdentityBson, OplogEntry, storage } from '@powersync/service-core';
 import { describe, expect, test } from 'vitest';
 import * as test_utils from '../test-utils/test-utils-index.js';
 import { TEST_TABLE } from './util.js';
@@ -1137,72 +1130,6 @@ bucket_definitions:
     expect(checkpoint2).toBeGreaterThan(checkpoint1);
   });
 
-  test('data with custom types', async () => {
-    await using factory = await generateStorageFactory();
-    const testValue = {
-      sourceTable: TEST_TABLE,
-      tag: storage.SaveOperationTag.INSERT,
-      after: {
-        id: 't1',
-        description: new DateTimeValue('2025-08-28T11:30:00')
-      },
-      afterReplicaId: test_utils.rid('t1')
-    } satisfies SaveOptions;
-
-    {
-      // First, deploy old sync rules and row with date time value
-      const syncRules = await factory.updateSyncRules({
-        content: `
-  bucket_definitions:
-    global:
-      data:
-        - SELECT id, description FROM test
-  `
-      });
-      const bucketStorage = factory.getInstance(syncRules);
-      await bucketStorage.startBatch(test_utils.BATCH_OPTIONS, async (batch) => {
-        await batch.save(testValue);
-        await batch.commit('1/1');
-      });
-
-      const { checkpoint } = await bucketStorage.getCheckpoint();
-      const batch = await test_utils.fromAsync(
-        bucketStorage.getBucketDataBatch(checkpoint, new Map([['global[]', 0n]]))
-      );
-      expect(batch[0].chunkData.data).toMatchObject([
-        {
-          data: '{"id":"t1","description":"2025-08-28 11:30:00"}'
-        }
-      ]);
-    }
-
-    const syncRules = await factory.updateSyncRules({
-      content: `
-  bucket_definitions:
-    global:
-      data:
-        - SELECT id, description FROM test
-  
-  config:
-    edition: 2
-  `
-    });
-    const bucketStorage = factory.getInstance(syncRules);
-    await bucketStorage.startBatch(test_utils.BATCH_OPTIONS, async (batch) => {
-      await batch.save(testValue);
-      await batch.commit('1/2');
-    });
-    const { checkpoint } = await bucketStorage.getCheckpoint();
-    const batch = await test_utils.fromAsync(
-      bucketStorage.getBucketDataBatch(checkpoint, new Map([['2#global[]', 0n]]))
-    );
-    expect(batch[0].chunkData.data).toMatchObject([
-      {
-        data: '{"id":"t1","description":"2025-08-28T11:30:00"}'
-      }
-    ]);
-  });
-
   test('unchanged checksums', async () => {
     await using factory = await generateStorageFactory();
     const syncRules = await factory.updateSyncRules({