Files
openclaw/scripts/check-no-deprecated-channel-access.ts
Peter SteinbergerandGitHub 601ffa2530 refactor(channels): move inbound turn execution into core (#110095)
* refactor(channels): centralize turn execution lifecycle

* refactor(extensions): adopt core channel turn plans

* test(channels): ratchet modern dispatch ownership

* chore(channels): drop stale max-lines exemption

* fix(channels): allow async delivery error cleanup

* test(channels): await async delivery cleanup

* test(channels): await delivery error callbacks

* fix(channels): preserve delivery error contract

* fix(plugin-sdk): preserve channel inbound declarations

* test(channels): exercise core delivery plans

* fix(channels): await delivery error cleanup

* fix(channels): preserve async cleanup contract

* refactor(channels): trim dispatch boilerplate

* fix(channels): mask observe-only dispatch results

* refactor(channels): delete unused dispatch exports

* fix(msteams): preserve resolver config overrides

* refactor(channels): keep Teams turn config internal

* test(plugins): drop retired Teams runtime export guard
2026-07-18 00:55:46 +01:00

116 lines
3.9 KiB
TypeScript

// Check No Deprecated Channel Access script supports OpenClaw repository automation.
import fs from "node:fs";
import path from "node:path";
import { collectFilesSync, isCodeFile, relativeToCwd } from "./check-file-utils.js";
import { classifyBundledExtensionSourcePath } from "./lib/extension-source-classifier.mjs";
type Rule = {
label: string;
pattern: RegExp;
};
const RULES: Rule[] = [
{
label: "deprecated channel runtime",
pattern:
/\.channel\.(?:reply\.(?:createReplyDispatcherWithTyping|resolveHumanDelayConfig|dispatchReplyFromConfig|finalizeInboundContext|formatInboundEnvelope)|session\.(?:resolveStorePath|recordInboundSession)|inbound\.(?:runPreparedReply|dispatchReply)|media\.fetchRemoteMedia)\b/u,
},
{
label: "caller-owned prepared channel dispatch",
pattern: /\b(?:runDispatch|onPreDispatchFailure)\b/u,
},
{
label: "caller-owned reply dispatcher lifecycle",
pattern:
/\b(?:createReplyDispatcherWithTyping|dispatchInboundMessage(?:WithBufferedDispatcher|WithDispatcher)?|dispatchReplyFromConfigWithSettledDispatcher|settleReplyDispatcher)\s*\(/u,
},
{
label: "deprecated channel ingress resolver aliases",
pattern:
/\b(?:resolved|result|directResolved|groupResolved)\.(?:legacyAccess|senderReasonCode|commandAuthorized|shouldBlockControlCommand)\b/u,
},
{
label: "inline deprecated channel ingress legacyAccess projection",
pattern: /\)\.legacyAccess\b/u,
},
{
label: "deprecated pairing-store access helper",
pattern: /\breadStoreAllowFromForDmPolicy\b/u,
},
{
label: "deprecated DM/group access helper",
pattern: /\bresolveDmGroupAccessWith(?:Lists|CommandGate)\b/u,
},
{
label: "deprecated DM/group access reason constants",
pattern: /\bDM_GROUP_ACCESS_REASON\b/u,
},
{
label: "deprecated group policy access helper",
pattern:
/\b(?:resolveSenderScopedGroupPolicy|evaluateSenderGroupAccess(?:ForPolicy)?|evaluateGroupRouteAccessForPolicy|evaluateMatchedGroupAccessForPolicy)\b/u,
},
{
label: "deprecated group access compatibility module",
pattern: /from\s+["']openclaw\/plugin-sdk\/group-access["']/u,
},
{
label: "deprecated command authorization helper",
pattern: /\bresolveSenderCommandAuthorization(?:WithRuntime)?\b/u,
},
{
label: "deprecated command auth SDK facade",
pattern: /from\s+["']openclaw\/plugin-sdk\/command-auth["']/u,
},
];
function collectBundledPluginProductionFiles(): string[] {
const extensionsDir = path.join(process.cwd(), "extensions");
return collectFilesSync(extensionsDir, {
includeFile(filePath) {
if (!isCodeFile(filePath)) {
return false;
}
const repoPath = relativeToCwd(filePath);
const classified = classifyBundledExtensionSourcePath(repoPath);
return classified.isProductionSource;
},
}).toSorted((left, right) => relativeToCwd(left).localeCompare(relativeToCwd(right)));
}
function main() {
const offenders: Array<{ file: string; line: number; label: string; text: string }> = [];
for (const file of collectBundledPluginProductionFiles()) {
const content = fs.readFileSync(file, "utf8");
const lines = content.split(/\r?\n/u);
for (const [index, line] of lines.entries()) {
for (const rule of RULES) {
if (rule.pattern.test(line)) {
offenders.push({
file: relativeToCwd(file),
line: index + 1,
label: rule.label,
text: line.trim(),
});
}
}
}
}
if (offenders.length > 0) {
console.error(
"Bundled plugin production code must use modern channel runtime and access seams.",
);
for (const offender of offenders) {
console.error(`- ${offender.file}:${offender.line}: ${offender.label}: ${offender.text}`);
}
process.exit(1);
}
console.log(
"OK: bundled plugin production code avoids deprecated channel runtime and access seams.",
);
}
main();