Add native iOS terminal with offset-based sync streaming (#554)

Author: arul28

apps/ade-cli/src/bootstrap.ts

@@ -761,15 +761,28 @@ export async function createAdeRuntime(args: {
   const ptyBackend = process.env.ADE_DISABLE_SUPERVISED_PTY_HOST === "1"
     ? null
     : createSupervisedPtyLoader({ logger });
+  // The sync runtime is created after ptyService (it takes ptyService as a
+  // dependency), so live PTY forwarding binds late through this ref — same
+  // pattern as desktop main. Without this bridge, paired phones only ever
+  // receive terminal snapshots, never live terminal_data push.
+  let syncServiceForPtyEvents: ReturnType<typeof createSyncService> | null = null;
   const ptyService = createPtyService({
     projectRoot,
     transcriptsDir: paths.transcriptsDir,
     laneService,
     sessionService,
     processRegistry,
     logger,
-    broadcastData: (event) => pushEvent("pty", { type: "pty_data", event }),
-    broadcastExit: (event) => pushEvent("pty", { type: "pty_exit", event }),
+    broadcastData: (event) => {
+      pushEvent("pty", { type: "pty_data", event });
+      const { projectRoot: _projectRoot, ...syncEvent } = event;
+      syncServiceForPtyEvents?.handlePtyData(syncEvent);
+    },
+    broadcastExit: (event) => {
+      pushEvent("pty", { type: "pty_exit", event });
+      const { projectRoot: _projectRoot, ...syncEvent } = event;
+      syncServiceForPtyEvents?.handlePtyExit(syncEvent);
+    },
     onSessionEnded: (event) => {
       void sessionDeltaService.computeSessionDelta(event.sessionId).catch((error) => {
         logger.warn("runtime.session_delta_compute_failed", {
@@ -1301,6 +1314,7 @@ export async function createAdeRuntime(args: {
       getModelPickerStore: () => getSharedModelPickerStore(db),
       onStatusChanged: (snapshot) => pushEvent("runtime", { type: "sync-status", snapshot }),
     });
+    syncServiceForPtyEvents = syncService;
   }
 
   if (syncService) {

apps/ade-cli/src/cli.ts

@@ -13526,10 +13526,19 @@ async function runServe(
         log: (message) => process.stderr.write(`${message}\n`),
         getServiceMainPid: getRuntimeServiceMainPid,
       });
-    })().catch((error: unknown) => {
-      process.stderr.write(
-        `ADE brain sync host startup loop failed: ${error instanceof Error ? error.message : String(error)}\n`,
-      );
+    })().catch(async (error: unknown) => {
+      // Cross-channel conflict (another build's live brain owns mobile sync):
+      // real builds never run sync-less, so fail the brain instead of coming
+      // up half-alive. The message carries the exact quit command.
+      const { SyncHostSingletonConflictError } = await import("./services/sync/syncHostSingleton");
+      const message = error instanceof Error ? error.message : String(error);
+      if (error instanceof SyncHostSingletonConflictError) {
+        process.stderr.write(`ADE brain refusing to run without mobile sync.\n${message}\n`);
+        process.exitCode = 1;
+        finish();
+        return;
+      }
+      process.stderr.write(`ADE brain sync host startup loop failed: ${message}\n`);
     });
   }