Function createProxy

tests/connection_test.ts:16–42

(
  target: Deno.Listener,
  source: { hostname: string; port: number },
)

import { getSocketName } from "../utils/utils.ts";

function createProxy(
  target: Deno.Listener,
  source: { hostname: string; port: number },
): { aborter: AbortController; proxy: Promise<void> } {
  const aborter = new AbortController();

  const proxy = (async () => {
    for await (const conn of target) {
      const outbound = await Deno.connect({
        hostname: source.hostname,
        port: source.port,
      });

      aborter.signal.addEventListener("abort", () => {
        conn.close();
        outbound.close();
      });

      await Promise.all([
        conn.readable.pipeTo(outbound.writable),
        outbound.readable.pipeTo(conn.writable),
      ]).catch(() => {});
    }
  })();

  return { aborter, proxy };
}

function getRandomString() {
  return Math.random().toString(36).substring(7);