Upload 2 files

README.md

@@ -1,5 +1,5 @@
 ---
-title: FFMpeg Command Runner
+title: Async Command Runner
 emoji: 🏃
 colorFrom: indigo
 colorTo: blue
@@ -7,20 +7,34 @@ sdk: docker
 pinned: false
 ---
 
-# API для асинхронного выполнения команд
+# API для выполнения команд
 
-Это API позволяет удаленно выполнять консольные команды в асинхронном режиме. Вы отправляете задачу и получаете ее ID, после чего можете отслеживать статус выполнения.
+Это API позволяет удаленно выполнять консольные команды. Поддерживается два режима:
 
-## Новый процесс работы
+1.  **Потоковый (Stream)**: Быстрая обработка "на лету" для простых команд.
+2.  **Асинхронные задачи (Tasks)**: Для длительных операций, с возможностью отслеживания прогресса.
 
-Процесс теперь состоит из 3 шагов:
+---
+
+## Режим 1: Потоковая обработка
 
-### Шаг 1: Создание задачи
+Идеально для быстрых команд. Файл передается в `stdin` команды, а результат из `stdout` возвращается клиенту. Файлы не сохраняются на диске.
 
-Отправьте POST-запрос на `/api/task/create`. Сервер примет файл, создаст задачу и немедленно вернет ответ.
+**Эндпоинт:** `POST /api/run/stream`
 
 **Пример `curl`:**
 ```bash
+curl -X POST 'https://<your-space-url>/api/run/stream' \
+-F 'file=@/path/to/your/image.jpg' \
+-F 'command=magick' \
+-F 'args=["convert", "-", "-grayscale", "average", "jpg:-"]' \
+--output grayscale_image.jpg
+
+Режим 2: Асинхронные задачи
+Используйте, когда команде нужно работать с файлами на диске или когда результат нужно сохранить.
+Шаг 1: Создание задачи
+Эндпоинт: POST /api/task/create
+Пример curl:
 curl -X POST 'https://<your-space-url>/api/task/create' \
 -F 'command=ffmpeg' \
 -F 'args=["-i", "{INPUT_FILE}", "-vcodec", "libx264", "-acodec", "aac", "{OUTPUT_FILE}"]' \
@@ -34,24 +48,11 @@ curl -X POST 'https://<your-space-url>/api/task/create' \
     "status_url": "/api/task/status/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx"
 }
 
-Сохраните taskId для следующего шага.
 Шаг 2: Проверка статуса задачи
-Отправляйте GET-запросы на эндпоинт status_url, полученный на предыдущем шаге, чтобы отслеживать выполнение.
-Пример curl:
-curl 'https://<your-space-url>/api/task/status/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx'
-
-Возможные ответы:
- * Задача в очереди или обрабатывается:
-   {
-    "id": "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
-    "status": "processing",
-    "elapsedTimeSeconds": 15,
-    "progress": 25,
-    "estimatedTimeLeftSeconds": 45
-}
-
- * Задача успешно завершена:
-   {
+Эндпоинт: GET /api/task/status/:taskId
+Отправляйте GET-запросы на status_url, чтобы отслеживать выполнение.
+Пример ответа (завершено):
+{
     "id": "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
     "status": "completed",
     "elapsedTimeSeconds": 60,
@@ -60,24 +61,10 @@ curl 'https://<your-space-url>/api/task/status/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxx
     }
 }
 
- * Задача завершилась с ошибкой:
-   {
-    "id": "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
-    "status": "failed",
-    "elapsedTimeSeconds": 10,
-    "error": {
-        "message": "Process exited with code 1",
-        "code": 1
-    }
-}
-
 Шаг 3: Скачивание результата
-Когда задача получает статус completed, используйте download_url из ответа для скачивания готового файла.
-Пример curl:
-# Используйте download_url из успешного ответа на Шаге 2
+Когда задача получает статус completed, используйте download_url для скачивания файла.
+Эндпоинт: GET /api/download/:fileId
 curl 'https://<your-space-url>/api/download/yyyyyyyy-yyyy-yyyy-yyyy-yyyyyyyyyyyy-converted.mp4' \
 --output "final_video.mp4"
 
-Этот новый подход более надежен для длительных операций и дает вам полный контроль над отслеживанием процесса.
-
 

index.js

@@ -1,7 +1,8 @@
 import express from 'express';
 import multer from 'multer';
 import { spawn } from 'child_process';
-import { writeFile, unlink, createReadStream } from 'fs/promises';
+import { writeFile, unlink } from 'fs/promises';
+import { createReadStream } from 'fs'; // <<< ИСПРАВЛЕНИЕ: Правильный импорт
 import path from 'path';
 import { v4 as uuidv4 } from 'uuid';
 import fetch from 'node-fetch';
@@ -28,6 +29,62 @@ const downloadFile = async (url) => {
     return Buffer.from(arrayBuffer);
 };
 
+
+// --- СТАРЫЙ ЭНДПОИНТ ДЛЯ ПОТОКОВОЙ ОБРАБОТКИ (ВОЗВРАЩЕН) ---
+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.' });
+        
+        let args;
+        try {
+           args = argsJson ? JSON.parse(argsJson) : [];
+        } catch(e) {
+           return res.status(400).send({ error: 'Parameter "args" must be a valid JSON array.' });
+        }
+
+        let inputBuffer;
+        if (file) {
+            inputBuffer = file.buffer;
+        } 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".' });
+        }
+        
+        const process = spawn(command, args);
+        let stdoutChunks = [];
+        
+        process.stdout.on('data', (data) => stdoutChunks.push(data));
+        
+        process.on('close', (code) => {
+            if (code === 0) {
+                res.setHeader('Content-Type', 'application/octet-stream');
+                res.send(Buffer.concat(stdoutChunks));
+            } else {
+                res.status(500).send({
+                    error: 'Command execution failed.',
+                    code: code
+                });
+            }
+        });
+        
+        process.stdin.write(inputBuffer);
+        process.stdin.end();
+
+    } catch (error) {
+        res.status(500).send({
+            error: 'Server error during stream processing.',
+            message: error.message
+        });
+    }
+});
+
+
+// --- НОВАЯ СИСТЕМА АСИНХРОННЫХ ЗАДАЧ ---
+
 const executeTask = async (taskId) => {
     const task = tasks[taskId];
     const { command, args, inputBuffer, outputFilename } = task.payload;
@@ -178,8 +235,7 @@ app.get('/api/task/status/:taskId', (req, res) => {
     };
 
     if (task.startTime) {
-        const
-         endTime = task.endTime || Date.now();
+        const endTime = task.endTime || Date.now();
         response.elapsedTimeSeconds = Math.round((endTime - task.startTime) / 1000);
     }
 
@@ -199,9 +255,6 @@ app.get('/api/task/status/:taskId', (req, res) => {
         response.error = task.error;
     }
     
-    // For debugging, optionally include stderr
-    // response.stderr = task.stderr;
-
     res.status(200).json(response);
 });
 
@@ -212,19 +265,18 @@ app.get('/api/download/:fileId', (req, res) => {
     }
 
     const filePath = path.join(TEMP_DIR, fileId);
-
-    createReadStream(filePath)
-        .then(stream => {
-            res.setHeader('Content-Type', 'application/octet-stream');
-            stream.pipe(res);
-        })
-        .catch(err => {
-            if (err.code === 'ENOENT') {
-                res.status(404).send('File not found or has been cleaned up.');
-            } else {
-                res.status(500).send('Server error.');
-            }
-        });
+    
+    // ИСПРАВЛЕНИЕ: Используем createReadStream без промиса
+    const stream = createReadStream(filePath);
+    stream.on('error', (err) => {
+        if (err.code === 'ENOENT') {
+            res.status(404).send('File not found or has been cleaned up.');
+        } else {
+            res.status(500).send('Server error.');
+        }
+    });
+    res.setHeader('Content-Type', 'application/octet-stream');
+    stream.pipe(res);
 });
 
 app.listen(PORT, () => {