import type { MastraDBMessage, MessageList } from '@mastra/core/agent/message-list';
import type { ComputeStateSignalArgs, ComputeStateSignalResult, ProcessInputStepArgs, Processor } from '@mastra/core/processors';
import type { BoardRegistry } from '../boards/index.js';
import type { FactoryRunBindingRecord, WorkItemsStorage, WorkItemRow } from '../storage/domains/work-items/base.js';
import type { FactoryTransitionService } from './transition-service.js';
import type { FactoryRuleJsonValue } from './types.js';
type PersistedMessageReader = {
    listMessages(input: {
        threadId: string;
        resourceId?: string;
        page: number;
        perPage: number;
        filter?: {
            dateRange?: {
                start?: Date;
            };
        };
        orderBy: {
            field: 'createdAt';
            direction: 'ASC';
        };
    }): Promise<{
        messages: MastraDBMessage[];
        hasMore: boolean;
    }>;
};
export declare class FactoryPhaseStateProcessor implements Processor<'factory-phase'> {
    private readonly options;
    readonly id = "factory-phase";
    readonly stateId = "factory-phase";
    constructor(options: {
        configVersion: string;
        storage: WorkItemsStorage;
        boards: BoardRegistry;
        transitionService?: Pick<FactoryTransitionService, 'transition'>;
        messageReader?: PersistedMessageReader;
        recordPullRequestProvenance?: (input: {
            binding: FactoryRunBindingRecord;
            item: WorkItemRow;
            assistantMessageId: string;
            toolCallId: string;
            toolName: string;
            toolInput: FactoryRuleJsonValue;
            toolResult: FactoryRuleJsonValue;
            status: 'success' | 'error';
        }) => Promise<void>;
    });
    processInputStep(args: ProcessInputStepArgs): Promise<MessageList | undefined>;
    computeStateSignal(args: ComputeStateSignalArgs): Promise<ComputeStateSignalResult>;
    reconcileAllBoundThreads(): Promise<void>;
    reconcileBinding(binding: FactoryRunBindingRecord): Promise<void>;
    private ingestMessages;
    private ingestToolResult;
}
export {};
//# sourceMappingURL=processor.d.ts.map