Dashboard/scripts/import-users.js

import XLSX from 'xlsx';
import { MongoClient, ObjectId } from 'mongodb';
import bcrypt from 'bcryptjs';
import path from 'path';
import { fileURLToPath } from 'url';
import dotenv from 'dotenv';

const __filename = fileURLToPath(import.meta.url);
const __dirname = path.dirname(__filename);

// Charger les variables d'environnement depuis .env.local
dotenv.config({ path: path.join(__dirname, '..', '.env.local') });

// Configuration
const MONGODB_URI = process.env.MONGODB_URI;
const XLSX_FILENAME = "Emmanuel_WATHELE.xlsx"; // ⚠️ À modifier selon le fichier
const DEFAULT_PASSWORD = "IHECS-2025";
const COURS = "Ouverture à l'esprit critique";

async function importUsers() {
  console.log("🚀 Démarrage de l'import...\n");

  try {
    // Vérifier que MONGODB_URI est défini
    if (!MONGODB_URI) {
      throw new Error("MONGODB_URI non défini dans .env.local");
    }

    // 1. Extraire le référent depuis le nom du fichier
    const referent = XLSX_FILENAME.replace('.xlsx', '').replace(/_/g, ' ');
    console.log(`📋 Référent: ${referent}`);
    console.log(`📚 Cours: ${COURS}`);
    console.log(`🔑 Password par défaut: ${DEFAULT_PASSWORD}\n`);

    // 2. Lire le fichier Excel
    const filePath = path.join(__dirname, '..', 'public', 'list_users', XLSX_FILENAME);
    console.log(`📁 Lecture du fichier: ${filePath}`);

    const workbook = XLSX.readFile(filePath);
    const sheet = workbook.Sheets[workbook.SheetNames[0]];
    const data = XLSX.utils.sheet_to_json(sheet);

    console.log(`✅ ${data.length} lignes détectées dans le fichier\n`);

    // 3. Hash le password une seule fois (optimisation)
    console.log("🔐 Hash du mot de passe...");
    const hashedPassword = await bcrypt.hash(DEFAULT_PASSWORD, 12);

    // 4. Préparer les users
    const users = data.map(row => ({
      nom: row["Nom Etudiant"],
      prenom: row["Prénom Etudiant"],
      name: `${row["Prénom Etudiant"]} ${row["Nom Etudiant"]}`,
      email: row["EMail Etudiant 2"],
      username: row["EMail Etudiant 2"]?.split("@")[0],
      password: hashedPassword,
      emailVerified: false,
      avatar: null,
      provider: "local",
      role: "USER",

      // Nouveaux champs pour le cours et le référent
      referent: referent,
      cours: COURS,

      plugins: [],
      twoFactorEnabled: false,
      termsAccepted: true,
      personalization: {
        memories: false,
        _id: new ObjectId(),
      },
      backupCodes: [],
      refreshToken: [],
      createdAt: new Date(),
      updatedAt: new Date(),
      __v: 0,
    }));

    // 5. Connexion à MongoDB
    console.log("🔌 Connexion à MongoDB...");
    const client = new MongoClient(MONGODB_URI);
    await client.connect();
    const db = client.db('librechat');
    console.log("✅ Connecté à MongoDB\n");

    // 6. Import des users
    const results = { created: [], errors: [], skipped: [] };

    console.log("📥 Import en cours...\n");

    for (let i = 0; i < users.length; i++) {
      const user = users[i];
      const progress = `[${i + 1}/${users.length}]`;

      try {
        // Validation email
        if (!user.email || !user.email.includes('@')) {
          console.log(`${progress} ⚠️  Email invalide: ${user.name}`);
          results.errors.push({ name: user.name, error: "Email invalide" });
          continue;
        }

        // Vérifier si email existe déjà
        const existing = await db.collection("users").findOne({ email: user.email });

        if (existing) {
          console.log(`${progress} ⏭️  Ignoré (existe déjà): ${user.email}`);
          results.skipped.push(user.email);
          continue;
        }

        // Insérer le user
        const result = await db.collection("users").insertOne(user);

        // Créer la balance initiale
        await db.collection("balances").insertOne({
          user: result.insertedId,
          tokenCredits: 3000000,
          autoRefillEnabled: false,
          lastRefill: new Date(),
          refillAmount: 0,
          refillIntervalUnit: "month",
          refillIntervalValue: 1,
          __v: 0,
        });

        console.log(`${progress} ✅ Créé: ${user.prenom} ${user.nom} (${user.email})`);
        results.created.push(user.email);

      } catch (error) {
        console.error(`${progress} ❌ Erreur: ${user.email} - ${error.message}`);
        results.errors.push({ email: user.email, error: error.message });
      }
    }

    // 7. Fermer la connexion
    await client.close();

    // 8. Résumé final
    console.log("\n" + "=".repeat(60));
    console.log("📊 RÉSUMÉ DE L'IMPORT");
    console.log("=".repeat(60));
    console.log(`✅ Utilisateurs créés: ${results.created.length}`);
    console.log(`⏭️  Utilisateurs ignorés (déjà existants): ${results.skipped.length}`);
    console.log(`❌ Erreurs: ${results.errors.length}`);
    console.log("=".repeat(60));

    if (results.errors.length > 0) {
      console.log("\n⚠️  DÉTAIL DES ERREURS:");
      results.errors.forEach(e => {
        console.log(`  - ${e.email || e.name}: ${e.error}`);
      });
    }

    console.log("\n✨ Import terminé !\n");

  } catch (error) {
    console.error("\n❌ ERREUR FATALE:", error.message);
    console.error(error);
    process.exit(1);
  }

  process.exit(0);
}

// Lancer l'import
importUsers();