Function fetch

packages/function/src/worker.ts:9–143

(
    request: Request,
    env: Env,
    ctx: ExecutionContext,
  )

export default {
  async fetch(
    request: Request,
    env: Env,
    ctx: ExecutionContext,
  ): Promise<Response> {
    const url = new URL(request.url);
    const ip = request.headers.get("cf-connecting-ip") ?? undefined;
    const country = request.headers.get("cf-ipcountry") ?? undefined;
    const agent = request.headers.get("user-agent") ?? undefined;
    const time = new Date().toISOString();
    if (agent?.includes("opencode") || agent?.includes("bun")) {
      ctx.waitUntil(
        fetch("https://us.i.posthog.com/i/v0/e/", {
          method: "POST",
          headers: {
            "Content-Type": "application/json",
          },
          body: JSON.stringify({
            api_key: JSON.parse(env.PosthogToken).value,
            event: "hit",
            distinct_id: ip ?? "unknown",
            properties: {
              $process_person_profile: false,
              user_agent: agent ?? "unknown",
              country: country ?? "unknown",
              path: url.pathname,
            },
          }),
        }),
      );

      ctx.waitUntil(
        fetch(JSON.parse(env.LakeUrl).value, {
          method: "POST",
          headers: {
            "Content-Type": "application/json",
            Authorization: `Bearer ${JSON.parse(env.LakeSecret).value}`,
          },
          body: JSON.stringify({
            events: [
              {
                _datalake_key: "inference.event",
                event_timestamp: time,
                event_date: time.slice(0, 10),
                event_type: "models.hit",
                ip: string(ip),
                ip_prefix: string(ipPrefix(ip)),
                user_agent: string(agent),
                cf_country: string(country),
                path: string(url.pathname),
              },
            ],
          }),
        }),
      );
    }

    if (url.pathname === "/model-schema.json") {