feat(workspace, search-results, org-workbench, shell): searches become async jobs — the queue rail lands

Agent searches (didi's links/streams/team crawls) ran as synchronous
invokes: the button disabled, one column was hijacked, and the operator
babysat a 60-210s wait per search. Now a search is a job — search.submit
returns a search_id in milliseconds, the workspace service owns a durable
registry, completion broadcasts over the existing WS event machinery, and
a new search-results remote renders the registry as a queue of cards in a
persistent right rail. Fire many, walk away, triage on arrival.

Registry + async execution (services/workspace):
- searches.ts — in-memory map + write-through JSON at SEARCH_STORE_PATH
  (the sessions/active-workspace volume precedent), 24h TTL sweep, and an
  executor that dispatches the existing organization.crawl.requested NATS
  request (same 600s budget) without awaiting it. prompt-runner untouched.
- Four local capabilities: search.submit / list / results / dismiss;
  search.updated joins the WS broadcast subjects. Stranded queued/running
  entries are marked failed-with-retry on restart, never left spinning.
- Local capabilities now receive the actor envelope, so didi attribution
  survives the async boundary into the crawl request.

The rail (apps/search-results, :3018 — spec said 3017 but strategy-curator
had claimed it):
- Cards show target chip, org, status, and elapsed vs typical duration
  (hardcoded v1: links/streams ~90s, team ~200s); done cards pulse and
  count into a header badge; the registry refetches on events, no polling.
- Expand fetches results on demand: links/streams rows with a ➕ that
  carries the crawl's kind (and stream name) through the write; a team
  surface with the full staged-people candidate gates, consume-on-accept.
- Dismissing a done card with unreviewed candidates asks once inline;
  failed cards offer Retry (resubmit same entity+target).

Door switchover (org-workbench, search-and-add, shell):
- The links/streams 🤖 and the People 🤖 now enqueue via search.submit and
  flip the rail visible (augment-it:search-submitted); StagedPeople and
  crawlTeam are deleted from org-workbench (the rail owns staging now).
- search-and-add's crawl mode and the envelope crawl flag are retired;
  term-search and stream-scan modes unchanged.
- Shell: 🔎 queue toggle + done-count badge beside 💬 chat, right-rail
  slot mirroring the chat rail; searchResults federation entry; dev.sh
  lists :3018.

Proven live against the Aspen safe target: prove-search-queue.mjs all
green over the real WS (submit 4ms → running + settle events → 7 results
→ dismiss), then a browser drive of the spec's click-path — two concurrent
crawls ticking in the rail, survival across a page reload, expand, one
accept with kind carry-through, and the unreviewed-candidates confirm.

Files changed: see the changelog entry
changelog/2026-07-24_07_Searches-Become-Async-Jobs-The-Queue-Rail-Lands-
Fire-Many-Walk-Away-Triage-On-Arrival.md for the full inventory.

Also included:
- .gitignore: .playwright-mcp/ browser-drive session artifacts
- spec annotated: port correction + status (Phases 1-3 implemented)

Closes #42.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_013u3i9BoKeZRndqToQ3M5Q5

Author: mpstaton

.gitignore

@@ -50,3 +50,6 @@ pnpm-debug.log*
 # Local agent + ad-hoc data backups
 .claude/
 .backups/
+
+# Playwright MCP browser-drive artifacts (session snapshots/logs)
+.playwright-mcp/

apps/org-workbench/src/OrgCard.svelte

@@ -9,6 +9,7 @@
   import PeopleReveal from './PeopleReveal.svelte';
   import { addOrgLink, addOrgStream, updateOrgStream, addOrgCorpus } from './lib/org-client';
   import { requestSearch } from './lib/search-request';
+  import { submitCrawl } from './lib/search-queue';
   import type { OrgDetail, SearchRequestDetail, StreamEntry } from './lib/types';
 
   let {
@@ -59,16 +60,16 @@
       });
   }
 
-  // 🤖 — didi's crawl for a whole list (v1.2): same envelope, crawl flag on;
-  // search-and-add's crawl mode fires organization.crawl instead of a term.
+  // 🤖 — didi's crawl for a whole list, enqueued as an async job: the search
+  // lands as a card in the search-results rail (which the shell flips
+  // visible), no column hijack, no babysitting. Replaces the v1.2
+  // search-and-add crawl mode per the Search-Results-Queue-Remote spec.
   function makeCrawl(target: 'links' | 'streams') {
-    return () =>
-      requestSearch({
-        entity: { type: 'organization', org_slug: org.slug, display_name: displayName },
-        target,
-        seed_term: '',
-        crawl: true,
-      });
+    return () => {
+      void submitCrawl({ org_slug: org.slug, display_name: displayName, target, client }).catch(
+        (err) => console.warn('[org-workbench] search.submit failed', err),
+      );
+    };
   }
 </script>
 

