/** Turns prepared User_Input changes into evaluator and storage mutations. */
import type { ResolvedWriterOptions } from "../../../../orm/persistence/support/contracts.js";
import { type PersistObservedRowInput, type PersistObservedRowResult } from "../../../../storage/state/observation/observationWriter.js";
import type { FencingContext } from "@hikoutei/ikisaki";
import { OBSERVATION_WRITE_RESULT_KINDS } from "../../../../storage/state/observation/observationConstants.js";
import type { MikroOrmSqliteAdapter } from "../storage/MikroOrmSqliteAdapter.js";
import { type InvalidRow, type PreparedRow, type SheetAccumulator } from "./MikroOrmUserInputPollingInspection.js";
import { type MappedPollingState } from "./MikroOrmUserInputPollingState.js";
/** Persists invalid polling evidence without mutating canonical entity state. */
export declare function persistInvalidPollingRows(storage: MikroOrmSqliteAdapter, writer: ResolvedWriterOptions, fence: FencingContext, rows: readonly InvalidRow[], accumulators: readonly SheetAccumulator[]): Promise<void>;
/** Persists each prepared row independently under the claimed writer fence. */
export declare function persistPreparedRows(storage: MikroOrmSqliteAdapter, writer: ResolvedWriterOptions, fence: FencingContext, state: MappedPollingState, rows: readonly PreparedRow[], accumulators: readonly SheetAccumulator[]): Promise<readonly PersistObservedRowInput[]>;
export declare function isAuthoritativeObservationResult(result: PersistObservedRowResult): result is Extract<PersistObservedRowResult, {
    readonly kind: typeof OBSERVATION_WRITE_RESULT_KINDS.PERSISTED;
}>;
/**
 * Identifies results whose current polling read may safely drive deferred
 * system-wins evidence. A duplicate means the observation is already durable,
 * not that the just-read visible baseline is obsolete; the provider CAS still
 * rejects a remote edit that occurs after this read.
 */
export declare function isObservationEvidenceUsableForDeferredResolution(result: PersistObservedRowResult): result is Extract<PersistObservedRowResult, {
    readonly kind: typeof OBSERVATION_WRITE_RESULT_KINDS.PERSISTED | typeof OBSERVATION_WRITE_RESULT_KINDS.DUPLICATE;
}>;
//# sourceMappingURL=MikroOrmUserInputPollingPersistence.d.ts.map