Spaces:

AIgoose
/

vinos-engine

Running

VinOS Agent Claude Opus 4.6 commited on Mar 27

Commit

1d15a1f

1 Parent(s): 6144942

Phase 8: Video Engine (Remotion Studio HF Space + /videos command)

Separate Remotion-powered HF Space (AIgoose/remotion-studio) with 4 video
templates, Express API, and web UI. VinOS integration via video_engine.js
skill, /videos Telegram command, sendTelegramVideo, proxy dashboard routes.

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

Files changed (7) hide show

CHANGELOG.md +22 -0
database/video_db.json +1 -0
public/videos-dashboard.html +212 -0
server.js +51 -0
skills/api_caller.js +22 -0
skills/set_telegram_menu.js +2 -1
skills/video_engine.js +356 -0

CHANGELOG.md CHANGED Viewed

@@ -2,6 +2,28 @@
 ---
 ## Phase 0 + 6 + 7 — Quick Wins, SEO-to-Revenue, Self-Optimization
 **Date:** 2026-03-27

 ---
+## Phase 8 — Video Engine (Remotion Studio + /videos command)
+**Date:** 2026-03-27
+### New HF Space: `AIgoose/remotion-studio`
+- Separate Remotion-powered video rendering API + web UI
+- 4 video templates: TextExplainer (16:9), ProductPromo (16:9), SocialShort (9:16), SeoSummary (16:9)
+- Docker: Node 20 + Chromium + pre-bundled compositions
+- REST API: `/api/render`, `/api/jobs`, `/api/download/:id`, `/api/templates`
+- Async render queue with progress tracking + 24h auto-cleanup
+- Dark theme web UI with template gallery, create form, job queue, video player
+### VinOS Integration
+- **New files:** `skills/video_engine.js`, `public/videos-dashboard.html`, `database/video_db.json`
+- **Modified:** `server.js`, `skills/api_caller.js`, `skills/set_telegram_menu.js`, `.env`
+- **New Telegram command:** `/videos` with sub-commands: `create`, `templates`, `status`
+- **New API method:** `sendTelegramVideo` in api_caller.js (50MB limit)
+- **Proxy routes:** `/videos-dashboard`, `/api/videos/templates`, `/api/videos/create`, `/api/videos/jobs`, `/api/videos/download/:id`
+- **Pipeline:** Topic → AI script generation → Remotion render → poll completion → send video to Telegram
+- Updated `/start` message with Video Engine section
+---
 ## Phase 0 + 6 + 7 — Quick Wins, SEO-to-Revenue, Self-Optimization
 **Date:** 2026-03-27

database/video_db.json ADDED Viewed

	@@ -0,0 +1 @@


1	+ {"jobs":[],"stats":{"totalRendered":0,"totalFailed":0}}

public/videos-dashboard.html ADDED Viewed

	@@ -0,0 +1,212 @@

