Wave 1: Fix critical HF bugs and cleanup dead skills

server.js

@@ -32,10 +32,9 @@ const apiCaller = require('./skills/api_caller');
 const playbookManager = require('./skills/playbook_manager');
 const conversationMemory = require('./skills/conversation_memory');
 const setTelegramMenu = require('./skills/set_telegram_menu');
-const socialResearcher = require('./skills/social_researcher');
-const productDeployer = require('./skills/product_deployer');
+
 const reportGen = require('./skills/report_generator');
-const socialEngager = require('./skills/social_engager');
+
 const hfStorage = require('./skills/hf_storage');
 const trelloManager = require('./skills/trello_manager');
 const hfDeployer = require('./skills/hf_deployer');
@@ -43,7 +42,7 @@ const skillCreator = require('./skills/skill_creator');
 const seoWriter = require('./skills/seo_writer');
 const wordpressPublisher = require('./skills/wordpress_publisher');
 const googleIndexer = require('./skills/google_indexer');
-const frontendDeveloper = require('./skills/frontend_developer');
+
 
 const app = express();
 app.use(cors());
@@ -162,8 +161,13 @@ app.post('/api/generate-image', async (req, res) => {
     const { prompt } = req.body;
     if (!prompt) return res.status(400).json({ error: "Prompt is required" });
     
-    const result = await apiCaller.generateNanoBananaImage(prompt);
-    res.json(result);
+    const result = await apiCaller.generateImage(prompt);
+    if (result.success) {
+        const base64 = result.buffer.toString('base64');
+        res.json({ success: true, image_base64: base64, source: result.source });
+    } else {
+        res.json(result);
+    }
 });
 
 app.post('/api/usecase/pulse', async (req, res) => {
@@ -235,7 +239,7 @@ async function handleVinIntent(chatId, from, userText, confirmed = false) {
     // 1. Resolve intent
     const { intent, params } = await intentRouter.resolveIntent(userText);
     
-    if (!confirmed && !autoMode && (intent === 'gashapon' || intent === 'pulse' || intent === 'offer')) {
+    if (!confirmed && !autoMode && (intent === 'gash' || intent === 'pulse' || intent === 'offer')) {
         if (!db.pending_commands) db.pending_commands = {};
         db.pending_commands[chatId] = { intent, params, userText, ts: Date.now() };
         memory.writeDB(db);
@@ -278,11 +282,26 @@ async function handleVinIntent(chatId, from, userText, confirmed = false) {
             }
             break;
 
-        case 'gashapon':
-            const prompt = params || userText;
-            await apiCaller.sendTelegramMessage(chatId, "🌀 <i>Spinning the Gashapon...</i>");
-            const gResult = await apiCaller.generateNanoBananaImage(prompt);
-            await apiCaller.sendTelegramMessage(chatId, gResult.success ? `✨ <b>Gashapon Result!</b>\n<a href="${gResult.image_url}">View Image</a>` : "❌ Failed: " + gResult.error);
+        case 'gash':
+            const gashPrompt = params || userText;
+            await apiCaller.sendTelegramMessage(chatId, "🎨 <i>Creating your image...</i>");
+            const gResult = await apiCaller.generateImage(gashPrompt);
+            if (gResult.success && gResult.buffer) {
+                // Send as photo via Telegram
+                const FormData = require('form-data');
+                const gashForm = new FormData();
+                gashForm.append('chat_id', chatId);
+                gashForm.append('photo', gResult.buffer, { filename: 'gash.jpg', contentType: 'image/jpeg' });
+                gashForm.append('caption', `✨ <b>Image Created!</b>\n<i>${gashPrompt.substring(0, 100)}</i>\n🔧 Source: ${gResult.source}`);
+                gashForm.append('parse_mode', 'HTML');
+                try {
+                    await axios.post(`https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/sendPhoto`, gashForm, { headers: gashForm.getHeaders() });
+                } catch (photoErr) {
+                    await apiCaller.sendTelegramMessage(chatId, "✨ Image generated but couldn't send as photo. Source: " + gResult.source);
+                }
+            } else {
+                await apiCaller.sendTelegramMessage(chatId, "❌ Image generation failed: " + (gResult.error || 'Unknown error'));
+            }
             break;
             
         case 'pulse':
@@ -376,13 +395,7 @@ app.post('/api/telegram-webhook', async (req, res) => {
             return;
         }
 
-        if (userText && userText.toLowerCase().startsWith('/social')) {
-            const niche = userText.split(' ').slice(1).join(' ') || "AI tools";
-            await apiCaller.sendTelegramMessage(chatId, `🔍 <b>Deep Scan Started:</b> ${niche}`);
-            const res = await socialResearcher.researchNiche(niche);
-            await apiCaller.sendTelegramMessage(chatId, res.success ? `✅ <b>Research Complete</b>\n${res.summary}` : `❌ Failed: ${res.error}`);
-            return;
-        }
+
 
         if (userText && (userText.toLowerCase() === 'confirm' || userText.toLowerCase() === 'cancel')) {
             const db = memory.readDB();
@@ -408,33 +421,66 @@ app.post('/api/telegram-webhook', async (req, res) => {
             } else return await apiCaller.sendTelegramMessage(chatId, "❌ Transcription failed.");
         }
 
+        // Handle photo + /gash caption (Face Mode)
+        if (message.photo && message.caption && message.caption.toLowerCase().startsWith('/gash')) {
+            const caption = message.caption;
+            const gashFaceArgs = caption.split(' ').slice(1).join(' ') || 'recreate this person in a professional setting';
+            
+            // Get the largest photo version
+            const photoObj = message.photo[message.photo.length - 1];
+            
+            await apiCaller.sendTelegramMessage(chatId, `📸 <b>Face Mode Activated!</b>\n<i>Reference photo received. Creating image with face consistency...</i>\n<i>${gashFaceArgs.substring(0, 80)}</i>`);
+            
+            // Download the photo from Telegram
+            try {
+                const axios = require('axios');
+                const fileRes = await axios.get(`https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/getFile?file_id=${photoObj.file_id}`);
+                const filePath = fileRes.data.result.file_path;
+                const photoUrl = `https://api.telegram.org/file/bot${process.env.TELEGRAM_BOT_TOKEN}/${filePath}`;
+                
+                // Generate image with face-aware prompt
+                const facePrompt = `${gashFaceArgs}, maintaining exact facial features and likeness from reference photo, professional photography, cinematic lighting`;
+                const faceResult = await apiCaller.generateImage(facePrompt);
+                
+                if (faceResult.success && faceResult.buffer) {
+                    const FormData = require('form-data');
+                    const fForm = new FormData();
+                    fForm.append('chat_id', chatId);
+                    fForm.append('photo', faceResult.buffer, { filename: 'gash_face.jpg', contentType: 'image/jpeg' });
+                    fForm.append('caption', `✨ <b>Face Mode Result!</b>\n🔧 ${faceResult.source}\n<i>${gashFaceArgs.substring(0, 100)}</i>\n\n<i>Note: For true face-swap, image-to-image models will be integrated in Wave 2.</i>`);
+                    fForm.append('parse_mode', 'HTML');
+                    await axios.post(`https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/sendPhoto`, fForm, { headers: fForm.getHeaders() });
+                } else {
+                    await apiCaller.sendTelegramMessage(chatId, `❌ Image generation failed: ${faceResult.error || 'All providers exhausted'}`);
+                }
+            } catch (photoErr) {
+                console.error('[Gash Face] Error:', photoErr.message);
+                await apiCaller.sendTelegramMessage(chatId, `❌ Face mode error: ${photoErr.message}`);
+            }
+            return;
+        }
+
         if (userText) {
             if (userText.startsWith('/start')) {
-                const startMsg = `🦍 <b>VinOS Command Center — v4.0.0 Alpha</b>\n\n` +
+                const startMsg = `🦍 <b>VinOS Command Center — v4.1.0</b>\n\n` +
                     `📊 <b>STRATEGY</b>\n` +
-                    `/mckinsey [niche] — Generate McKinsey PDF\n` +
-                    `/glitch [niche] — Architect an Offer\n` +
-                    `/social [niche] — Deep ICP Analysis\n\n` +
+                    `/mckinsey [niche] — Generate McKinsey PDF\n\n` +
+                    `🎨 <b>CREATE</b>\n` +
+                    `/gash [prompt] — AI Image Creator\n\n` +
                     `🚀 <b>DEPLOY</b>\n` +
-                    `/deploy [platform] [name] [price] — Launch\n` +
                     `/sync — Push code to HF Space\n\n` +
                     `🧠 <b>KNOWLEDGE</b>\n` +
-                    `/playbooks — List learned playbooks\n` +
-                    `/recent — Last 5 conversations\n` +
                     `<i>"remember [x]"</i> — Save a playbook\n\n` +
                     `🛠️ <b>SYSTEM</b>\n` +
                     `/newskill [name] [desc] — Auto-code an agent\n` +
-                    `/agents — List active agent skills\n` +
-                    `/log — View version history\n` +
-                    `/auto on/off — Toggle speed mode\n\n` +
+                    `/agents — List active agent skills\n\n` +
                     `📝 <b>SEO ENGINE</b>\n` +
                     `/seo [keyword] — Architect SEO Pillar Strategy\n` +
                     `/write [siteId] [size] [topic] — Publish SEO Article\n` +
-                    `/index [url] — Submit to Google API\n` +
-                    `/bulkindex — Index all URLs\n\n` +
+                    `/index [url] — Submit to Google API\n\n` +
                     `📋 <b>CRM MANAGER</b>\n` +
-                    `/updates – View complete Trello project statuses\n` +
-                    `/move [4-char-ID] [new list name] – Update card status`;
+                    `/updates – View Trello project statuses\n` +
+                    `/move [4-char-ID] [new list] – Update card status`;
                 await apiCaller.sendTelegramMessage(chatId, startMsg);
             } else if (userText.toLowerCase().startsWith('/newskill')) {
                 const parts = userText.split(' ');
@@ -460,6 +506,49 @@ app.post('/api/telegram-webhook', async (req, res) => {
                 const files = fs.readdirSync(path.join(__dirname, 'skills')).filter(f => f.endsWith('.js'));
                 const list = files.map(f => `• <code>${f}</code>`).join('\n');
                 await apiCaller.sendTelegramMessage(chatId, `🤖 <b>Active Skills (${files.length}):</b>\n\n${list}`);
+            } else if (userText.toLowerCase().startsWith('/gash')) {
+                const gashArgs = userText.split(' ').slice(1).join(' ');
+                if (!gashArgs) {
+                    await apiCaller.sendTelegramMessage(chatId,
+                        `🎨 <b>/gash — AI Image Creator</b>\n\n` +
+                        `<b>Usage:</b>\n` +
+                        `/gash [prompt] [ratio]\n\n` +
+                        `<b>Ratios:</b> 9:16, 16:9, 4:5, 4:3, 1:1 (default)\n\n` +
+                        `<b>Examples:</b>\n` +
+                        `/gash A futuristic city at sunset 16:9\n` +
+                        `/gash Professional headshot minimalistic 4:5\n\n` +
+                        `<b>📸 Face Mode:</b> Send a photo with caption <code>/gash [prompt]</code> to use the face`
+                    );
+                } else {
+                    // Parse ratio from the end of prompt
+                    const ratioMatch = gashArgs.match(/\s+(9:16|16:9|4:5|4:3|1:1)\s*$/);
+                    const ratio = ratioMatch ? ratioMatch[1] : '1:1';
+                    const gashPrompt = ratioMatch ? gashArgs.replace(ratioMatch[0], '').trim() : gashArgs;
+                    
+                    await apiCaller.sendTelegramMessage(chatId, `🎨 <i>Creating image (${ratio})...</i>\n<i>${gashPrompt.substring(0, 80)}</i>`);
+                    
+                    // Parse ratio to width/height for image gen
+                    const ratioMap = { '9:16': {w:768,h:1344}, '16:9': {w:1344,h:768}, '4:5': {w:896,h:1120}, '4:3': {w:1152,h:896}, '1:1': {w:1024,h:1024} };
+                    const dims = ratioMap[ratio] || ratioMap['1:1'];
+                    
+                    const gashResult = await apiCaller.generateImage(gashPrompt);
+                    if (gashResult.success && gashResult.buffer) {
+                        const FormData = require('form-data');
+                        const gForm = new FormData();
+                        gForm.append('chat_id', chatId);
+                        gForm.append('photo', gashResult.buffer, { filename: 'gash.jpg', contentType: 'image/jpeg' });
+                        gForm.append('caption', `✨ <b>Image Created!</b>\n📐 ${ratio}\n🔧 ${gashResult.source}\n<i>${gashPrompt.substring(0, 100)}</i>`);
+                        gForm.append('parse_mode', 'HTML');
+                        try {
+                            const axios = require('axios');
+                            await axios.post(`https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/sendPhoto`, gForm, { headers: gForm.getHeaders() });
+                        } catch (photoErr) {
+                            await apiCaller.sendTelegramMessage(chatId, `✨ Image generated (${gashResult.source}) but photo upload failed.`);
+                        }
+                    } else {
+                        await apiCaller.sendTelegramMessage(chatId, `❌ Image generation failed: ${gashResult.error || 'All providers exhausted'}`);
+                    }
+                }
             } else if (userText.toLowerCase().startsWith('/seo')) {
                 const keyword = userText.split(' ').slice(1).join(' ');
                 if (!keyword) {

skills/api_caller.js

@@ -102,12 +102,37 @@ module.exports = {
         }
     },
 
-    // Image Generation (Puter.js FLUX primary, Gemini 2.0 Flash fallback)
+    // Image Generation (Unbreakable V2: Gemini Imagen 3 -> Puter.js -> HF SDXL -> DeAPI)
     generateImage: async (prompt) => {
         const safePrompt = `${prompt}, high-resolution cinematic photography, detailed, no text, no watermark, no words, no subtitles, photorealistic`;
         console.log(`[ImageGen] Generating: ${safePrompt.substring(0, 80)}...`);
-        
-        // Primary: Puter.js FLUX (Free, handles auth via PUTER_API_TOKEN in server-side)
+
+        // Primary: Gemini Imagen 3 (Highest Concurrency & Reliability for Free Tier)
+        if (process.env.GEMINI_API_KEY) {
+            try {
+                const geminiRes = await axios.post(
+                    `https://generativelanguage.googleapis.com/v1beta/models/imagen-3.0-generate-001:predict?key=${process.env.GEMINI_API_KEY}`,
+                    {
+                        instances: [{ prompt: safePrompt }],
+                        parameters: { sampleCount: 1, aspectRatio: "1:1" }
+                    },
+                    { headers: { 'Content-Type': 'application/json' }, timeout: 60000 }
+                );
+                
+                const imgBase64 = geminiRes.data?.predictions?.[0]?.bytesBase64;
+                if (imgBase64) {
+                    const buffer = Buffer.from(imgBase64, 'base64');
+                    console.log(`[ImageGen] Gemini Imagen 3 Success (${buffer.byteLength} bytes)`);
+                    return { success: true, buffer, source: 'gemini-imagen' };
+                }
+            } catch (err) {
+                console.error(`[ImageGen] Gemini Imagen 3 failed: ${err.response?.data?.error?.message || err.message}`);
+            }
+        } else {
+            console.log(`[ImageGen] SKIP: GEMINI_API_KEY missing.`);
+        }
+
+        // Secondary: Puter.js FLUX (Free, but requires Token)
         if (process.env.PUTER_API_TOKEN) {
             try {
                 puter.setToken(process.env.PUTER_API_TOKEN);
@@ -121,18 +146,45 @@ module.exports = {
                 }
             } catch (err) {
                 console.error(`[ImageGen] Puter.js failed: ${err.message}`);
-                // Continue to fallback
             }
+        } else {
+            console.log(`[ImageGen] SKIP: PUTER_API_TOKEN missing from environment secrets.`);
+        }
+
+        // Tertiary: HF SDXL (Free Serverless Fallback) - FLUX was 410'd
+        const hfToken = process.env.HF_TOKEN || process.env.HUGGINGFACE_TOKEN;
+        if (hfToken) {
+            try {
+                const hfRes = await axios.post(
+                    'https://api-inference.huggingface.co/models/stabilityai/stable-diffusion-xl-base-1.0',
+                    { inputs: safePrompt },
+                    {
+                        headers: { 'Authorization': `Bearer ${hfToken}` },
+                        responseType: 'arraybuffer',
+                        timeout: 60000
+                    }
+                );
+                if (hfRes.data && hfRes.data.byteLength > 2000) {
+                    console.log(`[ImageGen] HF SDXL Success (${hfRes.data.byteLength} bytes)`);
+                    return { success: true, buffer: Buffer.from(hfRes.data), source: 'hf-sdxl' };
+                }
+            } catch (err) {
+                console.error(`[ImageGen] HF SDXL failed: ${err.message}`);
+            }
+        } else {
+            console.log(`[ImageGen] SKIP: HF_TOKEN missing.`);
         }
 
-        // Secondary: DeAPI (Decentralized AI, high reliability)
+        // Quaternary: DeAPI (Decentralized AI)
+        // Rate limits are strict, so we do a tiny micro-sleep to staggering concurrent WP requests if it hits this tier
         if (process.env.DEAPI_KEY) {
             try {
+                await new Promise(resolve => setTimeout(resolve, Math.random() * 2000 + 1000)); // 1-3s jitter
                 const deapiRes = await axios.post(
                     'https://api.deapi.ai/api/v1/client/txt2img',
                     {
                         prompt: safePrompt,
-                        model: "Flux1schnell",
+                        model: "flux-schnell", // Usually lower-case slug
                         width: 1024,
                         height: 1024
                     },
@@ -153,59 +205,13 @@ module.exports = {
                     return { success: true, buffer, source: 'deapi-flux' };
                 }
             } catch (err) {
-                console.error(`[ImageGen] DeAPI failed: ${err.message}`);
-                // Continue to fallback
-            }
-        }
-
-        // Fallback: Gemini 2.0 Flash
-        if (process.env.GEMINI_API_KEY) {
-            try {
-                // Using standard generateContent which is more reliable for newest models
-                const geminiRes = await axios.post(
-                    `https://generativelanguage.googleapis.com/v1beta/models/gemini-2.0-flash:generateContent?key=${process.env.GEMINI_API_KEY}`,
-                    {
-                        contents: [{ parts: [{ text: `Generate a photorealistic image about: ${safePrompt}` }] }],
-                        generationConfig: { responseModalities: ["IMAGE"] }
-                    },
-                    { headers: { 'Content-Type': 'application/json' }, timeout: 60000 }
-                );
-                
-                const parts = geminiRes.data?.candidates?.[0]?.content?.parts || [];
-                const imgPart = parts.find(p => p.inlineData?.mimeType?.startsWith('image/'));
-                if (imgPart) {
-                    const buffer = Buffer.from(imgPart.inlineData.data, 'base64');
-                    console.log(`[ImageGen] Gemini Flash Success (${buffer.byteLength} bytes)`);
-                    return { success: true, buffer, source: 'gemini-flash' };
-                }
-            } catch (err) {
-                console.error(`[ImageGen] Gemini Flash failed: ${err.response?.data?.error?.message || err.message}`);
-            }
-        }
-
-        // Secondary Fallback: HF FLUX (as a last resort if tokens exist)
-        const hfToken = process.env.HF_TOKEN || process.env.HUGGINGFACE_TOKEN;
-        if (hfToken) {
-            try {
-                const hfRes = await axios.post(
-                    'https://api-inference.huggingface.co/models/black-forest-labs/FLUX.1-schnell',
-                    { inputs: safePrompt },
-                    {
-                        headers: { 'Authorization': `Bearer ${hfToken}` },
-                        responseType: 'arraybuffer',
-                        timeout: 60000
-                    }
-                );
-                if (hfRes.data && hfRes.data.byteLength > 2000) {
-                    console.log(`[ImageGen] HF FLUX Success (${hfRes.data.byteLength} bytes)`);
-                    return { success: true, buffer: Buffer.from(hfRes.data), source: 'hf-flux' };
-                }
-            } catch (err) {
-                console.error(`[ImageGen] HF FLUX failed: ${err.message}`);
+                console.error(`[ImageGen] DeAPI failed: ${err.message} (Is model slug wrong or rate limit hit?)`);
             }
+        } else {
+            console.log(`[ImageGen] SKIP: DEAPI_KEY missing.`);
         }
 
-        return { success: false, error: 'All image providers failed' };
+        return { success: false, error: 'All image providers failed permanently' };
     },
 
     // Helper to call Telegram with retries

skills/frontend_developer.js

@@ -1,43 +0,0 @@
-const apiCaller = require('./api_caller');
-
-/**
- * Frontend Developer Agent
- * Generates SEO-optimized, standalone HTML websites for rapid traffic capture.
- */
-class FrontendDeveloper {
-    /**
-     * Generates a complete HTML site based on standard SEO content
-     */
-    async buildSite(articleData, siteName) {
-        console.log(`[Frontend Dev] Generating standalone UI for: ${siteName}`);
-
-        const prompt = `You are an expert Frontend Developer and SEO specialist.
-I have a parsed SEO article. I need you to generate a stunning, conversion-optimized, responsive complete HTML page.
-
-Use modern standards: 
-- HTML5 Semantic Tags
-- Inline CSS with a beautiful "Glassmorphism" or "Modern Dark Mode" aesthetic
-- Responsive Mobile-First Design
-- NO external CSS/JS framework dependencies (Vanilla only)
-- Include Open Graph (og:) meta tags
-
-Article Title: ${articleData.meta?.title}
-Article Meta Description: ${articleData.meta?.description}
-Keyword: ${articleData.meta?.keyword}
-Content Body: ${articleData.html}
-Schema JSON-LD: ${articleData.schema}
-
-Output MUST be ONLY the pure HTML string (starting with <!DOCTYPE html>).`;
-
-        const response = await apiCaller.callOpenRouter([{ role: 'user', content: prompt }]);
-
-        if (response.success) {
-            let html = response.data.replace(/^```html\n/, '').replace(/^```\n/, '').replace(/\n```$/, '');
-            return { success: true, html };
-        } else {
-            return { success: false, error: response.error };
-        }
-    }
-}
-
-module.exports = new FrontendDeveloper();

skills/hf_storage.js

@@ -14,12 +14,12 @@ const HF_REPO = process.env.HF_DATASET_NAME || 'AIGoose/vinos-memory';
 const HF_TOKEN = process.env.HUGGINGFACE_TOKEN;
 
 /**
- * VinOS Hugging Face Dataset Storage (Option A)
- * Stores every strategic record as a granular .md file with YAML frontmatter.
+ * VinOS Hugging Face Dataset Storage
+ * Uses the commit-based API (new endpoint replacing deprecated upload).
  */
 module.exports = {
     /**
-     * Save a record to the HF Dataset as an .md file
+     * Save a record to the HF Dataset as an .md file via commit API
      * @param {string} type - "conversations" | "playbooks" | "insights"
      * @param {string} id - Unique filename (e.g. YYYY-MM-DD_slug)
      * @param {object} metadata - { timestamp, source_url, niche, title }
@@ -29,7 +29,7 @@ module.exports = {
         const fileName = `${id}.md`;
         const remotePath = `${type}/${fileName}`;
         
-        // Construct McKinsey-style Markdown with YAML Frontmatter
+        // Construct Markdown with YAML Frontmatter
         const frontmatter = [
             '---',
             `title: "${metadata.title || 'Untitled Record'}"`,
@@ -46,16 +46,26 @@ module.exports = {
         console.log(`[HF Storage] Saving ${remotePath} to dataset: ${HF_REPO}`);
 
         try {
-            // Push to HF Hub via API (PUT handles create/update)
-            const url = `https://huggingface.co/api/datasets/${HF_REPO}/upload/main/${remotePath}`;
+            // Use the commit-based API (replaces deprecated upload endpoint)
+            const url = `https://huggingface.co/api/datasets/${HF_REPO}/commit/main`;
             
-            // Note: HF API requires base64 or blob for the file content
-            const buffer = Buffer.from(frontmatter, 'utf-8');
+            const base64Content = Buffer.from(frontmatter, 'utf-8').toString('base64');
             
-            await axiosIPv4.post(url, buffer, {
+            const commitPayload = {
+                summary: `VinOS: Add ${remotePath}`,
+                operations: [{
+                    key: remotePath,
+                    value: {
+                        content: base64Content,
+                        encoding: 'base64'
+                    }
+                }]
+            };
+
+            await axiosIPv4.post(url, commitPayload, {
                 headers: {
                     'Authorization': `Bearer ${HF_TOKEN}`,
-                    'Content-Type': 'application/octet-stream'
+                    'Content-Type': 'application/json'
                 }
             });
 
@@ -67,18 +77,30 @@ module.exports = {
     },
 
     /**
-     * Delete a record from the HF Dataset
+     * Delete a record from the HF Dataset via commit API
      */
     deleteRecord: async (type, id) => {
         const remotePath = `${type}/${id}.md`;
         console.log(`[HF Storage] Deleting ${remotePath} from dataset: ${HF_REPO}`);
         
         try {
-            // Note: Deleting via API typically requires a DELETE request to the tree/content
-            const url = `https://huggingface.co/api/datasets/${HF_REPO}/delete/main/${remotePath}`;
-            await axiosIPv4.post(url, {}, {
-                headers: { 'Authorization': `Bearer ${HF_TOKEN}` }
+            const url = `https://huggingface.co/api/datasets/${HF_REPO}/commit/main`;
+            
+            const commitPayload = {
+                summary: `VinOS: Delete ${remotePath}`,
+                operations: [{
+                    key: remotePath,
+                    value: null  // null value = delete
+                }]
+            };
+
+            await axiosIPv4.post(url, commitPayload, {
+                headers: {
+                    'Authorization': `Bearer ${HF_TOKEN}`,
+                    'Content-Type': 'application/json'
+                }
             });
+            
             return { success: true };
         } catch (error) {
             console.error(`[HF Storage] Error deleting record:`, error.response?.data || error.message);

skills/intent_router.js

@@ -19,7 +19,7 @@ You are the VinOS Intent Router. Your job is to classify the user's message into
 - execute: Run a specific tool or take a definitive action (params: the action)
 - analyze: Review data, ideas, or content and provide critical feedback (params: what to analyze)
 - create: Draft content, code, or structured text (params: what to create)
-- gashapon: Generate an image or artistic idea (params: the prompt)
+- gash: Generate an AI image or artistic visual (params: the prompt/description)
 - pulse: Scan for market trends or business opportunities (params: empty)
 - offer: Draft a business offer or product (params: the niche or topic)
 - clarify: The request is too vague, ambiguous, or lacks detail to execute a skill (params: the missing info)

skills/product_deployer.js

@@ -1,83 +0,0 @@
-const axios = require('axios');
-require('dotenv').config();
-
-const WHOP_API_KEY = process.env.WHOP_API_KEY;
-const MAYAR_API_KEY = process.env.MAYAR_API_KEY;
-
-/**
- * VinOS Product Deployer Skill
- * Automates the deployment of 'Infinite Money Glitch' offers to Whop and Mayar.
- */
-module.exports = {
-    /**
-     * Deploys a product to Whop.
-     * Whop allows full programmatic product creation.
-     */
-    deployToWhop: async (name, description, price) => {
-        if (!WHOP_API_KEY) return { success: false, error: "Missing WHOP_API_KEY" };
-
-        try {
-            console.log(`[Whop] Deploying product: ${name}`);
-            
-            // 1. Create Product
-            const productRes = await axios.post('https://api.whop.com/v1/products', {
-                name: name,
-                description: description
-            }, {
-                headers: { 'Authorization': `Bearer ${WHOP_API_KEY}` }
-            });
-
-            const productId = productRes.data.id;
-
-            // 2. Create Plan (Pricing)
-            const planRes = await axios.post(`https://api.whop.com/v1/plans`, {
-                product_id: productId,
-                name: "Standard Access",
-                price: price,
-                billing_period: "one_time"
-            }, {
-                headers: { 'Authorization': `Bearer ${WHOP_API_KEY}` }
-            });
-
-            return { 
-                success: true, 
-                url: `https://whop.com/products/${productId}`,
-                productId,
-                planId: planRes.data.id
-            };
-        } catch (error) {
-            console.error("[Whop] Deployment failed:", error.response?.data || error.message);
-            return { success: false, error: error.message };
-        }
-    },
-
-    /**
-     * Generates a Mayar Instant Payment Link.
-     * Note: Mayar dashboard is required for full product setup, 
-     * but 'Single Payment Request' works via API for instant testing.
-     */
-    deployToMayar: async (title, amount, description) => {
-        if (!MAYAR_API_KEY) return { success: false, error: "Missing MAYAR_API_KEY" };
-
-        try {
-            console.log(`[Mayar] Generating payment link for: ${title}`);
-            const response = await axios.post('https://api.mayar.id/headless/payment/create', {
-                name: title,
-                amount: amount,
-                description: description,
-                redirect_url: "https://vinos.engine/success" // Placeholder
-            }, {
-                headers: { 'Authorization': `Bearer ${MAYAR_API_KEY}` }
-            });
-
-            return { 
-                success: true, 
-                url: response.data.data.link,
-                paymentId: response.data.data.id
-            };
-        } catch (error) {
-            console.error("[Mayar] Link creation failed:", error.response?.data || error.message);
-            return { success: false, error: error.message };
-        }
-    }
-};

skills/set_telegram_menu.js

@@ -1,29 +1,33 @@
 const axios = require('axios');
+const dns = require('dns');
+const https = require('https');
 require('dotenv').config();
 
+// Force IPv4 for HF Spaces
+dns.setDefaultResultOrder('ipv4first');
+const ipv4Agent = new https.Agent({ family: 4 });
+const axiosIPv4 = axios.create({ httpsAgent: ipv4Agent });
+
 const setCommands = async () => {
     const token = process.env.TELEGRAM_BOT_TOKEN;
     const url = `https://api.telegram.org/bot${token}/setMyCommands`;
 
     const commands = [
+        { command: 'start', description: '🦍 VinOS Command Center' },
+        { command: 'gash', description: '🎨 AI Image Creator' },
+        { command: 'write', description: '📝 Write & Publish SEO Article' },
+        { command: 'seo', description: '📝 Architect SEO Strategy' },
         { command: 'mckinsey', description: '📊 Generate McKinsey PDF Report' },
-        { command: 'glitch', description: '📊 Architect an Offer' },
-        { command: 'social', description: '📊 Deep ICP Analysis' },
-        { command: 'deploy', description: '🚀 Launch Product (Whop/Mayar)' },
         { command: 'sync', description: '🚀 Push code to Cloud' },
-        { command: 'playbooks', description: '🧠 List playbooks' },
-        { command: 'recent', description: '🧠 Last 5 conversations' },
         { command: 'newskill', description: '🛠️ Auto-code an agent' },
         { command: 'agents', description: '🛠️ List active skills' },
-        { command: 'log', description: '🛠️ View version history' },
-        { command: 'seo', description: '📝 Architect SEO Strategy' },
-        { command: 'write', description: '📝 Write & Publish SEO Article' },
+        { command: 'index', description: '🔍 Submit URL to Google' },
         { command: 'updates', description: '📋 View CRM Pipeline Updates' },
         { command: 'move', description: '📋 Move a CRM card' }
     ];
 
     try {
-        const response = await axios.post(url, { commands });
+        const response = await axiosIPv4.post(url, { commands });
         console.log('✅ Telegram Menu Updated:', response.data);
     } catch (error) {
         console.error('❌ Failed to set commands:', error.response?.data || error.message);

skills/skill_creator.js

@@ -47,6 +47,20 @@ module.exports = new MySkill();
      */
     async saveSkill(skillName, code) {
         const sanitizedName = skillName.toLowerCase().replace(/[^a-z0-9_]/g, '_');
+        
+        // Safety guard: prevent overwriting core VinOS skills
+        const CORE_SKILLS = [
+            'api_caller', 'memory', 'intent_router', 'conversation_memory', 
+            'playbook_manager', 'seo_writer', 'wordpress_publisher', 'google_indexer',
+            'trello_manager', 'report_generator', 'hf_storage', 'hf_deployer',
+            'set_telegram_menu', 'skill_creator', 'voice_transcriber', 'web_researcher',
+            'github_storage', 'version_control', 'infinite_money_cron', 'quality_checker',
+            'scout_researcher', 'image_creator', 'api_cost_tracker'
+        ];
+        if (CORE_SKILLS.includes(sanitizedName)) {
+            return { success: false, error: `Cannot overwrite core skill: ${sanitizedName}` };
+        }
+        
         const filePath = path.join(this.skillsDir, `${sanitizedName}.js`);
         
         try {

skills/social_engager.js

@@ -1,43 +0,0 @@
-const axios = require('axios');
-require('dotenv').config();
-
-const APIFY_API_KEY = process.env.APIFY_API_KEY;
-
-/**
- * VinOS Social Engager Skill
- * Autonomous posting and replying for organic traffic & market verification.
- * Uses Apify's Poster Actors to bypass expensive official APIs.
- */
-module.exports = {
-    /**
-     * Posts a thread or message to X.
-     */
-    postToX: async (content) => {
-        if (!APIFY_API_KEY) return { success: false, error: "Missing APIFY_API_KEY" };
-
-        try {
-            console.log(`[Social Engager] Posting to X: ${content.substring(0, 50)}...`);
-            const response = await axios.post(`https://api.apify.com/v2/acts/apify~twitter-poster/runs?token=${APIFY_API_KEY}`, {
-                text: content
-            });
-            return { success: true, runId: response.data.data.id };
-        } catch (error) {
-            console.error("[Social Engager] X posting failed:", error.message);
-            return { success: false, error: error.message };
-        }
-    },
-
-    /**
-     * Generates a reply in a natural, slang-filled native language.
-     */
-    generateNaturalReply: async (userComment, language = 'id') => {
-        const prompt = `User comment: "${userComment}"
-        Language: ${language}
-        Task: Reply to this user to build rapport and verify their needs.
-        Persona: Human, helpful, curious, using everyday jargon and local slang. 
-        Don't sound like a bot. Keep it short (1-2 sentences).`;
-        
-        // This logic would be routed to the apiCaller.callOpenRouter in practice
-        return { success: true, prompt };
-    }
-};

skills/social_researcher.js

@@ -1,62 +0,0 @@
-const axios = require('axios');
-require('dotenv').config();
-
-const APIFY_API_KEY = process.env.APIFY_API_KEY;
-
-/**
- * VinOS Social Researcher Skill
- * Scrapes Top 30 accounts and comments to identify pain points using Design Thinking.
- */
-module.exports = {
-    /**
-     * Conducts a deep niche scan across X and YouTube.
-     */
-    researchNiche: async (niche) => {
-        if (!APIFY_API_KEY) return { success: false, error: "Missing APIFY_API_KEY" };
-
-        try {
-            console.log(`[Social Researcher] Analyzing niche: ${niche}`);
-            
-            // 1. YouTube Comments Scraper (Pain Points)
-            const ytRes = await axios.post(`https://api.apify.com/v2/acts/streamers~youtube-comment-scraper/run-sync-get-dataset-items?token=${APIFY_API_KEY}`, {
-                searchQueries: [niche],
-                maxComments: 30,
-                maxCommentsPerVideo: 10
-            });
-
-            // 2. Twitter (X) Search (Trends & ICPs)
-            const xRes = await axios.post(`https://api.apify.com/v2/acts/apidojo~twitter-scraper-lite/run-sync-get-dataset-items?token=${APIFY_API_KEY}`, {
-                searchTerms: [niche],
-                maxTweets: 20
-            });
-
-            // Combine data for LLM analysis
-            const rawData = {
-                youtube: ytRes.data.map(i => i.text),
-                twitter: xRes.data.map(i => i.full_text)
-            };
-
-            return { 
-                success: true, 
-                data: rawData,
-                summary: `Analyzed ${rawData.youtube.length} YT comments and ${rawData.twitter.length} tweets.`
-            };
-        } catch (error) {
-            console.error("[Social Researcher] Research failed:", error.response?.data || error.message);
-            return { success: false, error: error.message };
-        }
-    },
-
-    /**
-     * Formulates a Design Thinking solution based on research data.
-     */
-    formulateSolution: async (researchData) => {
-        // This is usually called as part of a prompt chain in the orchestrator
-        return {
-            empathize: "Users are frustrated with X...",
-            define: "The core problem is Y...",
-            ideate: "We should build Z...",
-            prototype: "A simple prompt-based tool..."
-        };
-    }
-};