Create apps/trend_cat.js

apps/trend_cat.js

@@ -0,0 +1,61 @@
+import express from 'express';
+import { generateCompletion, streamCompletion } from '../ai_engine.js';
+// import { createClient } from '@supabase/supabase-js';
+
+const router = express.Router();
+
+// const supabase = createClient(process.env.SUPABASE_URL, process.env.SUPABASE_KEY);
+
+const TREND_CAT_SYSTEM_PROMPT = `You are Trend Cat, an elite TikTok and Instagram Reels growth hacker. 
+Your goal is to analyze transcripts or ideas and output highly engaging, retention-optimized video scripts.
+Always include a viral hook framework. Be engaging, witty, and format your output in clean Markdown.`;
+
+// Basic generation endpoint for Trend Cat
+router.post('/remix', async (req, res) => {
+    const { transcript, niche, model } = req.body;
+    
+    // Example: Supabase Rate Limiting / DB logic could go here
+    // const { data, error } = await supabase.from('usage_logs').insert([...]);
+
+    const prompt = `Here is a transcript of a viral video: \n"${transcript}"\n\nAnalyze why this went viral, extract the psychological hook, and rewrite a script using this exact framework for the "${niche}" niche.`;
+
+    try {
+        const result = await generateCompletion({
+            model: model || "maverick", // Defaults to cheap Maverick 17B
+            prompt: prompt,
+            system_prompt: TREND_CAT_SYSTEM_PROMPT,
+            images:[]
+        });
+        res.json(result);
+    } catch (err) {
+        console.error(`❌ [Trend Cat Generate Error]:`, err.message);
+        res.status(500).json({ success: false, error: err.message });
+    }
+});
+
+// Streaming endpoint for Trend Cat (for real-time UI typing effect)
+router.post('/stream-remix', async (req, res) => {
+    const { transcript, niche, model } = req.body;
+    const prompt = `Here is a transcript of a viral video: \n"${transcript}"\n\nRewrite this viral script for the "${niche}" niche. Provide the Hook, Body, and Call to Action.`;
+
+    res.setHeader('Content-Type', 'text/plain; charset=utf-8');
+    res.setHeader('Transfer-Encoding', 'chunked');
+    res.setHeader('X-Accel-Buffering', 'no'); 
+    res.flushHeaders();
+
+    try {
+        await streamCompletion({
+            model: model || "maverick",
+            prompt: prompt,
+            system_prompt: TREND_CAT_SYSTEM_PROMPT,
+            images:[],
+            res: res
+        });
+    } catch (err) {
+        console.error(`❌ [Trend Cat Stream Error]:`, err.message);
+        res.write(`ERROR: ${err.message}`);
+        res.end();
+    }
+});
+
+export default router;