user management

app/api/add-credits/route.ts

@@ -4,9 +4,11 @@ import { getDatabase } from "@/lib/db/mongodb";
 export async function POST() {
   try {
     const db = await getDatabase();
-    const CREDITS_TO_ADD = 5000000; // 5 millions de tokens
+    const CREDITS_TO_ADD = 3000000; // 3 millions de tokens
 
-    console.log(`🚀 DÉBUT: Ajout de ${CREDITS_TO_ADD.toLocaleString()} crédits à tous les utilisateurs`);
+    console.log(
+      `🚀 DÉBUT: Ajout de ${CREDITS_TO_ADD.toLocaleString()} crédits à tous les utilisateurs`
+    );
 
     // Récupérer tous les utilisateurs existants
     const users = await db.collection("users").find({}).toArray();
@@ -15,14 +17,14 @@ export async function POST() {
     if (users.length === 0) {
       return NextResponse.json({
         success: false,
-        message: "Aucun utilisateur trouvé"
+        message: "Aucun utilisateur trouvé",
       });
     }
 
     // Récupérer toutes les balances existantes
     const existingBalances = await db.collection("balances").find({}).toArray();
     const existingBalanceUserIds = new Set(
-      existingBalances.map(balance => balance.user.toString())
+      existingBalances.map((balance) => balance.user.toString())
     );
 
     console.log(`💰 Balances existantes: ${existingBalances.length}`);
@@ -34,21 +36,23 @@ export async function POST() {
     // Pour chaque utilisateur
     for (const user of users) {
       const userId = user._id;
-      
+
       if (existingBalanceUserIds.has(userId.toString())) {
         // Utilisateur a déjà une balance - ajouter les crédits
         const updateResult = await db.collection("balances").updateOne(
           { user: userId },
-          { 
+          {
             $inc: { tokenCredits: CREDITS_TO_ADD },
-            $set: { lastRefill: new Date() }
+            $set: { lastRefill: new Date() },
           }
         );
-        
+
         if (updateResult.modifiedCount > 0) {
           updatedCount++;
           totalCreditsAdded += CREDITS_TO_ADD;
-          console.log(`✅ Crédits ajoutés pour l'utilisateur: ${user.email || user.name}`);
+          console.log(
+            `✅ Crédits ajoutés pour l'utilisateur: ${user.email || user.name}`
+          );
         }
       } else {
         // Utilisateur n'a pas de balance - créer une nouvelle balance
@@ -60,20 +64,24 @@ export async function POST() {
           refillAmount: 0,
           refillIntervalUnit: "month",
           refillIntervalValue: 1,
-          __v: 0
+          __v: 0,
         };
 
         await db.collection("balances").insertOne(newBalance);
         createdCount++;
         totalCreditsAdded += CREDITS_TO_ADD;
-        console.log(`🆕 Nouvelle balance créée pour: ${user.email || user.name}`);
+        console.log(
+          `🆕 Nouvelle balance créée pour: ${user.email || user.name}`
+        );
       }
     }
 
     console.log(`✅ TERMINÉ:`);
     console.log(`- Balances mises à jour: ${updatedCount}`);
     console.log(`- Nouvelles balances créées: ${createdCount}`);
-    console.log(`- Total crédits ajoutés: ${totalCreditsAdded.toLocaleString()}`);
+    console.log(
+      `- Total crédits ajoutés: ${totalCreditsAdded.toLocaleString()}`
+    );
 
     return NextResponse.json({
       success: true,
@@ -82,17 +90,21 @@ export async function POST() {
         updatedBalances: updatedCount,
         createdBalances: createdCount,
         creditsPerUser: CREDITS_TO_ADD,
-        totalCreditsAdded
+        totalCreditsAdded,
       },
-      message: `${CREDITS_TO_ADD.toLocaleString()} crédits ajoutés à ${users.length} utilisateurs (${updatedCount} mis à jour, ${createdCount} créés)`
+      message: `${CREDITS_TO_ADD.toLocaleString()} crédits ajoutés à ${
+        users.length
+      } utilisateurs (${updatedCount} mis à jour, ${createdCount} créés)`,
     });
-
   } catch (error) {
     console.error("Erreur lors de l'ajout des crédits:", error);
-    return NextResponse.json({ 
-      success: false,
-      error: "Erreur serveur lors de l'ajout des crédits" 
-    }, { status: 500 });
+    return NextResponse.json(
+      {
+        success: false,
+        error: "Erreur serveur lors de l'ajout des crédits",
+      },
+      { status: 500 }
+    );
   }
 }
 
@@ -104,8 +116,12 @@ export async function GET() {
     const users = await db.collection("users").find({}).toArray();
     const balances = await db.collection("balances").find({}).toArray();
 
-    const totalCredits = balances.reduce((sum, balance) => sum + (balance.tokenCredits || 0), 0);
-    const averageCredits = balances.length > 0 ? totalCredits / balances.length : 0;
+    const totalCredits = balances.reduce(
+      (sum, balance) => sum + (balance.tokenCredits || 0),
+      0
+    );
+    const averageCredits =
+      balances.length > 0 ? totalCredits / balances.length : 0;
 
     return NextResponse.json({
       statistics: {
@@ -113,12 +129,11 @@ export async function GET() {
         totalBalances: balances.length,
         totalCredits,
         averageCredits: Math.round(averageCredits),
-        usersWithoutBalance: users.length - balances.length
-      }
+        usersWithoutBalance: users.length - balances.length,
+      },
     });
-
   } catch (error) {
     console.error("Erreur lors de la récupération des statistiques:", error);
     return NextResponse.json({ error: "Erreur serveur" }, { status: 500 });
   }
-}
+}

app/api/create-user/route.ts

@@ -0,0 +1,126 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getDatabase } from "@/lib/db/mongodb";
+import bcrypt from "bcryptjs";
+import { ObjectId } from "mongodb";
+
+export async function POST(request: NextRequest) {
+  try {
+    const { name, email, password, role = "USER" } = await request.json();
+
+    // Validation des données
+    if (!name || !email || !password) {
+      return NextResponse.json(
+        { error: "Nom, email et mot de passe sont requis" },
+        { status: 400 }
+      );
+    }
+
+    // Validation de l'email
+    const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
+    if (!emailRegex.test(email)) {
+      return NextResponse.json(
+        { error: "Format d'email invalide" },
+        { status: 400 }
+      );
+    }
+
+    // Validation du mot de passe (minimum 8 caractères)
+    if (password.length < 8) {
+      return NextResponse.json(
+        { error: "Le mot de passe doit contenir au moins 8 caractères" },
+        { status: 400 }
+      );
+    }
+
+    // Validation du rôle
+    if (!["USER", "ADMIN"].includes(role)) {
+      return NextResponse.json(
+        { error: "Rôle invalide. Doit être USER ou ADMIN" },
+        { status: 400 }
+      );
+    }
+
+    const db = await getDatabase();
+
+    // Vérifier si l'utilisateur existe déjà
+    const existingUser = await db.collection("users").findOne({ email });
+    if (existingUser) {
+      return NextResponse.json(
+        { error: "Un utilisateur avec cet email existe déjà" },
+        { status: 409 }
+      );
+    }
+
+    // Hasher le mot de passe
+    const saltRounds = 12;
+    const hashedPassword = await bcrypt.hash(password, saltRounds);
+
+    // Créer le nouvel utilisateur
+    const newUser = {
+      name,
+      username: email.split("@")[0], // Utiliser la partie avant @ comme username
+      email,
+      emailVerified: false,
+      password: hashedPassword,
+      avatar: null,
+      provider: "local",
+      role,
+      plugins: [],
+      twoFactorEnabled: false,
+      termsAccepted: true,
+      personalization: {
+        memories: false,
+        _id: new ObjectId(),
+      },
+      backupCodes: [],
+      refreshToken: [],
+      createdAt: new Date(),
+      updatedAt: new Date(),
+      __v: 0,
+    };
+
+    // Insérer l'utilisateur dans la base de données
+    const result = await db.collection("users").insertOne(newUser);
+
+    if (!result.insertedId) {
+      return NextResponse.json(
+        { error: "Erreur lors de la création de l'utilisateur" },
+        { status: 500 }
+      );
+    }
+
+    // Créer une balance initiale pour l'utilisateur
+    const initialBalance = {
+      user: result.insertedId,
+      tokenCredits: 3000000, // 3 millions de tokens par défaut
+      autoRefillEnabled: false,
+      lastRefill: new Date(),
+      refillAmount: 0,
+      refillIntervalUnit: "month",
+      refillIntervalValue: 1,
+      __v: 0,
+    };
+
+    await db.collection("balances").insertOne(initialBalance);
+
+    console.log(`✅ Nouvel utilisateur créé: ${email} (${role})`);
+
+    return NextResponse.json({
+      success: true,
+      message: `Utilisateur ${name} créé avec succès`,
+      user: {
+        id: result.insertedId,
+        name,
+        email,
+        role,
+        createdAt: newUser.createdAt,
+      },
+    });
+  } catch (error) {
+    console.error("Erreur lors de la création de l'utilisateur:", error);
+    return NextResponse.json(
+      { error: "Erreur serveur lors de la création de l'utilisateur" },
+      { status: 500 }
+    );
+  }
+}

