${esc(b.text ?? b.content ?? \"\")}

${label}

| null, formId: string): string {\n const fields: any[] = (() => {\n if (!form) return [];\n if (Array.isArray(form.fields)) return form.fields;\n try { const p = JSON.parse(String(form.fields ?? \"[]\")); return Array.isArray(p) ? p : []; } catch { return []; }\n })();\n\n // Honest default when the form has no defined fields yet: collect just an email so the page\n // still captures a lead.\n const effective = fields.length > 0\n ? fields\n : [{ name: \"email\", label: \"Email\", type: \"email\", required: true }];\n\n const inputsHtml = effective.map((f: any) => {\n const name = String(f.name ?? f.label ?? \"field\").trim() || \"field\";\n const label = esc(f.label ?? name);\n const required = f.required ? \"required\" : \"\";\n const rawType = String(f.type ?? \"text\").toLowerCase();\n if (rawType === \"textarea\") {\n return `${label}` +\n ``;\n }\n const inputType = [\"email\", \"tel\", \"url\", \"number\"].includes(rawType) ? rawType : \"text\";\n return `${label}` +\n ``;\n }).join(\"\");\n\n const successMessage = esc(form?.success_message ?? \"Thanks — we'll be in touch.\");\n const submitId = esc(formId);\n\n // The inline script is self-contained (no app bundle). It serializes the form, posts JSON to\n // the public submit route, and on {ok:true} shows the success message (+ optional redirect).\n return `\n \n \n `;\n}\n\n// The 404 HTML returned when a slug doesn't resolve or the page isn't published. Same dark shell.\nfunction notFoundHtml(): string {\n return `\n\n\n\n\nPage not found\n\n\n

Page not found

This page is unavailable or has not been published.

\n`;\n}\n\n// renderLandingPage — PUBLIC. Resolve the page BY SLUG across ALL tenants (UNSCOPED — there is no\n// trusted session here; the slug is the global public key). Missing or unpublished → null (the\n// route renders a 404). Otherwise bump view_count for the OWNING tenant of this page (tenant_id\n// taken FROM the resolved row and asserted explicitly in the WHERE — never a session value) and\n// return a self-contained dark-themed HTML string. If the page has a form_id we look the form up\n// BY ID within that SAME owning tenant and embed it. INVARIANT: nothing here uses\n// currentTenantId(); a public render can only read the page it matched by slug and can only bump\n// the view_count of that page's owning tenant.\nexport async function renderLandingPage(slug: string): Promise {\n const cleanSlug = String(slug ?? \"\").trim();\n if (!cleanSlug) return null;\n\n // (1) Resolve the page by slug across all tenants — explicitly UNSCOPED.\n const r = await sqlite.execute(\n \"SELECT * FROM landing_pages WHERE slug = ? LIMIT 1\",\n [cleanSlug],\n );\n if (!r.rows || r.rows.length === 0) return null;\n const page = rowToObj(r.columns, r.rows[0] as any[]);\n\n // (2) Publication gate: unpublished pages are not publicly visible.\n if (Number(page.published) !== 1) return null;\n\n const owningTenantId = page.tenant_id; // the page's OWNING tenant — the only tenant we may touch.\n\n // (3) Bump view_count for the OWNING tenant explicitly. tenant_id in the WHERE comes FROM the\n // resolved row (never the anonymous session). Best-effort: a failed bump must not 500 the\n // public render.\n try {\n await sqlite.execute(\n \"UPDATE landing_pages SET view_count = COALESCE(view_count,0) + 1 WHERE id = ? AND tenant_id = ?\",\n [page.id, owningTenantId],\n );\n } catch { /* view counting is best-effort; never block the render */ }\n\n // (4) If a form is attached, look it up BY ID within the SAME owning tenant (the form belongs\n // to the same tenant as the page). Scoped by the page's owning tenant_id, not a session.\n let form: Record | null = null;\n if (page.form_id) {\n try {\n const fr = await sqlite.execute(\n \"SELECT * FROM marketing_forms WHERE id = ? AND tenant_id = ? LIMIT 1\",\n [page.form_id, owningTenantId],\n );\n if (fr.rows && fr.rows.length > 0) form = rowToObj(fr.columns, fr.rows[0] as any[]);\n } catch { form = null; }\n }\n\n const blocks = toJsonArray(page.blocks);\n const blocksHtml = blocks.map((b) => renderBlock(b)).join(\"\\n\");\n const formHtml = page.form_id ? renderEmbeddedForm(form, String(page.form_id)) : \"\";\n\n const title = esc(page.title ?? \"\");\n const subtitle = esc(page.subtitle ?? \"\");\n\n // Self-contained, inline-CSS dark page faithful to the app palette (bg #131316, surface #0e0e11,\n // accent #c0c1ff). No external assets, no app bundle, no session dependency.\n return `\n\n\n\n${title || \"Landing page\"}\n\n\n

\n ${title ? `

${title}

` : \"\"}\n ${subtitle ? `

${subtitle}

` : \"\"}\n

\n ${blocksHtml}\n

\n ${formHtml}\n \n

${esc(b.text ?? b.content ?? \"\")}

`;\n case \"text\":\n case \"paragraph\":\n return `

${esc(b.text ?? b.content ?? \"\")}

`;\n case \"image\": {\n const src = safeUrl(b.url ?? b.src);\n if (!src) return \"\";\n return ` $\"${esc(b.alt$ `;\n }\n case \"cta\": {\n const href = safeUrl(b.url ?? b.href);\n const label = esc(b.text ?? b.label ?? \"Learn more\");\n if (!href || href === \"#\") return `

${label}

`;\n return `

${label}

`;\n }\n default:\n return \"\";\n }\n}\n\n// Render the embedded lead-capture form (when the page has a form_id). The form POSTs to the\n// PUBLIC submit endpoint /api/marketing/forms/:id/submit, which resolves the owning tenant from\n// the form id. We include the `company_url` honeypot (hidden, off-screen, aria-hidden, tabindex\n// -1, autocomplete off) named to match the server bot-trap. On a 2xx JSON {ok:true} we swap the\n// form for success_message and optionally redirect; otherwise we show an inline error.\nfunction renderEmbeddedForm(form: Record | null, formId: string): string {\n const fields: any[] = (() => {\n if (!form) return [];\n if (Array.isArray(form.fields)) return form.fields;\n try { const p = JSON.parse(String(form.fields ?? \"[]\")); return Array.isArray(p) ? p : []; } catch { return []; }\n })();\n\n // Honest default when the form has no defined fields yet: collect just an email so the page\n // still captures a lead.\n const effective = fields.length > 0\n ? fields\n : [{ name: \"email\", label: \"Email\", type: \"email\", required: true }];\n\n const inputsHtml = effective.map((f: any) => {\n const name = String(f.name ?? f.label ?? \"field\").trim() || \"field\";\n const label = esc(f.label ?? name);\n const required = f.required ? \"required\" : \"\";\n const rawType = String(f.type ?? \"text\").toLowerCase();\n if (rawType === \"textarea\") {\n return `${label}` +\n ``;\n }\n const inputType = [\"email\", \"tel\", \"url\", \"number\"].includes(rawType) ? rawType : \"text\";\n return `${label}` +\n ``;\n }).join(\"\");\n\n const successMessage = esc(form?.success_message ?? \"Thanks — we'll be in touch.\");\n const submitId = esc(formId);\n\n // The inline script is self-contained (no app bundle). It serializes the form, posts JSON to\n // the public submit route, and on {ok:true} shows the success message (+ optional redirect).\n return `\n \n \n `;\n}\n\n// The 404 HTML returned when a slug doesn't resolve or the page isn't published. Same dark shell.\nfunction notFoundHtml(): string {\n return `\n\n\n\n\nPage not found\n\n\n

Page not found

This page is unavailable or has not been published.

\n ${title ? `

${title}

` : \"\"}\n ${subtitle ? `

${subtitle}

` : \"\"}\n

\n ${blocksHtml}\n

\n ${formHtml}\n \n

\n`;\n}\n\n// Convenience for the route: returns the 404 HTML body so the dispatcher can serve a faithful\n// dark not-found page (text/html) when renderLandingPage returns null.\nexport function landingNotFoundHtml(): string {\n return notFoundHtml();\n}\n","createdAt",["D",1780483960512],"branchVersion","branchId","ecb58646-56c9-11f1-abd8-ee650bb23af1","id","ecb4ccf6-56c9-11f1-abd8-ee650bb23af1","aihivecommand",["D",1779556068488],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","AIHive Command Center","imageUrl","e8c17657-6210-4c45-bd2b-dbcf2e020293","pinnedFileId","32167c2c-56ca-11f1-955a-ee650bb23af1","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e4de5-f6b1-7488-a017-a3a028bc2ba8","tursoName","ecb4ccf656c911f1abd8ee650bb23af1","tursoHostname","ecb4ccf656c911f1abd8ee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789503703835],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_101":100,"_108":104},"org",{"_101":100,"_102":100,"_103":104,"_18":56,"_105":106,"_107":25},"branch",{"_13":90,"_32":91,"_44":43,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":46,"_99":100},"isOwned",1111,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","vlduy123","handle","displayName","avatar","https://avatars.githubusercontent.com/u/208025931?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":1898,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":1899,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":1900,"_85":1901,"_87":1902,"_89":25},"tree",[555,641,659,688,689,690,691,692,693,694,695,696,697,698,699,700,701,702,703,704,705,706,707,708,709,710,711,712,713,714,715,716,717,718,719,720,721,722,723,724,725,726,727,728,729,730,731,732,733],"files",[555,556,557,558,559,560,561,562,563,564,565,566,567,568,569,570,571,572,573,574,575,576,577,578,579,580,581,582,583,584,585,586,587,588,589,590,591,592,593,594,595,596,597,598,599,600,601,602,603,604,605,606,607,608,609,610,611,612,613,614,615,616,617,618,619,620,621,622,623,624,625,626,627,628,629,630,631,632,633,634,635,636,637,638,639,640,641,642,643,644,645,646,647,648,649,650,651,652,653,654,655,656,657,658,659,660,661,662,663,664,665,666,667,668,669,670,671,672,673,674,675,676,677,678,679,680,681,682,683,684,685,686,687,688,689,690,691,692,693,694,695,696,697,698,699,700,701,702,703,704,705,706,707,708,709,710,711,712,713,714,715,716,717,718,719,720,721,722,723,724,725,726,727,728,729,730,731,732,733],"counts",{"_545":64,"_546":303,"_547":64,"_548":549,"_550":551},"contents",[131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162,163,164,165,166,167,168,169,170,171,172,173,174,175,176,177,178,179],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":540,"_32":541,"_30":542,"_183":-5,"_42":43,"_41":196,"_185":60,"_39":543,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_27":544},{"_44":534,"_32":535,"_30":536,"_183":-5,"_42":43,"_41":537,"_185":60,"_39":538,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_27":539},{"_44":527,"_32":528,"_30":529,"_183":-5,"_42":43,"_41":530,"_185":60,"_39":531,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_27":533},{"_44":520,"_32":521,"_30":522,"_183":-5,"_42":43,"_41":523,"_185":60,"_39":524,"_13":236,"_34":35,"_36":525,"_24":25,"_189":-5,"_27":526},{"_44":513,"_32":514,"_30":515,"_183":-5,"_42":43,"_41":516,"_185":25,"_39":517,"_13":220,"_34":35,"_36":518,"_24":25,"_189":-5,"_27":519},{"_44":506,"_32":507,"_30":508,"_183":-5,"_42":43,"_41":509,"_185":60,"_39":510,"_13":196,"_34":35,"_36":511,"_24":25,"_189":-5,"_27":512},{"_44":498,"_32":499,"_30":500,"_183":-5,"_42":43,"_41":501,"_185":25,"_39":502,"_13":503,"_34":35,"_36":504,"_24":25,"_189":-5,"_27":505},{"_44":490,"_32":491,"_30":492,"_183":-5,"_42":43,"_41":493,"_185":25,"_39":494,"_13":495,"_34":35,"_36":496,"_24":25,"_189":-5,"_27":497},{"_44":483,"_32":484,"_30":485,"_183":-5,"_42":43,"_41":486,"_185":60,"_39":487,"_13":303,"_34":35,"_36":488,"_24":25,"_189":-5,"_27":489},{"_44":475,"_32":476,"_30":477,"_183":-5,"_42":43,"_41":478,"_185":60,"_39":479,"_13":480,"_34":35,"_36":481,"_24":25,"_189":-5,"_27":482},{"_44":467,"_32":468,"_30":469,"_183":-5,"_42":43,"_41":470,"_185":60,"_39":471,"_13":472,"_34":35,"_36":473,"_24":25,"_189":-5,"_27":474},{"_44":460,"_32":461,"_30":462,"_183":-5,"_42":43,"_41":463,"_185":60,"_39":464,"_13":258,"_34":35,"_36":465,"_24":25,"_189":-5,"_27":466},{"_44":452,"_32":453,"_30":454,"_183":-5,"_42":43,"_41":455,"_185":60,"_39":456,"_13":457,"_34":35,"_36":458,"_24":25,"_189":-5,"_27":459},{"_44":445,"_32":446,"_30":447,"_183":-5,"_42":43,"_41":448,"_185":60,"_39":449,"_13":220,"_34":35,"_36":450,"_24":25,"_189":-5,"_27":451},{"_44":438,"_32":439,"_30":440,"_183":-5,"_42":43,"_41":441,"_185":60,"_39":442,"_13":64,"_34":35,"_36":443,"_24":25,"_189":-5,"_27":444},{"_44":431,"_32":432,"_30":433,"_183":-5,"_42":43,"_41":434,"_185":60,"_39":435,"_13":326,"_34":35,"_36":436,"_24":25,"_189":-5,"_27":437},{"_44":424,"_32":425,"_30":426,"_183":-5,"_42":43,"_41":427,"_185":60,"_39":428,"_13":220,"_34":35,"_36":429,"_24":25,"_189":-5,"_27":430},{"_44":416,"_32":417,"_30":418,"_183":-5,"_42":43,"_41":419,"_185":25,"_39":420,"_13":421,"_34":35,"_36":422,"_24":25,"_189":-5,"_27":423},{"_44":408,"_32":409,"_30":410,"_183":-5,"_42":43,"_41":411,"_185":25,"_39":412,"_13":413,"_34":35,"_36":414,"_24":25,"_189":-5,"_27":415},{"_44":401,"_32":402,"_30":403,"_183":-5,"_42":43,"_41":404,"_185":60,"_39":405,"_13":334,"_34":35,"_36":406,"_24":25,"_189":-5,"_27":407},{"_44":394,"_32":395,"_30":396,"_183":-5,"_42":43,"_41":397,"_185":25,"_39":398,"_13":326,"_34":35,"_36":399,"_24":25,"_189":-5,"_27":400},{"_44":387,"_32":388,"_30":389,"_183":-5,"_42":43,"_41":390,"_185":60,"_39":391,"_13":236,"_34":35,"_36":392,"_24":25,"_189":-5,"_27":393},{"_44":380,"_32":381,"_30":382,"_183":-5,"_42":43,"_41":383,"_185":60,"_39":384,"_13":64,"_34":35,"_36":385,"_24":25,"_189":-5,"_27":386},{"_44":373,"_32":374,"_30":375,"_183":-5,"_42":43,"_41":376,"_185":60,"_39":377,"_13":64,"_34":35,"_36":378,"_24":25,"_189":-5,"_27":379},{"_44":366,"_32":367,"_30":368,"_183":-5,"_42":43,"_41":369,"_185":60,"_39":370,"_13":64,"_34":35,"_36":371,"_24":25,"_189":-5,"_27":372},{"_44":359,"_32":360,"_30":361,"_183":-5,"_42":43,"_41":362,"_185":25,"_39":363,"_13":64,"_34":35,"_36":364,"_24":25,"_189":-5,"_27":365},{"_44":352,"_32":353,"_30":354,"_183":-5,"_42":43,"_41":355,"_185":60,"_39":356,"_13":326,"_34":35,"_36":357,"_24":25,"_189":-5,"_27":358},{"_44":344,"_32":345,"_30":346,"_183":-5,"_42":43,"_41":347,"_185":60,"_39":348,"_13":349,"_34":35,"_36":350,"_24":25,"_189":-5,"_27":351},{"_44":337,"_32":338,"_30":339,"_183":-5,"_42":43,"_41":340,"_185":60,"_39":341,"_13":196,"_34":35,"_36":342,"_24":25,"_189":-5,"_27":343},{"_44":329,"_32":330,"_30":331,"_183":-5,"_42":43,"_41":332,"_185":60,"_39":333,"_13":334,"_34":35,"_36":335,"_24":25,"_189":-5,"_27":336},{"_44":321,"_32":322,"_30":323,"_183":-5,"_42":43,"_41":324,"_185":60,"_39":325,"_13":326,"_34":35,"_36":327,"_24":25,"_189":-5,"_27":328},{"_44":313,"_32":314,"_30":315,"_183":-5,"_42":43,"_41":316,"_185":25,"_39":317,"_13":318,"_34":35,"_36":319,"_24":25,"_189":-5,"_27":320},{"_44":306,"_32":307,"_30":308,"_183":-5,"_42":43,"_41":309,"_185":60,"_39":310,"_13":196,"_34":35,"_36":311,"_24":25,"_189":-5,"_27":312},{"_44":298,"_32":299,"_30":300,"_183":-5,"_42":43,"_41":301,"_185":25,"_39":302,"_13":303,"_34":35,"_36":304,"_24":25,"_189":-5,"_27":305},{"_44":291,"_32":292,"_30":293,"_183":-5,"_42":43,"_41":294,"_185":60,"_39":295,"_13":236,"_34":35,"_36":296,"_24":25,"_189":-5,"_27":297},{"_44":284,"_32":285,"_30":286,"_183":-5,"_42":43,"_41":287,"_185":60,"_39":288,"_13":220,"_34":35,"_36":289,"_24":25,"_189":-5,"_27":290},{"_44":277,"_32":278,"_30":279,"_183":-5,"_42":43,"_41":280,"_185":60,"_39":281,"_13":196,"_34":35,"_36":282,"_24":25,"_189":-5,"_27":283},{"_44":269,"_32":270,"_30":271,"_183":-5,"_42":43,"_41":272,"_185":60,"_39":273,"_13":274,"_34":35,"_36":275,"_24":25,"_189":-5,"_27":276},{"_44":261,"_32":262,"_30":263,"_183":-5,"_42":43,"_41":264,"_185":60,"_39":265,"_13":266,"_34":35,"_36":267,"_24":25,"_189":-5,"_27":268},{"_44":253,"_32":254,"_30":255,"_183":-5,"_42":43,"_41":256,"_185":60,"_39":257,"_13":258,"_34":35,"_36":259,"_24":25,"_189":-5,"_27":260},{"_44":246,"_32":247,"_30":248,"_183":-5,"_42":43,"_41":249,"_185":60,"_39":250,"_13":64,"_34":35,"_36":251,"_24":25,"_189":-5,"_27":252},{"_44":239,"_32":240,"_30":241,"_183":-5,"_42":43,"_41":242,"_185":60,"_39":243,"_13":64,"_34":35,"_36":244,"_24":25,"_189":-5,"_27":245},{"_44":231,"_32":232,"_30":233,"_183":-5,"_42":43,"_41":234,"_185":60,"_39":235,"_13":236,"_34":35,"_36":237,"_24":25,"_189":-5,"_27":238},{"_44":223,"_32":224,"_30":225,"_183":-5,"_42":43,"_41":226,"_185":60,"_39":227,"_13":228,"_34":35,"_36":229,"_24":25,"_189":-5,"_27":230},{"_44":215,"_32":216,"_30":217,"_183":-5,"_42":43,"_41":218,"_185":60,"_39":219,"_13":220,"_34":35,"_36":221,"_24":25,"_189":-5,"_27":222},{"_44":207,"_32":208,"_30":58,"_183":-5,"_42":43,"_41":209,"_185":25,"_39":210,"_13":211,"_34":212,"_36":213,"_24":25,"_189":-5,"_27":214},{"_44":199,"_32":200,"_30":201,"_183":-5,"_42":43,"_41":202,"_185":25,"_39":203,"_13":204,"_34":35,"_36":205,"_24":25,"_189":-5,"_27":206},{"_44":191,"_32":192,"_30":193,"_183":-5,"_42":43,"_41":194,"_185":25,"_39":195,"_13":196,"_34":35,"_36":197,"_24":25,"_189":-5,"_27":198},{"_44":180,"_32":181,"_30":182,"_183":-5,"_42":43,"_41":184,"_185":60,"_39":186,"_13":187,"_34":35,"_36":188,"_24":25,"_189":-5,"_27":190},"026e63e8-5d7a-11f1-a7f5-1607ee4eb77e","types.ts","151549be-56ca-11f1-bc41-ee650bb23af1","parentId",699,"latest",["D",1780291403301],16,"export interface Integration {\n id: string;\n name: string; // 'ahrefs'|'ga4'|'gsc'|'linkedin'|'outlook'|'wordpress'|'youtube'|'producthunt'\n api_key?: string;\n api_secret?: string;\n access_token?: string;\n refresh_token?: string;\n extra_config?: string; // JSON string\n connected_at?: string;\n updated_at?: string;\n}\n\nexport interface LLMConfig {\n id: string;\n // QA fix: gemini was already routed in callLLM but missing from the union, causing TS noise.\n provider: 'anthropic' | 'openai' | 'gemini' | 'custom';\n api_key: string;\n endpoint?: string;\n model: string;\n updated_at?: string;\n // Per-provider key presence flags (computed from the 4 api_key_ columns) —\n // used by Settings UI to render \"(saved)\" pills without leaking the actual key.\n has_key?: { anthropic: boolean; openai: boolean; gemini: boolean; custom: boolean };\n}\n\nexport interface Agent {\n id: string;\n name: string;\n workspace: 'marketing' | 'sales';\n description: string;\n system_prompt: string;\n tools: string; // JSON array string\n model?: string;\n enabled: number; // 0 or 1\n created_at: string;\n updated_at: string;\n created_by: 'user' | 'ai';\n // B2: budget cap (USD/month) + running spend, joined from agent_budgets\n monthly_cap?: number;\n current_spend?: number;\n}\n\nexport interface Conversation {\n id: string;\n agent_id?: string;\n workspace: string;\n messages: string; // JSON array string\n created_at: string;\n updated_at: string;\n}\n\nexport interface Task {\n id: string;\n agent_id?: string;\n workspace: string;\n title: string;\n status: 'pending' | 'running' | 'done' | 'failed';\n input?: string;\n output?: string;\n created_at: string;\n completed_at?: string;\n}\n\nexport interface ChatMessage {\n role: 'user' | 'assistant' | 'system' | 'tool';\n content: string;\n timestamp?: string;\n // Tool-use fields (OpenAI-style) carried at runtime by chat.ts / llm.ts.\n tool_calls?: any[];\n tool_call_id?: string;\n reasoning_content?: string;\n // Part 14.2: structured execution trace (round/tool/action/message steps) shown in the UI.\n trace?: Array<{ t: string; role?: string; name?: string; preview?: string; args_preview?: string; result_preview?: string; ok?: boolean; ms?: number; n?: number; ts?: string }>;\n}\n","label",[181],"55fca990-5f3a-11f1-b12a-1607ee4eb77e","schema.ts","4ad25812-5f2b-11f1-9413-1607ee4eb77e",1070,["D",1780483958033],2,"import { sqlite, DEFAULT_AGENT_SEEDS } from \"./db.ts\";\n\n// The schema setup body lives here (moved verbatim out of db.ts) to keep db.ts under\n// val.town's 80KB/file cap. db.ts lazily `import(\"./schema.ts\")`s this and calls runSchema().\nexport async function runSchema(): Promise {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS integrations (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n api_key TEXT,\n api_secret TEXT,\n access_token TEXT,\n refresh_token TEXT,\n extra_config TEXT,\n connected_at TEXT,\n updated_at TEXT,\n tenant_id TEXT,\n UNIQUE(tenant_id, name)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS llm_config (\n id TEXT PRIMARY KEY DEFAULT 'default',\n provider TEXT NOT NULL DEFAULT 'anthropic',\n api_key TEXT NOT NULL DEFAULT '',\n endpoint TEXT,\n model TEXT NOT NULL DEFAULT 'claude-sonnet-4-6',\n updated_at TEXT\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agents (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n workspace TEXT NOT NULL,\n description TEXT,\n system_prompt TEXT,\n tools TEXT DEFAULT '[]',\n model TEXT,\n enabled INTEGER DEFAULT 1,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n created_by TEXT DEFAULT 'user'\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS conversations (\n id TEXT PRIMARY KEY,\n agent_id TEXT,\n workspace TEXT NOT NULL,\n messages TEXT DEFAULT '[]',\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )\n `);\n\n // F4 migration: the original tasks table (TEXT id, agent_id, input/output) is replaced by\n // the framework-layer tasks schema (INTEGER id, ICE fields, OKR/experiment links). If a\n // legacy table exists, rename it so the new CREATE further down can build the right shape.\n try {\n const cols = await sqlite.execute(\"PRAGMA table_info(tasks)\");\n const have = new Set((cols.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n // Old schema is identifiable by `agent_id` + `input` + no `priority`. New schema has `priority` + `ice_score`.\n const isLegacy = have.has(\"agent_id\") && have.has(\"input\") && !have.has(\"ice_score\");\n if (isLegacy) {\n await sqlite.execute(\"ALTER TABLE tasks RENAME TO tasks_legacy\");\n }\n } catch { /* table doesn't exist yet — fine, new CREATE will run */ }\n\n // Co-working: shared notes for team collaboration on strategies.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS notes (\n id TEXT PRIMARY KEY,\n author TEXT,\n content TEXT NOT NULL,\n workspace TEXT,\n pinned INTEGER DEFAULT 0,\n created_at TEXT NOT NULL,\n updated_at TEXT\n )\n `);\n\n // Intelligence layer: per-metric 30d baselines used for health scoring.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS metric_baselines (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n integration TEXT NOT NULL,\n metric_key TEXT NOT NULL,\n baseline_value REAL,\n baseline_period TEXT DEFAULT '30d',\n last_updated TEXT DEFAULT (datetime('now')),\n UNIQUE(integration, metric_key)\n )\n `);\n\n // Intelligence cache — funnel summary, correlations, recommendations, LLM-generated feed.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS intelligence_cache (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n cache_key TEXT UNIQUE NOT NULL,\n payload TEXT NOT NULL,\n generated_at TEXT DEFAULT (datetime('now')),\n expires_at TEXT NOT NULL\n )\n `);\n\n // App-wide key/value config: ROI inputs (avg_deal_size, est_marketing_spend),\n // workspace preferences (ultra_density, translucency, hardware_accel, etc.).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS app_config (\n key TEXT PRIMARY KEY,\n value TEXT,\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // Metric history — rolling timeseries for delta_7d / delta_30d computations.\n // Pruned to last 60 days on insert to keep size bounded.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS metric_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n integration TEXT NOT NULL,\n metric_key TEXT NOT NULL,\n value REAL NOT NULL,\n recorded_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_metric_history_key ON metric_history(integration, metric_key, recorded_at DESC)`);\n\n // A5: rolling baseline columns — added on existing metric_baselines tables via\n // PRAGMA-guarded ALTER so we never fail on re-run.\n try {\n const cols = await sqlite.execute(\"PRAGMA table_info(metric_baselines)\");\n const have = new Set((cols.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!have.has(\"rolling_avg\")) {\n await sqlite.execute(\"ALTER TABLE metric_baselines ADD COLUMN rolling_avg REAL\");\n }\n if (!have.has(\"sample_count\")) {\n await sqlite.execute(\"ALTER TABLE metric_baselines ADD COLUMN sample_count INTEGER DEFAULT 0\");\n }\n } catch { /* non-critical: warm-start baselines still work */ }\n\n // QA fix: per-provider key columns on llm_config so switching providers doesn't\n // overwrite the previous provider's key. PRAGMA-guarded ALTER (re-run safe).\n try {\n const cols = await sqlite.execute(\"PRAGMA table_info(llm_config)\");\n const have = new Set((cols.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n for (const col of [\"api_key_anthropic\", \"api_key_openai\", \"api_key_gemini\", \"api_key_custom\"]) {\n if (!have.has(col)) await sqlite.execute(`ALTER TABLE llm_config ADD COLUMN ${col} TEXT DEFAULT ''`);\n }\n if (!have.has(\"endpoint_custom\")) {\n await sqlite.execute(\"ALTER TABLE llm_config ADD COLUMN endpoint_custom TEXT DEFAULT ''\");\n }\n } catch { /* non-critical: legacy single-key still works */ }\n\n // Agent budget tracking — real monthly LLM-cost cap per agent.\n // current_spend incremented on each LLM call, reset at period_start rollover.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_budgets (\n agent_id TEXT PRIMARY KEY,\n monthly_cap REAL DEFAULT 250,\n current_spend REAL DEFAULT 0,\n period_start TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // C3: agent execution log. One row per run (manual or scheduled). Latest 50 power the\n // AgentCard timeline. status: queued → running → completed | failed | cancelled.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_runs (\n id TEXT PRIMARY KEY,\n agent_id TEXT NOT NULL,\n status TEXT NOT NULL,\n trigger TEXT DEFAULT 'manual',\n started_at TEXT DEFAULT (datetime('now')),\n finished_at TEXT,\n duration_ms INTEGER,\n input TEXT,\n output TEXT,\n error TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_agent_runs_agent ON agent_runs(agent_id, started_at DESC)`);\n\n // D1: customer cohorts. One row per cohort (e.g. signup month). Powers cohort-survival LTV\n // beyond the simple avg_deal × retention_months heuristic. retention_curve is a JSON array\n // [m1, m2, m3 ...] of retained customer counts. arpu = average revenue per user (monthly).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS customer_cohorts (\n id TEXT PRIMARY KEY,\n cohort_label TEXT NOT NULL,\n cohort_size INTEGER NOT NULL,\n arpu REAL NOT NULL,\n retention_curve TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // D3: lead state changes — every MQL→SQL transition gets a row so we can compute\n // engagement velocity (avg days lead spent in each stage).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS lead_state_changes (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n lead_email TEXT NOT NULL,\n from_state TEXT,\n to_state TEXT NOT NULL,\n changed_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_lead_state_email ON lead_state_changes(lead_email, changed_at)`);\n\n // D5: utm_conversions — channel attribution log. Populated when a conversion fires\n // (manually pushed via POST /api/attribution or scraped from GA4 in a later phase).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS utm_conversions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n utm_source TEXT,\n utm_medium TEXT,\n utm_campaign TEXT,\n conversion_value REAL DEFAULT 0,\n converted_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_utm_source ON utm_conversions(utm_source, converted_at DESC)`);\n\n // ─── FRAMEWORK LAYER (F1-F4): NSM, OKRs, Experiments, Tasks ─────────────────\n\n // F1: North Star Metric (singleton — only one active row; previous deleted on set)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS north_star (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n metric_name TEXT NOT NULL,\n metric_source TEXT NOT NULL,\n metric_key TEXT,\n current_value REAL,\n target_value REAL NOT NULL,\n target_date TEXT NOT NULL,\n unit TEXT DEFAULT 'count',\n description TEXT,\n set_at TEXT DEFAULT (datetime('now')),\n set_by TEXT DEFAULT 'admin'\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS nsm_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n nsm_id INTEGER REFERENCES north_star(id) ON DELETE CASCADE,\n value REAL NOT NULL,\n recorded_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_nsm_history_id ON nsm_history(nsm_id, recorded_at DESC)`);\n\n // F2: OKRs (Objectives + Key Results)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS objectives (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL,\n description TEXT,\n quarter TEXT NOT NULL,\n workspace TEXT DEFAULT 'marketing',\n owner TEXT,\n status TEXT DEFAULT 'active',\n progress REAL DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS key_results (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n objective_id INTEGER NOT NULL REFERENCES objectives(id) ON DELETE CASCADE,\n title TEXT NOT NULL,\n metric_source TEXT,\n metric_key TEXT,\n start_value REAL DEFAULT 0,\n current_value REAL DEFAULT 0,\n target_value REAL NOT NULL,\n unit TEXT DEFAULT 'count',\n confidence REAL DEFAULT 0.5,\n progress REAL DEFAULT 0,\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_kr_objective ON key_results(objective_id)`);\n\n // F3: ICE Experiments (ice_score + uplift_pct computed in app code — sqlite GENERATED\n // column support is uneven; safer to project them client-side from impact/confidence/ease).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS experiments (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL,\n hypothesis TEXT,\n objective_id INTEGER REFERENCES objectives(id) ON DELETE SET NULL,\n funnel_stage TEXT,\n aarrr_lever TEXT,\n status TEXT DEFAULT 'idea',\n impact REAL DEFAULT 5,\n confidence REAL DEFAULT 5,\n ease REAL DEFAULT 5,\n owner TEXT,\n start_date TEXT,\n end_date TEXT,\n channel TEXT,\n success_metric TEXT,\n baseline_value REAL,\n result_value REAL,\n outcome TEXT,\n learnings TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_exp_status ON experiments(status, updated_at DESC)`);\n\n // F4: Tasks (linked to OKRs / KRs / experiments — at least one for governance).\n // NOTE: the gap-closure prompt also referred to a \"tasks\" table — the older one (string id,\n // status enum 'pending|running|done|failed') is replaced by this richer schema. The two\n // were never wired to a shared UI so the swap is safe.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL,\n description TEXT,\n status TEXT DEFAULT 'todo',\n priority TEXT DEFAULT 'medium',\n workspace TEXT DEFAULT 'marketing',\n assignee TEXT,\n due_date TEXT,\n objective_id INTEGER REFERENCES objectives(id) ON DELETE SET NULL,\n key_result_id INTEGER REFERENCES key_results(id) ON DELETE SET NULL,\n experiment_id INTEGER REFERENCES experiments(id) ON DELETE SET NULL,\n ice_score REAL,\n impact REAL,\n confidence REAL,\n ease REAL,\n tags TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n completed_at TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_tasks_status ON tasks(status, due_date)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_tasks_links ON tasks(experiment_id, key_result_id, objective_id)`);\n\n // OKR→Campaign→Task link: a task can belong to a campaign (the higher-level container).\n // Completing the task rolls progress up through the campaign to its objective. PRAGMA-guarded\n // ALTER so existing tasks tables gain the column without failing on re-run.\n try {\n const tc = await sqlite.execute(\"PRAGMA table_info(tasks)\");\n const tHave = new Set((tc.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!tHave.has(\"campaign_id\")) await sqlite.execute(\"ALTER TABLE tasks ADD COLUMN campaign_id TEXT\");\n } catch { /* non-critical: tasks without a campaign link still work */ }\n\n // ─── INTELLIGENCE LAYER EXTENSIONS (I1, I4): Signals + Digests ──────────────\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS intent_signals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n lead_email TEXT NOT NULL,\n lead_name TEXT,\n company TEXT,\n signal_type TEXT NOT NULL,\n signal_source TEXT NOT NULL,\n signal_strength INTEGER DEFAULT 1,\n raw_data TEXT,\n detected_at TEXT DEFAULT (datetime('now')),\n actioned INTEGER DEFAULT 0,\n actioned_at TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_signals_email ON intent_signals(lead_email, detected_at DESC)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_signals_actioned ON intent_signals(actioned, detected_at DESC)`);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS growth_digests (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n week_of TEXT NOT NULL,\n payload TEXT NOT NULL,\n nsm_value_at_generation REAL,\n generated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_digest_week ON growth_digests(week_of DESC)`);\n\n // ─── UNIFIED CALENDAR (CAL1): standalone custom calendar entries ────────────\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS calendar_entries (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL,\n description TEXT,\n event_date TEXT NOT NULL,\n event_time TEXT,\n end_date TEXT,\n end_time TEXT,\n event_type TEXT DEFAULT 'custom',\n workspace TEXT DEFAULT 'marketing',\n color TEXT DEFAULT 'blue',\n all_day INTEGER DEFAULT 0,\n recurrence TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_calendar_date ON calendar_entries(event_date)`);\n\n // Knowledge files — growth playbooks/frameworks/formulas injected into AI features (see api/knowledge.ts).\n // This table was missing from initDB, so the knowledge UI + /api/knowledge endpoints failed (\"no such table\").\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS knowledge_files (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n kind TEXT DEFAULT 'playbook',\n content TEXT NOT NULL,\n summary TEXT,\n targets TEXT DEFAULT '[]',\n source TEXT DEFAULT 'user',\n tokens_estimate INTEGER DEFAULT 0,\n enabled INTEGER DEFAULT 1,\n uploaded_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_knowledge_enabled ON knowledge_files(enabled, uploaded_at DESC)`);\n\n // Action queue — human-in-the-loop execution. The AI/agents PREPARE external actions\n // (send email, publish post, post to LinkedIn, create calendar event) here; nothing is\n // sent until a human approves, at which point the integration call runs and the result\n // is recorded. status: prepared → approved → executing → done | failed | rejected.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS action_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n source_type TEXT DEFAULT 'chat',\n source_id TEXT,\n integration TEXT NOT NULL,\n endpoint TEXT NOT NULL,\n payload TEXT NOT NULL,\n preview TEXT,\n title TEXT,\n workspace TEXT DEFAULT 'marketing',\n status TEXT DEFAULT 'prepared',\n result TEXT,\n task_id TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n approved_at TEXT,\n executed_at TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_action_queue_status ON action_queue(status, created_at DESC)`);\n\n // CRM: sales pipeline deals. Hybrid model — rows are auto-seeded from qualified leads\n // (getLeadScores) via POST /api/deals/sync AND can be created/edited/dragged by the user.\n // stage ∈ lead | qualified | proposal | negotiation | won | lost. lead_email links a deal back\n // to its source lead so the detail view can show that contact's intent_signals as activity.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS deals (\n id TEXT PRIMARY KEY,\n title TEXT,\n company TEXT,\n contact_name TEXT,\n contact_email TEXT,\n stage TEXT NOT NULL DEFAULT 'lead',\n amount REAL DEFAULT 0,\n currency TEXT DEFAULT 'USD',\n probability INTEGER DEFAULT 0,\n owner TEXT,\n close_date TEXT,\n source TEXT DEFAULT 'manual',\n lead_email TEXT,\n notes TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n last_activity_at TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_deals_stage ON deals(stage, updated_at DESC)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_deals_lead ON deals(lead_email)`);\n\n // ─── RELATIONAL CRM FOUNDATION (WAVE 1): Accounts + Contacts ────────────────\n // First-class company (accounts) and person (contacts) records. Deals link to them via\n // account_id + primary_contact_id, plus a many-to-many deal_contacts join (role per contact).\n // Backfilled NON-DESTRUCTIVELY from the legacy deals.company/contact_name/contact_email text\n // columns by the mig_crm_relational_v1 migration below. All tenant-scoped (tenant_id on every\n // row; every query filters/sets it). The legacy deal text columns are KEPT for back-compat.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS accounts (\n id TEXT PRIMARY KEY,\n name TEXT,\n domain TEXT,\n industry TEXT,\n size TEXT,\n website TEXT,\n owner TEXT,\n tags TEXT DEFAULT '[]',\n custom_fields TEXT DEFAULT '{}',\n notes TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_accounts_name ON accounts(tenant_id, name)`);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS contacts (\n id TEXT PRIMARY KEY,\n account_id TEXT,\n first_name TEXT,\n last_name TEXT,\n email TEXT,\n phone TEXT,\n title TEXT,\n owner TEXT,\n tags TEXT DEFAULT '[]',\n custom_fields TEXT DEFAULT '{}',\n notes TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_contacts_email ON contacts(tenant_id, email)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_contacts_account ON contacts(tenant_id, account_id)`);\n\n // Many-to-many: a deal can involve several contacts, each with a buying-committee role\n // (decision_maker | champion | influencer | user | contact; the migration uses \"primary\"\n // for the deal's primary_contact_id). Composite PK prevents duplicate links.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS deal_contacts (\n deal_id TEXT NOT NULL,\n contact_id TEXT NOT NULL,\n role TEXT DEFAULT 'contact',\n tenant_id TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n PRIMARY KEY (deal_id, contact_id)\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_deal_contacts_contact ON deal_contacts(tenant_id, contact_id)`);\n\n // deals gains account_id + primary_contact_id (guarded ALTER, re-run safe). The legacy\n // company/contact_name/contact_email columns are intentionally KEPT for back-compat.\n try {\n const dc = await sqlite.execute(\"PRAGMA table_info(deals)\");\n const dHave = new Set((dc.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!dHave.has(\"account_id\")) await sqlite.execute(\"ALTER TABLE deals ADD COLUMN account_id TEXT\");\n if (!dHave.has(\"primary_contact_id\")) await sqlite.execute(\"ALTER TABLE deals ADD COLUMN primary_contact_id TEXT\");\n } catch { /* non-critical: relational links added next warm start */ }\n\n // ─── ENGAGEMENT + PIPELINE DEPTH (WAVE 2): Activities + Line Items + Stages ──\n // Unified activity timeline (logged calls/meetings/notes/emails/tasks) attachable to a\n // contact, account, and/or deal. The getTimeline() feed MERGES these rows with intent_signals\n // (by contact email) and linked tasks. All tenant-scoped (tenant_id on every row).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS activities (\n id TEXT PRIMARY KEY,\n type TEXT,\n subject TEXT,\n body TEXT,\n contact_id TEXT,\n account_id TEXT,\n deal_id TEXT,\n owner TEXT,\n due_date TEXT,\n completed INTEGER DEFAULT 0,\n occurred_at TEXT,\n created_at TEXT,\n updated_at TEXT,\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_activities_deal ON activities(tenant_id, deal_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_activities_contact ON activities(tenant_id, contact_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_activities_account ON activities(tenant_id, account_id)`);\n\n // Deal LINE ITEMS — products/services on a deal. The deal amount rolls up as SUM(amount) when\n // line items exist (else the manual deals.amount is kept). amount is persisted = quantity * unit_price.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS deal_products (\n id TEXT PRIMARY KEY,\n deal_id TEXT,\n name TEXT,\n quantity REAL DEFAULT 1,\n unit_price REAL DEFAULT 0,\n amount REAL DEFAULT 0,\n tenant_id TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_deal_products_deal ON deal_products(tenant_id, deal_id)`);\n\n // Configurable PIPELINE STAGES (label + win-probability per stage). Seeded once below with the\n // 6 existing stages so deal stage probabilities/labels become editable per tenant.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS pipeline_stages (\n id TEXT PRIMARY KEY,\n stage_key TEXT,\n label TEXT,\n probability INTEGER,\n sort_order INTEGER,\n is_won INTEGER DEFAULT 0,\n is_lost INTEGER DEFAULT 0,\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_pipeline_stages_tenant ON pipeline_stages(tenant_id, sort_order)`);\n\n // deals gains next_step + win/loss REASONS + recurring/MRR (guarded ALTER, re-run safe).\n try {\n const d2 = await sqlite.execute(\"PRAGMA table_info(deals)\");\n const d2Have = new Set((d2.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n for (const [col, def] of [\n [\"next_step\", \"TEXT\"], [\"win_reason\", \"TEXT\"], [\"lost_reason\", \"TEXT\"],\n [\"recurring_type\", \"TEXT\"], [\"mrr\", \"REAL DEFAULT 0\"],\n ] as Array<[string, string]>) {\n if (!d2Have.has(col)) await sqlite.execute(`ALTER TABLE deals ADD COLUMN ${col} ${def}`);\n }\n } catch { /* non-critical: deal next-step/reasons/MRR added next warm start */ }\n\n // tasks gains CRM links (deal_id / contact_id / account_id) so an existing Task can be a CRM\n // follow-up attached to a deal/contact/account — preserves ALL current task behavior.\n try {\n const t2 = await sqlite.execute(\"PRAGMA table_info(tasks)\");\n const t2Have = new Set((t2.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n for (const col of [\"deal_id\", \"contact_id\", \"account_id\"]) {\n if (!t2Have.has(col)) await sqlite.execute(`ALTER TABLE tasks ADD COLUMN ${col} TEXT`);\n }\n } catch { /* non-critical: CRM task links added next warm start */ }\n\n // ONE-TIME seed of the 6 default pipeline stages, gated by app_config \"mig_pipeline_stages_v1\".\n // Seeds for every tenant that already has pipeline_stages-eligible data (any present tenant_id\n // across tenants) OR at least the default tenant. Idempotent: INSERT OR IGNORE on a deterministic\n // id (tenant + stage_key) + an existence check, so a re-run never duplicates rows.\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_pipeline_stages_v1'\");\n if (flag.rows.length === 0) {\n const STAGE_SEEDS: Array<[string, string, number, number, number, number]> = [\n // stage_key, label, probability, sort_order, is_won, is_lost\n [\"lead\", \"Lead\", 10, 0, 0, 0],\n [\"qualified\", \"Qualified\", 30, 1, 0, 0],\n [\"proposal\", \"Proposal\", 50, 2, 0, 0],\n [\"negotiation\", \"Negotiation\", 70, 3, 0, 0],\n [\"won\", \"Won\", 100, 4, 1, 0],\n [\"lost\", \"Lost\", 0, 5, 0, 1],\n ];\n // Collect the set of tenants to seed: every distinct tenant on the tenants table, always\n // including t_default. Falls back to just t_default if the tenants table is empty/missing.\n const tenantIds = new Set([\"t_default\"]);\n try {\n const tns = await sqlite.execute(\"SELECT id FROM tenants\");\n for (const r of (tns.rows || [])) {\n const tid = String(Array.isArray(r) ? r[0] : (r as any).id ?? \"\").trim();\n if (tid) tenantIds.add(tid);\n }\n } catch { /* tenants table may not exist on a very fresh DB — default tenant still seeded */ }\n for (const tid of tenantIds) {\n for (const [key, label, prob, sort, isWon, isLost] of STAGE_SEEDS) {\n await sqlite.execute(\n `INSERT OR IGNORE INTO pipeline_stages (id, stage_key, label, probability, sort_order, is_won, is_lost, tenant_id)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\"ps_\" + tid + \"_\" + key, key, label, prob, sort, isWon, isLost, tid]\n );\n }\n }\n await sqlite.execute(\n \"INSERT OR REPLACE INTO app_config (key, value, tenant_id, updated_at) VALUES ('mig_pipeline_stages_v1', 'done', 't_default', datetime('now'))\"\n );\n }\n } catch { /* non-critical: stage seed retried next warm start (flag only set on success) */ }\n\n // ─── SALES ANALYTICS + LEAD OPS + PRODUCTIVITY (WAVE 3) ─────────────────────\n // Eight new tenant-scoped tables overlaid on the existing deals/contacts/intent_signals/users\n // foundation. All carry tenant_id on every row (every query filters/sets it) and are also added\n // to TENANT_SCOPED_TABLES below so the mig_tenant_v1 backfill covers them on legacy DBs.\n\n // A) SALES ANALYTICS ────────────────────────────────────────────────────────\n // deal_stage_history: one row per deal stage change (deals.ts logs it). Powers stage-conversion,\n // deal-velocity (time in stage), and the funnel/leaderboard analytics.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS deal_stage_history (\n id TEXT PRIMARY KEY,\n deal_id TEXT,\n from_stage TEXT,\n to_stage TEXT,\n owner TEXT,\n changed_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_deal_stage_history_deal ON deal_stage_history(tenant_id, deal_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_deal_stage_history_to ON deal_stage_history(tenant_id, to_stage)`);\n\n // sales_quotas: per-owner revenue target for a period. period_type ∈ month|quarter|year; period is\n // the label (e.g. 2026-Q2 or 2026-06). Powers quota-attainment (won vs target).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sales_quotas (\n id TEXT PRIMARY KEY,\n owner TEXT,\n period TEXT,\n period_type TEXT,\n target_amount REAL DEFAULT 0,\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_sales_quotas_owner ON sales_quotas(tenant_id, owner, period)`);\n\n // pipeline_snapshots: one row PER STAGE per snapshot_date (point-in-time pipeline state). Powers\n // pipeline trend over time. weighted_amount = total_amount × stage probability at capture time.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS pipeline_snapshots (\n id TEXT PRIMARY KEY,\n snapshot_date TEXT,\n stage TEXT,\n deal_count INTEGER DEFAULT 0,\n total_amount REAL DEFAULT 0,\n weighted_amount REAL DEFAULT 0,\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_pipeline_snapshots_date ON pipeline_snapshots(tenant_id, snapshot_date)`);\n\n // B) LEAD OPS ─────────────────────────────────────────────────────────────────\n // lead_status: grade/owner/SLA overlay keyed by lead_email (one row per lead per tenant). grade ∈\n // A|B|C|D; status ∈ new|working|qualified|disqualified. sla_due_at = first-response deadline,\n // first_response_at = when the SLA clock was stopped. Indexed (tenant_id, lead_email) for upsert.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS lead_status (\n id TEXT PRIMARY KEY,\n lead_email TEXT,\n grade TEXT,\n owner TEXT,\n status TEXT DEFAULT 'new',\n first_response_at TEXT,\n sla_due_at TEXT,\n assigned_at TEXT,\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n // UNIQUE so the one-row-per-(tenant,lead) overlay can't be duplicated by a concurrent grade/assign race.\n await sqlite.execute(`CREATE UNIQUE INDEX IF NOT EXISTS idx_lead_status_email ON lead_status(tenant_id, lead_email)`);\n\n // C) PRODUCTIVITY ─────────────────────────────────────────────────────────────\n // email_templates: reusable subject/body with {{merge_field}} placeholders; rendered then handed\n // to the existing Gmail/Outlook draft path.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS email_templates (\n id TEXT PRIMARY KEY,\n name TEXT,\n subject TEXT,\n body TEXT,\n category TEXT,\n owner TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_email_templates_tenant ON email_templates(tenant_id, category)`);\n\n // sequences: a named multi-step cadence (active=1 by default).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sequences (\n id TEXT PRIMARY KEY,\n name TEXT,\n description TEXT,\n active INTEGER DEFAULT 1,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_sequences_tenant ON sequences(tenant_id, active)`);\n\n // sequence_steps: ordered steps of a sequence. channel ∈ email|task|call. delay_days = wait after\n // the prior step. template_id optionally references an email_templates row; else inline subject/body.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sequence_steps (\n id TEXT PRIMARY KEY,\n sequence_id TEXT,\n step_order INTEGER DEFAULT 0,\n channel TEXT DEFAULT 'email',\n delay_days INTEGER DEFAULT 0,\n template_id TEXT,\n subject TEXT,\n body TEXT,\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_sequence_steps_seq ON sequence_steps(tenant_id, sequence_id, step_order)`);\n\n // sequence_enrollments: a contact (and optionally deal) enrolled in a sequence. current_step is the\n // 0-based pointer; status ∈ active|paused|completed; next_action_at drives the cadence runner.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sequence_enrollments (\n id TEXT PRIMARY KEY,\n sequence_id TEXT,\n contact_id TEXT,\n deal_id TEXT,\n current_step INTEGER DEFAULT 0,\n status TEXT DEFAULT 'active',\n enrolled_at TEXT DEFAULT (datetime('now')),\n next_action_at TEXT,\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_seq_enroll_seq ON sequence_enrollments(tenant_id, sequence_id, status)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_seq_enroll_contact ON sequence_enrollments(tenant_id, contact_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_seq_enroll_next ON sequence_enrollments(tenant_id, next_action_at)`);\n\n // ─── MARKETING WORKSPACE (WAVE 1) ─────────────────────────────────────────\n // Persona/ICP/segment library for the Marketing Audiences view. kind ∈ icp|persona|segment;\n // attributes is a JSON blob; source ∈ enrichment|manual (importPersonasFromEnrichment writes\n // 'enrichment' rows non-destructively). All tenant-scoped (tenant_id on every row).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS marketing_personas (\n id TEXT PRIMARY KEY,\n name TEXT,\n kind TEXT,\n description TEXT,\n attributes TEXT,\n source TEXT DEFAULT 'manual',\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_marketing_personas_kind ON marketing_personas(tenant_id, kind)`);\n\n // utm_links: saved campaign-tagged URLs for the UTM builder. full_url is the composed\n // base_url + utm params. All tenant-scoped (tenant_id on every row).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS utm_links (\n id TEXT PRIMARY KEY,\n name TEXT,\n base_url TEXT,\n utm_source TEXT,\n utm_medium TEXT,\n utm_campaign TEXT,\n utm_term TEXT,\n utm_content TEXT,\n full_url TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_utm_links_tenant ON utm_links(tenant_id)`);\n\n // brand_kit: one row per tenant (upsert) — voice/tone/values/dos/donts/boilerplate plus a JSON\n // palette and logo_url for the Brand Kit editor. tenant_id on every row.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS brand_kit (\n id TEXT PRIMARY KEY,\n voice TEXT,\n tone TEXT,\n brand_values TEXT,\n dos TEXT,\n donts TEXT,\n boilerplate TEXT,\n palette TEXT,\n logo_url TEXT,\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_brand_kit_tenant ON brand_kit(tenant_id)`);\n\n // ─── MARKETING CAPTURE + AUDIENCES (WAVE 2) ─────────────────────────────────\n // Six new tenant-scoped tables giving Marketing a place to CONVERT traffic (forms +\n // landing pages) and people to TARGET (segments + lists). All carry tenant_id on every\n // row (every query filters/sets it) EXCEPT the two PUBLIC read paths, which resolve the\n // owning tenant explicitly by id/slug. Added to TENANT_SCOPED_TABLES below so the\n // mig_tenant_v1 backfill covers them on legacy DBs. NEVER name a column with a SQL\n // reserved word (e.g. values/order/group) — a prior bug came from exactly that.\n\n // marketing_forms: a lead-capture form definition. fields is JSON [{name,label,type,required}].\n // asset_url = gated lead-magnet download; redirect_url = post-submit redirect. submit_count is\n // bumped on each public submission (by the form-owning tenant).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS marketing_forms (\n id TEXT PRIMARY KEY,\n name TEXT,\n fields TEXT,\n success_message TEXT,\n asset_url TEXT,\n redirect_url TEXT,\n submit_count INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_marketing_forms_tenant ON marketing_forms(tenant_id)`);\n\n // form_submissions: one row per public submit. data is JSON of the raw posted fields.\n // tenant_id is the OWNING tenant of form_id (resolved by id at submit time — never the\n // anonymous caller's session). Indexed (tenant_id, form_id) for the submissions table.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS form_submissions (\n id TEXT PRIMARY KEY,\n form_id TEXT,\n data TEXT,\n lead_email TEXT,\n lead_name TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_form_submissions_form ON form_submissions(tenant_id, form_id)`);\n\n // landing_pages: a public landing page. slug is GLOBALLY unique (used for the public\n // /api/marketing/p/:slug render across tenants). blocks is JSON [{type,...}]. form_id\n // optionally embeds a marketing_forms form. published=1 gates the public render; view_count\n // is bumped on each public view (by the page-owning tenant).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS landing_pages (\n id TEXT PRIMARY KEY,\n slug TEXT,\n title TEXT,\n subtitle TEXT,\n blocks TEXT,\n form_id TEXT,\n theme TEXT,\n published INTEGER DEFAULT 0,\n view_count INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_landing_pages_tenant ON landing_pages(tenant_id)`);\n // slug is GLOBALLY unique (public render resolves a page by slug across all tenants).\n await sqlite.execute(`CREATE UNIQUE INDEX IF NOT EXISTS idx_landing_pages_slug ON landing_pages(slug)`);\n\n // segments: a saved audience definition. kind ∈ dynamic|static. rules is JSON\n // [{field,op,value}] evaluated over contacts + lead_status + intent_signals within the tenant.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS segments (\n id TEXT PRIMARY KEY,\n name TEXT,\n description TEXT,\n kind TEXT,\n rules TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_segments_tenant ON segments(tenant_id)`);\n\n // marketing_lists: a named contact list. kind ∈ static|dynamic. For dynamic lists, segment_id\n // references the segment whose rules materialize the membership.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS marketing_lists (\n id TEXT PRIMARY KEY,\n name TEXT,\n kind TEXT,\n segment_id TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_marketing_lists_tenant ON marketing_lists(tenant_id)`);\n\n // list_members: membership join (a contact in a list). lead_email is the stable key when a\n // contact_id is unavailable. Indexed (tenant_id, list_id) for the members view.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS list_members (\n id TEXT PRIMARY KEY,\n list_id TEXT,\n contact_id TEXT,\n lead_email TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_list_members_list ON list_members(tenant_id, list_id)`);\n\n // ─── CONTENT + CAMPAIGN PRODUCTION ENGINE (WAVE 3) ──────────────────────────\n // Four new tenant-scoped tables powering the editorial calendar, SEO briefs, asset\n // library, and campaign budgeting/performance. All carry tenant_id on every row (every\n // query filters/sets it) and are added to TENANT_SCOPED_TABLES below so the mig_tenant_v1\n // backfill covers them on legacy DBs. NEVER name a column with a SQL reserved word.\n\n // content_items: a piece of marketing content moving through the pipeline. type ∈\n // blog|social|video|email|landing|ad; status ∈ idea|brief|draft|review|scheduled|published.\n // campaign_id links to campaigns; brief_id links to content_briefs; asset_ids is JSON of\n // marketing_assets ids. scheduled_at drives the editorial calendar; body holds the draft.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS content_items (\n id TEXT PRIMARY KEY,\n title TEXT,\n type TEXT,\n status TEXT DEFAULT 'idea',\n channel TEXT,\n campaign_id TEXT,\n brief_id TEXT,\n body TEXT,\n asset_ids TEXT DEFAULT '[]',\n owner TEXT,\n scheduled_at TEXT,\n published_at TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_content_items_status ON content_items(tenant_id, status)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_content_items_scheduled ON content_items(tenant_id, scheduled_at)`);\n\n // content_briefs: an SEO brief backing a content_item. outline/competitors/internal_links are\n // JSON or free text; word_count_target is the writer's target. content_id links back to the item.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS content_briefs (\n id TEXT PRIMARY KEY,\n content_id TEXT,\n target_keyword TEXT,\n search_intent TEXT,\n outline TEXT,\n competitors TEXT,\n internal_links TEXT,\n word_count_target INTEGER,\n notes TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_content_briefs_tenant ON content_briefs(tenant_id)`);\n\n // marketing_assets: the media/asset registry. asset_type ∈ image|video|doc|pdf|other;\n // source ∈ upload|wordpress|drive|link; tags is JSON or CSV; bytes is the file size.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS marketing_assets (\n id TEXT PRIMARY KEY,\n name TEXT,\n url TEXT,\n asset_type TEXT,\n tags TEXT,\n source TEXT DEFAULT 'upload',\n bytes INTEGER,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_marketing_assets_tenant ON marketing_assets(tenant_id)`);\n\n // campaign_budgets: planned vs actual spend per channel per period for a campaign. period is a\n // label (e.g. 2026-Q2 or 2026-06). actual_amount accrues as spend is recorded; powers pacing.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS campaign_budgets (\n id TEXT PRIMARY KEY,\n campaign_id TEXT,\n channel TEXT,\n period TEXT,\n planned_amount REAL DEFAULT 0,\n actual_amount REAL DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_campaign_budgets_campaign ON campaign_budgets(tenant_id, campaign_id)`);\n\n // ─── ACQUISITION CHANNELS + AUTOMATION DEPTH (WAVE 4) ───────────────────────\n // Six new tenant-scoped tables: paid media (ad_campaigns), triggered automation\n // (journeys + journey_runs), account-based marketing (abm_targets), email broadcasts\n // (broadcasts), and partner/referral channels (partners). All carry tenant_id on every\n // row (every query filters/sets it) and are added to TENANT_SCOPED_TABLES below so the\n // mig_tenant_v1 backfill covers them on legacy DBs. NEVER name a column with a SQL\n // reserved word — all column names here are non-reserved (e.g. no values/order/group).\n\n // ad_campaigns: paid-media spend rows. platform ∈ google_ads|meta|linkedin|other. external_id is\n // the platform's own campaign id; campaign_id links to an internal campaigns row. period is a label\n // (e.g. 2026-Q2 or 2026-06). Real data only — manual entry or (future) connected creds. Indexed\n // (tenant_id, platform) for the per-platform table.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ad_campaigns (\n id TEXT PRIMARY KEY,\n platform TEXT,\n external_id TEXT,\n name TEXT,\n status TEXT,\n spend REAL DEFAULT 0,\n impressions INTEGER DEFAULT 0,\n clicks INTEGER DEFAULT 0,\n conversions INTEGER DEFAULT 0,\n campaign_id TEXT,\n period TEXT,\n synced_at TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_ad_campaigns_platform ON ad_campaigns(tenant_id, platform)`);\n\n // journeys: triggered-automation rules. trigger_type ∈ form_submit|intent_signal|deal_stage|\n // list_added|manual; trigger_config is JSON matched against the runtime ctx. action_type ∈\n // enroll_sequence|add_to_list|create_task|notify|grade_lead; action_config is JSON for the action.\n // active=1 gates execution; run_count bumps on each match. Indexed (tenant_id, trigger_type, active)\n // for the runtime lookup in runJourneyTriggers.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS journeys (\n id TEXT PRIMARY KEY,\n name TEXT,\n description TEXT,\n trigger_type TEXT,\n trigger_config TEXT,\n action_type TEXT,\n action_config TEXT,\n active INTEGER DEFAULT 1,\n run_count INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_journeys_trigger ON journeys(tenant_id, trigger_type, active)`);\n\n // journey_runs: execution log. One row per journey evaluation. trigger_type mirrors the journey's;\n // entity_ref is the triggering entity (e.g. lead_email or deal_id). status ∈ matched|acted|skipped|\n // error; detail holds a short outcome message. Indexed (tenant_id, journey_id) for the run log.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS journey_runs (\n id TEXT PRIMARY KEY,\n journey_id TEXT,\n trigger_type TEXT,\n entity_ref TEXT,\n status TEXT,\n detail TEXT,\n ran_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_journey_runs_journey ON journey_runs(tenant_id, journey_id)`);\n\n // abm_targets: account-based marketing target accounts. account_id links to a CRM accounts row.\n // tier ∈ 1|2|3 (stored as text); engagement_score computed from real signals/activities/deals.\n // status ∈ target|engaged|opportunity|won|dropped. Indexed (tenant_id, account_id) for upsert/board.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS abm_targets (\n id TEXT PRIMARY KEY,\n account_id TEXT,\n tier TEXT,\n engagement_score REAL DEFAULT 0,\n status TEXT DEFAULT 'target',\n owner TEXT,\n notes TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_abm_targets_account ON abm_targets(tenant_id, account_id)`);\n\n // broadcasts: one-off/scheduled email sends. audience_type ∈ list|segment|all_contacts; audience_id\n // references the chosen list/segment (NULL for all_contacts). channel ∈ gmail|outlook. status ∈\n // draft|scheduled|sending|sent. sent_count accrues as the send resolves. Indexed (tenant_id, status).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS broadcasts (\n id TEXT PRIMARY KEY,\n name TEXT,\n subject TEXT,\n body TEXT,\n audience_type TEXT,\n audience_id TEXT,\n channel TEXT,\n status TEXT DEFAULT 'draft',\n scheduled_at TEXT,\n sent_count INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_broadcasts_status ON broadcasts(tenant_id, status)`);\n\n // partners: referral/affiliate/reseller/agency channel partners. type ∈ referral|affiliate|reseller|\n // agency. referral_code is the code carried on a referred deal/contact source. status ∈ active|paused.\n // deals_referred + revenue accrue from referral attribution. Indexed (tenant_id).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS partners (\n id TEXT PRIMARY KEY,\n name TEXT,\n type TEXT,\n contact_email TEXT,\n referral_code TEXT,\n status TEXT DEFAULT 'active',\n deals_referred INTEGER DEFAULT 0,\n revenue REAL DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_partners_tenant ON partners(tenant_id)`);\n\n // ── Wave 5: analytics / optimization / market-intel layer ──\n // competitors — tracked rival domains. metrics is a JSON snapshot (domain_rating/backlinks/\n // ref_domains/organic_keywords) refreshed from the Ahrefs integration. tracked_keywords is a\n // JSON array. Tenant-scoped, indexed (tenant_id).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS competitors (\n id TEXT PRIMARY KEY,\n name TEXT,\n domain TEXT,\n notes TEXT,\n tracked_keywords TEXT,\n metrics TEXT,\n last_checked TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_competitors_tenant ON competitors(tenant_id)`);\n\n // cro_tests — conversion-rate-optimization tests linking an experiment + a landing_page.\n // status ∈ draft|running|complete. winner names the winning arm once resolved. Results read\n // from the linked experiment (stat-significance reused from api/experiments.ts). Indexed\n // (tenant_id, status).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS cro_tests (\n id TEXT PRIMARY KEY,\n name TEXT,\n hypothesis TEXT,\n experiment_id INTEGER,\n landing_page_id TEXT,\n status TEXT DEFAULT 'draft',\n winner TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_cro_tests_tenant ON cro_tests(tenant_id, status)`);\n\n // market_digests — caches the AI market-intel digest. summary is the synthesized text; signals\n // is a JSON list of the real sources used (ProductHunt/YouTube/intent_signals/competitor metrics).\n // Indexed (tenant_id).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS market_digests (\n id TEXT PRIMARY KEY,\n period TEXT,\n summary TEXT,\n signals TEXT,\n generated_at TEXT DEFAULT (datetime('now')),\n tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_market_digests_tenant ON market_digests(tenant_id)`);\n\n // I3: agents.role column for Listener/Topic/Creator/Analyst/General roles (ALTER guarded)\n try {\n const ac = await sqlite.execute(\"PRAGMA table_info(agents)\");\n const aHave = new Set((ac.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!aHave.has(\"role\")) await sqlite.execute(\"ALTER TABLE agents ADD COLUMN role TEXT DEFAULT 'general'\");\n } catch { /* non-critical */ }\n\n // Part 15.3: persistent business memory (evolving learned facts). Additive on v551.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS memory (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n type TEXT DEFAULT 'fact',\n content TEXT NOT NULL,\n source TEXT DEFAULT 'manual',\n confidence REAL DEFAULT 0.7,\n pinned INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // Part 1: skills (marketing playbooks) STATE table — enabled/pinned + custom skills.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS skills (\n name TEXT PRIMARY KEY,\n enabled INTEGER DEFAULT 1,\n pinned INTEGER DEFAULT 0,\n source TEXT DEFAULT 'builtin',\n category TEXT,\n description TEXT,\n body TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // Part 3 fix 7: experiment significance + sample_size (PRAGMA-guarded ALTER).\n try {\n const ec = await sqlite.execute(\"PRAGMA table_info(experiments)\");\n const eHave = new Set((ec.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!eHave.has(\"sample_size\")) await sqlite.execute(\"ALTER TABLE experiments ADD COLUMN sample_size INTEGER\");\n if (!eHave.has(\"significance\")) await sqlite.execute(\"ALTER TABLE experiments ADD COLUMN significance REAL\");\n } catch { /* non-critical */ }\n\n // Part 14.2: agent_runs.trace JSON column (structured TraceStep[]).\n try {\n const rc = await sqlite.execute(\"PRAGMA table_info(agent_runs)\");\n const rHave = new Set((rc.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!rHave.has(\"trace\")) await sqlite.execute(\"ALTER TABLE agent_runs ADD COLUMN trace TEXT\");\n } catch { /* non-critical */ }\n\n // Multi-agent CAMPAIGNS — the higher-level container the user wants: a campaign has many\n // inputs + MANY member agents that cooperate. A campaign RUN is the Director orchestrating\n // its member agents (sequential handoff or parallel) and synthesizing a final output.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS campaigns (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n workspace TEXT NOT NULL DEFAULT 'marketing',\n description TEXT,\n goal TEXT,\n channel TEXT,\n audience TEXT,\n mode TEXT DEFAULT 'sequential',\n status TEXT DEFAULT 'active',\n objective_id INTEGER,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')),\n created_by TEXT DEFAULT 'user'\n )\n `);\n // Ordered membership: which agents are in the campaign + their pipeline order + role.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS campaign_agents (\n campaign_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n sequence INTEGER DEFAULT 0,\n role TEXT,\n PRIMARY KEY (campaign_id, agent_id)\n )\n `);\n // One coordinated pipeline execution (the Director run).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS campaign_runs (\n id TEXT PRIMARY KEY,\n campaign_id TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'running',\n input TEXT,\n final_output TEXT,\n trace TEXT,\n started_at TEXT DEFAULT (datetime('now')),\n finished_at TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_campaign_runs ON campaign_runs(campaign_id, started_at DESC)`);\n // Campaign TRIGGERS + LOOP (run continuously, not just on/off). trigger_type: manual | interval\n // | schedule | event. trigger_config: JSON (e.g. {minutes:60} or {event:\"new_lead\"}). loop=1 ⇒\n // reschedule after each run. next_run_at drives the cron-based runner. (Guarded ALTER, re-run safe.)\n try {\n const cc = await sqlite.execute(\"PRAGMA table_info(campaigns)\");\n const cHave = new Set((cc.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n for (const [col, def] of [[\"trigger_type\", \"TEXT DEFAULT 'manual'\"], [\"trigger_config\", \"TEXT\"], [\"next_run_at\", \"TEXT\"], [\"last_run_at\", \"TEXT\"], [\"loop\", \"INTEGER DEFAULT 0\"]] as Array<[string, string]>) {\n if (!cHave.has(col)) await sqlite.execute(`ALTER TABLE campaigns ADD COLUMN ${col} ${def}`);\n }\n } catch { /* non-critical */ }\n // agent_runs gains campaign context: which campaign run + the handed-off context from prior agents.\n try {\n const arc = await sqlite.execute(\"PRAGMA table_info(agent_runs)\");\n const arHave = new Set((arc.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!arHave.has(\"campaign_run_id\")) await sqlite.execute(\"ALTER TABLE agent_runs ADD COLUMN campaign_run_id TEXT\");\n if (!arHave.has(\"received_input\")) await sqlite.execute(\"ALTER TABLE agent_runs ADD COLUMN received_input TEXT\");\n // task_id links an agent_run back to the task it executed (POST /api/tasks/:id/run).\n if (!arHave.has(\"task_id\")) await sqlite.execute(\"ALTER TABLE agent_runs ADD COLUMN task_id TEXT\");\n } catch { /* non-critical */ }\n\n // ─── AUTH / MULTI-TENANCY FOUNDATION ───────────────────────────────────────\n // New auth tables. These have NO tenant_id (they ARE the tenant/identity layer).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS tenants (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n slug TEXT UNIQUE,\n plan TEXT DEFAULT 'trial',\n status TEXT DEFAULT 'active',\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS users (\n id TEXT PRIMARY KEY,\n email TEXT UNIQUE NOT NULL,\n name TEXT,\n password_hash TEXT,\n avatar_url TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n last_login_at TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS memberships (\n tenant_id TEXT NOT NULL,\n user_id TEXT NOT NULL,\n role TEXT DEFAULT 'owner',\n created_at TEXT DEFAULT (datetime('now')),\n PRIMARY KEY (tenant_id, user_id)\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY,\n user_id TEXT NOT NULL,\n tenant_id TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now')),\n expires_at TEXT,\n user_agent TEXT,\n revoked INTEGER DEFAULT 0\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_sessions_user ON sessions(user_id)`);\n\n // Phase D: read-only impersonation (\"view as tenant\"). A platform admin toggles this flag on\n // THEIR OWN session row; resolveSessionToken then redirects currentTenantId() to this target\n // tenant for reads only (all writes blocked by the main.ts guard). NULL = not impersonating.\n // PRAGMA-guarded ALTER (idempotent, re-run safe — same pattern as the other ALTERs above).\n try {\n const sc = await sqlite.execute(\"PRAGMA table_info(sessions)\");\n const sHave = new Set((sc.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!sHave.has(\"impersonate_tenant_id\")) await sqlite.execute(\"ALTER TABLE sessions ADD COLUMN impersonate_tenant_id TEXT\");\n } catch { /* non-critical: impersonation disabled until column exists; added next warm start */ }\n\n // ─── PLATFORM SUPERADMIN LAYER (above tenants) ─────────────────────────────\n // The single, audited exception to per-tenant isolation: a platform owner who can read\n // ACROSS all tenants. users gains is_platform_admin (the master flag) + status (active/…).\n // PRAGMA-guarded ALTERs (idempotent, re-run safe — same pattern as the other ALTERs above).\n try {\n const uc = await sqlite.execute(\"PRAGMA table_info(users)\");\n const uHave = new Set((uc.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (!uHave.has(\"is_platform_admin\")) await sqlite.execute(\"ALTER TABLE users ADD COLUMN is_platform_admin INTEGER DEFAULT 0\");\n if (!uHave.has(\"status\")) await sqlite.execute(\"ALTER TABLE users ADD COLUMN status TEXT DEFAULT 'active'\");\n } catch { /* non-critical: master flag set by migration below on next warm start */ }\n\n // platform_audit — append-only log of every master-only action (suspend/delete/impersonate in\n // LATER phases). Created now so the audit surface exists from the start. No tenant_id: it spans\n // all tenants by design (this is the cross-tenant exception).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS platform_audit (\n id TEXT PRIMARY KEY,\n actor_user_id TEXT,\n actor_email TEXT,\n action TEXT,\n target_type TEXT,\n target_id TEXT,\n detail TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // tenant_id column on EVERY existing business table. PRAGMA-guarded ALTER (idempotent, same\n // pattern used for other ALTERs above). Do NOT add to tenants/users/memberships/sessions.\n const TENANT_SCOPED_TABLES = [\n \"integrations\", \"llm_config\", \"agents\", \"conversations\", \"tasks\", \"tasks_legacy\",\n \"notes\", \"metric_baselines\", \"intelligence_cache\", \"app_config\", \"metric_history\",\n \"agent_budgets\", \"agent_runs\", \"customer_cohorts\", \"lead_state_changes\", \"utm_conversions\",\n \"north_star\", \"nsm_history\", \"objectives\", \"key_results\", \"experiments\", \"intent_signals\",\n \"growth_digests\", \"calendar_entries\", \"knowledge_files\", \"action_queue\", \"deals\", \"memory\",\n \"skills\", \"campaigns\", \"campaign_agents\", \"campaign_runs\",\n \"accounts\", \"contacts\", \"deal_contacts\",\n \"activities\", \"deal_products\", \"pipeline_stages\",\n \"deal_stage_history\", \"sales_quotas\", \"pipeline_snapshots\", \"lead_status\",\n \"email_templates\", \"sequences\", \"sequence_steps\", \"sequence_enrollments\",\n \"marketing_personas\", \"utm_links\", \"brand_kit\",\n \"marketing_forms\", \"form_submissions\", \"landing_pages\",\n \"segments\", \"marketing_lists\", \"list_members\",\n \"content_items\", \"content_briefs\", \"marketing_assets\", \"campaign_budgets\",\n \"ad_campaigns\", \"journeys\", \"journey_runs\", \"abm_targets\", \"broadcasts\", \"partners\",\n ];\n for (const tbl of TENANT_SCOPED_TABLES) {\n try {\n const cols = await sqlite.execute(`PRAGMA table_info(${tbl})`);\n const have = new Set((cols.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n // Only ALTER if the table actually exists (PRAGMA returns 0 cols for missing tables) and lacks tenant_id.\n if (have.size > 0 && !have.has(\"tenant_id\")) {\n await sqlite.execute(`ALTER TABLE ${tbl} ADD COLUMN tenant_id TEXT`);\n }\n } catch { /* non-critical: table may not exist yet (e.g. tasks_legacy) */ }\n }\n\n // ONE-TIME backfill + seed, gated by app_config \"mig_tenant_v1\" so it runs once. Backfill\n // every business table's tenant_id to \"t_default\" and insert the default tenant row. Owner\n // user creation is left to api/auth.ts bootstrapOwner (no password seeded here).\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_tenant_v1'\");\n if (flag.rows.length === 0) {\n for (const tbl of TENANT_SCOPED_TABLES) {\n try {\n const cols = await sqlite.execute(`PRAGMA table_info(${tbl})`);\n const have = new Set((cols.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n if (have.has(\"tenant_id\")) {\n await sqlite.execute(`UPDATE ${tbl} SET tenant_id = 't_default' WHERE tenant_id IS NULL`);\n }\n } catch { /* non-critical: skip missing tables */ }\n }\n await sqlite.execute(\n \"INSERT OR IGNORE INTO tenants (id, name, slug) VALUES ('t_default', 'Default Workspace', 'default')\"\n );\n // NOTE: app_config now has tenant_id; write the migration flag scoped to t_default so the\n // gate read above (no tenant filter) still finds it on subsequent boots.\n await sqlite.execute(\n \"INSERT OR REPLACE INTO app_config (key, value, tenant_id, updated_at) VALUES ('mig_tenant_v1', 'done', 't_default', datetime('now'))\"\n );\n }\n } catch { /* non-critical: migration retried next warm start */ }\n\n // ─── PLATFORM MASTER PROMOTION (mig_platform_admin_v1) ──────────────────────\n // ONE-TIME: promote the platform owner (PLATFORM_OWNER_EMAIL env, default the bootstrapped\n // master) to is_platform_admin=1. Gated by app_config \"mig_platform_admin_v1\" so it runs once.\n // api/auth.ts bootstrapOwner ALSO sets the flag at signup time; this covers the already-existing\n // master row. Idempotent: re-running the UPDATE is harmless even if the flag write ever fails.\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_platform_admin_v1'\");\n if (flag.rows.length === 0) {\n const masterEmail = (Deno.env.get(\"PLATFORM_OWNER_EMAIL\") || \"\").trim().toLowerCase();\n await sqlite.execute(\n \"UPDATE users SET is_platform_admin = 1 WHERE lower(email) = ?\",\n [masterEmail]\n );\n await sqlite.execute(\n \"INSERT OR REPLACE INTO app_config (key, value, tenant_id, updated_at) VALUES ('mig_platform_admin_v1', 'done', 't_default', datetime('now'))\"\n );\n }\n } catch { /* non-critical: promotion retried next warm start (flag only set on success) */ }\n\n // ─── INTEGRATIONS UNIQUENESS → PER-TENANT (mig_integrations_v2) ──────────────\n // The original integrations table has `name TEXT NOT NULL UNIQUE` (a GLOBAL unique\n // constraint). Multi-tenant needs each tenant to own its OWN 'google'/'outlook'/etc.\n // row, so uniqueness must be PER TENANT: UNIQUE(tenant_id, name). SQLite cannot ALTER a\n // UNIQUE constraint in place, so we do a ONE-TIME guarded table rebuild gated by an\n // app_config flag (\"mig_integrations_v2\"). Idempotent + safe on the live DB: we only\n // rebuild when the flag is absent AND the live table still carries the global UNIQUE(name)\n // index. By this point Stage 1's ALTER + backfill guarantee every existing integrations\n // row already has tenant_id='t_default', so the copy preserves correct ownership.\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_integrations_v2'\");\n if (flag.rows.length === 0) {\n // Confirm the table exists before rebuilding. A FRESH DB already gets the per-tenant\n // shape from the top-level CREATE (tenant_id present), so detect the OLD shape — the\n // global UNIQUE(name) index lacks the tenant_id column — and only rebuild then.\n const icols = await sqlite.execute(\"PRAGMA table_info(integrations)\");\n const iHave = new Set((icols.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n let needsRebuild = false;\n if (iHave.size > 0) {\n // index_list → for each unique index, index_info tells us its columns. The legacy global\n // constraint indexes only (name); the new one indexes (tenant_id, name).\n try {\n const idxList = await sqlite.execute(\"PRAGMA index_list(integrations)\");\n for (const row of (idxList.rows || [])) {\n const idxName = String(Array.isArray(row) ? row[1] : row.name);\n const idxUnique = Number(Array.isArray(row) ? row[2] : row.unique);\n if (!idxUnique) continue;\n const info = await sqlite.execute(`PRAGMA index_info(${idxName})`);\n const idxCols = (info.rows || []).map((r: any) => String(Array.isArray(r) ? r[2] : r.name));\n // Old-shape: a unique index over exactly [name] with no tenant_id ⇒ rebuild required.\n if (idxCols.includes(\"name\") && !idxCols.includes(\"tenant_id\")) needsRebuild = true;\n }\n } catch { needsRebuild = true; /* if we can't introspect, rebuild to be safe */ }\n }\n if (needsRebuild) {\n // Build v2 with the SAME columns (now including tenant_id) but UNIQUE(tenant_id, name).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS integrations_v2 (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n api_key TEXT,\n api_secret TEXT,\n access_token TEXT,\n refresh_token TEXT,\n extra_config TEXT,\n connected_at TEXT,\n updated_at TEXT,\n tenant_id TEXT,\n UNIQUE(tenant_id, name)\n )\n `);\n // Copy every row (existing rows already carry tenant_id='t_default' from Stage 1).\n await sqlite.execute(`\n INSERT OR IGNORE INTO integrations_v2\n (id, name, api_key, api_secret, access_token, refresh_token, extra_config, connected_at, updated_at, tenant_id)\n SELECT id, name, api_key, api_secret, access_token, refresh_token, extra_config, connected_at, updated_at,\n COALESCE(tenant_id, 't_default')\n FROM integrations\n `);\n await sqlite.execute(\"DROP TABLE integrations\");\n await sqlite.execute(\"ALTER TABLE integrations_v2 RENAME TO integrations\");\n }\n await sqlite.execute(\n \"INSERT OR REPLACE INTO app_config (key, value, tenant_id, updated_at) VALUES ('mig_integrations_v2', 'done', 't_default', datetime('now'))\"\n );\n }\n } catch { /* non-critical: rebuild retried next warm start (flag only set on success) */ }\n\n // ─── RELATIONAL CRM BACKFILL (mig_crm_relational_v1) ────────────────────────\n // ONE-TIME, gated by app_config \"mig_crm_relational_v1\". For EVERY existing deal, derive the\n // relational records NON-DESTRUCTIVELY from its legacy text fields:\n // • upsert an account by (tenant_id, lower(company)) [skip if company empty]\n // • upsert a contact by (tenant_id, lower(contact_email)) [skip if email empty], name from\n // contact_name, linked to that account\n // • set deal.account_id + deal.primary_contact_id, and insert a deal_contacts(role='primary') row\n // Runs at boot under the default ctx, so it is a GLOBAL pass: it reads each deal's OWN tenant_id\n // and writes the new rows carrying THAT tenant_id (never the boot ctx's). Fully idempotent —\n // existence checks + INSERT OR IGNORE — and never deletes/edits existing deal data.\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_crm_relational_v1'\");\n if (flag.rows.length === 0) {\n // Pull every deal with its own tenant_id + legacy text fields. SELECT * keeps this robust\n // regardless of column order; we read fields by name from the row object.\n const dealsRes = await sqlite.execute(\n \"SELECT id, tenant_id, company, contact_name, contact_email FROM deals\"\n );\n const dealRows = (dealsRes.rows || []) as any[];\n for (const row of dealRows) {\n // libSQL returns array OR object rows depending on driver — read defensively by index/name.\n const dealId = String(Array.isArray(row) ? row[0] : row.id ?? \"\");\n const tenantId = String((Array.isArray(row) ? row[1] : row.tenant_id) ?? \"t_default\") || \"t_default\";\n const company = String((Array.isArray(row) ? row[2] : row.company) ?? \"\").trim();\n const contactName = String((Array.isArray(row) ? row[3] : row.contact_name) ?? \"\").trim();\n const contactEmail = String((Array.isArray(row) ? row[4] : row.contact_email) ?? \"\").trim();\n if (!dealId) continue;\n\n let accountId: string | null = null;\n let contactId: string | null = null;\n\n // ── ACCOUNT upsert by (tenant_id, lower(company)) ──\n if (company) {\n const existAcct = await sqlite.execute(\n \"SELECT id FROM accounts WHERE tenant_id = ? AND lower(name) = lower(?) LIMIT 1\",\n [tenantId, company]\n );\n if (existAcct.rows.length > 0) {\n const ar = existAcct.rows[0] as any;\n accountId = String(Array.isArray(ar) ? ar[0] : ar.id);\n } else {\n accountId = crypto.randomUUID();\n await sqlite.execute(\n `INSERT INTO accounts (id, name, tags, custom_fields, created_at, updated_at, tenant_id)\n VALUES (?, ?, '[]', '{}', datetime('now'), datetime('now'), ?)`,\n [accountId, company, tenantId]\n );\n }\n }\n\n // ── CONTACT upsert by (tenant_id, lower(contact_email)) ──\n if (contactEmail) {\n const existContact = await sqlite.execute(\n \"SELECT id, account_id FROM contacts WHERE tenant_id = ? AND lower(email) = lower(?) LIMIT 1\",\n [tenantId, contactEmail]\n );\n if (existContact.rows.length > 0) {\n const cr = existContact.rows[0] as any;\n contactId = String(Array.isArray(cr) ? cr[0] : cr.id);\n const existingAcctId = Array.isArray(cr) ? cr[1] : cr.account_id;\n // Backfill the contact's account link if it has none yet and we found one here.\n if (accountId && (existingAcctId === null || existingAcctId === undefined || existingAcctId === \"\")) {\n await sqlite.execute(\n \"UPDATE contacts SET account_id = ?, updated_at = datetime('now') WHERE id = ? AND tenant_id = ?\",\n [accountId, contactId, tenantId]\n );\n }\n } else {\n // Split contact_name into first / last (first token = first name, remainder = last).\n let firstName = \"\", lastName = \"\";\n if (contactName) {\n const parts = contactName.split(/\\s+/);\n firstName = parts.shift() || \"\";\n lastName = parts.join(\" \");\n }\n contactId = crypto.randomUUID();\n await sqlite.execute(\n `INSERT INTO contacts (id, account_id, first_name, last_name, email, tags, custom_fields, created_at, updated_at, tenant_id)\n VALUES (?, ?, ?, ?, ?, '[]', '{}', datetime('now'), datetime('now'), ?)`,\n [contactId, accountId, firstName, lastName, contactEmail, tenantId]\n );\n }\n }\n\n // ── Link the deal: set account_id / primary_contact_id only if still empty (idempotent) ──\n if (accountId || contactId) {\n await sqlite.execute(\n `UPDATE deals\n SET account_id = COALESCE(NULLIF(account_id, ''), ?),\n primary_contact_id = COALESCE(NULLIF(primary_contact_id, ''), ?)\n WHERE id = ? AND tenant_id = ?`,\n [accountId, contactId, dealId, tenantId]\n );\n }\n\n // ── deal_contacts(role='primary') join row (INSERT OR IGNORE on composite PK) ──\n if (contactId) {\n await sqlite.execute(\n `INSERT OR IGNORE INTO deal_contacts (deal_id, contact_id, role, tenant_id, created_at)\n VALUES (?, ?, 'primary', ?, datetime('now'))`,\n [dealId, contactId, tenantId]\n );\n }\n }\n await sqlite.execute(\n \"INSERT OR REPLACE INTO app_config (key, value, tenant_id, updated_at) VALUES ('mig_crm_relational_v1', 'done', 't_default', datetime('now'))\"\n );\n }\n } catch { /* non-critical: relational backfill retried next warm start (flag only set on success) */ }\n\n // Seed default LLM config if not exists\n const existing = await sqlite.execute(\"SELECT id FROM llm_config WHERE id = 'default'\");\n if (existing.rows.length === 0) {\n await sqlite.execute(\n \"INSERT INTO llm_config (id, provider, api_key, model, updated_at) VALUES ('default', 'anthropic', '', 'claude-sonnet-4-6', ?)\",\n [new Date().toISOString()]\n );\n }\n\n // Demo-agent seeding disabled — starting from a clean agents table.\n // Re-enable by uncommenting the call below.\n // await seedDefaultAgents();\n}\n\nasync function seedDefaultAgents() {\n const existing = await sqlite.execute(\"SELECT id FROM agents LIMIT 1\");\n if (existing.rows.length > 0) return;\n\n const now = new Date().toISOString();\n for (const agent of DEFAULT_AGENT_SEEDS) {\n await sqlite.execute(\n `INSERT INTO agents (id, name, workspace, description, system_prompt, tools, model, enabled, created_at, updated_at, created_by)\n VALUES (?, ?, ?, ?, ?, ?, ?, 1, ?, ?, ?)`,\n [crypto.randomUUID(), agent.name, agent.workspace, agent.description, agent.system_prompt, agent.tools, agent.model, now, now, \"user\"]\n );\n }\n}\n",[192],"0cd8e370-5f15-11f1-bf54-1607ee4eb77e","router.ts","30479b74-56ca-11f1-a296-ee650bb23af1",1010,["D",1780467943919],126,"import { sqlite, initDB, DEFAULT_AGENT_SEEDS, currentRole, currentTenantId, currentCtx } from \"./db.ts\";\nimport { registerUser, loginUser, getMe, upsertOAuthUser, bootstrapOwner } from \"./api/auth.ts\";\nimport { resolveSession, sessionSetCookie, sessionClearCookie } from \"./api/session.ts\";\nimport { newOAuthState, CLEAR_OAUTH_STATE, redirectWithCookie, oauthStateValid, identityLoginStart, identityLoginCallback } from \"./api/oauth_login.ts\";\nimport { listAgents, createAgent, updateAgent, deleteAgent } from \"./api/agents.ts\";\nimport { getLLMConfig, saveLLMConfig } from \"./api/llm.ts\";\nimport { handleChat, handleChatStream, listConversations, getConversationById, deleteConversation } from \"./api/chat.ts\";\nimport { handleIntegrationProxy, getCredentials, GOOGLE_SERVICES, MICROSOFT_SCOPES, getIntegrationSchema, listDescriptorNames } from \"./api/integrations.ts\";\nimport { serveAppModule } from \"./app_modules.ts\";\nimport { getFunnelSummary, getCorrelations, getRecommendations, getLeadScores, getAIOKpis, getIntelligenceFeed } from \"./api/intelligence.ts\";\nimport { listSignals, recordSignal, actionSignal, getHotLeads, getHotLeadsCount } from \"./api/signals.ts\";\nimport { listObjectives, createObjective, updateObjective, deleteObjective, createKeyResult, updateKeyResult, getOKRDashboard, syncObjectivesFromFunnel } from \"./api/okrs.ts\";\nimport { getNSM, setNSM, recordNSMValue, getNSMProgress } from \"./api/nsm.ts\";\nimport { listCohorts, createCohort, deleteCohort, getCohortSummary, getEngagementVelocity, getAttributionSummary, recordConversion, getRetention, getRevenueModel } from \"./api/aio.ts\";\nimport { getLatestDigest, generateDigest, getDigestHistory } from \"./api/digest.ts\";\nimport { listExperiments, createExperiment, updateExperiment, deleteExperiment, runExperiment, completeExperiment, getExperimentStats, suggestICE } from \"./api/experiments.ts\";\nimport { getUnifiedCalendar, getCalendarSummary, createCalendarEntry, updateCalendarEntry, deleteCalendarEntry } from \"./api/calendar_unified.ts\";\nimport { getGraphify } from \"./api/graphify.ts\";\nimport { listTasks, createTask, updateTask, deleteTask, listIceRankedTasks, generateTasksFromSource, runTask } from \"./api/tasks.ts\";\nimport { listDeals, getDeal, createDeal, updateDeal, deleteDeal, syncDealsFromLeads, listCandidates, importDeals } from \"./api/deals.ts\";\nimport { listKnowledgeFiles, getKnowledgeFile, createKnowledgeFile, updateKnowledgeFile, deleteKnowledgeFile, summarizeKnowledgeFile, buildKnowledgeGraph, AI_FEATURES } from \"./api/knowledge.ts\";\nimport { getCompanyProfile, setCompanyProfile, getBrandContext, setBrandContext } from \"./api/company.ts\";\nimport { enrichCompanyProfile } from \"./api/company-enrichment.ts\";\nimport { listMemory, addMemory, updateMemory, deleteMemory } from \"./api/memory.ts\";\nimport { listSkills, getSkill, setSkillState, createCustomSkill } from \"./api/skills.ts\";\nimport { getMethodConfig, saveMethodConfig, getMethodsMetadata } from \"./api/method_config.ts\";\nimport { listActions, enqueueAction, getAction, approveAction, rejectAction } from \"./api/actions.ts\";\nimport { processPendingRuns } from \"./cron.ts\";\nimport { getExecutedWorkCounts } from \"./api/propagate.ts\";\nimport { listCampaigns, getCampaign, getCampaignAgents, createCampaign, deleteCampaign, listCampaignRuns, orchestrateCampaignRun, updateCampaign, setCampaignTrigger } from \"./api/campaigns.ts\";\nimport { getWorldActivity, getWorldBoard, getWorldProject } from \"./api/world.ts\";\nimport { handlePlatformRoutes } from \"./api/platform.ts\";\nimport { isCrmPath, handleCrmRoutes } from \"./api/crm_routes.ts\";\nimport { isMarketingPath, handleMarketingRoutes } from \"./api/marketing_routes.ts\";\n\nconst corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n};\n\n// App version for the data-free health probe. Prefer the val.town deploy id (DENO_DEPLOYMENT_ID\n// is set by the runtime per deploy); fall back to a hardcoded release tag when running locally.\nconst APP_VERSION = (() => {\n try { return Deno.env.get(\"DENO_DEPLOYMENT_ID\") || \"p3-s3\"; } catch { return \"p3-s3\"; }\n})();\n\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: {\n \"Content-Type\": \"application/json\",\n ...corsHeaders,\n },\n });\n}\n// JSON response that also carries a Set-Cookie header (session set/clear on auth endpoints).\nfunction jsonWithCookie(data: unknown, setCookie: string, status = 200): Response {\n const res = json(data, status);\n res.headers.append(\"Set-Cookie\", setCookie);\n return res;\n}\n// Best-effort client IP for per-IP rate limiting (val.town/Cloudflare forwarded headers).\nfunction clientIp(req: Request): string {\n return req.headers.get(\"x-forwarded-for\")?.split(\",\")[0].trim() || req.headers.get(\"cf-connecting-ip\") || \"\";\n}\n\n// Mask an integration row before returning it: NO endpoint may return secrets in cleartext\n// — only presence flags + a short masked hint.\nfunction maskIntegration(obj: any, googleConnected = false) {\n return {\n ...obj,\n connected: !!(obj.api_key || obj.access_token) ||\n (GOOGLE_SERVICES.includes(String(obj.name)) && googleConnected),\n has_api_key: !!obj.api_key,\n has_api_secret: !!obj.api_secret,\n has_access_token: !!obj.access_token,\n api_key: obj.api_key ? String(obj.api_key).slice(0, 4) + \"***\" : undefined,\n api_secret: obj.api_secret ? \"***\" : undefined,\n access_token: obj.access_token ? \"***\" : undefined,\n refresh_token: obj.refresh_token ? \"***\" : undefined,\n };\n}\n\n\nexport async function handleRequest(req: Request, url: URL): Promise {\n const { pathname } = url;\n const method = req.method;\n const tid = currentTenantId(); // tenant scope for every business query (stable within request)\n\n // CORS preflight\n if (method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders });\n }\n\n try {\n // GET /api/health — data-free liveness probe: { ok, version } (+ legacy status/timestamp).\n if (pathname === \"/api/health\" && method === \"GET\") {\n return json({ ok: true, version: APP_VERSION, status: \"ok\", timestamp: new Date().toISOString() });\n }\n\n // GET /api/health/auth - gated token verifier. Reaching this (past the main.ts gate) means the\n // APP_TOKEN is valid; the login screen uses it to confirm the password.\n if (pathname === \"/api/health/auth\" && method === \"GET\") {\n return json({ ok: true });\n }\n\n // --- Auth: email/password + session ----\n // Thin handlers — logic lives in api/auth.ts; the \"nexus_session\" cookie via api/session.ts.\n if (pathname === \"/api/auth/register\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const r = await registerUser({ email: body.email, password: body.password, name: body.name, honeypot: body.honeypot ?? body.company_url, turnstileToken: body.turnstileToken, ip: clientIp(req) });\n if (!r.ok) return json({ ok: false, error: r.error }, 400);\n return jsonWithCookie({ ok: true }, sessionSetCookie(r.ctxToken!));\n }\n if (pathname === \"/api/auth/login\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const r = await loginUser({ email: body.email, password: body.password, ip: clientIp(req) });\n if (!r.ok) return json({ ok: false, error: r.error }, 401);\n return jsonWithCookie({ ok: true }, sessionSetCookie(r.ctxToken!));\n }\n if (pathname === \"/api/auth/logout\" && method === \"POST\") {\n return jsonWithCookie({ ok: true }, sessionClearCookie());\n }\n if (pathname === \"/api/auth/me\" && method === \"GET\") {\n const ctx = await resolveSession(req);\n if (!ctx) return json({ ok: false, user: null }, 200);\n return json({ ok: true, ...(await getMe(ctx)) });\n }\n\n // GET /api/config - LLM runtime config + all app_config key/values\n if (pathname === \"/api/config\" && method === \"GET\") {\n const llmConfig = await getLLMConfig();\n const merged: Record = {\n provider: llmConfig.provider,\n model: llmConfig.model,\n has_key: (llmConfig as any).has_key,\n };\n try {\n const r = await sqlite.execute(\"SELECT key, value FROM app_config WHERE tenant_id = ?\", [tid]);\n for (const row of (r.rows || []) as any[]) {\n const k = String(row[0]);\n let v: any = row[1];\n if (typeof v === \"string\") { try { v = JSON.parse(v); } catch { /* keep raw string */ } }\n merged[k] = v;\n }\n } catch { /* app_config missing → just return LLM fields */ }\n return json(merged);\n }\n // POST /api/config - upsert arbitrary key/value into app_config (Settings toggles, ROI inputs…).\n if (pathname === \"/api/config\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const updated: Record = {};\n try {\n for (const [k, v] of Object.entries(body)) {\n if (k === \"provider\" || k === \"model\" || k === \"has_key\") continue;\n const value = typeof v === \"string\" ? v : JSON.stringify(v);\n await sqlite.execute(\n \"INSERT INTO app_config (key, value, tenant_id) VALUES (?, ?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value, tenant_id = excluded.tenant_id, updated_at = datetime('now')\",\n [k, value, tid],\n );\n updated[k] = v;\n }\n return json({ success: true, updated });\n } catch (e: any) {\n return json({ error: String(e?.message || e) }, 500);\n }\n }\n\n // --- Frontend JS module routes (table lives in app_modules.ts to keep router under 80KB) ----\n if (method === \"GET\") {\n const _moduleSrc = serveAppModule(pathname);\n if (_moduleSrc !== null) {\n return new Response(_moduleSrc, {\n headers: {\n \"Content-Type\": \"application/javascript\",\n \"Cache-Control\": \"no-cache, no-store, must-revalidate\",\n ...corsHeaders,\n },\n });\n }\n }\n\n // --- Intelligence routes ----\n if (pathname === \"/api/intelligence/funnel-summary\" && method === \"GET\") {\n const force = url.searchParams.get(\"force\") === \"1\";\n const days = parseInt(url.searchParams.get(\"days\") ?? \"30\", 10);\n return json(await getFunnelSummary(force, days));\n }\n if (pathname === \"/api/intelligence/correlations\" && method === \"GET\") {\n const force = url.searchParams.get(\"force\") === \"1\";\n return json(await getCorrelations(force));\n }\n if (pathname === \"/api/intelligence/recommendations\" && method === \"GET\") {\n return json(await getRecommendations());\n }\n if (pathname === \"/api/intelligence/leads\" && method === \"GET\") {\n return json(await getLeadScores());\n }\n if (pathname === \"/api/intelligence/kpis\" && method === \"GET\") {\n return json(await getAIOKpis());\n }\n if (pathname === \"/api/intelligence/feed\" && method === \"GET\") {\n return json(await getIntelligenceFeed());\n }\n // Execution-aware metric: how much real work was completed (tasks/experiments).\n if (pathname === \"/api/intelligence/executed-work\" && method === \"GET\") {\n const days = parseInt(url.searchParams.get(\"days\") ?? \"30\", 10);\n return json(await getExecutedWorkCounts(days));\n }\n\n // --- Signals routes ----\n if (pathname === \"/api/signals\" && method === \"GET\") {\n const actioned = url.searchParams.get(\"actioned\");\n const lead_email = url.searchParams.get(\"lead_email\") ?? undefined;\n return json(await listSignals({ lead_email, actioned: actioned === \"true\" ? true : actioned === \"false\" ? false : undefined }));\n }\n if (pathname === \"/api/signals\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (!body.lead_email || !body.signal_type) {\n return json({ error: \"lead_email and signal_type are required\" }, 400);\n }\n return json(await recordSignal(body), 201);\n }\n const signalActionMatch = pathname.match(/^\\/api\\/signals\\/([^/]+)\\/action$/);\n if (signalActionMatch && method === \"PUT\") {\n const result = await actionSignal(signalActionMatch[1]);\n return result ? json(result) : json({ error: \"Signal not found\" }, 404);\n }\n if (pathname === \"/api/signals/hot-leads\" && method === \"GET\") {\n return json(await getHotLeads());\n }\n if (pathname === \"/api/signals/hot-leads/count\" && method === \"GET\") {\n return json({ count: await getHotLeadsCount() });\n }\n\n // --- OKR / Objectives routes ----\n if (pathname === \"/api/okrs\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n return json(await listObjectives({ workspace }));\n }\n if (pathname === \"/api/okrs\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createObjective(body), 201);\n }\n if (pathname === \"/api/okrs/dashboard\" && method === \"GET\") {\n return json(await getOKRDashboard());\n }\n // Explicit funnel→OKR sync — refreshes stored KR/objective progress on demand.\n if (pathname === \"/api/okrs/sync\" && method === \"POST\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n return json(await syncObjectivesFromFunnel({ workspace }));\n }\n const okrIdMatch = pathname.match(/^\\/api\\/okrs\\/([^/]+)$/);\n if (okrIdMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n return json(await updateObjective(okrIdMatch[1], body));\n }\n if (okrIdMatch && method === \"DELETE\") {\n const ok = await deleteObjective(okrIdMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n const okrKrMatch = pathname.match(/^\\/api\\/okrs\\/([^/]+)\\/key-results$/);\n if (okrKrMatch && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createKeyResult(okrKrMatch[1], body), 201);\n }\n const krIdMatch = pathname.match(/^\\/api\\/okrs\\/key-results\\/([^/]+)$/);\n if (krIdMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n return json(await updateKeyResult(krIdMatch[1], body));\n }\n\n // --- NSM routes ----\n if (pathname === \"/api/nsm\" && method === \"GET\") {\n return json(await getNSM());\n }\n if (pathname === \"/api/nsm\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await setNSM(body));\n }\n if (pathname === \"/api/nsm/record\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n await recordNSMValue(body.value);\n return json({ success: true });\n }\n if (pathname === \"/api/nsm/progress\" && method === \"GET\") {\n return json(await getNSMProgress());\n }\n\n // --- AIO / Cohort routes ----\n if (pathname === \"/api/aio/cohorts\" && method === \"GET\") {\n return json(await listCohorts());\n }\n if (pathname === \"/api/aio/cohorts\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createCohort(body), 201);\n }\n const cohortIdMatch = pathname.match(/^\\/api\\/aio\\/cohorts\\/([^/]+)$/);\n if (cohortIdMatch && method === \"DELETE\") {\n return json({ success: await deleteCohort(cohortIdMatch[1]) });\n }\n if (pathname === \"/api/aio/cohort-summary\" && method === \"GET\") {\n return json(await getCohortSummary());\n }\n if (pathname === \"/api/aio/engagement-velocity\" && method === \"GET\") {\n return json(await getEngagementVelocity());\n }\n\n // --- Frontend-expected aliases (cohorts/attribution/key-results) ----\n if (pathname === \"/api/cohorts\" && method === \"GET\") {\n return json(await getCohortSummary());\n }\n if (pathname === \"/api/cohorts\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createCohort(body), 201);\n }\n const cohortAliasMatch = pathname.match(/^\\/api\\/cohorts\\/([^/]+)$/);\n if (cohortAliasMatch && method === \"DELETE\") {\n return json({ success: await deleteCohort(cohortAliasMatch[1]) });\n }\n if (pathname === \"/api/attribution\" && method === \"GET\") {\n return json(await getAttributionSummary());\n }\n // retention (GRR/NRR + curve) + revenue model endpoints.\n if (pathname === \"/api/intelligence/retention\" && method === \"GET\") {\n return json(await getRetention());\n }\n if (pathname === \"/api/intelligence/revenue-model\" && method === \"GET\") {\n return json(await getRevenueModel());\n }\n if (pathname === \"/api/attribution\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n await recordConversion(body);\n return json({ success: true }, 201);\n }\n const krAliasMatch = pathname.match(/^\\/api\\/key-results\\/([^/]+)$/);\n if (krAliasMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n return json(await updateKeyResult(krAliasMatch[1], body));\n }\n\n // --- Digest routes ----\n if (pathname === \"/api/digest\" && method === \"GET\") {\n return json(await getLatestDigest());\n }\n if (pathname === \"/api/digest/generate\" && method === \"POST\") {\n return json(await generateDigest());\n }\n if (pathname === \"/api/digest/history\" && method === \"GET\") {\n const limit = parseInt(url.searchParams.get(\"limit\") ?? \"10\", 10);\n return json(await getDigestHistory(limit));\n }\n\n // --- Experiments routes ----\n if (pathname === \"/api/experiments\" && method === \"GET\") {\n const status = url.searchParams.get(\"status\") ?? undefined;\n const funnel_stage = url.searchParams.get(\"stage\") ?? url.searchParams.get(\"funnel_stage\") ?? undefined;\n const aarrr_lever = url.searchParams.get(\"aarrr_lever\") ?? undefined;\n return json(await listExperiments({ status, funnel_stage, aarrr_lever }));\n }\n if (pathname === \"/api/experiments\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createExperiment(body), 201);\n }\n if (pathname === \"/api/experiments/stats\" && method === \"GET\") {\n return json(await getExperimentStats());\n }\n // suggest-ice: alias of ice-suggest (same handler).\n if ((pathname === \"/api/experiments/ice-suggest\" || pathname === \"/api/experiments/suggest-ice\") && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await suggestICE(body));\n }\n // GET /api/experiments/:id/stats — sub-resource form; getExperimentStats() is tenant-aggregate (portfolio-wide).\n // Declared before the run|complete and bare :id matchers so \"stats\" isn't read as an id.\n const expStatsMatch = pathname.match(/^\\/api\\/experiments\\/([^/]+)\\/stats$/);\n if (expStatsMatch && method === \"GET\") {\n return json(await getExperimentStats());\n }\n const expActionMatch = pathname.match(/^\\/api\\/experiments\\/([^/]+)\\/(run|complete)$/);\n if (expActionMatch && method === \"POST\") {\n const id = expActionMatch[1];\n const body = await req.json().catch(() => ({}));\n const result = expActionMatch[2] === \"run\"\n ? await runExperiment(id, Number(body.baseline_value) || 0)\n : await completeExperiment(id, {\n result_value: Number(body.result_value) || 0,\n outcome: body.outcome ?? \"inconclusive\",\n learnings: body.learnings,\n control: body.control,\n variant: body.variant,\n sample_size: body.sample_size,\n });\n return result ? json(result) : json({ error: \"Experiment not found\" }, 404);\n }\n const expIdMatch = pathname.match(/^\\/api\\/experiments\\/([^/]+)$/);\n if (expIdMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n const updated = await updateExperiment(expIdMatch[1], body);\n return updated ? json(updated) : json({ error: \"Experiment not found\" }, 404);\n }\n if (expIdMatch && method === \"DELETE\") {\n const ok = await deleteExperiment(expIdMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // --- Calendar unified route ----\n if (pathname === \"/api/calendar/unified\" && method === \"GET\") {\n const today = new Date().toISOString().slice(0, 10);\n const from = url.searchParams.get(\"from\") ?? url.searchParams.get(\"start\") ?? today;\n const to = url.searchParams.get(\"to\") ?? url.searchParams.get(\"end\") ?? from;\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n const sourcesParam = url.searchParams.getAll(\"source\");\n return json(await getUnifiedCalendar({ from, to, workspace, sources: sourcesParam.length ? sourcesParam as any : undefined }));\n }\n if (pathname === \"/api/calendar/summary\" && method === \"GET\") {\n const date = url.searchParams.get(\"date\") ?? new Date().toISOString().slice(0, 10);\n return json(await getCalendarSummary(date));\n }\n if (pathname === \"/api/calendar/entries\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createCalendarEntry(body), 201);\n }\n const calEntryMatch = pathname.match(/^\\/api\\/calendar\\/entries\\/([^/]+)$/);\n if (calEntryMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n const updated = await updateCalendarEntry(calEntryMatch[1], body);\n return updated ? json(updated) : json({ error: \"Not found\" }, 404);\n }\n if (calEntryMatch && method === \"DELETE\") {\n const ok = await deleteCalendarEntry(calEntryMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // --- Knowledge files (AI knowledge injection + graph view) ----\n if (pathname === \"/api/knowledge\" && method === \"GET\") {\n return json(await listKnowledgeFiles());\n }\n if (pathname === \"/api/knowledge\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const created = await createKnowledgeFile(body);\n return created ? json(created, 201) : json({ error: \"content required\" }, 400);\n }\n if (pathname === \"/api/knowledge/graph\" && method === \"GET\") {\n return json(await buildKnowledgeGraph());\n }\n if (pathname === \"/api/knowledge/features\" && method === \"GET\") {\n return json(AI_FEATURES);\n }\n const knSummarizeMatch = pathname.match(/^\\/api\\/knowledge\\/([^/]+)\\/summarize$/);\n if (knSummarizeMatch && method === \"POST\") {\n const summary = await summarizeKnowledgeFile(knSummarizeMatch[1]);\n const file = await getKnowledgeFile(knSummarizeMatch[1]);\n return json({ summary, tokens_estimate: file?.tokens_estimate ?? 0 });\n }\n const knIdMatch = pathname.match(/^\\/api\\/knowledge\\/([^/]+)$/);\n if (knIdMatch && method === \"GET\") {\n const f = await getKnowledgeFile(knIdMatch[1]);\n return f ? json(f) : json({ error: \"Not found\" }, 404);\n }\n if (knIdMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n const updated = await updateKnowledgeFile(knIdMatch[1], body);\n return updated ? json(updated) : json({ error: \"Not found\" }, 404);\n }\n if (knIdMatch && method === \"DELETE\") {\n const ok = await deleteKnowledgeFile(knIdMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // --- Company Profile + Brand Context (Part 15.2) — the business identity ---\n if (pathname === \"/api/company-profile\" && method === \"GET\") {\n return json(await getCompanyProfile());\n }\n if (pathname === \"/api/company-profile\" && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n return json(await setCompanyProfile(body));\n }\n if (pathname === \"/api/company-profile/enrich\" && method === \"POST\") {\n try {\n const enriched = await enrichCompanyProfile();\n return json({ enriched, message: \"AI enrichment complete — review and save.\" });\n } catch (e) {\n return json({ error: String(e?.message ?? e) }, 500);\n }\n }\n if (pathname === \"/api/brand-context\" && method === \"GET\") {\n return json({ text: await getBrandContext() });\n }\n if (pathname === \"/api/brand-context\" && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n await setBrandContext(String(body.text ?? \"\"));\n return json({ ok: true });\n }\n\n // --- Memory (Part 15.3) — persistent evolving business facts ----\n if (pathname === \"/api/memory\" && method === \"GET\") {\n return json(await listMemory());\n }\n if (pathname === \"/api/memory\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const m = await addMemory(body);\n return m ? json(m, 201) : json({ error: \"content required\" }, 400);\n }\n const memIdMatch = pathname.match(/^\\/api\\/memory\\/([0-9]+)$/);\n if (memIdMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n const m = await updateMemory(Number(memIdMatch[1]), body);\n return m ? json(m) : json({ error: \"Not found\" }, 404);\n }\n if (memIdMatch && method === \"DELETE\") {\n const ok = await deleteMemory(Number(memIdMatch[1]));\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // --- Skills (Playbooks) — marketing skill catalog + per-skill state ----\n if (pathname === \"/api/skills\" && method === \"GET\") {\n return json(await listSkills());\n }\n if (pathname === \"/api/skills\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const created = await createCustomSkill(body);\n return created.ok ? json(created, 201) : json({ error: created.error || \"invalid skill\" }, 400);\n }\n const skillNameMatch = pathname.match(/^\\/api\\/skills\\/([^/]+)$/);\n if (skillNameMatch && method === \"GET\") {\n const s = await getSkill(decodeURIComponent(skillNameMatch[1]));\n return s ? json(s) : json({ error: \"Not found\" }, 404);\n }\n if (skillNameMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n const ok = await setSkillState(decodeURIComponent(skillNameMatch[1]), body);\n return ok ? json({ ok: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // --- Method config (prioritization methodology: ICE/RICE/WSJF) ----\n if (pathname === \"/api/method-config/methods\" && method === \"GET\") {\n return json(getMethodsMetadata());\n }\n if (pathname === \"/api/method-config\" && method === \"GET\") {\n return json(await getMethodConfig());\n }\n if (pathname === \"/api/method-config\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await saveMethodConfig(body));\n }\n\n // --- Action queue (human-in-the-loop execution) ----\n if (pathname === \"/api/actions\" && method === \"GET\") {\n const status = url.searchParams.get(\"status\") ?? undefined;\n return json(await listActions(status));\n }\n if (pathname === \"/api/actions\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const created = await enqueueAction(body);\n return created ? json(created, 201) : json({ error: \"integration + endpoint required\" }, 400);\n }\n const actionApproveMatch = pathname.match(/^\\/api\\/actions\\/([^/]+)\\/approve$/);\n if (actionApproveMatch && method === \"POST\") {\n const a = await approveAction(actionApproveMatch[1]);\n return a ? json(a) : json({ error: \"Not found\" }, 404);\n }\n const actionRejectMatch = pathname.match(/^\\/api\\/actions\\/([^/]+)\\/reject$/);\n if (actionRejectMatch && method === \"POST\") {\n const a = await rejectAction(actionRejectMatch[1]);\n return a ? json(a) : json({ error: \"Not found\" }, 404);\n }\n const actionIdMatch = pathname.match(/^\\/api\\/actions\\/([^/]+)$/);\n if (actionIdMatch && method === \"GET\") {\n const a = await getAction(actionIdMatch[1]);\n return a ? json(a) : json({ error: \"Not found\" }, 404);\n }\n\n // Manual trigger for the execution engine (the interval val also calls processPendingRuns).\n if (pathname === \"/api/agents/run-pending\" && method === \"POST\") {\n const limit = parseInt(url.searchParams.get(\"limit\") ?? \"3\", 10);\n return json(await processPendingRuns(limit));\n }\n\n // GET /api/agents/activity?limit=N — cross-agent run feed; before the /api/agents/:id matchers.\n if (pathname === \"/api/agents/activity\" && method === \"GET\") {\n const limit = parseInt(url.searchParams.get(\"limit\") ?? \"20\", 10);\n const r = await sqlite.execute(\n `SELECT r.id, r.agent_id, a.name, a.workspace, r.status, r.started_at, r.finished_at, r.output\n FROM agent_runs r LEFT JOIN agents a ON a.id = r.agent_id AND a.tenant_id = ?\n WHERE r.tenant_id = ?\n ORDER BY r.started_at DESC LIMIT ?`,\n [tid, tid, limit]\n );\n return json({ activity: r.rows.map((row) => rowToObject(r.columns, row)) });\n }\n\n // --- Agent runs ----\n const agentRunsMatch = pathname.match(/^\\/api\\/agents\\/([^/]+)\\/runs$/);\n if (agentRunsMatch && method === \"GET\") {\n const agent_id = agentRunsMatch[1];\n const limit = parseInt(url.searchParams.get(\"limit\") ?? \"20\", 10);\n const result = await sqlite.execute(\n \"SELECT * FROM agent_runs WHERE agent_id = ? AND tenant_id = ? ORDER BY started_at DESC LIMIT ?\",\n [agent_id, tid, limit]\n );\n return json(result.rows.map((row) => rowToObject(result.columns, row)));\n }\n if (agentRunsMatch && method === \"POST\") {\n const agent_id = agentRunsMatch[1];\n const body = await req.json().catch(() => ({}));\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n await sqlite.execute(\n \"INSERT INTO agent_runs (id, agent_id, trigger, status, started_at, tenant_id) VALUES (?, ?, ?, ?, ?, ?)\",\n [id, agent_id, body.trigger ?? \"manual\", \"pending\", now, tid]\n );\n // App-level automation (no cron): run the queued job in-request. Fire-and-forget; status='running' claim guards dupes.\n processPendingRuns(1).catch(() => {});\n return json({ id, agent_id, trigger: body.trigger ?? \"manual\", status: \"pending\", started_at: now }, 201);\n }\n\n // Integrations routes\n // GET /api/integrations - list all integrations\n if (pathname === \"/api/integrations\" && method === \"GET\") {\n const result = await sqlite.execute(\"SELECT * FROM integrations WHERE tenant_id = ? ORDER BY name ASC\", [tid]);\n const rows = result.rows.map((row) => rowToObject(result.columns, row));\n // Google-family services inherit the central 'google' OAuth token, so they are \"connected\"\n // whenever google is — even without their own api_key/access_token row.\n const googleConnected = rows.some((o) => o.name === \"google\" && o.access_token);\n const integrations = rows.map((obj) => maskIntegration(obj, googleConnected));\n return json(integrations);\n }\n\n // POST /api/integrations/:name - upsert integration credentials\n const integrationUpsertMatch = pathname.match(/^\\/api\\/integrations\\/([^/]+)$/);\n if (integrationUpsertMatch && method === \"POST\") {\n const name = integrationUpsertMatch[1];\n const body = await req.json().catch(() => ({}));\n const now = new Date().toISOString();\n\n const existing = await sqlite.execute(\n \"SELECT id, api_key, api_secret, access_token, refresh_token, extra_config FROM integrations WHERE name = ? AND tenant_id = ?\",\n [name, tid]\n );\n\n // Keep the existing secret when the incoming value is blank/missing/masked (\"***\"),\n // so saving the masked Settings form does not wipe stored credentials.\n const keepSecret = (incoming: any, current: any) => {\n if (incoming == null) return current ?? null;\n const s = String(incoming);\n if (s === \"\" || s.includes(\"***\")) return current ?? null;\n return incoming;\n };\n\n if (existing.rows.length > 0) {\n const cur = existing.rows[0] as any[]; // [id, api_key, api_secret, access_token, refresh_token, extra_config]\n await sqlite.execute(\n `UPDATE integrations SET\n api_key = ?,\n api_secret = ?,\n access_token = ?,\n refresh_token = ?,\n extra_config = ?,\n updated_at = ?\n WHERE name = ? AND tenant_id = ?`,\n [\n keepSecret(body.api_key, cur[1]),\n keepSecret(body.api_secret, cur[2]),\n keepSecret(body.access_token, cur[3]),\n keepSecret(body.refresh_token, cur[4]),\n body.extra_config != null ? JSON.stringify(body.extra_config) : (cur[5] ?? null),\n now,\n name,\n tid,\n ]\n );\n } else {\n // Insert\n const id = crypto.randomUUID();\n await sqlite.execute(\n `INSERT INTO integrations (id, name, api_key, api_secret, access_token, refresh_token, extra_config, connected_at, updated_at, tenant_id)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n name,\n body.api_key ?? null,\n body.api_secret ?? null,\n body.access_token ?? null,\n body.refresh_token ?? null,\n body.extra_config != null ? JSON.stringify(body.extra_config) : null,\n now,\n now,\n tid,\n ]\n );\n }\n\n const updated = await sqlite.execute(\n \"SELECT * FROM integrations WHERE name = ? AND tenant_id = ?\",\n [name, tid]\n );\n const raw = rowToObject(updated.columns, updated.rows[0]);\n // NEVER return the just-saved secrets in cleartext — mask like the list endpoint.\n const googleConnected = raw.name === \"google\"\n ? !!raw.access_token\n : !!(await getCredentials(\"google\"))?.access_token;\n return json({ success: true, integration: maskIntegration(raw, googleConnected) });\n }\n\n // DELETE /api/integrations/:name\n const integrationDeleteMatch = pathname.match(/^\\/api\\/integrations\\/([^/]+)$/);\n if (integrationDeleteMatch && method === \"DELETE\") {\n const name = integrationDeleteMatch[1];\n await sqlite.execute(\"DELETE FROM integrations WHERE name = ? AND tenant_id = ?\", [name, tid]);\n return json({ success: true, message: `Integration '${name}' deleted` });\n }\n\n // Part 13: GET /api/integrations/:name/schema — descriptor-generated action/trigger schema\n // (UI form fields + AI tool hints). null when the integration is still hand-written.\n const integrationSchemaMatch = pathname.match(/^\\/api\\/integrations\\/([^/]+)\\/schema$/);\n if (integrationSchemaMatch && method === \"GET\") {\n const schema = getIntegrationSchema(integrationSchemaMatch[1]);\n return schema ? json(schema) : json({ error: \"no descriptor for this integration yet\", descriptor_integrations: listDescriptorNames() }, 404);\n }\n\n // GET|POST /api/integrations/:name/data - proxy to integration API\n const integrationDataMatch = pathname.match(/^\\/api\\/integrations\\/([^/]+)\\/data$/);\n if (integrationDataMatch && (method === \"GET\" || method === \"POST\")) {\n const name = integrationDataMatch[1];\n const credentials = await getCredentials(name);\n if (!credentials) {\n return json({ error: `Integration '${name}' not found or not configured` }, 404);\n }\n return handleIntegrationProxy(req, name, url.searchParams, credentials);\n }\n\n // Agents routes\n // GET /api/agents - list agents (optional ?workspace= query param)\n if (pathname === \"/api/agents\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n const agents = await listAgents(workspace);\n return json(agents);\n }\n\n // POST /api/agents - create agent\n if (pathname === \"/api/agents\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const agent = await createAgent(body);\n return json(agent, 201);\n }\n\n // PUT /api/agents/:id - update agent\n const agentUpdateMatch = pathname.match(/^\\/api\\/agents\\/([^/]+)$/);\n if (agentUpdateMatch && method === \"PUT\") {\n const id = agentUpdateMatch[1];\n const body = await req.json().catch(() => ({}));\n const agent = await updateAgent(id, body);\n if (!agent) {\n return json({ error: `Agent '${id}' not found` }, 404);\n }\n return json(agent);\n }\n\n // DELETE /api/agents/:id - delete agent\n const agentDeleteMatch = pathname.match(/^\\/api\\/agents\\/([^/]+)$/);\n if (agentDeleteMatch && method === \"DELETE\") {\n const id = agentDeleteMatch[1];\n const deleted = await deleteAgent(id);\n if (!deleted) {\n return json({ error: `Agent '${id}' not found` }, 404);\n }\n return json({ success: true, message: `Agent '${id}' deleted` });\n }\n\n // LLM config routes\n // GET /api/llm/config - get LLM config (mask api_key)\n if (pathname === \"/api/llm/config\" && method === \"GET\") {\n const config = await getLLMConfig();\n if (!config) {\n return json({ error: \"LLM config not found\" }, 404);\n }\n // Mask api_key: show first 8 chars + ***\n const masked = {\n ...config,\n api_key: config.api_key\n ? config.api_key.slice(0, 8) + \"***\"\n : \"\",\n };\n return json(masked);\n }\n\n // POST /api/llm/config - save LLM config\n if (pathname === \"/api/llm/config\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const config = await saveLLMConfig(body);\n // Mask api_key in response\n const masked = {\n ...config,\n api_key: config.api_key\n ? config.api_key.slice(0, 8) + \"***\"\n : \"\",\n };\n return json(masked);\n }\n\n // Chat route\n // POST /api/chat - AI chat handler\n if (pathname === \"/api/chat\" && method === \"POST\") {\n return handleChat(req);\n }\n\n // POST /api/chat/stream - SSE streaming chat\n if (pathname === \"/api/chat/stream\" && method === \"POST\") {\n return handleChatStream(req);\n }\n\n // --- Conversation history routes ----\n if (pathname === \"/api/conversations\" && method === \"GET\") {\n return json(await listConversations());\n }\n const convIdMatch = pathname.match(/^\\/api\\/conversations\\/([^/]+)$/);\n if (convIdMatch && method === \"GET\") {\n const conv = await getConversationById(convIdMatch[1]);\n return conv ? json(conv) : json({ error: \"Not found\" }, 404);\n }\n if (convIdMatch && method === \"DELETE\") {\n const ok = await deleteConversation(convIdMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // Tasks routes\n // GET /api/tasks - list tasks (optional ?workspace= query param)\n if (pathname === \"/api/tasks\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n const status = url.searchParams.get(\"status\") ?? undefined;\n return json(await listTasks({ workspace, status }));\n }\n\n // POST /api/tasks - create task\n if (pathname === \"/api/tasks\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createTask(body), 201);\n }\n\n // GET /api/tasks/ice - ICE-ranked backlog (sorted by ICE score desc).\n // Declared before the /api/tasks/:id matchers so \"ice\" isn't read as an id.\n if (pathname === \"/api/tasks/ice\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n const limit = parseInt(url.searchParams.get(\"limit\") ?? \"50\", 10);\n return json(await listIceRankedTasks({ workspace, limit }));\n }\n\n // POST /api/tasks/generate - LLM-plan tasks from an experiment/KR/objective/campaign.\n if (pathname === \"/api/tasks/generate\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (!body.source_type || !body.source_id) {\n return json({ error: \"source_type and source_id are required\" }, 400);\n }\n return json(await generateTasksFromSource(body), 201);\n }\n\n // POST /api/tasks/:id/run - execute the task with an agent (sub-resource; before the bare :id matchers).\n const taskRunMatch = pathname.match(/^\\/api\\/tasks\\/([^/]+)\\/run$/);\n if (taskRunMatch && method === \"POST\") {\n const result = await runTask(taskRunMatch[1]);\n if (!result.task) return json({ error: result.error || \"Not found\" }, 404);\n return json(result);\n }\n\n // PUT /api/tasks/:id - update task (e.g. toggle status)\n const taskUpdateMatch = pathname.match(/^\\/api\\/tasks\\/([^/]+)$/);\n if (taskUpdateMatch && method === \"PUT\") {\n const id = taskUpdateMatch[1];\n const body = await req.json().catch(() => ({}));\n const updated = await updateTask(id, body);\n if (!updated) return json({ error: \"Not found\" }, 404);\n return json(updated);\n }\n\n // DELETE /api/tasks/:id - delete task\n const taskDeleteMatch = pathname.match(/^\\/api\\/tasks\\/([^/]+)$/);\n if (taskDeleteMatch && method === \"DELETE\") {\n const ok = await deleteTask(taskDeleteMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // --- Relational CRM (accounts + contacts + deal↔contact links) ----\n // Delegate to api/crm_routes.ts; tenant context is already set by main.ts. Kept thin to stay under the 80KB file limit.\n if (isCrmPath(pathname)) return handleCrmRoutes(req, url, method);\n if (isMarketingPath(pathname)) return handleMarketingRoutes(req, url, method);\n\n // --- CRM Deals (sales pipeline) ----\n if (pathname === \"/api/deals\" && method === \"GET\") {\n return json(await listDeals(url.searchParams.get(\"stage\") ?? undefined));\n }\n if (pathname === \"/api/deals\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createDeal(body), 201);\n }\n // Seed deals from qualified leads (explicit; checked before the :id matcher).\n if (pathname === \"/api/deals/sync\" && method === \"POST\") {\n return json(await syncDealsFromLeads());\n }\n // Interactive import: candidate leads to review, then import the selected emails.\n if (pathname === \"/api/deals/candidates\" && method === \"GET\") {\n return json(await listCandidates());\n }\n if (pathname === \"/api/deals/import\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await importDeals(Array.isArray(body.emails) ? body.emails : []));\n }\n const dealIdMatch = pathname.match(/^\\/api\\/deals\\/([^/]+)$/);\n if (dealIdMatch && dealIdMatch[1] !== \"sync\" && method === \"GET\") {\n const d = await getDeal(dealIdMatch[1]);\n return d ? json(d) : json({ error: \"Not found\" }, 404);\n }\n if (dealIdMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n const updated = await updateDeal(dealIdMatch[1], body);\n return updated ? json(updated) : json({ error: \"Not found\" }, 404);\n }\n if (dealIdMatch && method === \"DELETE\") {\n const ok = await deleteDeal(dealIdMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // --- Data export (CSV) ----\n if (pathname === \"/api/export/signals\" && method === \"GET\") {\n const r = await sqlite.execute(\"SELECT id, lead_email, lead_name, signal_type, signal_source, signal_strength, actioned, detected_at FROM intent_signals WHERE tenant_id = ? ORDER BY detected_at DESC\", [tid]);\n const cols = r.columns;\n let csv = cols.join(\",\") + \"\\n\";\n for (const row of r.rows) {\n csv += (row as any[]).map((v) => `\"${String(v ?? \"\").replace(/\"/g, '\"\"')}\"`).join(\",\") + \"\\n\";\n }\n return new Response(csv, { headers: { \"Content-Type\": \"text/csv\", \"Content-Disposition\": 'attachment; filename=\"signals.csv\"', ...corsHeaders } });\n }\n if (pathname === \"/api/export/okrs\" && method === \"GET\") {\n const objR = await sqlite.execute(\"SELECT id, title, description, workspace, status, progress, quarter, created_at FROM objectives WHERE tenant_id = ? ORDER BY created_at DESC\", [tid]);\n const krR = await sqlite.execute(\"SELECT id, objective_id, title, target_value, current_value, unit, progress, updated_at FROM key_results WHERE tenant_id = ? ORDER BY updated_at DESC\", [tid]);\n let csv = \"type,\" + objR.columns.join(\",\") + \"\\n\";\n for (const row of objR.rows) {\n csv += \"objective,\" + (row as any[]).map((v) => `\"${String(v ?? \"\").replace(/\"/g, '\"\"')}\"`).join(\",\") + \"\\n\";\n }\n if (krR.rows.length > 0) {\n csv += \"\\ntype,\" + krR.columns.join(\",\") + \"\\n\";\n for (const row of krR.rows) {\n csv += \"key_result,\" + (row as any[]).map((v) => `\"${String(v ?? \"\").replace(/\"/g, '\"\"')}\"`).join(\",\") + \"\\n\";\n }\n }\n return new Response(csv, { headers: { \"Content-Type\": \"text/csv\", \"Content-Disposition\": 'attachment; filename=\"okrs.csv\"', ...corsHeaders } });\n }\n if (pathname === \"/api/export/tasks\" && method === \"GET\") {\n const r = await sqlite.execute(\"SELECT id, title, description, status, priority, workspace, due_date, created_at, updated_at FROM tasks WHERE tenant_id = ? ORDER BY created_at DESC\", [tid]);\n const cols = r.columns;\n let csv = cols.join(\",\") + \"\\n\";\n for (const row of r.rows) {\n csv += (row as any[]).map((v) => `\"${String(v ?? \"\").replace(/\"/g, '\"\"')}\"`).join(\",\") + \"\\n\";\n }\n return new Response(csv, { headers: { \"Content-Type\": \"text/csv\", \"Content-Disposition\": 'attachment; filename=\"tasks.csv\"', ...corsHeaders } });\n }\n\n // --- LinkedIn OAuth flow (legacy aliases) ----\n if (pathname === \"/api/oauth/linkedin/start\" && method === \"GET\") {\n return Response.redirect(`${url.origin}/api/auth/linkedin`);\n }\n if (pathname === \"/api/oauth/linkedin/callback\" && method === \"GET\") {\n return Response.redirect(`${url.origin}/api/auth/linkedin/callback?${url.search.slice(1)}`);\n }\n\n // --- Graphify - app map for MCP / AI-native navigation ----\n if (pathname === \"/api/graphify\" && method === \"GET\") {\n return json(await getGraphify());\n }\n\n // --- Calendar today shortcut (TodayPanel widget) ----\n if (pathname === \"/api/calendar/today\" && method === \"GET\") {\n const today = new Date().toISOString().slice(0, 10);\n return json(await getUnifiedCalendar({ from: today, to: today }));\n }\n\n // --- Digest latest alias ----\n if (pathname === \"/api/digest/latest\" && method === \"GET\") {\n return json(await getLatestDigest());\n }\n\n // --- PLATFORM SUPERADMIN (master-only; the single audited exception to tenant isolation) ----\n // GATE first, then delegate all /api/platform/* routes to handlePlatformRoutes (api/platform.ts).\n if (pathname.startsWith(\"/api/platform/\")) {\n if (!currentCtx().isPlatformAdmin) return json({ error: \"Forbidden: platform admin only\" }, 403);\n return handlePlatformRoutes(req, url, method);\n }\n\n // --- ADMIN LOCKDOWN: every destructive /api/admin/* route is owner-only (plus per-route confirm\n // tokens below). No-op under default SYSTEM_CTX (role \"owner\"); locks out trial members. ----\n if (pathname.startsWith(\"/api/admin/\") && currentRole() !== \"owner\") {\n return json({ error: \"Forbidden: owner role required\" }, 403);\n }\n\n // Owner bootstrap (owner-only): create/attach the platform owner to t_default for email+password login. Idempotent.\n if (pathname === \"/api/admin/bootstrap-owner\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (!body.email || !body.password) return json({ ok: false, error: \"email + password required\" }, 400);\n const r = await bootstrapOwner(String(body.email), String(body.password));\n return json({ ok: r.ok, created: r.created });\n }\n\n // Admin backup/export (owner-only): read-only, tenant-scoped (WHERE tenant_id=?) JSON snapshot of this tenant's rows.\n // Confirm is optional: pass { confirm: \"EXPORT\" } to be explicit, otherwise it just runs.\n if (pathname === \"/api/admin/export\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm != null && body.confirm !== \"EXPORT\") {\n return json({ ok: false, error: \"Send confirm: EXPORT (or omit confirm)\" }, 400);\n }\n const EXPORT_TABLES = [\n \"tasks\", \"deals\", \"campaigns\", \"objectives\", \"key_results\", \"experiments\",\n \"agents\", \"action_queue\", \"calendar_entries\", \"knowledge_files\", \"notes\",\n ];\n const data: Record = {};\n const counts: Record = {};\n for (const table of EXPORT_TABLES) {\n try {\n const r = await sqlite.execute(`SELECT * FROM ${table} WHERE tenant_id = ?`, [tid]);\n const rows = (r.rows || []).map((row) => rowToObject(r.columns, row));\n data[table] = rows;\n counts[table] = rows.length;\n } catch {\n // Missing table (e.g. not yet created): record empty rather than failing the whole export.\n data[table] = [];\n counts[table] = 0;\n }\n }\n const snapshot = {\n ok: true,\n tenant_id: tid,\n version: APP_VERSION,\n exported_at: new Date().toISOString(),\n tables: EXPORT_TABLES,\n counts,\n data,\n };\n const filename = `aihive-backup-${tid}-${new Date().toISOString().slice(0, 10)}.json`;\n return new Response(JSON.stringify(snapshot, null, 2), {\n headers: {\n \"Content-Type\": \"application/json\",\n \"Content-Disposition\": `attachment; filename=\"${filename}\"`,\n \"Cache-Control\": \"no-store\",\n ...corsHeaders,\n },\n });\n }\n\n // --- Admin purge (clear intelligence cache) ----\n if (pathname === \"/api/admin/purge\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm !== \"PURGE\") return json({ error: \"Send confirm: PURGE\" }, 400);\n await sqlite.execute(\"DELETE FROM intelligence_cache WHERE tenant_id = ?\", [tid]).catch(() => {});\n await sqlite.execute(\"UPDATE app_config SET value=NULL WHERE key='funnel_cache' AND tenant_id = ?\", [tid]).catch(() => {});\n return json({ success: true, message: \"Cache purged\" });\n }\n\n // Remove demo/seed data: starter agents matched exactly on (name, description, system_prompt) so edits are never touched.\n if (pathname === \"/api/admin/seed-status\" && method === \"GET\") {\n let agents = 0;\n for (const seed of DEFAULT_AGENT_SEEDS) {\n const r = await sqlite.execute(\n \"SELECT COUNT(*) FROM agents WHERE name = ? AND description = ? AND system_prompt = ? AND tenant_id = ?\",\n [seed.name, seed.description, seed.system_prompt, tid],\n ).catch(() => null);\n if (r?.rows?.length) agents += Number((r.rows[0] as any[])[0]) || 0;\n }\n return json({ ok: true, total: agents, counts: { agents } });\n }\n if (pathname === \"/api/admin/cleanup-mock\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm !== \"CLEANUP\") return json({ ok: false, error: \"Send confirm: CLEANUP\" }, 400);\n let removed = 0;\n for (const seed of DEFAULT_AGENT_SEEDS) {\n const r = await sqlite.execute(\n \"DELETE FROM agents WHERE name = ? AND description = ? AND system_prompt = ? AND tenant_id = ?\",\n [seed.name, seed.description, seed.system_prompt, tid],\n ).catch(() => null);\n removed += Number((r as any)?.rowsAffected ?? 0) || 0;\n }\n return json({ ok: true, total: removed });\n }\n\n // Bulk reset: wipe ALL agents (= agents + campaigns, same table) plus related\n // run/budget/conversation rows that deleteAgent() does not cascade. Confirm-guarded.\n if (pathname === \"/api/admin/reset-agents\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm !== \"CLEANUP\") return json({ ok: false, error: \"Send confirm: CLEANUP\" }, 400);\n const counts: Record = {};\n for (const table of [\"agents\", \"agent_runs\", \"agent_budgets\", \"conversations\"]) {\n const r = await sqlite.execute(`DELETE FROM ${table} WHERE tenant_id = ?`, [tid]).catch(() => null);\n counts[table] = Number((r as any)?.rowsAffected ?? 0) || 0;\n }\n return json({ ok: true, counts });\n }\n\n // Factory reset (this app + tenant only): wipe the data tables below, keeping integrations/llm_config/knowledge_files. Confirm-guarded.\n if (pathname === \"/api/admin/reset-data\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm !== \"CLEANUP\") return json({ ok: false, error: \"Send confirm: CLEANUP\" }, 400);\n const WIPE_TABLES = [\n \"agents\", \"conversations\", \"agent_budgets\", \"agent_runs\",\n \"objectives\", \"key_results\", \"north_star\", \"nsm_history\",\n \"experiments\", \"tasks\", \"tasks_legacy\", \"notes\",\n \"intent_signals\", \"growth_digests\", \"calendar_entries\", \"action_queue\",\n \"customer_cohorts\", \"lead_state_changes\", \"utm_conversions\",\n \"metric_baselines\", \"metric_history\", \"intelligence_cache\", \"app_config\",\n ];\n const counts: Record = {};\n for (const table of WIPE_TABLES) {\n const r = await sqlite.execute(`DELETE FROM ${table} WHERE tenant_id = ?`, [tid]).catch(() => null);\n counts[table] = Number((r as any)?.rowsAffected ?? 0) || 0;\n }\n return json({ ok: true, kept: [\"integrations\", \"llm_config\", \"knowledge_files\"], counts });\n }\n\n // Precise working-data wipe (KEEPS knowledge_files/skills/memory/app_config/integrations/llm_config). Confirm-guarded.\n if (pathname === \"/api/admin/wipe-working-data\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm !== \"WIPE\") return json({ ok: false, error: \"Send confirm: WIPE\" }, 400);\n const WIPE = [\n \"agents\", \"agent_runs\", \"agent_budgets\", \"conversations\", \"deals\",\n \"experiments\", \"tasks\", \"tasks_legacy\", \"objectives\", \"key_results\",\n \"north_star\", \"nsm_history\", \"intent_signals\", \"growth_digests\",\n \"calendar_entries\", \"action_queue\", \"customer_cohorts\", \"lead_state_changes\",\n \"utm_conversions\", \"metric_baselines\", \"metric_history\", \"intelligence_cache\", \"notes\",\n ];\n const counts: Record = {};\n for (const table of WIPE) {\n const r = await sqlite.execute(`DELETE FROM ${table} WHERE tenant_id = ?`, [tid]).catch(() => null);\n counts[table] = Number((r as any)?.rowsAffected ?? 0) || 0;\n }\n return json({\n ok: true,\n kept: [\"knowledge_files\", \"skills\", \"memory\", \"app_config\", \"integrations\", \"llm_config\"],\n counts,\n });\n }\n\n // --- Targeted wipe: tasks + run history + agents/budgets + campaign↔agent links ONLY ----\n // Keeps campaigns/objectives/everything else. Confirm-guarded.\n if (pathname === \"/api/admin/wipe-tasks-agents\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm !== \"WIPE\") return json({ ok: false, error: \"Send confirm: WIPE\" }, 400);\n const WIPE = [\"tasks\", \"tasks_legacy\", \"agent_runs\", \"agent_budgets\", \"campaign_agents\", \"agents\", \"campaign_runs\"];\n const counts: Record = {};\n for (const table of WIPE) {\n const r = await sqlite.execute(`DELETE FROM ${table} WHERE tenant_id = ?`, [tid]).catch(() => null);\n counts[table] = Number((r as any)?.rowsAffected ?? 0) || 0;\n }\n // Also clear internal completion events (metric_history integration='internal') and task-done\n // calendar markers (event_type='completion'); keep real integration metric history intact.\n const mh = await sqlite.execute(\"DELETE FROM metric_history WHERE integration = 'internal' AND tenant_id = ?\", [tid]).catch(() => null);\n counts[\"metric_history(internal)\"] = Number((mh as any)?.rowsAffected ?? 0) || 0;\n const cm = await sqlite.execute(\"DELETE FROM calendar_entries WHERE event_type = 'completion' AND tenant_id = ?\", [tid]).catch(() => null);\n counts[\"calendar_entries(completion)\"] = Number((cm as any)?.rowsAffected ?? 0) || 0;\n return json({ ok: true, wiped: [...WIPE, \"metric_history(internal)\", \"calendar_entries(completion)\"], counts });\n }\n\n // --- Targeted wipe: action_queue (approvals / prepared+sent action history) ONLY ----\n if (pathname === \"/api/admin/wipe-actions\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n if (body.confirm !== \"WIPE\") return json({ ok: false, error: \"Send confirm: WIPE\" }, 400);\n const r = await sqlite.execute(\"DELETE FROM action_queue WHERE tenant_id = ?\", [tid]).catch(() => null);\n return json({ ok: true, wiped: [\"action_queue\"], counts: { action_queue: Number((r as any)?.rowsAffected ?? 0) || 0 } });\n }\n\n // --- Google OAuth redirect flow ----\n if (pathname === \"/api/auth/google\" && method === \"GET\") {\n const creds = await getCredentials(\"google\");\n // OAuth client is env-driven by design (GOOGLE_CLIENT_ID/SECRET); fall back to the DB row.\n const clientId = Deno.env.get(\"GOOGLE_CLIENT_ID\") || creds?.extra_config?.client_id || creds?.extra_config?.clientId;\n const redirectUri = creds?.extra_config?.redirect_uri || creds?.extra_config?.redirectUri || `${url.origin}/api/auth/google/callback`;\n if (!clientId) {\n return new Response(\"Google OAuth not configured. Add Client ID in Settings - Google.\", { status: 400 });\n }\n const scopes = [\n \"https://www.googleapis.com/auth/userinfo.email\",\n \"https://www.googleapis.com/auth/analytics.readonly\",\n \"https://www.googleapis.com/auth/webmasters.readonly\",\n \"https://www.googleapis.com/auth/gmail.modify\",\n \"https://www.googleapis.com/auth/drive.readonly\",\n \"https://www.googleapis.com/auth/spreadsheets.readonly\",\n \"https://www.googleapis.com/auth/documents.readonly\",\n \"https://www.googleapis.com/auth/calendar\",\n \"https://www.googleapis.com/auth/youtube.readonly\",\n \"https://www.googleapis.com/auth/yt-analytics.readonly\",\n ].join(\" \");\n const { state, setCookie } = newOAuthState();\n const params = new URLSearchParams({\n client_id: clientId,\n redirect_uri: redirectUri,\n response_type: \"code\",\n scope: scopes,\n access_type: \"offline\",\n prompt: \"consent\",\n state,\n });\n return redirectWithCookie(`https://accounts.google.com/o/oauth2/v2/auth?${params}`, setCookie);\n }\n\n if (pathname === \"/api/auth/google/callback\" && method === \"GET\") {\n const code = url.searchParams.get(\"code\");\n const error = url.searchParams.get(\"error\");\n if (error || !code) {\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(error || \"no_code\")}`);\n }\n if (!oauthStateValid(req, url)) {\n return Response.redirect(`${url.origin}/?auth_error=state_mismatch`);\n }\n const creds = await getCredentials(\"google\");\n // Trim env/DB values to avoid whitespace producing a malformed (invalid_request) token request.\n const clientId = (Deno.env.get(\"GOOGLE_CLIENT_ID\") || creds?.extra_config?.client_id || creds?.extra_config?.clientId || \"\").trim();\n const clientSecret = (Deno.env.get(\"GOOGLE_CLIENT_SECRET\") || creds?.api_secret || \"\").trim();\n const redirectUri = (creds?.extra_config?.redirect_uri || creds?.extra_config?.redirectUri || `${url.origin}/api/auth/google/callback`).trim();\n\n // Fail fast with a clear cause if a required param is empty (Google would return invalid_request).\n if (!clientId || !clientSecret) {\n const missing = !clientId && !clientSecret ? \"client_id_and_secret\"\n : !clientId ? \"client_id\" : \"client_secret\";\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(\"missing_\" + missing)}`);\n }\n\n const tokenRes = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({ code, client_id: clientId, client_secret: clientSecret, redirect_uri: redirectUri, grant_type: \"authorization_code\" }),\n });\n const tokens = await tokenRes.json() as any;\n if (!tokenRes.ok || !tokens.access_token) {\n const detail = [tokens.error, tokens.error_description].filter(Boolean).join(\": \") || \"token_exchange_failed\";\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(detail)}`);\n }\n\n const now = new Date().toISOString();\n const newExtraConfig = { ...(creds?.extra_config || {}), token_expiry: Date.now() + (tokens.expires_in || 3600) * 1000 };\n const existing = await sqlite.execute(\"SELECT id FROM integrations WHERE name = ? AND tenant_id = ?\", [\"google\", tid]);\n if (existing.rows.length > 0) {\n await sqlite.execute(\n \"UPDATE integrations SET access_token=?, refresh_token=?, extra_config=?, updated_at=? WHERE name='google' AND tenant_id = ?\",\n [tokens.access_token, tokens.refresh_token || creds?.refresh_token || null, JSON.stringify(newExtraConfig), now, tid]\n );\n } else {\n await sqlite.execute(\n \"INSERT INTO integrations (id, name, access_token, refresh_token, extra_config, connected_at, updated_at, tenant_id) VALUES (?,?,?,?,?,?,?,?)\",\n [crypto.randomUUID(), \"google\", tokens.access_token, tokens.refresh_token || null, JSON.stringify(newExtraConfig), now, now, tid]\n );\n }\n return redirectWithCookie(`${url.origin}/?auth=google_ok`, CLEAR_OAUTH_STATE);\n }\n\n // --- LinkedIn OAuth flow ----\n if (pathname === \"/api/auth/linkedin\" && method === \"GET\") {\n const creds = await getCredentials(\"linkedin\");\n const clientId = creds?.extra_config?.clientId || creds?.extra_config?.client_id;\n const redirectUri = `${url.origin}/api/auth/linkedin/callback`;\n if (!clientId) {\n return new Response(\"LinkedIn OAuth not configured. Add Client ID in Settings - LinkedIn.\", { status: 400 });\n }\n const { state, setCookie } = newOAuthState();\n const params = new URLSearchParams({\n response_type: \"code\",\n client_id: clientId,\n redirect_uri: redirectUri,\n scope: \"openid profile email w_member_social r_basicprofile\",\n state,\n });\n return redirectWithCookie(`https://www.linkedin.com/oauth/v2/authorization?${params}`, setCookie);\n }\n\n if (pathname === \"/api/auth/linkedin/callback\" && method === \"GET\") {\n const code = url.searchParams.get(\"code\");\n const error = url.searchParams.get(\"error\");\n if (error || !code) {\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(error || \"no_code\")}`);\n }\n if (!oauthStateValid(req, url)) {\n return Response.redirect(`${url.origin}/?auth_error=state_mismatch`);\n }\n const creds = await getCredentials(\"linkedin\");\n const clientId = creds?.extra_config?.clientId || creds?.extra_config?.client_id || \"\";\n const clientSecret = creds?.api_secret || \"\";\n const redirectUri = `${url.origin}/api/auth/linkedin/callback`;\n\n const tokenRes = await fetch(\"https://www.linkedin.com/oauth/v2/accessToken\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({ grant_type: \"authorization_code\", code, redirect_uri: redirectUri, client_id: clientId, client_secret: clientSecret }),\n });\n const tokens = await tokenRes.json() as any;\n if (!tokenRes.ok || !tokens.access_token) {\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(tokens.error || \"linkedin_token_failed\")}`);\n }\n\n // Fetch LinkedIn profile to get the author URN needed for posts endpoint.\n let authorId = creds?.extra_config?.author_id || \"\";\n try {\n const profileRes = await fetch(\"https://api.linkedin.com/v2/me\", {\n headers: { Authorization: `Bearer ${tokens.access_token}` },\n });\n if (profileRes.ok) {\n const profile = await profileRes.json() as any;\n if (profile.id) authorId = `urn:li:person:${profile.id}`;\n }\n } catch { /* non-fatal - author_id can be set manually later */ }\n\n const now = new Date().toISOString();\n const newExtraConfig = { ...(creds?.extra_config || {}), token_expiry: Date.now() + (tokens.expires_in || 5184000) * 1000, author_id: authorId };\n const existing = await sqlite.execute(\"SELECT id FROM integrations WHERE name = ? AND tenant_id = ?\", [\"linkedin\", tid]);\n if (existing.rows.length > 0) {\n await sqlite.execute(\n \"UPDATE integrations SET access_token=?, extra_config=?, updated_at=? WHERE name='linkedin' AND tenant_id = ?\",\n [tokens.access_token, JSON.stringify(newExtraConfig), now, tid]\n );\n } else {\n await sqlite.execute(\n \"INSERT INTO integrations (id, name, access_token, extra_config, connected_at, updated_at, tenant_id) VALUES (?,?,?,?,?,?,?)\",\n [crypto.randomUUID(), \"linkedin\", tokens.access_token, JSON.stringify(newExtraConfig), now, now, tid]\n );\n }\n return redirectWithCookie(`${url.origin}/?auth=linkedin_ok`, CLEAR_OAUTH_STATE);\n }\n\n // Microsoft (Outlook) OAuth: env-first client (MICROSOFT_CLIENT_ID/SECRET), `common` tenant, DB fallback. Mirrors Google.\n if (pathname === \"/api/auth/microsoft\" && method === \"GET\") {\n const mcreds = await getCredentials(\"outlook\");\n const clientId = (Deno.env.get(\"MICROSOFT_CLIENT_ID\") || mcreds?.extra_config?.client_id || mcreds?.extra_config?.clientId || \"\").trim();\n if (!clientId) {\n return new Response(\"Microsoft OAuth not configured. Set MICROSOFT_CLIENT_ID (env) or add the Client ID in Settings → Outlook.\", { status: 400 });\n }\n const redirectUri = `${url.origin}/api/auth/microsoft/callback`;\n const scopes = MICROSOFT_SCOPES;\n const { state, setCookie } = newOAuthState();\n const params = new URLSearchParams({\n client_id: clientId,\n response_type: \"code\",\n redirect_uri: redirectUri,\n response_mode: \"query\",\n scope: scopes,\n state,\n });\n return redirectWithCookie(`https://login.microsoftonline.com/common/oauth2/v2.0/authorize?${params}`, setCookie);\n }\n\n if (pathname === \"/api/auth/microsoft/callback\" && method === \"GET\") {\n const code = url.searchParams.get(\"code\");\n const error = url.searchParams.get(\"error\");\n if (error || !code) {\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(error || \"no_code\")}`);\n }\n if (!oauthStateValid(req, url)) {\n return Response.redirect(`${url.origin}/?auth_error=state_mismatch`);\n }\n const creds = await getCredentials(\"outlook\");\n const clientId = (Deno.env.get(\"MICROSOFT_CLIENT_ID\") || creds?.extra_config?.client_id || creds?.extra_config?.clientId || \"\").trim();\n const clientSecret = (Deno.env.get(\"MICROSOFT_CLIENT_SECRET\") || creds?.api_secret || \"\").trim();\n const redirectUri = `${url.origin}/api/auth/microsoft/callback`;\n if (!clientId || !clientSecret) {\n const missing = !clientId && !clientSecret ? \"client_id_and_secret\" : !clientId ? \"client_id\" : \"client_secret\";\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(\"missing_microsoft_\" + missing)}`);\n }\n const scopes = MICROSOFT_SCOPES;\n const tokenRes = await fetch(\"https://login.microsoftonline.com/common/oauth2/v2.0/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({ client_id: clientId, client_secret: clientSecret, code, redirect_uri: redirectUri, grant_type: \"authorization_code\", scope: scopes }),\n });\n const tokens = await tokenRes.json() as any;\n if (!tokenRes.ok || !tokens.access_token) {\n const detail = [tokens.error, tokens.error_description].filter(Boolean).join(\": \") || \"token_exchange_failed\";\n return Response.redirect(`${url.origin}/?auth_error=${encodeURIComponent(detail)}`);\n }\n\n const now = new Date().toISOString();\n const newExtraConfig = { ...(creds?.extra_config || {}), token_expiry: Date.now() + (tokens.expires_in || 3600) * 1000 };\n const existing = await sqlite.execute(\"SELECT id FROM integrations WHERE name = ? AND tenant_id = ?\", [\"outlook\", tid]);\n if (existing.rows.length > 0) {\n await sqlite.execute(\n \"UPDATE integrations SET access_token=?, refresh_token=?, extra_config=?, updated_at=? WHERE name='outlook' AND tenant_id = ?\",\n [tokens.access_token, tokens.refresh_token || creds?.refresh_token || null, JSON.stringify(newExtraConfig), now, tid]\n );\n } else {\n await sqlite.execute(\n \"INSERT INTO integrations (id, name, access_token, refresh_token, extra_config, connected_at, updated_at, tenant_id) VALUES (?,?,?,?,?,?,?,?)\",\n [crypto.randomUUID(), \"outlook\", tokens.access_token, tokens.refresh_token || null, JSON.stringify(newExtraConfig), now, now, tid]\n );\n }\n return redirectWithCookie(`${url.origin}/?auth=outlook_ok`, CLEAR_OAUTH_STATE);\n }\n\n // Identity login OAuth (sign-in, NOT data scopes): scope \"openid email profile\"; callback mints an app session.\n const loginMatch = pathname.match(/^\\/api\\/login\\/(google|microsoft)(\\/callback)?$/);\n if (loginMatch && method === \"GET\") {\n const provider = loginMatch[1] as \"google\" | \"microsoft\";\n return loginMatch[2]\n ? await identityLoginCallback(provider, req, url)\n : identityLoginStart(provider, url);\n }\n\n // --- Notes routes (TeamHub collaborative notes) ----\n if (pathname === \"/api/notes\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? \"marketing\";\n const result = await sqlite.execute(\n \"SELECT * FROM notes WHERE workspace=? AND tenant_id = ? ORDER BY pinned DESC, created_at DESC\",\n [workspace, tid]\n );\n return json(result.rows.map((r) => rowToObject(result.columns, r)));\n }\n if (pathname === \"/api/notes\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n await sqlite.execute(\n \"INSERT INTO notes (id, content, pinned, workspace, created_at, updated_at, tenant_id) VALUES (?,?,?,?,?,?,?)\",\n [id, body.content ?? \"\", body.pinned ? 1 : 0, body.workspace ?? \"marketing\", now, now, tid]\n );\n return json({ id, content: body.content ?? \"\", pinned: !!body.pinned, workspace: body.workspace ?? \"marketing\", created_at: now, updated_at: now }, 201);\n }\n const noteMatch = pathname.match(/^\\/api\\/notes\\/([^/]+)$/);\n if (noteMatch && method === \"PUT\") {\n const id = noteMatch[1];\n const body = await req.json().catch(() => ({}));\n const now = new Date().toISOString();\n const setParts: string[] = [\"updated_at=?\"];\n const setArgs: any[] = [now];\n if (body.pinned !== undefined) { setParts.push(\"pinned=?\"); setArgs.push(body.pinned ? 1 : 0); }\n if (body.content !== undefined) { setParts.push(\"content=?\"); setArgs.push(body.content); }\n await sqlite.execute(\n `UPDATE notes SET ${setParts.join(\", \")} WHERE id=? AND tenant_id = ?`,\n [...setArgs, id, tid]\n );\n const r = await sqlite.execute(\"SELECT * FROM notes WHERE id=? AND tenant_id = ?\", [id, tid]);\n if (!r.rows.length) return json({ error: \"Not found\" }, 404);\n return json(rowToObject(r.columns, r.rows[0]));\n }\n if (noteMatch && method === \"DELETE\") {\n await sqlite.execute(\"DELETE FROM notes WHERE id=? AND tenant_id = ?\", [noteMatch[1], tid]);\n return json({ success: true });\n }\n\n // --- World dashboard rollups (logs / kanban / project panels) ----\n // /api/world/activity — cross-agent runs; ?campaign[_id]=ID scopes to that campaign, bare ?campaign = legacy filter.\n if (pathname === \"/api/world/activity\" && method === \"GET\") {\n const limit = parseInt(url.searchParams.get(\"limit\") ?? \"40\", 10);\n const status = url.searchParams.get(\"status\") ?? undefined;\n const agent_id = url.searchParams.get(\"agent_id\") ?? undefined;\n const campaignParam = url.searchParams.get(\"campaign_id\") ?? url.searchParams.get(\"campaign\");\n const campaign_id = campaignParam ? campaignParam : undefined;\n const campaign = url.searchParams.get(\"campaign\") != null && !campaign_id;\n return json(await getWorldActivity({ limit, status, agent_id, campaign, campaign_id }));\n }\n // /api/world/board — tasks grouped into the 4 kanban columns; ?campaign[_id]=ID scopes them.\n if (pathname === \"/api/world/board\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n const campaign_id = url.searchParams.get(\"campaign_id\") ?? url.searchParams.get(\"campaign\") ?? undefined;\n return json(await getWorldBoard({ workspace, campaign_id: campaign_id || undefined }));\n }\n // /api/world/project — active campaign brief + real run-usage rollup; ?campaign[_id]=ID focuses it.\n if (pathname === \"/api/world/project\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n const campaign_id = url.searchParams.get(\"campaign_id\") ?? url.searchParams.get(\"campaign\") ?? undefined;\n return json(await getWorldProject({ workspace, campaign_id: campaign_id || undefined }));\n }\n\n // --- Campaigns (Director: multi-agent orchestrated pipelines) ----\n if (pathname === \"/api/campaigns\" && method === \"GET\") {\n const workspace = url.searchParams.get(\"workspace\") ?? undefined;\n return json(await listCampaigns(workspace));\n }\n if (pathname === \"/api/campaigns\" && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await createCampaign(body), 201);\n }\n // Sub-resources (:id/runs, :id/agents, :id/trigger) before the bare :id matcher.\n const campaignRunsMatch = pathname.match(/^\\/api\\/campaigns\\/([^/]+)\\/runs$/);\n if (campaignRunsMatch && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n // Runs the Director pipeline synchronously and returns the run result.\n return json(await orchestrateCampaignRun(campaignRunsMatch[1], body.input));\n }\n if (campaignRunsMatch && method === \"GET\") {\n return json(await listCampaignRuns(campaignRunsMatch[1]));\n }\n const campaignAgentsMatch = pathname.match(/^\\/api\\/campaigns\\/([^/]+)\\/agents$/);\n if (campaignAgentsMatch && method === \"GET\") {\n return json(await getCampaignAgents(campaignAgentsMatch[1]));\n }\n // Clicking a campaign returns its tasks (OKR→Campaign→Task link).\n const campaignTasksMatch = pathname.match(/^\\/api\\/campaigns\\/([^/]+)\\/tasks$/);\n if (campaignTasksMatch && method === \"GET\") {\n return json(await listTasks({ campaign_id: campaignTasksMatch[1] }));\n }\n const campaignTriggerMatch = pathname.match(/^\\/api\\/campaigns\\/([^/]+)\\/trigger$/);\n if (campaignTriggerMatch && method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n return json(await setCampaignTrigger(campaignTriggerMatch[1], body));\n }\n const campaignIdMatch = pathname.match(/^\\/api\\/campaigns\\/([^/]+)$/);\n if (campaignIdMatch && method === \"GET\") {\n const c = await getCampaign(campaignIdMatch[1]);\n return c ? json(c) : json({ error: \"Not found\" }, 404);\n }\n if (campaignIdMatch && method === \"PUT\") {\n const body = await req.json().catch(() => ({}));\n return json(await updateCampaign(campaignIdMatch[1], body));\n }\n if (campaignIdMatch && method === \"DELETE\") {\n const ok = await deleteCampaign(campaignIdMatch[1]);\n return ok ? json({ success: true }) : json({ error: \"Not found\" }, 404);\n }\n\n // No route matched\n return json({ error: \"Not found\", path: pathname }, 404);\n } catch (err) {\n const message = err instanceof Error ? err.message : String(err);\n console.error(`[router] Error handling ${method} ${pathname}:`, message);\n return json({ error: \"Internal server error\", detail: message }, 500);\n }\n}\n\n/**\n * Converts a sqlite result row (array of values) to a plain object\n * using the columns array from the result set.\n */\nfunction rowToObject(columns: string[], row: unknown[]): Record {\n const obj: Record = {};\n for (let i = 0; i < columns.length; i++) {\n obj[columns[i]] = row[i];\n }\n return obj;\n}\n",[200],"731c8246-5f37-11f1-acf9-1607ee4eb77e","main.ts",1066,["D",1780482718390],23,"http","import { initDB, tenantStore, SYSTEM_CTX } from \"./db.ts\";\nimport { handleRequest } from \"./router.ts\";\nimport { getFrontendHTML, getWorldHTML } from \"./frontend.ts\";\nimport { seedKnowledge } from \"./api/knowledge_seed.ts\";\nimport { resolveSession } from \"./api/session.ts\";\n\n// Foundation tenant context: a session resolves to a TenantCtx; absent one we fall back to the\n// system/default SYSTEM_CTX (imported from db.ts, typed as TenantCtx) so all existing\n// (t_default-backfilled) data keeps working exactly as today.\n\nlet initialized = false;\n\n// Shared-secret gate. Set APP_TOKEN in the val's environment. Every /api/* route\n// requires `Authorization: Bearer ` (or `?token=` for download links),\n// EXCEPT the public paths below. Fail-closed: if APP_TOKEN is unset, data routes 503.\nconst APP_TOKEN = (Deno.env.get(\"APP_TOKEN\") || \"\").trim();\n\n// Auth ENABLED (Phase 3): /api/* requires a valid nexus_session cookie OR the APP_TOKEN bearer\n// (recovery hatch). Public paths (app modules, /api/auth/*, /api/login/*, /api/health) stay open so\n// the login screen always loads. Verified: owner session authorizes, anonymous → 401 → login screen.\nconst AUTH_DISABLED = false;\n\n// Public /api paths that must stay reachable without the app token:\n// - /api/app-* : the frontend's own JS modules (static code, no secrets; loaded by \n \n \n \n \n \n \n \n \n\n\n

\n \n\n`;\n}\n\n// Part 10: the Agent World shell — a \"the-delegation\" simulation DASHBOARD at /world. Same origin\n// (shares nexus_token + every /api/* route), so the agents + panels run over the REAL backend.\n// This shell is the SOLE creator of every fixed DOM id the world modules target. It is a CSS-grid\n// dashboard (light theme): a top bar, a LEFT logs panel, a CENTER stage (scene header + a BOUNDED\n// canvas + a kanban under it) and a RIGHT project panel. The canvas is NOT fullscreen — it lives\n// inside #world-canvas-wrap and the scene sizes to that wrapper. three.js (+ addons) load from a\n// CDN via the importmap; the 3D + panel logic is in /api/app-world (the entry) and its sub-modules.\nexport function getWorldHTML(): string {\n return `\n\n\n \n \n AIHive · Agent World\n \n \n \n \n\n\n

\n \n

\n \n\n`;\n}\n",[491],"731798f6-5f2f-11f1-ae87-1607ee4eb77e","db.ts","2f68e1b8-56ca-11f1-b821-ee650bb23af1",1048,["D",1780479282410],55,"import { sqlite as _sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ── DB BACKEND (portable across hosts) ───────────────────────────────────────\n// AIHive runs on val.town today (std/sqlite) but is migrating to Firebase Hosting + Cloud Run, where\n// the database is a real Turso libSQL (no shared rate limit, runs on any host). This selects the\n// backend from ENV without changing a single caller: when TURSO_DATABASE_URL is set we use the Turso\n// libSQL client; otherwise we fall back to val.town's std/sqlite. Both expose the SAME\n// execute(string | {sql, args}) → {rows, columns, rowsAffected} shape, so the rest of the app and the\n// rate-limit retry wrapper below are unchanged. On val.town (no TURSO_* env) this is a no-op: the\n// libSQL client is never even imported.\nfunction _env(k: string): string | undefined {\n try {\n const g = globalThis as any;\n return g.Deno?.env?.get?.(k) ?? g.process?.env?.[k];\n } catch {\n return undefined;\n }\n}\nconst _tursoUrl = _env(\"TURSO_DATABASE_URL\");\nlet _exec: (stmt: any) => Promise;\nif (_tursoUrl) {\n // Lazy import so std-only (val.town) deploys never load the libSQL client.\n const { createClient } = await import(\"https://esm.sh/@libsql/client@0.14.0/web\");\n const _client = createClient({ url: _tursoUrl, authToken: _env(\"TURSO_AUTH_TOKEN\") });\n _exec = (stmt: any) => _client.execute(stmt);\n} else {\n // Compatibility shim: std/sqlite accepts execute(string) or execute({sql, args}).\n const _bound = _sqlite.execute.bind(_sqlite);\n _exec = (stmt: any) => _bound(stmt);\n}\n\n// RATE-LIMIT RESILIENCE: std/sqlite enforces a shared rate limit. A cold-boot initDB fires ~170\n// CREATE/ALTER/INDEX calls in a burst and can exceed the window MID-init — which used to wedge the\n// whole app in a permanent 500 loop (init fails part-way → memo resets → next request re-bursts →\n// fails again, never converging). We retry rate-limited calls with backoff so init (and any runtime\n// query) PACES THROUGH the limit and completes. Non-rate-limit errors are rethrown immediately.\nconst _isRateLimit = (e: any): boolean => /rate limit|too many request|429/i.test(String((e && e.message) || e));\nconst _backoffMs = (e: any, attempt: number): number => {\n const m = String((e && e.message) || e).match(/retry in (\\d+)\\s*second/i);\n if (m) return Math.min(8000, (Number(m[1]) + 1) * 1000); // honor the server's hint when given\n return Math.min(4000, 500 * Math.pow(2, attempt));\n};\nconst _execRetry = async (stmt: any): Promise => {\n for (let attempt = 0; ; attempt++) {\n try {\n return await _exec(stmt);\n } catch (e) {\n if (attempt < 10 && _isRateLimit(e)) {\n await new Promise((r) => setTimeout(r, _backoffMs(e, attempt)));\n continue;\n }\n throw e;\n }\n }\n};\nexport const sqlite = {\n ..._sqlite,\n execute: async (stmt: string | { sql: string; args?: any[] }, args?: any[]): Promise => {\n if (typeof stmt === \"string\" && args !== undefined) {\n return _execRetry({ sql: stmt, args });\n }\n return _execRetry(stmt as any);\n },\n};\n\n// ─── TENANT CONTEXT (AUTH/TENANT FOUNDATION) ────────────────────────────────\n// Per-request tenant/user/role context carried via AsyncLocalStorage. main.ts wraps each\n// handleRequest in tenantStore.run(ctx, ...). When there is no active store (cron, system\n// boot, recovery APP_TOKEN path) we DEFAULT to t_default/system/owner so all existing data\n// (backfilled to tenant_id=\"t_default\") keeps working exactly as today.\nimport { AsyncLocalStorage } from \"node:async_hooks\";\n\n// impersonating / realTenantId are set ONLY for read-only \"view as tenant\" (Phase D): when a\n// platform admin toggles sessions.impersonate_tenant_id, resolveSessionToken redirects tenantId to\n// the target tenant while keeping userId/email/role/isPlatformAdmin = the master. realTenantId holds\n// the master's OWN membership tenant. Optional so every existing ctx literal stays valid.\nexport type TenantCtx = { tenantId: string; userId: string; email: string; role: \"owner\" | \"admin\" | \"member\"; isPlatformAdmin: boolean; impersonating?: boolean; realTenantId?: string };\n// SYSTEM_CTX is the platform-trusted recovery context (APP_TOKEN / cron / boot). It IS platform admin.\nexport const SYSTEM_CTX: TenantCtx = { tenantId: \"t_default\", userId: \"system\", email: \"system\", role: \"owner\", isPlatformAdmin: true };\n\nexport const tenantStore = new AsyncLocalStorage();\nexport function currentCtx(): TenantCtx {\n // The bare no-store default is intentionally NOT platform admin (safe-by-default). Only the\n // explicit SYSTEM_CTX (used by main.ts for cron/recovery) carries isPlatformAdmin:true.\n return tenantStore.getStore() || { tenantId: \"t_default\", userId: \"system\", email: \"system\", role: \"owner\", isPlatformAdmin: false };\n}\nexport function currentTenantId(): string { return currentCtx().tenantId; }\nexport function currentUserId(): string { return currentCtx().userId; }\nexport function currentRole(): \"owner\" | \"admin\" | \"member\" { return currentCtx().role; }\n\n// MEMOIZED: run the full schema setup ONCE per warm instance, not on every request. initDB was\n// awaited per-request, firing dozens of CREATE/ALTER sqlite calls each time → std/sqlite 429\n// \"Too Many Requests\" → intermittent 500s across the app (the \"too many requests\" symptom). The\n// cached promise makes every subsequent call free; on failure we reset so the next request retries.\nlet _initPromise: Promise | null = null;\nexport function initDB(): Promise {\n if (!_initPromise) {\n _initPromise = _initDBImpl().catch((e) => { _initPromise = null; throw e; });\n }\n return _initPromise;\n}\nasync function _initDBImpl(): Promise {\n // Schema lives in ./schema.ts to keep db.ts under val.town's 80KB/file cap. Lazy import\n // avoids a static cycle (schema.ts imports sqlite from db.ts).\n const { runSchema } = await import(\"./schema.ts\");\n await runSchema();\n}\n\n// The starter \"demo\" agents seeded on first boot. Exported so the admin \"Remove demo data\"\n// route can identify + remove untouched seed rows (matched by name+description+system_prompt,\n// so a user-renamed/edited agent is never deleted).\nexport const DEFAULT_AGENT_SEEDS = [\n {\n name: \"SEO Analyst\",\n workspace: \"marketing\",\n description: \"Analyzes SEO performance using Ahrefs and Google Search Console data\",\n system_prompt: \"You are an expert SEO analyst. Analyze search performance data, identify opportunities, and provide actionable recommendations to improve organic search rankings.\",\n tools: JSON.stringify([\"ahrefs\", \"gsc\", \"ga4\"]),\n model: \"claude-sonnet-4-6\",\n },\n {\n name: \"Content Creator\",\n workspace: \"marketing\",\n description: \"Creates and manages content for WordPress, YouTube, and social media\",\n system_prompt: \"You are a creative content strategist. Help plan, write, and optimize content for blogs, videos, and social media platforms to drive engagement and conversions.\",\n tools: JSON.stringify([\"wordpress\", \"youtube\", \"ga4\"]),\n model: \"claude-sonnet-4-6\",\n },\n {\n name: \"Analytics Reporter\",\n workspace: \"marketing\",\n description: \"Generates reports from GA4 and Search Console data\",\n system_prompt: \"You are a data analyst specializing in digital marketing analytics. Create insightful reports from GA4 and Search Console data to track KPIs and identify growth opportunities.\",\n tools: JSON.stringify([\"ga4\", \"gsc\", \"ahrefs\"]),\n model: \"claude-sonnet-4-6\",\n },\n {\n name: \"LinkedIn Outreach\",\n workspace: \"sales\",\n description: \"Manages LinkedIn prospecting and connection campaigns\",\n system_prompt: \"You are a sales development expert specializing in LinkedIn outreach. Help craft personalized connection requests, follow-up messages, and engagement strategies to build pipeline.\",\n tools: JSON.stringify([\"linkedin\", \"outlook\"]),\n model: \"claude-sonnet-4-6\",\n },\n {\n name: \"Lead Researcher\",\n workspace: \"sales\",\n description: \"Researches prospects using LinkedIn and web data\",\n system_prompt: \"You are a research specialist who finds and qualifies sales leads. Analyze LinkedIn profiles, company data, and online presence to identify ideal prospects and gather intelligence for sales outreach.\",\n tools: JSON.stringify([\"linkedin\"]),\n model: \"claude-sonnet-4-6\",\n },\n {\n name: \"Email Composer\",\n workspace: \"sales\",\n description: \"Drafts and sends personalized sales emails via Outlook\",\n system_prompt: \"You are a sales email expert who crafts compelling, personalized outreach emails. Write emails that are concise, value-focused, and drive response rates while maintaining brand voice.\",\n tools: JSON.stringify([\"outlook\", \"linkedin\"]),\n model: \"claude-sonnet-4-6\",\n },\n];\n\n\n",[499],"cf768a30-5e7b-11f1-a326-1607ee4eb77e","cron_entry.ts","fb10767e-5b1a-11f1-b807-ee650bb23af1",925,["D",1780402127969],"// Scheduled entrypoint — deploy this file as a Val Town INTERVAL/CRON trigger (separate from\n// the HTTP val in main.ts). A single file can't be both the HTTP handler AND the scheduled\n// trigger, which is why the execution engine never ran on its own before: cron.ts had a default\n// export but nothing scheduled it.\n//\n// What it does each tick:\n// 1) processPendingRuns() — runs the LLM tool-loop for any agent_runs with status='pending'\n// (external sends still go to the human-approval action_queue; nothing auto-sends).\n// 2) syncObjectivesFromFunnel() — refreshes + persists KR/objective progress from live funnel\n// data (the GET /api/okrs list no longer writes on read, so this keeps stored progress fresh).\n//\n// Schedule: set the interval in the Val Town dashboard (Triggers → e.g. every 5 minutes).\nimport { initDB } from \"./db.ts\";\nimport { processPendingRuns } from \"./cron.ts\";\nimport { syncObjectivesFromFunnel } from \"./api/okrs.ts\";\nimport { processCampaignTriggers } from \"./api/campaigns.ts\";\n\n// Crash-proof scheduled tick. A single failure (DB 429, a bad run, a flaky integration)\n// must be logged and swallowed so the default export NEVER throws to the Val Town runtime\n// (an uncaught throw kills the tick silently and can disable the trigger). initDB() and each\n// unit of work are guarded INDEPENDENTLY so one failing does not skip the others.\nexport default async function (): Promise {\n // 1) Ensure the DB is ready. If this fails (e.g. DB 429), we cannot safely run the\n // tenant-scoped work below, so log and return — but never throw.\n try {\n await initDB();\n } catch (err) {\n console.error(\"[cron] initDB failed; skipping this tick:\", err);\n return;\n }\n\n // 2) Process pending agent runs (external sends still go to the human-approval queue).\n let runs = { processed: 0, failed: 0 };\n try {\n runs = await processPendingRuns(5);\n } catch (err) {\n console.error(\"[cron] processPendingRuns failed:\", err);\n }\n\n // 3) Fire scheduled/looping campaigns on the cron tick (after agent runs are processed).\n try {\n await processCampaignTriggers(2);\n } catch (err) {\n console.error(\"[cron] processCampaignTriggers failed:\", err);\n }\n\n // 4) Refresh + persist KR/objective progress from live funnel data.\n let okr = { objectives: 0, key_results: 0 };\n try {\n okr = await syncObjectivesFromFunnel();\n } catch (err) {\n console.error(\"[cron] syncObjectivesFromFunnel failed:\", err);\n }\n\n console.log(\n `[cron] runs processed=${runs.processed} failed=${runs.failed}; ` +\n `okr synced objectives=${okr.objectives} key_results=${okr.key_results}`,\n );\n}\n",[507],"cfec26aa-5e7b-11f1-a9e2-1607ee4eb77e","cron.ts","50e655da-5a69-11f1-ab8c-ee650bb23af1",926,["D",1780402128741],"// Execution engine — the missing piece that makes agents actually RUN.\n// Deploy as a val.town interval val (default export runs on a schedule, e.g. every 1–5 min),\n// or trigger manually via POST /api/agents/run-pending (wired in router.ts).\n//\n// It polls agent_runs for status='pending', loads the agent config, and runs an LLM\n// tool-loop reusing chat.ts's buildTools()/executeTool(). External sends still go to the\n// human-approval action_queue (the tools enqueue, they don't send) — so the engine is safe.\nimport { sqlite, tenantStore } from \"./db.ts\";\nimport { getLLMConfig, callLLM } from \"./api/llm.ts\";\nimport { getAgent } from \"./api/agents.ts\";\nimport { buildTools, executeTool } from \"./api/chat.ts\";\nimport { getSkillsIndex } from \"./api/skills.ts\";\nimport { captureMemoryFromConversation } from \"./api/memory.ts\";\nimport { getCompanyContextString } from \"./api/company.ts\";\n\nconst ENGINE_SYSTEM_SUFFIX =\n \"\\n\\nYou can ACT using tools. External sends (email / LinkedIn / WordPress) are QUEUED for human \" +\n \"approval — prepare them and they will appear in Approvals; they will NOT send until a human approves. \" +\n \"Create tasks and schedule calendar events directly. Take the single next-best action toward the goal.\";\n\nexport async function processPendingRuns(limit = 3): Promise<{ processed: number; failed: number }> {\n let processed = 0;\n let failed = 0;\n let rows: any[] = [];\n // Fetch the marketing skills index once per invocation; append to the agent system prompt\n // so the autonomous agent can apply_skill on a match. Empty index = no-op.\n const skillsIdx = await getSkillsIndex({ maxChars: 5000 }).catch(() => \"\");\n const skillsSuffix = skillsIdx\n ? \"\\n\\n\" + skillsIdx + \"\\n\\nWhen a request matches a skill above, call apply_skill with that skill name before acting.\"\n : \"\";\n // Unified business context: prepended to every autonomous agent's system prompt so each run\n // knows the company. Cheap single app_config read; empty string on any error = no-op.\n const companyCtx = await getCompanyContextString(2000).catch(() => \"\");\n try {\n const r = await sqlite.execute(\n \"SELECT id, agent_id, input, tenant_id FROM agent_runs WHERE status = 'pending' ORDER BY started_at ASC LIMIT ?\",\n [limit],\n );\n rows = (r.rows || []) as any[];\n } catch {\n return { processed, failed };\n }\n\n for (const row of rows) {\n const runId = String(row[0]);\n const agentId = String(row[1]);\n const input = row[2] ? String(row[2]) : \"\";\n // MULTI-TENANT CORRECTNESS: cron runs with NO active tenant store, so currentTenantId()\n // would default to t_default and every tenant's pending runs would be processed (and their\n // tool calls / data reads/writes scoped) under t_default. Read THIS row's tenant_id and run\n // the whole processing body inside tenantStore.run so the agent executes in ITS OWN tenant\n // scope. Backfilled/legacy rows with NULL tenant_id fall back to t_default (current behavior).\n const tenantId = row[3] ? String(row[3]) : \"t_default\";\n const ctx = { tenantId, userId: \"system\", email: \"system\", role: \"owner\" as const };\n // Per-run result so the outer counters update after the scoped body returns.\n const r = await tenantStore.run(ctx, async (): Promise<{ ok: boolean }> => {\n // Wrapped so one run's UPDATE failure can't abort the drain.\n try {\n await sqlite.execute(\"UPDATE agent_runs SET status='running' WHERE id=?\", [runId]);\n } catch { /* status flip best-effort; continue processing */ }\n // Part 14.2: structured execution trace (TraceStep[]) — hoisted so a partial trace can be\n // persisted in the catch block on failure. Reset per run.\n const trace: any[] = [];\n try {\n const agent = await getAgent(agentId);\n const llmConfig = await getLLMConfig();\n if (!(llmConfig as any).api_key) throw new Error(\"No LLM API key configured\");\n\n const systemPrompt =\n (companyCtx ? companyCtx + \"\\n\\n---\\n\\n\" : \"\") +\n (agent?.system_prompt || \"You are an autonomous marketing & sales agent.\") + ENGINE_SYSTEM_SUFFIX + skillsSuffix;\n const messages: any[] = [{\n role: \"user\",\n content: input || `Run agent \"${agent?.name || agentId}\". Decide and prepare the next best action toward its goal.`,\n }];\n\n const tools = buildTools();\n let llm = await callLLM(llmConfig, messages, { systemPrompt, tools, maxTokens: 2048 });\n const actionLog: string[] = [];\n let rounds = 0;\n while (llm.tool_calls && llm.tool_calls.length > 0 && rounds < 4) {\n rounds++;\n trace.push({ t: \"round\", n: rounds, ts: new Date().toISOString() });\n messages.push({ role: \"assistant\", content: llm.content || \"\", tool_calls: llm.tool_calls });\n for (const tc of llm.tool_calls) {\n let args: Record = {};\n try {\n args = typeof tc.function.arguments === \"string\"\n ? JSON.parse(tc.function.arguments)\n : (tc.function.arguments || {});\n } catch { args = {}; }\n const toolStart = performance.now();\n const res = await executeTool(tc.function.name, args, llmConfig);\n const ms = Math.round(performance.now() - toolStart);\n actionLog.push(`${tc.function.name}: ${res}`);\n trace.push({\n t: \"tool\",\n name: tc.function.name,\n args_preview: JSON.stringify(args).slice(0, 300),\n result_preview: String(res).slice(0, 300),\n ok: true,\n ms,\n ts: new Date().toISOString(),\n });\n messages.push({ role: \"tool\", tool_call_id: tc.id, content: res });\n }\n llm = await callLLM(llmConfig, messages, { systemPrompt, tools, maxTokens: 2048 });\n }\n\n const output = ((llm.content || \"\") + (actionLog.length ? \"\\n\\n[actions]\\n\" + actionLog.join(\"\\n\") : \"\")).slice(0, 8000);\n trace.push({ t: \"message\", role: \"assistant\", preview: String(output).slice(0, 300), ts: new Date().toISOString() });\n // Per-run status UPDATE in its own try/catch so one failure does not abort the drain.\n try {\n await sqlite.execute(\n \"UPDATE agent_runs SET status='completed', finished_at=datetime('now'), output=?, trace=? WHERE id=?\",\n [output, JSON.stringify(trace), runId],\n );\n } catch { /* completion write best-effort; run already executed */ }\n // Fire-and-forget: distill durable business facts from this completed run into memory.\n captureMemoryFromConversation([\n { role: \"user\", content: messages[0]?.content || input },\n { role: \"assistant\", content: llm.content || output },\n ]).catch(() => {});\n return { ok: true };\n } catch (e: any) {\n // Part 14.2: persist the partial trace captured before the failure.\n await sqlite.execute(\n \"UPDATE agent_runs SET status='failed', finished_at=datetime('now'), error=?, trace=? WHERE id=?\",\n [String(e?.message || e), JSON.stringify(trace), runId],\n ).catch(() => {});\n return { ok: false };\n }\n });\n if (r.ok) processed++; else failed++;\n }\n return { processed, failed };\n}\n\n// val.town interval-val entrypoint.\nexport default async function (): Promise {\n const result = await processPendingRuns(3);\n console.log(`[cron] agent runs processed=${result.processed} failed=${result.failed}`);\n}\n",[514],"7197bde6-5f37-11f1-960f-1607ee4eb77e","app_modules.ts","09d7b534-5f15-11f1-9609-1607ee4eb77e",1064,["D",1780482715858],"// Frontend ES-module route table — extracted from router.ts to keep router under val.town's\n// 80000-byte/file hard cap. Each /api/app-* path maps to a get*JS() that returns the browser\n// ES-module source string; the SPA shell lazy-imports these. Add new frontend modules HERE\n// (one import + one map entry) so router.ts never grows. serveAppModule() returns the module\n// source for a known path, or null when the path is not a frontend module route.\nimport { getAppJS } from \"./frontend_js.ts\";\nimport { getUIJS } from \"./frontend_ui.ts\";\nimport { getChartsJS } from \"./frontend_charts.ts\";\nimport { getRenderersJS } from \"./frontend_renderers.ts\";\nimport { getRenderers2JS } from \"./frontend_renderers2.ts\";\nimport { getCRMJS } from \"./frontend_crm.ts\";\nimport { getCRM2JS } from \"./frontend_crm2.ts\";\nimport { getMarketing2JS } from \"./frontend_marketing2.ts\";\nimport { getMarketing3JS } from \"./frontend_marketing3.ts\";\nimport { getMarketing4JS } from \"./frontend_marketing4.ts\";\nimport { getMarketing5JS } from \"./frontend_marketing5.ts\";\nimport { getMarketing6JS } from \"./frontend_marketing6.ts\";\nimport { getMarketingWorkspaceJS } from \"./frontend_marketing.ts\";\nimport { getPagesJS } from \"./frontend_pages.ts\";\nimport { getCommandJS } from \"./frontend_command.ts\";\nimport { getIntelligenceJS } from \"./frontend_intelligence.ts\";\nimport { getSettingsJS } from \"./frontend_settings.ts\";\nimport { getWidgetsJS } from \"./frontend_widgets.ts\";\nimport { getObjectivesJS } from \"./frontend_objectives.ts\";\nimport { getCalendarJS } from \"./frontend_calendar.ts\";\nimport { getExperimentsJS } from \"./frontend_experiments.ts\";\nimport { getSkillsJS } from \"./frontend_skills.ts\";\nimport { getWorldJS } from \"./frontend_world.ts\";\nimport { getWorldSceneJS } from \"./frontend_world_scene.ts\";\nimport { getWorldOfficeJS } from \"./frontend_world_office.ts\";\nimport { getWorldAgentsJS } from \"./frontend_world_agents.ts\";\nimport { getWorldUIJS } from \"./frontend_world_ui.ts\";\nimport { getWorldDashJS } from \"./frontend_world_dash.ts\";\nimport { getCampaignsJS } from \"./frontend_campaigns.ts\";\nimport { getTasksJS } from \"./frontend_tasks.ts\";\nimport { getKnowledgeGraphJS } from \"./frontend_knowledge_graph.ts\";\nimport { getApprovalsJS } from \"./frontend_approvals.ts\";\nimport { getPlatformJS } from \"./frontend_platform.ts\";\nimport { getSupportJS } from \"./frontend_support.ts\";\n\nconst MODULE_ROUTES: Record string> = {\n \"/api/app-js\": getAppJS,\n \"/api/app-ui\": getUIJS,\n \"/api/app-charts\": getChartsJS,\n \"/api/app-renderers\": getRenderersJS,\n \"/api/app-renderers2\": getRenderers2JS,\n \"/api/app-pages\": getPagesJS,\n \"/api/app-command\": getCommandJS,\n \"/api/app-intelligence\": getIntelligenceJS,\n \"/api/app-settings\": getSettingsJS,\n \"/api/app-widgets\": getWidgetsJS,\n \"/api/app-objectives\": getObjectivesJS,\n \"/api/app-calendar\": getCalendarJS,\n \"/api/app-experiments\": getExperimentsJS,\n \"/api/app-campaigns\": getCampaignsJS,\n \"/api/app-tasks\": getTasksJS,\n \"/api/app-knowledge-graph\": getKnowledgeGraphJS,\n \"/api/app-approvals\": getApprovalsJS,\n \"/api/app-crm\": getCRMJS,\n \"/api/app-crm2\": getCRM2JS,\n \"/api/app-marketing2\": getMarketing2JS,\n \"/api/app-marketing3\": getMarketing3JS,\n \"/api/app-marketing4\": getMarketing4JS,\n \"/api/app-marketing5\": getMarketing5JS,\n \"/api/app-marketing6\": getMarketing6JS,\n \"/api/app-marketing\": getMarketingWorkspaceJS,\n \"/api/app-skills\": getSkillsJS,\n \"/api/app-world\": getWorldJS,\n \"/api/app-world-scene\": getWorldSceneJS,\n \"/api/app-world-office\": getWorldOfficeJS,\n \"/api/app-world-agents\": getWorldAgentsJS,\n \"/api/app-world-ui\": getWorldUIJS,\n \"/api/app-world-dash\": getWorldDashJS,\n \"/api/app-platform\": getPlatformJS,\n \"/api/app-support\": getSupportJS,\n};\n\n// Return the browser module source for a frontend route, or null if pathname is not one.\nexport function serveAppModule(pathname: string): string | null {\n const fn = MODULE_ROUTES[pathname];\n return fn ? fn() : null;\n}\n",[521],"eb52f0ae-5d6d-11f1-95b0-1607ee4eb77e","skills","00cb9425-5deb-432c-b10f-0fcd3d61109e",644,["D",1780286210534],"directory",[528],"d0f43d42-5b4e-11f1-8d86-ee650bb23af1","renderers","d81e0fb0-4134-482f-8b60-863ef03f710e",520,["D",1780052949625],[535],"156bfa70-56ca-11f1-8a9a-ee650bb23af1","api","e712dcc1-c69e-4e42-a401-18299fcf7843",["D",1779556136787],[541],"pulls","branches","forks","envVars",{"_552":236,"_554":64},"connections",{"_552":303,"_553":64},"count","unfilledCount","emptyCount",{"_44":540,"_32":541,"_30":542,"_183":-5,"_42":43,"_41":196,"_185":60,"_39":1895,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_735":1896,"_27":1897},{"_44":1890,"_32":1744,"_30":1738,"_183":542,"_42":43,"_41":1891,"_185":60,"_39":1892,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_735":1893,"_27":1894},{"_44":1882,"_32":1883,"_30":1884,"_183":1738,"_42":43,"_41":1885,"_185":60,"_39":1886,"_13":196,"_34":35,"_36":1887,"_24":25,"_189":-5,"_735":1888,"_27":1889},{"_44":1874,"_32":1875,"_30":1876,"_183":1738,"_42":43,"_41":1877,"_185":25,"_39":1878,"_13":187,"_34":35,"_36":1879,"_24":25,"_189":-5,"_735":1880,"_27":1881},{"_44":1867,"_32":1216,"_30":1868,"_183":1738,"_42":43,"_41":1869,"_185":60,"_39":1870,"_13":196,"_34":35,"_36":1871,"_24":25,"_189":-5,"_735":1872,"_27":1873},{"_44":1860,"_32":1208,"_30":1861,"_183":1738,"_42":43,"_41":1862,"_185":60,"_39":1863,"_13":303,"_34":35,"_36":1864,"_24":25,"_189":-5,"_735":1865,"_27":1866},{"_44":1853,"_32":1200,"_30":1854,"_183":1738,"_42":43,"_41":1855,"_185":60,"_39":1856,"_13":326,"_34":35,"_36":1857,"_24":25,"_189":-5,"_735":1858,"_27":1859},{"_44":1846,"_32":1192,"_30":1847,"_183":1738,"_42":43,"_41":1848,"_185":60,"_39":1849,"_13":228,"_34":35,"_36":1850,"_24":25,"_189":-5,"_735":1851,"_27":1852},{"_44":1839,"_32":1184,"_30":1840,"_183":1738,"_42":43,"_41":1841,"_185":60,"_39":1842,"_13":64,"_34":35,"_36":1843,"_24":25,"_189":-5,"_735":1844,"_27":1845},{"_44":1832,"_32":1176,"_30":1833,"_183":1738,"_42":43,"_41":1834,"_185":60,"_39":1835,"_13":220,"_34":35,"_36":1836,"_24":25,"_189":-5,"_735":1837,"_27":1838},{"_44":1825,"_32":1168,"_30":1826,"_183":1738,"_42":43,"_41":1827,"_185":60,"_39":1828,"_13":303,"_34":35,"_36":1829,"_24":25,"_189":-5,"_735":1830,"_27":1831},{"_44":1817,"_32":1818,"_30":1819,"_183":1738,"_42":43,"_41":1820,"_185":60,"_39":1821,"_13":64,"_34":35,"_36":1822,"_24":25,"_189":-5,"_735":1823,"_27":1824},{"_44":1810,"_32":1160,"_30":1811,"_183":1738,"_42":43,"_41":1812,"_185":60,"_39":1813,"_13":228,"_34":35,"_36":1814,"_24":25,"_189":-5,"_735":1815,"_27":1816},{"_44":1803,"_32":1152,"_30":1804,"_183":1738,"_42":43,"_41":1805,"_185":60,"_39":1806,"_13":274,"_34":35,"_36":1807,"_24":25,"_189":-5,"_735":1808,"_27":1809},{"_44":1795,"_32":1796,"_30":1797,"_183":1738,"_42":43,"_41":1798,"_185":60,"_39":1799,"_13":64,"_34":35,"_36":1800,"_24":25,"_189":-5,"_735":1801,"_27":1802},{"_44":1787,"_32":1788,"_30":1789,"_183":1738,"_42":43,"_41":1790,"_185":60,"_39":1791,"_13":64,"_34":35,"_36":1792,"_24":25,"_189":-5,"_735":1793,"_27":1794},{"_44":1780,"_32":1144,"_30":1781,"_183":1738,"_42":43,"_41":1782,"_185":60,"_39":1783,"_13":228,"_34":35,"_36":1784,"_24":25,"_189":-5,"_735":1785,"_27":1786},{"_44":1773,"_32":1136,"_30":1774,"_183":1738,"_42":43,"_41":1775,"_185":60,"_39":1776,"_13":480,"_34":35,"_36":1777,"_24":25,"_189":-5,"_735":1778,"_27":1779},{"_44":1766,"_32":1128,"_30":1767,"_183":1738,"_42":43,"_41":1768,"_185":60,"_39":1769,"_13":64,"_34":35,"_36":1770,"_24":25,"_189":-5,"_735":1771,"_27":1772},{"_44":1759,"_32":1120,"_30":1760,"_183":1738,"_42":43,"_41":1761,"_185":60,"_39":1762,"_13":64,"_34":35,"_36":1763,"_24":25,"_189":-5,"_735":1764,"_27":1765},{"_44":1752,"_32":1112,"_30":1753,"_183":1738,"_42":43,"_41":1754,"_185":60,"_39":1755,"_13":64,"_34":35,"_36":1756,"_24":25,"_189":-5,"_735":1757,"_27":1758},{"_44":1745,"_32":1104,"_30":1746,"_183":1738,"_42":43,"_41":1747,"_185":60,"_39":1748,"_13":326,"_34":35,"_36":1749,"_24":25,"_189":-5,"_735":1750,"_27":1751},{"_44":1736,"_32":1096,"_30":1737,"_183":1738,"_42":43,"_41":1739,"_185":25,"_39":1740,"_13":326,"_34":35,"_36":1741,"_24":25,"_189":-5,"_735":1742,"_27":1743},{"_44":1728,"_32":1729,"_30":1730,"_183":542,"_42":43,"_41":1731,"_185":60,"_39":1732,"_13":64,"_34":35,"_36":1733,"_24":25,"_189":-5,"_735":1734,"_27":1735},{"_44":1720,"_32":1721,"_30":1722,"_183":542,"_42":43,"_41":1723,"_185":60,"_39":1724,"_13":64,"_34":35,"_36":1725,"_24":25,"_189":-5,"_735":1726,"_27":1727},{"_44":1712,"_32":1713,"_30":1714,"_183":542,"_42":43,"_41":1715,"_185":60,"_39":1716,"_13":326,"_34":35,"_36":1717,"_24":25,"_189":-5,"_735":1718,"_27":1719},{"_44":1704,"_32":1705,"_30":1706,"_183":542,"_42":43,"_41":1707,"_185":60,"_39":1708,"_13":64,"_34":35,"_36":1709,"_24":25,"_189":-5,"_735":1710,"_27":1711},{"_44":1696,"_32":1697,"_30":1698,"_183":542,"_42":43,"_41":1699,"_185":60,"_39":1700,"_13":1483,"_34":35,"_36":1701,"_24":25,"_189":-5,"_735":1702,"_27":1703},{"_44":1688,"_32":1689,"_30":1690,"_183":542,"_42":43,"_41":1691,"_185":60,"_39":1692,"_13":303,"_34":35,"_36":1693,"_24":25,"_189":-5,"_735":1694,"_27":1695},{"_44":1680,"_32":1681,"_30":1682,"_183":542,"_42":43,"_41":1683,"_185":60,"_39":1684,"_13":480,"_34":35,"_36":1685,"_24":25,"_189":-5,"_735":1686,"_27":1687},{"_44":1672,"_32":1673,"_30":1674,"_183":542,"_42":43,"_41":1675,"_185":60,"_39":1676,"_13":64,"_34":35,"_36":1677,"_24":25,"_189":-5,"_735":1678,"_27":1679},{"_44":1664,"_32":1665,"_30":1666,"_183":542,"_42":43,"_41":1667,"_185":60,"_39":1668,"_13":64,"_34":35,"_36":1669,"_24":25,"_189":-5,"_735":1670,"_27":1671},{"_44":1656,"_32":1657,"_30":1658,"_183":542,"_42":43,"_41":1659,"_185":60,"_39":1660,"_13":236,"_34":35,"_36":1661,"_24":25,"_189":-5,"_735":1662,"_27":1663},{"_44":1648,"_32":1649,"_30":1650,"_183":542,"_42":43,"_41":1651,"_185":60,"_39":1652,"_13":64,"_34":35,"_36":1653,"_24":25,"_189":-5,"_735":1654,"_27":1655},{"_44":1640,"_32":1641,"_30":1642,"_183":542,"_42":43,"_41":1643,"_185":60,"_39":1644,"_13":220,"_34":35,"_36":1645,"_24":25,"_189":-5,"_735":1646,"_27":1647},{"_44":1632,"_32":1633,"_30":1634,"_183":542,"_42":43,"_41":1635,"_185":60,"_39":1636,"_13":64,"_34":35,"_36":1637,"_24":25,"_189":-5,"_735":1638,"_27":1639},{"_44":1624,"_32":1625,"_30":1626,"_183":542,"_42":43,"_41":1627,"_185":60,"_39":1628,"_13":480,"_34":35,"_36":1629,"_24":25,"_189":-5,"_735":1630,"_27":1631},{"_44":1615,"_32":1616,"_30":1617,"_183":542,"_42":43,"_41":1618,"_185":60,"_39":1619,"_13":1620,"_34":35,"_36":1621,"_24":25,"_189":-5,"_735":1622,"_27":1623},{"_44":1607,"_32":1608,"_30":1609,"_183":542,"_42":43,"_41":1610,"_185":60,"_39":1611,"_13":64,"_34":35,"_36":1612,"_24":25,"_189":-5,"_735":1613,"_27":1614},{"_44":1599,"_32":1600,"_30":1601,"_183":542,"_42":43,"_41":1602,"_185":25,"_39":1603,"_13":303,"_34":35,"_36":1604,"_24":25,"_189":-5,"_735":1605,"_27":1606},{"_44":1591,"_32":1592,"_30":1593,"_183":542,"_42":43,"_41":1594,"_185":25,"_39":1595,"_13":303,"_34":35,"_36":1596,"_24":25,"_189":-5,"_735":1597,"_27":1598},{"_44":1583,"_32":1584,"_30":1585,"_183":542,"_42":43,"_41":1586,"_185":60,"_39":1587,"_13":64,"_34":35,"_36":1588,"_24":25,"_189":-5,"_735":1589,"_27":1590},{"_44":1575,"_32":1576,"_30":1577,"_183":542,"_42":43,"_41":1578,"_185":60,"_39":1579,"_13":64,"_34":35,"_36":1580,"_24":25,"_189":-5,"_735":1581,"_27":1582},{"_44":1567,"_32":1568,"_30":1569,"_183":542,"_42":43,"_41":1570,"_185":60,"_39":1571,"_13":64,"_34":35,"_36":1572,"_24":25,"_189":-5,"_735":1573,"_27":1574},{"_44":1559,"_32":1560,"_30":1561,"_183":542,"_42":43,"_41":1562,"_185":60,"_39":1563,"_13":326,"_34":35,"_36":1564,"_24":25,"_189":-5,"_735":1565,"_27":1566},{"_44":1551,"_32":1552,"_30":1553,"_183":542,"_42":43,"_41":1554,"_185":60,"_39":1555,"_13":64,"_34":35,"_36":1556,"_24":25,"_189":-5,"_735":1557,"_27":1558},{"_44":1543,"_32":1544,"_30":1545,"_183":542,"_42":43,"_41":1546,"_185":60,"_39":1547,"_13":472,"_34":35,"_36":1548,"_24":25,"_189":-5,"_735":1549,"_27":1550},{"_44":1535,"_32":1536,"_30":1537,"_183":542,"_42":43,"_41":1538,"_185":60,"_39":1539,"_13":64,"_34":35,"_36":1540,"_24":25,"_189":-5,"_735":1541,"_27":1542},{"_44":1527,"_32":1528,"_30":1529,"_183":542,"_42":43,"_41":1530,"_185":60,"_39":1531,"_13":236,"_34":35,"_36":1532,"_24":25,"_189":-5,"_735":1533,"_27":1534},{"_44":1519,"_32":1520,"_30":1521,"_183":542,"_42":43,"_41":1522,"_185":60,"_39":1523,"_13":266,"_34":35,"_36":1524,"_24":25,"_189":-5,"_735":1525,"_27":1526},{"_44":1511,"_32":1512,"_30":1513,"_183":542,"_42":43,"_41":1514,"_185":60,"_39":1515,"_13":303,"_34":35,"_36":1516,"_24":25,"_189":-5,"_735":1517,"_27":1518},{"_44":1503,"_32":1504,"_30":1505,"_183":542,"_42":43,"_41":1506,"_185":60,"_39":1507,"_13":64,"_34":35,"_36":1508,"_24":25,"_189":-5,"_735":1509,"_27":1510},{"_44":1495,"_32":1496,"_30":1497,"_183":542,"_42":43,"_41":1498,"_185":60,"_39":1499,"_13":64,"_34":35,"_36":1500,"_24":25,"_189":-5,"_735":1501,"_27":1502},{"_44":1487,"_32":1488,"_30":1489,"_183":542,"_42":43,"_41":1490,"_185":25,"_39":1491,"_13":349,"_34":35,"_36":1492,"_24":25,"_189":-5,"_735":1493,"_27":1494},{"_44":1478,"_32":1479,"_30":1480,"_183":542,"_42":43,"_41":1481,"_185":25,"_39":1482,"_13":1483,"_34":35,"_36":1484,"_24":25,"_189":-5,"_735":1485,"_27":1486},{"_44":1470,"_32":1471,"_30":1472,"_183":542,"_42":43,"_41":1473,"_185":60,"_39":1474,"_13":64,"_34":35,"_36":1475,"_24":25,"_189":-5,"_735":1476,"_27":1477},{"_44":1462,"_32":1463,"_30":1464,"_183":542,"_42":43,"_41":1465,"_185":60,"_39":1466,"_13":220,"_34":35,"_36":1467,"_24":25,"_189":-5,"_735":1468,"_27":1469},{"_44":1454,"_32":1455,"_30":1456,"_183":542,"_42":43,"_41":1457,"_185":25,"_39":1458,"_13":64,"_34":35,"_36":1459,"_24":25,"_189":-5,"_735":1460,"_27":1461},{"_44":1450,"_32":33,"_30":31,"_183":542,"_42":43,"_41":14,"_185":60,"_39":1451,"_13":303,"_34":35,"_36":38,"_24":25,"_189":-5,"_735":1452,"_27":1453},{"_44":1442,"_32":1443,"_30":1444,"_183":542,"_42":43,"_41":1445,"_185":60,"_39":1446,"_13":64,"_34":35,"_36":1447,"_24":25,"_189":-5,"_735":1448,"_27":1449},{"_44":1433,"_32":1434,"_30":1435,"_183":542,"_42":43,"_41":1436,"_185":25,"_39":1437,"_13":1438,"_34":35,"_36":1439,"_24":25,"_189":-5,"_735":1440,"_27":1441},{"_44":1425,"_32":1426,"_30":1427,"_183":542,"_42":43,"_41":1428,"_185":60,"_39":1429,"_13":64,"_34":35,"_36":1430,"_24":25,"_189":-5,"_735":1431,"_27":1432},{"_44":1417,"_32":1418,"_30":1419,"_183":542,"_42":43,"_41":1420,"_185":60,"_39":1421,"_13":196,"_34":35,"_36":1422,"_24":25,"_189":-5,"_735":1423,"_27":1424},{"_44":1409,"_32":1410,"_30":1411,"_183":542,"_42":43,"_41":1412,"_185":60,"_39":1413,"_13":64,"_34":35,"_36":1414,"_24":25,"_189":-5,"_735":1415,"_27":1416},{"_44":1401,"_32":1402,"_30":1403,"_183":542,"_42":43,"_41":1404,"_185":25,"_39":1405,"_13":228,"_34":35,"_36":1406,"_24":25,"_189":-5,"_735":1407,"_27":1408},{"_44":1393,"_32":1394,"_30":1395,"_183":542,"_42":43,"_41":1396,"_185":60,"_39":1397,"_13":303,"_34":35,"_36":1398,"_24":25,"_189":-5,"_735":1399,"_27":1400},{"_44":1385,"_32":1386,"_30":1387,"_183":542,"_42":43,"_41":1388,"_185":60,"_39":1389,"_13":303,"_34":35,"_36":1390,"_24":25,"_189":-5,"_735":1391,"_27":1392},{"_44":1377,"_32":1378,"_30":1379,"_183":542,"_42":43,"_41":1380,"_185":25,"_39":1381,"_13":303,"_34":35,"_36":1382,"_24":25,"_189":-5,"_735":1383,"_27":1384},{"_44":1369,"_32":1370,"_30":1371,"_183":542,"_42":43,"_41":1372,"_185":25,"_39":1373,"_13":480,"_34":35,"_36":1374,"_24":25,"_189":-5,"_735":1375,"_27":1376},{"_44":1361,"_32":1362,"_30":1363,"_183":542,"_42":43,"_41":1364,"_185":25,"_39":1365,"_13":64,"_34":35,"_36":1366,"_24":25,"_189":-5,"_735":1367,"_27":1368},{"_44":1353,"_32":1354,"_30":1355,"_183":542,"_42":43,"_41":1356,"_185":60,"_39":1357,"_13":472,"_34":35,"_36":1358,"_24":25,"_189":-5,"_735":1359,"_27":1360},{"_44":1345,"_32":1346,"_30":1347,"_183":542,"_42":43,"_41":1348,"_185":60,"_39":1349,"_13":303,"_34":35,"_36":1350,"_24":25,"_189":-5,"_735":1351,"_27":1352},{"_44":1337,"_32":1338,"_30":1339,"_183":542,"_42":43,"_41":1340,"_185":60,"_39":1341,"_13":64,"_34":35,"_36":1342,"_24":25,"_189":-5,"_735":1343,"_27":1344},{"_44":1329,"_32":1330,"_30":1331,"_183":542,"_42":43,"_41":1332,"_185":60,"_39":1333,"_13":64,"_34":35,"_36":1334,"_24":25,"_189":-5,"_735":1335,"_27":1336},{"_44":1321,"_32":1322,"_30":1323,"_183":542,"_42":43,"_41":1324,"_185":60,"_39":1325,"_13":196,"_34":35,"_36":1326,"_24":25,"_189":-5,"_735":1327,"_27":1328},{"_44":1313,"_32":1314,"_30":1315,"_183":542,"_42":43,"_41":1316,"_185":60,"_39":1317,"_13":220,"_34":35,"_36":1318,"_24":25,"_189":-5,"_735":1319,"_27":1320},{"_44":1305,"_32":1306,"_30":1307,"_183":542,"_42":43,"_41":1308,"_185":60,"_39":1309,"_13":64,"_34":35,"_36":1310,"_24":25,"_189":-5,"_735":1311,"_27":1312},{"_44":1297,"_32":1298,"_30":1299,"_183":542,"_42":43,"_41":1300,"_185":25,"_39":1301,"_13":64,"_34":35,"_36":1302,"_24":25,"_189":-5,"_735":1303,"_27":1304},{"_44":1289,"_32":1290,"_30":1291,"_183":542,"_42":43,"_41":1292,"_185":60,"_39":1293,"_13":64,"_34":35,"_36":1294,"_24":25,"_189":-5,"_735":1295,"_27":1296},{"_44":1281,"_32":1282,"_30":1283,"_183":542,"_42":43,"_41":1284,"_185":60,"_39":1285,"_13":220,"_34":35,"_36":1286,"_24":25,"_189":-5,"_735":1287,"_27":1288},{"_44":1273,"_32":1274,"_30":1275,"_183":542,"_42":43,"_41":1276,"_185":60,"_39":1277,"_13":303,"_34":35,"_36":1278,"_24":25,"_189":-5,"_735":1279,"_27":1280},{"_44":1265,"_32":1266,"_30":1267,"_183":542,"_42":43,"_41":1268,"_185":60,"_39":1269,"_13":64,"_34":35,"_36":1270,"_24":25,"_189":-5,"_735":1271,"_27":1272},{"_44":1257,"_32":1258,"_30":1259,"_183":542,"_42":43,"_41":1260,"_185":60,"_39":1261,"_13":64,"_34":35,"_36":1262,"_24":25,"_189":-5,"_735":1263,"_27":1264},{"_44":1249,"_32":1250,"_30":1251,"_183":542,"_42":43,"_41":1252,"_185":60,"_39":1253,"_13":258,"_34":35,"_36":1254,"_24":25,"_189":-5,"_735":1255,"_27":1256},{"_44":1241,"_32":1242,"_30":1243,"_183":542,"_42":43,"_41":1244,"_185":60,"_39":1245,"_13":64,"_34":35,"_36":1246,"_24":25,"_189":-5,"_735":1247,"_27":1248},{"_44":1233,"_32":1234,"_30":1235,"_183":542,"_42":43,"_41":1236,"_185":60,"_39":1237,"_13":236,"_34":35,"_36":1238,"_24":25,"_189":-5,"_735":1239,"_27":1240},{"_44":534,"_32":535,"_30":536,"_183":-5,"_42":43,"_41":537,"_185":60,"_39":1230,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_735":1231,"_27":1232},{"_44":1223,"_32":1224,"_30":1225,"_183":536,"_42":43,"_41":537,"_185":60,"_39":1226,"_13":64,"_34":35,"_36":1227,"_24":25,"_189":-5,"_735":1228,"_27":1229},{"_44":1215,"_32":1216,"_30":1217,"_183":536,"_42":43,"_41":1218,"_185":60,"_39":1219,"_13":64,"_34":35,"_36":1220,"_24":25,"_189":-5,"_735":1221,"_27":1222},{"_44":1207,"_32":1208,"_30":1209,"_183":536,"_42":43,"_41":1210,"_185":60,"_39":1211,"_13":64,"_34":35,"_36":1212,"_24":25,"_189":-5,"_735":1213,"_27":1214},{"_44":1199,"_32":1200,"_30":1201,"_183":536,"_42":43,"_41":1202,"_185":60,"_39":1203,"_13":303,"_34":35,"_36":1204,"_24":25,"_189":-5,"_735":1205,"_27":1206},{"_44":1191,"_32":1192,"_30":1193,"_183":536,"_42":43,"_41":1194,"_185":60,"_39":1195,"_13":64,"_34":35,"_36":1196,"_24":25,"_189":-5,"_735":1197,"_27":1198},{"_44":1183,"_32":1184,"_30":1185,"_183":536,"_42":43,"_41":1186,"_185":60,"_39":1187,"_13":64,"_34":35,"_36":1188,"_24":25,"_189":-5,"_735":1189,"_27":1190},{"_44":1175,"_32":1176,"_30":1177,"_183":536,"_42":43,"_41":1178,"_185":60,"_39":1179,"_13":196,"_34":35,"_36":1180,"_24":25,"_189":-5,"_735":1181,"_27":1182},{"_44":1167,"_32":1168,"_30":1169,"_183":536,"_42":43,"_41":1170,"_185":60,"_39":1171,"_13":64,"_34":35,"_36":1172,"_24":25,"_189":-5,"_735":1173,"_27":1174},{"_44":1159,"_32":1160,"_30":1161,"_183":536,"_42":43,"_41":1162,"_185":60,"_39":1163,"_13":303,"_34":35,"_36":1164,"_24":25,"_189":-5,"_735":1165,"_27":1166},{"_44":1151,"_32":1152,"_30":1153,"_183":536,"_42":43,"_41":1154,"_185":60,"_39":1155,"_13":64,"_34":35,"_36":1156,"_24":25,"_189":-5,"_735":1157,"_27":1158},{"_44":1143,"_32":1144,"_30":1145,"_183":536,"_42":43,"_41":1146,"_185":60,"_39":1147,"_13":64,"_34":35,"_36":1148,"_24":25,"_189":-5,"_735":1149,"_27":1150},{"_44":1135,"_32":1136,"_30":1137,"_183":536,"_42":43,"_41":1138,"_185":60,"_39":1139,"_13":64,"_34":35,"_36":1140,"_24":25,"_189":-5,"_735":1141,"_27":1142},{"_44":1127,"_32":1128,"_30":1129,"_183":536,"_42":43,"_41":1130,"_185":60,"_39":1131,"_13":64,"_34":35,"_36":1132,"_24":25,"_189":-5,"_735":1133,"_27":1134},{"_44":1119,"_32":1120,"_30":1121,"_183":536,"_42":43,"_41":1122,"_185":60,"_39":1123,"_13":303,"_34":35,"_36":1124,"_24":25,"_189":-5,"_735":1125,"_27":1126},{"_44":1111,"_32":1112,"_30":1113,"_183":536,"_42":43,"_41":1114,"_185":60,"_39":1115,"_13":64,"_34":35,"_36":1116,"_24":25,"_189":-5,"_735":1117,"_27":1118},{"_44":1103,"_32":1104,"_30":1105,"_183":536,"_42":43,"_41":1106,"_185":60,"_39":1107,"_13":64,"_34":35,"_36":1108,"_24":25,"_189":-5,"_735":1109,"_27":1110},{"_44":1095,"_32":1096,"_30":1097,"_183":536,"_42":43,"_41":1098,"_185":60,"_39":1099,"_13":196,"_34":35,"_36":1100,"_24":25,"_189":-5,"_735":1101,"_27":1102},{"_44":527,"_32":528,"_30":529,"_183":-5,"_42":43,"_41":530,"_185":60,"_39":1092,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_735":1093,"_27":1094},{"_44":1088,"_32":1024,"_30":1018,"_183":529,"_42":43,"_41":530,"_185":60,"_39":1089,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_735":1090,"_27":1091},{"_44":1081,"_32":1082,"_30":1083,"_183":1018,"_42":43,"_41":530,"_185":60,"_39":1084,"_13":64,"_34":35,"_36":1085,"_24":25,"_189":-5,"_735":1086,"_27":1087},{"_44":1073,"_32":1074,"_30":1075,"_183":1018,"_42":43,"_41":1076,"_185":60,"_39":1077,"_13":64,"_34":35,"_36":1078,"_24":25,"_189":-5,"_735":1079,"_27":1080},{"_44":1065,"_32":1066,"_30":1067,"_183":1018,"_42":43,"_41":1068,"_185":60,"_39":1069,"_13":64,"_34":35,"_36":1070,"_24":25,"_189":-5,"_735":1071,"_27":1072},{"_44":1057,"_32":1058,"_30":1059,"_183":1018,"_42":43,"_41":1060,"_185":60,"_39":1061,"_13":64,"_34":35,"_36":1062,"_24":25,"_189":-5,"_735":1063,"_27":1064},{"_44":1049,"_32":1050,"_30":1051,"_183":1018,"_42":43,"_41":1052,"_185":60,"_39":1053,"_13":64,"_34":35,"_36":1054,"_24":25,"_189":-5,"_735":1055,"_27":1056},{"_44":1041,"_32":1042,"_30":1043,"_183":1018,"_42":43,"_41":1044,"_185":60,"_39":1045,"_13":64,"_34":35,"_36":1046,"_24":25,"_189":-5,"_735":1047,"_27":1048},{"_44":1033,"_32":1034,"_30":1035,"_183":1018,"_42":43,"_41":1036,"_185":60,"_39":1037,"_13":64,"_34":35,"_36":1038,"_24":25,"_189":-5,"_735":1039,"_27":1040},{"_44":1025,"_32":1026,"_30":1027,"_183":1018,"_42":43,"_41":1028,"_185":60,"_39":1029,"_13":64,"_34":35,"_36":1030,"_24":25,"_189":-5,"_735":1031,"_27":1032},{"_44":1015,"_32":1016,"_30":1017,"_183":1018,"_42":43,"_41":1019,"_185":60,"_39":1020,"_13":64,"_34":35,"_36":1021,"_24":25,"_189":-5,"_735":1022,"_27":1023},{"_44":1011,"_32":890,"_30":884,"_183":529,"_42":43,"_41":1006,"_185":60,"_39":1012,"_13":64,"_34":532,"_36":-5,"_24":25,"_189":-5,"_735":1013,"_27":1014},{"_44":1003,"_32":1004,"_30":1005,"_183":884,"_42":43,"_41":1006,"_185":60,"_39":1007,"_13":64,"_34":35,"_36":1008,"_24":25,"_189":-5,"_735":1009,"_27":1010},{"_44":995,"_32":996,"_30":997,"_183":884,"_42":43,"_41":998,"_185":60,"_39":999,"_13":64,"_34":35,"_36":1000,"_24":25,"_189":-5,"_735":1001,"_27":1002},{"_44":987,"_32":988,"_30":989,"_183":884,"_42":43,"_41":990,"_185":60,"_39":991,"_13":64,"_34":35,"_36":992,"_24":25,"_189":-5,"_735":993,"_27":994},{"_44":979,"_32":980,"_30":981,"_183":884,"_42":43,"_41":982,"_185":60,"_39":983,"_13":64,"_34":35,"_36":984,"_24":25,"_189":-5,"_735":985,"_27":986},{"_44":971,"_32":972,"_30":973,"_183":884,"_42":43,"_41":974,"_185":60,"_39":975,"_13":64,"_34":35,"_36":976,"_24":25,"_189":-5,"_735":977,"_27":978},{"_44":963,"_32":964,"_30":965,"_183":884,"_42":43,"_41":966,"_185":60,"_39":967,"_13":64,"_34":35,"_36":968,"_24":25,"_189":-5,"_735":969,"_27":970},{"_44":955,"_32":956,"_30":957,"_183":884,"_42":43,"_41":958,"_185":60,"_39":959,"_13":64,"_34":35,"_36":960,"_24":25,"_189":-5,"_735":961,"_27":962},{"_44":947,"_32":948,"_30":949,"_183":884,"_42":43,"_41":950,"_185":60,"_39":951,"_13":64,"_34":35,"_36":952,"_24":25,"_189":-5,"_735":953,"_27":954},{"_44":939,"_32":940,"_30":941,"_183":884,"_42":43,"_41":942,"_185":60,"_39":943,"_13":64,"_34":35,"_36":944,"_24":25,"_189":-5,"_735":945,"_27":946},{"_44":931,"_32":932,"_30":933,"_183":884,"_42":43,"_41":934,"_185":60,"_39":935,"_13":64,"_34":35,"_36":936,"_24":25,"_189":-5,"_735":937,"_27":938},{"_44":923,"_32":924,"_30":925,"_183":884,"_42":43,"_41":926,"_185":60,"_39":927,"_13":64,"_34":35,"_36":928,"_24":25,"_189":-5,"_735":929,"_27":930},{"_44":915,"_32":916,"_30":917,"_183":884,"_42":43,"_41":918,"_185":60,"_39":919,"_13":64,"_34":35,"_36":920,"_24":25,"_189":-5,"_735":921,"_27":922},{"_44":907,"_32":908,"_30":909,"_183":884,"_42":43,"_41":910,"_185":60,"_39":911,"_13":64,"_34":35,"_36":912,"_24":25,"_189":-5,"_735":913,"_27":914},{"_44":899,"_32":900,"_30":901,"_183":884,"_42":43,"_41":902,"_185":60,"_39":903,"_13":64,"_34":35,"_36":904,"_24":25,"_189":-5,"_735":905,"_27":906},{"_44":891,"_32":892,"_30":893,"_183":884,"_42":43,"_41":894,"_185":60,"_39":895,"_13":64,"_34":35,"_36":896,"_24":25,"_189":-5,"_735":897,"_27":898},{"_44":881,"_32":882,"_30":883,"_183":884,"_42":43,"_41":885,"_185":60,"_39":886,"_13":64,"_34":35,"_36":887,"_24":25,"_189":-5,"_735":888,"_27":889},{"_44":873,"_32":874,"_30":875,"_183":529,"_42":43,"_41":876,"_185":60,"_39":877,"_13":64,"_34":35,"_36":878,"_24":25,"_189":-5,"_735":879,"_27":880},{"_44":520,"_32":521,"_30":522,"_183":-5,"_42":43,"_41":523,"_185":60,"_39":870,"_13":236,"_34":35,"_36":525,"_24":25,"_189":-5,"_735":871,"_27":872},{"_44":513,"_32":514,"_30":515,"_183":-5,"_42":43,"_41":516,"_185":25,"_39":867,"_13":220,"_34":35,"_36":518,"_24":25,"_189":-5,"_735":868,"_27":869},{"_44":506,"_32":507,"_30":508,"_183":-5,"_42":43,"_41":509,"_185":60,"_39":864,"_13":196,"_34":35,"_36":511,"_24":25,"_189":-5,"_735":865,"_27":866},{"_44":498,"_32":499,"_30":500,"_183":-5,"_42":43,"_41":501,"_185":25,"_39":861,"_13":503,"_34":35,"_36":504,"_24":25,"_189":-5,"_735":862,"_27":863},{"_44":490,"_32":491,"_30":492,"_183":-5,"_42":43,"_41":493,"_185":25,"_39":858,"_13":495,"_34":35,"_36":496,"_24":25,"_189":-5,"_735":859,"_27":860},{"_44":483,"_32":484,"_30":485,"_183":-5,"_42":43,"_41":486,"_185":60,"_39":855,"_13":303,"_34":35,"_36":488,"_24":25,"_189":-5,"_735":856,"_27":857},{"_44":475,"_32":476,"_30":477,"_183":-5,"_42":43,"_41":478,"_185":60,"_39":852,"_13":480,"_34":35,"_36":481,"_24":25,"_189":-5,"_735":853,"_27":854},{"_44":467,"_32":468,"_30":469,"_183":-5,"_42":43,"_41":470,"_185":60,"_39":849,"_13":472,"_34":35,"_36":473,"_24":25,"_189":-5,"_735":850,"_27":851},{"_44":460,"_32":461,"_30":462,"_183":-5,"_42":43,"_41":463,"_185":60,"_39":846,"_13":258,"_34":35,"_36":465,"_24":25,"_189":-5,"_735":847,"_27":848},{"_44":452,"_32":453,"_30":454,"_183":-5,"_42":43,"_41":455,"_185":60,"_39":843,"_13":457,"_34":35,"_36":458,"_24":25,"_189":-5,"_735":844,"_27":845},{"_44":445,"_32":446,"_30":447,"_183":-5,"_42":43,"_41":448,"_185":60,"_39":840,"_13":220,"_34":35,"_36":450,"_24":25,"_189":-5,"_735":841,"_27":842},{"_44":438,"_32":439,"_30":440,"_183":-5,"_42":43,"_41":441,"_185":60,"_39":837,"_13":64,"_34":35,"_36":443,"_24":25,"_189":-5,"_735":838,"_27":839},{"_44":431,"_32":432,"_30":433,"_183":-5,"_42":43,"_41":434,"_185":60,"_39":834,"_13":326,"_34":35,"_36":436,"_24":25,"_189":-5,"_735":835,"_27":836},{"_44":424,"_32":425,"_30":426,"_183":-5,"_42":43,"_41":427,"_185":60,"_39":831,"_13":220,"_34":35,"_36":429,"_24":25,"_189":-5,"_735":832,"_27":833},{"_44":416,"_32":417,"_30":418,"_183":-5,"_42":43,"_41":419,"_185":25,"_39":828,"_13":421,"_34":35,"_36":422,"_24":25,"_189":-5,"_735":829,"_27":830},{"_44":408,"_32":409,"_30":410,"_183":-5,"_42":43,"_41":411,"_185":25,"_39":825,"_13":413,"_34":35,"_36":414,"_24":25,"_189":-5,"_735":826,"_27":827},{"_44":401,"_32":402,"_30":403,"_183":-5,"_42":43,"_41":404,"_185":60,"_39":822,"_13":334,"_34":35,"_36":406,"_24":25,"_189":-5,"_735":823,"_27":824},{"_44":394,"_32":395,"_30":396,"_183":-5,"_42":43,"_41":397,"_185":25,"_39":819,"_13":326,"_34":35,"_36":399,"_24":25,"_189":-5,"_735":820,"_27":821},{"_44":387,"_32":388,"_30":389,"_183":-5,"_42":43,"_41":390,"_185":60,"_39":816,"_13":236,"_34":35,"_36":392,"_24":25,"_189":-5,"_735":817,"_27":818},{"_44":380,"_32":381,"_30":382,"_183":-5,"_42":43,"_41":383,"_185":60,"_39":813,"_13":64,"_34":35,"_36":385,"_24":25,"_189":-5,"_735":814,"_27":815},{"_44":373,"_32":374,"_30":375,"_183":-5,"_42":43,"_41":376,"_185":60,"_39":810,"_13":64,"_34":35,"_36":378,"_24":25,"_189":-5,"_735":811,"_27":812},{"_44":366,"_32":367,"_30":368,"_183":-5,"_42":43,"_41":369,"_185":60,"_39":807,"_13":64,"_34":35,"_36":371,"_24":25,"_189":-5,"_735":808,"_27":809},{"_44":359,"_32":360,"_30":361,"_183":-5,"_42":43,"_41":362,"_185":25,"_39":804,"_13":64,"_34":35,"_36":364,"_24":25,"_189":-5,"_735":805,"_27":806},{"_44":352,"_32":353,"_30":354,"_183":-5,"_42":43,"_41":355,"_185":60,"_39":801,"_13":326,"_34":35,"_36":357,"_24":25,"_189":-5,"_735":802,"_27":803},{"_44":344,"_32":345,"_30":346,"_183":-5,"_42":43,"_41":347,"_185":60,"_39":798,"_13":349,"_34":35,"_36":350,"_24":25,"_189":-5,"_735":799,"_27":800},{"_44":337,"_32":338,"_30":339,"_183":-5,"_42":43,"_41":340,"_185":60,"_39":795,"_13":196,"_34":35,"_36":342,"_24":25,"_189":-5,"_735":796,"_27":797},{"_44":329,"_32":330,"_30":331,"_183":-5,"_42":43,"_41":332,"_185":60,"_39":792,"_13":334,"_34":35,"_36":335,"_24":25,"_189":-5,"_735":793,"_27":794},{"_44":321,"_32":322,"_30":323,"_183":-5,"_42":43,"_41":324,"_185":60,"_39":789,"_13":326,"_34":35,"_36":327,"_24":25,"_189":-5,"_735":790,"_27":791},{"_44":313,"_32":314,"_30":315,"_183":-5,"_42":43,"_41":316,"_185":25,"_39":786,"_13":318,"_34":35,"_36":319,"_24":25,"_189":-5,"_735":787,"_27":788},{"_44":306,"_32":307,"_30":308,"_183":-5,"_42":43,"_41":309,"_185":60,"_39":783,"_13":196,"_34":35,"_36":311,"_24":25,"_189":-5,"_735":784,"_27":785},{"_44":298,"_32":299,"_30":300,"_183":-5,"_42":43,"_41":301,"_185":25,"_39":780,"_13":303,"_34":35,"_36":304,"_24":25,"_189":-5,"_735":781,"_27":782},{"_44":291,"_32":292,"_30":293,"_183":-5,"_42":43,"_41":294,"_185":60,"_39":777,"_13":236,"_34":35,"_36":296,"_24":25,"_189":-5,"_735":778,"_27":779},{"_44":284,"_32":285,"_30":286,"_183":-5,"_42":43,"_41":287,"_185":60,"_39":774,"_13":220,"_34":35,"_36":289,"_24":25,"_189":-5,"_735":775,"_27":776},{"_44":277,"_32":278,"_30":279,"_183":-5,"_42":43,"_41":280,"_185":60,"_39":771,"_13":196,"_34":35,"_36":282,"_24":25,"_189":-5,"_735":772,"_27":773},{"_44":269,"_32":270,"_30":271,"_183":-5,"_42":43,"_41":272,"_185":60,"_39":768,"_13":274,"_34":35,"_36":275,"_24":25,"_189":-5,"_735":769,"_27":770},{"_44":261,"_32":262,"_30":263,"_183":-5,"_42":43,"_41":264,"_185":60,"_39":765,"_13":266,"_34":35,"_36":267,"_24":25,"_189":-5,"_735":766,"_27":767},{"_44":253,"_32":254,"_30":255,"_183":-5,"_42":43,"_41":256,"_185":60,"_39":762,"_13":258,"_34":35,"_36":259,"_24":25,"_189":-5,"_735":763,"_27":764},{"_44":246,"_32":247,"_30":248,"_183":-5,"_42":43,"_41":249,"_185":60,"_39":759,"_13":64,"_34":35,"_36":251,"_24":25,"_189":-5,"_735":760,"_27":761},{"_44":239,"_32":240,"_30":241,"_183":-5,"_42":43,"_41":242,"_185":60,"_39":756,"_13":64,"_34":35,"_36":244,"_24":25,"_189":-5,"_735":757,"_27":758},{"_44":231,"_32":232,"_30":233,"_183":-5,"_42":43,"_41":234,"_185":60,"_39":753,"_13":236,"_34":35,"_36":237,"_24":25,"_189":-5,"_735":754,"_27":755},{"_44":223,"_32":224,"_30":225,"_183":-5,"_42":43,"_41":226,"_185":60,"_39":750,"_13":228,"_34":35,"_36":229,"_24":25,"_189":-5,"_735":751,"_27":752},{"_44":215,"_32":216,"_30":217,"_183":-5,"_42":43,"_41":218,"_185":60,"_39":747,"_13":220,"_34":35,"_36":221,"_24":25,"_189":-5,"_735":748,"_27":749},{"_44":207,"_32":208,"_30":58,"_183":-5,"_42":43,"_41":209,"_185":25,"_39":744,"_13":211,"_34":212,"_36":213,"_24":25,"_189":-5,"_735":745,"_27":746},{"_44":199,"_32":200,"_30":201,"_183":-5,"_42":43,"_41":202,"_185":25,"_39":741,"_13":204,"_34":35,"_36":205,"_24":25,"_189":-5,"_735":742,"_27":743},{"_44":191,"_32":192,"_30":193,"_183":-5,"_42":43,"_41":194,"_185":25,"_39":738,"_13":196,"_34":35,"_36":197,"_24":25,"_189":-5,"_735":739,"_27":740},{"_44":180,"_32":181,"_30":182,"_183":-5,"_42":43,"_41":184,"_185":60,"_39":734,"_13":187,"_34":35,"_36":188,"_24":25,"_189":-5,"_735":736,"_27":737},["D",1780291403301],"children",[],[181],["D",1780483958033],[],[192],["D",1780467943919],[],[200],["D",1780482718390],[],[208],["D",1780393062576],[],[216],["D",1780372195351],[],[224],["D",1780372198155],[],[232],["D",1780403524788],[],[240],["D",1780403526320],[],[247],["D",1780403527651],[],[254],["D",1780393064155],[],[262],["D",1780393049485],[],[270],["D",1780029981482],[],[278],["D",1779775316358],[],[285],["D",1780402139102],[],[292],["D",1780483403236],[],[299],["D",1780402136705],[],[307],["D",1780481469597],[],[314],["D",1780052948479],[],[322],["D",1780052947805],[],[330],["D",1780455959852],[],[338],["D",1780481472236],[],[345],["D",1780030685043],[],[353],["D",1780478543433],[],[360],["D",1780477255781],[],[367],["D",1780475241108],[],[374],["D",1780467941202],[],[381],["D",1780481471458],[],[388],["D",1780481470269],[],[395],["D",1780402137967],[],[402],["D",1780482717239],[],[409],["D",1780482719923],[],[417],["D",1780305934253],[],[425],["D",1780402134889],[],[432],["D",1780462244747],[],[439],["D",1780462245605],[],[446],["D",1780393054688],[],[453],["D",1780393060117],[],[461],["D",1780393047117],[],[468],["D",1780053308385],[],[476],["D",1780305932286],[],[484],["D",1780310003617],[],[491],["D",1780479282410],[],[499],["D",1780402127969],[],[507],["D",1780402128741],[],[514],["D",1780482715858],[],[521],"ffa758d8-5d6d-11f1-97cc-1607ee4eb77e","index.ts","ffa75996-5d6d-11f1-97cc-1607ee4eb77e",669,["D",1780286244707],"// GENERATED by deploy/gen_skills_catalog.mjs — do not edit by hand.\n// Bundled marketing-skills catalog (43 skills, 97 references),\n// read from memory like the renderers/ assembly. State (enabled/pinned/custom) lives in the\n// 'skills' DB table; this module is the immutable builtin content.\nimport { SKILLS_PART_1 } from \"./catalog/part_1.ts\";\nimport { SKILLS_PART_2 } from \"./catalog/part_2.ts\";\nimport { SKILLS_PART_3 } from \"./catalog/part_3.ts\";\nimport { SKILLS_PART_4 } from \"./catalog/part_4.ts\";\nimport { SKILLS_PART_5 } from \"./catalog/part_5.ts\";\nimport { SKILLS_PART_6 } from \"./catalog/part_6.ts\";\nimport { SKILLS_PART_7 } from \"./catalog/part_7.ts\";\nimport { SKILLS_PART_8 } from \"./catalog/part_8.ts\";\nimport { SKILLS_PART_9 } from \"./catalog/part_9.ts\";\nimport { REFS_PART_1 } from \"./refs/ref_1.ts\";\nimport { REFS_PART_2 } from \"./refs/ref_2.ts\";\nimport { REFS_PART_3 } from \"./refs/ref_3.ts\";\nimport { REFS_PART_4 } from \"./refs/ref_4.ts\";\nimport { REFS_PART_5 } from \"./refs/ref_5.ts\";\nimport { REFS_PART_6 } from \"./refs/ref_6.ts\";\nimport { REFS_PART_7 } from \"./refs/ref_7.ts\";\nimport { REFS_PART_8 } from \"./refs/ref_8.ts\";\nimport { REFS_PART_9 } from \"./refs/ref_9.ts\";\nimport { REFS_PART_10 } from \"./refs/ref_10.ts\";\nimport { REFS_PART_11 } from \"./refs/ref_11.ts\";\nimport { REFS_PART_12 } from \"./refs/ref_12.ts\";\nimport { REFS_PART_13 } from \"./refs/ref_13.ts\";\nimport { REFS_PART_14 } from \"./refs/ref_14.ts\";\nimport { REFS_PART_15 } from \"./refs/ref_15.ts\";\nimport { REFS_PART_16 } from \"./refs/ref_16.ts\";\n\nexport interface SkillDef { name: string; category: string; description: string; version: string; body: string }\nexport interface SkillRef { skill: string; ref: string; body: string }\n\nexport const BUILTIN_SKILLS: SkillDef[] = [...SKILLS_PART_1, ...SKILLS_PART_2, ...SKILLS_PART_3, ...SKILLS_PART_4, ...SKILLS_PART_5, ...SKILLS_PART_6, ...SKILLS_PART_7, ...SKILLS_PART_8, ...SKILLS_PART_9];\nconst REFS: SkillRef[] = [...REFS_PART_1, ...REFS_PART_2, ...REFS_PART_3, ...REFS_PART_4, ...REFS_PART_5, ...REFS_PART_6, ...REFS_PART_7, ...REFS_PART_8, ...REFS_PART_9, ...REFS_PART_10, ...REFS_PART_11, ...REFS_PART_12, ...REFS_PART_13, ...REFS_PART_14, ...REFS_PART_15, ...REFS_PART_16];\n\nconst BY_NAME = new Map(BUILTIN_SKILLS.map((s) => [s.name, s]));\n\nexport function getSkillDef(name: string): SkillDef | undefined { return BY_NAME.get(name); }\nexport function getSkillBody(name: string): string | null { return BY_NAME.get(name)?.body ?? null; }\nexport function listReferences(name: string): string[] { return REFS.filter((r) => r.skill === name).map((r) => r.ref); }\nexport function getReference(name: string, ref: string): string | null {\n const hit = REFS.find((r) => r.skill === name && r.ref === ref);\n return hit ? hit.body : null;\n}\n",[],[528,874],"ff025a0e-5d6d-11f1-b895-1607ee4eb77e","ref_9.ts","ff025aea-5d6d-11f1-b895-1607ee4eb77e","c9768083-9936-4697-a4d4-80b7978fe701",668,["D",1780286243627],"// GENERATED by deploy/gen_skills_catalog.mjs — do not edit by hand.\nimport type { SkillRef } from \"../index.ts\";\nexport const REFS_PART_9: SkillRef[] = [\n {\"skill\":\"marketing-plan\",\"ref\":\"example-quietude\",\"body\":\"# Example — Quietude Marketing Plan v1\\n\\n**This is the canonical reference example for the `/marketing-plan` skill.** It's based on a real fCMO engagement for a hybrid hardware-and-software wellness platform. **Names, domains, and identifying details have been changed** — the client is called \\\"Quietude\\\" here, and the team members have been renamed (Alex / Sam / Casey / Devon). The funnel numbers, budget, and structural lessons preserve the shape of the original engagement so the example retains its teaching value.\\n\\nUse this as the \\\"what good looks like\\\" reference when drafting a new plan. The structure, tone, depth, and operational specificity are the bar to clear.\\n\\n**Quietude's archetype:** Hybrid hardware + software with deep-tech / clinical credibility layer. See `references/client-types.md` for archetype patterns.\\n\\n**Funding-stage context:** Pre-seed-close (mid-raise on $3M seed). Tier 1 per `references/funding-stage-unlocks.md`. $0 paid budget; organic + lifecycle + ambassador only.\\n\\n**What was strong about this plan:**\\n- Strategic frame (Section 2) leaned on the founder's own meditation-vs-regulation framing as the content pillar\\n- Current state (Section 3) included the 17-section audit rubric scored against existing materials (no formal audit run)\\n- 90-day roadmap (Section 9) had owner-assigned moves, not just actions\\n- Ops stack (Section 11) included a concrete operational proof-point (Customer.io MCP used live by non-technical founder on the kickoff call)\\n- Tactical idea bank (Section 12) cross-referenced all 139 marketing-ideas to AARRR + Quietude-specific status, including 23 explicit skips with rationale\\n\\n---\\n\\n# Quietude — Marketing Plan v1\\n\\n**Prepared by:** Casey Reed (fCMO)\\n**For:** Alex, Sam, and the Quietude team\\n**Date:** 2026-05-27\\n**Status:** Draft v1 — for team review\\n\\n## 1. Executive summary\\n\\nQuietude has built something rare: a clinically validated, brand-coherent, founder-led product in a category that doesn't yet have a name. The opportunity in the next twelve months is not to invent a marketing engine from scratch — it's to **convert the existing organic gravity into a measurable, repeatable funnel**, then layer paid acquisition on top of that funnel once the seed round closes.\\n\\n**Three big bets, ranked by leverage:**\\n\\n1. **Fix the leak before pouring water in.** The Day 1 → Day 35 funnel shape (1.34% → 5.46%) tells us the product converts given time and contact. What it's missing is a working first-session moment (the headphone gate is killing conversion) and a lifecycle layer to deliver the contact. These two pieces — onboarding rebuild and Customer.io flows shipped — are the unlock for everything else.\\n2. **Compound the moats Quietude already has.** Peer-reviewed clinical study, longevity-influencer PR, 15K live event participants, Alex's founder voice — these are link generators, content pillars, and credibility anchors that most wellness brands would kill for. They're under-leveraged. SEO, content, and App Store optimization translate them into search and discovery surface area.\\n3. **Build the founder-and-fCMO operating system that lets a 4-person team market like a 20-person one.** This is what makes the plan actually executable at Quietude's team size and burn rate — agentic tooling on top of Customer.io, Shopify, App Store, Stripe, GitHub, and the marketing skill library means we ship without hiring.\\n\\n**What twelve months looks like, plausibly:**\\n\\n- App goes from beta to GA. Onboarding converts at meaningful lift over today's baseline.\\n- 4 SEO content pillars staked, with Pillar 1 (Nervous System Regulation) and Pillar 2 (Sleep + Eye Mask) ranking on Tier-1 keywords.\\n- Full lifecycle live in Customer.io: onboarding, lapsed re-engagement, hardware post-purchase, subscription-center opt-ins.\\n- Ambassador program live with 15–25 active hosts. First Quietude Guides cert pilot run.\\n- Eye mask wedge selling at scale via Shopify with a clean hardware → app activation path. Blended CAC measured and tracked.\\n- Paid acquisition firing post-seed-close at $5–10K/mo initial test budget, scaling to $20–50K/mo if unit economics validate.\\n- Series A narrative writes itself: clinical evidence + activation lift + lifecycle compounding + first B2B install reference cases.\\n\\n**The 90-day priorities** (which the rest of this doc operationalizes):\\n\\n1. Kill the headphones gate. Ship the bedrock fix this week.\\n2. Run the three-variant onboarding test. Find the activation winner.\\n3. Ship Customer.io Flows 6 (eye mask post-purchase) and 4 (lapsed user) — hold Flow 2 (onboarding) until app UI stabilizes.\\n4. Rewrite the App Store listing in Quietude's brand voice. Highest-leverage non-site asset right now.\\n5. Stake the SEO foundation: consolidate to `quietude.app`, publish Pillar 1 hub + 3 spokes, publish the peer-reviewed psychophysiology study landing page.\\n6. Launch the ambassador program with the ~5 inbound waiting.\\n\\nEverything else compounds on top of those six.\\n\\n---\\n\\n## 2. Strategic frame\\n\\nThis section distills positioning, ICP, and brand voice into what the team needs to keep in mind while executing. Full detail lives in `marketing-os.md`, `icp.md`, and `sound-philosophy.md`.\\n\\n### What Quietude is, in one sentence\\n\\nA nervous system intelligence platform — clinically validated spatial audio + AI reflection companion (Mira) + hardware + venue installations + practitioner network. *\\\"We start with sound. We expand to every sense. We end with cities.\\\"*\\n\\n### The category we're claiming (and defending)\\n\\nQuietude doesn't fit the meditation app category, the focus audio category, or the sleep tech category. The brand makes a stronger claim: **bottom-up nervous system regulation through spatial audio**, with clinical evidence as proof and somatic credibility as defense.\\n\\nThe category-defining frame, per Alex (2026-05-19): **Meditation is top-down. Quietude is bottom-up.** Meditation uses the mind to command the body — mental kung fu that fails the very people most likely to need help, because the prefrontal cortex is offline when stressed. Quietude enters through the brainstem, before the thinking mind. The body responds before it has to try. (Full content-pillar treatment in `meditation-vs-regulation.md`.)\\n\\nThis is the single most important strategic message. It belongs in App Store copy, onboarding, lifecycle email, SEO content, ambassador talking points, and the seed deck.\\n\\n### Who we're for (D2C ICP, distilled)\\n\\nOverstimulated high-achieving professionals, 25–45, urban (Bay Area, NYC, London, Berlin, Austin). Tech workers, founders, creators, academics, designers, consultants. Often neurodivergent (ADHD, HSP, gifted). Sophisticated wellness buyers — already invested heavily in their inner life.\\n\\n**Their stated problem:** *\\\"I can't shut my brain off. I've tried meditation apps. They don't work.\\\"*\\n\\n**Their real problem:** Overstimulation, not under-motivation. Their gift (quick thinking) became a curse. They need permission to stop optimizing — including their rest.\\n\\n**What they're actually buying:** the *feeling* of stability, sensory indulgence, beautiful rituals, effortless effectiveness, a luxurious shortcut to the genius they can't access in chaos.\\n\\n### The business model logic (per seed deck)\\n\\n**B2B seeds the market. D2C harvests.** A venue install puts Quietude in front of ~20K people/year at ~$17K cost → 5% convert to subs → ~$430K/year per venue. Six compound channels (referral, Guides, content, home hosting, PR, community) make CAC approach zero by Year 3. Year 5: 75% of new subs come from near-zero-cost channels.\\n\\n**fCMO scope per kickoff: D2C-led.** Alex owns B2B sales through events/network/founder credibility. The fCMO leverage is on the app/hardware D2C side. This plan reflects that split — B2B is acknowledged as the harvest engine but not treated as primary work surface.\\n\\n### Brand voice (the non-negotiable)\\n\\nPer Marketing OS:\\n- **Tone.** Authoritative yet accessible. Intimate yet professional. Revolutionary yet grounded. Authority comes from lived experience, not explanation.\\n- **Speak from the body, not the mind.** Every sentence restores somatic safety and orientation. Language opens space rather than closing meaning.\\n- **YES vocabulary:** Aliveness, inner life, nervous system, spatial sound, resonance, somatic safety, embodied clarity, natural rhythm, orientation, initiation, truth-telling.\\n- **NO vocabulary:** Zen, chill, vibes, \\\"high-vibe,\\\" spiritual bypass, meditation clichés, didactic/explainer language, \\\"let me explain why this works.\\\"\\n- **Core method: Initiatory Reflection.** Writing's purpose isn't to explain or convince — it's to shift the reader's internal state. The result should be *\\\"something in me moved,\\\"* not *\\\"I understand this concept.\\\"*\\n- **CTA rule:** Never pressure. \\\"We do not remind. We invite.\\\"\\n\\nThis rule constrains every piece of copy across every AARRR stage. When in doubt: rewrite from the body.\\n\\n---\\n\\n## 3. Current state\\n\\nThis is what we're starting from — team, budget, what's already in motion, what's stuck, scored against the CF Marketing Audit 17-section rubric.\\n\\n### Team composition (marketing surface area)\\n\\n| Person | Role | Marketing surface area |\\n|---|---|---|\\n| **Alex** | Co-founder, CEO | Owns: personal LinkedIn, live events, B2B sales, founder narrative, investor relations, brand voice authorship |\\n| **Sam** | Co-founder, CXO | Owns: clinical/somatic credibility, brand-voice stewardship, somatic angle on copy review, practitioner network |\\n| **Devon** | Lead Dev | Owns: product/UI build, instrumentation, Customer.io event wiring, App Store deployment |\\n| **Ed Dorsey** | Design Advisor | Advisory cadence (ex-Apple/Airbnb/Strava) |\\n| **Emily Babich** | Creative Strategy | Advisory cadence |\\n| **Matt Mikkelsen** | Field Recording | Audio library, not marketing |\\n| **Casey Reed** | fCMO | Strategy, lifecycle, SEO, onboarding tests, content, ambassador program, ops stack |\\n\\n**No dedicated marketing hire yet.** First hire likely post-seed close (Q3 2026 candidate): a lifecycle + content marketing manager who owns Customer.io, SEO content production, and ambassador operations day-to-day.\\n\\n### Marketing budget (current)\\n\\n- **Paid acquisition:** $0. Confirmed by Alex, 2026-05-20: *\\\"D2C UA so far: My personal LinkedIn posts, live Quietude events, organic word of mouth, and organic app store discovery.\\\"* No paid layer.\\n- **Tooling stack:** Customer.io subscription, Shopify (eye mask storefront), App Store Connect, GA4 (or pending), Stripe, Notion, Dub.co (ambassador attribution). Estimate ~$500–1,500/mo combined.\\n- **fCMO retainer:** Casey Reed engagement.\\n- **PR:** No paid PR. Organic longevity-influencer tailwind, consumer-tech angels + foundation-model lab network.\\n\\n**Implication:** The 90-day plan must produce gains without any paid lever pulled. Everything in the next 12 weeks is organic, lifecycle, or product-level. Paid is a Q2–Q3 unlock.\\n\\n### What's already done (acknowledge, then build on)\\n\\n| Asset | Status | Marketing leverage |\\n|---|---|---|\\n| Peer-reviewed peer-reviewed psychophysiology study (2025) | Published | Anchor of clinical authority. Most undermarketed asset Quietude owns. |\\n| longevity-influencer eye-mask endorsement | Live, generating Shopify sales | Press hook. Underused for landing-page social proof. |\\n| consumer-tech angels + foundation-model lab investment | Closed | Investor PR opportunity. \\\"Why I invested\\\" Substack/Medium pieces. |\\n| 15K+ live event participants over a decade | Real | Email list potential, ambassador pool, testimonial bank, B2B reference. |\\n| Quietude eye mask (5K in stock) | Selling | The wedge product. Hardware → app activation path. |\\n| 38% 12-month retention (vs. category avg 20%) | Real | Headline metric. Belongs everywhere. |\\n| Customer.io + Shopify integration | Wired | The lifecycle infrastructure exists. Flows just need to ship. |\\n| 4 GitHub repos for context + product | Set up | `quietude-context` (shared brain), `quietude-promo`, `quietude-app` (app), `mira` (AI), `quietude-api` |\\n| Alex's Sound Philosophy doc | Working doc | Linkable position paper once polished and published. |\\n| ~5 inbound ambassadors waiting | Inbound | Referral program ready to launch — no demand-gen needed for v1. |\\n| Aurora B2B install (~€250K, July deadline) | In-flight | First flagship venue. Reference case once installed. |\\n| Notion Knowledge Directory | Live | Internal context. |\\n| Customer.io MCP (Claude integration) | Validated on kickoff | Non-technical team can ship flows independently. |\\n\\n### What's in-flight (drafted but not shipped)\\n\\n| Item | Status | Blocker |\\n|---|---|---|\\n| Flow 2 — App Onboarding (8 emails / 14 days) | Draft | App UI in flux; copy references screens that may change |\\n| Flow 4 — Lapsed User Re-engagement (5 emails / 38 days) | Draft | None — ship-ready |\\n| Flow 6 — Eye Mask Post-Purchase | Draft | None — ship-ready |\\n| Onboarding rebuild (3-variant test plan) | Strategy doc done | Eng scoping + headphone-gate removal |\\n| SEO 90-day plan + keyword research | Done | Awaiting domain consolidation decision + content production start |\\n\\n### What's stuck (and needs to unstick this quarter)\\n\\n| Issue | Cost of inaction | Action |\\n|---|---|---|\\n| Headphones hard-gate in onboarding | Confirmed conversion drop post-launch | Kill this week (bedrock fix) |\\n| 4 domains unconsolidated (quietude.app, quietude.space, quietude.audio, quietude.center) | SEO authority fragmenting, transactional email confusion | Consolidate to `quietude.app` per SEO data |\\n| App Store listing copy not in brand voice | Highest-traffic Quietude surface; off-brand experience for arriving users | Rewrite in voice (Pillar 1) |\\n| Domain consolidation requires 301 plan + email sender migration | Risk of traffic loss if mishandled | Plan in weeks 1–2, execute weeks 3–4 |\\n| `quietude-promo` repo hasn't shipped since March 2026 | Marketing site is stale | Confirm whether it's live; rewrite or replace |\\n| 29% monthly App Store churn vs. 38% 12-month retention claim | Metric definition mismatch confusing the team | Reconcile with Devon + Customer.io data |\\n| Mira post-session reflection scope unknown | Blocks Variant B and Variant C onboarding tests | Resolve with Devon |\\n\\n### Audit rubric snapshot (17-section)\\n\\nScored 0–5 from materials, using the embedded rubric in `references/current-state-rubric.md`. Marked \\\"scored from materials\\\" rather than \\\"formal audit\\\" — Alex can push back on any score where they have better data.\\n\\n| # | Section | Score | Note |\\n|---|---|---|---|\\n| 1 | Positioning | **4** | Clear, original category claim. The bottom-up frame is the strongest piece. Needs broader external articulation. |\\n| 2 | Customer research | **4** | Deep founder-led research, decade of live participants. Could be more systematically captured. |\\n| 3 | Homepage | **2** | `quietude-promo` hasn't shipped since March. Off-brand voice in places. |\\n| 4 | Sales / product pages | **2** | Eye mask page exists on Shopify but isn't optimized for SEO or sales narrative. No app-product landing page in brand voice. |\\n| 5 | Conversion pages | **2** | `/partner` exists on `quietude.app`. No `/science`, `/eye-mask`, `/ambassadors`, `/guides` pages live. |\\n| 6 | Competitor comparison | **1** | Nothing exists. Big SEO + sales opportunity (own \\\"Quietude vs. Calm/Headspace/Brain.fm/Endel\\\" SERPs). |\\n| 7 | Resources / content | **1** | Sound Philosophy not yet public. peer-reviewed psychophysiology study not yet on a dedicated page. No blog. |\\n| 8 | Onboarding | **2** | Headphones gate killing conversion. Hold-and-fix project this quarter. |\\n| 9 | Email lifecycle | **1** | All three flows drafted, none live. Ship-order set. |\\n| 10 | Sales material | **3** | Seed deck is strong (investor-facing). B2B sales material more founder-led than asset-led. |\\n| 11 | Messaging | **5** | Alex + Sam have authored the most distinctive brand voice in the wellness category. This is a moat. |\\n| 12 | Pricing | **3** | $30/mo app, $45 eye mask, $7,500 speakers, $50–200K B2B. Hasn't been pressure-tested for D2C conversion lift. |\\n| 13 | CRO | **2** | App Store conversion rate trackable but no A/B history. Headphones gate is the obvious first test removal. |\\n| 14 | GTM / launches | **2** | App in throttled beta. Major launches (eye mask, Mira public) haven't had structured GTM. |\\n| 15 | Ads | **0** | No paid layer. Reflects the current organic strategy — not a weakness, but the budget unlock means this will move. |\\n| 16 | SEO | **1** | Current state: 7 organic visits/mo. Plan exists; execution not yet started. |\\n| 17 | Internationalization | **1** | Finland HQ + global ICP, but EN-only and US-centric copy. Defer until Q4+. |\\n\\n**Total: 36 / 85 (42%).** The shape matters more than the score: high in Positioning + Messaging + Customer research, low in Conversion pages + Email lifecycle + SEO + Resources + Ads. That's the gap this plan closes.\\n\\n---\\n\\n## 4. Acquisition\\n\\n> *\\\"How do strangers become aware of Quietude?\\\"*\\n\\n### Current state\\n\\n100% organic. Four real channels: Alex's personal LinkedIn, live Quietude events, organic word of mouth, organic App Store discovery. Plus passive PR drag from longevity-influencer endorsement + clinical study.\\n\\nThis is good news, not bad. Every dollar of revenue earned to date has been earned without paid acquisition. The bar to exceed it isn't high; the upside on top of an organic base is significant.\\n\\n### The plan\\n\\n**Channel 1 — SEO (primary 90-day investment).**\\nThe full 90-day plan lives in `seo/plan.md`. Summary: consolidate to `quietude.app`, target three asymmetric clusters (nervous-system regulation KD 14–32, weighted/blackout sleep mask KD 6–30, WELL + social-wellness-club B2B KD 5–34), publish 4 content pillars. 90-day target: 500–1,500 organic visits/mo, 80+ ranking keywords. 12-month target: 10,000/mo, 1,000+ keywords.\\n\\n**Channel 2 — App Store optimization (highest-leverage non-site asset).**\\nThe App Store listing is currently the most-visited Quietude URL by Apple's algorithm. Fixing the copy is higher-leverage this quarter than fixing the marketing site. Rewrite in brand voice. Add the meditation-vs-regulation framing. Lead with the clinical anchor. Test screenshot variations.\\n\\n**Channel 3 — Alex's LinkedIn (productize the channel).**\\nToday it's ad-hoc founder posting. The next move is structured: a 2–3x/week cadence, post categories that map to the content pillars (nervous system, sound science, founder journey, clinical evidence, behind-the-scenes), trackable links via Dub, follower → email subscriber → app install funnel measured. This is Alex's voice — the channel only works if he's the one writing. fCMO + Typefully scheduling makes the cadence sustainable.\\n\\n**Channel 4 — PR amplification.**\\nlongevity-influencer tailwind is real but underused on owned surfaces. Add a `/notable-users` or `/in-the-press` page. Pitch the peer-reviewed psychophysiology study to 5 outlets (wellness press: Well+Good, MindBodyGreen; tech-adjacent: Wired with the longevity-influencer hook; mainstream: Outside, Forbes Wellness). HARO/Help-A-B2B-Writer responses citing Quietude's data. Investor PR moments (\\\"Why I invested in Quietude\\\" Substack pieces from consumer-tech angels — push for these with backlinks).\\n\\n**Channel 5 — Event-to-app instrumentation.**\\nLive events are the highest-converting ICP exposure Quietude has (15K+ participants, decade of trust). They're un-instrumented. Add: per-event QR code → app install + email capture, post-event lifecycle (Customer.io Flow 7?), event ROI tracking. Goal: turn an event from a one-night conversion moment into a 30-day funnel.\\n\\n**Channel 6 — Eye mask wedge (consumer entry product).**\\n5K masks in stock. Shopify storefront exists but isn't optimized. Improvements: SEO-optimize the product page (target \\\"weighted sleep mask,\\\" \\\"blackout sleep mask,\\\" \\\"silk sleep mask\\\"), add reviews via Judge.me (per kickoff decision), 30-day return policy (US-market expectation, per kickoff), build the listicle (\\\"Quietude vs. Manta vs. Nodpod vs. Lumon\\\"). Consider Amazon listing as a v2 distribution play.\\n\\n**Channel 7 — B2B venue installs (kept lean per kickoff).**\\nAlex owns this. Marketing supports with: case studies after each install, `/partner` page rewrite in voice (already exists on quietude.app), Pillar 4 content (\\\"The Missing Sound Feature in WELL\\\"), reciprocal links from partner venues baked into contracts.\\n\\n**Channel 8 — Paid layer (unlocked post-seed close).**\\nHeld until seed funding lands. Initial test budget: $5–10K/mo split across Apple Search Ads (highest-intent for App Store), Meta (Instagram + Facebook for eye mask), LinkedIn (B2B venue buyers). Don't fire until: (a) onboarding bedrock fix is shipped, (b) Flow 6 is live, (c) at least one Pillar landing page is in voice. Paid amplifies what already works — premature paid amplifies what's broken.\\n\\n### 90-day acquisition moves\\n\\n- Weeks 1–2: Domain consolidation decision + 301 plan. App Store listing rewrite first pass.\\n- Weeks 3–4: Domain 301s executed. GSC migration. SEO Pillar 1 hub drafted.\\n- Weeks 5–8: Pillar 1 hub + 3 spokes published. Pillar 2 (Eye Mask) hub + listicle published. Alex's LinkedIn cadence operationalized via Typefully. peer-reviewed psychophysiology study lands on dedicated `/science` page.\\n- Weeks 9–12: Pillar 4 (WELL/B2B) cornerstone published. Sound Philosophy goes public at `/research/sound-philosophy`. First PR push: pitch study + longevity-influencer hook to 5 outlets.\\n\\n### 12-month acquisition outlook\\n\\n- Q1 (Months 1–3): Foundation. SEO pillars staked. App Store rewrite shipped. LinkedIn cadence stable. PR push launched.\\n- Q2 (Months 4–6, post-seed close): Paid acquisition pilot at $5–10K/mo. SEO compounding — Pillar 1 ranking. First B2B install reference case live.\\n- Q3 (Months 7–9): Paid scales to $20–30K/mo if unit economics hold. All four pillars producing. App GA — new GTM moment.\\n- Q4 (Months 10–12): Compound channels live. 50+ pieces of pillar content. First Quietude Guides program pilot creating local SEO + earned media.\\n\\n### Skills + tools\\n\\n- **Skills:** `seo-audit`, `ai-seo`, `programmatic-seo`, `schema`, `content-strategy`, `competitors`, `launch`, `ads`, `ad-creative`, `social`, `typefully`, `analytics`, `copywriting`, `marketing-website-design`, `free-tools`\\n- **MCPs / APIs:** Ahrefs API, DataForSEO API, Typefully MCP (LinkedIn scheduling), GA4 MCP (when wired), GitHub MCP (`quietude-promo` repo work), Notion (knowledge directory), Stripe MCP (LTV / paid-CAC math), `agent-browser` (LinkedIn drafting + testing), `defuddle` (research)\\n\\n---\\n\\n## 5. Activation\\n\\n> *\\\"Once someone tries Quietude, do they have an experience that converts?\\\"*\\n\\n### Current state\\n\\nDay 1 → paid: **1.34%**. Day 7 → paid: **3.73%**. Day 35 → paid: **5.46%**. *The funnel shape is the signal.* The ~4× lift over 35 days means the product converts given time and contact — both of which the current onboarding undermines and the lifecycle layer doesn't yet provide.\\n\\nCaveats: app is in throttled beta. Metrics are noisy. Don't optimize against absolutes; optimize against funnel *shape* and *cohort comparison*.\\n\\n### The plan\\n\\n**Move 1 — Kill the headphones hard-gate (bedrock fix, this week).**\\nConfirmed conversion drop after the gate shipped. The fix isn't better copy on the gate — it's removing the gate. Replace with passive headphone detection + soft single-line nudge. No regret change. Full reasoning in `onboarding-recommendation.md`.\\n\\n**Move 2 — Run the three-variant onboarding test.**\\nThree variants, each a pure expression of one belief about what drives activation in this ICP:\\n- **Variant 1 — Trust First.** Bold promise + clinical anchor + testimonial wall + 1-line mechanism. Tests whether the saturated ICP needs framing before they'll invest.\\n- **Variant 2 — Seen First.** Multi-step diagnostic → AI-generated \\\"we see you\\\" summary → personalized session. Tests whether being accurately named is the conversion event.\\n- **Variant 3 — Felt First.** Audio starts on app open. ~15 words on screen. The session IS the onboarding. Tests whether the product can carry it cold.\\n\\nTest sequence (sequential, ~7 weeks to a winner): bedrock baseline → V3 vs. baseline → winner vs. V1 → winner vs. V2. Full system in `onboarding-recommendation.md`.\\n\\n**Move 3 — App Store listing rewrite.**\\nHighest-leverage non-site asset. Rewrite in brand voice. Lead with meditation-vs-regulation. Screenshot variations to test. This is also an Acquisition move (organic discovery) but it lives here because it's the threshold to the trial.\\n\\n**Move 4 — Customer.io Flow 2 (held until UI stable).**\\nThe 8-email / 14-day onboarding sequence is drafted and on-brand. Holding the ship because the emails reference in-app screens that will change during the onboarding rebuild. Once a winning onboarding variant ships, Flow 2 gets a copy refresh against the final UI and goes live.\\n\\n**Move 5 — Paywall + pricing review (cross-cuts to Revenue).**\\nWhat's the current trial structure? Length, paywall trigger, intro pricing? When the funnel shape is \\\"lift over 35 days,\\\" extending trial may convert better than aggressively gating earlier. To be audited in Q1.\\n\\n### 90-day activation moves\\n\\n- Week 1: Headphones gate removed. Baseline established.\\n- Weeks 2–3: Variant 3 (Felt First) prototyped, instrumented, shipped to a test cohort.\\n- Weeks 4–5: Read Variant 3 vs. baseline. Decide ship/iterate. Begin Variant 1 build.\\n- Weeks 6–7: Variant 1 (Trust First) live.\\n- Weeks 8–9: Read V1 vs. winner. Begin Variant 2 build.\\n- Weeks 10–11: Variant 2 (Seen First) live.\\n- Week 12: Final read. Winning variant scheduled for permanent ship. Flow 2 unblocked.\\n\\n### 12-month activation outlook\\n\\n- Q1: Winning variant identified and shipped.\\n- Q2: Flow 2 ships. Paywall A/B tests start.\\n- Q3: GA launch — onboarding re-validated at higher traffic. Cohort segmentation by acquisition source (Shopify/eye-mask vs. direct vs. ambassador vs. paid) starts to drive variant forks.\\n- Q4: Onboarding is no longer the bottleneck. Focus moves to Activation → Retention transition (sessions 2–7).\\n\\n### Skills + tools\\n\\n- **Skills:** `onboarding`, `signup`, `cro`, `cro`, `paywalls`, `popups`, `copywriting`, `copy-editing`, `copycraft`, `marketing-website-design`, `ab-testing`, `marketing-psychology`\\n- **MCPs / APIs:** App Store Connect (manual + `dev-browser` for screenshot automation), GitHub MCP (`quietude-app` app repo for onboarding code), Figma / Pencil MCP (for onboarding screen design), Customer.io MCP (for any in-app/email coordination), GA4 MCP (activation events)\\n\\n---\\n\\n## 6. Retention\\n\\n> *\\\"Once someone converts, do they stay — and deepen?\\\"*\\n\\n### Current state\\n\\n**Headline metric (per seed deck): 38% 12-month retention** — nearly double the category average (~20%). This is the strongest single retention signal in the deck and one of the most undermarketed claims Quietude owns.\\n\\n**App Store snapshot, 2026-05-16:** 145 paid, 42 churned (~29% monthly churn). Definition mismatch with the 38% claim — to reconcile. Possibly: 38% is annual cohort retention (people who paid month 1 and still pay month 12), 29% is gross monthly churn (people who paid this month who didn't pay next month). Both can be true. Need to clarify which metric is reported externally and which is the actual product health signal.\\n\\n### The plan\\n\\n**Move 1 — Ship Flow 6 first (Eye Mask Post-Purchase).**\\nPer kickoff decision and the onboarding-recommendation doc: this is the ship-ready flow. Hardware-anchored, doesn't reference in-app screens, can ship today. Wires the hardware → app activation path (eye mask buyers should get a free 6-month Premium trial — formalize this as part of the flow).\\n\\n**Move 2 — Ship Flow 4 second (Lapsed User Re-engagement).**\\nFive emails over 38 days. Language is universal — doesn't depend on app UI state. Ship after Flow 6 is live.\\n\\n**Move 3 — Hold Flow 2 (Onboarding).**\\nEight emails over 14 days. Holds until app UI stabilizes post-onboarding-rebuild. Don't ship copy that will need rewriting in 8 weeks.\\n\\n**Move 4 — Customer.io subscription center with opt-in topics.**\\nPer kickoff decision. Topics: events, app updates, somatics & nervous system, eye mask promotions. Users self-segment. Improves deliverability (lower complaint rates) and gives lifecycle a richer segmentation surface.\\n\\n**Move 5 — Mira post-session reflection (when scoped).**\\nMost powerful retention move medium-term. After a session, Mira asks *\\\"What did you notice?\\\"* Optional preset chips + free text. Two payoffs: (a) gives Mira priors for personalization on session 2+, (b) reflection responses become a content + segmentation goldmine for the team. Scope question for Devon — does Mira currently support this, or is it new build?\\n\\n**Move 6 — Hardware → app activation flow.**\\nThe eye-mask-buyer-becomes-Premium-subscriber path is hinted in the seed deck (blended CAC via hardware) but isn't visible in the App Store dashboard. Audit the existing flow: does an eye mask Shopify purchase actually deliver a free Premium code? How is it redeemed? What's the conversion rate? This is foundational to the \\\"B2C wedge\\\" thesis.\\n\\n**Move 7 — Reconcile the retention metric.**\\nWhat's the actual definition of \\\"38% 12-month retention\\\"? Cohort? Plan type (monthly vs. annual)? Survives this even if the answer is uncomfortable — the team and investors need to be talking about the same metric.\\n\\n**Move 8 — Annual plan as default (cross-cuts to Revenue).**\\nIndustry pattern: defaulting to annual reduces churn anxiety and improves LTV. To test in Q2.\\n\\n### 90-day retention moves\\n\\n- Weeks 1–2: Flow 6 (eye mask post-purchase) ships. Address fixes from kickoff review (study link line break, CAN-SPAM footer, founder face-bubble signature, Judge.me reviews).\\n- Weeks 3–4: Flow 4 (lapsed user re-engagement) ships.\\n- Weeks 5–6: Customer.io subscription center built and live.\\n- Weeks 7–8: Hardware → app activation flow audited and documented. Fix any leaks.\\n- Weeks 9–10: Retention metric reconciliation (with Devon).\\n- Weeks 11–12: Win-back campaign for churned cohort — test re-activation copy.\\n\\n### 12-month retention outlook\\n\\n- Q1: Flows 6 + 4 firing. Subscription center live.\\n- Q2: Flow 2 ships (post-onboarding-rebuild). Mira post-session reflection in production. Annual plan default tested.\\n- Q3: GA launch — retention metrics re-baselined at higher volume. Cohort-based lifecycle flows (eye mask vs. direct app install).\\n- Q4: Full lifecycle compound. Retention is no longer a top-three concern — focus moves to Referral and Revenue.\\n\\n### Skills + tools\\n\\n- **Skills:** `emails`, `churn-prevention`, `copywriting`, `copy-editing`, `paywalls`, `ab-testing`\\n- **MCPs / APIs:** **Customer.io MCP** (validated on kickoff — non-technical team can ship flows), Shopify (eye mask buyers as event source), Stripe MCP (subscription state, churn cohort pulls), GA4 MCP (session events, retention curves)\\n\\n---\\n\\n## 7. Referral\\n\\n> *\\\"Do retained users bring more users — and at what cost?\\\"*\\n\\n### Current state\\n\\n~5 inbound ambassadors waiting (per kickoff). Dub.co set up. No formal program yet. WOM happens naturally per Alex's UA breakdown.\\n\\nThis is one of the strongest leading indicators in the business: 5 unaffiliated people have raised their hand asking to bring Quietude to their network *before any program exists*. That signal doesn't show up in apps with weaker product-market fit.\\n\\n### The plan\\n\\n**Move 1 — Launch the ambassador program with the 5 inbound.**\\nTier 1 of the program. Per-ambassador landing pages (e.g., `quietude.app/with/sarah`). Dub.co tracks attribution. Commission structure to determine (per kickoff, $/sub or rev-share TBD). Soft-launch with the 5 — treat as pilot cohort, gather feedback, refine before opening applications.\\n\\n**Move 2 — Build the share-after-shift moment.**\\nThe Mira post-session reflection (see Retention) is the natural moment to surface a share prompt. After a user reports a felt shift, offer: *\\\"Want to share Quietude with someone who needs this?\\\"* Single-line, never pushy. Most powerful WOM mechanism: gift-a-month flow where the recipient gets a discounted or free intro.\\n\\n**Move 3 — Founder amplification (Alex + Sam as ambassador-zero).**\\nAlex mentioning the fCMO engagement in fundraise pitches (permission granted). Reciprocal mentions in fCMO-side content. Sam's clinical network → practitioner ambassador pool.\\n\\n**Move 4 — Quietude Guides cert pilot (long-term, Q3+).**\\nThe Guides program is the Phase-2 referral compound (per seed deck). 500–1,000 Guides across 50+ cities by Y3–5. First cert pilot: 3–5 hosts who run live sessions, get a rev-share + co-marketing. Builds local SEO + earned media + ambassador-of-ambassadors flywheel. Hold until paid + lifecycle are firing — Guides is a multi-quarter build.\\n\\n**Move 5 — Eye mask gifting flow.**\\nHardware referral is rare and powerful. *\\\"Send a friend an Quietude eye mask. They get the mask + a free 3-month Premium. You get a credit toward your next thing.\\\"* Holiday/gifting peak windows are the test.\\n\\n### 90-day referral moves\\n\\n- Weeks 1–4: Ambassador program scoped, commission structure decided, per-ambassador landing page template built, 5 inbound onboarded.\\n- Weeks 5–8: First ambassador-driven sales tracked via Dub. Attribution and payout flow validated.\\n- Weeks 9–12: Open applications for next 10–15 ambassadors. Begin Quietude Guides scoping.\\n\\n### 12-month referral outlook\\n\\n- Q1: Ambassador program live with 5–10 active.\\n- Q2: 15–25 active ambassadors. Share-after-shift moment in production (post-Mira reflection).\\n- Q3: Guides cert pilot launched (3–5 hosts). Eye mask gifting flow live for holiday peak.\\n- Q4: 50+ ambassadors + 5–10 Guides. Referral driving 15–25% of new D2C subs.\\n\\n### Skills + tools\\n\\n- **Skills:** `referrals`, `social`, `copywriting`, `marketing-website-design` (per-ambassador landing pages)\\n- **MCPs / APIs:** Dub.co (attribution — already in stack), Stripe MCP (commission accounting + payouts), GitHub MCP (landing page deployment in `quietude-promo` or new `quietude-ambassadors` repo), Customer.io MCP (ambassador lifecycle: onboarding, monthly performance digest, payout notification)\\n\\n---\\n\\n## 8. Revenue\\n\\n> *\\\"What do we charge, who pays, and how does that compound?\\\"*\\n\\n### Current state\\n\\n| Product | Price | Volume signal |\\n|---|---|---|\\n| Quietude App + Mira | ~$30/mo | 145 paid subs (App Store snapshot 2026-05-16) |\\n| Quietude Eye Mask | ~$45 | 5K in stock, longevity-influencer PR-driven sales |\\n| Quietude Audio (speakers) | ~$7,500 | Niche, founder-led |\\n| Quietude Spaces (B2B install) | $50–200K | Aurora flagship in-flight (~€250K), pipeline of 4 venues |\\n| Quietude Experiences (events) | Varies | 15K+ historical participants |\\n| Quietude Guides | Rev share | Not yet operational |\\n\\n**Revenue to date: ~$500K on ~$250K raised.** Capital-efficient. Hardware + B2B + app subs all contributing.\\n\\n**MRR (App Store snapshot): $592.** Beta-throttled, not steady-state. The implied ~$4/sub/mo against $30/mo list suggests heavy annual plan adoption (which compresses monthly revenue but improves LTV) or significant promotional pricing — to reconcile with Alex.\\n\\n### The plan\\n\\n**Move 1 — Pricing audit.**\\nWhat's actually being charged today? List price, common plan mix, intro pricing, churn-recovery offers? The $4/sub/mo implied math doesn't tell a clean story — need ground truth before recommending changes.\\n\\n**Move 2 — Annual plan as default (test).**\\nIndustry pattern, cross-references to Retention. Test in Q2.\\n\\n**Move 3 — Hardware → app bundling formalized.**\\nPer partner-event-business framing in the seed deck: blended CAC via hardware → app subscription is the play. Today an eye mask buyer gets... what, exactly? Free Premium? Trial code? Audit + formalize. The eye mask is the wedge; the app is the LTV.\\n\\n**Move 4 — Eye mask Shopify storefront optimization.**\\nThe current page underperforms what it could. Add: SEO targeting (\\\"weighted sleep mask,\\\" \\\"blackout sleep mask\\\"), Judge.me reviews (kickoff decision), 30-day return policy (kickoff decision), upsell flow into Premium app.\\n\\n**Move 5 — Consider Amazon listing for eye mask.**\\nAmazon takes margin but is its own discovery engine. Test as v2 distribution if Shopify volume validates.\\n\\n**Move 6 — B2B install case studies + sales material.**\\nAlex owns B2B sales but marketing supports with: post-install case studies (Aurora as the flagship), `/partner` page rewrite in voice, Pillar 4 SEO content. Each B2B install is a ~$430K/year recurring + reference-case multiplier.\\n\\n**Move 7 — Data licensing (long-term, flag for ops stack).**\\nPer seed deck Y10–15 value pool: $100–160M/yr. Not immediate revenue. Belongs in the 24-month strategic agenda. Flag here so we don't lose sight.\\n\\n### 90-day revenue moves\\n\\n- Weeks 1–2: Pricing audit. Reconcile implied vs. listed MRR.\\n- Weeks 3–4: Hardware → app activation flow audited (also Retention move 6).\\n- Weeks 5–8: Eye mask Shopify page rewrite + SEO optimization + Judge.me + return policy. Aurora case study scaffolded for post-install.\\n- Weeks 9–12: Annual plan default test scoped.\\n\\n### 12-month revenue outlook\\n\\n- Q1: Pricing audit closes. Hardware → app activation formalized.\\n- Q2: Annual plan default test live. Eye mask Shopify producing measurable lift.\\n- Q3: B2B install case studies (1–2) published. GA launch + new pricing tier consideration (e.g., a higher-tier Mira-heavy plan?).\\n- Q4: Pricing optimized via test results. Hardware → app blended CAC tracked and reported. First numbers on the data-licensing thesis (still very early).\\n\\n### Skills + tools\\n\\n- **Skills:** `pricing`, `paywalls`, `sales-enablement`, `revops`, `ab-testing`, `copywriting`\\n- **MCPs / APIs:** Stripe MCP (pricing tests, subscription analytics, churn cohort, blended CAC math), Customer.io MCP (paywall-related lifecycle), Shopify (eye mask transactions), GA4 MCP (revenue events), Notion (commercial knowledge directory)\\n\\n---\\n\\n## 9. 90-day roadmap\\n\\nTactical execution layer. Each item is AARRR-tagged so priority is visible.\\n\\n### Weeks 1–2 — Unblock\\n\\n| Move | Stage | Owner |\\n|---|---|---|\\n| Kill the headphones hard-gate | Activation | Casey + Devon |\\n| Domain consolidation decision documented | Acquisition | Casey + Alex |\\n| 301 plan drafted (page-by-page) | Acquisition | Casey |\\n| App Store listing rewrite — first pass | Activation + Acquisition | Casey + Alex + Sam (voice review) |\\n| Flow 6 (eye mask post-purchase) ships | Retention | Casey + Customer.io MCP |\\n| Ambassador program scoping doc | Referral | Casey |\\n| Pricing audit kicked off | Revenue | Casey + Alex |\\n\\n### Weeks 3–4 — Foundation\\n\\n| Move | Stage | Owner |\\n|---|---|---|\\n| Domain consolidation 301s executed | Acquisition | Devon + Casey |\\n| GSC + GA4 stood up on `quietude.app` | Acquisition | Casey |\\n| SEO Pillar 1 hub drafted (Nervous System Regulation) | Acquisition | Casey |\\n| `/science` hub built with peer-reviewed psychophysiology study | Acquisition + brand | Casey + Sam |\\n| Variant 3 (Felt First) onboarding prototyped + tested | Activation | Casey + Devon |\\n| Flow 4 (lapsed user) ships | Retention | Casey |\\n| Ambassador program: 5 inbound onboarded | Referral | Casey |\\n| Hardware → app activation flow audited | Retention + Revenue | Casey + Devon |\\n| App Store listing rewrite — final + ship | Activation + Acquisition | Alex + Sam + Casey |\\n\\n### Weeks 5–8 — Velocity\\n\\n| Move | Stage | Owner |\\n|---|---|---|\\n| Pillar 1 hub + 3 spokes published | Acquisition | Casey |\\n| Pillar 2 hub (Eye Mask) + listicle published | Acquisition | Casey |\\n| Alex's LinkedIn cadence operationalized (Typefully) | Acquisition | Alex + Casey |\\n| First PR push: study + longevity-influencer hook to 5 outlets | Acquisition | Casey + Alex |\\n| Variant 3 read; ship or iterate | Activation | Casey |\\n| Variant 1 (Trust First) prototyped + tested | Activation | Casey + Devon |\\n| Customer.io subscription center built | Retention | Casey |\\n| Eye mask Shopify storefront rewrite (SEO + reviews + return) | Acquisition + Revenue | Casey + Alex |\\n| First ambassador attribution verified via Dub | Referral | Casey |\\n\\n### Weeks 9–12 — Compound\\n\\n| Move | Stage | Owner |\\n|---|---|---|\\n| Pillar 4 (WELL/B2B) cornerstone published | Acquisition | Casey |\\n| 3 more Pillar 1 spokes published | Acquisition | Casey |\\n| Sound Philosophy published at `/research/sound-philosophy` | Acquisition + brand | Alex + Casey |\\n| Variant 1 read; begin Variant 2 (Seen First) build (Mira-dependent) | Activation | Casey + Devon |\\n| Win-back campaign for churned cohort | Retention | Casey |\\n| Annual plan default test scoped | Revenue | Casey + Alex |\\n| Open ambassador applications for next 10–15 | Referral | Casey |\\n| 90-day review + Q2 plan recalibration | Cross-cutting | Casey + Alex |\\n\\n---\\n\\n## 10. 12-month outlook\\n\\nQuarterly milestones with funding-stage capability unlocks named explicitly.\\n\\n### Q1 — Months 1–3 (Jun–Aug 2026)\\n\\n**Funding state:** Pre-seed-close. Paid budget = $0. fCMO + founder-led + tool costs only.\\n\\n**Focus:** Foundation. Plug the leaks. Stake the SEO ground. Get lifecycle firing.\\n\\n**Outcomes by end of Q1:**\\n- Headphones gate gone; onboarding winner identified\\n- All four SEO pillars seeded (hub + first spokes)\\n- Lifecycle Flows 4 + 6 live\\n- App Store listing in brand voice\\n- 5 ambassadors active\\n- Pricing audit closed\\n- Domain consolidated\\n\\n**KPI targets:** Onboarding Day 1 → paid lift of 25–50%. Organic traffic 500–1,500/mo. App Store conversion rate +20%.\\n\\n### Q2 — Months 4–6 (Sep–Nov 2026)\\n\\n**Funding state:** Seed close (~Q3 2026 target). First paid budget unlock: $5–10K/mo test.\\n\\n**Focus:** Validate paid. Scale winning onboarding. Add Flow 2.\\n\\n**Outcomes by end of Q2:**\\n- Paid acquisition firing on Apple Search Ads + Meta\\n- Onboarding winner permanently shipped\\n- Flow 2 (onboarding emails) shipped\\n- Mira post-session reflection in production\\n- 15–25 ambassadors active\\n- First B2B install reference case (Aurora) published\\n- Annual plan default tested\\n\\n**KPI targets:** Paid CAC < $50 blended. Organic traffic 1,500–3,500/mo. Retention curves visibly improving.\\n\\n### Q3 — Months 7–9 (Dec 2026–Feb 2027)\\n\\n**Funding state:** Seed deployment. Paid scales to $20–50K/mo if unit economics hold. First marketing hire (lifecycle + content manager).\\n\\n**Focus:** Scale + diversify. App GA. B2B reference cases compound.\\n\\n**Outcomes by end of Q3:**\\n- App GA launched with new GTM moment (PR + ad creative refresh + Pillar 3 spatial-audio-science content cycle)\\n- First Quietude Guides cert pilot (3–5 hosts)\\n- All four pillars producing weekly content\\n- Eye mask gifting flow live for holiday peak\\n- New marketing hire onboarded\\n\\n**KPI targets:** Paid + organic blended CAC stabilizing. App GA conversion +50% from beta baseline. Guides pilot validates rev-share + co-marketing model.\\n\\n### Q4 — Months 10–12 (Mar–May 2027)\\n\\n**Funding state:** Pre–Series A. Paid scaling continues. Series A pitch in motion.\\n\\n**Focus:** Compound. Position for Series A.\\n\\n**Outcomes by end of Q4:**\\n- Compound channels (organic + ambassador + Guides + lifecycle) producing 50%+ of new subs\\n- 50+ ambassadors, 5–10 Guides\\n- 4 SEO pillars + 30+ pieces of content live\\n- Paid scaling to $50–150K/mo if validated\\n- Series A narrative: clinical evidence + activation lift + lifecycle compounding + B2B reference case pipeline\\n\\n**KPI targets:** D2C ARR run-rate trajectory clear. Blended LTV/CAC > 3. Founder narrative + data + reference cases ready for Series A.\\n\\n---\\n\\n## 11. Marketing operations stack\\n\\nThis is what makes the plan executable at Quietude's team size. A 4-person founder team + fCMO + agentic tooling can ship the output of a 15–20-person traditional marketing org — because the marketing skill library and MCP integrations do the orchestration.\\n\\n### The thesis\\n\\nEvery move in the AARRR breakdown above maps to (a) one or more marketing skills that operationalize the work, and (b) one or more MCP/API integrations that let it execute without a dedicated headcount per channel.\\n\\nThe fCMO's job is to:\\n1. Define the strategy and sequencing (this doc)\\n2. Run the skills against the right context at the right time\\n3. Maintain the shared context (`quietude-context`) and tooling so Alex + Sam + future hires can plug in\\n4. Hand off operational work to humans (or future hires) only where the cost of agentic execution > human execution\\n\\n### Skills mapped to AARRR stages\\n\\n| Stage | Primary skills | Supporting skills |\\n|---|---|---|\\n| **Acquisition** | `seo-audit`, `ai-seo`, `programmatic-seo`, `schema`, `content-strategy`, `competitors`, `ads`, `ad-creative`, `social`, `typefully` | `launch`, `free-tools`, `analytics`, `cold-email`, `copywriting`, `marketing-website-design` |\\n| **Activation** | `onboarding`, `signup`, `paywalls`, `cro`, `copywriting`, `copy-editing`, `copycraft` | `marketing-website-design`, `ab-testing`, `marketing-psychology`, `cro`, `popups` |\\n| **Retention** | `emails`, `churn-prevention` | `copywriting`, `copy-editing`, `ab-testing`, `paywalls` |\\n| **Referral** | `referrals`, `social` | `copywriting`, `marketing-website-design`, `emails` |\\n| **Revenue** | `pricing`, `paywalls`, `sales-enablement`, `revops` | `ab-testing`, `copywriting` |\\n| **Cross-cutting** (brand, intelligence) | `product-marketing`, `customer-research`, `marketing-psychology` | `marketing-ideas`, `diagram-maker` |\\n\\n### MCPs / APIs mapped to stages\\n\\n| Stage | Existing connections at Quietude | Tooling layer (Casey's fCMO stack) |\\n|---|---|---|\\n| **Acquisition** | App Store Connect (manual), Shopify, GA4 (in progress), Notion | Ahrefs API, DataForSEO API, Typefully MCP, GitHub MCP (`quietude-promo`), `agent-browser`, `defuddle` |\\n| **Activation** | App Store Connect, Customer.io, Shopify | App Store Connect (via `dev-browser` for screenshot automation), Figma / Pencil MCP, GitHub MCP (`quietude-app` app repo), Stripe MCP |\\n| **Retention** | **Customer.io (with Claude MCP — validated on kickoff)**, Stripe, Shopify | Customer.io MCP, Stripe MCP, GA4 MCP |\\n| **Referral** | Dub.co, Stripe | Dub.co, Stripe MCP, GitHub MCP (per-ambassador landing pages), Customer.io MCP |\\n| **Revenue** | Stripe, Shopify, Customer.io | Stripe MCP, Shopify, GA4 MCP, Notion |\\n| **Cross-cutting** | Notion, GitHub (`quietude-context`) | Notion, GitHub MCP, `defuddle`, `obsidian-cli` (for Casey's working notes) |\\n\\n### The Customer.io MCP unlock (concrete example)\\n\\nPer kickoff call: *\\\"Built live on call — abandoned-cart flow drafted using Customer.io's Claude MCP. Validated that non-technical team can use the skill pattern independently.\\\"*\\n\\nThis is the operational proof that the stack works. Alex, who is not a developer, drafted a working lifecycle flow with Claude + Customer.io MCP in real time on a kickoff call. The same pattern applies to: Flow 4 ship (lapsed user re-engagement), subscription center build, win-back campaign, eye mask gifting flow, ambassador lifecycle. The fCMO's role becomes orchestration + brand-voice QA, not hand-cranking each email.\\n\\n### Capability unlocks by funding stage\\n\\n| Stage | Headcount | Tooling | Channels live |\\n|---|---|---|---|\\n| **Pre-seed-close (now)** | fCMO + founder team | All current tooling + Casey's marketing skill library + MCP layer | Organic only (SEO, content, App Store, LinkedIn, events, WOM, ambassador) |\\n| **Seed close (~Q3 2026)** | + first marketing hire (lifecycle/content) by end of Q3 | + paid ad accounts (Apple Search Ads, Meta, LinkedIn) | + paid acquisition pilot $5–10K/mo |\\n| **Seed deployment (Q3–Q4 2026)** | + designer (potentially fractional) | + analytics expansion (Mixpanel or Amplitude if needed) | + paid scaling $20–50K/mo, + Guides cert pilot |\\n| **Series A (2027)** | + performance marketing lead + content lead | + dedicated tooling spend (~$2–5K/mo software) | + paid scaling $50–150K/mo, + international, + B2B vertical expansion |\\n\\nThe marketing skill library scales these stages. Every channel added doesn't require a 1:1 headcount increase because each skill encodes the workflow.\\n\\n---\\n\\n## 12. Tactical idea bank — 139-idea cross-reference\\n\\nThe `marketing-ideas` skill catalogs 139 proven marketing tactics. Sections 4–8 (AARRR) prescribe what we're *doing*. This section maps the full universe of what's *possible* — every idea cross-referenced to the AARRR stage it primarily serves, with Quietude applicability and timing.\\n\\nThis is the exhaustive menu. The plan above is the curated path. When we move to Q2 / Q3 / Series A and unlock new capacity, this is the inventory we pull from.\\n\\n**Status legend:**\\n\\n- **Now (Q1)** — already in the 90-day plan OR can run alongside it without new capacity\\n- **Q2** — post-bedrock-fix, post-foundation;

Diff · v1073