fix(mobile): pass the cloning flag and wait for the project before opening its draft

The flag was dropped in the rebase; without it Start was enabled before the
clone stream reported. The draft also waits briefly for the project.created
event so it opens on the new project instead of its picker.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: juliusmarminge

apps/mobile/src/features/projects/AddProjectScreen.tsx

@@ -49,7 +49,7 @@ import * as Order from "effect/Order";
 import { AsyncResult } from "effect/unstable/reactivity";
 import { cn } from "../../lib/cn";
 
-import { useProjects, useServerConfigs } from "../../state/entities";
+import { useProjects, useServerConfigs, waitForProject } from "../../state/entities";
 import { filesystemEnvironment } from "../../state/filesystem";
 import { projectEnvironment } from "../../state/projects";
 import { useEnvironmentQuery } from "../../state/query";
@@ -972,10 +972,15 @@ export function AddProjectDestinationScreen(props: {
       if (AsyncResult.isFailure(startResult)) {
         setError(errorMessage(Cause.squash(startResult.cause)));
       } else {
+        // The create event usually lands before the RPC returns; give the
+        // shell stream a moment so the draft opens on the new project rather
+        // than falling back to its picker.
+        await waitForProject({ environmentId: environment.environmentId, projectId }, 3_000);
         openNewTaskDraft(navigation, {
           environmentId: environment.environmentId,
           projectId,
           title,
+          cloning: "1",
         });
       }
       setIsSubmitting(false);

apps/mobile/src/state/entities.ts

@@ -1,4 +1,6 @@
 import { useAtomValue } from "@effect/atom-react";
+
+import { appAtomRegistry } from "./atom-registry";
 import type {
   EnvironmentProject,
   EnvironmentThreadShell,
@@ -25,6 +27,31 @@ const EMPTY_SERVER_CONFIG_ATOM = Atom.make<ServerConfig | null>(null).pipe(
   Atom.withLabel("mobile-server-config:empty"),
 );
 
+/** Resolves when the project event reaches the live client store. */
+export function waitForProject(
+  ref: ScopedProjectRef,
+  timeoutMs = 10_000,
+): Promise<EnvironmentProject | null> {
+  const atom = environmentProjects.projectAtom(ref);
+  const current = appAtomRegistry.get(atom);
+  if (current !== null) return Promise.resolve(current);
+  return new Promise((resolve) => {
+    let unsubscribe: (() => void) | null = null;
+    const timeout = setTimeout(() => {
+      unsubscribe?.();
+      resolve(null);
+    }, timeoutMs);
+    const finish = (project: EnvironmentProject | null) => {
+      if (project === null) return;
+      clearTimeout(timeout);
+      unsubscribe?.();
+      resolve(project);
+    };
+    unsubscribe = appAtomRegistry.subscribe(atom, finish);
+    finish(appAtomRegistry.get(atom));
+  });
+}
+
 export function useProjects(): ReadonlyArray<EnvironmentProject> {
   return useAtomValue(environmentProjects.projectsAtom);
 }