Upload index.js

index.js

@@ -2,7 +2,7 @@ import express from 'express';
 import multer from 'multer';
 import { spawn } from 'child_process';
 import { writeFile, unlink } from 'fs/promises';
-import { createReadStream } from 'fs'; // <<< ИСПРАВЛЕНИЕ: Правильный импорт
+import { createReadStream } from 'fs';
 import path from 'path';
 import { v4 as uuidv4 } from 'uuid';
 import fetch from 'node-fetch';
@@ -30,19 +30,19 @@ const downloadFile = async (url) => {
 };
 
 
-// --- СТАРЫЙ ЭНДПОИНТ ДЛЯ ПОТОКОВОЙ ОБРАБОТКИ (ВОЗВРАЩЕН) ---
+// --- ЭНДПОИНТ ДЛЯ ПОТОКОВОЙ ОБРАБОТКИ (ИСПРАВЛЕН) ---
 app.post('/api/run/stream', upload.single('file'), async (req, res) => {
     try {
         const { command, args: argsJson, file_url } = req.body;
         const file = req.file;
 
-        if (!command) return res.status(400).send({ error: 'Parameter "command" is required.' });
+        if (!command) return res.status(400).json({ error: 'Parameter "command" is required.' });
         
         let args;
         try {
            args = argsJson ? JSON.parse(argsJson) : [];
         } catch(e) {
-           return res.status(400).send({ error: 'Parameter "args" must be a valid JSON array.' });
+           return res.status(400).json({ error: 'Parameter "args" must be a valid JSON array.' });
         }
 
         let inputBuffer;
@@ -51,22 +51,35 @@ app.post('/api/run/stream', upload.single('file'), async (req, res) => {
         } else if (file_url) {
             inputBuffer = await downloadFile(file_url);
         } else {
-            return res.status(400).send({ error: 'A file must be provided via "file" or "file_url".' });
+            return res.status(400).json({ error: 'A file must be provided via "file" or "file_url".' });
         }
         
         const process = spawn(command, args);
+        
         let stdoutChunks = [];
+        let stderrChunks = []; // <<< ДОБАВЛЕНО: Сбор ошибок
         
         process.stdout.on('data', (data) => stdoutChunks.push(data));
+        process.stderr.on('data', (data) => stderrChunks.push(data)); // <<< ДОБАВЛЕНО: Слушаем stderr
+
+        process.on('error', (err) => { // <<< ДОБАВЛЕНО: Обработка ошибок запуска
+             res.status(500).json({
+                error: 'Failed to start command.',
+                message: err.message
+            });
+        });
         
         process.on('close', (code) => {
             if (code === 0) {
                 res.setHeader('Content-Type', 'application/octet-stream');
                 res.send(Buffer.concat(stdoutChunks));
             } else {
-                res.status(500).send({
+                // <<< ИЗМЕНЕНО: Отправляем подробную ошибку
+                const stderr = Buffer.concat(stderrChunks).toString('utf8');
+                res.status(500).json({
                     error: 'Command execution failed.',
-                    code: code
+                    code: code,
+                    stderr: stderr 
                 });
             }
         });
@@ -75,7 +88,7 @@ app.post('/api/run/stream', upload.single('file'), async (req, res) => {
         process.stdin.end();
 
     } catch (error) {
-        res.status(500).send({
+        res.status(500).json({
             error: 'Server error during stream processing.',
             message: error.message
         });
@@ -83,7 +96,7 @@ app.post('/api/run/stream', upload.single('file'), async (req, res) => {
 });
 
 
-// --- НОВАЯ СИСТЕМА АСИНХРОННЫХ ЗАДАЧ ---
+// --- СИСТЕМА АСИНХРОННЫХ ЗАДАЧ ---
 
 const executeTask = async (taskId) => {
     const task = tasks[taskId];
@@ -266,7 +279,6 @@ app.get('/api/download/:fileId', (req, res) => {
 
     const filePath = path.join(TEMP_DIR, fileId);
     
-    // ИСПРАВЛЕНИЕ: Используем createReadStream без промиса
     const stream = createReadStream(filePath);
     stream.on('error', (err) => {
         if (err.code === 'ENOENT') {