Rename genisi.js to server.js

genisi.js

@@ -1,155 +0,0 @@
-import express from 'express';
-import cors from 'cors';
-import { OpenAI } from "openai";
-import fetch from 'node-fetch';
-import path from 'path';
-import { fileURLToPath } from 'url';
-
-const __dirname = path.dirname(fileURLToPath(import.meta.url));
-const app = express();
-
-app.use(cors());
-app.use(express.json());
-app.use(express.static(__dirname));
-
-// ⚡ الوضع السريع: Chat Completions (بدون reasoning)
-app.post('/api/fast', async (req, res) => {
-    const { message } = req.body;
-    
-    res.setHeader('Content-Type', 'text/event-stream');
-    res.setHeader('Cache-Control', 'no-cache');
-    
-    const client = new OpenAI({
-        apiKey: process.env.POE_API_KEY,
-        baseURL: "https://api.poe.com/v1"
-    });
-    
-    try {
-        // استخدام Chat Completions للسرعة (GPT-5.4 أو Gemini أو Claude بدون reasoning)
-        const stream = await client.chat.completions.create({
-            model: "kimi-k2.5-fw",  // أو "Gemini-3.1-Pro" - سريع ولا يفكر طويلاً
-            messages: [{ role: "user", content: message }],
-            stream: true,
-            temperature: 0.7
-        });
-        
-        for await (const chunk of stream) {
-            const content = chunk.choices[0]?.delta?.content || "";
-            if (content) {
-                res.write(`data: ${JSON.stringify({ type: 'content', content })}\n\n`);
-            }
-        }
-        
-        res.write('data: [DONE]\n\n');
-        res.end();
-        
-    } catch (err) {
-        // Fallback إلى Pollinations
-        try {
-            const pollRes = await fetch('https://text.pollinations.ai/' + encodeURIComponent(message));
-            const text = await pollRes.text();
-            const chars = text.split('');
-            for (let i = 0; i < chars.length; i += 3) {
-                res.write(`data: ${JSON.stringify({ type: 'content', content: chars.slice(i, i+3).join('') })}\n\n`);
-                await new Promise(r => setTimeout(r, 10));
-            }
-            res.write('data: [DONE]\n\n');
-            res.end();
-        } catch {
-            res.write(`data: ${JSON.stringify({ type: 'error', error: err.message })}\n\n`);
-            res.end();
-        }
-    }
-});
-
-// 🧠 الوضع المفكر: Responses API (مع reasoning حقيقي)
-app.post('/api/think', async (req, res) => {
-    const { message } = req.body;
-    const POE_KEY = process.env.POE_API_KEY;
-
-    if (!POE_KEY) return res.status(401).json({ error: "POE_API_KEY missing" });
-
-    res.setHeader('Content-Type', 'text/event-stream');
-    res.setHeader('Cache-Control', 'no-cache');
-
-    const client = new OpenAI({
-        apiKey: POE_KEY,
-        baseURL: "https://api.poe.com/v1"
-    });
-
-    try {
-        // ✅ إشارة بدء التفكير (محاكاة UI)
-        res.write(`data: ${JSON.stringify({ type: 'status', status: 'reasoning' })}\n\n`);
-        
-        // ✅ استخدام Responses API (وليس Chat Completions) للـ Reasoning
-        const stream = await client.responses.create({
-            model: "kimi-k2.5-fw",  // ✅ يدعم reasoning حسب التوثيق
-            input: message,              // ملاحظة: "input" وليس "messages"
-            stream: true,
-            reasoning: false,
-            temperature: 0.7
-        });
-        
-        // إشالة بدء الرد الفعلي
-        res.write(`data: ${JSON.stringify({ type: 'status', status: 'responding' })}\n\n`);
-        
-        // استلام الرد (output_text في Responses API)
-        for await (const chunk of stream) {
-            // في Responses API، المحتوى يأتي بشكل مختلف قليلاً
-            const content = chunk.output_text || chunk.delta?.content || "";
-            if (content) {
-                res.write(`data: ${JSON.stringify({ type: 'content', content })}\n\n`);
-            }
-        }
-
-        res.write('data: [DONE]\n\n');
-        res.end();
-        
-    } catch (err) {
-        // إذا فشل Claude، نرجع إلى Chat Completions العادي مع محاكاة التفكير
-        console.error("Responses API Error:", err);
-        
-        try {
-            res.write(`data: ${JSON.stringify({ type: 'status', status: 'reasoning_fallback' })}\n\n`);
-            
-            const stream = await client.chat.completions.create({
-                model: "kimi-k2.5-fw",  // الرجوع إلى kimi بدون reasoning parameter
-                messages: [{ 
-                    role: "user", 
-                    content: `اشرح خطوات تفكيرك بالتفصيل ثم أعطِ الإجابة النهائية: ${message}`
-                }],
-                stream: true
-            });
-            
-            res.write(`data: ${JSON.stringify({ type: 'status', status: 'responding' })}\n\n`);
-            
-            for await (const chunk of stream) {
-                const content = chunk.choices[0]?.delta?.content || "";
-                if (content) {
-                    res.write(`data: ${JSON.stringify({ type: 'content', content })}\n\n`);
-                }
-            }
-            
-            res.write('data: [DONE]\n\n');
-            res.end();
-            
-        } catch (fallbackErr) {
-            res.write(`data: ${JSON.stringify({ type: 'error', error: fallbackErr.message })}\n\n`);
-            res.end();
-        }
-    }
-});
-
-app.get('/', (req, res) => res.sendFile(path.join(__dirname, 'index.html')));
-
-const PORT = process.env.PORT || 7860;
-app.listen(PORT, () => {
-    console.log(`
-    ✅ Poe API - Correct Implementation
-    ----------------------------------
-    ⚡ Fast: Chat Completions (GPT-5.4)
-    🧠 Think: Responses API (Claude + reasoning)
-    Docs: OpenAI Compatible API
-    ----------------------------------
-    `);
-});

