50 lines
2.5 KiB
JavaScript
50 lines
2.5 KiB
JavaScript
// `mosaic plugins` (vikunja:19/305, REQ-PLUG-1): read and switch the organization file's plug-in
|
|
// modules through the broker's plugins and plugins.set verbs, the human's and, with --tester, the
|
|
// tester's (row 175, #1673, Q173). The broker refuses an agent and a reader, a stale revision, a bad
|
|
// shape and a module that doesn't exist, and the change is logged with its actor (the human or
|
|
// `tester`) in the organization's changes.jsonl.
|
|
import { readFileSync } from "node:fs";
|
|
import { CliError } from "./errors.mjs";
|
|
import { orgSelector } from "./org-selector.mjs";
|
|
|
|
export const PLUGINS_USAGE = "mosaic plugins [--business ID] [--json] [--tester] | set --file PATCH [--business ID] [--tester] | install SOURCE --sha256 HASH [--commit FULL_SHA] | list | remove NAME";
|
|
|
|
function parse(args) {
|
|
const out = { positional: [], flags: new Set(), values: {} };
|
|
// --org and --business are one selector in this parser's scope (rename design r2).
|
|
const selector = orgSelector(() => new CliError(PLUGINS_USAGE, 4));
|
|
for (let i = 0; i < args.length; i++) {
|
|
const arg = args[i];
|
|
if (selector.owns(arg)) { selector.take(arg, args[i + 1]); i++; }
|
|
else if (arg === "--json" || arg === "--tester") out.flags.add(arg);
|
|
else if (arg === "--file") {
|
|
if (!args[i + 1] || Object.hasOwn(out.values, arg)) throw new CliError(PLUGINS_USAGE, 4);
|
|
out.values[arg] = args[++i];
|
|
} else if (arg.startsWith("--")) throw new CliError(PLUGINS_USAGE, 4);
|
|
else out.positional.push(arg);
|
|
}
|
|
if (selector.given) out.values["--business"] = selector.value;
|
|
return out;
|
|
}
|
|
|
|
// PATCH is { "revision": <from a read>, "plugins": { "<kind>": <name or [names] or null> } }. It names
|
|
// the kinds it changes: a kind with a value is switched to it, a kind with null is removed, and a
|
|
// kind it doesn't name keeps its setting (vikunja:19/309). An empty patch is refused.
|
|
export async function pluginsCommand(args, io, callFor) {
|
|
const parsed = parse(args);
|
|
const verb = parsed.positional[0] ?? "view";
|
|
if (parsed.positional.length > 1 || !["view", "set"].includes(verb) || (verb === "set") !== Boolean(parsed.values["--file"])) {
|
|
throw new CliError(PLUGINS_USAGE, 4);
|
|
}
|
|
try {
|
|
const call = callFor(parsed);
|
|
const result = verb === "set"
|
|
? await call("plugins.set", JSON.parse(readFileSync(parsed.values["--file"], "utf8")))
|
|
: await call("plugins", {});
|
|
io.stdout.write(JSON.stringify(result, null, 2) + "\n");
|
|
} catch (error) {
|
|
if (error instanceof CliError) throw error;
|
|
throw new CliError(error.message, 2);
|
|
}
|
|
}
|