93 lines
2.5 KiB
JavaScript
93 lines
2.5 KiB
JavaScript
const net = require('net');
|
|
const handlers = require('../../handlers');
|
|
const path = require('path');
|
|
const express = require('express');
|
|
|
|
const url = require('url');
|
|
const app = express();
|
|
app.post("/*", async function (req, res) {
|
|
console.log("Reading a post request")
|
|
var a = parseInt(req.header('Content-Length'))
|
|
const dat = Buffer.alloc(a);
|
|
var ptr = 0;
|
|
async function handle() {
|
|
try {
|
|
fetch = (await import('node-fetch')).default;
|
|
|
|
const resFromRev = await fetch('http://127.0.0.1:3040/' + url.parse(req.url).search, {
|
|
body: dat,
|
|
"headers": req.headers,
|
|
method: "POST"
|
|
});
|
|
res.header('Content-Type', 'application/x-protobuffer');
|
|
res.writeHead(resFromRev.status, resFromRev.statusText);
|
|
res.end(new Uint8Array((await resFromRev.arrayBuffer())));
|
|
} catch (e) {
|
|
if (!e.response) {
|
|
console.error("An error occurred contacting dmbackend! Make sure you're running it!");
|
|
console.error(e);
|
|
res.writeHead(500, 'Internal server error');
|
|
res.end('An error has occured');
|
|
return;
|
|
}
|
|
res.header('Content-Type', "application/x-protobuffer");
|
|
res.header('Content-Length', e.response.data.length.toString());
|
|
res.writeHead(e.response.status, "Internal server error");
|
|
|
|
res.end(e.response.data);
|
|
}
|
|
}
|
|
|
|
req.on("data", function (r) {
|
|
dat.set(r, ptr);
|
|
ptr += r.length;
|
|
console.log(ptr);
|
|
if (ptr === a) {
|
|
handle()
|
|
}
|
|
})
|
|
|
|
|
|
|
|
});
|
|
app.get('/*', (req, res) => {
|
|
res.writeHead(200, "OK");
|
|
res.end("OK");
|
|
})
|
|
|
|
/**
|
|
*
|
|
* @param {import("../../proxy").FilterInfo} f
|
|
*/
|
|
function filter(f) {
|
|
if (f.tls) {
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
*
|
|
* @param {import("../../proxy").ServerConfig} config
|
|
* @param {net.Socket} sock
|
|
*/
|
|
function proxy(config, sock) {
|
|
const ms = handlers.getMiniServer(function (req, res) {
|
|
app(req, res);
|
|
}, path.resolve(__dirname, "public", "google.com.pem"), path.resolve(__dirname, "public", "google.com.key"))
|
|
|
|
const socks = net.createConnection({
|
|
host: "127.0.0.1",
|
|
port: ms.port
|
|
}, function () {
|
|
sock.write('HTTP/1.1 200 OK\r\n\n');
|
|
sock.pipe(socks);
|
|
socks.pipe(sock);
|
|
});
|
|
|
|
}
|
|
module.exports = {
|
|
filter,
|
|
proxy
|
|
}
|