Function fetch

runner/server.mjs:306–342

(request)

}

async function handleLivePreview(runId, request, suffix) {
  const target = livePreviewTarget(runId, request, suffix, "http");
  const headers = new Headers(request.headers);
  headers.set("host", target.host);
  return fetch(target, new Request(target, {
    method: request.method,
    headers,
    body: request.body,
    redirect: "manual",
    duplex: request.body ? "half" : undefined,
  }));
}

function upgradeLivePreview(server, request, runId, suffix) {
  const target = livePreviewTarget(runId, request, suffix, "ws");
  return server.upgrade(request, { data: { target: target.toString(), upstream: null } });
}

let bunServer = null;

if (typeof Bun !== "undefined") {
  bunServer = Bun.serve({
    port: PORT,
    async fetch(request) {
      const url = new URL(request.url);
      if (url.pathname === "/health") return json({ ok: true });
      if (url.pathname === "/run" && request.method === "POST") {
        try { return json(await handleRun(await request.json())); }
        catch (error) { return json({ ok: false, error: String(error?.message || error) }, 400); }
      }
        const previewMatch = url.pathname.match(/^\/live\/(run_[A-Za-z0-9-]+)\/preview\/?(.*)$/);
      if (previewMatch) {
        const [, runId, suffix] = previewMatch;
        try {
          if (request.headers.get("upgrade")?.toLowerCase() === "websocket") {
            if (upgradeLivePreview(bunServer, request, runId, suffix)) return;
            return json({ ok: false, error: "preview_websocket_upgrade_failed" }, 502);
          }
          return await handleLivePreview(runId, request, suffix);
        }