Function handleServerFunction

packages/start/src/fns/handler.ts:26–159

(h3Event: H3Event)

import { getExpectedRedirectStatus } from "../server/util.ts";

export async function handleServerFunction(h3Event: H3Event) {
  const event = getFetchEvent(h3Event);
  const request = event.request;

  const serverReference = request.headers.get("X-Server-Id");
  const instance = request.headers.get("X-Server-Instance");
  const singleFlight = request.headers.has("X-Single-Flight");
  const url = new URL(request.url);
  let functionId: string | undefined | null;
  if (serverReference) {
    // invariant(typeof serverReference === "string", "Invalid server function");
    [functionId] = serverReference.split("#");
  } else {
    functionId = url.searchParams.get("id");

    if (!functionId) {
      return process.env.NODE_ENV === "development"
        ? new Response("Server function not found", { status: 404 })
        : new Response(null, { status: 404 });
    }
  }

  const serverFunction = getServerFunction(functionId!);

  let parsed: any[] = [];

  // grab bound arguments from url when no JS
  if (!instance || request.method === "GET") {
    const args = url.searchParams.get("args");
    if (args) {
      const result = (await deserializeFromJSONString(args)) as any[];
      for (const arg of result) {
        parsed.push(arg);
      }
    }
  }
  if (request.method === "POST" && request.body !== null) {
    const bodyFormat = request.headers.get(BODY_FORMAT_KEY);
    const decoded = await extractBody("", false, request.clone());
    if (bodyFormat === BodyFormat.Seroval) {
      parsed = decoded as any[];
    } else {
      parsed.push(decoded);
    }
  }
  try {
    let result = await provideRequestEvent(event, async () => {
      /* @ts-expect-error */
      sharedConfig.context = { event };
      event.locals.serverFunctionMeta = {
        id: functionId,
      };
      return serverFunction(...parsed);
    });

    if (singleFlight && instance) {
      result = await handleSingleFlight(event, result);
    }