feat(test_runner): support live Firebase and HTTP under flutter test

.gitignore

@@ -46,3 +46,7 @@ starter/system.bak
 
 # remove molos .iml files
 **/melos_*.iml
+
+generated_failed_sheet.png
+generated_passed_sheet.png
+generated_multidevice_sheet.png

modules/auth/lib/signin/auth_manager.dart

@@ -1,3 +1,4 @@
+import 'dart:async';
 import 'dart:io';
 import 'package:collection/collection.dart';
 
@@ -137,8 +138,10 @@ class AuthManager with UserAuthentication {
       customFirebaseApp ??= await _initializeFirebaseSignIn();
       final _auth = FirebaseAuth.instanceFor(app: customFirebaseApp!);
 
-      UserCredential userCredential =
-          await _auth.signInWithCustomToken(evaluatedJwtToken);
+      UserCredential userCredential = await _signInWithCustomTokenWithRetry(
+        _auth,
+        evaluatedJwtToken,
+      );
       User? user = userCredential.user;
       if (user == null) {
         throw StateError('Firebase sign-in failed. User is null.');
@@ -153,6 +156,47 @@ class AuthManager with UserAuthentication {
     }
   }
 
+  Future<UserCredential> _signInWithCustomTokenWithRetry(
+    FirebaseAuth auth,
+    String token, {
+    int maxAttempts = 4,
+  }) async {
+    Object? lastError;
+    for (var attempt = 1; attempt <= maxAttempts; attempt++) {
+      try {
+        return await auth.signInWithCustomToken(token);
+      } catch (error) {
+        lastError = error;
+        if (!_isRetryableFirebaseAuthError(error) || attempt >= maxAttempts) {
+          rethrow;
+        }
+        if (kDebugMode) {
+        debugPrint(
+            'Retrying Firebase custom-token sign-in after transient error '
+            '($attempt/$maxAttempts): $error',
+          );
+        }
+        await Future<void>.delayed(Duration(milliseconds: 300 * attempt));
+      }
+    }
+    throw lastError ?? StateError('Firebase custom-token sign-in failed.');
+  }
+
+  bool _isRetryableFirebaseAuthError(Object error) {
+    if (error is FirebaseAuthException) {
+      return error.code == 'network-request-failed';
+    }
+    if (error is SocketException || error is TimeoutException) {
+      return true;
+    }
+    final message = error.toString().toLowerCase();
+    return message.contains('network-request-failed') ||
+        message.contains('connection reset') ||
+        message.contains('connection closed') ||
+        message.contains('timed out') ||
+        message.contains('socketexception');
+  }
+
   Future<void> updateCurrentFirebaseUser(BuildContext context, User newUser) async {
     await StorageManager()
         .writeToSystemStorage(UserAuthentication._idKey, newUser.uid);

modules/auth/lib/signin/sign_in_anonymous.dart

@@ -14,12 +14,13 @@ class SignInAnonymousImpl implements SignInAnonymous {
     if (idToken != null) {
       if (action.onAuthenticated != null) {
         AuthenticatedUser? currentUser = AuthManager().getCurrentUser();
-        ScreenController().executeAction(context, action.onAuthenticated!,
-            event: EnsembleEvent(null, data: {'user': currentUser, 'idToken': idToken}));
+        await ScreenController().executeAction(context, action.onAuthenticated!,
+            event: EnsembleEvent(null,
+                data: {'user': currentUser, 'idToken': idToken}));
       }
     } else {
       if (action.onError != null) {
-        ScreenController().executeAction(context, action.onError!);
+        await ScreenController().executeAction(context, action.onError!);
       }
     }
   }

modules/auth/lib/signin/sign_in_with_custom_token.dart

@@ -23,14 +23,14 @@ class SignInWithCustomTokenImpl implements SignInWithCustomToken {
       if (idToken != null) {
         if (action.onAuthenticated != null) {
           AuthenticatedUser? currentUser = AuthManager().getCurrentUser();
-          ScreenController().executeAction(context, action.onAuthenticated!,
+          await ScreenController().executeAction(context, action.onAuthenticated!,
               event: EnsembleEvent(null,
                   data: {'user': currentUser, 'idToken': idToken}));
         }
       }
     } catch (e) {
       if (action.onError != null) {
-        ScreenController().executeAction(context, action.onError!,
+        await ScreenController().executeAction(context, action.onError!,
             event: EnsembleEvent(null, error: {'error': e.toString()}));
       }
     }

modules/ensemble/lib/action/dialog_actions.dart

@@ -1,4 +1,5 @@
 import 'package:ensemble/framework/action.dart';
+import 'package:ensemble/framework/apiproviders/api_provider.dart';
 import 'package:ensemble/framework/error_handling.dart';
 import 'package:ensemble/framework/event.dart';
 import 'package:ensemble/framework/scope.dart';
@@ -62,6 +63,7 @@ class ShowDialogAction extends EnsembleAction {
 
     bool useDefaultStyle = dialogStyles['style'] != 'none';
     BuildContext? dialogContext;
+    final apiProviders = APIProviders.of(context);
 
     showGeneralDialog(
         useRootNavigator: false,
@@ -113,12 +115,14 @@ class ShowDialogAction extends EnsembleAction {
                               useDefaultStyle ? const EdgeInsets.all(20) : null,
                           padding:
                               useDefaultStyle ? const EdgeInsets.all(20) : null,
-                          child: DataScopeWidget(
-                              scopeManager: scopeManager.createChildScope(),
-                              child: SingleChildScrollView(
-                                child: scopeManager
-                                    .buildWidgetFromDefinition(body),
-                              ))))));
+                          child: APIProviders(
+                              providers: apiProviders.providers,
+                              child: DataScopeWidget(
+                                  scopeManager: scopeManager.createChildScope(),
+                                  child: SingleChildScrollView(
+                                    child: scopeManager
+                                        .buildWidgetFromDefinition(body),
+                                  )))))));
         }).then((payload) {
       // remove the dialog context since we are closing them
       scopeManager.openedDialogs.remove(dialogContext);
@@ -178,4 +182,4 @@ class CloseAllDialogsAction extends EnsembleAction {
     scopeManager.openedDialogs.clear();
     return Future.value(null);
   }
-}
+}

