Phase 0+6+7: Quick Wins, SEO-to-Revenue Pipeline, Self-Optimization

Phase 0: Fix _handleWrite/_handleResearch crash bugs, wire /costs,
/scout, /landing commands, create link-in-bio landing page.

Phase 6: CTA auto-injection in WordPress articles with UTM tracking,
/seo2offer one-command pipeline (scout→offer→article→publish→index),
post-publish offer suggestion.

Phase 7: A/B variant model per offer, /offer ab and /offer variants
commands, smart evaluation (auto-variant at 48h, pause at 72h, scale
winners), click tracking at /api/track, failure pattern learning from
retired offers.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

.claude/claude.md

@@ -8,3 +8,13 @@ Your job is to maintain, expand, and execute the VinOS local stack using Node.js
 2. Use `skills/api_caller.js` for external integrations.
 3. Update `public/index.html` and `public/app.js` when adding new dashboard features.
 4. If a route is missing, add it to `server.js`.
+
+## Deployment Protocol:
+After every commit that completes a phase or significant feature:
+1. **Push to HF Spaces** — `git push hf master:main` (deploys to live `AIgoose/vinos-engine`)
+2. **Send Telegram deploy notification** — Run `node -e "require('./skills/hf_deployer').notifyDeploy()"` after push. This generates AI release notes from the commits and sends a notification to Telegram with what's new.
+3. **Update CHANGELOG.md** — Add a dated entry at the top with: phase name, commit hash, what changed (files created/modified, new commands, new endpoints, new dashboards)
+4. **Verify deployment** — Boot test (`node -e "require('./server.js')"`) or check HF Space logs
+5. Never leave unpushed commits — if code is committed, it should be deployed unless explicitly told otherwise
+
+Alternative: Use `hfDeployer.syncCode()` which handles push + notification together (used by `/sync` Telegram command).

CHANGELOG.md

@@ -2,6 +2,47 @@
 
 ---
 
+## Phase 0 + 6 + 7 — Quick Wins, SEO-to-Revenue, Self-Optimization
+**Date:** 2026-03-27
+
+### Phase 0: Quick Wins + Bug Fix
+- **Fixed `_handleWrite` crash** — Defined missing `_handleWrite()` and `_handleResearch()` functions. The `/write` flow no longer crashes when user replies with context.
+- **`/costs` command** — Shows API spend breakdown by model from `cost_tracker.getCosts()`
+- **`/scout [keyword]` command** — Market viability scout (competition, volume, angles)
+- **`/landing` page** — Public link-in-bio page at `/landing` auto-renders active offers with Mayar CTA buttons
+- **`/landing` command** — Returns the public URL for sharing
+- Telegram menu updated with `/costs`, `/scout`, `/seo2offer`, `/landing`
+
+### Phase 6: SEO-to-Revenue Pipeline
+- **CTA injection in WordPress publisher** — Articles auto-inject a styled CTA block when a matching offer exists, with UTM tracking (`utm_source=seo&utm_medium=article&utm_campaign=...`)
+- **UTM support in `injectOfferLink()`** — Returns `utmUrl` alongside `url` for attribution tracking across SEO articles vs social posts
+- **`/seo2offer [keyword]` command** — One-command full pipeline: scout → create offer → write SEO article (with auto-CTA) → publish to WordPress → Google index
+- **Post-publish offer suggestion** — After successful WP publish, if no matching offer exists, Telegram suggests `/offer [topic]`
+
+### Phase 7: Self-Optimization & A/B Testing
+- **Offer variants model** — Each offer now supports a `variants[]` array with per-variant stats (impressions, clicks, sales, isActive)
+- **`createVariant(offerId)`** — AI generates alternative copy/angle, informed by failure patterns
+- **Smart evaluation** — Replaces binary pause/scale: 48h no sales + <2 variants → auto-create variant; 72h still 0 → pause; 3+ sales/24h → scale winner + pause loser variants
+- **`/offer ab [id]` command** — Create A/B test variant for any offer
+- **`/offer variants [id]` command** — View all variants with conversion rates
+- **Click tracking** — `GET /api/track?offer=X&variant=Y` increments counters and redirects to Mayar
+- **Failure pattern learning** — `analyzeFailurePatterns()` extracts patterns from retired offers via LLM, stores in `failure_patterns`, future offer creation avoids repeating mistakes
+
+#### NEW FILES
+| File | Purpose |
+|------|---------|
+| `public/landing.html` | Link-in-bio page — dark theme, auto-renders active offers from `/api/landing` |
+
+#### MODIFIED FILES
+| File | Changes |
+|------|---------|
+| `server.js` | `_handleWrite()`, `_handleResearch()` functions, `/costs`, `/scout`, `/landing`, `/seo2offer` commands, `/api/track` click tracking, `/api/landing` endpoint, `/offer ab`, `/offer variants` |
+| `skills/sales_engine.js` | `createVariant()`, `getVariants()`, `trackClick()`, `analyzeFailurePatterns()`, smart `evaluateOffers()`, UTM-aware `injectOfferLink()` |
+| `skills/wordpress_publisher.js` | CTA block injection with offer matching before `finalContent` assembly |
+| `skills/set_telegram_menu.js` | Added `/costs`, `/scout`, `/seo2offer`, `/landing` |
+
+---
+
 ## Phase 5 — Autonomous Traffic-to-Sales Engine
 **Date:** 2026-03-27 | **Commit:** `f30cee0`
 

public/landing.html

