import type { AgentMessage, AgentRunState, AgentThread } from '@pikku/core/agent';
import type { AgentRunScore } from '@pikku/core/agent-scorer';
import type { AgentRunStateService, AgentStorageService, CreateRunInput, SaveScoreInput } from '@pikku/core/services';
import type { Kysely } from 'kysely';
import type { KyselyPikkuDB } from './kysely-tables.js';
export declare class KyselyAgentStorageService implements AgentStorageService, AgentRunStateService {
    private db;
    private initialized;
    constructor(db: Kysely<KyselyPikkuDB>);
    init(): Promise<void>;
    createThread(resourceId: string, options?: {
        threadId?: string;
        title?: string;
        metadata?: Record<string, unknown>;
    }): Promise<AgentThread>;
    getThread(threadId: string): Promise<AgentThread>;
    getThreads(resourceId: string): Promise<AgentThread[]>;
    deleteThread(threadId: string): Promise<void>;
    getMessages(threadId: string, options?: {
        lastN?: number;
        cursor?: string;
    }): Promise<AgentMessage[]>;
    saveMessages(threadId: string, messages: AgentMessage[]): Promise<void>;
    getWorkingMemory(id: string, scope: 'resource' | 'thread'): Promise<Record<string, unknown> | null>;
    saveWorkingMemory(id: string, scope: 'resource' | 'thread', data: Record<string, unknown>): Promise<void>;
    createRun(run: CreateRunInput): Promise<string>;
    updateRun(runId: string, updates: Partial<AgentRunState>): Promise<void>;
    getRun(runId: string): Promise<AgentRunState | null>;
    getRunsByThread(threadId: string): Promise<AgentRunState[]>;
    private setApprovals;
    private mapRunRow;
    findRunByToolCallId(toolCallId: string): Promise<{
        run: AgentRunState;
        approval: NonNullable<AgentRunState['pendingApprovals']>[number];
    } | null>;
    resolveApproval(toolCallId: string, status: 'approved' | 'denied'): Promise<boolean>;
    saveScore(score: SaveScoreInput): Promise<void>;
    getScores(runId: string): Promise<AgentRunScore[]>;
    close(): Promise<void>;
}