+<!DOCTYPE html>
+<html lang="en">
+<head>
+  <meta charset="UTF-8">
+  <meta name="viewport" content="width=device-width, initial-scale=1.0">
+  <title>VinOS — Video Engine</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; --red: #ef4444;
+      --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: 800px; margin: 0 auto; }
+    .header { display: flex; justify-content: space-between; align-items: center; margin-bottom: 24px; }
+    .header h1 { font-size: 1.6rem; font-weight: 700; background: linear-gradient(135deg, var(--accent), var(--green)); -webkit-background-clip: text; -webkit-text-fill-color: transparent; }
+    .header .back { color: var(--accent); text-decoration: none; font-size: 0.85rem; }
+    .header .back:hover { text-decoration: underline; }
+    .stats-row { display: flex; gap: 12px; margin-bottom: 24px; }
+    .stat-card { flex: 1; background: var(--surface); border: 1px solid var(--border); border-radius: 12px; padding: 16px; text-align: center; }
+    .stat-card .val { font-size: 1.5rem; font-weight: 700; color: var(--accent); }
+    .stat-card .label { font-size: 0.7rem; color: var(--muted); margin-top: 4px; }
+    .section-title { font-size: 1rem; font-weight: 600; margin-bottom: 14px; color: var(--muted); }
+    /* Template Cards */
+    .templates { display: grid; grid-template-columns: repeat(2, 1fr); gap: 12px; margin-bottom: 28px; }
+    .tmpl { background: var(--surface); border: 1px solid var(--border); border-radius: 12px; padding: 18px; cursor: pointer; transition: all 0.2s; }
+    .tmpl:hover, .tmpl.selected { border-color: var(--accent); box-shadow: 0 0 20px rgba(0,229,255,0.06); }
+    .tmpl.selected { background: var(--surface2); }
+    .tmpl .ratio { display: inline-block; font-size: 0.6rem; padding: 2px 8px; border-radius: 6px; background: var(--accent)20; color: var(--accent); font-weight: 600; margin-bottom: 6px; }
+    .tmpl h3 { font-size: 0.95rem; font-weight: 600; margin-bottom: 4px; }
+    .tmpl p { font-size: 0.75rem; color: var(--muted); line-height: 1.4; }
+    /* Create Form */
+    .create-form { background: var(--surface); border: 1px solid var(--border); border-radius: 14px; padding: 24px; margin-bottom: 28px; display: none; }
+    .create-form.visible { display: block; }
+    .form-group { margin-bottom: 14px; }
+    .form-group label { display: block; font-size: 0.8rem; color: var(--muted); margin-bottom: 4px; }
+    .form-group input, .form-group textarea {
+      width: 100%; padding: 10px 14px; background: var(--bg); border: 1px solid var(--border);
+      border-radius: 8px; color: var(--text); font-family: inherit; font-size: 0.85rem; outline: none;
+    }
+    .form-group input:focus, .form-group textarea:focus { border-color: var(--accent); }
+    .form-group textarea { min-height: 70px; resize: vertical; }
+    .btn { padding: 10px 24px; border: none; border-radius: 8px; font-family: inherit; font-weight: 700; cursor: pointer; transition: all 0.2s; font-size: 0.85rem; }
+    .btn-primary { background: linear-gradient(135deg, var(--accent), var(--green)); color: #000; }
+    .btn-primary:hover { opacity: 0.9; }
+    .btn-primary:disabled { opacity: 0.4; cursor: not-allowed; }
+    .btn-sm { padding: 6px 14px; font-size: 0.75rem; border-radius: 6px; }
+    .btn-ghost { background: transparent; border: 1px solid var(--border); color: var(--text); }
+    /* Jobs */
+    .job { background: var(--surface); border: 1px solid var(--border); border-radius: 12px; padding: 16px; margin-bottom: 10px; }
+    .job-row { display: flex; justify-content: space-between; align-items: center; }
+    .job-id { font-size: 0.7rem; color: var(--muted); font-family: monospace; }
+    .badge { font-size: 0.65rem; padding: 3px 10px; border-radius: 6px; font-weight: 600; text-transform: uppercase; }
+    .badge-queued { background: var(--orange)20; color: var(--orange); }
+    .badge-rendering { background: var(--accent)20; color: var(--accent); }
+    .badge-complete { background: var(--green)20; color: var(--green); }
+    .badge-failed { background: var(--red)20; color: var(--red); }
+    .badge-expired { background: var(--muted)20; color: var(--muted); }
+    .progress { height: 3px; background: var(--border); border-radius: 2px; margin-top: 8px; overflow: hidden; }
+    .progress-fill { height: 100%; background: linear-gradient(90deg, var(--accent), var(--green)); transition: width 0.3s; }
+    .job-actions { display: flex; gap: 6px; margin-top: 8px; }
+    .empty { text-align: center; color: var(--muted); padding: 30px; font-style: italic; font-size: 0.85rem; }
+    /* Player */
+    .modal { display: none; position: fixed; inset: 0; background: rgba(0,0,0,0.85); z-index: 100; justify-content: center; align-items: center; }
+    .modal.visible { display: flex; }
+    .modal video { max-width: 90vw; max-height: 80vh; border-radius: 10px; }
+    .modal-close { position: absolute; top: 16px; right: 24px; font-size: 2rem; color: #fff; cursor: pointer; }
+    @media (max-width: 640px) { .templates { grid-template-columns: 1fr; } .stats-row { flex-wrap: wrap; } .stat-card { min-width: 45%; } }
+  </style>
+</head>
+<body>
+  <div class="container">
+    <div class="header">
+      <h1>Video Engine</h1>
+      <a class="back" href="/">Dashboard</a>
+    </div>
+    <div class="stats-row">
+      <div class="stat-card"><div class="val" id="sTotal">0</div><div class="label">Rendered</div></div>
+      <div class="stat-card"><div class="val" id="sActive">0</div><div class="label">Active</div></div>
+      <div class="stat-card"><div class="val" id="sTemplates">4</div><div class="label">Templates</div></div>
+    </div>
+    <div class="section-title">Choose Template</div>
+    <div class="templates" id="tmplGrid"></div>
+    <div class="create-form" id="createForm">
+      <div class="form-group">
+        <label>Topic *</label>
+        <input type="text" id="inTopic" placeholder="AI Productivity Tips for Founders">
+      </div>
+      <div class="form-group">
+        <label>Duration (seconds)</label>
+        <input type="range" id="inDuration" min="10" max="60" value="30" oninput="document.getElementById('durVal').textContent=this.value+'s'">
+        <span style="font-size:0.75rem;color:var(--muted)" id="durVal">30s</span>
+      </div>
+      <button class="btn btn-primary" id="btnCreate" onclick="createVideo()">Generate Video</button>
+    </div>
+    <div class="section-title">Recent Jobs</div>
+    <div id="jobsList"><div class="empty">No jobs yet</div></div>
+  </div>
+  <div class="modal" id="playerModal">
+    <div class="modal-close" onclick="closePlayer()">&times;</div>
+    <video id="playerVid" controls></video>
+  </div>
+  <script>
+    const esc = s => { const d = document.createElement('div'); d.textContent = s; return d.innerHTML; };
+    let templates = [], selectedKey = null, pollId = null;
+    async function loadTemplates() {
+      try {
+        const r = await fetch('/api/videos/templates');
+        const d = await r.json();
+        templates = d.templates || [];
+        document.getElementById('tmplGrid').innerHTML = templates.map(t => `
+          <div class="tmpl" data-key="${t.key}" onclick="selectTmpl('${t.key}')">
+            <div class="ratio">${esc(t.ratio)}</div>
+            <h3>${esc(t.name)}</h3>
+            <p>${esc(t.description)}</p>
+          </div>
+        `).join('');
+      } catch (e) {
+        document.getElementById('tmplGrid').innerHTML = '<div class="empty">Remotion Studio offline</div>';
+      }
+    }
+    function selectTmpl(key) {
+      selectedKey = key;
+      document.querySelectorAll('.tmpl').forEach(c => c.classList.remove('selected'));
+      document.querySelector(`.tmpl[data-key="${key}"]`)?.classList.add('selected');
+      document.getElementById('createForm').classList.add('visible');
+    }
+    async function createVideo() {
+      const topic = document.getElementById('inTopic').value.trim();
+      if (!topic || !selectedKey) return alert('Enter a topic and select a template');
+      const btn = document.getElementById('btnCreate');
+      btn.disabled = true; btn.textContent = 'Submitting...';
+      try {
+        const r = await fetch('/api/videos/create', {
+          method: 'POST',
+          headers: { 'Content-Type': 'application/json' },
+          body: JSON.stringify({ topic, template: selectedKey, duration: +document.getElementById('inDuration').value })
+        });
+        const d = await r.json();
+        if (d.success) { loadJobs(); startPoll(); }
+        else alert(d.error || 'Failed');
+      } catch (e) { alert(e.message); }
+      btn.disabled = false; btn.textContent = 'Generate Video';
+    }
+    async function loadJobs() {
+      try {
+        const r = await fetch('/api/videos/jobs?limit=15');
+        const d = await r.json();
+        const jobs = d.jobs || [];
+        document.getElementById('sTotal').textContent = jobs.filter(j => j.status === 'complete').length;
+        document.getElementById('sActive').textContent = jobs.filter(j => j.status === 'rendering' || j.status === 'queued').length;
+        if (!jobs.length) { document.getElementById('jobsList').innerHTML = '<div class="empty">No jobs yet</div>'; return; }
+        document.getElementById('jobsList').innerHTML = jobs.map(j => `
+          <div class="job">
+            <div class="job-row">
+              <span class="job-id">${j.id}</span>
+              <span class="badge badge-${j.status}">${j.status}</span>
+            </div>
+            <div style="font-size:0.85rem;margin-top:4px;">${esc(j.template)}</div>
+            <div style="font-size:0.7rem;color:var(--muted);">${new Date(j.created).toLocaleString()}</div>
+            ${j.status === 'rendering' ? `<div class="progress"><div class="progress-fill" style="width:${j.progress||0}%"></div></div>` : ''}
+            ${j.error ? `<div style="color:var(--red);font-size:0.75rem;margin-top:4px;">${esc(j.error)}</div>` : ''}
+            <div class="job-actions">
+              ${j.status === 'complete' ? `<button class="btn btn-sm btn-primary" onclick="playVid('${j.id}')">Play</button><a href="/api/videos/download/${j.id}" class="btn btn-sm btn-ghost" download>Download</a>` : ''}
+            </div>
+          </div>
+        `).join('');
+        const hasActive = jobs.some(j => j.status === 'queued' || j.status === 'rendering');
+        if (!hasActive) stopPoll();
+      } catch (e) { /* */ }
+    }
+    function startPoll() { if (!pollId) pollId = setInterval(loadJobs, 3000); }
+    function stopPoll() { if (pollId) { clearInterval(pollId); pollId = null; } }
+    function playVid(id) {
+      const v = document.getElementById('playerVid');
+      v.src = `/api/videos/download/${id}`;
+      document.getElementById('playerModal').classList.add('visible');
+      v.play();
+    }
+    function closePlayer() {
+      const v = document.getElementById('playerVid');
+      v.pause(); v.src = '';
+      document.getElementById('playerModal').classList.remove('visible');
+    }
+    loadTemplates();
+    loadJobs();
+  </script>
+</body>
+</html>

server.js CHANGED Viewed

@@ -59,6 +59,7 @@ const salesEngine = require('./skills/sales_engine');
 const mayarClient = require('./skills/mayar_client');
 const costTracker = require('./skills/cost_tracker');
 const scoutAgent = require('./skills/scout_agent');
@@ -97,6 +98,47 @@ app.get('/api/landing', (req, res) => {
     } catch (e) { res.json({ success: true, offers: [] }); }
 });
 // ============================================
 // SALES ENGINE API
 // ============================================
@@ -1342,6 +1384,11 @@ app.post('/api/telegram-webhook', async (req, res) => {
         // --- Commands ---
         if (userText && userText.toLowerCase().startsWith('/viral')) {
             await viralFlow.start(chatId, userText);
             return;
@@ -1894,6 +1941,10 @@ This engine researches any URL or topic and generates content with your options.
                     `/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` +

 const mayarClient = require('./skills/mayar_client');
 const costTracker = require('./skills/cost_tracker');
 const scoutAgent = require('./skills/scout_agent');
+const videoEngine = require('./skills/video_engine');
     } catch (e) { res.json({ success: true, offers: [] }); }
 });
+// ============================================
+// VIDEO ENGINE API (proxy to Remotion Studio)
+// ============================================
+app.get('/videos-dashboard', (req, res) => {
+    res.sendFile(path.join(__dirname, 'public', 'videos-dashboard.html'));
+});
+app.get('/api/videos/templates', async (req, res) => {
+    try {
+        const r = await apiCaller.axiosIPv4.get(`${process.env.REMOTION_URL || 'https://AIgoose-remotion-studio.hf.space'}/api/templates`, { timeout: 10000 });
+        res.json(r.data);
+    } catch (e) { res.json({ templates: [] }); }
+});
+app.post('/api/videos/create', async (req, res) => {
+    try {
+        const { topic, template, duration } = req.body;
+        // Generate script via video engine then submit
+        const chatId = 'web';
+        await videoEngine.createVideo(chatId, topic || 'AI Technology', template || 'text-explainer');
+        res.json({ success: true, message: 'Video queued. Check the job queue.' });
+    } catch (e) { res.json({ success: false, error: e.message }); }
+});
+app.get('/api/videos/jobs', async (req, res) => {
+    try {
+        const r = await apiCaller.axiosIPv4.get(`${process.env.REMOTION_URL || 'https://AIgoose-remotion-studio.hf.space'}/api/jobs?limit=${req.query.limit || 20}`, { timeout: 10000 });
+        res.json(r.data);
+    } catch (e) { res.json({ jobs: [] }); }
+});
+app.get('/api/videos/download/:id', async (req, res) => {
+    try {
+        const remotionUrl = process.env.REMOTION_URL || 'https://AIgoose-remotion-studio.hf.space';
+        const r = await apiCaller.axiosIPv4.get(`${remotionUrl}/api/download/${req.params.id}`, { responseType: 'stream', timeout: 60000 });
+        res.set('Content-Type', 'video/mp4');
+        res.set('Content-Disposition', `attachment; filename="${req.params.id}.mp4"`);
+        r.data.pipe(res);
+    } catch (e) { res.status(404).json({ error: 'Video not available' }); }
+});
 // ============================================
 // SALES ENGINE API
 // ============================================
         // --- Commands ---
+        if (userText && userText.toLowerCase().startsWith('/videos')) {
+            await videoEngine.start(chatId, userText);
+            return;
+        }
         if (userText && userText.toLowerCase().startsWith('/viral')) {
             await viralFlow.start(chatId, userText);
             return;
                     `/offer eval — Run offer evaluation\n` +
                     `/revenue — Revenue summary\n` +
                     `/revenue today — Today's sales only\n\n` +
+                    `🎬 <b>VIDEO ENGINE</b>\n` +
+                    `/videos create [topic] — AI-generate + render video\n` +
+                    `/videos templates — List video templates\n` +
+                    `/videos status — Render queue status\n\n` +
                     `🔍 <b>RESEARCH</b>\n` +
                     `/scout [keyword] — Market viability scout\n` +
                     `/costs — API spend breakdown\n` +

skills/api_caller.js CHANGED Viewed

@@ -544,4 +544,26 @@ module.exports = {
             return { success: false, error: error.message };
         }
     },
 };

             return { success: false, error: error.message };
         }
     },
