Nota al margen Me conecto a DB con el siguiente código:

 const mongoose = require('mongoose'); const connectDB = (url) => { return mongoose.connect(url); }

Descripción del problema: Tengo dos colecciones diferentes. Ambas operaciones, findByIdAndUpdate y create deben ejecutarse como una operación atómica. Esto debería ser posible con Transacciones mangosta.

 const registerCustomer = async (req, res) => { await CustomerRegistrationCode.findByIdAndUpdate(req.body._id, { used: true }); const customer = await Customer.create({firstName: req.body.firstName}); }

Lo que probé:

 const registerCustomer = async (req, res) => { const session = await mongoose.startSession(); await session.startTransaction(); try { await CustomerRegistrationCode.findByIdAndUpdate(req.body._id, { used: true }); //updates even though const customer = await Customer.create({ firstName: req.body.firstName });// this line will throw error await session.commitTransaction(); session.endSession(); } catch (error) { console.error('abort transaction'); await session.abortTransaction(); session.endSession(); throw error; } }

Problema La colección CustomerRegistrationCode se actualiza aunque el método Customer.create genera un error. ¿Cómo se puede solucionar esto?

El nuevo enfoque para comprender las transacciones de MongoDB falla, pero este es un código oficial de https://mongoosejs.com/docs/transactions.html

 const mongoose = require('mongoose'); const debugMongo = async () => { const db = await mongoose.createConnection("mongodb://localhost:27017/mongotest"); const Customer = db.model('Customer', new mongoose.Schema({ name: String })); const session = await db.startSession(); session.startTransaction(); await Customer.create([{ name: 'Test' }], { session: session }); //(node:20416) UnhandledPromiseRejectionWarning: MongoServerError: Transaction numbers are only allowed on a replica set member or mongos let doc = await Customer.findOne({ name: 'Test' }); assert.ok(!doc); doc = await Customer.findOne({ name: 'Test' }).session(session); assert.ok(doc); await session.commitTransaction(); doc = await Customer.findOne({ name: 'Test' }); assert.ok(doc); session.endSession(); } debugMongo();

En Customer.create se lanza un error y no sé por qué. ¿Alguien tiene un ejemplo mínimo de trabajo?