@@ -0,0 +1,85 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+  <meta charset="UTF-8">
+  <meta name="viewport" content="width=device-width, initial-scale=1.0">
+  <title>VinOS — Digital Products</title>
+  <link rel="preconnect" href="https://fonts.googleapis.com">
+  <link href="https://fonts.googleapis.com/css2?family=Space+Grotesk:wght@300;400;500;600;700&display=swap" rel="stylesheet">
+  <style>
+    *, *::before, *::after { box-sizing: border-box; margin: 0; padding: 0; }
+    :root {
+      --bg: #090c12; --surface: #111622; --surface2: #161e2e; --border: #1e2d45;
+      --accent: #00e5ff; --accent2: #7c3aed; --green: #22d3a0; --orange: #f59e0b;
+      --text: #e2e8f0; --muted: #64748b;
+    }
+    body { font-family: 'Space Grotesk', system-ui, sans-serif; background: var(--bg); color: var(--text); min-height: 100vh; padding: 20px; }
+    .container { max-width: 600px; margin: 0 auto; }
+    .brand { text-align: center; padding: 40px 0 30px; }
+    .brand h1 { font-size: 2rem; font-weight: 700; background: linear-gradient(135deg, var(--accent), var(--green)); -webkit-background-clip: text; -webkit-text-fill-color: transparent; }
+    .brand p { color: var(--muted); margin-top: 8px; font-size: 0.9rem; }
+    .offers-grid { display: flex; flex-direction: column; gap: 16px; margin-bottom: 40px; }
+    .offer-card { background: var(--surface); border: 1px solid var(--border); border-radius: 14px; padding: 24px; transition: transform 0.2s, box-shadow 0.2s; }
+    .offer-card:hover { transform: translateY(-2px); box-shadow: 0 0 30px rgba(0, 229, 255, 0.08); }
+    .offer-card .pillar { color: var(--accent); font-size: 0.7rem; text-transform: uppercase; letter-spacing: 1.5px; font-weight: 600; margin-bottom: 8px; }
+    .offer-card h2 { font-size: 1.2rem; font-weight: 600; margin-bottom: 8px; }
+    .offer-card .desc { color: var(--muted); font-size: 0.85rem; margin-bottom: 16px; line-height: 1.5; }
+    .offer-card .price { font-size: 1.4rem; font-weight: 700; color: var(--green); margin-bottom: 16px; }
+    .offer-card .cta { display: inline-block; padding: 12px 28px; background: linear-gradient(135deg, var(--accent), var(--green)); color: #000; font-weight: 700; font-size: 0.9rem; border-radius: 10px; text-decoration: none; transition: opacity 0.2s; }
+    .offer-card .cta:hover { opacity: 0.9; }
+    .empty { text-align: center; color: var(--muted); padding: 60px 20px; font-style: italic; }
+    .footer { text-align: center; padding: 30px 0; border-top: 1px solid var(--border); }
+    .footer p { color: var(--muted); font-size: 0.75rem; }
+    .footer .links { margin-top: 12px; display: flex; justify-content: center; gap: 16px; }
+    .footer .links a { color: var(--accent); text-decoration: none; font-size: 0.8rem; }
+    .footer .links a:hover { text-decoration: underline; }
+  </style>
+</head>
+<body>
+  <div class="container">
+    <div class="brand">
+      <h1>VinOS</h1>
+      <p>AI-Powered Digital Products</p>
+    </div>
+    <div class="offers-grid" id="offersGrid">
+      <div class="empty">Loading offers...</div>
+    </div>
+    <div class="footer">
+      <p>Powered by VinOS Engine</p>
+    </div>
+  </div>
+  <script>
+    const esc = s => { const d = document.createElement('div'); d.textContent = s; return d.innerHTML; };
+    const fmt = n => `Rp ${(n || 0).toLocaleString('id-ID')}`;
+
+    async function loadOffers() {
+      try {
+        const res = await fetch('/api/landing');
+        const data = await res.json();
+        const grid = document.getElementById('offersGrid');
+
+        if (!data.success || !data.offers || data.offers.length === 0) {
+          grid.innerHTML = '<div class="empty">No offers available right now. Check back soon!</div>';
+          return;
+        }
+
+        let html = '';
+        for (const o of data.offers) {
+          html += `<div class="offer-card">
+            ${o.pillar ? `<div class="pillar">${esc(o.pillar)}</div>` : ''}
+            <h2>${esc(o.title)}</h2>
+            ${o.description ? `<div class="desc">${esc(o.description)}</div>` : ''}
+            <div class="price">${fmt(o.priceIDR)}</div>
+            ${o.paymentUrl ? `<a class="cta" href="${esc(o.paymentUrl)}" target="_blank">Get It Now &rarr;</a>` : '<span class="desc">Coming soon</span>'}
+          </div>`;
+        }
+        grid.innerHTML = html;
+      } catch (e) {
+        document.getElementById('offersGrid').innerHTML = '<div class="empty">Unable to load offers.</div>';
+      }
+    }
+
+    loadOffers();
+  </script>
+</body>
+</html>

server.js

@@ -57,6 +57,8 @@ const analyticsEngine = require('./analytics-engine');
 const viralFlow = require('./skills/viral_flow');
 const salesEngine = require('./skills/sales_engine');
 const mayarClient = require('./skills/mayar_client');
+const costTracker = require('./skills/cost_tracker');
+const scoutAgent = require('./skills/scout_agent');
 
 
 
@@ -80,6 +82,21 @@ app.get('/revenue', (req, res) => {
     res.sendFile(path.join(__dirname, 'public', 'revenue-dashboard.html'));
 });
 
+app.get('/landing', (req, res) => {
+    res.sendFile(path.join(__dirname, 'public', 'landing.html'));
+});
+
+app.get('/api/landing', (req, res) => {
+    try {
+        const dash = salesEngine.getDashboardData();
+        const activeOffers = dash.activeOffers.map(o => ({
+            title: o.title, description: o.description || '',
+            priceIDR: o.priceIDR, paymentUrl: o.paymentUrl, pillar: o.pillar || ''
+        }));
+        res.json({ success: true, offers: activeOffers });
+    } catch (e) { res.json({ success: true, offers: [] }); }
+});
+
 // ============================================
 // SALES ENGINE API
 // ============================================
@@ -136,6 +153,19 @@ app.post('/api/sales/webhook/mayar', async (req, res) => {
     }
 });
 
