admin/Moltbot
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

refactor(cli): dedupe approvals allowlist actions

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-15 14:14:39 +00:00
parent 0f86ee531b
commit d458131821
1 changed files with 36 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
src/cli/exec-approvals-cli.ts
View File

@@ -95,6 +95,14 @@ function exitWithError(message: string): never {
throw new Error(message);
}
function requireTrimmedNonEmpty(value: string, message: string): string {
const trimmed = value.trim();
if (!trimmed) {
exitWithError(message);
}
return trimmed;
}
async function loadWritableSnapshotTarget(opts: ExecApprovalsCliOpts): Promise<{
snapshot: ExecApprovalsSnapshot;
nodeId: string | null;
@@ -262,6 +270,28 @@ function isEmptyAgent(agent: ExecApprovalsAgent): boolean {
);
}
async function loadWritableAllowlistAgent(opts: ExecApprovalsCliOpts): Promise<{
nodeId: string | null;
source: "gateway" | "node" | "local";
targetLabel: string;
baseHash: string;
file: ExecApprovalsFile;
agentKey: string;
agent: ExecApprovalsAgent;
allowlistEntries: NonNullable<ExecApprovalsAgent["allowlist"]>;
}> {
const { snapshot, nodeId, source, targetLabel, baseHash } =
await loadWritableSnapshotTarget(opts);
const file = snapshot.file ?? { version: 1 };
file.version = 1;
const agentKey = resolveAgentKey(opts.agent);
const agent = ensureAgent(file, agentKey);
const allowlistEntries = Array.isArray(agent.allowlist) ? agent.allowlist : [];
return { nodeId, source, targetLabel, baseHash, file, agentKey, agent, allowlistEntries };
}
export function registerExecApprovalsCli(program: Command) {
const formatExample = (cmd: string, desc: string) =>
` ${theme.command(cmd)}\n ${theme.muted(desc)}`;
@@ -364,17 +394,9 @@ export function registerExecApprovalsCli(program: Command) {
.option("--agent <id>", 'Agent id (defaults to "*")')
.action(async (pattern: string, opts: ExecApprovalsCliOpts) => {
try {
const trimmed = pattern.trim();
if (!trimmed) {
exitWithError("Pattern required.");
}
const { snapshot, nodeId, source, targetLabel, baseHash } =
await loadWritableSnapshotTarget(opts);
const file = snapshot.file ?? { version: 1 };
file.version = 1;
const agentKey = resolveAgentKey(opts.agent);
const agent = ensureAgent(file, agentKey);
const allowlistEntries = Array.isArray(agent.allowlist) ? agent.allowlist : [];
const trimmed = requireTrimmedNonEmpty(pattern, "Pattern required.");
const { nodeId, source, targetLabel, baseHash, file, agentKey, agent, allowlistEntries } =
await loadWritableAllowlistAgent(opts);
if (allowlistEntries.some((entry) => normalizeAllowlistEntry(entry) === trimmed)) {
defaultRuntime.log("Already allowlisted.");
return;
@@ -398,17 +420,9 @@ export function registerExecApprovalsCli(program: Command) {
.option("--agent <id>", 'Agent id (defaults to "*")')
.action(async (pattern: string, opts: ExecApprovalsCliOpts) => {
try {
const trimmed = pattern.trim();
if (!trimmed) {
exitWithError("Pattern required.");
}
const { snapshot, nodeId, source, targetLabel, baseHash } =
await loadWritableSnapshotTarget(opts);
const file = snapshot.file ?? { version: 1 };
file.version = 1;
const agentKey = resolveAgentKey(opts.agent);
const agent = ensureAgent(file, agentKey);
const allowlistEntries = Array.isArray(agent.allowlist) ? agent.allowlist : [];
const trimmed = requireTrimmedNonEmpty(pattern, "Pattern required.");
const { nodeId, source, targetLabel, baseHash, file, agentKey, agent, allowlistEntries } =
await loadWritableAllowlistAgent(opts);
const nextEntries = allowlistEntries.filter(
(entry) => normalizeAllowlistEntry(entry) !== trimmed,
);