import assert from 'node:assert'; import BoxError from '../boxerror.js'; import { HttpError } from '@cloudron/connect-lastmile'; import { HttpSuccess } from '@cloudron/connect-lastmile'; import safe from 'safetydance'; import tasks from '../tasks.js'; async function load(req, res, next) { assert.strictEqual(typeof req.params.taskId, 'string'); const [error, result] = await safe(tasks.get(req.params.taskId)); if (error) return next(BoxError.toHttpError(error)); if (!result) return next(new HttpError(404, 'Task not found')); req.resources.task = result; next(); } async function get(req, res, next) { assert.strictEqual(typeof req.params.taskId, 'string'); next(new HttpSuccess(200, tasks.removePrivateFields(req.resources.task))); } async function list(req, res, next) { const page = typeof req.query.page === 'string' ? parseInt(req.query.page) : 1; if (!page || page < 0) return next(new HttpError(400, 'page query param has to be a postive number')); const perPage = typeof req.query.per_page === 'string'? parseInt(req.query.per_page) : 25; if (!perPage || perPage < 0) return next(new HttpError(400, 'per_page query param has to be a postive number')); if ('type' in req.query && typeof req.query.type !== 'string') return next(new HttpError(400, 'type must be a string')); const [error, result] = await safe(tasks.list(page, perPage, { type: req.query.type || null })); if (error) return next(BoxError.toHttpError(error)); next(new HttpSuccess(200, { tasks: result.map(tasks.removePrivateFields) })); } async function stopTask(req, res, next) { assert.strictEqual(typeof req.resources.task, 'object'); const [error] = await safe(tasks.stopTask(req.resources.task.id)); if (error) return next(BoxError.toHttpError(error)); next(new HttpSuccess(204, {})); } async function getLogs(req, res, next) { assert.strictEqual(typeof req.resources.task, 'object'); const lines = typeof req.query.lines === 'string' ? parseInt(req.query.lines, 10) : 10; // we ignore last-event-id if (isNaN(lines)) return next(new HttpError(400, 'lines must be a number')); const options = { lines: lines, follow: false, format: typeof req.query.format === 'string' ? req.query.format : 'json' }; const [error, logStream] = await safe(tasks.getLogs(req.resources.task, options)); if (error) return next(BoxError.toHttpError(error)); res.writeHead(200, { 'Content-Type': 'application/x-logs', 'Content-Disposition': `attachment; filename="task-${req.resources.task.id}.log"`, 'Cache-Control': 'no-cache', 'X-Accel-Buffering': 'no' // disable nginx buffering }); res.on('close', () => logStream.destroy()); logStream.pipe(res); } // this route is for streaming logs async function getLogStream(req, res, next) { assert.strictEqual(typeof req.resources.task, 'object'); const lines = typeof req.query.lines === 'string' ? parseInt(req.query.lines, 10) : 10; // we ignore last-event-id if (isNaN(lines)) return next(new HttpError(400, 'lines must be a valid number')); function sse(id, data) { return 'id: ' + id + '\ndata: ' + data + '\n\n'; } if (req.headers.accept !== 'text/event-stream') return next(new HttpError(400, 'This API call requires EventStream')); const options = { lines: lines, follow: true, format: 'json' }; const [error, logStream] = await safe(tasks.getLogs(req.resources.task, options)); if (error) return next(BoxError.toHttpError(error)); res.writeHead(200, { 'Content-Type': 'text/event-stream', 'Cache-Control': 'no-cache', 'Connection': 'keep-alive', 'X-Accel-Buffering': 'no', // disable nginx buffering 'Access-Control-Allow-Origin': '*' }); res.write('retry: 3000\n'); res.on('close', () => logStream.destroy()); logStream.on('data', function (data) { const obj = JSON.parse(data); res.write(sse(obj.realtimeTimestamp, JSON.stringify(obj))); // send timestamp as id }); logStream.on('end', res.end.bind(res)); logStream.on('error', res.end.bind(res, null)); } export default { load, get, list, stopTask, getLogs, getLogStream };