import type { RequestEvent } from "@sveltejs/kit";

const COUNTER_DO_NAME = "counter-instance";

export async function maybeHandleCounterWebSocket({
  event,
}: {
  event: RequestEvent;
  params: Record<string, string>;
  routePathname: string;
}) {
  if (event.request.headers.get("upgrade")?.toLowerCase() !== "websocket") {
    return null;
  }

  const env = event.platform?.env as Env | undefined;

  if (!env) {
    return null;
  }

  const id = env.DO_COUNTER.idFromName(COUNTER_DO_NAME);
  const stub = env.DO_COUNTER.get(id);

  return stub.fetch(new Request("https://counter-do/ws-live", event.request));
}