import { Context } from 'koishi';
import type { AgenticMemorySnapshotItem, LivingMemoryPresetExport, LivingMemoryPresetImportSummary, MemoryEntryRecord, MemoryJobKind, MemoryJobRecord, MemoryMutationInput, MemoryScope, MemorySnapshotRecord, MemorySourceMessage, MemoryUpdatePatch, PresetSpeakerInput, PresetSpeakerRecord, UserProfileInput, UserProfileRecord } from '../../contracts/memory';
import type { LegacyMemoryEmbeddingRecord, MemoryIndexSourceRecord } from '../../contracts/vector_index';
import type { AttributedMemoryItem, DreamMemoryEntryRecord, JobRepository, RecallRepository, SnapshotRepository, UserProfileMemoryRepository, UserProfileRepository } from '../../contracts/workflows';
import { type PresetPersonaWriteInput } from './preset_personas';
export declare class LivingMemoryRepository implements RecallRepository, SnapshotRepository, JobRepository, UserProfileMemoryRepository, UserProfileRepository {
    private readonly ctx;
    private readonly entries;
    private readonly jobs;
    private readonly snapshots;
    private readonly userProfiles;
    private readonly presetPersonas;
    private readonly transactions;
    constructor(ctx: Context);
    getPresetPersona(presetId: string): Promise<import("../..").PresetPersonaRecord | undefined>;
    listPresetPersonas(): Promise<import("../..").PresetPersonaRecord[]>;
    upsertPresetPersona(input: PresetPersonaWriteInput): Promise<void>;
    deletePresetPersona(presetId: string): Promise<void>;
    defineTables(): void;
    /**
     * 全部事务的唯一入口。单连接数据库无法并发开启事务，因此所有事务共用一条
     * 串行链；这是驱动限制的变通，不是一致性机制本身——一致性来自事务边界，
     * 上层的预设级串行队列不得因此被移除。
     */
    private runTransaction;
    migrateMemorySourceOriginsArray(): Promise<number>;
    migrateWebuiSourceConversationKeys(): Promise<number>;
    migrateActiveMemorySpeakers(): Promise<number>;
    removeLegacyReferenceSnapshots(): Promise<number>;
    hasMigratedLegacyEmbeddings(): Promise<boolean>;
    completeLegacyEmbeddingMigration(): Promise<void>;
    listEntriesByPreset(presetId: string): Promise<MemoryEntryRecord[]>;
    listArchivedEntriesBefore(presetId: string, updatedBefore: Date): Promise<import("koishi").FlatPick<import("./types").LivingMemoryEntryTableRecord, "id" | "importance" | "updatedAt">[]>;
    listDreamEntriesByPreset(presetId: string): Promise<DreamMemoryEntryRecord[]>;
    listActiveMemorySpeakerKeys(presetId: string): Promise<string[]>;
    listActiveMemorySpeakerLinks(presetId: string, speakerKeys: string[]): Promise<import("koishi").FlatPick<import("./types").LivingMemoryEntrySpeakerRecord, "memoryId" | "speakerKey">[]>;
    listEntryIndexSourcePage(afterId: string | null, limit: number): Promise<MemoryIndexSourceRecord[]>;
    listEntryIndexSourcePageByPreset(presetId: string, afterId: string | null, limit: number): Promise<MemoryIndexSourceRecord[]>;
    listLegacyEmbeddingPage(afterId: string | null, limit: number): Promise<LegacyMemoryEmbeddingRecord[]>;
    countEntriesByPreset(presetId: string): Promise<number>;
    countEntries(): Promise<number>;
    listEntryPresetIds(): Promise<string[]>;
    countActiveEntries(presetId: string): Promise<number>;
    getEntryById(id: string): Promise<MemoryEntryRecord | undefined>;
    getEntriesByPresetAndIds(presetId: string, ids: string[]): Promise<MemoryEntryRecord[]>;
    getSearchEntriesByPresetAndIds(presetId: string, ids: string[]): Promise<import("koishi").FlatPick<import("./types").LivingMemoryEntryTableRecord, keyof MemoryEntryRecord>[]>;
    appendMemories(scope: MemoryScope, sourceOriginMessages: MemorySourceMessage[], extracted: AttributedMemoryItem[], sourceLabel?: string | null): Promise<MemoryEntryRecord[]>;
    createMemory(scope: MemoryScope, input: MemoryMutationInput, speakerKeys?: string[]): Promise<MemoryEntryRecord>;
    updateMemory(id: string, patch: MemoryUpdatePatch): Promise<{
        record: {
            id: string;
            presetId: string;
            sourceConversationId: string | null;
            sourceLabel: string | null;
            sourceOrigins: import("../..").MemorySourceOrigin[];
            createdAt: Date;
            updatedAt: Date;
            speakerKeys: string[];
            type: "context" | "fact" | "identity" | "other" | "plan" | "preference";
            status: "active" | "archived";
            content: string;
            keywords: string[];
            summary: string | null;
            sentiment: string | null;
            importance: number | null;
        };
        contentChanged: boolean;
    } | null>;
    archiveActiveEntries(presetId: string, ids: string[]): Promise<{
        id: string;
        presetId: string;
        speakerKeys: string[];
        type: import("../..").MemoryEntryType;
        content: string;
        keywords: string[];
        summary: string | null;
        sentiment: string | null;
        importance: number | null;
        sourceConversationId: string | null;
        sourceLabel: string | null;
        sourceOrigins: import("../..").MemorySourceOrigin[];
        createdAt: Date;
        status: 'archived';
        updatedAt: Date;
    }[]>;
    splitMemory(presetId: string, sourceMemoryId: string, memories: AttributedMemoryItem[]): Promise<{
        memories: MemoryEntryRecord[];
        archivedSource: {
            id: string;
            presetId: string;
            speakerKeys: string[];
            type: import("../..").MemoryEntryType;
            content: string;
            keywords: string[];
            summary: string | null;
            sentiment: string | null;
            importance: number | null;
            sourceConversationId: string | null;
            sourceLabel: string | null;
            sourceOrigins: import("../..").MemorySourceOrigin[];
            createdAt: Date;
            status: 'archived';
            updatedAt: Date;
        };
    }>;
    mergeMemories(presetId: string, sourceMemoryIds: string[], memory: AttributedMemoryItem): Promise<{
        memory: MemoryEntryRecord;
        archivedSources: {
            id: string;
            presetId: string;
            speakerKeys: string[];
            type: import("../..").MemoryEntryType;
            content: string;
            keywords: string[];
            summary: string | null;
            sentiment: string | null;
            importance: number | null;
            sourceConversationId: string | null;
            sourceLabel: string | null;
            sourceOrigins: import("../..").MemorySourceOrigin[];
            createdAt: Date;
            status: 'archived';
            updatedAt: Date;
        }[];
    }>;
    deleteMemory(id: string): Promise<MemoryEntryRecord | null>;
    deleteEntries(presetId: string, ids: string[]): Promise<void>;
    getLatestSnapshotByScope(scope: Pick<MemoryScope, 'presetId' | 'conversationId'>): Promise<MemorySnapshotRecord | undefined>;
    listSnapshotsByPreset(presetId: string): Promise<MemorySnapshotRecord[]>;
    upsertSnapshot(scope: MemoryScope, query: string, items: AgenticMemorySnapshotItem[]): Promise<void>;
    deleteSnapshot(snapshotId: string): Promise<MemorySnapshotRecord | undefined>;
    deleteSnapshotsByConversation(conversationId: string): Promise<MemorySnapshotRecord[]>;
    deleteSnapshotsByPreset(presetId: string): Promise<void>;
    createJob(scope: MemoryScope, kind: MemoryJobKind, input: string): Promise<MemoryJobRecord>;
    createFailedJob(scope: MemoryScope, kind: MemoryJobKind, input: string, error: unknown, startedAt: Date): Promise<MemoryJobRecord>;
    updateJob(id: string, patch: Partial<MemoryJobRecord>): Promise<void>;
    listJobsByPreset(presetId: string): Promise<MemoryJobRecord[]>;
    markStaleRunningJobsAsFailed(options?: {
        presetId?: string;
        kind?: MemoryJobKind;
    }, reason?: string): Promise<MemoryJobRecord[]>;
    removeExpiredJobs(deadline: Date): Promise<void>;
    listPresetSpeakers(presetId: string): Promise<PresetSpeakerRecord[]>;
    upsertPresetSpeaker(input: PresetSpeakerInput): Promise<void>;
    registerMissingPresetSpeakers(presetId: string, speakers: Array<{
        speakerKey: string;
        speakerLabel: string;
    }>): Promise<void>;
    reconcilePresetSpeaker(input: PresetSpeakerInput): Promise<void>;
    listUserProfilesByPreset(presetId: string): Promise<UserProfileRecord[]>;
    listUserProfilesBySpeakerKeys(presetId: string, speakerKeys: string[]): Promise<UserProfileRecord[]>;
    replaceUserProfile(presetId: string, profile: UserProfileInput): Promise<void>;
    updateUserProfileContent(profileId: string, content: string): Promise<void>;
    markUserProfileReviewed(profileId: string, sourceMemoryIds: string[]): Promise<void>;
    deleteUserProfile(profileId: string): Promise<void>;
    clearAllByPreset(presetId: string): Promise<void>;
    exportPresetData(presetId: string): Promise<LivingMemoryPresetExport>;
    importPresetData(targetPresetId: string, data: LivingMemoryPresetExport): Promise<LivingMemoryPresetImportSummary>;
    private buildPresetImportRows;
    listDistinctPresetIds(): Promise<string[]>;
}