+// Click tracking redirect (for A/B variant attribution)
+app.get('/api/track', (req, res) => {
+    const { offer, variant, action } = req.query;
+    if (!offer) return res.status(400).json({ error: 'Missing offer param' });
+    const redirectUrl = salesEngine.trackClick(offer, variant || 'v0');
+    if (redirectUrl) {
+        const utm = `${redirectUrl.includes('?') ? '&' : '?'}utm_source=track&utm_medium=cta&utm_campaign=${encodeURIComponent(offer)}`;
+        res.redirect(302, redirectUrl + utm);
+    } else {
+        res.status(404).json({ error: 'Offer not found' });
+    }
+});
+
 // ============================================
 // VIRAL CONTENT ENGINE API
 // ============================================
@@ -1048,6 +1078,131 @@ async function processOrchestratorIntent(chatId, intent, userText, params) {
     }
 }
 
+// --- Helper: handle /write context reply ---
+async function _handleWrite(chatId, pending, userContext) {
+    const { targetSiteId, topic, size, pov, intent, tone } = pending;
+
+    const initRes = await apiCaller.sendTelegramMessage(chatId, `📝 <b>SEO Engine Pipeline</b>\n[■□□□□□] 16% AI Architecting: "${topic}"...`);
+    const msgId = initRes.messageId;
+
+    try {
+        const articleRes = await seoWriter.generateArticle(size, pov, intent, tone, topic, userContext);
+        if (!articleRes.success) {
+            if (msgId) await apiCaller.editTelegramMessage(chatId, msgId, `⚠️ <b>Pipeline Failed</b>\n❌ Writer Error: ${articleRes.error}`);
+            return;
+        }
+
+        if (msgId) await apiCaller.editTelegramMessage(chatId, msgId, `📝 <b>SEO Engine Pipeline</b>\n[■■□□□□] 33% QC: Scoring EEAT Quality...`);
+        const scoreRes = await seoWriter.scoreEEAT(articleRes.html);
+
+        if (msgId) await apiCaller.editTelegramMessage(chatId, msgId, `📝 <b>SEO Engine Pipeline</b>\n[■■■□□□] 50% Image Engine: Generating ${articleRes.imagePlaceholders?.length || 0} AI Images...`);
+
+        if (msgId) await apiCaller.editTelegramMessage(chatId, msgId, `📝 <b>SEO Engine Pipeline</b>\n[■■■■□□] 66% Publishing: Uploading to [${targetSiteId}]...`);
+        const pubRes = await wordpressPublisher.publishPost(articleRes, targetSiteId);
+
+        if (!pubRes.success) {
+            if (msgId) await apiCaller.editTelegramMessage(chatId, msgId, `⚠️ <b>Pipeline Failed</b>\n❌ WordPress Error: ${pubRes.error}`);
+            return;
+        }
+
+        if (msgId) await apiCaller.editTelegramMessage(chatId, msgId, `📝 <b>SEO Engine Pipeline</b>\n[■■■■■□] 83% SEO Indexing: Google Search Console...`);
+        const idxRes = await googleIndexer.submitUrl(pubRes.url);
+
+        if (msgId) await apiCaller.editTelegramMessage(chatId, msgId, `📝 <b>SEO Engine Pipeline</b>\n[■■■■■■] 100% CRM Sync: Trello Workflow...`);
+        const trelloRes = await trelloManager.logSeoPost(topic, targetSiteId || 'Default', pubRes.url, scoreRes.score || 'N/A');
+
+        let finalMsg = `🌟 <b>Pipeline Complete!</b>\n\n`;
+        finalMsg += `<b>🔗 Article:</b> ${pubRes.url}\n`;
+        if (scoreRes.success) finalMsg += `<b>🧠 EEAT Score:</b> ${scoreRes.score}/100\n`;
+        if (idxRes.success) finalMsg += `<b>🔍 Google:</b> Indexed 🟢\n`;
+        else finalMsg += `<b>🔍 Google:</b> Pending 🟡 (${idxRes.error})\n`;
+        if (trelloRes.success) finalMsg += `<b>📊 Trello:</b> <a href="${trelloRes.url}">View Card</a> 📋\n`;
+        else finalMsg += `<b>📊 Trello:</b> Failed 🔴\n`;
+
+        // Check for matching sales offer → suggest creating one if none
+        try {
+            const offerLink = salesEngine.injectOfferLink(topic);
+            if (offerLink) {
+                finalMsg += `\n💰 <b>Offer CTA injected:</b> ${offerLink}\n`;
+            } else {
+                finalMsg += `\n💡 No matching offer for "${topic}". Create one? <code>/offer ${topic}</code>\n`;
+            }
+        } catch (e) { /* non-critical */ }
+
+        await apiCaller.sendTelegramMessage(chatId, finalMsg);
+
+        // Auto-push SEO publish metadata to HF
+        try {
+            await hfStorage.saveRecord('seo', `seo_${Date.now()}`, {
+                title: `SEO: ${topic}`,
+                timestamp: new Date().toISOString(),
+                source_url: pubRes.url,
+                niche: 'SEO'
+            }, `# Published: ${topic}\n\n- URL: ${pubRes.url}\n- Site: ${targetSiteId || 'Default'}\n- EEAT Score: ${scoreRes.score || 'N/A'}\n- Google Indexed: ${idxRes.success}\n- Trello: ${trelloRes.success ? trelloRes.url : 'N/A'}`);
+        } catch (e) {
+            console.error('[HF Auto] SEO log failed:', e.message);
+        }
+    } catch (err) {
+        console.error('[_handleWrite] Error:', err.message);
+        await apiCaller.sendTelegramMessage(chatId, `⚠️ <b>Write Pipeline Error:</b> ${err.message}`);
+    }
+}
+
+// --- Helper: handle /research context reply ---
+async function _handleResearch(chatId, url, angle) {
+    await apiCaller.sendTelegramMessage(chatId, `🔍 <b>Research Auto-Pilot</b>\nAnalyzing URL with focus: <i>${angle || 'General'}</i>...`);
+
+    const researchModule = require('./research');
+    const aiContentMod = require('./ai-content');
+    const imageGenMod = require('./image-gen');
+    const schedulerMod = require('./scheduler');
+
+    try {
+        const scrapeRes = await researchModule.scrapePost(url, angle);
+        if (!scrapeRes.success) {
+            await apiCaller.sendTelegramMessage(chatId, `❌ Scrape failed: ${scrapeRes.error}`);
+            return;
+        }
+
+        await apiCaller.sendTelegramMessage(chatId, `🧠 Scrape successful! Remixing content...`);
+        const remixRes = await aiContentMod.remix(scrapeRes.data);
+        if (!remixRes.success) {
+            await apiCaller.sendTelegramMessage(chatId, `❌ AI Remix failed: ${remixRes.error}`);
+            return;
+        }
+
+        const v1 = remixRes.data.variant_1;
+        await apiCaller.sendTelegramMessage(chatId, `🎨 Generating high-conversion visual...`);
+        const imgRes = await imageGenMod.generateAndUpload(v1.visual_prompt, 'res_v1');
+        if (imgRes.success) v1.mediaUrl = imgRes.publicUrl;
+
+        const draftId = `res_${Date.now().toString().slice(-6)}`;
+        const draftPost = {
+            id: draftId, status: 'draft', created: new Date().toISOString(),
+            input: url, platform: scrapeRes.data.platform || 'web',
+            sourceData: scrapeRes.data, type: 'standard',
+            v1, v2: remixRes.data.variant_2, v3: remixRes.data.variant_3
+        };
+        schedulerMod.config.posts.push(draftPost);
+        schedulerMod.saveDB();
+
+        if (imgRes.success && v1.mediaUrl) {
+            const FormData = require('form-data');
+            const fForm = new FormData();
+            fForm.append('chat_id', chatId);
+            fForm.append('photo', v1.mediaUrl.startsWith('/') ? fs.createReadStream(path.join(__dirname, 'public', v1.mediaUrl)) : v1.mediaUrl);
+            fForm.append('caption', `✅ <b>Research Draft Ready!</b>\n\n${v1.ig_en.substring(0, 800)}...\n\nReview in Dashboard.`);
+            fForm.append('parse_mode', 'HTML');
+            await apiCaller.axiosIPv4.post(`https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/sendPhoto`, fForm, { headers: fForm.getHeaders() });
+        } else {
+            await apiCaller.sendTelegramMessage(chatId, `✅ <b>Research Draft Ready!</b>\n\n${v1.ig_en.substring(0, 800)}...\n\nReview in Dashboard.`);
+        }
+    } catch (err) {
+        console.error('[_handleResearch] Error:', err.message);
+        await apiCaller.sendTelegramMessage(chatId, `⚠️ <b>Research Error:</b> ${err.message}`);
+    }
+}
+
 // Telegram Webhook
 app.post('/api/telegram-webhook', async (req, res) => {
     res.status(200).send({ status: 'received' });
@@ -1727,14 +1882,22 @@ This engine researches any URL or topic and generates content with your options.
                     `📝 <b>SEO ENGINE</b>\n` +
                     `/seo [keyword] — Architect SEO Pillar Strategy\n` +
                     `/write [siteId] [size] [topic] — Publish SEO Article\n` +
+                    `/seo2offer [keyword] — Full pipeline: scout → offer → article → publish → index\n` +
                     `/index [url] — Submit to Google API\n\n` +
                     `💰 <b>SALES ENGINE</b>\n` +
                     `/offer — List active offers with payment links\n` +
                     `/offer [topic] — Create offer (AI copy → Mayar link)\n` +
                     `/offer pause [id] — Pause underperforming offer\n` +
+                    `/offer ab [id] — Create A/B test variant\n` +
+                    `/offer variants [id] — View variant stats\n` +
                     `/offer board — Pipeline stage counts\n` +
+                    `/offer eval — Run offer evaluation\n` +
                     `/revenue — Revenue summary\n` +
                     `/revenue today — Today's sales only\n\n` +
+                    `🔍 <b>RESEARCH</b>\n` +
+                    `/scout [keyword] — Market viability scout\n` +
+                    `/costs — API spend breakdown\n` +
+                    `/landing — Your link-in-bio page\n\n` +
                     `📋 <b>CRM MANAGER</b>\n` +
                     `/updates – View Trello project statuses\n` +
                     `/move [4-char-ID] [new list] – Update card status`;
@@ -1818,6 +1981,65 @@ This engine researches any URL or topic and generates content with your options.
                         await apiCaller.sendTelegramMessage(chatId, `❌ Image generation failed: ${gashResult.error || 'All providers exhausted'}`);
                     }
                 }
