diff --git a/tests/test_app.py b/tests/test_app.py
index cf0cecf..67d9ccc 100644
--- a/tests/test_app.py
+++ b/tests/test_app.py
@@ -3,6 +3,7 @@ import os
import tempfile
import threading
import time
+from pathlib import Path
import urllib.error
import unittest
from http.client import HTTPConnection
@@ -191,6 +192,13 @@ class BrowserOnlyAppTests(unittest.TestCase):
saved = server.db().execute("SELECT ai_probability,ai_recommendation,ai_reasoning FROM prospects WHERE id=1").fetchone()
self.assertEqual(tuple(saved), (84.0, "contact", "Active business with a clear website opportunity."))
+ def test_prospect_workspace_has_pipeline_and_view_switcher(self):
+ script = Path(__file__).resolve().parents[1].joinpath("web", "app.js").read_text()
+ self.assertIn("prospectBoard", script)
+ self.assertIn("prospectViewMode", script)
+ self.assertIn("data-board-status", script)
+ self.assertIn("Needs review", script)
+
def test_firecrawl_search_normalises_public_results(self):
response = {"success": True, "data": {"web": [{"title": "Cape Town Plumbing", "url": "https://plumber.example.co.za/", "description": "Local plumbing services"}]}}
with patch("api.server.http_json", return_value=response) as request, patch("api.server._safe_url", return_value=True):
diff --git a/web/app.js b/web/app.js
index 9cf7b14..7799bc3 100644
--- a/web/app.js
+++ b/web/app.js
@@ -10,7 +10,7 @@ let prospectScoreBand='all',prospectWebsiteFilter='all',prospectEmailFilter='all
const HIGH_POTENTIAL_SCORE=70;
async function api(path,opt={}){const headers={'Content-Type':'application/json',...(opt.headers||{})};if(csrfToken&&!headers['X-CSRF-Token'])headers['X-CSRF-Token']=csrfToken;const r=await fetch(path,{...opt,credentials:'same-origin',headers});const b=await r.json().catch(()=>({}));if(r.status===401&&!path.startsWith('/api/auth/')){currentUser=null;csrfToken='';renderAuth({setup_required:false});}if(!r.ok)throw Error(b.error||`Request failed (${r.status})`);return b}
let loadWarnings=[];
-async function refreshWorkerStatus(){const dot=$('sourceDot'),label=$('sourceLabel'),sub=$('sourceSub');if(!dot||!label||!sub)return;try{const health=await api('/api/health');const ready=Boolean(health.configured);dot.classList.toggle('offline',!ready);label.textContent=health.source==='browser'?'Browser discovery':'Google Maps worker';sub.textContent=ready?'Ready':'Not configured';}catch(error){dot.classList.add('offline');label.textContent='Discovery status';sub.textContent='Unavailable';}}
+async function refreshWorkerStatus(){const dot=$('sourceDot'),label=$('sourceLabel'),sub=$('sourceSub');if(!dot||!label||!sub)return;try{const health=await api('/api/health');const ready=Boolean(health.configured);dot.classList.toggle('offline',!ready);label.textContent=health.source==='browser'?'Browser discovery':health.source==='firecrawl'?'Firecrawl web search':'Google Maps worker';sub.textContent=ready?'Ready':'Not configured';}catch(error){dot.classList.add('offline');label.textContent='Discovery status';sub.textContent='Unavailable';}}
function date(v){if(!v)return'—';const d=new Date(v);return isNaN(d)?String(v):d.toLocaleString(undefined,{day:'numeric',month:'short',hour:'2-digit',minute:'2-digit'})}
function layout(title,sub,body,actions=''){ $('pageName').textContent=title; return `${body}` }
function empty(text){return `⌕ ${text}
`}
@@ -22,7 +22,7 @@ function prospectTabs(){const categories=[...new Set(prospects.map(prospectCateg
function prospectRows(){const q=($('prospectSearch')?.value||'').toLowerCase();return prospects.filter(p=>{const hay=[p.name,p.domain,p.search_category,p.category,p.address,p.emails].join(' ').toLowerCase();const score=effectiveScore(p);const websiteStatus=String(p.website_status||'unknown').toLowerCase();const tabMatch=activeProspectCategory==='all'?score>=HIGH_POTENTIAL_SCORE:prospectCategory(p)===activeProspectCategory;const scoreMatch=prospectScoreBand==='all'||(prospectScoreBand==='hot'&&score>=85)||(prospectScoreBand==='high'&&score>=70&&score<85)||(prospectScoreBand==='medium'&&score>=45&&score<70)||(prospectScoreBand==='low'&&score<45);const websiteMatch=prospectWebsiteFilter==='all'||(prospectWebsiteFilter==='missing'&&(!p.website||websiteStatus==='no_detected_website'))||(prospectWebsiteFilter==='broken'&&['broken','unreachable','error','timeout'].some(v=>websiteStatus.includes(v)))||(prospectWebsiteFilter==='healthy'&&websiteStatus==='healthy');const emailMatch=prospectEmailFilter==='all'||(prospectEmailFilter==='has_email'&&Boolean(String(p.emails||'').trim()))||(prospectEmailFilter==='no_email'&&!String(p.emails||'').trim());const reviewMatch=prospectReviewFilter==='all'||String(p.review_status||'pending')===prospectReviewFilter;return tabMatch&&scoreMatch&&websiteMatch&&emailMatch&&reviewMatch&&(!q||hay.includes(q))}).sort((a,b)=>effectiveScore(b)-effectiveScore(a)||String(a.name||'').localeCompare(String(b.name||'')))}
function prospectTable(){const rows=prospectRows();return `Prospect Website Email Potential ${rows.map(p=>{const score=effectiveScore(p);return `${esc(p.name)} ${esc(prospectCategory(p))} · ${esc(p.address||'')} ${esc((p.website_status||'unknown').replaceAll('_',' '))} ${p.website?`Open ↗ `:'No detected website '}${p.emails?`✉ ${esc(p.emails)} `:'Not found '} ${score} ${score>=85?'Hot':score>=70?'High':score>=45?'Medium':'Low'}${p.ai_checked_at?' · AI':''} ✦
CATALOGUE ${total} saved prospects
NEEDS REVIEW ${pending} awaiting your decision
HIGH OPPORTUNITY ${hot} score 75 or higher
PUBLIC EMAILS ${withEmail} evidence-backed contacts
NEXT ACTION Review your strongest leads Inspect the evidence before deciding whether to contact them.
Open explorer → ${strongest.map(p=>{const score=effectiveScore(p);return `${score} ${esc(p.name)} ${esc(p.website_status?.replaceAll('_',' ')||'unknown')} · ${esc(p.emails||'no public email')}${p.ai_checked_at?' · AI assessed':''} ›
${runs.slice(0,6).map(r=>`
#${r.id} · ${esc(r.query)} ${esc(r.status)} · ${r.added||0} added ${date(r.created_at)}
`).join('')||empty('No runs yet')}
NEW RUN Find potential customers Search Google Maps, deduplicate the catalogue, then enrich each result.
Email collection always on HOW IT WORKS
Evidence-first pipeline Search Maps worker finds public business listings. Enrich Website, HTTPS, DNS hints and public email checks run safely. Review You decide what is relevant before any contact. NEW RUN Find potential customers Search your selected discovery source, verify public websites, and review the results before contact.
Email collection always on HOW IT WORKS
Evidence-first pipeline Search Maps worker finds public business listings. Enrich Website, HTTPS, DNS hints and public email checks run safely. Review You decide what is relevant before any contact. ${prospectTabs()}
Click any prospect to review evidence, change its status, assess it with AI, or draft a tailored message. Review status is changed inside the prospect drawer.
${prospectTable()}
Run Status Results Started Source Actions ${runs.map(r=>{const active=['queued','running'].includes(r.status);const retry=['failed','cancelled'].includes(r.status)||r.recovery_state==='retryable';return `#${r.id} ${esc(r.query)} ${esc(r.status)} ${esc(r.stage||'')}${r.recovery_state?` · ${esc(r.recovery_state)}`:''} ${r.added||0} added / ${r.found||0} found ${date(r.created_at)} ${esc(r.source||'google_maps')} ${active?`Cancel `:''}${retry?`Retry `:''}Events
`)}
function logTabCount(tab,counts){return tab==='errors'?Number(counts?.errors||0):Number(counts?.[tab]||0)}
@@ -338,3 +338,46 @@ document.addEventListener('keydown',e=>{if(e.target.id==='messageRevisionInput'&
/* The first call above happens before this enhancement is defined. Run the
* non-destructive wrapper once so the panel exists before the first click. */
ensureMessageDialog(false);
+
+/* Prospect workspace v2: pipeline-first tracking with a compact alternative list. */
+let prospectViewMode=localStorage.getItem('prospect-view-mode')||'board';
+const PROSPECT_STAGES=[['pending','Needs review','Inspect evidence and decide'],['approved','Ready to contact','Approved for follow-up'],['contacted','Contacted','Already actioned'],['rejected','Not now','Kept out of the active queue']];
+function prospectDisplayRows(){
+ const q=String($('prospectSearch')?.value||'').trim().toLowerCase();
+ return prospects.filter(p=>{
+ const hay=[p.name,p.domain,p.search_category,p.category,p.address,p.emails,p.description].join(' ').toLowerCase();
+ const score=effectiveScore(p), site=String(p.website_status||'unknown').toLowerCase(), review=String(p.review_status||'pending');
+ const scoreOk=prospectScoreBand==='all'||(prospectScoreBand==='hot'&&score>=85)||(prospectScoreBand==='high'&&score>=70&&score<85)||(prospectScoreBand==='medium'&&score>=45&&score<70)||(prospectScoreBand==='low'&&score<45);
+ const siteOk=prospectWebsiteFilter==='all'||(prospectWebsiteFilter==='missing'&&(!p.website||site==='no_detected_website'))||(prospectWebsiteFilter==='broken'&&['broken','unreachable','error','timeout'].some(v=>site.includes(v)))||(prospectWebsiteFilter==='healthy'&&site==='healthy');
+ const emailOk=prospectEmailFilter==='all'||(prospectEmailFilter==='has_email'&&Boolean(String(p.emails||'').trim()))||(prospectEmailFilter==='no_email'&&!String(p.emails||'').trim());
+ const reviewOk=prospectReviewFilter==='all'||review===prospectReviewFilter;
+ return scoreOk&&siteOk&&emailOk&&reviewOk&&(!q||hay.includes(q));
+ }).sort((a,b)=>effectiveScore(b)-effectiveScore(a)||String(a.name||'').localeCompare(String(b.name||'')));
+}
+function prospectCard(p){
+ const score=effectiveScore(p),stage=String(p.review_status||'pending'),site=String(p.website_status||'unknown').replaceAll('_',' ');
+ return `${score} ${esc(p.source||'web')}
${esc(p.name||'Unnamed prospect')} ${esc(prospectCategory(p))}${p.address?` · ${esc(p.address)}`:''}
${site==='healthy'?'✓':'○'} ${esc(site)} ${p.emails?'✉ Public email':'✉ No email'}
Review details ${PROSPECT_STAGES.map(([key,label])=>`${label} `).join('')}
${PROSPECT_STAGES.map(([key,label,desc])=>{const items=rows.filter(p=>String(p.review_status||'pending')===key);return `
${items.map(prospectCard).join('')||`
No prospects here
`}
`}).join('')}
${rows.map(p=>{const score=effectiveScore(p),stage=String(p.review_status||'pending');return `${score} ${esc(p.name)} ${esc(prospectCategory(p))}${p.address?` · ${esc(p.address)}`:''} ${esc(String(p.website_status||'unknown').replaceAll('_',' '))} ${p.emails?'Has email':'No email'} ${esc(PROSPECT_STAGES.find(s=>s[0]===stage)?.[1]||'Needs review')} ›
`;
+}
+function prospectWorkspace(){
+ const rows=prospectDisplayRows();
+ const body=prospectViewMode==='list'?prospectCompactList():prospectBoard();
+ const pending=prospects.filter(p=>String(p.review_status||'pending')==='pending').length;
+ const hot=prospects.filter(p=>effectiveScore(p)>=85).length;
+ $('prospectTable').innerHTML=body;
+ const count=$('prospectResultCount');if(count)count.textContent=`Showing ${rows.length} of ${prospects.length}`;
+ const summary=$('prospectSummary');if(summary)summary.innerHTML=`${pending} need review${hot} high potential${prospects.filter(p=>p.emails).length} with public emailStart in Needs review . Open a card for evidence, then move it to the next stage. The list view is best for quick scanning.
ProspectOS
ProspectOS · public data only · manual review before contact ProspectOS
ProspectOS · public data only · manual review before contact