57 lines
1.4 KiB
TypeScript
57 lines
1.4 KiB
TypeScript
import { signalCheck, signalRpcRequest } from "./client.js";
|
|
|
|
export type SignalProbe = {
|
|
ok: boolean;
|
|
status?: number | null;
|
|
error?: string | null;
|
|
elapsedMs: number;
|
|
version?: string | null;
|
|
};
|
|
|
|
function parseSignalVersion(value: unknown): string | null {
|
|
if (typeof value === "string" && value.trim()) return value.trim();
|
|
if (typeof value === "object" && value !== null) {
|
|
const version = (value as { version?: unknown }).version;
|
|
if (typeof version === "string" && version.trim()) return version.trim();
|
|
}
|
|
return null;
|
|
}
|
|
|
|
export async function probeSignal(
|
|
baseUrl: string,
|
|
timeoutMs: number,
|
|
): Promise<SignalProbe> {
|
|
const started = Date.now();
|
|
const result: SignalProbe = {
|
|
ok: false,
|
|
status: null,
|
|
error: null,
|
|
elapsedMs: 0,
|
|
version: null,
|
|
};
|
|
const check = await signalCheck(baseUrl, timeoutMs);
|
|
if (!check.ok) {
|
|
return {
|
|
...result,
|
|
status: check.status ?? null,
|
|
error: check.error ?? "unreachable",
|
|
elapsedMs: Date.now() - started,
|
|
};
|
|
}
|
|
try {
|
|
const version = await signalRpcRequest<unknown>("version", undefined, {
|
|
baseUrl,
|
|
timeoutMs,
|
|
});
|
|
result.version = parseSignalVersion(version);
|
|
} catch (err) {
|
|
result.error = err instanceof Error ? err.message : String(err);
|
|
}
|
|
return {
|
|
...result,
|
|
ok: true,
|
|
status: check.status ?? null,
|
|
elapsedMs: Date.now() - started,
|
|
};
|
|
}
|