RFC: allow users to pass a custom logger to init

client/packages/admin/src/index.ts

@@ -81,6 +81,7 @@ import {
   type ReadableStreamCtor,
   InstantWritableStream,
   InstantReadableStream,
+  type Logger,
 } from '@instantdb/core';
 
 import version from './version.ts';
@@ -135,6 +136,7 @@ type Config = {
   useDateObjects?: boolean;
   disableValidation?: boolean;
   verbose?: boolean;
+  logger?: Logger;
 };
 
 export type InstantConfig<
@@ -148,6 +150,7 @@ export type InstantConfig<
   useDateObjects: UseDates;
   disableValidation?: boolean;
   verbose?: boolean;
+  logger?: Logger;
   WritableStream?: WritableStreamCtor;
   ReadableStream?: ReadableStreamCtor;
 };
@@ -1101,17 +1104,14 @@ type AdminQueryOpts = {
   fetchOpts?: RequestInit;
 };
 
-interface Logger {
-  info: (...args: any[]) => void;
-  debug: (...args: any[]) => void;
-  error: (...args: any[]) => void;
-}
-
-function createLogger(isEnabled: boolean): Logger {
+function createLogger(
+  isEnabled: boolean,
+  baseLogger: Logger = console,
+): Logger {
   return {
-    info: isEnabled ? (...args: any[]) => console.info(...args) : () => {},
-    debug: isEnabled ? (...args: any[]) => console.debug(...args) : () => {},
-    error: isEnabled ? (...args: any[]) => console.error(...args) : () => {},
+    info: isEnabled ? (...args: any[]) => baseLogger.info(...args) : () => {},
+    debug: isEnabled ? (...args: any[]) => baseLogger.debug(...args) : () => {},
+    error: isEnabled ? (...args: any[]) => baseLogger.error(...args) : () => {},
   };
 }
 
@@ -1154,7 +1154,7 @@ class InstantAdminDatabase<
     this.streams = new Streams(this.#ensureInstantStream.bind(this));
     this.rooms = new Rooms<Schema>(this.config);
     this.webhooks = new Webhooks<Schema>(this.config, jsonFetch);
-    this.#log = createLogger(!!this.config.verbose);
+    this.#log = createLogger(!!this.config.verbose, this.config.logger);
   }
 
   /**
@@ -1719,4 +1719,7 @@ export {
 
   // error types
   type InstantIssue,
+
+  // logger
+  type Logger,
 };

client/packages/core/src/Reactor.js

@@ -303,6 +303,7 @@ export default class Reactor {
     this._log = createLogger(
       config.verbose || flags.devBackend || flags.instantLogs,
       () => this._reactorStats(),
+      config.logger,
     );
 
     this.versions = { ...(versions || {}), '@instantdb/core': version };

client/packages/core/src/index.ts

@@ -29,6 +29,7 @@ import {
 } from './utils/PersistedObject.ts';
 import { createInstantRouteHandler } from './createRouteHandler.ts';
 import { parseSchemaFromJSON } from './parseSchemaFromJSON.ts';
+import type { Logger } from './utils/log.ts';
 
 import type {
   PresenceOpts,
@@ -169,6 +170,7 @@ export type Config = {
   apiURI?: string;
   devtool?: boolean | DevtoolConfig;
   verbose?: boolean;
+  logger?: Logger;
   queryCacheLimit?: number;
   useDateObjects: boolean;
   disableValidation?: boolean;
@@ -185,6 +187,7 @@ export type InstantConfig<
   apiURI?: string;
   devtool?: boolean | DevtoolConfig;
   verbose?: boolean;
+  logger?: Logger;
   queryCacheLimit?: number;
   useDateObjects: UseDates;
   disableValidation?: boolean;
@@ -1225,6 +1228,7 @@ export {
   type StoreInterfaceClass,
   type StoreInterfaceStoreName,
   createInstantRouteHandler,
+  type Logger,
 };
 
 /** @deprecated Use StoreInterface instead */

client/packages/core/src/utils/log.ts

@@ -7,16 +7,17 @@ export interface Logger {
 export default function createLogger(
   isEnabled: boolean,
   getStats: () => Record<string, any>,
+  baseLogger: Logger = console,
 ): Logger {
   return {
     info: isEnabled
-      ? (...args: any[]) => console.info(...args, getStats())
+      ? (...args: any[]) => baseLogger.info(...args, getStats())
       : () => {},
     debug: isEnabled
-      ? (...args: any[]) => console.debug(...args, getStats())
+      ? (...args: any[]) => baseLogger.debug(...args, getStats())
       : () => {},
     error: isEnabled
-      ? (...args: any[]) => console.error(...args, getStats())
+      ? (...args: any[]) => baseLogger.error(...args, getStats())
       : () => {},
   };
 }

client/packages/react-native/src/index.ts

@@ -102,6 +102,7 @@ import {
   CreateWriteStreamOpts,
   InstantWritableStream,
   InstantReadableStream,
+  type Logger,
 } from '@instantdb/core';
 
 /**
@@ -283,4 +284,7 @@ export {
   type SyncTableSyncTransaction,
   type SyncTableLoadFromStorage,
   type SyncTableSetupError,
+
+  // logger
+  type Logger,
 };

client/packages/react/src/index.ts

@@ -95,6 +95,7 @@ import {
   type StoreInterfaceStoreName,
   InstantWritableStream,
   InstantReadableStream,
+  type Logger,
 } from '@instantdb/core';
 
 import { InstantReactAbstractDatabase } from '@instantdb/react-common';
@@ -212,4 +213,7 @@ export {
 
   // Server helper
   createInstantRouteHandler,
+
+  // logger
+  type Logger,
 };

client/packages/solidjs/src/index.ts

@@ -88,6 +88,7 @@ import {
   StoreInterface,
   createInstantRouteHandler,
   type StoreInterfaceStoreName,
+  type Logger,
 } from '@instantdb/core';
 
 import { InstantSolidDatabase } from './InstantSolidDatabase.js';
@@ -191,4 +192,7 @@ export {
 
   // Server helper
   createInstantRouteHandler,
+
+  // logger
+  type Logger,
 };

client/packages/svelte/src/lib/index.ts

@@ -88,6 +88,7 @@ import {
   StoreInterface,
   createInstantRouteHandler,
   type StoreInterfaceStoreName,
+  type Logger,
 } from '@instantdb/core';
 
 import { InstantSvelteDatabase } from './InstantSvelteDatabase.svelte.js';
@@ -197,4 +198,7 @@ export {
 
   // Server helper
   createInstantRouteHandler,
+
+  // logger
+  type Logger,
 };

client/packages/version/src/version.ts

@@ -2,6 +2,6 @@
 // Update the version here and merge your code to main to
 // publish a new version of all of the packages to npm.
 
-const version = 'v1.0.44';
+const version = 'v1.0.45';
 
 export { version };

client/packages/vue/src/index.ts

@@ -88,6 +88,7 @@ import {
   StoreInterface,
   createInstantRouteHandler,
   type StoreInterfaceStoreName,
+  type Logger,
 } from '@instantdb/core';
 
 import { InstantVueDatabase, init } from './InstantVueDatabase.js';
@@ -196,4 +197,7 @@ export {
 
   // Server helper
   createInstantRouteHandler,
+
+  // logger
+  type Logger,
 };