[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_437":438,"_439":440},"routes/_app.x.$handle.$name",{"_96":95,"_31":44,"_104":86,"_26":52,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":24,"_118":119,"_120":58,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":24},"version",155,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/assessments/main.js","latestPath","fileId","de11a35e-9810-11f0-93f3-0224a6c84d84","name","main.js","fileType","script","content","// Central aggregator for assessments\n// Exposes a single backgroundAssessEmail() used by API routes\n\nimport { isEmailAddress as uIsEmailAddress, mergeSpamStatus as uMergeSpamStatus, getEmailDomain as uGetEmailDomain, isGenericEmailDomain as uIsGenericEmailDomain, dedupeStrings as uDedupeStrings, statusToLabel as uStatusToLabel } from './utils.js';\nimport { preAllowlistAssess as modPreAllowlistAssess } from './pre/allowlist.js';\nimport { preAcademicAssess as modPreAcademicAssess } from './pre/academic.js';\nimport { preBlocklistAssess as modPreBlocklistAssess } from './pre/blocklist.js';\nimport { roleHeuristicAssess as modRoleHeuristicAssess } from './full/roleHeuristic.js';\nimport { llmCompoundAssess as modLlmCompoundAssess } from './full/llmCompound.js';\nimport { browserSearchAssess as modBrowserSearchAssess } from './full/browserSearch.js';\nimport { finalJudgeAssess as modFinalJudgeAssess } from './full/finalJudge.js';\n\nexport async function backgroundAssessEmail(apiKey, email, systemPrompt, allowlistRules, blocklistRules) {\n let status = undefined; const messages = []; const fields = {};\n const assessments = [];\n if (!uIsEmailAddress(email)) { status = 'spam'; messages.push('Invalid email format'); }\n\n // Pre-assessments (early exits)\n try { console.log('>> [pre] starting', { email, allowlistCount: Array.isArray(allowlistRules) ? allowlistRules.length : 0, blocklistCount: Array.isArray(blocklistRules) ? blocklistRules.length : 0 }); } catch (_) {}\n const preAssessors = [\n { name: 'allowlist', run: () => modPreAllowlistAssess(email, allowlistRules) },\n { name: 'academic', run: () => modPreAcademicAssess(email) },\n { name: 'blocklist', run: () => modPreBlocklistAssess(email, blocklistRules) },\n ];\n for (const pre of preAssessors) {\n try {\n const r = await pre.run();\n try { console.log('>> [pre] result', pre.name, r); } catch (_) {}\n if (r && r.decided) {\n if (r.fields) Object.assign(fields, r.fields);\n if (r.assessment) assessments.push(r.assessment);\n // Include role heuristic quick flag for scanning\n const roleQuick = modRoleHeuristicAssess(email);\n if (roleQuick && roleQuick.message) { fields.bg_role = true; fields.bg_role_msg = roleQuick.message; }\n else { fields.bg_role = false; }\n // Build standardized one-liner outputs for all assessors (marking not-run assessors explicitly)\n const toHuman = (s) => (s === 'person_high' ? 'likely human' : s === 'person_low' ? 'possible human' : s === 'person_none' ? 'no evidence' : s === 'spam' ? 'spam' : String(s || ''));\n const lines = [];\n // allowlist / blocklist\n lines.push('allowlist: ' + (fields.bg_allowlist_rule ? 'allowed' : 'not listed'));\n lines.push('blocklist: ' + (fields.bg_blocklist_rule ? 'blocked' : 'not blocked'));\n // academic\n lines.push('academic: ' + (fields.bg_academic ? (fields.bg_institution ? fields.bg_institution : 'academic') : 'not academic'));\n // role\n lines.push('role: ' + (fields.bg_role ? (fields.bg_role_msg || 'role-based') : 'clean'));\n // browser / llm not run due to early exit\n lines.push('browser: not run');\n lines.push('llm: not run');\n // final maps to decided status\n lines.push('final: ' + toHuman(r.status));\n fields.bg_assessor_lines = lines;\n fields.bg_assessments = assessments;\n return { email, status: r.status, message: r.message || '', fields, assessments };\n } else {\n // Even if not decided, add assessment for tracking\n assessments.push({ name: pre.name, status: null, message: r?.message || 'no match' });\n }\n } catch (_) {\n assessments.push({ name: pre.name, status: null, message: 'error' });\n }\n }\n\n const role = modRoleHeuristicAssess(email);\n if (role.status) status = uMergeSpamStatus(status, role.status);\n if (role.message) messages.push(role.message);\n if (role && role.message) { fields.bg_role = true; fields.bg_role_msg = role.message; }\n else { fields.bg_role = false; }\n\n try {\n let llm = null; let browse = null;\n const [llmRes, browseRes] = await Promise.allSettled([\n modLlmCompoundAssess(apiKey, email, systemPrompt),\n modBrowserSearchAssess(apiKey, email, systemPrompt)\n ]);\n if (llmRes.status === 'fulfilled') {\n llm = llmRes.value;\n if (llm) {\n if (llm.status) status = uMergeSpamStatus(status, llm.status);\n if (llm.message) fields.bg_compound_msg = llm.message;\n if (llm.status) fields.bg_compound_label = uStatusToLabel(llm.status);\n if (!fields.bg_compound_short && llm.message) fields.bg_compound_short = llm.message;\n if (llm.fields) Object.assign(fields, llm.fields);\n assessments.push({ name: 'compound', status: llm.status || null, message: llm.message || null });\n }\n } else {\n try { console.error('>> [compound] error:', llmRes.reason && llmRes.reason.message ? llmRes.reason.message : String(llmRes.reason)); } catch (_) {}\n fields.bg_compound_debug = llmRes.reason && llmRes.reason.message ? llmRes.reason.message : String(llmRes.reason);\n }\n if (browseRes.status === 'fulfilled') {\n browse = browseRes.value;\n if (browse) {\n if (browse.status) status = uMergeSpamStatus(status, browse.status);\n if (browse.message) fields.bg_browser_msg = browse.message;\n if (!fields.bg_browser_short && browse.message) fields.bg_browser_short = browse.message;\n if (browse.fields) Object.assign(fields, browse.fields);\n assessments.push({ name: 'browser', status: browse.status || null, message: browse.message || null });\n }\n } else {\n try { console.error('>> [browser] error:', browseRes.reason && browseRes.reason.message ? browseRes.reason.message : String(browseRes.reason)); } catch (_) {}\n fields.bg_browser_debug = browseRes.reason && browseRes.reason.message ? browseRes.reason.message : String(browseRes.reason);\n }\n\n // Final judge\n const d = uGetEmailDomain(email);\n const evidence = {\n academic: { academic: !!fields.bg_academic, institution: fields.bg_institution || null },\n role: { message: role.message || null, status: role.status || null },\n domain: { domain: d || null, generic_provider: d ? uIsGenericEmailDomain(d) : null },\n compound: { status: llm?.status || null, message: llm?.message || null, short: fields.bg_compound_short || null, label: fields.bg_compound_label || null, evidence: Array.isArray(fields.bg_compound_evidence) ? fields.bg_compound_evidence : [] },\n browser: { status: browse?.status || null, message: browse?.message || null, short: fields.bg_browser_short || null, label: fields.bg_browser_label || null, evidence: Array.isArray(fields.bg_browser_evidence) ? fields.bg_browser_evidence : [] }\n };\n try { console.log('>> [final judge] evidence:', JSON.stringify(evidence)); } catch (_) {}\n const judge = await modFinalJudgeAssess(apiKey, email, systemPrompt, evidence);\n if (judge) {\n if (judge.status) status = judge.status;\n if (judge.message && !fields.bg_final_short) fields.bg_final_short = judge.message;\n if (judge.fields) Object.assign(fields, judge.fields);\n assessments.push({ name: 'final_judge', status: judge.status || null, message: judge.message || null });\n }\n try { console.log('>> [final judge] judge:', JSON.stringify(judge)); } catch (_) {}\n\n // Consolidate evidence bullets and UI detail if missing\n const allEvidence = [];\n if (Array.isArray(fields.bg_final_evidence)) allEvidence.push(...fields.bg_final_evidence);\n if (Array.isArray(fields.bg_browser_evidence)) allEvidence.push(...fields.bg_browser_evidence);\n if (Array.isArray(fields.bg_compound_evidence)) allEvidence.push(...fields.bg_compound_evidence);\n const domain = uGetEmailDomain(email);\n if (fields.bg_academic && fields.bg_institution) allEvidence.push('Academic institution: ' + fields.bg_institution);\n if (domain) {\n if (uIsGenericEmailDomain(domain)) allEvidence.push('Generic email provider: ' + domain); else allEvidence.push('Organization domain detected: ' + domain);\n }\n if (role && role.message) allEvidence.push(role.message);\n const deduped = uDedupeStrings(allEvidence).slice(0, 8);\n if (!fields.bg_final_evidence) fields.bg_final_evidence = deduped.length > 0 ? deduped : ['No public evidence found'];\n if (!fields.bg_final_detail) {\n const parts = [];\n if (fields.bg_academic && fields.bg_institution) parts.push('Academic institution: ' + fields.bg_institution + '.');\n else if (domain) parts.push(uIsGenericEmailDomain(domain) ? ('Generic provider: ' + domain + '.') : ('Organization domain: ' + domain + '.'));\n if (judge && judge.message) parts.push(judge.message);\n const fallback = parts.join(' ').trim();\n fields.bg_final_detail = fallback || 'No public evidence found.';\n }\n // Build standardized one-liner outputs for scanning\n const toHuman = (s) => (s === 'person_high' ? 'likely human' : s === 'person_low' ? 'possible human' : s === 'person_none' ? 'no evidence' : s === 'spam' ? 'spam' : String(s || ''));\n const lines = [];\n lines.push('allowlist: ' + (fields.bg_allowlist_rule ? 'allowed' : 'not listed'));\n lines.push('blocklist: ' + (fields.bg_blocklist_rule ? 'blocked' : 'not blocked'));\n lines.push('academic: ' + (fields.bg_academic ? (fields.bg_institution ? fields.bg_institution : 'academic') : 'not academic'));\n lines.push('role: ' + (fields.bg_role ? (fields.bg_role_msg || 'role-based') : 'clean'));\n lines.push('browser: ' + (browse && browse.status ? toHuman(browse.status) : (fields.bg_browser_label ? String(fields.bg_browser_label) : 'not run')));\n lines.push('llm: ' + (llm && llm.status ? toHuman(llm.status) : (fields.bg_compound_label ? String(fields.bg_compound_label) : 'not run')));\n lines.push('final: ' + toHuman(status));\n fields.bg_assessor_lines = lines;\n // Ensure all assessors have entries in the assessments array\n const assessorNames = ['allowlist', 'academic', 'blocklist', 'role_heuristic', 'compound', 'browser', 'final_judge'];\n for (const name of assessorNames) {\n const existing = assessments.find(a => a.name === name);\n if (!existing) {\n let message = 'not run';\n let status = null;\n if (name === 'allowlist') message = fields.bg_allowlist_rule ? 'allowed' : 'no match';\n else if (name === 'blocklist') message = fields.bg_blocklist_rule ? 'blocked' : 'no match';\n else if (name === 'academic') message = fields.bg_academic ? 'academic' : 'no match';\n else if (name === 'role_heuristic') message = fields.bg_role ? (fields.bg_role_msg || 'role-based') : 'clean';\n assessments.push({ name, status, message });\n }\n }\n } catch (err) {\n try { console.error('>> [compound] error:', err && err.message ? err.message : String(err)); } catch (_) {}\n fields.bg_compound_debug = err && err.message ? err.message : String(err);\n }\n if (!status) status = 'person_low';\n fields.bg_assessments = assessments;\n return { email, status, message: messages.join('; '), fields, assessments };\n}\n\n\n","createdAt",["D",1758585866099],"branchVersion","branchId","c8640a52-81f8-11f0-9cb4-0224a6c84d84","id","c863bed0-81f8-11f0-9cb4-0224a6c84d84","mailcheck",["D",1756156596230],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","a8270e74-6479-475a-8025-9b69544ee0e7","pinnedFileId","cc59d100-81f8-11f0-8f5e-0224a6c84d84","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","8319defa-6e1a-46d4-ba66-2114ffd3360b","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":54,"_100":101,"_102":24},"branch",{"_13":85,"_31":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"isOwned",166,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","yawnxyz","handle","displayName","avatar","https://images.clerk.dev/oauth_github/img_2NnaHhpxNuH1xWRIRjQNoo16TVc.jpeg","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_31":44,"_37":433,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":434,"_80":435,"_82":436,"_84":24},"tree",[256,258,267,270,274,275,276,277,278,279,280,281,282,283,284],"files",[256,257,258,259,260,261,262,263,264,265,266,267,268,269,270,271,272,273,274,275,276,277,278,279,280,281,282,283,284],"counts",{"_246":62,"_247":176,"_248":62,"_249":250,"_251":252},"contents",[125,126,127,128,129,130,131,132,133,134,135,136,137,138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":240,"_31":241,"_29":242,"_143":-5,"_40":41,"_39":243,"_145":58,"_37":244,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_26":245},{"_42":234,"_31":235,"_29":236,"_143":-5,"_40":41,"_39":237,"_145":58,"_37":238,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_26":239},{"_42":229,"_31":230,"_29":231,"_143":-5,"_40":41,"_39":176,"_145":58,"_37":232,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_26":233},{"_42":222,"_31":223,"_29":224,"_143":-5,"_40":41,"_39":225,"_145":24,"_37":226,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_26":228},{"_42":215,"_31":216,"_29":217,"_143":-5,"_40":41,"_39":218,"_145":58,"_37":219,"_13":62,"_33":20,"_35":220,"_23":24,"_148":-5,"_26":221},{"_42":208,"_31":209,"_29":210,"_143":-5,"_40":41,"_39":211,"_145":58,"_37":212,"_13":62,"_33":20,"_35":213,"_23":24,"_148":-5,"_26":214},{"_42":201,"_31":202,"_29":203,"_143":-5,"_40":41,"_39":204,"_145":58,"_37":205,"_13":62,"_33":20,"_35":206,"_23":24,"_148":-5,"_26":207},{"_42":193,"_31":194,"_29":195,"_143":-5,"_40":41,"_39":196,"_145":24,"_37":197,"_13":198,"_33":20,"_35":199,"_23":24,"_148":-5,"_26":200},{"_42":186,"_31":187,"_29":188,"_143":-5,"_40":41,"_39":189,"_145":58,"_37":190,"_13":62,"_33":34,"_35":191,"_23":24,"_148":-5,"_26":192},{"_42":179,"_31":180,"_29":181,"_143":-5,"_40":41,"_39":182,"_145":58,"_37":183,"_13":62,"_33":34,"_35":184,"_23":24,"_148":-5,"_26":185},{"_42":171,"_31":172,"_29":173,"_143":-5,"_40":41,"_39":174,"_145":24,"_37":175,"_13":176,"_33":20,"_35":177,"_23":24,"_148":-5,"_26":178},{"_42":164,"_31":165,"_29":166,"_143":-5,"_40":41,"_39":167,"_145":58,"_37":168,"_13":62,"_33":20,"_35":169,"_23":24,"_148":-5,"_26":170},{"_42":157,"_31":158,"_29":159,"_143":-5,"_40":41,"_39":160,"_145":24,"_37":161,"_13":153,"_33":20,"_35":162,"_23":24,"_148":-5,"_26":163},{"_42":150,"_31":32,"_29":56,"_143":-5,"_40":41,"_39":151,"_145":24,"_37":152,"_13":153,"_33":154,"_35":155,"_23":24,"_148":44,"_26":156},{"_42":140,"_31":141,"_29":142,"_143":-5,"_40":41,"_39":144,"_145":58,"_37":146,"_13":62,"_33":20,"_35":147,"_23":24,"_148":-5,"_26":149},"cc68fd88-81f8-11f0-b660-0224a6c84d84","notes.md","cc68fe46-81f8-11f0-b660-0224a6c84d84","parentId",51,"latest",["D",1756156602938],"\n\n## random\n\n- [x] output questions to csv","label",[141],"1af731de-8539-11f0-8f35-0224a6c84d84",123,["D",1756514076036],5,"http","import { Hono } from 'https://deno.land/x/hono@v3.11.12/mod.ts';\nimport { serve } from 'https://deno.land/std@0.190.0/http/server.ts';\nimport { listFiles, readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport \"jsr:@std/dotenv/load\"; // needed for deno run; not req for smallweb or valtown\nimport { groqChatCompletion } from \"./chatCompletion.js\";\nimport { backgroundAssessEmail } from \"./backend/assessments/main.js\";\n\nconst app = new Hono();\nconst serverApiKey = null; // Deno.env.get(\"GROQ_API_KEY\");\n\n// Settings configuration (minimal)\nconst settings = {};\n\n// In-memory async job registry (ephemeral per process)\nconst jobRegistry = new Map(); // jobId -> { id, running, cancelled, total, completed, createdAt, updatedAt, items: [{ id, email, status, result?, error? }], systemPrompt }\n\nfunction generateId() {\n try { return crypto.randomUUID(); } catch (_) { return (Date.now().toString(36) + Math.random().toString(36).slice(2)); }\n}\n\nfunction nowTs() { return Date.now(); }\n\nfunction summarizeJob(job) {\n return {\n id: job.id,\n running: !!job.running,\n cancelled: !!job.cancelled,\n total: job.total | 0,\n completed: job.completed | 0,\n createdAt: job.createdAt,\n updatedAt: job.updatedAt,\n systemPrompt: job.systemPrompt || '',\n items: job.items.map((it) => ({ id: it.id, email: it.email, status: it.status, result: it.result || null, error: it.error || null }))\n };\n}\n\nasync function runAsyncJob(job, apiKey, concurrency) {\n if (!Array.isArray(job.items) || job.items.length === 0) { job.running = false; job.updatedAt = nowTs(); return; }\n job.running = true; job.cancelled = false; job.updatedAt = nowTs();\n const systemPrompt = job.systemPrompt || '';\n const indices = job.items.map((_, i) => i);\n job.total = indices.length; job.completed = 0;\n\n // Pre-mark pending as checking\n for (const idx of indices) {\n const it = job.items[idx];\n if (!it) continue;\n if (it.status === 'done' || it.status === 'error') continue;\n it.status = 'checking';\n }\n job.updatedAt = nowTs();\n\n const limit = Math.max(1, Number(concurrency || 8) || 8);\n let cursor = 0;\n const runNext = async () => {\n if (job.cancelled) return;\n if (cursor >= indices.length) return;\n const idx = indices[cursor++];\n const item = job.items[idx];\n if (!item) return runNext();\n if (item.status === 'done' || item.status === 'error') { job.completed++; return runNext(); }\n try {\n const res = await backgroundAssessEmail(apiKey, item.email, systemPrompt);\n item.result = res;\n item.status = 'done';\n } catch (err) {\n item.error = err && err.message ? err.message : String(err);\n item.status = 'error';\n } finally {\n job.completed++;\n job.updatedAt = nowTs();\n await runNext();\n }\n };\n const runners = [];\n for (let k = 0; k < limit; k++) runners.push(runNext());\n try { await Promise.all(runners); } catch (_) {}\n job.running = false; job.updatedAt = nowTs();\n}\n\n\n// Helper: Collect readable text from tool records for URL-grounded extraction\nfunction collectToolTextFromArray(toolArray) {\n if (!Array.isArray(toolArray)) return '';\n const parts = [];\n for (const t of toolArray) {\n try {\n const name = t?.name || t?.tool || t?.function?.name || t?.id || '';\n const args = t?.arguments || t?.input || t?.params || null;\n const output = t?.output || t?.result || t?.content || null;\n const searchResults = t?.search_results || t?.results || null;\n if (name) parts.push('name: ' + String(name));\n if (args) parts.push('arguments: ' + (typeof args === 'string' ? args : JSON.stringify(args)));\n if (output) parts.push('output: ' + (typeof output === 'string' ? output : JSON.stringify(output)));\n if (searchResults) parts.push('search_results: ' + (typeof searchResults === 'string' ? searchResults : JSON.stringify(searchResults)));\n } catch (_) {\n // ignore malformed tool objects\n }\n }\n return parts.join('\\n');\n}\n\n\n\n// Reusable background-check helpers\nfunction isEmailAddress(s) {\n const str = String(s || '').trim();\n if (!str) return false;\n return /^[^\\s@]+@[^\\s@]+\\.[^\\s@]{2,}$/.test(str);\n}\nfunction mergeSpamStatus(current, next) {\n if (!next) return current || undefined;\n if (!current) return next;\n const score = (s) => (s === 'likely_spam' ? 3 : s === 'suspected_spam' ? 2 : s === 'not_spam' ? 1 : 0);\n return score(next) >= score(current) ? next : current;\n}\nfunction mergeStatus(current, next) {\n if (!next) return current || undefined;\n if (!current) return next;\n const score = (s) => (s === 'spam' ? 4 : s === 'person_none' ? 3 : s === 'person_low' ? 2 : s === 'person_high' ? 1 : 0);\n return score(next) >= score(current) ? next : current;\n}\nfunction extractJsonBetweenTags(text) {\n try {\n if (!text) return null;\n const m = String(text).match(/[\\s\\S]*?<\\/json>/i);\n const slice = m ? m[0] : null;\n if (!slice) return null;\n const inner = slice.replace(/^/i, '').replace(/<\\/json>$/i, '');\n const trimmed = inner.trim();\n return JSON.parse(trimmed);\n } catch (err) { \n console.error('Failed to parse JSON between tags:', trimmed, 'Error:', err.message);\n return null; \n }\n}\nfunction logGroqCurl(tag, apiKey, payload) {\n try {\n const compact = JSON.stringify(payload);\n const esc = compact.replace(/'/g, `'\"'\"'`);\n const curl = [\n 'curl --request POST \\\\\\n' +\n ' --url https://api.groq.com/openai/v1/chat/completions \\\\\\n' +\n ` --header 'authorization: Bearer ${apiKey}' \\\\\\n` +\n \" --header 'content-type: application/json' \\\\\\n\" +\n ` --data '${esc}'`\n ].join('');\n console.log(`>> [${tag}] curl script:\\n${curl}`);\n } catch (_) {}\n}\nfunction coerceJsonFromText(text) {\n try {\n if (!text) return null;\n // 1) Try to find a raw JSON object substring\n const raw = String(text);\n const firstBrace = raw.indexOf('{');\n const lastBrace = raw.lastIndexOf('}');\n if (firstBrace !== -1 && lastBrace > firstBrace) {\n const candidate = raw.slice(firstBrace, lastBrace + 1);\n try { return JSON.parse(candidate); } catch (_) {}\n }\n // 2) Try loose key extraction\n const statusMatch = raw.match(/status\\s*[:=]\\s*[\"']?([a-zA-Z_]+)[\"']?/);\n const messageMatch = raw.match(/message\\s*[:=]\\s*[\"']([^\"']+)[\"']/);\n const explMatch = raw.match(/explanation_short\\s*[:=]\\s*[\"']([^\"']+)[\"']/);\n const out = {};\n if (statusMatch) out.status = statusMatch[1];\n if (messageMatch) out.message = messageMatch[1];\n if (explMatch) out.explanation_short = explMatch[1];\n return Object.keys(out).length > 0 ? out : null;\n } catch (_) { return null; }\n}\n\nfunction getEmailDomain(address) {\n try { return String(address || '').split('@')[1]?.toLowerCase() || ''; } catch (_) { return ''; }\n}\nfunction isGenericEmailDomain(domain) {\n const generic = new Set(['gmail.com','yahoo.com','outlook.com','hotmail.com','icloud.com','gmx.com','aol.com','proton.me','protonmail.com','mail.com','yandex.com']);\n return generic.has(String(domain || '').toLowerCase());\n}\nfunction dedupeStrings(arr) {\n const seen = new Set();\n const out = [];\n for (const s of (arr || [])) { const v = String(s || '').trim(); if (v && !seen.has(v)) { seen.add(v); out.push(v); } }\n return out;\n}\n// Whitelist helpers\nfunction normalizeWhitelistTokens(list) {\n try {\n if (!Array.isArray(list)) return [];\n const out = [];\n const seen = new Set();\n for (const raw of list) {\n const t = String(raw || '').trim().toLowerCase();\n if (!t) continue;\n if (seen.has(t)) continue;\n seen.add(t);\n out.push(t);\n }\n return out;\n } catch (_) { return []; }\n}\nfunction domainMatches(supplied, actualDomain) {\n try {\n const d = String(actualDomain || '').toLowerCase();\n const token = String(supplied || '').toLowerCase();\n if (!token || !d) return false;\n const t = token.replace(/^\\*@/, '').replace(/^@/, '');\n if (!t) return false;\n if (d === t) return true;\n // allow subdomain suffix matches\n return d.endsWith('.' + t);\n } catch (_) { return false; }\n}\nfunction matchWhitelist(email, tokens) {\n try {\n const e = String(email || '').toLowerCase();\n const domain = getEmailDomain(e);\n const list = normalizeWhitelistTokens(tokens);\n for (const t of list) {\n if (!t) continue;\n if (t.includes('@') && !t.includes('*')) {\n // exact email or @domain\n if (t.startsWith('@')) { if (domainMatches(t, domain)) return t; }\n else if (e === t) return t;\n } else if (t.startsWith('*@')) {\n if (domainMatches(t, domain)) return t;\n } else if (t.startsWith('@')) {\n if (domainMatches(t, domain)) return t;\n } else if (t.includes('.')) {\n // bare domain like example.com\n if (domainMatches(t, domain)) return t;\n }\n }\n return null;\n } catch (_) { return null; }\n}\nfunction statusToLabel(status) {\n if (status === 'spam') return 'spam';\n if (status === 'person_none') return 'no evidence';\n if (status === 'person_low') return 'possible person';\n if (status === 'likely_spam') return 'spam';\n if (status === 'suspected_spam') return 'suspicious';\n if (status === 'not_spam' || status === 'person_high') return 'likely real person';\n return String(status || '');\n}\nfunction cleanDetailText(text) {\n try {\n if (!text) return '';\n let s = String(text);\n // Remove tool and output blocks often present in compound traces\n s = s.replace(/[\\s\\S]*?<\\/tool>/gi, '').replace(/[\\s\\S]*?<\\/output>/gi, '');\n // Drop embedded JSON blocks\n s = s.replace(/[\\s\\S]*?<\\/json>/gi, '');\n // Normalize whitespace\n s = s.replace(/[ \\t]+/g, ' ').replace(/\\n{3,}/g, '\\n\\n').trim();\n // Keep only 1-3 short paragraphs\n const paras = s.split(/\\n\\s*\\n/).filter(p => p && p.trim());\n const limited = paras.slice(0, 3).map(p => p.trim().slice(0, 500));\n const joined = limited.join('\\n\\n').trim();\n return joined.slice(0, 1400);\n } catch (_) { return ''; }\n}\n\n// Produce a concise one-sentence identity-first summary from an explanation\nfunction deriveIdentityShort(explanation) {\n try {\n if (!explanation) return '';\n let s = String(explanation).trim();\n // Take the first sentence\n try {\n const parts = s.split(/(?<=[.!?])\\s+/).filter(Boolean);\n if (parts.length > 0) s = parts[0];\n } catch (_) {}\n // Length guard\n if (s.length > 200) s = s.slice(0, 199).replace(/[,;:\\s]+$/, '').trim() + '…';\n return s;\n } catch (_) { return ''; }\n}\n\n// Convert a plain-text analysis (Status/Message/Explanation/Evidence sections) into strict JSON\n// Schema: { status: 'person_high|person_low|person_none|spam', message: string, explanation_short: string, evidence: string[] }\nasync function convertAnalysisToJson(apiKey, email, analysisText) {\n try {\n const convModel = 'openai/gpt-oss-20b';\n const convSys = [\n 'You convert analysis text into a strict JSON object. Do not browse or call tools.',\n 'Schema: { \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }',\n 'Rules:',\n '- message: one short sentence.',\n '- explanation_short: 2-3 sentences (<= 400 chars). If analysis indicates nothing credible was found, include \"No public evidence found.\" If known, include person background (name, role/title, organization). If credible negative signals are present (e.g., StopForumSpam, Spamhaus, scam-reporting communities), mention that.',\n '- evidence: 0-5 short bullets (no links). Include a background bullet when available (e.g., \"Name — Title, Organization, City\"). Include negative bullets when applicable (e.g., \"Flagged on StopForumSpam\"). Use [] when no credible evidence.',\n '- Only output a JSON object (no markdown, no extra text).'\n ].join('\\n');\n const convMessages = [\n { role: 'system', content: convSys },\n { role: 'user', content: 'Email: ' + email + '\\nAnalysis to convert:\\n' + analysisText }\n ];\n const convPayload = { model: convModel, messages: convMessages, stream: false, temperature: 0, response_format: { type: 'json_object' }, tool_choice: 'none' };\n const convRes = await groqChatCompletion(apiKey, convPayload);\n const t2 = convRes?.choices?.[0]?.message?.content || '';\n try { return JSON.parse(t2); } catch (_) { return null; }\n } catch (_) {\n return null;\n }\n}\nasync function llmCompoundAssess(apiKey, email, systemPrompt) {\n const baseSystem = [\n 'You assess whether an email belongs to a real person. Perform targeted web checks. If you cannot browse, reason only from public patterns in the address and provider; do not fabricate.',\n 'Make an effort to look for identity signals on LinkedIn, company/staff pages, academic directories, GitHub, personal sites, press/newsroom/author pages, and social profiles.',\n 'When identity is indicated, do light background digging: capture the person\\'s name, role/title, organization, department/team, and location/city if available.',\n 'Also look for negative signals: credible anti-abuse/anti-spam sources (e.g., StopForumSpam, Spamhaus, PhishTank), scam-reporting communities, or reputable media coverage indicating misuse. If credible negative signals exist, prefer status: spam.',\n 'Return ONLY JSON wrapped in ... tags using this schema:',\n '{ \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }',\n 'Guidelines:',\n '- person_high: strong identity signals clearly tie to the email/user (e.g., staff or author page, LinkedIn with matching name and employer, academic page listing the email).',\n '- person_low: weak or indirect signals; likely a person but unverified.',\n '- person_none: no public identity evidence.',\n '- spam: obvious spam/role-based/throwaway patterns, or credible anti-spam sources flag the address.',\n '- Leniency: If the domain appears to be a non-generic organization or an academic domain (e.g., .edu, .ac.*, or a known university/company), and there are weak but plausible signals (name match, role on org page without explicit email), lean toward person_low rather than person_none.',\n '- Escalation: When you find a plausible identity match (person name plus role/title and/or organization/institution) from credible sources and there are no credible negative signals, prefer status: person_high, even if the address uses a generic email provider (e.g., gmail).',\n '- message: one short sentence preferring an identity-first summary, e.g., \"Linked to Name — Title, Organization\" when available. explanation_short: 2-3 sentences (<= 400 chars), plain text; no tool logs, URLs, or headings. If known, include person background (name, role/title, organization).',\n '- evidence: 1-5 short bullets summarizing concrete findings (no links). Include at least one background bullet when available (e.g., \"Name — Title, Organization, City\"). Include negative bullets when applicable (e.g., \"Flagged on StopForumSpam\" or \"Reported in scam community\"). If nothing found, set evidence to [] and explicitly state \"No public evidence found.\" in explanation_short.',\n '- If the address indicates a role (e.g., info, noreply) or a notable role (e.g., reporter, journalist, professor, founder), include that in evidence.',\n '- Do not include any text outside the ... wrapper.'\n ].join('\\n');\n const messages = [\n { role: 'system', content: baseSystem + (systemPrompt ? ('\\nExtra instructions: ' + systemPrompt) : '') },\n { role: 'user', content: 'Email: ' + email + '\\nTask: quick legitimacy check.' }\n ];\n const model = 'compound-beta';\n const compoundPayload1 = { model, messages, stream: false, temperature: 0.2, tool_choice: 'none' };\n const r1 = await groqChatCompletion(apiKey, compoundPayload1);\n // logGroqCurl('compound r1', apiKey, compoundPayload1);\n // try { console.log('>> [compound] r1:', JSON.stringify(r1)); } catch (_) {}\n const t1 = r1?.choices?.[0]?.message?.content || '';\n const reasoning1 = r1?.choices?.[0]?.message?.reasoning || '';\n let parsed = extractJsonBetweenTags(t1);\n if (!parsed) {\n // In JSON mode, remove the wrapper instruction to avoid tool_use_failed\n const baseSystemJson = [\n 'You assess whether an email likely belongs to a real person based on quick web checks; do not fabricate.',\n 'Return ONLY a JSON object with this schema (no tags, no markdown):',\n '{ \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }',\n 'Keep message concise; explanation_short 2-3 sentences (<= 400 chars).'\n ].join('\\n');\n const messagesJson = [\n { role: 'system', content: baseSystemJson + (systemPrompt ? ('\\nExtra instructions: ' + systemPrompt) : '') },\n { role: 'user', content: 'Email: ' + email + '\\nTask: quick legitimacy check.' }\n ];\n const payload2 = { model, messages: messagesJson, stream: false, temperature: 0.2, response_format: { type: 'json_object' }, tool_choice: 'none' };\n // logGroqCurl('compound r2', apiKey, payload2);\n const r2 = await groqChatCompletion(apiKey, payload2);\n try { console.log('>> [compound] r2:', JSON.stringify(r2)); } catch (_) {}\n const t2 = r2?.choices?.[0]?.message?.content || '';\n try { parsed = JSON.parse(t2); } catch (_) { parsed = null; }\n if (!parsed) {\n return {\n status: 'person_low',\n message: 'no compound signal',\n fields: { bg_compound_debug: (t1 || t2 || '').slice(0, 800), bg_llm_model: model }\n };\n }\n }\n const out = { fields: { bg_llm_model: model } };\n if (parsed) {\n if (parsed.status && (parsed.status === 'person_high' || parsed.status === 'person_low' || parsed.status === 'person_none' || parsed.status === 'spam')) out.status = parsed.status;\n if (typeof parsed.message === 'string' && parsed.message.trim()) {\n out.message = parsed.message.trim();\n } else if (out.status) {\n const label = statusToLabel(out.status);\n out.message = 'compound: ' + label;\n } else {\n out.message = 'compound: ' + statusToLabel('person_low');\n }\n // Add compact label + short/long messages\n const label = statusToLabel(out.status || (parsed.status || 'person_low'));\n out.fields.bg_compound_label = label;\n out.fields.bg_compound_short = out.message || label;\n // Prefer model-provided reasoning if available, else raw content stripped of JSON tags\n let detail = '';\n if (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) {\n detail = cleanDetailText(parsed.explanation_short);\n // further limit to ~2-3 sentences / 450 chars\n try {\n const parts = detail.split(/(?<=[.!?])\\s+/).filter(Boolean).slice(0, 3);\n detail = parts.join(' ');\n if (detail.length > 450) detail = detail.slice(0, 449).replace(/[,;:\\s]+$/, '').trim() + '…';\n } catch (_) {}\n }\n if (!detail && reasoning1 && typeof reasoning1 === 'string') {\n detail = cleanDetailText(reasoning1);\n }\n if (!detail && t1) {\n detail = cleanDetailText(String(t1));\n }\n if (detail) out.fields.bg_compound_detail = detail;\n // Prefer an identity-first short derived from explanation when available\n try {\n const shortPref = (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) ? deriveIdentityShort(parsed.explanation_short) : '';\n if (shortPref) out.fields.bg_compound_short = shortPref;\n } catch (_) {}\n // Evidence list\n try {\n let ev = parsed.evidence;\n if (Array.isArray(ev)) {\n ev = ev.map((s) => String(s || '').trim()).filter(Boolean).slice(0, 5);\n } else if (typeof ev === 'string' && ev.trim()) {\n ev = [ev.trim()];\n } else {\n ev = [];\n }\n if (ev.length > 0) out.fields.bg_compound_evidence = ev;\n } catch (_) {}\n }\n return out;\n}\n\n// Browser search assessor using Groq's browser_search tool\nasync function browserSearchAssess(apiKey, email, systemPrompt) {\n const baseSystem = [\n 'Use web browsing to gather public signals about whether this email belongs to a real person; do not fabricate.',\n 'Call browser_search with multiple targeted queries. Try: the full email in quotes; the local part and domain; site:linkedin.com with likely name/handle; site:github.com with the handle; university/staff directories; newsroom/author pages; personal sites; press pages.',\n 'Prefer authoritative sources: LinkedIn, staff/author/company pages, academic directories, GitHub, reputable media. Also check credible anti-abuse/anti-spam sources (StopForumSpam, Spamhaus, PhishTank) and scam-reporting communities. Avoid data brokers and spammy aggregators.',\n 'When identity is indicated, do light background digging: capture the person\\'s name, role/title, organization, department/team, and location/city if available.',\n 'Leniency rule: If the domain appears to be a non-generic organization or academic domain (e.g., .edu, .ac.*, or a recognized university/company), and you find weak but plausible signals (name on org page, directory listing without explicit email, matching role), prefer Status: person_low over person_none unless there are credible negative signals.',\n 'Escalation rule: If you find a plausible identity match (person name plus role/title and/or organization/institution) from credible sources and no credible negative signals, prefer Status: person_high, even when the address uses a generic provider (e.g., gmail).',\n 'Produce a concise plain-text analysis with the following sections only (do not include any JSON):',\n 'Status: one of person_high | person_low | person_none | spam',\n 'Message: one short sentence preferring an identity-first summary, e.g., \"Linked to Name — Title, Organization\" when available',\n 'Explanation: 2-3 sentences (<= 400 chars), reference evidence or say No public evidence found. If known, include person background (name, role/title, organization).',\n 'Evidence: 1-5 short bullet points summarizing concrete findings (no links). Include at least one bullet with person background when available (e.g., \"Name — Title, Organization, City\"). Include negative bullets such as \"Flagged on StopForumSpam\" or \"Mentioned in scam-reporting community\" when applicable. If nothing credible found, leave this section empty.',\n 'Also note recognizable roles when present (reporter, journalist, professor, founder, recruiter).'\n ].join('\\n');\n const messages = [\n { role: 'system', content: baseSystem + (systemPrompt ? ('\\nExtra instructions: ' + systemPrompt) : '') },\n { role: 'user', content: 'Email: ' + email + '\\nTask: web search legitimacy check.' }\n ];\n const model = 'openai/gpt-oss-20b';\n const payload = { model, messages, stream: false, temperature: 0.2, tools: [{ type: 'browser_search' }] };\n const r1 = await groqChatCompletion(apiKey, payload);\n logGroqCurl('browser r1', apiKey, payload);\n // try { console.log('>> [browser] r1:', JSON.stringify(r1)); } catch (_) {}\n const t1 = r1?.choices?.[0]?.message?.content || '';\n const out = { fields: { bg_browser_model: model } };\n // Second pass: convert the plain-text analysis to strict JSON\n let parsed = await convertAnalysisToJson(apiKey, email, t1);\n\n if (!parsed) {\n // As a last resort, attempt to coerce\n parsed = coerceJsonFromText(t1);\n }\n\n if (parsed) {\n if (parsed.status && (parsed.status === 'person_high' || parsed.status === 'person_low' || parsed.status === 'person_none' || parsed.status === 'spam')) out.status = parsed.status;\n if (typeof parsed.message === 'string' && parsed.message.trim()) out.message = parsed.message.trim();\n const label = statusToLabel(out.status || (parsed.status || 'person_low'));\n out.fields.bg_browser_label = label;\n out.fields.bg_browser_short = out.message || label;\n if (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) {\n let detail = String(parsed.explanation_short).trim();\n if (detail.length > 450) detail = detail.slice(0, 449).replace(/[,;:\\s]+$/, '').trim() + '…';\n out.fields.bg_browser_detail = detail;\n // Prefer identity-first short if explanation is present\n try {\n const shortPref = deriveIdentityShort(parsed.explanation_short);\n if (shortPref) out.fields.bg_browser_short = shortPref;\n } catch (_) {}\n }\n try {\n let ev = parsed.evidence;\n if (Array.isArray(ev)) {\n ev = ev.map((s) => String(s || '').trim()).filter(Boolean).slice(0, 5);\n } else if (typeof ev === 'string' && ev.trim()) {\n ev = [ev.trim()];\n } else {\n ev = [];\n }\n if (ev.length > 0) out.fields.bg_browser_evidence = ev;\n } catch (_) {}\n } else {\n out.fields.bg_browser_debug = 'browser_search produced non-JSON analysis and conversion failed.';\n }\n\n return out;\n}\n\n// Final judge to consolidate all signals\nasync function finalJudgeAssess(apiKey, email, systemPrompt, evidence) {\n console.log('>> [final judge] evidence:', email, JSON.stringify(evidence));\n const model = 'openai/gpt-oss-120b';\n const schema = '{ \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }';\n const sys = [\n 'You are a strict judge that consolidates signals from two assessors and heuristics (academic, role, domain) to decide if an email belongs to a real person.',\n 'Decide using severity: spam > person_none > person_low > person_high.',\n 'Return ONLY JSON per schema:', schema,\n 'Rules:',\n '- Compose evidence as a deduplicated list of concrete bullets merged from all inputs (no links).',\n '- Include at least one bullet with person background when available (name, role/title, organization, location).',\n '- If credible anti-spam signals exist (e.g., StopForumSpam, Spamhaus, scam-reporting communities), prefer status: spam and include a negative bullet.',\n '- Leniency: For non-generic organization or academic domains with weak but plausible identity signals, prefer person_low over person_none unless negative signals exist.',\n '- Escalation: If there is a plausible identity match (person name plus role/title and/or organization/institution) from credible sources and no credible negative signals, prefer person_high even if the address uses a generic provider (e.g., gmail).',\n '- If no credible public evidence is present, set evidence to [] and explicitly say \"No public evidence found.\" in explanation_short.',\n '- message must be one short, specific sentence preferring an identity-first summary like \"Linked to Name — Title, Organization\" when available. explanation_short must be 2-3 sentences (<= 400 chars) and reference key evidence or lack thereof. If known, weave in person background (name, role/title, organization).',\n '- Note recognizable roles when present (reporter, journalist, professor, founder, recruiter).'\n ].join('\\n');\n const user = [\n 'Email: ' + email,\n 'Evidence (JSON):',\n JSON.stringify(evidence)\n ].join('\\n');\n // Ask for json_object to avoid extra parsing\n const judgePayload = { model, messages: [ { role: 'system', content: sys + (systemPrompt ? ('\\nExtra: ' + systemPrompt) : '') }, { role: 'user', content: user } ], stream: false, temperature: 0.2, response_format: { type: 'json_object' } };\n // logGroqCurl('judge', apiKey, judgePayload);\n const r = await groqChatCompletion(apiKey, judgePayload);\n // try { console.log('>> [judge] r:', JSON.stringify(r)); } catch (_) {}\n let parsed = null;\n try { parsed = JSON.parse(r?.choices?.[0]?.message?.content || '{}'); } catch (_) { parsed = null; }\n if (!parsed) return {};\n const out = { fields: { bg_final_model: model } };\n if (parsed.status && (parsed.status === 'person_high' || parsed.status === 'person_low' || parsed.status === 'person_none' || parsed.status === 'spam')) out.status = parsed.status;\n if (typeof parsed.message === 'string' && parsed.message.trim()) out.message = parsed.message.trim();\n const label = statusToLabel(out.status || (parsed.status || 'person_low'));\n out.fields.bg_final_label = label;\n out.fields.bg_final_short = out.message || label;\n if (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) {\n let d = String(parsed.explanation_short).trim();\n if (d.length > 450) d = d.slice(0, 449).replace(/[,;:\\s]+$/, '').trim() + '…';\n out.fields.bg_final_detail = d;\n // Prefer identity-first one-liner for the short summary\n try {\n const shortPref = deriveIdentityShort(parsed.explanation_short);\n if (shortPref) out.fields.bg_final_short = shortPref;\n } catch (_) {}\n }\n try {\n let ev = parsed.evidence;\n if (Array.isArray(ev)) {\n ev = ev.map((s) => String(s || '').trim()).filter(Boolean).slice(0, 5);\n } else if (typeof ev === 'string' && ev.trim()) {\n ev = [ev.trim()];\n } else {\n ev = [];\n }\n if (ev.length > 0) out.fields.bg_final_evidence = ev;\n } catch (_) {}\n return out;\n}\nasync function academicAssess(email) {\n const out = { fields: {} };\n try {\n const { Verifier } = await import('npm:academic-email-verifier');\n let isAcademic = false; let institution = null;\n try { isAcademic = await Verifier.isAcademic(email); } catch (_) { isAcademic = false; }\n try { institution = await Verifier.getInstitutionName(email); } catch (_) { institution = null; }\n const inst = typeof institution === 'string' ? institution.trim() : (institution ? String(institution) : null);\n out.fields.bg_academic = !!isAcademic; if (inst) out.fields.bg_institution = inst;\n if (isAcademic) out.fields.bg_academic_msg = inst || 'Academic domain';\n } catch (_) {}\n return out;\n}\nfunction roleHeuristicAssess(email) {\n try {\n const local = String(email || '').split('@')[0].toLowerCase();\n const roleList = ['info', 'support', 'admin', 'sales', 'contact', 'hello', 'team', 'marketing', 'noreply', 'no-reply'];\n if (roleList.includes(local)) return { status: 'suspected_spam', message: 'Role-based address' };\n } catch (_) {}\n return {};\n}\n\n\n// Check if server has API key\napp.get('/api/check-key', (c) => {\n return c.json({ hasServerKey: !!serverApiKey });\n});\n\n// Environment-aware file reading function\nasync function readFileContent(filePath) {\n // Check if we're in Val Town environment\n if (typeof Deno !== \"undefined\" && Deno.env.get(\"valtown\")) {\n // Use Val Town's readFile\n return await readFile(filePath, import.meta.url);\n } else {\n // Use Deno's native readTextFile for local development\n return await Deno.readTextFile(filePath);\n }\n}\n\n// Serve root with HTML content\napp.get('/', async (c) => {\n try {\n const htmlContent = await readFileContent('index.html');\n return c.html(htmlContent);\n } catch (error) {\n console.error('Error reading HTML file:', error);\n return c.text('Error loading page', 500);\n }\n});\n\n// Serve frontend modules (no static middleware)\n// Removed legacy research frontend\n\napp.get('/frontend/init.js', async (c) => {\n try {\n const js = await readFileContent('frontend/init.js');\n return new Response(js, {\n headers: { 'Content-Type': 'application/javascript; charset=utf-8', 'Cache-Control': 'no-store, must-revalidate', 'Pragma': 'no-cache' },\n });\n } catch (error) {\n console.error('Error reading init.js:', error);\n return c.text('Not found', 404);\n }\n});\n\n// Removed legacy lorraine frontend\n\napp.get('/frontend/mailcheckApp.js', async (c) => {\n try {\n const js = await readFileContent('frontend/mailcheckApp.js');\n return new Response(js, {\n headers: { 'Content-Type': 'application/javascript; charset=utf-8', 'Cache-Control': 'no-store, must-revalidate', 'Pragma': 'no-cache' },\n });\n } catch (error) {\n console.error('Error reading mailcheckApp.js:', error);\n return c.text('Not found', 404);\n }\n});\n\n// Academic email check (server-side; uses npm:academic-email-verifier)\n// Removed standalone academic check endpoint; academic is part of /api/check/background\n\n// Background check endpoint: runs sequential checkers server-side\napp.post('/api/check/background', async (c) => {\n try {\n const body = await c.req.json().catch(() => ({}));\n const email = String(body?.email || '').trim();\n const systemPrompt = typeof body?.systemPrompt === 'string' ? body.systemPrompt : '';\n const whitelist = Array.isArray(body?.whitelist) ? body.whitelist : [];\n const blacklist = Array.isArray(body?.blacklist) ? body.blacklist : [];\n // Prefer Authorization: Bearer header, then body.userApiKey, then env\n const authHeader = c.req.header('Authorization') || c.req.header('authorization') || '';\n const m = authHeader.match(/^Bearer\\s+(.+)$/i);\n const headerKey = m ? m[1].trim() : '';\n const apiKey = serverApiKey || headerKey || body?.userApiKey || Deno.env.get(\"GROQ_API_KEY\");\n if (!apiKey) return c.json({ error: 'No Groq API key available.' }, 400);\n if (!email) return c.json({ error: 'email required' }, 400);\n const out = await backgroundAssessEmail(apiKey, email, systemPrompt, whitelist, blacklist);\n // try { console.log('>> [/api/check/background] result:', JSON.stringify(out)); } catch (_) {}\n return c.json(out);\n } catch (error) {\n console.error('background check error:', error);\n return c.json({ error: 'background check error: ' + error.message }, 500);\n }\n});\n\n// Async job APIs\n// Create a job with one or more items. Body: { items: string[] | { email }[], systemPrompt?, concurrency?, userApiKey? }\napp.post('/api/jobs', async (c) => {\n try {\n const body = await c.req.json().catch(() => ({}));\n let items = Array.isArray(body?.items) ? body.items : [];\n const systemPrompt = typeof body?.systemPrompt === 'string' ? body.systemPrompt : '';\n const concurrency = Math.max(1, Number(body?.concurrency || 8) || 8);\n const authHeader = c.req.header('Authorization') || c.req.header('authorization') || '';\n const m = authHeader.match(/^Bearer\\s+(.+)$/i);\n const headerKey = m ? m[1].trim() : '';\n const apiKey = serverApiKey || headerKey || body?.userApiKey || Deno.env.get(\"GROQ_API_KEY\");\n if (!apiKey) return c.json({ error: 'No Groq API key available.' }, 400);\n // Normalize items to { id, email, status }\n items = items.map((v) => {\n const email = (v && typeof v === 'object') ? String(v.email || '').trim() : String(v || '').trim();\n return { id: generateId(), email, status: 'pending' };\n }).filter((it) => it.email);\n if (items.length === 0) return c.json({ error: 'no valid items' }, 400);\n const job = { id: generateId(), running: false, cancelled: false, total: 0, completed: 0, createdAt: nowTs(), updatedAt: nowTs(), items, systemPrompt };\n jobRegistry.set(job.id, job);\n // fire and forget\n runAsyncJob(job, apiKey, concurrency);\n return c.json(summarizeJob(job));\n } catch (error) {\n console.error('create job error:', error);\n return c.json({ error: 'create job error: ' + error.message }, 500);\n }\n});\n\n// Get job status by id\napp.get('/api/jobs/:id', (c) => {\n try {\n const id = c.req.param('id');\n const job = id && jobRegistry.get(id);\n if (!job) return c.json({ error: 'not found' }, 404);\n return c.json(summarizeJob(job));\n } catch (error) {\n console.error('get job error:', error);\n return c.json({ error: 'get job error: ' + error.message }, 500);\n }\n});\n\n// Cancel a job by id\napp.post('/api/jobs/:id/cancel', (c) => {\n try {\n const id = c.req.param('id');\n const job = id && jobRegistry.get(id);\n if (!job) return c.json({ error: 'not found' }, 404);\n job.cancelled = true;\n job.running = false;\n job.updatedAt = nowTs();\n return c.json(summarizeJob(job));\n } catch (error) {\n console.error('cancel job error:', error);\n return c.json({ error: 'cancel job error: ' + error.message }, 500);\n }\n});\n\n// LLM-based email legitimacy checker\n// Asks the model to return JSON wrapped in ... tags; retries with JSON modes if needed\n// Removed standalone llm-email endpoint; compound is part of /api/check/background\n\nexport default (typeof Deno !== \"undefined\" && Deno.env.get(\"valtown\")) ? app.fetch : app;",[32],"c444afde-9810-11f0-8c45-0224a6c84d84","index.html","cbfb404a-81f8-11f0-b660-0224a6c84d84",127,["D",1758585822735],"\n\n\n \n \n MCP Navigator\n \n \n \n \n \n \n\n \n \n \n \n \n \n \n \n \n \n \n \n\n \n\n\n