app/api/delete-user/route.ts

@@ -0,0 +1,160 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getDatabase } from "@/lib/db/mongodb";
+import { ObjectId } from "mongodb";
+
+interface QueryFilter {
+  _id?: ObjectId;
+  email?: string;
+}
+
+export async function DELETE(request: NextRequest) {
+  try {
+    const { searchParams } = new URL(request.url);
+    const userId = searchParams.get("id");
+    const email = searchParams.get("email");
+
+    if (!userId && !email) {
+      return NextResponse.json(
+        { error: "ID utilisateur ou email requis" },
+        { status: 400 }
+      );
+    }
+
+    const db = await getDatabase();
+    const usersCollection = db.collection("users");
+    const balancesCollection = db.collection("balances");
+
+    // Construire la requête de recherche
+    const query: QueryFilter = {};
+    if (userId) {
+      // Vérifier si l'ID est un ObjectId valide
+      if (!ObjectId.isValid(userId)) {
+        return NextResponse.json(
+          { error: "ID utilisateur invalide" },
+          { status: 400 }
+        );
+      }
+      query._id = new ObjectId(userId);
+    } else if (email) {
+      query.email = email.toLowerCase();
+    }
+
+    // Vérifier si l'utilisateur existe
+    const existingUser = await usersCollection.findOne(query);
+    if (!existingUser) {
+      return NextResponse.json(
+        { error: "Utilisateur non trouvé" },
+        { status: 404 }
+      );
+    }
+
+    // Supprimer l'utilisateur
+    const deleteUserResult = await usersCollection.deleteOne(query);
+    
+    // Supprimer le solde associé
+    const deleteBalanceResult = await balancesCollection.deleteOne({
+      user: existingUser._id
+    });
+
+    if (deleteUserResult.deletedCount === 0) {
+      return NextResponse.json(
+        { error: "Erreur lors de la suppression de l'utilisateur" },
+        { status: 500 }
+      );
+    }
+
+    return NextResponse.json({
+      success: true,
+      message: "Utilisateur supprimé avec succès",
+      deletedUser: {
+        id: existingUser._id.toString(),
+        name: existingUser.name,
+        email: existingUser.email,
+        role: existingUser.role
+      },
+      balanceDeleted: deleteBalanceResult.deletedCount > 0
+    });
+
+  } catch (error) {
+    console.error("Erreur lors de la suppression de l'utilisateur:", error);
+    return NextResponse.json(
+      { error: "Erreur interne du serveur" },
+      { status: 500 }
+    );
+  }
+}
+
+export async function POST(request: NextRequest) {
+  try {
+    const { userId, email } = await request.json();
+
+    if (!userId && !email) {
+      return NextResponse.json(
+        { error: "ID utilisateur ou email requis" },
+        { status: 400 }
+      );
+    }
+
+    const db = await getDatabase();
+    const usersCollection = db.collection("users");
+    const balancesCollection = db.collection("balances");
+
+    // Construire la requête de recherche
+    const query: QueryFilter = {};
+    if (userId) {
+      // Vérifier si l'ID est un ObjectId valide
+      if (!ObjectId.isValid(userId)) {
+        return NextResponse.json(
+          { error: "ID utilisateur invalide" },
+          { status: 400 }
+        );
+      }
+      query._id = new ObjectId(userId);
+    } else if (email) {
+      query.email = email.toLowerCase();
+    }
+
+    // Vérifier si l'utilisateur existe
+    const existingUser = await usersCollection.findOne(query);
+    if (!existingUser) {
+      return NextResponse.json(
+        { error: "Utilisateur non trouvé" },
+        { status: 404 }
+      );
+    }
+
+    // Supprimer l'utilisateur
+    const deleteUserResult = await usersCollection.deleteOne(query);
+    
+    // Supprimer le solde associé
+    const deleteBalanceResult = await balancesCollection.deleteOne({
+      user: existingUser._id
+    });
+
+    if (deleteUserResult.deletedCount === 0) {
+      return NextResponse.json(
+        { error: "Erreur lors de la suppression de l'utilisateur" },
+        { status: 500 }
+      );
+    }
+
+    return NextResponse.json({
+      success: true,
+      message: "Utilisateur supprimé avec succès",
+      deletedUser: {
+        id: existingUser._id.toString(),
+        name: existingUser.name,
+        email: existingUser.email,
+        role: existingUser.role
+      },
+      balanceDeleted: deleteBalanceResult.deletedCount > 0
+    });
+
+  } catch (error) {
+    console.error("Erreur lors de la suppression de l'utilisateur:", error);
+    return NextResponse.json(
+      { error: "Erreur interne du serveur" },
+      { status: 500 }
+    );
+  }
+}