Koa 代理图片

const axios = require('axios');
module.exports = async (ctx, next) => {
  var req = ctx.req;
  var p = new Promise((resolve, reject) => {
    var buffers = [];
    req.on('data', (chunk) => {
      buffers.push(chunk);
    });
    req.on('end', async () => {
      let requestBody = Buffer.concat(buffers);
      axios({
        url: `https://i.qtum-cat.com/api/v1/upload`,
        method: 'POST',
        headers: {
          'content-type': req.headers['content-type'],
          Authorization: `*****************`,
        },
        data: requestBody,
      })
        .then((res) => {
          resolve(res.data);
        })
        .catch((err) => {
          reject(err);
        });
    });
    req.on('error', function () {
      ctx.body = {
        code: 0,
        message: '获取上传文件失败',
      };
    });
  });
  var info = await p;
  if (info.status) {
    ctx.lskyInfo = info.data;
    await next();
  } else {
    ctx.body = {
      code: 0,
      message: '上传文件到图床失败',
    };
  }
};

var proxy = require('koa-better-http-proxy');
var Koa = require('koa');
const router = require('koa-router')();
var app = new Koa();
router.get(
  '/test',
  proxy('localhost:4189', {
    proxyReqPathResolver: function (ctx) {
      return '/test'; //自定义路径
    },
    proxyReqOptDecorator: function (proxyReqOpts, ctx) {
      proxyReqOpts.headers.token = '123'; //自定义请求头部
      return proxyReqOpts;
    },
  })
);
app.use(router.routes());
app.use(router.allowedMethods());
app.listen('3000');