/**
 * Trigger Manager
 *
 * Central management for all workflow triggers (cron, webhook, event).
 * Coordinates trigger registration, firing, and lifecycle.
 */
import type { WorkflowTrigger, TriggerContext, TriggerManager as ITriggerManager, CronTriggerConfig, WebhookTriggerConfig, EventTriggerConfig, Workflow, WorkflowState } from '@cogitator-ai/types';
import { type WebhookRequest } from './webhook-trigger.js';
/**
 * Trigger store interface
 */
export interface TriggerStore {
    save(trigger: WorkflowTrigger): Promise<void>;
    get(id: string): Promise<WorkflowTrigger | null>;
    update(id: string, updates: Partial<WorkflowTrigger>): Promise<void>;
    delete(id: string): Promise<void>;
    list(workflowName?: string): Promise<WorkflowTrigger[]>;
    listEnabled(): Promise<WorkflowTrigger[]>;
    listByType(type: 'cron' | 'webhook' | 'event'): Promise<WorkflowTrigger[]>;
}
/**
 * In-memory trigger store
 */
export declare class InMemoryTriggerStore implements TriggerStore {
    private triggers;
    save(trigger: WorkflowTrigger): Promise<void>;
    get(id: string): Promise<WorkflowTrigger | null>;
    update(id: string, updates: Partial<WorkflowTrigger>): Promise<void>;
    delete(id: string): Promise<void>;
    list(workflowName?: string): Promise<WorkflowTrigger[]>;
    listEnabled(): Promise<WorkflowTrigger[]>;
    listByType(type: 'cron' | 'webhook' | 'event'): Promise<WorkflowTrigger[]>;
    clear(): void;
}
/**
 * Event emitter for triggers
 */
export interface TriggerEventEmitter {
    emit(eventType: string, payload: unknown): void;
    on(eventType: string, callback: (payload: unknown) => void): () => void;
}
/**
 * Simple event emitter implementation
 */
export declare class SimpleTriggerEventEmitter implements TriggerEventEmitter {
    private listeners;
    emit(eventType: string, payload: unknown): void;
    on(eventType: string, callback: (payload: unknown) => void): () => void;
    clear(): void;
}
/**
 * Trigger manager configuration
 */
export interface TriggerManagerConfig {
    store?: TriggerStore;
    eventEmitter?: TriggerEventEmitter;
    onTriggerFire?: (trigger: WorkflowTrigger, context: TriggerContext) => Promise<string>;
}
/**
 * Default trigger manager implementation
 */
export declare class DefaultTriggerManager implements ITriggerManager {
    private store;
    private eventEmitter;
    private cronExecutor;
    private webhookExecutor;
    private triggerCallbacks;
    private eventListeners;
    private config;
    private _started;
    constructor(config?: TriggerManagerConfig);
    /**
     * Start the trigger manager
     */
    start(): void;
    /**
     * Stop the trigger manager
     */
    stop(): void;
    /**
     * Check if the manager is running
     */
    get isRunning(): boolean;
    /**
     * Register a trigger
     */
    register(trigger: Omit<WorkflowTrigger, 'id' | 'createdAt' | 'triggerCount' | 'errorCount'>): Promise<string>;
    /**
     * Unregister a trigger
     */
    unregister(id: string): Promise<void>;
    /**
     * Enable a trigger
     */
    enable(id: string): Promise<void>;
    /**
     * Disable a trigger
     */
    disable(id: string): Promise<void>;
    /**
     * Get a trigger
     */
    get(id: string): Promise<WorkflowTrigger | null>;
    /**
     * List triggers
     */
    list(workflowName?: string): Promise<WorkflowTrigger[]>;
    /**
     * List enabled triggers
     */
    listEnabled(): Promise<WorkflowTrigger[]>;
    /**
     * Manually fire a trigger
     */
    fire(id: string, partialContext?: Partial<TriggerContext>): Promise<string>;
    /**
     * Subscribe to trigger events
     */
    onTrigger(callback: (trigger: WorkflowTrigger, context: TriggerContext) => void): () => void;
    /**
     * Handle incoming webhook request
     */
    handleWebhook(request: WebhookRequest): Promise<import("./webhook-trigger.js").WebhookHandlerResult | null>;
    /**
     * Emit an event (for event triggers)
     */
    emitEvent(eventType: string, payload: unknown): void;
    /**
     * Register a workflow with triggers
     */
    registerWorkflow<S extends WorkflowState>(workflow: Workflow<S>, triggers: {
        type: 'cron' | 'webhook' | 'event';
        config: CronTriggerConfig | WebhookTriggerConfig | EventTriggerConfig;
    }[]): Promise<string[]>;
    /**
     * Get trigger stats
     */
    getStats(): Promise<{
        total: number;
        enabled: number;
        byType: Record<string, number>;
        totalFired: number;
        totalErrors: number;
    }>;
    /**
     * Dispose the manager
     */
    dispose(): void;
    private registerEventTrigger;
}
/**
 * Create a trigger manager
 */
export declare function createTriggerManager(config?: TriggerManagerConfig): DefaultTriggerManager;
/**
 * Helper to create a cron trigger config
 */
export declare function cronTrigger(expression: string, options?: Partial<Omit<CronTriggerConfig, 'expression'>>): CronTriggerConfig;
/**
 * Helper to create a webhook trigger config
 */
export declare function webhookTrigger(path: string, method?: WebhookTriggerConfig['method'], options?: Partial<Omit<WebhookTriggerConfig, 'path' | 'method'>>): WebhookTriggerConfig;
/**
 * Helper to create an event trigger config
 */
export declare function eventTrigger(eventType: string, options?: Partial<Omit<EventTriggerConfig, 'eventType'>>): EventTriggerConfig;
//# sourceMappingURL=trigger-manager.d.ts.map