chore(worker_bee): Use AWSLogger for logging

commit-id:4d0b5dc5

Author: Dillon Nys

packages/auth/amplify_auth_cognito_dart/lib/src/flows/device/confirm_device_worker.worker.vm.dart

@@ -8,15 +8,15 @@ import 'package:worker_bee/worker_bee.dart';
 
 Future<void> _run(SendPorts ports) async {
   final channel = IsolateChannel<Object?>.connectSend(ports.messagePort);
-  final logsChannel = IsolateChannel<LogMessage>.connectSend(ports.logPort);
+  final logsChannel = IsolateChannel<LogEntry>.connectSend(ports.logPort);
   final worker = ConfirmDeviceWorkerImpl();
   await worker.connect(logsChannel: logsChannel);
   final result = await worker.run(
     channel.stream.asBroadcastStream().cast(),
     channel.sink.cast(),
   );
 // ignore: invalid_use_of_protected_member
-  worker.logger.finest('Finished');
+  worker.logger.verbose('Finished');
   unawaited(worker.close());
   Isolate.exit(ports.donePort, result);
 }

packages/auth/amplify_auth_cognito_dart/lib/src/flows/srp/srp_device_password_verifier_worker.worker.vm.dart

@@ -8,15 +8,15 @@ import 'package:worker_bee/worker_bee.dart';
 
 Future<void> _run(SendPorts ports) async {
   final channel = IsolateChannel<Object?>.connectSend(ports.messagePort);
-  final logsChannel = IsolateChannel<LogMessage>.connectSend(ports.logPort);
+  final logsChannel = IsolateChannel<LogEntry>.connectSend(ports.logPort);
   final worker = SrpDevicePasswordVerifierWorkerImpl();
   await worker.connect(logsChannel: logsChannel);
   final result = await worker.run(
     channel.stream.asBroadcastStream().cast(),
     channel.sink.cast(),
   );
 // ignore: invalid_use_of_protected_member
-  worker.logger.finest('Finished');
+  worker.logger.verbose('Finished');
   unawaited(worker.close());
   Isolate.exit(ports.donePort, result);
 }

packages/auth/amplify_auth_cognito_dart/lib/src/flows/srp/srp_init_worker.worker.vm.dart

@@ -8,15 +8,15 @@ import 'package:worker_bee/worker_bee.dart';
 
 Future<void> _run(SendPorts ports) async {
   final channel = IsolateChannel<Object?>.connectSend(ports.messagePort);
-  final logsChannel = IsolateChannel<LogMessage>.connectSend(ports.logPort);
+  final logsChannel = IsolateChannel<LogEntry>.connectSend(ports.logPort);
   final worker = SrpInitWorkerImpl();
   await worker.connect(logsChannel: logsChannel);
   final result = await worker.run(
     channel.stream.asBroadcastStream().cast(),
     channel.sink.cast(),
   );
 // ignore: invalid_use_of_protected_member
-  worker.logger.finest('Finished');
+  worker.logger.verbose('Finished');
   unawaited(worker.close());
   Isolate.exit(ports.donePort, result);
 }

packages/auth/amplify_auth_cognito_dart/lib/src/flows/srp/srp_password_verifier_worker.worker.vm.dart

@@ -8,15 +8,15 @@ import 'package:worker_bee/worker_bee.dart';
 
 Future<void> _run(SendPorts ports) async {
   final channel = IsolateChannel<Object?>.connectSend(ports.messagePort);
-  final logsChannel = IsolateChannel<LogMessage>.connectSend(ports.logPort);
+  final logsChannel = IsolateChannel<LogEntry>.connectSend(ports.logPort);
   final worker = SrpPasswordVerifierWorkerImpl();
   await worker.connect(logsChannel: logsChannel);
   final result = await worker.run(
     channel.stream.asBroadcastStream().cast(),
     channel.sink.cast(),
   );
 // ignore: invalid_use_of_protected_member
-  worker.logger.finest('Finished');
+  worker.logger.verbose('Finished');
   unawaited(worker.close());
   Isolate.exit(ports.donePort, result);
 }

packages/auth/amplify_auth_cognito_dart/lib/src/state/machines/sign_in_state_machine.dart

@@ -37,7 +37,6 @@ import 'package:amplify_core/amplify_core.dart'
 import 'package:async/async.dart';
 import 'package:built_collection/built_collection.dart';
 import 'package:meta/meta.dart';
-import 'package:worker_bee/worker_bee.dart';
 
 /// {@template amplify_auth_cognito.sign_in_state_machine}
 /// Base class for state machines which perform some auth flow. These all follow
@@ -97,6 +96,15 @@ class SignInStateMachine extends StateMachine<SignInEvent, SignInState> {
   final AsyncMemoizer<ConfirmDeviceWorker> _confirmDeviceWorkerMemoizer =
       AsyncMemoizer();
 
+  void _logWorkerBeeMessage(AWSLogger logger, LogEntry logEntry) {
+    logger.log(
+      logEntry.level,
+      logEntry.message,
+      logEntry.error,
+      logEntry.stackTrace,
+    );
+  }
+
   /// The SRP init worker.
   Future<SrpInitWorker> get initWorker async =>
       _initWorkerMemoizer.runOnce(() async {
@@ -105,8 +113,8 @@ class SignInStateMachine extends StateMachine<SignInEvent, SignInState> {
           return worker;
         }
         worker = SrpInitWorker.create();
-        // TODO(dnys1): Log
-        worker.logs.listen(safePrint);
+        final logger = this.logger.createChild(worker.name);
+        worker.logs.listen((entry) => _logWorkerBeeMessage(logger, entry));
         await worker.spawn();
         addInstance<SrpInitWorker>(worker);
         return worker;
@@ -120,8 +128,8 @@ class SignInStateMachine extends StateMachine<SignInEvent, SignInState> {
           return worker;
         }
         worker = SrpPasswordVerifierWorker.create();
-        // TODO(dnys1): Log
-        worker.logs.listen(safePrint);
+        final logger = this.logger.createChild(worker.name);
+        worker.logs.listen((entry) => _logWorkerBeeMessage(logger, entry));
         await worker.spawn();
         addInstance<SrpPasswordVerifierWorker>(worker);
         return worker;
@@ -135,8 +143,8 @@ class SignInStateMachine extends StateMachine<SignInEvent, SignInState> {
           return worker;
         }
         worker = SrpDevicePasswordVerifierWorker.create();
-        // TODO(dnys1): Log
-        worker.logs.listen(safePrint);
+        final logger = this.logger.createChild(worker.name);
+        worker.logs.listen((entry) => _logWorkerBeeMessage(logger, entry));
         await worker.spawn();
         addInstance<SrpDevicePasswordVerifierWorker>(worker);
         return worker;
@@ -150,8 +158,8 @@ class SignInStateMachine extends StateMachine<SignInEvent, SignInState> {
           return worker;
         }
         worker = ConfirmDeviceWorker.create();
-        // TODO(dnys1): Log
-        worker.logs.listen(safePrint);
+        final logger = this.logger.createChild(worker.name);
+        worker.logs.listen((entry) => _logWorkerBeeMessage(logger, entry));
         await worker.spawn();
         addInstance<ConfirmDeviceWorker>(worker);
         return worker;