Update genisi.js

genisi.js

@@ -11,10 +11,8 @@ app.use(cors());
 app.use(express.json());
 app.use(express.static(__dirname));
 
-// ✅ نموذج واحد فقط: kimi-k2.5-fw بدون تفكير
-const MODEL = "glm-5-fwai";
-
-app.post('/api/chat', async (req, res) => {
+// ✅ وضع المفكر: Kimi مع إظهار التفكير
+app.post('/api/think', async (req, res) => {
     const { message } = req.body;
     const POE_KEY = process.env.POE_API_KEY;
 
@@ -22,10 +20,8 @@ app.post('/api/chat', async (req, res) => {
         return res.status(401).json({ error: "POE_API_KEY غير موجود" });
     }
 
-    // إعداد Streaming
     res.setHeader('Content-Type', 'text/event-stream');
     res.setHeader('Cache-Control', 'no-cache');
-    res.setHeader('Connection', 'keep-alive');
 
     const client = new OpenAI({
         apiKey: POE_KEY,
@@ -33,20 +29,20 @@ app.post('/api/chat', async (req, res) => {
     });
 
     try {
+        // إرسال إشارة بدء التفكير أولاً
+        res.write(`data: ${JSON.stringify({ status: "thinking" })}\n\n`);
+
         const stream = await client.chat.completions.create({
-            model: MODEL,  // ✅ نموذج واحد فقط
+            model: "kimi-k2.5-fw",  // النموذج المفكر
             messages: [{ role: "user", content: message }],
             stream: true,
-            temperature: 0.7,
-            // ⛔ تعطيل التفكير بكل الطرق الممكنة
-            extra_body: {
-                reasoning: false,
-                thinking_budget: 0,
-                reasoning_effort: "none",
-                disable_thinking: true  // محاولة إضافية خاصة بـ kimi
-            }
+            temperature: 0.7
+            // لا نحاول تعطيل التفكير هنا - نتركه يفكر
         });
 
+        // إرسال إشارة بدء الرد الفعلي
+        res.write(`data: ${JSON.stringify({ status: "responding" })}\n\n`);
+
         for await (const chunk of stream) {
             const content = chunk.choices[0]?.delta?.content || "";
             if (content) {
@@ -58,11 +54,8 @@ app.post('/api/chat', async (req, res) => {
         res.end();
 
     } catch (err) {
-        console.error("Error:", err);
-        if (!res.writableEnded) {
-            res.write(`data: ${JSON.stringify({ error: err.message })}\n\n`);
-            res.end();
-        }
+        res.write(`data: ${JSON.stringify({ error: err.message })}\n\n`);
+        res.end();
     }
 });
 
@@ -70,12 +63,5 @@ app.get('/', (req, res) => res.sendFile(path.join(__dirname, 'index.html')));
 
 const PORT = process.env.PORT || 7860;
 app.listen(PORT, () => {
-    console.log(`
-    🚀 Kimi K2.5 FW (No Thinking Mode)
-    ----------------------------------
-    Model: ${MODEL}
-    Reasoning: DISABLED (Forced)
-    Port: ${PORT}
-    ----------------------------------
-    `);
+    console.log(`🚀 Server: Think Mode (Kimi) active on port ${PORT}`);
 });