import type { AttentionSuggestionPayload } from '../../shared/activity.js';
import { type InboxItem } from '../../shared/inbox.js';
import type { WakeQueueEnqueueResult, WakeQueueService } from './wake-queue.service.js';
export interface IngestRuntimeDecision {
    attentionSuggestion?: string;
    reason: string;
    shouldStartRuntime: boolean;
}
export type IngestSurfaceLogInput<Item extends InboxItem, Decision extends IngestRuntimeDecision> = {
    decision: Decision;
    outcome: 'ignored';
} | {
    decision: Decision;
    outcome: 'enqueued';
    result: WakeQueueEnqueueResult & {
        item: Item;
    };
};
export interface RunIngestPipelineHooks<Item extends InboxItem, Decision extends IngestRuntimeDecision> {
    agentId: string;
    attentionSuggestionPayload?(item: Item, suggestion: string): AttentionSuggestionPayload;
    decide(input: {
        duplicate: boolean;
    }): Promise<Decision>;
    enrich(input: {
        decision: Decision;
    }): Promise<Item>;
    itemId: string;
    onAfterAttentionSuggestion?(input: {
        decision: Decision;
        item: Item;
        result: WakeQueueEnqueueResult & {
            item: Item;
        };
    }): void;
    onAfterEnqueue?(input: {
        decision: Decision;
        item: Item;
        result: WakeQueueEnqueueResult & {
            item: Item;
        };
    }): void;
    queue: Pick<WakeQueueService, 'enqueue' | 'hasSeen'>;
    surfaceLog(input: IngestSurfaceLogInput<Item, Decision>): object;
}
export declare function runIngestPipeline<Item extends InboxItem, Decision extends IngestRuntimeDecision>(hooks: RunIngestPipelineHooks<Item, Decision>): Promise<void>;
//# sourceMappingURL=ingest-pipeline.d.ts.map