0

我是 Node/Express 的新手，正在尝试使用 Promises 来执行对 Apple CloudKit JS API 的连续 API 调用。

我不清楚如何按顺序排列函数并将它们各自的返回值从一个函数传递到下一个函数。

这是我到目前为止所拥有的：

var CloudKit = require('./setup')

//----
var fetchUserRecord = function(emailConfirmationCode){
  var query = { ... }

  // Execute the query
  CloudKit.publicDB.performQuery(query).then(function (response) {
    if(response.hasErrors) {
      return Promise.reject(response.errors[0])
    }else if(response.records.length == 0){
      return Promise.reject('Email activation code not found.')
    }else{
      return Promise.resolve(response.records[0])
    }
  })
}

//-----
var saveRecord = function(record){
  // Update the record (recordChangeTag required to update)
  var updatedRecord = { ... }

  CloudKit.publicDB.saveRecords(updatedRecord).then(function(response) {
    if(response.hasErrors) {
      Promise.reject(response.errors[0])
    }else{
      Promise.resolve()
    }
  })
}

//----- Start the Promise Chain Here -----
exports.startActivation = function(emailConfirmationCode){

  CloudKit.container.setUpAuth() //<-- This returns a promise
  .then(fetchUserRecord) //<-- This is the 1st function above
  .then(saveRecord(record)) //<-- This is the 2nd function above
    Promise.resolve('Success!')
  .catch(function(error){
    Promise.reject(error)
  })

}

我在接近尾声时收到一个错误：.then(saveRecord(record))它说record未定义。我认为它会以某种方式从先前的承诺中得到回报。

看起来这应该比我做的更简单，但我很困惑。resolve当每个 Promise 有不同的/结果时，如何让多个 Promise 像这样链接在一起reject？

4

2 回答 2

4

代码中的问题很少。

首先：您必须将函数传递给，.then()但实际上传递的是函数调用的结果：

.then(saveRecord(record))

除了saveRecord(record)技术上可能会返回一个函数，因此可以使这样的声明有效，这似乎不是您的情况。所以你只需要

.then(saveRecord)

另一个问题是没有从内部返回任何东西，saveRecord并且fetchUserRecord功能也一样。

最后，您不需要Promise.resolve从内部返回包装器.then：您可以只返回转换后的数据，它将通过链接向前传递。

var CloudKit = require('./setup')

//----
var fetchUserRecord = function(emailConfirmationCode){
  var query = { ... }

  // Execute the query
  return CloudKit.publicDB.performQuery(query).then(function (response) {
    if(response.hasErrors) {
      return Promise.reject(response.errors[0]);
    }else if(response.records.length == 0){
      return Promise.reject('Email activation code not found.');
    }else{
      return response.records[0];
    }
  })
}

//-----
var saveRecord = function(record){
  // Update the record (recordChangeTag required to update)
  var updatedRecord = { ... }

  return CloudKit.publicDB.saveRecords(updatedRecord).then(function(response) {
    if(response.hasErrors) {
      return Promise.reject(response.errors[0]);
    }else{
      return Promise.resolve();
    }
  })
}

//----- Start the Promise Chain Here -----
exports.startActivation = function(emailConfirmationCode){

  return CloudKit.container.setUpAuth() //<-- This returns a promise
    .then(fetchUserRecord) //<-- This is the 1st function above
    .then(saveRecord) //<-- This is the 2nd function above
    .catch(function(error){});
}

不要忘记返回转换后的数据或新的承诺。否则undefined将返回到下一个链式函数。

于 2018-08-21T20:10:44.113 回答
0

由于@skyboyer 帮助我弄清楚发生了什么，我会将他们的答案标记为正确答案。

我不得不稍微调整一下，因为我需要将返回的值传递给我的 Promise 链中的后续函数。这是我结束的地方：

exports.startActivation = function(emailConfirmationCode){
  return new Promise((resolve, reject) => {

    CloudKit.container.setUpAuth()
      .then(() => {
        return fetchUserRecord(emailConfirmationCode)
      })
      .then((record) => {
        resolve(saveRecord(record))
      }).catch(function(error){
        reject(error)
      })

  })
}
于 2018-08-21T22:51:46.390 回答