Node.js lodashのforEachが全て終わった後に処理をしたい

Question

module.exports.getHoge = (userId, date) => new Promise((resolve, reject) => {
  let hoges = [];

  Promise.all([getHogeIncluded(userId, date), getHogeExcluded(userId, date)])
    .then((arrHoge) => {
      if (arrHoge[0][0]) {

        =============> console.log('1');

        const foreachfunction = new Promise((resolve, reject) => {
          _.forEach(arrHoge[0], (val, key) => {

            =============> console.log('2');

            knex
              .select('hoge_name')
              .from('Hoge_hoge')
              .where('hoge_id', val.hoge_id)
              .then((hogeNames) => {

                =============> console.log('3');

                _.forEach(hogeNames, (v, k) => {
                  hoges.push(`${URL}/${hogeId}/${val.hoge_id}/${hogeNames[k].hoge_name}`);
                });

                =============> console.log('4');

                arrHoge[0][key].hoge = hoges; // eslint-disable-line no-param-reassign
                hoges = [];
              });
          });
          resolve(arrHoge);
        });

        foreachfunction
          .then(() => {

            =============> console.log('5');

          })

      }
    })
});

このような関数を実行すると

1
2
2
2
2
5
3
4
3
4
3
4
3
4

となります。

全てのforEachの処理後の結果が欲しいのですが途中で5が呼ばれしまっている状況にあります。
初心者ながらPromiseを使っているのですが私が実現したいことはどのように書き換えれば可能なのでしょうか...。
ご教授していただけると幸いです。

Answer 1

これは_.forEach()の問題ではなく、knexが非同期処理をしている点に原因があります。（５が３よりも先に呼ばれている点に注目してください)

複数の非同期処理をまとめてやりたい場合は、knexを呼ぶ処理をPromiseを返す関数として分けてしまって、それを以下のようにPromise.allで呼んで全部の実行を待つか、

// 非同期処理を並行実行する場合の実装例
const callKnex = (val) => new Promise((resolve) => {
  knex()
    // snip
    .then((hogeNames) => {
       // snip
       resolve(hogeNames);
    });
});

const tasks = [];
_.forEach(arrHoge[0], (val) => { tasks.push(callKnex(val)); });

Promise.all(tasks).then((results) => {
   console.log('5');
});

あるいは以下のような即時関数をつかって複数のプロミス関数を１つずつ実行するように書くこともできます。

let promise = Promise.resolve();
tasks.forEach((task) => {
  promise = promise.then(() => task());
});