使用 Promise 链接方法

Question

我正在努力理解承诺，我想我可以看到它们是如何工作的，例如你可以说做Step 1、Step 2 然后Step 3。
我使用node-fetch（使用原生 Promises）创建了这个下载功能

## FileDownload.js

const fetch = require('node-fetch');
const fs = require('fs');

module.exports = function(url, target) {
  fetch(url)
    .then(function(res) {
      var dest = fs.createWriteStream(target);
      res.body.pipe(dest);
    }).then(function(){
      console.log(`File saved at ${target}`)
    }).catch(function(err){
      console.log(err)
  });
}

所以这一切都是按顺序执行的，我可以看到它是如何工作的。

我有另一种方法可以将 CSV 文件转换为 JSON（再次使用 Promise）

## CSVToJson.js

const csvjson = require('csvjson');
const fs = require('fs');
const write_file = require('../helpers/WriteToFile');

function csvToJson(csv_file, json_path) {
  return new Promise(function(resolve, reject) {
    fs.readFile(csv_file, function(err, data){
      if (err)
        reject(err);
      else
        var data = data.toString();
        var options = {
          delimiter : ',',
          quote     : '"'
        };
      const json_data = csvjson.toObject(data, options);
      write_file(json_path, json_data)
      resolve(data);
    });
  });
}

module.exports = {
  csvToJson: csvToJson
}

当我一个接一个地调用这些函数时，第二个函数失败了，因为第一个函数没有完成。

我是否需要将这两个函数调用包装在另一个 Promise 中，即使它们各自都实现了 Promise？

如果我完全误解了这一点，请告知

Answer 1

当我一个接一个地调用这些函数时，第二个函数失败了，因为第一个函数还没有完成。

第一个有两个问题：

1. 它不等待文件被写入；它所做的只是设置管道，而无需等待过程完成
2. 它不提供任何方式让调用者知道进程何时完成

要处理第一个问题，您必须等待目标流上的finish 事件（pipe 返回）。要处理第二个问题，您需要返回一个在发生之前不会实现的承诺。沿着这些思路（见** cmets）：

module.exports = function(url, target) {
  // ** Return the end of the chain
  return fetch(url)
    .then(function(res) {
      // ** Unfortunately, `pipe` is not Promise-enabled, so we have to resort
      // to creating a promise here
      return new Promise((resolve, reject) => {
        var dest = fs.createWriteStream(target);
        res.body.pipe(dest)
          .on('finish', () => resolve()) // ** Resolve on success
          .on('error', reject);          // ** Reject on error
      });
    }).then(result => {
      console.log(`File saved at ${target}`);
      return result;
    });
    // ** Don't `catch` here, let the caller handle it
}

然后您可以在结果上使用then 和catch 进行下一步：

theFunctionAbove("/some/url", "some-target")
    .then(() = {
        // It worked, do the next thing
    })
    .catch(err => {
        // It failed
    });

（或async/await.）

---

旁注：我没有对其进行代码审查，但csvToJson 中的一个严重问题跳出，一个小问题也是如此，@Bergi 突出显示了第二个问题：

1. else 逻辑周围缺少 { 和 }

2. 小问题是您有 var data = data.toString(); 但 data 是该函数的参数，因此 var 具有误导性（但无害）

3. 没有正确处理readFile回调的else部分代码中的错误

我们可以通过在else 中执行resolve 并在then 处理程序中执行其余逻辑来解决这两个问题：

function csvToJson(csv_file, json_path) {
  return new Promise(function(resolve, reject) {
    fs.readFile(csv_file, function(err, data){
      if (err)
        reject(err);
      else
        resolve(data);
    });
  })
  .then(data => {
    data = data.toString();
    var options = {
      delimiter : ',',
      quote     : '"'
    };
    const json_data = csvjson.toObject(data, options);
    write_file(json_path, json_data);
    return data;
  });
}