Merge pull request #43 from lossless-group/feature/search-results-queue

Searches become async jobs — the search-results queue rail (spec Phases 1–3)

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}