12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
import {    copy,    writeAll,} from "https://deno.land/std@0.152.0/streams/conversion.ts";import { ConnInfo, serve_http, serve_https } from "./mod.ts";export function upgrade(req: Request, connInfo: ConnInfo) {    const { socket, response } = Deno.upgradeWebSocket(req);    const { url, headers, method } = req;    const data = {        ...connInfo,        url,        method,        headers: Object.fromEntries(headers),    };
    const body = JSON.stringify(data);    console.log("upgrade", body);    socket.addEventListener("open", () => {        socket.send(body);        socket.close();    });    return response;}export { request as request };function request(req: Request, connInfo: ConnInfo): Response {    const { url, headers, method } = req;
    const data = {        ...connInfo,        url,        method,        headers: Object.fromEntries(headers),    };
    const body = JSON.stringify(data);    console.log("request", body);    return new Response(body, {        headers: { "content-type": "application/json" },    });}export async function connect(    request: Request,    connInfo: ConnInfo,): Promise<Response> {    const { url, headers, method } = request;
    const data = {        ...connInfo,        url,        method,        headers: Object.fromEntries(headers),    };
    const body = JSON.stringify(data);    console.log("connect", body);    const req = request;    const { port, hostname } = new URL(req.url);
    const connect_port = port ? Number(port) : 80;    try {        const socket: Deno.TcpConn = await Deno.connect({            port: connect_port,            hostname,        });        Deno.upgradeHttp(request).then(async ([conn, firstPacket]) => {            try {                await writeAll(conn, firstPacket);                await Promise.race([copy(conn, socket), copy(socket, conn)]);            } catch (error) {                console.error(error);            } finally {                socket.close();                conn.close();            }        });        return new Response(null, { status: 200 });    } catch (e) {        console.error(String(e));        return new Response("503", { status: 503 });    }}export const handlers = { upgrade, connect, request: request };
export const key = await (    await fetch("https://unpkg.com/self-signed-cert@1.0.1/key.pem")).text();export const cert = await (    await fetch("https://unpkg.com/self-signed-cert@1.0.1/cert.pem")).text();// console.log(cert, key);if (import.meta.main) {    await Promise.all([        serve_http(handlers, { port: 18080 }),        serve_https(handlers, { port: 18443, cert, key }),    ]);}