NodeJS Promise и Async Проблемы (Firebase) - PullRequest
Новая
       9

NodeJS Promise и Async Проблемы (Firebase)

0 голосов
/ 10 мая 2018

Проблема с обещаниями и асинхронной функцией.«Все перемещено» должно быть зарегистрировано после того, как все в async.each сделано.Но ничего не записывается.

Вот мои функции экспорта: 

var courier_id = data.ref.parent.key;
return admin.database().ref("firewall_queue/"+courier_id+"/orders").once('value',function(orders){
    //console.log(Object.keys(orders.val()));
    async.each(Object.keys(orders.val()), function (order, callback) {
        if(order != "none") {
            return moveToWaitingFromFirewall(order).then(callback())

        }
    },
    function (err) {
        console.log("All moved");
        return admin.database().ref("/firewall_queue/"+courier_id+"/orders/").remove().then(()=>{
            return pushToPending(courier_id,data.ref.key);
        })
    });
})

Вот моя функция moveToWaitingFromFirewall: 

function moveToWaitingFromFirewall(order_id){
var order = {};
order.id = order_id;
var promises = [];
promises.push(new Promise((resolve) => {
    admin.database().ref("orders/"+order_id+"/zone").once('value').then(function(zone){
        order.zone = zone.val();
        resolve();
    })

}))
promises.push(new Promise((resolve) => {
    admin.database().ref("orders/"+order_id+"/time_order_placed").once('value').then(function(time_order_placed){
        order.time = time_order_placed.val();
        resolve();
    })
}))
//grab zone and time first
return Promise.all(promises).then(()=>{
    return admin.database().ref(order.zone+"/wait_order_queue/"+order.id).set(order.time);
})

}

JSON Firebase 

"c98" : {
    "orders" : {
      "0333" : 123123,
      "0345" : 12,
      "0911" : 123,
      "none" : "none"
    }

1 Ответ

0 голосов
/ 10 мая 2018

Изучите это немного, и, возможно, примените к вашему текущему коду.

Представьте себе, admin.database().ref("orders/"+order_id+"/time_order_placed").once('value') похоже на delay(time)

// let delay = time => new Promise(res=>setTimeout(res,time));
let delay = function(time){
  return new Promise(function(resolve,reject){
    setTimeout(function(){ 
      resolve();
    },time);
  });
}

let myPromise = function(order){
  return Promise.all([
    delay(500),
    delay(500),
    delay(1000).then(function(){
      console.log('Order complete: ',order);
      return; // returns undefined, so cb doesn't pass anything to cb(err), but use ()=>cb() to avoid this anyways.
    })
  ]);
}

let orders = [1,2,3];

async.each(orders,function(order,cb){
  myPromise(order)
  .then(()=>cb())
  .catch(err=>cb(err));
},function(err,data){
  if(err){
    console.log('Err',err);
  }else{
    console.log('all Finished');
  }
});
<script src="https://cdnjs.cloudflare.com/ajax/libs/async/2.6.0/async.js"></script>
...