//Se declara express const express = require("express"); //Se inicializa express var app = express(); const Model = require("./model"); const ModelSupply = require("../supplies/model"); //Agrega el mensaje a la BD async function addOrder(order) { const myOrder = new Model(order); const saved = myOrder.save(); console.log(order.idProvider) await ModelSupply.findOneAndUpdate({_id: order.idProduct, providers: {$ne: order.idProvider}}, {$addToSet: {providers: order.idProvider}}) return saved; } async function getOrders(filterOrders) { return new Promise((resolve, reject) => { console.log(filterOrders); let filter = {}; if (filterOrders !== null) { filter = { idProduct: filterOrders }; } Model.find(filter) //Busca por objectID en user y lo inserta en mensaje //.select("_id") .populate("idProduct", 'name') .populate("idProvider", "name") .exec((error, populated) => { if (error) { console.log("···· Error ", error); reject(error); return false; } resolve(populated); }); }); } async function getListProviders(filterOrders) { return new Promise((resolve, reject) => { console.log(filterOrders); let filter = {}; if (filterOrders !== null) { filter = { idProduct: filterOrders }; } Model.find(filter) //Busca por objectID en user y lo inserta en mensaje //.select("_id") .populate("idProduct", 'name') .populate("idProvider", "name") .select('idProvider') .exec((error, populated) => { if (error) { console.log("···· Error ", error); reject(error); return false; } resolve(populated); }); }); } module.exports = { add: addOrder, list: getOrders, getListProviders };