fix: verbose logging listener

impaktfull · Mar 9, 2024 · c0e8e1e · c0e8e1e
1 parent 3a5aacc
commit c0e8e1e
Show file tree

Hide file tree

Showing 4 changed files with 30 additions and 4 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,9 @@
+# 0.13.7
+
+## Fix
+
+- Verbose logger listener converted to a broadcast stream
+
 # 0.13.6
 
 ## Fix

diff --git a/lib/src/core/util/input_listener/force_quit_listener.dart b/lib/src/core/util/input_listener/force_quit_listener.dart
@@ -17,8 +17,7 @@ class ForceQuitListener {
       _listeners.remove(listener);
 
   static void init() {
-    _subscription =
-        ProcessSignal.sigint.watch().asBroadcastStream().listen((signal) async {
+    _subscription = ProcessSignal.sigint.watch().listen((signal) async {
       if (_isShuttingDown) return;
       _isShuttingDown = true;
       ImpaktfullCliLogger.log('\nForce quit detected. Cleaning up...');

diff --git a/lib/src/core/util/input_listener/versbose_logging_listener.dart b/lib/src/core/util/input_listener/versbose_logging_listener.dart
@@ -5,12 +5,15 @@ import 'package:impaktfull_cli/src/core/util/logger/logger.dart';
 
 class VerboseLoggingListener {
   static StreamSubscription<List<int>>? _subscription;
+  static var _cancelOnStop = true;
+  static StreamController<String> streamController =
+      StreamController.broadcast();
 
   VerboseLoggingListener._();
 
   static void startInputListener() {
-    _subscription?.cancel();
-    _subscription = stdin.asBroadcastStream().listen((data) {
+    if (_subscription != null) return;
+    _subscription = stdin.listen((data) {
       final input = String.fromCharCodes(data).trim();
 
       if (input.toLowerCase() == 'v' || input.toLowerCase() == 'verbose') {
@@ -23,7 +26,18 @@ class VerboseLoggingListener {
   }
 
   static void stopListening() {
+    if (!_cancelOnStop) return;
     _subscription?.cancel();
     _subscription = null;
   }
+
+  static void setupMutiCommandInputListener() {
+    _cancelOnStop = false;
+  }
+
+  static void clearMultipleCommandInputListener() {
+    _cancelOnStop = true;
+    stopListening();
+    streamController.close();
+  }
 }
diff --git a/lib/src/impaktfull_cli.dart b/lib/src/impaktfull_cli.dart
@@ -2,6 +2,7 @@ import 'package:args/command_runner.dart';
 import 'package:impaktfull_cli/src/core/model/error/impaktfull_cli_error.dart';
 import 'package:impaktfull_cli/src/core/plugin/impaktfull_plugin.dart';
 import 'package:impaktfull_cli/src/core/util/input_listener/force_quit_listener.dart';
+import 'package:impaktfull_cli/src/core/util/input_listener/versbose_logging_listener.dart';
 import 'package:impaktfull_cli/src/integrations/appcenter/plugin/appcenter_plugin.dart';
 import 'package:impaktfull_cli/src/integrations/apple_certificate/command/apple_certificate_root_command.dart';
 import 'package:impaktfull_cli/src/core/util/extensions/arg_parser_extensions.dart';
@@ -131,4 +132,10 @@ class ImpaktfullCli {
     });
     dispose();
   }
+
+  Future<void> runMultiplCommands(AsyncCallback function) async {
+    VerboseLoggingListener.setupMutiCommandInputListener();
+    await function();
+    VerboseLoggingListener.clearMultipleCommandInputListener();
+  }
 }