File size: 2,708 Bytes
f778c12 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 | // Local notification command for paired nodes.
import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";
import { type Command, Option } from "commander";
import { defaultRuntime } from "../../runtime.js";
import { getNodesTheme, runNodesCommand } from "./cli-utils.js";
import {
buildNodeInvokeParams,
callNodesGatewayCli,
nodesCallOpts,
parseOptionalNodePositiveInteger,
resolveCliNodeId,
} from "./rpc.js";
import type { NodesRpcOpts } from "./types.js";
/** Register node notification command. */
export function registerNodesNotifyCommand(nodes: Command) {
nodesCallOpts(
nodes
.command("notify")
.description("Send a local notification on a node")
.requiredOption("--node <idOrNameOrIp>", "Node id, name, or IP")
.option("--title <text>", "Notification title")
.option("--body <text>", "Notification body")
.option("--sound <name>", "Notification sound")
.addOption(
new Option("--priority <passive|active|timeSensitive>", "Notification priority").choices([
"passive",
"active",
"timeSensitive",
]),
)
.addOption(
new Option("--delivery <system|overlay|auto>", "Delivery mode")
.choices(["system", "overlay", "auto"])
.default("system"),
)
.option("--invoke-timeout <ms>", "Node invoke timeout in ms (default 15000)", "15000")
.action(async (opts: NodesRpcOpts) => {
await runNodesCommand("notify", async () => {
const title = normalizeOptionalString(opts.title) ?? "";
const body = normalizeOptionalString(opts.body) ?? "";
if (!title && !body) {
throw new Error("missing --title or --body");
}
const invokeTimeout = parseOptionalNodePositiveInteger(
opts.invokeTimeout,
"--invoke-timeout",
);
const nodeId = await resolveCliNodeId(opts, normalizeOptionalString(opts.node) ?? "");
const invokeParams = buildNodeInvokeParams({
nodeId,
command: "system.notify",
params: {
title,
body,
sound: opts.sound,
priority: opts.priority,
delivery: opts.delivery,
},
idempotencyKey: opts.idempotencyKey,
timeoutMs: invokeTimeout,
});
const result = await callNodesGatewayCli("node.invoke", opts, invokeParams);
if (opts.json) {
defaultRuntime.writeJson(result);
return;
}
const { ok } = getNodesTheme();
defaultRuntime.log(ok("notify ok"));
});
}),
);
}
|