在将有效负载发送到客户端之前从 requestjs 转换有效负载

Question

兄弟姐妹们，我正在构建一个 Express API Endpoint，它需要使用外部 API，对键和值进行一些更改，并将结果返回给客户端。到目前为止，这是我所拥有的：

const external_endpoint = <external_api_end_point>;

app.get('/', function (req, res, next) {

  request({ url: external_endpoint}).pipe(res);
});

这将返回您直接点击external_endpoint 所获得的确切有效负载。

在res 发送给客户之前，我不能做些什么来更改它吗？我尝试了一些东西，但没有任何效果。与对传入有效负载进行转换相关的任何想法或最佳实践？

为了简单起见。假设这是有效载荷obj.json：

{
    "sad": {
        "userid": 5,
        "username": "jsmith",
        "isAdmin": true
    }
}

我想将sad 更改为happy。

我知道在请求之外我可以做这样的事情：

obj = JSON.parse(JSON.stringify(obj).split('"sad":').join('"happy":'));

但是用obj 代替res 是行不通的。我已经尝试分配这个res 和res.body 的值，但没有骰子。

提前感谢您的帮助！

Answer 1

如果您使用的是request-promise，您可以简单地做出新的回复并发送，或者修改您收到的回复：

app.get('/', function (req, res, next) {    
    request({ url: external_endpoint, json: true})
        .then(response => res.json({ happy: response.sad })))
        .catch(next);
});

（当然，你需要适当地处理错误）

如果您想将其作为流处理（如果您有大量数据，这很有意义），您可以使用原始的request 模块，并使用event-stream 创建您的管道：

const es = require('event-stream');

const swapper = es.through(
    function write(data) {
        this.emit("data", data.replace("sad", "happy"));
    },
    function end() {
        this.emit("end");
    }
);

request({ url: external_endpoint})
    .pipe(es.stringify())
    .pipe(swapper)
    .pipe(es.parse())
    .pipe(res);

这是一个测试流处理的沙盒：https://codesandbox.io/s/3wqx67pq6