{props.label}

{String(props.value ?? 0)}

\n );\n}\n\nfunction formatDate(value: unknown): string {\n if (!value) return \"—\";\n const date = new Date(String(value));\n if (Number.isNaN(date.getTime())) return String(value);\n return new Intl.DateTimeFormat(\"en-SA\", {\n timeZone: \"Asia/Riyadh\",\n dateStyle: \"medium\",\n timeStyle: \"short\",\n }).format(date);\n}\n\napp.get(\"/\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n await initSchema();\n const config = getRuntimeConfig();\n const data = await recentDashboardData();\n const counts = data.counts as Record;\n const runs = data.runs as Array>;\n const opportunities = data.opportunities as Array>;\n const replies = data.replies as Array>;\n\n return c.render(\n

Saudi Medical Agency Intelligence

Manufacturer opportunity control room

Research, qualification, staged outreach, supplier replies, quotations, and follow-ups for Saudi medical distribution.

\n {statusBadge(config.autoSendEnabled, \"Auto-send enabled\", \"Auto-send disabled\")}\n {statusBadge(config.gmailConfigured, \"Gmail active\", \"Gmail activation required\")}\n

\n\n {!config.gmailConfigured && (\n

One activation input remains

Add a Google app password to this project as GMAIL_PASS. Your normal Gmail password must not be used. Research may run, but no supplier email or inbox read will occur until this secret is present.

\n )}\n\n

\n \n \n \n \n \n \n \n

\n\n

Active schedules

Daily research batch

Every day at 9:00 AM Saudi time; German and disposable workers process durable tasks every 15 minutes until 12:48 PM.

Supplier response monitoring

Every day at 10:00 AM Saudi time; queued replies are analyzed every 15 minutes through the daily processing window.

\n\n

Manual controls

Manual runs use the same scoring, duplicate, territory, email, and commitment safeguards as scheduled runs.

\n \n \n \n \n \n \n

\n\n

Recent opportunities

Latest 50

\n \n \n \n {opportunities.length ? opportunities.map((item) => (\n \n \n \n \n \n \n \n \n \n )) : }\n \n

Manufacturer	Track	Score	Territory	Decision	Contacted	Reply
{String(item.legal_name \|\| \"—\")} {String(item.product_family \|\| \"\")}	{String(item.track \|\| \"—\")}	{String(item.precontact_score ?? \"—\")}	{String(item.territory_status \|\| \"—\")}	{String(item.decision \|\| \"—\")}	{formatDate(item.outreach_sent_at)}	{String(item.reply_status \|\| \"none\")}
No opportunity records yet.

\n\n

Recent automation runs

\n {runs.length ? runs.map((run) => (\n

{String(run.run_type)}{statusBadge(run.status === \"completed\", String(run.status), String(run.status))}

{formatDate(run.started_at)}

\n {run.error_text &&

{String(run.error_text)}

}\n

\n )) :

No runs yet.

}\n

\n\n

Recent supplier replies

\n {replies.length ? replies.map((reply) => (\n

{String(reply.legal_name || reply.from_address || \"Supplier\")}

{String(reply.subject || \"No subject\")}

{formatDate(reply.occurred_at)}

\n )) :

No supplier replies processed yet.

}\n

\n\n \n

\n );\n});\n\napp.get(\"/api/status\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n await initSchema();\n return c.json({ config: { ...getRuntimeConfig(), gmailPass: undefined }, data: await recentDashboardData() });\n});\n\napp.post(\"/run/weekly\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n const result = await startDailyResearchBatch();\n return c.json(result);\n});\n\napp.post(\"/run/german-worker\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n return c.json(await processResearchWorker(\"GERMAN_INSTRUMENTS\"));\n});\n\napp.post(\"/run/disposables-worker\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n return c.json(await processResearchWorker(\"DISPOSABLES\"));\n});\n\napp.post(\"/run/daily\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n return c.json(await scanSupplierInbox({ force: true }));\n});\n\napp.post(\"/run/reply-worker\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n return c.json(await processSupplierReplyWorker());\n});\n\napp.post(\"/test-gmail\", async (c) => {\n const auth = await requireOwner(c.req.raw);\n if (!auth.ok) return auth.response;\n return c.json(await testGmailConnection());\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\nexport default oauthMiddleware(app.fetch);\n","saudi-medical-agency",[158],"bb2d7457-8797-417d-b96a-a5154a046d86","README.md","b2d9b908-a7c1-11f1-b63a-1607ee4eb77e",162,["D",1788464283619],8,"# Saudi Medical Manufacturer Agency Intelligence\n\nA scheduled manufacturer-research, qualification, staged-outreach, supplier-reply, quotation, and follow-up system for Saudi medical distribution opportunities.\n\n## Active schedule\n\n- Daily research-batch starter: 09:00 Asia/Riyadh (`0 6 * * *` UTC).\n- German instrument research worker: every 15 minutes during the daily 09:01–12:46 Asia/Riyadh processing window.\n- Disposable-product research worker: every 15 minutes during the daily 09:02–12:47 Asia/Riyadh processing window.\n- Supplier inbox scan and due follow-ups: every day at 10:00 Asia/Riyadh (`0 7 * * *` UTC).\n- Supplier-reply analysis worker: every 15 minutes during the daily 10:03–18:48 Asia/Riyadh processing window.\n\nThe 09:00 starter creates a durable daily batch. Each research worker processes exactly one bounded AI task per execution. The 10:00 inbox job scans and queues replies; the reply worker analyzes one email and its attachments per execution. This avoids the runtime's one-minute execution ceiling without losing progress.\n\n## Supplier tracks\n\n1. Actual German reusable surgical-instrument manufacturers, prioritizing Tuttlingen and comparable manufacturing clusters.\n2. Actual manufacturers of electrosurgical disposables, operating-room disposables, absorbent surgical products, custom procedure packs, wound care, CSSD consumables, and defensibly differentiated high-volume hospital products.\n\n## Staged outreach\n\nThe first email is deliberately short. It verifies Saudi territory, obtains an initial catalogue and price indication, confirms basic MOQ/origin/lead-time/sample terms, and reaches the right export contact. Detailed commercial and technical diligence begins only after positive supplier interest.\n\n## Automatic safeguards\n\n- Actual manufacturer and target-product verification.\n- Conservative 100-point pre-contact scoring; automatic contact threshold is 75.\n- Confirmed exclusive Saudi representation, a direct Saudi office, or local manufacturing blocks automatic contact unless additional-channel evidence exists.\n- Official company-domain recipient required; no free-email recipients.\n- Ninety-day duplicate control and maximum five first contacts per daily batch.\n- Two to four questions and 120–195 words in first contact.\n- One follow-up after five Saudi business days and one final follow-up after ten.\n- No order, payment, exclusivity, registration-spend, annual-target, bank-information, or sales-volume commitment.\n- Supplier replies and attachments are parsed before clarification questions are drafted.\n- Routine clarification is limited to six grouped factual questions.\n- Numeric prices are labelled by issuer/provenance and converted to SAR for preliminary landed-cost and gross-margin screening.\n- Canonical like-for-like electrosurgical-pad configuration keys control the private BOVIE comparison.\n- Private commercial benchmarks are stored in project-scoped SQLite, not in public source code.\n- Research and reply tasks are durable, retried once, and protected against uncontrolled email resend after an interrupted SMTP operation.\n\n## Gmail activation\n\n`GMAIL_USER` is configured. Add a Google app password as `GMAIL_PASS` in the project's Environment Variables. Do not use the normal Gmail password. Until this secret exists, the system does not read or send Gmail.\n\n## Main files\n\n- `jobs/weekly.ts` — daily 09:00 research-batch starter.\n- `jobs/german-worker.ts` — German-instrument discovery and qualification worker.\n- `jobs/disposables-worker.ts` — disposable-manufacturer discovery and qualification worker.\n- `jobs/daily.ts` — daily inbox scan and due follow-ups.\n- `jobs/reply-worker.ts` — queued supplier-reply and quotation-analysis worker.\n- `dashboard.tsx` — owner-authenticated control room.\n- `lib/researchQueue.ts` — durable manufacturer-research state machine.\n- `lib/inboxScan.ts` — Gmail scan, reply matching, queuing, and follow-up logic.\n- `lib/replyWorker.ts` — reply analysis, landed-cost calculations, safe clarification, and decision brief.\n- `lib/ai.ts` — current web research and structured analysis.\n- `lib/email.ts` — Gmail SMTP/IMAP and PDF, spreadsheet, Word, text, and image attachment extraction.\n- `lib/pricing.ts` — cached FX, landed cost, VAT, gross profit, margin, receivable exposure, and private benchmark logic.\n- `lib/safeguards.ts` — qualification, territory, contact, duplicate, email, and commitment gates.\n- `lib/db.ts` — project-scoped SQLite schema, audit ledger, queues, and idempotency controls.\n- `smoke.ts` — non-destructive integration smoke test.\n- `diagnostics/reply-worker.ts` — self-cleaning dry-run of a realistic positive supplier quotation.\n\n## Dashboard\n\n`https://saudi-medical-agency.val.run/`\n\nOnly the configured Val Town owner username is permitted after login.\n\n\n## Source visibility\n\nThe current Val Town account has no remaining private-project allowance, so this project’s source code is public. No Gmail credential, personal outreach identity, supplier ledger, or confidential BOVIE commercial benchmark is stored in source code; those values live in environment variables or project-scoped SQLite. The dashboard itself still applies owner-only Val Town login inside the application. Upgrade the Val Town plan before changing the project source to private.\n",[167],"a21a10f4-be06-46ed-9d30-94ac37e4dad2","lib","b71ac322-a7c1-11f1-ac68-1607ee4eb77e",2,["D",1788458586756],"directory",[175],"ae2ef0c1-1322-4244-aa5a-8c468a611286","jobs","bb71376c-a7c1-11f1-bc0c-1607ee4eb77e",3,["D",1788458594032],[182],"7d290c3f-5e3b-490b-bc04-5bee3140b462","diagnostics","1756dd86-a7c5-11f1-9f51-1607ee4eb77e",49,["D",1788460036703],[188],"pulls","branches","forks","envVars",{"_200":202,"_203":62},"connections",{"_200":62,"_201":62},"count","unfilledCount",22,"emptyCount",{"_42":187,"_31":188,"_29":189,"_140":-5,"_40":41,"_39":190,"_142":58,"_37":458,"_13":62,"_33":179,"_35":-5,"_23":24,"_147":-5,"_238":459,"_26":460},{"_42":450,"_31":451,"_29":452,"_140":189,"_40":41,"_39":453,"_142":58,"_37":454,"_13":62,"_33":145,"_35":455,"_23":24,"_147":-5,"_238":456,"_26":457},{"_42":442,"_31":443,"_29":444,"_140":189,"_40":41,"_39":445,"_142":58,"_37":446,"_13":62,"_33":145,"_35":447,"_23":24,"_147":-5,"_238":448,"_26":449},{"_42":434,"_31":435,"_29":436,"_140":189,"_40":41,"_39":437,"_142":58,"_37":438,"_13":62,"_33":145,"_35":439,"_23":24,"_147":-5,"_238":440,"_26":441},{"_42":427,"_31":369,"_29":428,"_140":189,"_40":41,"_39":429,"_142":58,"_37":430,"_13":263,"_33":145,"_35":431,"_23":24,"_147":-5,"_238":432,"_26":433},{"_42":181,"_31":182,"_29":183,"_140":-5,"_40":41,"_39":184,"_142":58,"_37":424,"_13":62,"_33":179,"_35":-5,"_23":24,"_147":-5,"_238":425,"_26":426},{"_42":417,"_31":418,"_29":419,"_140":183,"_40":41,"_39":420,"_142":58,"_37":421,"_13":62,"_33":34,"_35":389,"_23":24,"_147":-5,"_238":422,"_26":423},{"_42":410,"_31":411,"_29":412,"_140":183,"_40":41,"_39":413,"_142":58,"_37":414,"_13":62,"_33":34,"_35":381,"_23":24,"_147":-5,"_238":415,"_26":416},{"_42":406,"_31":32,"_29":30,"_140":183,"_40":41,"_39":14,"_142":58,"_37":407,"_13":62,"_33":34,"_35":36,"_23":24,"_147":-5,"_238":408,"_26":409},{"_42":399,"_31":400,"_29":401,"_140":183,"_40":41,"_39":402,"_142":58,"_37":403,"_13":62,"_33":34,"_35":365,"_23":24,"_147":-5,"_238":404,"_26":405},{"_42":392,"_31":393,"_29":394,"_140":183,"_40":41,"_39":395,"_142":24,"_37":396,"_13":144,"_33":34,"_35":36,"_23":24,"_147":-5,"_238":397,"_26":398},{"_42":384,"_31":385,"_29":386,"_140":183,"_40":41,"_39":387,"_142":24,"_37":388,"_13":177,"_33":34,"_35":389,"_23":24,"_147":-5,"_238":390,"_26":391},{"_42":376,"_31":377,"_29":378,"_140":183,"_40":41,"_39":379,"_142":24,"_37":380,"_13":177,"_33":34,"_35":381,"_23":24,"_147":-5,"_238":382,"_26":383},{"_42":368,"_31":369,"_29":370,"_140":183,"_40":41,"_39":371,"_142":24,"_37":372,"_13":177,"_33":34,"_35":373,"_23":24,"_147":-5,"_238":374,"_26":375},{"_42":360,"_31":361,"_29":362,"_140":183,"_40":41,"_39":363,"_142":24,"_37":364,"_13":144,"_33":34,"_35":365,"_23":24,"_147":-5,"_238":366,"_26":367},{"_42":174,"_31":175,"_29":176,"_140":-5,"_40":41,"_39":177,"_142":58,"_37":357,"_13":62,"_33":179,"_35":-5,"_23":24,"_147":-5,"_238":358,"_26":359},{"_42":348,"_31":349,"_29":350,"_140":176,"_40":41,"_39":351,"_142":24,"_37":352,"_13":353,"_33":145,"_35":354,"_23":24,"_147":-5,"_238":355,"_26":356},{"_42":340,"_31":341,"_29":342,"_140":176,"_40":41,"_39":343,"_142":24,"_37":344,"_13":263,"_33":145,"_35":345,"_23":24,"_147":-5,"_238":346,"_26":347},{"_42":332,"_31":333,"_29":334,"_140":176,"_40":41,"_39":335,"_142":24,"_37":336,"_13":177,"_33":145,"_35":337,"_23":24,"_147":-5,"_238":338,"_26":339},{"_42":324,"_31":325,"_29":326,"_140":176,"_40":41,"_39":327,"_142":58,"_37":328,"_13":62,"_33":145,"_35":329,"_23":24,"_147":-5,"_238":330,"_26":331},{"_42":315,"_31":316,"_29":317,"_140":176,"_40":41,"_39":318,"_142":24,"_37":319,"_13":320,"_33":145,"_35":321,"_23":24,"_147":-5,"_238":322,"_26":323},{"_42":307,"_31":308,"_29":309,"_140":176,"_40":41,"_39":310,"_142":24,"_37":311,"_13":62,"_33":145,"_35":312,"_23":24,"_147":-5,"_238":313,"_26":314},{"_42":299,"_31":300,"_29":301,"_140":176,"_40":41,"_39":302,"_142":24,"_37":303,"_13":62,"_33":145,"_35":304,"_23":24,"_147":-5,"_238":305,"_26":306},{"_42":291,"_31":292,"_29":293,"_140":176,"_40":41,"_39":294,"_142":24,"_37":295,"_13":154,"_33":145,"_35":296,"_23":24,"_147":-5,"_238":297,"_26":298},{"_42":283,"_31":284,"_29":285,"_140":176,"_40":41,"_39":286,"_142":24,"_37":287,"_13":263,"_33":145,"_35":288,"_23":24,"_147":-5,"_238":289,"_26":290},{"_42":275,"_31":276,"_29":277,"_140":176,"_40":41,"_39":278,"_142":24,"_37":279,"_13":263,"_33":145,"_35":280,"_23":24,"_147":-5,"_238":281,"_26":282},{"_42":267,"_31":268,"_29":269,"_140":176,"_40":41,"_39":270,"_142":24,"_37":271,"_13":177,"_33":145,"_35":272,"_23":24,"_147":-5,"_238":273,"_26":274},{"_42":258,"_31":259,"_29":260,"_140":176,"_40":41,"_39":261,"_142":24,"_37":262,"_13":263,"_33":145,"_35":264,"_23":24,"_147":-5,"_238":265,"_26":266},{"_42":250,"_31":251,"_29":252,"_140":176,"_40":41,"_39":253,"_142":24,"_37":254,"_13":177,"_33":145,"_35":255,"_23":24,"_147":-5,"_238":256,"_26":257},{"_42":166,"_31":167,"_29":168,"_140":-5,"_40":41,"_39":169,"_142":24,"_37":247,"_13":171,"_33":20,"_35":172,"_23":24,"_147":-5,"_238":248,"_26":249},{"_42":157,"_31":158,"_29":56,"_140":-5,"_40":41,"_39":159,"_142":24,"_37":244,"_13":161,"_33":162,"_35":163,"_23":24,"_147":164,"_238":245,"_26":246},{"_42":149,"_31":150,"_29":151,"_140":-5,"_40":41,"_39":152,"_142":24,"_37":241,"_13":154,"_33":145,"_35":155,"_23":24,"_147":-5,"_238":242,"_26":243},{"_42":137,"_31":138,"_29":139,"_140":-5,"_40":41,"_39":141,"_142":24,"_37":237,"_13":144,"_33":145,"_35":146,"_23":24,"_147":-5,"_238":239,"_26":240},["D",1788462648469],"children",[],[138],["D",1788459487849],[],[150],["D",1788464241929],[],[158],["D",1788464283619],[],[167],"53ffab2f-126a-42da-a086-097b8decad6a","types.ts","cd366ad0-a7c1-11f1-a3c3-1607ee4eb77e",23,["D",1788459276378],"export type Track = \"GERMAN_INSTRUMENTS\" | \"DISPOSABLES\";\n\nexport type TerritoryStatus =\n | \"Confirmed Saudi territory open\"\n | \"Manufacturer actively seeking Saudi distributor\"\n | \"Strong indication territory is open\"\n | \"No public Saudi representative identified\"\n | \"Existing Saudi representation, exclusivity unknown\"\n | \"Existing Saudi non-exclusive distributor\"\n | \"Confirmed exclusive Saudi distributor\"\n | \"Direct Saudi office\"\n | \"Saudi local-manufacturing partnership\"\n | \"Distributor change identified\"\n | \"Evidence insufficient\";\n\nexport type Decision =\n | \"CONTACTED — HIGH-PRIORITY OPPORTUNITY\"\n | \"CONTACTED — PRICE VERIFICATION REQUIRED\"\n | \"CONTACTED — TERRITORY VERIFICATION REQUIRED\"\n | \"REQUEST SAMPLES\"\n | \"REQUEST FORMAL QUOTATION\"\n | \"NEGOTIATE SAUDI EXCLUSIVITY\"\n | \"DISCUSS OEM/PRIVATE LABEL\"\n | \"MONITOR\"\n | \"BENCHMARK ONLY\"\n | \"REJECT — TERRITORY OCCUPIED\"\n | \"REJECT — PRICE NOT COMPETITIVE\"\n | \"REJECT — INSUFFICIENT QUALITY\"\n | \"REJECT — INADEQUATE DOCUMENTATION\"\n | \"REJECT — TOO COMMODITIZED\";\n\nexport interface EvidenceSource {\n title: string;\n url: string;\n claim: string;\n sourceType: \"official_manufacturer\" | \"regulator\" | \"government\" | \"authorized_distributor\" | \"trade_show\" | \"professional_network\" | \"other\";\n}\n\nexport interface CandidateSeed {\n legalName: string;\n brand: string;\n country: string;\n city: string;\n website: string;\n domain: string;\n track: Track;\n productFamilies: string[];\n discoveryReason: string;\n initialEvidence: EvidenceSource[];\n}\n\nexport interface ScoreBreakdown {\n manufacturerAndProductFit: number;\n publicRegulatoryCredibility: number;\n saudiTerritoryPotential: number;\n differentiationOrCommercialAdvantage: number;\n recurringSaudiDemand: number;\n exportCredibilityAndSupplyReliability: number;\n officialContactQuality: number;\n}\n\nexport interface QualifiedCandidate extends CandidateSeed {\n actualManufacturer: boolean;\n actualManufacturerConfidence: number;\n manufacturingLocations: string[];\n countryOfOriginNotes: string;\n exactProducts: string[];\n modelNumbers: string[];\n regulatoryEvidence: string[];\n qualityAdvantage: string;\n commercialAdvantage: string;\n saudiDistributor: string;\n saudiAuthorizedRepresentative: string;\n sfdaEvidence: string;\n nupcoEvidence: string;\n gccRepresentation: string;\n exclusivityEvidence: string;\n territoryStatus: TerritoryStatus;\n territoryConfidence: number;\n recipientName: string;\n recipientRole: string;\n recipientEmail: string;\n contactSourceUrl: string;\n score: ScoreBreakdown;\n risks: string[];\n evidence: EvidenceSource[];\n}\n\nexport interface QuoteLine {\n modelNumber: string;\n description: string;\n configurationKey: string;\n unitPrice: number;\n currency: string;\n incoterm: string;\n unitsInPriceBasis: number;\n unitsPerBox: number;\n priceSourceClassification: \"official_manufacturer_quotation\" | \"official_distributor_quotation\" | \"saudi_distributor_quotation\" | \"public_saudi_selling_price\" | \"government_or_tender_price\" | \"international_reseller_price\" | \"estimated_price\" | \"unverified_market_indication\";\n}\n\n\nexport interface SupplierReplyAnalysis {\n classification: \"positive\" | \"neutral\" | \"negative\" | \"territory_occupied\" | \"wrong_contact\" | \"automatic\" | \"unrelated\";\n confidence: number;\n summary: string;\n territoryStatement: string;\n priceSourceClassification: \"official_manufacturer_quotation\" | \"official_distributor_quotation\" | \"saudi_distributor_quotation\" | \"public_saudi_selling_price\" | \"government_or_tender_price\" | \"international_reseller_price\" | \"estimated_price\" | \"unverified_market_indication\" | \"not_provided\";\n quoteLines: QuoteLine[];\n extracted: {\n currencies: string[];\n incoterms: string[];\n modelNumbers: string[];\n prices: string[];\n moq: string;\n boxQuantities: string;\n leadTime: string;\n shelfLife: string;\n countryOfOrigin: string;\n certifications: string[];\n sampleTerms: string;\n exclusivityTerms: string;\n paymentTerms: string;\n };\n missingCriticalInformation: string[];\n prohibitedCommitmentDetected: boolean;\n recommendedDecision: Decision;\n shouldSendRoutineClarification: boolean;\n clarificationSubject: string;\n clarificationBody: string;\n}\n\nexport interface ContactIdentity {\n name: string;\n company: string;\n phone: string;\n email: string;\n country: string;\n}\n\nexport interface RunSummary {\n reviewed: number;\n qualified: number;\n contacted: number;\n rejected: number;\n repliesProcessed?: number;\n notificationsSent: number;\n notes: string[];\n}\n",[],[175,251],"271adaca-8c2d-4410-8e97-5c793dc3166f","templates.ts","57084cec-a7c2-11f1-a17a-1607ee4eb77e",43,["D",1788459751867],6,"import type { ContactIdentity, QualifiedCandidate } from \"./types.ts\";\n\nfunction compact(items: string[], max = 4): string {\n return items.map((item) => item.trim()).filter(Boolean).slice(0, max).join(\", \");\n}\n\nfunction greeting(name: string): string {\n return name.trim() ? `Dear ${name.trim()},` : \"Dear Export Team,\";\n}\n\nfunction signature(identity: ContactIdentity): string {\n return `${identity.name}\\n${identity.company}\\n${identity.phone}\\n${identity.email}\\n${identity.country}`;\n}\n\nexport function buildFirstContact(candidate: QualifiedCandidate, identity: ContactIdentity): { subject: string; body: string } {\n const products = compact(candidate.exactProducts.length ? candidate.exactProducts : candidate.productFamilies);\n const rawReason = (candidate.qualityAdvantage || candidate.commercialAdvantage || candidate.discoveryReason).trim();\n const reason = rawReason.length > 180 ? `${rawReason.slice(0, 177)}...` : rawReason;\n\n if (candidate.track === \"GERMAN_INSTRUMENTS\") {\n return {\n subject: `Saudi Arabia Distribution Partnership – ${candidate.brand || candidate.legalName} Surgical Instruments`,\n body: `${greeting(candidate.recipientName)}\n\nMy name is ${identity.name} from ${identity.company} in Saudi Arabia.\n\nWe are evaluating a long-term Saudi distribution partnership for your ${products}. We selected your company because ${reason}.\n\nPlease confirm:\n\n1. Is Saudi Arabia available for an exclusive or non-exclusive partnership, and do you have a Saudi distributor or authorized representative?\n2. Can you share the relevant instrument catalogue and an initial export or distributor-price list?\n3. What are the manufacturing location, product-family country of origin, general MOQ, lead time, and sample terms?\n4. Who is the correct export or international-sales contact for the next evaluation stage?\n\nWe seek dependable quality, workable export pricing, and serious Saudi market interest. This preliminary inquiry creates no purchase, volume, registration, or exclusivity commitment.\n\nBest regards,\n\n${signature(identity)}`,\n };\n }\n\n return {\n subject: `Saudi Arabia Distribution Opportunity – ${candidate.brand || candidate.legalName} ${compact(candidate.productFamilies, 2)}`,\n body: `${greeting(candidate.recipientName)}\n\nMy name is ${identity.name} from ${identity.company} in Saudi Arabia.\n\nWe are evaluating a long-term Saudi distribution partnership for your ${products}. We selected your company because ${reason}.\n\nPlease confirm:\n\n1. Is Saudi Arabia available for an exclusive or non-exclusive partnership, and do you have a Saudi distributor or authorized representative?\n2. Can you share the relevant catalogue and an initial export or distributor-price indication?\n3. What are the general MOQ, country of origin, lead time, shelf life, and sample terms?\n4. Who is the correct export or international-sales contact for the next evaluation stage?\n\nWe aim to build a serious Saudi market position, not make a one-time purchase. This preliminary inquiry creates no purchase, volume, registration, or exclusivity commitment.\n\nBest regards,\n\n${signature(identity)}`,\n };\n}\n\nexport function buildFollowup(\n opportunity: Record,\n identity: ContactIdentity,\n final: boolean,\n): { subject: string; body: string } {\n const manufacturer = String(opportunity.brand || opportunity.legal_name || \"Manufacturer\");\n const products = String(opportunity.product_family || \"products\");\n const name = String(opportunity.recipient_name || \"\");\n if (final) {\n return {\n subject: `Final Follow-up: Saudi Arabia Distribution Opportunity – ${manufacturer}`,\n body: `${greeting(name)}\n\nI am making a final follow-up regarding the potential distribution of your ${products} in Saudi Arabia.\n\nIf Saudi Arabia is currently available, please share the appropriate export contact, distributor terms, initial price list, and relevant product documentation.\n\nIf the territory is already assigned, a brief confirmation would also be appreciated so we can update our records.\n\nBest regards,\n\n${signature(identity)}`,\n };\n }\n return {\n subject: `Follow-up: Saudi Arabia Distribution Opportunity – ${manufacturer}`,\n body: `${greeting(name)}\n\nI am following up on my previous message regarding a potential Saudi distribution partnership for ${products}.\n\nWe remain interested in evaluating your product range, initial distributor pricing, Saudi territory status, regulatory-document availability, and sample availability.\n\nPlease let me know the appropriate person to coordinate with if this inquiry should be directed to another department.\n\nBest regards,\n\n${signature(identity)}`,\n };\n}\n\nexport function buildContactNotification(\n candidate: QualifiedCandidate,\n score: number,\n subject: string,\n body: string,\n): string {\n const sources = candidate.evidence.map((source, index) => `${index + 1}. ${source.claim}\\n ${source.url}`).join(\"\\n\");\n return `MANUFACTURER CONTACTED\n\nManufacturer: ${candidate.legalName}\nCountry: ${candidate.country}\nProducts: ${compact(candidate.exactProducts, 6)}\nWhy it qualified: ${candidate.qualityAdvantage || candidate.commercialAdvantage}\nSaudi representation: ${candidate.territoryStatus}; ${candidate.saudiDistributor || \"no confirmed distributor identified\"}\nRecipient: ${candidate.recipientName || \"Export team\"} — ${candidate.recipientRole || \"Official company contact\"} — ${candidate.recipientEmail}\nOpportunity score: ${score}/100\nNext action: Await territory confirmation, catalogue, initial pricing, MOQ, lead time, and sample terms.\n\nEXACT SUBJECT\n${subject}\n\nEXACT EMAIL SENT\n${body}\n\nSOURCES AND EVIDENCE\n${sources}`;\n}\n\nexport function buildReplyNotification(\n manufacturer: string,\n sender: string,\n subject: string,\n analysis: Record,\n clarificationSent: boolean,\n): string {\n const extracted = analysis.extracted as Record | undefined;\n const pricing = Array.isArray(analysis.pricingEstimates)\n ? (analysis.pricingEstimates as Array>).slice(0, 8).map((item) => {\n if (item.error) return `${String(item.modelNumber || \"Unknown model\")}: pricing error — ${String(item.error)}`;\n const comparison = item.bovieComparison as Record | undefined;\n return [\n `${String(item.modelNumber || item.description || \"Quoted item\")}`,\n `source=${String(item.sourceClassification || \"unknown\")}`,\n `landed ex-VAT SAR ${String(item.estimatedLandedCostExVatSar ?? \"n/a\")}`,\n `cash incl. VAT SAR ${String(item.cashRequirementIncludingVatSar ?? \"n/a\")}`,\n `recommended sale ex-VAT SAR ${String(item.recommendedSellingPriceExVatSar ?? \"n/a\")}`,\n `gross profit SAR ${String(item.grossProfitPerUnitSar ?? \"n/a\")}`,\n `margin ${String(item.grossMarginPct ?? \"n/a\")}%`,\n `status=${String(item.completeness || \"unknown\")}`,\n comparison ? `BOVIE like-for-like 15% threshold passed=${String(comparison.passes15PercentAgainstEntireRange)}` : \"\",\n ].filter(Boolean).join(\"; \");\n }).join(\"\\n\")\n : \"No numeric quote lines available.\";\n return `SUPPLIER REPLY RECEIVED\n\nManufacturer: ${manufacturer}\nSender: ${sender}\nSubject: ${subject}\nClassification: ${analysis.classification ?? \"unknown\"}\nSummary: ${analysis.summary ?? \"\"}\nTerritory statement: ${analysis.territoryStatement ?? \"Not confirmed\"}\nPrice classification: ${analysis.priceSourceClassification ?? \"not_provided\"}\nPrices: ${JSON.stringify(extracted?.prices ?? [])}\nIncoterms: ${JSON.stringify(extracted?.incoterms ?? [])}\nMOQ: ${String(extracted?.moq ?? \"Not provided\")}\nLead time: ${String(extracted?.leadTime ?? \"Not provided\")}\nMissing information: ${JSON.stringify(analysis.missingCriticalInformation ?? [])}\n\nPRICING AND LANDED-COST SCREEN\n${pricing}\n\nDecision: ${analysis.recommendedDecision ?? \"MONITOR\"}\nRoutine clarification sent: ${clarificationSent ? \"Yes\" : \"No\"}`;\n}\n",[],[175,259],"250e78b8-c29c-4551-a3f9-e5cda092d44f","safeguards.ts","4835665a-a7c2-11f1-a50a-1607ee4eb77e",71,["D",1788460515013],"import type { QualifiedCandidate, ScoreBreakdown } from \"./types.ts\";\n\nconst FREE_EMAIL_DOMAINS = new Set([\n \"gmail.com\", \"googlemail.com\", \"yahoo.com\", \"outlook.com\", \"hotmail.com\",\n \"live.com\", \"icloud.com\", \"aol.com\", \"proton.me\", \"protonmail.com\",\n]);\n\nconst BLOCKED_TERRITORIES = new Set([\n \"Confirmed exclusive Saudi distributor\",\n \"Direct Saudi office\",\n \"Saudi local-manufacturing partnership\",\n]);\n\nexport function normalizeDomain(input: string): string {\n const raw = input.trim().toLowerCase();\n if (!raw) return \"\";\n try {\n const url = raw.includes(\"://\") ? new URL(raw) : new URL(`https://${raw}`);\n return url.hostname.replace(/^www\\./, \"\");\n } catch {\n return raw.replace(/^www\\./, \"\").split(\"/\")[0];\n }\n}\n\nexport function emailDomain(email: string): string {\n return normalizeDomain(email.split(\"@\")[1] ?? \"\");\n}\n\nexport function totalPrecontactScore(score: ScoreBreakdown): number {\n const capped = [\n Math.min(25, Math.max(0, score.manufacturerAndProductFit)),\n Math.min(15, Math.max(0, score.publicRegulatoryCredibility)),\n Math.min(20, Math.max(0, score.saudiTerritoryPotential)),\n Math.min(15, Math.max(0, score.differentiationOrCommercialAdvantage)),\n Math.min(10, Math.max(0, score.recurringSaudiDemand)),\n Math.min(10, Math.max(0, score.exportCredibilityAndSupplyReliability)),\n Math.min(5, Math.max(0, score.officialContactQuality)),\n ];\n return Math.round(capped.reduce((sum, value) => sum + value, 0));\n}\n\nexport function validateCandidate(candidate: QualifiedCandidate): string[] {\n const reasons: string[] = [];\n candidate.domain = normalizeDomain(candidate.domain || candidate.website);\n const contactDomain = emailDomain(candidate.recipientEmail);\n\n if (!candidate.actualManufacturer || candidate.actualManufacturerConfidence < 0.7) {\n reasons.push(\"Actual manufacturer status is not sufficiently verified\");\n }\n if (!candidate.domain || !candidate.website) reasons.push(\"Official website/domain is missing\");\n if (!candidate.productFamilies?.length || !candidate.exactProducts?.length) reasons.push(\"Target-product fit is insufficient\");\n if (!candidate.regulatoryEvidence?.length) reasons.push(\"No credible public regulatory evidence\");\n if (BLOCKED_TERRITORIES.has(candidate.territoryStatus)) reasons.push(`Territory blocked: ${candidate.territoryStatus}`);\n if (!candidate.recipientEmail || !candidate.recipientEmail.includes(\"@\")) reasons.push(\"No legitimate recipient email\");\n if (FREE_EMAIL_DOMAINS.has(contactDomain)) reasons.push(\"Recipient uses an unverified free-email domain\");\n if (candidate.domain && contactDomain && contactDomain !== candidate.domain && !contactDomain.endsWith(`.${candidate.domain}`)) {\n reasons.push(\"Recipient email domain does not match the official manufacturer domain\");\n }\n const contactSourceDomain = normalizeDomain(candidate.contactSourceUrl);\n if (\n !candidate.contactSourceUrl ||\n !contactSourceDomain ||\n (contactSourceDomain !== candidate.domain && !contactSourceDomain.endsWith(`.${candidate.domain}`))\n ) {\n reasons.push(\"Recipient is not evidenced on the official manufacturer domain\");\n }\n if ((candidate.evidence ?? []).filter((source) => source.url && source.claim).length < 2) {\n reasons.push(\"Fewer than two usable evidence sources\");\n }\n if (!candidate.qualityAdvantage?.trim() && !candidate.commercialAdvantage?.trim()) {\n reasons.push(\"No material quality, specialization, price, or agency advantage\");\n }\n return reasons;\n}\n\nconst COMMITMENT_PATTERNS = [\n /\\bwe (?:hereby )?(?:accept|agree|commit|guarantee|confirm an order)\\b/i,\n /\\bwe will purchase\\b/i,\n /\\bminimum annual purchase commitment\\b/i,\n /\\bwe accept exclusivity\\b/i,\n /\\bwe approve (?:the )?(?:registration|payment|quotation)\\b/i,\n /\\bour bank (?:details|information)\\b/i,\n];\n\nexport function validateFirstContactEmail(body: string): string[] {\n const problems: string[] = [];\n const words = body.trim().split(/\\s+/).filter(Boolean).length;\n const numberedQuestions = (body.match(/^\\s*[1-4][.)]\\s/gm) ?? []).length;\n if (words < 120 || words > 195) problems.push(`First email length is ${words} words; expected 120–195`);\n if (numberedQuestions < 2 || numberedQuestions > 4) problems.push(`First email contains ${numberedQuestions} numbered questions; maximum is 4`);\n for (const pattern of COMMITMENT_PATTERNS) if (pattern.test(body)) problems.push(`Prohibited commitment language detected: ${pattern}`);\n if (/\\b(?:SAR|riyals?)\\s*(?:5(?:\\.\\d+)?|6(?:\\.\\d+)?|9(?:\\.\\d+)?)\\b/i.test(body) && /BOVIE|grounding|return electrode/i.test(body)) {\n problems.push(\"Possible disclosure of the private BOVIE benchmark\");\n }\n return problems;\n}\n\nexport function validateRoutineClarification(body: string): string[] {\n const problems: string[] = [];\n const numberedQuestions = (body.match(/^\\s*\\d+[.)]\\s/gm) ?? []).length;\n if (numberedQuestions > 6) problems.push(\"Clarification email exceeds six grouped questions\");\n for (const pattern of COMMITMENT_PATTERNS) if (pattern.test(body)) problems.push(`Prohibited commitment language detected: ${pattern}`);\n if (/bank information|pay(?:ment)? for samples|accept annual target|place (?:an )?order/i.test(body)) {\n problems.push(\"Clarification email attempts a prohibited commitment or payment action\");\n }\n return problems;\n}\n\nexport function safeForAutomaticContact(candidate: QualifiedCandidate, score: number): { ok: boolean; reasons: string[] } {\n const reasons = validateCandidate(candidate);\n if (score < 75) reasons.push(`Pre-contact score ${score} is below 75`);\n return { ok: reasons.length === 0, reasons };\n}\n",[],[175,268],"4552abf9-b783-42c0-ace5-e165620045fe","researchQueue.ts","13158d1a-a7c7-11f1-9784-1607ee4eb77e",151,["D",1788464171536],"import { discoverCandidates, qualifyCandidate } from \"./ai.ts\";\nimport { getIdentity, getRuntimeConfig } from \"./config.ts\";\nimport {\n acquireLock,\n checkpointResearchTask,\n claimNextResearchTask,\n clearResearchTaskError,\n completeResearchTask,\n createOpportunity,\n createResearchBatch,\n enqueueResearchTask,\n failRun,\n finishRun,\n getOpportunityById,\n getResearchBatch,\n getSetting,\n initSchema,\n listDiscoveryExclusionDomains,\n listHolidaySet,\n markOutreachSent,\n maybeFinalizeResearchBatch,\n recoverStaleResearchTasks,\n releaseLock,\n releaseResearchBatchContactSlot,\n requeueOrFailResearchTask,\n reserveResearchBatchContactSlot,\n setSetting,\n startRun,\n updateOpportunityDecision,\n upsertManufacturer,\n wasDomainRecentlyContacted,\n} from \"./db.ts\";\nimport { addSaudiBusinessDays, riyadhDateParts } from \"./date.ts\";\nimport { sendGmail, sendOwnerNotification } from \"./email.ts\";\nimport { safeForAutomaticContact, totalPrecontactScore, validateFirstContactEmail } from \"./safeguards.ts\";\nimport { buildContactNotification, buildFirstContact } from \"./templates.ts\";\nimport type { CandidateSeed, QualifiedCandidate, Track } from \"./types.ts\";\n\ninterface BatchStartResult {\n ok: boolean;\n batchId: number;\n batchKey: string;\n tasksCreated: number;\n alreadyQueued: number;\n}\n\ninterface WorkerResult {\n ok: boolean;\n skipped: boolean;\n track: Track;\n taskId?: number;\n taskType?: string;\n taskStatus?: string;\n runId?: number;\n result?: Record;\n error?: string;\n recoveredStaleTasks?: number;\n batchFinalization?: Record | null;\n}\n\ninterface QualificationCheckpoint {\n candidate?: QualifiedCandidate;\n score?: number;\n opportunityId?: number;\n manufacturerId?: number;\n gateReasons?: string[];\n sendState?: \"not_started\" | \"pending\" | \"failed\" | \"sent\";\n sentMessageId?: string;\n note?: string;\n}\n\nfunction saudiDateKey(date = new Date()): string {\n const parts = riyadhDateParts(date);\n return `${parts.year}-${String(parts.month).padStart(2, \"0\")}-${String(parts.day).padStart(2, \"0\")}`;\n}\n\nfunction parseJson(value: unknown, fallback: T): T {\n if (typeof value !== \"string\" || !value.trim()) return fallback;\n try {\n return JSON.parse(value) as T;\n } catch {\n return fallback;\n }\n}\n\nfunction rejectionDecision(reasons: string[], score: number, candidate: QualifiedCandidate): string {\n if (reasons.some((reason) => reason.includes(\"Territory blocked\"))) return \"REJECT — TERRITORY OCCUPIED\";\n if (reasons.some((reason) => /regulatory|certification/i.test(reason))) return \"REJECT — INADEQUATE DOCUMENTATION\";\n if (reasons.some((reason) => reason.includes(\"Actual manufacturer\"))) return \"REJECT — INSUFFICIENT QUALITY\";\n if (score >= 65) return \"MONITOR\";\n if (candidate.track === \"DISPOSABLES\" && !candidate.qualityAdvantage && !candidate.commercialAdvantage) {\n return \"REJECT — TOO COMMODITIZED\";\n }\n return \"BENCHMARK ONLY\";\n}\n\nasync function notifyGmailActivationOnce(): Promise {\n const lastNotification = await getSetting(\"gmail_activation_notified_at\", \"\");\n const lastTimestamp = Date.parse(lastNotification);\n if (Number.isFinite(lastTimestamp) && Date.now() - lastTimestamp < 24 * 60 * 60 * 1000) return false;\n await sendOwnerNotification(\n \"Gmail activation required\",\n \"The manufacturer research system is active, but supplier outreach and inbox monitoring cannot use Gmail until a Google app password is stored as GMAIL_PASS in the Val Town project. The normal Gmail password must not be used.\",\n );\n await setSetting(\"gmail_activation_notified_at\", new Date().toISOString());\n return true;\n}\n\nexport async function startDailyResearchBatch(date = new Date()): Promise {\n await initSchema();\n const key = `daily:${saudiDateKey(date)}`;\n const lockKey = `daily-batch-start:${key}`;\n if (!(await acquireLock(lockKey, 5))) {\n throw new Error(`Daily batch ${key} is already being initialized`);\n }\n\n const runId = await startRun(\"daily_research_batch_start\");\n try {\n const config = getRuntimeConfig();\n const batchId = await createResearchBatch(key, date.toISOString(), config.maxWeeklyContacts);\n let tasksCreated = 0;\n let alreadyQueued = 0;\n for (const track of [\"GERMAN_INSTRUMENTS\", \"DISPOSABLES\"] as Track[]) {\n const created = await enqueueResearchTask({\n batchId,\n track,\n taskType: \"DISCOVER\",\n taskKey: `${key}:${track}:DISCOVER`,\n payload: { track, batchKey: key },\n });\n if (created) tasksCreated += 1;\n else alreadyQueued += 1;\n }\n const result = { ok: true, batchId, batchKey: key, tasksCreated, alreadyQueued };\n await finishRun(runId, result);\n console.log(JSON.stringify({ event: \"weekly_batch_started\", runId, ...result }));\n return result;\n } catch (error) {\n await failRun(runId, error);\n try {\n await sendOwnerNotification(\n \"Weekly research batch failed to start\",\n `The Monday manufacturer-research batch could not be initialized.\\n\\n${error instanceof Error ? error.stack || error.message : String(error)}`,\n );\n } catch { /* the audit record remains authoritative */ }\n throw error;\n } finally {\n await releaseLock(lockKey);\n }\n}\n\nasync function processDiscoveryTask(task: Record, track: Track): Promise> {\n const excludedDomains = (await listDiscoveryExclusionDomains()).slice(0, 250);\n const candidates = await discoverCandidates(track, excludedDomains);\n const selected = candidates.slice(0, 2);\n const batch = await getResearchBatch(Number(task.batch_id));\n if (!batch) throw new Error(`Research batch ${String(task.batch_id)} no longer exists`);\n\n let queued = 0;\n for (const seed of selected) {\n const created = await enqueueResearchTask({\n batchId: Number(task.batch_id),\n track,\n taskType: \"QUALIFY\",\n taskKey: `${String(batch.batch_key)}:${track}:QUALIFY:${seed.domain}`,\n payload: seed,\n });\n if (created) queued += 1;\n }\n\n return {\n stage: \"discovery\",\n track,\n discovered: candidates.length,\n selected: selected.length,\n qualificationTasksQueued: queued,\n candidates: selected.map((candidate) => ({\n legalName: candidate.legalName,\n domain: candidate.domain,\n productFamilies: candidate.productFamilies,\n })),\n };\n}\n\nasync function processQualificationTask(\n task: Record,\n track: Track,\n runId: number,\n): Promise> {\n const config = getRuntimeConfig();\n const identity = getIdentity();\n const taskId = Number(task.id);\n const batchId = Number(task.batch_id);\n const seed = parseJson(task.payload_json, {} as CandidateSeed);\n let checkpoint = parseJson(task.result_json, {});\n\n if (checkpoint.sendState === \"pending\") {\n const existingOpportunity = checkpoint.opportunityId\n ? await getOpportunityById(checkpoint.opportunityId)\n : null;\n if (existingOpportunity?.outreach_sent_at) {\n const decision = Number(checkpoint.score ?? 0) >= 85\n ? \"CONTACTED — HIGH-PRIORITY OPPORTUNITY\"\n : \"CONTACTED — TERRITORY VERIFICATION REQUIRED\";\n await updateOpportunityDecision(Number(existingOpportunity.id), decision, checkpoint.candidate ?? seed);\n return {\n stage: \"qualification\",\n track,\n manufacturer: checkpoint.candidate?.legalName || seed.legalName,\n score: checkpoint.score,\n contacted: true,\n decision,\n recoveredRecordedSend: true,\n };\n }\n\n const warning = \"A previous worker ended after SMTP dispatch began but before delivery could be recorded. Automatic resend is blocked to prevent a duplicate email.\";\n if (checkpoint.opportunityId) {\n await updateOpportunityDecision(checkpoint.opportunityId, \"MONITOR\", {\n ...(checkpoint.candidate ?? seed),\n risks: [...new Set([...(checkpoint.candidate?.risks ?? []), warning])],\n });\n }\n await sendOwnerNotification(\n \"Manual email-delivery verification required\",\n `${checkpoint.candidate?.legalName || seed.legalName || \"A manufacturer\"}: ${warning}`,\n );\n return { stage: \"qualification\", track, contacted: false, uncertainSendState: true, warning };\n }\n\n let candidate = checkpoint.candidate;\n if (!candidate) {\n candidate = await qualifyCandidate(seed);\n }\n const score = checkpoint.score ?? totalPrecontactScore(candidate.score);\n const gate = safeForAutomaticContact(candidate, score);\n candidate.risks = [...new Set([...(candidate.risks ?? []), ...gate.reasons])];\n\n const manufacturerId = checkpoint.manufacturerId ?? await upsertManufacturer(candidate);\n const initialDecision = gate.ok ? \"MONITOR\" : rejectionDecision(gate.reasons, score, candidate);\n const opportunityId = await createOpportunity(\n runId,\n manufacturerId,\n candidate,\n score,\n initialDecision,\n taskId,\n );\n checkpoint = {\n candidate,\n score,\n manufacturerId,\n opportunityId,\n gateReasons: gate.reasons,\n sendState: checkpoint.sendState ?? \"not_started\",\n };\n await checkpointResearchTask(taskId, checkpoint);\n\n if (!gate.ok) {\n return {\n stage: \"qualification\",\n track,\n manufacturer: candidate.legalName,\n score,\n contacted: false,\n decision: initialDecision,\n reasons: gate.reasons,\n };\n }\n\n if (await wasDomainRecentlyContacted(candidate.domain, config.duplicateWindowDays)) {\n const note = `Manufacturer contacted within the previous ${config.duplicateWindowDays} days`;\n candidate.risks.push(note);\n await updateOpportunityDecision(opportunityId, \"MONITOR\", candidate);\n return { stage: \"qualification\", track, manufacturer: candidate.legalName, score, contacted: false, decision: \"MONITOR\", reason: note };\n }\n\n const email = buildFirstContact(candidate, identity);\n const emailProblems = validateFirstContactEmail(email.body);\n if (emailProblems.length) {\n candidate.risks.push(...emailProblems);\n await updateOpportunityDecision(opportunityId, \"MONITOR\", candidate);\n return { stage: \"qualification\", track, manufacturer: candidate.legalName, score, contacted: false, decision: \"MONITOR\", reasons: emailProblems };\n }\n\n if (!config.autoSendEnabled) {\n await updateOpportunityDecision(opportunityId, \"MONITOR\", candidate);\n return { stage: \"qualification\", track, manufacturer: candidate.legalName, score, contacted: false, decision: \"MONITOR\", reason: \"Automatic sending is disabled\" };\n }\n\n if (!config.gmailConfigured) {\n candidate.risks.push(\"Gmail app password is not configured\");\n await updateOpportunityDecision(opportunityId, \"MONITOR\", candidate);\n try { await notifyGmailActivationOnce(); } catch { /* status remains visible in the dashboard */ }\n return { stage: \"qualification\", track, manufacturer: candidate.legalName, score, contacted: false, decision: \"MONITOR\", reason: \"Gmail activation is incomplete\" };\n }\n\n const slotReserved = await reserveResearchBatchContactSlot(batchId);\n if (!slotReserved) {\n candidate.risks.push(\"Weekly first-contact cap reached\");\n await updateOpportunityDecision(opportunityId, \"MONITOR\", candidate);\n return { stage: \"qualification\", track, manufacturer: candidate.legalName, score, contacted: false, decision: \"MONITOR\", reason: \"Weekly contact cap reached\" };\n }\n\n checkpoint = { ...checkpoint, candidate, score, opportunityId, manufacturerId, sendState: \"pending\" };\n await checkpointResearchTask(taskId, checkpoint);\n try {\n const sent = await sendGmail({\n to: candidate.recipientEmail,\n subject: email.subject,\n text: email.body,\n });\n const holidays = await listHolidaySet();\n const sentAt = new Date();\n const firstDue = addSaudiBusinessDays(sentAt, 5, holidays).toISOString();\n const finalDue = addSaudiBusinessDays(sentAt, 10, holidays).toISOString();\n await markOutreachSent(\n opportunityId,\n email.subject,\n email.body,\n config.gmailUser,\n candidate.recipientEmail,\n sent.messageId,\n firstDue,\n finalDue,\n );\n const decision = score >= 85\n ? \"CONTACTED — HIGH-PRIORITY OPPORTUNITY\"\n : \"CONTACTED — TERRITORY VERIFICATION REQUIRED\";\n await updateOpportunityDecision(opportunityId, decision, candidate);\n checkpoint = { ...checkpoint, sendState: \"sent\", sentMessageId: sent.messageId };\n await checkpointResearchTask(taskId, checkpoint);\n\n try {\n await sendOwnerNotification(\n `Contacted: ${candidate.legalName}`,\n buildContactNotification(candidate, score, email.subject, email.body),\n );\n } catch (notificationError) {\n console.error(JSON.stringify({\n event: \"owner_contact_notification_failed\",\n manufacturer: candidate.legalName,\n error: notificationError instanceof Error ? notificationError.message : String(notificationError),\n }));\n }\n\n return {\n stage: \"qualification\",\n track,\n manufacturer: candidate.legalName,\n score,\n contacted: true,\n recipient: candidate.recipientEmail,\n decision,\n messageId: sent.messageId,\n };\n } catch (error) {\n await releaseResearchBatchContactSlot(batchId);\n checkpoint = {\n ...checkpoint,\n sendState: \"failed\",\n note: error instanceof Error ? `${error.name}: ${error.message}` : String(error),\n };\n await checkpointResearchTask(taskId, checkpoint);\n throw error;\n }\n}\n\nexport async function processResearchWorker(track: Track): Promise {\n await initSchema();\n const lockKey = `research-worker:${track}`;\n if (!(await acquireLock(lockKey, 8))) {\n return { ok: true, skipped: true, track, taskStatus: \"worker_locked\" };\n }\n\n let runId: number | undefined;\n let task: Record | null = null;\n try {\n const recoveredStaleTasks = await recoverStaleResearchTasks(track, 8);\n task = await claimNextResearchTask(track);\n if (!task) {\n return { ok: true, skipped: true, track, taskStatus: \"queue_empty\", recoveredStaleTasks };\n }\n\n runId = await startRun(`research_worker_${track.toLowerCase()}_${String(task.task_type).toLowerCase()}`);\n console.log(JSON.stringify({ event: \"research_task_started\", runId, taskId: task.id, track, taskType: task.task_type, attempt: task.attempts }));\n let result: Record;\n if (String(task.task_type) === \"DISCOVER\") {\n result = await processDiscoveryTask(task, track);\n } else if (String(task.task_type) === \"QUALIFY\") {\n result = await processQualificationTask(task, track, runId);\n } else {\n throw new Error(`Unsupported research task type: ${String(task.task_type)}`);\n }\n\n await completeResearchTask(Number(task.id), result);\n await clearResearchTaskError(Number(task.id));\n const batchFinalization = await maybeFinalizeResearchBatch(Number(task.batch_id));\n const audit = {\n taskId: Number(task.id),\n taskType: String(task.task_type),\n track,\n taskStatus: \"completed\",\n result,\n batchFinalization,\n recoveredStaleTasks,\n };\n await finishRun(runId, audit);\n console.log(JSON.stringify({ event: \"research_task_completed\", runId, ...audit }));\n return { ok: true, skipped: false, track, runId, ...audit };\n } catch (error) {\n const message = error instanceof Error ? `${error.name}: ${error.message}` : String(error);\n if (!task) {\n if (runId) await failRun(runId, error);\n return { ok: false, skipped: false, track, runId, error: message };\n }\n\n const taskStatus = await requeueOrFailResearchTask(task, error, 15);\n const batchFinalization = taskStatus === \"failed\"\n ? await maybeFinalizeResearchBatch(Number(task.batch_id))\n : null;\n if (runId) {\n if (taskStatus === \"failed\") await failRun(runId, error);\n else await finishRun(runId, {\n taskId: Number(task.id),\n taskType: String(task.task_type),\n track,\n taskStatus,\n error: message,\n });\n }\n\n console.error(JSON.stringify({ event: \"research_task_failed\", runId, taskId: task.id, track, taskType: task.task_type, taskStatus, error: message }));\n if (taskStatus === \"failed\") {\n try {\n await sendOwnerNotification(\n \"Manufacturer research task failed\",\n `Track: ${track}\\nTask: ${String(task.task_type)}\\nAttempts: ${String(task.attempts)}\\nError: ${message}\\n\\nThe failure is recorded in the dashboard. No supplier commitment or uncontrolled resend occurred.`,\n );\n } catch { /* audit already contains the failure */ }\n }\n return {\n ok: taskStatus !== \"failed\",\n skipped: false,\n track,\n runId,\n taskId: Number(task.id),\n taskType: String(task.task_type),\n taskStatus,\n error: message,\n batchFinalization,\n };\n } finally {\n await releaseLock(lockKey);\n }\n}\n",[],[175,276],"7e2c2c54-f1be-4843-bc4d-e5ed9714bf89","replyWorker.ts","f34ecb3e-a7c8-11f1-9e70-1607ee4eb77e",115,["D",1788461896841],"import { analyzeSupplierReply } from \"./ai.ts\";\nimport { getRuntimeConfig } from \"./config.ts\";\nimport {\n acquireLock,\n checkpointSupplierReplyTask,\n claimNextSupplierReplyTask,\n completeSupplierReplyTask,\n failRun,\n findRecordedClarification,\n finishRun,\n getSupplierReplyTaskContext,\n initSchema,\n markEmailProcessed,\n recordOutboundClarification,\n recordQuotationEstimate,\n recoverStaleSupplierReplyTasks,\n releaseLock,\n requeueOrFailSupplierReplyTask,\n startRun,\n updateReplyAnalysis,\n} from \"./db.ts\";\nimport { sendGmail, sendOwnerNotification } from \"./email.ts\";\nimport type { ParsedAttachment, ParsedInboxMessage } from \"./email.ts\";\nimport { estimateLandedCost } from \"./pricing.ts\";\nimport { validateRoutineClarification } from \"./safeguards.ts\";\nimport { buildReplyNotification } from \"./templates.ts\";\nimport type { QuoteLine, SupplierReplyAnalysis, Track } from \"./types.ts\";\n\ninterface ReplyCheckpoint {\n rawAnalysis?: SupplierReplyAnalysis;\n analysisWithPricing?: Record;\n clarificationSendState?: \"not_started\" | \"not_needed\" | \"blocked\" | \"pending\" | \"sent\" | \"failed\" | \"uncertain\";\n clarificationSubject?: string;\n clarificationBody?: string;\n clarificationRecipient?: string;\n clarificationMessageId?: string;\n clarificationNote?: string;\n ownerNotificationState?: \"not_started\" | \"pending\" | \"sent\" | \"failed\" | \"uncertain\";\n ownerNotificationNote?: string;\n}\n\nexport interface ReplyWorkerResult {\n ok: boolean;\n skipped: boolean;\n taskStatus: string;\n taskId?: number;\n runId?: number;\n manufacturer?: string;\n classification?: string;\n clarificationSent?: boolean;\n ownerNotified?: boolean;\n recoveredStaleTasks?: number;\n error?: string;\n}\n\nfunction parseJson(value: unknown, fallback: T): T {\n if (typeof value !== \"string\" || !value.trim()) return fallback;\n try {\n return JSON.parse(value) as T;\n } catch {\n return fallback;\n }\n}\n\nfunction normalizeReferences(value: unknown): string[] {\n if (!Array.isArray(value)) return [];\n return [...new Set(value.map(String).map((item) => item.trim()).filter(Boolean))];\n}\n\nfunction reconstructMessage(context: Record): ParsedInboxMessage {\n const metadata = parseJson>(context.metadata_json, {});\n const attachments = parseJson(context.attachments_json, []);\n return {\n uid: Number(metadata.uid ?? 0),\n messageId: String(context.message_id ?? \"\"),\n inReplyTo: String(metadata.inReplyTo ?? \"\"),\n references: normalizeReferences(metadata.references),\n from: String(context.from_address ?? \"\").toLowerCase(),\n to: String(context.to_address ?? \"\").toLowerCase(),\n replyTo: String(metadata.replyTo ?? context.from_address ?? \"\").toLowerCase(),\n subject: String(context.subject ?? \"\"),\n text: String(context.body_text ?? \"\"),\n htmlText: \"\",\n date: String(context.occurred_at ?? new Date().toISOString()),\n attachments,\n };\n}\n\nfunction replyStatus(analysis: SupplierReplyAnalysis): string {\n switch (analysis.classification) {\n case \"positive\": return \"positive\";\n case \"neutral\": return \"neutral\";\n case \"negative\": return \"negative\";\n case \"territory_occupied\": return \"territory_occupied\";\n case \"wrong_contact\": return \"wrong_contact\";\n case \"automatic\": return \"automatic\";\n default: return \"unrelated\";\n }\n}\n\nfunction isMeaningfulReply(analysis: SupplierReplyAnalysis): boolean {\n return ![\"automatic\", \"unrelated\"].includes(analysis.classification);\n}\n\nfunction clarificationSubject(analysis: SupplierReplyAnalysis, originalSubject: string): string {\n const supplied = analysis.clarificationSubject.trim();\n if (!supplied) return /^re:/i.test(originalSubject) ? originalSubject : `Re: ${originalSubject}`;\n return /^re:/i.test(supplied) ? supplied : `Re: ${supplied}`;\n}\n\nfunction quoteLineKey(line: QuoteLine, index: number): string {\n return [\n index,\n line.modelNumber,\n line.description,\n line.configurationKey,\n line.currency,\n line.incoterm,\n line.unitPrice,\n line.unitsInPriceBasis,\n ].map((part) => String(part ?? \"\").trim().toLowerCase()).join(\"|\");\n}\n\nasync function calculatePricing(\n rawAnalysis: SupplierReplyAnalysis,\n context: Record,\n taskId: number,\n): Promise[]> {\n const estimates: Record[] = [];\n const track: Track = String(context.track) === \"GERMAN_INSTRUMENTS\"\n ? \"GERMAN_INSTRUMENTS\"\n : \"DISPOSABLES\";\n const opportunityId = Number(context.opportunity_id);\n\n for (const [index, line] of (rawAnalysis.quoteLines ?? []).slice(0, 20).entries()) {\n try {\n const estimate = await estimateLandedCost(line, track);\n const record = estimate as unknown as Record;\n estimates.push(record);\n await recordQuotationEstimate(\n opportunityId,\n line as unknown as Record,\n record,\n taskId,\n quoteLineKey(line, index),\n );\n } catch (error) {\n estimates.push({\n modelNumber: line.modelNumber,\n description: line.description,\n error: error instanceof Error ? `${error.name}: ${error.message}` : String(error),\n });\n }\n }\n return estimates;\n}\n\nasync function handleClarification(\n checkpoint: ReplyCheckpoint,\n taskId: number,\n context: Record,\n message: ParsedInboxMessage,\n analysis: SupplierReplyAnalysis,\n diagnosticDryRun = false,\n): Promise<{ checkpoint: ReplyCheckpoint; sent: boolean }> {\n const config = getRuntimeConfig();\n const opportunityId = Number(context.opportunity_id);\n\n if (!analysis.shouldSendRoutineClarification) {\n checkpoint.clarificationSendState = \"not_needed\";\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: false };\n }\n\n const subject = checkpoint.clarificationSubject || clarificationSubject(analysis, message.subject);\n const body = checkpoint.clarificationBody || analysis.clarificationBody.trim();\n const recipient = checkpoint.clarificationRecipient || message.replyTo || message.from;\n checkpoint = {\n ...checkpoint,\n clarificationSubject: subject,\n clarificationBody: body,\n clarificationRecipient: recipient,\n clarificationSendState: checkpoint.clarificationSendState ?? \"not_started\",\n };\n\n if (checkpoint.clarificationSendState === \"sent\") return { checkpoint, sent: true };\n if ([\"blocked\", \"failed\", \"uncertain\"].includes(String(checkpoint.clarificationSendState))) {\n return { checkpoint, sent: false };\n }\n\n if (checkpoint.clarificationSendState === \"pending\") {\n const recorded = await findRecordedClarification(opportunityId, subject, body);\n if (recorded?.message_id) {\n checkpoint.clarificationSendState = \"sent\";\n checkpoint.clarificationMessageId = String(recorded.message_id);\n checkpoint.clarificationNote = \"Recovered a clarification already recorded before the previous worker stopped.\";\n } else {\n checkpoint.clarificationSendState = \"uncertain\";\n checkpoint.clarificationNote = \"Automatic resend blocked because the prior worker stopped after SMTP dispatch began but before delivery was recorded.\";\n try {\n await sendOwnerNotification(\n \"Manual clarification-delivery check required\",\n `${String(context.legal_name || context.brand || message.from)}: ${checkpoint.clarificationNote}\\nSubject: ${subject}`,\n );\n } catch { /* dashboard remains authoritative */ }\n }\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: checkpoint.clarificationSendState === \"sent\" };\n }\n\n const safetyProblems = validateRoutineClarification(body);\n const blockReasons: string[] = [];\n if (!body || !subject || !recipient) blockReasons.push(\"Clarification subject, body, or recipient is missing\");\n if (analysis.confidence < 0.75) blockReasons.push(`Reply-analysis confidence ${analysis.confidence} is below 0.75`);\n if (analysis.prohibitedCommitmentDetected) blockReasons.push(\"Potential prohibited commitment detected\");\n if (diagnosticDryRun) blockReasons.push(\"Diagnostic dry run: external email is disabled\");\n if (!config.autoSendEnabled) blockReasons.push(\"Automatic sending is disabled\");\n if (!config.gmailConfigured) blockReasons.push(\"Gmail is not activated\");\n blockReasons.push(...safetyProblems);\n\n if (blockReasons.length) {\n checkpoint.clarificationSendState = \"blocked\";\n checkpoint.clarificationNote = blockReasons.join(\"; \");\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: false };\n }\n\n checkpoint.clarificationSendState = \"pending\";\n await checkpointSupplierReplyTask(taskId, checkpoint);\n try {\n const references = [...new Set([\n message.inReplyTo,\n ...message.references,\n message.messageId,\n ].map((item) => String(item || \"\").trim()).filter(Boolean))];\n const sent = await sendGmail({\n to: recipient,\n subject,\n text: body,\n inReplyTo: message.messageId || undefined,\n references,\n });\n await recordOutboundClarification(\n opportunityId,\n config.gmailUser,\n recipient,\n subject,\n body,\n sent.messageId,\n );\n checkpoint.clarificationSendState = \"sent\";\n checkpoint.clarificationMessageId = sent.messageId;\n checkpoint.clarificationNote = \"Routine factual clarification sent automatically.\";\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: true };\n } catch (error) {\n checkpoint.clarificationSendState = \"failed\";\n checkpoint.clarificationNote = error instanceof Error ? `${error.name}: ${error.message}` : String(error);\n await checkpointSupplierReplyTask(taskId, checkpoint);\n throw error;\n }\n}\n\nasync function notifyOwner(\n checkpoint: ReplyCheckpoint,\n taskId: number,\n context: Record,\n message: ParsedInboxMessage,\n analysisWithPricing: Record,\n clarificationSent: boolean,\n diagnosticDryRun = false,\n): Promise<{ checkpoint: ReplyCheckpoint; sent: boolean }> {\n const rawAnalysis = analysisWithPricing as unknown as SupplierReplyAnalysis;\n if (diagnosticDryRun) {\n checkpoint.ownerNotificationState = \"not_started\";\n checkpoint.ownerNotificationNote = \"Diagnostic dry run: owner notification suppressed.\";\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: false };\n }\n if (!isMeaningfulReply(rawAnalysis)) {\n checkpoint.ownerNotificationState = \"not_started\";\n return { checkpoint, sent: false };\n }\n if (checkpoint.ownerNotificationState === \"sent\") return { checkpoint, sent: true };\n if (checkpoint.ownerNotificationState === \"pending\") {\n checkpoint.ownerNotificationState = \"uncertain\";\n checkpoint.ownerNotificationNote = \"The previous worker stopped while owner notification delivery was in progress; duplicate notification suppressed.\";\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: false };\n }\n if ([\"failed\", \"uncertain\"].includes(String(checkpoint.ownerNotificationState))) {\n return { checkpoint, sent: false };\n }\n\n checkpoint.ownerNotificationState = \"pending\";\n await checkpointSupplierReplyTask(taskId, checkpoint);\n try {\n await sendOwnerNotification(\n `Supplier reply: ${String(context.legal_name || context.brand || message.from)}`,\n buildReplyNotification(\n String(context.legal_name || context.brand || \"Unknown manufacturer\"),\n message.from,\n message.subject,\n analysisWithPricing,\n clarificationSent,\n ),\n );\n checkpoint.ownerNotificationState = \"sent\";\n checkpoint.ownerNotificationNote = \"Decision brief delivered to owner.\";\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: true };\n } catch (error) {\n checkpoint.ownerNotificationState = \"failed\";\n checkpoint.ownerNotificationNote = error instanceof Error ? `${error.name}: ${error.message}` : String(error);\n await checkpointSupplierReplyTask(taskId, checkpoint);\n return { checkpoint, sent: false };\n }\n}\n\nexport async function processSupplierReplyWorker(): Promise {\n await initSchema();\n const lockKey = \"supplier-reply-worker\";\n if (!(await acquireLock(lockKey, 8))) {\n return { ok: true, skipped: true, taskStatus: \"worker_locked\" };\n }\n\n let task: Record | null = null;\n let runId: number | undefined;\n let context: Record | null = null;\n try {\n const recoveredStaleTasks = await recoverStaleSupplierReplyTasks(8);\n task = await claimNextSupplierReplyTask();\n if (!task) {\n return { ok: true, skipped: true, taskStatus: \"queue_empty\", recoveredStaleTasks };\n }\n\n runId = await startRun(\"supplier_reply_worker\");\n context = await getSupplierReplyTaskContext(Number(task.id));\n if (!context) throw new Error(`Supplier reply task ${String(task.id)} has no joined email/opportunity context`);\n const message = reconstructMessage(context);\n const messageMetadata = parseJson>(context.metadata_json, {});\n const diagnosticDryRun = messageMetadata.diagnosticDryRun === true;\n let checkpoint = parseJson(context.task_result_json, {});\n console.log(JSON.stringify({\n event: \"supplier_reply_task_started\",\n runId,\n taskId: task.id,\n opportunityId: context.opportunity_id,\n manufacturer: context.legal_name,\n attempt: task.attempts,\n }));\n\n let rawAnalysis = checkpoint.rawAnalysis;\n if (!rawAnalysis) {\n rawAnalysis = await analyzeSupplierReply(context, message);\n checkpoint.rawAnalysis = rawAnalysis;\n checkpoint.clarificationSendState = checkpoint.clarificationSendState ?? \"not_started\";\n checkpoint.ownerNotificationState = checkpoint.ownerNotificationState ?? \"not_started\";\n await checkpointSupplierReplyTask(Number(task.id), checkpoint);\n }\n\n let analysisWithPricing = checkpoint.analysisWithPricing;\n if (!analysisWithPricing) {\n const pricingEstimates = await calculatePricing(rawAnalysis, context, Number(task.id));\n analysisWithPricing = { ...rawAnalysis, pricingEstimates };\n checkpoint.analysisWithPricing = analysisWithPricing;\n await checkpointSupplierReplyTask(Number(task.id), checkpoint);\n }\n\n await updateReplyAnalysis(\n Number(context.opportunity_id),\n replyStatus(rawAnalysis),\n analysisWithPricing,\n );\n\n const clarification = await handleClarification(\n checkpoint,\n Number(task.id),\n context,\n message,\n rawAnalysis,\n diagnosticDryRun,\n );\n checkpoint = clarification.checkpoint;\n\n const notification = await notifyOwner(\n checkpoint,\n Number(task.id),\n context,\n message,\n analysisWithPricing,\n clarification.sent,\n diagnosticDryRun,\n );\n checkpoint = notification.checkpoint;\n\n await markEmailProcessed(message.messageId, \"completed\", analysisWithPricing);\n const finalResult = {\n manufacturer: String(context.legal_name || context.brand || message.from),\n classification: rawAnalysis.classification,\n decision: rawAnalysis.recommendedDecision,\n clarificationSent: clarification.sent,\n clarificationState: checkpoint.clarificationSendState,\n ownerNotified: notification.sent,\n ownerNotificationState: checkpoint.ownerNotificationState,\n pricingLineCount: rawAnalysis.quoteLines?.length ?? 0,\n recoveredStaleTasks,\n };\n await completeSupplierReplyTask(Number(task.id), { ...checkpoint, finalResult });\n await finishRun(runId, {\n taskId: Number(task.id),\n opportunityId: Number(context.opportunity_id),\n ...finalResult,\n });\n console.log(JSON.stringify({ event: \"supplier_reply_task_completed\", runId, taskId: task.id, ...finalResult }));\n return {\n ok: true,\n skipped: false,\n taskStatus: \"completed\",\n taskId: Number(task.id),\n runId,\n manufacturer: finalResult.manufacturer,\n classification: finalResult.classification,\n clarificationSent: finalResult.clarificationSent,\n ownerNotified: finalResult.ownerNotified,\n recoveredStaleTasks,\n };\n } catch (error) {\n const message = error instanceof Error ? `${error.name}: ${error.message}` : String(error);\n if (!task) {\n if (runId) await failRun(runId, error);\n return { ok: false, skipped: false, taskStatus: \"failed\", runId, error: message };\n }\n\n const taskStatus = await requeueOrFailSupplierReplyTask(task, error, 15);\n if (context?.message_id && taskStatus === \"failed\") {\n await markEmailProcessed(String(context.message_id), \"failed\", { error: message });\n }\n if (runId) {\n if (taskStatus === \"failed\") await failRun(runId, error);\n else await finishRun(runId, {\n taskId: Number(task.id),\n taskStatus,\n error: message,\n });\n }\n if (taskStatus === \"failed\") {\n try {\n await sendOwnerNotification(\n \"Supplier reply processing failed\",\n `Manufacturer: ${String(context?.legal_name || context?.from_address || \"Unknown\")}\\nSubject: ${String(context?.subject || \"No subject\")}\\nAttempts: ${String(task.attempts)}\\nError: ${message}\\n\\nThe failure is recorded in the dashboard. No order, payment, exclusivity, or uncontrolled supplier-email resend occurred.`,\n );\n } catch { /* audit record remains authoritative */ }\n }\n console.error(JSON.stringify({\n event: \"supplier_reply_task_failed\",\n runId,\n taskId: task.id,\n taskStatus,\n error: message,\n }));\n return {\n ok: taskStatus !== \"failed\",\n skipped: false,\n taskStatus,\n taskId: Number(task.id),\n runId,\n manufacturer: String(context?.legal_name || \"\"),\n error: message,\n };\n } finally {\n await releaseLock(lockKey);\n }\n}\n",[],[175,284],"cf02f890-92e3-4d6a-b7bb-0140c9447409","pricing.ts","809eab40-a7c3-11f1-bf2e-1607ee4eb77e",98,["D",1788461561425],"import { getSetting } from \"./db.ts\";\nimport type { QuoteLine, Track } from \"./types.ts\";\n\nexport interface LandedCostPolicy {\n vatRate: number;\n exwFreightPct: number;\n fobFreightPct: number;\n unknownFreightPct: number;\n insurancePct: number;\n screeningCustomsDutyPct: number;\n bankAndFxPct: number;\n warehousePct: number;\n expiryAndDamagePct: number;\n domesticTransportPerUnitSar: number;\n clearanceAndPortPerUnitSar: number;\n arabicLabellingPerUnitSar: number;\n authorizedRepresentativePerUnitSar: number;\n sfdaRegistrationPerUnitSar: number;\n sampleEvaluationPerUnitSar: number;\n targetMarginSpecializedDisposable: number;\n targetMarginReusableInstrument: number;\n targetMarginCommodity: number;\n assumedRegistrationMarketEntryCostSar: number;\n}\n\nexport interface FxResult {\n baseCurrency: string;\n sarPerBase: number;\n source: string;\n retrievedAt: string;\n providerUpdatedAt: string;\n}\n\nexport interface LandedCostEstimate {\n modelNumber: string;\n description: string;\n configurationKey: string;\n sourceClassification: string;\n currency: string;\n fxRateToSar: number;\n fxSource: string;\n manufacturerUnitCostSar: number;\n components: {\n internationalFreightSar: number;\n insuranceSar: number;\n customsDutySar: number;\n clearanceAndPortSar: number;\n bankAndFxSar: number;\n authorizedRepresentativeSar: number;\n sfdaRegistrationSar: number;\n arabicLabellingSar: number;\n warehouseSar: number;\n domesticTransportSar: number;\n expiryAndDamageSar: number;\n sampleEvaluationSar: number;\n };\n estimatedLandedCostExVatSar: number;\n recoverableVatSar: number;\n cashRequirementIncludingVatSar: number;\n recommendedSellingPriceExVatSar: number;\n recommendedSellingPriceIncludingVatSar: number;\n grossProfitPerUnitSar: number;\n grossMarginPct: number;\n receivableExposureAt60DaysPerUnitSar: number;\n unitsToRecoverMarketEntryCost: number;\n targetMarginPct: number;\n completeness: \"verified_true_landed_cost\" | \"preliminary_screening_estimate\";\n missingVerifiedInputs: string[];\n bovieComparison?: {\n applicable: boolean;\n benchmarkConfiguration: string;\n benchmarkStatus: string;\n alternativeLandedCostSar: number;\n fifteenPercentThresholdRangeSar: [number, number];\n twentyPercentThresholdRangeSar: [number, number];\n passes15PercentAgainstEntireRange: boolean;\n passes20PercentAgainstEntireRange: boolean;\n note: string;\n };\n}\n\nconst DEFAULT_POLICY: LandedCostPolicy = {\n vatRate: 0.15,\n exwFreightPct: 0.10,\n fobFreightPct: 0.07,\n unknownFreightPct: 0.12,\n insurancePct: 0.005,\n screeningCustomsDutyPct: 0.05,\n bankAndFxPct: 0.015,\n warehousePct: 0.02,\n expiryAndDamagePct: 0.02,\n domesticTransportPerUnitSar: 0,\n clearanceAndPortPerUnitSar: 0,\n arabicLabellingPerUnitSar: 0,\n authorizedRepresentativePerUnitSar: 0,\n sfdaRegistrationPerUnitSar: 0,\n sampleEvaluationPerUnitSar: 0,\n targetMarginSpecializedDisposable: 0.40,\n targetMarginReusableInstrument: 0.45,\n targetMarginCommodity: 0.32,\n assumedRegistrationMarketEntryCostSar: 0,\n};\n\nfunction round(value: number, decimals = 2): number {\n const factor = 10 ** decimals;\n return Math.round((value + Number.EPSILON) * factor) / factor;\n}\n\nfunction finiteNonNegative(value: unknown, fallback = 0): number {\n const number = Number(value);\n return Number.isFinite(number) && number >= 0 ? number : fallback;\n}\n\nfunction normalizedIncoterm(value: string): string {\n return value.trim().toUpperCase().split(/\\s+/)[0];\n}\n\nfunction freightPct(incoterm: string, policy: LandedCostPolicy): number {\n const term = normalizedIncoterm(incoterm);\n if ([\"CIF\", \"CIP\", \"DDP\", \"DAP\", \"DPU\"].includes(term)) return 0;\n if ([\"FOB\", \"FCA\", \"CFR\", \"CPT\"].includes(term)) return policy.fobFreightPct;\n if ([\"EXW\"].includes(term)) return policy.exwFreightPct;\n return policy.unknownFreightPct;\n}\n\nfunction targetMargin(track: Track, description: string, policy: LandedCostPolicy): number {\n if (track === \"GERMAN_INSTRUMENTS\") return policy.targetMarginReusableInstrument;\n if (/syringe|needle|glove|gauze|urine bag|oxygen mask|nasal cannula/i.test(description)) return policy.targetMarginCommodity;\n return policy.targetMarginSpecializedDisposable;\n}\n\nexport async function getLandedCostPolicy(): Promise {\n const stored = await getSetting>(\"landed_cost_policy\", {});\n return { ...DEFAULT_POLICY, ...stored };\n}\n\nconst fxCache = new Map>();\n\nasync function fetchSarRate(code: string): Promise {\n if (code === \"SAR\") {\n const now = new Date().toISOString();\n return {\n baseCurrency: \"SAR\",\n sarPerBase: 1,\n source: \"Identity conversion\",\n retrievedAt: now,\n providerUpdatedAt: now,\n };\n }\n\n const response = await fetch(`https://open.er-api.com/v6/latest/${encodeURIComponent(code)}`, {\n headers: { Accept: \"application/json\" },\n signal: AbortSignal.timeout(8_000),\n });\n if (!response.ok) throw new Error(`FX provider returned HTTP ${response.status} for ${code}`);\n const payload = await response.json() as Record;\n const rate = Number(payload?.rates?.SAR);\n if (!Number.isFinite(rate) || rate <= 0) throw new Error(`FX provider did not return a valid ${code}/SAR rate`);\n return {\n baseCurrency: code,\n sarPerBase: rate,\n source: \"ExchangeRate-API Open Access\",\n retrievedAt: new Date().toISOString(),\n providerUpdatedAt: payload.time_last_update_utc || payload.time_last_update_unix\n ? String(payload.time_last_update_utc || new Date(Number(payload.time_last_update_unix) * 1000).toISOString())\n : \"not provided\",\n };\n}\n\nexport async function getSarRate(currency: string): Promise {\n const code = currency.trim().toUpperCase();\n if (!/^[A-Z]{3}$/.test(code)) throw new Error(`Invalid currency code: ${currency}`);\n const cached = fxCache.get(code);\n if (cached) return await cached;\n\n const pending = fetchSarRate(code);\n fxCache.set(code, pending);\n try {\n return await pending;\n } catch (error) {\n fxCache.delete(code);\n throw error;\n }\n}\n\nfunction exactLikeForLikeKey(value: string): string {\n return value.toLowerCase().replace(/[^a-z0-9]+/g, \"_\").replace(/^_+|_+$/g, \"\");\n}\n\nasync function compareWithPrivateBovieBenchmark(\n configurationKey: string,\n landedCostSar: number,\n): Promise {\n const key = exactLikeForLikeKey(configurationKey);\n const allowed = new Set([\n \"adult_split_without_cable_rem\",\n \"adult_solid_without_cable\",\n \"adult_split_with_2_8m_cable_rem\",\n ]);\n if (!allowed.has(key)) return undefined;\n\n const benchmark = await getSetting<{\n status: string;\n landedCostLowSar: number;\n landedCostHighSar: number;\n }>(\"private_bovie_benchmark\", {\n status: \"provisional pending latest supplier invoice\",\n landedCostLowSar: 5,\n landedCostHighSar: 6,\n });\n const low = finiteNonNegative(benchmark.landedCostLowSar, 5);\n const high = Math.max(low, finiteNonNegative(benchmark.landedCostHighSar, 6));\n const threshold15: [number, number] = [round(low * 0.85), round(high * 0.85)];\n const threshold20: [number, number] = [round(low * 0.80), round(high * 0.80)];\n\n return {\n applicable: true,\n benchmarkConfiguration: key,\n benchmarkStatus: benchmark.status,\n alternativeLandedCostSar: round(landedCostSar),\n fifteenPercentThresholdRangeSar: threshold15,\n twentyPercentThresholdRangeSar: threshold20,\n passes15PercentAgainstEntireRange: landedCostSar <= threshold15[0],\n passes20PercentAgainstEntireRange: landedCostSar <= threshold20[0],\n note: \"Internal comparison only. Never disclose benchmark purchase or selling prices to a prospective supplier. An alternative may still qualify through obtainable exclusivity, documented safety/quality, supply reliability, or stronger combined pad-and-pencil economics.\",\n };\n}\n\nexport async function estimateLandedCost(line: QuoteLine, track: Track): Promise {\n if (!Number.isFinite(line.unitPrice) || line.unitPrice <= 0) throw new Error(\"Quote line must contain a positive numeric price\");\n const basis = Number.isFinite(line.unitsInPriceBasis) && line.unitsInPriceBasis > 0 ? line.unitsInPriceBasis : 1;\n const policy = await getLandedCostPolicy();\n const fx = await getSarRate(line.currency);\n const manufacturerUnitCostSar = (line.unitPrice / basis) * fx.sarPerBase;\n const freight = manufacturerUnitCostSar * freightPct(line.incoterm, policy);\n const insurance = manufacturerUnitCostSar * policy.insurancePct;\n const customsBase = manufacturerUnitCostSar + freight + insurance;\n const customs = customsBase * policy.screeningCustomsDutyPct;\n const bank = manufacturerUnitCostSar * policy.bankAndFxPct;\n const warehouse = manufacturerUnitCostSar * policy.warehousePct;\n const expiry = manufacturerUnitCostSar * policy.expiryAndDamagePct;\n\n const components = {\n internationalFreightSar: freight,\n insuranceSar: insurance,\n customsDutySar: customs,\n clearanceAndPortSar: policy.clearanceAndPortPerUnitSar,\n bankAndFxSar: bank,\n authorizedRepresentativeSar: policy.authorizedRepresentativePerUnitSar,\n sfdaRegistrationSar: policy.sfdaRegistrationPerUnitSar,\n arabicLabellingSar: policy.arabicLabellingPerUnitSar,\n warehouseSar: warehouse,\n domesticTransportSar: policy.domesticTransportPerUnitSar,\n expiryAndDamageSar: expiry,\n sampleEvaluationSar: policy.sampleEvaluationPerUnitSar,\n };\n const estimatedLanded = manufacturerUnitCostSar + Object.values(components).reduce((sum, value) => sum + value, 0);\n const margin = targetMargin(track, line.description, policy);\n const sellingExVat = estimatedLanded / (1 - margin);\n const grossProfit = sellingExVat - estimatedLanded;\n const vat = estimatedLanded * policy.vatRate;\n const sellingInclVat = sellingExVat * (1 + policy.vatRate);\n const missingVerifiedInputs = [\n \"actual international freight allocation\",\n \"insurance allocation\",\n \"HS-code-specific customs duty\",\n \"customs-clearance and port charges\",\n \"Saudi authorized-representative allocation\",\n \"SFDA registration allocation\",\n \"Arabic labelling/packaging allocation\",\n \"warehouse and domestic transport allocation\",\n \"expiry/damage allowance\",\n \"sample and hospital-evaluation allocation\",\n ].filter((item) => {\n if (item.startsWith(\"Saudi authorized\") && policy.authorizedRepresentativePerUnitSar > 0) return false;\n if (item.startsWith(\"SFDA\") && policy.sfdaRegistrationPerUnitSar > 0) return false;\n if (item.startsWith(\"Arabic\") && policy.arabicLabellingPerUnitSar > 0) return false;\n if (item.startsWith(\"customs-clearance\") && policy.clearanceAndPortPerUnitSar > 0) return false;\n if (item.startsWith(\"sample\") && policy.sampleEvaluationPerUnitSar > 0) return false;\n return true;\n });\n\n const result: LandedCostEstimate = {\n modelNumber: line.modelNumber,\n description: line.description,\n configurationKey: line.configurationKey,\n sourceClassification: line.priceSourceClassification,\n currency: line.currency.toUpperCase(),\n fxRateToSar: round(fx.sarPerBase, 6),\n fxSource: `${fx.source}; provider update: ${fx.providerUpdatedAt}`,\n manufacturerUnitCostSar: round(manufacturerUnitCostSar),\n components: Object.fromEntries(Object.entries(components).map(([key, value]) => [key, round(value)])) as LandedCostEstimate[\"components\"],\n estimatedLandedCostExVatSar: round(estimatedLanded),\n recoverableVatSar: round(vat),\n cashRequirementIncludingVatSar: round(estimatedLanded + vat),\n recommendedSellingPriceExVatSar: round(sellingExVat),\n recommendedSellingPriceIncludingVatSar: round(sellingInclVat),\n grossProfitPerUnitSar: round(grossProfit),\n grossMarginPct: round((grossProfit / sellingExVat) * 100, 1),\n receivableExposureAt60DaysPerUnitSar: round(sellingInclVat),\n unitsToRecoverMarketEntryCost: grossProfit > 0 && policy.assumedRegistrationMarketEntryCostSar > 0\n ? Math.ceil(policy.assumedRegistrationMarketEntryCostSar / grossProfit)\n : 0,\n targetMarginPct: round(margin * 100, 1),\n completeness: missingVerifiedInputs.length ? \"preliminary_screening_estimate\" : \"verified_true_landed_cost\",\n missingVerifiedInputs,\n };\n result.bovieComparison = await compareWithPrivateBovieBenchmark(line.configurationKey, estimatedLanded);\n return result;\n}\n",[],[175,292],"a0e85a0b-9e7b-4030-bdc1-83ec9d5bf746","inboxScan.ts","62bfb5f6-a7c8-11f1-a3fe-1607ee4eb77e",95,["D",1788461451695],"import { getIdentity, getRuntimeConfig } from \"./config.ts\";\nimport {\n acquireLock,\n emailAlreadyProcessed,\n enqueueSupplierReplyTask,\n failRun,\n findOpportunityByDomain,\n findOpportunityByMessageReferences,\n finishRun,\n getSetting,\n initSchema,\n listDueFollowups,\n listHolidaySet,\n markEmailProcessed,\n markFollowupSent,\n markReplyQueued,\n recordInboundEmail,\n releaseLock,\n setSetting,\n startRun,\n} from \"./db.ts\";\nimport { isSaudiBusinessDay, safeDate } from \"./date.ts\";\nimport { fetchInboxSince, sendGmail, sendOwnerNotification } from \"./email.ts\";\nimport type { ParsedAttachment, ParsedInboxMessage } from \"./email.ts\";\nimport { emailDomain, validateRoutineClarification } from \"./safeguards.ts\";\nimport { buildFollowup } from \"./templates.ts\";\n\ninterface InboxScanOptions {\n since?: Date | string;\n force?: boolean;\n}\n\ninterface InboxScanResult {\n runId: number;\n ok: boolean;\n skipped: boolean;\n messagesScanned: number;\n matchedSupplierReplies: number;\n replyTasksQueued: number;\n followupsSent: number;\n notificationsSent: number;\n notes: string[];\n}\n\nfunction referencesFor(message: ParsedInboxMessage): string[] {\n return [...new Set([\n message.inReplyTo,\n ...(message.references ?? []),\n ].map((item) => String(item || \"\").trim()).filter(Boolean))];\n}\n\nfunction compactAttachmentMetadata(attachments: ParsedAttachment[]): Array> {\n return attachments.slice(0, 12).map((attachment) => ({\n filename: attachment.filename,\n contentType: attachment.contentType,\n size: attachment.size,\n extractionWarning: attachment.extractionWarning ?? \"\",\n }));\n}\n\nfunction queueAttachmentPayload(attachments: ParsedAttachment[]): Array> {\n let remainingImageCharacters = 2_500_000;\n return attachments.slice(0, 12).map((attachment) => {\n const item: Record = {\n filename: attachment.filename,\n contentType: attachment.contentType,\n size: attachment.size,\n extractedText: attachment.extractedText.slice(0, 100_000),\n extractionWarning: attachment.extractionWarning ?? \"\",\n };\n if (attachment.imageDataUrl) {\n if (attachment.imageDataUrl.length <= remainingImageCharacters) {\n item.imageDataUrl = attachment.imageDataUrl;\n remainingImageCharacters -= attachment.imageDataUrl.length;\n } else {\n item.extractionWarning = [\n String(item.extractionWarning || \"\"),\n \"Image omitted from automatic analysis payload because it exceeded the safe queue-size budget; manual review may be required.\",\n ].filter(Boolean).join(\" \");\n }\n }\n return item;\n });\n}\n\nasync function notifyGmailActivationOnce(): Promise {\n const lastNotification = await getSetting(\"gmail_activation_notified_at\", \"\");\n const lastTimestamp = Date.parse(lastNotification);\n if (Number.isFinite(lastTimestamp) && Date.now() - lastTimestamp < 24 * 60 * 60 * 1000) return false;\n await sendOwnerNotification(\n \"Gmail activation required\",\n \"Supplier-response monitoring is scheduled, but Gmail cannot be read or used for supplier outreach until a Google app password is stored as GMAIL_PASS in the Val Town project. The normal Gmail password must not be used.\",\n );\n await setSetting(\"gmail_activation_notified_at\", new Date().toISOString());\n return true;\n}\n\nexport async function scanSupplierInbox(options: InboxScanOptions = {}): Promise {\n await initSchema();\n const runId = await startRun(\"supplier_inbox_scan_and_followups\");\n const result: InboxScanResult = {\n runId,\n ok: true,\n skipped: false,\n messagesScanned: 0,\n matchedSupplierReplies: 0,\n replyTasksQueued: 0,\n followupsSent: 0,\n notificationsSent: 0,\n notes: [],\n };\n\n const holidays = await listHolidaySet();\n if (!options.force && !isSaudiBusinessDay(new Date(), holidays)) {\n result.skipped = true;\n result.notes.push(\"Skipped because today is not a Saudi business day\");\n await finishRun(runId, result);\n return result;\n }\n\n const lockKey = \"supplier-inbox-scan\";\n if (!(await acquireLock(lockKey, 5))) {\n result.skipped = true;\n result.notes.push(\"Another inbox scan is already running\");\n await finishRun(runId, result);\n return result;\n }\n\n try {\n const config = getRuntimeConfig();\n const identity = getIdentity();\n if (!config.gmailConfigured) {\n result.skipped = true;\n result.notes.push(\"Gmail monitoring is awaiting GMAIL_PASS activation\");\n try {\n if (await notifyGmailActivationOnce()) result.notificationsSent += 1;\n } catch (error) {\n result.notes.push(`Activation notification failed: ${error instanceof Error ? error.message : String(error)}`);\n }\n await finishRun(runId, result);\n console.log(JSON.stringify({ event: \"inbox_scan_blocked_configuration\", runId, reason: \"GMAIL_PASS missing\" }));\n return result;\n }\n\n const baseSince = safeDate(options.since, new Date(Date.now() - 36 * 60 * 60 * 1000));\n const since = new Date(baseSince.getTime() - 6 * 60 * 60 * 1000);\n const messages = await fetchInboxSince(since, 30);\n result.messagesScanned = messages.length;\n\n for (const message of messages) {\n if (!message.messageId || await emailAlreadyProcessed(message.messageId)) continue;\n\n if (!message.from || message.from === config.gmailUser.toLowerCase()) {\n const emailId = await recordInboundEmail({\n messageId: message.messageId,\n threadKey: message.references.at(-1) || message.inReplyTo,\n from: message.from,\n to: message.to,\n subject: message.subject,\n body: \"\",\n occurredAt: message.date,\n attachments: compactAttachmentMetadata(message.attachments),\n metadata: { ignoredReason: \"own-or-missing-sender\", uid: message.uid },\n });\n if (emailId) await markEmailProcessed(message.messageId, \"ignored\");\n continue;\n }\n\n let opportunity = await findOpportunityByMessageReferences(referencesFor(message));\n if (!opportunity) {\n const senderDomain = emailDomain(message.replyTo || message.from);\n if (senderDomain) opportunity = await findOpportunityByDomain(senderDomain);\n }\n\n if (!opportunity) {\n const emailId = await recordInboundEmail({\n messageId: message.messageId,\n threadKey: message.references.at(-1) || message.inReplyTo,\n from: message.from,\n to: message.to,\n subject: message.subject,\n body: \"\",\n occurredAt: message.date,\n attachments: compactAttachmentMetadata(message.attachments),\n metadata: { ignoredReason: \"no-matching-supplier-opportunity\", uid: message.uid },\n });\n if (emailId) await markEmailProcessed(message.messageId, \"ignored\");\n continue;\n }\n\n const opportunityId = Number(opportunity.id);\n const emailId = await recordInboundEmail({\n opportunityId,\n messageId: message.messageId,\n threadKey: message.references.at(-1) || message.inReplyTo,\n from: message.from,\n to: message.to,\n subject: message.subject,\n body: message.text || message.htmlText,\n occurredAt: message.date,\n attachments: queueAttachmentPayload(message.attachments),\n metadata: {\n uid: message.uid,\n replyTo: message.replyTo,\n inReplyTo: message.inReplyTo,\n references: message.references,\n },\n });\n await markReplyQueued(opportunityId, message.date);\n result.matchedSupplierReplies += 1;\n if (await enqueueSupplierReplyTask(emailId, opportunityId)) result.replyTasksQueued += 1;\n }\n\n const dueFollowups = (await listDueFollowups()).slice(0, 10);\n const followupActivity: string[] = [];\n for (const opportunity of dueFollowups) {\n const final = Boolean(opportunity.first_followup_sent_at);\n const followup = buildFollowup(opportunity, identity, final);\n const safetyProblems = validateRoutineClarification(followup.body);\n if (safetyProblems.length) {\n result.notes.push(`${String(opportunity.legal_name)} follow-up blocked: ${safetyProblems.join(\"; \")}`);\n continue;\n }\n\n const recipient = String(opportunity.recipient_email || \"\").trim();\n if (!recipient) {\n result.notes.push(`${String(opportunity.legal_name)} follow-up blocked: recipient missing`);\n continue;\n }\n const originalMessageId = String(opportunity.original_message_id || \"\").trim();\n const sent = await sendGmail({\n to: recipient,\n subject: followup.subject,\n text: followup.body,\n inReplyTo: originalMessageId || undefined,\n references: originalMessageId ? [originalMessageId] : undefined,\n });\n await markFollowupSent(\n Number(opportunity.id),\n final ? \"final_followup\" : \"first_followup\",\n followup.subject,\n followup.body,\n config.gmailUser,\n recipient,\n sent.messageId,\n );\n result.followupsSent += 1;\n followupActivity.push(`${String(opportunity.legal_name)} — ${final ? \"final follow-up\" : \"first follow-up\"}`);\n }\n\n if (followupActivity.length) {\n await sendOwnerNotification(\n \"Supplier follow-ups sent\",\n `The following automatic follow-ups were sent after the required Saudi business-day intervals:\\n\\n${followupActivity.join(\"\\n\")}`,\n );\n result.notificationsSent += 1;\n }\n\n await finishRun(runId, result);\n console.log(JSON.stringify({ event: \"supplier_inbox_scan_completed\", ...result }));\n return result;\n } catch (error) {\n result.ok = false;\n await failRun(runId, error);\n try {\n await sendOwnerNotification(\n \"Supplier inbox scan failed\",\n `The scheduled supplier inbox scan failed.\\n\\n${error instanceof Error ? error.stack || error.message : String(error)}`,\n );\n } catch { /* audit record remains authoritative */ }\n throw error;\n } finally {\n await releaseLock(lockKey);\n }\n}\n",[],[175,300],"a47e23b8-6cdd-49de-a43e-0612c07cbfa3","email.ts","6e53f1da-a7c2-11f1-acc8-1607ee4eb77e",10,["D",1788458894157],"import nodemailer from \"npm:nodemailer\";\nimport { ImapFlow } from \"npm:imapflow\";\nimport { simpleParser } from \"npm:mailparser\";\nimport { email as valTownEmail } from \"https://esm.town/v/std/email\";\nimport { getRuntimeConfig, requireGmailCredentials } from \"./config.ts\";\n\nexport interface ParsedAttachment {\n filename: string;\n contentType: string;\n size: number;\n extractedText: string;\n imageDataUrl?: string;\n extractionWarning?: string;\n}\n\nexport interface ParsedInboxMessage {\n uid: number;\n messageId: string;\n inReplyTo: string;\n references: string[];\n from: string;\n to: string;\n replyTo: string;\n subject: string;\n text: string;\n htmlText: string;\n date: string;\n attachments: ParsedAttachment[];\n}\n\nfunction cleanAddress(value: unknown): string {\n const text = String(value ?? \"\").trim();\n const match = text.match(/<([^>]+@[^>]+)>/);\n return (match?.[1] ?? text).trim().toLowerCase();\n}\n\nfunction truncate(text: string, limit: number): string {\n return text.length <= limit ? text : `${text.slice(0, limit)}\\n[truncated]`;\n}\n\nasync function extractAttachment(attachment: any): Promise {\n const filename = attachment.filename || \"attachment\";\n const contentType = attachment.contentType || \"application/octet-stream\";\n const buffer: Uint8Array = attachment.content;\n const size = Number(attachment.size || buffer?.byteLength || 0);\n const base: ParsedAttachment = { filename, contentType, size, extractedText: \"\" };\n\n try {\n if (contentType.startsWith(\"text/\") || /\\.(csv|txt|xml|json)$/i.test(filename)) {\n base.extractedText = truncate(new TextDecoder().decode(buffer), 40_000);\n return base;\n }\n\n if (contentType === \"application/pdf\" || /\\.pdf$/i.test(filename)) {\n const module = await import(\"npm:pdf-parse\");\n const parse = (module.default ?? module) as (input: Uint8Array) => Promise<{ text?: string }>;\n const result = await parse(buffer);\n base.extractedText = truncate(result.text ?? \"\", 60_000);\n if (!base.extractedText.trim()) base.extractionWarning = \"PDF contained no extractable text; manual or visual review may be required.\";\n return base;\n }\n\n if (/\\.(xlsx|xls)$/i.test(filename) || /spreadsheetml|ms-excel/i.test(contentType)) {\n const XLSX = await import(\"npm:xlsx\");\n const workbook = XLSX.read(buffer, { type: \"array\" });\n const sections: string[] = [];\n for (const name of workbook.SheetNames.slice(0, 12)) {\n sections.push(`SHEET: ${name}\\n${XLSX.utils.sheet_to_csv(workbook.Sheets[name])}`);\n }\n base.extractedText = truncate(sections.join(\"\\n\\n\"), 80_000);\n return base;\n }\n\n if (/\\.docx$/i.test(filename) || contentType.includes(\"wordprocessingml\")) {\n const mammoth = await import(\"npm:mammoth\");\n const result = await mammoth.extractRawText({ buffer: Buffer.from(buffer) });\n base.extractedText = truncate(result.value ?? \"\", 60_000);\n return base;\n }\n\n if (contentType.startsWith(\"image/\") && size <= 8_000_000) {\n const encoded = Buffer.from(buffer).toString(\"base64\");\n base.imageDataUrl = `data:${contentType};base64,${encoded}`;\n base.extractionWarning = \"Image supplied to the analysis model for visual extraction.\";\n return base;\n }\n\n base.extractionWarning = \"Unsupported attachment type; retained as metadata only.\";\n return base;\n } catch (error) {\n base.extractionWarning = `Attachment extraction failed: ${error instanceof Error ? error.message : String(error)}`;\n return base;\n }\n}\n\nexport async function sendGmail(input: {\n to: string;\n subject: string;\n text: string;\n inReplyTo?: string;\n references?: string[];\n}): Promise<{ messageId: string; accepted: string[] }> {\n const credentials = requireGmailCredentials();\n const transporter = nodemailer.createTransport({\n service: \"gmail\",\n auth: { user: credentials.user, pass: credentials.pass },\n });\n\n const info = await transporter.sendMail({\n from: credentials.user,\n to: input.to,\n subject: input.subject,\n text: input.text,\n inReplyTo: input.inReplyTo || undefined,\n references: input.references?.length ? input.references : undefined,\n });\n\n return {\n messageId: String(info.messageId || `smtp-${crypto.randomUUID()}@local`),\n accepted: (info.accepted ?? []).map(String),\n };\n}\n\nexport async function sendOwnerNotification(subject: string, text: string): Promise {\n const config = getRuntimeConfig();\n await valTownEmail({\n subject: `${config.notificationPrefix} ${subject}`,\n text,\n });\n}\n\nexport async function testGmailConnection(): Promise<{ ok: boolean; detail: string }> {\n const credentials = requireGmailCredentials();\n const client = new ImapFlow({\n host: \"imap.gmail.com\",\n port: 993,\n secure: true,\n logger: false,\n auth: { user: credentials.user, pass: credentials.pass },\n });\n try {\n await client.connect();\n await client.mailboxOpen(\"INBOX\", { readOnly: true });\n return { ok: true, detail: `Connected to ${credentials.user}` };\n } finally {\n try { await client.logout(); } catch { /* connection may already be closed */ }\n }\n}\n\nexport async function fetchInboxSince(since: Date, maxMessages = 75): Promise {\n const credentials = requireGmailCredentials();\n const client = new ImapFlow({\n host: \"imap.gmail.com\",\n port: 993,\n secure: true,\n logger: false,\n auth: { user: credentials.user, pass: credentials.pass },\n });\n\n const output: ParsedInboxMessage[] = [];\n await client.connect();\n const lock = await client.getMailboxLock(\"INBOX\");\n try {\n const uids = await client.search({ since }, { uid: true });\n const selected = uids.slice(-maxMessages);\n if (!selected.length) return output;\n\n for await (const message of client.fetch(\n selected,\n { source: true, envelope: true, internalDate: true, uid: true },\n { uid: true },\n )) {\n if (!message.source) continue;\n const parsed = await simpleParser(message.source);\n const attachments: ParsedAttachment[] = [];\n for (const attachment of (parsed.attachments ?? []).slice(0, 12)) {\n attachments.push(await extractAttachment(attachment));\n }\n\n const from = cleanAddress(parsed.from?.text || message.envelope?.from?.[0]?.address || \"\");\n const to = cleanAddress(parsed.to?.text || message.envelope?.to?.[0]?.address || \"\");\n const replyTo = cleanAddress(parsed.replyTo?.text || from);\n output.push({\n uid: Number(message.uid || 0),\n messageId: String(parsed.messageId || `imap-${message.uid}-${parsed.date?.getTime() ?? Date.now()}`),\n inReplyTo: String(parsed.inReplyTo || \"\"),\n references: Array.isArray(parsed.references) ? parsed.references.map(String) : parsed.references ? [String(parsed.references)] : [],\n from,\n to,\n replyTo,\n subject: String(parsed.subject || \"\"),\n text: truncate(String(parsed.text || \"\"), 80_000),\n htmlText: truncate(typeof parsed.html === \"string\" ? parsed.html.replace(/<[^>]+>/g, \" \") : \"\", 30_000),\n date: (parsed.date || message.internalDate || new Date()).toISOString(),\n attachments,\n });\n }\n return output.sort((a, b) => a.date.localeCompare(b.date));\n } finally {\n lock.release();\n try { await client.logout(); } catch { /* ignore */ }\n }\n}\n",[],[175,308],"949bbef9-0a9d-4efb-8c0a-e4f865442a32","db.ts","f2bf1766-a7c1-11f1-ad35-1607ee4eb77e",127,["D",1788462193158],26,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { daysAgoIso, nowIso } from \"./date.ts\";\nimport type { QualifiedCandidate, RunSummary } from \"./types.ts\";\n\nexport async function initSchema(): Promise {\n await sqlite.batch([\n { sql: `CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS run_audit (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_type TEXT NOT NULL,\n started_at TEXT NOT NULL,\n completed_at TEXT,\n status TEXT NOT NULL DEFAULT 'running',\n summary_json TEXT,\n error_text TEXT\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS manufacturers (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n legal_name TEXT NOT NULL,\n brand TEXT,\n domain TEXT NOT NULL UNIQUE,\n website TEXT,\n country TEXT,\n city TEXT,\n track TEXT NOT NULL,\n actual_manufacturer INTEGER NOT NULL DEFAULT 0,\n manufacturing_locations_json TEXT,\n territory_status TEXT,\n territory_confidence REAL,\n last_researched_at TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS opportunities (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_id INTEGER,\n research_task_id INTEGER,\n manufacturer_id INTEGER NOT NULL,\n product_family TEXT NOT NULL,\n product_models_json TEXT,\n precontact_score INTEGER NOT NULL,\n postreply_score INTEGER,\n decision TEXT NOT NULL,\n qualification_json TEXT NOT NULL,\n evidence_json TEXT NOT NULL,\n recipient_name TEXT,\n recipient_role TEXT,\n recipient_email TEXT,\n exact_subject TEXT,\n exact_message TEXT,\n outreach_sent_at TEXT,\n first_followup_due_at TEXT,\n first_followup_sent_at TEXT,\n final_followup_due_at TEXT,\n final_followup_sent_at TEXT,\n reply_status TEXT NOT NULL DEFAULT 'none',\n last_reply_at TEXT,\n reply_analysis_json TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY(manufacturer_id) REFERENCES manufacturers(id),\n FOREIGN KEY(run_id) REFERENCES run_audit(id)\n )` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_opportunities_outreach ON opportunities(outreach_sent_at)` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_opportunities_reply ON opportunities(reply_status)` },\n { sql: `CREATE TABLE IF NOT EXISTS emails (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n opportunity_id INTEGER,\n direction TEXT NOT NULL,\n email_type TEXT NOT NULL,\n message_id TEXT UNIQUE,\n thread_key TEXT,\n from_address TEXT,\n to_address TEXT,\n subject TEXT,\n body_text TEXT,\n attachments_json TEXT,\n occurred_at TEXT NOT NULL,\n metadata_json TEXT,\n processing_status TEXT NOT NULL DEFAULT 'completed',\n analysis_json TEXT,\n FOREIGN KEY(opportunity_id) REFERENCES opportunities(id)\n )` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_emails_opportunity ON emails(opportunity_id)` },\n { sql: `CREATE TABLE IF NOT EXISTS quotations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n opportunity_id INTEGER NOT NULL,\n supplier_reply_task_id INTEGER,\n line_key TEXT,\n source_classification TEXT NOT NULL,\n currency TEXT,\n incoterm TEXT,\n unit_price REAL,\n units_per_box REAL,\n estimated_landed_cost_sar REAL,\n recoverable_vat_sar REAL,\n cash_requirement_including_vat_sar REAL,\n recommended_selling_price_ex_vat REAL,\n recommended_selling_price_incl_vat REAL,\n gross_profit_sar REAL,\n gross_margin_pct REAL,\n raw_quote_json TEXT NOT NULL,\n created_at TEXT NOT NULL,\n FOREIGN KEY(opportunity_id) REFERENCES opportunities(id)\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS holidays (\n date TEXT PRIMARY KEY,\n name TEXT NOT NULL\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS processing_locks (\n lock_key TEXT PRIMARY KEY,\n acquired_at TEXT NOT NULL,\n expires_at TEXT NOT NULL\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS research_batches (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n batch_key TEXT NOT NULL UNIQUE,\n scheduled_for TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'queued',\n max_contacts INTEGER NOT NULL DEFAULT 5,\n contacted_count INTEGER NOT NULL DEFAULT 0,\n summary_json TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n completed_at TEXT\n )` },\n { sql: `CREATE TABLE IF NOT EXISTS research_tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n batch_id INTEGER NOT NULL,\n track TEXT NOT NULL,\n task_type TEXT NOT NULL,\n task_key TEXT NOT NULL UNIQUE,\n payload_json TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n attempts INTEGER NOT NULL DEFAULT 0,\n available_at TEXT NOT NULL,\n started_at TEXT,\n completed_at TEXT,\n result_json TEXT,\n error_text TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY(batch_id) REFERENCES research_batches(id)\n )` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_research_tasks_next ON research_tasks(track, status, available_at, id)` },\n { sql: `CREATE TABLE IF NOT EXISTS supplier_reply_tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email_id INTEGER NOT NULL UNIQUE,\n opportunity_id INTEGER NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n attempts INTEGER NOT NULL DEFAULT 0,\n available_at TEXT NOT NULL,\n started_at TEXT,\n completed_at TEXT,\n result_json TEXT,\n error_text TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY(email_id) REFERENCES emails(id),\n FOREIGN KEY(opportunity_id) REFERENCES opportunities(id)\n )` },\n { sql: `CREATE INDEX IF NOT EXISTS idx_supplier_reply_tasks_next ON supplier_reply_tasks(status, available_at, id)` },\n ]);\n try {\n await sqlite.execute(\"ALTER TABLE opportunities ADD COLUMN research_task_id INTEGER\");\n } catch (error) {\n const message = error instanceof Error ? error.message : String(error);\n if (!/duplicate column name/i.test(message)) throw error;\n }\n await sqlite.execute(\"CREATE UNIQUE INDEX IF NOT EXISTS idx_opportunities_research_task ON opportunities(research_task_id)\");\n for (const migration of [\n \"ALTER TABLE quotations ADD COLUMN supplier_reply_task_id INTEGER\",\n \"ALTER TABLE quotations ADD COLUMN line_key TEXT\",\n ]) {\n try {\n await sqlite.execute(migration);\n } catch (error) {\n const message = error instanceof Error ? error.message : String(error);\n if (!/duplicate column name/i.test(message)) throw error;\n }\n }\n await sqlite.execute(\"CREATE UNIQUE INDEX IF NOT EXISTS idx_quotations_reply_line ON quotations(supplier_reply_task_id, line_key)\");\n}\n\nexport async function setSetting(key: string, value: unknown): Promise {\n const now = nowIso();\n await sqlite.execute({\n sql: `INSERT INTO settings(key, value, updated_at) VALUES (?, ?, ?)\n ON CONFLICT(key) DO UPDATE SET value=excluded.value, updated_at=excluded.updated_at`,\n args: [key, JSON.stringify(value), now],\n });\n}\n\nexport async function getSetting(key: string, fallback: T): Promise {\n const result = await sqlite.execute({ sql: \"SELECT value FROM settings WHERE key = ?\", args: [key] });\n const raw = result.rows[0]?.value;\n if (typeof raw !== \"string\") return fallback;\n try { return JSON.parse(raw) as T; } catch { return fallback; }\n}\n\nexport async function startRun(runType: string): Promise {\n const result = await sqlite.execute({\n sql: \"INSERT INTO run_audit(run_type, started_at, status) VALUES (?, ?, 'running') RETURNING id\",\n args: [runType, nowIso()],\n });\n return Number(result.rows[0].id);\n}\n\nexport async function finishRun(runId: number, summary: RunSummary | Record): Promise {\n await sqlite.execute({\n sql: \"UPDATE run_audit SET completed_at=?, status='completed', summary_json=? WHERE id=?\",\n args: [nowIso(), JSON.stringify(summary), runId],\n });\n}\n\nexport async function failRun(runId: number, error: unknown): Promise {\n const message = error instanceof Error ? `${error.name}: ${error.message}` : String(error);\n await sqlite.execute({\n sql: \"UPDATE run_audit SET completed_at=?, status='failed', error_text=? WHERE id=?\",\n args: [nowIso(), message.slice(0, 8000), runId],\n });\n}\n\nexport async function acquireLock(lockKey: string, minutes = 55): Promise {\n const now = new Date();\n const expires = new Date(now.getTime() + minutes * 60_000);\n await sqlite.execute({ sql: \"DELETE FROM processing_locks WHERE expires_at < ?\", args: [now.toISOString()] });\n try {\n await sqlite.execute({\n sql: \"INSERT INTO processing_locks(lock_key, acquired_at, expires_at) VALUES (?, ?, ?)\",\n args: [lockKey, now.toISOString(), expires.toISOString()],\n });\n return true;\n } catch {\n return false;\n }\n}\n\nexport async function releaseLock(lockKey: string): Promise {\n await sqlite.execute({ sql: \"DELETE FROM processing_locks WHERE lock_key = ?\", args: [lockKey] });\n}\n\nexport async function upsertManufacturer(candidate: QualifiedCandidate): Promise {\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `INSERT INTO manufacturers(\n legal_name, brand, domain, website, country, city, track, actual_manufacturer,\n manufacturing_locations_json, territory_status, territory_confidence,\n last_researched_at, created_at, updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(domain) DO UPDATE SET\n legal_name=excluded.legal_name, brand=excluded.brand, website=excluded.website,\n country=excluded.country, city=excluded.city, track=excluded.track,\n actual_manufacturer=excluded.actual_manufacturer,\n manufacturing_locations_json=excluded.manufacturing_locations_json,\n territory_status=excluded.territory_status,\n territory_confidence=excluded.territory_confidence,\n last_researched_at=excluded.last_researched_at, updated_at=excluded.updated_at\n RETURNING id`,\n args: [\n candidate.legalName, candidate.brand, candidate.domain, candidate.website,\n candidate.country, candidate.city, candidate.track, candidate.actualManufacturer ? 1 : 0,\n JSON.stringify(candidate.manufacturingLocations), candidate.territoryStatus,\n candidate.territoryConfidence, now, now, now,\n ],\n });\n return Number(result.rows[0].id);\n}\n\nexport async function createOpportunity(\n runId: number,\n manufacturerId: number,\n candidate: QualifiedCandidate,\n precontactScore: number,\n decision: string,\n researchTaskId?: number,\n): Promise {\n const now = nowIso();\n const productFamily = candidate.productFamilies.slice(0, 4).join(\"; \");\n const result = await sqlite.execute({\n sql: `INSERT INTO opportunities(\n run_id, research_task_id, manufacturer_id, product_family, product_models_json, precontact_score,\n decision, qualification_json, evidence_json, recipient_name, recipient_role,\n recipient_email, created_at, updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(research_task_id) DO UPDATE SET\n run_id=excluded.run_id,\n manufacturer_id=excluded.manufacturer_id,\n product_family=excluded.product_family,\n product_models_json=excluded.product_models_json,\n precontact_score=excluded.precontact_score,\n decision=excluded.decision,\n qualification_json=excluded.qualification_json,\n evidence_json=excluded.evidence_json,\n recipient_name=excluded.recipient_name,\n recipient_role=excluded.recipient_role,\n recipient_email=excluded.recipient_email,\n updated_at=excluded.updated_at\n RETURNING id`,\n args: [runId, researchTaskId ?? null, manufacturerId, productFamily, JSON.stringify(candidate.modelNumbers), precontactScore,\n decision, JSON.stringify(candidate), JSON.stringify(candidate.evidence), candidate.recipientName,\n candidate.recipientRole, candidate.recipientEmail, now, now],\n });\n return Number(result.rows[0].id);\n}\n\nexport async function wasRecentlyContacted(domain: string, productFamily: string, days = 90): Promise {\n const result = await sqlite.execute({\n sql: `SELECT o.id FROM opportunities o JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE lower(m.domain)=lower(?) AND lower(o.product_family)=lower(?)\n AND o.outreach_sent_at IS NOT NULL AND o.outreach_sent_at >= ? LIMIT 1`,\n args: [domain, productFamily, daysAgoIso(days)],\n });\n return result.rows.length > 0;\n}\n\nexport async function markOutreachSent(\n opportunityId: number,\n subject: string,\n message: string,\n sender: string,\n recipient: string,\n messageId: string,\n firstDue: string,\n finalDue: string,\n): Promise {\n const now = nowIso();\n await sqlite.batch([\n {\n sql: `UPDATE opportunities SET exact_subject=?, exact_message=?, outreach_sent_at=?,\n first_followup_due_at=?, final_followup_due_at=?, decision='CONTACTED — TERRITORY VERIFICATION REQUIRED', updated_at=?\n WHERE id=?`,\n args: [subject, message, now, firstDue, finalDue, now, opportunityId],\n },\n {\n sql: `INSERT OR IGNORE INTO emails(opportunity_id, direction, email_type, message_id,\n from_address, to_address, subject, body_text, occurred_at, metadata_json)\n VALUES (?, 'outbound', 'first_contact', ?, ?, ?, ?, ?, ?, '{}')`,\n args: [opportunityId, messageId, sender, recipient, subject, message, now],\n },\n ]);\n}\n\nexport async function listDueFollowups(atIso = nowIso()): Promise[]> {\n const result = await sqlite.execute({\n sql: `SELECT o.*, m.legal_name, m.brand, m.domain, m.country, m.track,\n (SELECT e.message_id FROM emails e WHERE e.opportunity_id=o.id AND e.email_type='first_contact' ORDER BY e.id ASC LIMIT 1) AS original_message_id\n FROM opportunities o JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE o.outreach_sent_at IS NOT NULL AND o.reply_status='none'\n AND ((o.first_followup_sent_at IS NULL AND o.first_followup_due_at <= ?)\n OR (o.first_followup_sent_at IS NOT NULL AND o.final_followup_sent_at IS NULL AND o.final_followup_due_at <= ?))\n ORDER BY COALESCE(o.first_followup_due_at, o.final_followup_due_at) ASC`,\n args: [atIso, atIso],\n });\n return result.rows as Record[];\n}\n\nexport async function markFollowupSent(\n opportunityId: number,\n kind: \"first_followup\" | \"final_followup\",\n subject: string,\n body: string,\n sender: string,\n recipient: string,\n messageId: string,\n): Promise {\n const now = nowIso();\n const field = kind === \"first_followup\" ? \"first_followup_sent_at\" : \"final_followup_sent_at\";\n await sqlite.batch([\n { sql: `UPDATE opportunities SET ${field}=?, updated_at=? WHERE id=?`, args: [now, now, opportunityId] },\n { sql: `INSERT OR IGNORE INTO emails(opportunity_id, direction, email_type, message_id, from_address,\n to_address, subject, body_text, occurred_at, metadata_json) VALUES (?, 'outbound', ?, ?, ?, ?, ?, ?, ?, '{}')`,\n args: [opportunityId, kind, messageId, sender, recipient, subject, body, now] },\n ]);\n}\n\nexport async function listOpenOpportunities(): Promise[]> {\n const result = await sqlite.execute(`SELECT o.*, m.legal_name, m.brand, m.domain, m.country, m.track, m.website\n FROM opportunities o JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE o.outreach_sent_at IS NOT NULL AND o.reply_status IN ('none','positive','neutral','wrong_contact')\n ORDER BY o.outreach_sent_at DESC`);\n return result.rows as Record[];\n}\n\nexport async function findOpportunityByDomain(domain: string): Promise | null> {\n const result = await sqlite.execute({\n sql: `SELECT o.*, m.legal_name, m.brand, m.domain, m.country, m.track, m.website\n FROM opportunities o JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE lower(m.domain)=lower(?) AND o.outreach_sent_at IS NOT NULL\n ORDER BY o.outreach_sent_at DESC LIMIT 1`,\n args: [domain],\n });\n return (result.rows[0] as Record | undefined) ?? null;\n}\n\nexport async function emailAlreadyProcessed(messageId: string): Promise {\n if (!messageId) return false;\n const result = await sqlite.execute({\n sql: \"SELECT id FROM emails WHERE message_id=? AND processing_status IN ('completed','ignored') LIMIT 1\",\n args: [messageId],\n });\n return result.rows.length > 0;\n}\n\nexport async function recordInboundEmail(data: {\n opportunityId?: number | null;\n messageId: string;\n threadKey?: string;\n from: string;\n to: string;\n subject: string;\n body: string;\n occurredAt: string;\n attachments: unknown[];\n metadata?: unknown;\n}): Promise {\n const result = await sqlite.execute({\n sql: `INSERT INTO emails(opportunity_id, direction, email_type, message_id, thread_key,\n from_address, to_address, subject, body_text, attachments_json, occurred_at, metadata_json, processing_status)\n VALUES (?, 'inbound', 'supplier_reply', ?, ?, ?, ?, ?, ?, ?, ?, ?, 'pending')\n ON CONFLICT(message_id) DO UPDATE SET opportunity_id=excluded.opportunity_id,\n attachments_json=excluded.attachments_json, metadata_json=excluded.metadata_json, processing_status='pending'\n RETURNING id`,\n args: [data.opportunityId ?? null, data.messageId, data.threadKey ?? \"\", data.from, data.to,\n data.subject, data.body, JSON.stringify(data.attachments), data.occurredAt, JSON.stringify(data.metadata ?? {})],\n });\n return Number(result.rows[0].id);\n}\n\nexport async function updateReplyAnalysis(opportunityId: number, status: string, analysis: unknown): Promise {\n await sqlite.execute({\n sql: `UPDATE opportunities SET reply_status=?, last_reply_at=?, reply_analysis_json=?, decision=?, updated_at=? WHERE id=?`,\n args: [status, nowIso(), JSON.stringify(analysis), String((analysis as { recommendedDecision?: string })?.recommendedDecision ?? \"MONITOR\"), nowIso(), opportunityId],\n });\n}\n\nexport async function recordOutboundClarification(\n opportunityId: number, sender: string, recipient: string, subject: string, body: string, messageId: string,\n): Promise {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO emails(opportunity_id, direction, email_type, message_id, from_address,\n to_address, subject, body_text, occurred_at, metadata_json) VALUES (?, 'outbound', 'clarification', ?, ?, ?, ?, ?, ?, '{}')`,\n args: [opportunityId, messageId, sender, recipient, subject, body, nowIso()],\n });\n}\n\nexport async function recentDashboardData(): Promise> {\n const [runs, opportunities, replies, counts] = await Promise.all([\n sqlite.execute(\"SELECT * FROM run_audit ORDER BY started_at DESC LIMIT 20\"),\n sqlite.execute(`SELECT o.id, o.product_family, o.precontact_score, o.postreply_score, o.decision,\n o.recipient_email, o.outreach_sent_at, o.reply_status, o.last_reply_at,\n m.legal_name, m.country, m.track, m.territory_status\n FROM opportunities o JOIN manufacturers m ON m.id=o.manufacturer_id\n ORDER BY o.created_at DESC LIMIT 50`),\n sqlite.execute(`SELECT e.subject, e.from_address, e.occurred_at, m.legal_name\n FROM emails e LEFT JOIN opportunities o ON o.id=e.opportunity_id\n LEFT JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE e.direction='inbound' ORDER BY e.occurred_at DESC LIMIT 20`),\n sqlite.execute(`SELECT\n (SELECT COUNT(*) FROM manufacturers) AS manufacturers,\n (SELECT COUNT(*) FROM opportunities) AS opportunities,\n (SELECT COUNT(*) FROM opportunities WHERE outreach_sent_at IS NOT NULL) AS contacted,\n (SELECT COUNT(*) FROM opportunities WHERE reply_status NOT IN ('none','queued')) AS replied,\n (SELECT COUNT(*) FROM research_tasks WHERE status IN ('pending','running')) AS research_queue,\n (SELECT COUNT(*) FROM supplier_reply_tasks WHERE status IN ('pending','running')) AS reply_queue,\n (SELECT COUNT(*) FROM research_tasks WHERE status='failed') +\n (SELECT COUNT(*) FROM supplier_reply_tasks WHERE status='failed') AS failed_tasks`),\n ]);\n return { runs: runs.rows, opportunities: opportunities.rows, replies: replies.rows, counts: counts.rows[0] ?? {} };\n}\n\n\nexport async function markEmailProcessed(messageId: string, status: \"completed\" | \"ignored\" | \"failed\", analysis?: unknown): Promise {\n await sqlite.execute({\n sql: \"UPDATE emails SET processing_status=?, analysis_json=? WHERE message_id=?\",\n args: [status, analysis === undefined ? null : JSON.stringify(analysis), messageId],\n });\n}\n\nexport async function listKnownDomains(): Promise {\n const result = await sqlite.execute(\"SELECT domain FROM manufacturers ORDER BY last_researched_at DESC\");\n return result.rows.map((row) => String(row.domain || \"\").toLowerCase()).filter(Boolean);\n}\n\nexport async function listHolidaySet(): Promise> {\n const result = await sqlite.execute(\"SELECT date FROM holidays\");\n return new Set(result.rows.map((row) => String(row.date)));\n}\n\nexport async function findOpportunityByMessageReferences(references: string[]): Promise | null> {\n const normalized = references.map(String).map((item) => item.trim()).filter(Boolean);\n if (!normalized.length) return null;\n const placeholders = normalized.map(() => \"?\").join(\",\");\n const result = await sqlite.execute({\n sql: `SELECT o.*, m.legal_name, m.brand, m.domain, m.country, m.track, m.website\n FROM emails e JOIN opportunities o ON o.id=e.opportunity_id\n JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE e.message_id IN (${placeholders}) ORDER BY o.outreach_sent_at DESC LIMIT 1`,\n args: normalized,\n });\n return (result.rows[0] as Record | undefined) ?? null;\n}\n\n\nexport async function wasDomainRecentlyContacted(domain: string, days = 90): Promise {\n const result = await sqlite.execute({\n sql: `SELECT o.id FROM opportunities o JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE lower(m.domain)=lower(?) AND o.outreach_sent_at IS NOT NULL AND o.outreach_sent_at >= ? LIMIT 1`,\n args: [domain, daysAgoIso(days)],\n });\n return result.rows.length > 0;\n}\n\nexport async function updateOpportunityDecision(opportunityId: number, decision: string, qualification?: unknown): Promise {\n if (qualification === undefined) {\n await sqlite.execute({ sql: \"UPDATE opportunities SET decision=?, updated_at=? WHERE id=?\", args: [decision, nowIso(), opportunityId] });\n return;\n }\n await sqlite.execute({\n sql: \"UPDATE opportunities SET decision=?, qualification_json=?, updated_at=? WHERE id=?\",\n args: [decision, JSON.stringify(qualification), nowIso(), opportunityId],\n });\n}\n\n\nexport async function recordQuotationEstimate(\n opportunityId: number,\n quoteLine: Record,\n estimate: Record,\n supplierReplyTaskId?: number,\n lineKey?: string,\n): Promise {\n const stableLineKey = lineKey || [\n String(quoteLine.modelNumber || \"\"),\n String(quoteLine.description || \"\"),\n String(quoteLine.currency || \"\"),\n String(quoteLine.incoterm || \"\"),\n String(quoteLine.unitPrice || \"\"),\n ].join(\"|\").toLowerCase();\n await sqlite.execute({\n sql: `INSERT INTO quotations(\n opportunity_id, supplier_reply_task_id, line_key, source_classification, currency, incoterm, unit_price, units_per_box,\n estimated_landed_cost_sar, recoverable_vat_sar, cash_requirement_including_vat_sar,\n recommended_selling_price_ex_vat, recommended_selling_price_incl_vat,\n gross_profit_sar, gross_margin_pct, raw_quote_json, created_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(supplier_reply_task_id, line_key) DO UPDATE SET\n opportunity_id=excluded.opportunity_id,\n source_classification=excluded.source_classification,\n currency=excluded.currency,\n incoterm=excluded.incoterm,\n unit_price=excluded.unit_price,\n units_per_box=excluded.units_per_box,\n estimated_landed_cost_sar=excluded.estimated_landed_cost_sar,\n recoverable_vat_sar=excluded.recoverable_vat_sar,\n cash_requirement_including_vat_sar=excluded.cash_requirement_including_vat_sar,\n recommended_selling_price_ex_vat=excluded.recommended_selling_price_ex_vat,\n recommended_selling_price_incl_vat=excluded.recommended_selling_price_incl_vat,\n gross_profit_sar=excluded.gross_profit_sar,\n gross_margin_pct=excluded.gross_margin_pct,\n raw_quote_json=excluded.raw_quote_json`,\n args: [\n opportunityId,\n supplierReplyTaskId ?? null,\n stableLineKey,\n String(quoteLine.priceSourceClassification || \"unverified_market_indication\"),\n String(quoteLine.currency || \"\"),\n String(quoteLine.incoterm || \"\"),\n Number(quoteLine.unitPrice || 0),\n Number(quoteLine.unitsPerBox || 0),\n Number(estimate.estimatedLandedCostExVatSar || 0),\n Number(estimate.recoverableVatSar || 0),\n Number(estimate.cashRequirementIncludingVatSar || 0),\n Number(estimate.recommendedSellingPriceExVatSar || 0),\n Number(estimate.recommendedSellingPriceIncludingVatSar || 0),\n Number(estimate.grossProfitPerUnitSar || 0),\n Number(estimate.grossMarginPct || 0),\n JSON.stringify({ quoteLine, estimate }),\n nowIso(),\n ],\n });\n}\n\nexport async function listQuotationEstimates(opportunityId: number): Promise[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM quotations WHERE opportunity_id=? ORDER BY created_at DESC\",\n args: [opportunityId],\n });\n return result.rows as Record[];\n}\n\n\nexport async function listDiscoveryExclusionDomains(): Promise {\n const result = await sqlite.execute({\n sql: `SELECT DISTINCT m.domain\n FROM manufacturers m JOIN opportunities o ON o.manufacturer_id=m.id\n WHERE (o.outreach_sent_at IS NOT NULL AND o.outreach_sent_at >= ?)\n OR (o.decision LIKE 'REJECT — %' AND o.created_at >= ?)\n ORDER BY m.domain`,\n args: [daysAgoIso(90), daysAgoIso(30)],\n });\n return result.rows.map((row) => String(row.domain || \"\").toLowerCase()).filter(Boolean);\n}\n\n\nexport async function createResearchBatch(batchKey: string, scheduledFor: string, maxContacts = 5): Promise {\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `INSERT INTO research_batches(batch_key, scheduled_for, status, max_contacts, created_at, updated_at)\n VALUES (?, ?, 'queued', ?, ?, ?)\n ON CONFLICT(batch_key) DO UPDATE SET updated_at=excluded.updated_at\n RETURNING id`,\n args: [batchKey, scheduledFor, maxContacts, now, now],\n });\n return Number(result.rows[0].id);\n}\n\nexport async function enqueueResearchTask(input: {\n batchId: number;\n track: string;\n taskType: \"DISCOVER\" | \"QUALIFY\";\n taskKey: string;\n payload: unknown;\n availableAt?: string;\n}): Promise {\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO research_tasks(\n batch_id, track, task_type, task_key, payload_json, status, attempts,\n available_at, created_at, updated_at\n ) VALUES (?, ?, ?, ?, ?, 'pending', 0, ?, ?, ?)`,\n args: [\n input.batchId,\n input.track,\n input.taskType,\n input.taskKey,\n JSON.stringify(input.payload),\n input.availableAt ?? now,\n now,\n now,\n ],\n });\n return Number(result.rowsAffected ?? 0) > 0;\n}\n\nexport async function recoverStaleResearchTasks(track: string, staleMinutes = 8): Promise {\n const cutoff = new Date(Date.now() - staleMinutes * 60_000).toISOString();\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `UPDATE research_tasks\n SET status=CASE WHEN attempts < 2 THEN 'pending' ELSE 'failed' END,\n available_at=?, completed_at=CASE WHEN attempts < 2 THEN NULL ELSE ? END,\n error_text=CASE WHEN attempts < 2\n THEN 'Recovered after worker execution ended before task completion'\n ELSE 'Task failed after two interrupted or timed-out attempts' END,\n updated_at=?\n WHERE track=? AND status='running' AND started_at < ?`,\n args: [now, now, now, track, cutoff],\n });\n return Number(result.rowsAffected ?? 0);\n}\n\nexport async function claimNextResearchTask(track: string): Promise | null> {\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `UPDATE research_tasks\n SET status='running', attempts=attempts+1, started_at=?, updated_at=?\n WHERE id=(\n SELECT id FROM research_tasks\n WHERE track=? AND status='pending' AND available_at <= ?\n ORDER BY CASE task_type WHEN 'DISCOVER' THEN 0 ELSE 1 END, id\n LIMIT 1\n ) AND status='pending'\n RETURNING *`,\n args: [now, now, track, now],\n });\n const task = result.rows[0] as Record | undefined;\n if (task) {\n await sqlite.execute({\n sql: \"UPDATE research_batches SET status='processing', updated_at=? WHERE id=? AND status IN ('queued','processing')\",\n args: [now, Number(task.batch_id)],\n });\n }\n return task ?? null;\n}\n\nexport async function completeResearchTask(taskId: number, resultPayload: unknown): Promise {\n const now = nowIso();\n await sqlite.execute({\n sql: `UPDATE research_tasks SET status='completed', completed_at=?, result_json=?, error_text=NULL, updated_at=? WHERE id=?`,\n args: [now, JSON.stringify(resultPayload), now, taskId],\n });\n}\n\nexport async function requeueOrFailResearchTask(task: Record, error: unknown, delayMinutes = 15): Promise<\"pending\" | \"failed\"> {\n const attempts = Number(task.attempts ?? 1);\n const message = error instanceof Error ? `${error.name}: ${error.message}` : String(error);\n const now = new Date();\n const nextStatus = attempts < 2 ? \"pending\" : \"failed\";\n const availableAt = new Date(now.getTime() + delayMinutes * 60_000).toISOString();\n await sqlite.execute({\n sql: `UPDATE research_tasks SET status=?, available_at=?, completed_at=?, error_text=?, updated_at=? WHERE id=?`,\n args: [\n nextStatus,\n nextStatus === \"pending\" ? availableAt : now.toISOString(),\n nextStatus === \"failed\" ? now.toISOString() : null,\n message.slice(0, 8000),\n now.toISOString(),\n Number(task.id),\n ],\n });\n return nextStatus;\n}\n\nexport async function reserveResearchBatchContactSlot(batchId: number): Promise {\n const result = await sqlite.execute({\n sql: `UPDATE research_batches\n SET contacted_count=contacted_count+1, updated_at=?\n WHERE id=? AND contacted_count < max_contacts\n RETURNING contacted_count`,\n args: [nowIso(), batchId],\n });\n return result.rows.length > 0;\n}\n\nexport async function releaseResearchBatchContactSlot(batchId: number): Promise {\n await sqlite.execute({\n sql: `UPDATE research_batches SET contacted_count=CASE WHEN contacted_count > 0 THEN contacted_count-1 ELSE 0 END, updated_at=? WHERE id=?`,\n args: [nowIso(), batchId],\n });\n}\n\nexport async function maybeFinalizeResearchBatch(batchId: number): Promise | null> {\n const taskCountsResult = await sqlite.execute({\n sql: `SELECT status, COUNT(*) AS count FROM research_tasks WHERE batch_id=? GROUP BY status`,\n args: [batchId],\n });\n const counts: Record = {};\n for (const row of taskCountsResult.rows) counts[String(row.status)] = Number(row.count);\n if ((counts.pending ?? 0) > 0 || (counts.running ?? 0) > 0) return null;\n\n const batchResult = await sqlite.execute({ sql: \"SELECT * FROM research_batches WHERE id=?\", args: [batchId] });\n const batch = batchResult.rows[0] as Record | undefined;\n if (!batch) return null;\n const summary = {\n batchId,\n batchKey: batch.batch_key,\n scheduledFor: batch.scheduled_for,\n taskCounts: counts,\n contactedCount: Number(batch.contacted_count ?? 0),\n completedWithErrors: (counts.failed ?? 0) > 0,\n };\n const status = summary.completedWithErrors ? \"completed_with_errors\" : \"completed\";\n const now = nowIso();\n await sqlite.execute({\n sql: `UPDATE research_batches SET status=?, summary_json=?, completed_at=COALESCE(completed_at, ?), updated_at=? WHERE id=?`,\n args: [status, JSON.stringify(summary), now, now, batchId],\n });\n return summary;\n}\n\nexport async function researchQueueStatus(batchId?: number): Promise> {\n const batchFilter = batchId ? \"WHERE id=?\" : \"ORDER BY id DESC LIMIT 10\";\n const batchArgs = batchId ? [batchId] : [];\n const batches = await sqlite.execute({ sql: `SELECT * FROM research_batches ${batchFilter}`, args: batchArgs });\n const tasks = batchId\n ? await sqlite.execute({ sql: \"SELECT * FROM research_tasks WHERE batch_id=? ORDER BY id\", args: [batchId] })\n : await sqlite.execute(\"SELECT * FROM research_tasks ORDER BY id DESC LIMIT 50\");\n return { batches: batches.rows, tasks: tasks.rows };\n}\n\n\nexport async function checkpointResearchTask(taskId: number, checkpoint: unknown): Promise {\n await sqlite.execute({\n sql: \"UPDATE research_tasks SET result_json=?, updated_at=? WHERE id=? AND status='running'\",\n args: [JSON.stringify(checkpoint), nowIso(), taskId],\n });\n}\n\nexport async function getResearchBatch(batchId: number): Promise | null> {\n const result = await sqlite.execute({ sql: \"SELECT * FROM research_batches WHERE id=?\", args: [batchId] });\n return (result.rows[0] as Record | undefined) ?? null;\n}\n\nexport async function clearResearchTaskError(taskId: number): Promise {\n await sqlite.execute({\n sql: \"UPDATE research_tasks SET error_text=NULL, updated_at=? WHERE id=?\",\n args: [nowIso(), taskId],\n });\n}\n\n\nexport async function enqueueSupplierReplyTask(emailId: number, opportunityId: number): Promise {\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO supplier_reply_tasks(\n email_id, opportunity_id, status, attempts, available_at, created_at, updated_at\n ) VALUES (?, ?, 'pending', 0, ?, ?, ?)`,\n args: [emailId, opportunityId, now, now, now],\n });\n return Number(result.rowsAffected ?? 0) > 0;\n}\n\nexport async function recoverStaleSupplierReplyTasks(staleMinutes = 8): Promise {\n const cutoff = new Date(Date.now() - staleMinutes * 60_000).toISOString();\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `UPDATE supplier_reply_tasks\n SET status=CASE WHEN attempts < 2 THEN 'pending' ELSE 'failed' END,\n available_at=?, completed_at=CASE WHEN attempts < 2 THEN NULL ELSE ? END,\n error_text=CASE WHEN attempts < 2\n THEN 'Recovered after reply worker ended before completion'\n ELSE 'Reply analysis failed after two interrupted or timed-out attempts' END,\n updated_at=?\n WHERE status='running' AND started_at < ?`,\n args: [now, now, now, cutoff],\n });\n return Number(result.rowsAffected ?? 0);\n}\n\nexport async function claimNextSupplierReplyTask(): Promise | null> {\n const now = nowIso();\n const result = await sqlite.execute({\n sql: `UPDATE supplier_reply_tasks\n SET status='running', attempts=attempts+1, started_at=?, updated_at=?\n WHERE id=(\n SELECT id FROM supplier_reply_tasks\n WHERE status='pending' AND available_at <= ?\n ORDER BY id LIMIT 1\n ) AND status='pending'\n RETURNING *`,\n args: [now, now, now],\n });\n return (result.rows[0] as Record | undefined) ?? null;\n}\n\nexport async function getSupplierReplyTaskContext(taskId: number): Promise | null> {\n const result = await sqlite.execute({\n sql: `SELECT\n t.id AS task_id, t.email_id, t.opportunity_id, t.attempts, t.result_json AS task_result_json,\n e.message_id, e.thread_key, e.from_address, e.to_address, e.subject, e.body_text,\n e.attachments_json, e.occurred_at, e.metadata_json,\n o.product_family, o.precontact_score, o.decision, o.qualification_json,\n o.recipient_email, o.exact_subject, o.outreach_sent_at, o.reply_status,\n m.legal_name, m.brand, m.domain, m.country, m.track, m.website\n FROM supplier_reply_tasks t\n JOIN emails e ON e.id=t.email_id\n JOIN opportunities o ON o.id=t.opportunity_id\n JOIN manufacturers m ON m.id=o.manufacturer_id\n WHERE t.id=?`,\n args: [taskId],\n });\n return (result.rows[0] as Record | undefined) ?? null;\n}\n\nexport async function completeSupplierReplyTask(taskId: number, resultPayload: unknown): Promise {\n const now = nowIso();\n await sqlite.execute({\n sql: `UPDATE supplier_reply_tasks SET status='completed', completed_at=?, result_json=?, error_text=NULL, updated_at=? WHERE id=?`,\n args: [now, JSON.stringify(resultPayload), now, taskId],\n });\n}\n\nexport async function requeueOrFailSupplierReplyTask(\n task: Record,\n error: unknown,\n delayMinutes = 15,\n): Promise<\"pending\" | \"failed\"> {\n const attempts = Number(task.attempts ?? 1);\n const message = error instanceof Error ? `${error.name}: ${error.message}` : String(error);\n const now = new Date();\n const status = attempts < 2 ? \"pending\" : \"failed\";\n await sqlite.execute({\n sql: `UPDATE supplier_reply_tasks SET status=?, available_at=?, completed_at=?, error_text=?, updated_at=? WHERE id=?`,\n args: [\n status,\n status === \"pending\" ? new Date(now.getTime() + delayMinutes * 60_000).toISOString() : now.toISOString(),\n status === \"failed\" ? now.toISOString() : null,\n message.slice(0, 8000),\n now.toISOString(),\n Number(task.id),\n ],\n });\n return status;\n}\n\nexport async function supplierReplyQueueStatus(): Promise> {\n const counts = await sqlite.execute(\"SELECT status, COUNT(*) AS count FROM supplier_reply_tasks GROUP BY status\");\n const recent = await sqlite.execute(`SELECT t.*, e.subject, e.from_address, m.legal_name\n FROM supplier_reply_tasks t\n JOIN emails e ON e.id=t.email_id\n JOIN opportunities o ON o.id=t.opportunity_id\n JOIN manufacturers m ON m.id=o.manufacturer_id\n ORDER BY t.id DESC LIMIT 30`);\n return { counts: counts.rows, recent: recent.rows };\n}\n\n\nexport async function checkpointSupplierReplyTask(taskId: number, checkpoint: unknown): Promise {\n await sqlite.execute({\n sql: \"UPDATE supplier_reply_tasks SET result_json=?, updated_at=? WHERE id=? AND status='running'\",\n args: [JSON.stringify(checkpoint), nowIso(), taskId],\n });\n}\n\nexport async function getOpportunityById(opportunityId: number): Promise | null> {\n const result = await sqlite.execute({\n sql: `SELECT o.*, m.legal_name, m.brand, m.domain, m.country, m.track, m.website\n FROM opportunities o JOIN manufacturers m ON m.id=o.manufacturer_id WHERE o.id=?`,\n args: [opportunityId],\n });\n return (result.rows[0] as Record | undefined) ?? null;\n}\n\n\nexport async function markReplyQueued(opportunityId: number, receivedAt: string): Promise {\n await sqlite.execute({\n sql: \"UPDATE opportunities SET reply_status='queued', last_reply_at=?, updated_at=? WHERE id=?\",\n args: [receivedAt, nowIso(), opportunityId],\n });\n}\n\n\nexport async function findRecordedClarification(\n opportunityId: number,\n subject: string,\n body: string,\n): Promise | null> {\n const result = await sqlite.execute({\n sql: `SELECT * FROM emails\n WHERE opportunity_id=? AND direction='outbound' AND email_type='clarification'\n AND subject=? AND body_text=?\n ORDER BY occurred_at DESC LIMIT 1`,\n args: [opportunityId, subject, body],\n });\n return (result.rows[0] as Record | undefined) ?? null;\n}\n",[],[175,316],"806f4bde-a188-426e-aac9-b514d0762479","date.ts","d6db52d0-a7c1-11f1-bfd1-1607ee4eb77e",5,["D",1788458640029],"const RIYADH_OFFSET_MS = 3 * 60 * 60 * 1000;\n\nexport function nowIso(): string {\n return new Date().toISOString();\n}\n\nexport function riyadhDateParts(date = new Date()): { year: number; month: number; day: number; weekday: number; hour: number } {\n const shifted = new Date(date.getTime() + RIYADH_OFFSET_MS);\n return {\n year: shifted.getUTCFullYear(),\n month: shifted.getUTCMonth() + 1,\n day: shifted.getUTCDate(),\n weekday: shifted.getUTCDay(),\n hour: shifted.getUTCHours(),\n };\n}\n\nexport function isSaudiBusinessDay(date = new Date(), holidays: Set = new Set()): boolean {\n const p = riyadhDateParts(date);\n const key = `${p.year}-${String(p.month).padStart(2, \"0\")}-${String(p.day).padStart(2, \"0\")}`;\n return p.weekday >= 0 && p.weekday <= 4 && !holidays.has(key);\n}\n\nexport function addSaudiBusinessDays(start: Date, businessDays: number, holidays: Set = new Set()): Date {\n if (!Number.isInteger(businessDays) || businessDays < 0) throw new Error(\"businessDays must be a non-negative integer\");\n let cursor = new Date(start);\n let added = 0;\n while (added < businessDays) {\n cursor = new Date(cursor.getTime() + 24 * 60 * 60 * 1000);\n if (isSaudiBusinessDay(cursor, holidays)) added += 1;\n }\n return cursor;\n}\n\nexport function daysAgoIso(days: number): string {\n return new Date(Date.now() - days * 24 * 60 * 60 * 1000).toISOString();\n}\n\nexport function safeDate(value: unknown, fallback = new Date()): Date {\n const date = new Date(String(value ?? \"\"));\n return Number.isNaN(date.getTime()) ? fallback : date;\n}\n",[],[175,325],"64ddfc6f-5504-405a-9ab3-2e4dfcc0d1f2","config.ts","389f2ece-a7c2-11f1-be7c-1607ee4eb77e",136,["D",1788462638193],"import type { ContactIdentity } from \"./types.ts\";\n\nfunction env(name: string, fallback = \"\"): string {\n return (Deno.env.get(name) ?? fallback).trim();\n}\n\nexport function getIdentity(): ContactIdentity {\n const identity: ContactIdentity = {\n name: env(\"CONTACT_NAME\"),\n company: env(\"COMPANY_NAME\"),\n phone: env(\"CONTACT_PHONE\"),\n email: env(\"BUSINESS_EMAIL\", env(\"GMAIL_USER\")),\n country: \"Saudi Arabia\",\n };\n const missing = Object.entries(identity)\n .filter(([key, value]) => key !== \"country\" && !value)\n .map(([key]) => key);\n if (missing.length) {\n throw new Error(`Outreach identity is incomplete. Missing environment values: ${missing.join(\", \")}`);\n }\n return identity;\n}\n\nexport function getRuntimeConfig() {\n const gmailUser = env(\"GMAIL_USER\");\n const gmailPass = env(\"GMAIL_PASS\");\n return {\n timezone: \"Asia/Riyadh\",\n aiModel: env(\"AI_MODEL\", \"gpt-5.4-nano\"),\n autoSendEnabled: env(\"AUTO_SEND_ENABLED\", \"true\").toLowerCase() === \"true\",\n gmailUser,\n gmailPass,\n gmailConfigured: Boolean(gmailUser && gmailPass),\n maxWeeklyContacts: Math.min(5, Math.max(1, Number(env(\"MAX_WEEKLY_CONTACTS\", \"5\")) || 5)),\n duplicateWindowDays: 90,\n ownerUsername: env(\"OWNER_VALTOWN_USERNAME\"),\n notificationPrefix: \"[Saudi Medical Agency]\",\n };\n}\n\nexport function requireGmailCredentials(): { user: string; pass: string } {\n const config = getRuntimeConfig();\n if (!config.gmailConfigured) {\n throw new Error(\"Gmail is not activated. Add the GMAIL_PASS app password to this Val Town project.\");\n }\n return { user: config.gmailUser, pass: config.gmailPass };\n}\n",[],[175,333],"6c856f36-2415-41c4-8506-d3362a6f4454","aiSchemas.ts","869279e2-a7c2-11f1-a7f2-1607ee4eb77e",126,["D",1788462140915],"const sourceProperties = {\n title: { type: \"string\" },\n url: { type: \"string\" },\n claim: { type: \"string\" },\n sourceType: {\n type: \"string\",\n enum: [\"official_manufacturer\", \"regulator\", \"government\", \"authorized_distributor\", \"trade_show\", \"professional_network\", \"other\"],\n },\n};\n\nconst sourceSchema = {\n type: \"object\",\n properties: sourceProperties,\n required: [\"title\", \"url\", \"claim\", \"sourceType\"],\n additionalProperties: false,\n};\n\nexport const discoverySchema = {\n type: \"object\",\n properties: {\n candidates: {\n type: \"array\",\n maxItems: 6,\n items: {\n type: \"object\",\n properties: {\n legalName: { type: \"string\" },\n brand: { type: \"string\" },\n country: { type: \"string\" },\n city: { type: \"string\" },\n website: { type: \"string\" },\n domain: { type: \"string\" },\n track: { type: \"string\", enum: [\"GERMAN_INSTRUMENTS\", \"DISPOSABLES\"] },\n productFamilies: { type: \"array\", items: { type: \"string\" }, maxItems: 8 },\n discoveryReason: { type: \"string\" },\n initialEvidence: { type: \"array\", items: sourceSchema, maxItems: 6 },\n },\n required: [\"legalName\", \"brand\", \"country\", \"city\", \"website\", \"domain\", \"track\", \"productFamilies\", \"discoveryReason\", \"initialEvidence\"],\n additionalProperties: false,\n },\n },\n },\n required: [\"candidates\"],\n additionalProperties: false,\n};\n\nexport const qualificationSchema = {\n type: \"object\",\n properties: {\n legalName: { type: \"string\" },\n brand: { type: \"string\" },\n country: { type: \"string\" },\n city: { type: \"string\" },\n website: { type: \"string\" },\n domain: { type: \"string\" },\n track: { type: \"string\", enum: [\"GERMAN_INSTRUMENTS\", \"DISPOSABLES\"] },\n productFamilies: { type: \"array\", items: { type: \"string\" }, maxItems: 8 },\n discoveryReason: { type: \"string\" },\n initialEvidence: { type: \"array\", items: sourceSchema, maxItems: 8 },\n actualManufacturer: { type: \"boolean\" },\n actualManufacturerConfidence: { type: \"number\", minimum: 0, maximum: 1 },\n manufacturingLocations: { type: \"array\", items: { type: \"string\" }, maxItems: 8 },\n countryOfOriginNotes: { type: \"string\" },\n exactProducts: { type: \"array\", items: { type: \"string\" }, maxItems: 12 },\n modelNumbers: { type: \"array\", items: { type: \"string\" }, maxItems: 16 },\n regulatoryEvidence: { type: \"array\", items: { type: \"string\" }, maxItems: 12 },\n qualityAdvantage: { type: \"string\" },\n commercialAdvantage: { type: \"string\" },\n saudiDistributor: { type: \"string\" },\n saudiAuthorizedRepresentative: { type: \"string\" },\n sfdaEvidence: { type: \"string\" },\n nupcoEvidence: { type: \"string\" },\n gccRepresentation: { type: \"string\" },\n exclusivityEvidence: { type: \"string\" },\n territoryStatus: {\n type: \"string\",\n enum: [\n \"Confirmed Saudi territory open\",\n \"Manufacturer actively seeking Saudi distributor\",\n \"Strong indication territory is open\",\n \"No public Saudi representative identified\",\n \"Existing Saudi representation, exclusivity unknown\",\n \"Existing Saudi non-exclusive distributor\",\n \"Confirmed exclusive Saudi distributor\",\n \"Direct Saudi office\",\n \"Saudi local-manufacturing partnership\",\n \"Distributor change identified\",\n \"Evidence insufficient\",\n ],\n },\n territoryConfidence: { type: \"number\", minimum: 0, maximum: 1 },\n recipientName: { type: \"string\" },\n recipientRole: { type: \"string\" },\n recipientEmail: { type: \"string\" },\n contactSourceUrl: { type: \"string\" },\n score: {\n type: \"object\",\n properties: {\n manufacturerAndProductFit: { type: \"integer\", minimum: 0, maximum: 25 },\n publicRegulatoryCredibility: { type: \"integer\", minimum: 0, maximum: 15 },\n saudiTerritoryPotential: { type: \"integer\", minimum: 0, maximum: 20 },\n differentiationOrCommercialAdvantage: { type: \"integer\", minimum: 0, maximum: 15 },\n recurringSaudiDemand: { type: \"integer\", minimum: 0, maximum: 10 },\n exportCredibilityAndSupplyReliability: { type: \"integer\", minimum: 0, maximum: 10 },\n officialContactQuality: { type: \"integer\", minimum: 0, maximum: 5 },\n },\n required: [\"manufacturerAndProductFit\", \"publicRegulatoryCredibility\", \"saudiTerritoryPotential\", \"differentiationOrCommercialAdvantage\", \"recurringSaudiDemand\", \"exportCredibilityAndSupplyReliability\", \"officialContactQuality\"],\n additionalProperties: false,\n },\n risks: { type: \"array\", items: { type: \"string\" }, maxItems: 12 },\n evidence: { type: \"array\", items: sourceSchema, maxItems: 16 },\n },\n required: [\n \"legalName\", \"brand\", \"country\", \"city\", \"website\", \"domain\", \"track\", \"productFamilies\", \"discoveryReason\", \"initialEvidence\",\n \"actualManufacturer\", \"actualManufacturerConfidence\", \"manufacturingLocations\", \"countryOfOriginNotes\", \"exactProducts\", \"modelNumbers\",\n \"regulatoryEvidence\", \"qualityAdvantage\", \"commercialAdvantage\", \"saudiDistributor\", \"saudiAuthorizedRepresentative\", \"sfdaEvidence\",\n \"nupcoEvidence\", \"gccRepresentation\", \"exclusivityEvidence\", \"territoryStatus\", \"territoryConfidence\", \"recipientName\", \"recipientRole\",\n \"recipientEmail\", \"contactSourceUrl\", \"score\", \"risks\", \"evidence\",\n ],\n additionalProperties: false,\n};\n\nconst decisions = [\n \"CONTACTED — HIGH-PRIORITY OPPORTUNITY\",\n \"CONTACTED — PRICE VERIFICATION REQUIRED\",\n \"CONTACTED — TERRITORY VERIFICATION REQUIRED\",\n \"REQUEST SAMPLES\",\n \"REQUEST FORMAL QUOTATION\",\n \"NEGOTIATE SAUDI EXCLUSIVITY\",\n \"DISCUSS OEM/PRIVATE LABEL\",\n \"MONITOR\",\n \"BENCHMARK ONLY\",\n \"REJECT — TERRITORY OCCUPIED\",\n \"REJECT — PRICE NOT COMPETITIVE\",\n \"REJECT — INSUFFICIENT QUALITY\",\n \"REJECT — INADEQUATE DOCUMENTATION\",\n \"REJECT — TOO COMMODITIZED\",\n];\n\nexport const replyAnalysisSchema = {\n type: \"object\",\n properties: {\n classification: {\n type: \"string\",\n description: \"Classify the supplier's actual reply. Use positive when the supplier expresses interest, confirms open territory, or provides requested commercial information. Use territory_occupied only for explicit or conclusively verified blocked Saudi territory. Use neutral for unresolved conflicts or incomplete non-negative replies.\",\n enum: [\"positive\", \"neutral\", \"negative\", \"territory_occupied\", \"wrong_contact\", \"automatic\", \"unrelated\"],\n },\n confidence: { type: \"number\", minimum: 0, maximum: 1 },\n summary: { type: \"string\" },\n territoryStatement: { type: \"string\" },\n priceSourceClassification: {\n type: \"string\",\n enum: [\"official_manufacturer_quotation\", \"official_distributor_quotation\", \"saudi_distributor_quotation\", \"public_saudi_selling_price\", \"government_or_tender_price\", \"international_reseller_price\", \"estimated_price\", \"unverified_market_indication\", \"not_provided\"],\n },\n quoteLines: {\n type: \"array\",\n description: \"Only explicit numeric product quotations contained in the supplier email or its attachments. Omit unpriced products, promised future price lists, and unrelated public web prices.\",\n maxItems: 40,\n items: {\n type: \"object\",\n properties: {\n modelNumber: { type: \"string\" },\n description: { type: \"string\" },\n configurationKey: {\n type: \"string\",\n enum: [\n \"adult_split_without_cable_rem\",\n \"adult_solid_without_cable\",\n \"adult_split_with_2_8m_cable_rem\",\n \"other\",\n ],\n },\n unitPrice: { type: \"number\", exclusiveMinimum: 0 },\n currency: { type: \"string\" },\n incoterm: { type: \"string\" },\n unitsInPriceBasis: { type: \"number\", exclusiveMinimum: 0 },\n unitsPerBox: { type: \"number\", minimum: 0 },\n priceSourceClassification: {\n type: \"string\",\n enum: [\"official_manufacturer_quotation\", \"official_distributor_quotation\", \"saudi_distributor_quotation\", \"public_saudi_selling_price\", \"government_or_tender_price\", \"international_reseller_price\", \"estimated_price\", \"unverified_market_indication\"],\n },\n },\n required: [\"modelNumber\", \"description\", \"configurationKey\", \"unitPrice\", \"currency\", \"incoterm\", \"unitsInPriceBasis\", \"unitsPerBox\", \"priceSourceClassification\"],\n additionalProperties: false,\n },\n },\n extracted: {\n type: \"object\",\n properties: {\n currencies: { type: \"array\", items: { type: \"string\" } },\n incoterms: { type: \"array\", items: { type: \"string\" } },\n modelNumbers: { type: \"array\", items: { type: \"string\" } },\n prices: { type: \"array\", items: { type: \"string\" } },\n moq: { type: \"string\" },\n boxQuantities: { type: \"string\" },\n leadTime: { type: \"string\" },\n shelfLife: { type: \"string\" },\n countryOfOrigin: { type: \"string\" },\n certifications: { type: \"array\", items: { type: \"string\" } },\n sampleTerms: { type: \"string\" },\n exclusivityTerms: { type: \"string\" },\n paymentTerms: { type: \"string\" },\n },\n required: [\"currencies\", \"incoterms\", \"modelNumbers\", \"prices\", \"moq\", \"boxQuantities\", \"leadTime\", \"shelfLife\", \"countryOfOrigin\", \"certifications\", \"sampleTerms\", \"exclusivityTerms\", \"paymentTerms\"],\n additionalProperties: false,\n },\n missingCriticalInformation: { type: \"array\", items: { type: \"string\" }, maxItems: 12 },\n prohibitedCommitmentDetected: { type: \"boolean\" },\n recommendedDecision: { type: \"string\", enum: decisions },\n shouldSendRoutineClarification: { type: \"boolean\" },\n clarificationSubject: { type: \"string\" },\n clarificationBody: { type: \"string\" },\n },\n required: [\"classification\", \"confidence\", \"summary\", \"territoryStatement\", \"priceSourceClassification\", \"quoteLines\", \"extracted\", \"missingCriticalInformation\", \"prohibitedCommitmentDetected\", \"recommendedDecision\", \"shouldSendRoutineClarification\", \"clarificationSubject\", \"clarificationBody\"],\n additionalProperties: false,\n};\n",[],[175,341],"4d0a81c2-5e87-4c8d-ba8a-d59c6600cb97","ai.ts","acb0bb84-a7c2-11f1-b254-1607ee4eb77e",124,["D",1788462120661],12,"import { ValTownOpenAI } from \"https://esm.town/v/std/openai/main.ts\";\nimport { getRuntimeConfig, getIdentity } from \"./config.ts\";\nimport { getSetting } from \"./db.ts\";\nimport { discoverySchema, qualificationSchema, replyAnalysisSchema } from \"./aiSchemas.ts\";\nimport { normalizeDomain } from \"./safeguards.ts\";\nimport type { CandidateSeed, QualifiedCandidate, SupplierReplyAnalysis, Track } from \"./types.ts\";\nimport type { ParsedInboxMessage } from \"./email.ts\";\n\nconst openai = new ValTownOpenAI({ timeout: 45_000, maxRetries: 0 });\n\nasync function structured(input: {\n name: string;\n schema: Record;\n instructions: string;\n userInput: any;\n webSearch?: boolean;\n maxOutputTokens?: number;\n}): Promise {\n const config = getRuntimeConfig();\n const startedAt = Date.now();\n console.log(JSON.stringify({ event: \"ai_request_started\", name: input.name, webSearch: Boolean(input.webSearch) }));\n try {\n const response = await openai.responses.create({\n model: config.aiModel,\n tools: input.webSearch ? [{ type: \"web_search\" }] : undefined,\n instructions: input.instructions,\n input: input.userInput,\n max_output_tokens: input.maxOutputTokens ?? 4_500,\n reasoning: { effort: \"low\" },\n text: {\n format: {\n type: \"json_schema\",\n name: input.name,\n strict: true,\n schema: input.schema,\n },\n },\n } as any);\n const text = String(response.output_text || \"\").trim();\n if (!text) throw new Error(`AI returned no structured output for ${input.name}`);\n const parsed = JSON.parse(text) as T;\n console.log(JSON.stringify({ event: \"ai_request_completed\", name: input.name, elapsedMs: Date.now() - startedAt }));\n return parsed;\n } catch (error) {\n console.error(JSON.stringify({\n event: \"ai_request_failed\",\n name: input.name,\n elapsedMs: Date.now() - startedAt,\n error: error instanceof Error ? `${error.name}: ${error.message}` : String(error),\n }));\n throw error;\n }\n}\n\nfunction trackDiscoveryFocus(track: Track): string {\n if (track === \"GERMAN_INSTRUMENTS\") {\n return `Find actual German reusable surgical-instrument manufacturers, prioritizing Tuttlingen and comparable German clusters. Focus on general surgery, ENT, urology, gynecology, laparoscopy, neurosurgery, cardiovascular, orthopedic, micro, tungsten-carbide, bipolar/monopolar, retractors, scissors, forceps, needle holders, clamps, specula, suction instruments, instrument sets, and customized sets. Do not assume German headquarters means every product is made in Germany.`;\n }\n return `Find actual manufacturers of hospital and operating-room disposables, electrosurgical disposable accessories, custom procedure packs, CSSD consumables, absorbent surgical products, wound care, and defensibly differentiated high-volume consumables. Search Germany first, then credible manufacturers in Spain, Italy, Poland, Czech Republic, Portugal, Austria, Switzerland, France, Belgium, Netherlands, United Kingdom, Turkey, and other credible manufacturing countries. Reject undifferentiated commodities unless there is a defensible price, safety, regulatory, capacity, shelf-life, packaging, private-label, GCC-stock, or exclusivity advantage.`;\n}\n\nexport async function discoverCandidates(track: Track, excludedDomains: string[]): Promise {\n const policy = await getSetting(\"research_policy\", \"Use conservative evidence-based supplier research. Never invent facts or contacts.\");\n const today = new Date().toISOString().slice(0, 10);\n const result = await structured<{ candidates: CandidateSeed[] }>({\n name: \"manufacturer_discovery\",\n schema: discoverySchema,\n webSearch: true,\n maxOutputTokens: 4_000,\n instructions: `You are a rigorous medical-device manufacturer sourcing analyst working for the Saudi market.\n\n${policy}\n\nRules:\n- Use current web research as of ${today}.\n- Return no more than three strongest new candidates, ordered by likely commercial attractiveness.\n- A candidate must appear to be an actual manufacturer, not merely a reseller.\n- Use official manufacturer evidence wherever possible.\n- Do not call a territory open merely because no public Saudi distributor was found.\n- Do not invent model numbers, certifications, distributor status, contact details, or pricing.\n- Do not return benchmark/reference companies merely for prestige; return a company only when there is a plausible new Saudi opportunity.\n- Evidence URLs must support the claim beside them.\n- Exclude these domains: ${excludedDomains.join(\", \") || \"none\"}.`,\n userInput: `${trackDiscoveryFocus(track)}\\n\\nIdentify commercially credible candidates for Saudi distribution or agency evaluation.`,\n });\n return result.candidates\n .map((candidate) => ({ ...candidate, domain: normalizeDomain(candidate.domain || candidate.website), track }))\n .filter((candidate) => candidate.domain && !excludedDomains.includes(candidate.domain));\n}\n\nexport async function qualifyCandidate(seed: CandidateSeed): Promise {\n const policy = await getSetting(\"qualification_policy\", \"Verify manufacturer status, Saudi representation, regulatory credibility, differentiation, and an official decision-maker before recommending outreach.\");\n const today = new Date().toISOString().slice(0, 10);\n const result = await structured({\n name: \"manufacturer_qualification\",\n schema: qualificationSchema,\n webSearch: true,\n maxOutputTokens: 5_000,\n instructions: `You are performing a pre-contact due-diligence investigation for a Saudi medical-products distributor.\n\n${policy}\n\nCurrent date: ${today}.\n\nMandatory discipline:\n- Investigate the supplied company only.\n- Verify whether it actually manufactures the target products and where.\n- Distinguish headquarters, legal address, warehouse, and manufacturing site.\n- Do not state Made in Germany or any country of origin without evidence at product-family level.\n- Check official manufacturer pages, official documents, regulator/government evidence, Saudi distributor sites, public Saudi authorized-representative evidence, SFDA/MDMA evidence, NUPCO/tender evidence, GCC distributors, credible distributor announcements, and trade-show evidence.\n- No public Saudi distributor found means only “No public Saudi representative identified,” never confirmed open territory.\n- A confirmed exclusive Saudi distributor, direct Saudi office, or local-manufacturing partnership blocks automatic outreach unless credible evidence shows an additional-channel or distributor-change opportunity.\n- Recipient priority: Export Director; International Sales Manager; Middle East/GCC Sales Manager; Managing Director for a small manufacturer; official export department; official general email last.\n- The recipient email must be shown on the company’s official domain. If not found, leave recipient fields blank rather than guessing.\n- Score conservatively in WHOLE POINTS, not decimals or proportions. Use these exact ranges: manufacturer/product fit 0–25; public regulatory credibility 0–15; Saudi territory potential 0–20; differentiation/commercial advantage 0–15; recurring Saudi demand 0–10; export credibility/supply reliability 0–10; official contact quality 0–5. Example: 20 means 20 points out of 25; never write 0.8 to mean 80%.\n- Public price speculation is not an official factory quote.\n- Evidence must be claim-specific and traceable. Unknown facts must remain explicit as unknown or evidence insufficient.\n- Quality cannot be inferred from nationality alone.\n- The first contact is only territory and initial-commercial screening; do not demand the full due-diligence questionnaire yet.`,\n userInput: `Candidate seed:\\n${JSON.stringify(seed, null, 2)}\\n\\nPerform full public pre-contact qualification and return the exact structured record.`,\n });\n result.domain = normalizeDomain(result.domain || result.website || seed.domain);\n result.track = seed.track;\n return result;\n}\n\nexport async function analyzeSupplierReply(\n opportunity: Record,\n message: ParsedInboxMessage,\n): Promise {\n const policy = await getSetting(\"reply_policy\", \"Extract supplier facts, identify missing commercial information, and send only routine non-committal clarifications when safe.\");\n const identity = getIdentity();\n const attachmentText = message.attachments.map((attachment) => [\n `ATTACHMENT: ${attachment.filename}`,\n `TYPE: ${attachment.contentType}`,\n `SIZE: ${attachment.size}`,\n attachment.extractionWarning ? `WARNING: ${attachment.extractionWarning}` : \"\",\n attachment.extractedText,\n ].filter(Boolean).join(\"\\n\")).join(\"\\n\\n\");\n\n const contextText = `Analyze this supplier reply and all extracted attachment content.\n\nINTERNAL OPPORTUNITY RECORD\n${JSON.stringify(opportunity, null, 2)}\n\nEMAIL\nFrom: ${message.from}\nReply-To: ${message.replyTo}\nSubject: ${message.subject}\nDate: ${message.date}\nBody:\n${message.text || message.htmlText}\n\nATTACHMENT CONTENT\n${attachmentText || \"No extracted attachment text.\"}`;\n\n const content: any[] = [{ type: \"input_text\", text: contextText }];\n for (const attachment of message.attachments.filter((item) => item.imageDataUrl).slice(0, 4)) {\n content.push({ type: \"input_image\", image_url: attachment.imageDataUrl });\n }\n\n return await structured({\n name: \"supplier_reply_analysis\",\n schema: replyAnalysisSchema,\n webSearch: true,\n maxOutputTokens: 6_000,\n instructions: `You are a medical-supplier commercial analyst. ${policy}\n\nRules:\n- Read the full email and every provided attachment extraction.\n- The supplier email and attachments are the primary evidence for what the supplier stated. Public web search may verify or challenge a claim, but it must not silently rewrite an explicit supplier statement. If an explicit supplier statement conflicts with credible public evidence, classify the reply as neutral, quote the conflict in the summary, and place the issue in missingCriticalInformation for human verification.\n- Use territory_occupied only when the supplier explicitly says Saudi Arabia is assigned, closed, exclusive, or unavailable, or when credible current evidence conclusively proves a blocking Saudi relationship. An explicit statement that Saudi Arabia is open and has no distributor is positive, not territory_occupied.\n- Extract exact prices, currency, price basis, Incoterms, MOQ, carton quantities, model numbers, lead times, shelf life, origin, certifications, samples, territory, exclusivity, and payment terms without inventing missing facts.\n- Create a quoteLines entry only when the email or attachment explicitly provides a positive numeric price, currency, and identifiable product or model. Do not create a quote line for a product that is merely mentioned, for a price promised later, or from an unrelated public web price. Preserve the exact quoted number and price basis.\n- For quoteLines.configurationKey, use adult_split_without_cable_rem only for an adult split/dual REM-compatible pad with no attached cable; adult_solid_without_cable only for an adult solid pad with no cable; adult_split_with_2_8m_cable_rem only for an adult split/dual REM-compatible pad with an attached 2.8-metre cable; otherwise use other. Never force a benchmark key onto an unlike product.\n- Classify price provenance by who issued the written quotation. Pricing issued directly by the manufacturer is official_manufacturer_quotation even when it is described as a distributor price list. Use official_distributor_quotation only when an authorized distributor—not the manufacturer—issued it. A reseller or public price is never a factory quotation.\n- Verify certificate claims and quoted-model coverage through current public evidence where possible; unresolved validity remains missing information.\n- Never disclose internal benchmark prices.\n- Never accept a quotation, place an order, accept exclusivity, commit to annual targets, provide bank details, pay for samples, approve registration spending, or promise volumes.\n- A routine clarification may be drafted only for missing factual items such as price list, model, MOQ, Incoterm, origin, shelf life, certifications, samples, territory, connector compatibility, or lead time.\n- Ask no more than six grouped questions, only for information not already supplied.\n- If the reply is automatic, unrelated, negative, or confirms occupied territory, do not draft a clarification.\n- The clarification must be professional, short, non-committal, and signed exactly as:\n${identity.name}\\n${identity.company}\\n${identity.phone}\\n${identity.email}\n- Set shouldSendRoutineClarification false when confidence is below 0.75 or a human decision is required.`,\n userInput: [{ role: \"user\", content }],\n });\n}\n",[],[175,349],["D",1788458586756],[220,221,222,223,224,225,226,227,228,229,230,231,232],[175],"57563f35-5e15-4af0-ae05-0a5173e1b00b","weekly.ts","f644607e-a7c3-11f1-85ee-1607ee4eb77e",163,["D",1788464289615],"import { startDailyResearchBatch } from \"../lib/researchQueue.ts\";\n\nexport default async function (_interval: Interval) {\n return await startDailyResearchBatch();\n}\n",[],[182,361],"7cae1dd1-a513-43c3-a806-076aabe17cab","reply-worker.ts","f9abc798-a7c8-11f1-941c-1607ee4eb77e",167,["D",1788464333542],"import { processSupplierReplyWorker } from \"../lib/replyWorker.ts\";\n\nexport default async function (_interval: Interval) {\n return await processSupplierReplyWorker();\n}\n",[],[182,369],"f9b562c9-24aa-499a-aff2-0cd09444ddd0","german-worker.ts","23d06274-a7c7-11f1-b3de-1607ee4eb77e",164,["D",1788464299052],"import { processResearchWorker } from \"../lib/researchQueue.ts\";\n\nexport default async function (_interval: Interval) {\n return await processResearchWorker(\"GERMAN_INSTRUMENTS\");\n}\n",[],[182,377],"54ad002e-2718-45f7-b876-ca61f50eaf78","disposables-worker.ts","2898fe4c-a7c7-11f1-bc46-1607ee4eb77e",165,["D",1788464306750],"import { processResearchWorker } from \"../lib/researchQueue.ts\";\n\nexport default async function (_interval: Interval) {\n return await processResearchWorker(\"DISPOSABLES\");\n}\n",[],[182,385],"9f960db6-28be-434e-a4d5-b52e1f90b631","daily.ts","fcd5b910-a7c3-11f1-82ef-1607ee4eb77e",166,["D",1788464317345],[],[182,393],"005e442d-acc3-4d29-b8bb-3ac2734ba937","daily-research.ts","677daf42-a7cf-11f1-a4d2-1607ee4eb77e",168,["D",1788464466140],[],[182,400],"f761f43f-3195-4c3b-8025-680eaf1bb2e6",["D",1788464499127],[],[182,32],"9dfc81af-46bb-499a-9057-0fdbab86053b","daily-german-worker.ts","6d3ee9a0-a7cf-11f1-9439-1607ee4eb77e",169,["D",1788464475789],[],[182,411],"a5a9e5f6-7d9c-4fd2-85c9-df363e56d797","daily-disposables-worker.ts","748ac0a8-a7cf-11f1-b78c-1607ee4eb77e",170,["D",1788464488038],[],[182,418],["D",1788458594032],[210,211,212,213,214,215,216,217,218],[182],"1e7b51f5-6bcd-4b91-9299-504a935b7a29","80bc25ac-a7c9-11f1-b1cf-1607ee4eb77e",138,["D",1788462661516],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initSchema } from \"../lib/db.ts\";\nimport { processSupplierReplyWorker } from \"../lib/replyWorker.ts\";\n\nfunction assert(condition: unknown, message: string): asserts condition {\n if (!condition) throw new Error(`Reply-worker diagnostic failed: ${message}`);\n}\n\nawait initSchema();\nconst token = crypto.randomUUID();\nconst domain = `diagnostic-${token}.invalid`;\nconst now = new Date().toISOString();\nlet manufacturerId = 0;\nlet opportunityId = 0;\nlet emailId = 0;\nlet taskId = 0;\nlet workerRunId = 0;\nlet finalOutput: Record = {};\n\ntry {\n const manufacturer = await sqlite.execute({\n sql: `INSERT INTO manufacturers(\n legal_name, brand, domain, website, country, city, track, actual_manufacturer,\n manufacturing_locations_json, territory_status, territory_confidence,\n last_researched_at, created_at, updated_at\n ) VALUES (?, ?, ?, ?, 'Italy', 'Turin', 'DISPOSABLES', 1, ?,\n 'Confirmed Saudi territory open', 0.95, ?, ?, ?) RETURNING id`,\n args: [\n \"Diagnostic Electrosurgical Manufacturer S.r.l.\",\n \"Diagnostic ESU\",\n domain,\n `https://${domain}`,\n JSON.stringify([\"Turin, Italy\"]),\n now,\n now,\n now,\n ],\n });\n manufacturerId = Number(manufacturer.rows[0].id);\n\n const opportunity = await sqlite.execute({\n sql: `INSERT INTO opportunities(\n run_id, research_task_id, manufacturer_id, product_family, product_models_json,\n precontact_score, decision, qualification_json, evidence_json, recipient_name,\n recipient_role, recipient_email, exact_subject, exact_message, outreach_sent_at,\n first_followup_due_at, final_followup_due_at, reply_status, created_at, updated_at\n ) VALUES (NULL, NULL, ?, ?, '[]', 82, 'CONTACTED — TERRITORY VERIFICATION REQUIRED',\n '{}', '[]', 'Export Manager', 'International Sales Manager', ?, ?, ?, ?, ?, ?, 'queued', ?, ?)\n RETURNING id`,\n args: [\n manufacturerId,\n \"adult split REM return electrodes without cable; disposable push-button pencils\",\n `export@${domain}`,\n \"Saudi Arabia Distribution Opportunity – Diagnostic ESU Electrosurgical Disposables\",\n \"Diagnostic first-contact email\",\n now,\n new Date(Date.now() + 5 * 86_400_000).toISOString(),\n new Date(Date.now() + 10 * 86_400_000).toISOString(),\n now,\n now,\n ],\n });\n opportunityId = Number(opportunity.rows[0].id);\n\n const inbound = await sqlite.execute({\n sql: `INSERT INTO emails(\n opportunity_id, direction, email_type, message_id, thread_key, from_address,\n to_address, subject, body_text, attachments_json, occurred_at, metadata_json,\n processing_status\n ) VALUES (?, 'inbound', 'supplier_reply', ?, ?, ?, 'owner@example.invalid', ?, ?, '[]', ?, ?, 'pending')\n RETURNING id`,\n args: [\n opportunityId,\n ``,\n ``,\n `export@${domain}`,\n \"Re: Saudi Arabia Distribution Opportunity – Diagnostic ESU Electrosurgical Disposables\",\n `Dear Mr. Khadim,\n\nThank you for your inquiry. Saudi Arabia is currently open, and we do not have a Saudi distributor or authorized representative.\n\nWe manufacture model ALT-REM-01, an adult split REM-compatible patient-return electrode without cable. This written quotation is issued directly by us as the manufacturer: our distributor unit price is EUR 0.78 per unit EXW Turin. MOQ is 50,000 units, packed 100 units per box. Production lead time is six weeks and shelf life is three years. The product is non-sterile, latex-free, CE marked under the MDR, and manufactured under ISO 13485. Samples are available without charge, but courier cost is for the distributor.\n\nWe also manufacture disposable push-button electrosurgical pencils and can send that price list separately. Please advise your expected annual volume and whether you require Arabic private-label packaging.\n\nBest regards,\nInternational Sales Manager`,\n now,\n JSON.stringify({\n diagnosticDryRun: true,\n replyTo: `export@${domain}`,\n inReplyTo: ``,\n references: [``],\n uid: 0,\n }),\n ],\n });\n emailId = Number(inbound.rows[0].id);\n\n const task = await sqlite.execute({\n sql: `INSERT INTO supplier_reply_tasks(\n email_id, opportunity_id, status, attempts, available_at, created_at, updated_at\n ) VALUES (?, ?, 'pending', 0, ?, ?, ?) RETURNING id`,\n args: [emailId, opportunityId, now, now, now],\n });\n taskId = Number(task.rows[0].id);\n\n const result = await processSupplierReplyWorker();\n workerRunId = Number(result.runId || 0);\n const [taskState, opportunityState, quotationState, outboundState] = await Promise.all([\n sqlite.execute({ sql: \"SELECT status, attempts, result_json, error_text FROM supplier_reply_tasks WHERE id=?\", args: [taskId] }),\n sqlite.execute({ sql: \"SELECT reply_status, decision, reply_analysis_json FROM opportunities WHERE id=?\", args: [opportunityId] }),\n sqlite.execute({ sql: \"SELECT * FROM quotations WHERE supplier_reply_task_id=?\", args: [taskId] }),\n sqlite.execute({\n sql: `SELECT COUNT(*) AS count FROM emails\n WHERE opportunity_id=? AND direction='outbound' AND email_type='clarification'`,\n args: [opportunityId],\n }),\n ]);\n\n const taskRow = taskState.rows[0] as Record;\n const opportunityRow = opportunityState.rows[0] as Record;\n const firstQuotation = quotationState.rows[0] as Record | undefined;\n const rawQuotation = firstQuotation?.raw_quote_json\n ? JSON.parse(String(firstQuotation.raw_quote_json)) as Record\n : {};\n const outboundCount = Number(outboundState.rows[0]?.count ?? 0);\n assert(result.ok && result.taskStatus === \"completed\", `worker returned ${JSON.stringify(result)}`);\n assert(taskRow.status === \"completed\", `task status is ${String(taskRow.status)}`);\n assert([\"positive\", \"neutral\"].includes(String(opportunityRow.reply_status)), `reply status is ${String(opportunityRow.reply_status)}`);\n assert(quotationState.rows.length >= 1, \"numeric quotation was not extracted and costed\");\n assert(rawQuotation.quoteLine?.configurationKey === \"adult_split_without_cable_rem\", `configuration key is ${String(rawQuotation.quoteLine?.configurationKey)}`);\n assert(rawQuotation.quoteLine?.priceSourceClassification === \"official_manufacturer_quotation\", `price provenance is ${String(rawQuotation.quoteLine?.priceSourceClassification)}`);\n assert(rawQuotation.estimate?.bovieComparison?.applicable === true, \"like-for-like BOVIE comparison was not applied\");\n assert(outboundCount === 0, `dry run created ${outboundCount} outbound clarification email record(s)`);\n\n finalOutput = {\n ok: true,\n workerResult: result,\n replyStatus: opportunityRow.reply_status,\n decision: opportunityRow.decision,\n quotationCount: quotationState.rows.length,\n firstQuotation: quotationState.rows[0] ?? null,\n outboundSupplierEmails: outboundCount,\n diagnosticDryRun: true,\n };\n} finally {\n if (taskId) await sqlite.execute({ sql: \"DELETE FROM quotations WHERE supplier_reply_task_id=?\", args: [taskId] });\n if (taskId) await sqlite.execute({ sql: \"DELETE FROM supplier_reply_tasks WHERE id=?\", args: [taskId] });\n if (opportunityId) await sqlite.execute({ sql: \"DELETE FROM emails WHERE opportunity_id=?\", args: [opportunityId] });\n if (opportunityId) await sqlite.execute({ sql: \"DELETE FROM opportunities WHERE id=?\", args: [opportunityId] });\n if (manufacturerId) await sqlite.execute({ sql: \"DELETE FROM manufacturers WHERE id=?\", args: [manufacturerId] });\n if (workerRunId) await sqlite.execute({ sql: \"DELETE FROM run_audit WHERE id=?\", args: [workerRunId] });\n}\n\n\nconsole.log(JSON.stringify(finalOutput));\nexport default finalOutput;\n",[],[188,369],"1c48a8cf-e10c-453a-b93f-0962d726fe67","qualification.ts","d2848338-a7c5-11f1-ba13-1607ee4eb77e",68,["D",1788460350734],"import { qualifyCandidate } from \"../lib/ai.ts\";\nimport { initSchema } from \"../lib/db.ts\";\nimport type { CandidateSeed } from \"../lib/types.ts\";\n\nawait initSchema();\nconst seed: CandidateSeed = {\n legalName: \"DUFNER Instrumente GmbH\",\n brand: \"DUFNER\",\n country: \"Germany\",\n city: \"Tuttlingen\",\n website: \"https://dufner-tuttlingen.de/\",\n domain: \"dufner-tuttlingen.de\",\n track: \"GERMAN_INSTRUMENTS\",\n productFamilies: [\n \"reusable surgical instruments\",\n \"micro instruments\",\n \"gynecology instruments\",\n \"urology sets\",\n \"bipolar instruments\",\n ],\n discoveryReason: \"The official company presence indicates reusable surgical-instrument manufacturing and specialized electrosurgical instrument capabilities.\",\n initialEvidence: [\n {\n title: \"DUFNER official website\",\n url: \"https://dufner-tuttlingen.de/\",\n claim: \"Official company and product presence\",\n sourceType: \"official_manufacturer\",\n },\n ],\n};\n\nconst started = Date.now();\nconst candidate = await qualifyCandidate(seed);\nconst output = {\n ok: true,\n elapsedMs: Date.now() - started,\n legalName: candidate.legalName,\n actualManufacturer: candidate.actualManufacturer,\n territoryStatus: candidate.territoryStatus,\n recipientEmail: candidate.recipientEmail,\n evidenceCount: candidate.evidence.length,\n score: candidate.score,\n};\nconsole.log(JSON.stringify(output));\nexport default output;\n",[],[188,435],"f9823392-1dd1-41e0-9f47-52397c8a8844","discovery.ts","ad1fd39a-a7c5-11f1-b61f-1607ee4eb77e",67,["D",1788460287990],"import { discoverCandidates } from \"../lib/ai.ts\";\nimport { initSchema } from \"../lib/db.ts\";\n\nawait initSchema();\nconst started = Date.now();\nconst candidates = await discoverCandidates(\"GERMAN_INSTRUMENTS\", []);\nconst output = {\n ok: true,\n elapsedMs: Date.now() - started,\n count: candidates.length,\n candidates: candidates.map((candidate) => ({\n legalName: candidate.legalName,\n country: candidate.country,\n domain: candidate.domain,\n productFamilies: candidate.productFamilies,\n evidenceCount: candidate.initialEvidence.length,\n })),\n};\nconsole.log(JSON.stringify(output));\nexport default output;\n",[],[188,443],"4e6877dd-0991-41b3-96e1-79692c5a0183","ai-proxy.ts","210010be-a7c5-11f1-b633-1607ee4eb77e",50,["D",1788460052915],"import { ValTownOpenAI } from \"https://esm.town/v/std/openai/main.ts\";\n\nconst started = Date.now();\nconsole.log(\"diagnostic:start\");\nconst openai = new ValTownOpenAI({ timeout: 45_000, maxRetries: 0 });\nconst response = await openai.responses.create({\n model: \"gpt-5.4-nano\",\n tools: [{ type: \"web_search\" }],\n instructions: \"Use current web search. Return only structured JSON. Do not speculate.\",\n input: \"Identify the official country and city of BMT Medizintechnik GmbH, with one supporting official URL.\",\n max_output_tokens: 600,\n reasoning: { effort: \"low\" },\n text: {\n format: {\n type: \"json_schema\",\n name: \"diagnostic\",\n strict: true,\n schema: {\n type: \"object\",\n properties: {\n company: { type: \"string\" },\n country: { type: \"string\" },\n city: { type: \"string\" },\n officialUrl: { type: \"string\" },\n },\n required: [\"company\", \"country\", \"city\", \"officialUrl\"],\n additionalProperties: false,\n },\n },\n },\n} as any);\nconst output = { ok: true, elapsedMs: Date.now() - started, result: JSON.parse(String(response.output_text)) };\nconsole.log(JSON.stringify(output));\nexport default output;\n",[],[188,451],["D",1788460036703],[205,206,207,208],[188],["D",1788458579589],["D",1789501878689],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_127":499,"_500":501,"_502":503,"_504":24,"_505":24,"_506":24,"_507":58,"_508":-5,"_509":-7,"_510":-7,"_511":62,"_512":24,"_513":24,"_514":-5,"_515":24,"_516":24,"_517":24,"_518":-5},"ENV",{"_470":471,"_472":473,"_474":89,"_475":476,"_477":478,"_479":480,"_481":482,"_483":484,"_485":486,"_487":488,"_489":490,"_491":492,"_493":494,"_495":496,"_497":498},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v171