Fix package build

Author: simolus3

packages/adapter-sql-js/src/SQLJSAdapter.ts

@@ -4,15 +4,16 @@ import {
   BatchedUpdateNotification,
   ConnectionPool,
   ControlledExecutor,
-  createLogger,
+  createPowerSyncLogger,
   DBAdapter,
   DBAdapterDefaultMixin,
   DBAdapterListener,
   DBGetUtilsDefaultMixin,
   DBLockOptions,
-  ILogger,
   LockContext,
+  LogLevels,
   Mutex,
+  PowerSyncLogger,
   QueryResult,
   SqlExecutor,
   SQLOpenFactory,
@@ -30,12 +31,12 @@ export interface SQLJSPersister {
 
 export interface SQLJSOpenOptions extends SQLOpenOptions {
   persister?: SQLJSPersister;
-  logger?: ILogger;
+  logger?: PowerSyncLogger;
 }
 
 export interface ResolvedSQLJSOpenOptions extends SQLJSOpenOptions {
   persister?: SQLJSPersister;
-  logger: ILogger;
+  logger: PowerSyncLogger;
 }
 
 export class SQLJSOpenFactory implements SQLOpenFactory {
@@ -110,7 +111,7 @@ class SqlJsConnectionPool extends BaseObserver<DBAdapterListener> implements Con
   }
 
   protected resolveOptions(options: SQLJSOpenOptions): ResolvedSQLJSOpenOptions {
-    const logger = options.logger ?? createLogger('SQLJSDBAdapter');
+    const logger = options.logger ?? createPowerSyncLogger({ prefix: 'SQLJSDBAdapter' });
 
     return {
       ...options,
@@ -122,10 +123,10 @@ class SqlJsConnectionPool extends BaseObserver<DBAdapterListener> implements Con
     const SQL = await SQLJs({
       locateFile: (filename: any) => `../dist/${filename}`,
       print: (text) => {
-        this.options.logger.info(text);
+        this.options.logger.log(LogLevels.info, text);
       },
       printErr: (text) => {
-        this.options.logger.error('[stderr]', text);
+        this.options.logger.log(LogLevels.error, '[stderr]', text);
       }
     });
     const existing = await this.options.persister?.readFile();

packages/capacitor/src/PowerSyncDatabase.ts

@@ -2,6 +2,7 @@ import { Capacitor } from '@capacitor/core';
 import {
   DBAdapter,
   DEFAULT_STREAM_CONNECTION_OPTIONS,
+  LogLevels,
   MEMORY_TRIGGER_CLAIM_MANAGER,
   PowerSyncBackendConnector,
   PowerSyncConnectionOptions,
@@ -37,7 +38,8 @@ export class PowerSyncDatabase extends WebPowerSyncDatabase {
       ? SyncStreamConnectionMethod.HTTP
       : DEFAULT_STREAM_CONNECTION_OPTIONS.connectionMethod;
     if (options?.connectionMethod == SyncStreamConnectionMethod.WEB_SOCKET && isUsingCapacitorDriver) {
-      this.logger.warn(
+      this.logger.log(
+        LogLevels.warn,
         `Connecting via 'SyncStreamConnectionMethod.WEB_SOCKET' when using the 'CapacitorSQLiteAdapter' will result in poor sync performance. Use 'SyncStreamConnectionMethod.HTTP' (the default for native) instead.`
       );
     }
@@ -57,17 +59,20 @@ export class PowerSyncDatabase extends WebPowerSyncDatabase {
     const platform = Capacitor.getPlatform();
     if (platform == 'ios' || platform == 'android') {
       if (options.database.dbLocation) {
-        options.logger?.warn(`
+        options.logger?.log(
+          LogLevels.warn,
+          `
           dbLocation is ignored on iOS and Android platforms. 
           The database directory can be configured in the Capacitor project.
-          See https://github.com/capacitor-community/sqlite?tab=readme-ov-file#installation`);
+          See https://github.com/capacitor-community/sqlite?tab=readme-ov-file#installation`
+        );
       }
-      options.logger?.debug(`Using CapacitorSQLiteAdapter for platform: ${platform}`);
+      options.logger?.log(LogLevels.debug, `Using CapacitorSQLiteAdapter for platform: ${platform}`);
       return new CapacitorSQLiteAdapter({
         ...options.database
       });
     } else {
-      options.logger?.debug(`Using default web adapter for web platform`);
+      options.logger?.log(LogLevels.debug, `Using default web adapter for web platform`);
       return super.openDBAdapter(options);
     }
   }
@@ -102,9 +107,12 @@ export class PowerSyncDatabase extends WebPowerSyncDatabase {
     if (this.isNativeCapacitorPlatform) {
       // We don't want to support multi-tab on mobile platforms.
       // We technically can, but it's not a common use case and requires additional work/testing.
-      this.logger.debug(`Using Capacitor sync implementation`);
+      this.logger.log(LogLevels.debug, `Using Capacitor sync implementation`);
       if (this.options.flags?.enableMultiTabs) {
-        this.logger.warn(`enableMultiTabs is not supported on Capacitor mobile platforms. Ignoring the flag.`);
+        this.logger.log(
+          LogLevels.warn,
+          `enableMultiTabs is not supported on Capacitor mobile platforms. Ignoring the flag.`
+        );
       }
 
       const remote = new CapacitorRemote(connector, this.logger);
@@ -124,7 +132,7 @@ export class PowerSyncDatabase extends WebPowerSyncDatabase {
         subscriptions: options.subscriptions
       });
     } else {
-      this.logger.debug(`Using default web sync implementation for web platform`);
+      this.logger.log(LogLevels.debug, `Using default web sync implementation for web platform`);
       return super.generateSyncStreamImplementation(connector, options);
     }
   }

packages/react-native/src/db/adapters/react-native-quick-sqlite/RNQSDBOpenFactory.ts

@@ -2,6 +2,7 @@ import {
   AbstractPowerSyncDatabase,
   AbstractPowerSyncDatabaseOpenFactory,
   DBAdapter,
+  LogLevels,
   PowerSyncDatabaseOptions,
   PowerSyncOpenFactoryOptions,
   SQLOpenFactory
@@ -36,7 +37,10 @@ export class RNQSPowerSyncDatabaseOpenFactory extends AbstractPowerSyncDatabaseO
 
   generateInstance(options: PowerSyncDatabaseOptions): AbstractPowerSyncDatabase {
     if (this.instanceGenerated) {
-      this.options.logger?.warn('Generating multiple PowerSync instances can sometimes cause unexpected results.');
+      this.options.logger?.log(
+        LogLevels.warn,
+        'Generating multiple PowerSync instances can sometimes cause unexpected results.'
+      );
     }
     this.instanceGenerated = true;
     return new PowerSyncDatabase(options);

packages/react-native/src/sync/stream/ReactNativeRemote.ts

@@ -1,10 +1,10 @@
 import {
   AbstractRemote,
   AbstractRemoteOptions,
-  DEFAULT_REMOTE_LOGGER,
   FetchImplementation,
   FetchImplementationProvider,
-  ILogger,
+  LogLevels,
+  PowerSyncLogger,
   RemoteConnector,
   SyncStreamOptions
 } from '@powersync/common';
@@ -29,7 +29,7 @@ class ReactNativeFetchProvider extends FetchImplementationProvider {
 export class ReactNativeRemote extends AbstractRemote {
   constructor(
     protected connector: RemoteConnector,
-    protected logger: ILogger = DEFAULT_REMOTE_LOGGER,
+    protected logger: PowerSyncLogger,
     options?: Partial<AbstractRemoteOptions>
   ) {
     super(connector, logger, {
@@ -60,7 +60,8 @@ export class ReactNativeRemote extends AbstractRemote {
     const timeout =
       Platform.OS == 'android'
         ? setTimeout(() => {
-            this.logger.warn(
+            this.logger.log(
+              LogLevels.warn,
               `HTTP Streaming POST is taking longer than ${Math.ceil(
                 STREAMING_POST_TIMEOUT_MS / 1000
               )} seconds to resolve. If using a debug build, please ensure Flipper Network plugin is disabled.`

packages/vue/src/composables/useSingleQuery.ts

@@ -1,6 +1,7 @@
 import {
   type CompilableQuery,
   DifferentialWatchedQueryComparator,
+  LogLevels,
   ParsedQuery,
   parseQuery,
   SQLOnChangeOptions
@@ -85,7 +86,7 @@ export const useSingleQuery = <T = any>(
   let fetchData: () => Promise<void> | undefined;
 
   const powerSync = usePowerSync();
-  const logger = powerSync?.value?.logger ?? console;
+  const logger = powerSync?.value?.logger;
 
   const finishLoading = () => {
     isLoading.value = false;
@@ -130,7 +131,7 @@ export const useSingleQuery = <T = any>(
     try {
       parsedQuery = parseQuery(queryValue, toValue(sqlParameters).map(toValue));
     } catch (e) {
-      logger.error('Failed to parse query:', e);
+      logger?.log(LogLevels.error, 'Failed to parse query:', e);
       handleError(e);
       return;
     }
@@ -146,7 +147,7 @@ export const useSingleQuery = <T = any>(
         const result = await executor();
         handleResult(result);
       } catch (e) {
-        logger.error('Failed to fetch data:', e);
+        logger?.log(LogLevels.error, 'Failed to fetch data:', e);
         handleError(e);
       }
     };

packages/vue/src/composables/useWatchedQuery.ts

@@ -1,4 +1,4 @@
-import { type CompilableQuery, ParsedQuery, parseQuery, WatchCompatibleQuery } from '@powersync/common';
+import { type CompilableQuery, LogLevels, ParsedQuery, parseQuery, WatchCompatibleQuery } from '@powersync/common';
 import { type MaybeRef, type Ref, ref, toValue, watchEffect } from 'vue';
 import { usePowerSync } from './powerSync.js';
 import { AdditionalOptions, WatchedQueryResult } from './useSingleQuery.js';
@@ -47,7 +47,7 @@ export const useWatchedQuery = <T = any>(
     try {
       parsedQuery = parseQuery(queryValue, toValue(sqlParameters).map(toValue));
     } catch (e) {
-      logger.error('Failed to parse query:', e);
+      logger.log(LogLevels.error, 'Failed to parse query:', e);
       handleError(e);
       return;
     }