node.jsのasyncモジュールで、waterfallの外に変数を出したい

Question

node.js：v9.5.0
MySQL：5.7.21
MacOS：10.12

node.jsのasyncモジュールを使うことが条件となります。

MySQLの結果を加工して他の関数でいじりたいのですが、asyncモジュールのwaterfallを使って出した結果はwaterfallの外に出すことができません。

例えば下のコードの結果は、

'use strict';

const async = require('async');
const mysql = require('mysql');

let arr = [];

async.waterfall([
  (next) => { // MySQL接続
    const conn = mysql.createConnection({
      host: 'localhost',
      user: 'root',
      password: '',
      database: 'table'
    });

    conn.connect((err) => {
      if (err) throw err;
      return next(null, conn);
    });
  },
  (conn, next) => {
    const sql = 'SELECT * FROM foo';
    conn.query(sql, (err, data) => {
      conn.end();
      if (err) throw err;

      // SQLの結果をpushで配列にする
      async.eachSeries(data, (hoge, callback) => {
        arr.push(hoge.id);
        return callback();
      });
      return next(null, arr);
    });
  }
], (err, arr) => {
  if (err) throw err;
  console.log('asyncの中：', arr); // [ 80, 81, 86, 87, 88, 89, 91, 17, 31, 32, 33 ]
});

console.log('asyncの外：', arr) // []

asyncの外： []
asyncの中： [ 80, 81, 86, 87, 88, 89, 91, 17, 31, 32, 33 ]

のようなイメージとなります（当たり前ですが）。
結果arrをwaterfallの外に出す方法はないでしょうか。

Comments

[y_waiwai]

出すことが出来ないとはどーゆーふーにできないのか説明してください

[退会済みユーザー]

恐縮です。async.waterfallの外でlet arr宣言しているので、いったんarrに結果が入ったら、そのままasync.waterfallの外でもarrに値が入ったままになって欲しいのですが、async.waterfallの外に出てしまうとarrの中の値が空になってしまう、ということなのですが、これでわかりますでしょうか。

Answer 1

タイムマシンでも使わない限り無理です。

というのも、async.waterfallの中身はあとから実行されるものなので、console.log('asyncの外：', arr)のほうが先に実行されるからです。

「待たせたい」のに「async.waterfallの外に書きたい」というのは、希望自体が矛盾しています。

Answer 2

たんに非同期関数が実行される前にarrを読んでいるということはないでしょうか
関数が終了するのを待って読んでみればどうでしょう

Comments

[退会済みユーザー]

「やっぱりまたコレか･･･」と思いコードを見直してみました。ありがとうございました。

Answer 3

回答を下さった皆様、ありがとうございました。
正解でなくてもヒントにはなりました。

実際のコードは非常に複雑で長いのでここでは紹介出来かねますが、うまくいかなかった原因はコールバック関数の抜けとか、位置が違うという理由でした。

なので上記のコードがfunctionの中に入っていた場合、きちんとarrの中に値は入ってきます。
以下、正しいコードの例となります。

'use strict';

const async = require('async');

let hoge = [0, 1, 2, 3, 4];
let foo = [];

let main = () => {
  async.waterfall([
    (next) => {
      async.eachSeries(hoge, (h, callback) => {
        sub(h, (t) => {
          foo.push(t);
          return callback(); // このcallbackの位置が違っていた
        });
      }, (err) => { // ここから
        return next(null);
      }); // ここまでが抜けていた
    }
  ], (err) => {
    if (err) throw err;
    console.log(foo);
  });
}

let sub = (i, callback) => {
  let e = i + 1;
  return callback(e);
}

main();

省略しちゃいましたが、実際にはasync.eachSeriesの中にMySQLの結果を入れています。
正しく書けば、ここでいうfooはきちんと表示されます。

コールバックの書き忘れや書く位置が違うミスが多いです。
エラーを出してくれるツールでもあればいいのですが。。。

Answer 4

async.seriesを使って

1. waterfallの処理
2. waterfallで得た値を使って実行したい

処理でどうでしょうか？(少し強引ですが