ждите обещание перед обратным вызовом в async.each - PullRequest
Новая
       34

ждите обещание перед обратным вызовом в async.each

0 голосов
/ 26 октября 2018 
router.post('/runCommand', async function(req, res){
  let results = [];
  async.each(req.body.requests, async function(request, callback){
    const data = await connect(request.command)
    await results.push(data);
    await callback(null);
  }, function(err){
    if (!err) {
      res.send(202, results)
    }
  })
})

Res.send никогда не выполняется, и кажется, что обратный вызов происходит до завершения соединения. Connect успешно возвращает обещание, потому что это 

router.get('/topics', async function(req, res) {
  console.log('in get');
  const data = await connect(req.body.command);
  await res.send(data);
});

отлично работает. Но включение async.each для запуска нескольких команд кажется неработоспособным. Я знаю, что это проблема с тем, как я вызываю функцию обратного вызова async.each, но исследование не помогло, как я должен был вызывать ее. Можно ли использовать .then() после ожидания обещания? 

function connect(command){
  return new Promise(function(resolve) {
  let host = {
        server: {
          host: "host",
          port: "port",
          userName: "user",
          password: config.Devpassword
        },
        commands: [ command ]
      };
  var SSH2Shell = require ('ssh2shell'),
  //Create a new instance passing in the host object
  SSH = new SSH2Shell(host),
  //Use a callback function to process the full session text
  callback = function(sessionText){
    console.log(sessionText)
    resolve(sessionText);
  }
  SSH.connect(callback);
  })
};

1 Ответ

0 голосов
/ 26 октября 2018

Хотя вы можете продолжать тратить больше времени на то, чтобы заставить async.each() работать, я рекомендую просто отбросить его и использовать исключительно синтаксис async / await, который значительно упрощает ваш код: 

router.post('/runCommand', async function (req, res) {
  try {
    const results = await Promise.all(
      req.body.requests.map(({ command }) => connect(command))
    );

    res.send(202, results);
  } catch ({ message, stack }) {
    res.send(500, { error: message, stack });
  }
})

Глядя на документацию ssh2shell, я думаю, что ваша функция connect также может быть улучшена для лучшей читаемости и обработки ошибок: 

const SSH2Shell = require('ssh2shell');

function connect (command) {
  return new Promise((resolve, reject) => {
    const host = {
      server: {
        host: 'host',
        port: 'port',
        userName: 'user',
        password: config.Devpassword
      },
      commands: [command]
    };
    //Create a new instance passing in the host object
    const SSH = new SSH2Shell(host);

    SSH.on('error', reject);
    SSH.connect(resolve);
  });
}

Пожалуйста, не стесняйтесь комментировать, если это все еще неработа для вас.

...