import { MongoSchemaIR } from "@prisma-next/mongo-schema-ir";
import { ContractMarkerRecord, LedgerEntryRecord } from "@prisma-next/contract/types";
import { ControlAdapterDescriptor, ControlAdapterInstance, ControlDriverInstance } from "@prisma-next/framework-components/control";
//#region src/core/control-adapter.d.ts
/**
 * Mongo control adapter interface for control-plane operations.
 * Implemented by target-specific adapters (e.g. `@prisma-next/adapter-mongo`).
 *
 * Mirrors `SqlControlAdapter` so the family layer dispatches every
 * driver-bound wire operation through a single SPI surface instead of
 * importing target-package internals directly. The adapter is the
 * natural home for these method bodies because it owns both the
 * `ControlDriverInstance` (which exposes the underlying `Db`) and the
 * Mongo command vocabulary used to talk to it.
 *
 * @template TTarget - The target ID (today only `'mongo'`).
 */
interface MongoControlAdapter<TTarget extends string = string> extends ControlAdapterInstance<'mongo', TTarget> {
  /**
   * Reads the contract marker document for `space`, or returns `null`
   * if no marker document has been written for that space yet. Each
   * space owns one document keyed by `_id: <space>` in the
   * `_prisma_migrations` collection.
   */
  readMarker(driver: ControlDriverInstance<'mongo', TTarget>, space: string): Promise<ContractMarkerRecord | null>;
  /**
   * Reads every marker document (one per contract space) and returns
   * them keyed by `space`. Used by the per-space verifier to detect
   * marker-vs-on-disk drift and orphan marker rows. Returns an empty
   * map when no marker documents exist yet.
   */
  readAllMarkers(driver: ControlDriverInstance<'mongo', TTarget>): Promise<ReadonlyMap<string, ContractMarkerRecord>>;
  /**
   * Inserts an initial marker document for the given space.
   */
  initMarker(driver: ControlDriverInstance<'mongo', TTarget>, space: string, destination: {
    readonly storageHash: string;
    readonly profileHash: string;
    readonly invariants?: readonly string[];
  }): Promise<void>;
  /**
   * Atomically updates the marker document for `space` (CAS on
   * `expectedFrom`). Returns `true` when the CAS succeeded, `false`
   * when another process advanced the marker first.
   */
  updateMarker(driver: ControlDriverInstance<'mongo', TTarget>, space: string, expectedFrom: string, destination: {
    readonly storageHash: string;
    readonly profileHash: string;
    readonly invariants?: readonly string[];
  }): Promise<boolean>;
  /**
   * Appends a ledger entry for the given space. Ledger entries co-exist
   * with marker documents in the same collection; their key shape
   * distinguishes them at read time.
   */
  writeLedgerEntry(driver: ControlDriverInstance<'mongo', TTarget>, space: string, entry: {
    readonly edgeId: string;
    readonly from: string;
    readonly to: string;
    readonly migrationName: string;
    readonly migrationHash: string;
    readonly operations: readonly unknown[];
  }): Promise<void>;
  /**
   * Reads the per-migration ledger journal in apply order. When `space` is
   * omitted, returns rows for every space.
   */
  readLedger(driver: ControlDriverInstance<'mongo', TTarget>, space?: string): Promise<readonly LedgerEntryRecord[]>;
  /**
   * Introspects the live database and returns a `MongoSchemaIR`.
   */
  introspectSchema(driver: ControlDriverInstance<'mongo', TTarget>): Promise<MongoSchemaIR>;
}
/**
 * Mongo control adapter descriptor. Mirrors `SqlControlAdapterDescriptor`:
 * extends the framework's `ControlAdapterDescriptor` and narrows the
 * `create()` return to a `MongoControlAdapter<TTarget>`.
 */
interface MongoControlAdapterDescriptor<TTarget extends string = string> extends ControlAdapterDescriptor<'mongo', TTarget, MongoControlAdapter<TTarget>> {}
//#endregion
export type { MongoControlAdapter, MongoControlAdapterDescriptor };
//# sourceMappingURL=control-adapter.d.mts.map