import type { Command } from "commander"; import { randomIdempotencyKey } from "../../gateway/call.js"; import { defaultRuntime } from "../../runtime.js"; import { runNodesCommand } from "./cli-utils.js"; import { callGatewayCli, nodesCallOpts, resolveNodeId } from "./rpc.js"; import type { NodesRpcOpts } from "./types.js"; export function registerNodesLocationCommands(nodes: Command) { const location = nodes.command("location").description("Fetch location from a paired node"); nodesCallOpts( location .command("get") .description("Fetch the current location from a node") .requiredOption("--node ", "Node id, name, or IP") .option("--max-age ", "Use cached location newer than this (ms)") .option( "--accuracy ", "Desired accuracy (default: balanced/precise depending on node setting)", ) .option("--location-timeout ", "Location fix timeout (ms)", "10000") .option("--invoke-timeout ", "Node invoke timeout in ms (default 20000)", "20000") .action(async (opts: NodesRpcOpts) => { await runNodesCommand("location get", async () => { const nodeId = await resolveNodeId(opts, String(opts.node ?? "")); const maxAgeMs = opts.maxAge ? Number.parseInt(String(opts.maxAge), 10) : undefined; const desiredAccuracyRaw = typeof opts.accuracy === "string" ? opts.accuracy.trim().toLowerCase() : undefined; const desiredAccuracy = desiredAccuracyRaw === "coarse" || desiredAccuracyRaw === "balanced" || desiredAccuracyRaw === "precise" ? desiredAccuracyRaw : undefined; const timeoutMs = opts.locationTimeout ? Number.parseInt(String(opts.locationTimeout), 10) : undefined; const invokeTimeoutMs = opts.invokeTimeout ? Number.parseInt(String(opts.invokeTimeout), 10) : undefined; const invokeParams: Record = { nodeId, command: "location.get", params: { maxAgeMs: Number.isFinite(maxAgeMs) ? maxAgeMs : undefined, desiredAccuracy, timeoutMs: Number.isFinite(timeoutMs) ? timeoutMs : undefined, }, idempotencyKey: randomIdempotencyKey(), }; if (typeof invokeTimeoutMs === "number" && Number.isFinite(invokeTimeoutMs)) { invokeParams.timeoutMs = invokeTimeoutMs; } const raw = (await callGatewayCli("node.invoke", opts, invokeParams)) as unknown; const res = typeof raw === "object" && raw !== null ? (raw as { payload?: unknown }) : {}; const payload = res.payload && typeof res.payload === "object" ? (res.payload as Record) : {}; if (opts.json) { defaultRuntime.log(JSON.stringify(payload, null, 2)); return; } const lat = payload.lat; const lon = payload.lon; const acc = payload.accuracyMeters; if (typeof lat === "number" && typeof lon === "number") { const accText = typeof acc === "number" ? ` ±${acc.toFixed(1)}m` : ""; defaultRuntime.log(`${lat},${lon}${accText}`); return; } defaultRuntime.log(JSON.stringify(payload)); }); }), { timeoutMs: 30_000 }, ); }