\n \n \n

\n\n \n

\n \n \n

\n \n

\n\n \n

\n \n \n

\n \n \n \n

\n\n \n

\n \n \n

Welcome to MCP Navigator

Ask me anything and I'll automatically select the best tools to help you.

\n Public MCPs are sourced from the official MCP Registry and provide remote hosted access.\n

Examples:

\"What's the weather in San Francisco?\"
\"Find trending AI models on Hugging Face\"
\"Show me how to use the GitHub MCP tool\"
\"List all available tools and models\"
\"Generate a huggingface mcp curl example\"

\n\n \n

\n \n

\n\n \n

\n \n \n

\n \n \n \n github\n

\n\n

\n\n",[158],"cc63e41a-81f8-11f0-b11d-0224a6c84d84","deno.lock","cc63e4e2-81f8-11f0-b11d-0224a6c84d84",50,["D",1756156602938],"{\n \"version\": \"5\",\n \"specifiers\": {\n \"jsr:@std/dotenv@*\": \"0.225.5\",\n \"npm:@valtown/sdk@0.37.0\": \"0.37.0\",\n \"npm:badge-maker@*\": \"5.0.2\",\n \"npm:groq-sdk@*\": \"0.21.0\",\n \"npm:marked@*\": \"15.0.11\",\n \"npm:mime-types@2.1.35\": \"2.1.35\",\n \"npm:preact-render-to-string@*\": \"6.5.13_preact@10.27.0\",\n \"npm:pretty-ms@*\": \"9.2.0\"\n },\n \"jsr\": {\n \"@std/dotenv@0.225.5\": {\n \"integrity\": \"9ce6f9d0ec3311f74a32535aa1b8c62ed88b1ab91b7f0815797d77a6f60c922f\"\n }\n },\n \"npm\": {\n \"@types/node-fetch@2.6.12\": {\n \"integrity\": \"sha512-8nneRWKCg3rMtF69nLQJnOYUcbafYeFSjqkw3jCRLsqkWFlHaoQrr5mXmofFGOx3DKn7UfmBMyov8ySvLRVldA==\",\n \"dependencies\": [\n \"@types/node@22.15.15\",\n \"form-data\"\n ]\n },\n \"@types/node@18.19.118\": {\n \"integrity\": \"sha512-hIPK0hSrrcaoAu/gJMzN3QClXE4QdCdFvaenJ0JsjIbExP1JFFVH+RHcBt25c9n8bx5dkIfqKE+uw6BmBns7ug==\",\n \"dependencies\": [\n \"undici-types@5.26.5\"\n ]\n },\n \"@types/node@22.15.15\": {\n \"integrity\": \"sha512-R5muMcZob3/Jjchn5LcO8jdKwSCbzqmPB6ruBxMcf9kbxtniZHP327s6C37iOfuw8mbKK3cAQa7sEl7afLrQ8A==\",\n \"dependencies\": [\n \"undici-types@6.21.0\"\n ]\n },\n \"@valtown/sdk@0.37.0\": {\n \"integrity\": \"sha512-8YnynWRljje10MDRGJdftC5qU5FguFLYLDIauEjDUb5IlZbVevMdiunJpK7i37jDBm/QljCmIjPdPUpDE89snw==\",\n \"dependencies\": [\n \"@types/node@18.19.118\",\n \"@types/node-fetch\",\n \"abort-controller\",\n \"agentkeepalive\",\n \"form-data-encoder\",\n \"formdata-node\",\n \"node-fetch\"\n ]\n },\n \"abort-controller@3.0.0\": {\n \"integrity\": \"sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg==\",\n \"dependencies\": [\n \"event-target-shim\"\n ]\n },\n \"agentkeepalive@4.6.0\": {\n \"integrity\": \"sha512-kja8j7PjmncONqaTsB8fQ+wE2mSU2DJ9D4XKoJ5PFWIdRMa6SLSN1ff4mOr4jCbfRSsxR4keIiySJU0N9T5hIQ==\",\n \"dependencies\": [\n \"humanize-ms\"\n ]\n },\n \"anafanafo@2.0.0\": {\n \"integrity\": \"sha512-Nlfq7NC4AOkTJerWRIZcOAiMNtIDVIGWGvQ98O7Jl6Kr2Dk0dX5u4MqN778kSRTy5KRqchpLdF2RtLFEz9FVkQ==\",\n \"dependencies\": [\n \"char-width-table-consumer\"\n ]\n },\n \"asynckit@0.4.0\": {\n \"integrity\": \"sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q==\"\n },\n \"badge-maker@5.0.2\": {\n \"integrity\": \"sha512-Xd3YUmKPEShQcn6PFB03Wxq0RNJRFwVVroyRz0qIjSXwniYUGsGWNHqtNsQYi/Sbs8Ni7qAEf7LKgDOtcAoCDg==\",\n \"dependencies\": [\n \"anafanafo\",\n \"css-color-converter\"\n ],\n \"bin\": true\n },\n \"binary-search@1.3.6\": {\n \"integrity\": \"sha512-nbE1WxOTTrUWIfsfZ4aHGYu5DOuNkbxGokjV6Z2kxfJK3uaAb8zNK1muzOeipoLHZjInT4Br88BHpzevc681xA==\"\n },\n \"call-bind-apply-helpers@1.0.2\": {\n \"integrity\": \"sha512-Sp1ablJ0ivDkSzjcaJdxEunN5/XvksFJ2sMBFfq6x0ryhQV/2b/KwFe21cMpmHtPOSij8K99/wSfoEuTObmuMQ==\",\n \"dependencies\": [\n \"es-errors\",\n \"function-bind\"\n ]\n },\n \"char-width-table-consumer@1.0.0\": {\n \"integrity\": \"sha512-Fz4UD0LBpxPgL9i29CJ5O4KANwaMnX/OhhbxzvNa332h+9+nRKyeuLw4wA51lt/ex67+/AdsoBQJF3kgX2feYQ==\",\n \"dependencies\": [\n \"binary-search\"\n ]\n },\n \"color-convert@0.5.3\": {\n \"integrity\": \"sha512-RwBeO/B/vZR3dfKL1ye/vx8MHZ40ugzpyfeVG5GsiuGnrlMWe2o8wxBbLCpw9CsxV+wHuzYlCiWnybrIA0ling==\"\n },\n \"color-name@1.1.4\": {\n \"integrity\": \"sha512-dOy+3AuW3a2wNbZHIuMZpTcgjGuLU/uBL/ubcZF9OXbDo8ff4O8yVp5Bf0efS8uEoYo5q4Fx7dY9OgQGXgAsQA==\"\n },\n \"combined-stream@1.0.8\": {\n \"integrity\": \"sha512-FQN4MRfuJeHf7cBbBMJFXhKSDq+2kAArBlmRBvcvFE5BB1HZKXtSFASDhdlz9zOYwxh8lDdnvmMOe/+5cdoEdg==\",\n \"dependencies\": [\n \"delayed-stream\"\n ]\n },\n \"css-color-converter@2.0.0\": {\n \"integrity\": \"sha512-oLIG2soZz3wcC3aAl/7Us5RS8Hvvc6I8G8LniF/qfMmrm7fIKQ8RIDDRZeKyGL2SrWfNqYspuLShbnjBMVWm8g==\",\n \"dependencies\": [\n \"color-convert\",\n \"color-name\",\n \"css-unit-converter\"\n ]\n },\n \"css-unit-converter@1.1.2\": {\n \"integrity\": \"sha512-IiJwMC8rdZE0+xiEZHeru6YoONC4rfPMqGm2W85jMIbkFvv5nFTwJVFHam2eFrN6txmoUYFAFXiv8ICVeTO0MA==\"\n },\n \"delayed-stream@1.0.0\": {\n \"integrity\": \"sha512-ZySD7Nf91aLB0RxL4KGrKHBXl7Eds1DAmEdcoVawXnLD7SDhpNgtuII2aAkg7a7QS41jxPSZ17p4VdGnMHk3MQ==\"\n },\n \"dunder-proto@1.0.1\": {\n \"integrity\": \"sha512-KIN/nDJBQRcXw0MLVhZE9iQHmG68qAVIBg9CqmUYjmQIhgij9U5MFvrqkUL5FbtyyzZuOeOt0zdeRe4UY7ct+A==\",\n \"dependencies\": [\n \"call-bind-apply-helpers\",\n \"es-errors\",\n \"gopd\"\n ]\n },\n \"es-define-property@1.0.1\": {\n \"integrity\": \"sha512-e3nRfgfUZ4rNGL232gUgX06QNyyez04KdjFrF+LTRoOXmrOgFKDg4BCdsjW8EnT69eqdYGmRpJwiPVYNrCaW3g==\"\n },\n \"es-errors@1.3.0\": {\n \"integrity\": \"sha512-Zf5H2Kxt2xjTvbJvP2ZWLEICxA6j+hAmMzIlypy4xcBg1vKVnx89Wy0GbS+kf5cwCVFFzdCFh2XSCFNULS6csw==\"\n },\n \"es-object-atoms@1.1.1\": {\n \"integrity\": \"sha512-FGgH2h8zKNim9ljj7dankFPcICIK9Cp5bm+c2gQSYePhpaG5+esrLODihIorn+Pe6FGJzWhXQotPv73jTaldXA==\",\n \"dependencies\": [\n \"es-errors\"\n ]\n },\n \"es-set-tostringtag@2.1.0\": {\n \"integrity\": \"sha512-j6vWzfrGVfyXxge+O0x5sh6cvxAog0a/4Rdd2K36zCMV5eJ+/+tOAngRO8cODMNWbVRdVlmGZQL2YS3yR8bIUA==\",\n \"dependencies\": [\n \"es-errors\",\n \"get-intrinsic\",\n \"has-tostringtag\",\n \"hasown\"\n ]\n },\n \"event-target-shim@5.0.1\": {\n \"integrity\": \"sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==\"\n },\n \"form-data-encoder@1.7.2\": {\n \"integrity\": \"sha512-qfqtYan3rxrnCk1VYaA4H+Ms9xdpPqvLZa6xmMgFvhO32x7/3J/ExcTd6qpxM0vH2GdMI+poehyBZvqfMTto8A==\"\n },\n \"form-data@4.0.2\": {\n \"integrity\": \"sha512-hGfm/slu0ZabnNt4oaRZ6uREyfCj6P4fT/n6A1rGV+Z0VdGXjfOhVUpkn6qVQONHGIFwmveGXyDs75+nr6FM8w==\",\n \"dependencies\": [\n \"asynckit\",\n \"combined-stream\",\n \"es-set-tostringtag\",\n \"mime-types\"\n ]\n },\n \"formdata-node@4.4.1\": {\n \"integrity\": \"sha512-0iirZp3uVDjVGt9p49aTaqjk84TrglENEDuqfdlZQ1roC9CWlPk6Avf8EEnZNcAqPonwkG35x4n3ww/1THYAeQ==\",\n \"dependencies\": [\n \"node-domexception\",\n \"web-streams-polyfill\"\n ]\n },\n \"function-bind@1.1.2\": {\n \"integrity\": \"sha512-7XHNxH7qX9xG5mIwxkhumTox/MIRNcOgDrxWsMt2pAr23WHp6MrRlN7FBSFpCpr+oVO0F744iUgR82nJMfG2SA==\"\n },\n \"get-intrinsic@1.3.0\": {\n \"integrity\": \"sha512-9fSjSaos/fRIVIp+xSJlE6lfwhES7LNtKaCBIamHsjr2na1BiABJPo0mOjjz8GJDURarmCPGqaiVg5mfjb98CQ==\",\n \"dependencies\": [\n \"call-bind-apply-helpers\",\n \"es-define-property\",\n \"es-errors\",\n \"es-object-atoms\",\n \"function-bind\",\n \"get-proto\",\n \"gopd\",\n \"has-symbols\",\n \"hasown\",\n \"math-intrinsics\"\n ]\n },\n \"get-proto@1.0.1\": {\n \"integrity\": \"sha512-sTSfBjoXBp89JvIKIefqw7U2CCebsc74kiY6awiGogKtoSGbgjYE/G/+l9sF3MWFPNc9IcoOC4ODfKHfxFmp0g==\",\n \"dependencies\": [\n \"dunder-proto\",\n \"es-object-atoms\"\n ]\n },\n \"gopd@1.2.0\": {\n \"integrity\": \"sha512-ZUKRh6/kUFoAiTAtTYPZJ3hw9wNxx+BIBOijnlG9PnrJsCcSjs1wyyD6vJpaYtgnzDrKYRSqf3OO6Rfa93xsRg==\"\n },\n \"groq-sdk@0.21.0\": {\n \"integrity\": \"sha512-SZg7oH/DsFvJllmdujNGZbfKUr2ATaU6urq0ZcnyObnmj6+nYM7WCGkyI2JMK+aWDzNiW6MwBNlSH722sHvtEQ==\",\n \"dependencies\": [\n \"@types/node@18.19.118\",\n \"@types/node-fetch\",\n \"abort-controller\",\n \"agentkeepalive\",\n \"form-data-encoder\",\n \"formdata-node\",\n \"node-fetch\"\n ]\n },\n \"has-symbols@1.1.0\": {\n \"integrity\": \"sha512-1cDNdwJ2Jaohmb3sg4OmKaMBwuC48sYni5HUw2DvsC8LjGTLK9h+eb1X6RyuOHe4hT0ULCW68iomhjUoKUqlPQ==\"\n },\n \"has-tostringtag@1.0.2\": {\n \"integrity\": \"sha512-NqADB8VjPFLM2V0VvHUewwwsw0ZWBaIdgo+ieHtK3hasLz4qeCRjYcqfB6AQrBggRKppKF8L52/VqdVsO47Dlw==\",\n \"dependencies\": [\n \"has-symbols\"\n ]\n },\n \"hasown@2.0.2\": {\n \"integrity\": \"sha512-0hJU9SCPvmMzIBdZFqNPXWa6dqh7WdH0cII9y+CyS8rG3nL48Bclra9HmKhVVUHyPWNH5Y7xDwAB7bfgSjkUMQ==\",\n \"dependencies\": [\n \"function-bind\"\n ]\n },\n \"humanize-ms@1.2.1\": {\n \"integrity\": \"sha512-Fl70vYtsAFb/C06PTS9dZBo7ihau+Tu/DNCk/OyHhea07S+aeMWpFFkUaXRa8fI+ScZbEI8dfSxwY7gxZ9SAVQ==\",\n \"dependencies\": [\n \"ms\"\n ]\n },\n \"marked@15.0.11\": {\n \"integrity\": \"sha512-1BEXAU2euRCG3xwgLVT1y0xbJEld1XOrmRJpUwRCcy7rxhSCwMrmEu9LXoPhHSCJG41V7YcQ2mjKRr5BA3ITIA==\",\n \"bin\": true\n },\n \"math-intrinsics@1.1.0\": {\n \"integrity\": \"sha512-/IXtbwEk5HTPyEwyKX6hGkYXxM9nbj64B+ilVJnC/R6B0pH5G4V3b0pVbL7DBj4tkhBAppbQUlf6F6Xl9LHu1g==\"\n },\n \"mime-db@1.52.0\": {\n \"integrity\": \"sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg==\"\n },\n \"mime-types@2.1.35\": {\n \"integrity\": \"sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw==\",\n \"dependencies\": [\n \"mime-db\"\n ]\n },\n \"ms@2.1.3\": {\n \"integrity\": \"sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==\"\n },\n \"node-domexception@1.0.0\": {\n \"integrity\": \"sha512-/jKZoMpw0F8GRwl4/eLROPA3cfcXtLApP0QzLmUT/HuPCZWyB7IY9ZrMeKw2O/nFIqPQB3PVM9aYm0F312AXDQ==\",\n \"deprecated\": true\n },\n \"node-fetch@2.7.0\": {\n \"integrity\": \"sha512-c4FRfUm/dbcWZ7U+1Wq0AwCyFL+3nt2bEw05wfxSz+DWpWsitgmSgYmy2dQdWyKC1694ELPqMs/YzUSNozLt8A==\",\n \"dependencies\": [\n \"whatwg-url\"\n ]\n },\n \"parse-ms@4.0.0\": {\n \"integrity\": \"sha512-TXfryirbmq34y8QBwgqCVLi+8oA3oWx2eAnSn62ITyEhEYaWRlVZ2DvMM9eZbMs/RfxPu/PK/aBLyGj4IrqMHw==\"\n },\n \"preact-render-to-string@6.5.13_preact@10.27.0\": {\n \"integrity\": \"sha512-iGPd+hKPMFKsfpR2vL4kJ6ZPcFIoWZEcBf0Dpm3zOpdVvj77aY8RlLiQji5OMrngEyaxGogeakTb54uS2FvA6w==\",\n \"dependencies\": [\n \"preact\"\n ]\n },\n \"preact@10.27.0\": {\n \"integrity\": \"sha512-/DTYoB6mwwgPytiqQTh/7SFRL98ZdiD8Sk8zIUVOxtwq4oWcwrcd1uno9fE/zZmUaUrFNYzbH14CPebOz9tZQw==\"\n },\n \"pretty-ms@9.2.0\": {\n \"integrity\": \"sha512-4yf0QO/sllf/1zbZWYnvWw3NxCQwLXKzIj0G849LSufP15BXKM0rbD2Z3wVnkMfjdn/CB0Dpp444gYAACdsplg==\",\n \"dependencies\": [\n \"parse-ms\"\n ]\n },\n \"tr46@0.0.3\": {\n \"integrity\": \"sha512-N3WMsuqV66lT30CrXNbEjx4GEwlow3v6rr4mCcv6prnfwhS01rkgyFdjPNBYd9br7LpXV1+Emh01fHnq2Gdgrw==\"\n },\n \"undici-types@5.26.5\": {\n \"integrity\": \"sha512-JlCMO+ehdEIKqlFxk6IfVoAUVmgz7cU7zD/h9XZ0qzeosSHmUJVOzSQvvYSYWXkFXC+IfLKSIffhv0sVZup6pA==\"\n },\n \"undici-types@6.21.0\": {\n \"integrity\": \"sha512-iwDZqg0QAGrg9Rav5H4n0M64c3mkR59cJ6wQp+7C4nI0gsmExaedaYLNO44eT4AtBBwjbTiGPMlt2Md0T9H9JQ==\"\n },\n \"web-streams-polyfill@4.0.0-beta.3\": {\n \"integrity\": \"sha512-QW95TCTaHmsYfHDybGMwO5IJIM93I/6vTRk+daHTWFPhwh+C8Cg7j7XyKrwrj8Ib6vYXe0ocYNrmzY4xAAN6ug==\"\n },\n \"webidl-conversions@3.0.1\": {\n \"integrity\": \"sha512-2JAn3z8AR6rjK8Sm8orRC0h/bcl/DqL7tRPdGZ4I1CjdF+EaMLmYxBHyXuKL849eucPFhvBoxMsflfOb8kxaeQ==\"\n },\n \"whatwg-url@5.0.0\": {\n \"integrity\": \"sha512-saE57nupxk6v3HY35+jzBwYa0rKSy0XR8JSxZPwgLr7ys0IBzhGviA1/TUGJLmSVqs8pb9AnvICXEuOHLprYTw==\",\n \"dependencies\": [\n \"tr46\",\n \"webidl-conversions\"\n ]\n }\n },\n \"redirects\": {\n \"https://esm.sh/preact/jsx-runtime\": \"https://esm.sh/preact@10.27.0/jsx-runtime\"\n },\n \"remote\": {\n \"https://deno.land/std@0.190.0/_util/asserts.ts\": \"178dfc49a464aee693a7e285567b3d0b555dc805ff490505a8aae34f9cfb1462\",\n \"https://deno.land/std@0.190.0/async/abortable.ts\": \"fd682fa46f3b7b16b4606a5ab52a7ce309434b76f820d3221bdfb862719a15d7\",\n \"https://deno.land/std@0.190.0/async/deadline.ts\": \"58f72a3cc0fcb731b2cc055ba046f4b5be3349ff6bf98f2e793c3b969354aab2\",\n \"https://deno.land/std@0.190.0/async/debounce.ts\": \"adab11d04ca38d699444ac8a9d9856b4155e8dda2afd07ce78276c01ea5a4332\",\n \"https://deno.land/std@0.190.0/async/deferred.ts\": \"42790112f36a75a57db4a96d33974a936deb7b04d25c6084a9fa8a49f135def8\",\n \"https://deno.land/std@0.190.0/async/delay.ts\": \"73aa04cec034c84fc748c7be49bb15cac3dd43a57174bfdb7a4aec22c248f0dd\",\n \"https://deno.land/std@0.190.0/async/mod.ts\": \"f04344fa21738e5ad6bea37a6bfffd57c617c2d372bb9f9dcfd118a1b622e576\",\n \"https://deno.land/std@0.190.0/async/mux_async_iterator.ts\": \"70c7f2ee4e9466161350473ad61cac0b9f115cff4c552eaa7ef9d50c4cbb4cc9\",\n \"https://deno.land/std@0.190.0/async/pool.ts\": \"f1b8d3df4d7fd3c73f8cbc91cc2e8b8e950910f1eab94230b443944d7584c657\",\n \"https://deno.land/std@0.190.0/async/retry.ts\": \"c9248325ec08cc2cceb7618472e77589a51a25cee460e07b6096be34966c2ead\",\n \"https://deno.land/std@0.190.0/async/tee.ts\": \"47e42d35f622650b02234d43803d0383a89eb4387e1b83b5a40106d18ae36757\",\n \"https://deno.land/std@0.190.0/http/server.ts\": \"1b23463b5b36e4eebc495417f6af47a6f7d52e3294827a1226d2a1aab23d9d20\",\n \"https://deno.land/x/hono@v3.11.12/client/client.ts\": \"ff340f58041203879972dd368b011ed130c66914f789826610869a90603406bf\",\n \"https://deno.land/x/hono@v3.11.12/client/index.ts\": \"3ff4cf246f3543f827a85a2c84d66a025ac350ee927613629bda47e854bfb7ba\",\n \"https://deno.land/x/hono@v3.11.12/client/utils.ts\": \"053273c002963b549d38268a1b423ac8ca211a8028bdab1ed0b781a62aa5e661\",\n \"https://deno.land/x/hono@v3.11.12/compose.ts\": \"37d6e33b7db80e4c43a0629b12fd3a1e3406e7d9e62a4bfad4b30426ea7ae4f1\",\n \"https://deno.land/x/hono@v3.11.12/context.ts\": \"5cac561498e1f4af7a355673a047f07f47349056c5167ed9aec8a20cdcac8464\",\n \"https://deno.land/x/hono@v3.11.12/helper/cookie/index.ts\": \"a05ce7e3bafe1f8c7f45d04abf79822716011be75904fe1aad2e99126fd985b9\",\n \"https://deno.land/x/hono@v3.11.12/helper/html/index.ts\": \"701ed12b808e8c253247edc02c2c4b32261ae899e9c98f1427f7f6eaa8b7d1ce\",\n \"https://deno.land/x/hono@v3.11.12/hono-base.ts\": \"976dad584171a29765af1b0ad200766e8c3e1c35fbec7556dd4bc0b254df9ef4\",\n \"https://deno.land/x/hono@v3.11.12/hono.ts\": \"2cc4c292e541463a4d6f83edbcea58048d203e9564ae62ec430a3d466b49a865\",\n \"https://deno.land/x/hono@v3.11.12/http-exception.ts\": \"6071df078b5f76d279684d52fe82a590f447a64ffe1b75eb5064d0c8a8d2d676\",\n \"https://deno.land/x/hono@v3.11.12/mod.ts\": \"90114a97be9111b348129ad0143e764a64921f60dd03b8f3da529db98a0d3a82\",\n \"https://deno.land/x/hono@v3.11.12/request.ts\": \"71a67261d14bba95e9a8b4782a1c1704d12d54a77390ce404741df15ab99a109\",\n \"https://deno.land/x/hono@v3.11.12/router.ts\": \"880316f561918fc197481755aac2165fdbe2f530b925c5357a9f98d6e2cc85c7\",\n \"https://deno.land/x/hono@v3.11.12/router/linear-router/index.ts\": \"8a2a7144c50b1f4a92d9ee99c2c396716af144c868e10608255f969695efccd0\",\n \"https://deno.land/x/hono@v3.11.12/router/linear-router/router.ts\": \"bc63e8b5bc1dabc815306d50bebd1bb5877ffa3936ba2ad7550d093c95ee6bd1\",\n \"https://deno.land/x/hono@v3.11.12/router/pattern-router/index.ts\": \"304a66c50e243872037ed41c7dd79ed0c89d815e17e172e7ad7cdc4bc07d3383\",\n \"https://deno.land/x/hono@v3.11.12/router/pattern-router/router.ts\": \"a9a5a2a182cce8c3ae82139892cc0502be7dd8f579f31e76d0302b19b338e548\",\n \"https://deno.land/x/hono@v3.11.12/router/reg-exp-router/index.ts\": \"52755829213941756159b7a963097bafde5cc4fc22b13b1c7c9184dc0512d1db\",\n \"https://deno.land/x/hono@v3.11.12/router/reg-exp-router/node.ts\": \"5b3fb80411db04c65df066e69fedb2c8c0844753c2633d703336de84d569252c\",\n \"https://deno.land/x/hono@v3.11.12/router/reg-exp-router/router.ts\": \"7f7af7ce45a4327f9ac7dbdee186f7ba9a24f2eff14c720e3f670be001e71780\",\n \"https://deno.land/x/hono@v3.11.12/router/reg-exp-router/trie.ts\": \"852ce7207e6701e47fa30889a0d2b8bfcd56d8862c97e7bc9831e0a64bd8835f\",\n \"https://deno.land/x/hono@v3.11.12/router/smart-router/index.ts\": \"74f9b4fe15ea535900f2b9b048581915f12fe94e531dd2b0032f5610e61c3bef\",\n \"https://deno.land/x/hono@v3.11.12/router/smart-router/router.ts\": \"f1848a2a1eefa316a11853ae12e749552747771fb8a11fe713ae04ea6461140b\",\n \"https://deno.land/x/hono@v3.11.12/router/trie-router/index.ts\": \"3eb75e7f71ba81801631b30de6b1f5cefb2c7239c03797e2b2cbab5085911b41\",\n \"https://deno.land/x/hono@v3.11.12/router/trie-router/node.ts\": \"1709750f3da7bf7fa3e8078caa1fc0bd5583b03c79f3a63f75480a2db25e62ad\",\n \"https://deno.land/x/hono@v3.11.12/router/trie-router/router.ts\": \"54ced78d35676302c8fcdda4204f7bdf5a7cc907fbf9967c75674b1e394f830d\",\n \"https://deno.land/x/hono@v3.11.12/utils/body.ts\": \"7a16a6656331a96bcae57642f8d5e3912bd361cbbcc2c0d2157ecc3f218f7a92\",\n \"https://deno.land/x/hono@v3.11.12/utils/buffer.ts\": \"9066a973e64498cb262c7e932f47eed525a51677b17f90893862b7279dc0773e\",\n \"https://deno.land/x/hono@v3.11.12/utils/cookie.ts\": \"19920ba6756944aae1ad8585c3ddeaa9df479733f59d05359db096f7361e5e4b\",\n \"https://deno.land/x/hono@v3.11.12/utils/crypto.ts\": \"bda0e141bbe46d3a4a20f8fbcb6380d473b617123d9fdfa93e4499410b537acc\",\n \"https://deno.land/x/hono@v3.11.12/utils/html.ts\": \"b60def9561d2fbeb7254035632ea98b97ef852ec72baae2924fc126e96315696\",\n \"https://deno.land/x/hono@v3.11.12/utils/stream.ts\": \"1789dcc73c5b0ede28f83d7d34e47ae432c20e680907cb3275a9c9187f293983\",\n \"https://deno.land/x/hono@v3.11.12/utils/url.ts\": \"af0d600973ce11f9279da19a49e1264fe2f7a5658ccd97e30f7c3c2239dca052\",\n \"https://deno.land/x/hono@v3.11.12/validator/index.ts\": \"6c986e8b91dcf857ecc8164a506ae8eea8665792a4ff7215471df669c632ae7c\",\n \"https://deno.land/x/hono@v3.11.12/validator/validator.ts\": \"f6139f0b6eb2040bc9f7ed4148905d5affc898235952772b2d6585fdae8d4731\",\n \"https://esm.sh/preact@10.27.0/denonext/jsx-runtime.mjs\": \"eca8d082839db06e1964509be699072222b5822483819dc5ac96d7fee1201343\",\n \"https://esm.sh/preact@10.27.0/denonext/preact.mjs\": \"7c0a67d0152259c63d2afea05ce8791f6f4e38ef355fdab8a2c71989cf590c3d\",\n \"https://esm.sh/preact@10.27.0/jsx-runtime\": \"f33f69315b770515e473b14403cef9c49f3427ff61016041220e36505ab8cc68\",\n \"https://esm.town/v/std/utils@85-main/file/index.ts\": \"f7b4d1f95fb1ef1cbcb3bc0d2fe83194f18403c7d35115a9f066cba4ef6b84d0\",\n \"https://esm.town/v/std/utils@85-main/index.ts\": \"3d060a58ccd352517da960077ffd78b80c1051ca2117cb37adbff0365cb45efb\",\n \"https://esm.town/v/std/utils@85-main/parseImportMeta/project.ts\": \"1a47e75e21faf22b38fb07e6ead284b6a381a48970a39490e585507a8bb47bbf\",\n \"https://esm.town/v/std/utils@85-main/serve-file/index.ts\": \"1386c1fe12e8e9a41e3561b0a1e55f332bc559fe98fa81f99434b4f642275cd4\",\n \"https://esm.town/v/std/utils@85-main/test/index.tsx\": \"41fc8ccb29945e8cf65263dc61a6840decf9f62fb035be8d0651267ac84b573d\"\n }\n}\n",[165],"c49a8cba-9810-11f0-8ad1-0224a6c84d84","deno.json","cced18f2-81f8-11f0-976d-0224a6c84d84",138,["D",1758585823050],1,"{\n \"tasks\": {\n \"serve\": \"deno serve --allow-sys --allow-read --allow-import --allow-env --allow-write --allow-net --reload=https://esm.town ./main.js\"\n },\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}",[172],"dde989fa-9810-11f0-8d07-0224a6c84d84","chatStreaming.js","dde98aae-9810-11f0-8d07-0224a6c84d84",148,["D",1758585865833],"// Removed legacy streaming utilities; not used by background checker.\n\n// Intentionally left minimal; streaming utilities were removed.\n\n\n",[180],"de0165fc-9810-11f0-894e-0224a6c84d84","chatCompletion.js","de0166b0-9810-11f0-894e-0224a6c84d84",151,["D",1758585865836],"// Minimal Groq Chat Completions client using fetch (for background checker)\nexport async function groqChatCompletion(apiKey, payload) {\n // console.log('>>> [groqChatCompletion] Payload:', payload);\n let response;\n try {\n response = await fetch('https://api.groq.com/openai/v1/chat/completions', {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n 'Authorization': `Bearer ${apiKey}`,\n },\n body: JSON.stringify(payload),\n });\n } catch (err) {\n console.error('>>> [groqChatCompletion] Network error:', err && err.message ? err.message : String(err));\n throw err;\n }\n console.log('>>> [groqChatCompletion] Status:', response.status);\n if (!response.ok) {\n const text = await response.text();\n console.error('>>> [groqChatCompletion] Error response:', response.status, text);\n throw new Error(`Groq API error: ${response.status} ${text}`);\n }\n const json = await response.json();\n // try { console.log('>>> [groqChatCompletion] JSON:', JSON.stringify(json)); } catch (_) {}\n return json;\n}\n\n\n",[187],"c46b2970-9810-11f0-b38b-0224a6c84d84","README.md","cc3b4d20-81f8-11f0-b51c-0224a6c84d84",131,["D",1758585823042],4,"# MCP Navigator — AI-Powered MCP Tool Router for Groq\n\nA smart, unified API for accessing Model Context Protocol (MCP) tools through Groq's Responses endpoint. Features AI-powered tool selection, dynamic MCP registry integration, and zero-configuration tool access.\n\n## Features\n\n- **🤖 AI Tool Selection** — Let AI automatically choose the best tools for your queries\n- **🌐 Universal MCP Access** — Access any MCP tool from the official registry without configuration\n- **📝 Dynamic Documentation** — Auto-generated examples based on actual available tools\n- **🔑 Per-Tool API Keys** — Bring your own keys for each MCP tool\n- **🚀 Browser-Friendly** — GET requests with query parameters for easy testing\n- **⚡ Multiple Tool Support** — Execute multiple MCP tools in one request\n- **🔧 Smart Registry** — Local tools + automatic fallback to public MCP registry\n\n## Quick Start\n\n1. **Install Deno:** https://deno.land/#installation\n\n2. **Set environment variables:**\n```bash\nexport GROQ_API_KEY=\"your_groq_api_key\"\nexport PARALLEL_API_KEY=\"your_parallel_api_key\"\n```\n\n3. **Start the server:**\n```bash\ndeno task serve\n```\nThis runs: `deno serve --allow-sys --allow-read --allow-import --allow-env --allow-write --allow-net --reload=https://esm.town ./main.js`\n\n4. **Open http://localhost:8000** to see the API documentation\n\n## Usage Examples\n\n### 🤖 AI-Powered Tool Selection (Recommended)\n\nLet AI automatically choose the best tools for your query:\n\n```bash\n# Browser-friendly: AI picks the right tools and executes them\nGET /select?q=Plan a 3-day trip to Tokyo\n\n# Generate curl commands for any query\nGET /select?q=Find trending AI models&mode=curl\n\n# Programmatic usage with custom API keys\ncurl -X POST \"http://localhost:8000/select\" \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer YOUR_GROQ_API_KEY\" \\\n -d '{\"query\": \"Build a travel itinerary for Paris\", \"mode\": \"execute\"}'\n```\n\n### 🎯 Direct Tool Execution\n\nWhen you know exactly which tools to use:\n\n```bash\n# Execute specific tools\nGET /?tools=parallel_web_search&q=what's the weather in San Francisco\n\n# Multiple tools coordination\nGET /?tools=github,huggingface&q=research trending AI models and create an issue\n\n# MCP Registry tool (zero configuration)\nGET /?tools=garden.stanislav.svelte-llm/svelte-llm-mcp&q=what are svelte runes\n```\n\n### 📋 Tool Discovery\n\n```bash\n# List all available tools\nGET /?mode=list\n\n# Get detailed tool schemas\nGET /?tools=parallel_web_search&mode=list\n\n# Browse the MCP registry\nGET /registry\n\n# Search for specific tools\nGET /registry?search=gmail\n```\n\n### Advanced: Per-Tool API Keys (POST)\n\nFor production use, you can provide custom API keys per tool using the POST endpoint:\n\n```bash\n# Execute with custom API keys for each tool\ncurl -X POST \"http://localhost:8000/\" \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer YOUR_GROQ_API_KEY\" \\\n -d '{\n \"tools\": \"parallel_web_search,github\",\n \"q\": \"research latest AI developments and create an issue\",\n \"toolHeaders\": {\n \"parallel_web_search\": {\n \"x-api-key\": \"USER_PROVIDED_PARALLEL_KEY\"\n },\n \"github\": {\n \"Authorization\": \"Bearer USER_PROVIDED_GITHUB_TOKEN\"\n }\n }\n }'\n\n# List tools with custom headers\ncurl -X POST \"http://localhost:8000/\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\n \"mode\": \"list\",\n \"tools\": \"parallel_web_search\",\n \"apiKey\": \"YOUR_GROQ_API_KEY\",\n \"toolHeaders\": {\n \"parallel_web_search\": {\n \"x-api-key\": \"USER_PROVIDED_PARALLEL_KEY\"\n }\n }\n }'\n```\n\n**Key Features:**\n- **Bring Your Own Keys**: Users can provide their own API keys for each MCP tool\n- **Secure**: Keys are used per-request, not stored\n- **Priority**: User-provided keys override environment variables\n- **Flexible**: Mix environment keys with user keys as needed\n\n## API Reference\n\n### 🤖 AI Tool Selection\n\n**`GET/POST /select`** — AI automatically chooses the best tools for your query\n\n#### GET Parameters\n| Parameter | Description | Default | Required |\n|-----------|-------------|---------|----------|\n| `q` or `query` | Your natural language query | - | Yes |\n| `mode` | `execute` or `curl` | `execute` | No |\n| `model` | Groq model to use | `openai/gpt-oss-120b` | No |\n\n#### POST Body\n```json\n{\n \"query\": \"Your natural language query\",\n \"mode\": \"execute\", // or \"curl\"\n \"model\": \"openai/gpt-oss-120b\"\n}\n```\n\n**Examples:**\n```bash\n# Let AI pick tools and execute\nGET /select?q=Plan a trip to Tokyo\n\n# Generate curl command \nGET /select?q=Find trending AI models&mode=curl\n\n# Programmatic usage\nPOST /select {\"query\": \"Search for emails about project\", \"mode\": \"execute\"}\n```\n\n### 🎯 Direct Tool Execution\n\n**`GET/POST /`** — Execute specific tools when you know what you need\n\n#### GET Parameters\n| Parameter | Description | Default | Required |\n|-----------|-------------|---------|----------|\n| `tools` | Comma-separated tool names | - | For execute mode |\n| `q` | Query/input for tools | - | For execute mode |\n| `mode` | `execute` or `list` | `execute` | No |\n| `model` | Groq model | `openai/gpt-oss-120b` | No |\n\n#### POST Body (Enhanced)\n ```json\n {\n \"tools\": \"tool1,tool2\",\n \"q\": \"Your query\",\n \"mode\": \"execute\",\n \"toolHeaders\": {\n \"tool1\": {\"x-api-key\": \"YOUR_KEY\"}\n }\n}\n```\n\n### 🔧 Other Endpoints\n\n- **`GET /registry`** — Browse official MCP registry with search\n- **`POST /api/tool/:toolName`** — Individual tool execution (supports MCP registry)\n- **`GET /debug`** — Environment and configuration check\n- **`POST /api/groq/responses`** — Direct Groq API wrapper\n\n## 🌐 Universal MCP Access\n\nOne of the most powerful features is **zero-configuration access** to any MCP tool from the official registry:\n\n```bash\n# Use any MCP tool without setup - automatically discovered from registry\nGET /?tools=garden.stanislav.svelte-llm/svelte-llm-mcp&q=what are svelte runes\nGET /?tools=com.peek/mcp&q=plan a 3-day tokyo itinerary \nGET /?tools=ai.waystation/gmail&q=search for emails about the project\n\n# Or let AI pick the perfect tool automatically \nGET /select?q=I need help with Svelte development\n```\n\n**How it works:**\n1. **Local Registry First** — Checks your configured tools\n2. **MCP Registry Fallback** — Automatically searches 300+ public MCP tools\n3. **Smart Matching** — Finds tools by exact name or fuzzy matching\n4. **Zero Config** — Works immediately without setup\n\n## Tool Registry\n\nTools are registered in the `toolsRegistry` object in `main.js`. Each tool can include optional `_meta` for better documentation and examples:\n\n```javascript\nconst toolsRegistry = {\n parallel_web_search: {\n type: \"mcp\",\n server_label: \"parallel_web_search\",\n server_url: \"https://mcp.parallel.ai/v1beta/search_mcp/\",\n headers: {\n \"x-api-key\": () => Deno.env.get(\"PARALLEL_API_KEY\")\n },\n require_approval: \"never\",\n // Optional metadata for better dynamic examples\n _meta: {\n description: \"Web search with AI-optimized results\",\n example_queries: [\n \"what's the weather in San Francisco\",\n \"latest developments in AI safety research\",\n \"current news about climate change\"\n ],\n use_cases: [\"Current events\", \"Research\", \"Weather\", \"News\"]\n }\n },\n github: {\n type: \"mcp\",\n server_label: \"GitHub\",\n server_url: \"https://api.githubcopilot.com/mcp/\",\n headers: {\n \"Authorization\": () => `Bearer ${Deno.env.get(\"GITHUB_TOKEN\")}`\n },\n require_approval: \"never\",\n _meta: {\n description: \"GitHub repository management and operations\",\n example_queries: [\n \"create an issue in my repo about adding MCP examples\",\n \"search for repositories related to AI\",\n \"create a new issue titled 'Add authentication'\"\n ],\n use_cases: [\"Create issues\", \"Manage repos\", \"Code search\", \"Pull requests\"]\n }\n },\n // Add more tools here...\n};\n```\n\n### Adding New Tools\n\n1. Add your tool configuration to `toolsRegistry`\n2. Set required environment variables\n3. Optionally add `_meta` for better documentation\n4. The tool will automatically be available via the API with dynamic examples\n\nExample:\n```javascript\nnew_tool: {\n type: \"mcp\",\n server_label: \"new_tool\",\n server_url: \"https://example.com/mcp/\",\n headers: {\n \"authorization\": () => `Bearer ${Deno.env.get(\"NEW_TOOL_API_KEY\")}`\n },\n require_approval: \"never\",\n _meta: {\n description: \"Custom tool for specific operations\",\n example_queries: [\n \"primary example query\",\n \"secondary example query\",\n \"tertiary example query\"\n ],\n use_cases: [\"Use case 1\", \"Use case 2\", \"Use case 3\"]\n }\n}\n```\n\n### Dynamic Documentation\n\nThe API documentation at `/` is **completely dynamic** and generates examples based on:\n\n1. **Tool metadata** (`_meta`) if provided\n2. **Registry descriptions** from dynamically loaded MCP tools \n3. **Smart detection** based on tool names and server labels\n4. **Fallback examples** for unknown tool types\n\nThis means:\n- ✅ **No hardcoded examples** - everything reflects your actual tool registry\n- ✅ **Automatic updates** - adding tools instantly updates documentation\n- ✅ **Consistent behavior** - examples work out of the box\n- ✅ **Smart defaults** - reasonable examples even without metadata\n\n## Response Format\n\n### Successful Tool Execution\n ```json\n{\n \"id\": \"resp_01k5shpe...\",\n \"object\": \"response\",\n \"status\": \"completed\",\n \"output\": [\n {\n \"type\": \"mcp_call\",\n \"server_label\": \"parallel_web_search\",\n \"name\": \"web_search_preview\",\n \"output\": \"...\"\n },\n {\n \"type\": \"message\",\n \"role\": \"assistant\",\n \"content\": [...]\n }\n ],\n \"usage\": {...}\n}\n```\n\n### Tool Schema Response\n ```json\n {\n \"mode\": \"list\",\n \"schemas\": [\n {\n \"toolName\": \"parallel_web_search\",\n \"server_label\": \"parallel_web_search\",\n \"tools\": [\n {\n \"name\": \"web_search_preview\",\n \"description\": \"Perform web searches...\",\n \"input_schema\": {...}\n }\n ],\n \"tool_count\": 1\n }\n ]\n}\n```\n\n## Environment Variables\n\n| Variable | Description | Required |\n|----------|-------------|----------|\n| `GROQ_API_KEY` | Groq API key for model access | Yes |\n| `PARALLEL_API_KEY` | Parallel AI API key for web search | For parallel_web_search tool |\n| `GITHUB_TOKEN` | GitHub token for GitHub MCP tool | For github tool |\n\n## SDK Examples\n\n### Using OpenAI SDK with Groq\n\n```javascript\nimport OpenAI from \"openai\";\n\nconst client = new OpenAI({\n apiKey: process.env.GROQ_API_KEY,\n baseURL: \"https://api.groq.com/openai/v1\",\n});\n\n// Single tool example\nconst response = await client.responses.create({\n model: \"openai/gpt-oss-120b\",\n input: \"What models are trending on Huggingface?\",\n tools: [\n {\n type: \"mcp\",\n server_label: \"Huggingface\",\n server_url: \"https://huggingface.co/mcp\",\n }\n ]\n});\n\nconsole.log(response);\n```\n\n### Multiple MCP Servers\n\n```javascript\nconst response = await client.responses.create({\n model: \"openai/gpt-oss-120b\",\n input: \"Please create a new issue in my repository called 'build-with-groq/groq-code-cli' with the title 'Add MCP examples' and outline a few examples of MCP?\",\n tools: [\n {\n type: \"mcp\",\n server_label: \"GitHub\",\n server_url: \"https://api.githubcopilot.com/mcp/\",\n headers: {\n Authorization: \"Bearer \"\n }\n },\n {\n type: \"mcp\",\n server_label: \"Huggingface\",\n server_url: \"https://huggingface.co/mcp\",\n }\n ]\n});\n\nconsole.log(response);\n```\n\n### Advanced: Multiple Systems Coordination\n\n```javascript\nconst response = await client.responses.create({\n model: \"openai/gpt-oss-120b\",\n input: \"Research trending AI models and create a GitHub issue summarizing them\",\n tools: [\n {\n type: \"mcp\",\n server_label: \"GitHub\",\n server_url: \"https://api.githubcopilot.com/mcp/\",\n headers: { \"Authorization\": \"Bearer \" }\n },\n {\n type: \"mcp\",\n server_label: \"Huggingface\",\n server_url: \"https://huggingface.co/mcp\"\n },\n {\n type: \"mcp\",\n server_label: \"parallel_web_search\",\n server_url: \"https://mcp.parallel.ai/v1beta/search_mcp/\",\n headers: { \"x-api-key\": \"\" }\n }\n ]\n});\n```\n\n## Architecture\n\n### Core Components\n\n- **🤖 AI Tool Selector** — GPT-oss-120b automatically chooses optimal tools\n- **🌐 Universal Registry** — Local tools + dynamic MCP registry integration \n- **📝 Dynamic Documentation** — Auto-generated examples from tool metadata\n- **🔑 Flexible Auth** — Per-tool API keys with environment fallback\n- **⚡ Smart Router** — Context-aware endpoint handling\n\n### Intelligent Behaviors\n\n- **`/select?q=X`** → AI picks tools and executes\n- **`/?tools=X&q=Y`** → Direct tool execution\n- **`/?mode=list`** → Tool discovery and schemas\n- **No parameters** → Dynamic API documentation\n- **Unknown tools** → Automatic MCP registry lookup\n\n## Error Handling\n\nThe API provides detailed error messages with helpful examples:\n\n- **401 Unauthorized** — Missing or invalid API keys\n- **404 Not Found** — Tool not found in registry\n- **400 Bad Request** — Missing required parameters\n\n## Development\n\n### Project Structure\n```\ngroq-mcp-nav/\n├── main.js # Main server and API logic\n├── deno.json # Deno configuration\n├── README.md # This file\n└── ...\n```\n\n### Testing Tools\n\nMultiple ways to test and explore:\n- **`/`** → Interactive API documentation\n- **`/select?q=your query`** → AI-powered tool selection \n- **`/?tools=tool_name&q=test`** → Direct tool execution\n- **`/?mode=list`** → Explore available tools\n- **`/registry`** → Browse 300+ public MCP tools\n- **`/debug`** → Check configuration and API keys\n\n## Requirements\n\n- **Deno 1.40+**\n- **Groq API Key** (get one at https://groq.com)\n- **Tool-specific API Keys** (e.g., Parallel AI for web search)\n\n## Notes\n\n- **AI-Powered** — Uses GPT-oss-120b for intelligent tool selection\n- **Universal Access** — Works with 300+ MCP tools from the official registry\n- **Zero Config** — Most tools work immediately without setup\n- **Production Ready** — Per-tool API keys and secure environment variables\n- **Browser & API** — Designed for both interactive and programmatic usage\n\n**Powered by Groq** — get your API key at https://groq.com\n",[194],"cd6e4698-81f8-11f0-b9be-0224a6c84d84",".vtignore","cd6e4738-81f8-11f0-b9be-0224a6c84d84",88,["D",1756156604684],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor\n.env",[202],"cc70d0ee-81f8-11f0-bbd2-0224a6c84d84",".gitignore","cc70d17a-81f8-11f0-bbd2-0224a6c84d84",52,["D",1756156602949],".env\n.DS_Store",[209],"cc334c7e-81f8-11f0-b660-0224a6c84d84",".cursorrules","cc334d0a-81f8-11f0-b660-0224a6c84d84",46,["D",1756156602621],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious operations)\n- Follow modern ES6+ conventions and functional programming practices if possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = 'todo_app_users_2';\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(`SELECT * FROM ${TABLE_NAME} WHERE id = ?`, [1]);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: \"Say hello in a creative way\" },\n ],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({ \n subject: \"Hi\", \n text: \"Hi\", \n html: \"

Hi

\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n \n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n \n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[216],"c41612dc-9810-11f0-b894-0224a6c84d84","groq-mcp-nav","c4161458-9810-11f0-b894-0224a6c84d84",124,["D",1758585822504],"directory",[223],"c8b9ba24-81f8-11f0-8eeb-0224a6c84d84","frontend","c8b9bace-81f8-11f0-8eeb-0224a6c84d84",["D",1756156596788],[230],"a8fe7f0e-8530-11f0-b9d8-0224a6c84d84","backend","a8fe7fcc-8530-11f0-b9d8-0224a6c84d84",104,["D",1756510448859],[235],"c8cc9cb6-81f8-11f0-8e18-0224a6c84d84",".vt","c8cc9d7e-81f8-11f0-8e18-0224a6c84d84",2,["D",1756156596911],[241],"pulls","branches","forks","envVars",{"_253":62,"_255":62},"connections",{"_253":62,"_254":62},"count","unfilledCount","emptyCount",{"_42":240,"_31":241,"_29":242,"_143":-5,"_40":41,"_39":243,"_145":58,"_37":430,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_286":431,"_26":432},{"_42":422,"_31":423,"_29":424,"_143":242,"_40":41,"_39":425,"_145":58,"_37":426,"_13":62,"_33":20,"_35":427,"_23":24,"_148":-5,"_286":428,"_26":429},{"_42":234,"_31":235,"_29":236,"_143":-5,"_40":41,"_39":237,"_145":58,"_37":419,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_286":420,"_26":421},{"_42":414,"_31":367,"_29":363,"_143":236,"_40":41,"_39":415,"_145":58,"_37":416,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_286":417,"_26":418},{"_42":409,"_31":384,"_29":378,"_143":363,"_40":41,"_39":410,"_145":58,"_37":411,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_286":412,"_26":413},{"_42":401,"_31":402,"_29":403,"_143":378,"_40":41,"_39":404,"_145":58,"_37":405,"_13":62,"_33":34,"_35":406,"_23":24,"_148":-5,"_286":407,"_26":408},{"_42":393,"_31":394,"_29":395,"_143":378,"_40":41,"_39":396,"_145":58,"_37":397,"_13":62,"_33":34,"_35":398,"_23":24,"_148":-5,"_286":399,"_26":400},{"_42":385,"_31":386,"_29":387,"_143":378,"_40":41,"_39":388,"_145":58,"_37":389,"_13":62,"_33":34,"_35":390,"_23":24,"_148":-5,"_286":391,"_26":392},{"_42":375,"_31":376,"_29":377,"_143":378,"_40":41,"_39":379,"_145":58,"_37":380,"_13":62,"_33":34,"_35":381,"_23":24,"_148":-5,"_286":382,"_26":383},{"_42":368,"_31":369,"_29":370,"_143":363,"_40":41,"_39":371,"_145":58,"_37":372,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_286":373,"_26":374},{"_42":362,"_31":32,"_29":30,"_143":363,"_40":41,"_39":14,"_145":58,"_37":364,"_13":62,"_33":34,"_35":36,"_23":24,"_148":-5,"_286":365,"_26":366},{"_42":229,"_31":230,"_29":231,"_143":-5,"_40":41,"_39":176,"_145":58,"_37":359,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_286":360,"_26":361},{"_42":351,"_31":352,"_29":353,"_143":231,"_40":41,"_39":354,"_145":24,"_37":355,"_13":243,"_33":34,"_35":356,"_23":24,"_148":-5,"_286":357,"_26":358},{"_42":343,"_31":344,"_29":345,"_143":231,"_40":41,"_39":346,"_145":58,"_37":347,"_13":62,"_33":34,"_35":348,"_23":24,"_148":-5,"_286":349,"_26":350},{"_42":222,"_31":223,"_29":224,"_143":-5,"_40":41,"_39":225,"_145":24,"_37":340,"_13":62,"_33":227,"_35":-5,"_23":24,"_148":-5,"_286":341,"_26":342},{"_42":333,"_31":202,"_29":334,"_143":224,"_40":41,"_39":335,"_145":24,"_37":336,"_13":62,"_33":20,"_35":337,"_23":24,"_148":-5,"_286":338,"_26":339},{"_42":326,"_31":327,"_29":328,"_143":224,"_40":41,"_39":329,"_145":24,"_37":330,"_13":62,"_33":20,"_35":220,"_23":24,"_148":-5,"_286":331,"_26":332},{"_42":319,"_31":172,"_29":320,"_143":224,"_40":41,"_39":321,"_145":24,"_37":322,"_13":62,"_33":20,"_35":323,"_23":24,"_148":-5,"_286":324,"_26":325},{"_42":215,"_31":216,"_29":217,"_143":-5,"_40":41,"_39":218,"_145":58,"_37":316,"_13":62,"_33":20,"_35":220,"_23":24,"_148":-5,"_286":317,"_26":318},{"_42":208,"_31":209,"_29":210,"_143":-5,"_40":41,"_39":211,"_145":58,"_37":313,"_13":62,"_33":20,"_35":213,"_23":24,"_148":-5,"_286":314,"_26":315},{"_42":201,"_31":202,"_29":203,"_143":-5,"_40":41,"_39":204,"_145":58,"_37":310,"_13":62,"_33":20,"_35":206,"_23":24,"_148":-5,"_286":311,"_26":312},{"_42":193,"_31":194,"_29":195,"_143":-5,"_40":41,"_39":196,"_145":24,"_37":307,"_13":198,"_33":20,"_35":199,"_23":24,"_148":-5,"_286":308,"_26":309},{"_42":186,"_31":187,"_29":188,"_143":-5,"_40":41,"_39":189,"_145":58,"_37":304,"_13":62,"_33":34,"_35":191,"_23":24,"_148":-5,"_286":305,"_26":306},{"_42":179,"_31":180,"_29":181,"_143":-5,"_40":41,"_39":182,"_145":58,"_37":301,"_13":62,"_33":34,"_35":184,"_23":24,"_148":-5,"_286":302,"_26":303},{"_42":171,"_31":172,"_29":173,"_143":-5,"_40":41,"_39":174,"_145":24,"_37":298,"_13":176,"_33":20,"_35":177,"_23":24,"_148":-5,"_286":299,"_26":300},{"_42":164,"_31":165,"_29":166,"_143":-5,"_40":41,"_39":167,"_145":58,"_37":295,"_13":62,"_33":20,"_35":169,"_23":24,"_148":-5,"_286":296,"_26":297},{"_42":157,"_31":158,"_29":159,"_143":-5,"_40":41,"_39":160,"_145":24,"_37":292,"_13":153,"_33":20,"_35":162,"_23":24,"_148":-5,"_286":293,"_26":294},{"_42":150,"_31":32,"_29":56,"_143":-5,"_40":41,"_39":151,"_145":24,"_37":289,"_13":153,"_33":154,"_35":155,"_23":24,"_148":44,"_286":290,"_26":291},{"_42":140,"_31":141,"_29":142,"_143":-5,"_40":41,"_39":144,"_145":58,"_37":285,"_13":62,"_33":20,"_35":147,"_23":24,"_148":-5,"_286":287,"_26":288},["D",1756156602938],"children",[],[141],["D",1756514076036],[],[32],["D",1758585822735],[],[158],["D",1756156602938],[],[165],["D",1758585823050],[],[172],["D",1758585865833],[],[180],["D",1758585865836],[],[187],["D",1758585823042],[],[194],["D",1756156604684],[],[202],["D",1756156602949],[],[209],["D",1756156602621],[],[216],"c43a0660-9810-11f0-b894-0224a6c84d84","c43a0714-9810-11f0-b894-0224a6c84d84",126,["D",1758585822744],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}",[],[223,172],"c4355930-9810-11f0-a285-0224a6c84d84","AGENTS.md","c43559e4-9810-11f0-a285-0224a6c84d84",125,["D",1758585822714],[],[223,327],"c44af4b6-9810-11f0-b930-0224a6c84d84","c44af57e-9810-11f0-b930-0224a6c84d84",128,["D",1758585822856],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor",[],[223,202],["D",1758585822504],[271,272,273],[223],"ddf3e300-9810-11f0-87e9-0224a6c84d84","mailcheckApp.js","ddf3e3dc-9810-11f0-87e9-0224a6c84d84",150,["D",1758585865890],"export default function mailcheckApp() {\n const inst = {\n // Groq key UI (kept for future LLM-based checks)\n hasServerKey: true,\n userApiKey: '',\n apiKeyInput: '',\n\n // Jobs\n jobName: '',\n jobInput: '',\n jobStore: {}, // { [jobName]: { items: Record[], meta: {...}, updated_at } }\n jobsArray: [],\n\n // Ingest/UI state\n systemPrompt: '',\n pasteInput: '',\n sourceFileName: '',\n sourceKind: '', // 'csv' | 'json' | 'text'\n sourceHeaders: [], // headers from CSV/JSON when applicable\n items: [], // array of row objects, each includes detected email and bg fields\n emailFieldName: '',\n detectedEmailCount: 0,\n\n // Allowlist/Blocklist rules UI (emails or domains or regex), persisted in localStorage\n allowlistText: '',\n blocklistText: '',\n\n // Single email spot-check\n singleEmailInput: '',\n singleChecking: false,\n singleResult: null,\n\n // Run state\n isRunning: false,\n cancelRequested: false,\n concurrency: 8,\n\n // Background job runners keyed by job name. Each runner manages its own queue/state.\n jobRunners: {},\n // Interval used to reflect active job runner state in the UI\n _activeRunnerInterval: null,\n // Map of jobName -> boolean running flag for sidebar indicators\n jobRunningMap: {},\n // Map of jobName -> last completion timestamp for \"done\" flash\n jobDoneAt: {},\n // Duration to show the done flash (ms)\n jobDoneFlashMs: 3500,\n\n // Sidebar/UI\n sidebarOpen: false,\n sidebarCollapsed: false,\n sidebarTransitioning: false,\n sidebarAnimMs: 300,\n\n async init() {\n // API key from localStorage\n try {\n const storedApiKey = localStorage.getItem('groq_api_key');\n if (storedApiKey) this.userApiKey = storedApiKey;\n } catch (_) {}\n await this.checkServerKey();\n\n // Load job name + jobs\n try {\n const storedJob = localStorage.getItem('mailcheck_job_name');\n if (storedJob) { this.jobName = storedJob; this.jobInput = storedJob; }\n } catch (_) {}\n try { this.loadJobsFromStorage(); this.refreshJobsArray(); } catch (_) {}\n // If active job exists, hydrate\n if (this.jobName && this.jobStore[this.jobName]) {\n this.hydrateFromJob(this.jobStore[this.jobName]);\n }\n // Load allowlist/blocklist from storage with UI-provided examples\n try {\n const wl = localStorage.getItem('mailcheck_allowlist_v1');\n this.allowlistText = (wl && wl.trim()) ? wl : '@groq.com';\n } catch (_) { this.allowlistText = '@groq.com'; }\n try {\n const bl = localStorage.getItem('mailcheck_blocklist_v1');\n this.blocklistText = (bl && bl.trim()) ? bl : '/^[a-z]{2,}[0-9]{1,4}@/i\\n@temp-mail.com\\n*@noidem';\n } catch (_) { this.blocklistText = '/^[a-z]{2,}[0-9]{1,4}@/i\\n@temp-mail.com\\n*@noidem'; }\n try { this._refreshJobRunningMap(); } catch (_) {}\n try { this._watchActiveRunner(); } catch (_) {}\n },\n\n async checkServerKey() {\n try {\n const r = await fetch('/api/check-key');\n const j = await r.json();\n this.hasServerKey = !!j.hasServerKey;\n } catch (_) { this.hasServerKey = false; }\n },\n\n setApiKey() {\n if (this.apiKeyInput && this.apiKeyInput.trim()) {\n this.userApiKey = this.apiKeyInput.trim();\n try { localStorage.setItem('groq_api_key', this.userApiKey); } catch (_) {}\n this.apiKeyInput = '';\n }\n },\n changeApiKey() { this.userApiKey = ''; },\n clearApiKey() { this.userApiKey = ''; try { localStorage.removeItem('groq_api_key'); } catch (_) {} },\n get maskedApiKey() {\n if (!this.userApiKey) return '';\n const k = this.userApiKey;\n return k.substring(0, 8) + '*'.repeat(Math.max(0, k.length - 12)) + k.substring(k.length - 4);\n },\n\n // Jobs\n loadJobsFromStorage() {\n try {\n const raw = localStorage.getItem('mailcheck_jobs_v1');\n this.jobStore = raw ? JSON.parse(raw) : {};\n } catch (_) { this.jobStore = {}; }\n },\n saveJobsToStorage() {\n try { localStorage.setItem('mailcheck_jobs_v1', JSON.stringify(this.jobStore)); } catch (_) {}\n this.refreshJobsArray();\n },\n saveActiveJob() {\n try {\n const name = (this.jobName || '').trim();\n if (!name) return;\n const existed = this.jobStore ? this.jobStore[name] : null;\n const payload = {\n job: name,\n items: Array.isArray(this.items) ? this.items : [],\n meta: {\n systemPrompt: this.systemPrompt || '',\n sourceKind: this.sourceKind || '',\n sourceHeaders: Array.isArray(this.sourceHeaders) ? this.sourceHeaders : [],\n emailFieldName: this.emailFieldName || '',\n sourceFileName: this.sourceFileName || ''\n },\n created_at: existed && existed.created_at ? existed.created_at : new Date().toISOString(),\n updated_at: new Date().toISOString()\n };\n this.jobStore[name] = payload;\n this.saveJobsToStorage();\n // Persist lists for the app\n try { localStorage.setItem('mailcheck_allowlist_v1', this.allowlistText || ''); } catch (_) {}\n try { localStorage.setItem('mailcheck_blocklist_v1', this.blocklistText || ''); } catch (_) {}\n } catch (_) {}\n },\n hydrateFromJob(jobPayload) {\n try {\n const p = jobPayload || {};\n this.items = Array.isArray(p.items) ? p.items : [];\n const m = p.meta || {};\n this.systemPrompt = m.systemPrompt || '';\n this.sourceKind = m.sourceKind || '';\n this.sourceHeaders = Array.isArray(m.sourceHeaders) ? m.sourceHeaders : [];\n this.emailFieldName = m.emailFieldName || '';\n this.sourceFileName = m.sourceFileName || '';\n // recompute detected count\n this.detectedEmailCount = (this.items || []).reduce((acc, it) => acc + (this.getRecordEmail(it) ? 1 : 0), 0);\n } catch (_) {}\n },\n refreshJobsArray() {\n try {\n const arr = Object.entries(this.jobStore || {}).map(([name, payload]) => {\n const items = Array.isArray(payload?.items) ? payload.items : [];\n const done = items.filter((it) => !!(it && (it.bg_status === 'person_high' || it.bg_status === 'person_low' || it.bg_status === 'person_none' || it.bg_status === 'spam' || it.bg_status === 'error'))).length;\n return { name, answersCount: done, created_at: payload?.created_at || payload?.updated_at || null };\n });\n arr.sort((a, b) => {\n const ta = a.created_at ? Date.parse(a.created_at) : 0;\n const tb = b.created_at ? Date.parse(b.created_at) : 0;\n if (ta !== tb) return ta - tb; // stable by creation time\n return a.name.localeCompare(b.name);\n });\n this.jobsArray = arr;\n } catch (_) { this.jobsArray = []; }\n },\n nextDefaultJobName() {\n try {\n const keys = Object.keys(this.jobStore || {});\n let maxN = 0;\n for (const k of keys) {\n const m = /^job-(\\d+)$/.exec(k);\n if (m) {\n const n = parseInt(m[1], 10);\n if (!Number.isNaN(n) && n > maxN) maxN = n;\n }\n }\n return `job-${maxN + 1}`;\n } catch (_) {\n return 'job-1';\n }\n },\n setJobName() {\n const newName = (this.jobInput || '').trim();\n const oldName = this.jobName || '';\n if (!newName) return;\n if (oldName && newName !== oldName) {\n try {\n const existed = this.jobStore && this.jobStore[oldName];\n if (existed) {\n const migrated = { ...existed, job: newName, updated_at: new Date().toISOString() };\n this.jobStore[newName] = migrated;\n try { delete this.jobStore[oldName]; } catch (_) {}\n this.saveJobsToStorage();\n }\n } catch (_) {}\n }\n this.jobName = newName;\n try { localStorage.setItem('mailcheck_job_name', this.jobName || ''); } catch (_) {}\n try { this.saveActiveJob(); } catch (_) {}\n },\n selectJob(name) {\n try { this.saveActiveJob(); } catch (_) {}\n const j = this.jobStore && this.jobStore[name];\n if (!j) return;\n this.jobName = name;\n this.jobInput = name;\n try { localStorage.setItem('mailcheck_job_name', name); } catch (_) {}\n this.hydrateFromJob(j);\n try { this.saveActiveJob(); } catch (_) {}\n // Reflect background runner state for the newly selected job\n try {\n const s = this.getBackgroundRunStatus(this.jobName);\n this.isRunning = !!(s && s.running);\n this._watchActiveRunner();\n } catch (_) {}\n },\n createNewJob() {\n try { this.saveActiveJob(); } catch (_) {}\n const defaultName = this.nextDefaultJobName();\n this.jobName = defaultName;\n this.jobInput = defaultName;\n this.items = [];\n this.sourceHeaders = [];\n this.sourceKind = '';\n this.emailFieldName = '';\n this.detectedEmailCount = 0;\n try { this.saveActiveJob(); } catch (_) {}\n try { localStorage.setItem('mailcheck_job_name', defaultName); } catch (_) {}\n },\n deleteJob(name) {\n try {\n if (!name) return;\n if (this.jobStore && this.jobStore[name]) {\n delete this.jobStore[name];\n this.saveJobsToStorage();\n }\n if (this.jobName === name) {\n this.jobName = '';\n this.jobInput = '';\n this.items = [];\n this.sourceHeaders = [];\n this.sourceKind = '';\n this.emailFieldName = '';\n this.detectedEmailCount = 0;\n try { localStorage.removeItem('mailcheck_job_name'); } catch (_) {}\n }\n } catch (_) {}\n },\n\n // Sidebar helpers\n toggleSidebar() { this.sidebarOpen = !this.sidebarOpen; },\n collapseSidebar() { this.sidebarTransitioning = true; this.sidebarCollapsed = true; setTimeout(() => { this.sidebarTransitioning = false; }, this.sidebarAnimMs); },\n expandSidebar() { this.sidebarTransitioning = true; this.sidebarCollapsed = false; setTimeout(() => { this.sidebarTransitioning = false; }, this.sidebarAnimMs); },\n\n // Mark job as done just now (for UI flash)\n markJobDone(name) { try { if (!name) return; this.jobDoneAt[name] = Date.now(); } catch (_) {} },\n // Whether job recently completed (and not currently running)\n isJobDoneRecently(name) {\n try {\n if (!name) return false;\n if (this.isJobRunning(name)) return false;\n const ts = this.jobDoneAt && this.jobDoneAt[name];\n if (!ts) return false;\n return (Date.now() - ts) < (this.jobDoneFlashMs || 3000);\n } catch (_) { return false; }\n },\n // Refresh running map and, if fully idle, mark as done\n finishCheckForJob(name) {\n try { this._refreshJobRunningMap(); if (!this._computeJobIsRunning(name)) this.markJobDone(name); } catch (_) {}\n },\n\n // --- Multi-job Background Runners ---\n // Start a background run for a specific job name. Creates an isolated runner that\n // continues even if the UI switches to another job. Safe for multiple jobs in parallel.\n startBackgroundRunForJob(jobName, options = {}) {\n try {\n const name = String(jobName || '').trim();\n if (!name) return null;\n if (this.jobRunners[name] && this.jobRunners[name].status().running) {\n return this.jobRunners[name];\n }\n const runner = createJobRunner(this, name, {\n concurrency: Math.max(1, Number(options.concurrency || this.concurrency) || 8),\n onlyPending: options.onlyPending !== false\n });\n this.jobRunners[name] = runner;\n runner.start();\n try { this.jobRunningMap[name] = true; this._refreshJobRunningMap(); this._watchActiveRunner(); } catch (_) {}\n return runner;\n } catch (_) { return null; }\n },\n\n // Cancel a background run for a job, if one is active.\n cancelBackgroundRunForJob(jobName) {\n try {\n const r = this.jobRunners && this.jobRunners[jobName];\n if (r) r.cancel();\n try { this.jobRunningMap[jobName] = false; this._refreshJobRunningMap(); } catch (_) {}\n } catch (_) {}\n },\n\n // Shallow status snapshot for a job's runner (or a default if none).\n getBackgroundRunStatus(jobName) {\n try {\n const r = this.jobRunners && this.jobRunners[jobName];\n return r ? r.status() : { running: false, cancelled: false, total: 0, completed: 0 };\n } catch (_) { return { running: false, cancelled: false, total: 0, completed: 0 }; }\n },\n // Public helper for templates\n isJobRunning(name) {\n try { return !!this.jobRunningMap && !!this.jobRunningMap[name]; } catch (_) { return false; }\n },\n // Refresh the running map for all known jobs\n _refreshJobRunningMap() {\n try {\n const names = new Set(Object.keys(this.jobStore || {}));\n for (const n of Object.keys(this.jobRunners || {})) names.add(n);\n const next = {};\n for (const n of names) next[n] = this._computeJobIsRunning(n);\n this.jobRunningMap = next;\n } catch (_) {}\n },\n\n // Compute if a job appears to be running by either active runner state or any 'checking' items\n _computeJobIsRunning(jobName) {\n try {\n if (!jobName) return false;\n const s = this.getBackgroundRunStatus(jobName);\n if (s && s.running) return true;\n const payload = this.jobStore && this.jobStore[jobName];\n if (!payload || !Array.isArray(payload.items)) return false;\n for (const it of payload.items) { if (it && it.bg_status === 'checking') return true; }\n return false;\n } catch (_) { return false; }\n },\n\n // Parsing & ingest\n async handleFileChange(evt) {\n try {\n const file = (evt && evt.target && evt.target.files && evt.target.files[0]) ? evt.target.files[0] : null;\n if (!file) return;\n this.sourceFileName = file.name || '';\n this.ensureDefaultJobName(file.name || '(upload)');\n const text = await file.text();\n await this.parseInputText(text, file.name || 'upload');\n } catch (_) {}\n },\n async parsePaste() {\n this.ensureDefaultJobName('(pasted)');\n await this.parseInputText(this.pasteInput || '', '(pasted)', { append: true });\n this.pasteInput = '';\n },\n looksLikeJson(text) {\n const t = String(text || '').trim();\n return t.startsWith('{') || t.startsWith('[');\n },\n async parseInputText(text, filename, options = {}) {\n try {\n const trimmed = String(text || '').trim();\n if (!trimmed) {\n if (!options.append) {\n this.items = []; this.sourceHeaders = []; this.sourceKind = ''; this.emailFieldName=''; this.detectedEmailCount=0; this.saveActiveJob();\n }\n return;\n }\n\n // Always extract emails, regardless of whether it looks like JSON/CSV\n this.sourceKind = 'text'; // Explicitly set sourceKind to text\n const emails = this.extractEmailsFromText(trimmed);\n const objs = emails.map((email) => ({ email }));\n await this.ingestObjectsArray(objs, { append: !!options.append });\n\n this.saveActiveJob();\n } catch (_) {}\n },\n\n // Ensure a default job name exists before saving parsed content\n ensureDefaultJobName(sourceLabel) {\n try {\n if ((this.jobName || '').trim()) return;\n let candidate = this.nextDefaultJobName();\n // Avoid duplicates (paranoia)\n let ctr = 2;\n while (this.jobStore && this.jobStore[candidate]) { candidate = `job-${parseInt(candidate.split('-')[1] || '1', 10) + 1}`; ctr++; }\n this.jobName = candidate;\n this.jobInput = candidate;\n try { localStorage.setItem('mailcheck_job_name', candidate); } catch (_) {}\n try { this.saveActiveJob(); } catch (_) {}\n } catch (_) {}\n },\n\n // Inline edit helpers\n enableEdit(idx) {\n try {\n const it = this.items[idx];\n if (!it) return;\n it._editingEmail = true;\n it._editEmailValue = this.getRecordEmail(it);\n } catch (_) {}\n },\n commitEdit(idx) {\n try {\n const it = this.items[idx];\n if (!it) return;\n const val = String(it._editEmailValue || '').trim();\n const key = (this.emailFieldName && (this.emailFieldName in it)) ? this.emailFieldName : 'email';\n it[key] = val;\n it.email = val;\n // reset status so it can be re-run\n it.bg_status = 'pending';\n it.bg_message = '';\n it.bg_checked_at = null;\n // end edit\n it._editingEmail = false;\n delete it._editEmailValue;\n this.recomputeDetectedEmails();\n this.saveActiveJob();\n } catch (_) {}\n },\n cancelEdit(idx) {\n try {\n const it = this.items[idx];\n if (!it) return;\n it._editingEmail = false;\n delete it._editEmailValue;\n } catch (_) {}\n },\n deleteItem(idx) {\n try {\n if (!confirm('Delete this row?')) return;\n if (idx < 0 || idx >= (this.items?.length || 0)) return;\n this.items.splice(idx, 1);\n this.recomputeDetectedEmails();\n this.saveActiveJob();\n } catch (_) {}\n },\n recomputeDetectedEmails() {\n try {\n this.detectedEmailCount = (this.items || []).reduce((acc, it) => acc + (this.getRecordEmail(it) ? 1 : 0), 0);\n } catch (_) { this.detectedEmailCount = 0; }\n },\n parseCsv(text) {\n // Minimal CSV parser supporting quotes and commas\n const rows = [];\n let row = [];\n let i = 0, inQuotes = false, field = '';\n const pushField = () => { row.push(field); field = ''; };\n const pushRow = () => { rows.push(row); row = []; };\n while (i < text.length) {\n const ch = text[i];\n if (inQuotes) {\n if (ch === '\"') {\n if (text[i + 1] === '\"') { field += '\"'; i++; } else { inQuotes = false; }\n } else { field += ch; }\n } else {\n if (ch === '\"') { inQuotes = true; }\n else if (ch === ',') { pushField(); }\n else if (ch === '\\n') { pushField(); pushRow(); }\n else if (ch === '\\r') { /* ignore */ }\n else { field += ch; }\n }\n i++;\n }\n // last field\n pushField();\n // last row if not added\n if (row.length > 0) pushRow();\n // Trim possible trailing empty row\n while (rows.length > 0 && rows[rows.length - 1].every(v => String(v || '').trim() === '')) rows.pop();\n // Determine headers: if first row has any non-email header-like strings, assume header row; else synthesize\n let headers = [];\n if (rows.length > 0) {\n const first = rows[0].map((s) => String(s || '').trim());\n const hasAlpha = first.some((s) => /[a-zA-Z]/.test(s));\n const looksHeaderish = hasAlpha && !first.every((s) => this.isEmail(s));\n if (looksHeaderish) {\n headers = first.map((h, idx) => h || ('col_' + (idx + 1)));\n rows.shift();\n } else {\n headers = first.map((_, idx) => 'col_' + (idx + 1));\n }\n }\n return { headers, rows };\n },\n async ingestCsvParsed(headers, rows, options = {}) {\n const normalizedHeaders = headers.map(h => String(h || '').trim());\n this.sourceHeaders = normalizedHeaders;\n // Build objects per row\n const items = rows.map((r) => {\n const obj = {};\n for (let i = 0; i < normalizedHeaders.length; i++) {\n const key = normalizedHeaders[i] || ('col_' + (i + 1));\n obj[key] = r[i] !== undefined ? r[i] : '';\n }\n return obj;\n });\n await this.ingestObjectsArray(items, { append: !!options.append });\n },\n async ingestObjectsArray(objs, options = {}) {\n const items = Array.isArray(objs) ? objs.map((o) => (o && typeof o === 'object') ? { ...o } : { value: String(o) }) : [];\n // Detect email field name if not already set\n if (!this.emailFieldName) this.emailFieldName = this.detectEmailFieldName(items);\n // Normalize each row with bg fields\n const newItems = items.map((it, idx) => {\n const email = this.extractEmailFromRecord(it);\n return {\n ...it,\n email: email || it.email || it.Email || it.e_mail || it.mail || '',\n _row_index: (this.items?.length || 0) + idx,\n bg_status: 'pending',\n bg_message: '',\n bg_checked_at: null\n };\n });\n if (options.append) {\n const existing = new Set((this.items || []).map((it) => this.emailKey(this.getRecordEmail(it))));\n const filtered = newItems.filter((it) => {\n const k = this.emailKey(this.getRecordEmail(it));\n if (!k) return false;\n if (existing.has(k)) return false;\n existing.add(k);\n return true;\n });\n this.items = [...(this.items || []), ...filtered];\n } else {\n this.items = newItems;\n }\n this.recomputeDetectedEmails();\n },\n emailKey(s) { return String(s || '').trim().toLowerCase(); },\n detectEmailFieldName(items) {\n // 1) Prefer property names that include 'email'\n const candidateNames = new Set();\n for (const it of (items || [])) {\n for (const k of Object.keys(it || {})) {\n const lower = k.toLowerCase();\n if (lower.includes('email')) candidateNames.add(k);\n }\n }\n if (candidateNames.size > 0) {\n // Choose the one with most valid-looking values\n let best = '', bestCount = -1;\n for (const k of candidateNames) {\n let count = 0;\n for (const it of (items || [])) { if (this.isEmail(String(it[k] || ''))) count++; }\n if (count > bestCount) { best = k; bestCount = count; }\n }\n if (best) return best;\n }\n // 2) Otherwise, scan all fields and pick the field with the most email-like values\n const counts = {};\n for (const it of (items || [])) {\n for (const [k, v] of Object.entries(it || {})) {\n if (this.isEmail(String(v || ''))) counts[k] = (counts[k] || 0) + 1;\n }\n }\n let maxK = '';\n let maxV = -1;\n for (const [k, v] of Object.entries(counts)) { if (v > maxV) { maxK = k; maxV = v; } }\n return maxV > 0 ? maxK : 'email';\n },\n isEmail(s) {\n const str = String(s || '').trim();\n if (!str) return false;\n // Simple, permissive email regex\n return /^[^\\s@]+@[^\\s@]+\\.[^\\s@]{2,}$/.test(str);\n },\n extractEmailsFromText(text) {\n try {\n const src = String(text || '');\n const matches = src.match(/[A-Z0-9._%+-]+@[A-Z0-9.-]+\\.[A-Z]{2,}/gi) || [];\n const seen = new Set();\n const out = [];\n for (let m of matches) {\n let e = String(m || '').trim();\n e = e.replace(/^[<({\\[\"']+/, '');\n e = e.replace(/[>)}\\]\"',.;:!?]+$/, '');\n e = e.toLowerCase();\n if (this.isEmail(e)) {\n const k = this.emailKey(e);\n if (!seen.has(k)) { seen.add(k); out.push(e); }\n }\n }\n return out;\n } catch (_) { return []; }\n },\n extractEmailFromRecord(it) {\n if (!it || typeof it !== 'object') return '';\n // 1) Direct by detected field name\n if (this.emailFieldName && it[this.emailFieldName]) return String(it[this.emailFieldName] || '').trim();\n // 2) Common keys\n for (const k of ['email', 'Email', 'e_mail', 'mail']) { if (it[k]) return String(it[k]).trim(); }\n // 3) Search values for email-looking string\n for (const v of Object.values(it)) { if (this.isEmail(v)) return String(v).trim(); }\n return '';\n },\n getRecordEmail(it) {\n return this.extractEmailFromRecord(it);\n },\n\n // Run checks with per-row updates\n async runChecks() {\n if (!Array.isArray(this.items) || this.items.length === 0) return;\n // Kick off a background run for the active job (include all rows)\n this.cancelRequested = false;\n this.startBackgroundRunForJob(this.jobName, { concurrency: this.concurrency, onlyPending: false });\n this.isRunning = true;\n this._watchActiveRunner();\n },\n async runPendingChecks() {\n if (!Array.isArray(this.items) || this.items.length === 0) return;\n // Kick off a background run for the active job (pending only)\n this.cancelRequested = false;\n this.startBackgroundRunForJob(this.jobName, { concurrency: this.concurrency, onlyPending: true });\n this.isRunning = true;\n this._watchActiveRunner();\n },\n // Individual row run for active job delegates to generic per-job API\n async runOne(idx) { return await this.runOneForJob(this.jobName, idx); },\n // Run one record by job name and row index (works even if a background run is active)\n async runOneForJob(jobName, idx) {\n try {\n const payload = this.jobStore && this.jobStore[jobName];\n if (!payload) return;\n const items = Array.isArray(payload.items) ? payload.items : [];\n if (idx < 0 || idx >= items.length) return;\n const rec = items[idx];\n if (!rec) return;\n if (rec.bg_status === 'checking') return; // already in flight\n const email = this.getRecordEmail ? this.getRecordEmail(rec) : (rec.email || '');\n // Clear previous per-check transient fields (fully reset assessment UI)\n delete rec.bg_compound_msg; delete rec.bg_compound_debug; delete rec.bg_browser_debug;\n delete rec.bg_compound_label; delete rec.bg_compound_short; delete rec.bg_compound_detail;\n delete rec.bg_browser_label; delete rec.bg_browser_short; delete rec.bg_browser_detail;\n delete rec.bg_final_label; delete rec.bg_final_short; delete rec.bg_final_detail;\n delete rec.bg_compound_evidence; delete rec.bg_browser_evidence; delete rec.bg_final_evidence;\n if (!email || !(this.isEmail && this.isEmail(email))) {\n rec.bg_status = 'error';\n rec.bg_message = 'No email detected';\n rec.bg_checked_at = new Date().toISOString();\n payload.items[idx] = rec; payload.updated_at = new Date().toISOString();\n this.jobStore[jobName] = payload; this.saveJobsToStorage(); this.refreshJobsArray();\n if (this.jobName === jobName) { this.items[idx] = { ...this.items[idx], ...rec }; this.recomputeDetectedEmails(); }\n return;\n }\n if (!this.hasServerKey && !this.userApiKey) throw new Error('No Groq API key set. Add a key to run checks.');\n // Mark as checking and persist before network call to avoid duplicate work by runners\n delete rec.bg_assessments; rec.bg_status = 'checking'; rec.bg_message = ''; rec.bg_checked_at = null;\n payload.items[idx] = rec; payload.updated_at = new Date().toISOString();\n this.jobStore[jobName] = payload; this.saveJobsToStorage(); this.refreshJobsArray();\n if (this.jobName === jobName) { this.items[idx] = { ...this.items[idx], ...rec }; this.recomputeDetectedEmails(); }\n // Perform the check\n const systemPrompt = payload?.meta?.systemPrompt || '';\n const result = await this.callBackgroundCheckApi(email, systemPrompt);\n rec.bg_status = result?.status || 'person_low';\n rec.bg_message = result?.message || '';\n if (result && result.fields && typeof result.fields === 'object') {\n for (const [k, v] of Object.entries(result.fields)) rec[k] = v;\n }\n rec.bg_checked_at = new Date().toISOString();\n payload.items[idx] = rec; payload.updated_at = new Date().toISOString();\n this.jobStore[jobName] = payload; this.saveJobsToStorage(); this.refreshJobsArray();\n if (this.jobName === jobName) { this.items[idx] = { ...this.items[idx], ...rec }; this.recomputeDetectedEmails(); }\n this.finishCheckForJob(jobName);\n } catch (e) {\n // Best-effort error capture to the active job if applicable\n try {\n const payload = this.jobStore && this.jobStore[jobName];\n if (!payload) return;\n const items = Array.isArray(payload.items) ? payload.items : [];\n if (idx < 0 || idx >= items.length) return;\n const rec = items[idx]; if (!rec) return;\n rec.bg_status = 'error';\n rec.bg_message = (e && e.message) ? e.message : 'Error';\n rec.bg_checked_at = new Date().toISOString();\n payload.items[idx] = rec; payload.updated_at = new Date().toISOString();\n this.jobStore[jobName] = payload; this.saveJobsToStorage(); this.refreshJobsArray();\n if (this.jobName === jobName) { this.items[idx] = { ...this.items[idx], ...rec }; this.recomputeDetectedEmails(); }\n this.finishCheckForJob(jobName);\n } catch (_) {}\n }\n },\n async runOne(idx) {\n try {\n if (idx < 0 || idx >= (this.items?.length || 0)) return;\n const rec = this.items[idx];\n if (!rec) return;\n if (!this.getRecordEmail(rec)) {\n rec.bg_status = 'error';\n rec.bg_message = 'No email detected';\n rec.bg_checked_at = new Date().toISOString();\n this.saveActiveJob();\n return;\n }\n // Clear prior assessment fields for this row (fully reset)\n delete rec.bg_compound_msg;\n delete rec.bg_compound_debug;\n delete rec.bg_browser_debug;\n delete rec.bg_compound_label;\n delete rec.bg_compound_short;\n delete rec.bg_compound_detail;\n delete rec.bg_browser_label;\n delete rec.bg_browser_short;\n delete rec.bg_browser_detail;\n delete rec.bg_final_label;\n delete rec.bg_final_short;\n delete rec.bg_final_detail;\n delete rec.bg_compound_evidence;\n delete rec.bg_browser_evidence;\n delete rec.bg_final_evidence;\n delete rec.bg_assessments; rec.bg_status = 'checking';\n rec.bg_message = '';\n this.saveActiveJob();\n // Ensure sidebar reflects running state for per-row checks\n try { this._refreshJobRunningMap(); this._watchActiveRunner(); } catch (_) {}\n if (!this.hasServerKey && !this.userApiKey) throw new Error('No Groq API key set. Add a key to run checks.');\n const email = this.getRecordEmail(rec);\n const result = await this.callBackgroundCheckApi(email, this.systemPrompt);\n rec.bg_status = result?.status || 'person_low';\n rec.bg_message = result?.message || '';\n if (result && result.fields && typeof result.fields === 'object') {\n for (const [k, v] of Object.entries(result.fields)) rec[k] = v;\n }\n rec.bg_checked_at = new Date().toISOString();\n } catch (e) {\n const rec = this.items[idx];\n if (rec) {\n rec.bg_status = 'error';\n rec.bg_message = (e && e.message) ? e.message : 'Error';\n rec.bg_checked_at = new Date().toISOString();\n }\n } finally {\n this.saveActiveJob();\n try { this.finishCheckForJob(this.jobName); } catch (_) {}\n }\n },\n cancelRun() {\n this.cancelRequested = true;\n try { if (this.jobName) this.cancelBackgroundRunForJob(this.jobName); } catch (_) {}\n // isRunning will flip false when the runner loop drains; also stop UI watcher\n try { if (this._activeRunnerInterval) { clearInterval(this._activeRunnerInterval); this._activeRunnerInterval = null; } } catch (_) {}\n },\n async runSingleCheck() {\n try {\n const raw = String(this.singleEmailInput || '').trim();\n let email = '';\n if (this.isEmail(raw)) {\n email = raw;\n } else {\n const found = this.extractEmailsFromText(raw);\n email = (found && found.length > 0) ? found[0] : '';\n }\n if (!email) return;\n if (!this.hasServerKey && !this.userApiKey) throw new Error('No Groq API key set. Add a key to run checks.');\n this.singleChecking = true;\n this.singleResult = null;\n // Ensure we have an active job to reflect sidebar state\n this.ensureDefaultJobName('(single)');\n // clear UI debug leftovers and transient fields\n for (const it of (this.items || [])) {\n delete it.bg_compound_debug;\n delete it.bg_browser_debug;\n }\n // Pre-mark target record as checking so sidebar shows spinner\n const key = this.emailKey(email);\n let idx = -1;\n for (let i = 0; i < (this.items?.length || 0); i++) {\n const k = this.emailKey(this.getRecordEmail(this.items[i]));\n if (k && k === key) { idx = i; break; }\n }\n if (idx >= 0) {\n const rec = this.items[idx];\n delete rec.bg_compound_msg;\n delete rec.bg_compound_label;\n delete rec.bg_compound_short;\n delete rec.bg_compound_detail;\n delete rec.bg_browser_label;\n delete rec.bg_browser_short;\n delete rec.bg_browser_detail;\n delete rec.bg_final_label;\n delete rec.bg_final_short;\n delete rec.bg_final_detail;\n delete rec.bg_compound_evidence;\n delete rec.bg_browser_evidence;\n delete rec.bg_final_evidence;\n delete rec.bg_assessments; rec.bg_status = 'checking';\n rec.bg_message = '';\n rec.bg_checked_at = null;\n this.items[idx] = rec;\n } else {\n const rec = {\n email,\n _row_index: (this.items?.length || 0),\n bg_status: 'checking',\n bg_message: '',\n bg_checked_at: null\n };\n this.items = [...(this.items || []), rec];\n this.recomputeDetectedEmails();\n idx = this.items.length - 1;\n }\n this.saveActiveJob();\n try { this._refreshJobRunningMap(); this._watchActiveRunner(); } catch (_) {}\n\n // Perform the check\n const result = await this.callBackgroundCheckApi(email, this.systemPrompt);\n this.singleResult = result;\n\n // Update the record with results\n const rec2 = this.items[idx] || { email, _row_index: idx };\n rec2.bg_status = result?.status || 'person_low';\n rec2.bg_message = result?.message || '';\n if (result && result.fields && typeof result.fields === 'object') {\n for (const [k, v] of Object.entries(result.fields)) rec2[k] = v;\n }\n rec2.bg_checked_at = new Date().toISOString();\n this.items[idx] = rec2;\n this.saveActiveJob();\n try { this._refreshJobRunningMap(); } catch (_) {}\n } catch (e) {\n this.singleResult = { email: this.singleEmailInput, status: 'error', message: (e && e.message) ? e.message : 'Error', fields: {} };\n } finally {\n this.singleChecking = false;\n try { this.finishCheckForJob(this.jobName); } catch (_) {}\n // Re-focus the single input for quick subsequent checks\n try { const el = document.querySelector('input[x-ref=\"singleEmailInputRef\"]'); if (el) el.focus(); } catch (_) {}\n }\n },\n // Background check orchestrator — sequentially runs an array of checker functions\n async backgroundCheck(email, prompt) {\n const checkers = this.buildCheckers(prompt);\n const messages = [];\n let status = undefined;\n const fields = {};\n for (const checker of checkers) {\n try {\n // Each checker may be sync or async\n // Shape: { status?, message?, fields? }\n const res = await checker(email);\n if (!res) continue;\n if (res.message) messages.push(String(res.message));\n if (res.fields && typeof res.fields === 'object') Object.assign(fields, res.fields);\n if (res.status) status = this.mergeStatus(status, res.status);\n } catch (_) { /* ignore individual checker errors */ }\n }\n // Fallback classification if still unset\n if (!status) {\n const fb = await this.heuristicFallbackChecker(email);\n status = fb.status;\n if (fb.message) messages.push(fb.message);\n }\n return { status, message: messages.join('; ') || this.statusToMessage(status), fields };\n },\n\n async callBackgroundCheckApi(email, systemPrompt) {\n const resp = await fetch('/api/check/background', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ email, systemPrompt: systemPrompt || '', userApiKey: this.userApiKey || undefined, allowlist: this.parseListText(this.allowlistText), blocklist: this.parseListText(this.blocklistText) })\n });\n if (!resp.ok) throw new Error(await resp.text().catch(() => resp.statusText));\n return await resp.json();\n },\n\n parseListText(text) {\n try {\n // Only split on newlines; commas are valid inside regex quantifiers (e.g., {2,4})\n const src = String(text || '').replace(/[\\r\\n]+/g, '\\n');\n const lines = src.split('\\n').map(s => String(s || '').trim()).filter(Boolean);\n const seen = new Set();\n const out = [];\n for (const s of lines) { const key = s.startsWith('/') ? s : s.toLowerCase(); if (!seen.has(key)) { seen.add(key); out.push(s); } }\n return out;\n } catch (_) { return []; }\n },\n\n // Compose the list of checkers to run in order\n buildCheckers(prompt) {\n return [\n // 1) Basic syntax validation\n async (email) => {\n if (!this.isEmail(email)) return { status: 'undeliverable', message: 'Invalid email format' };\n return { status: undefined };\n },\n // 2) Academic domain check (server-assisted)\n async (email) => {\n try {\n const info = await this.checkAcademic(email);\n if (!info) return null;\n const fields = { bg_academic: !!info.isAcademic };\n if (info.institution) fields.bg_institution = info.institution;\n // Academic domains are not penalized; annotate message only\n if (info.isAcademic) {\n const short = info.institution ? String(info.institution) : 'Academic domain';\n fields.bg_academic_msg = short;\n return { message: short, fields };\n }\n return { fields };\n } catch (_) {\n return null;\n }\n },\n // 2b) LLM legitimacy check (optional; annotate + potential status nudge)\n async (email) => {\n try {\n if (!this.userApiKey && !this.hasServerKey) return null;\n const data = await this.callLlmEmailCheck(email, prompt);\n if (!data) return null;\n const out = { fields: data.fields || {}, message: data.message || '' };\n if (data.status && (data.status === 'person_high' || data.status === 'person_low' || data.status === 'person_none' || data.status === 'spam')) {\n out.status = data.status;\n }\n if (out.message) out.fields.bg_compound_msg = out.message;\n return out;\n } catch (_) { return null; }\n },\n // 3) Role/alias heuristic (flag as suspicious)\n async (email) => {\n try {\n const local = String(email || '').split('@')[0].toLowerCase();\n const roleList = ['info', 'support', 'admin', 'sales', 'contact', 'hello', 'team', 'marketing', 'noreply', 'no-reply'];\n if (roleList.includes(local)) return { status: 'person_none', message: 'Role-based address' };\n return null;\n } catch (_) { return null; }\n }\n ];\n },\n\n async callLlmEmailCheck(email, systemPrompt) {\n try {\n const resp = await fetch('/api/check/llm-email', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ email, systemPrompt: systemPrompt || '', userApiKey: this.userApiKey || undefined })\n });\n if (!resp.ok) return null;\n return await resp.json();\n } catch (_) { return null; }\n },\n\n async heuristicFallbackChecker(email) {\n // Default to person_low when heuristic needed; avoid penalizing good emails\n await new Promise((res) => setTimeout(res, 120 + Math.floor(Math.random() * 300)));\n return { status: 'person_low', message: '' };\n },\n\n async checkAcademic(email) {\n try {\n const resp = await fetch('/api/check/academic', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ email })\n });\n if (!resp.ok) return null;\n const data = await resp.json();\n return { isAcademic: !!data?.isAcademic, institution: data?.institution || null };\n } catch (_) { return null; }\n },\n\n mergeStatus(current, next) {\n if (!next) return current || undefined;\n if (!current) return next;\n const score = (s) => (s === 'spam' ? 4 : s === 'person_none' ? 3 : s === 'person_low' ? 2 : s === 'person_high' ? 1 : 0);\n return score(next) >= score(current) ? next : current;\n },\n\n // Display label for statuses (new person confidence scale + legacy)\n statusLabel(status) {\n if (status === 'academic') return 'academic';\n if (status === 'whitelist') return 'allowlist';\n if (status === 'person_high') return 'likely real person';\n if (status === 'person_low') return 'possible person';\n if (status === 'person_none') return 'no evidence';\n if (status === 'spam') return 'spam';\n if (status === 'person_high') return 'likely real person';\n if (status === 'person_low') return 'possible person';\n if (status === 'person_none') return 'no evidence';\n if (status === 'spam') return 'spam';\n if (status === 'checking') return 'checking';\n if (status === 'error') return 'error';\n return String(status || '');\n },\n statusToMessage(status) {\n if (status === 'person_high') return 'Likely real person';\n if (status === 'person_low') return 'Possible person';\n if (status === 'person_none') return 'No public identity evidence';\n if (status === 'spam') return 'Spam or invalid';\n if (status === 'deliverable') return 'Looks good: deliverable address';\n if (status === 'suspicious') return 'Risky patterns: disposable/role-based or malformed parts';\n if (status === 'undeliverable') return 'Likely bounce or spamtrap';\n if (status === 'checking') return 'Checking...';\n if (status === 'error') return 'Error checking email';\n return String(status || '');\n },\n\n // Downloads\n downloadCsv() {\n try {\n const { headers, rows } = this.buildOutputTable();\n const escapeCsv = (v) => {\n const s = (v === null || v === undefined) ? '' : String(v);\n if (/[\",\\n]/.test(s)) return '\"' + s.replace(/\"/g, '\"\"') + '\"';\n return s;\n };\n const out = [headers.map(escapeCsv).join(',')];\n for (const r of rows) out.push(r.map(escapeCsv).join(','));\n const csv = out.join('\\n');\n const blob = new Blob([csv], { type: 'text/csv;charset=utf-8' });\n const url = URL.createObjectURL(blob);\n const a = document.createElement('a');\n a.href = url; a.download = (this.jobName ? (this.jobName + '_') : '') + 'mailcheck.csv';\n document.body.appendChild(a); a.click(); a.remove();\n URL.revokeObjectURL(url);\n } catch (_) {}\n },\n downloadJson() {\n try {\n const arr = this.buildOutputObjects();\n const blob = new Blob([JSON.stringify(arr, null, 2)], { type: 'application/json' });\n const url = URL.createObjectURL(blob);\n const a = document.createElement('a');\n a.href = url; a.download = (this.jobName ? (this.jobName + '_') : '') + 'mailcheck.json';\n document.body.appendChild(a); a.click(); a.remove();\n URL.revokeObjectURL(url);\n } catch (_) {}\n },\n async copyJson() {\n try { await navigator.clipboard.writeText(JSON.stringify(this.buildOutputObjects(), null, 2)); } catch (_) {}\n },\n buildOutputObjects() {\n // Preserve original fields, plus bg_status and bg_message\n const out = [];\n for (const it of (this.items || [])) {\n const obj = { ...it };\n // Keep explicit fields\n obj.bg_status = it.bg_status || 'pending';\n obj.bg_message = it.bg_message || '';\n obj.bg_checked_at = it.bg_checked_at || null;\n // Remove internal helper fields\n delete obj._row_index;\n out.push(obj);\n }\n return out;\n },\n buildOutputTable() {\n // Construct headers from input headers or dynamic keys\n const rows = [];\n const keysSet = new Set();\n if (Array.isArray(this.sourceHeaders) && this.sourceHeaders.length > 0) {\n for (const h of this.sourceHeaders) keysSet.add(h);\n } else {\n for (const it of (this.items || [])) {\n for (const k of Object.keys(it || {})) {\n if (k === '_row_index' || k === '_editingEmail' || k === '_editEmailValue') continue;\n keysSet.add(k);\n }\n }\n }\n // Ensure email field present\n if (this.emailFieldName && !keysSet.has(this.emailFieldName)) keysSet.add(this.emailFieldName);\n // Add bg fields at end\n const headers = Array.from(keysSet);\n for (const k of ['bg_status', 'bg_message', 'bg_checked_at']) if (!headers.includes(k)) headers.push(k);\n for (const it of (this.items || [])) {\n const row = headers.map((h) => it[h] !== undefined ? it[h] : '');\n rows.push(row);\n }\n return { headers, rows };\n },\n\n // UI helpers\n get totalCount() { return Array.isArray(this.items) ? this.items.length : 0; },\n get pendingCount() {\n let n = 0;\n for (const it of (this.items || [])) { if (it && (!it.bg_checked_at || it.bg_status === 'pending' || !it.bg_status)) n++; }\n return n;\n },\n get completedCount() {\n let n = 0;\n for (const it of (this.items || [])) {\n if (it && (it.bg_status === 'person_high' || it.bg_status === 'person_low' || it.bg_status === 'person_none' || it.bg_status === 'spam' || it.bg_status === 'not_spam' || it.bg_status === 'suspected_spam' || it.bg_status === 'likely_spam' || it.bg_status === 'academic' || it.bg_status === 'whitelist' || it.bg_status === 'error')) n++;\n }\n return n;\n },\n badgeClass(status) {\n if (status === 'person_high' || status === 'not_spam' || status === 'academic' || status === 'whitelist') return 'bg-green-100 text-green-800 border-green-200';\n if (status === 'person_low' || status === 'suspected_spam') return 'bg-amber-100 text-amber-800 border-amber-200';\n if (status === 'person_none') return 'bg-gray-100 text-gray-800 border-gray-300';\n if (status === 'spam' || status === 'likely_spam' || status === 'error') return 'bg-red-100 text-red-800 border-red-200';\n if (status === 'checking') return 'bg-blue-100 text-blue-800 border-blue-200';\n return 'bg-gray-100 text-gray-800 border-gray-200';\n },\n\n // Generalized assessment text formatting\n formatAssessmentsText(record) {\n try {\n const fields = record || {};\n const assessments = Array.isArray(fields.bg_assessments) ? fields.bg_assessments : [];\n return this._formatAssessmentsTextCore(fields, assessments);\n } catch (_) { return ''; }\n },\n formatAssessmentsTextFromResult(result) {\n try {\n if (!result) return '';\n const fields = { ...(result.fields || {}) };\n if (result.status && !fields.bg_status) fields.bg_status = result.status;\n if (result.message && !fields.bg_message) fields.bg_message = result.message;\n const assessments = Array.isArray(result.assessments) ? result.assessments : (Array.isArray(fields.bg_assessments) ? fields.bg_assessments : []);\n return this._formatAssessmentsTextCore(fields, assessments);\n } catch (_) { return ''; }\n },\n _formatAssessmentsTextCore(fields, assessments) {\n try {\n const lines = [];\n const prettyName = (n) => ({ final_judge: 'final', compound: 'llm', browser: 'browser', academic: 'academic', allowlist: 'allowlist', blocklist: 'blocklist' }[String(n || '')] || String(n || ''));\n const byName = {};\n for (const a of (assessments || [])) { if (a && a.name && !byName[a.name]) byName[a.name] = a; }\n // If some assessors ran but didn't add to bg_assessments, infer lightweight entries from fields/messages\n // final\n if (!byName.final_judge && (fields.bg_final_short || fields.bg_final_label || fields.bg_final_detail)) {\n byName.final_judge = { name: 'final_judge', status: fields.bg_status || null, message: fields.bg_final_short || fields.bg_final_label || null };\n }\n // browser\n if (!byName.browser && (fields.bg_browser_short || fields.bg_browser_label || fields.bg_browser_detail)) {\n byName.browser = { name: 'browser', status: null, message: fields.bg_browser_short || fields.bg_browser_label || null };\n }\n // compound\n if (!byName.compound && (fields.bg_compound_short || fields.bg_compound_label || fields.bg_compound_detail)) {\n byName.compound = { name: 'compound', status: null, message: fields.bg_compound_short || fields.bg_compound_label || null };\n }\n // academic\n if (!byName.academic && (fields.bg_academic || fields.bg_institution || fields.bg_academic_msg)) {\n byName.academic = { name: 'academic', status: fields.bg_academic ? 'academic' : null, message: fields.bg_academic_msg || (fields.bg_institution ? ('Academic institution: ' + fields.bg_institution) : null) };\n }\n // allowlist/blocklist\n if (!byName.allowlist && (fields.bg_allowlist_rule || fields.bg_allowlist_msg)) {\n byName.allowlist = { name: 'allowlist', status: 'whitelist', message: fields.bg_allowlist_msg || (fields.bg_allowlist_rule ? ('matched ' + fields.bg_allowlist_rule) : null) };\n }\n if (!byName.blocklist && (fields.bg_blocklist_rule || fields.bg_blocklist_msg)) {\n byName.blocklist = { name: 'blocklist', status: 'spam', message: fields.bg_blocklist_msg || (fields.bg_blocklist_rule ? ('matched ' + fields.bg_blocklist_rule) : null) };\n }\n const pushBlock = (name, header, detail, evidence) => {\n const title = prettyName(name);\n const headerLine = (title + ': ' + String(header || '').trim()).trim();\n lines.push(headerLine);\n if (detail && String(detail).trim()) lines.push(String(detail).trim());\n if (Array.isArray(evidence) && evidence.length > 0) {\n for (const e of evidence.slice(0, 5)) { const s = String(e || '').trim(); if (s) lines.push('- ' + s); }\n }\n lines.push('');\n };\n // Quick scan one-liners from API (if provided)\n const scanLines = Array.isArray(fields.bg_assessor_lines) ? fields.bg_assessor_lines : [];\n if (scanLines.length > 0) {\n for (const s of scanLines) { const t = String(s || '').trim(); if (t) lines.push(t); }\n lines.push('');\n }\n // Ordered known assessments first\n const order = ['final_judge', 'browser', 'compound', 'academic', 'allowlist', 'blocklist'];\n const seen = new Set();\n const getLabel = (s) => this.statusLabel ? this.statusLabel(s) : String(s || '');\n for (const key of order) {\n if (byName[key]) {\n const a = byName[key]; seen.add(key);\n if (key === 'final_judge') {\n const header = fields.bg_final_short || a.message || fields.bg_final_label || getLabel(a.status);\n pushBlock(key, header, fields.bg_final_detail, Array.isArray(fields.bg_final_evidence) ? fields.bg_final_evidence : []);\n continue;\n }\n if (key === 'browser') {\n const header = fields.bg_browser_short || a.message || fields.bg_browser_label || getLabel(a.status);\n pushBlock(key, header, fields.bg_browser_detail, Array.isArray(fields.bg_browser_evidence) ? fields.bg_browser_evidence : []);\n continue;\n }\n if (key === 'compound') {\n const header = fields.bg_compound_short || a.message || fields.bg_compound_label || getLabel(a.status);\n pushBlock(key, header, fields.bg_compound_detail, Array.isArray(fields.bg_compound_evidence) ? fields.bg_compound_evidence : []);\n continue;\n }\n if (key === 'academic') {\n const header = fields.bg_academic_msg || a.message || getLabel(a.status);\n const extra = fields.bg_institution ? ('Institution: ' + fields.bg_institution) : '';\n pushBlock(key, header, extra, []);\n continue;\n }\n if (key === 'allowlist') {\n const header = fields.bg_allowlist_msg || a.message || getLabel(a.status);\n const extra = fields.bg_allowlist_rule ? ('Rule: ' + fields.bg_allowlist_rule) : '';\n pushBlock(key, header, extra, []);\n continue;\n }\n if (key === 'blocklist') {\n const header = fields.bg_blocklist_msg || a.message || getLabel(a.status);\n const extra = fields.bg_blocklist_rule ? ('Rule: ' + fields.bg_blocklist_rule) : '';\n pushBlock(key, header, extra, []);\n continue;\n }\n }\n }\n // Any remaining assessments not in known order\n for (const a of (assessments || [])) {\n if (!a || !a.name || seen.has(a.name)) continue;\n const header = a.message || getLabel(a.status);\n pushBlock(a.name, header, '', []);\n }\n // Also include any inferred entries not present in original list\n for (const [name, a] of Object.entries(byName)) {\n if (seen.has(name)) continue;\n const header = a.message || getLabel(a.status);\n // Attach evidence/detail when available by name\n let detail = '';\n let ev = [];\n if (name === 'final_judge') { detail = fields.bg_final_detail; ev = Array.isArray(fields.bg_final_evidence) ? fields.bg_final_evidence : []; }\n else if (name === 'browser') { detail = fields.bg_browser_detail; ev = Array.isArray(fields.bg_browser_evidence) ? fields.bg_browser_evidence : []; }\n else if (name === 'compound') { detail = fields.bg_compound_detail; ev = Array.isArray(fields.bg_compound_evidence) ? fields.bg_compound_evidence : []; }\n else if (name === 'academic') { detail = fields.bg_institution ? ('Institution: ' + fields.bg_institution) : ''; ev = []; }\n else if (name === 'allowlist') { detail = fields.bg_allowlist_rule ? ('Rule: ' + fields.bg_allowlist_rule) : ''; ev = []; }\n else if (name === 'blocklist') { detail = fields.bg_blocklist_rule ? ('Rule: ' + fields.bg_blocklist_rule) : ''; ev = []; }\n pushBlock(name, header, detail, ev);\n seen.add(name);\n }\n // Fallback when no assessments: show overall status/message if present\n if (lines.filter(s => s && s.trim()).length === 0) {\n const status = fields.bg_status || '';\n if (String(status).toLowerCase() !== 'checking') {\n const header = fields.bg_message || getLabel(status) || '';\n if (header) lines.push(String(header));\n }\n }\n while (lines.length > 0 && !String(lines[lines.length - 1]).trim()) lines.pop();\n return lines.join('\\n');\n } catch (_) { return ''; }\n },\n\n // i18n\n get i18n() {\n return {\n title: 'Email Background Checker',\n subtitle: 'Upload or paste emails; verify they belong to real people.',\n apiKey: 'API Key:', change: 'Change', clear: 'Clear', getKeyHere: 'Get your free key here'\n };\n }\n };\n try { _attachWatchActiveRunner(inst); } catch (_) {}\n return inst;\n}\n\n// createJobRunner\n// A small, copyable background runner that processes a single job's items with\n// controlled concurrency. It runs independently from UI state and persists\n// progress safely back into app.jobStore[jobName].\n//\n// Usage:\n// const runner = createJobRunner(app, 'my-job', { concurrency: 8, onlyPending: true });\n// runner.start();\n// runner.cancel();\n// const s = runner.status(); // { running, cancelled, total, completed }\nfunction createJobRunner(app, jobName, options = {}) {\n // Internal runner state — not reactive\n const state = {\n running: false,\n cancelled: false,\n total: 0,\n completed: 0\n };\n\n // Persist the updated job payload back to localStorage via app helpers,\n // refresh sidebar job counts, and live-update the UI list if this job is active.\n function persistAndMaybeUpdateUi(updatedPayload, idx) {\n try {\n app.jobStore[jobName] = updatedPayload;\n app.saveJobsToStorage();\n app.refreshJobsArray();\n if (app.jobName === jobName) {\n const uiItems = app.items || [];\n const jobItems = updatedPayload.items || [];\n if (idx >= 0 && idx < jobItems.length && idx < uiItems.length) {\n const updated = jobItems[idx];\n // Basic defensive sync by index\n app.items[idx] = { ...app.items[idx], ...updated };\n }\n app.recomputeDetectedEmails();\n }\n } catch (_) {}\n }\n\n // Build the list of indices to process for the job\n function collectTargetIndices(items) {\n const onlyPending = options.onlyPending !== false;\n const indices = [];\n for (let i = 0; i < (items?.length || 0); i++) {\n const it = items[i];\n if (!it) continue;\n if (!onlyPending) { indices.push(i); continue; }\n const pending = (!it.bg_checked_at || it.bg_status === 'pending' || !it.bg_status);\n if (pending) indices.push(i);\n }\n return indices;\n }\n\n async function start() {\n if (state.running) return;\n state.running = true;\n state.cancelled = false;\n try {\n const payload = app.jobStore && app.jobStore[jobName] ? { ...app.jobStore[jobName] } : null;\n if (!payload) { state.running = false; return; }\n const items = Array.isArray(payload.items) ? payload.items.slice() : [];\n const systemPrompt = payload?.meta?.systemPrompt || '';\n const indices = collectTargetIndices(items);\n state.total = indices.length;\n state.completed = 0;\n if (indices.length === 0) { state.running = false; return; }\n\n // Pre-mark queued rows as checking (or error if no email) and persist\n for (const idx of indices) {\n const rec = items[idx];\n if (!rec) continue;\n const email = app.getRecordEmail ? app.getRecordEmail(rec) : (rec.email || '');\n // Clear previous per-check transient fields\n delete rec.bg_compound_msg; delete rec.bg_compound_debug; delete rec.bg_browser_debug;\n delete rec.bg_compound_label; delete rec.bg_compound_short; delete rec.bg_compound_detail;\n delete rec.bg_browser_label; delete rec.bg_browser_short; delete rec.bg_browser_detail;\n delete rec.bg_compound_evidence; delete rec.bg_browser_evidence; delete rec.bg_final_evidence;\n if (!email || !(app.isEmail && app.isEmail(email))) {\n rec.bg_status = 'error';\n rec.bg_message = 'No email detected';\n rec.bg_checked_at = new Date().toISOString();\n } else {\n rec.bg_status = 'checking';\n rec.bg_message = '';\n rec.bg_checked_at = null;\n }\n payload.items[idx] = rec; payload.updated_at = new Date().toISOString();\n persistAndMaybeUpdateUi(payload, idx);\n }\n\n const limit = Math.max(1, Number(options.concurrency || app.concurrency) || 8);\n let cursor = 0;\n const runNext = async () => {\n if (state.cancelled) return;\n if (cursor >= indices.length) return;\n const idx = indices[cursor++];\n const rec = items[idx];\n if (!rec) { state.completed++; return runNext(); }\n if (rec.bg_status === 'error') { state.completed++; return runNext(); }\n try {\n const email = app.getRecordEmail ? app.getRecordEmail(rec) : (rec.email || '');\n if (!app.hasServerKey && !app.userApiKey) throw new Error('No Groq API key set. Add a key to run checks.');\n // Fully clear any previous assessment fields before each call\n delete rec.bg_compound_msg; delete rec.bg_compound_debug; delete rec.bg_browser_debug;\n delete rec.bg_compound_label; delete rec.bg_compound_short; delete rec.bg_compound_detail;\n delete rec.bg_browser_label; delete rec.bg_browser_short; delete rec.bg_browser_detail;\n delete rec.bg_final_label; delete rec.bg_final_short; delete rec.bg_final_detail;\n delete rec.bg_compound_evidence; delete rec.bg_browser_evidence; delete rec.bg_final_evidence;\n const result = await app.callBackgroundCheckApi(email, systemPrompt);\n rec.bg_status = result?.status || 'person_low';\n rec.bg_message = result?.message || '';\n if (result && result.fields && typeof result.fields === 'object') {\n for (const [k, v] of Object.entries(result.fields)) rec[k] = v;\n }\n rec.bg_checked_at = new Date().toISOString();\n } catch (e) {\n rec.bg_status = 'error';\n rec.bg_message = (e && e.message) ? e.message : 'Error';\n rec.bg_checked_at = new Date().toISOString();\n } finally {\n // Write back the single record and persist\n payload.items[idx] = rec;\n payload.updated_at = new Date().toISOString();\n persistAndMaybeUpdateUi(payload, idx);\n state.completed++;\n await runNext();\n }\n };\n const runners = [];\n for (let k = 0; k < limit; k++) runners.push(runNext());\n await Promise.all(runners);\n } catch (_) {\n // swallow\n } finally {\n state.running = false;\n }\n }\n\n function cancel() { state.cancelled = true; }\n function status() { return { running: state.running, cancelled: state.cancelled, total: state.total, completed: state.completed }; }\n\n return { start, cancel, status };\n}\n\n// UI helper: watch the active job runner state and reflect it in isRunning\n// Stops automatically when the runner finishes or job changes\n// (attached to the component instance via function expression to access `this`)\nmailcheckApp.prototype = mailcheckApp.prototype || {};\n// Attach as method on the returned object instead (Alpine pattern)\n// eslint-disable-next-line no-unused-vars\nfunction _attachWatchActiveRunner(instance) {\n instance._watchActiveRunner = function () {\n try { if (this._activeRunnerInterval) { clearInterval(this._activeRunnerInterval); this._activeRunnerInterval = null; } } catch (_) {}\n this._activeRunnerInterval = setInterval(() => {\n try {\n const s = this.getBackgroundRunStatus(this.jobName);\n this.isRunning = !!(s && s.running);\n // Keep a per-job map for sidebar indicators\n this._refreshJobRunningMap();\n // Stop watcher when no jobs are active or checking\n let anyRunning = false;\n try { anyRunning = Object.values(this.jobRunningMap || {}).some(Boolean); } catch (_) { anyRunning = this.isRunning; }\n if (!anyRunning) { clearInterval(this._activeRunnerInterval); this._activeRunnerInterval = null; }\n } catch (_) {\n try { clearInterval(this._activeRunnerInterval); this._activeRunnerInterval = null; } catch (_) {}\n }\n }, 400);\n };\n}\n// (wrapper removed) — default export is now the single factory with watcher injection\n\n\n\n",[],[230,344],"c4518880-9810-11f0-90e5-0224a6c84d84","init.js","cc00986a-81f8-11f0-9ea2-0224a6c84d84",129,["D",1758585822824],"import mcpNavApp from './mcpNavApp.js';\n\nwindow.mcpNavApp = mcpNavApp;\n\n// Register with Alpine when ready\nif (window.Alpine && typeof window.Alpine.data === 'function') {\n window.Alpine.data('mcpNavApp', mcpNavApp);\n} else {\n document.addEventListener('alpine:init', () => {\n try {\n if (window.Alpine && typeof window.Alpine.data === 'function') {\n window.Alpine.data('mcpNavApp', mcpNavApp);\n }\n } catch (_) { /* no-op */ }\n });\n}\n\n// If Alpine was deferred via window.deferLoadingAlpine, start it now\ntry { if (typeof window._startAlpine === 'function') window._startAlpine(); } catch (_) {}\n\n\n",[],[230,352],["D",1756156596788],[268,269],[230],"de11a28c-9810-11f0-93f3-0224a6c84d84","dd8f7406-9810-11f0-87e9-0224a6c84d84",["D",1758585866099],[],[235,367,32],"assessments","ddc679a6-9810-11f0-9eb6-0224a6c84d84","pre","ddc67abe-9810-11f0-9eb6-0224a6c84d84",147,["D",1758585865607],[],[235,367,369],"de04f226-9810-11f0-87e9-0224a6c84d84","roleHeuristic.js","de04f2d0-9810-11f0-87e9-0224a6c84d84","ddab80a6-9810-11f0-970f-0224a6c84d84",152,["D",1758585866018],"export function roleHeuristicAssess(email) {\n try {\n const local = String(email || '').split('@')[0].toLowerCase();\n const roleList = ['info', 'support', 'admin', 'sales', 'contact', 'hello', 'team', 'marketing', 'noreply', 'no-reply'];\n if (roleList.includes(local)) return { status: 'suspected_spam', message: 'Role-based address' };\n } catch (_) {}\n return {};\n}\n\n\n",[],[235,367,384,376],"full","de09125c-9810-11f0-9d01-0224a6c84d84","llmCompound.js","de0912e8-9810-11f0-9d01-0224a6c84d84",153,["D",1758585866012],"import { groqChatCompletion } from '../../../chatCompletion.js';\nimport { extractJsonBetweenTags, cleanDetailText, deriveIdentityShort, statusToLabel } from '../utils.js';\n\nexport async function llmCompoundAssess(apiKey, email, systemPrompt) {\n const baseSystem = [\n 'You assess whether an email belongs to a real person. Perform targeted web checks. If you cannot browse, reason only from public patterns in the address and provider; do not fabricate.',\n 'Make an effort to look for identity signals on LinkedIn, company/staff pages, academic directories, GitHub, personal sites, press/newsroom/author pages, and social profiles.',\n 'When identity is indicated, do light background digging: capture the person\\'s name, role/title, organization, department/team, and location/city if available.',\n 'Also look for negative signals: credible anti-abuse/anti-spam sources (e.g., StopForumSpam, Spamhaus, PhishTank), scam-reporting communities, or reputable media coverage indicating misuse. If credible negative signals exist, prefer status: spam.',\n 'Return ONLY JSON wrapped in ... tags using this schema:',\n '{ \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }',\n 'Guidelines:',\n '- person_high: strong identity signals clearly tie to the email/user (e.g., staff/author page, university/company directory, or a portfolio/personal site that credibly matches the individual).',\n '- person_low: requires at least one concrete, credible public signal about the person (e.g., portfolio/personal site with matching name/handle, staff/author/university/company page, or GitHub with substantive profile). Mere name-like matches or generic social profiles without a clear tie do NOT qualify.',\n '- person_none: choose this when there is no credible public identity evidence. Ambiguous name matches (e.g., multiple LinkedIn results for common names), generic provider emails with only a name-like local part, or signals that cannot be tied to the email/person should be person_none.',\n '- spam: obvious spam/role-based/throwaway patterns, or credible anti-spam sources flag the address.',\n '- Leniency: Only apply leniency toward person_low for non-generic organization or academic domains when there is at least one plausible institutional signal (e.g., being listed on an org/staff page). Do not apply leniency for generic providers or name-only signals.',\n '- Escalation: When you find a plausible identity match (person name plus role/title and/or organization/institution) from credible sources and there are no credible negative signals, prefer status: person_high, even if the address uses a generic email provider (e.g., gmail).',\n '- message: one short sentence preferring an identity-first summary, e.g., \"Linked to Name — Title, Organization\" when available. explanation_short: 2-3 sentences (<= 400 chars), plain text; no tool logs, URLs, or headings. If known, include person background (name, role/title, organization).',\n '- evidence: 1-5 short bullets summarizing concrete findings (no links). Include at least one background bullet when available (e.g., \"Name — Title, Organization, City\"). Include negative bullets when applicable (e.g., \"Flagged on StopForumSpam\" or \"Reported in scam community\"). If nothing credible is found, set evidence to [] and explicitly say \"No public evidence found.\" and prefer status person_none.',\n '- If the address indicates a role (e.g., info, noreply) or a notable role (e.g., reporter, journalist, professor, founder), include that in evidence.',\n '- Do not include any text outside the ... wrapper.'\n ].join('\\n');\n const messages = [\n { role: 'system', content: baseSystem + (systemPrompt ? ('\\nExtra instructions: ' + systemPrompt) : '') },\n { role: 'user', content: 'Email: ' + email + '\\nTask: quick legitimacy check.' }\n ];\n const model = 'compound-beta';\n const compoundPayload1 = { model, messages, stream: false, temperature: 0.2, tool_choice: 'none' };\n const r1 = await groqChatCompletion(apiKey, compoundPayload1);\n const t1 = r1?.choices?.[0]?.message?.content || '';\n const reasoning1 = r1?.choices?.[0]?.message?.reasoning || '';\n let parsed = extractJsonBetweenTags(t1);\n if (!parsed) {\n const baseSystemJson = [\n 'You assess whether an email likely belongs to a real person based on quick web checks; do not fabricate.',\n 'Return ONLY a JSON object with this schema (no tags, no markdown):',\n '{ \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }',\n 'Keep message concise; explanation_short 2-3 sentences (<= 400 chars).'\n ].join('\\n');\n const messagesJson = [\n { role: 'system', content: baseSystemJson + (systemPrompt ? ('\\nExtra instructions: ' + systemPrompt) : '') },\n { role: 'user', content: 'Email: ' + email + '\\nTask: quick legitimacy check.' }\n ];\n const payload2 = { model, messages: messagesJson, stream: false, temperature: 0.2, response_format: { type: 'json_object' }, tool_choice: 'none' };\n const r2 = await groqChatCompletion(apiKey, payload2);\n try { parsed = JSON.parse(r2?.choices?.[0]?.message?.content || ''); } catch (_) { parsed = null; }\n if (!parsed) {\n return {\n status: 'person_low',\n message: 'no compound signal',\n fields: { bg_compound_debug: (t1 || '').slice(0, 800), bg_llm_model: model }\n };\n }\n }\n const out = { fields: { bg_llm_model: model } };\n if (parsed) {\n if (parsed.status && (parsed.status === 'person_high' || parsed.status === 'person_low' || parsed.status === 'person_none' || parsed.status === 'spam')) out.status = parsed.status;\n if (typeof parsed.message === 'string' && parsed.message.trim()) {\n out.message = parsed.message.trim();\n } else if (out.status) {\n const label = statusToLabel(out.status);\n out.message = 'compound: ' + label;\n } else {\n out.message = 'compound: ' + statusToLabel('person_low');\n }\n const label = statusToLabel(out.status || (parsed.status || 'person_low'));\n out.fields.bg_compound_label = label;\n out.fields.bg_compound_short = out.message || label;\n let detail = '';\n if (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) {\n detail = cleanDetailText(parsed.explanation_short);\n try {\n const parts = detail.split(/(?<=[.!?])\\s+/).filter(Boolean).slice(0, 3);\n detail = parts.join(' ');\n if (detail.length > 450) detail = detail.slice(0, 449).replace(/[,;:\\s]+$/, '').trim() + '…';\n } catch (_) {}\n }\n if (!detail && reasoning1 && typeof reasoning1 === 'string') {\n detail = cleanDetailText(reasoning1);\n }\n if (!detail && t1) {\n detail = cleanDetailText(String(t1));\n }\n if (detail) out.fields.bg_compound_detail = detail;\n try {\n const shortPref = (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) ? deriveIdentityShort(parsed.explanation_short) : '';\n if (shortPref) out.fields.bg_compound_short = shortPref;\n } catch (_) {}\n try {\n let ev = parsed.evidence;\n if (Array.isArray(ev)) {\n ev = ev.map((s) => String(s || '').trim()).filter(Boolean).slice(0, 5);\n } else if (typeof ev === 'string' && ev.trim()) {\n ev = [ev.trim()];\n } else {\n ev = [];\n }\n if (ev.length > 0) out.fields.bg_compound_evidence = ev;\n } catch (_) {}\n }\n return out;\n}\n\n\n",[],[235,367,384,386],"de0c7140-9810-11f0-894e-0224a6c84d84","finalJudge.js","de0c7208-9810-11f0-894e-0224a6c84d84",154,["D",1758585866055],"import { groqChatCompletion } from '../../../chatCompletion.js';\nimport { statusToLabel, deriveIdentityShort } from '../utils.js';\n\nexport async function finalJudgeAssess(apiKey, email, systemPrompt, evidence) {\n console.log('>> [final judge] evidence:', email, JSON.stringify(evidence));\n const model = 'openai/gpt-oss-120b';\n const schema = '{ \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }';\n const sys = [\n 'You are a strict judge that consolidates signals from two assessors and heuristics (academic, role, domain) to decide if an email belongs to a real person.',\n 'Decide using severity: spam > person_none > person_low > person_high.',\n 'Return ONLY JSON per schema:', schema,\n 'Rules:',\n '- Compose evidence as a deduplicated list of concrete bullets merged from all inputs (no links).',\n '- Include at least one bullet with person background when available (name, role/title, organization, location).',\n '- If credible anti-spam signals exist (e.g., StopForumSpam, Spamhaus, scam-reporting communities), prefer status: spam and include a negative bullet.',\n '- Leniency: Only apply leniency toward person_low for non-generic organization or academic domains when at least one institutional or portfolio-like signal exists (e.g., org/staff page, university directory, personal site with substantive details). Do not apply leniency for generic providers or name-only matches.',\n '- Escalation: If there is a plausible identity match (person name plus role/title and/or organization/institution) from credible sources and no credible negative signals, prefer person_high even if the address uses a generic provider (e.g., gmail).',\n '- If no credible public evidence is present, set evidence to [] and explicitly say \"No public evidence found.\" in explanation_short and prefer status: person_none.',\n '- message must be one short, specific sentence preferring an identity-first summary like \"Linked to Name — Title, Organization\" when available. explanation_short must be 2-3 sentences (<= 400 chars) and reference key evidence or lack thereof. If known, weave in person background (name, role/title, organization).',\n '- Note recognizable roles when present (reporter, journalist, professor, founder, recruiter).'\n ].join('\\n');\n const user = [ 'Email: ' + email, 'Evidence (JSON):', JSON.stringify(evidence) ].join('\\n');\n const judgePayload = { model, messages: [ { role: 'system', content: sys + (systemPrompt ? ('\\nExtra: ' + systemPrompt) : '') }, { role: 'user', content: user } ], stream: false, temperature: 0.2, response_format: { type: 'json_object' } };\n const r = await groqChatCompletion(apiKey, judgePayload);\n let parsed = null;\n try { parsed = JSON.parse(r?.choices?.[0]?.message?.content || '{}'); } catch (_) { parsed = null; }\n if (!parsed) return {};\n const out = { fields: { bg_final_model: model } };\n if (parsed.status && (parsed.status === 'person_high' || parsed.status === 'person_low' || parsed.status === 'person_none' || parsed.status === 'spam')) out.status = parsed.status;\n if (typeof parsed.message === 'string' && parsed.message.trim()) out.message = parsed.message.trim();\n const label = statusToLabel(out.status || (parsed.status || 'person_low'));\n out.fields.bg_final_label = label;\n out.fields.bg_final_short = out.message || label;\n if (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) {\n let d = String(parsed.explanation_short).trim();\n if (d.length > 450) d = d.slice(0, 449).replace(/[,;:\\s]+$/, '').trim() + '…';\n out.fields.bg_final_detail = d;\n try {\n const shortPref = deriveIdentityShort(parsed.explanation_short);\n if (shortPref) out.fields.bg_final_short = shortPref;\n } catch (_) {}\n }\n try {\n let ev = parsed.evidence;\n if (Array.isArray(ev)) {\n ev = ev.map((s) => String(s || '').trim()).filter(Boolean).slice(0, 5);\n } else if (typeof ev === 'string' && ev.trim()) {\n ev = [ev.trim()];\n } else {\n ev = [];\n }\n if (ev.length > 0) out.fields.bg_final_evidence = ev;\n } catch (_) {}\n return out;\n}\n\n\n",[],[235,367,384,394],"ddee2a0a-9810-11f0-8622-0224a6c84d84","browserSearch.js","ddee2aa0-9810-11f0-8622-0224a6c84d84",149,["D",1758585865866],"import { groqChatCompletion } from '../../../chatCompletion.js';\nimport { statusToLabel, deriveIdentityShort, coerceJsonFromText, logGroqCurl } from '../utils.js';\n\nasync function convertAnalysisToJson(apiKey, email, analysisText) {\n try {\n const convModel = 'openai/gpt-oss-20b';\n const convSys = [\n 'You convert analysis text into a strict JSON object. Do not browse or call tools.',\n 'Schema: { \"status\": \"person_high|person_low|person_none|spam\", \"message\": string, \"explanation_short\": string, \"evidence\": string[] }',\n 'Rules:',\n '- message: one short sentence.',\n '- explanation_short: 2-3 sentences (<= 400 chars). If analysis indicates nothing credible was found, include \"No public evidence found.\" If known, include person background (name, role/title, organization). If credible negative signals are present (e.g., StopForumSpam, Spamhaus, scam-reporting communities), mention that.',\n '- evidence: 0-5 short bullets (no links). Include a background bullet when available (e.g., \"Name — Title, Organization, City\"). Include negative bullets when applicable (e.g., \"Flagged on StopForumSpam\"). Use [] when no credible evidence.',\n '- Only output a JSON object (no markdown, no extra text).'\n ].join('\\n');\n const convMessages = [\n { role: 'system', content: convSys },\n { role: 'user', content: 'Email: ' + email + '\\nAnalysis to convert:\\n' + analysisText }\n ];\n const convPayload = { model: convModel, messages: convMessages, stream: false, temperature: 0, response_format: { type: 'json_object' }, tool_choice: 'none' };\n const convRes = await groqChatCompletion(apiKey, convPayload);\n const t2 = convRes?.choices?.[0]?.message?.content || '';\n try { return JSON.parse(t2); } catch (_) { return null; }\n } catch (_) {\n return null;\n }\n}\n\nexport async function browserSearchAssess(apiKey, email, systemPrompt) {\n const baseSystem = [\n 'Use web browsing to gather public signals about whether this email belongs to a real person; do not fabricate.',\n 'Call browser_search with multiple targeted queries. Try: the full email in quotes; the local part and domain; site:linkedin.com with likely name/handle; site:github.com with the handle; university/staff directories; newsroom/author pages; personal sites; press pages.',\n 'Prefer authoritative sources: LinkedIn, staff/author/company pages, academic directories, GitHub, reputable media. Also check credible anti-abuse/anti-spam sources (StopForumSpam, Spamhaus, PhishTank) and scam-reporting communities. Avoid data brokers and spammy aggregators.',\n 'When identity is indicated, do light background digging: capture the person\\'s name, role/title, organization, department/team, and location/city if available.',\n 'Leniency rule: Only apply leniency toward person_low for non-generic organization or academic domains when there is at least one plausible institutional signal (e.g., listed on org/staff page or directory). Do not apply leniency for generic providers or name-only matches.',\n 'Escalation rule: If you find a plausible identity match (person name plus role/title and/or organization/institution) from credible sources and no credible negative signals, prefer Status: person_high, even when the address uses a generic provider (e.g., gmail).',\n 'Produce a concise plain-text analysis with the following sections only (do not include any JSON):',\n 'Status: one of person_high | person_low | person_none | spam',\n 'Message: one short sentence preferring an identity-first summary, e.g., \"Linked to Name — Title, Organization\" when available',\n 'Explanation: 2-3 sentences (<= 400 chars), reference evidence or say No public evidence found. If known, include person background (name, role/title, organization).',\n 'Evidence: 1-5 short bullet points summarizing concrete findings (no links). Include at least one bullet with person background when available (e.g., \"Name — Title, Organization, City\"). Include negative bullets such as \"Flagged on StopForumSpam\" or \"Mentioned in scam-reporting community\" when applicable. If nothing credible found, leave this section empty and prefer Status: person_none.',\n 'Also note recognizable roles when present (reporter, journalist, professor, founder, recruiter).'\n ].join('\\n');\n const messages = [\n { role: 'system', content: baseSystem + (systemPrompt ? ('\\nExtra instructions: ' + systemPrompt) : '') },\n { role: 'user', content: 'Email: ' + email + '\\nTask: web search legitimacy check.' }\n ];\n const model = 'openai/gpt-oss-20b';\n const payload = { model, messages, stream: false, temperature: 0.2, tools: [{ type: 'browser_search' }] };\n const r1 = await groqChatCompletion(apiKey, payload);\n logGroqCurl('browser r1', apiKey, payload);\n const t1 = r1?.choices?.[0]?.message?.content || '';\n const out = { fields: { bg_browser_model: model } };\n let parsed = await convertAnalysisToJson(apiKey, email, t1);\n if (!parsed) parsed = coerceJsonFromText(t1);\n if (parsed) {\n if (parsed.status && (parsed.status === 'person_high' || parsed.status === 'person_low' || parsed.status === 'person_none' || parsed.status === 'spam')) out.status = parsed.status;\n if (typeof parsed.message === 'string' && parsed.message.trim()) out.message = parsed.message.trim();\n const label = statusToLabel(out.status || (parsed.status || 'person_low'));\n out.fields.bg_browser_label = label;\n out.fields.bg_browser_short = out.message || label;\n if (typeof parsed.explanation_short === 'string' && parsed.explanation_short.trim()) {\n let detail = String(parsed.explanation_short).trim();\n if (detail.length > 450) detail = detail.slice(0, 449).replace(/[,;:\\s]+$/, '').trim() + '…';\n out.fields.bg_browser_detail = detail;\n try {\n const shortPref = deriveIdentityShort(parsed.explanation_short);\n if (shortPref) out.fields.bg_browser_short = shortPref;\n } catch (_) {}\n }\n try {\n let ev = parsed.evidence;\n if (Array.isArray(ev)) {\n ev = ev.map((s) => String(s || '').trim()).filter(Boolean).slice(0, 5);\n } else if (typeof ev === 'string' && ev.trim()) {\n ev = [ev.trim()];\n } else {\n ev = [];\n }\n if (ev.length > 0) out.fields.bg_browser_evidence = ev;\n } catch (_) {}\n } else {\n out.fields.bg_browser_debug = 'browser_search produced non-JSON analysis and conversion failed.';\n }\n return out;\n}\n\n\n",[],[235,367,384,402],"ddab7fde-9810-11f0-970f-0224a6c84d84",146,["D",1758585865432],[261,262,263,264],[235,367,384],"dd8f7370-9810-11f0-87e9-0224a6c84d84",145,["D",1758585865237],[260,265,266],[235,367],["D",1756510448859],[259],[235],"cc4035b0-81f8-11f0-af77-0224a6c84d84","state.json","cc40365a-81f8-11f0-af77-0224a6c84d84",48,["D",1756156602547],"{\n \"val\": {\n \"id\": \"4849d342-81f8-11f0-9ed4-0224a6c84d84\"\n },\n \"branch\": {\n \"id\": \"484a2f22-81f8-11f0-9ed4-0224a6c84d84\",\n \"version\": 88\n },\n \"lastRun\": {\n \"pid\": 87094,\n \"time\": \"2025-08-25T21:13:10.136Z\"\n }\n}",[],[241,423],["D",1756156596911],[257],[241],["D",1756156596230],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":54,"_100":101,"_102":24},{"_13":85,"_31":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_122":470,"_471":472,"_473":474,"_475":24,"_476":24,"_477":24,"_478":58,"_479":-5,"_480":-7,"_481":-7,"_482":62,"_483":24,"_484":24,"_485":-5,"_486":24,"_487":24,"_488":24,"_489":-5},"ENV",{"_441":442,"_443":444,"_445":86,"_446":447,"_448":449,"_450":451,"_452":453,"_454":455,"_456":457,"_458":459,"_460":461,"_462":463,"_464":465,"_466":467,"_468":469},"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 · v155