Update server.js

server.js

@@ -82,33 +82,30 @@ app.post('/gen', async (req, res) => {
       responseType: 'stream',
     });
 
-    let fullData = '';
+    let fullContent = ''; 
+
     response.data.on('data', (chunk) => {
-      fullData += chunk.toString();
+      const chunkString = chunk.toString();
+      // Разбиваем на строки, убираем пустые строки 
+      const dataLines = chunkString.split('\n').filter(line => line.trim() !== ''); 
+      dataLines.forEach(line => {
+        try {
+          // Парсим строку как JSON
+          const jsonData = JSON.parse(line.trim().substring(6));
+          const textPart = jsonData.candidates[0].content.parts.map(part => part.text).join('');
+          fullContent += textPart; 
+        } catch (error) {
+          console.error('Ошибка парсинга фрагмента:', error, line); // Выводим строку для отладки
+        }
+      });
     });
 
     await new Promise((resolve) => {
       response.data.on('end', () => {
+        res.json({ content: fullContent });
         resolve();
       });
     });
-
-    const jsonData = JSON.parse(fullData); 
-    res.json({ content: jsonData.candidates[0].content.parts.map(part => part.text).join('') });
-    
-/*
-    if (response.data.choices && response.data.choices.length > 0 && response.data.choices[0].message) {
-      console.log(response.data);
-      
-      const content = JSON.parse(response.data);
-      res.json({ content: content.candidates[0].content.parts.map(part => part.text).join('') });
-    
-    } else {
-      const content = response.data;
-      console.log(content);
-      res.json({ content: '+ошибка+❌ Не удалось прочитать ответ.-ошибка-' });
-    }
-*/
   } catch (error) {
     console.error(error);
     res.json({ content: '+ошибка+❌ Произошла ошибка сервера при генерации.-ошибка-' });