如何修改管道以返回自定义响应？

Question

如何使用request 库向客户端返回自定义响应（或错误）？ .pipe() 将始终通过管道将原始响应返回给客户端

这会返回原始响应

request(options)
    .on('error', err => {
      return cb(err);
    })
    .on('response', response => {
      // This is an error
      if (response.statusCode === 500) {
        const error = new Error('File not found');
        return cb(error);
      }
      return cb(null, response, 'application/pdf');
    })
    .pipe(res);

这将返回我的自定义响应

request(options)
    .on('error', err => {
      return cb(err);
    })
    .on('response', response => {
      // This is an error
      if (response.statusCode === 500) {
        const error = new Error('File not found');
        return cb(error);
      }
      return cb(null, response, 'application/pdf');
    });
    // .pipe(res);

是否可以根据响应控制是否不进行管道传输？

Answer 1

一旦您从流中读取，该数据将不会通过管道传输到其他地方，因此您无法读取内容的第一部分，然后决定您要传输整个内容，然后调用 .pipe()并期望您已经阅读的原始内容包含在管道响应中。

您也许可以阅读一些内容，准确记录您阅读的内容，然后如果您决定只是想通过管道传输它，您可以发送您已经阅读的内容并致电.pipe()。您必须自己进行测试，看看是否有任何竞争条件可能导致您丢失一些数据。

如果数据不是很大，一个相对简单的事情是读取所有数据（request() 库可以用于为您获取所有响应的模式），然后一旦你有所有数据，您可以检查数据并决定发送什么。您可以发送原始数据，也可以对其进行修改并发送修改后的数据，或者您可以决定发送不同的数据。

Answer 2

请求将在收到响应后立即开始管道传输。如果您想根据收到的状态代码控制管道或不控制管道，则必须像这样对响应回调进行管道调用：

const req = request(options)
  .on('error', err => cb(err))
  .on('response', response => {
    // This is an error
    if (response.statusCode === 500) {
      const error = new Error('File not found');
      return cb(error);
    }

    if (typeof response.end === 'function') {
      req.pipe(response);
    }
    if (response.req.finished) {
      return cb(null, response, 'application/pdf');
    }
  });