Function run

scripts/studio-host-provider.mjs:69–127

(args)

}

async function run(args) {
  const config = await loadConfig(args);
  config.localUrl = (
    args["local-url"] ||
    config.localUrl ||
    defaultLocalUrl
  ).replace(/\/$/, "");
  config.localToken = args["local-token"] || config.localToken || "";
  config.maxCapacity = clampCapacity(
    Number(args["max-capacity"] || config.maxCapacity || 1),
  );
  config.workRoot = args["work-root"] || config.workRoot || defaultWorkRoot;
  config.simulatorTemplateName =
    args["simulator-template"] ||
    config.simulatorTemplateName ||
    "iPhone 17 Pro";
  config.pollIntervalMs = Number(args["poll-interval-ms"] || 750);
  config.heartbeatIntervalMs = Number(args["heartbeat-interval-ms"] || 15000);
  config.proxyTimeoutMs = Number(args["proxy-timeout-ms"] || 25000);
  config.videoCodec = args["video-codec"] || config.videoCodec || "software";
  config.streamQuality =
    args["stream-quality"] || config.streamQuality || "smooth";

  await fs.promises.mkdir(config.workRoot, { recursive: true });
  const state = {
    activeRequests: new Set(),
    activeSessions: new Map(),
    inFlightAllocations: 0,
    lastHeartbeatAt: 0,
    stopped: false,
  };
  for (const signal of ["SIGINT", "SIGTERM", "SIGHUP"]) {
    process.once(signal, () => {
      state.stopped = true;
    });
  }

  await ensureService(config);
  await heartbeat(config, state, true);
  console.log(
    `[simdeck-provider] online as ${config.hostId} for ${config.studioUrl}`,
  );

  while (!state.stopped) {
    try {
      if (Date.now() - state.lastHeartbeatAt >= config.heartbeatIntervalMs) {
        await heartbeat(config, state, false);
      }
      await Promise.all([pollJob(config, state), pollRpc(config, state)]);
    } catch (error) {
      console.error(`[simdeck-provider] ${describeError(error)}`);
      await sleep(1000);
    }
    await sleep(config.pollIntervalMs);
  }

  await Promise.allSettled(state.activeRequests);
  await heartbeat(config, state, false, "draining");