Modifier la route de rendu vidéo pour utiliser POST, ajouter la gestion des erreurs et démarrer le processus de rendu vidéo

This commit is contained in:
2025-03-10 17:42:32 +01:00
parent 55697fc032
commit 9ec8ff73f3

View File

@@ -256,50 +256,60 @@ router.delete('/videos/:id', (req, res) => {
* 400: * 400:
* description: Video not yet produced * description: Video not yet produced
*/ */
router.get('/videos/file/:video_id', (req, res) => { router.post('/videos/render/:video_id', async (req, res) => {
const videoId = req.params.video_id; const videoId = req.params.video_id;
const query = 'SELECT video_file, status FROM public.videos WHERE id = $1'; const query = 'SELECT measurement_ids, project_id, duration FROM public.videos WHERE id = $1';
db.query(query, [videoId], (err, results) => {
db.query(query, [videoId], async (err, results) => {
if (err) { if (err) {
return serverError.sendError('Error getting video:', res, err); console.error('Error getting video:', err);
return serveFallbackVideo(res);
} }
if (results.rows.length === 0) { if (results.rows.length === 0) {
return res.status(404).json({ error: 'Video not found' }); console.error('Video not found');
return serveFallbackVideo(res);
} }
const video = results.rows[0];
if (video.status === 0) {
return res.status(400).json({ error: 'Video not yet produced' });
}
const videoPath = video.video_file;
const stat = fs.statSync(videoPath);
const fileSize = stat.size;
const range = req.headers.range;
if (range) { console.log('Video found:', results.rows[0]);
const parts = rangeParser(fileSize, range); const duration = results.rows[0].duration;
const start = parts[0].start;
const end = parts[0].end; console.log('Rendering video:', videoId);
const chunksize = (end - start) + 1;
const file = fs.createReadStream(videoPath, { start, end }); const measurementIds = results.rows[0].measurement_ids;
const head = { const project_id = results.rows[0].project_id;
'Content-Range': `bytes ${start}-${end}/${fileSize}`, console.log('Measurement IDs:', measurementIds);
'Accept-Ranges': 'bytes', console.log('Project ID:', project_id);
'Content-Length': chunksize,
'Content-Type': 'video/mp4', try {
}; const pathList = await measureManager.getPathList(measurementIds, project_id);
res.writeHead(206, head); console.log('Path list:', pathList);
file.pipe(res); res.json({ message: 'Render process started' });
} else {
const head = { const videoFile = await videoManager.createVideoWithList(project_id, pathList, duration, videoId);
'Content-Length': fileSize, console.log('Video file:', videoFile);
'Content-Type': 'video/mp4',
}; await videoManager.updateVideoFile(videoId, videoFile);
res.writeHead(200, head);
fs.createReadStream(videoPath).pipe(res); console.log('Video rendering complete');
} catch (err) {
console.error('Error during video rendering:', err);
return serveFallbackVideo(res);
} }
}); });
}); });
function serveFallbackVideo(res) {
const videoPath = dbTester.getCatVideo();
fs.access(videoPath, fs.constants.F_OK, (err) => {
if (err) {
console.error('Fallback video not found:', err);
return res.status(500).json({ error: 'Fallback video not found' });
}
res.download(videoPath);
});
}
/** /**
* @swagger * @swagger
* /videos/render/{video_id}: * /videos/render/{video_id}: