11import fs from 'node:fs' ;
22import { Worker } from 'node:worker_threads' ;
33
4- import { PowerSyncDatabase , SyncStreamConnectionMethod } from '@powersync/node' ;
4+ import {
5+ createBaseLogger ,
6+ createLogger ,
7+ LogLevel ,
8+ PowerSyncDatabase ,
9+ SyncStreamConnectionMethod
10+ } from '@powersync/node' ;
511import { app , BrowserWindow , ipcMain , MessagePortMain } from 'electron' ;
612import { AppSchema , BackendConnector } from './powersync' ;
7- import { default as Logger } from 'js-logger' ;
813
9- const logger = Logger . get ( 'PowerSyncDemo' ) ;
10- Logger . useDefaults ( { defaultLevel : logger . WARN } ) ;
14+ const baseLogger = createBaseLogger ( ) ;
15+ baseLogger . useDefaults ( { defaultLevel : LogLevel . WARN } ) ;
16+
17+ const logger = createLogger ( 'PowerSyncDemo' ) ;
1118
1219// This allows TypeScript to pick up the magic constants that's auto-generated by Forge's Webpack
1320// plugin that tells the Electron app where to look for the Webpack-bundled app code (depending on
@@ -71,7 +78,7 @@ app.whenReady().then(() => {
7178 const unregister = database . registerListener ( {
7279 statusChanged ( status ) {
7380 port . postMessage ( status . toJSON ( ) ) ;
74- } ,
81+ }
7582 } ) ;
7683 port . once ( 'close' , unregister ) ;
7784 } ;
@@ -80,31 +87,36 @@ app.whenReady().then(() => {
8087 const abort = new AbortController ( ) ;
8188 port . once ( 'close' , ( ) => abort . abort ( ) ) ;
8289
83- database . watchWithCallback ( sql , args , {
84- onResult ( results ) {
85- port . postMessage ( results . rows . _array ) ;
86- } ,
87- onError ( error ) {
88- console . error ( `Watch ${ sql } with ${ args } failed` , error ) ;
90+ database . watchWithCallback (
91+ sql ,
92+ args ,
93+ {
94+ onResult ( results ) {
95+ port . postMessage ( results . rows . _array ) ;
96+ } ,
97+ onError ( error ) {
98+ console . error ( `Watch ${ sql } with ${ args } failed` , error ) ;
99+ }
89100 } ,
90- } , { signal : abort . signal } ) ;
101+ { signal : abort . signal }
102+ ) ;
91103 } ;
92104
93105 ipcMain . on ( 'port' , ( portEvent ) => {
94106 const [ port ] = portEvent . ports ;
95107 port . start ( ) ;
96108
97109 port . on ( 'message' , ( event ) => {
98- const { method, payload} = event . data ;
110+ const { method, payload } = event . data ;
99111 switch ( method ) {
100112 case 'syncStatus' :
101113 forwardSyncStatus ( port ) ;
102114 break ;
103115 case 'watch' :
104- const { sql, args} = payload ;
116+ const { sql, args } = payload ;
105117 forwardWatchResults ( sql , args , port ) ;
106118 break ;
107- } ;
119+ }
108120 } ) ;
109121 } ) ;
110122
0 commit comments