server.js

@@ -0,0 +1,187 @@
+import express from 'express';
+import { Client } from '@gradio/client';
+import cors from 'cors';
+import dotenv from 'dotenv';
+
+dotenv.config();
+
+const app = express();
+const PORT = process.env.PORT || 3000;
+
+app.use(cors());
+app.use(express.json());
+app.use(express.static('public'));
+
+// إعدادات النموذج
+const MODEL_CONFIGS = {
+    flash: {
+        temperature: 1.0,
+        top_p: 0.95,
+        max_tokens: 2048,
+        system_message: "أنت مساعد ودود وسريع. اسمك MiniMax-M2.5. قدم إجابات مباشرة وواضحة. عندما تريد التفكير في مشكلة معقدة، استخدم علامة 'genisi thought' ثم اكتب تفكيرك، ثم أغلق العلامة.",
+        description: "وضع الفلاش - سريع ومناسب للمحادثات العامة"
+    },
+    pro: {
+        temperature: 0.7,
+        top_p: 0.9,
+        max_tokens: 4096,
+        system_message: "أنت مساعد خبير ومحلل عميق. اسمك MiniMax-M2.5-Pro. استخدم علامة 'genisi thought' لتحليل المشكلات بعمق قبل الإجابة. قدم حلولاً متقدمة ومفصلة مع أمثلة عملية. فكر خطوة بخطوة باستخدام genisi thought ثم قدم الإجابة النهائية.",
+        description: "وضع البرو - تحليل عميق وتفكير متقدم"
+    }
+};
+
+let currentMode = 'flash';
+
+// الاتصال بالنموذج
+let client = null;
+
+async function initClient() {
+    try {
+        client = await Client.connect("ostarling/MiniMax-M2.5-Chat");
+        console.log('✅ تم الاتصال بـ MiniMax M2.5 بنجاح');
+    } catch (error) {
+        console.error('❌ فشل الاتصال:', error);
+    }
+}
+
+// دالة لإرسال الرسالة للنموذج
+async function sendToModel(message, mode) {
+    const config = MODEL_CONFIGS[mode];
+    
+    try {
+        if (!client) {
+            await initClient();
+        }
+        
+        // إضافة إرشادات للتفكير بناءً على الوضع
+        let enhancedMessage = message;
+        if (mode === 'pro') {
+            enhancedMessage = `استخدم تحليل genisi thought قبل الإجابة: ${message}`;
+        }
+        
+        const result = await client.predict("/respond", {
+            message: enhancedMessage,
+            system_message: config.system_message,
+            max_tokens: config.max_tokens,
+            temperature: config.temperature,
+            top_p: config.top_p
+        });
+        
+        return result.data;
+    } catch (error) {
+        console.error('خطأ في الاتصال:', error);
+        throw error;
+    }
+}
+
+// دالة لتحليل نص الرد واستخراج أجزاء التفكير
+function parseResponse(text) {
+    const thoughtRegex = /genisi thought\s*([\s\S]*?)(?=genisi thought|$)/gi;
+    const parts = [];
+    let lastIndex = 0;
+    let match;
+    
+    while ((match = thoughtRegex.exec(text)) !== null) {
+        // النص قبل التفكير
+        if (match.index > lastIndex) {
+            parts.push({
+                type: 'text',
+                content: text.substring(lastIndex, match.index).trim()
+            });
+        }
+        
+        // محتوى التفكير
+        parts.push({
+            type: 'thought',
+            content: match[1].trim()
+        });
+        
+        lastIndex = match.index + match[0].length;
+    }
+    
+    // باقي النص بعد آخر تفكير
+    if (lastIndex < text.length) {
+        parts.push({
+            type: 'text',
+            content: text.substring(lastIndex).trim()
+        });
+    }
+    
+    // إذا لم يتم العثور على أي تفكير
+    if (parts.length === 0) {
+        parts.push({
+            type: 'text',
+            content: text
+        });
+    }
+    
+    return parts;
+}
+
+// API endpoint للدردشة
+app.post('/api/chat', async (req, res) => {
+    const { message, mode } = req.body;
+    
+    if (!message) {
+        return res.status(400).json({ error: 'الرسالة مطلوبة' });
+    }
+    
+    if (mode) {
+        currentMode = mode;
+    }
+    
+    try {
+        const response = await sendToModel(message, currentMode);
+        const modelResponse = response[0] || response;
+        
+        // تحليل الرد لاستخراج أجزاء التفكير
+        const parsedResponse = parseResponse(modelResponse);
+        
+        res.json({
+            success: true,
+            response: parsedResponse,
+            mode: currentMode,
+            rawResponse: modelResponse
+        });
+    } catch (error) {
+        res.status(500).json({
+            success: false,
+            error: error.message
+        });
+    }
+});
+
+// API endpoint لتغيير الوضع
+app.post('/api/mode', (req, res) => {
+    const { mode } = req.body;
+    if (mode === 'flash' || mode === 'pro') {
+        currentMode = mode;
+        res.json({
+            success: true,
+            mode: currentMode,
+            config: MODEL_CONFIGS[mode]
+        });
+    } else {
+        res.status(400).json({ error: 'وضع غير صالح' });
+    }
+});
+
+// API endpoint للحصول على الوضع الحالي
+app.get('/api/mode', (req, res) => {
+    res.json({
+        mode: currentMode,
+        config: MODEL_CONFIGS[currentMode]
+    });
+});
+
+// بدء الخادم
+async function startServer() {
+    await initClient();
+    app.listen(PORT, () => {
+        console.log(`🚀 الخادم يعمل على http://localhost:${PORT}`);
+        console.log(`📌 الوضع الحالي: ${currentMode}`);
+        console.log(`⚙️  إعدادات: ${MODEL_CONFIGS[currentMode].description}`);
+    });
+}
+
+startServer();