From 94fec8ac5f5b9da2ace363e9c50b894932196f07 Mon Sep 17 00:00:00 2001 From: Kerboul Date: Wed, 15 Jan 2025 09:35:09 +0100 Subject: [PATCH] =?UTF-8?q?Ajout=20d'une=20gestion=20centralis=C3=A9e=20de?= =?UTF-8?q?s=20erreurs=20dans=20les=20routes=20API=20et=20cr=C3=A9ation=20?= =?UTF-8?q?d'un=20fichier=20utilitaire=20pour=20la=20gestion=20des=20erreu?= =?UTF-8?q?rs=20serveur?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- routes/api.js | 54 ++++++++++++++++---------------------------- utils/dbUtils.js | 0 utils/serverError.js | 8 +++++++ 3 files changed, 27 insertions(+), 35 deletions(-) create mode 100644 utils/dbUtils.js create mode 100644 utils/serverError.js diff --git a/routes/api.js b/routes/api.js index 4ac73de..fb9d973 100644 --- a/routes/api.js +++ b/routes/api.js @@ -6,6 +6,7 @@ const path = require('path'); const fs = require('fs'); const ffmpeg = require('../ffmpeg'); const fileUtils = require('../utils/fileUtils'); +const serverError = require('../utils/serverError'); /** * @swagger @@ -23,8 +24,7 @@ router.get('/projects', async (req, res) => { const projects = await db.query('SELECT * FROM public.projects'); res.json(projects.rows); } catch (error) { - console.error('Error fetching projects:', error); - res.status(500).json({ error: 'Internal server error' }); + serverError.sendError('Error getting projects:', res, error); } }); @@ -51,7 +51,7 @@ router.get('/projects', async (req, res) => { router.get('/projects/:id/create-video', async (req, res) => { const projectId = req.params.id; const imageDir = `/storage/${projectId}`; - const outputVideo = `/storage/${projectId}/output_video.mp4`; + const outputVideo = `/storage/${projectId}/videos/output_video.mp4`; const frameRate = 24; const tempFile = `/storage/${projectId}/temp_file.txt`; @@ -70,8 +70,7 @@ router.get('/projects/:id/create-video', async (req, res) => { fs.unlinkSync(tempFile); res.status(200).json({ message: 'Video created successfully', videoPath: outputVideo }); } catch (error) { - console.error('Error creating video:', error); - res.status(500).json({ error: 'Internal server error' }); + serverError.sendError('Error creating video:', res, error); } }); @@ -101,8 +100,7 @@ router.get('/projects/:id', async (req, res) => { } res.json(project); } catch (error) { - console.error('Erreur lors de la récupération du projet:', error); - res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération du projet:', res, error); } }); @@ -132,8 +130,7 @@ router.get('/projects/:id/videos', (req, res) => { res.setHeader('Access-Control-Allow-Headers', 'Content-Type'); db.query(query, [projectId], (err, results) => { if (err) { - console.error('Erreur lors de la récupération des vidéos pour le projet:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération des vidéos pour le projet:', res, err); } res.json(results.rows); }); @@ -165,8 +162,7 @@ router.get('/projects/:id/measurements', (req, res) => { res.setHeader('Access-Control-Allow-Headers', 'Content-Type'); db.query(query, [projectId], (err, results) => { if (err) { - console.error('Erreur lors de la récupération des mesures pour le projet:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération des mesures pour le projet:', res, err); } res.json(results.rows); }); @@ -208,8 +204,7 @@ router.post('/projects', async (req, res) => { fileUtils.createProjectDirectory(projectId); res.status(201).json({ message: 'Project created successfully', projectId }); } catch (error) { - console.error('Error creating project:', error); - res.status(500).json({ error: 'Internal server error' }); + serverError.sendError('Error creating project:', res, error); } }); @@ -245,8 +240,7 @@ router.delete('/projects/:id', async (req, res) => { fileUtils.deleteProjectDirectory(projectId); res.status(200).json({ message: 'Project deleted successfully', id: projectId }); } catch (error) { - console.error('Error deleting project:', error); - res.status(500).json({ error: 'Internal server error' }); + serverError.sendError('Error deleting project:', res, error); } }); @@ -268,8 +262,7 @@ router.get('/measurements', (req, res) => { res.setHeader('Access-Control-Allow-Headers', 'Content-Type'); db.query(query, (err, results) => { if (err) { - console.error('Erreur lors de la récupération des mesures:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération des mesures:', res, err); } res.json(results.rows); }); @@ -301,8 +294,7 @@ router.get('/measurements/:id', (req, res) => { res.setHeader('Access-Control-Allow-Headers', 'Content-Type'); db.query(query, [measurementId], (err, results) => { if (err) { - console.error('Erreur lors de la récupération de la mesure:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération de la mesure:', res, err); } res.json(results.rows); }); @@ -323,8 +315,7 @@ router.post('/measurements', (req, res) => { const query = 'INSERT INTO public.measurements (project_id, timestamp, image_path, temperature, humidity, completed) VALUES ($1, $2, $3, $4, $5, $6) RETURNING id'; db.query(query, [req.body.project_id, req.body.timestamp, req.body.image_path, req.body.temperature, req.body.humidity, req.body.completed], (err, results) => { if (err) { - console.error('Erreur lors de l\'ajout de la mesure:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de l\'ajout de la mesure:', res, err); } res.status(201).json({ message: 'Mesure ajoutée avec succès', id: results.rows[0].id }); }); @@ -355,8 +346,7 @@ router.delete('/measurements/:id', (req, res) => { const query = 'DELETE FROM public.measurements WHERE id = $1 RETURNING id'; db.query(query, [measurementId], (err, results) => { if (err) { - console.error('Erreur lors de la suppression de la mesure:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la suppression de la mesure:', res, err); } if (results.rowCount === 0) { return res.status(404).json({ error: 'Aucune mesure trouvée avec cet ID.' }); @@ -383,8 +373,7 @@ router.get('/videos', (req, res) => { res.setHeader('Access-Control-Allow-Headers', 'Content-Type'); db.query(query, (err, results) => { if (err) { - console.error('Erreur lors de la récupération des vidéos:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération des vidéos:', res, err); } res.json(results.rows); }); @@ -416,8 +405,7 @@ router.get('/videos/:id', (req, res) => { res.setHeader('Access-Control-Allow-Headers', 'Content-Type'); db.query(query, [videoId], (err, results) => { if (err) { - console.error('Erreur lors de la récupération de la vidéo:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération de la vidéo:', res, err); } res.json(results.rows); }); @@ -464,23 +452,20 @@ router.post('/videos', (req, res) => { const query_last = 'SELECT timestamp FROM public.measurements WHERE id = $1'; db.query(query_first, [list_ids[0]], (err, results) => { if (err) { - console.error('Erreur lors de la récupération du timestamp de la première image:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération du timestamp de la première image:', res, err); } const start_timestamp = results.rows[0].timestamp; db.query(query_last, [list_ids[image_count - 1]], (err, results) => { if (err) { - console.error('Erreur lors de la récupération du timestamp de la dernière image:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la récupération du timestamp de la dernière image:', res, err); } const end_timestamp = results.rows[0].timestamp; const fps = image_count / req.body.duration; db.query(query, [req.body.project_id, req.body.measurement_ids, video_path, start_timestamp, end_timestamp, image_count, req.body.resolution, req.body.duration, fps, 0, req.body.name], (err, results) => { if (err) { - console.error('Erreur lors de l\'ajout de la vidéo:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de l\'ajout de la vidéo:', res, err); } res.status(201).json({ message: 'Vidéo ajoutée avec succès', id: results.rows[0].id }); }); @@ -513,8 +498,7 @@ router.delete('/videos/:id', (req, res) => { const query = 'DELETE FROM public.videos WHERE id = $1 RETURNING id'; db.query(query, [videoId], (err, results) => { if (err) { - console.error('Erreur lors de la suppression de la vidéo:', err); - return res.status(500).json({ error: 'Erreur serveur' }); + serverError.sendError('Erreur lors de la suppression de la vidéo:', res, err); } if (results.rowCount === 0) { return res.status(404).json({ error: 'Aucune vidéo trouvée avec cet ID.' }); diff --git a/utils/dbUtils.js b/utils/dbUtils.js new file mode 100644 index 0000000..e69de29 diff --git a/utils/serverError.js b/utils/serverError.js new file mode 100644 index 0000000..44638f3 --- /dev/null +++ b/utils/serverError.js @@ -0,0 +1,8 @@ +function sendError(comment, res, err) { + console.error(comment, err); + res.status(500).send('Server error'); +} + +module.exports = { + sendError +} \ No newline at end of file