Incident fix

Author: TaeHagen

lib/app/layouts/settings/settings_page.dart

@@ -1137,20 +1137,7 @@ class _SettingsPageState extends OptimizedState<SettingsPage> {
                                                                     .primary)),
                                                     onPressed: () async {
                                                       Navigator.of(context).pop();
-                                                      if (ss.settings.deviceIsHosted.value) {
-                                                        String? ticket = await api.validateRelay(configRef: pushService.state!.osConfig);
-                                                        if (ticket != null) {
-                                                          var activated = await http.dio.post("https://hw.openbubbles.app/ticket/$ticket/release");
-                                                          if (activated.statusCode == 200) {
-                                                            pushService.markFailedToLogin(hw: true, ui: true);
-                                                            return;
-                                                          }
-                                                        }
-                                                        pushService.markFailedToLogin();
-                                                        return;
-                                                      } else {
-                                                        pushService.markFailedToLogin(hw: true, ui: true);
-                                                      }
+                                                      pushService.markFailedToLogin(hw: true, ui: true);
                                                     }
                                                   ),
                                                 ],

lib/services/rustpush/rustpush_service.dart

@@ -4784,6 +4784,7 @@ class RustPushService extends GetxService {
     initAppLinks();
     initMixPanel();
     await initFuture;
+    Timer(const Duration(seconds: 2), checkIncident);
     // pre-cache next FT link
     if (pushService.state != null) api.getFtLink(facetime: pushService.state!.ftClient, usage: "next");
     Logger.info("initDone");
@@ -4799,6 +4800,41 @@ class RustPushService extends GetxService {
     Logger.info("finishInit");
   }
 
+  void checkIncident() {
+    if (!File("$statePath/incident_affected").existsSync()) return;
+    showDialog(
+      context: Get.context!,
+      builder: (context) => AlertDialog(
+        title: Text(
+          "Action requried",
+          style: context.theme.textTheme.titleLarge,
+        ),
+        backgroundColor: context.theme.colorScheme.properSurface,
+        content: Text("There's an issue with a recent update. A software bug corrupted part of the app's internal state and needs to be fixed before messaging can continue. You won't be able to send messages until you take action.\n\nYour data was not compromised, and this was not a security issue.\nWe recommend backing up any important messages before proceeding. Have your apple device and account authentication credentials ready.", style: context.theme.textTheme.bodyLarge),
+        actions: [
+          TextButton(
+            child: Text(
+                "Dismiss for now",
+                style: context.theme.textTheme.bodyLarge!.copyWith(color: context.theme.colorScheme.primary)
+            ),
+            onPressed: () => Navigator.of(context).pop(),
+          ),
+          TextButton(
+            child: Text(
+                "Fix",
+                style: context.theme.textTheme.bodyLarge!.copyWith(color: context.theme.colorScheme.primary)
+            ),
+            onPressed: () async {
+              Navigator.of(context).pop();
+              pushService.markFailedToLogin(hw: true, logout: true, ui: true);
+              File("$statePath/incident_affected").deleteSync();
+            }
+          ),
+        ],
+      ),
+    );
+  }
+
   void initMixPanel() async {
     if (ss.settings.finishedSetup.value && !ss.settings.deviceIsHosted.value) return;
     mixpanel = await Mixpanel.init("d66dc2d8f2ad649fac2640ff059dc9f4", trackAutomaticEvents: false);
@@ -4899,6 +4935,7 @@ class RustPushService extends GetxService {
 
   Future configured() async {
     await handleRegistered();
+    Timer(const Duration(seconds: 2), checkIncident);
     if (Platform.isAndroid) {
       await mcs.invokeMethod("notify-native-configured");
     }

rust/src/api/api.rs

@@ -25,6 +25,7 @@ pub use icloud_auth::DefaultAnisetteProvider;
 use uniffi::HandleAlloc;
 use rand::Rng;
 use uuid::Uuid;
+use rustpush::KeyCache;
 use std::io::Seek;
 use async_recursion::async_recursion;
 use base64::prelude::*;
@@ -385,6 +386,14 @@ pub async fn make_imclient(path: String, conn: &APSConnection, users: &Vec<IDSUs
     let dir = PathBuf::from_str(&path).unwrap();
     let id_path = dir.join("id.plist");
 
+    let incident_path = dir.join("incident");
+    if !incident_path.exists() {
+        if plist::from_file::<_, KeyCache>(dir.join("id_cache.plist")).is_ok() {
+            let _ = fs::File::create(dir.join("incident_affected"));
+        }
+        let _ = fs::File::create(incident_path);
+    }
+
     Arc::new(IMClient::new(conn.clone(), users.clone(), identity.clone(),
     &[&MADRID_SERVICE, &MULTIPLEX_SERVICE, &FACETIME_SERVICE, &VIDEO_SERVICE], dir.join("id_cache.plist"), conn.os_config.clone(), Box::new(move |updated_keys| {
         println!("updated keys!!!");