()
| 15 | |
| 16 | describe(`Sync Streams`, () => { |
| 17 | async function createDatabase() { |
| 18 | const db = new PowerSyncDatabase({ |
| 19 | database: { |
| 20 | dbFilename: `test-sync-streams-${randomUUID()}.sqlite`, |
| 21 | dbLocation: tmpdir(), |
| 22 | implementation: { type: `node:sqlite` }, |
| 23 | }, |
| 24 | schema: APP_SCHEMA, |
| 25 | }) |
| 26 | onTestFinished(async () => { |
| 27 | await db.disconnectAndClear() |
| 28 | await new Promise((resolve) => setTimeout(resolve, 100)) |
| 29 | await db.close() |
| 30 | }) |
| 31 | await db.disconnectAndClear() |
| 32 | return db |
| 33 | } |
| 34 | |
| 35 | async function createTestProducts(db: PowerSyncDatabase) { |
| 36 | await db.execute(` |
no test coverage detected