123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
import { ConnInfo } from "./ConnInfo.ts";import { Handler } from "./Handler.ts";import { Handlers } from "./Handlers.ts";import { is_connect_or_upgrade } from "./is_connect_or_upgrade.ts";import { on_Error } from "./on_Error.ts";import { on_NotFound } from "./on_NotFound.ts";import { requestEventProcessor } from "./requestEventProcessor.ts";
export async function on_tls_connection({    conn,    handlers,    onError = on_Error,    signal,    onNotFound = on_NotFound,}: {    signal?: AbortSignal;    conn: Deno.TlsConn;    handlers: Handlers;
    onError?: (        // deno-lint-ignore no-explicit-any        reason: any,        request: Request,        connInfo: ConnInfo,    ) => Response | PromiseLike<Response>;    onNotFound?: Handler;}) {    if (signal?.aborted) {        return;    }    const { localAddr, remoteAddr } = conn;
    const hand_shake_info = await conn.handshake();    const { alpnProtocol } = hand_shake_info;    const conn_info: ConnInfo = {        localAddr,        alpnProtocol: alpnProtocol,        remoteAddr,    };    const httpConn = Deno.serveHttp(conn);    signal?.addEventListener("abort", function () {        httpConn.close();        conn.close();    });
    for await (const requestEvent of httpConn) {        if (signal?.aborted) {            return;        }
        const promise = requestEventProcessor({            handlers,            requestEvent,            conn_info,            onError,            onNotFound,        }).catch(console.error);        if (            alpnProtocol !== "h2" &&            is_connect_or_upgrade(requestEvent.request)        ) {            return await promise;        }    }}