Files
noteflow/routes/users.routes.js
T
Claude 55a1809e71 Fix: Chargement automatique SQLite/PostgreSQL
CORRECTIF URGENT: L'application chargeait toujours SQLite même avec
PostgreSQL configuré, causant une perte apparente de toutes les données.

Ajout de database-loader.js qui détecte automatiquement:
- DB_TYPE=postgres → PostgreSQL
- DATABASE_URL=postgresql:// → PostgreSQL
- Sinon → SQLite

Tous les routes et services mis à jour pour utiliser database-loader
au lieu de charger directement database.js.

Les données ne sont PAS perdues, elles sont dans PostgreSQL.
L'application se reconnectera correctement après redémarrage.

Fichiers modifiés:
- config/database-loader.js (nouveau)
- server.js
- routes/*.js (11 fichiers)
- services/*.js (2 fichiers)
2025-11-14 09:50:21 +00:00

156 lines
5.0 KiB
JavaScript

// Routes de gestion des utilisateurs (admin uniquement)
const express = require('express');
const router = express.Router();
const bcrypt = require('bcrypt');
const { body, validationResult } = require('express-validator');
const { getAll, getOne, runQuery } = require('../config/database-loader');
const { authenticateToken, requireAdmin } = require('../middleware/auth');
const logger = require('../config/logger');
// Toutes les routes nécessitent authentification et droits admin
router.use(authenticateToken);
router.use(requireAdmin);
/**
* GET /api/users
* Liste tous les utilisateurs
*/
router.get('/', async (req, res) => {
try {
const users = await getAll(
'SELECT id, username, is_admin, created_at FROM users ORDER BY created_at DESC'
);
res.json(users);
} catch (error) {
logger.error('Erreur lors de la récupération des utilisateurs:', error);
res.status(500).json({ error: 'Erreur serveur' });
}
});
/**
* POST /api/users
* Créer un nouvel utilisateur
*/
router.post('/',
[
body('username').trim().isLength({ min: 3 }).withMessage('Le nom d\'utilisateur doit contenir au moins 3 caractères'),
body('password').isLength({ min: 6 }).withMessage('Le mot de passe doit contenir au moins 6 caractères'),
body('is_admin').optional().isBoolean()
],
async (req, res) => {
try {
const errors = validationResult(req);
if (!errors.isEmpty()) {
return res.status(400).json({ error: 'Données invalides', details: errors.array() });
}
const { username, password, is_admin } = req.body;
// Vérifier si l'utilisateur existe déjà
const existingUser = await getOne('SELECT id FROM users WHERE username = ?', [username]);
if (existingUser) {
return res.status(400).json({ error: 'Ce nom d\'utilisateur existe déjà' });
}
// Hasher le mot de passe
const passwordHash = await bcrypt.hash(password, 12);
// Créer l'utilisateur
const result = await runQuery(
'INSERT INTO users (username, password_hash, is_admin) VALUES (?, ?, ?)',
[username, passwordHash, is_admin ? 1 : 0]
);
logger.info(`Utilisateur créé: ${username} (ID: ${result.id})`);
res.status(201).json({
id: result.id,
username,
is_admin: is_admin || false
});
} catch (error) {
logger.error('Erreur lors de la création de l\'utilisateur:', error);
res.status(500).json({ error: 'Erreur serveur' });
}
}
);
/**
* PUT /api/users/:id
* Modifier un utilisateur
*/
router.put('/:id',
[
body('password').optional().isLength({ min: 6 }).withMessage('Le mot de passe doit contenir au moins 6 caractères'),
body('is_admin').optional().isBoolean()
],
async (req, res) => {
try {
const errors = validationResult(req);
if (!errors.isEmpty()) {
return res.status(400).json({ error: 'Données invalides', details: errors.array() });
}
const userId = req.params.id;
const { password, is_admin } = req.body;
// Vérifier que l'utilisateur existe
const user = await getOne('SELECT id, username FROM users WHERE id = ?', [userId]);
if (!user) {
return res.status(404).json({ error: 'Utilisateur non trouvé' });
}
// Mettre à jour le mot de passe si fourni
if (password) {
const passwordHash = await bcrypt.hash(password, 12);
await runQuery('UPDATE users SET password_hash = ? WHERE id = ?', [passwordHash, userId]);
}
// Mettre à jour le statut admin si fourni
if (typeof is_admin !== 'undefined') {
await runQuery('UPDATE users SET is_admin = ? WHERE id = ?', [is_admin ? 1 : 0, userId]);
}
logger.info(`Utilisateur modifié: ${user.username} (ID: ${userId})`);
res.json({ message: 'Utilisateur modifié avec succès' });
} catch (error) {
logger.error('Erreur lors de la modification de l\'utilisateur:', error);
res.status(500).json({ error: 'Erreur serveur' });
}
}
);
/**
* DELETE /api/users/:id
* Supprimer un utilisateur
*/
router.delete('/:id', async (req, res) => {
try {
const userId = req.params.id;
// Ne pas permettre la suppression de soi-même
if (parseInt(userId) === req.user.id) {
return res.status(400).json({ error: 'Vous ne pouvez pas supprimer votre propre compte' });
}
// Vérifier que l'utilisateur existe
const user = await getOne('SELECT id, username FROM users WHERE id = ?', [userId]);
if (!user) {
return res.status(404).json({ error: 'Utilisateur non trouvé' });
}
// Supprimer l'utilisateur (les notes et todos seront supprimés en cascade)
await runQuery('DELETE FROM users WHERE id = ?', [userId]);
logger.info(`Utilisateur supprimé: ${user.username} (ID: ${userId})`);
res.json({ message: 'Utilisateur supprimé avec succès' });
} catch (error) {
logger.error('Erreur lors de la suppression de l\'utilisateur:', error);
res.status(500).json({ error: 'Erreur serveur' });
}
});
module.exports = router;