+            } else if (userText.toLowerCase().startsWith('/seo2offer')) {
+                const keyword = userText.split(' ').slice(1).join(' ').trim();
+                if (!keyword) {
+                    await apiCaller.sendTelegramMessage(chatId, `❌ Usage: <code>/seo2offer [keyword]</code>\nFull pipeline: scout → offer → article → publish → index`);
+                    return;
+                }
+                await apiCaller.sendTelegramMessage(chatId, `🚀 <b>SEO-to-Revenue Pipeline</b>\n[■□□□□□] Scouting: "${keyword}"...`);
+
+                // 1. Scout market viability
+                let scoutResult;
+                try { scoutResult = await scoutAgent.runScout(keyword); } catch (e) { scoutResult = 'Scout unavailable'; }
+
+                await apiCaller.sendTelegramMessage(chatId, `🚀 <b>SEO-to-Revenue Pipeline</b>\n[■■□□□□] Creating offer + Mayar link...`);
+
+                // 2. Create offer
+                const offerResult = await salesEngine.createOfferFromTopic(keyword, 49000);
+                let offerMsg = '';
+                if (offerResult.success) {
+                    offerMsg = `✅ Offer: ${offerResult.offer.title}\n💳 ${offerResult.offer.paymentUrl || 'Pending'}`;
+                } else {
+                    offerMsg = `⚠️ Offer: ${offerResult.verdict || 'skipped'} (${offerResult.reason || offerResult.error || ''})`;
+                }
+
+                await apiCaller.sendTelegramMessage(chatId, `🚀 <b>SEO-to-Revenue Pipeline</b>\n[■■■□□□] Writing SEO article...`);
+
+                // 3. Write article
+                let sites = {};
+                try { sites = JSON.parse(process.env.WP_SITES_JSON || "{}"); } catch(e){}
+                const siteKeys = Object.keys(sites);
+                const targetSite = siteKeys.length > 0 ? siteKeys[0] : null;
+
+                const articleRes = await seoWriter.generateArticle('medium', '3rd person', 'Educational', 'Authoritative', keyword, '');
+                if (!articleRes.success) {
+                    await apiCaller.sendTelegramMessage(chatId, `⚠️ Article failed: ${articleRes.error}\n\n${offerMsg}\n\n🕵️ <b>Scout:</b>\n${scoutResult}`);
+                    return;
+                }
+
+                await apiCaller.sendTelegramMessage(chatId, `🚀 <b>SEO-to-Revenue Pipeline</b>\n[■■■■□□] Publishing to WordPress (CTA auto-injected)...`);
+
+                // 4. Publish (CTA injection happens inside publisher automatically)
+                const pubRes = await wordpressPublisher.publishPost(articleRes, targetSite);
+                if (!pubRes.success) {
+                    await apiCaller.sendTelegramMessage(chatId, `⚠️ Publish failed: ${pubRes.error}\n\n${offerMsg}\n\n🕵️ <b>Scout:</b>\n${scoutResult}`);
+                    return;
+                }
+
+                await apiCaller.sendTelegramMessage(chatId, `🚀 <b>SEO-to-Revenue Pipeline</b>\n[■■■■■□] Indexing on Google...`);
+
+                // 5. Index
+                const idxRes = await googleIndexer.submitUrl(pubRes.url);
+
+                // 6. Final report
+                let finalMsg = `🎯 <b>SEO-to-Revenue Complete!</b>\n\n`;
+                finalMsg += `🔗 <b>Article:</b> ${pubRes.url}\n`;
+                finalMsg += `🔍 <b>Google:</b> ${idxRes.success ? 'Indexed 🟢' : 'Pending 🟡'}\n`;
+                finalMsg += `${offerMsg}\n\n`;
+                finalMsg += `🕵️ <b>Scout Report:</b>\n${typeof scoutResult === 'string' ? scoutResult.substring(0, 500) : 'N/A'}`;
+                await apiCaller.sendTelegramMessage(chatId, finalMsg);
+
             } else if (userText.toLowerCase().startsWith('/seo')) {
                 const keyword = userText.split(' ').slice(1).join(' ');
                 if (!keyword) {
@@ -2084,6 +2306,27 @@ This engine researches any URL or topic and generates content with your options.
                     const emoji = { active: '🟢', pending_link: '🟡', pending_validation: '🔵', paused: '⏸️', retired: '🔴' };
                     const lines = stages.filter(s => counts[s]).map(s => `${emoji[s] || '•'} ${s}: ${counts[s]}`).join('\n');
                     await apiCaller.sendTelegramMessage(chatId, `📋 <b>Offer Pipeline</b>\n\n${lines || 'No offers yet.'}\n\nTotal: ${db.offers.length}`);
+                } else if (args.toLowerCase().startsWith('ab ')) {
+                    // /offer ab [id] — create A/B variant
+                    const offerId = args.split(' ')[1];
+                    await apiCaller.sendTelegramMessage(chatId, `🧪 <i>Creating variant for ${offerId}...</i>`);
+                    const result = await salesEngine.createVariant(offerId);
+                    if (!result.success) {
+                        await apiCaller.sendTelegramMessage(chatId, `❌ ${result.error}`);
+                    }
+                } else if (args.toLowerCase().startsWith('variants ')) {
+                    // /offer variants [id] — show all variants
+                    const offerId = args.split(' ')[1];
+                    const result = salesEngine.getVariants(offerId);
+                    if (!result.success) {
+                        await apiCaller.sendTelegramMessage(chatId, `❌ ${result.error}`);
+                    } else {
+                        const lines = result.variants.map(v => {
+                            const convRate = v.clicks > 0 ? ((v.sales / v.clicks) * 100).toFixed(1) : '0.0';
+                            return `🔀 <b>${v.id}:</b> ${v.title}\n   📊 ${v.sales} sales | ${v.clicks} clicks | ${convRate}% conv | ${v.isActive ? '🟢 Active' : '🔴 Paused'}`;
+                        }).join('\n\n');
+                        await apiCaller.sendTelegramMessage(chatId, `🧪 <b>Variants: ${result.offerTitle || offerId}</b>\n\n${lines}`);
+                    }
                 } else if (args.toLowerCase().startsWith('eval')) {
                     // /offer eval — run evaluation
                     await apiCaller.sendTelegramMessage(chatId, '📊 <i>Evaluating offers...</i>');
@@ -2136,6 +2379,35 @@ This engine researches any URL or topic and generates content with your options.
                     );
                 }
 
