Setup bug fix

Author: TaeHagen

lib/app/layouts/setup/pages/rustpush/hw_inp.dart

@@ -365,6 +365,7 @@ class HwInpState extends OptimizedState<HwInp> {
     } catch (e, s) {
       Get.back();
       showSnackbar("Failure handling subscription! Please try again", e.toString());
+      pushService.mixpanel.track("hosted-device-failure");
       rethrow;
     }
     Get.back();
@@ -596,6 +597,7 @@ class HwInpState extends OptimizedState<HwInp> {
                                 hosted,
                                 () async {
                                   if (hosted) {
+                                    pushService.mixpanel.track("choose-hosted");
                                     wrapSubscriptionPromise<void>((() async {
                                       await controller.ensureToken();
                                       pushService.client.runWithClientNonRetryable<void>((client) async {
@@ -952,42 +954,47 @@ class HwInpState extends OptimizedState<HwInp> {
           ss.settings.cachedCodes.remove(items.key);
         }
         ss.saveSettings();
+        if (isHosted) {
+          pushService.mixpanel.track("hosted-device-configured");
+        }
       }
 
       var state = await api.getDeviceInfoState(state: pushService.state);
       controller.supportsPhoneReg.value = state.name.contains("iPhone") || state.name.contains("iPod") || state.name.contains("iPad");
       // controller.updatePhoneReg();
-      showDialog(
-        context: context,
-        barrierDismissible: false,
-        builder: (context) => AlertDialog(
-          title: const Column(
-            crossAxisAlignment: CrossAxisAlignment.center,
-            children: [
-              Icon(
-                Icons.security,
-                size: 40,
-                color: Colors.blue,
+      Future.delayed(const Duration(milliseconds: 200), () {
+        showDialog(
+          context: context,
+          barrierDismissible: false,
+          builder: (context) => AlertDialog(
+            title: const Column(
+              crossAxisAlignment: CrossAxisAlignment.center,
+              children: [
+                Icon(
+                  Icons.security,
+                  size: 40,
+                  color: Colors.blue,
+                ),
+                SizedBox(height: 12),
+                Text("You're in control"),
+              ],
+            ),
+            content: const Text('A new Apple device will appear on your Apple Account.\n\nAll keys and account credentials are generated and stored locally on this device. The new device does not have any access to your Apple Account or Messages.'),
+            actions: [
+              TextButton(
+                onPressed: () {
+                  Navigator.of(context).pop();
+                  controller.pageController.nextPage(
+                    duration: const Duration(milliseconds: 300),
+                    curve: Curves.easeInOut,
+                  );
+                },
+                child: const Text('Next'),
               ),
-              SizedBox(height: 12),
-              Text("You're in control"),
             ],
           ),
-          content: const Text('A new Apple device will appear on your Apple Account.\n\nAll keys and account credentials are generated and stored locally on this device. The new device does not have any access to your Apple Account or Messages.'),
-          actions: [
-            TextButton(
-              onPressed: () {
-                Navigator.of(context).pop();
-                controller.pageController.nextPage(
-                  duration: const Duration(milliseconds: 300),
-                  curve: Curves.easeInOut,
-                );
-              },
-              child: const Text('Next'),
-            ),
-          ],
-        ),
-      );
+        );
+      });
     } catch (e) {
       if (e is AnyhowException) {
         controller.updateConnectError(e.message);

lib/app/layouts/setup/setup_view.dart

@@ -73,6 +73,10 @@ class SetupViewController extends StatefulController {
   String? currentWaitlist;
   RxString noCapErrorMsg = "Currently full. If you got an invite, enter your code from your email. Otherwise, sign up to get notified!".obs;
 
+  bool errorIsProblem() {
+    return error.isNotEmpty && !error.contains("Enter the correct password") && !error.contains("Your account information was entered incorrectly") && (!error.contains("Relay device offline") || !ss.settings.deviceIsHosted.value);
+  }
+
   bool hasValidToken() {
     return !tokenExpiry.isBefore(DateTime.now());
   }
@@ -359,6 +363,9 @@ class SetupViewController extends StatefulController {
       // persisting SMS auth certs is actually really useful
       // ss.settings.cachedCodes.clear();
       Logger.debug("Success registered!");
+      if (ss.settings.deviceIsHosted.value) {
+        pushService.mixpanel.track("hosted-setup-success");
+      }
       await pushService.configured();
 
       var handles = await api.getHandles(state: pushService.state);
@@ -450,6 +457,9 @@ class SetupViewController extends StatefulController {
       newError += " Make sure Contact Key Verification and Advanced Data Protection are off.";
     }
     error = newError;
+    if (ss.settings.deviceIsHosted.value && errorIsProblem()) {
+      pushService.mixpanel.track("hosted-setup-error");
+    }
     updateWidgets<ErrorText>(newError);
   }
 }
@@ -768,7 +778,7 @@ class _ErrorTextState extends CustomState<ErrorText, String, SetupViewController
                       .copyWith(height: 2)),
             ),
           ),
-        if (controller.error.isNotEmpty && !controller.error.contains("Enter the correct password") && !controller.error.contains("Your account information was entered incorrectly") && (!controller.error.contains("Relay device offline") || !ss.settings.deviceIsHosted.value))
+        if (controller.errorIsProblem())
         TextButton(
           onPressed: () async {
             final TextEditingController participantController = TextEditingController();

lib/services/rustpush/rustpush_service.dart

@@ -1252,6 +1252,7 @@ class RustPushService extends GetxService {
   var findMy = false;
   var sharedStreams = false;
 
+  late Mixpanel mixpanel;
 
   var disableOutgoingSms = false;
 
@@ -2683,9 +2684,15 @@ class RustPushService extends GetxService {
       var state = push.field0;
       if (state is api.RegisterState_Registered) {
         notifiedFailed = false;
+        if (ss.settings.deviceIsHosted.value) {
+          mixpanel.track("hosted-register-success");
+        }
         handleRegistered();
       }
       if (state is api.RegisterState_Failed && !notifiedFailed) {
+        if (ss.settings.deviceIsHosted.value) {
+          mixpanel.track("hosted-register-failure");
+        }
         notif.createRegisterFailed(state.retryWait == null);
         if (state.retryWait == null) {
           (backend as RustPushBackend).markFailedToLogin(hw: false);
@@ -3688,6 +3695,7 @@ class RustPushService extends GetxService {
       validateSubState();
     })();
     initAppLinks();
+    initMixPanel();
     await initFuture;
     // pre-cache next FT link
     api.getFtLink(state: pushService.state, usage: "next");
@@ -3705,6 +3713,10 @@ class RustPushService extends GetxService {
     Logger.info("finishInit");
   }
 
+  void initMixPanel() async {
+    mixpanel = await Mixpanel.init("d66dc2d8f2ad649fac2640ff059dc9f4", trackAutomaticEvents: false);
+  }
+
   Future reset(bool hw, bool logout) async {
     await api.resetState(state: state, resetHw: hw, logout: logout);
   }