| const http = require('http'); |
| const net = require('net'); |
|
|
| const T_HOST = '127.0.0.1'; |
| const T_PORT = 3080; |
|
|
| |
| function fix(h) { |
| const o = { ...h, host: `${T_HOST}:${T_PORT}` }; |
| if (o.origin) o.origin = `http://${T_HOST}:${T_PORT}`; |
| for (const k of Object.keys(o)) { |
| if (k.startsWith('x-forwarded-')) delete o[k]; |
| } |
| return o; |
| } |
|
|
| const server = http.createServer((req, res) => { |
| const p = http.request( |
| { |
| host: T_HOST, |
| port: T_PORT, |
| method: req.method, |
| path: req.url, |
| headers: fix(req.headers), |
| }, |
| (pr) => { |
| res.writeHead(pr.statusCode, pr.headers); |
| pr.pipe(res); |
| } |
| ); |
| p.on('error', () => { |
| res.writeHead(502); |
| res.end('upstream not ready'); |
| }); |
| req.pipe(p); |
| }); |
|
|
| |
| server.on('upgrade', (req, socket, head) => { |
| const up = net.connect(T_PORT, T_HOST, () => { |
| let raw = `${req.method} ${req.url} HTTP/1.1\r\n`; |
| for (const [k, v] of Object.entries(fix(req.headers))) { |
| raw += `${k}: ${v}\r\n`; |
| } |
| up.write(raw + '\r\n'); |
| if (head && head.length) up.write(head); |
| socket.pipe(up); |
| up.pipe(socket); |
| }); |
| up.on('error', () => socket.destroy()); |
| socket.on('error', () => up.destroy()); |
| }); |
|
|
| server.listen(7860, '0.0.0.0'); |
