Fanstock/backend/components/orders/controller.js

//Mock de base de datos
const store = require("./store");

//Conexión por websockets
//const { socket } = require('../../socket');

function addOrder(idProduct, idProvider, amount, quantity, description) {
  return new Promise((resolve, reject) => {
    if (!idProduct) {
      console.error("[messageController]: No hay usuario o mensaje!");
      reject("Los datos son incorrectos!");
    }
    const fullOrder = {
      idProduct: idProduct,
      idProvider: idProvider,
      amount: amount,
      quantity: quantity,
      description: description,
      date: new Date(),
      statusDB: true,
    };


    

    //socket.io.emit('listenProviders', fullProvider);

    resolve(store.add(fullOrder));
  });
}

function getOrders(filterOrders) {
  return new Promise((resolve, reject) => {
    resolve(store.list(filterOrders));
  });
}

function getListProviders(filterOrders) {
  return new Promise((resolve, reject) => {
    resolve(store.getListProviders(filterOrders));
  });
}

/* function pushProduct(newProduct) {
  return new Promise((resolve, reject) => {
    resolve(store.push(newProduct));
  });
}

// add product to Provider
function addProductToProvider(idProvider, productId) {
  return new Promise((resolve, reject) => {
    resolve(store.addProductToProvider(idProvider, productId));
  });
}

// add price to provider and return the new price
function addPriceToProvider(idProvider, price) {
  return new Promise((resolve, reject) => {
    resolve(store.addPriceToProvider(idProvider, price));
  });
} */


// function updateProvider(id, message) {
//     return new Promise(async (resolve, reject) => {
//         console.log(id)
//         console.log(message)
//         if(!id || !message){
//             reject('Invalid data')
//             return false
//         }
//         const result = await store.updateText(id, message);
//         resolve(result);
//     })
// }

// function deleteProvider(id) {
//     return new Promise(async (resolve, reject) => {
//         if (!id) {
//             reject ('Id inválido')
//         }

//         resolve(store.remove(id));
//     });
// }

module.exports = {
  addOrder,
  getOrders,
  getListProviders
 /*  pushProduct,
  addProductToProvider,
  addPriceToProvider, */
  // updateProvider,
  // deleteProvider,
};