+    // Telegram (Send Video)
+    sendTelegramVideo: async (chatId, filePath, caption = "") => {
+        const formData = new FormData();
+        formData.append('chat_id', chatId);
+        formData.append('video', fs.createReadStream(filePath));
+        formData.append('caption', caption);
+        formData.append('parse_mode', 'HTML');
+        console.log(`[Telegram] Sending video to ${chatId}: ${path.basename(filePath)}`);
+        try {
+            const response = await axiosIPv4.post(`https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/sendVideo`, formData, {
+                headers: formData.getHeaders(),
+                maxContentLength: 50 * 1024 * 1024,
+                maxBodyLength: 50 * 1024 * 1024,
+            });
+            return { success: true, data: response.data };
+        } catch (error) {
+            console.error("[Telegram] API Video Error:", error.response?.data || error.message);
+            return { success: false, error: error.message };
+        }
+    },
 };

skills/set_telegram_menu.js CHANGED Viewed

@@ -40,7 +40,8 @@ const setCommands = async () => {
         { 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 {

         { 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' },
+        { command: 'videos', description: '🎬 AI Video Generator' }
     ];
     try {

skills/video_engine.js ADDED Viewed

	@@ -0,0 +1,356 @@

+const fs = require('fs');
+const path = require('path');
+const apiCaller = require('./api_caller');
+const memory = require('./memory');
+const REMOTION_URL = process.env.REMOTION_URL || 'https://AIgoose-remotion-studio.hf.space';
+const REMOTION_KEY = process.env.REMOTION_API_KEY || '';
+const DB_PATH = path.join(__dirname, '../database/video_db.json');
+const TMP_DIR = path.join(__dirname, '../public/tmp/videos');
+// Ensure dirs exist
+if (!fs.existsSync(TMP_DIR)) fs.mkdirSync(TMP_DIR, { recursive: true });
+function readDB() {
+    try {
+        if (fs.existsSync(DB_PATH)) return JSON.parse(fs.readFileSync(DB_PATH, 'utf8'));
+    } catch (e) { /* */ }
+    return { jobs: [], stats: { totalRendered: 0, totalFailed: 0 } };
+}
+function writeDB(db) {
+    fs.writeFileSync(DB_PATH, JSON.stringify(db, null, 2));
+}
+function remotionHeaders() {
+    const headers = { 'Content-Type': 'application/json' };
+    if (REMOTION_KEY) headers['Authorization'] = `Bearer ${REMOTION_KEY}`;
+    return headers;
+}
+const TEMPLATE_PROMPTS = {
+    'text-explainer': {
+        system: 'You are a content strategist. Create engaging explainer video content. Output JSON only.',
+        format: '{"title":"string","hook":"string","bullets":["string","string","string"],"cta":"string"}',
+    },
+    'product-promo': {
+        system: 'You are a sales copywriter. Create compelling product promo video content. Output JSON only.',
+        format: '{"productName":"string","price":"string","benefits":["string","string","string"],"cta":"string"}',
+    },
+    'social-short': {
+        system: 'You are a viral content creator for TikTok/Reels. Create scroll-stopping vertical video content. Output JSON only.',
+        format: '{"hook":"string","points":["string","string","string"],"cta":"string"}',
+    },
+    'seo-summary': {
+        system: 'You are an SEO content strategist. Create article summary video content. Output JSON only.',
+        format: '{"articleTitle":"string","keyPoints":["string","string","string"],"source":"VinOS Blog","cta":"Read the full article"}',
+    },
+};
+module.exports = {
+    async start(chatId, userText) {
+        const args = userText.replace(/^\/videos?\s*/i, '').trim();
+        if (!args || args === 'help') {
+            await apiCaller.sendTelegramMessage(chatId,
+                `🎬 <b>Video Engine</b>\n\n` +
+                `<b>Commands:</b>\n` +
+                `<code>/videos create [topic]</code> — AI generates + renders video\n` +
+                `<code>/videos create [topic] --template social-short</code> — specific template\n` +
+                `<code>/videos templates</code> — list available templates\n` +
+                `<code>/videos status</code> — show render queue\n` +
+                `<code>/videos status [id]</code> — check specific job\n\n` +
+                `<b>Templates:</b> text-explainer, product-promo, social-short, seo-summary\n\n` +
+                `🔗 Web UI: ${REMOTION_URL}`
+            );
+            return;
+        }
+        if (args.toLowerCase() === 'templates') {
+            return await this.listTemplates(chatId);
+        }
+        if (args.toLowerCase().startsWith('status')) {
+            const jobId = args.replace(/^status\s*/i, '').trim();
+            return await this.checkStatus(chatId, jobId || null);
+        }
+        if (args.toLowerCase().startsWith('create')) {
+            const createArgs = args.replace(/^create\s*/i, '').trim();
+            let template = 'text-explainer';
+            let topic = createArgs;
+            // Parse --template flag
+            const templateMatch = createArgs.match(/--template\s+(\S+)/i);
+            if (templateMatch) {
+                template = templateMatch[1];
+                topic = createArgs.replace(/--template\s+\S+/i, '').trim();
+            }
+            if (!topic) {
+                await apiCaller.sendTelegramMessage(chatId, '⚠️ Please provide a topic: <code>/videos create AI Productivity Tips</code>');
+                return;
+            }
+            return await this.createVideo(chatId, topic, template);
+        }
+        await apiCaller.sendTelegramMessage(chatId, '❓ Unknown command. Try <code>/videos help</code>');
+    },
+    async listTemplates(chatId) {
+        try {
+            const res = await apiCaller.axiosIPv4.get(`${REMOTION_URL}/api/templates`, {
+                headers: remotionHeaders(),
+                timeout: 10000,
+            });
+            const templates = res.data.templates || [];
+            let msg = '🎬 <b>Video Templates</b>\n\n';
+            for (const t of templates) {
+                msg += `📐 <b>${t.name}</b> [${t.ratio}]\n`;
+                msg += `${t.description}\n`;
+                msg += `Key: <code>${t.key}</code>\n\n`;
+            }
+            msg += `Usage: <code>/videos create [topic] --template [key]</code>`;
+            await apiCaller.sendTelegramMessage(chatId, msg);
+        } catch (e) {
+            await apiCaller.sendTelegramMessage(chatId,
+                `⚠️ Remotion Studio unreachable.\n🔗 ${REMOTION_URL}\nError: ${e.message}`
+            );
+        }
+    },
+    async createVideo(chatId, topic, template = 'text-explainer') {
+        const promptConfig = TEMPLATE_PROMPTS[template];
+        if (!promptConfig) {
+            await apiCaller.sendTelegramMessage(chatId,
+                `⚠️ Unknown template: ${template}\nAvailable: ${Object.keys(TEMPLATE_PROMPTS).join(', ')}`
+            );
+            return;
+        }
+        await apiCaller.sendTelegramMessage(chatId,
+            `🎬 <b>Video Pipeline Started</b>\n\n` +
+            `📋 Topic: ${topic}\n` +
+            `📐 Template: ${template}\n` +
+            `[■□□□□] 20% — Generating AI script...`
+        );
+        // Step 1: Generate script via LLM
+        const prompt = [
+            { role: 'system', content: promptConfig.system },
+            { role: 'user', content: `Topic: "${topic}"\n\nCreate compelling video content for this topic.\nOutput format: ${promptConfig.format}` },
+        ];
+        const aiResult = await apiCaller.callOpenRouter(prompt);
+        let inputProps = {};
+        if (aiResult.success) {
+            try {
+                inputProps = JSON.parse(aiResult.data.replace(/```json?\n?|```/g, '').trim());
+            } catch (e) {
+                await apiCaller.sendTelegramMessage(chatId, '⚠️ AI script generation failed (parse error). Retrying with defaults...');
+                inputProps = this._getDefaultProps(template, topic);
+            }
+        } else {
+            inputProps = this._getDefaultProps(template, topic);
+        }
+        // Add brand color
+        inputProps.brandColor = inputProps.brandColor || '#22d3a0';
+        await apiCaller.sendTelegramMessage(chatId,
+            `[■■□□□] 40% — Script ready. Sending to Remotion Studio...`
+        );
+        // Step 2: Submit render to Remotion Studio
+        try {
+            const res = await apiCaller.axiosIPv4.post(`${REMOTION_URL}/api/render`, {
+                template,
+                inputProps,
+                duration: 30,
+            }, {
+                headers: remotionHeaders(),
+                timeout: 15000,
+            });
+            const { jobId, estimatedTime } = res.data;
+            // Save to local DB
+            const db = readDB();
+            db.jobs.push({
+                id: jobId,
+                chatId: String(chatId),
+                topic,
+                template,
+                inputProps,
+                status: 'rendering',
+                created: new Date().toISOString(),
+            });
+            writeDB(db);
+            await apiCaller.sendTelegramMessage(chatId,
+                `[■■■□□] 60% — Rendering on Remotion Studio...\n\n` +
+                `🆔 Job: <code>${jobId}</code>\n` +
+                `⏱ Estimated: ${estimatedTime}\n\n` +
+                `I'll notify you when it's done!\nCheck progress: <code>/videos status ${jobId}</code>`
+            );
+            // Step 3: Poll for completion
+            this._pollAndDeliver(chatId, jobId);
+        } catch (e) {
+            const errMsg = e.response?.data?.error || e.message;
+            await apiCaller.sendTelegramMessage(chatId,
+                `⚠️ <b>Render submission failed</b>\n${errMsg}\n\n🔗 Try the web UI: ${REMOTION_URL}`
+            );
+        }
+    },
+    async _pollAndDeliver(chatId, jobId) {
+        const maxAttempts = 60; // 60 * 3s = 3 min max
+        let attempts = 0;
+        const poll = async () => {
+            attempts++;
+            if (attempts > maxAttempts) {
+                await apiCaller.sendTelegramMessage(chatId,
+                    `⏰ Render timed out for job <code>${jobId}</code>.\nCheck: ${REMOTION_URL}`
+                );
+                return;
+            }
+            try {
+                const res = await apiCaller.axiosIPv4.get(`${REMOTION_URL}/api/jobs/${jobId}`, {
+                    headers: remotionHeaders(),
+                    timeout: 10000,
+                });
+                const job = res.data;
+                if (job.status === 'complete') {
+                    // Update local DB
+                    const db = readDB();
+                    const local = db.jobs.find(j => j.id === jobId);
+                    if (local) { local.status = 'complete'; local.completed = new Date().toISOString(); }
+                    db.stats.totalRendered++;
+                    writeDB(db);
+                    // Download video
+                    const videoPath = path.join(TMP_DIR, `${jobId}.mp4`);
+                    try {
+                        const dlRes = await apiCaller.axiosIPv4.get(`${REMOTION_URL}/api/download/${jobId}`, {
+                            responseType: 'arraybuffer',
+                            timeout: 60000,
+                        });
+                        fs.writeFileSync(videoPath, Buffer.from(dlRes.data));
+                        // Send to Telegram
+                        await apiCaller.sendTelegramVideo(chatId, videoPath,
+                            `🎬 <b>Video Ready!</b>\n📋 ${job.inputProps?.title || job.inputProps?.hook || 'Video'}\n📐 ${job.template}`
+                        );
+                        // Cleanup local copy after sending
+                        setTimeout(() => {
+                            try { if (fs.existsSync(videoPath)) fs.unlinkSync(videoPath); } catch (e) { /* */ }
+                        }, 60000);
+                    } catch (dlErr) {
+                        await apiCaller.sendTelegramMessage(chatId,
+                            `✅ <b>Video rendered!</b>\n\n` +
+                            `🔗 Download: ${REMOTION_URL}/api/download/${jobId}\n` +
+                            `(Direct send failed: ${dlErr.message})`
+                        );
+                    }
+                    return;
+                }
+                if (job.status === 'failed') {
+                    const db = readDB();
+                    const local = db.jobs.find(j => j.id === jobId);
+                    if (local) { local.status = 'failed'; local.error = job.error; }
+                    db.stats.totalFailed++;
+                    writeDB(db);
+                    await apiCaller.sendTelegramMessage(chatId,
+                        `❌ <b>Render failed</b>\n🆔 ${jobId}\n💬 ${job.error || 'Unknown error'}`
+                    );
+                    return;
+                }
+                // Still rendering — poll again
+                setTimeout(poll, 3000);
+            } catch (e) {
+                // Network error — retry
+                setTimeout(poll, 5000);
+            }
+        };
+        setTimeout(poll, 5000); // First check after 5s
+    },
+    async checkStatus(chatId, jobId) {
+        if (jobId) {
+            // Check specific job
+            try {
+                const res = await apiCaller.axiosIPv4.get(`${REMOTION_URL}/api/jobs/${jobId}`, {
+                    headers: remotionHeaders(),
+                    timeout: 10000,
+                });
+                const j = res.data;
+                await apiCaller.sendTelegramMessage(chatId,
+                    `🎬 <b>Job Status</b>\n\n` +
+                    `🆔 ${j.id}\n` +
+                    `📐 Template: ${j.template}\n` +
+                    `📊 Status: ${j.status}${j.progress ? ` (${j.progress}%)` : ''}\n` +
+                    `📅 Created: ${new Date(j.created).toLocaleString()}\n` +
+                    (j.status === 'complete' ? `🔗 Download: ${REMOTION_URL}/api/download/${j.id}\n` : '') +
+                    (j.error ? `❌ Error: ${j.error}\n` : '')
+                );
+            } catch (e) {
+                await apiCaller.sendTelegramMessage(chatId, `⚠️ Job not found or Remotion unreachable: ${e.message}`);
+            }
+        } else {
+            // List recent jobs
+            try {
+                const res = await apiCaller.axiosIPv4.get(`${REMOTION_URL}/api/jobs?limit=5`, {
+                    headers: remotionHeaders(),
+                    timeout: 10000,
+                });
+                const jobList = res.data.jobs || [];
+                if (jobList.length === 0) {
+                    await apiCaller.sendTelegramMessage(chatId, '📭 No video jobs yet. Create one: <code>/videos create [topic]</code>');
+                    return;
+                }
+                let msg = '🎬 <b>Recent Video Jobs</b>\n\n';
+                for (const j of jobList) {
+                    const icon = j.status === 'complete' ? '✅' : j.status === 'rendering' ? '⏳' : j.status === 'queued' ? '📋' : '❌';
+                    msg += `${icon} <code>${j.id}</code>\n   ${j.template} — ${j.status}${j.progress ? ` (${j.progress}%)` : ''}\n\n`;
+                }
+                await apiCaller.sendTelegramMessage(chatId, msg);
+            } catch (e) {
+                await apiCaller.sendTelegramMessage(chatId, `⚠️ Remotion Studio unreachable: ${e.message}`);
+            }
+        }
+    },
+    _getDefaultProps(template, topic) {
+        const defaults = {
+            'text-explainer': { title: topic, hook: `Everything you need to know about ${topic}`, bullets: [`Key insight about ${topic}`, `Why ${topic} matters`, `How to get started`], cta: 'Learn More' },
+            'product-promo': { productName: topic, price: 'Rp 49.000', benefits: [`Master ${topic}`, 'Step-by-step guide', 'Lifetime access'], cta: 'Get It Now' },
+            'social-short': { hook: `Stop scrolling. ${topic} is changing everything.`, points: [`${topic} saves you hours`, `Most people don't know this`, 'Here\'s the proof'], cta: 'Link in bio' },
+            'seo-summary': { articleTitle: topic, keyPoints: [`Key finding about ${topic}`, 'The data behind it', 'What to do next'], source: 'VinOS Blog', cta: 'Read the full article' },
+        };
+        return defaults[template] || defaults['text-explainer'];
+    },
+    getDashboardData() {
+        const db = readDB();
+        return {
+            jobs: db.jobs.slice(-20).reverse(),
+            stats: db.stats,
+            remotionUrl: REMOTION_URL,
+        };
+    },
+};