{children}

;\n}\n\napp.get(\"/\", async (c) => {\n const view = c.req.query(\"view\") || \"overview\";\n await ensureOutreachQueue();\n const q = c.req.query();\n const [leads,hunts,st,h,sources,settings,outreachRows,brief] = await Promise.all([\n listLeads({status:q.status||undefined,location:q.location||undefined,q:q.q||undefined,order:q.order||undefined}),\n listHunts(15),stats(),health(),listSources(),getHunterSettings(),listOutreach(\"pending\"),briefingStats()\n ]);\n const byStatus = st.byStatus as Record;\n const latest = st.latestHunt as Record|null;\n\n const top =

{view===\"overview\"?\"Command Center\":view===\"leads\"?\"Qualified Leads\":view===\"outreach\"?\"Outbound Command Center\":view===\"sources\"?\"Lead Sources\":view===\"activity\"?\"Hunt Activity\":\"System Settings\"}

Autonomous discovery → intelligence → approval → outreach

Refresh

;\n\n return c.html({top}\n {view===\"overview\" && <>\n

Your private AI outbound engine

Find real buyer signals, qualify them with Gemini, prepare personalized follow-up, and put every action behind your approval. WhatsApp API can stay off while you copy and send manually.

Gemini CONNECTEDDiscovery WORKINGApproval ONWhatsApp Manual Mode

{Number(st.totalLeads)}

Qualified leads

{brief.high}

High intent

{brief.medium}

Medium intent

{brief.pending}

Pending approvals

Morning briefing preview

New qualified leads	{brief.total}
High intent	{brief.high}
Medium intent	{brief.medium}
Low intent	{brief.low}
Pending approval	{brief.pending}

System status

Gemini	{String(h.gemini)}
Discovery	{String(h.discovery)}
Qualification	{String(h.qualification)}
Automation	CRON ACTIVE

Top buyers

{leads.length?{leads.slice(0,5).map((l)=>)}

Intent	Buyer	Requirement	Location	Source	Evidence
=80?\"high\":Number(l.intent_score)>=65?\"medium\":\"low\"}`}>{l.intent_score}	{l.buyer_name\|\|l.company\|\|\"Public buyer\"}	{l.requirement}	{l.location\|\|\"—\"}	{l.source\|\|\"web\"}	Open evidence

No qualified buyers yet.

}

\n }\n\n {view===\"leads\" &&

{leads.length?{leads.map((l:LeadRow)=>)}

Intent	Buyer	Requirement	Location	Evidence	Status	Copy/WhatsApp
{l.intent_score}	{l.buyer_name\|\|l.company\|\|\"Public buyer\"}	{l.requirement}	{l.location\|\|\"—\"}	Source {l.evidence_snippet}	{l.status}	{l.whatsapp_link?Open WhatsApp:\"No public number\"}

No qualified leads.

}

}\n\n {view===\"outreach\" &&

Pending approval

{outreachRows.length?{outreachRows.map(o=>)}

Tier	Buyer	Requirement	AI Draft	Action
{String(o.tier).toUpperCase()}	{String(o.buyer_name\|\|o.company\|\|\"Buyer\")}	{String(o.requirement\|\|\"\")}	{String(o.draft\|\|\"\")}	Evidence

No pending approvals.

}

Manual WhatsApp mode

WhatsApp API is intentionally pending. Approve a draft, copy it, open WhatsApp, paste and send. Nothing is sent automatically from this dashboard.

Business line: 0916 072 6032

{whatsappConfigured()?\"API CONNECTED\":\"API PENDING\"}

}\n\n {view===\"sources\" &&

Add and manage lead sources

{sources.map(s=>)}

Source	Category	Status	Action
{s.name\|\|s.url} {s.url}	{s.category\|\|\"custom\"}	{s.enabled?\"enabled\":\"disabled\"}

}\n\n {view===\"activity\" &&

Recent hunts

{hunts.map(x=>)}

#	Worker	Started	Hits	Candidates	New	Rejected	Status
{String(x.id)}	{String(x.triggered_by)}	{new Date(String(x.started_at)).toLocaleString()}	{String(x.hits_seen??0)}	{String(x.candidates??0)}	{String(x.new_leads??0)}	{String(x.rejected??0)}	{String(x.status)}

}\n\n {view===\"settings\" &&

Hunter settings

Business channels

Website: is-real-modern-furniture

Business WhatsApp: 0916 072 6032

WhatsApp API: {whatsappConfigured()?\"CONNECTED\":\"PENDING\"}

}\n );\n});\n\napp.post(\"/api/hunt\", async (c) => { await runHunt({source:\"manual\"}); return c.redirect(\"/?view=overview\"); });\napp.get(\"/api/leads\", async (c) => { const q=c.req.query(); const leads=await listLeads({status:q.status||undefined,location:q.location||undefined,q:q.q||undefined,order:q.order||undefined,limit:Number(q.limit??100)}); return c.json({ok:true,count:leads.length,leads}); });\napp.get(\"/api/leads/:id\", async c => { const lead=await getLead(Number(c.req.param(\"id\"))); return lead?c.json({ok:true,lead}):c.json({ok:false,error:\"not found\"},404); });\napp.post(\"/api/leads/:id/status\", async c => { const text=await c.req.text(); let status:string|null=null; const m=text.match(/(?:^|&)status=([^&]+)/); if(m) status=decodeURIComponent(m[1]); else {try{status=JSON.parse(text)?.status??null}catch{}} if(!status||!VALID_STATUSES.includes(status as never)) return c.json({ok:false,error:\"invalid status\"},400); await setLeadStatus(Number(c.req.param(\"id\")),status); return c.json({ok:true}); });\napp.get(\"/api/hunts\", async c=>c.json({ok:true,hunts:await listHunts()}));\napp.get(\"/api/stats\", async c=>c.json({ok:true,...await stats()}));\napp.get(\"/api/health\", async c=>c.json({ok:true,...await health()}));\napp.get(\"/api/outreach\", async c=>c.json({ok:true,queue:await listOutreach(c.req.query(\"status\")||\"pending\"),whatsappConfigured:whatsappConfigured()}));\napp.post(\"/api/outreach/:id/approve\", async c=>{await setApproval(Number(c.req.param(\"id\")),\"approved\");return c.redirect(\"/?view=outreach\")});\napp.post(\"/api/outreach/:id/reject\", async c=>{await setApproval(Number(c.req.param(\"id\")),\"rejected\");return c.redirect(\"/?view=outreach\")});\napp.post(\"/api/outreach/:id/send\", async c=>{const r=await sendApprovedWhatsApp(Number(c.req.param(\"id\")));if(!r.ok)return c.text(`Send failed: ${r.error}`,400);return c.redirect(\"/?view=outreach\")});\napp.get(\"/api/sources\", async c=>c.json({ok:true,sources:await listSources()}));\napp.post(\"/api/sources\", async c=>{const fd=await c.req.formData();await addSource(String(fd.get(\"url\")||\"\"),String(fd.get(\"name\")||\"\"),String(fd.get(\"category\")||\"custom\"));return c.redirect(\"/?view=sources\")});\napp.post(\"/api/sources/:id/toggle\", async c=>{const fd=await c.req.formData();await setSourceEnabled(Number(c.req.param(\"id\")),fd.get(\"enabled\")===\"on\");return c.redirect(\"/?view=sources\")});\napp.post(\"/api/sources/:id/remove\", async c=>{await removeSource(Number(c.req.param(\"id\")));return c.redirect(\"/?view=sources\")});\napp.get(\"/api/settings\", async c=>c.json({ok:true,settings:await getSettingsMap()}));\napp.post(\"/api/settings\", async c=>{const fd=await c.req.formData();for(const k of [\"min_lead_score\",\"locations\",\"categories\"]){const v=fd.get(k);if(v!=null)await setSetting(k,String(v))}await setSetting(\"bing_enabled\",fd.get(\"bing_enabled\")===\"true\"?\"true\":\"false\");await setSetting(\"gemini_search_enabled\",fd.get(\"gemini_search_enabled\")===\"true\"?\"true\":\"false\");return c.redirect(\"/?view=settings\")});\napp.get(\"/api/config\", async c=>c.json({ok:true,geminiConfigured:Boolean(Deno.env.get(\"GEMINI_API_KEY\")),businessWhatsApp:`https://wa.me/${BUSINESS_WHATSAPP}`,website:WEBSITE}));\napp.get(\"/source\", c=>c.redirect(parseVal().links.self.val));\nexport default app.fetch;\n","is-real-sales-os",[],[195],"5ef7367d-18c2-42f3-a667-5d3424895482","cron-source.ts","243df5da-a026-11f1-89cf-1607ee4eb77e",88,["D",1787622110233],"// cron-source.ts — SOURCE CRAWLER worker (independent CRON).\n// Crawls configured public sources only; stays under the free-tier run limit.\nimport { runHunt } from \"./lib/hunter.ts\";\nexport default async function () {\n const r = await runHunt({ source: \"cron:source-crawler\", layer: \"crawl\" });\n console.log(JSON.stringify({ worker: \"source-crawler\", run: r.status, ok: r.ok, huntId: r.huntId, hits: r.hitsSeen, newLeads: r.newLeads, error: r.error ?? null }));\n}\n",[],[205],"3a98ba4c-0f80-4130-ad7c-06ee3a6af491","cron-source-fast.ts","e5e21a8c-a0e8-11f1-9a3f-1607ee4eb77e",100,["D",1787705879446],"import { runHunt } from \"./lib/hunter.ts\";\n\n// Small automatic source-crawl slice designed for Val Town free-tier runtime.\nexport default async function runSourceSlice() {\n return await runHunt({ layer: \"crawl\" });\n}",[],[213],"c317031f-b1e3-4813-9284-1191e718fa6e","cron-source-batch-b.ts","308649c4-a0f2-11f1-9891-1607ee4eb77e",["D",1787709748164],"import { runHunt } from \"./lib/hunter.ts\";\n// Staggered crawler worker for the remaining source pool.\nawait runHunt({ layer: \"crawl\" });",[],[221],"ec82416e-db25-4010-95a3-62fbdb917ebd","cron-source-batch-a.ts","2bf7bd3e-a0f2-11f1-a60d-1607ee4eb77e",111,["D",1787709740518],"import { runHunt } from \"./lib/hunter.ts\";\n// Small automatic crawler batch; keeps free-tier executions short.\nawait runHunt({ layer: \"crawl\" });",[],[228],["D",1787622110301],[],[18],"21303525-798d-4d75-8ee9-aacbc2d17f68","cron-morning-briefing.ts","9bfa56da-a0ea-11f1-b066-1607ee4eb77e",109,["D",1787706492471],"import { ensureOutreachQueue, briefingStats } from \"./lib/outbound.ts\";\n\nexport default async function () {\n const created = await ensureOutreachQueue();\n const s = await briefingStats();\n console.log(JSON.stringify({\n worker: \"morning-briefing\",\n briefing: true,\n totalLeads: s.total,\n highIntent: s.high,\n mediumIntent: s.medium,\n lowIntent: s.low,\n pendingApprovals: s.pending,\n newOutreachDrafts: created,\n whatsappConfigured: Boolean(Deno.env.get(\"WHATSAPP_ACCESS_TOKEN\") && Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\")),\n }));\n}",[],[239],"bba0dadd-460b-43b9-9931-bd9899ee1347","README.md","01a02b72-4343-720e-b974-d4ca608b4c7d",15,["D",1787618025544],"# IS-REAL AI Sales OS — Market Hunter\n\nA production market-intelligence worker that continuously scans public web sources for\n**genuine furniture-buying opportunities in Nigeria** (Lagos, Ogun, Ibadan, Abuja), qualifies\nthem with Gemini, scores purchase intent, and stores them as actionable sales leads — with a\nlive dashboard and WhatsApp outreach links.\n\n**No fabricated buyers, contacts, prices, evidence, or opportunities. Ever.**\nAll contact details and values come only from public evidence surfaced by the hunter; anything\nnot publicly stated is stored as empty.\n\n## Live URL\n\nDashboard + API: **https://is-real-sales-os.val.run/**\n\n## What it does\n\n```mermaid\ngraph LR\n DDG[DuckDuckGo public search
classifieds / forums / tenders] -->|public hits| HUN\n HUN[Market Hunter
lib/hunter.ts] -->|evidence batches| GEM[Gemini
lib/gemini.ts]\n GEM -->|qualified + scored| SQL[(SQLite leads + hunts)]\n SQL --> WEB[Hono dashboard + API
index.ts]\n SQL --> WA[WhatsApp wa.me links
0916 072 6032]\n CRON[cron: 0 */4 * * *] --> HUN\n POST[POST /api/hunt] --> HUN\n```\n\n1. **Discover** — runs targeted searches of public web sources for buyer signals across\n product categories (sofas, wardrobes, beds, kitchen cabinets, office/hotel/salon/construction\n furniture). Surfaces only genuinely public pages.\n2. **Qualify & score** — batches evidence to Gemini, which returns strict JSON: opportunity\n requirement, location, optional contact fields (only when public), 0–100 intent score,\n optional opportunity value, confidence, and reject reasons.\n3. **Store** — qualified leads (intent ≥ 50) are written to the val's SQLite DB with a\n SHA-256 deduplication key; re-surfaced duplicates are counted and skipped, not re-stored.\n Hunt history is recorded too.\n4. **Act** — each lead carries a `wa.me` outreach link to IS-REAL's business WhatsApp\n 0916 072 6032, prefilled with an evidence-driven message referencing the prospect's\n requirement and IS-REAL's site.\n\n## Files\n\n| File | Type | Role |\n| --- | --- | --- |\n| `market-hunter.ts` | interval | Scheduled worker, runs on cron, logs structured results |\n| `lib/hunter.ts` | script | Orchestrator: discovery → Gemini → storage, SQLite schema, query helpers |\n| `lib/sources.ts` | script | Public-source discovery + parsing |\n| `lib/gemini.ts` | script | Gemini qualification/scoring (reads `GEMINI_API_KEY`) |\n| `index.ts` | http | Hono dashboard + API (manual hunt, leads, hunts, stats) |\n\n## Configuration (environment variables)\n\n- **`GEMINI_API_KEY`** (required) — Google AI Studio key used to qualify/score leads.\n Read securely at runtime via `Deno.env.get(\"GEMINI_API_KEY\")` — never hardcoded.\n- `MARKET_SOURCES` (optional) — comma-separated direct public URLs to hunt instead of search.\n- `MIN_INTENT_SCORE` (optional, default `50`) — minimum intent score to store a lead.\n- `QUERY_LIMIT` (optional, default `60`) — max search queries per hunt.\n\n👉 Add GEMINI_API_KEY here: https://www.val.town/x/isrealmodernfurniture/is-real-ai-sales-os/environment-variables?key=GEMINI_API_KEY\n\n## HTTP API\n\n- `GET /` — live dashboard (real leads + hunt history)\n- `POST /api/hunt` — run a market hunt now (manual trigger)\n- `GET /api/leads?status=&location=&q=&order=` — list leads\n- `GET /api/leads/:id` — single lead\n- `POST /api/leads/:id/status` — set lead status (form `status=new|contacted|quoted|closed|rejected`)\n- `GET /api/hunts` — hunt history\n- `GET /api/stats` — counts by status/location + latest hunt\n- `GET /api/config` — config status\n\n## Schedule\n\nThe worker runs automatically on a cron (every 4 hours, UTC). It can also be triggered from\nthe dashboard / `POST /api/hunt`, or run manually.\n\n## Verified behaviors\n\n- Gemini API key read via `Deno.env.get()` (secure). ✓\n- Real public-source discovery + Gemini qualification + scoring. ✓\n- SHA-256 deduplication; duplicates counted, not stored twice. ✓\n- Leads + hunt history persisted in project-scoped SQLite. ✓\n- Dashboard renders saved leads and latest hunt from the DB. ✓\n- WhatsApp outreach deep links use IS-REAL business line `09160726032` (`2349160726032`)\n and reference https://is-real-modern-furniture-gr29qv.v2.appdeploy.ai/ ✓\n- Strict no-fabrication rules enforced in the Gemini prompt and storage layer. ✓\n",[],[247],"85ec53ba-e244-4227-a1e2-f02cd8817b77","CHANGELOG.md","01a02b72-4343-720e-b974-d22eb6cc0255",["D",1787435303615],"# Changelog\n\n## 2026-07-30 — Immutable asset caching\n\nFrontend files are now served at version-addressed URLs\n(`/__immutable/45/frontend/index.tsx`) with\n`Cache-Control: public, max-age=31536000, immutable`, so repeat visits load the\nwhole client graph from the browser cache — roughly 3× faster (~665ms → ~157ms\nmeasured). Publishing your val bumps its version, which changes every URL, so\ncaches invalidate automatically. Old-version URLs return 404 after a publish\n(like Next.js build assets); a reload picks up the new version.\n\nWhat changed in the template:\n\n- `frontend/index.html` → [`frontend/root.tsx`](/frontend/root.tsx): the HTML\n shell is now JSX and stamps asset URLs with `immutableFileUrl()`\n- [`index.ts`](/index.ts): serves `Root()` at `/`, and one\n `app.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path))` route\n serves all frontend files\n\n### Upgrading an existing remix\n\nYour copy of this template doesn't update automatically. Two options:\n\n**Minimal (most of the benefit):** point both routes at `serveImmutableFile` —\nyour existing bare URLs redirect into versioned space, the new route serves\nthem, and the whole module graph gets cached (costs one redirect per page view):\n\n```ts\nimport { serveImmutableFile } from \"https://esm.town/v/std/utils/index.ts\";\n\napp.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path));\napp.get(\"/frontend/**/*\", (c) => serveImmutableFile(c.req.path)); // was serveFile\n```\n\n**Full upgrade (also removes the redirect):** three self-contained steps —\nno other files needed. Adjust the ``, favicon, and body of `Root()` to\nmatch your app's existing `index.html`, and stamp anything else your shell\nreferences directly (images, css) with `immutableFileUrl()`.\n\n1. Create `frontend/root.tsx`:\n\n```tsx\n/** @jsxImportSource npm:hono@4/jsx */\nimport { raw } from \"npm:hono@4/html\";\nimport { immutableFileUrl } from \"https://esm.town/v/std/utils/index.ts\";\n\n// The HTML shell for the app. It is never cached, so immutableFileUrl can stamp\n// the current val version into each asset URL — the browser caches those\n// immutably, and publishing the val changes the URLs, refetching exactly once.\nexport function Root() {\n return (\n <>\n {raw(\"<!DOCTYPE html>\")}\n <html lang=\"en\">\n <head>\n <meta charSet=\"UTF-8\" />\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\" />\n <title>React Hono Val Town Starter\n

History · cron-procurement.ts