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();