probeTimeoutMs?: () => number | undefined;

}

export interface EnsureVmRunningOptions extends WaitForVmStatusOptions {

transitionTimeoutMs?: () => number | undefined;

}

export function listVmNames(): string[] {

return listVms()

.map((item) => (item.name ?? "").trim())

.filter(Boolean);

}

export function vmStatus(vmName: string): string {

return listVms().find((vm) => vm.name === vmName)?.status || "missing";

export function vmStatus(vmName: string, timeoutMs?: number): string {

return listVms(timeoutMs).find((vm) => vm.name === vmName)?.status || "missing";

}

export function waitForVmStatus(

throw new Error(`VM ${vmName} did not reach ${expected}`);

}

export function ensureVmRunning(vmName: string, timeoutSeconds = 180): void {

export function ensureVmRunning(

vmName: string,

timeoutSeconds = 180,

options: EnsureVmRunningOptions = {},

): void {

const deadline = Date.now() + timeoutSeconds * 1000;

while (Date.now() < deadline) {

const status = vmStatus(vmName);

const status = vmStatus(vmName, options.probeTimeoutMs?.());

if (status === "running") {

return;

}

if (status === "stopped") {

say(`Start ${vmName} before update phase`);

run("prlctl", ["start", vmName], {

quiet: true,

timeoutMs: PRLCTL_TRANSITION_TIMEOUT_MS,

timeoutMs: options.transitionTimeoutMs?.() ?? PRLCTL_TRANSITION_TIMEOUT_MS,

});

} else if (status === "suspended" || status === "paused") {

say(`Resume ${vmName} before update phase`);

run("prlctl", ["resume", vmName], {

quiet: true,

timeoutMs: PRLCTL_TRANSITION_TIMEOUT_MS,

timeoutMs: options.transitionTimeoutMs?.() ?? PRLCTL_TRANSITION_TIMEOUT_MS,

});

} else if (status === "missing") {

die(`VM not found before update phase: ${vmName}`);

return fallback;

}

function listVms(): PrlctlVmListItem[] {

function listVms(timeoutMs = PRLCTL_STATUS_TIMEOUT_MS): PrlctlVmListItem[] {

return JSON.parse(

run("prlctl", ["list", "--all", "--json"], {

quiet: true,

timeoutMs: PRLCTL_STATUS_TIMEOUT_MS,

timeoutMs,

}).stdout,

) as PrlctlVmListItem[];

}