fix(test): allow iui e2e tests to re-run

Author: sneurlax

lib/services/testing/test_suites/epiccash_integration_test_suite.dart

@@ -17,7 +17,7 @@ import '../test_suite_interface.dart';
 import '../testing_models.dart';
 
 class EpiccashIntegrationTestSuite implements TestSuiteInterface {
-  final StreamController<TestSuiteStatus> _statusController = 
+  StreamController<TestSuiteStatus> _statusController =
       StreamController<TestSuiteStatus>.broadcast();
   TestSuiteStatus _status = TestSuiteStatus.waiting;
 
@@ -31,7 +31,12 @@ class EpiccashIntegrationTestSuite implements TestSuiteInterface {
   TestSuiteStatus get status => _status;
 
   @override
-  Stream<TestSuiteStatus> get statusStream => _statusController.stream;
+  Stream<TestSuiteStatus> get statusStream {
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
+    return _statusController.stream;
+  }
 
   @override
   Future<TestResult> runTests() async {
@@ -157,6 +162,9 @@ class EpiccashIntegrationTestSuite implements TestSuiteInterface {
 
   void _updateStatus(TestSuiteStatus newStatus) {
     _status = newStatus;
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
     _statusController.add(newStatus);
   }
 

lib/services/testing/test_suites/firo_integration_test_suite.dart

@@ -18,7 +18,7 @@ import '../test_suite_interface.dart';
 import '../testing_models.dart';
 
 class FiroIntegrationTestSuite implements TestSuiteInterface {
-  final StreamController<TestSuiteStatus> _statusController = 
+  StreamController<TestSuiteStatus> _statusController =
       StreamController<TestSuiteStatus>.broadcast();
   TestSuiteStatus _status = TestSuiteStatus.waiting;
 
@@ -32,7 +32,12 @@ class FiroIntegrationTestSuite implements TestSuiteInterface {
   TestSuiteStatus get status => _status;
 
   @override
-  Stream<TestSuiteStatus> get statusStream => _statusController.stream;
+  Stream<TestSuiteStatus> get statusStream {
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
+    return _statusController.stream;
+  }
 
   @override
   Future<TestResult> runTests() async {
@@ -210,6 +215,9 @@ class FiroIntegrationTestSuite implements TestSuiteInterface {
 
   void _updateStatus(TestSuiteStatus newStatus) {
     _status = newStatus;
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
     _statusController.add(newStatus);
   }
 

lib/services/testing/test_suites/litecoin_mweb_integration_test_suite.dart

@@ -22,7 +22,7 @@ import '../test_suite_interface.dart';
 import '../testing_models.dart';
 
 class LitecoinMwebIntegrationTestSuite implements TestSuiteInterface {
-  final StreamController<TestSuiteStatus> _statusController = 
+  StreamController<TestSuiteStatus> _statusController =
       StreamController<TestSuiteStatus>.broadcast();
   TestSuiteStatus _status = TestSuiteStatus.waiting;
 
@@ -36,7 +36,12 @@ class LitecoinMwebIntegrationTestSuite implements TestSuiteInterface {
   TestSuiteStatus get status => _status;
 
   @override
-  Stream<TestSuiteStatus> get statusStream => _statusController.stream;
+  Stream<TestSuiteStatus> get statusStream {
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
+    return _statusController.stream;
+  }
 
   @override
   Future<TestResult> runTests() async {
@@ -272,6 +277,9 @@ class LitecoinMwebIntegrationTestSuite implements TestSuiteInterface {
 
   void _updateStatus(TestSuiteStatus newStatus) {
     _status = newStatus;
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
     _statusController.add(newStatus);
   }
 

lib/services/testing/test_suites/monero_integration_test_suite.dart

@@ -25,7 +25,7 @@ import '../testing_models.dart';
 import 'test_data/polyseed_vectors.dart';
 
 class MoneroWalletTestSuite implements TestSuiteInterface {
-  final StreamController<TestSuiteStatus> _statusController = 
+  StreamController<TestSuiteStatus> _statusController =
       StreamController<TestSuiteStatus>.broadcast();
   TestSuiteStatus _status = TestSuiteStatus.waiting;
 
@@ -39,7 +39,12 @@ class MoneroWalletTestSuite implements TestSuiteInterface {
   TestSuiteStatus get status => _status;
 
   @override
-  Stream<TestSuiteStatus> get statusStream => _statusController.stream;
+  Stream<TestSuiteStatus> get statusStream {
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
+    return _statusController.stream;
+  }
 
   @override
   Future<TestResult> runTests() async {
@@ -540,6 +545,9 @@ class MoneroWalletTestSuite implements TestSuiteInterface {
 
   void _updateStatus(TestSuiteStatus newStatus) {
     _status = newStatus;
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
     _statusController.add(newStatus);
   }
 

lib/services/testing/test_suites/salvium_integration_test_suite.dart

@@ -23,7 +23,7 @@ import '../test_suite_interface.dart';
 import '../testing_models.dart';
 
 class SalviumIntegrationTestSuite implements TestSuiteInterface {
-  final StreamController<TestSuiteStatus> _statusController = 
+  StreamController<TestSuiteStatus> _statusController =
       StreamController<TestSuiteStatus>.broadcast();
   TestSuiteStatus _status = TestSuiteStatus.waiting;
 
@@ -37,7 +37,12 @@ class SalviumIntegrationTestSuite implements TestSuiteInterface {
   TestSuiteStatus get status => _status;
 
   @override
-  Stream<TestSuiteStatus> get statusStream => _statusController.stream;
+  Stream<TestSuiteStatus> get statusStream {
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
+    return _statusController.stream;
+  }
 
   @override
   Future<TestResult> runTests() async {
@@ -441,6 +446,9 @@ class SalviumIntegrationTestSuite implements TestSuiteInterface {
 
   void _updateStatus(TestSuiteStatus newStatus) {
     _status = newStatus;
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
     _statusController.add(newStatus);
   }
 

lib/services/testing/test_suites/tor_test_suite.dart

@@ -25,7 +25,7 @@ import '../../../electrumx_rpc/electrumx_client.dart';
 import '../../../utilities/tor_plain_net_option_enum.dart';
 
 class TorTestSuite implements TestSuiteInterface {
-  final StreamController<TestSuiteStatus> _statusController = StreamController<TestSuiteStatus>.broadcast();
+  StreamController<TestSuiteStatus> _statusController = StreamController<TestSuiteStatus>.broadcast();
   TestSuiteStatus _status = TestSuiteStatus.waiting;
 
   @override
@@ -38,7 +38,12 @@ class TorTestSuite implements TestSuiteInterface {
   TestSuiteStatus get status => _status;
 
   @override
-  Stream<TestSuiteStatus> get statusStream => _statusController.stream;
+  Stream<TestSuiteStatus> get statusStream {
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
+    return _statusController.stream;
+  }
 
   @override
   Future<TestResult> runTests() async {
@@ -296,6 +301,9 @@ class TorTestSuite implements TestSuiteInterface {
 
   void _updateStatus(TestSuiteStatus newStatus) {
     _status = newStatus;
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
     _statusController.add(_status);
   }
 

lib/services/testing/test_suites/wownero_integration_test_suite.dart

@@ -24,7 +24,7 @@ import '../test_suite_interface.dart';
 import '../testing_models.dart';
 
 class WowneroIntegrationTestSuite implements TestSuiteInterface {
-  final StreamController<TestSuiteStatus> _statusController = 
+  StreamController<TestSuiteStatus> _statusController =
       StreamController<TestSuiteStatus>.broadcast();
   TestSuiteStatus _status = TestSuiteStatus.waiting;
 
@@ -38,7 +38,12 @@ class WowneroIntegrationTestSuite implements TestSuiteInterface {
   TestSuiteStatus get status => _status;
 
   @override
-  Stream<TestSuiteStatus> get statusStream => _statusController.stream;
+  Stream<TestSuiteStatus> get statusStream {
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
+    return _statusController.stream;
+  }
 
   @override
   Future<TestResult> runTests() async {
@@ -460,6 +465,9 @@ class WowneroIntegrationTestSuite implements TestSuiteInterface {
 
   void _updateStatus(TestSuiteStatus newStatus) {
     _status = newStatus;
+    if (_statusController.isClosed) {
+      _statusController = StreamController<TestSuiteStatus>.broadcast();
+    }
     _statusController.add(newStatus);
   }