Function pollRpc

scripts/studio-host-provider.mjs:322–341

(config, state)

}

async function pollRpc(config, state) {
  const response = await studioJson(
    config,
    "/api/actions/provider-hosts/rpc/next",
    {
      hostId: config.hostId,
      hostToken: config.hostToken,
    },
  );
  if (!response?.request) {
    return;
  }
  const task = handleRpc(config, response.request).catch((error) => {
    console.error(
      `[simdeck-provider] rpc ${response.request.id} failed: ${describeError(error)}`,
    );
  });
  state.activeRequests.add(task);
  task.finally(() => state.activeRequests.delete(task));
}

async function handleRpc(config, request) {
  if (isWebSocketUpgradeRequest(request)) {