import type { CheckpointResult, DispatchInput, DispatchProcessor, JsonObject, ModelMessage, SessionEntry, SessionEntryType, ShellResult } from '@fabric-harness/sdk';
import type { ActivityIdempotency, ExecuteToolActivityInput, ExecuteToolActivityResult, ModelGenerateActivityInput, ModelGenerateActivityResult, PromptWorkflowInput, PromptWorkflowResult, SessionRuntime, SessionRuntimeCheckpointCreateInput, SessionRuntimeCheckpointRestoreInput, SessionRuntimeShellInput, SnapshotRef } from './types.js';
export interface AppendSessionEntryActivityInput {
    sessionId: string;
    type: SessionEntryType;
    data?: JsonObject;
    idempotency: ActivityIdempotency;
}
export interface AppendSessionEntryActivityResult {
    entry: SessionEntry;
}
export interface AppendSessionEventActivityInput {
    sessionId: string;
    type: string;
    data?: JsonObject;
    idempotency: ActivityIdempotency;
    /** Sequential event index for append-only enforcement within a workflow run. */
    eventIndex?: number;
}
export interface LoadSessionActivityInput {
    sessionId: string;
}
export interface BuildContextActivityInput {
    sessionId: string;
    role?: string;
    idempotency: ActivityIdempotency;
}
export interface BuildContextActivityResult {
    messages: ModelMessage[];
}
export interface CheckpointActivityInput {
    sessionId: string;
    label: string;
    idempotency: ActivityIdempotency;
}
export interface CheckpointActivityResult {
    checkpointId: string;
    snapshot?: SnapshotRef;
}
export interface CompactSessionActivityInput {
    sessionId: string;
    keepRecentEntries?: number;
    idempotency: ActivityIdempotency;
}
export interface CompactSessionActivityResult {
    compactionEntryId: string;
    summary: string;
    firstKeptEntryId?: string;
}
export interface ResolveSecretActivityInput {
    name: string;
    idempotency: ActivityIdempotency;
}
export interface RuntimePromptActivityInput extends PromptWorkflowInput {
}
export interface RuntimeCheckpointCreateActivityInput extends SessionRuntimeCheckpointCreateInput {
    sessionId: string;
    idempotency: ActivityIdempotency;
}
export interface RuntimeCheckpointRestoreActivityInput extends SessionRuntimeCheckpointRestoreInput {
    sessionId: string;
    idempotency: ActivityIdempotency;
}
export interface RuntimeShellActivityInput extends SessionRuntimeShellInput {
    sessionId: string;
    idempotency: ActivityIdempotency;
}
export interface TemporalSessionRuntimeActivities {
    runPrompt(input: RuntimePromptActivityInput): Promise<PromptWorkflowResult>;
    runCheckpointCreate(input: RuntimeCheckpointCreateActivityInput): Promise<CheckpointResult>;
    runCheckpointRestore(input: RuntimeCheckpointRestoreActivityInput): Promise<CheckpointResult>;
    runShell(input: RuntimeShellActivityInput): Promise<ShellResult>;
}
export interface TemporalActivities extends TemporalSessionRuntimeActivities {
    appendSessionEntry(input: AppendSessionEntryActivityInput): Promise<AppendSessionEntryActivityResult>;
    appendSessionEvent(input: AppendSessionEventActivityInput): Promise<void>;
    loadSession(input: LoadSessionActivityInput): Promise<unknown>;
    buildContext(input: BuildContextActivityInput): Promise<BuildContextActivityResult>;
    modelGenerate(input: ModelGenerateActivityInput): Promise<ModelGenerateActivityResult>;
    executeTool(input: ExecuteToolActivityInput): Promise<ExecuteToolActivityResult>;
    createCheckpoint(input: CheckpointActivityInput): Promise<CheckpointActivityResult>;
    restoreCheckpoint(input: CheckpointActivityInput): Promise<CheckpointActivityResult>;
    compactSession(input: CompactSessionActivityInput): Promise<CompactSessionActivityResult>;
    resolveSecret(input: ResolveSecretActivityInput): Promise<string | undefined>;
}
export type SessionRuntimeFactory = (sessionId: string) => SessionRuntime | Promise<SessionRuntime>;
export interface CreateTemporalSessionRuntimeActivitiesOptions {
    runtimeForSession: SessionRuntimeFactory;
}
export declare function createTemporalSessionRuntimeActivities(options: CreateTemporalSessionRuntimeActivitiesOptions): TemporalSessionRuntimeActivities;
export declare function requireIdempotency(input: {
    idempotency?: ActivityIdempotency;
}, activityName: string): ActivityIdempotency;
/** Activity that durably applies a dispatched input to a persistent instance. */
export interface TemporalDispatchActivities {
    processDispatch(input: DispatchInput): Promise<void>;
}
export interface CreateTemporalDispatchActivitiesOptions {
    /** The host's dispatch processor (e.g. node's `createPersistentDispatchProcessor`). */
    processor: DispatchProcessor;
}
/**
 * Wrap a {@link DispatchProcessor} as a Temporal activity. The processor is
 * idempotent by `dispatchId`, so Temporal retries are safe.
 */
export declare function createTemporalDispatchActivities(options: CreateTemporalDispatchActivitiesOptions): TemporalDispatchActivities;
//# sourceMappingURL=activities.d.ts.map