He encontrado algunas preguntas relacionadas con esto ( aquí y aquí ), pero no he podido interpretar las respuestas de una manera que pueda entender cómo hacer lo que necesito.
Tengo 3 colecciones: Organizaciones, Usuarios y Proyectos. Cada proyecto pertenece a un usuario y cada usuario pertenece a una organización. Desde la identificación del usuario, necesito devolver todos los proyectos que pertenecen a la organización a la que pertenece el usuario que inició sesión.
Devolver los proyectos de la colección que pertenecen al usuario es fácil, con esta consulta:
const projects = await Project.find({ user: req.user.id }).sort({ createdAt: -1 })Cada usuario tiene una identificación de organización como clave externa, y creo que necesito hacer algo con los comandos $lookup y quizás $unwind mongo, pero a diferencia de las consultas SQL, realmente me cuesta entender lo que está sucediendo para poder construir consultas correctamente.
EDITAR: Usando esta consulta
const orgProjects = User.aggregate( [ { $match: { _id: req.user.id } }, { $project: { _id: 0, org_id: 1 } }, { $lookup: { from: "users", localField: "organisation", foreignField: Organisation._id, as: "users_of_org" } }, { $lookup: { from: "projects", localField: "users_of_org._id", foreignField: "user", as: "projects" } }, { $unset: ["organisation", "users_of_org"] }, { $unwind: "$projects" }, { $replaceWith: "$projects" } ])Parece que casi funciona, devolviendo lo siguiente:
Aggregate { _pipeline: [ { '$match': [Object] }, { '$project': [Object] }, { '$lookup': [Object] }, { '$lookup': [Object] }, { '$unset': [Array] }, { '$unwind': '$projects' }, { '$replaceWith': '$projects' } ], _model: Model { User }, options: {} }suponiendo que sus documentos tengan un esquema como este , podría hacer una canalización de agregación como la siguiente con 2 etapas $lookup .
db.users.aggregate( [ { $match: { _id: "user1" } }, { $project: { _id: 0, org_id: 1 } }, { $lookup: { from: "users", localField: "org_id", foreignField: "org_id", as: "users_of_org" } }, { $lookup: { from: "projects", localField: "users_of_org._id", foreignField: "user_id", as: "projects" } }, { $unset: ["org_id", "users_of_org"] }, { $unwind: "$projects" }, { $replaceWith: "$projects" } ])