fix: respect stored live activity preference in sync path

The in-memory localLiveActivitiesEnabled flag was not updated when the
user disabled Live Activity Updates via settings, allowing snapshot
subscriptions to recreate activities after disable.

- Export setLocalLiveActivitiesEnabled from liveActivityController
- Call it from setLiveActivityUpdatesEnabled when preference changes
- Add initializeLiveActivityPreferenceState to hydrate the in-memory
  flag from stored preferences on app startup (before environments
  connect)

Author: cursoragent

apps/mobile/src/features/agent-awareness/liveActivityController.ts

@@ -598,6 +598,10 @@ function isMissingNativeLiveActivityError(error: unknown): boolean {
   return error instanceof Error && error.message.includes("Can't find live activity with id:");
 }
 
+export function setLocalLiveActivitiesEnabled(enabled: boolean): void {
+  localLiveActivitiesEnabled = enabled;
+}
+
 export function __resetAgentLiveActivitiesForTest(): void {
   localLiveActivitiesEnabled = true;
   activeActivity = null;

apps/mobile/src/features/agent-awareness/liveActivityPreferences.test.ts

@@ -8,7 +8,7 @@ import { HttpClient } from "effect/unstable/http";
 import type { SavedRemoteConnection } from "../../lib/connection";
 import { savePreferencesPatch } from "../../lib/storage";
 import { linkEnvironmentToCloud } from "../cloud/linkEnvironment";
-import { endAllAgentLiveActivities } from "./liveActivityController";
+import { endAllAgentLiveActivities, setLocalLiveActivitiesEnabled } from "./liveActivityController";
 import { setLiveActivityUpdatesEnabled } from "./liveActivityPreferences";
 import { refreshAgentAwarenessRegistration } from "./remoteRegistration";
 
@@ -22,6 +22,7 @@ vi.mock("../cloud/linkEnvironment", () => ({
 
 vi.mock("./liveActivityController", () => ({
   endAllAgentLiveActivities: vi.fn(() => Effect.void),
+  setLocalLiveActivitiesEnabled: vi.fn(),
 }));
 
 vi.mock("./remoteRegistration", () => ({

apps/mobile/src/features/agent-awareness/liveActivityPreferences.ts

@@ -3,11 +3,18 @@ import { HttpClient } from "effect/unstable/http";
 import { ManagedRelayClient } from "@t3tools/client-runtime";
 
 import type { SavedRemoteConnection } from "../../lib/connection";
-import { savePreferencesPatch } from "../../lib/storage";
+import { loadPreferences, savePreferencesPatch } from "../../lib/storage";
 import { linkEnvironmentToCloud } from "../cloud/linkEnvironment";
-import { endAllAgentLiveActivities } from "./liveActivityController";
+import { endAllAgentLiveActivities, setLocalLiveActivitiesEnabled } from "./liveActivityController";
 import { refreshAgentAwarenessRegistration } from "./remoteRegistration";
 
+export async function initializeLiveActivityPreferenceState(): Promise<void> {
+  const preferences = await loadPreferences();
+  if (preferences.liveActivitiesEnabled === false) {
+    setLocalLiveActivitiesEnabled(false);
+  }
+}
+
 export function setLiveActivityUpdatesEnabled(input: {
   readonly enabled: boolean;
   readonly clerkToken: string | null;
@@ -19,6 +26,8 @@ export function setLiveActivityUpdatesEnabled(input: {
       catch: (error) => error,
     });
 
+    setLocalLiveActivitiesEnabled(input.enabled);
+
     if (!input.enabled) {
       yield* endAllAgentLiveActivities();
     }

apps/mobile/src/state/use-remote-environment-registry.ts

@@ -59,6 +59,7 @@ import {
   stopAgentAwarenessForEnvironment,
   stopAllAgentAwareness,
 } from "../features/agent-awareness/shellLiveActivitySync";
+import { initializeLiveActivityPreferenceState } from "../features/agent-awareness/liveActivityPreferences";
 import { environmentRuntimeManager, useEnvironmentRuntimeStates } from "./use-environment-runtime";
 import {
   clearCachedShellSnapshotMetadata,
@@ -565,6 +566,11 @@ export function useRemoteEnvironmentBootstrap() {
           return;
         }
 
+        await initializeLiveActivityPreferenceState();
+        if (cancelled) {
+          return;
+        }
+
         replaceSavedConnections(
           Object.fromEntries(
             connections.map((connection) => [connection.environmentId, connection]),