Function takeOverActiveLocalServer

apps/cli/src/main.ts:391–427

(input?: {
  readonly onlyKind?: ExecutorLocalServerKind;
})

  });

const takeOverActiveLocalServer = (input?: {
  readonly onlyKind?: ExecutorLocalServerKind;
}): Effect.Effect<
  ExecutorLocalServerManifest | null,
  Error,
  FileSystem.FileSystem | PlatformPath.Path
> =>
  Effect.gen(function* () {
    const manifest = yield* readLocalServerManifest();
    if (!manifest) return null;
    if (input?.onlyKind && manifest.kind !== input.onlyKind) return null;

    if (!isPidAlive(manifest.pid) || manifest.pid === process.pid) {
      yield* removeLocalServerManifestIfOwnedBy({ pid: manifest.pid }).pipe(Effect.ignore);
      return null;
    }

    yield* terminatePid(manifest.pid).pipe(Effect.ignore);
    const stopped = yield* waitForUnreachable({
      check: isServerReachable(manifest.connection.origin),
      timeoutMs: DAEMON_STOP_TIMEOUT_MS,
      intervalMs: DAEMON_BOOT_POLL_MS,
    });
    if (!stopped) {
      return yield* Effect.fail(
        new Error(
          [
            `The existing Executor ${manifest.kind} at ${manifest.connection.origin} (pid ${manifest.pid}) did not stop within ${DAEMON_STOP_TIMEOUT_MS / 1000}s.`,
            "Stop it manually and re-run.",
          ].join("\n"),
        ),
      );
    }

    yield* removeLocalServerManifestIfOwnedBy({ pid: manifest.pid }).pipe(Effect.ignore);
    return manifest;
  });

const publishLocalServerManifest = (input: {
  readonly kind: ExecutorLocalServerKind;