timelapse/timelapse-backend
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Ajout d'une gestion centralisée des erreurs dans les routes API et création d'un fichier utilitaire pour la gestion des erreurs serveur

Browse Source
This commit is contained in:
Kerboul
2025-01-15 09:35:09 +01:00
parent d71de3e33c
commit 94fec8ac5f
3 changed files with 27 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
routes/api.js
View File

@@ -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.' });

0
utils/dbUtils.js Normal file
View File

8
utils/serverError.js Normal file
View File

@@ -0,0 +1,8 @@
function sendError(comment, res, err) {
console.error(comment, err);
res.status(500).send('Server error');
}
module.exports = {
sendError
}