return "authProbe" in result ? result.authProbe : result;

}

function readRuntimeVersionFromStatusPayload(payload: unknown): string | null {

if (!payload || typeof payload !== "object") {

return null;

}

const runtimeVersion = (payload as { runtimeVersion?: unknown }).runtimeVersion;

return typeof runtimeVersion === "string" && runtimeVersion.trim().length > 0

? runtimeVersion.trim()

: null;

}

export async function probeGatewayStatus(opts: {

url: string;

token?: string;

}) {

const kind = (opts.requireRpc ? "read" : "connect") satisfies GatewayStatusProbeKind;

try {

let statusRuntimeVersion: string | null = null;

const result = await withProgress<GatewayStatusProbeResult>(

{

label: "Checking gateway status...",

};

if (opts.requireRpc) {

const { callGateway } = await import("../../gateway/call.js");

await callGateway({

const statusPayload = await callGateway({

url: opts.url,

token: opts.token,

password: opts.password,

timeoutMs: opts.timeoutMs,

...(opts.configPath ? { configPath: opts.configPath } : {}),

});

statusRuntimeVersion = readRuntimeVersionFromStatusPayload(statusPayload);

const authProbe = await probeGateway(probeOpts).catch(() => null);

return { ok: true as const, authProbe };

}

const auth = probeDetails?.auth;

const server = probeDetails?.server;

const serverSummary = server ? { server } : {};

const version = server?.version ?? ("authProbe" in result ? statusRuntimeVersion : null);

if (result.ok) {

return {

ok: true,

: auth?.capability,

auth,

...serverSummary,

...(version != null ? { version } : {}),

} as const;

}

return {

capability: auth?.capability,

auth,

...serverSummary,

...(version != null ? { version } : {}),

error: resolveProbeFailureMessage(result),

} as const;

} catch (err) {