104 lines
4.0 KiB
JavaScript
104 lines
4.0 KiB
JavaScript
const fs = require('fs');
|
|
const path = require('path');
|
|
const db = require('./db'); // Assurez-vous d'importer le fichier db.js
|
|
|
|
const PROJECTS_DIR = path.join(__dirname, '../storage');
|
|
|
|
// Fonction pour créer un dossier pour un projet
|
|
function createProjectDirectory(projectId) {
|
|
const projectPath = path.join(PROJECTS_DIR, projectId.toString());
|
|
|
|
fs.mkdir(projectPath, { recursive: true }, (err) => {
|
|
if (err) {
|
|
console.error(`Erreur lors de la création du dossier du projet ${projectId}:`, err);
|
|
return;
|
|
}
|
|
console.log(`Dossier créé pour le projet ${projectId} à ${projectPath}`);
|
|
});
|
|
}
|
|
|
|
// Fonction pour récupérer la liste des projets existants et générer leurs dossiers s'ils n'existent pas
|
|
function initializeProjectDirectories() {
|
|
db.query('SELECT id FROM public.projects', (err, result) => {
|
|
if (err) {
|
|
console.error('Erreur lors de la récupération des projets existants:', err);
|
|
return;
|
|
}
|
|
result.rows.forEach(row => {
|
|
const projectId = row.id;
|
|
const projectPath = path.join(PROJECTS_DIR, projectId.toString());
|
|
if (!fs.existsSync(projectPath)) {
|
|
createProjectDirectory(projectId);
|
|
}
|
|
});
|
|
});
|
|
}
|
|
// Fonction pour supprimer les dossiers qui ne font pas partie de la base de données
|
|
function cleanUpProjectDirectories() {
|
|
fs.readdir(PROJECTS_DIR, (err, files) => {
|
|
if (err) {
|
|
console.error('Erreur lors de la lecture du dossier des projets:', err);
|
|
return;
|
|
}
|
|
db.query('SELECT id FROM public.projects', (err, result) => {
|
|
if (err) {
|
|
console.error('Erreur lors de la récupération des projets existants:', err);
|
|
return;
|
|
}
|
|
const projectIds = result.rows.map(row => row.id.toString());
|
|
files.forEach(file => {
|
|
const projectPath = path.join(PROJECTS_DIR, file);
|
|
if (fs.statSync(projectPath).isDirectory() && !projectIds.includes(file)) {
|
|
fs.rmdir(projectPath, { recursive: true }, (err) => {
|
|
if (err) {
|
|
console.error(`Erreur lors de la suppression du dossier du projet ${file}:`, err);
|
|
return;
|
|
}
|
|
console.log(`Dossier supprimé pour le projet ${file} à ${projectPath}`);
|
|
});
|
|
}
|
|
});
|
|
});
|
|
});
|
|
}
|
|
|
|
// Nettoyer les dossiers des projets qui ne sont pas dans la base de données
|
|
cleanUpProjectDirectories();
|
|
// Fonction pour surveiller les changements dans le dossier de projets
|
|
function watchProjects() {
|
|
fs.watch(PROJECTS_DIR, (eventType, filename) => {
|
|
if (eventType === 'rename') {
|
|
const projectId = path.basename(filename);
|
|
if (fs.existsSync(path.join(PROJECTS_DIR, filename))) {
|
|
// Un nouveau projet a été créé
|
|
console.log(`Nouveau projet détecté: ${projectId}`);
|
|
createProjectDirectory(projectId);
|
|
// Ajouter une entrée dans la base de données
|
|
db.query('INSERT INTO public.projects (id, name) VALUES ($1, $2)', [projectId, projectId], (err) => {
|
|
if (err) {
|
|
console.error('Erreur lors de l\'ajout du projet à la base de données:', err);
|
|
} else {
|
|
console.log(`Projet ${projectId} ajouté à la base de données.`);
|
|
}
|
|
});
|
|
} else {
|
|
// Un projet a été supprimé
|
|
console.log(`Projet supprimé: ${projectId}`);
|
|
// Supprimer l'entrée de la base de données
|
|
db.query('DELETE FROM public.projects WHERE id = $1', [projectId], (err) => {
|
|
if (err) {
|
|
console.error('Erreur lors de la suppression du projet de la base de données:', err);
|
|
} else {
|
|
console.log(`Projet ${projectId} supprimé de la base de données.`);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
});
|
|
}
|
|
|
|
// Initialiser les dossiers des projets existants
|
|
initializeProjectDirectories();
|
|
|
|
// Démarrer la surveillance des projets
|
|
watchProjects(); |