使用回调或承诺使异步代码像 nodejs 中的同步一样工作

Question

我的nodejs api函数：

exports.userSignup = (req, res) => {
  const home = {
    address: req.body.name,
    phoneno: req.body.code,
  };
  Home.create(home)
    .then((data) => {
      createUser()
        // i want to complete the above createUser() function fully then only i need to move to this below then function

        .then(() => {
          const loginDetails = {
            username: 'stackoverflow',
          };
          User.create(loginDetails)
            .then((data) => {
              return res.status(200).send(data);
            }).catch((err) => {
              console.log('error while create schema:', err);
            });
        });

    })
    .catch((err) => {
      console.log('err:', err);
    });
};

我的createUser函数代码：

const createUser = () => {
  Home.findAll({
    raw: true,
  }).then((data) => {
    data.forEach((client) => {
      postgresDB.createSchema(client.code).then(() => {
        Object.keys(postgresDB.models).forEach((currentItem) => {
          postgresDB.models[currentItem].schema(client.code).sync();
        });
        console.log('Postgres schema created');
      }).catch((err) => {
        console.log(err);
      });
    });
  }).catch((err) => {
    console.log('Warning:', err.message);
  });
};
createUser();

但是这个是异步的，

如何使用 Promise 解决拒绝或回调？

查看我的代码，我做了一个需要先工作的评论，

我尝试了异步等待但不工作！

Answer 1

您可以在 createUser 函数中使用 async 和 await。您可以通过使用 promise 来更改您的功能，我们可以解决或拒绝。 https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Statements/async_function

Answer 2

如果async/await 不适合您，只需使用承诺链。看到人们只是用 Promise 编写基于回调的代码，却忘记了你可以通过从 onFulfilled() 参数返回一个 Promise 到 then() 来链接 Promise，真是太痛苦了：

const createUser = () => {
  return Home.findAll({ raw: true }).
    then(data => {
      return Promise.all(data.map(client => postgresDB.createSchema(client.code)));
    }).
    then(() => {
      const keys = Object.keys(postgresDBModels);
      return Promise.all(keys.map(currentItem => {
        return postgresDB.models[currentItem].schema(client.code).sync();
      }));
    }).
    then(() => console.log('Postgres schema created')).
    catch((err) => {
      console.log(err);
    });
};
createUser();

Answer 3

问题在于 createUser 函数内部的同步 data.forEach() 调用，它没有等待异步 createSchema 调用在返回之前完成。 您可以通过使用 forEach 函数的异步实现或使用 Promise.all() 来解决此问题

这是一段可能对你有用的代码：

const createUser = () => {
  return Home.findAll({
    raw: true
  }).then((data) => Promise.all(
    data.map((client) => postgresDB.createSchema(client.code).then(() =>
      Promise.all(Object.keys(postgresDB.models).map((currentItem) =>
        postgresDB.models[currentItem].schema(client.code).sync()
      ))
    ))
  ))
    .catch((err) => {
      console.log('Warning:', err.message);
    });
};

Answer 4

为了让 Promise 链起作用，您必须为任何异步函数返回一个 Promise，否则它不会等待。您还将为您迭代的每个客户端进行另一个异步调用。为了一次处理多个 Promise，您需要将每个 Promise 推入一个数组并将其传递给Promise.all。这是一个应该可以工作的 sn-p。

const createUser = () => {
  return Home.findAll({
    raw: true,
  }).then((data) => {
    const promises = [];
    data.forEach((client) => {
      promises.push(
        postgresDB.createSchema(client.code).then(() => {
          Object.keys(postgresDB.models).forEach((currentItem) => {
             postgresDB.models[currentItem].schema(client.code).sync();
             console.log('Postgres schema created');
          })
        })
      );
    });
    return Promise.all(promises);
  }).catch((err) => {
    console.log('Warning:', err.message);
  });
};