refactor: call cron service directly for plugin scheduled...

Recent Commits to openclaw:main

steipete · 2026-05-11 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -2,6 +2,7 @@ import { primeConfiguredBindingRegistry } from "../channels/plugins/binding-regi`
`2`	`2`	`import { applyPluginAutoEnable } from "../config/plugin-auto-enable.js";`
`3`	`3`	`import type { OpenClawConfig } from "../config/types.openclaw.js";`
`4`	`4`	`import type { PluginLookUpTable } from "../plugins/plugin-lookup-table.js";`
	`5`	`+import type { PluginRegistryParams } from "../plugins/registry-types.js";`
`5`	`6`	`import type { PluginRegistry } from "../plugins/registry.js";`
`6`	`7`	`import { pinActivePluginChannelRegistry } from "../plugins/runtime.js";`
`7`	`8`	`import {`
`@@ -35,6 +36,7 @@ type GatewayPluginBootstrapParams = {`
`35`	`36`	`log: GatewayPluginBootstrapLog;`
`36`	`37`	`coreGatewayHandlers?: Record<string, GatewayRequestHandler>;`
`37`	`38`	`coreGatewayMethodNames?: readonly string[];`
	`39`	`+hostServices?: PluginRegistryParams["hostServices"];`
`38`	`40`	`baseMethods: string[];`
`39`	`41`	`pluginIds?: string[];`
`40`	`42`	`pluginLookUpTable?: PluginLookUpTable;`
`@@ -102,6 +104,9 @@ export function prepareGatewayPluginLoad(params: GatewayPluginBootstrapParams) {`
`102`	`104`	`...(params.coreGatewayMethodNames !== undefined && {`
`103`	`105`	`coreGatewayMethodNames: params.coreGatewayMethodNames,`
`104`	`106`	`}),`
	`107`	`+ ...(params.hostServices !== undefined && {`
	`108`	`+hostServices: params.hostServices,`
	`109`	`+}),`
`105`	`110`	`baseMethods: params.baseMethods,`
`106`	`111`	`pluginIds: params.pluginIds,`
`107`	`112`	`pluginLookUpTable: params.pluginLookUpTable,`

Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,7 @@ import { clearActivatedPluginRuntimeState, loadOpenClawPlugins } from "../plugin`
`8`	`8`	`import { loadPluginLookUpTable, type PluginLookUpTable } from "../plugins/plugin-lookup-table.js";`
`9`	`9`	`import { getPluginModuleLoaderStats } from "../plugins/plugin-module-loader-cache.js";`
`10`	`10`	`import { createEmptyPluginRegistry } from "../plugins/registry-empty.js";`
	`11`	`+import type { PluginRegistryParams } from "../plugins/registry-types.js";`
`11`	`12`	`import { setActivePluginRegistry } from "../plugins/runtime.js";`
`12`	`13`	`import { getPluginRuntimeGatewayRequestScope } from "../plugins/runtime/gateway-request-scope.js";`
`13`	`14`	`import { createPluginRuntimeLoaderLogger } from "../plugins/runtime/load-context.js";`
`@@ -527,6 +528,7 @@ export function loadGatewayPlugins(params: {`
`527`	`528`	`};`
`528`	`529`	`coreGatewayHandlers?: Record<string, GatewayRequestHandler>;`
`529`	`530`	`coreGatewayMethodNames?: readonly string[];`
	`531`	`+hostServices?: PluginRegistryParams["hostServices"];`
`530`	`532`	`baseMethods: string[];`
`531`	`533`	`pluginIds?: string[];`
`532`	`534`	`pluginLookUpTable?: PluginLookUpTable;`
`@@ -616,6 +618,9 @@ export function loadGatewayPlugins(params: {`
`616`	`618`	`...(params.coreGatewayMethodNames !== undefined && {`
`617`	`619`	`coreGatewayMethodNames: params.coreGatewayMethodNames,`
`618`	`620`	`}),`
	`621`	`+ ...(params.hostServices !== undefined && {`
	`622`	`+hostServices: params.hostServices,`
	`623`	`+}),`