+            } else if (userText.toLowerCase().startsWith('/costs')) {
+                const costs = costTracker.getCosts();
+                let msg = `💸 <b>API Cost Tracker</b>\n\n`;
+                msg += `📊 <b>Total Spend:</b> $${(costs.total || 0).toFixed(4)}\n\n`;
+                const models = Object.entries(costs.by_model || {}).sort((a, b) => b[1] - a[1]);
+                if (models.length > 0) {
+                    msg += `<b>By Model:</b>\n`;
+                    for (const [model, cost] of models) {
+                        msg += `• ${model}: $${cost.toFixed(4)}\n`;
+                    }
+                } else {
+                    msg += `<i>No costs tracked yet.</i>`;
+                }
+                await apiCaller.sendTelegramMessage(chatId, msg);
+
+            } else if (userText.toLowerCase().startsWith('/scout')) {
+                const keyword = userText.split(' ').slice(1).join(' ').trim();
+                if (!keyword) {
+                    await apiCaller.sendTelegramMessage(chatId, `❌ Usage: <code>/scout [keyword]</code>\nExample: /scout AI productivity tools`);
+                    return;
+                }
+                await apiCaller.sendTelegramMessage(chatId, `🔍 <b>Scouting:</b> "${keyword}"...\nAnalyzing competition, volume, and angles...`);
+                const result = await scoutAgent.runScout(keyword);
+                await apiCaller.sendTelegramMessage(chatId, `🕵️ <b>Scout Report: ${keyword}</b>\n\n${result}`);
+
+            } else if (userText.toLowerCase().startsWith('/landing')) {
+                const publicUrl = process.env.PUBLIC_URL || `https://${process.env.SPACE_ID || 'aigoose-vinos-engine'}.hf.space`;
+                await apiCaller.sendTelegramMessage(chatId, `🔗 <b>Your Landing Page:</b>\n${publicUrl}/landing\n\nShare this link as your link-in-bio!`);
+
             } else {
                 await handleVinIntent(chatId, from, userText);
             }

