};

}

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 : {};

...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,

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,

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);

}

}

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) {