Function handleRequest

scripts/studio-provider-bridge.mjs:427–479

(request)

}

async function handleRequest(request) {
  let responsePayload;
  if (isWebSocketUpgradeRequest(request)) {
    await complete({
      requestId: request.id,
      responseBodyBase64: Buffer.from(
        "Studio provider RPC does not tunnel WebSocket upgrade requests.",
      ).toString("base64"),
      responseHeaders: { "content-type": "text/plain; charset=utf-8" },
      responseStatus: 426,
    });
    return;
  }
  try {
    responsePayload = await cachedProxyResponse(request);
  } catch (error) {
    console.error(
      `[simdeck-provider-bridge] request ${request.id} ${request.method} ${request.path} failed: ${describeError(error)}`,
    );
    await handleLocalProxyFailure(error);
    if (request.method !== "GET") {
      await complete({
        requestId: request.id,
        error: describeError(error),
      });
      return;
    }
    try {
      responsePayload = await proxyLocalRequest(request);
    } catch (retryError) {
      console.error(
        `[simdeck-provider-bridge] request ${request.id} ${request.method} ${request.path} retry failed: ${describeError(retryError)}`,
      );
      await complete({
        requestId: request.id,
        error: describeError(retryError),
      });
      return;
    }
  }

  try {
    await complete({
      requestId: request.id,
      ...responsePayload,
    });
  } catch (error) {
    console.error(
      `[simdeck-provider-bridge] request ${request.id} ${request.method} ${request.path} completion failed: ${describeError(error)}`,
    );
    throw error;
  }
}

function runProviderRequest(request) {
  const task = handleRequest(request).catch((error) => {