1- import { SqliteRow } from '@powersync/service-sync-rules' ;
1+ import { SqliteInputRow , SqliteRow } from '@powersync/service-sync-rules' ;
22import { afterAll , describe , expect , test } from 'vitest' ;
33import { clearTestDb , TEST_CONNECTION_OPTIONS } from './util.js' ;
44import { eventIsWriteMutation , eventIsXid } from '@module/replication/zongji/zongji-utils.js' ;
@@ -298,7 +298,7 @@ INSERT INTO test_data (
298298 } ) ;
299299} ) ;
300300
301- async function getDatabaseRows ( connection : MySQLConnectionManager , tableName : string ) : Promise < SqliteRow [ ] > {
301+ async function getDatabaseRows ( connection : MySQLConnectionManager , tableName : string ) : Promise < SqliteInputRow [ ] > {
302302 const [ results , fields ] = await connection . query ( `SELECT * FROM ${ tableName } ` ) ;
303303 const columns = toColumnDescriptors ( fields ) ;
304304 return results . map ( ( row ) => common . toSQLiteRow ( row , columns ) ) ;
@@ -307,15 +307,15 @@ async function getDatabaseRows(connection: MySQLConnectionManager, tableName: st
307307/**
308308 * Return all the inserts from the first transaction in the binlog stream.
309309 */
310- async function getReplicatedRows ( expectedTransactionsCount ?: number ) : Promise < SqliteRow [ ] > {
311- let transformed : SqliteRow [ ] = [ ] ;
310+ async function getReplicatedRows ( expectedTransactionsCount ?: number ) : Promise < SqliteInputRow [ ] > {
311+ let transformed : SqliteInputRow [ ] = [ ] ;
312312 const zongji = new ZongJi ( {
313313 host : TEST_CONNECTION_OPTIONS . hostname ,
314314 user : TEST_CONNECTION_OPTIONS . username ,
315315 password : TEST_CONNECTION_OPTIONS . password
316316 } ) ;
317317
318- const completionPromise = new Promise < SqliteRow [ ] > ( ( resolve , reject ) => {
318+ const completionPromise = new Promise < SqliteInputRow [ ] > ( ( resolve , reject ) => {
319319 zongji . on ( 'binlog' , ( evt : BinLogEvent ) => {
320320 try {
321321 if ( eventIsWriteMutation ( evt ) ) {
0 commit comments