Update Dockerfile

Dockerfile

@@ -65,7 +65,7 @@ const parseApiResponse = (data) => {
     return { answer: data, sources: [] };
 };
 
-const createPayload = (prompt, system, web, asyncMode = false) => {
+const createPayload = (prompt, system, web) => {
     const newUserMessage = { role: 'user', content: prompt, id: generateId() };
     const messagesForPayload = [newUserMessage];
 
@@ -110,13 +110,7 @@ const createPayload = (prompt, system, web, asyncMode = false) => {
         domains: null,
         vscodeClient: false,
         codeInterpreterMode: false,
-        customProfile: {
-            name: '',
-            occupation: '',
-            traits: [],
-            additionalInfo: '',
-            enableNewChats: false,
-        },
+        customProfile: { name: '', occupation: '', traits: [], additionalInfo: '', enableNewChats: false },
         webSearchModeOption,
         session: {
             user: randomUser,
@@ -124,17 +118,12 @@ const createPayload = (prompt, system, web, asyncMode = false) => {
             isNewUser: Math.random() < 0.1,
         },
         isPremium: false,
-        subscriptionCache: {
-            status: 'FREE',
-            expiryTimestamp: null,
-            lastChecked: Date.now(),
-            isTrialSubscription: false,
-        },
+        subscriptionCache: { status: 'FREE', expiryTimestamp: null, lastChecked: Date.now(), isTrialSubscription: false },
         beastMode: false,
         reasoningMode: false,
         designerMode: false,
         workspaceId: '',
-        asyncMode,
+        asyncMode: false,
         integrations: {},
         isTaskPersistent: false,
         selectedElement: null,
@@ -146,23 +135,21 @@ app.use(express.json());
 
 const chatApiUrl = 'https://www.blackbox.ai/api/chat';
 const headers = {
-    Accept: '*/*',
+    'Accept': '*/*',
     'Content-Type': 'application/json',
-    Origin: 'https://www.blackbox.ai',
-    Referer: 'https://www.blackbox.ai/',
+    'Origin': 'https://www.blackbox.ai',
+    'Referer': 'https://www.blackbox.ai/',
     'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 Safari/537.36',
 };
 
 app.post('/api/generate', async (req, res) => {
     const { prompt, system, web } = req.body;
-    if (!prompt) {
-        return res.status(400).json({ error: 'Request body harus menyertakan "prompt"' });
-    }
+    if (!prompt) return res.status(400).json({ error: 'Request body harus menyertakan "prompt"' });
+    
     try {
-        const payload = createPayload(prompt, system, web, false);
+        const payload = createPayload(prompt, system, web);
         const chatResponse = await axios.post(chatApiUrl, payload, { headers });
-        const assistantRawResponse = chatResponse.data;
-        const parsedResult = parseApiResponse(assistantRawResponse);
+        const parsedResult = parseApiResponse(chatResponse.data);
         res.send(parsedResult.answer);
     } catch (error) {
         console.error("Error pada /api/generate:", error.message);
@@ -170,36 +157,35 @@ app.post('/api/generate', async (req, res) => {
     }
 });
 
+const streamResponseByWord = async (res, text, delay = 50) => {
+    const words = text.split(' ');
+    for (const word of words) {
+        res.write(word + ' ');
+        await new Promise(resolve => setTimeout(resolve, delay));
+    }
+    res.end();
+};
+
 app.post('/api/stream', async (req, res) => {
     const { prompt, system, web } = req.body;
-    if (!prompt) {
-        return res.status(400).json({ error: 'Request body harus menyertakan "prompt"' });
-    }
+    if (!prompt) return res.status(400).json({ error: 'Request body harus menyertakan "prompt"' });
+    
     try {
-        const payload = createPayload(prompt, system, web, true);
-        const chatResponse = await axios.post(chatApiUrl, payload, {
-            headers,
-            responseType: 'stream'
-        });
+        const payload = createPayload(prompt, system, web);
+        const chatResponse = await axios.post(chatApiUrl, payload, { headers });
+        const parsedResult = parseApiResponse(chatResponse.data);
+        const fullAnswer = parsedResult.answer;
 
         res.setHeader('Content-Type', 'text/plain; charset=utf-8');
         res.setHeader('Cache-Control', 'no-cache');
         res.setHeader('Connection', 'keep-alive');
-        
-        chatResponse.data.pipe(res);
 
-        chatResponse.data.on('error', (err) => {
-            console.error("Stream error:", err.message);
-            if (!res.headersSent) {
-                res.status(500).send("Terjadi kesalahan pada stream.");
-            }
-            res.end();
-        });
+        await streamResponseByWord(res, fullAnswer);
 
     } catch (error) {
         console.error("Error pada /api/stream:", error.message);
         if (!res.headersSent) {
-            res.status(500).send("Terjadi kesalahan pada server saat memulai stream.");
+            res.status(500).send("Terjadi kesalahan pada server saat memproses permintaan.");
         }
     }
 });
@@ -208,7 +194,7 @@ app.listen(PORT, () => {
     console.log(`Server berjalan di http://localhost:${PORT}`);
     console.log('Endpoints tersedia:');
     console.log('  - POST /api/generate (non-streaming)');
-    console.log('  - POST /api/stream (streaming)');
+    console.log('  - POST /api/stream (simulated streaming)');
 });
 EOF