import { i as HookEntry } from "./internal-hook-types-CKIMi9vm.js"; import { $ as PluginHookModelCallStartedEvent, $t as PluginHookBeforeAgentStartEvent, A as PluginHookBeforeMessageWriteResult, C as PluginHookBeforeInstallEvent, E as PluginHookBeforeInstallResult, Et as PluginHookToolResultPersistResult, F as PluginHookCronChangedEvent, Ft as PluginAgentTurnPrepareEvent, G as PluginHookGatewayStartEvent, Gt as PluginHookMessageContext, I as PluginHookGatewayContext, It as PluginAgentTurnPrepareResult, J as PluginHookInboundClaimResult, Jt as PluginHookMessageSendingResult, K as PluginHookGatewayStopEvent, Kt as PluginHookMessageReceivedEvent, Lt as PluginHeartbeatPromptContributionEvent, M as PluginHookBeforeToolCallEvent, N as PluginHookBeforeToolCallResult, Q as PluginHookModelCallEndedEvent, Rt as PluginHeartbeatPromptContributionResult, S as PluginHookBeforeInstallContext, Tt as PluginHookToolResultPersistEvent, Ut as PluginHookInboundClaimContext, Wt as PluginHookInboundClaimEvent, X as PluginHookLlmOutputEvent, Xt as GateHookResult, Y as PluginHookLlmInputEvent, Yt as PluginHookMessageSentEvent, Zt as InputGateDecision, _ as PluginHookBeforeCompactionEvent, _t as PluginHookSubagentSpawnedEvent, an as PluginHookBeforePromptBuildEvent, b as PluginHookBeforeDispatchResult, c as PluginHookAfterToolCallEvent, ct as PluginHookReplyPayloadSendingResult, d as PluginHookBeforeAgentFinalizeEvent, et as PluginHookName, f as PluginHookBeforeAgentFinalizeResult, ft as PluginHookSessionStartEvent, gt as PluginHookSubagentEndedEvent, h as PluginHookBeforeAgentRunEvent, ht as PluginHookSubagentDeliveryTargetResult, in as PluginHookBeforeModelResolveResult, it as PluginHookReplyDispatchResult, j as PluginHookBeforeResetEvent, k as PluginHookBeforeMessageWriteEvent, l as PluginHookAgentContext, lt as PluginHookSessionContext, m as PluginHookBeforeAgentReplyResult, mt as PluginHookSubagentDeliveryTargetEvent, nt as PluginHookReplyDispatchContext, on as PluginHookBeforePromptBuildResult, ot as PluginHookReplyPayloadSendingContext, p as PluginHookBeforeAgentReplyEvent, pt as PluginHookSubagentContext, qt as PluginHookMessageSendingEvent, rn as PluginHookBeforeModelResolveEvent, rt as PluginHookReplyDispatchEvent, s as PluginHookAfterCompactionEvent, st as PluginHookReplyPayloadSendingEvent, tn as PluginHookBeforeAgentStartResult, tt as PluginHookRegistration, u as PluginHookAgentEndEvent, ut as PluginHookSessionEndEvent, v as PluginHookBeforeDispatchContext, vt as PluginHookSubagentSpawningEvent, wt as PluginHookToolResultPersistContext, xt as PluginHookToolContext, y as PluginHookBeforeDispatchEvent, yt as PluginHookSubagentSpawningResult } from "./hook-types-Ddb7SJ-d.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 VoidHookRunOptions = { unrefTimeout?: boolean; }; 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, options?: VoidHookRunOptions) => 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; runReplyPayloadSending: (event: PluginHookReplyPayloadSendingEvent, ctx: PluginHookReplyPayloadSendingContext) => 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 };