skills/sales_engine.js

@@ -233,53 +233,189 @@ module.exports = {
         return { success: true, transaction: txn, offer };
     },
 
+    async createVariant(offerId) {
+        const db = readSalesDB();
+        const offer = db.offers.find(o => o.id === offerId);
+        if (!offer) return { success: false, error: 'Offer not found' };
+
+        // Initialize variants array if not present (backward compat)
+        if (!offer.variants) {
+            offer.variants = [{
+                id: 'v0', title: offer.title, description: offer.description,
+                priceIDR: offer.priceIDR, benefits: offer.benefits || [],
+                impressions: 0, clicks: 0, sales: offer.totalSales || 0, isActive: true
+            }];
+        }
+
+        const existingStats = offer.variants.map(v =>
+            `Variant ${v.id}: "${v.title}" — ${v.sales} sales, ${v.clicks} clicks`
+        ).join('\n');
+
+        // Load failure patterns for context
+        const mainDb = memory.readDB();
+        const failureHints = (mainDb.failure_patterns || []).slice(0, 3).map(p => `- ${p}`).join('\n');
+
+        const prompt = [
+            { role: 'system', content: 'You are an A/B testing expert for digital products. Create a DIFFERENT angle/hook than existing variants. Output JSON only.' },
+            { role: 'user', content: `Topic: "${offer.topic}"\nPrice: Rp ${offer.priceIDR.toLocaleString()}\n\nExisting variants:\n${existingStats}\n\n${failureHints ? `Known failure patterns to avoid:\n${failureHints}\n\n` : ''}Create variant ${offer.variants.length} with a different angle, hook, or value proposition.\nJSON: { "title": string, "description": string, "benefits": [string, string, string] }` }
+        ];
+
+        const aiResult = await apiCaller.callOpenRouter(prompt);
+        let variantData = { title: `${offer.topic} (V${offer.variants.length})`, description: offer.description, benefits: [] };
+        if (aiResult.success) {
+            try {
+                const parsed = JSON.parse(aiResult.data.replace(/```json?\n?|```/g, '').trim());
+                variantData = { ...variantData, ...parsed };
+            } catch (e) { /* use default */ }
+        }
+
+        const variant = {
+            id: `v${offer.variants.length}`,
+            title: variantData.title,
+            description: variantData.description,
+            priceIDR: offer.priceIDR,
+            benefits: variantData.benefits || [],
+            impressions: 0, clicks: 0, sales: 0, isActive: true
+        };
+        offer.variants.push(variant);
+        writeSalesDB(db);
+
+        await apiCaller.sendTelegramMessage(process.env.TELEGRAM_CHAT_ID,
+            `🧪 <b>New Variant Created!</b>\n\n` +
+            `📦 Offer: ${offer.title}\n` +
+            `🔀 Variant ${variant.id}: "${variant.title}"\n` +
+            `📝 ${variant.description}\n\n` +
+            `Total variants: ${offer.variants.length}`
+        );
+
+        return { success: true, variant, offer };
+    },
+
+    getVariants(offerId) {
+        const db = readSalesDB();
+        const offer = db.offers.find(o => o.id === offerId);
+        if (!offer) return { success: false, error: 'Offer not found' };
+        if (!offer.variants || offer.variants.length === 0) {
+            return { success: true, variants: [{ id: 'v0', title: offer.title, sales: offer.totalSales, clicks: 0, impressions: 0, isActive: true }] };
+        }
+        return { success: true, variants: offer.variants, offerTitle: offer.title };
+    },
+
+    trackClick(offerId, variantId) {
+        const db = readSalesDB();
+        const offer = db.offers.find(o => o.id === offerId);
+        if (!offer) return null;
+        if (offer.variants) {
+            const variant = offer.variants.find(v => v.id === variantId);
+            if (variant) { variant.clicks = (variant.clicks || 0) + 1; variant.impressions = (variant.impressions || 0) + 1; }
+        }
+        writeSalesDB(db);
+        return offer.paymentUrl;
+    },
+
+    async analyzeFailurePatterns() {
+        const db = readSalesDB();
+        const retired = db.offers.filter(o => o.status === 'retired' || o.status === 'paused');
+        if (retired.length < 3) return { success: false, reason: 'Need at least 3 retired/paused offers to analyze' };
+
+        const retiredSummary = retired.map(o =>
+            `- "${o.title}" (${o.topic}): ${o.totalSales} sales, Rp ${o.priceIDR}, pillar: ${o.sourcePillar || 'general'}, trend: ${o.trendScore || 'N/A'}`
+        ).join('\n');
+
+        const prompt = [
+            { role: 'system', content: 'You are a sales strategist analyzing failed digital product offers. Extract 3-5 actionable patterns. Be specific about what to avoid. Output as a JSON array of strings.' },
+            { role: 'user', content: `Retired/paused offers:\n${retiredSummary}\n\nExtract failure patterns as JSON array: ["pattern 1", "pattern 2", ...]` }
+        ];
+
+        const aiResult = await apiCaller.callOpenRouter(prompt);
+        let patterns = [];
+        if (aiResult.success) {
+            try {
+                patterns = JSON.parse(aiResult.data.replace(/```json?\n?|```/g, '').trim());
+            } catch (e) { patterns = [aiResult.data.substring(0, 200)]; }
+        }
+
+        const mainDb = memory.readDB();
+        mainDb.failure_patterns = patterns;
+        memory.writeDB(mainDb);
+
+        return { success: true, patterns };
+    },
+
     async evaluateOffers() {
         const db = readSalesDB();
         const now = Date.now();
         let actions = [];
 
         for (const offer of db.offers) {
-            if (offer.status !== 'active') continue;
+            if (offer.status !== 'active') {
+                // Re-check pending_validation offers
+                if (offer.status === 'pending_validation' && offer.nextCheck && new Date(offer.nextCheck) <= new Date()) {
+                    try {
+                        const trendValidator = require('./trend_validator');
+                        const recheck = await trendValidator.validateTopic(offer.topic);
+                        if (recheck.verdict === 'go') {
+                            offer.status = 'retired';
+                            await this.createOfferFromTopic(offer.topic, offer.priceIDR, offer.sourcePostIds[0], offer.sourcePillar);
+                            actions.push({ offerId: offer.id, action: 'promoted_from_wait' });
+                        } else if (recheck.verdict === 'skip') {
+                            offer.status = 'retired';
+                            actions.push({ offerId: offer.id, action: 'retired_after_recheck' });
+                        } else {
+                            offer.nextCheck = new Date(Date.now() + 48 * 3600000).toISOString();
+                        }
+                    } catch (e) { /* skip recheck on error */ }
+                }
+                continue;
+            }
 
             const ageHours = (now - new Date(offer.created).getTime()) / 3600000;
             const salesLast24h = db.transactions.filter(t =>
                 t.offerId === offer.id && (now - new Date(t.ts).getTime()) < 86400000
             ).length;
 
+            const variantCount = (offer.variants || []).length;
+
             if (salesLast24h >= 3) {
                 // Winner! Scale it
                 actions.push({ offerId: offer.id, action: 'scale', salesLast24h });
                 await this.scaleWinner(offer.id);
+
+                // If variants exist, pause losers
+                if (offer.variants && offer.variants.length > 1) {
+                    const sorted = [...offer.variants].sort((a, b) => (b.sales || 0) - (a.sales || 0));
+                    for (let i = 1; i < sorted.length; i++) {
+                        sorted[i].isActive = false;
+                    }
+                    actions.push({ offerId: offer.id, action: 'variant_loser_paused', winner: sorted[0].id });
+                }
+
+            } else if (ageHours >= 48 && offer.totalSales === 0 && variantCount < 2) {
+                // Stale 48h, no sales, < 2 variants → auto-create variant instead of waiting
+                try {
+                    await this.createVariant(offer.id);
+                    actions.push({ offerId: offer.id, action: 'auto_variant_created', reason: 'no_sales_48h' });
+                } catch (e) {
+                    actions.push({ offerId: offer.id, action: 'variant_create_failed', error: e.message });
+                }
+
             } else if (ageHours >= 72 && offer.totalSales === 0) {
-                // No sales in 72h → pause
+                // 72h, still 0 sales even with variants → pause
                 offer.status = 'paused';
                 actions.push({ offerId: offer.id, action: 'pause', reason: 'no_sales_72h' });
             }
-
-            // Re-check pending_validation offers
-            if (offer.status === 'pending_validation' && offer.nextCheck && new Date(offer.nextCheck) <= new Date()) {
-                try {
-                    const trendValidator = require('./trend_validator');
-                    const recheck = await trendValidator.validateTopic(offer.topic);
-                    if (recheck.verdict === 'go') {
-                        // Promote to active offer creation
-                        offer.status = 'retired'; // retire the pending one
-                        await this.createOfferFromTopic(offer.topic, offer.priceIDR, offer.sourcePostIds[0], offer.sourcePillar);
-                        actions.push({ offerId: offer.id, action: 'promoted_from_wait' });
-                    } else if (recheck.verdict === 'skip') {
-                        offer.status = 'retired';
-                        actions.push({ offerId: offer.id, action: 'retired_after_recheck' });
-                    } else {
-                        offer.nextCheck = new Date(Date.now() + 48 * 3600000).toISOString();
-                    }
-                } catch (e) { /* skip recheck on error */ }
-            }
         }
 
         writeSalesDB(db);
 
+        // Analyze failure patterns if enough retired offers
+        const retiredCount = db.offers.filter(o => o.status === 'retired' || o.status === 'paused').length;
+        if (retiredCount >= 3) {
+            try { await this.analyzeFailurePatterns(); } catch (e) { /* non-critical */ }
+        }
+
         if (actions.length > 0) {
-            const summary = actions.map(a => `• ${a.offerId}: ${a.action}`).join('\n');
+            const summary = actions.map(a => `• ${a.offerId}: ${a.action}${a.reason ? ` (${a.reason})` : ''}`).join('\n');
             await apiCaller.sendTelegramMessage(process.env.TELEGRAM_CHAT_ID,
                 `📋 <b>Offer Evaluation Complete</b>\n\n${summary}`
             );
@@ -389,12 +525,19 @@ module.exports = {
         };
     },
 
-    injectOfferLink(topic) {
+    injectOfferLink(topic, source = 'social') {
         const db = readSalesDB();
+        const topicLower = topic.toLowerCase();
         const matching = db.offers
             .filter(o => o.status === 'active' && o.paymentUrl)
-            .find(o => topic.toLowerCase().includes(o.topic.toLowerCase().split(' ')[0]) ||
-                       o.topic.toLowerCase().includes(topic.toLowerCase().split(' ')[0]));
-        return matching ? { url: matching.paymentUrl, title: matching.title, priceIDR: matching.priceIDR } : null;
+            .find(o => {
+                const offerWords = o.topic.toLowerCase().split(/\s+/);
+                const topicWords = topicLower.split(/\s+/);
+                return offerWords.some(w => w.length > 3 && topicLower.includes(w)) ||
+                       topicWords.some(w => w.length > 3 && o.topic.toLowerCase().includes(w));
+            });
+        if (!matching) return null;
+        const utm = `?utm_source=${source}&utm_medium=${source === 'seo' ? 'article' : 'post'}&utm_campaign=${encodeURIComponent(topic.replace(/\s+/g, '-').toLowerCase())}`;
+        return { url: matching.paymentUrl, utmUrl: matching.paymentUrl + utm, title: matching.title, priceIDR: matching.priceIDR, offerId: matching.id };
     }
 };

skills/set_telegram_menu.js

@@ -36,7 +36,11 @@ const setCommands = async () => {
         { command: 'pulseconfig', description: '⚙️ Configure Daily Pulse (v2.0)' },
         { command: 'viral', description: '🦠 Viral Content Engine (v1.0)' },
         { command: 'offer', description: '💰 Sales Offers (create/list/pause)' },
-        { command: 'revenue', description: '📊 Revenue Dashboard & Summary' }
+        { command: 'revenue', description: '📊 Revenue Dashboard & Summary' },
+        { command: 'costs', description: '💸 API Spend Breakdown' },
+        { command: 'scout', description: '🔍 Market Viability Scout' },
+        { command: 'seo2offer', description: '🎯 Full SEO-to-Revenue Pipeline' },
+        { command: 'landing', description: '🔗 Link-in-Bio Page' }
     ];
 
     try {

skills/wordpress_publisher.js

@@ -66,7 +66,25 @@ class WordPressPublisher {
         // Also handle any leftover Pollinations <img> tags (from older articles)
         htmlWithMedia = htmlWithMedia.replace(/<img[^>]+src="https:\/\/image\.pollinations\.ai[^"]*"[^>]*>/g, '');
 
-        const finalContent = `${htmlWithMedia}\n\n<!-- SEO Schema (Generated by VinOS) -->\n${articleData.schema}`;
+        // CTA injection — match active sales offer to article keyword
+        let ctaBlock = '';
+        try {
+            const salesEngine = require('./sales_engine');
+            const keyword = articleData.meta?.keyword || articleData.meta?.title || '';
+            const offerMatch = salesEngine.injectOfferLink(keyword, 'seo');
+            if (offerMatch) {
+                ctaBlock = `\n<div class="vinos-cta" style="margin:32px 0;padding:24px;background:#f8f9fa;border-left:4px solid #22d3a0;border-radius:8px;">` +
+                    `<h3 style="margin:0 0 8px;font-size:1.2rem;">${offerMatch.title}</h3>` +
+                    `<p style="margin:0 0 12px;color:#666;">Rp ${(offerMatch.priceIDR || 0).toLocaleString('id-ID')}</p>` +
+                    `<a href="${offerMatch.utmUrl}" target="_blank" rel="noopener" style="display:inline-block;padding:10px 24px;background:#22d3a0;color:#fff;text-decoration:none;border-radius:6px;font-weight:bold;">Get It Now &rarr;</a>` +
+                    `</div>`;
+                console.log(`[WP Publisher] CTA injected for offer: ${offerMatch.title}`);
+            }
+        } catch (e) {
+            console.error('[WP Publisher] CTA injection skipped:', e.message);
+        }
+
+        const finalContent = `${htmlWithMedia}${ctaBlock}\n\n<!-- SEO Schema (Generated by VinOS) -->\n${articleData.schema}`;
 
         // Handle Tags
         let tagIds = [];