import { ArkoLifecycle } from './arko-lifecycle.js';
import type { ArkmeArkoLifecycleCommand } from '../arko-lifecycle-contract.js';
import type { ArkmeArkoHistoryQuery, ArkmeArkoSearchQuery, ArkmeArkoMessagePage, ArkmeArkoSearchPage, ArkmeArkoContextQuery, ArkmeArkoContextWindow, ArkmeArkoExport, ArkmeArkoExportProgress } from '../arko-history-contract.js';
import { type ArkmeArkoPendingTurn } from '../arko-turn-contract.js';
import type { ArkmeSessionCredentials } from '../keychain-store.js';
import type { ArkmeArkoAskResult, ArkmeArkoCancelResult, ArkmeArkoHistoryItem, ArkmeArkoHistoryPage, ArkmeArkoModelCatalog, ArkmeArkoProfile, ArkmeArkoRunStatus, ArkmeArkoSession, ArkmeTimelineItem } from '../types.js';
import { ProfileService } from './profile-service.js';
import { ServiceRuntime } from './service.js';
import { MessageActionService } from './message-action-service.js';
import type { ArkmeContentBlock, ArkmeUploadedAsset } from '../types.js';
import type { ArkmeLocalFile } from '../file-transfer-contract.js';
import { ArkoLocalMarks } from './arko-local-marks.js';
export interface ArkoImagePorts {
    withReferences?<T>(refs: readonly string[], userId: number, persist: () => Promise<T>): Promise<T>;
    read(fileRef: string): Promise<{
        file: ArkmeLocalFile;
    }>;
    upload(fileRefs: readonly string[], signal?: AbortSignal): Promise<ArkmeUploadedAsset[]>;
    project(raw: unknown, userId: number): ArkmeContentBlock[];
}
export declare class ArkoService {
    private readonly runtime;
    private readonly profile;
    private readonly messageActions?;
    private readonly images?;
    private readonly historyCodec;
    private readonly generated;
    readonly lifecycle: ArkoLifecycle;
    readonly localMarks: ArkoLocalMarks;
    private readonly arkoProfileDisplayNameCache;
    constructor(runtime: ServiceRuntime, profile: ProfileService, messageActions?: MessageActionService | undefined, images?: ArkoImagePorts | undefined);
    dispose(): void;
    arkoProfile(signal?: AbortSignal): Promise<ArkmeArkoProfile>;
    arkoEnsureSession(signal?: AbortSignal): Promise<ArkmeArkoSession>;
    arkoCreateSession(signal?: AbortSignal): Promise<ArkmeArkoSession>;
    arkoModelCatalog(signal?: AbortSignal): Promise<ArkmeArkoModelCatalog>;
    arkoActivateModel(routeKey: string, signal?: AbortSignal): Promise<ArkmeArkoModelCatalog>;
    arkoHistoryPage(limit?: number, offset?: number, signal?: AbortSignal): Promise<ArkmeArkoHistoryPage>;
    private historyFacts;
    private projectHistory;
    private historyBody;
    private messageRef;
    private historyContinuation;
    arkoLifecycle(refs?: readonly string[], signal?: AbortSignal): Promise<import("../arko-lifecycle-contract.js").ArkmeArkoLifecycleSnapshot>;
    arkoChangeLifecycle(command: ArkmeArkoLifecycleCommand, signal?: AbortSignal): Promise<import("../arko-lifecycle-contract.js").ArkmeArkoLifecycleResult>;
    arkoRecentlyDeleted(cursor?: string, signal?: AbortSignal): Promise<import("../arko-lifecycle-contract.js").ArkmeArkoDeletedPage>;
    arkoMessages(query?: ArkmeArkoHistoryQuery, signal?: AbortSignal): Promise<ArkmeArkoMessagePage>;
    arkoSearch(query: ArkmeArkoSearchQuery, signal?: AbortSignal): Promise<ArkmeArkoSearchPage>;
    arkoContext(query: ArkmeArkoContextQuery, signal?: AbortSignal): Promise<ArkmeArkoContextWindow>;
    private readMessages;
    private readSearch;
    private readContext;
    arkoExport(signal?: AbortSignal, onProgress?: (progress: ArkmeArkoExportProgress) => void): Promise<ArkmeArkoExport>;
    actionMessages(anchors: readonly {
        sessionId: number;
        messageId: number;
    }[], userId: number, signal?: AbortSignal): Promise<ArkmeArkoHistoryItem[]>;
    readGeneratedFile(ref: string): Promise<{
        path: string;
        file: ArkmeLocalFile;
    }>;
    arkoAsk(text: string, options?: {
        sessionId?: number;
        clientTurnUid?: string;
        waitMillis?: number;
        modelRouteKey?: string;
        replyToRunUid?: string;
        replyToAssistantMsgId?: number;
        imageFileRefs?: readonly string[];
        expectedUserId?: number;
        signal?: AbortSignal;
    }): Promise<ArkmeArkoAskResult>;
    private newPendingTurn;
    arkoPendingTurns(expectedUserId?: number): Promise<ArkmeArkoPendingTurn[]>;
    arkoPrepareTurn(turn: ArkmeArkoPendingTurn): Promise<void>;
    arkoAcknowledgeTurn(uid: string, expectedUserId?: number): Promise<void>;
    private postArkoTurn;
    arkoRunStatus(sessionId: number, runUid: string, signal?: AbortSignal): Promise<ArkmeArkoRunStatus>;
    arkoCancel(sessionId: number, assistantMsgId: number, runUid: string, signal?: AbortSignal): Promise<ArkmeArkoCancelResult>;
    private arkoProfileDisplayName;
    private cacheArkoProfileDisplayName;
    private cachedArkoProfileDisplayName;
    currentUserAgentSourceFallback(userId: number, source: ArkmeTimelineItem['agentSource'] | undefined): ArkmeTimelineItem['agentSource'] | undefined;
    agentSourceDisplayName(session: ArkmeSessionCredentials): Promise<string>;
    private authenticatedIntelligentSseEvents;
    private readIntelligentSseEvents;
    private projectArkoStreamEvents;
}
//# sourceMappingURL=arko-service.d.ts.map