Merge pull request #231 from powersync-ja/fix/sync-worker-logs

Use database logger for sync protocol

packages/powersync_core/lib/src/web/sync_controller.dart

@@ -29,6 +29,7 @@ class SyncWorkerHandle implements StreamingSync {
     _channel = WorkerCommunicationChannel(
       port: sendToWorker,
       errors: EventStreamProviders.errorEvent.forTarget(worker),
+      logger: database.logger,
       requestHandler: (type, payload) async {
         switch (type) {
           case SyncWorkerMessageType.requestEndpoint:
@@ -84,12 +85,13 @@ class SyncWorkerHandle implements StreamingSync {
       Map<String, dynamic>? syncParams}) async {
     final worker = SharedWorker(workerUri.toString().toJS);
     final handle = SyncWorkerHandle._(
-        database: database,
-        connector: connector,
-        crudThrottleTimeMs: crudThrottleTimeMs,
-        sendToWorker: worker.port,
-        worker: worker,
-        syncParams: syncParams);
+      database: database,
+      connector: connector,
+      crudThrottleTimeMs: crudThrottleTimeMs,
+      sendToWorker: worker.port,
+      worker: worker,
+      syncParams: syncParams,
+    );
 
     // Make sure that the worker is working, or throw immediately.
     await handle._channel.ping();

packages/powersync_core/lib/src/web/sync_worker_protocol.dart

@@ -2,6 +2,7 @@ import 'dart:async';
 import 'dart:convert';
 import 'dart:js_interop';
 
+import 'package:logging/logging.dart';
 import 'package:web/web.dart';
 
 import '../connector.dart';
@@ -197,8 +198,6 @@ extension type SerializedSyncStatus._(JSObject _) implements JSObject {
 }
 
 final class WorkerCommunicationChannel {
-  static final _logger = autoLogger;
-
   final Map<int, Completer<JSAny?>> _pendingRequests = {};
   int _nextRequestId = 0;
   bool _hasError = false;
@@ -210,14 +209,16 @@ final class WorkerCommunicationChannel {
       requestHandler;
   final StreamController<(SyncWorkerMessageType, JSAny)> _events =
       StreamController();
+  final Logger _logger;
 
   Stream<(SyncWorkerMessageType, JSAny)> get events => _events.stream;
 
   WorkerCommunicationChannel({
     required this.port,
     required this.requestHandler,
     Stream<Event>? errors,
-  }) {
+    Logger? logger,
+  }) : _logger = logger ?? autoLogger {
     port.start();
     _incomingErrors = errors?.listen((event) {
       _hasError = true;