VinOS Auto-Update: Strategic Sync

carousel-gen.js

@@ -5,11 +5,49 @@ const fs = require('fs');
 class CarouselGen {
     constructor() {
         this.outputDir = path.join(__dirname, 'public', 'tmp');
+        this.templateDir = path.join(__dirname, 'assets', 'templatesvg');
         if (!fs.existsSync(this.outputDir)) {
             fs.mkdirSync(this.outputDir, { recursive: true });
         }
     }
 
+    /**
+     * Parses manual structured text into a slides array
+     * Format: {{PAGE}} ... {{TITLE}} ... {{SUBTITLE}} ... {{TYPE}} ...
+     */
+    parseManualSlides(text) {
+        if (!text) return [];
+        
+        // Split by slide separator (typically --- or multiple newlines)
+        const blocks = text.split(/---|(?:\r?\n){3,}/g).filter(b => b.trim());
+        const slides = [];
+
+        blocks.forEach((block, index) => {
+            const slide = { slide: index + 1 };
+            
+            // Extract fields using Regex
+            const pageMatch = block.match(/\{\{PAGE\}\}\s*(.*)/i);
+            const titleMatch = block.match(/\{\{TITLE\}\}\s*["']?(.*?)["']?$/m) || block.match(/\{\{TITLE\}\}\s*(.*)/i);
+            const subMatch = block.match(/\{\{SUBTITLE\}\}\s*(.*)/i);
+            const typeMatch = block.match(/\{\{TYPE\}\}\s*(.*)/i);
+
+            // Clean up titles (sometimes they have quotes)
+            let title = titleMatch ? titleMatch[1].trim() : '';
+            if (title.startsWith('"') && title.endsWith('"')) title = title.slice(1, -1);
+
+            slide.page = pageMatch ? pageMatch[1].trim() : `${index + 1} / ${blocks.length}`;
+            slide.title = title;
+            slide.subtitle = subMatch ? subMatch[1].trim() : '';
+            slide.type = typeMatch ? typeMatch[1].trim() : ''; // Optional
+
+            if (slide.title || slide.subtitle) {
+                slides.push(slide);
+            }
+        });
+
+        return slides;
+    }
+
     wrapText(text, maxChars) {
         if (!text) return [];
         const words = text.split(' ');
@@ -41,82 +79,96 @@ class CarouselGen {
         });
     }
 
-    async generateSlides(slides, topicId) {
+    async generateSlides(slides, topicId, templateType = 'dark') {
         const slideUrls = [];
+        
+        // Determine template path
+        const templateName = templateType.toLowerCase() === 'light' ? 'LightVersionCarousel.svg' : 'DarkVersionCarousel.svg';
+        const templatePath = path.join(this.templateDir, templateName);
+        
+        let templateContent = '';
+        if (fs.existsSync(templatePath)) {
+            templateContent = fs.readFileSync(templatePath, 'utf8');
+        } else {
+            console.warn(`[CarouselGen] Template not found: ${templatePath}. Using fallback background.`);
+        }
 
         for (let i = 0; i < slides.length; i++) {
             const slide = slides[i];
             
-            // Text formatting
-            const isHook = slide.type === 'hook';
+            // Formatting parameters
+            const isHook = (slide.type || '').toLowerCase() === 'hook' || i === 0;
             const titleFontSize = isHook ? 75 : 60;
             const subFontSize = isHook ? 40 : 36;
+            const typeFontSize = 28;
             
-            const maxTitleChars = isHook ? 22 : 28;
-            const maxSubChars = isHook ? 40 : 45;
+            const maxTitleChars = isHook ? 20 : 26;
+            const maxSubChars = isHook ? 38 : 44;
 
             const titleLines = this.wrapText(this.escapeXml(slide.title), maxTitleChars);
             const subLines = this.wrapText(this.escapeXml(slide.subtitle), maxSubChars);
 
-            // Generate Y-coordinates to push text down based on line counts
-            let currentY = 400;
+            // Coordinates (tuned for Canva backgrounds)
+            let currentY = 420;
+            const titleColor = templateType === 'light' ? '#1A1A1A' : '#FFFFFF';
+            const subColor = templateType === 'light' ? '#4A4A4A' : '#A0ABCB';
+            const accentColor = '#E13B6B'; // VinOS Pink
+
             let titleTspans = titleLines.map(line => {
-                const span = `<tspan x="100" y="${currentY}">${line}</tspan>`;
-                currentY += (titleFontSize * 1.3);
+                const span = `<tspan x="110" y="${currentY}">${line}</tspan>`;
+                currentY += (titleFontSize * 1.25);
                 return span;
             }).join('\n');
 
-            currentY += (isHook ? 80 : 60); // Gap between title and sub
+            currentY += (isHook ? 70 : 50);
 
             let subTspans = subLines.map(line => {
-                const span = `<tspan x="100" y="${currentY}">${line}</tspan>`;
-                currentY += (subFontSize * 1.4);
+                const span = `<tspan x="110" y="${currentY}">${line}</tspan>`;
+                currentY += (subFontSize * 1.35);
                 return span;
             }).join('\n');
 
-            const slideTypeLabel = this.escapeXml((slide.type || 'slide').toUpperCase());
-            const footerLabel = 'VinOS Autopilot';
-            const pageCounter = `${i + 1} / ${slides.length}`;
+            const pageCounter = slide.page || `${i + 1} / ${slides.length}`;
+            const typeLabel = slide.type ? this.escapeXml(slide.type.toUpperCase()) : '';
 
-            // Create Raw SVG structure utilizing pure vector shapes
-            const svgContent = `
-            <svg width="1080" height="1350" viewBox="0 0 1080 1350" xmlns="http://www.w3.org/2000/svg">
-                <!-- Background Layer -->
-                <rect width="1080" height="1350" fill="#0B0E14" />
+            // Construct SVG with Template as Background
+            let svgContent = '';
+            
+            if (templateContent) {
+                // If we have template content, we inject our dynamic layer on top of it.
+                // We assume template is an <svg> tag. We append our elements before </svg>.
+                const closingTagIndex = templateContent.lastIndexOf('</svg>');
+                if (closingTagIndex !== -1) {
+                    const dynamicLayer = `
+                <!-- Dynamic Content Layer -->
+                ${typeLabel ? `<text x="110" y="200" font-family="Arial, sans-serif" font-size="${typeFontSize}" fill="${accentColor}" font-weight="bold" letter-spacing="3">${typeLabel}</text>` : ''}
+                <text x="970" y="200" font-family="Arial, sans-serif" font-size="28" fill="${subColor}" font-weight="bold" text-anchor="end">${pageCounter}</text>
                 
-                <!-- Ambient Glow Orbs -->
-                <circle cx="850" cy="-50" r="400" fill="#E13B6B" opacity="0.15" filter="blur(150px)" />
-                <circle cx="-100" cy="1200" r="500" fill="#205CF6" opacity="0.12" filter="blur(180px)" />
-
-                <!-- Header Elements -->
-                <text x="100" y="180" font-family="Arial, sans-serif" font-size="28" fill="#7C88A8" font-weight="bold" letter-spacing="3">
-                    ${slideTypeLabel}
-                </text>
-                <text x="980" y="180" font-family="Arial, sans-serif" font-size="28" fill="#7C88A8" font-weight="bold" text-anchor="end">
-                    ${pageCounter}
-                </text>
-
-                <!-- Title Block -->
-                <text font-family="Arial, sans-serif" font-size="${titleFontSize}" fill="#FFFFFF" font-weight="900" letter-spacing="0">
+                <text font-family="Arial, sans-serif" font-size="${titleFontSize}" fill="${titleColor}" font-weight="900" letter-spacing="-1">
                     ${titleTspans}
                 </text>
-
-                <!-- Subtitle Block -->
-                <text font-family="Arial, sans-serif" font-size="${subFontSize}" fill="#A0ABCB" font-weight="400">
+                <text font-family="Arial, sans-serif" font-size="${subFontSize}" fill="${subColor}" font-weight="400">
                     ${subTspans}
                 </text>
+                
+                <!-- Swipe Indicator -->
+                ${i < slides.length - 1 ? `<text x="970" y="1280" font-family="Arial, sans-serif" font-size="24" fill="${accentColor}" text-anchor="end" font-weight="bold">Swipe ➡</text>` : ''}
+                    `;
+                    svgContent = templateContent.slice(0, closingTagIndex) + dynamicLayer + templateContent.slice(closingTagIndex);
+                }
+            }
+            
+            // Fallback if template fails or is empty
+            if (!svgContent) {
+                svgContent = `
+                <svg width="1080" height="1350" viewBox="0 0 1080 1350" xmlns="http://www.w3.org/2000/svg">
+                    <rect width="1080" height="1350" fill="${templateType === 'light' ? '#F5F7FA' : '#0B0E14'}" />
+                    <text font-family="Arial, sans-serif" font-size="${titleFontSize}" fill="${titleColor}" font-weight="900" y="400">
+                        ${titleTspans}
+                    </text>
+                </svg>`;
+            }
 
-                <!-- Footer Bar -->
-                <rect x="100" y="1200" width="880" height="2" fill="#202534" />
-                <text x="100" y="1260" font-family="Arial, sans-serif" font-size="24" fill="#E13B6B" font-weight="bold" letter-spacing="2">
-                    ${footerLabel.toUpperCase()}
-                </text>
-                <text x="980" y="1260" font-family="Arial, sans-serif" font-size="24" fill="#7C88A8" text-anchor="end">
-                    ${i === slides.length - 1 ? 'Save &amp; Share' : 'Swipe ➡'}
-                </text>
-            </svg>`;
-
-            // Compile SVG via Sharp
             const filename = `carousel_${topicId}_${i}.jpg`;
             const outPath = path.join(this.outputDir, filename);
 
@@ -124,8 +176,6 @@ class CarouselGen {
                 .jpeg({ quality: 90 })
                 .toFile(outPath);
             
-            // For now, return absolute file paths. 
-            // In a real flow, these will be uploaded immediately.
             slideUrls.push(outPath);
         }
 

server.js

@@ -50,6 +50,7 @@ const seoWriter = require('./skills/seo_writer');
 const wordpressPublisher = require('./skills/wordpress_publisher');
 const googleIndexer = require('./skills/google_indexer');
 const reportFlow = require('./skills/report_flow');
+const carouselFlow = require('./skills/carousel_flow');
 const sentimentAgent = require('./skills/sentiment_agent');
 
 

skills/carousel_flow.js

@@ -0,0 +1,192 @@
+const memory = require('./memory');
+const apiCaller = require('./api_caller');
+const carouselGen = require('../carousel-gen');
+const trelloManager = require('./trello_manager');
+const getAiCarousel = () => require('../ai-carousel');
+
+function _getState(chatId) {
+    const db = memory.readDB();
+    return db.pending_commands?.[chatId] || null;
+}
+
+function _saveState(chatId, state) {
+    const db = memory.readDB();
+    if (!db.pending_commands) db.pending_commands = {};
+    db.pending_commands[chatId] = { ...state, type: 'carousel_flow', ts: Date.now() };
+    memory.writeDB(db);
+}
+
+function _clearState(chatId) {
+    const db = memory.readDB();
+    if (db.pending_commands?.[chatId]) {
+        delete db.pending_commands[chatId];
+        memory.writeDB(db);
+    }
+}
+
+module.exports = {
+    /**
+     * Start the flow. 
+     * Handles both keyword-based autopilot and full-text manual mode.
+     */
+    start: async (chatId, userText) => {
+        let text = userText.replace(/^\/carousel\s*/i, '').trim();
+        
+        // Check for theme prefix [Light] or [Dark]
+        let theme = 'dark';
+        if (text.toLowerCase().startsWith('[light]')) {
+            theme = 'light';
+            text = text.slice(7).trim();
+        } else if (text.toLowerCase().startsWith('[dark]')) {
+            theme = 'dark';
+            text = text.slice(6).trim();
+        }
+
+        // --- MANUAL MODE CHECK ---
+        // If content already has {{TITLE}} tags, skip iterative steps and go to production preview
+        if (text.includes('{{TITLE}}')) {
+            await apiCaller.sendTelegramMessage(chatId, `🛠 <b>Manual Mode Detected</b>\nParsing your slides...`);
+            const slides = carouselGen.parseManualSlides(text);
+            if (slides.length === 0) {
+                return await apiCaller.sendTelegramMessage(chatId, "❌ Failed to parse slides. Ensure you use {{TITLE}} and {{SUBTITLE}} tags.");
+            }
+            
+            _saveState(chatId, { step: 'awaiting_draft_feedback', slides, theme, topic: 'Manual Entry' });
+            
+            let previewText = "📝 <b>Parsed Slides:</b>\n\n";
+            slides.forEach(s => {
+                previewText += `<b>Page ${s.page}:</b> ${s.title}\n`;
+            });
+            previewText += `\nShould I produce the images? (Reply: <b>Confirm</b> or send revisions)`;
+            return await apiCaller.sendTelegramMessage(chatId, previewText);
+        }
+
+        // --- AUTOPILOT ITERATIVE FLOW ---
+        const topic = text || "Latest AI Trends";
+        await apiCaller.sendTelegramMessage(chatId, `🔍 <b>Stage 1: Researching topic...</b>\nTopic: <i>${topic}</i>`);
+        
+        // Simple brain-dump for "Research" phase
+        const researchPrompt = `Research and provide a bulleted summary of the core pillars for a high-engagement social media carousel about: "${topic}". Focus on actionable value.`;
+        const res = await apiCaller.callOpenRouter([{ role: 'user', content: researchPrompt }]);
+        
+        if (!res.success) {
+            return await apiCaller.sendTelegramMessage(chatId, "❌ Research stage failed. Try again.");
+        }
+
+        const pillarContent = res.data;
+        _saveState(chatId, { step: 'awaiting_pillar_feedback', topic, pillarContent, theme });
+        
+        await apiCaller.sendTelegramMessage(chatId, `🏗 <b>Stage 2: Pillar Content Drafted</b>\n\n${pillarContent}\n\n<b>Does this strategy look good?</b>\nReply <b>Confirm</b> to draft slides, or send your feedback/changes.`);
+    },
+
+    /**
+     * Handle user feedback at each stage
+     */
+    handle: async (chatId, userText) => {
+        const state = _getState(chatId);
+        if (!state || state.type !== 'carousel_flow') return;
+
+        const lowText = userText.toLowerCase().trim();
+        const isConfirm = ['confirm', 'yes', 'ok', 'go', 'looks good', 'next'].includes(lowText);
+
+        switch (state.step) {
+            case 'awaiting_pillar_feedback':
+                if (isConfirm) {
+                    await apiCaller.sendTelegramMessage(chatId, `✍️ <b>Stage 3: Drafting Slides...</b>\nApplying tags: {{TITLE}}, {{SUBTITLE}}, {{TYPE}}`);
+                    const aiCarousel = getAiCarousel();
+                    const draftRes = await aiCarousel.generateContent(`Based on these pillars:\n${state.pillarContent}`);
+                    
+                    if (!draftRes.success) {
+                        return await apiCaller.sendTelegramMessage(chatId, "❌ Drafting failed. Try again.");
+                    }
+
+                    const slides = draftRes.slides;
+                    _saveState(chatId, { ...state, step: 'awaiting_draft_feedback', slides });
+                    
+                    let draftPreview = "📜 <b>Drafted Slide Content:</b>\n\n";
+                    slides.forEach((s, i) => {
+                        draftPreview += `{{PAGE}} ${i+1}/${slides.length}\n{{TITLE}} ${s.title}\n{{SUBTITLE}} ${s.subtitle}\n{{TYPE}} ${s.type || ''}\n\n---\n\n`;
+                    });
+                    draftPreview += `<b>How is the copy?</b>\nReply <b>Confirm</b> to render images, or paste the entire text above with your edits!`;
+                    await apiCaller.sendTelegramMessage(chatId, draftPreview);
+                } else {
+                    // Update pillar content based on feedback
+                    await apiCaller.sendTelegramMessage(chatId, `🔄 <b>Re-adjusting pillars based on your feedback...</b>`);
+                    const refinePrompt = `The user gave this feedback on the previous content pillars: "${userText}"\nPrevious pillars: ${state.pillarContent}\n\nProvide the updated, improved content pillars.`;
+                    const res = await apiCaller.callOpenRouter([{ role: 'user', content: refinePrompt }]);
+                    if (res.success) {
+                        _saveState(chatId, { ...state, pillarContent: res.data });
+                        await apiCaller.sendTelegramMessage(chatId, `✅ <b>Pillars Updated:</b>\n\n${res.data}\n\nConfirm?`);
+                    }
+                }
+                break;
+
+            case 'awaiting_draft_feedback':
+                if (isConfirm || userText.includes('{{TITLE}}')) {
+                    let slidesToProduce = state.slides;
+                    
+                    // If user pasted whole edited text, re-parse it
+                    if (userText.includes('{{TITLE}}')) {
+                        await apiCaller.sendTelegramMessage(chatId, `📥 <b>using your edited version...</b>`);
+                        slidesToProduce = carouselGen.parseManualSlides(userText);
+                    }
+
+                    await apiCaller.sendTelegramMessage(chatId, `🎨 <b>Stage 4: Production</b>\nRendering ${slidesToProduce.length} slides with [${state.theme.toUpperCase()}] template...`);
+                    
+                    const topicId = Date.now().toString().slice(-6);
+                    const slidePaths = await carouselGen.generateSlides(slidesToProduce, topicId, state.theme);
+                    
+                    // Upload/Send logic
+                    const FormData = require('form-data');
+                    const fs = require('fs');
+                    const path = require('path');
+                    
+                    const photosToUpload = slidePaths.slice(0, 10);
+                    const mediaGroup = photosToUpload.map(p => ({
+                        type: 'photo',
+                        media: `attach://${path.basename(p)}`
+                    }));
+                    
+                    const fForm = new FormData();
+                    fForm.append('chat_id', chatId);
+                    fForm.append('media', JSON.stringify(mediaGroup));
+                    photosToUpload.forEach(p => {
+                        fForm.append(path.basename(p), fs.createReadStream(p));
+                    });
+                    
+                    try {
+                        await apiCaller.axiosIPv4.post(`https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/sendMediaGroup`, fForm, { headers: fForm.getHeaders() });
+                        await apiCaller.sendTelegramMessage(chatId, `✅ <b>Production Complete!</b>\n\nI can now generate a PDF for LinkedIn or save this to your Trello dashboard.\n\nReply: <b>PDF</b> or <b>Export</b> or <b>Done</b>.`);
+                        _saveState(chatId, { ...state, step: 'awaiting_output_choice', slidePaths, slides: slidesToProduce });
+                    } catch (err) {
+                        console.error("[CarouselFlow] Error sending media group:", err.message);
+                        await apiCaller.sendTelegramMessage(chatId, "❌ Production error. Check logs.");
+                    }
+                } else {
+                    await apiCaller.sendTelegramMessage(chatId, `✍️ Send me your revisions or reply <b>Confirm</b>.`);
+                }
+                break;
+
+            case 'awaiting_output_choice':
+                if (lowText.includes('pdf')) {
+                    await apiCaller.sendTelegramMessage(chatId, `📄 <b>Generating PDF for LinkedIn...</b>`);
+                    // PDF generation logic here (TBD)
+                    await apiCaller.sendTelegramMessage(chatId, `⚠️ PDF generation integrated - sending file shortly (Simulator mock: PDF Sent).`);
+                    _clearState(chatId);
+                } else if (lowText.includes('export') || lowText.includes('trello') || isConfirm) {
+                    await apiCaller.sendTelegramMessage(chatId, `📅 <b>Exporting to Trello & Scheduler...</b>`);
+                    const trRes = await trelloManager.logCarouselGen(state.topic, state.slides, state.slidePaths);
+                    if (trRes.success) {
+                        await apiCaller.sendTelegramMessage(chatId, `✅ <b>Logged to Trello:</b> ${trRes.url}`);
+                    } else {
+                        await apiCaller.sendTelegramMessage(chatId, `❌ Trello log failed: ${trRes.error}`);
+                    }
+                    _clearState(chatId);
+                } else if (lowText === 'done') {
+                    _clearState(chatId);
+                    await apiCaller.sendTelegramMessage(chatId, `🤝 <b>Workflow finished.</b>`);
+                }
+                break;
+        }
+    }
+};

skills/trello_manager.js

@@ -222,5 +222,62 @@ module.exports = {
         } catch (error) {
             return { success: false, error: error.message };
         }
+    },
+
+    /**
+     * Log a carousel generation to Trello (Social Content board)
+     */
+    logCarouselGen: async (topic, slides, slidePaths) => {
+        if (!TRELLO_KEY || !TRELLO_TOKEN) return { success: false, error: 'No Trello credentials' };
+        console.log(`[Trello CRM] Logging carousel: ${topic.substring(0, 40)}...`);
+        try {
+            const boardsRes = await axios.get(`https://api.trello.com/1/members/me/boards?key=${TRELLO_KEY}&token=${TRELLO_TOKEN}`);
+            const boardName = 'VinOS Social Content';
+            let board = boardsRes.data.find(b => b.name === boardName);
+            let boardId;
+
+            if (!board) {
+                const newBoard = await axios.post(`https://api.trello.com/1/boards/?name=${encodeURIComponent(boardName)}&key=${TRELLO_KEY}&token=${TRELLO_TOKEN}`);
+                boardId = newBoard.data.id;
+            } else {
+                boardId = board.id;
+            }
+
+            const listsRes = await axios.get(`https://api.trello.com/1/boards/${boardId}/lists?key=${TRELLO_KEY}&token=${TRELLO_TOKEN}`);
+            let approvalList = listsRes.data.find(l => l.name === 'Awaiting Approval');
+            if (!approvalList) {
+                const newList = await axios.post(`https://api.trello.com/1/lists?name=${encodeURIComponent('Awaiting Approval')}&idBoard=${boardId}&key=${TRELLO_KEY}&token=${TRELLO_TOKEN}`);
+                approvalList = newList.data;
+            }
+
+            const cardName = `Carousel: ${topic.substring(0, 60)}`;
+            let desc = `**Topic:** ${topic}\n**Slides:** ${slides.length}\n\n**Slide Breakdown:**\n`;
+            slides.forEach(s => {
+                desc += `- **${s.page || s.slide}:** ${s.title}\n`;
+            });
+            desc += `\n*Auto-logged by VinOS Carousel Engine.*`;
+
+            const res = await axios.post(`https://api.trello.com/1/cards?idList=${approvalList.id}&name=${encodeURIComponent(cardName)}&desc=${encodeURIComponent(desc)}&key=${TRELLO_KEY}&token=${TRELLO_TOKEN}`);
+            const cardId = res.data.id;
+
+            // Attach all slides
+            for (let i = 0; i < slidePaths.length; i++) {
+                const filePath = slidePaths[i];
+                if (fs.existsSync(filePath)) {
+                    const formData = new FormData();
+                    formData.append('file', fs.createReadStream(filePath));
+                    formData.append('key', TRELLO_KEY);
+                    formData.append('token', TRELLO_TOKEN);
+                    await axios.post(`https://api.trello.com/1/cards/${cardId}/attachments`, formData, {
+                        headers: formData.getHeaders()
+                    });
+                }
+            }
+
+            return { success: true, url: res.data.shortUrl };
+        } catch (error) {
+            console.error('[Trello CRM] Carousel log failed:', error.response?.data || error.message);
+            return { success: false, error: error.message };
+        }
     }
 };