import { t as HookEntry } from "./types-CZ5dWnd9.js"; import { $ as PluginHookModelCallStartedEvent, A as PluginHookBeforeMessageWriteResult, At as PluginAgentTurnPrepareResult, Bt as PluginHookMessageReceivedEvent, C as PluginHookBeforeInstallEvent, E as PluginHookBeforeInstallResult, F as PluginHookCronChangedEvent, G as PluginHookGatewayStartEvent, Ht as PluginHookMessageSendingResult, I as PluginHookGatewayContext, J as PluginHookInboundClaimResult, K as PluginHookGatewayStopEvent, Lt as PluginHookInboundClaimContext, M as PluginHookBeforeToolCallEvent, Mt as PluginHeartbeatPromptContributionResult, N as PluginHookBeforeToolCallResult, Q as PluginHookModelCallEndedEvent, Qt as PluginHookBeforeAgentStartEvent, Rt as PluginHookInboundClaimEvent, S as PluginHookBeforeInstallContext, Ut as PluginHookMessageSentEvent, Vt as PluginHookMessageSendingEvent, X as PluginHookLlmOutputEvent, Xt as InputGateDecision, Y as PluginHookLlmInputEvent, Yt as GateHookResult, _ as PluginHookBeforeCompactionEvent, _t as PluginHookToolContext, an as PluginHookBeforePromptBuildResult, at as PluginHookSessionContext, b as PluginHookBeforeDispatchResult, bt as PluginHookToolResultPersistResult, c as PluginHookAfterToolCallEvent, ct as PluginHookSessionStartEvent, d as PluginHookBeforeAgentFinalizeEvent, dt as PluginHookSubagentDeliveryTargetResult, en as PluginHookBeforeAgentStartResult, et as PluginHookName, f as PluginHookBeforeAgentFinalizeResult, ft as PluginHookSubagentEndedEvent, h as PluginHookBeforeAgentRunEvent, ht as PluginHookSubagentSpawningResult, in as PluginHookBeforePromptBuildEvent, it as PluginHookReplyDispatchResult, j as PluginHookBeforeResetEvent, jt as PluginHeartbeatPromptContributionEvent, k as PluginHookBeforeMessageWriteEvent, kt as PluginAgentTurnPrepareEvent, l as PluginHookAgentContext, lt as PluginHookSubagentContext, m as PluginHookBeforeAgentReplyResult, mt as PluginHookSubagentSpawningEvent, nn as PluginHookBeforeModelResolveEvent, nt as PluginHookReplyDispatchContext, ot as PluginHookSessionEndEvent, p as PluginHookBeforeAgentReplyEvent, pt as PluginHookSubagentSpawnedEvent, rn as PluginHookBeforeModelResolveResult, rt as PluginHookReplyDispatchEvent, s as PluginHookAfterCompactionEvent, tt as PluginHookRegistration, u as PluginHookAgentEndEvent, ut as PluginHookSubagentDeliveryTargetEvent, v as PluginHookBeforeDispatchContext, vt as PluginHookToolResultPersistContext, y as PluginHookBeforeDispatchEvent, yt as PluginHookToolResultPersistEvent, zt as PluginHookMessageContext } from "./hook-types-CPHkmr9n.js"; //#region src/plugins/hook-registry.types.d.ts type PluginLegacyHookRegistration = { pluginId: string; entry: HookEntry; events: string[]; source: string; rootDir?: string; }; type HookRunnerRegistry = { hooks: PluginLegacyHookRegistration[]; typedHooks: PluginHookRegistration[]; }; type GlobalHookRunnerRegistry = HookRunnerRegistry & { plugins: Array<{ id: string; status: "loaded" | "disabled" | "error"; }>; }; //#endregion //#region src/plugins/hooks.d.ts type HookRunnerLogger = { debug?: (message: string) => void; warn: (message: string) => void; error: (message: string) => void; }; type HookFailurePolicy = "fail-open" | "fail-closed"; type HookRunnerOptions = { logger?: HookRunnerLogger; /** If true, errors in hooks will be caught and logged instead of thrown */ catchErrors?: boolean; /** * Optional per-hook failure policy. * Defaults to fail-open unless explicitly overridden for a hook name. */ failurePolicyByHook?: Partial>; /** * Optional timeout for void/observation hooks. A timed-out hook is logged and * the runner continues, but the plugin's underlying work is not cancelled. */ voidHookTimeoutMsByHook?: Partial>; /** * Optional timeout for modifying hooks. A timed-out hook is logged and skipped, * but the plugin's underlying work is not cancelled. */ modifyingHookTimeoutMsByHook?: Partial>; }; type PluginTargetedInboundClaimOutcome = { status: "handled"; result: PluginHookInboundClaimResult; } | { status: "missing_plugin"; } | { status: "no_handler"; } | { status: "declined"; } | { status: "error"; error: string; }; /** * Create a hook runner for a specific registry. */ declare function createHookRunner(registry: GlobalHookRunnerRegistry, options?: HookRunnerOptions): { runBeforeModelResolve: (event: PluginHookBeforeModelResolveEvent, ctx: PluginHookAgentContext) => Promise; runAgentTurnPrepare: (event: PluginAgentTurnPrepareEvent, ctx: PluginHookAgentContext) => Promise; runBeforePromptBuild: (event: PluginHookBeforePromptBuildEvent, ctx: PluginHookAgentContext) => Promise; runBeforeAgentStart: (event: PluginHookBeforeAgentStartEvent, ctx: PluginHookAgentContext) => Promise; runBeforeAgentReply: (event: PluginHookBeforeAgentReplyEvent, ctx: PluginHookAgentContext) => Promise; runModelCallStarted: (event: PluginHookModelCallStartedEvent, ctx: PluginHookAgentContext) => Promise; runModelCallEnded: (event: PluginHookModelCallEndedEvent, ctx: PluginHookAgentContext) => Promise; runLlmInput: (event: PluginHookLlmInputEvent, ctx: PluginHookAgentContext) => Promise; runLlmOutput: (event: PluginHookLlmOutputEvent, ctx: PluginHookAgentContext) => Promise; runBeforeAgentFinalize: (event: PluginHookBeforeAgentFinalizeEvent, ctx: PluginHookAgentContext) => Promise; runAgentEnd: (event: PluginHookAgentEndEvent, ctx: PluginHookAgentContext) => Promise; runBeforeCompaction: (event: PluginHookBeforeCompactionEvent, ctx: PluginHookAgentContext) => Promise; runAfterCompaction: (event: PluginHookAfterCompactionEvent, ctx: PluginHookAgentContext) => Promise; runBeforeReset: (event: PluginHookBeforeResetEvent, ctx: PluginHookAgentContext) => Promise; runBeforeAgentRun: (event: PluginHookBeforeAgentRunEvent, ctx: PluginHookAgentContext) => Promise | undefined>; runInboundClaim: (event: PluginHookInboundClaimEvent, ctx: PluginHookInboundClaimContext) => Promise; runInboundClaimForPlugin: (pluginId: string, event: PluginHookInboundClaimEvent, ctx: PluginHookInboundClaimContext) => Promise; runInboundClaimForPluginOutcome: (pluginId: string, event: PluginHookInboundClaimEvent, ctx: PluginHookInboundClaimContext) => Promise; runMessageReceived: (event: PluginHookMessageReceivedEvent, ctx: PluginHookMessageContext) => Promise; runBeforeDispatch: (event: PluginHookBeforeDispatchEvent, ctx: PluginHookBeforeDispatchContext) => Promise; runReplyDispatch: (event: PluginHookReplyDispatchEvent, ctx: PluginHookReplyDispatchContext) => Promise; runMessageSending: (event: PluginHookMessageSendingEvent, ctx: PluginHookMessageContext) => Promise; runMessageSent: (event: PluginHookMessageSentEvent, ctx: PluginHookMessageContext) => Promise; runBeforeToolCall: (event: PluginHookBeforeToolCallEvent, ctx: PluginHookToolContext) => Promise; runAfterToolCall: (event: PluginHookAfterToolCallEvent, ctx: PluginHookToolContext) => Promise; runToolResultPersist: (event: PluginHookToolResultPersistEvent, ctx: PluginHookToolResultPersistContext) => PluginHookToolResultPersistResult | undefined; runBeforeMessageWrite: (event: PluginHookBeforeMessageWriteEvent, ctx: { agentId?: string; sessionKey?: string; }) => PluginHookBeforeMessageWriteResult | undefined; runSessionStart: (event: PluginHookSessionStartEvent, ctx: PluginHookSessionContext) => Promise; runSessionEnd: (event: PluginHookSessionEndEvent, ctx: PluginHookSessionContext) => Promise; runSubagentSpawning: (event: PluginHookSubagentSpawningEvent, ctx: PluginHookSubagentContext) => Promise; runSubagentDeliveryTarget: (event: PluginHookSubagentDeliveryTargetEvent, ctx: PluginHookSubagentContext) => Promise; runSubagentSpawned: (event: PluginHookSubagentSpawnedEvent, ctx: PluginHookSubagentContext) => Promise; runSubagentEnded: (event: PluginHookSubagentEndedEvent, ctx: PluginHookSubagentContext) => Promise; runGatewayStart: (event: PluginHookGatewayStartEvent, ctx: PluginHookGatewayContext) => Promise; runGatewayStop: (event: PluginHookGatewayStopEvent, ctx: PluginHookGatewayContext) => Promise; runHeartbeatPromptContribution: (event: PluginHeartbeatPromptContributionEvent, ctx: PluginHookAgentContext) => Promise; runCronChanged: (event: PluginHookCronChangedEvent, ctx: PluginHookGatewayContext) => Promise; runBeforeInstall: (event: PluginHookBeforeInstallEvent, ctx: PluginHookBeforeInstallContext) => Promise; hasHooks: (hookName: PluginHookName) => boolean; getHookCount: (hookName: PluginHookName) => number; }; type HookRunner = ReturnType; //#endregion //#region src/plugins/hook-runner-global.d.ts /** * Initialize the global hook runner with a plugin registry. * Called once when plugins are loaded during gateway startup. */ declare function initializeGlobalHookRunner(registry: GlobalHookRunnerRegistry): void; /** * Get the global hook runner. * Returns null if plugins haven't been loaded yet. */ declare function getGlobalHookRunner(): HookRunner | null; /** * Get the global plugin registry. * Returns null if plugins haven't been loaded yet. */ declare function getGlobalPluginRegistry(): GlobalHookRunnerRegistry | null; /** * Check if any hooks are registered for a given hook name. */ declare function hasGlobalHooks(hookName: Parameters[0]): boolean; declare function runGlobalGatewayStopSafely(params: { event: PluginHookGatewayStopEvent; ctx: PluginHookGatewayContext; onError?: (err: unknown) => void; }): Promise; /** * Reset the global hook runner (for testing). */ declare function resetGlobalHookRunner(): void; //#endregion export { resetGlobalHookRunner as a, initializeGlobalHookRunner as i, getGlobalPluginRegistry as n, runGlobalGatewayStopSafely as o, hasGlobalHooks as r, getGlobalHookRunner as t };