`619`	`624`	`runtimeOptions: {`
`620`	`625`	`allowGatewaySubagentBinding: true,`
`621`	`626`	`},`

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,7 @@ import { applyPluginAutoEnable } from "../config/plugin-auto-enable.js";`
`4`	`4`	`import type { OpenClawConfig } from "../config/types.openclaw.js";`
`5`	`5`	`import { loadPluginLookUpTable } from "../plugins/plugin-lookup-table.js";`
`6`	`6`	`import type { PluginMetadataSnapshot } from "../plugins/plugin-metadata-snapshot.js";`
	`7`	`+import type { PluginRegistryParams } from "../plugins/registry-types.js";`
`7`	`8`	`import { createEmptyPluginRegistry } from "../plugins/registry.js";`
`8`	`9`	`import { getActivePluginRegistry, setActivePluginRegistry } from "../plugins/runtime.js";`
`9`	`10`	`import { mergeActivationSectionsIntoRuntimeConfig } from "./plugin-activation-runtime-config.js";`
`@@ -151,6 +152,7 @@ export async function loadGatewayStartupPluginRuntime(params: {`
`151`	`152`	`workspaceDir: string;`
`152`	`153`	`log: GatewayPluginBootstrapLog;`
`153`	`154`	`baseMethods: string[];`
	`155`	`+hostServices?: PluginRegistryParams["hostServices"];`
`154`	`156`	`startupPluginIds: string[];`
`155`	`157`	`pluginLookUpTable?: ReturnType<typeof loadPluginLookUpTable>;`
`156`	`158`	`preferSetupRuntimeForChannelPlugins?: boolean;`
`@@ -165,6 +167,9 @@ export async function loadGatewayStartupPluginRuntime(params: {`
`165`	`167`	`log: params.log,`
`166`	`168`	`coreGatewayMethodNames: params.baseMethods,`
`167`	`169`	`baseMethods: params.baseMethods,`
	`170`	`+ ...(params.hostServices !== undefined && {`
	`171`	`+hostServices: params.hostServices,`
	`172`	`+}),`
`168`	`173`	`pluginIds: params.startupPluginIds,`
`169`	`174`	`pluginLookUpTable: params.pluginLookUpTable,`
`170`	`175`	`preferSetupRuntimeForChannelPlugins: params.preferSetupRuntimeForChannelPlugins,`

Original file line number	Diff line number	Diff line change
`@@ -882,6 +882,11 @@ export async function startGatewayServer(`
`882`	`882`	`gatewayMethods: listActiveGatewayMethods(baseGatewayMethods),`
`883`	`883`	`});`
`884`	`884`	`deps.cron = runtimeState.cronState.cron;`
	`885`	`+const pluginHostServices = {`
	`886`	`+get cron() {`
	`887`	`+return runtimeState.cronState.cron;`
	`888`	`+},`
	`889`	`+};`
`885`	`890`
`886`	`891`	`let closePreludeStarted = false;`
`887`	`892`	`let postReadyMaintenanceTimer: ReturnType<typeof setTimeout> \| null = null;`
`@@ -1177,6 +1182,7 @@ export async function startGatewayServer(`
`1177`	`1182`	`workspaceDir: defaultWorkspaceDir,`
`1178`	`1183`	`log,`
`1179`	`1184`	`coreGatewayMethodNames: baseMethods,`
	`1185`	`+hostServices: pluginHostServices,`
`1180`	`1186`	`baseMethods,`
`1181`	`1187`	`pluginLookUpTable: nextPluginLookUpTable,`
`1182`	`1188`	`});`
`@@ -1307,6 +1313,7 @@ export async function startGatewayServer(`
`1307`	`1313`	`workspaceDir: defaultWorkspaceDir,`
`1308`	`1314`	`log,`
`1309`	`1315`	`coreGatewayMethodNames: baseMethods,`
	`1316`	`+hostServices: pluginHostServices,`
`1310`	`1317`	`baseMethods,`
`1311`	`1318`	`pluginIds: startupPluginIds,`
`1312`	`1319`	`pluginLookUpTable,`
`@@ -1415,6 +1422,7 @@ export async function startGatewayServer(`
`1415`	`1422`	`workspaceDir: defaultWorkspaceDir,`
`1416`	`1423`	`log,`
`1417`	`1424`	`baseMethods,`
	`1425`	`+hostServices: pluginHostServices,`
`1418`	`1426`	`startupPluginIds,`
`1419`	`1427`	`pluginLookUpTable,`
`1420`	`1428`	`startupTrace,`

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,4 @@`
	`1`	`+import type { PluginRegistryParams } from "../../plugins/registry-types.js";`
`1`	`2`	`import type { OpenClawPluginApi } from "../plugin-entry.js";`
`2`	`3`	`import {`
`3`	`4`	`createPluginRecord,`
`@@ -13,7 +14,10 @@ import { uniqueSortedStrings } from "./string-utils.js";`
`13`	`14`
`14`	`15`	`export { registerProviders, requireProvider, uniqueSortedStrings };`
`15`	`16`
`16`		`-export function createPluginRegistryFixture(config = {} as OpenClawConfig) {`
	`17`	`+export function createPluginRegistryFixture(`
	`18`	`+config = {} as OpenClawConfig,`
	`19`	`+params: { hostServices?: PluginRegistryParams["hostServices"] } = {},`
	`20`	`+) {`
`17`	`21`	`return {`
`18`	`22`	`config,`
`19`	`23`	`registry: createPluginRegistry({`
`@@ -24,6 +28,7 @@ export function createPluginRegistryFixture(config = {} as OpenClawConfig) {`
`24`	`28`	`debug() {},`
`25`	`29`	`},`
`26`	`30`	`runtime: {} as PluginRuntime,`
	`31`	`+ ...(params.hostServices ? { hostServices: params.hostServices } : {}),`
`27`	`32`	`}),`
`28`	`33`	`};`
`29`	`34`	`}`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main