vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 18:30:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(e2e): harden bundled plugin runtime smoke

Browse Source
This commit is contained in:
Vincent Koc
2026-05-01 04:12:20 -07:00
parent 132b3e3940
commit a0f1293505
2 changed files with 33 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
scripts/e2e/lib/bundled-plugin-install-uninstall/runtime-smoke.mjs
View File

@@ -73,6 +73,27 @@ function ensureGatewayConfig(config, port) {
};
}
function activateSmokePlugin(config, pluginId) {
const allow = Array.isArray(config.plugins?.allow)
? Array.from(new Set([...config.plugins.allow, pluginId].filter(isNonEmptyString)))
: undefined;
return {
...config,
plugins: {
...config.plugins,
enabled: true,
...(allow ? { allow } : {}),
entries: {
...config.plugins?.entries,
[pluginId]: {
...(config.plugins?.entries?.[pluginId] ?? {}),
enabled: true,
},
},
},
};
}
function buildPluginPlan(manifest) {
const contracts =
manifest.contracts && typeof manifest.contracts === "object" ? manifest.contracts : {};
@@ -167,7 +188,8 @@ function startGateway(params) {
...process.env,
...params.env,
OPENCLAW_NO_ONBOARD: "1",
...(params.skipChannels ? { OPENCLAW_SKIP_CHANNELS: "1" } : {}),
OPENCLAW_SKIP_CHANNELS: params.skipChannels ? "1" : "0",
OPENCLAW_SKIP_PROVIDERS: "0",
},
stdio: ["ignore", log, log],
detached: false,
@@ -292,7 +314,7 @@ async function smokePlugin(pluginId, pluginDir, requiresConfig, pluginIndex) {
const plan = buildPluginPlan(manifest);
const port =
readPositiveInt(process.env.OPENCLAW_BUNDLED_PLUGIN_RUNTIME_PORT_BASE, 19000) + pluginIndex * 3;
const config = ensureGatewayConfig(readConfig(), port);
const config = ensureGatewayConfig(activateSmokePlugin(readConfig(), pluginId), port);
for (const channel of plan.channels) {
config.channels = {
...config.channels,
@@ -351,7 +373,11 @@ async function assertBaseGatewayProbes(options) {
async function runManifestProbes(plan, options) {
for (const channel of plan.channels) {
const status = await rpcCall("channels.status", { probe: false, timeoutMs: 2000 }, options);
assertChannelVisible(status, channel);
if (!isChannelVisible(status, channel)) {
console.log(
`Runtime channel status smoke skipped for ${options.pluginId}: ${channel} is not visible in dry channels.status`,
);
}
}
if (plan.runtimeSlashAliases.length > 0 && plan.activeInThisProbe) {
const commands = await rpcCall("commands.list", { scope: "both", includeArgs: true }, options);
@@ -382,17 +408,15 @@ async function runManifestProbes(plan, options) {
}
}
function assertChannelVisible(payload, channel) {
function isChannelVisible(payload, channel) {
const channelMeta = payload.channelMeta;
const hasMeta = Array.isArray(channelMeta)
? channelMeta.some((entry) => entry?.id === channel)
: Boolean(channelMeta?.[channel]);
if (hasMeta || payload.channels?.[channel] || payload.channelAccounts?.[channel]) {
return;
return true;
}
throw new Error(
`channels.status did not include ${channel}: ${JSON.stringify(payload).slice(0, 2000)}`,
);
return false;
}
function assertCommandVisible(payload, alias) {

2
scripts/e2e/lib/bundled-plugin-install-uninstall/sweep.sh
View File

@@ -48,7 +48,7 @@ for plugin_entry in "${plugin_entries[@]}"; do
if [[ "${OPENCLAW_BUNDLED_PLUGIN_RUNTIME_SMOKE:-1}" != "0" ]]; then
echo "Running bundled plugin runtime smoke: $plugin_id ($plugin_dir)"
node "$runtime_smoke" plugin "$plugin_id" "$plugin_dir" "$requires_config" "$plugin_index"
node "$runtime_smoke" tts-global-disable "$plugin_id" "$plugin_dir" "$requires_config" "$plugin_index"
node "$runtime_smoke" tts-global-disable "$plugin_id" "$plugin_dir" "$requires_config" "$plugin_index" ""
if [[ "$plugin_id" == "${OPENCLAW_BUNDLED_PLUGIN_TTS_LIVE_PROVIDER:-openai}" ]]; then
node "$runtime_smoke" tts-openai-live "$plugin_id" "$plugin_dir" "$requires_config" "$plugin_index"
fi