как использовать node-http-proxy внутри контроллера AdonisJS

Я пытаюсь использовать node-http-proxy внутри контроллера AdonisJS, но получаю сообщение об ошибке

The "url" argument must be of type string. Received type function

Строка, вызывающая ошибку, - это proxy.web(request, response, { target: urlToProxy });

async proxy({ request, response }){
    var resource = await Resource.query().where('uri', request.url()).with('service.user').with('userSecurity').first()
    resource = resource.toJSON()
    if(!resource.service.active){
      return response.status(404).send(`Parent service '${resource.service.title}' is disabled`)
    }
    if(!resource.active){
      return response.status(404).send(`Resource is disabled`)
    }
    if(resource.userSecurity.length <= 0) {
      return response.status(403).send(`You are not permitted to access that resource. Contact ${resource.service.user.first_name} ${resource.service.user.last_name} (${resource.service.user.email})`)
    }

    var urlToProxy = url.resolve(resource.service.basepath, request.originalUrl())
    var proxy = httpProxy.createProxyServer()

    proxy.web(request, response, { target: urlToProxy });

  }

node.js node-http-proxy adonis.js
person PrestonDocks    schedule 01.07.2019    source источник

Ответы (2)


arrow_upward
0
arrow_downward

В конце концов я подошел немного ближе, но не до конца. Приближаясь, я понял, что http-прокси доставляет данные через буфер, поэтому мне пришлось сделать что-то вроде этого

proxy.web(req, res, { target: data.service.basepath})
    proxy.on('error', function(err, req, res){
      console.log("There was an error", err)
    })

    proxy.on('proxyRes', async (proxyRes, request, response) =>{
      var body = new Buffer('')
      proxyRes.on('data', (data)=>{
        body = Buffer.concat([body, data])
      })

      proxyRes.on('end', ()=>{
        body = body.toString()
        try{
          res.send(body)
        }catch(err){
        }
      })
    });

Однако я все еще не мог заставить его работать, поскольку контроллер возвращался до того, как http-прокси завершил запрос.

В конце концов, и, вероятно, к лучшему, я написал автономное прокси-приложение и использовал основное приложение только для проверки токенов JWT, прежде чем они пройдут через прокси.

person PrestonDocks    schedule 02.07.2019

arrow_upward
0
arrow_downward

Вы были так близки, что я хотел сделать что-то подобное и заключил прокси в обещание, чтобы мы могли дождаться возврата прокси, прежде чем отвечать нашим ответом:

const proxy = httpProxy.createProxyServer();
const prom = new Promise((resolve, reject) => {
    proxy.web(request.request, response.response, {
        target: urlToTarget
    }, (e) => {
        reject(e);
    });

    proxy.on('proxyRes', function (proxyRes, req, res) {
        let body = [];
        proxyRes.on('data', function (chunk) {
            body.push(chunk);
        });
        proxyRes.on('end', function () {
            body = Buffer.concat(body).toString();
            resolve(body);
        });
    });
});

const result = await prom;
response.body(result);
return response;

Я подумал, что дам вам полный ответ для всех, кто сталкивается с этим.

person R. Chappell    schedule 23.08.2019