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
}