асинхронная проблема, не удалось запустить команды shelljs после .then - PullRequest
Новая
       40

асинхронная проблема, не удалось запустить команды shelljs после .then

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

Обновление: я добавил короткую паузу после записи в файл, только тогда сработали команды оболочки. 

async function testRun() {
    await createInsertCurlReq.createInsertCurlReq(process.argv[2]);
    await timeout(3000);
    shell.chmod("+x", "./curl.sh");
    shell.exec("./curl.sh");
  }
}

Оригинальный вопрос

Мой .then()блок после createInsertCurlReq.createInsertCurlReq(process.argv[2]) не запускается.Как мне переписать это так, чтобы оно работало?Я заметил, что если я не удаляю файл и просто добавляю файл, скрипт запускается. 

    async function testRun() {

        if (fs.existsSync('./curl.sh')) {
          shell.rm('-rf', './curl.sh');
        }

        createInsertCurlReq.createInsertCurlReq(process.argv[2]).then(() => {
           shell.chmod('+x', './curl.sh');
           shell.exec('./curl.sh')
           return
        })

      }
    }

curlCreation.js



     function createInsertCurlReq(filePath) {
          return utils
            .readJSONFileOnDisk(filePath)
            .then(data => {
              obj = JSON.parse(data);
              let resultArr = [];
              for (let key in obj) {
                for (let innerKey in obj[key]) {
                  let arrayNew = {};
                  arrayNew[key] = obj[key][innerKey].resolved;
                  resultArr.push(arrayNew);
                }
              }
              return resultArr;
            })
            .then(data => {
              if (!fs.existsSync("./curl.sh")) {
                shell.touch("./curl.sh");
              }
              return data;
            })
            .then(data => {
              for (let i = 0; i < data.length; i++) {
                for (let key in data[i]) {
                  fs.appendFile(
                    "curl.sh",
                    `curl -X POST -H "xxx",
                    function(err) {
                      if (err) throw err;
                    }
                  );
                }
              }
            });
        }
        module.exports = { createInsertCurlReq: createInsertCurlReq };

Ответы [ 2 ]

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

В createInsertCurlReq вы используете цепочку jsut для передачи массива, когда асинхронных операций нет.попробуйте этот формат: 

async function testRun() {
  if (fs.existsSync('./curl.sh')) {
    shell.rm('-rf', './curl.sh');
  }
  await createInsertCurlReq.createInsertCurlReq(process.argv[2])
  shell.chmod('+x', './curl.sh');
  shell.exec('./curl.sh');
}

async function createInsertCurlReq(filePath) {
  const data = await utils.readJSONFileOnDisk(filePath);
  const obj = JSON.parse(data);
  let resultArr = [];
  for (let key in obj) {
    for (let innerKey in obj[key]) {
      let arrayNew = {};
      arrayNew[key] = obj[key][innerKey].resolved;
      resultArr.push(arrayNew);
    }
  }
  if (!fs.existsSync("./curl.sh")) {
    shell.touch("./curl.sh");
  }
  for (let i = 0; i < resultArr.length; i++) {
    for (let key in resultArr[i]) {
      fs.appendFileSync(
        "curl.sh",
        `curl -X POST -H "xxx"`
      );
    }
  }
}
0 голосов
/ 23 октября 2018

Мне кажется, проблема в том, что у вас есть синхронный цикл в последнем then вызове createInsertCurlReq.Другая, но связанная проблема: Использование async / await с циклом forEach

Попробуйте заменить его на что-то вроде: 

const {promisify} = require('util');

const appendFileAsync = promisify(fs.appendFile);
// ...
.then(data => Promise.all(data.map(() => appendFileAsync(
  "curl.sh",
  `curl -X POST -H "xxx"`
).catch(err => { throw err; }))));

Таким образом, все fs.appendFile вызовы будутвыполнить настройку перед переходом к следующему then.

Если вы не возражаете против добавления модуля, вы также можете использовать async-af для рефакторинга в асинхронный метод forEach: 

const {promisify} = require('util');
const AsyncAF = require('async-af');

const appendFileAsync = promisify(fs.appendFile);
// ...
.then(data => AsyncAF(data).forEach(() => appendFileAsync(
  "curl.sh",
  `curl -X POST -H "xxx"`
).catch(err => { throw err; })));
...