Node.js et MongoDB : le driver officiel

npm install mongodb      # version 7 en 2026, qui demande Node.js 20.19 ou plus récent

// src/db.js
import { MongoClient } from 'mongodb';

const client = new MongoClient(process.env.MONGODB_URI);

export async function connecter() {
  await client.connect();
  return client.db();          // la base indiquée dans l'URI (appli_frais)
}

export async function deconnecter() {
  await client.close();
}

// essai.js : node --env-file=.env essai.js
import { connecter, deconnecter } from './src/db.js';

const db = await connecter();
const fiches = db.collection('fiches');
console.log(await fiches.countDocuments({ etat: 'CR' }));   // 3
await deconnecter();

const fiches = db.collection('fiches');

// Lire : find renvoie un curseur, toArray le transforme en tableau
const enCours = await fiches
  .find({ etat: 'CR' }, { projection: { _id: 0, mois: 1, visiteur: 1 } })
  .sort({ mois: 1 })
  .toArray();

// Un seul document, ou null
const lucas = await db.collection('visiteurs')
  .findOne({ matricule: 'a131' }, { projection: { nom: 1, prenom: 1 } });
// { _id: new ObjectId('6a0000000000000000000001'), nom: 'Martin', prenom: 'Lucas' }

// Créer
const { insertedId } = await fiches.insertOne({
  visiteur: lucas._id, mois: '2026-11', etat: 'CR',
  lignesForfait: [], fraisHorsForfait: [], montantValide: null, dateModif: new Date()
});

// Modifier
const resultat = await fiches.updateOne(
  { _id: insertedId },
  { $push: { lignesForfait: { code: 'REP', quantite: 1, montantUnitaire: 25 } },
    $currentDate: { dateModif: true } }
);
// { acknowledged: true, modifiedCount: 1, upsertedId: null, upsertedCount: 0, matchedCount: 1 }

// Modifier et récupérer le document modifié
const cloturee = await fiches.findOneAndUpdate(
  { _id: insertedId, etat: 'CR' },
  { $set: { etat: 'CL' } },
  { returnDocument: 'after', projection: { etat: 1, lignesForfait: 1 } }
);
// { _id: …, etat: 'CL', lignesForfait: [ { code: 'REP', quantite: 1, montantUnitaire: 25 } ] }
// ou null si aucune fiche en cours ne correspondait

// Supprimer
await fiches.deleteOne({ _id: insertedId });   // { acknowledged: true, deletedCount: 1 }

// Agréger : même pipeline que dans mongosh
const parEtat = await fiches.aggregate([
  { $group: { _id: '$etat', nb: { $sum: 1 } } },
  { $sort: { _id: 1 } }
]).toArray();

for await (const fiche of fiches.find({ etat: 'RB' })) {
  // traiter une fiche à la fois
}

import { ObjectId } from 'mongodb';

ObjectId.isValid('6a0000000000000000000001');   // true
ObjectId.isValid('123');                        // false
new ObjectId('123');
// BSONError: input must be a 24 character hex string, 12 byte Uint8Array, or an integer

export async function trouverFiche(db, id) {
  if (!ObjectId.isValid(id)) return null;        // l'API répondra 404 ou 400
  return db.collection('fiches').findOne({ _id: new ObjectId(id) });
}

fiche.visiteur === '6a0000000000000000000001'         // false, toujours
fiche.visiteur.equals('6a0000000000000000000001')     // true
fiche.visiteur.toString()                             // '6a0000000000000000000001'

try {
  await fiches.insertOne(nouvelleFiche);
} catch (err) {
  if (err.code === 11000) {
    // une fiche existe déjà pour ce visiteur et ce mois : l'API répondra 409
  } else {
    throw err;
  }
}

// src/repositories/fiches.repository.js
import { ObjectId } from 'mongodb';

export function fichesRepository(db) {
  const fiches = db.collection('fiches');
  return {
    parVisiteur: (idVisiteur) =>
      fiches.find({ visiteur: new ObjectId(idVisiteur) }).sort({ mois: -1 }).toArray(),

    duMois: (idVisiteur, mois) =>
      fiches.findOne({ visiteur: new ObjectId(idVisiteur), mois }),

    creer: async (idVisiteur, mois) => {
      const fiche = { visiteur: new ObjectId(idVisiteur), mois, etat: 'CR',
                      lignesForfait: [], fraisHorsForfait: [], montantValide: null, dateModif: new Date() };
      const { insertedId } = await fiches.insertOne(fiche);
      return { _id: insertedId, ...fiche };
    },

    cloturer: (id, idVisiteur) =>
      fiches.findOneAndUpdate(
        { _id: new ObjectId(id), visiteur: new ObjectId(idVisiteur), etat: 'CR' },
        { $set: { etat: 'CL' }, $currentDate: { dateModif: true } },
        { returnDocument: 'after' }
      ),
  };
}