modules/ensemble/lib/ensemble_app.dart

@@ -159,6 +159,9 @@ class EnsembleAppState extends State<EnsembleApp> with WidgetsBindingObserver {
   bool _hasInternet = true;
   late final StreamSubscription<List<ConnectivityResult>>
       _connectivitySubscription;
+  StreamSubscription<ThemeChangeEvent>? _themeChangeSubscription;
+  StreamSubscription<SetLocaleEvent>? _setLocaleSubscription;
+  StreamSubscription<ClearLocaleEvent>? _clearLocaleSubscription;
   SemanticsHandle? _testSemanticsHandle;
 
   @override
@@ -178,18 +181,30 @@ class EnsembleAppState extends State<EnsembleApp> with WidgetsBindingObserver {
       Workmanager().initialize(callbackDispatcher, isInDebugMode: false);
       initDeepLink(AppLifecycleState.resumed);
     }
-    AppEventBus().eventBus.on<ThemeChangeEvent>().listen((event) {
+    _themeChangeSubscription =
+        AppEventBus().eventBus.on<ThemeChangeEvent>().listen((event) {
+      if (!mounted) {
+        return;
+      }
       setState(() {});
     });
 
     // selecting a Locale at run time
-    AppEventBus().eventBus.on<SetLocaleEvent>().listen((event) async {
+    _setLocaleSubscription =
+        AppEventBus().eventBus.on<SetLocaleEvent>().listen((event) {
+      if (!mounted) {
+        return;
+      }
       if (runtimeLocale != event.locale) {
         runtimeLocale = event.locale;
         rebuildApp();
       }
     });
-    AppEventBus().eventBus.on<ClearLocaleEvent>().listen((event) {
+    _clearLocaleSubscription =
+        AppEventBus().eventBus.on<ClearLocaleEvent>().listen((event) {
+      if (!mounted) {
+        return;
+      }
       if (runtimeLocale != null) {
         runtimeLocale = null;
         rebuildApp();
@@ -203,6 +218,9 @@ class EnsembleAppState extends State<EnsembleApp> with WidgetsBindingObserver {
   /// Check the device’s connectivity and update the state.
   Future<void> _updateConnectivity() async {
     final result = await Connectivity().checkConnectivity();
+    if (!mounted) {
+      return;
+    }
     final hasInternetNow = result.any((r) => r != ConnectivityResult.none);
 
     // If connectivity has been restored, reinitialize the app
@@ -246,6 +264,9 @@ class EnsembleAppState extends State<EnsembleApp> with WidgetsBindingObserver {
   @override
   void dispose() {
     _connectivitySubscription.cancel();
+    _themeChangeSubscription?.cancel();
+    _setLocaleSubscription?.cancel();
+    _clearLocaleSubscription?.cancel();
     _testSemanticsHandle?.dispose();
     WidgetsBinding.instance.removeObserver(this);
     super.dispose();
@@ -289,6 +310,9 @@ class EnsembleAppState extends State<EnsembleApp> with WidgetsBindingObserver {
    * at runtime where a complete rebuild is needed.
    */
   void rebuildApp() {
+    if (!mounted) {
+      return;
+    }
     setState(() {
       appKey = UniqueKey();
     });

modules/ensemble/lib/framework/apiproviders/api_provider.dart

@@ -29,7 +29,7 @@ class APIProviders extends InheritedWidget {
     if (provider == null) {
       return httpProvider;
     } else if (provider == 'firebaseFunction') {
-      return FirebaseFunctionsAPIProvider();
+      return providers[provider] ?? FirebaseFunctionsAPIProvider();
     } else if (provider == 'sse') {
       return providers[provider] ?? SSEAPIProvider();
     } else {

modules/ensemble/lib/framework/widget/view_util.dart

@@ -171,6 +171,9 @@ class ViewUtil {
     if (callerPayload?['id'] != null) {
       props["id"] = callerPayload?['id'];
     }
+    if (callerPayload?['testId'] != null) {
+      props["testId"] = callerPayload?['testId'];
+    }
 
     Map<String, dynamic> inputPayload = {};
     if (callerPayload?['inputs'] is Map) {

modules/ensemble/lib/layout/ensemble_page_route.dart

@@ -78,8 +78,12 @@ extension PageTransitionTypeX on PageTransitionType {
 /// Page route builder that presents a screen without transition animation.
 class EnsemblePageRouteNoTransitionBuilder extends PageRouteBuilder {
   /// Creates a [EnsemblePageRouteNoTransitionBuilder] object.
-  EnsemblePageRouteNoTransitionBuilder({required Widget screenWidget})
+  EnsemblePageRouteNoTransitionBuilder({
+    required Widget screenWidget,
+    RouteSettings? settings,
+  })
       : super(
+          settings: settings,
           pageBuilder: (context, animation, secondaryAnimation) => screenWidget,
         );
 }

modules/ensemble/lib/screen_controller.dart

@@ -279,7 +279,7 @@ class ScreenController {
           (isRepeat ? repeatInterval! : 0);
 
       // we always execute at least once, delayed by startAfter and fallback to repeatInterval (or immediate if startAfter is 0)
-      Timer(Duration(seconds: delay), () {
+      final timer = Timer(Duration(seconds: delay), () {
         // execute the action
         executeActionWithScope(context, scopeManager, action.onTimer);
 
@@ -298,7 +298,7 @@ class ScreenController {
           int? repeatCount = maxTimes != null ? maxTimes - 1 : null;
           if (repeatCount != 0) {
             int counter = 0;
-            final timer =
+            final periodicTimer =
                 Timer.periodic(Duration(seconds: repeatInterval), (timer) {
               // execute the action
               executeActionWithScope(context, scopeManager, action.onTimer);
@@ -317,10 +317,11 @@ class ScreenController {
 
             // save our timer to our PageData since user may want to cancel at anytime
             // and also when we navigate away from the page
-            scopeManager.addTimer(action, timer);
+            scopeManager.addTimer(action, periodicTimer);
           }
         }
       });
+      scopeManager.addTimer(action, timer);
     } else if (action is StopTimerAction) {
       try {
         scopeManager.removeTimer(action.id);
@@ -360,9 +361,9 @@ class ScreenController {
           apiMap: apiMap,
           scopeManager: scopeManager);
     } else if (action is SignInAnonymousAction) {
-      GetIt.I<SignInAnonymous>().signInAnonymously(context, action: action);
+      await GetIt.I<SignInAnonymous>().signInAnonymously(context, action: action);
     } else if (action is SignInWithCustomTokenAction) {
-      GetIt.I<SignInWithCustomToken>().signInWithCustomToken(context, action: action);
+      await GetIt.I<SignInWithCustomToken>().signInWithCustomToken(context, action: action);
     } else if (action is WalletConnectAction) {
       //  TODO store session:  WalletConnectSession? session = await sessionStorage.getSession();
 
@@ -584,12 +585,24 @@ class ScreenController {
             defaultTransitionOptions[_pageType]?['duration'],
         fallback: 250);
 
+    final routeSettings = RouteSettings(
+      name: screenName ?? screenId,
+      arguments: ScreenPayload(
+        screenId: screenId,
+        screenName: screenName,
+        pageType: pageType,
+        arguments: pageArgs,
+        isExternal: isExternal,
+      ),
+    );
+
     PageRouteBuilder route = getScreenBuilder(
       screenWidget,
       pageType: pageType,
       transitionType: transitionType,
       alignment: alignment,
       duration: duration,
+      settings: routeSettings,
     );
     // push the new route and remove all existing screens. This is suitable for logging out.
     if (routeOption == RouteOption.clearAllScreens) {
@@ -651,12 +664,14 @@ class ScreenController {
     PageTransitionType? transitionType,
     Alignment? alignment,
     int? duration,
+    RouteSettings? settings,
   }) {
     const enableTransition =
         bool.fromEnvironment('transitions', defaultValue: true);
 
     if (!enableTransition) {
-      return EnsemblePageRouteNoTransitionBuilder(screenWidget: screenWidget);
+      return EnsemblePageRouteNoTransitionBuilder(
+          screenWidget: screenWidget, settings: settings);
     }
 
     if (pageType == PageType.modal) {
@@ -669,13 +684,15 @@ class ScreenController {
         duration: Duration(milliseconds: duration ?? 250),
         barrierDismissible: true,
         barrierColor: Colors.black54,
+        settings: settings,
       );
     } else {
       return EnsemblePageRouteBuilder(
         child: screenWidget,
         transitionType: transitionType ?? PageTransitionType.fade,
         alignment: alignment ?? Alignment.center,
         duration: Duration(milliseconds: duration ?? 250),
+        settings: settings,
       );
     }
   }

modules/ensemble/lib/util/ensemble_utils.dart

@@ -24,8 +24,13 @@ class EnsembleUtils {
 
     // Fallback to RouteObserver method
     final route = Ensemble().getCurrentRoute();
-    if (route is PopupRoute && route.isCurrent && route.navigator != null) {
-      return route.navigator!.maybePop(payload);
+    final navigator = route?.navigator;
+    if (route is PopupRoute &&
+        route.isCurrent &&
+        navigator != null &&
+        navigator.canPop()) {
+      navigator.pop(payload);
+      return Future.value(true);
     }
     return Future.value(false);
   }
@@ -54,10 +59,13 @@ class EnsembleUtils {
 
     // Fallback to RouteObserver method
     final route = Ensemble().getCurrentRoute();
+    final navigator = route?.navigator;
     if (route is ModalBottomSheetRoute &&
         route.isCurrent &&
-        route.navigator != null) {
-      return route.navigator!.maybePop(payload);
+        navigator != null &&
+        navigator.canPop()) {
+      navigator.pop(payload);
+      return Future.value(true);
     }
     return Future.value(false);
   }