mirror of
https://github.com/R0m1k3/noteflow.git
synced 2026-10-11 17:29:37 +02:00
feat: add admin service for user management and migration, and routes for database cleanup.
This commit is contained in:
1 parent
c177833b38
commit
00ac17da70
3 files changed
+105
-16
No files matched your search
@@ -362,4 +362,45 @@ router.get('/stats', async (req, res) => {
|
||||
}
|
||||
});
|
||||
|
||||
/**
|
||||
* POST /api/admin/migrate/in-progress
|
||||
* Exécuter la migration pour ajouter la colonne in_progress
|
||||
*/
|
||||
router.post('/migrate/in-progress', async (req, res) => {
|
||||
const pool = new Pool({ connectionString: DATABASE_URL });
|
||||
|
||||
try {
|
||||
const client = await pool.connect();
|
||||
try {
|
||||
logger.info('Lancement manuel de la migration in_progress par admin');
|
||||
|
||||
// Check if column exists
|
||||
const checkRes = await client.query(`
|
||||
SELECT column_name
|
||||
FROM information_schema.columns
|
||||
WHERE table_name='global_todos' AND column_name='in_progress'
|
||||
`);
|
||||
|
||||
if (checkRes.rows.length === 0) {
|
||||
await client.query('ALTER TABLE global_todos ADD COLUMN in_progress INTEGER DEFAULT 0');
|
||||
logger.info('✓ Colonne in_progress ajoutée avec succès');
|
||||
res.json({ success: true, message: 'Migration réussie : colonne ajoutée' });
|
||||
} else {
|
||||
logger.info('⚠ Colonne in_progress existe déjà');
|
||||
res.json({ success: true, message: 'Migration non nécessaire : la colonne existe déjà' });
|
||||
}
|
||||
} finally {
|
||||
client.release();
|
||||
}
|
||||
await pool.end();
|
||||
} catch (error) {
|
||||
logger.error('Erreur lors de la migration manuelle:', error);
|
||||
res.status(500).json({
|
||||
success: false,
|
||||
error: 'Erreur lors de la migration',
|
||||
message: error.message
|
||||
});
|
||||
}
|
||||
});
|
||||
|
||||
module.exports = router;
|
||||
@@ -2115,6 +2115,32 @@ const Index = () => {
|
||||
<Button onClick={handleSaveSettings}>
|
||||
Enregistrer
|
||||
</Button>
|
||||
|
||||
<div className="border-t pt-4 mt-4">
|
||||
<h3 className="font-semibold mb-2 text-red-600">Zone de danger / Maintenance</h3>
|
||||
<p className="text-sm text-muted-foreground mb-3">
|
||||
Utilisez ces options uniquement si vous rencontrez des problèmes spécifiques.
|
||||
</p>
|
||||
<Button
|
||||
variant="outline"
|
||||
className="border-red-200 hover:bg-red-50 text-red-700"
|
||||
onClick={async () => {
|
||||
try {
|
||||
const result = await AdminService.runInProgressMigration();
|
||||
if (result.success) {
|
||||
showSuccess(result.message);
|
||||
} else {
|
||||
showError(result.message);
|
||||
}
|
||||
} catch (error) {
|
||||
showError("Erreur lors de la migration");
|
||||
}
|
||||
}}
|
||||
>
|
||||
<RefreshCw className="h-4 w-4 mr-2" />
|
||||
Réparer la base de données (Migration)
|
||||
</Button>
|
||||
</div>
|
||||
</CardContent>
|
||||
</Card>
|
||||
</TabsContent>
|
||||
|
||||
@@ -14,25 +14,25 @@ class AdminService {
|
||||
const response = await fetch("/api/users", {
|
||||
headers: AuthService.getHeaders()
|
||||
});
|
||||
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error("Erreur lors de la récupération des utilisateurs");
|
||||
}
|
||||
|
||||
|
||||
const users = await response.json();
|
||||
|
||||
|
||||
// Vérifier que les données sont un tableau
|
||||
if (!Array.isArray(users)) {
|
||||
return [];
|
||||
}
|
||||
|
||||
|
||||
return users;
|
||||
} catch (error) {
|
||||
showError(error instanceof Error ? error.message : "Erreur serveur");
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
async createUser(username: string, password: string, isAdmin: boolean): Promise<User | null> {
|
||||
try {
|
||||
const response = await fetch("/api/users", {
|
||||
@@ -40,12 +40,12 @@ class AdminService {
|
||||
headers: AuthService.getHeaders(),
|
||||
body: JSON.stringify({ username, password, is_admin: isAdmin })
|
||||
});
|
||||
|
||||
|
||||
if (!response.ok) {
|
||||
const error = await response.json();
|
||||
throw new Error(error.message || "Erreur lors de la création de l'utilisateur");
|
||||
}
|
||||
|
||||
|
||||
showSuccess("Utilisateur créé avec succès");
|
||||
return await response.json();
|
||||
} catch (error) {
|
||||
@@ -53,7 +53,7 @@ class AdminService {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
async updateUserPassword(userId: number, password: string): Promise<boolean> {
|
||||
try {
|
||||
const response = await fetch(`/api/users/${userId}`, {
|
||||
@@ -61,11 +61,11 @@ class AdminService {
|
||||
headers: AuthService.getHeaders(),
|
||||
body: JSON.stringify({ password })
|
||||
});
|
||||
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error("Erreur lors de la modification du mot de passe");
|
||||
}
|
||||
|
||||
|
||||
showSuccess("Mot de passe modifié avec succès");
|
||||
return true;
|
||||
} catch (error) {
|
||||
@@ -73,7 +73,7 @@ class AdminService {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
async toggleAdminStatus(userId: number, currentStatus: boolean): Promise<boolean> {
|
||||
try {
|
||||
const response = await fetch(`/api/users/${userId}`, {
|
||||
@@ -81,11 +81,11 @@ class AdminService {
|
||||
headers: AuthService.getHeaders(),
|
||||
body: JSON.stringify({ is_admin: !currentStatus })
|
||||
});
|
||||
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error("Erreur lors de la modification des droits");
|
||||
}
|
||||
|
||||
|
||||
showSuccess("Droits modifiés avec succès");
|
||||
return true;
|
||||
} catch (error) {
|
||||
@@ -93,18 +93,18 @@ class AdminService {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
async deleteUser(userId: number): Promise<boolean> {
|
||||
try {
|
||||
const response = await fetch(`/api/users/${userId}`, {
|
||||
method: "DELETE",
|
||||
headers: AuthService.getHeaders()
|
||||
});
|
||||
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error("Erreur lors de la suppression de l'utilisateur");
|
||||
}
|
||||
|
||||
|
||||
showSuccess("Utilisateur supprimé avec succès");
|
||||
return true;
|
||||
} catch (error) {
|
||||
@@ -112,6 +112,28 @@ class AdminService {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
async runInProgressMigration(): Promise<{ success: boolean; message: string }> {
|
||||
try {
|
||||
const response = await fetch("/api/admin/migrate/in-progress", {
|
||||
method: "POST",
|
||||
headers: AuthService.getHeaders()
|
||||
});
|
||||
|
||||
const data = await response.json();
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error(data.message || "Erreur lors de la migration");
|
||||
}
|
||||
|
||||
return data;
|
||||
} catch (error) {
|
||||
return {
|
||||
success: false,
|
||||
message: error instanceof Error ? error.message : "Erreur serveur"
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Créer une instance unique
|
||||
|
||||
Reference in new issue
Block a user