\\n

{productName}

\\n

{tagline}

\\n

{price}

\\n

Shop Now

\\n \\n );\\n};\\n```\\n\\n**2. A/B test video variations**\\nRender the same template with different headlines, CTAs, or color schemes:\\n```tsx\\nconst variations = [\\n {headline: \\\"Save 50% Today\\\", cta: \\\"Get the Deal\\\", theme: \\\"urgent\\\"},\\n {headline: \\\"Join 10K+ Teams\\\", cta: \\\"Start Free\\\", theme: \\\"social-proof\\\"},\\n {headline: \\\"Built for Speed\\\", cta: \\\"Try It Now\\\", theme: \\\"benefit\\\"},\\n];\\n// Render all variations programmatically\\n```\\n\\n**3. Personalized outreach videos**\\nGenerate videos addressing prospects by name for cold outreach or sales.\\n\\n**4. Social ad batch production**\\nRender the same content across different aspect ratios:\\n- 1:1 for feed\\n- 9:16 for Stories/Reels\\n- 16:9 for YouTube\\n\\n### Remotion Workflow for Ad Creative\\n\\n```\\n1. Design template in React (or use AI to generate the component)\\n2. Define data schema (products, headlines, CTAs, images)\\n3. Feed data array into template\\n4. Batch render all variations\\n5. Upload to ad platform\\n```\\n\\n### Getting Started\\n\\n```bash\\n# Create a new Remotion project\\nnpx create-video@latest\\n\\n# Render a single video\\nnpx remotion render src/index.ts MyComposition out/video.mp4\\n\\n# Batch render from data\\nnpx remotion render src/index.ts MyComposition --props='{\\\"data\\\": [...]}'\\n```\\n\\n---\\n\\n## Choosing the Right Tool\\n\\n### Decision Tree\\n\\n```\\nNeed video ads?\\n├── Templated, data-driven (same structure, different data)\\n│ └── Use Remotion\\n├── Unique creative from prompts (exploratory)\\n│ ├── Need dialogue/voiceover? → Sora 2, Veo 3.1, Kling 2.6, Seedance 2.0\\n│ ├── Need consistency across scenes? → Runway Gen-4\\n│ ├── Need vertical social video? → Veo 3.1 (native 9:16)\\n│ ├── Need high volume at low cost? → Seedance 2.0\\n│ └── Need cinematic camera work? → Higgsfield, Kling\\n└── Both → Use AI gen for hero creative, Remotion for variations\\n\\nNeed image ads?\\n├── Need text/headlines in image? → Ideogram\\n├── Need product consistency across variations? → Flux (multi-ref)\\n├── Need quick iterations on existing images? → Nano Banana Pro\\n├── Need highest visual quality? → Flux Pro, Midjourney\\n└── Need high volume at low cost? → Flux Klein, Nano Banana\\n```\\n\\n### Cost Comparison for 100 Ad Variations\\n\\n| Approach | Tool | Approximate Cost |\\n|----------|------|-----------------|\\n| 100 static images | Nano Banana Pro | ~$4-24 |\\n| 100 static images | Flux Dev | ~$1-2 |\\n| 100 static images | Ideogram API | ~$6 |\\n| 100 × 15-sec videos | Veo 3.1 Fast | ~$225 |\\n| 100 × 15-sec videos | Remotion (templated) | ~$0 (self-hosted render) |\\n| 10 hero videos + 90 templated | Veo + Remotion | ~$22 + render time |\\n\\n### Recommended Workflow for Scaled Ad Production\\n\\n1. **Generate hero creative** with AI (Nano Banana, Flux, Veo) — high-quality, exploratory\\n2. **Build templates** in Remotion based on winning creative patterns\\n3. **Batch produce variations** with Remotion using data (products, headlines, CTAs)\\n4. **Iterate** — use AI tools for new angles, Remotion for scale\\n\\nThis hybrid approach gives you the creative exploration of AI generators and the consistency and scale of code-based rendering.\\n\\n---\\n\\n## Platform-Specific Image Specs\\n\\nWhen generating images for ads, request the correct dimensions:\\n\\n| Platform | Placement | Aspect Ratio | Recommended Size |\\n|----------|-----------|-------------|-----------------|\\n| Meta Feed | Single image | 1:1 | 1080x1080 |\\n| Meta Stories/Reels | Vertical | 9:16 | 1080x1920 |\\n| Meta Carousel | Square | 1:1 | 1080x1080 |\\n| Google Display | Landscape | 1.91:1 | 1200x628 |\\n| Google Display | Square | 1:1 | 1200x1200 |\\n| LinkedIn Feed | Landscape | 1.91:1 | 1200x627 |\\n| LinkedIn Feed | Square | 1:1 | 1200x1200 |\\n| TikTok Feed | Vertical | 9:16 | 1080x1920 |\\n| Twitter/X Feed | Landscape | 16:9 | 1200x675 |\\n| Twitter/X Card | Landscape | 1.91:1 | 800x418 |\\n\\nInclude these dimensions in your generation prompts to avoid needing to crop or resize.\\n\"},\n {\"skill\":\"ad-creative\",\"ref\":\"platform-specs\",\"body\":\"# Platform Specs Reference\\n\\nComplete character limits, format requirements, and best practices for each ad platform.\\n\\n---\\n\\n## Google Ads\\n\\n### Responsive Search Ads (RSAs)\\n\\n| Element | Character Limit | Required | Notes |\\n|---------|----------------|----------|-------|\\n| Headline | 30 chars | 3 minimum, 15 max | Any 3 may be shown together |\\n| Description | 90 chars | 2 minimum, 4 max | Any 2 may be shown together |\\n| Display path 1 | 15 chars | Optional | Appears after domain in URL |\\n| Display path 2 | 15 chars | Optional | Appears after path 1 |\\n| Final URL | No limit | Required | Landing page URL |\\n\\n**Combination rules:**\\n- Google selects up to 3 headlines and 2 descriptions to show\\n- Headlines appear separated by \\\" | \\\" or stacked\\n- Any headline can appear in any position unless pinned\\n- Pinning reduces Google's ability to optimize — use sparingly\\n\\n**Pinning strategy:**\\n- Pin your brand name to position 1 if brand guidelines require it\\n- Pin your strongest CTA to position 2 or 3\\n- Leave most headlines unpinned for machine learning\\n\\n**Headline mix recommendation (15 headlines):**\\n- 3-4 keyword-focused (match search intent)\\n- 3-4 benefit-focused (what they get)\\n- 2-3 social proof (numbers, awards, customers)\\n- 2-3 CTA-focused (action to take)\\n- 1-2 differentiators (why you over competitors)\\n- 1 brand name headline\\n\\n**Description mix recommendation (4 descriptions):**\\n- 1 benefit + proof point\\n- 1 feature + outcome\\n- 1 social proof + CTA\\n- 1 urgency/offer + CTA (if applicable)\\n\\n### Performance Max\\n\\n| Element | Character Limit | Notes |\\n|---------|----------------|-------|\\n| Headline | 30 chars (5 required) | Short headlines for various placements |\\n| Long headline | 90 chars (5 required) | Used in display, video, discover |\\n| Description | 90 chars (1 required, 5 max) | Accompany various ad formats |\\n| Business name | 25 chars | Required |\\n\\n### Display Ads\\n\\n| Element | Character Limit |\\n|---------|----------------|\\n| Headline | 30 chars |\\n| Long headline | 90 chars |\\n| Description | 90 chars |\\n| Business name | 25 chars |\\n\\n---\\n\\n## Meta Ads (Facebook & Instagram)\\n\\n### Single Image / Video / Carousel\\n\\n| Element | Recommended | Maximum | Notes |\\n|---------|-------------|---------|-------|\\n| Primary text | 125 chars | 2,200 chars | Text above image; truncated after ~125 |\\n| Headline | 40 chars | 255 chars | Below image; truncated after ~40 |\\n| Description | 30 chars | 255 chars | Below headline; may not show |\\n| URL display link | 40 chars | N/A | Optional custom display URL |\\n\\n**Placement-specific notes:**\\n- **Feed**: All elements show; primary text most visible\\n- **Stories/Reels**: Primary text overlaid; keep under 72 chars\\n- **Right column**: Only headline visible; skip description\\n- **Audience Network**: Varies by publisher\\n\\n**Best practices:**\\n- Front-load the hook in primary text (first 125 chars)\\n- Use line breaks for readability in longer primary text\\n- Emojis: test, but don't overuse — 1-2 per ad max\\n- Questions in primary text increase engagement\\n- Headline should be a clear CTA or value statement\\n\\n### Lead Ads (Instant Form)\\n\\n| Element | Limit |\\n|---------|-------|\\n| Greeting headline | 60 chars |\\n| Greeting description | 360 chars |\\n| Privacy policy text | 200 chars |\\n\\n---\\n\\n## LinkedIn Ads\\n\\n### Single Image Ad\\n\\n| Element | Recommended | Maximum | Notes |\\n|---------|-------------|---------|-------|\\n| Intro text | 150 chars | 600 chars | Above the image; truncated after ~150 |\\n| Headline | 70 chars | 200 chars | Below the image |\\n| Description | 100 chars | 300 chars | Only shows on Audience Network |\\n\\n### Carousel Ad\\n\\n| Element | Limit |\\n|---------|-------|\\n| Intro text | 255 chars |\\n| Card headline | 45 chars |\\n| Card count | 2-10 cards |\\n\\n### Message Ad (InMail)\\n\\n| Element | Limit |\\n|---------|-------|\\n| Subject line | 60 chars |\\n| Message body | 1,500 chars |\\n| CTA button | 20 chars |\\n\\n### Text Ad\\n\\n| Element | Limit |\\n|---------|-------|\\n| Headline | 25 chars |\\n| Description | 75 chars |\\n\\n**LinkedIn-specific guidelines:**\\n- Professional tone, but not boring\\n- Use job-specific language the audience recognizes\\n- Statistics and data points perform well\\n- Avoid consumer-style hype (\\\"Amazing!\\\" \\\"Incredible!\\\")\\n- First-person testimonials from peers resonate\\n\\n---\\n\\n## TikTok Ads\\n\\n### In-Feed Ads\\n\\n| Element | Recommended | Maximum | Notes |\\n|---------|-------------|---------|-------|\\n| Ad text | 80 chars | 100 chars | Above the video |\\n| Display name | N/A | 40 chars | Brand name |\\n| CTA button | Platform options | Predefined | Select from TikTok's options |\\n\\n### Spark Ads (Boosted Organic)\\n\\n| Element | Notes |\\n|---------|-------|\\n| Caption | Uses original post caption |\\n| CTA button | Added by advertiser |\\n| Display name | Original creator's handle |\\n\\n**TikTok-specific guidelines:**\\n- Native content outperforms polished ads\\n- First 2 seconds determine if they watch\\n- Use trending sounds and formats\\n- Text overlay is essential (most watch with sound off)\\n- Vertical video only (9:16)\\n\\n---\\n\\n## Twitter/X Ads\\n\\n### Promoted Tweets\\n\\n| Element | Limit | Notes |\\n|---------|-------|-------|\\n| Tweet text | 280 chars | Full tweet with image/video |\\n| Card headline | 70 chars | Website card |\\n| Card description | 200 chars | Website card |\\n\\n### Website Cards\\n\\n| Element | Limit |\\n|---------|-------|\\n| Headline | 70 chars |\\n| Description | 200 chars |\\n\\n**Twitter/X-specific guidelines:**\\n- Conversational, casual tone\\n- Short sentences work best\\n- One clear message per tweet\\n- Hashtags: 1-2 max (0 is often better for ads)\\n- Threads can work for consideration-stage content\\n\\n---\\n\\n## Character Counting Tips\\n\\n- **Spaces count** as characters on all platforms\\n- **Emojis** count as 1-2 characters depending on platform\\n- **Special characters** (|, &, etc.) count as 1 character\\n- **URLs** in body text count against limits\\n- **Dynamic keyword insertion** (`{KeyWord:default}`) can exceed limits — set safe defaults\\n- Always verify in the platform's ad preview before launching\\n\\n---\\n\\n## Multi-Platform Creative Adaptation\\n\\nWhen creating for multiple platforms simultaneously, start with the most restrictive format:\\n\\n1. **Google Search headlines** (30 chars) — forces the tightest messaging\\n2. **Expand to Meta headlines** (40 chars) — add a word or two\\n3. **Expand to LinkedIn intro text** (150 chars) — add context and proof\\n4. **Expand to Meta primary text** (125+ chars) — full hook and value prop\\n\\nThis cascading approach ensures your core message works everywhere, then gets enriched for platforms that allow more space.\\n\"},\n {\"skill\":\"ads\",\"ref\":\"ad-copy-templates\",\"body\":\"# Ad Copy Templates Reference\\n\\nDetailed formulas and templates for writing high-converting ad copy.\\n\\n## Contents\\n- Primary Text Formulas (Problem-Agitate-Solve, Before-After-Bridge, Social Proof Lead, Feature-Benefit Bridge, Direct Response)\\n- Headline Formulas (For Search Ads, For Social Ads)\\n- CTA Variations (Soft CTAs, Hard CTAs, Urgency CTAs, Action-Oriented CTAs)\\n- Platform-Specific Copy Guidelines (Google Search Ads, Meta Ads, LinkedIn Ads)\\n- Copy Testing Priority\\n\\n## Primary Text Formulas\\n\\n### Problem-Agitate-Solve (PAS)\\n\\n```\\n[Problem statement]\\n[Agitate the pain]\\n[Introduce solution]\\n[CTA]\\n```\\n\\n**Example:**\\n> Spending hours on manual reporting every week?\\n> While you're buried in spreadsheets, your competitors are making decisions.\\n> [Product] automates your reports in minutes.\\n> Start your free trial →\\n\\n---\\n\\n### Before-After-Bridge (BAB)\\n\\n```\\n[Current painful state]\\n[Desired future state]\\n[Your product as the bridge]\\n```\\n\\n**Example:**\\n> Before: Chasing down approvals across email, Slack, and spreadsheets.\\n> After: Every approval tracked, automated, and on time.\\n> [Product] connects your tools and keeps projects moving.\\n\\n---\\n\\n### Social Proof Lead\\n\\n```\\n[Impressive stat or testimonial]\\n[What you do]\\n[CTA]\\n```\\n\\n**Example:**\\n> \\\"We cut our reporting time by 75%.\\\" — Sarah K., Marketing Director\\n> [Product] automates the reports you hate building.\\n> See how it works →\\n\\n---\\n\\n### Feature-Benefit Bridge\\n\\n```\\n[Feature]\\n[So that...]\\n[Which means...]\\n```\\n\\n**Example:**\\n> Real-time collaboration on documents\\n> So your team always works from the latest version\\n> Which means no more version confusion or lost work\\n\\n---\\n\\n### Direct Response\\n\\n```\\n[Bold claim/outcome]\\n[Proof point]\\n[CTA with urgency if genuine]\\n```\\n\\n**Example:**\\n> Cut your reporting time by 80%\\n> Join 5,000+ marketing teams already using [Product]\\n> Start free → First month 50% off\\n\\n---\\n\\n## Headline Formulas\\n\\n### For Search Ads\\n\\n| Formula | Example |\\n|---------|---------|\\n| [Keyword] + [Benefit] | \\\"Project Management That Teams Actually Use\\\" |\\n| [Action] + [Outcome] | \\\"Automate Reports \\\\| Save 10 Hours Weekly\\\" |\\n| [Question] | \\\"Tired of Manual Data Entry?\\\" |\\n| [Number] + [Benefit] | \\\"500+ Teams Trust [Product] for [Outcome]\\\" |\\n| [Keyword] + [Differentiator] | \\\"CRM Built for Small Teams\\\" |\\n| [Price/Offer] + [Keyword] | \\\"Free Project Management \\\\| No Credit Card\\\" |\\n\\n### For Social Ads\\n\\n| Type | Example |\\n|------|---------|\\n| Outcome hook | \\\"How we 3x'd our conversion rate\\\" |\\n| Curiosity hook | \\\"The reporting hack no one talks about\\\" |\\n| Contrarian hook | \\\"Why we stopped using [common tool]\\\" |\\n| Specificity hook | \\\"The exact template we use for...\\\" |\\n| Question hook | \\\"What if you could cut your admin time in half?\\\" |\\n| Number hook | \\\"7 ways to improve your workflow today\\\" |\\n| Story hook | \\\"We almost gave up. Then we found...\\\" |\\n\\n---\\n\\n## CTA Variations\\n\\n### Soft CTAs (awareness/consideration)\\n\\nBest for: Top of funnel, cold audiences, complex products\\n\\n- Learn More\\n- See How It Works\\n- Watch Demo\\n- Get the Guide\\n- Explore Features\\n- See Examples\\n- Read the Case Study\\n\\n### Hard CTAs (conversion)\\n\\nBest for: Bottom of funnel, warm audiences, clear offers\\n\\n- Start Free Trial\\n- Get Started Free\\n- Book a Demo\\n- Claim Your Discount\\n- Buy Now\\n- Sign Up Free\\n- Get Instant Access\\n\\n### Urgency CTAs (use when genuine)\\n\\nBest for: Limited-time offers, scarcity situations\\n\\n- Limited Time: 30% Off\\n- Offer Ends [Date]\\n- Only X Spots Left\\n- Last Chance\\n- Early Bird Pricing Ends Soon\\n\\n### Action-Oriented CTAs\\n\\nBest for: Active voice, clear next step\\n\\n- Start Saving Time Today\\n- Get Your Free Report\\n- See Your Score\\n- Calculate Your ROI\\n- Build Your First Project\\n\\n---\\n\\n## Platform-Specific Copy Guidelines\\n\\n### Google Search Ads\\n\\n- **Headline limits:** 30 characters each (up to 15 headlines)\\n- **Description limits:** 90 characters each (up to 4 descriptions)\\n- Include keywords naturally\\n- Use all available headline slots\\n- Include numbers and stats when possible\\n- Test dynamic keyword insertion\\n\\n### Meta Ads (Facebook/Instagram)\\n\\n- **Primary text:** 125 characters visible (can be longer, gets truncated)\\n- **Headline:** 40 characters recommended\\n- Front-load the hook (first line matters most)\\n- Emojis can work but test\\n- Questions perform well\\n- Keep image text under 20%\\n\\n### LinkedIn Ads\\n\\n- **Intro text:** 600 characters max (150 recommended)\\n- **Headline:** 200 characters max (70 recommended)\\n- Professional tone (but not boring)\\n- Specific job outcomes resonate\\n- Stats and social proof important\\n- Avoid consumer-style hype\\n\\n---\\n\\n## Copy Testing Priority\\n\\nWhen testing ad copy, focus on these elements in order of impact:\\n\\n1. **Hook/angle** (biggest impact on performance)\\n2. **Headline**\\n3. **Primary benefit**\\n4. **CTA**\\n5. **Supporting proof points**\\n\\nTest one element at a time for clean data.\\n\"},\n {\"skill\":\"ads\",\"ref\":\"audience-targeting\",\"body\":\"# Audience Targeting Reference\\n\\nDetailed targeting strategies for each major ad platform.\\n\\n## Contents\\n- Google Ads Audiences (Search Campaign Targeting, Display/YouTube Targeting)\\n- Meta Audiences (Core Audiences, Custom Audiences, Lookalike Audiences)\\n- LinkedIn Audiences (Job-Based Targeting, Company-Based Targeting, High-Performing Combinations)\\n- Twitter/X Audiences\\n- TikTok Audiences\\n- Audience Size Guidelines\\n- Exclusion Strategy\\n\\n## Google Ads Audiences\\n\\n### Search Campaign Targeting\\n\\n**Keywords:**\\n- Exact match: [keyword] — most precise, lower volume\\n- Phrase match: \\\"keyword\\\" — moderate precision and volume\\n- Broad match: keyword — highest volume, use with smart bidding\\n\\n**Audience layering:**\\n- Add audiences in \\\"observation\\\" mode first\\n- Analyze performance by audience\\n- Switch to \\\"targeting\\\" mode for high performers\\n\\n**RLSA (Remarketing Lists for Search Ads):**\\n- Bid higher on past visitors searching your terms\\n- Show different ads to returning searchers\\n- Exclude converters from prospecting campaigns\\n\\n### Display/YouTube Targeting\\n\\n**Custom intent audiences:**\\n- Based on recent search behavior\\n- Create from your converting keywords\\n- High intent, good for prospecting\\n\\n**In-market audiences:**\\n- People actively researching solutions\\n- Pre-built by Google\\n- Layer with demographics for precision\\n\\n**Affinity audiences:**\\n- Based on interests and habits\\n- Better for awareness\\n- Broad but can exclude irrelevant\\n\\n**Customer match:**\\n- Upload email lists\\n- Retarget existing customers\\n- Create lookalikes from best customers\\n\\n**Similar/lookalike audiences:**\\n- Based on your customer match lists\\n- Expand reach while maintaining relevance\\n- Best when source list is high-quality customers\\n\\n---\\n\\n## Meta Audiences\\n\\n### Core Audiences (Interest/Demographic)\\n\\n**Interest targeting tips:**\\n- Layer interests with AND logic for precision\\n- Use Audience Insights to research interests\\n- Start broad, let algorithm optimize\\n- Exclude existing customers always\\n\\n**Demographic targeting:**\\n- Age and gender (if product-specific)\\n- Location (down to zip/postal code)\\n- Language\\n- Education and work (limited data now)\\n\\n**Behavior targeting:**\\n- Purchase behavior\\n- Device usage\\n- Travel patterns\\n- Life events\\n\\n### Custom Audiences\\n\\n**Website visitors:**\\n- All visitors (last 180 days max)\\n- Specific page visitors\\n- Time on site thresholds\\n- Frequency (visited X times)\\n\\n**Customer list:**\\n- Upload emails/phone numbers\\n- Match rate typically 30-70%\\n- Refresh regularly for accuracy\\n\\n**Engagement audiences:**\\n- Video viewers (25%, 50%, 75%, 95%)\\n- Page/profile engagers\\n- Form openers\\n- Instagram engagers\\n\\n**App activity:**\\n- App installers\\n- In-app events\\n- Purchase events\\n\\n### Lookalike Audiences\\n\\n**Source audience quality matters:**\\n- Use high-LTV customers, not all customers\\n- Purchasers > leads > all visitors\\n- Minimum 100 source users, ideally 1,000+\\n\\n**Size recommendations:**\\n- 1% — most similar, smallest reach\\n- 1-3% — good balance for most\\n- 3-5% — broader, good for scale\\n- 5-10% — very broad, awareness only\\n\\n**Layering strategies:**\\n- Lookalike + interest = more precision early\\n- Test lookalike-only as you scale\\n- Exclude the source audience\\n\\n---\\n\\n## LinkedIn Audiences\\n\\n### Job-Based Targeting\\n\\n**Job titles:**\\n- Be specific (CMO vs. \\\"Marketing\\\")\\n- LinkedIn normalizes titles, but verify\\n- Stack related titles\\n- Exclude irrelevant titles\\n\\n**Job functions:**\\n- Broader than titles\\n- Combine with seniority level\\n- Good for awareness campaigns\\n\\n**Seniority levels:**\\n- Entry, Senior, Manager, Director, VP, CXO, Partner\\n- Layer with function for precision\\n\\n**Skills:**\\n- Self-reported, less reliable\\n- Good for technical roles\\n- Use as expansion layer\\n\\n### Company-Based Targeting\\n\\n**Company size:**\\n- 1-10, 11-50, 51-200, 201-500, 501-1000, 1001-5000, 5000+\\n- Key filter for B2B\\n\\n**Industry:**\\n- Based on company classification\\n- Can be broad, layer with other criteria\\n\\n**Company names (ABM):**\\n- Upload target account list\\n- Minimum 300 companies recommended\\n- Match rate varies\\n\\n**Company growth rate:**\\n- Hiring rapidly = budget available\\n- Good signal for timing\\n\\n### High-Performing Combinations\\n\\n| Use Case | Targeting Combination |\\n|----------|----------------------|\\n| Enterprise sales | Company size 1000+ + VP/CXO + Industry |\\n| SMB sales | Company size 11-200 + Manager/Director + Function |\\n| Developer tools | Skills + Job function + Company type |\\n| ABM campaigns | Company list + Decision-maker titles |\\n| Broad awareness | Industry + Seniority + Geography |\\n\\n---\\n\\n## Twitter/X Audiences\\n\\n### Targeting options:\\n- Follower lookalikes (accounts similar to followers of X)\\n- Interest categories\\n- Keywords (in tweets)\\n- Conversation topics\\n- Events\\n- Tailored audiences (your lists)\\n\\n### Best practices:\\n- Follower lookalikes of relevant accounts work well\\n- Keyword targeting catches active conversations\\n- Lower CPMs than LinkedIn/Meta\\n- Less precise, better for awareness\\n\\n---\\n\\n## TikTok Audiences\\n\\n### Targeting options:\\n- Demographics (age, gender, location)\\n- Interests (TikTok's categories)\\n- Behaviors (video interactions)\\n- Device (iOS/Android, connection type)\\n- Custom audiences (pixel, customer file)\\n- Lookalike audiences\\n\\n### Best practices:\\n- Younger skew (18-34 primarily)\\n- Interest targeting is broad\\n- Creative matters more than targeting\\n- Let algorithm optimize with broad targeting\\n\\n---\\n\\n## Audience Size Guidelines\\n\\n| Platform | Minimum Recommended | Ideal Range |\\n|----------|-------------------|-------------|\\n| Google Search | 1,000+ searches/mo | 5,000-50,000 |\\n| Google Display | 100,000+ | 500K-5M |\\n| Meta | 100,000+ | 500K-10M |\\n| LinkedIn | 50,000+ | 100K-500K |\\n| Twitter/X | 50,000+ | 100K-1M |\\n| TikTok | 100,000+ | 1M+ |\\n\\nToo narrow = expensive, slow learning\\nToo broad = wasted spend, poor relevance\\n\\n---\\n\\n## Exclusion Strategy\\n\\nAlways exclude:\\n- Existing customers (unless upsell)\\n- Recent converters (7-14 days)\\n- Bounced visitors (<10 sec)\\n- Employees (by company or email list)\\n- Irrelevant page visitors (careers, support)\\n- Competitors (if identifiable)\\n\"}\n];\n",[306,222,79],"pulls","branches",1,"forks","envVars",{"_395":397,"_398":26},"connections",{"_395":389,"_396":26},"count","unfilledCount",4,"emptyCount",{"_48":1928,"_13":1259,"_77":1253,"_58":-5,"_50":51,"_300":689,"_301":24,"_52":1929,"_54":26,"_80":223,"_303":-5,"_82":30,"_304":-5,"_586":1930,"_17":1931},{"_48":1923,"_13":1777,"_77":1771,"_58":1253,"_50":51,"_300":1924,"_301":24,"_52":1925,"_54":26,"_80":223,"_303":-5,"_82":30,"_304":-5,"_586":1926,"_17":1927},{"_48":1915,"_13":1916,"_77":1917,"_58":1771,"_50":51,"_300":1918,"_301":24,"_52":1919,"_54":689,"_80":81,"_303":1920,"_82":30,"_304":-5,"_586":1921,"_17":1922},{"_48":1907,"_13":1908,"_77":1909,"_58":1771,"_50":51,"_300":1910,"_301":24,"_52":1911,"_54":680,"_80":81,"_303":1912,"_82":30,"_304":-5,"_586":1913,"_17":1914},{"_48":1900,"_13":1231,"_77":1901,"_58":1771,"_50":51,"_300":1902,"_301":24,"_52":1903,"_54":689,"_80":81,"_303":1904,"_82":30,"_304":-5,"_586":1905,"_17":1906},{"_48":1893,"_13":1223,"_77":1894,"_58":1771,"_50":51,"_300":1895,"_301":24,"_52":1896,"_54":389,"_80":81,"_303":1897,"_82":30,"_304":-5,"_586":1898,"_17":1899},{"_48":1886,"_13":1215,"_77":1887,"_58":1771,"_50":51,"_300":1888,"_301":24,"_52":1889,"_54":738,"_80":81,"_303":1890,"_82":30,"_304":-5,"_586":1891,"_17":1892},{"_48":1879,"_13":1207,"_77":1880,"_58":1771,"_50":51,"_300":1881,"_301":24,"_52":1882,"_54":629,"_80":81,"_303":1883,"_82":30,"_304":-5,"_586":1884,"_17":1885},{"_48":1872,"_13":1199,"_77":1873,"_58":1771,"_50":51,"_300":1874,"_301":24,"_52":1875,"_54":26,"_80":81,"_303":1876,"_82":30,"_304":-5,"_586":1877,"_17":1878},{"_48":1865,"_13":1191,"_77":1866,"_58":1771,"_50":51,"_300":1867,"_301":24,"_52":1868,"_54":620,"_80":81,"_303":1869,"_82":30,"_304":-5,"_586":1870,"_17":1871},{"_48":1858,"_13":1183,"_77":1859,"_58":1771,"_50":51,"_300":1860,"_301":24,"_52":1861,"_54":389,"_80":81,"_303":1862,"_82":30,"_304":-5,"_586":1863,"_17":1864},{"_48":1850,"_13":1851,"_77":1852,"_58":1771,"_50":51,"_300":1853,"_301":24,"_52":1854,"_54":26,"_80":81,"_303":1855,"_82":30,"_304":-5,"_586":1856,"_17":1857},{"_48":1843,"_13":1175,"_77":1844,"_58":1771,"_50":51,"_300":1845,"_301":24,"_52":1846,"_54":629,"_80":81,"_303":1847,"_82":30,"_304":-5,"_586":1848,"_17":1849},{"_48":1836,"_13":1167,"_77":1837,"_58":1771,"_50":51,"_300":1838,"_301":24,"_52":1839,"_54":680,"_80":81,"_303":1840,"_82":30,"_304":-5,"_586":1841,"_17":1842},{"_48":1828,"_13":1829,"_77":1830,"_58":1771,"_50":51,"_300":1831,"_301":24,"_52":1832,"_54":26,"_80":81,"_303":1833,"_82":30,"_304":-5,"_586":1834,"_17":1835},{"_48":1820,"_13":1821,"_77":1822,"_58":1771,"_50":51,"_300":1823,"_301":24,"_52":1824,"_54":26,"_80":81,"_303":1825,"_82":30,"_304":-5,"_586":1826,"_17":1827},{"_48":1813,"_13":1159,"_77":1814,"_58":1771,"_50":51,"_300":1815,"_301":24,"_52":1816,"_54":629,"_80":81,"_303":1817,"_82":30,"_304":-5,"_586":1818,"_17":1819},{"_48":1806,"_13":1151,"_77":1807,"_58":1771,"_50":51,"_300":1808,"_301":24,"_52":1809,"_54":913,"_80":81,"_303":1810,"_82":30,"_304":-5,"_586":1811,"_17":1812},{"_48":1799,"_13":1143,"_77":1800,"_58":1771,"_50":51,"_300":1801,"_301":24,"_52":1802,"_54":26,"_80":81,"_303":1803,"_82":30,"_304":-5,"_586":1804,"_17":1805},{"_48":1792,"_13":1135,"_77":1793,"_58":1771,"_50":51,"_300":1794,"_301":24,"_52":1795,"_54":26,"_80":81,"_303":1796,"_82":30,"_304":-5,"_586":1797,"_17":1798},{"_48":1785,"_13":1127,"_77":1786,"_58":1771,"_50":51,"_300":1787,"_301":24,"_52":1788,"_54":26,"_80":81,"_303":1789,"_82":30,"_304":-5,"_586":1790,"_17":1791},{"_48":1778,"_13":1119,"_77":1779,"_58":1771,"_50":51,"_300":1780,"_301":24,"_52":1781,"_54":738,"_80":81,"_303":1782,"_82":30,"_304":-5,"_586":1783,"_17":1784},{"_48":1769,"_13":1109,"_77":1770,"_58":1771,"_50":51,"_300":1772,"_301":24,"_52":1773,"_54":397,"_80":81,"_303":1774,"_82":30,"_304":-5,"_586":1775,"_17":1776},{"_48":1761,"_13":1762,"_77":1763,"_58":1253,"_50":51,"_300":1764,"_301":24,"_52":1765,"_54":26,"_80":81,"_303":1766,"_82":30,"_304":-5,"_586":1767,"_17":1768},{"_48":1753,"_13":1754,"_77":1755,"_58":1253,"_50":51,"_300":1756,"_301":24,"_52":1757,"_54":26,"_80":81,"_303":1758,"_82":30,"_304":-5,"_586":1759,"_17":1760},{"_48":1745,"_13":1746,"_77":1747,"_58":1253,"_50":51,"_300":1748,"_301":24,"_52":1749,"_54":738,"_80":81,"_303":1750,"_82":30,"_304":-5,"_586":1751,"_17":1752},{"_48":1737,"_13":1738,"_77":1739,"_58":1253,"_50":51,"_300":1740,"_301":24,"_52":1741,"_54":26,"_80":81,"_303":1742,"_82":30,"_304":-5,"_586":1743,"_17":1744},{"_48":1728,"_13":1729,"_77":1730,"_58":1253,"_50":51,"_300":1731,"_301":24,"_52":1732,"_54":1733,"_80":81,"_303":1734,"_82":30,"_304":-5,"_586":1735,"_17":1736},{"_48":1720,"_13":1721,"_77":1722,"_58":1253,"_50":51,"_300":1723,"_301":24,"_52":1724,"_54":389,"_80":81,"_303":1725,"_82":30,"_304":-5,"_586":1726,"_17":1727},{"_48":1712,"_13":1713,"_77":1714,"_58":1253,"_50":51,"_300":1715,"_301":24,"_52":1716,"_54":913,"_80":81,"_303":1717,"_82":30,"_304":-5,"_586":1718,"_17":1719},{"_48":1704,"_13":1705,"_77":1706,"_58":1253,"_50":51,"_300":1707,"_301":24,"_52":1708,"_54":26,"_80":81,"_303":1709,"_82":30,"_304":-5,"_586":1710,"_17":1711},{"_48":1696,"_13":1697,"_77":1698,"_58":1253,"_50":51,"_300":1699,"_301":24,"_52":1700,"_54":26,"_80":81,"_303":1701,"_82":30,"_304":-5,"_586":1702,"_17":1703},{"_48":1688,"_13":1689,"_77":1690,"_58":1253,"_50":51,"_300":1691,"_301":24,"_52":1692,"_54":397,"_80":81,"_303":1693,"_82":30,"_304":-5,"_586":1694,"_17":1695},{"_48":1680,"_13":1681,"_77":1682,"_58":1253,"_50":51,"_300":1683,"_301":24,"_52":1684,"_54":26,"_80":81,"_303":1685,"_82":30,"_304":-5,"_586":1686,"_17":1687},{"_48":1672,"_13":1673,"_77":1674,"_58":1253,"_50":51,"_300":1675,"_301":24,"_52":1676,"_54":620,"_80":81,"_303":1677,"_82":30,"_304":-5,"_586":1678,"_17":1679},{"_48":1664,"_13":1665,"_77":1666,"_58":1253,"_50":51,"_300":1667,"_301":24,"_52":1668,"_54":26,"_80":81,"_303":1669,"_82":30,"_304":-5,"_586":1670,"_17":1671},{"_48":1656,"_13":1657,"_77":1658,"_58":1253,"_50":51,"_300":1659,"_301":24,"_52":1660,"_54":913,"_80":81,"_303":1661,"_82":30,"_304":-5,"_586":1662,"_17":1663},{"_48":1647,"_13":1648,"_77":1649,"_58":1253,"_50":51,"_300":1650,"_301":24,"_52":1651,"_54":1652,"_80":81,"_303":1653,"_82":30,"_304":-5,"_586":1654,"_17":1655},{"_48":1639,"_13":1640,"_77":1641,"_58":1253,"_50":51,"_300":1642,"_301":24,"_52":1643,"_54":26,"_80":81,"_303":1644,"_82":30,"_304":-5,"_586":1645,"_17":1646},{"_48":1631,"_13":1632,"_77":1633,"_58":1253,"_50":51,"_300":1634,"_301":24,"_52":1635,"_54":689,"_80":81,"_303":1636,"_82":30,"_304":-5,"_586":1637,"_17":1638},{"_48":1623,"_13":1624,"_77":1625,"_58":1253,"_50":51,"_300":1626,"_301":24,"_52":1627,"_54":738,"_80":81,"_303":1628,"_82":30,"_304":-5,"_586":1629,"_17":1630},{"_48":1615,"_13":1616,"_77":1617,"_58":1253,"_50":51,"_300":1618,"_301":24,"_52":1619,"_54":26,"_80":81,"_303":1620,"_82":30,"_304":-5,"_586":1621,"_17":1622},{"_48":1607,"_13":1608,"_77":1609,"_58":1253,"_50":51,"_300":1610,"_301":24,"_52":1611,"_54":26,"_80":81,"_303":1612,"_82":30,"_304":-5,"_586":1613,"_17":1614},{"_48":1599,"_13":1600,"_77":1601,"_58":1253,"_50":51,"_300":1602,"_301":24,"_52":1603,"_54":26,"_80":81,"_303":1604,"_82":30,"_304":-5,"_586":1605,"_17":1606},{"_48":1591,"_13":1592,"_77":1593,"_58":1253,"_50":51,"_300":1594,"_301":24,"_52":1595,"_54":689,"_80":81,"_303":1596,"_82":30,"_304":-5,"_586":1597,"_17":1598},{"_48":1583,"_13":1584,"_77":1585,"_58":1253,"_50":51,"_300":1586,"_301":24,"_52":1587,"_54":738,"_80":81,"_303":1588,"_82":30,"_304":-5,"_586":1589,"_17":1590},{"_48":1575,"_13":1576,"_77":1577,"_58":1253,"_50":51,"_300":1578,"_301":24,"_52":1579,"_54":26,"_80":81,"_303":1580,"_82":30,"_304":-5,"_586":1581,"_17":1582},{"_48":1567,"_13":1568,"_77":1569,"_58":1253,"_50":51,"_300":1570,"_301":24,"_52":1571,"_54":904,"_80":81,"_303":1572,"_82":30,"_304":-5,"_586":1573,"_17":1574},{"_48":1559,"_13":1560,"_77":1561,"_58":1253,"_50":51,"_300":1562,"_301":24,"_52":1563,"_54":26,"_80":81,"_303":1564,"_82":30,"_304":-5,"_586":1565,"_17":1566},{"_48":1551,"_13":1552,"_77":1553,"_58":1253,"_50":51,"_300":1554,"_301":24,"_52":1555,"_54":397,"_80":81,"_303":1556,"_82":30,"_304":-5,"_586":1557,"_17":1558},{"_48":1543,"_13":1544,"_77":1545,"_58":1253,"_50":51,"_300":1546,"_301":24,"_52":1547,"_54":671,"_80":81,"_303":1548,"_82":30,"_304":-5,"_586":1549,"_17":1550},{"_48":1535,"_13":1536,"_77":1537,"_58":1253,"_50":51,"_300":1538,"_301":24,"_52":1539,"_54":389,"_80":81,"_303":1540,"_82":30,"_304":-5,"_586":1541,"_17":1542},{"_48":1527,"_13":1528,"_77":1529,"_58":1253,"_50":51,"_300":1530,"_301":24,"_52":1531,"_54":26,"_80":81,"_303":1532,"_82":30,"_304":-5,"_586":1533,"_17":1534},{"_48":1519,"_13":1520,"_77":1521,"_58":1253,"_50":51,"_300":1522,"_301":24,"_52":1523,"_54":26,"_80":81,"_303":1524,"_82":30,"_304":-5,"_586":1525,"_17":1526},{"_48":1510,"_13":1511,"_77":1512,"_58":1253,"_50":51,"_300":1513,"_301":24,"_52":1514,"_54":1515,"_80":81,"_303":1516,"_82":30,"_304":-5,"_586":1517,"_17":1518},{"_48":1501,"_13":1502,"_77":1503,"_58":1253,"_50":51,"_300":1504,"_301":24,"_52":1505,"_54":1506,"_80":81,"_303":1507,"_82":30,"_304":-5,"_586":1508,"_17":1509},{"_48":1493,"_13":1494,"_77":1495,"_58":1253,"_50":51,"_300":1496,"_301":24,"_52":1497,"_54":26,"_80":81,"_303":1498,"_82":30,"_304":-5,"_586":1499,"_17":1500},{"_48":1485,"_13":1486,"_77":1487,"_58":1253,"_50":51,"_300":1488,"_301":24,"_52":1489,"_54":620,"_80":81,"_303":1490,"_82":30,"_304":-5,"_586":1491,"_17":1492},{"_48":1477,"_13":1478,"_77":1479,"_58":1253,"_50":51,"_300":1480,"_301":24,"_52":1481,"_54":389,"_80":81,"_303":1482,"_82":30,"_304":-5,"_586":1483,"_17":1484},{"_48":1469,"_13":1470,"_77":1471,"_58":1253,"_50":51,"_300":1472,"_301":24,"_52":1473,"_54":389,"_80":81,"_303":1474,"_82":30,"_304":-5,"_586":1475,"_17":1476},{"_48":1461,"_13":1462,"_77":1463,"_58":1253,"_50":51,"_300":1464,"_301":24,"_52":1465,"_54":26,"_80":81,"_303":1466,"_82":30,"_304":-5,"_586":1467,"_17":1468},{"_48":1452,"_13":1453,"_77":1454,"_58":1253,"_50":51,"_300":1455,"_301":24,"_52":1456,"_54":1457,"_80":81,"_303":1458,"_82":30,"_304":-5,"_586":1459,"_17":1460},{"_48":1444,"_13":1445,"_77":1446,"_58":1253,"_50":51,"_300":1447,"_301":24,"_52":1448,"_54":26,"_80":81,"_303":1449,"_82":30,"_304":-5,"_586":1450,"_17":1451},{"_48":1436,"_13":1437,"_77":1438,"_58":1253,"_50":51,"_300":1439,"_301":24,"_52":1440,"_54":689,"_80":81,"_303":1441,"_82":30,"_304":-5,"_586":1442,"_17":1443},{"_48":1428,"_13":1429,"_77":1430,"_58":1253,"_50":51,"_300":1431,"_301":24,"_52":1432,"_54":26,"_80":81,"_303":1433,"_82":30,"_304":-5,"_586":1434,"_17":1435},{"_48":1420,"_13":1421,"_77":1422,"_58":1253,"_50":51,"_300":1423,"_301":24,"_52":1424,"_54":620,"_80":81,"_303":1425,"_82":30,"_304":-5,"_586":1426,"_17":1427},{"_48":1412,"_13":1413,"_77":1414,"_58":1253,"_50":51,"_300":1415,"_301":24,"_52":1416,"_54":389,"_80":81,"_303":1417,"_82":30,"_304":-5,"_586":1418,"_17":1419},{"_48":1404,"_13":1405,"_77":1406,"_58":1253,"_50":51,"_300":1407,"_301":24,"_52":1408,"_54":389,"_80":81,"_303":1409,"_82":30,"_304":-5,"_586":1410,"_17":1411},{"_48":1396,"_13":1397,"_77":1398,"_58":1253,"_50":51,"_300":1399,"_301":24,"_52":1400,"_54":689,"_80":81,"_303":1401,"_82":30,"_304":-5,"_586":1402,"_17":1403},{"_48":1388,"_13":1389,"_77":1390,"_58":1253,"_50":51,"_300":1391,"_301":24,"_52":1392,"_54":904,"_80":81,"_303":1393,"_82":30,"_304":-5,"_586":1394,"_17":1395},{"_48":1380,"_13":1381,"_77":1382,"_58":1253,"_50":51,"_300":1383,"_301":24,"_52":1384,"_54":389,"_80":81,"_303":1385,"_82":30,"_304":-5,"_586":1386,"_17":1387},{"_48":1372,"_13":1373,"_77":1374,"_58":1253,"_50":51,"_300":1375,"_301":24,"_52":1376,"_54":904,"_80":81,"_303":1377,"_82":30,"_304":-5,"_586":1378,"_17":1379},{"_48":1364,"_13":1365,"_77":1366,"_58":1253,"_50":51,"_300":1367,"_301":24,"_52":1368,"_54":389,"_80":81,"_303":1369,"_82":30,"_304":-5,"_586":1370,"_17":1371},{"_48":1356,"_13":1357,"_77":1358,"_58":1253,"_50":51,"_300":1359,"_301":24,"_52":1360,"_54":26,"_80":81,"_303":1361,"_82":30,"_304":-5,"_586":1362,"_17":1363},{"_48":1348,"_13":1349,"_77":1350,"_58":1253,"_50":51,"_300":1351,"_301":24,"_52":1352,"_54":26,"_80":81,"_303":1353,"_82":30,"_304":-5,"_586":1354,"_17":1355},{"_48":1340,"_13":1341,"_77":1342,"_58":1253,"_50":51,"_300":1343,"_301":24,"_52":1344,"_54":689,"_80":81,"_303":1345,"_82":30,"_304":-5,"_586":1346,"_17":1347},{"_48":1332,"_13":1333,"_77":1334,"_58":1253,"_50":51,"_300":1335,"_301":24,"_52":1336,"_54":620,"_80":81,"_303":1337,"_82":30,"_304":-5,"_586":1338,"_17":1339},{"_48":1324,"_13":1325,"_77":1326,"_58":1253,"_50":51,"_300":1327,"_301":24,"_52":1328,"_54":26,"_80":81,"_303":1329,"_82":30,"_304":-5,"_586":1330,"_17":1331},{"_48":1316,"_13":1317,"_77":1318,"_58":1253,"_50":51,"_300":1319,"_301":24,"_52":1320,"_54":389,"_80":81,"_303":1321,"_82":30,"_304":-5,"_586":1322,"_17":1323},{"_48":1308,"_13":1309,"_77":1310,"_58":1253,"_50":51,"_300":1311,"_301":24,"_52":1312,"_54":26,"_80":81,"_303":1313,"_82":30,"_304":-5,"_586":1314,"_17":1315},{"_48":1300,"_13":1301,"_77":1302,"_58":1253,"_50":51,"_300":1303,"_301":24,"_52":1304,"_54":620,"_80":81,"_303":1305,"_82":30,"_304":-5,"_586":1306,"_17":1307},{"_48":1292,"_13":1293,"_77":1294,"_58":1253,"_50":51,"_300":1295,"_301":24,"_52":1296,"_54":389,"_80":81,"_303":1297,"_82":30,"_304":-5,"_586":1298,"_17":1299},{"_48":1284,"_13":1285,"_77":1286,"_58":1253,"_50":51,"_300":1287,"_301":24,"_52":1288,"_54":26,"_80":81,"_303":1289,"_82":30,"_304":-5,"_586":1290,"_17":1291},{"_48":1276,"_13":1277,"_77":1278,"_58":1253,"_50":51,"_300":1279,"_301":24,"_52":1280,"_54":26,"_80":81,"_303":1281,"_82":30,"_304":-5,"_586":1282,"_17":1283},{"_48":1268,"_13":1269,"_77":1270,"_58":1253,"_50":51,"_300":1271,"_301":24,"_52":1272,"_54":662,"_80":81,"_303":1273,"_82":30,"_304":-5,"_586":1274,"_17":1275},{"_48":1260,"_13":1261,"_77":1262,"_58":1253,"_50":51,"_300":1263,"_301":24,"_52":1264,"_54":26,"_80":81,"_303":1265,"_82":30,"_304":-5,"_586":1266,"_17":1267},{"_48":1250,"_13":1251,"_77":1252,"_58":1253,"_50":51,"_300":1254,"_301":24,"_52":1255,"_54":397,"_80":81,"_303":1256,"_82":30,"_304":-5,"_586":1257,"_17":1258},{"_48":1246,"_13":1117,"_77":1111,"_58":-5,"_50":51,"_300":1241,"_301":24,"_52":1247,"_54":26,"_80":223,"_303":-5,"_82":30,"_304":-5,"_586":1248,"_17":1249},{"_48":1238,"_13":1239,"_77":1240,"_58":1111,"_50":51,"_300":1241,"_301":24,"_52":1242,"_54":26,"_80":81,"_303":1243,"_82":30,"_304":-5,"_586":1244,"_17":1245},{"_48":1230,"_13":1231,"_77":1232,"_58":1111,"_50":51,"_300":1233,"_301":24,"_52":1234,"_54":26,"_80":81,"_303":1235,"_82":30,"_304":-5,"_586":1236,"_17":1237},{"_48":1222,"_13":1223,"_77":1224,"_58":1111,"_50":51,"_300":1225,"_301":24,"_52":1226,"_54":26,"_80":81,"_303":1227,"_82":30,"_304":-5,"_586":1228,"_17":1229},{"_48":1214,"_13":1215,"_77":1216,"_58":1111,"_50":51,"_300":1217,"_301":24,"_52":1218,"_54":389,"_80":81,"_303":1219,"_82":30,"_304":-5,"_586":1220,"_17":1221},{"_48":1206,"_13":1207,"_77":1208,"_58":1111,"_50":51,"_300":1209,"_301":24,"_52":1210,"_54":26,"_80":81,"_303":1211,"_82":30,"_304":-5,"_586":1212,"_17":1213},{"_48":1198,"_13":1199,"_77":1200,"_58":1111,"_50":51,"_300":1201,"_301":24,"_52":1202,"_54":26,"_80":81,"_303":1203,"_82":30,"_304":-5,"_586":1204,"_17":1205},{"_48":1190,"_13":1191,"_77":1192,"_58":1111,"_50":51,"_300":1193,"_301":24,"_52":1194,"_54":689,"_80":81,"_303":1195,"_82":30,"_304":-5,"_586":1196,"_17":1197},{"_48":1182,"_13":1183,"_77":1184,"_58":1111,"_50":51,"_300":1185,"_301":24,"_52":1186,"_54":26,"_80":81,"_303":1187,"_82":30,"_304":-5,"_586":1188,"_17":1189},{"_48":1174,"_13":1175,"_77":1176,"_58":1111,"_50":51,"_300":1177,"_301":24,"_52":1178,"_54":389,"_80":81,"_303":1179,"_82":30,"_304":-5,"_586":1180,"_17":1181},{"_48":1166,"_13":1167,"_77":1168,"_58":1111,"_50":51,"_300":1169,"_301":24,"_52":1170,"_54":26,"_80":81,"_303":1171,"_82":30,"_304":-5,"_586":1172,"_17":1173},{"_48":1158,"_13":1159,"_77":1160,"_58":1111,"_50":51,"_300":1161,"_301":24,"_52":1162,"_54":26,"_80":81,"_303":1163,"_82":30,"_304":-5,"_586":1164,"_17":1165},{"_48":1150,"_13":1151,"_77":1152,"_58":1111,"_50":51,"_300":1153,"_301":24,"_52":1154,"_54":26,"_80":81,"_303":1155,"_82":30,"_304":-5,"_586":1156,"_17":1157},{"_48":1142,"_13":1143,"_77":1144,"_58":1111,"_50":51,"_300":1145,"_301":24,"_52":1146,"_54":26,"_80":81,"_303":1147,"_82":30,"_304":-5,"_586":1148,"_17":1149},{"_48":1134,"_13":1135,"_77":1136,"_58":1111,"_50":51,"_300":1137,"_301":24,"_52":1138,"_54":389,"_80":81,"_303":1139,"_82":30,"_304":-5,"_586":1140,"_17":1141},{"_48":1126,"_13":1127,"_77":1128,"_58":1111,"_50":51,"_300":1129,"_301":24,"_52":1130,"_54":26,"_80":81,"_303":1131,"_82":30,"_304":-5,"_586":1132,"_17":1133},{"_48":1118,"_13":1119,"_77":1120,"_58":1111,"_50":51,"_300":1121,"_301":24,"_52":1122,"_54":26,"_80":81,"_303":1123,"_82":30,"_304":-5,"_586":1124,"_17":1125},{"_48":1108,"_13":1109,"_77":1110,"_58":1111,"_50":51,"_300":1112,"_301":24,"_52":1113,"_54":689,"_80":81,"_303":1114,"_82":30,"_304":-5,"_586":1115,"_17":1116},{"_48":1104,"_13":306,"_77":299,"_58":-5,"_50":51,"_300":1095,"_301":24,"_52":1105,"_54":26,"_80":223,"_303":-5,"_82":30,"_304":-5,"_586":1106,"_17":1107},{"_48":1100,"_13":1035,"_77":1029,"_58":299,"_50":51,"_300":1095,"_301":24,"_52":1101,"_54":26,"_80":223,"_303":-5,"_82":30,"_304":-5,"_586":1102,"_17":1103},{"_48":1092,"_13":1093,"_77":1094,"_58":1029,"_50":51,"_300":1095,"_301":24,"_52":1096,"_54":26,"_80":81,"_303":1097,"_82":30,"_304":-5,"_586":1098,"_17":1099},{"_48":1084,"_13":1085,"_77":1086,"_58":1029,"_50":51,"_300":1087,"_301":24,"_52":1088,"_54":26,"_80":81,"_303":1089,"_82":30,"_304":-5,"_586":1090,"_17":1091},{"_48":1076,"_13":1077,"_77":1078,"_58":1029,"_50":51,"_300":1079,"_301":24,"_52":1080,"_54":26,"_80":81,"_303":1081,"_82":30,"_304":-5,"_586":1082,"_17":1083},{"_48":1068,"_13":1069,"_77":1070,"_58":1029,"_50":51,"_300":1071,"_301":24,"_52":1072,"_54":26,"_80":81,"_303":1073,"_82":30,"_304":-5,"_586":1074,"_17":1075},{"_48":1060,"_13":1061,"_77":1062,"_58":1029,"_50":51,"_300":1063,"_301":24,"_52":1064,"_54":26,"_80":81,"_303":1065,"_82":30,"_304":-5,"_586":1066,"_17":1067},{"_48":1052,"_13":1053,"_77":1054,"_58":1029,"_50":51,"_300":1055,"_301":24,"_52":1056,"_54":26,"_80":81,"_303":1057,"_82":30,"_304":-5,"_586":1058,"_17":1059},{"_48":1044,"_13":1045,"_77":1046,"_58":1029,"_50":51,"_300":1047,"_301":24,"_52":1048,"_54":26,"_80":81,"_303":1049,"_82":30,"_304":-5,"_586":1050,"_17":1051},{"_48":1036,"_13":1037,"_77":1038,"_58":1029,"_50":51,"_300":1039,"_301":24,"_52":1040,"_54":26,"_80":81,"_303":1041,"_82":30,"_304":-5,"_586":1042,"_17":1043},{"_48":1026,"_13":1027,"_77":1028,"_58":1029,"_50":51,"_300":1030,"_301":24,"_52":1031,"_54":26,"_80":81,"_303":1032,"_82":30,"_304":-5,"_586":1033,"_17":1034},{"_48":298,"_13":222,"_77":221,"_58":299,"_50":51,"_300":55,"_301":24,"_52":1023,"_54":26,"_80":223,"_303":-5,"_82":30,"_304":-5,"_586":1024,"_17":1025},{"_48":383,"_13":79,"_77":78,"_58":221,"_50":51,"_300":55,"_301":24,"_52":1020,"_54":26,"_80":81,"_303":385,"_82":30,"_304":-5,"_586":1021,"_17":1022},{"_48":379,"_13":94,"_77":93,"_58":221,"_50":51,"_300":88,"_301":24,"_52":1017,"_54":26,"_80":81,"_303":381,"_82":30,"_304":-5,"_586":1018,"_17":1019},{"_48":375,"_13":103,"_77":102,"_58":221,"_50":51,"_300":97,"_301":24,"_52":1014,"_54":26,"_80":81,"_303":377,"_82":30,"_304":-5,"_586":1015,"_17":1016},{"_48":371,"_13":112,"_77":111,"_58":221,"_50":51,"_300":106,"_301":24,"_52":1011,"_54":26,"_80":81,"_303":373,"_82":30,"_304":-5,"_586":1012,"_17":1013},{"_48":367,"_13":121,"_77":120,"_58":221,"_50":51,"_300":115,"_301":24,"_52":1008,"_54":26,"_80":81,"_303":369,"_82":30,"_304":-5,"_586":1009,"_17":1010},{"_48":363,"_13":130,"_77":129,"_58":221,"_50":51,"_300":124,"_301":24,"_52":1005,"_54":26,"_80":81,"_303":365,"_82":30,"_304":-5,"_586":1006,"_17":1007},{"_48":359,"_13":139,"_77":138,"_58":221,"_50":51,"_300":133,"_301":24,"_52":1002,"_54":26,"_80":81,"_303":361,"_82":30,"_304":-5,"_586":1003,"_17":1004},{"_48":355,"_13":148,"_77":147,"_58":221,"_50":51,"_300":142,"_301":24,"_52":999,"_54":26,"_80":81,"_303":357,"_82":30,"_304":-5,"_586":1000,"_17":1001},{"_48":351,"_13":157,"_77":156,"_58":221,"_50":51,"_300":151,"_301":24,"_52":996,"_54":26,"_80":81,"_303":353,"_82":30,"_304":-5,"_586":997,"_17":998},{"_48":347,"_13":166,"_77":165,"_58":221,"_50":51,"_300":160,"_301":24,"_52":993,"_54":26,"_80":81,"_303":349,"_82":30,"_304":-5,"_586":994,"_17":995},{"_48":343,"_13":175,"_77":174,"_58":221,"_50":51,"_300":169,"_301":24,"_52":990,"_54":26,"_80":81,"_303":345,"_82":30,"_304":-5,"_586":991,"_17":992},{"_48":339,"_13":184,"_77":183,"_58":221,"_50":51,"_300":178,"_301":24,"_52":987,"_54":26,"_80":81,"_303":341,"_82":30,"_304":-5,"_586":988,"_17":989},{"_48":335,"_13":193,"_77":192,"_58":221,"_50":51,"_300":187,"_301":24,"_52":984,"_54":26,"_80":81,"_303":337,"_82":30,"_304":-5,"_586":985,"_17":986},{"_48":331,"_13":202,"_77":201,"_58":221,"_50":51,"_300":196,"_301":24,"_52":981,"_54":26,"_80":81,"_303":333,"_82":30,"_304":-5,"_586":982,"_17":983},{"_48":327,"_13":211,"_77":210,"_58":221,"_50":51,"_300":205,"_301":24,"_52":978,"_54":26,"_80":81,"_303":329,"_82":30,"_304":-5,"_586":979,"_17":980},{"_48":323,"_13":220,"_77":219,"_58":221,"_50":51,"_300":214,"_301":24,"_52":975,"_54":26,"_80":81,"_303":325,"_82":30,"_304":-5,"_586":976,"_17":977},{"_48":967,"_13":968,"_77":969,"_58":299,"_50":51,"_300":970,"_301":24,"_52":971,"_54":26,"_80":81,"_303":972,"_82":30,"_304":-5,"_586":973,"_17":974},{"_48":959,"_13":960,"_77":961,"_58":-5,"_50":51,"_300":962,"_301":24,"_52":963,"_54":397,"_80":81,"_303":964,"_82":30,"_304":-5,"_586":965,"_17":966},{"_48":951,"_13":952,"_77":953,"_58":-5,"_50":51,"_300":954,"_301":24,"_52":955,"_54":913,"_80":81,"_303":956,"_82":30,"_304":-5,"_586":957,"_17":958},{"_48":943,"_13":944,"_77":945,"_58":-5,"_50":51,"_300":946,"_301":24,"_52":947,"_54":689,"_80":81,"_303":948,"_82":30,"_304":-5,"_586":949,"_17":950},{"_48":934,"_13":935,"_77":936,"_58":-5,"_50":51,"_300":937,"_301":24,"_52":938,"_54":939,"_80":81,"_303":940,"_82":30,"_304":-5,"_586":941,"_17":942},{"_48":925,"_13":926,"_77":927,"_58":-5,"_50":51,"_300":928,"_301":24,"_52":929,"_54":930,"_80":81,"_303":931,"_82":30,"_304":-5,"_586":932,"_17":933},{"_48":917,"_13":918,"_77":919,"_58":-5,"_50":51,"_300":920,"_301":24,"_52":921,"_54":389,"_80":81,"_303":922,"_82":30,"_304":-5,"_586":923,"_17":924},{"_48":908,"_13":909,"_77":910,"_58":-5,"_50":51,"_300":911,"_301":24,"_52":912,"_54":913,"_80":81,"_303":914,"_82":30,"_304":-5,"_586":915,"_17":916},{"_48":899,"_13":900,"_77":901,"_58":-5,"_50":51,"_300":902,"_301":24,"_52":903,"_54":904,"_80":81,"_303":905,"_82":30,"_304":-5,"_586":906,"_17":907},{"_48":891,"_13":892,"_77":893,"_58":-5,"_50":51,"_300":894,"_301":24,"_52":895,"_54":662,"_80":81,"_303":896,"_82":30,"_304":-5,"_586":897,"_17":898},{"_48":882,"_13":883,"_77":884,"_58":-5,"_50":51,"_300":885,"_301":24,"_52":886,"_54":887,"_80":81,"_303":888,"_82":30,"_304":-5,"_586":889,"_17":890},{"_48":874,"_13":875,"_77":876,"_58":-5,"_50":51,"_300":877,"_301":24,"_52":878,"_54":620,"_80":81,"_303":879,"_82":30,"_304":-5,"_586":880,"_17":881},{"_48":866,"_13":867,"_77":868,"_58":-5,"_50":51,"_300":869,"_301":24,"_52":870,"_54":26,"_80":81,"_303":871,"_82":30,"_304":-5,"_586":872,"_17":873},{"_48":858,"_13":859,"_77":860,"_58":-5,"_50":51,"_300":861,"_301":24,"_52":862,"_54":738,"_80":81,"_303":863,"_82":30,"_304":-5,"_586":864,"_17":865},{"_48":850,"_13":851,"_77":852,"_58":-5,"_50":51,"_300":853,"_301":24,"_52":854,"_54":620,"_80":81,"_303":855,"_82":30,"_304":-5,"_586":856,"_17":857},{"_48":841,"_13":842,"_77":843,"_58":-5,"_50":51,"_300":844,"_301":24,"_52":845,"_54":846,"_80":81,"_303":847,"_82":30,"_304":-5,"_586":848,"_17":849},{"_48":832,"_13":833,"_77":834,"_58":-5,"_50":51,"_300":835,"_301":24,"_52":836,"_54":837,"_80":81,"_303":838,"_82":30,"_304":-5,"_586":839,"_17":840},{"_48":824,"_13":825,"_77":826,"_58":-5,"_50":51,"_300":827,"_301":24,"_52":828,"_54":747,"_80":81,"_303":829,"_82":30,"_304":-5,"_586":830,"_17":831},{"_48":816,"_13":817,"_77":818,"_58":-5,"_50":51,"_300":819,"_301":24,"_52":820,"_54":397,"_80":81,"_303":821,"_82":30,"_304":-5,"_586":822,"_17":823},{"_48":808,"_13":809,"_77":810,"_58":-5,"_50":51,"_300":811,"_301":24,"_52":812,"_54":397,"_80":81,"_303":813,"_82":30,"_304":-5,"_586":814,"_17":815},{"_48":800,"_13":801,"_77":802,"_58":-5,"_50":51,"_300":803,"_301":24,"_52":804,"_54":26,"_80":81,"_303":805,"_82":30,"_304":-5,"_586":806,"_17":807},{"_48":792,"_13":793,"_77":794,"_58":-5,"_50":51,"_300":795,"_301":24,"_52":796,"_54":26,"_80":81,"_303":797,"_82":30,"_304":-5,"_586":798,"_17":799},{"_48":784,"_13":785,"_77":786,"_58":-5,"_50":51,"_300":787,"_301":24,"_52":788,"_54":26,"_80":81,"_303":789,"_82":30,"_304":-5,"_586":790,"_17":791},{"_48":776,"_13":777,"_77":778,"_58":-5,"_50":51,"_300":779,"_301":24,"_52":780,"_54":389,"_80":81,"_303":781,"_82":30,"_304":-5,"_586":782,"_17":783},{"_48":768,"_13":769,"_77":770,"_58":-5,"_50":51,"_300":771,"_301":24,"_52":772,"_54":738,"_80":81,"_303":773,"_82":30,"_304":-5,"_586":774,"_17":775},{"_48":759,"_13":760,"_77":761,"_58":-5,"_50":51,"_300":762,"_301":24,"_52":763,"_54":764,"_80":81,"_303":765,"_82":30,"_304":-5,"_586":766,"_17":767},{"_48":751,"_13":752,"_77":753,"_58":-5,"_50":51,"_300":754,"_301":24,"_52":755,"_54":689,"_80":81,"_303":756,"_82":30,"_304":-5,"_586":757,"_17":758},{"_48":742,"_13":743,"_77":744,"_58":-5,"_50":51,"_300":745,"_301":24,"_52":746,"_54":747,"_80":81,"_303":748,"_82":30,"_304":-5,"_586":749,"_17":750},{"_48":733,"_13":734,"_77":735,"_58":-5,"_50":51,"_300":736,"_301":24,"_52":737,"_54":738,"_80":81,"_303":739,"_82":30,"_304":-5,"_586":740,"_17":741},{"_48":725,"_13":726,"_77":727,"_58":-5,"_50":51,"_300":263,"_301":24,"_52":728,"_54":729,"_80":81,"_303":730,"_82":30,"_304":-5,"_586":731,"_17":732},{"_48":717,"_13":718,"_77":719,"_58":-5,"_50":51,"_300":720,"_301":24,"_52":721,"_54":689,"_80":81,"_303":722,"_82":30,"_304":-5,"_586":723,"_17":724},{"_48":709,"_13":710,"_77":711,"_58":-5,"_50":51,"_300":712,"_301":24,"_52":713,"_54":689,"_80":81,"_303":714,"_82":30,"_304":-5,"_586":715,"_17":716},{"_48":701,"_13":702,"_77":703,"_58":-5,"_50":51,"_300":704,"_301":24,"_52":705,"_54":397,"_80":81,"_303":706,"_82":30,"_304":-5,"_586":707,"_17":708},{"_48":693,"_13":694,"_77":695,"_58":-5,"_50":51,"_300":696,"_301":24,"_52":697,"_54":620,"_80":81,"_303":698,"_82":30,"_304":-5,"_586":699,"_17":700},{"_48":684,"_13":685,"_77":686,"_58":-5,"_50":51,"_300":687,"_301":24,"_52":688,"_54":689,"_80":81,"_303":690,"_82":30,"_304":-5,"_586":691,"_17":692},{"_48":675,"_13":676,"_77":677,"_58":-5,"_50":51,"_300":678,"_301":24,"_52":679,"_54":680,"_80":81,"_303":681,"_82":30,"_304":-5,"_586":682,"_17":683},{"_48":666,"_13":667,"_77":668,"_58":-5,"_50":51,"_300":669,"_301":24,"_52":670,"_54":671,"_80":81,"_303":672,"_82":30,"_304":-5,"_586":673,"_17":674},{"_48":657,"_13":658,"_77":659,"_58":-5,"_50":51,"_300":660,"_301":24,"_52":661,"_54":662,"_80":81,"_303":663,"_82":30,"_304":-5,"_586":664,"_17":665},{"_48":649,"_13":650,"_77":651,"_58":-5,"_50":51,"_300":652,"_301":24,"_52":653,"_54":26,"_80":81,"_303":654,"_82":30,"_304":-5,"_586":655,"_17":656},{"_48":641,"_13":642,"_77":643,"_58":-5,"_50":51,"_300":644,"_301":24,"_52":645,"_54":26,"_80":81,"_303":646,"_82":30,"_304":-5,"_586":647,"_17":648},{"_48":633,"_13":634,"_77":635,"_58":-5,"_50":51,"_300":636,"_301":24,"_52":637,"_54":397,"_80":81,"_303":638,"_82":30,"_304":-5,"_586":639,"_17":640},{"_48":624,"_13":625,"_77":626,"_58":-5,"_50":51,"_300":627,"_301":24,"_52":628,"_54":629,"_80":81,"_303":630,"_82":30,"_304":-5,"_586":631,"_17":632},{"_48":615,"_13":616,"_77":617,"_58":-5,"_50":51,"_300":618,"_301":24,"_52":619,"_54":620,"_80":81,"_303":621,"_82":30,"_304":-5,"_586":622,"_17":623},{"_48":606,"_13":607,"_77":236,"_58":-5,"_50":51,"_300":608,"_301":24,"_52":609,"_54":610,"_80":611,"_303":612,"_82":30,"_304":-5,"_586":613,"_17":614},{"_48":597,"_13":598,"_77":599,"_58":-5,"_50":51,"_300":600,"_301":24,"_52":601,"_54":602,"_80":81,"_303":603,"_82":30,"_304":-5,"_586":604,"_17":605},{"_48":589,"_13":590,"_77":591,"_58":-5,"_50":51,"_300":592,"_301":24,"_52":593,"_54":397,"_80":81,"_303":594,"_82":30,"_304":-5,"_586":595,"_17":596},{"_48":579,"_13":580,"_77":581,"_58":-5,"_50":51,"_300":582,"_301":24,"_52":583,"_54":584,"_80":81,"_303":585,"_82":30,"_304":-5,"_586":587,"_17":588},"026e63e8-5d7a-11f1-a7f5-1607ee4eb77e","types.ts","151549be-56ca-11f1-bc41-ee650bb23af1",699,["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","children",[],[580],"0b901660-5f64-11f1-8407-1607ee4eb77e","schema.ts","4ad25812-5f2b-11f1-9413-1607ee4eb77e",1099,["D",1780501872038],"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, name TEXT NOT NULL, api_key TEXT, api_secret TEXT, access_token TEXT,\n refresh_token TEXT, extra_config TEXT, connected_at TEXT, updated_at TEXT, tenant_id TEXT,\n UNIQUE(tenant_id, name)\n )\n `);\n\n // llm_config — LLM provider/key/model. (Rebuilt to PRIMARY KEY tenant_id by\n // mig_llm_config_tenant_v1 below so each tenant owns its own provider + keys.)\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, name TEXT NOT NULL, workspace TEXT NOT NULL, description TEXT,\n system_prompt TEXT, tools TEXT DEFAULT '[]', model TEXT, enabled INTEGER DEFAULT 1,\n created_at TEXT NOT NULL, updated_at TEXT NOT NULL, 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 the\n // framework-layer tasks schema. Rename a legacy table so the new CREATE below builds 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 // notes — shared team notes.\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 for health scoring. (Made per-tenant\n // UNIQUE(tenant_id, integration, metric_key) by mig_metric_baselines_tenant_v1 below.)\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 feed. (cache_key made\n // per-tenant UNIQUE(tenant_id, cache_key) by mig_intelligence_cache_tenant_v1 below.)\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 + workspace preferences. (Made per-tenant by\n // mig_app_config_tenant_v1 below: composite PK (tenant_id, key).)\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. Pruned to last 60 days on insert.\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 on metric_baselines (guarded ALTER).\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 keeps prior keys. Guarded ALTER.\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_budgets — monthly LLM-cost cap per agent. current_spend bumps per call, reset at period_start.\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_runs — one row per run (manual/scheduled); latest 50 power the AgentCard timeline.\n // status: queued → running → completed | failed | cancelled.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS agent_runs (\n id TEXT PRIMARY KEY, agent_id TEXT NOT NULL, status TEXT NOT NULL, trigger TEXT DEFAULT 'manual',\n started_at TEXT DEFAULT (datetime('now')), finished_at TEXT, duration_ms INTEGER,\n input TEXT, output TEXT, 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) for cohort-survival LTV.\n // retention_curve = JSON [m1,m2,...] retained counts; arpu = avg monthly revenue per user.\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 — one row per MQL→SQL transition (engagement velocity = avg days per 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 (POST /api/attribution or future GA4 scrape).\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 — 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\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 from impact/confidence/ease).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS experiments (\n id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL, hypothesis TEXT,\n objective_id INTEGER REFERENCES objectives(id) ON DELETE SET NULL,\n funnel_stage TEXT, aarrr_lever TEXT, status TEXT DEFAULT 'idea',\n impact REAL DEFAULT 5, confidence REAL DEFAULT 5, ease REAL DEFAULT 5,\n owner TEXT, start_date TEXT, end_date TEXT, channel TEXT, success_metric TEXT,\n baseline_value REAL, result_value REAL, outcome TEXT, learnings TEXT,\n created_at TEXT DEFAULT (datetime('now')), 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). Replaces the older string-id tasks table (renamed\n // to tasks_legacy above); the two 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, title TEXT NOT NULL, description TEXT,\n status TEXT DEFAULT 'todo', priority TEXT DEFAULT 'medium', workspace TEXT DEFAULT 'marketing',\n assignee TEXT, 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, impact REAL, confidence REAL, ease REAL, tags TEXT,\n created_at TEXT DEFAULT (datetime('now')), updated_at TEXT DEFAULT (datetime('now')), 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 // tasks.campaign_id — a task can belong to a campaign; completing it rolls progress up to the\n // objective. PRAGMA-guarded ALTER.\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 (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): 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 (api/knowledge.ts).\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. AI/agents PREPARE actions here; nothing sends until a human\n // approves, then the integration call runs. 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 // deals: CRM sales pipeline. Auto-seeded from qualified leads (POST /api/deals/sync) AND user-editable.\n // stage ∈ lead|qualified|proposal|negotiation|won|lost. lead_email links back to the source lead.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS deals (\n id TEXT PRIMARY KEY, title TEXT, company TEXT, contact_name TEXT, contact_email TEXT,\n stage TEXT NOT NULL DEFAULT 'lead', amount REAL DEFAULT 0, currency TEXT DEFAULT 'USD',\n probability INTEGER DEFAULT 0, owner TEXT, close_date TEXT, source TEXT DEFAULT 'manual',\n lead_email TEXT, notes TEXT, created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')), 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 accounts + contacts; deals link via account_id + primary_contact_id + deal_contacts.\n // Backfilled non-destructively from legacy deal text columns by mig_crm_relational_v1. Tenant-scoped.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS accounts (\n id TEXT PRIMARY KEY, name TEXT, domain TEXT, industry TEXT, size TEXT, website TEXT, owner TEXT,\n tags TEXT DEFAULT '[]', custom_fields TEXT DEFAULT '{}', notes TEXT,\n created_at TEXT DEFAULT (datetime('now')), updated_at TEXT DEFAULT (datetime('now')), 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, account_id TEXT, first_name TEXT, last_name TEXT, email TEXT, phone TEXT,\n title TEXT, owner TEXT, tags TEXT DEFAULT '[]', custom_fields TEXT DEFAULT '{}', notes TEXT,\n created_at TEXT DEFAULT (datetime('now')), updated_at TEXT DEFAULT (datetime('now')), 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 deal↔contact with a buying-committee role (migration uses \"primary\" for the deal's\n // 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). Legacy text columns KEPT.\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 // activities: unified timeline (calls/meetings/notes/emails/tasks) on contact/account/deal.\n // getTimeline() MERGES these with intent_signals (by email) + linked tasks. Tenant-scoped.\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_products — LINE ITEMS. Deal amount rolls up as SUM(amount) when present (else manual\n // deals.amount). amount = 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 // pipeline_stages — configurable label + win-probability per stage (seeded once below, 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).\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); 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 (flag mig_pipeline_stages_v1) for every tenant\n // (always incl. t_default). Idempotent: INSERT OR IGNORE on a deterministic id (tenant + stage_key).\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 // Tenants to seed: every row in the tenants table, always including t_default.\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 tenant-scoped tables over deals/contacts/intent_signals/users; in TENANT_SCOPED_TABLES.\n\n // A) SALES ANALYTICS ───\n // deal_stage_history: one row per stage change. Powers stage-conversion, velocity, funnel/leaderboard.\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 per period. period_type ∈ month|quarter|year; period = label.\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. weighted_amount = total × stage prob.\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 per (tenant, lead_email). grade ∈ A|B|C|D; status ∈\n // new|working|qualified|disqualified. sla_due_at = first-response deadline; first_response_at stops clock.\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 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 → 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: named multi-step cadence (active=1 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. channel ∈ email|task|call; delay_days = wait after prior step;\n // template_id → email_templates (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: contact (+ optional deal) in a sequence. current_step = 0-based pointer;\n // status ∈ active|paused|completed; next_action_at drives the 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 // marketing_personas: Persona/ICP/segment library. kind ∈ icp|persona|segment; attributes = JSON;\n // source ∈ enrichment|manual. Tenant-scoped.\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 (UTM builder). full_url = base_url + utm params. Tenant-scoped.\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 — voice/tone/values/dos/donts/boilerplate + JSON palette + logo_url.\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 tenant-scoped tables: CONVERT traffic (forms + landing pages) + TARGET people (segments +\n // lists). tenant_id on all EXCEPT two PUBLIC read paths (resolve owning tenant by id/slug). In\n // TENANT_SCOPED_TABLES for mig_tenant_v1. NEVER use a SQL reserved word as a column name.\n\n // marketing_forms: lead-capture form. fields = JSON; asset_url = gated download; redirect_url =\n // post-submit redirect; submit_count bumps on each public submit.\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 = JSON of posted fields. tenant_id = the OWNING\n // tenant of form_id (resolved by id at submit time, never the anonymous caller's session).\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: public page. slug GLOBALLY unique (public /api/marketing/p/:slug render across\n // tenants). blocks = JSON; form_id embeds a form; published=1 gates render; view_count bumps.\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 await sqlite.execute(`CREATE UNIQUE INDEX IF NOT EXISTS idx_landing_pages_slug ON landing_pages(slug)`);\n\n // segments: saved audience. kind ∈ dynamic|static; rules = JSON over contacts + lead_status + signals.\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: named contact list. kind ∈ static|dynamic; dynamic → segment_id materializes members.\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: contact↔list join. lead_email is the stable key when contact_id is unavailable.\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 tenant-scoped tables: editorial calendar, SEO briefs, asset library, campaign budgeting.\n // In TENANT_SCOPED_TABLES. NEVER use a SQL reserved word as a column name.\n\n // content_items: a content piece. type ∈ blog|social|video|email|landing|ad; status ∈\n // idea|brief|draft|review|scheduled|published. campaign_id/brief_id link out; asset_ids = JSON ids;\n // scheduled_at drives the editorial calendar; body = 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: SEO brief for a content_item (content_id links back). outline/competitors/\n // internal_links = JSON/text; word_count_target = writer's target.\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: media registry. asset_type ∈ image|video|doc|pdf|other; source ∈\n // upload|wordpress|drive|link; bytes = 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. actual_amount accrues (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 tenant-scoped tables: ad_campaigns, journeys + journey_runs, abm_targets, broadcasts,\n // partners. In TENANT_SCOPED_TABLES. NEVER use a SQL reserved word as a column name.\n\n // ad_campaigns: paid-media spend. platform ∈ google_ads|meta|linkedin|other; external_id = the\n // platform's campaign id; campaign_id links an internal campaigns row; period is a label.\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 JSON); action_type ∈ enroll_sequence|add_to_list|create_task|\n // notify|grade_lead (action_config JSON). active=1 gates; run_count bumps per match.\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: one row per journey evaluation. entity_ref = triggering entity (lead_email/deal_id);\n // status ∈ matched|acted|skipped|error; detail = short outcome message.\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: ABM target accounts (account_id → accounts). tier ∈ 1|2|3 (text); engagement_score\n // from real signals/activities/deals; status ∈ target|engaged|opportunity|won|dropped.\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 // → chosen list/segment, NULL for all). channel ∈ gmail|outlook; status ∈ draft|scheduled|sending|sent.\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. referral_code carried on a referred\n // deal/contact source; status ∈ active|paused; deals_referred + revenue accrue from attribution.\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 ──\n // competitors — tracked rival domains. metrics = JSON snapshot (domain_rating/backlinks/\n // ref_domains/organic_keywords) from Ahrefs; tracked_keywords = JSON. Tenant-scoped.\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 — CRO tests linking an experiment + a landing_page. status ∈ draft|running|complete;\n // winner names the winning arm. Results read from the linked experiment (stat-sig via experiments.ts).\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 = synthesized text; signals = JSON list\n // of real sources used (ProductHunt/YouTube/intent_signals/competitor metrics).\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 // ─── SEO WEB CRAWLER (site-wide audit) — complements the single-URL analyzer (api/seo.ts) ───\n // Two tenant-scoped tables driving api/crawler.ts (in TENANT_SCOPED_TABLES below). No SQL reserved\n // words as columns. seo_crawls = one crawl run (status running|done|error); seo_crawl_pages = one\n // row per page (headings/issues JSON; markdown = page content; depth = BFS distance from start_url).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS seo_crawls (\n id TEXT PRIMARY KEY, start_url TEXT, domain TEXT, status TEXT DEFAULT 'running',\n max_pages INTEGER DEFAULT 25, pages_crawled INTEGER DEFAULT 0, issues_count INTEGER DEFAULT 0,\n error TEXT, created_at TEXT DEFAULT (datetime('now')), finished_at TEXT, tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_seo_crawls_tenant ON seo_crawls(tenant_id)`);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS seo_crawl_pages (\n id TEXT PRIMARY KEY, crawl_id TEXT, url TEXT, status_code INTEGER, title TEXT, title_len INTEGER,\n meta_description TEXT, meta_desc_len INTEGER, h1 TEXT, h1_count INTEGER, headings TEXT,\n word_count INTEGER, internal_links INTEGER, external_links INTEGER, images INTEGER,\n images_missing_alt INTEGER, canonical TEXT, robots_meta TEXT, issues TEXT, markdown TEXT,\n depth INTEGER, fetched_at TEXT DEFAULT (datetime('now')), tenant_id TEXT\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_seo_crawl_pages_tenant ON seo_crawl_pages(tenant_id, crawl_id)`);\n\n // I3: agents.role for Listener/Topic/Creator/Analyst/General (guarded ALTER)\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).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS memory (\n id INTEGER PRIMARY KEY AUTOINCREMENT, type TEXT DEFAULT 'fact', content TEXT NOT NULL,\n source TEXT DEFAULT 'manual', confidence REAL DEFAULT 0.7, pinned INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')), updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // Part 1: skills STATE — enabled/pinned + custom skills.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS skills (\n name TEXT PRIMARY KEY, enabled INTEGER DEFAULT 1, pinned INTEGER DEFAULT 0,\n source TEXT DEFAULT 'builtin', category TEXT, description TEXT, body TEXT,\n created_at TEXT DEFAULT (datetime('now')), updated_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // Part 3 fix 7: experiments.sample_size + significance (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 (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 — a campaign has many inputs + MANY member agents. A campaign RUN is the\n // Director orchestrating member agents (sequential/parallel) and synthesizing a final output.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS campaigns (\n id TEXT PRIMARY KEY, name TEXT NOT NULL, workspace TEXT NOT NULL DEFAULT 'marketing',\n description TEXT, goal TEXT, channel TEXT, audience TEXT, mode TEXT DEFAULT 'sequential',\n status TEXT DEFAULT 'active', objective_id INTEGER, created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now')), created_by TEXT DEFAULT 'user'\n )\n `);\n // campaign_agents — ordered membership (agents + pipeline order + role).\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS campaign_agents (\n campaign_id TEXT NOT NULL, agent_id TEXT NOT NULL, sequence INTEGER DEFAULT 0, role TEXT,\n PRIMARY KEY (campaign_id, agent_id)\n )\n `);\n // campaign_runs — one Director pipeline execution.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS campaign_runs (\n id TEXT PRIMARY KEY, campaign_id TEXT NOT NULL, status TEXT NOT NULL DEFAULT 'running',\n input TEXT, final_output TEXT, trace TEXT, started_at TEXT DEFAULT (datetime('now')), 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. trigger_type ∈ manual|interval|schedule|event; trigger_config = JSON;\n // loop=1 reschedules after each run; next_run_at drives the cron runner. (Guarded ALTER.)\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 (campaign_run_id + handed-off input 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 // Identity tables — 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, name TEXT NOT NULL, slug TEXT UNIQUE,\n plan TEXT DEFAULT 'trial', status TEXT DEFAULT 'active', created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS users (\n id TEXT PRIMARY KEY, email TEXT UNIQUE NOT NULL, name TEXT, password_hash TEXT,\n avatar_url TEXT, created_at TEXT DEFAULT (datetime('now')), last_login_at TEXT\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS memberships (\n tenant_id TEXT NOT NULL, user_id TEXT NOT NULL, role TEXT DEFAULT 'owner',\n created_at TEXT DEFAULT (datetime('now')), PRIMARY KEY (tenant_id, user_id)\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY, user_id TEXT NOT NULL, tenant_id TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now')), expires_at TEXT, user_agent TEXT, 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\"). Admin toggles this on THEIR OWN session;\n // resolveSessionToken redirects currentTenantId() to the target tenant for reads only (writes\n // blocked by main.ts). NULL = not impersonating. PRAGMA-guarded ALTER (idempotent).\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 reads across all\n // tenants. users gains is_platform_admin (master flag) + status. PRAGMA-guarded ALTERs (idempotent).\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. No tenant_id: spans all tenants.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS platform_audit (\n id TEXT PRIMARY KEY, actor_user_id TEXT, actor_email TEXT, action TEXT,\n target_type TEXT, target_id TEXT, detail TEXT, created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // tenant_id column on EVERY business table (PRAGMA-guarded ALTER, idempotent). NOT on\n // tenants/users/memberships/sessions (those ARE the identity layer).\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 \"seo_crawls\", \"seo_crawl_pages\",\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 (flag mig_tenant_v1). Backfill every business table's tenant_id to\n // \"t_default\" + insert the default tenant row. Owner user creation is left to api/auth.ts.\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 (flag mig_platform_admin_v1): promote the platform owner (PLATFORM_OWNER_EMAIL env) to\n // is_platform_admin=1. api/auth.ts also sets it at signup. Idempotent UPDATE.\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 // Legacy global `name UNIQUE` → UNIQUE(tenant_id, name) so each tenant owns its own row. SQLite\n // can't ALTER a UNIQUE in place → ONE-TIME guarded rebuild (flag mig_integrations_v2). Idempotent:\n // rebuilds only when flag absent AND the live table still has the global UNIQUE(name) index. Rows\n // already carry tenant_id='t_default', so the copy preserves 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 // A FRESH DB is already per-tenant (top-level CREATE), so detect the OLD shape (global\n // UNIQUE(name) index lacking tenant_id) 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 → index_info gives each unique index's columns. Legacy = (name); new = (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, name TEXT NOT NULL, api_key TEXT, api_secret TEXT, access_token TEXT,\n refresh_token TEXT, extra_config TEXT, connected_at TEXT, updated_at TEXT, 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. For EVERY deal, derive relational rows non-destructively from its legacy text fields:\n // upsert account by (tenant_id, lower(company)); upsert contact by (tenant_id, lower(contact_email))\n // linked to that account; set deal.account_id + primary_contact_id; insert deal_contacts('primary').\n // Reads each deal's OWN tenant_id; writes rows carrying THAT tenant_id. Idempotent (existence checks\n // + INSERT OR IGNORE); 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.\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 by 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 → first (first token) / last (remainder).\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 // ─── PER-TENANT KEY/UNIQUE REBUILDS (AUDIT FIXES 1-3) ───\n // Four tables had a tenant_id column but GLOBAL primary/unique keys + tenant-blind OR-REPLACE writes\n // (one shared row across tenants). Each fix rebuilds the table with the key made PER-TENANT (SQLite\n // can't ALTER a PK/UNIQUE in place), gated by an app_config flag, NON-DESTRUCTIVE + idempotent: copy\n // every row assigning tenant_id (null → t_default), then drop+rename. Rows already carry\n // tenant_id='t_default' (mig_tenant_v1), so ownership is preserved.\n\n // hasGlobalUniqueWithout(table, mustCols, absentCol): true when a UNIQUE index covers all mustCols\n // but NOT absentCol (the legacy global-unique shape) — so a FRESH per-tenant DB is never rebuilt.\n // Returns true on introspection failure (rebuild-to-be-safe).\n const hasGlobalUniqueWithout = async (\n table: string, mustCols: string[], absentCol: string\n ): Promise => {\n try {\n const idxList = await sqlite.execute(`PRAGMA index_list(${table})`);\n for (const row of (idxList.rows || [])) {\n if (!Number(Array.isArray(row) ? row[2] : (row as any).unique)) continue;\n const idxName = String(Array.isArray(row) ? row[1] : (row as any).name);\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 if (mustCols.every((c) => idxCols.includes(c)) && !idxCols.includes(absentCol)) return true;\n }\n return false;\n } catch { return true; }\n };\n const colsOf = async (table: string): Promise> => {\n try {\n const cols = await sqlite.execute(`PRAGMA table_info(${table})`);\n return new Set((cols.rows || []).map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n } catch { return new Set(); }\n };\n const setMigFlag = async (key: string): Promise => {\n // Flags are app-level: written at t_default with INSERT OR REPLACE so the unfiltered flag-gate\n // SELECTs (one row per key, all at t_default) keep resolving after app_config goes composite-PK.\n await sqlite.execute(\n `INSERT OR REPLACE INTO app_config (key, value, tenant_id, updated_at) VALUES (?, 'done', 't_default', datetime('now'))`,\n [key]\n );\n };\n\n // FIX 1: llm_config → PRIMARY KEY tenant_id (was id='default' singleton; one tenant clobbered all).\n // Keeps every column incl. the per-provider keys from the QA ALTER; `id` retained as a plain column.\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_llm_config_tenant_v1'\");\n if (flag.rows.length === 0) {\n const lInfo = ((await sqlite.execute(\"PRAGMA table_info(llm_config)\")).rows || []) as any[];\n let tenantIsPk = false, hasIdCol = false;\n for (const r of lInfo) {\n const c = String(Array.isArray(r) ? r[1] : r.name);\n const pk = Number(Array.isArray(r) ? r[5] : (r as any).pk) || 0;\n if (c === \"id\") hasIdCol = true;\n if (c === \"tenant_id\" && pk > 0) tenantIsPk = true;\n }\n if (lInfo.length > 0 && hasIdCol && !tenantIsPk) {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS llm_config_v2 (\n tenant_id TEXT PRIMARY KEY, id TEXT DEFAULT 'default',\n provider TEXT NOT NULL DEFAULT 'anthropic', api_key TEXT NOT NULL DEFAULT '',\n endpoint TEXT, model TEXT NOT NULL DEFAULT 'claude-sonnet-4-6', updated_at TEXT,\n api_key_anthropic TEXT DEFAULT '', api_key_openai TEXT DEFAULT '',\n api_key_gemini TEXT DEFAULT '', api_key_custom TEXT DEFAULT '', endpoint_custom TEXT DEFAULT ''\n )\n `);\n await sqlite.execute(`\n INSERT OR IGNORE INTO llm_config_v2\n (tenant_id, id, provider, api_key, endpoint, model, updated_at,\n api_key_anthropic, api_key_openai, api_key_gemini, api_key_custom, endpoint_custom)\n SELECT COALESCE(tenant_id, 't_default'), COALESCE(id, 'default'),\n COALESCE(provider, 'anthropic'), COALESCE(api_key, ''), endpoint,\n COALESCE(model, 'claude-sonnet-4-6'), updated_at,\n COALESCE(api_key_anthropic, ''), COALESCE(api_key_openai, ''),\n COALESCE(api_key_gemini, ''), COALESCE(api_key_custom, ''), COALESCE(endpoint_custom, '')\n FROM llm_config\n `);\n await sqlite.execute(\"DROP TABLE llm_config\");\n await sqlite.execute(\"ALTER TABLE llm_config_v2 RENAME TO llm_config\");\n }\n await setMigFlag(\"mig_llm_config_tenant_v1\");\n }\n } catch { /* non-critical: retried next warm start (flag only set on success) */ }\n\n // FIX 2 (DELICATE): app_config → composite PRIMARY KEY (tenant_id, key) (was global key, so one\n // tenant's config write overwrote another's row + stole its tenant_id). Migration FLAGS (all at\n // t_default, one row per key) still resolve under the unfiltered flag-gate SELECTs, and flag writes\n // (INSERT OR REPLACE at t_default) key on the new composite PK. Copy preserves each row's tenant_id.\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_app_config_tenant_v1'\");\n if (flag.rows.length === 0) {\n const aInfo = ((await sqlite.execute(\"PRAGMA table_info(app_config)\")).rows || []) as any[];\n const aCols = new Set(aInfo.map((r: any) => String(Array.isArray(r) ? r[1] : r.name)));\n let tenantInPk = false;\n for (const r of aInfo) {\n const c = String(Array.isArray(r) ? r[1] : r.name);\n const pk = Number(Array.isArray(r) ? r[5] : (r as any).pk) || 0;\n if (c === \"tenant_id\" && pk > 0) tenantInPk = true;\n }\n if (aCols.size > 0 && aCols.has(\"tenant_id\") && !tenantInPk) {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS app_config_v2 (\n tenant_id TEXT NOT NULL DEFAULT 't_default',\n key TEXT NOT NULL,\n value TEXT,\n updated_at TEXT DEFAULT (datetime('now')),\n PRIMARY KEY (tenant_id, key)\n )\n `);\n await sqlite.execute(`\n INSERT OR IGNORE INTO app_config_v2 (tenant_id, key, value, updated_at)\n SELECT COALESCE(tenant_id, 't_default'), key, value, updated_at FROM app_config\n `);\n await sqlite.execute(\"DROP TABLE app_config\");\n await sqlite.execute(\"ALTER TABLE app_config_v2 RENAME TO app_config\");\n }\n await setMigFlag(\"mig_app_config_tenant_v1\");\n }\n } catch { /* non-critical: retried next warm start (flag only set on success) */ }\n\n // FIX 3a: intelligence_cache → UNIQUE(tenant_id, cache_key) (was global UNIQUE(cache_key); the\n // tenant-tagged INSERT OR REPLACE matched cache_key alone and clobbered another tenant's cache).\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_intelligence_cache_tenant_v1'\");\n if (flag.rows.length === 0) {\n const have = await colsOf(\"intelligence_cache\");\n if (have.size > 0 && await hasGlobalUniqueWithout(\"intelligence_cache\", [\"cache_key\"], \"tenant_id\")) {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS intelligence_cache_v2 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n cache_key TEXT NOT NULL,\n payload TEXT NOT NULL,\n generated_at TEXT DEFAULT (datetime('now')),\n expires_at TEXT NOT NULL,\n tenant_id TEXT,\n UNIQUE(tenant_id, cache_key)\n )\n `);\n await sqlite.execute(`\n INSERT OR IGNORE INTO intelligence_cache_v2 (cache_key, payload, generated_at, expires_at, tenant_id)\n SELECT cache_key, payload, generated_at, expires_at, COALESCE(tenant_id, 't_default')\n FROM intelligence_cache\n `);\n await sqlite.execute(\"DROP TABLE intelligence_cache\");\n await sqlite.execute(\"ALTER TABLE intelligence_cache_v2 RENAME TO intelligence_cache\");\n }\n await setMigFlag(\"mig_intelligence_cache_tenant_v1\");\n }\n } catch { /* non-critical: retried next warm start (flag only set on success) */ }\n\n // FIX 3b: metric_baselines → UNIQUE(tenant_id, integration, metric_key) (was global UNIQUE\n // (integration, metric_key)). Preserves the rolling_avg/sample_count columns from the A5 ALTER\n // (copied conditionally so the SELECT never references a column a legacy DB lacks).\n try {\n const flag = await sqlite.execute(\"SELECT value FROM app_config WHERE key = 'mig_metric_baselines_tenant_v1'\");\n if (flag.rows.length === 0) {\n const have = await colsOf(\"metric_baselines\");\n if (have.size > 0 && await hasGlobalUniqueWithout(\"metric_baselines\", [\"integration\", \"metric_key\"], \"tenant_id\")) {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS metric_baselines_v2 (\n id INTEGER PRIMARY KEY AUTOINCREMENT, integration TEXT NOT NULL, metric_key TEXT NOT NULL,\n baseline_value REAL, baseline_period TEXT DEFAULT '30d',\n last_updated TEXT DEFAULT (datetime('now')), rolling_avg REAL, sample_count INTEGER DEFAULT 0,\n tenant_id TEXT, UNIQUE(tenant_id, integration, metric_key)\n )\n `);\n const rollingSel = have.has(\"rolling_avg\") ? \"rolling_avg\" : \"NULL\";\n const sampleSel = have.has(\"sample_count\") ? \"sample_count\" : \"0\";\n await sqlite.execute(`\n INSERT OR IGNORE INTO metric_baselines_v2\n (integration, metric_key, baseline_value, baseline_period, last_updated, rolling_avg, sample_count, tenant_id)\n SELECT integration, metric_key, baseline_value, baseline_period, last_updated,\n ${rollingSel}, ${sampleSel}, COALESCE(tenant_id, 't_default')\n FROM metric_baselines\n `);\n await sqlite.execute(\"DROP TABLE metric_baselines\");\n await sqlite.execute(\"ALTER TABLE metric_baselines_v2 RENAME TO metric_baselines\");\n }\n await setMigFlag(\"mig_metric_baselines_tenant_v1\");\n }\n } catch { /* non-critical: retried next warm start (flag only set on success) */ }\n\n // Seed default LLM config if absent. After FIX 1 the table is keyed by tenant_id, so seed the boot\n // tenant's row (t_default); column-guarded to also handle a not-yet-migrated id-keyed shape.\n try {\n const lHave = await colsOf(\"llm_config\");\n if (lHave.has(\"tenant_id\")) {\n const existing = await sqlite.execute(\"SELECT tenant_id FROM llm_config WHERE tenant_id = 't_default'\");\n if (existing.rows.length === 0) {\n await sqlite.execute(\n \"INSERT OR IGNORE INTO llm_config (tenant_id, id, provider, api_key, model, updated_at) VALUES ('t_default', 'default', 'anthropic', '', 'claude-sonnet-4-6', ?)\",\n [new Date().toISOString()]\n );\n }\n } else {\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 } catch { /* non-critical: default LLM config seeded next warm start */ }\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",[],[590],"61716cc0-5f5d-11f1-b593-1607ee4eb77e","router.ts","30479b74-56ca-11f1-a296-ee650bb23af1",1097,["D",1780499009647],129,"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, GOOGLE_DATA_SCOPES, 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 // Per-tenant write: composite PK (tenant_id, key) → conflict target must include tenant_id\n // so tenant B can't overwrite tenant A's row. Do NOT touch tenant_id on update (it's the key).\n await sqlite.execute(\n \"INSERT INTO app_config (key, value, tenant_id) VALUES (?, ?, ?) ON CONFLICT(tenant_id, key) DO UPDATE SET value = excluded.value, 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 await setCompanyProfile(enriched); // AUTO-FILL: persist the analyzed profile so the AI uses it (no manual save)\n return json({ enriched, message: \"AI enrichment complete — your Company Profile was auto-filled from your uploaded docs.\" });\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 = `nexus-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 // SINGLE SOURCE OF TRUTH for Google data scopes (api/integrations/_shared.ts), shared with the\n // identity-login authorize URL so signing in with Google grants the same data integrations.\n const scopes = GOOGLE_DATA_SCOPES.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",[],[598],"d72af100-5f6e-11f1-9a9f-1607ee4eb77e","main.ts",1110,["D",1780506508594],25,"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 ` (header ONLY — a ?token= query string is\n// rejected; FIX 5), 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

History · refs