Files
openclaw/src/gateway/node-command-policy.test.ts
T
Peter Steinberger 0b8aabe864 docs: document auth profile failure policy contract (#89613)
* docs: document markdown marker renderer

* docs: document rendered markdown chunking

* docs: document markdown text chunking

* docs: document shared text chunking

* docs: document plugin text chunking exports

* docs: document avatar policy constants

* docs: document node match candidates

* docs: document scoped expiring id cache

* docs: document runtime import normalization

* docs: document string sample summaries

* docs: document session usage timeseries types

* docs: document session usage response types

* docs: document manifest frontmatter shapes

* docs: document channel route input metadata

* docs: document pair loop guard settings

* docs: document migration config patch helpers

* docs: document api provider registry

* docs: document tool call repair payloads

* docs: document plugin tool payload helpers

* docs: document lazy promise loader

* docs: document store writer queue state

* docs: document thread binding lifecycle

* docs: document concurrency helper contract

* docs: document gateway client info contract

* docs: document delivery context contracts

* docs: document secret ref defaults contract

* docs: document command gating contract

* docs: document avatar policy contract

* docs: document node match policy

* docs: document message channel normalization

* docs: document boolean parsing contract

* docs: document zod parse helpers

* docs: document direct dm guard policy

* docs: document fixed window limiter contract

* docs: document node presence event contract

* docs: document secret normalization contract

* docs: document progress draft line removal

* docs: document usage formatting contracts

* docs: document agent run status contract

* docs: document runtime import helpers

* docs: document provider utility ownership

* docs: document invalid config helpers

* docs: document json compat parser

* docs: document channel config metadata ownership

* docs: document channel logging helpers

* docs: document sender identity validation ownership

* docs: document string sampling helper

* docs: document global singleton helpers

* docs: document transcript tool helpers

* docs: document exec safe-bin normalization

* docs: document reaction level resolver

* docs: document account snapshot redaction boundary

* docs: document messaging target helpers

* docs: document thread binding messages

* docs: document conversation binding context

* docs: document conversation resolution helper

* docs: document owner display secret retention

* docs: document provider request config types

* docs: document skills config types

* docs: document memory config types

* docs: document imessage config types

* docs: document crestodian config types

* docs: document tools config policies

* docs: document shared config base types

* docs: document channel config contracts

* docs: document openclaw config state types

* docs: document model config contracts

* docs: document shared agent config types

* docs: document agent defaults config types

* docs: document secret input contracts

* docs: document auth config contracts

* docs: document gateway config contracts

* docs: document tool call stream repair contracts

* docs: document memory host facades

* docs: document llm core contracts

* docs: document markdown core contracts

* docs: document gateway connect error contracts

* docs: document gateway protocol primitives

* docs: document gateway frame schemas

* docs: document gateway device schemas

* docs: document gateway environment schemas

* docs: document gateway push schemas

* docs: document gateway plugin schemas

* docs: document gateway artifact schemas

* docs: document gateway command schemas

* docs: document gateway task schemas

* docs: document gateway exec approval schemas

* docs: document gateway secret schemas

* docs: document gateway config schemas

* docs: document gateway snapshot schemas

* docs: document gateway chat schemas

* docs: document gateway wizard schemas

* docs: document gateway node schemas

* docs: document gateway plugin approval schemas

* docs: document gateway talk schemas

* docs: document gateway agent schemas

* docs: document gateway session schemas

* docs: document gateway cron schemas

* docs: document gateway agent model skill schemas

* docs: document gateway skill proposal tool schemas

* docs: document gateway protocol registry

* docs: document gateway channel status schemas

* docs: document gateway schema regression tests

* docs: document gateway schema barrel

* docs: document gateway validator tests

* docs: document gateway primitive push tests

* docs: document gateway contract tests

* docs: document native protocol guard

* docs: document channel schema tests

* docs: document gateway protocol smoke tests

* docs: document gateway protocol entrypoint

* docs: document gateway protocol type exports

* docs: document gateway error codes

* docs: document protocol schema registry

* docs: document talk audio codec

* docs: document talk activation names

* docs: document talk consult questions

* docs: document talk consult tool

* docs: document talk run control contracts

* docs: document talk run control adapter

* docs: document talkback consult queue

* docs: document talk consult transcript guard

* docs: document talk fast context runtime

* docs: document forced talk consult coordinator

* docs: document talk output activity tracker

* docs: document talk event metrics

* docs: document talk diagnostics

* docs: document talk observability hook

* docs: document talk provider resolver

* docs: document talk provider registry

* docs: document talk runtime primitives

* docs: document talk consult controller logs

* docs: document channel identity helpers

* docs: document channel account allowlist helpers

* docs: document channel metadata draft controls

* docs: document channel ingress policy

* docs: document channel sender access gates

* docs: document channel catalog message contracts

* docs: document channel account plugin helpers

* docs: document configured binding helpers

* docs: document channel acp approval config helpers

* docs: document channel bundled config write helpers

* docs: document channel plugin utility contracts

* docs: document channel config access helpers

* docs: document channel message action helpers

* docs: document channel outbound runtime helpers

* docs: document channel pairing promotion helpers

* docs: document channel registry helpers

* docs: document channel setup wizard helpers

* docs: document channel lifecycle status helpers

* docs: document channel target thread helpers

* docs: document channel session binding helpers

* docs: document channel package module probes

* docs: document channel setup wizard contracts

* docs: document channel plugin API barrels

* docs: document channel contract test helpers

* docs: document channel core helpers

* docs: document small core facades

* docs: document provider runtime helpers

* docs: document persistence and realtime helpers

* docs: document mcp and state helpers

* docs: document tool planner contracts

* docs: document music generation runtime

* docs: document crestodian command flow

* docs: document utility helpers

* docs: document node host helpers

* docs: document transcript contracts

* docs: document trajectory export contracts

* docs: document image generation contracts

* docs: document routing helper contracts

* docs: document session helper contracts

* docs: document video generation contracts

* docs: document model catalog contracts

* docs: document proxy capture contracts

* docs: document status rendering contracts

* docs: document test helper contracts

* docs: document wizard setup contracts

* docs: document process contracts

* docs: document memory host sdk contracts

* docs: document tts contracts

* docs: document secrets runtime contracts

* docs: document shared helper contracts

* docs: document hook runtime contracts

* docs: document security audit contracts

* docs: document flow contracts

* docs: document media understanding contracts

* docs: document tui contracts

* docs: document logging contracts

* docs: document llm contracts

* docs: document cron contracts

* docs: document daemon contracts

* docs: document task contracts

* docs: document acp contracts

* docs: document test utility contracts

* docs: document skill contracts

* docs: document config contracts

* docs: document outbound infra contracts

* docs: document command analysis contracts

* docs: document provider usage infra contracts

* docs: document file safety infra contracts

* docs: document exec approval infra contracts

* docs: document gateway runtime infra contracts

* docs: document infra utility contracts

* docs: document infra queue storage contracts

* docs: document heartbeat infra contracts

* docs: document remaining infra contracts

* docs: document gateway auth contracts

* docs: document gateway display helpers

* docs: document gateway http helpers

* docs: document gateway node helpers

* docs: document gateway mcp helpers

* docs: document gateway support helpers

* docs: document gateway server runtime helpers

* docs: document gateway runtime bootstrap helpers

* docs: document gateway session events

* docs: document gateway utility helpers

* docs: document gateway talk helpers

* docs: document gateway helper contracts

* docs: document gateway server method helpers

* docs: document gateway server auth helpers

* docs: document gateway server tests

* docs: document gateway test helpers

* docs: document gateway node tests

* docs: document gateway channel tests

* docs: document gateway session tests

* docs: document gateway server startup tests

* docs: document gateway tool test helpers

* docs: document gateway server test helpers

* docs: document gateway server method tests

* docs: document remaining gateway tests

* docs: document plugin sdk public subpaths

* docs: document plugin sdk runtime helpers

* docs: document plugin sdk memory provider helpers

* docs: document plugin sdk runtime facades

* docs: document plugin sdk command approval helpers

* docs: document plugin sdk runtime types

* docs: document plugin sdk browser account helpers

* docs: document plugin sdk media memory helpers

* docs: document plugin sdk core tests

* docs: document plugin sdk contract helpers

* docs: document plugin sdk test helpers

* docs: document remaining plugin sdk tests

* docs: document cli utility helpers

* docs: document cli runtime helpers

* docs: document cli command registration helpers

* docs: document node cli helpers

* docs: document cli program registration

* docs: document message cli registration

* docs: document daemon cli helpers

* docs: document cli route parsers
2026-06-03 15:20:39 -07:00

255 lines
8.6 KiB
TypeScript

/**
* Node command policy regression tests.
*/
import { afterEach, describe, expect, it } from "vitest";
import {
GATEWAY_CLIENT_IDS,
GATEWAY_CLIENT_MODES,
} from "../../packages/gateway-protocol/src/client-info.js";
import type { OpenClawConfig } from "../config/types.openclaw.js";
import { createEmptyPluginRegistry } from "../plugins/registry-empty.js";
import { resetPluginRuntimeStateForTest, setActivePluginRegistry } from "../plugins/runtime.js";
import {
isForegroundRestrictedPluginNodeCommand,
isNodeCommandAllowed,
normalizeDeclaredNodeCommands,
resolveNodeCommandAllowlist,
} from "./node-command-policy.js";
describe("gateway/node-command-policy", () => {
afterEach(() => {
resetPluginRuntimeStateForTest();
});
function installCanvasPluginDefaults() {
const registry = createEmptyPluginRegistry();
(registry.nodeInvokePolicies ??= []).push({
pluginId: "canvas",
pluginName: "Canvas",
source: "/extensions/canvas/index.ts",
rootDir: "/extensions/canvas",
pluginConfig: {},
policy: {
commands: ["canvas.snapshot", "canvas.present"],
defaultPlatforms: ["ios", "android", "macos", "windows", "unknown"],
foregroundRestrictedOnIos: true,
handle: (ctx) => ctx.invokeNode(),
},
});
setActivePluginRegistry(registry);
}
it("normalizes declared node commands against the allowlist", () => {
const allowlist = new Set(["canvas.snapshot", "system.run"]);
expect(
normalizeDeclaredNodeCommands({
declaredCommands: [" canvas.snapshot ", "", "system.run", "system.run", "screen.record"],
allowlist,
}),
).toEqual(["canvas.snapshot", "system.run"]);
});
it("allows declared push-to-talk commands on trusted talk-capable nodes", () => {
const cfg = {} as OpenClawConfig;
for (const platform of ["ios", "android", "macos", "other"]) {
const allowlist = resolveNodeCommandAllowlist(cfg, { platform, caps: ["talk"] });
expect(allowlist.has("talk.ptt.start")).toBe(true);
expect(allowlist.has("talk.ptt.stop")).toBe(true);
expect(allowlist.has("talk.ptt.cancel")).toBe(true);
expect(allowlist.has("talk.ptt.once")).toBe(true);
expect(
isNodeCommandAllowed({
command: "talk.ptt.start",
declaredCommands: ["talk.ptt.start"],
allowlist,
}),
).toEqual({ ok: true });
}
});
it("does not allow push-to-talk commands from platform label alone", () => {
const cfg = {} as OpenClawConfig;
const allowlist = resolveNodeCommandAllowlist(cfg, {
platform: "android",
caps: ["device"],
commands: [],
});
expect(allowlist.has("talk.ptt.start")).toBe(false);
});
it("allows push-to-talk commands when the node declares talk command support", () => {
const cfg = {} as OpenClawConfig;
const allowlist = resolveNodeCommandAllowlist(cfg, {
platform: "custom",
commands: ["talk.ptt.start"],
});
expect(allowlist.has("talk.ptt.start")).toBe(true);
});
it("keeps canvas commands out of core defaults when the canvas plugin is not active", () => {
const allowlist = resolveNodeCommandAllowlist({} as OpenClawConfig, {
platform: "windows",
deviceFamily: "Windows",
});
expect(allowlist.has("canvas.snapshot")).toBe(false);
});
it("adds canvas commands from the active canvas plugin node policy", () => {
installCanvasPluginDefaults();
const allowlist = resolveNodeCommandAllowlist({} as OpenClawConfig, {
platform: "windows",
deviceFamily: "Windows",
});
expect(allowlist.has("canvas.snapshot")).toBe(true);
expect(allowlist.has("canvas.present")).toBe(true);
});
it("does not grant host command defaults for platform prefix aliases", () => {
const cfg = {} as OpenClawConfig;
const cases = [
{ platform: "darwin", deviceFamily: "iPhone" },
{ platform: "darwin", deviceFamily: "Mac" },
{ platform: "macos" },
{ platform: "macos", deviceFamily: "Mac" },
{ platform: "macos", deviceFamily: "iPhone" },
{ platform: "macOS 26.3.1", deviceFamily: "iPhone" },
{ platform: "macOS 26.3.1", deviceFamily: "Mac" },
{ platform: "windows" },
{ platform: "windows", deviceFamily: "Windows" },
{ platform: "windows", deviceFamily: "iPhone" },
{ platform: "linux" },
{ platform: "linux", deviceFamily: "Linux" },
{ platform: "linux", deviceFamily: "iPhone" },
{ platform: "Darwin-x64" },
{ platform: "macintosh" },
{ platform: "win32" },
{ platform: "linux-gnu" },
{
platform: "macos",
deviceFamily: "Mac",
clientId: GATEWAY_CLIENT_IDS.NODE_HOST,
clientMode: GATEWAY_CLIENT_MODES.NODE,
},
];
for (const node of cases) {
const allowlist = resolveNodeCommandAllowlist(cfg, node);
expect(allowlist.has("system.run")).toBe(false);
expect(allowlist.has("system.run.prepare")).toBe(false);
expect(allowlist.has("system.which")).toBe(false);
expect(allowlist.has("browser.proxy")).toBe(false);
expect(allowlist.has("screen.snapshot")).toBe(false);
expect(allowlist.has("system.notify")).toBe(true);
}
});
it("keeps defaults for first-party native platform labels with matching families", () => {
const cfg = {} as OpenClawConfig;
const iosAllowlist = resolveNodeCommandAllowlist(cfg, {
platform: "iOS 18.4.0",
deviceFamily: "iPhone",
});
expect(iosAllowlist.has("device.info")).toBe(true);
expect(iosAllowlist.has("photos.latest")).toBe(true);
expect(iosAllowlist.has("system.run")).toBe(false);
const ipadAllowlist = resolveNodeCommandAllowlist(cfg, {
platform: "iPadOS 18.4.0",
deviceFamily: "iPad",
});
expect(ipadAllowlist.has("device.info")).toBe(true);
expect(ipadAllowlist.has("motion.activity")).toBe(true);
expect(ipadAllowlist.has("system.run")).toBe(false);
const macAllowlist = resolveNodeCommandAllowlist(cfg, {
platform: "macOS 15.5.0",
deviceFamily: "Mac",
});
expect(macAllowlist.has("system.run")).toBe(false);
expect(macAllowlist.has("system.which")).toBe(false);
expect(macAllowlist.has("screen.snapshot")).toBe(false);
});
it("keeps explicitly approved host commands for desktop platforms", () => {
const cfg = {} as OpenClawConfig;
const cases = [
{ platform: "macos", deviceFamily: "Mac" },
{ platform: "windows", deviceFamily: "Windows" },
{ platform: "linux", deviceFamily: "Linux" },
];
for (const node of cases) {
const allowlist = resolveNodeCommandAllowlist(cfg, {
...node,
approvedCommands: ["system.run", "system.which"],
});
expect(allowlist.has("system.run")).toBe(true);
expect(allowlist.has("system.which")).toBe(true);
}
});
it("keeps approved host commands on live desktop node sessions", () => {
const allowlist = resolveNodeCommandAllowlist({} as OpenClawConfig, {
nodeId: "node-1",
connId: "conn-1",
platform: "linux",
deviceFamily: "Linux",
commands: ["browser.proxy", "system.run"],
});
expect(allowlist.has("browser.proxy")).toBe(true);
expect(allowlist.has("system.run")).toBe(true);
});
it("does not treat unconnected declared host commands as approved", () => {
const allowlist = resolveNodeCommandAllowlist({} as OpenClawConfig, {
platform: "linux",
deviceFamily: "Linux",
commands: ["browser.proxy", "system.run"],
});
expect(allowlist.has("browser.proxy")).toBe(false);
expect(allowlist.has("system.run")).toBe(false);
});
it("does not grandfather approved non-default commands after config removal", () => {
const staleApproval = resolveNodeCommandAllowlist({} as OpenClawConfig, {
platform: "macos",
deviceFamily: "Mac",
approvedCommands: ["screen.record"],
});
expect(staleApproval.has("screen.record")).toBe(false);
const currentConfigApproval = resolveNodeCommandAllowlist(
{
gateway: {
nodes: {
allowCommands: ["screen.record"],
},
},
} as OpenClawConfig,
{
platform: "macos",
deviceFamily: "Mac",
approvedCommands: ["screen.record"],
},
);
expect(currentConfigApproval.has("screen.record")).toBe(true);
});
it("reads foreground restriction metadata from plugin node policies", () => {
expect(isForegroundRestrictedPluginNodeCommand("canvas.snapshot")).toBe(false);
installCanvasPluginDefaults();
expect(isForegroundRestrictedPluginNodeCommand("canvas.snapshot")).toBe(true);
expect(isForegroundRestrictedPluginNodeCommand("system.run")).toBe(false);
});
});