Hapi.js 代理 - 在回复之前更改响应

Question

我正在尝试为我正在处理的一个新项目测试 Hapi.js 我的目标是在我的 Hapi 服务器上触发一个请求，这个请求将在使用 Hapi 代理的远程服务器上触发另一个请求，并且响应将只是来自远程响应的特定属性

要对此进行测试，必须向 /api/type3/name 发出请求，这将调用对 GitHub 的 API 的 API 调用以获取用户对象

代码：

server.route({
    method: 'GET',
    path: '/api/type3/{name}',
    handler: {
      proxy: {
        mapUri: function(request,callback){
            callback(null,'https://api.github.com/users/'+request.params.name);
        },
        onResponse: function(err, res, request, reply, settings, ttl){
           console.log(res); 
           reply(res);
        },
        passThrough: true,
        xforward: true
      }
    }
});

上述代码的响应是来自GitHub的响应对象 现在我需要保存这个响应，以便我可以操纵它并只返回我需要的内容

但是当我调试响应对象时，它包含大量数据，我无法在其中找到响应负载

那么如何从响应对象中只提取来自 GitHub 的响应呢？

非常感谢

Answer 1

res 对象是一个http.IncomingMessage。如果您想使用响应的正文，您需要先从其中读取所有数据。

您有 2 个选择。

1) 普通节点

onResponse: function(err, res, request, reply, settings, ttl){

    var body = '';

    res.on('data', function (chunk) {
        body += chunk;
    });

    res.on('end', function () {
        console.log(body);  
        reply(body);
    });
}

2) 使用 Wreck（Hapi 人制作的用于在 Node 中使用 HTTP 的模块）

var Wreck = require('wreck');

onResponse: function(err, res, request, reply, settings, ttl){
   Wreck.read(res, null, function (err, payload) {
       console.log(payload);
       reply(payload);
   });
}

Answer 2

在上面的沉船案例中，你可以这样做

payload = payload.toString();

将缓冲区转换为实际数据。

Answer 3

我想从远程服务器加载 xml 数据并将响应转换为 json。 该线程帮助我找到了适合我的解决方案。但在我的情况下，上面的代码也不起作用，因为来自远程服务器的响应被压缩了。在我的控制台中只有不可读的数据。

我尝试为代理启用自动负载解析，但没有成功。最后我不得不自己用'zlib'解压缩响应。

这段代码对我有用：

'use strict'

const url = require('url')
const h2o2 = require('h2o2')
const Hapi = require('hapi')
const parseString = require('xml2js').parseString
var zlib = require('zlib')
const _ = require('lodash')

var remoteServerUrl = 'http://some-url.com:2434'
var originUrl = 'http://localhost:3000'

// Create a server with a host and port
const server = new Hapi.Server()
server.connection({
  host: 'localhost',
  port: 3001,
  routes: {
    cors: {
      origin: [originUrl],
    },
  },
})

server.register({
  register: h2o2,
}, function (err) {
  server.start(function (err) {
    console.log('Proxy Server started at: ' + server.info.uri)
  })
})

server.route({
  method: '*',
  path: '/proxy/{path*}',

  config: {
    payload: {
      // parse: true,   // didn't worked for me
      // parse: 'gzip', // didn't worked for me
      output: 'stream',
    },
  },

  handler: {

    proxy: {
      passThrough: true,
      timeout: 15000,
      acceptEncoding: false,

      mapUri (request, callback) {
        callback(null, url.format({
          protocol: url.parse(remoteServerUrl).protocol,
          host: url.parse(remoteServerUrl).host,
          port: url.parse(remoteServerUrl).port,
          pathname: request.params.path,
          query: request.query,
        }))
      },

      onResponse (err, res, request, reply, settings, ttl) {
        if (err) {
          console.error('Hapi server error: ', err)
        }

        // let's unzip the response 
        var gunzip = zlib.createGunzip()
        var xmlStr = ''

        gunzip.on('data', function (data) {
          xmlStr += data.toString()
        })

        gunzip.on('end', function () {
          // do something with the string
          // in this case convert xml to json string
          parseString(xmlStr, {}, function (err, result) {
            // send result back
            reply(result)
          })
        })

        res.pipe(gunzip)
      },
    },
  },
})

也许这对其他人有帮助；）