Function handleSingleFlight

packages/start/src/fns/handler.ts:235–287

(sourceEvent: FetchEvent, result: any)

  return headers;
}
async function handleSingleFlight(sourceEvent: FetchEvent, result: any): Promise<Response> {
  let revalidate: string[];
  let url = new URL(sourceEvent.request.headers.get("referer")!).toString();
  if (result instanceof Response) {
    if (result.headers.has("X-Revalidate"))
      revalidate = result.headers.get("X-Revalidate")!.split(",");
    if (result.headers.has("Location"))
      url = new URL(
        result.headers.get("Location")!,
        new URL(sourceEvent.request.url).origin + import.meta.env.BASE_URL,
      ).toString();
  }
  const event = { ...sourceEvent } as PageEvent;
  event.request = new Request(url, {
    headers: createSingleFlightHeaders(sourceEvent),
  });
  return await provideRequestEvent(event, async () => {
    await createPageEvent(event);
    App || (App = (await import("solid-start:app")).default);
    /* @ts-expect-error */
    event.router.dataOnly = revalidate || true;
    /* @ts-expect-error */
    event.router.previousUrl = sourceEvent.request.headers.get("referer");
    try {
      renderToString(() => {
        /* @ts-expect-error */
        sharedConfig.context.event = event;
        App();
      });
    } catch (e) {
      console.log(e);
    }

    /* @ts-expect-error */
    const body = event.router.data;
    if (!body) return result;
    let containsKey = false;
    for (const key in body) {
      if (body[key] === undefined) delete body[key];
      else containsKey = true;
    }
    if (!containsKey) return result;
    if (!(result instanceof Response)) {
      body["_$value"] = result;
      result = new Response(null, { status: 200 });
    } else if ((result as any).customBody) {
      body["_$value"] = (result as any).customBody();
    }
    result.customBody = () => body;
    result.headers.set("X-Single-Flight", "true");
    return result;
  });
}