Update genisi.js

genisi.js

@@ -1,7 +1,6 @@
 import express from 'express';
 import cors from 'cors';
 import { OpenAI } from "openai";
-import fetch from 'node-fetch';  // أو fetch الأصلي في Node 18+
 import path from 'path';
 import { fileURLToPath } from 'url';
 
@@ -12,58 +11,7 @@ app.use(cors());
 app.use(express.json());
 app.use(express.static(__dirname));
 
-// ✅ الوضع السريع: MiniMax عبر Hugging Face Inference API (بدون @gradio/client)
-app.post('/api/fast', async (req, res) => {
-    const { message } = req.body;
-    
-    try {
-        // استدعاء مباشر لـ Hugging Face Space API
-        const response = await fetch('https://ostarling-minimax-m2-5-chat.hf.space/api/predict', {
-            method: 'POST',
-            headers: {
-                'Content-Type': 'application/json',
-                // إذا احتجت token لاحقاً: 'Authorization': 'Bearer hf_...'
-            },
-            body: JSON.stringify({
-                fn_index: 0,  // عادةً 0 للدالة الأولى
-                data: [
-                    message,                                    // message
-                    "You are a helpful assistant.",            // system_message
-                    2048,                                       // max_tokens
-                    0.7,                                        // temperature
-                    0.95                                        // top_p
-                ]
-            })
-        });
-        
-        if (!response.ok) throw new Error(`HTTP ${response.status}`);
-        
-        const result = await response.json();
-        // result.data يحتوي على الرد
-        
-        res.json({ 
-            success: true,
-            content: result.data?.[0] || result.data || "لا يوجد رد",
-            model: "MiniMax-M2.5-Chat (HF)"
-        });
-        
-    } catch (err) {
-        console.error('HF Error:', err);
-        // fallback: استخدام pollinations مباشرة
-        try {
-            const pollRes = await fetch('https://text.pollinations.ai/' + encodeURIComponent(message));
-            const text = await pollRes.text();
-            res.json({ success: true, content: text, model: "Pollinations (Fallback)" });
-        } catch (pollErr) {
-            res.status(500).json({ 
-                success: false,
-                error: "فشل الاتصال: " + err.message 
-            });
-        }
-    }
-});
-
-// ✅ الوضع المفكر: Kimi (كما هو)
+// ✅ Kimi مع دعم Reasoning المنفصل
 app.post('/api/think', async (req, res) => {
     const { message } = req.body;
     const POE_KEY = process.env.POE_API_KEY;
@@ -72,32 +20,101 @@ app.post('/api/think', async (req, res) => {
 
     res.setHeader('Content-Type', 'text/event-stream');
     res.setHeader('Cache-Control', 'no-cache');
+    res.setHeader('Connection', 'keep-alive');
 
-    const poeClient = new OpenAI({
+    const client = new OpenAI({
         apiKey: POE_KEY,
         baseURL: "https://api.poe.com/v1"
     });
 
     try {
-        res.write(`data: ${JSON.stringify({ status: "thinking" })}\n\n`);
-        
-        const stream = await poeClient.chat.completions.create({
-            model: "kimi-k2.5-fw",
+        // إشارة بدء التفكير
+        res.write(`data: ${JSON.stringify({ type: 'status', status: 'reasoning' })}\n\n`);
+
+        const stream = await client.chat.completions.create({
+            model: "kimi-k2.5-fw",  // النموذج المفكر إجبارياً
             messages: [{ role: "user", content: message }],
-            stream: true
+            stream: true,
+            // محاولة طلب Reasoning منفصل (إن دعمته Poe لاحقاً)
+            extra_body: {
+                show_reasoning: true
+            }
         });
 
-        res.write(`data: ${JSON.stringify({ status: "responding" })}\n\n`);
+        let reasoningBuffer = "";
+        let isReasoningPhase = true;
+        let contentBuffer = "";
 
         for await (const chunk of stream) {
-            const content = chunk.choices[0]?.delta?.content || "";
-            if (content) res.write(`data: ${JSON.stringify({ content })}\n\n`);
+            const delta = chunk.choices[0]?.delta;
+            const content = delta?.content || "";
+            
+            // ✅ محاولة استخراج Reasoning إن وُجد (OpenAI o1-style أو أTag)
+            if (delta?.reasoning && isReasoningPhase) {
+                res.write(`data: ${JSON.stringify({ type: 'reasoning', content: delta.reasoning })}\n\n`);
+            } 
+            // ✅ إذا لم يوجد حقل منفصل، نفترض أن البداية هي التفكير ( heuristic )
+            else if (content) {
+                // نبحث عن علامة نهاية التفكير (إذا كان النموذج يستخدم <thinking> أو ---)
+                if (isReasoningPhase && (content.includes('</thinking>') || content.includes('\n\n**Answer:**'))) {
+                    isReasoningPhase = false;
+                    // إرسال ما سبق كتفكير
+                    if (reasoningBuffer) {
+                        res.write(`data: ${JSON.stringify({ type: 'reasoning_end' })}\n\n`);
+                    }
+                }
+                
+                if (isReasoningPhase) {
+                    reasoningBuffer += content;
+                    res.write(`data: ${JSON.stringify({ type: 'reasoning', content })}\n\n`);
+                } else {
+                    res.write(`data: ${JSON.stringify({ type: 'content', content })}\n\n`);
+                }
+            }
         }
 
         res.write('data: [DONE]\n\n');
         res.end();
+
+    } catch (err) {
+        res.write(`data: ${JSON.stringify({ type: 'error', error: err.message })}\n\n`);
+        res.end();
+    }
+});
+
+// ⚡ الوضع السريع: MiniMax (بدون تفكير معقد)
+app.post('/api/fast', async (req, res) => {
+    const { message } = req.body;
+    
+    res.setHeader('Content-Type', 'text/event-stream');
+    res.setHeader('Cache-Control', 'no-cache');
+    
+    try {
+        const response = await fetch('https://ostarling-minimax-m2-5-chat.hf.space/api/predict', {
+            method: 'POST',
+            headers: { 'Content-Type': 'application/json' },
+            body: JSON.stringify({
+                fn_index: 0,
+                data: [message, "You are helpful", 1024, 0.7, 0.95]
+            })
+        });
+        
+        const result = await response.json();
+        const text = result.data?.[0] || "";
+        
+        // محاكاة Streaming للنص الكامل
+        const chars = text.split('');
+        for (let i = 0; i < chars.length; i += 2) {
+            const chunk = chars.slice(i, i + 2).join('');
+            res.write(`data: ${JSON.stringify({ type: 'content', content: chunk })}\n\n`);
+            await new Promise(r => setTimeout(r, 10));
+        }
+        
+        res.write('data: [DONE]\n\n');
+        res.end();
+        
     } catch (err) {
-        res.write(`data: ${JSON.stringify({ error: err.message })}\n\n`);
+        res.write(`data: ${JSON.stringify({ type: 'error', error: err.message })}\n\n`);
         res.end();
     }
 });
@@ -106,12 +123,5 @@ app.get('/', (req, res) => res.sendFile(path.join(__dirname, 'index.html')));
 
 const PORT = process.env.PORT || 7860;
 app.listen(PORT, () => {
-    console.log(`
-    ✅ Server Ready (No @gradio/client needed)
-    -------------------------------------------
-    ⚡ Fast:  MiniMax (HF API) or Pollinations
-    🧠 Think: Kimi K2.5 FW (Poe API)
-    Port: ${PORT}
-    -------------------------------------------
-    `);
+    console.log(`🧠 Server: Kimi Reasoning Mode | Port ${PORT}`);
 });