apps/org-workbench/src/PeopleReveal.svelte

@@ -9,8 +9,8 @@
   import { onMount } from 'svelte';
   import PersonCard from './PersonCard.svelte';
   import AddPersonInline from './AddPersonInline.svelte';
-  import StagedPeople from './StagedPeople.svelte';
-  import { fetchOrgAffiliations, crawlTeam, type CrawledPerson } from './lib/org-client';
+  import { fetchOrgAffiliations } from './lib/org-client';
+  import { submitCrawl } from './lib/search-queue';
   import type { AffiliatedPerson } from './lib/types';
 
   let {
@@ -30,28 +30,21 @@
   let error = $state<string | null>(null);
   let expanded = $state<string | null>(null); // person_uuid
 
-  // didi's team crawl (v1.2) — staged candidates, never auto-written.
-  let crawling = $state(false);
+  // didi's team crawl — enqueued as an async job; candidates land as a card
+  // in the search-results rail (staging + accept gates live there now, per
+  // the Search-Results-Queue-Remote spec). The transient note is the only
+  // local feedback the door needs.
+  let queued = $state(false);
   let crawlError = $state<string | null>(null);
-  let crawlGen = $state(0); // bumps per crawl so StagedPeople remounts fresh
-  let staged = $state<{
-    people: CrawledPerson[];
-    filtered_note: string;
-    source_urls: string[];
-  } | null>(null);
 
   async function crawl() {
-    crawling = true;
     crawlError = null;
     try {
-      const r = await crawlTeam(org_slug, client);
-      staged = r;
-      crawlGen += 1;
-      if (!open) toggle();
+      await submitCrawl({ org_slug, display_name: orgName, target: 'team', client });
+      queued = true;
+      setTimeout(() => (queued = false), 5_000);
     } catch (err) {
       crawlError = err instanceof Error ? err.message : String(err);
-    } finally {
-      crawling = false;
     }
   }
 
@@ -74,10 +67,15 @@
   }
 
   function onEntityUpdated(e: Event) {
-    const detail = (e as CustomEvent).detail as { person_uuid?: string } | undefined;
-    if (detail?.person_uuid && loaded && people.some((p) => p.person_uuid === detail.person_uuid)) {
+    const detail = (e as CustomEvent).detail as { person_uuid?: string; org_slug?: string } | undefined;
+    if (!loaded) return;
+    if (detail?.person_uuid && people.some((p) => p.person_uuid === detail.person_uuid)) {
       void load();
+      return;
     }
+    // Org-shaped events cover the search rail's team accepts (TeamAccept
+    // writes person + affiliation, then broadcasts with the org_slug).
+    if (detail?.org_slug && detail.org_slug === org_slug) void load();
   }
 
   // A new org card means fresh people — reset and lazy-load on next reveal.
@@ -86,7 +84,6 @@
     people = [];
     loaded = false;
     expanded = null;
-    staged = null;
     crawlError = null;
     if (open) void load();
   });
@@ -108,15 +105,14 @@
       <button
         type="button"
         class="ow-plus"
-        title="didi: crawl the web for relevant team members (selection per the relevance brief)"
-        disabled={crawling}
+        title="didi: crawl the web for relevant team members (selection per the relevance brief) — lands in the search queue"
         onclick={crawl}
       >
-        {crawling ? '…' : '🤖'}
+        🤖
       </button>
     </span>
   </header>
-  {#if crawling}<p class="ow-empty">didi is crawling for team members — this takes a minute…</p>{/if}
+  {#if queued}<p class="ow-empty">team search queued — it lands in the 🔎 search rail when done; keep working</p>{/if}
   {#if crawlError}<div class="ow-error">{crawlError}</div>{/if}
 
   {#if open}
@@ -151,20 +147,6 @@
           {/each}
         </ul>
       {/if}
-      {#if staged}
-        {#key crawlGen}
-          <StagedPeople
-            {org_slug}
-            {orgName}
-            {client}
-            people={staged.people}
-            filtered_note={staged.filtered_note}
-            source_urls={staged.source_urls}
-            onchanged={load}
-            onclear={() => (staged = null)}
-          />
-        {/key}
-      {/if}
       <AddPersonInline {org_slug} {orgName} {client} onadded={load} />
     {/if}
   {/if}