@prisma-next/sql-relational-core - npm Package Compare versions

Comparing version 0.1.0-pr.36.1 to 0.1.0-pr.36.2

dist/chunk-6JM7ZPMQ.js

+import {
+  isColumnBuilder
+} from "./chunk-R77KHJFH.js";
+
+// src/ast/codec-types.ts
+var CodecRegistryImpl = class {
+  _byId = /* @__PURE__ */ new Map();
+  _byScalar = /* @__PURE__ */ new Map();
+  /**
+   * Map-like interface for codec lookup by ID.
+   * Example: registry.get('pg/text@1')
+   */
+  get(id) {
+    return this._byId.get(id);
+  }
+  /**
+   * Check if a codec with the given ID is registered.
+   */
+  has(id) {
+    return this._byId.has(id);
+  }
+  /**
+   * Get all codecs that handle a given scalar type.
+   * Returns an empty frozen array if no codecs are found.
+   * Example: registry.getByScalar('text') → [codec1, codec2, ...]
+   */
+  getByScalar(scalar) {
+    return this._byScalar.get(scalar) ?? Object.freeze([]);
+  }
+  /**
+   * Get the default codec for a scalar type (first registered codec).
+   * Returns undefined if no codec handles this scalar type.
+   */
+  getDefaultCodec(scalar) {
+    const _codecs = this._byScalar.get(scalar);
+    return _codecs?.[0];
+  }
+  /**
+   * Register a codec in the registry.
+   * Throws an error if a codec with the same ID is already registered.
+   *
+   * @param codec - The codec to register
+   * @throws Error if a codec with the same ID already exists
+   */
+  register(codec2) {
+    if (this._byId.has(codec2.id)) {
+      throw new Error(`Codec with ID '${codec2.id}' is already registered`);
+    }
+    this._byId.set(codec2.id, codec2);
+    for (const scalarType of codec2.targetTypes) {
+      const existing = this._byScalar.get(scalarType);
+      if (existing) {
+        existing.push(codec2);
+      } else {
+        this._byScalar.set(scalarType, [codec2]);
+      }
+    }
+  }
+  /**
+   * Returns an iterator over all registered codecs.
+   * Useful for iterating through codecs from another registry.
+   */
+  *[Symbol.iterator]() {
+    for (const codec2 of this._byId.values()) {
+      yield codec2;
+    }
+  }
+  /**
+   * Returns an iterable of all registered codecs.
+   */
+  values() {
+    return this._byId.values();
+  }
+};
+function codec(config) {
+  return {
+    id: config.typeId,
+    targetTypes: config.targetTypes,
+    ...config.meta ? { meta: config.meta } : {},
+    encode: config.encode,
+    decode: config.decode
+  };
+}
+var CodecDefBuilderImpl = class _CodecDefBuilderImpl {
+  _codecs;
+  CodecTypes;
+  dataTypes;
+  constructor(codecs) {
+    this._codecs = codecs;
+    const codecTypes = {};
+    for (const [, codecImpl] of Object.entries(this._codecs)) {
+      const codecImplTyped = codecImpl;
+      codecTypes[codecImplTyped.id] = {
+        input: void 0,
+        output: void 0
+      };
+    }
+    this.CodecTypes = codecTypes;
+    const dataTypes = {};
+    for (const key in this._codecs) {
+      if (Object.hasOwn(this._codecs, key)) {
+        const codec2 = this._codecs[key];
+        dataTypes[key] = codec2.id;
+      }
+    }
+    this.dataTypes = dataTypes;
+  }
+  add(scalarName, codecImpl) {
+    return new _CodecDefBuilderImpl({
+      ...this._codecs,
+      [scalarName]: codecImpl
+    });
+  }
+  /**
+   * Derive codecDefinitions structure.
+   */
+  get codecDefinitions() {
+    const result = {};
+    for (const [scalarName, codecImpl] of Object.entries(this._codecs)) {
+      const codec2 = codecImpl;
+      result[scalarName] = {
+        typeId: codec2.id,
+        scalar: scalarName,
+        codec: codec2,
+        input: void 0,
+        output: void 0,
+        jsType: void 0
+      };
+    }
+    return result;
+  }
+};
+function createCodecRegistry() {
+  return new CodecRegistryImpl();
+}
+function defineCodecs() {
+  return new CodecDefBuilderImpl({});
+}
+
+// src/ast/util.ts
+function compact(o) {
+  const out = {};
+  for (const [k, v] of Object.entries(o)) {
+    if (v === void 0 || v === null) continue;
+    if (Array.isArray(v) && v.length === 0) continue;
+    out[k] = v;
+  }
+  return out;
+}
+
+// src/ast/common.ts
+function createTableRef(name) {
+  return {
+    kind: "table",
+    name
+  };
+}
+function createColumnRef(table, column) {
+  return {
+    kind: "col",
+    table,
+    column
+  };
+}
+function createParamRef(index, name) {
+  return compact({
+    kind: "param",
+    index,
+    name
+  });
+}
+function createOperationExpr(operation) {
+  return operation;
+}
+function createLiteralExpr(value) {
+  return {
+    kind: "literal",
+    value
+  };
+}
+
+// src/ast/delete.ts
+function createDeleteAst(options) {
+  return compact({
+    kind: "delete",
+    table: options.table,
+    where: options.where,
+    returning: options.returning
+  });
+}
+
+// src/ast/insert.ts
+function createInsertAst(options) {
+  return compact({
+    kind: "insert",
+    table: options.table,
+    values: options.values,
+    returning: options.returning
+  });
+}
+
+// src/ast/join.ts
+import { planInvalid } from "@prisma-next/plan";
+function createJoin(joinType, table, on) {
+  return {
+    kind: "join",
+    joinType,
+    table,
+    on
+  };
+}
+function createJoinOnExpr(left, right) {
+  return {
+    kind: "eqCol",
+    left,
+    right
+  };
+}
+var JoinOnBuilderImpl = class {
+  eqCol(left, right) {
+    if (!left || !isColumnBuilder(left)) {
+      throw planInvalid("Join ON left operand must be a column");
+    }
+    if (!right || !isColumnBuilder(right)) {
+      throw planInvalid("Join ON right operand must be a column");
+    }
+    const leftCol = left;
+    const rightCol = right;
+    if (leftCol.table === rightCol.table) {
+      throw planInvalid("Self-joins are not supported in MVP");
+    }
+    return {
+      kind: "join-on",
+      left,
+      right
+    };
+  }
+};
+function createJoinOnBuilder() {
+  return new JoinOnBuilderImpl();
+}
+
+// src/ast/order.ts
+function createOrderByItem(expr, dir) {
+  return {
+    expr,
+    dir
+  };
+}
+
+// src/ast/predicate.ts
+function createBinaryExpr(op, left, right) {
+  return {
+    kind: "bin",
+    op,
+    left,
+    right
+  };
+}
+function createExistsExpr(not, subquery) {
+  return {
+    kind: "exists",
+    not,
+    subquery
+  };
+}
+
+// src/ast/select.ts
+function createSelectAst(options) {
+  return compact({
+    kind: "select",
+    from: options.from,
+    joins: options.joins,
+    includes: options.includes,
+    project: options.project,
+    where: options.where,
+    orderBy: options.orderBy,
+    limit: options.limit
+  });
+}
+
+// src/ast/types.ts
+function isOperationExpr(expr) {
+  return expr.kind === "operation";
+}
+
+// src/ast/update.ts
+function createUpdateAst(options) {
+  return compact({
+    kind: "update",
+    table: options.table,
+    set: options.set,
+    where: options.where,
+    returning: options.returning
+  });
+}
+
+export {
+  codec,
+  createCodecRegistry,
+  defineCodecs,
+  compact,
+  createTableRef,
+  createColumnRef,
+  createParamRef,
+  createOperationExpr,
+  createLiteralExpr,
+  createDeleteAst,
+  createInsertAst,
+  createJoin,
+  createJoinOnExpr,
+  createJoinOnBuilder,
+  createOrderByItem,
+  createBinaryExpr,
+  createExistsExpr,
+  createSelectAst,
+  isOperationExpr,
+  createUpdateAst
+};
+//# sourceMappingURL=chunk-6JM7ZPMQ.js.map

dist/chunk-6JM7ZPMQ.js.map

+{"version":3,"sources":["../src/ast/codec-types.ts","../src/ast/util.ts","../src/ast/common.ts","../src/ast/delete.ts","../src/ast/insert.ts","../src/ast/join.ts","../src/ast/order.ts","../src/ast/predicate.ts","../src/ast/select.ts","../src/ast/types.ts","../src/ast/update.ts"],"sourcesContent":["import type { O } from 'ts-toolbelt';\n\n/**\n * Codec metadata for database-specific type information.\n * Used for schema introspection and verification.\n */\nexport interface CodecMeta {\n  readonly db?: {\n    readonly sql?: {\n      readonly postgres?: {\n        readonly nativeType: string; // e.g. 'integer', 'text', 'vector', 'timestamp with time zone'\n      };\n    };\n  };\n}\n\n/**\n * Codec interface for encoding/decoding values between wire format and JavaScript types.\n *\n * Codecs are pure, synchronous functions with no side effects or IO.\n * They provide deterministic conversion between database wire types and JS values.\n */\nexport interface Codec<Id extends string = string, TWire = unknown, TJs = unknown> {\n  /**\n   * Namespaced codec identifier in format 'namespace/name@version'\n   * Examples: 'pg/text@1', 'pg/uuid@1', 'pg/timestamptz@1'\n   */\n  readonly id: Id;\n\n  /**\n   * Contract scalar type IDs that this codec can handle.\n   * Examples: ['text'], ['int4', 'float8'], ['timestamp', 'timestamptz']\n   */\n  readonly targetTypes: readonly string[];\n\n  /**\n   * Optional metadata for database-specific type information.\n   * Used for schema introspection and verification.\n   */\n  readonly meta?: CodecMeta;\n\n  /**\n   * Decode a wire value (from database) to JavaScript type.\n   * Must be synchronous and pure (no side effects).\n   */\n  decode(wire: TWire): TJs;\n\n  /**\n   * Encode a JavaScript value to wire format (for database).\n   * Optional - if not provided, values pass through unchanged.\n   * Must be synchronous and pure (no side effects).\n   */\n  encode?(value: TJs): TWire;\n}\n\n/**\n * Registry interface for codecs organized by ID and by contract scalar type.\n *\n * The registry allows looking up codecs by their namespaced ID or by the\n * contract scalar types they handle. Multiple codecs may handle the same\n * scalar type; ordering in byScalar reflects preference (adapter first,\n * then packs, then app overrides).\n */\nexport interface CodecRegistry {\n  get(id: string): Codec<string> | undefined;\n  has(id: string): boolean;\n  getByScalar(scalar: string): readonly Codec<string>[];\n  getDefaultCodec(scalar: string): Codec<string> | undefined;\n  register(codec: Codec<string>): void;\n  [Symbol.iterator](): Iterator<Codec<string>>;\n  values(): IterableIterator<Codec<string>>;\n}\n\n/**\n * Implementation of CodecRegistry.\n */\nclass CodecRegistryImpl implements CodecRegistry {\n  private readonly _byId = new Map<string, Codec<string>>();\n  private readonly _byScalar = new Map<string, Codec<string>[]>();\n\n  /**\n   * Map-like interface for codec lookup by ID.\n   * Example: registry.get('pg/text@1')\n   */\n  get(id: string): Codec<string> | undefined {\n    return this._byId.get(id);\n  }\n\n  /**\n   * Check if a codec with the given ID is registered.\n   */\n  has(id: string): boolean {\n    return this._byId.has(id);\n  }\n\n  /**\n   * Get all codecs that handle a given scalar type.\n   * Returns an empty frozen array if no codecs are found.\n   * Example: registry.getByScalar('text') → [codec1, codec2, ...]\n   */\n  getByScalar(scalar: string): readonly Codec<string>[] {\n    return this._byScalar.get(scalar) ?? Object.freeze([]);\n  }\n\n  /**\n   * Get the default codec for a scalar type (first registered codec).\n   * Returns undefined if no codec handles this scalar type.\n   */\n  getDefaultCodec(scalar: string): Codec<string> | undefined {\n    const _codecs = this._byScalar.get(scalar);\n    return _codecs?.[0];\n  }\n\n  /**\n   * Register a codec in the registry.\n   * Throws an error if a codec with the same ID is already registered.\n   *\n   * @param codec - The codec to register\n   * @throws Error if a codec with the same ID already exists\n   */\n  register(codec: Codec<string>): void {\n    if (this._byId.has(codec.id)) {\n      throw new Error(`Codec with ID '${codec.id}' is already registered`);\n    }\n\n    this._byId.set(codec.id, codec);\n\n    // Update byScalar mapping\n    for (const scalarType of codec.targetTypes) {\n      const existing = this._byScalar.get(scalarType);\n      if (existing) {\n        existing.push(codec);\n      } else {\n        this._byScalar.set(scalarType, [codec]);\n      }\n    }\n  }\n\n  /**\n   * Returns an iterator over all registered codecs.\n   * Useful for iterating through codecs from another registry.\n   */\n  *[Symbol.iterator](): Iterator<Codec<string>> {\n    for (const codec of this._byId.values()) {\n      yield codec;\n    }\n  }\n\n  /**\n   * Returns an iterable of all registered codecs.\n   */\n  values(): IterableIterator<Codec<string>> {\n    return this._byId.values();\n  }\n}\n\n/**\n * Codec factory - creates a codec with typeId and encode/decode functions.\n */\nexport function codec<Id extends string, TWire, TJs>(config: {\n  typeId: Id;\n  targetTypes: readonly string[];\n  encode: (value: TJs) => TWire;\n  decode: (wire: TWire) => TJs;\n  meta?: CodecMeta;\n}): Codec<Id, TWire, TJs> {\n  return {\n    id: config.typeId,\n    targetTypes: config.targetTypes,\n    ...(config.meta ? { meta: config.meta } : {}),\n    encode: config.encode,\n    decode: config.decode,\n  };\n}\n\n/**\n * Type helpers to extract codec types.\n */\nexport type CodecId<T> = T extends Codec<infer Id, unknown, unknown>\n  ? Id\n  : T extends { readonly id: infer Id }\n    ? Id\n    : never;\nexport type CodecInput<T> = T extends Codec<string, unknown, infer JsT> ? JsT : never;\nexport type CodecOutput<T> = T extends Codec<string, unknown, infer JsT> ? JsT : never;\n\n/**\n * Type helper to extract codec types from builder instance.\n */\nexport type ExtractCodecTypes<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> } = Record<never, never>,\n> = {\n  readonly [K in keyof ScalarNames as ScalarNames[K] extends Codec<infer Id, unknown, unknown>\n    ? Id\n    : never]: {\n    readonly input: CodecInput<ScalarNames[K]>;\n    readonly output: CodecOutput<ScalarNames[K]>;\n  };\n};\n\n/**\n * Type helper to extract data type IDs from builder instance.\n * Uses ExtractCodecTypes which preserves literal types as keys.\n * Since ExtractCodecTypes<Record<K, ScalarNames[K]>> has exactly one key (the Id),\n * we extract it by creating a mapped type that uses the Id as both key and value,\n * then extract the value type. This preserves literal types.\n */\nexport type ExtractDataTypes<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> },\n> = {\n  readonly [K in keyof ScalarNames]: {\n    readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n  }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n};\n\n/**\n * Builder interface for declaring codecs.\n */\nexport interface CodecDefBuilder<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> } = Record<never, never>,\n> {\n  readonly CodecTypes: ExtractCodecTypes<ScalarNames>;\n\n  add<ScalarName extends string, CodecImpl extends Codec<string>>(\n    scalarName: ScalarName,\n    codecImpl: CodecImpl,\n  ): CodecDefBuilder<\n    O.Overwrite<ScalarNames, Record<ScalarName, CodecImpl>> & Record<ScalarName, CodecImpl>\n  >;\n\n  readonly codecDefinitions: {\n    readonly [K in keyof ScalarNames]: {\n      readonly typeId: ScalarNames[K] extends Codec<infer Id extends string, unknown, unknown>\n        ? Id\n        : never;\n      readonly scalar: K;\n      readonly codec: ScalarNames[K];\n      readonly input: CodecInput<ScalarNames[K]>;\n      readonly output: CodecOutput<ScalarNames[K]>;\n      readonly jsType: CodecOutput<ScalarNames[K]>;\n    };\n  };\n\n  readonly dataTypes: {\n    readonly [K in keyof ScalarNames]: {\n      readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n    }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n  };\n}\n\n/**\n * Implementation of CodecDefBuilder.\n */\nclass CodecDefBuilderImpl<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> } = Record<never, never>,\n> implements CodecDefBuilder<ScalarNames>\n{\n  private readonly _codecs: ScalarNames;\n\n  public readonly CodecTypes: ExtractCodecTypes<ScalarNames>;\n  public readonly dataTypes: {\n    readonly [K in keyof ScalarNames]: {\n      readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n    }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n  };\n\n  constructor(codecs: ScalarNames) {\n    this._codecs = codecs;\n\n    // Populate CodecTypes from codecs\n    const codecTypes: Record<string, { readonly input: unknown; readonly output: unknown }> = {};\n    for (const [, codecImpl] of Object.entries(this._codecs)) {\n      const codecImplTyped = codecImpl as Codec<string>;\n      codecTypes[codecImplTyped.id] = {\n        input: undefined as unknown as CodecInput<typeof codecImplTyped>,\n        output: undefined as unknown as CodecOutput<typeof codecImplTyped>,\n      };\n    }\n    this.CodecTypes = codecTypes as ExtractCodecTypes<ScalarNames>;\n\n    // Populate dataTypes from codecs - extract id property from each codec\n    // Build object preserving keys from ScalarNames\n    // Type assertion is safe because we know ScalarNames structure matches the return type\n    // biome-ignore lint/suspicious/noExplicitAny: dynamic codec mapping requires any\n    const dataTypes = {} as any;\n    for (const key in this._codecs) {\n      if (Object.hasOwn(this._codecs, key)) {\n        const codec = this._codecs[key] as Codec<string>;\n        dataTypes[key] = codec.id;\n      }\n    }\n    this.dataTypes = dataTypes as {\n      readonly [K in keyof ScalarNames]: {\n        readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n      }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n    };\n  }\n\n  add<ScalarName extends string, CodecImpl extends Codec<string>>(\n    scalarName: ScalarName,\n    codecImpl: CodecImpl,\n  ): CodecDefBuilder<\n    O.Overwrite<ScalarNames, Record<ScalarName, CodecImpl>> & Record<ScalarName, CodecImpl>\n  > {\n    return new CodecDefBuilderImpl({\n      ...this._codecs,\n      [scalarName]: codecImpl,\n    } as O.Overwrite<ScalarNames, Record<ScalarName, CodecImpl>> & Record<ScalarName, CodecImpl>);\n  }\n\n  /**\n   * Derive codecDefinitions structure.\n   */\n  get codecDefinitions(): {\n    readonly [K in keyof ScalarNames]: {\n      readonly typeId: ScalarNames[K] extends Codec<infer Id, unknown, unknown> ? Id : never;\n      readonly scalar: K;\n      readonly codec: ScalarNames[K];\n      readonly input: CodecInput<ScalarNames[K]>;\n      readonly output: CodecOutput<ScalarNames[K]>;\n      readonly jsType: CodecOutput<ScalarNames[K]>;\n    };\n  } {\n    const result: Record<\n      string,\n      {\n        typeId: string;\n        scalar: string;\n        codec: Codec;\n        input: unknown;\n        output: unknown;\n        jsType: unknown;\n      }\n    > = {};\n\n    for (const [scalarName, codecImpl] of Object.entries(this._codecs)) {\n      const codec = codecImpl as Codec<string>;\n      result[scalarName] = {\n        typeId: codec.id,\n        scalar: scalarName,\n        codec: codec,\n        input: undefined as unknown as CodecInput<typeof codec>,\n        output: undefined as unknown as CodecOutput<typeof codec>,\n        jsType: undefined as unknown as CodecOutput<typeof codec>,\n      };\n    }\n\n    return result as {\n      readonly [K in keyof ScalarNames]: {\n        readonly typeId: ScalarNames[K] extends Codec<infer Id extends string, unknown, unknown>\n          ? Id\n          : never;\n        readonly scalar: K;\n        readonly codec: ScalarNames[K];\n        readonly input: CodecInput<ScalarNames[K]>;\n        readonly output: CodecOutput<ScalarNames[K]>;\n        readonly jsType: CodecOutput<ScalarNames[K]>;\n      };\n    };\n  }\n}\n\n/**\n * Create a new codec registry.\n */\nexport function createCodecRegistry(): CodecRegistry {\n  return new CodecRegistryImpl();\n}\n\n/**\n * Create a new codec definition builder.\n */\nexport function defineCodecs(): CodecDefBuilder<Record<never, never>> {\n  return new CodecDefBuilderImpl({});\n}\n","export function compact<T extends Record<string, unknown>>(o: T): T {\n  const out: Record<string, unknown> = {};\n  for (const [k, v] of Object.entries(o)) {\n    if (v === undefined || v === null) continue;\n    if (Array.isArray(v) && v.length === 0) continue;\n    out[k] = v;\n  }\n  return out as T;\n}\n","import type { ColumnRef, LiteralExpr, OperationExpr, ParamRef, TableRef } from './types';\nimport { compact } from './util';\n\nexport function createTableRef(name: string): TableRef {\n  return {\n    kind: 'table',\n    name,\n  };\n}\n\nexport function createColumnRef(table: string, column: string): ColumnRef {\n  return {\n    kind: 'col',\n    table,\n    column,\n  };\n}\n\nexport function createParamRef(index: number, name?: string): ParamRef {\n  return compact({\n    kind: 'param',\n    index,\n    name,\n  }) as ParamRef;\n}\n\nexport function createOperationExpr(operation: OperationExpr): OperationExpr {\n  return operation;\n}\n\nexport function createLiteralExpr(value: unknown): LiteralExpr {\n  return {\n    kind: 'literal',\n    value,\n  };\n}\n","import type { BinaryExpr, ColumnRef, DeleteAst, TableRef } from './types';\nimport { compact } from './util';\n\nexport interface CreateDeleteAstOptions {\n  readonly table: TableRef;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport function createDeleteAst(options: CreateDeleteAstOptions): DeleteAst {\n  return compact({\n    kind: 'delete',\n    table: options.table,\n    where: options.where,\n    returning: options.returning,\n  }) as DeleteAst;\n}\n","import type { ColumnRef, InsertAst, ParamRef, TableRef } from './types';\nimport { compact } from './util';\n\nexport interface CreateInsertAstOptions {\n  readonly table: TableRef;\n  readonly values: Record<string, ColumnRef | ParamRef>;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport function createInsertAst(options: CreateInsertAstOptions): InsertAst {\n  return compact({\n    kind: 'insert',\n    table: options.table,\n    values: options.values,\n    returning: options.returning,\n  }) as InsertAst;\n}\n","import { planInvalid } from '@prisma-next/plan';\nimport type { AnyColumnBuilder, JoinOnBuilder, JoinOnPredicate } from '../types';\nimport { isColumnBuilder } from '../types';\nimport type { ColumnRef, JoinAst, JoinOnExpr, TableRef } from './types';\n\nexport function createJoin(\n  joinType: 'inner' | 'left' | 'right' | 'full',\n  table: TableRef,\n  on: JoinOnExpr,\n): JoinAst {\n  return {\n    kind: 'join',\n    joinType,\n    table,\n    on,\n  };\n}\n\nexport function createJoinOnExpr(left: ColumnRef, right: ColumnRef): JoinOnExpr {\n  return {\n    kind: 'eqCol',\n    left,\n    right,\n  };\n}\n\nclass JoinOnBuilderImpl implements JoinOnBuilder {\n  eqCol(left: AnyColumnBuilder, right: AnyColumnBuilder): JoinOnPredicate {\n    if (!left || !isColumnBuilder(left)) {\n      throw planInvalid('Join ON left operand must be a column');\n    }\n\n    if (!right || !isColumnBuilder(right)) {\n      throw planInvalid('Join ON right operand must be a column');\n    }\n\n    // TypeScript can't narrow ColumnBuilder properly, so we assert\n    const leftCol = left as unknown as { table: string; column: string };\n    const rightCol = right as unknown as { table: string; column: string };\n    if (leftCol.table === rightCol.table) {\n      throw planInvalid('Self-joins are not supported in MVP');\n    }\n\n    return {\n      kind: 'join-on',\n      left: left as AnyColumnBuilder,\n      right: right as AnyColumnBuilder,\n    };\n  }\n}\n\nexport function createJoinOnBuilder(): JoinOnBuilder {\n  return new JoinOnBuilderImpl();\n}\n","import type { ColumnRef, Direction, OperationExpr } from './types';\n\nexport function createOrderByItem(\n  expr: ColumnRef | OperationExpr,\n  dir: 'asc' | 'desc',\n): { expr: ColumnRef | OperationExpr; dir: Direction } {\n  return {\n    expr,\n    dir,\n  };\n}\n","import type {\n  BinaryExpr,\n  BinaryOp,\n  ColumnRef,\n  ExistsExpr,\n  OperationExpr,\n  ParamRef,\n  SelectAst,\n} from './types';\n\nexport function createBinaryExpr(\n  op: BinaryOp,\n  left: ColumnRef | OperationExpr,\n  right: ParamRef,\n): BinaryExpr {\n  return {\n    kind: 'bin',\n    op,\n    left,\n    right,\n  };\n}\n\nexport function createExistsExpr(not: boolean, subquery: SelectAst): ExistsExpr {\n  return {\n    kind: 'exists',\n    not,\n    subquery,\n  };\n}\n","import type {\n  BinaryExpr,\n  ColumnRef,\n  Direction,\n  ExistsExpr,\n  IncludeAst,\n  IncludeRef,\n  JoinAst,\n  OperationExpr,\n  SelectAst,\n  TableRef,\n} from './types';\nimport { compact } from './util';\n\nexport interface CreateSelectAstOptions {\n  readonly from: TableRef;\n  readonly joins?: ReadonlyArray<JoinAst>;\n  readonly includes?: ReadonlyArray<IncludeAst>;\n  readonly project: ReadonlyArray<{\n    alias: string;\n    expr: ColumnRef | IncludeRef | OperationExpr;\n  }>;\n  readonly where?: BinaryExpr | ExistsExpr;\n  readonly orderBy?: ReadonlyArray<{ expr: ColumnRef | OperationExpr; dir: Direction }>;\n  readonly limit?: number;\n}\n\nexport function createSelectAst(options: CreateSelectAstOptions): SelectAst {\n  return compact({\n    kind: 'select',\n    from: options.from,\n    joins: options.joins,\n    includes: options.includes,\n    project: options.project,\n    where: options.where,\n    orderBy: options.orderBy,\n    limit: options.limit,\n  }) as SelectAst;\n}\n","import type { ReturnSpec } from '@prisma-next/operations';\nimport type { SqlLoweringSpec } from '@prisma-next/sql-operations';\n\n// SQL-specific AST types and supporting types\n// These types are needed by adapters and runtime for SQL query execution\n\nexport type Direction = 'asc' | 'desc';\n\nexport interface TableRef {\n  readonly kind: 'table';\n  readonly name: string;\n}\n\nexport interface ColumnRef {\n  readonly kind: 'col';\n  readonly table: string;\n  readonly column: string;\n}\n\nexport interface ParamRef {\n  readonly kind: 'param';\n  readonly index: number;\n  readonly name?: string;\n}\n\nexport interface LiteralExpr {\n  readonly kind: 'literal';\n  readonly value: unknown;\n}\n\nexport interface OperationExpr {\n  readonly kind: 'operation';\n  readonly method: string;\n  readonly forTypeId: string;\n  readonly self: ColumnRef | OperationExpr;\n  readonly args: ReadonlyArray<ColumnRef | ParamRef | LiteralExpr | OperationExpr>;\n  readonly returns: ReturnSpec;\n  readonly lowering: SqlLoweringSpec;\n}\n\nexport function isOperationExpr(expr: ColumnRef | OperationExpr): expr is OperationExpr {\n  return expr.kind === 'operation';\n}\n\nexport type BinaryOp = 'eq' | 'neq' | 'gt' | 'lt' | 'gte' | 'lte';\n\nexport interface BinaryExpr {\n  readonly kind: 'bin';\n  readonly op: BinaryOp;\n  readonly left: ColumnRef | OperationExpr;\n  readonly right: ParamRef;\n}\n\nexport interface ExistsExpr {\n  readonly kind: 'exists';\n  readonly not: boolean;\n  readonly subquery: SelectAst;\n}\n\nexport type JoinOnExpr = {\n  readonly kind: 'eqCol';\n  readonly left: ColumnRef;\n  readonly right: ColumnRef;\n};\n\nexport interface JoinAst {\n  readonly kind: 'join';\n  readonly joinType: 'inner' | 'left' | 'right' | 'full';\n  readonly table: TableRef;\n  readonly on: JoinOnExpr;\n}\n\nexport interface IncludeRef {\n  readonly kind: 'includeRef';\n  readonly alias: string;\n}\n\nexport interface IncludeAst {\n  readonly kind: 'includeMany';\n  readonly alias: string;\n  readonly child: {\n    readonly table: TableRef;\n    readonly on: JoinOnExpr;\n    readonly where?: BinaryExpr | ExistsExpr;\n    readonly orderBy?: ReadonlyArray<{ expr: ColumnRef | OperationExpr; dir: Direction }>;\n    readonly limit?: number;\n    readonly project: ReadonlyArray<{ alias: string; expr: ColumnRef | OperationExpr }>;\n  };\n}\n\nexport interface SelectAst {\n  readonly kind: 'select';\n  readonly from: TableRef;\n  readonly joins?: ReadonlyArray<JoinAst>;\n  readonly includes?: ReadonlyArray<IncludeAst>;\n  readonly project: ReadonlyArray<{\n    alias: string;\n    expr: ColumnRef | IncludeRef | OperationExpr | LiteralExpr;\n  }>;\n  readonly where?: BinaryExpr | ExistsExpr;\n  readonly orderBy?: ReadonlyArray<{ expr: ColumnRef | OperationExpr; dir: Direction }>;\n  readonly limit?: number;\n}\n\nexport interface InsertAst {\n  readonly kind: 'insert';\n  readonly table: TableRef;\n  readonly values: Record<string, ColumnRef | ParamRef>;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport interface UpdateAst {\n  readonly kind: 'update';\n  readonly table: TableRef;\n  readonly set: Record<string, ColumnRef | ParamRef>;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport interface DeleteAst {\n  readonly kind: 'delete';\n  readonly table: TableRef;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport type QueryAst = SelectAst | InsertAst | UpdateAst | DeleteAst;\n\nexport interface LoweredStatement {\n  readonly sql: string;\n  readonly params: readonly unknown[];\n  readonly annotations?: Record<string, unknown>;\n}\n","import type { BinaryExpr, ColumnRef, ParamRef, TableRef, UpdateAst } from './types';\nimport { compact } from './util';\n\nexport interface CreateUpdateAstOptions {\n  readonly table: TableRef;\n  readonly set: Record<string, ColumnRef | ParamRef>;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport function createUpdateAst(options: CreateUpdateAstOptions): UpdateAst {\n  return compact({\n    kind: 'update',\n    table: options.table,\n    set: options.set,\n    where: options.where,\n    returning: options.returning,\n  }) as UpdateAst;\n}\n"],"mappings":";;;;;AA4EA,IAAM,oBAAN,MAAiD;AAAA,EAC9B,QAAQ,oBAAI,IAA2B;AAAA,EACvC,YAAY,oBAAI,IAA6B;AAAA;AAAA;AAAA;AAAA;AAAA,EAM9D,IAAI,IAAuC;AACzC,WAAO,KAAK,MAAM,IAAI,EAAE;AAAA,EAC1B;AAAA;AAAA;AAAA;AAAA,EAKA,IAAI,IAAqB;AACvB,WAAO,KAAK,MAAM,IAAI,EAAE;AAAA,EAC1B;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAOA,YAAY,QAA0C;AACpD,WAAO,KAAK,UAAU,IAAI,MAAM,KAAK,OAAO,OAAO,CAAC,CAAC;AAAA,EACvD;AAAA;AAAA;AAAA;AAAA;AAAA,EAMA,gBAAgB,QAA2C;AACzD,UAAM,UAAU,KAAK,UAAU,IAAI,MAAM;AACzC,WAAO,UAAU,CAAC;AAAA,EACpB;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EASA,SAASA,QAA4B;AACnC,QAAI,KAAK,MAAM,IAAIA,OAAM,EAAE,GAAG;AAC5B,YAAM,IAAI,MAAM,kBAAkBA,OAAM,EAAE,yBAAyB;AAAA,IACrE;AAEA,SAAK,MAAM,IAAIA,OAAM,IAAIA,MAAK;AAG9B,eAAW,cAAcA,OAAM,aAAa;AAC1C,YAAM,WAAW,KAAK,UAAU,IAAI,UAAU;AAC9C,UAAI,UAAU;AACZ,iBAAS,KAAKA,MAAK;AAAA,MACrB,OAAO;AACL,aAAK,UAAU,IAAI,YAAY,CAACA,MAAK,CAAC;AAAA,MACxC;AAAA,IACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA;AAAA,EAMA,EAAE,OAAO,QAAQ,IAA6B;AAC5C,eAAWA,UAAS,KAAK,MAAM,OAAO,GAAG;AACvC,YAAMA;AAAA,IACR;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,SAA0C;AACxC,WAAO,KAAK,MAAM,OAAO;AAAA,EAC3B;AACF;AAKO,SAAS,MAAqC,QAM3B;AACxB,SAAO;AAAA,IACL,IAAI,OAAO;AAAA,IACX,aAAa,OAAO;AAAA,IACpB,GAAI,OAAO,OAAO,EAAE,MAAM,OAAO,KAAK,IAAI,CAAC;AAAA,IAC3C,QAAQ,OAAO;AAAA,IACf,QAAQ,OAAO;AAAA,EACjB;AACF;AAgFA,IAAM,sBAAN,MAAM,qBAGN;AAAA,EACmB;AAAA,EAED;AAAA,EACA;AAAA,EAMhB,YAAY,QAAqB;AAC/B,SAAK,UAAU;AAGf,UAAM,aAAoF,CAAC;AAC3F,eAAW,CAAC,EAAE,SAAS,KAAK,OAAO,QAAQ,KAAK,OAAO,GAAG;AACxD,YAAM,iBAAiB;AACvB,iBAAW,eAAe,EAAE,IAAI;AAAA,QAC9B,OAAO;AAAA,QACP,QAAQ;AAAA,MACV;AAAA,IACF;AACA,SAAK,aAAa;AAMlB,UAAM,YAAY,CAAC;AACnB,eAAW,OAAO,KAAK,SAAS;AAC9B,UAAI,OAAO,OAAO,KAAK,SAAS,GAAG,GAAG;AACpC,cAAMA,SAAQ,KAAK,QAAQ,GAAG;AAC9B,kBAAU,GAAG,IAAIA,OAAM;AAAA,MACzB;AAAA,IACF;AACA,SAAK,YAAY;AAAA,EAKnB;AAAA,EAEA,IACE,YACA,WAGA;AACA,WAAO,IAAI,qBAAoB;AAAA,MAC7B,GAAG,KAAK;AAAA,MACR,CAAC,UAAU,GAAG;AAAA,IAChB,CAA4F;AAAA,EAC9F;AAAA;AAAA;AAAA;AAAA,EAKA,IAAI,mBASF;AACA,UAAM,SAUF,CAAC;AAEL,eAAW,CAAC,YAAY,SAAS,KAAK,OAAO,QAAQ,KAAK,OAAO,GAAG;AAClE,YAAMA,SAAQ;AACd,aAAO,UAAU,IAAI;AAAA,QACnB,QAAQA,OAAM;AAAA,QACd,QAAQ;AAAA,QACR,OAAOA;AAAA,QACP,OAAO;AAAA,QACP,QAAQ;AAAA,QACR,QAAQ;AAAA,MACV;AAAA,IACF;AAEA,WAAO;AAAA,EAYT;AACF;AAKO,SAAS,sBAAqC;AACnD,SAAO,IAAI,kBAAkB;AAC/B;AAKO,SAAS,eAAsD;AACpE,SAAO,IAAI,oBAAoB,CAAC,CAAC;AACnC;;;ACtXO,SAAS,QAA2C,GAAS;AAClE,QAAM,MAA+B,CAAC;AACtC,aAAW,CAAC,GAAG,CAAC,KAAK,OAAO,QAAQ,CAAC,GAAG;AACtC,QAAI,MAAM,UAAa,MAAM,KAAM;AACnC,QAAI,MAAM,QAAQ,CAAC,KAAK,EAAE,WAAW,EAAG;AACxC,QAAI,CAAC,IAAI;AAAA,EACX;AACA,SAAO;AACT;;;ACLO,SAAS,eAAe,MAAwB;AACrD,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,EACF;AACF;AAEO,SAAS,gBAAgB,OAAe,QAA2B;AACxE,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF;AACF;AAEO,SAAS,eAAe,OAAe,MAAyB;AACrE,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF,CAAC;AACH;AAEO,SAAS,oBAAoB,WAAyC;AAC3E,SAAO;AACT;AAEO,SAAS,kBAAkB,OAA6B;AAC7D,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,EACF;AACF;;;AC1BO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,OAAO,QAAQ;AAAA,IACf,OAAO,QAAQ;AAAA,IACf,WAAW,QAAQ;AAAA,EACrB,CAAC;AACH;;;ACPO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,OAAO,QAAQ;AAAA,IACf,QAAQ,QAAQ;AAAA,IAChB,WAAW,QAAQ;AAAA,EACrB,CAAC;AACH;;;AChBA,SAAS,mBAAmB;AAKrB,SAAS,WACd,UACA,OACA,IACS;AACT,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,IACA;AAAA,EACF;AACF;AAEO,SAAS,iBAAiB,MAAiB,OAA8B;AAC9E,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF;AACF;AAEA,IAAM,oBAAN,MAAiD;AAAA,EAC/C,MAAM,MAAwB,OAA0C;AACtE,QAAI,CAAC,QAAQ,CAAC,gBAAgB,IAAI,GAAG;AACnC,YAAM,YAAY,uCAAuC;AAAA,IAC3D;AAEA,QAAI,CAAC,SAAS,CAAC,gBAAgB,KAAK,GAAG;AACrC,YAAM,YAAY,wCAAwC;AAAA,IAC5D;AAGA,UAAM,UAAU;AAChB,UAAM,WAAW;AACjB,QAAI,QAAQ,UAAU,SAAS,OAAO;AACpC,YAAM,YAAY,qCAAqC;AAAA,IACzD;AAEA,WAAO;AAAA,MACL,MAAM;AAAA,MACN;AAAA,MACA;AAAA,IACF;AAAA,EACF;AACF;AAEO,SAAS,sBAAqC;AACnD,SAAO,IAAI,kBAAkB;AAC/B;;;ACnDO,SAAS,kBACd,MACA,KACqD;AACrD,SAAO;AAAA,IACL;AAAA,IACA;AAAA,EACF;AACF;;;ACAO,SAAS,iBACd,IACA,MACA,OACY;AACZ,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,IACA;AAAA,EACF;AACF;AAEO,SAAS,iBAAiB,KAAc,UAAiC;AAC9E,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF;AACF;;;ACFO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,MAAM,QAAQ;AAAA,IACd,OAAO,QAAQ;AAAA,IACf,UAAU,QAAQ;AAAA,IAClB,SAAS,QAAQ;AAAA,IACjB,OAAO,QAAQ;AAAA,IACf,SAAS,QAAQ;AAAA,IACjB,OAAO,QAAQ;AAAA,EACjB,CAAC;AACH;;;ACEO,SAAS,gBAAgB,MAAwD;AACtF,SAAO,KAAK,SAAS;AACvB;;;AChCO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,OAAO,QAAQ;AAAA,IACf,KAAK,QAAQ;AAAA,IACb,OAAO,QAAQ;AAAA,IACf,WAAW,QAAQ;AAAA,EACrB,CAAC;AACH;","names":["codec"]}

dist/chunk-R77KHJFH.js

+// src/types.ts
+function isColumnBuilder(value) {
+  return typeof value === "object" && value !== null && "kind" in value && value.kind === "column";
+}
+
+export {
+  isColumnBuilder
+};
+//# sourceMappingURL=chunk-R77KHJFH.js.map

dist/chunk-R77KHJFH.js.map

+{"version":3,"sources":["../src/types.ts"],"sourcesContent":["import type {\n  ResultType as CoreResultType,\n  ExecutionPlan,\n  PlanRefs,\n} from '@prisma-next/contract/types';\nimport type { ArgSpec, ReturnSpec } from '@prisma-next/operations';\nimport type { SqlContract, SqlStorage, StorageColumn } from '@prisma-next/sql-contract/types';\nimport type { SqlLoweringSpec } from '@prisma-next/sql-operations';\nimport type {\n  BinaryOp,\n  ColumnRef,\n  Direction,\n  OperationExpr,\n  ParamRef,\n  QueryAst,\n} from './ast/types';\nimport type { SqlQueryPlan } from './plan';\nimport type { QueryLaneContext } from './query-lane-context';\n\nexport interface ParamPlaceholder {\n  readonly kind: 'param-placeholder';\n  readonly name: string;\n}\n\nexport interface OrderBuilder<\n  ColumnName extends string = string,\n  ColumnMeta extends StorageColumn = StorageColumn,\n  JsType = unknown,\n> {\n  readonly kind: 'order';\n  readonly expr: ColumnBuilder<ColumnName, ColumnMeta, JsType> | OperationExpr;\n  readonly dir: Direction;\n}\n\n/**\n * ColumnBuilder with optional operation methods based on the column's typeId.\n * When Operations is provided and the column's typeId matches, operation methods are included.\n */\nexport type ColumnBuilder<\n  ColumnName extends string = string,\n  ColumnMeta extends StorageColumn = StorageColumn,\n  JsType = unknown,\n  Operations extends OperationTypes = Record<string, never>,\n> = {\n  readonly kind: 'column';\n  readonly table: string;\n  readonly column: ColumnName;\n  readonly columnMeta: ColumnMeta;\n  eq(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  neq(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  gt(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  lt(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  gte(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  lte(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  asc(): OrderBuilder<ColumnName, ColumnMeta, JsType>;\n  desc(): OrderBuilder<ColumnName, ColumnMeta, JsType>;\n  // Helper property for type extraction (not used at runtime)\n  readonly __jsType: JsType;\n} & (ColumnMeta['codecId'] extends string\n  ? ColumnMeta['codecId'] extends keyof Operations\n    ? OperationMethods<\n        OperationsForTypeId<ColumnMeta['codecId'] & string, Operations>,\n        ColumnName,\n        StorageColumn,\n        JsType\n      >\n    : Record<string, never>\n  : Record<string, never>);\n\nexport interface BinaryBuilder<\n  ColumnName extends string = string,\n  ColumnMeta extends StorageColumn = StorageColumn,\n  JsType = unknown,\n> {\n  readonly kind: 'binary';\n  readonly op: BinaryOp;\n  readonly left: ColumnBuilder<ColumnName, ColumnMeta, JsType> | OperationExpr;\n  readonly right: ParamPlaceholder;\n}\n\n// Helper aliases for usage sites where the specific column parameters are irrelevant\n// Accepts any ColumnBuilder regardless of its Operations parameter\n// Note: We use `any` here because TypeScript's variance rules don't allow us to express\n// \"any type that extends OperationTypes\" in a way that works for assignment.\n// Contract-specific OperationTypes (e.g., PgVectorOperationTypes) are not assignable\n// to the base OperationTypes in generic parameter position, even though they extend it structurally.\n// Helper type that accepts any ColumnBuilder regardless of its generic parameters\n// This is needed because conditional types in ColumnBuilder create incompatible intersection types\n// when Operations differs, even though structurally they're compatible\ntype AnyColumnBuilderBase = {\n  readonly kind: 'column';\n  readonly table: string;\n  readonly column: string;\n  readonly columnMeta: StorageColumn;\n  eq(value: ParamPlaceholder): AnyBinaryBuilder;\n  neq(value: ParamPlaceholder): AnyBinaryBuilder;\n  gt(value: ParamPlaceholder): AnyBinaryBuilder;\n  lt(value: ParamPlaceholder): AnyBinaryBuilder;\n  gte(value: ParamPlaceholder): AnyBinaryBuilder;\n  lte(value: ParamPlaceholder): AnyBinaryBuilder;\n  asc(): AnyOrderBuilder;\n  desc(): AnyOrderBuilder;\n  readonly __jsType: unknown;\n  // Allow any operation methods (from conditional type)\n  readonly [key: string]: unknown;\n};\n\nexport type AnyColumnBuilder =\n  | ColumnBuilder<\n      string,\n      StorageColumn,\n      unknown,\n      // biome-ignore lint/suspicious/noExplicitAny: AnyColumnBuilder must accept column builders with any operation types\n      any\n    >\n  | AnyColumnBuilderBase;\nexport type AnyBinaryBuilder = BinaryBuilder<string, StorageColumn, unknown>;\nexport type AnyOrderBuilder = OrderBuilder<string, StorageColumn, unknown>;\n\nexport function isColumnBuilder(value: unknown): value is AnyColumnBuilder {\n  return (\n    typeof value === 'object' &&\n    value !== null &&\n    'kind' in value &&\n    (value as { kind: unknown }).kind === 'column'\n  );\n}\n\nexport interface JoinOnBuilder {\n  eqCol(left: AnyColumnBuilder, right: AnyColumnBuilder): JoinOnPredicate;\n}\n\nexport interface JoinOnPredicate {\n  readonly kind: 'join-on';\n  readonly left: AnyColumnBuilder;\n  readonly right: AnyColumnBuilder;\n}\n\nexport type Expr = ColumnRef | ParamRef;\n\n/**\n * Helper type to extract codec output type from CodecTypes.\n * Returns never if the codecId is not found in CodecTypes.\n */\ntype ExtractCodecOutputType<\n  CodecId extends string,\n  CodecTypes extends Record<string, { readonly output: unknown }>,\n> = CodecId extends keyof CodecTypes\n  ? CodecTypes[CodecId] extends { readonly output: infer Output }\n    ? Output\n    : never\n  : never;\n\n/**\n * Type-level operation signature.\n * Represents an operation at the type level, similar to OperationSignature at runtime.\n */\nexport type OperationTypeSignature = {\n  readonly args: ReadonlyArray<ArgSpec>;\n  readonly returns: ReturnSpec;\n  readonly lowering: SqlLoweringSpec;\n  readonly capabilities?: ReadonlyArray<string>;\n};\n\n/**\n * Type-level operation registry.\n * Maps typeId → operations, where operations is a record of method name → operation signature.\n *\n * Example:\n * ```typescript\n * type MyOperations: OperationTypes = {\n *   'pg/vector@1': {\n *     cosineDistance: {\n *       args: [{ kind: 'typeId'; type: 'pg/vector@1' }];\n *       returns: { kind: 'builtin'; type: 'number' };\n *       lowering: { targetFamily: 'sql'; strategy: 'function'; template: '...' };\n *     };\n *   };\n * };\n * ```\n */\nexport type OperationTypes = Record<string, Record<string, OperationTypeSignature>>;\n\n/**\n * CodecTypes represents a map of typeId to codec definitions.\n * Each codec definition must have an `output` property indicating the JavaScript type.\n *\n * Example:\n * ```typescript\n * type MyCodecTypes: CodecTypes = {\n *   'pg/int4@1': { output: number };\n *   'pg/text@1': { output: string };\n * };\n * ```\n */\nexport type CodecTypes = Record<string, { readonly output: unknown }>;\n\n/**\n * Extracts operations for a given typeId from the operation registry.\n * Returns an empty record if the typeId is not found.\n *\n * @example\n * ```typescript\n * type Ops = OperationsForTypeId<'pg/vector@1', MyOperations>;\n * // Ops = { cosineDistance: { ... }, l2Distance: { ... } }\n * ```\n */\nexport type OperationsForTypeId<\n  TypeId extends string,\n  Operations extends OperationTypes,\n> = Operations extends Record<string, never>\n  ? Record<string, never>\n  : TypeId extends keyof Operations\n    ? Operations[TypeId]\n    : Record<string, never>;\n\n/**\n * Maps operation signatures to method signatures on ColumnBuilder.\n * Each operation becomes a method that returns a ColumnBuilder or BinaryBuilder\n * based on the return type.\n */\ntype OperationMethods<\n  Ops extends Record<string, OperationTypeSignature>,\n  ColumnName extends string,\n  ColumnMeta extends StorageColumn,\n  JsType,\n> = {\n  [K in keyof Ops]: Ops[K] extends OperationTypeSignature\n    ? (\n        ...args: OperationArgs<Ops[K]['args']>\n      ) => OperationReturn<Ops[K]['returns'], ColumnName, ColumnMeta, JsType>\n    : never;\n};\n\n/**\n * Maps operation argument specs to TypeScript argument types.\n * - typeId args: ColumnBuilder (accepts base columns or operation results)\n * - param args: ParamPlaceholder\n * - literal args: unknown (could be more specific in future)\n */\ntype OperationArgs<Args extends ReadonlyArray<ArgSpec>> = Args extends readonly [\n  infer First,\n  ...infer Rest,\n]\n  ? First extends ArgSpec\n    ? [ArgToType<First>, ...(Rest extends ReadonlyArray<ArgSpec> ? OperationArgs<Rest> : [])]\n    : []\n  : [];\n\ntype ArgToType<Arg extends ArgSpec> = Arg extends { kind: 'typeId' }\n  ? AnyColumnBuilder\n  : Arg extends { kind: 'param' }\n    ? ParamPlaceholder\n    : Arg extends { kind: 'literal' }\n      ? unknown\n      : never;\n\n/**\n * Maps operation return spec to return type.\n * - builtin types: ColumnBuilder with appropriate JsType (matches runtime behavior)\n * - typeId types: ColumnBuilder (for now, could be more specific in future)\n */\ntype OperationReturn<\n  Returns extends ReturnSpec,\n  ColumnName extends string,\n  ColumnMeta extends StorageColumn,\n  _JsType,\n> = Returns extends { kind: 'builtin'; type: infer T }\n  ? T extends 'number'\n    ? ColumnBuilder<ColumnName, ColumnMeta, number>\n    : T extends 'boolean'\n      ? ColumnBuilder<ColumnName, ColumnMeta, boolean>\n      : T extends 'string'\n        ? ColumnBuilder<ColumnName, ColumnMeta, string>\n        : ColumnBuilder<ColumnName, ColumnMeta, unknown>\n  : Returns extends { kind: 'typeId' }\n    ? AnyColumnBuilder\n    : ColumnBuilder<ColumnName, ColumnMeta, unknown>;\n\n/**\n * Computes JavaScript type for a column at column creation time.\n *\n * Type inference:\n * - Read columnMeta.codecId as typeId string literal\n * - Look up CodecTypes[typeId].output\n * - Apply nullability: nullable ? Output | null : Output\n */\ntype ColumnMetaTypeId<ColumnMeta> = ColumnMeta extends { codecId: infer CodecId extends string }\n  ? CodecId\n  : ColumnMeta extends { type: infer TypeId extends string }\n    ? TypeId\n    : never;\n\nexport type ComputeColumnJsType<\n  _Contract extends SqlContract<SqlStorage>,\n  _TableName extends string,\n  _ColumnName extends string,\n  ColumnMeta extends StorageColumn,\n  CodecTypes extends Record<string, { readonly output: unknown }>,\n> = ColumnMeta extends { nullable: infer Nullable }\n  ? ColumnMetaTypeId<ColumnMeta> extends infer TypeId\n    ? TypeId extends string\n      ? ExtractCodecOutputType<TypeId, CodecTypes> extends infer CodecOutput\n        ? [CodecOutput] extends [never]\n          ? unknown // Codec not found in CodecTypes\n          : Nullable extends true\n            ? CodecOutput | null\n            : CodecOutput\n        : unknown\n      : unknown\n    : unknown\n  : unknown;\n\n/**\n * Infers Row type from a projection object.\n * Maps Record<string, ColumnBuilder> to Record<string, JSType>\n *\n * Extracts the pre-computed JsType from each ColumnBuilder in the projection.\n */\n/**\n * Extracts the inferred JsType carried by a ColumnBuilder.\n */\ntype ExtractJsTypeFromColumnBuilder<CB extends AnyColumnBuilder> = CB extends ColumnBuilder<\n  infer _ColumnName extends string,\n  infer _ColumnMeta extends StorageColumn,\n  infer JsType,\n  infer _Ops\n>\n  ? JsType\n  : never;\n\nexport type InferProjectionRow<P extends Record<string, AnyColumnBuilder>> = {\n  [K in keyof P]: ExtractJsTypeFromColumnBuilder<P[K]>;\n};\n\n/**\n * Nested projection type - allows recursive nesting of ColumnBuilder or nested objects.\n */\nexport type NestedProjection = Record<\n  string,\n  | AnyColumnBuilder\n  | Record<\n      string,\n      | AnyColumnBuilder\n      | Record<\n          string,\n          AnyColumnBuilder | Record<string, AnyColumnBuilder | Record<string, AnyColumnBuilder>>\n        >\n    >\n>;\n\n/**\n * Helper type to extract include type from Includes map.\n * Returns the value type if K is a key of Includes, otherwise returns unknown.\n */\ntype ExtractIncludeType<\n  K extends string,\n  Includes extends Record<string, unknown>,\n> = K extends keyof Includes ? Includes[K] : unknown;\n\n/**\n * Infers Row type from a nested projection object.\n * Recursively maps Record<string, ColumnBuilder | boolean | NestedProjection> to nested object types.\n *\n * Extracts the pre-computed JsType from each ColumnBuilder at leaves.\n * When a value is `true`, it represents an include reference and infers `Array<ChildShape>`\n * by looking up the include alias in the Includes type map.\n */\nexport type InferNestedProjectionRow<\n  P extends Record<string, AnyColumnBuilder | boolean | NestedProjection>,\n  CodecTypes extends Record<string, { readonly output: unknown }> = Record<string, never>,\n  Includes extends Record<string, unknown> = Record<string, never>,\n> = {\n  [K in keyof P]: P[K] extends AnyColumnBuilder\n    ? ExtractJsTypeFromColumnBuilder<P[K]>\n    : P[K] extends true\n      ? Array<ExtractIncludeType<K & string, Includes>> // Include reference - infers Array<ChildShape> from Includes map\n      : P[K] extends NestedProjection\n        ? InferNestedProjectionRow<P[K], CodecTypes, Includes>\n        : never;\n};\n\n/**\n * Infers Row type from a tuple of ColumnBuilders used in returning() clause.\n * Extracts column name and JsType from each ColumnBuilder and creates a Record.\n */\nexport type InferReturningRow<Columns extends readonly AnyColumnBuilder[]> =\n  Columns extends readonly [infer First, ...infer Rest]\n    ? First extends ColumnBuilder<\n        infer Name,\n        infer _Meta,\n        infer JsType,\n        infer _Ops extends OperationTypes\n      >\n      ? Name extends string\n        ? Rest extends readonly AnyColumnBuilder[]\n          ? { [K in Name]: JsType } & InferReturningRow<Rest>\n          : { [K in Name]: JsType }\n        : never\n      : never\n    : Record<string, never>;\n\n/**\n * Utility type to check if a contract has the required capabilities for includeMany.\n * Requires both `lateral` and `jsonAgg` to be `true` in the contract's capabilities for the target.\n * Capabilities are nested by target: `{ [target]: { lateral: true, jsonAgg: true } }`\n */\nexport type HasIncludeManyCapabilities<TContract extends SqlContract<SqlStorage>> =\n  TContract extends { capabilities: infer C; target: infer T }\n    ? T extends string\n      ? C extends Record<string, Record<string, boolean>>\n        ? C extends { [K in T]: infer TargetCaps }\n          ? TargetCaps extends { lateral: true; jsonAgg: true }\n            ? true\n            : false\n          : false\n        : false\n      : false\n    : false;\n\n/**\n * SQL-specific Plan type that refines the ast field to use QueryAst.\n * This is the type used by SQL query builders.\n */\nexport type SqlPlan<Row = unknown> = ExecutionPlan<Row, QueryAst>;\n\n/**\n * Helper types for extracting contract structure.\n */\nexport type TablesOf<TContract> = TContract extends {\n  storage: { tables: infer U };\n}\n  ? U\n  : never;\n\nexport type TableKey<TContract> = Extract<keyof TablesOf<TContract>, string>;\n\n// Common types for contract.d.ts generation (SQL-specific)\n// These types are used by emitted contract.d.ts files to provide type-safe DSL/ORM types\n\n/**\n * Unique symbol for metadata property to avoid collisions with user-defined properties\n */\nexport declare const META: unique symbol;\n\n/**\n * Extracts metadata from a type that has a META property\n */\nexport type Meta<T extends { [META]: unknown }> = T[typeof META];\n\n/**\n * Metadata interface for table definitions\n */\nexport interface TableMetadata<Name extends string> {\n  name: Name;\n}\n\n/**\n * Metadata interface for model definitions\n */\nexport interface ModelMetadata<Name extends string> {\n  name: Name;\n}\n\n/**\n * Base interface for table definitions with metadata\n * Used in contract.d.ts to define storage-level table types\n */\nexport interface TableDef<Name extends string> {\n  readonly [META]: TableMetadata<Name>;\n}\n\n/**\n * Base interface for model definitions with metadata\n * Used in contract.d.ts to define application-level model types\n */\nexport interface ModelDef<Name extends string> {\n  readonly [META]: ModelMetadata<Name>;\n}\n\nexport type ColumnsOf<\n  TContract,\n  K extends TableKey<TContract>,\n> = K extends keyof TablesOf<TContract>\n  ? TablesOf<TContract>[K] extends { columns: infer C }\n    ? C\n    : never\n  : never;\n\nexport interface RawTemplateOptions {\n  readonly refs?: PlanRefs;\n  readonly annotations?: Record<string, unknown>;\n  readonly projection?: ReadonlyArray<string>;\n}\n\nexport interface RawFunctionOptions extends RawTemplateOptions {\n  readonly params: ReadonlyArray<unknown>;\n}\n\nexport type RawTemplateFactory = (\n  strings: TemplateStringsArray,\n  ...values: readonly unknown[]\n) => ExecutionPlan;\n\nexport interface RawFactory extends RawTemplateFactory {\n  (text: string, options: RawFunctionOptions): ExecutionPlan;\n  with(options: RawTemplateOptions): RawTemplateFactory;\n}\n\nexport type { RuntimeError } from '@prisma-next/plan';\n\nexport interface BuildParamsMap {\n  readonly [name: string]: unknown;\n}\n\nexport interface BuildOptions {\n  readonly params?: BuildParamsMap;\n}\n\nexport interface SqlBuilderOptions<\n  TContract extends SqlContract<SqlStorage> = SqlContract<SqlStorage>,\n> {\n  readonly context: QueryLaneContext<TContract>;\n}\n\n/**\n * SQL-specific ResultType that works with both Plan and SqlQueryPlan.\n * This extends the core ResultType to also handle SqlQueryPlan.\n * Example: `type Row = ResultType<typeof plan>`\n */\nexport type ResultType<P> = P extends SqlQueryPlan<infer R> ? R : CoreResultType<P>;\n"],"mappings":";AAuHO,SAAS,gBAAgB,OAA2C;AACzE,SACE,OAAO,UAAU,YACjB,UAAU,QACV,UAAU,SACT,MAA4B,SAAS;AAE1C;","names":[]}

dist/exports/ast.js

@@ -22,4 +22,4 @@ import {
   isOperationExpr
-} from "../chunk-JQRBZSNT.js";
-import "../chunk-PWV44G7K.js";
+} from "../chunk-6JM7ZPMQ.js";
+import "../chunk-R77KHJFH.js";
 export {
@@ -26,0 +26,0 @@ codec,

dist/exports/types.d.ts

@@ -29,2 +29,3 @@ import { ExecutionPlan, PlanRefs, ResultType as ResultType$1 } from '@prisma-next/contract/types';
     eq(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;
+    neq(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;
     gt(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;
@@ -50,2 +51,3 @@ lt(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;
     eq(value: ParamPlaceholder): AnyBinaryBuilder;
+    neq(value: ParamPlaceholder): AnyBinaryBuilder;
     gt(value: ParamPlaceholder): AnyBinaryBuilder;
@@ -52,0 +54,0 @@ lt(value: ParamPlaceholder): AnyBinaryBuilder;

dist/exports/types.js

 import "../chunk-36WJWNHT.js";
 import {
   isColumnBuilder
-} from "../chunk-PWV44G7K.js";
+} from "../chunk-R77KHJFH.js";
 export {
@@ -6,0 +6,0 @@ isColumnBuilder

dist/index.js

@@ -40,6 +40,6 @@ import "./chunk-U7AXAUJA.js";
   isOperationExpr
-} from "./chunk-JQRBZSNT.js";
+} from "./chunk-6JM7ZPMQ.js";
 import {
   isColumnBuilder
-} from "./chunk-PWV44G7K.js";
+} from "./chunk-R77KHJFH.js";
 import {
@@ -46,0 +46,0 @@ augmentDescriptorWithColumnMeta

package.json

 {
   "name": "@prisma-next/sql-relational-core",
-  "version": "0.1.0-pr.36.1",
+  "version": "0.1.0-pr.36.2",
   "type": "module",
@@ -9,7 +9,7 @@ "sideEffects": false,
     "ts-toolbelt": "^9.6.0",
-    "@prisma-next/contract": "0.1.0-pr.36.1",
-    "@prisma-next/plan": "0.1.0-pr.36.1",
-    "@prisma-next/operations": "0.1.0-pr.36.1",
-    "@prisma-next/sql-contract": "0.1.0-pr.36.1",
-    "@prisma-next/sql-operations": "0.1.0-pr.36.1"
+    "@prisma-next/plan": "0.1.0-pr.36.2",
+    "@prisma-next/operations": "0.1.0-pr.36.2",
+    "@prisma-next/sql-contract": "0.1.0-pr.36.2",
+    "@prisma-next/sql-operations": "0.1.0-pr.36.2",
+    "@prisma-next/contract": "0.1.0-pr.36.2"
   },
@@ -21,3 +21,3 @@ "devDependencies": {
     "vitest": "^2.1.1",
-    "@prisma-next/sql-contract-ts": "0.1.0-pr.36.1",
+    "@prisma-next/sql-contract-ts": "0.1.0-pr.36.2",
     "@prisma-next/test-utils": "0.0.1"
@@ -24,0 +24,0 @@ },

dist/chunk-JQRBZSNT.js

-import {
-  isColumnBuilder
-} from "./chunk-PWV44G7K.js";
-
-// src/ast/codec-types.ts
-var CodecRegistryImpl = class {
-  _byId = /* @__PURE__ */ new Map();
-  _byScalar = /* @__PURE__ */ new Map();
-  /**
-   * Map-like interface for codec lookup by ID.
-   * Example: registry.get('pg/text@1')
-   */
-  get(id) {
-    return this._byId.get(id);
-  }
-  /**
-   * Check if a codec with the given ID is registered.
-   */
-  has(id) {
-    return this._byId.has(id);
-  }
-  /**
-   * Get all codecs that handle a given scalar type.
-   * Returns an empty frozen array if no codecs are found.
-   * Example: registry.getByScalar('text') → [codec1, codec2, ...]
-   */
-  getByScalar(scalar) {
-    return this._byScalar.get(scalar) ?? Object.freeze([]);
-  }
-  /**
-   * Get the default codec for a scalar type (first registered codec).
-   * Returns undefined if no codec handles this scalar type.
-   */
-  getDefaultCodec(scalar) {
-    const _codecs = this._byScalar.get(scalar);
-    return _codecs?.[0];
-  }
-  /**
-   * Register a codec in the registry.
-   * Throws an error if a codec with the same ID is already registered.
-   *
-   * @param codec - The codec to register
-   * @throws Error if a codec with the same ID already exists
-   */
-  register(codec2) {
-    if (this._byId.has(codec2.id)) {
-      throw new Error(`Codec with ID '${codec2.id}' is already registered`);
-    }
-    this._byId.set(codec2.id, codec2);
-    for (const scalarType of codec2.targetTypes) {
-      const existing = this._byScalar.get(scalarType);
-      if (existing) {
-        existing.push(codec2);
-      } else {
-        this._byScalar.set(scalarType, [codec2]);
-      }
-    }
-  }
-  /**
-   * Returns an iterator over all registered codecs.
-   * Useful for iterating through codecs from another registry.
-   */
-  *[Symbol.iterator]() {
-    for (const codec2 of this._byId.values()) {
-      yield codec2;
-    }
-  }
-  /**
-   * Returns an iterable of all registered codecs.
-   */
-  values() {
-    return this._byId.values();
-  }
-};
-function codec(config) {
-  return {
-    id: config.typeId,
-    targetTypes: config.targetTypes,
-    ...config.meta ? { meta: config.meta } : {},
-    encode: config.encode,
-    decode: config.decode
-  };
-}
-var CodecDefBuilderImpl = class _CodecDefBuilderImpl {
-  _codecs;
-  CodecTypes;
-  dataTypes;
-  constructor(codecs) {
-    this._codecs = codecs;
-    const codecTypes = {};
-    for (const [, codecImpl] of Object.entries(this._codecs)) {
-      const codecImplTyped = codecImpl;
-      codecTypes[codecImplTyped.id] = {
-        input: void 0,
-        output: void 0
-      };
-    }
-    this.CodecTypes = codecTypes;
-    const dataTypes = {};
-    for (const key in this._codecs) {
-      if (Object.hasOwn(this._codecs, key)) {
-        const codec2 = this._codecs[key];
-        dataTypes[key] = codec2.id;
-      }
-    }
-    this.dataTypes = dataTypes;
-  }
-  add(scalarName, codecImpl) {
-    return new _CodecDefBuilderImpl({
-      ...this._codecs,
-      [scalarName]: codecImpl
-    });
-  }
-  /**
-   * Derive codecDefinitions structure.
-   */
-  get codecDefinitions() {
-    const result = {};
-    for (const [scalarName, codecImpl] of Object.entries(this._codecs)) {
-      const codec2 = codecImpl;
-      result[scalarName] = {
-        typeId: codec2.id,
-        scalar: scalarName,
-        codec: codec2,
-        input: void 0,
-        output: void 0,
-        jsType: void 0
-      };
-    }
-    return result;
-  }
-};
-function createCodecRegistry() {
-  return new CodecRegistryImpl();
-}
-function defineCodecs() {
-  return new CodecDefBuilderImpl({});
-}
-
-// src/ast/util.ts
-function compact(o) {
-  const out = {};
-  for (const [k, v] of Object.entries(o)) {
-    if (v === void 0 || v === null) continue;
-    if (Array.isArray(v) && v.length === 0) continue;
-    out[k] = v;
-  }
-  return out;
-}
-
-// src/ast/common.ts
-function createTableRef(name) {
-  return {
-    kind: "table",
-    name
-  };
-}
-function createColumnRef(table, column) {
-  return {
-    kind: "col",
-    table,
-    column
-  };
-}
-function createParamRef(index, name) {
-  return compact({
-    kind: "param",
-    index,
-    name
-  });
-}
-function createOperationExpr(operation) {
-  return operation;
-}
-function createLiteralExpr(value) {
-  return {
-    kind: "literal",
-    value
-  };
-}
-
-// src/ast/delete.ts
-function createDeleteAst(options) {
-  return compact({
-    kind: "delete",
-    table: options.table,
-    where: options.where,
-    returning: options.returning
-  });
-}
-
-// src/ast/insert.ts
-function createInsertAst(options) {
-  return compact({
-    kind: "insert",
-    table: options.table,
-    values: options.values,
-    returning: options.returning
-  });
-}
-
-// src/ast/join.ts
-import { planInvalid } from "@prisma-next/plan";
-function createJoin(joinType, table, on) {
-  return {
-    kind: "join",
-    joinType,
-    table,
-    on
-  };
-}
-function createJoinOnExpr(left, right) {
-  return {
-    kind: "eqCol",
-    left,
-    right
-  };
-}
-var JoinOnBuilderImpl = class {
-  eqCol(left, right) {
-    if (!left || !isColumnBuilder(left)) {
-      throw planInvalid("Join ON left operand must be a column");
-    }
-    if (!right || !isColumnBuilder(right)) {
-      throw planInvalid("Join ON right operand must be a column");
-    }
-    const leftCol = left;
-    const rightCol = right;
-    if (leftCol.table === rightCol.table) {
-      throw planInvalid("Self-joins are not supported in MVP");
-    }
-    return {
-      kind: "join-on",
-      left,
-      right
-    };
-  }
-};
-function createJoinOnBuilder() {
-  return new JoinOnBuilderImpl();
-}
-
-// src/ast/order.ts
-function createOrderByItem(expr, dir) {
-  return {
-    expr,
-    dir
-  };
-}
-
-// src/ast/predicate.ts
-function createBinaryExpr(op, left, right) {
-  return {
-    kind: "bin",
-    op,
-    left,
-    right
-  };
-}
-function createExistsExpr(not, subquery) {
-  return {
-    kind: "exists",
-    not,
-    subquery
-  };
-}
-
-// src/ast/select.ts
-function createSelectAst(options) {
-  return compact({
-    kind: "select",
-    from: options.from,
-    joins: options.joins,
-    includes: options.includes,
-    project: options.project,
-    where: options.where,
-    orderBy: options.orderBy,
-    limit: options.limit
-  });
-}
-
-// src/ast/types.ts
-function isOperationExpr(expr) {
-  return expr.kind === "operation";
-}
-
-// src/ast/update.ts
-function createUpdateAst(options) {
-  return compact({
-    kind: "update",
-    table: options.table,
-    set: options.set,
-    where: options.where,
-    returning: options.returning
-  });
-}
-
-export {
-  codec,
-  createCodecRegistry,
-  defineCodecs,
-  compact,
-  createTableRef,
-  createColumnRef,
-  createParamRef,
-  createOperationExpr,
-  createLiteralExpr,
-  createDeleteAst,
-  createInsertAst,
-  createJoin,
-  createJoinOnExpr,
-  createJoinOnBuilder,
-  createOrderByItem,
-  createBinaryExpr,
-  createExistsExpr,
-  createSelectAst,
-  isOperationExpr,
-  createUpdateAst
-};
-//# sourceMappingURL=chunk-JQRBZSNT.js.map

dist/chunk-JQRBZSNT.js.map

-{"version":3,"sources":["../src/ast/codec-types.ts","../src/ast/util.ts","../src/ast/common.ts","../src/ast/delete.ts","../src/ast/insert.ts","../src/ast/join.ts","../src/ast/order.ts","../src/ast/predicate.ts","../src/ast/select.ts","../src/ast/types.ts","../src/ast/update.ts"],"sourcesContent":["import type { O } from 'ts-toolbelt';\n\n/**\n * Codec metadata for database-specific type information.\n * Used for schema introspection and verification.\n */\nexport interface CodecMeta {\n  readonly db?: {\n    readonly sql?: {\n      readonly postgres?: {\n        readonly nativeType: string; // e.g. 'integer', 'text', 'vector', 'timestamp with time zone'\n      };\n    };\n  };\n}\n\n/**\n * Codec interface for encoding/decoding values between wire format and JavaScript types.\n *\n * Codecs are pure, synchronous functions with no side effects or IO.\n * They provide deterministic conversion between database wire types and JS values.\n */\nexport interface Codec<Id extends string = string, TWire = unknown, TJs = unknown> {\n  /**\n   * Namespaced codec identifier in format 'namespace/name@version'\n   * Examples: 'pg/text@1', 'pg/uuid@1', 'pg/timestamptz@1'\n   */\n  readonly id: Id;\n\n  /**\n   * Contract scalar type IDs that this codec can handle.\n   * Examples: ['text'], ['int4', 'float8'], ['timestamp', 'timestamptz']\n   */\n  readonly targetTypes: readonly string[];\n\n  /**\n   * Optional metadata for database-specific type information.\n   * Used for schema introspection and verification.\n   */\n  readonly meta?: CodecMeta;\n\n  /**\n   * Decode a wire value (from database) to JavaScript type.\n   * Must be synchronous and pure (no side effects).\n   */\n  decode(wire: TWire): TJs;\n\n  /**\n   * Encode a JavaScript value to wire format (for database).\n   * Optional - if not provided, values pass through unchanged.\n   * Must be synchronous and pure (no side effects).\n   */\n  encode?(value: TJs): TWire;\n}\n\n/**\n * Registry interface for codecs organized by ID and by contract scalar type.\n *\n * The registry allows looking up codecs by their namespaced ID or by the\n * contract scalar types they handle. Multiple codecs may handle the same\n * scalar type; ordering in byScalar reflects preference (adapter first,\n * then packs, then app overrides).\n */\nexport interface CodecRegistry {\n  get(id: string): Codec<string> | undefined;\n  has(id: string): boolean;\n  getByScalar(scalar: string): readonly Codec<string>[];\n  getDefaultCodec(scalar: string): Codec<string> | undefined;\n  register(codec: Codec<string>): void;\n  [Symbol.iterator](): Iterator<Codec<string>>;\n  values(): IterableIterator<Codec<string>>;\n}\n\n/**\n * Implementation of CodecRegistry.\n */\nclass CodecRegistryImpl implements CodecRegistry {\n  private readonly _byId = new Map<string, Codec<string>>();\n  private readonly _byScalar = new Map<string, Codec<string>[]>();\n\n  /**\n   * Map-like interface for codec lookup by ID.\n   * Example: registry.get('pg/text@1')\n   */\n  get(id: string): Codec<string> | undefined {\n    return this._byId.get(id);\n  }\n\n  /**\n   * Check if a codec with the given ID is registered.\n   */\n  has(id: string): boolean {\n    return this._byId.has(id);\n  }\n\n  /**\n   * Get all codecs that handle a given scalar type.\n   * Returns an empty frozen array if no codecs are found.\n   * Example: registry.getByScalar('text') → [codec1, codec2, ...]\n   */\n  getByScalar(scalar: string): readonly Codec<string>[] {\n    return this._byScalar.get(scalar) ?? Object.freeze([]);\n  }\n\n  /**\n   * Get the default codec for a scalar type (first registered codec).\n   * Returns undefined if no codec handles this scalar type.\n   */\n  getDefaultCodec(scalar: string): Codec<string> | undefined {\n    const _codecs = this._byScalar.get(scalar);\n    return _codecs?.[0];\n  }\n\n  /**\n   * Register a codec in the registry.\n   * Throws an error if a codec with the same ID is already registered.\n   *\n   * @param codec - The codec to register\n   * @throws Error if a codec with the same ID already exists\n   */\n  register(codec: Codec<string>): void {\n    if (this._byId.has(codec.id)) {\n      throw new Error(`Codec with ID '${codec.id}' is already registered`);\n    }\n\n    this._byId.set(codec.id, codec);\n\n    // Update byScalar mapping\n    for (const scalarType of codec.targetTypes) {\n      const existing = this._byScalar.get(scalarType);\n      if (existing) {\n        existing.push(codec);\n      } else {\n        this._byScalar.set(scalarType, [codec]);\n      }\n    }\n  }\n\n  /**\n   * Returns an iterator over all registered codecs.\n   * Useful for iterating through codecs from another registry.\n   */\n  *[Symbol.iterator](): Iterator<Codec<string>> {\n    for (const codec of this._byId.values()) {\n      yield codec;\n    }\n  }\n\n  /**\n   * Returns an iterable of all registered codecs.\n   */\n  values(): IterableIterator<Codec<string>> {\n    return this._byId.values();\n  }\n}\n\n/**\n * Codec factory - creates a codec with typeId and encode/decode functions.\n */\nexport function codec<Id extends string, TWire, TJs>(config: {\n  typeId: Id;\n  targetTypes: readonly string[];\n  encode: (value: TJs) => TWire;\n  decode: (wire: TWire) => TJs;\n  meta?: CodecMeta;\n}): Codec<Id, TWire, TJs> {\n  return {\n    id: config.typeId,\n    targetTypes: config.targetTypes,\n    ...(config.meta ? { meta: config.meta } : {}),\n    encode: config.encode,\n    decode: config.decode,\n  };\n}\n\n/**\n * Type helpers to extract codec types.\n */\nexport type CodecId<T> = T extends Codec<infer Id, unknown, unknown>\n  ? Id\n  : T extends { readonly id: infer Id }\n    ? Id\n    : never;\nexport type CodecInput<T> = T extends Codec<string, unknown, infer JsT> ? JsT : never;\nexport type CodecOutput<T> = T extends Codec<string, unknown, infer JsT> ? JsT : never;\n\n/**\n * Type helper to extract codec types from builder instance.\n */\nexport type ExtractCodecTypes<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> } = Record<never, never>,\n> = {\n  readonly [K in keyof ScalarNames as ScalarNames[K] extends Codec<infer Id, unknown, unknown>\n    ? Id\n    : never]: {\n    readonly input: CodecInput<ScalarNames[K]>;\n    readonly output: CodecOutput<ScalarNames[K]>;\n  };\n};\n\n/**\n * Type helper to extract data type IDs from builder instance.\n * Uses ExtractCodecTypes which preserves literal types as keys.\n * Since ExtractCodecTypes<Record<K, ScalarNames[K]>> has exactly one key (the Id),\n * we extract it by creating a mapped type that uses the Id as both key and value,\n * then extract the value type. This preserves literal types.\n */\nexport type ExtractDataTypes<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> },\n> = {\n  readonly [K in keyof ScalarNames]: {\n    readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n  }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n};\n\n/**\n * Builder interface for declaring codecs.\n */\nexport interface CodecDefBuilder<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> } = Record<never, never>,\n> {\n  readonly CodecTypes: ExtractCodecTypes<ScalarNames>;\n\n  add<ScalarName extends string, CodecImpl extends Codec<string>>(\n    scalarName: ScalarName,\n    codecImpl: CodecImpl,\n  ): CodecDefBuilder<\n    O.Overwrite<ScalarNames, Record<ScalarName, CodecImpl>> & Record<ScalarName, CodecImpl>\n  >;\n\n  readonly codecDefinitions: {\n    readonly [K in keyof ScalarNames]: {\n      readonly typeId: ScalarNames[K] extends Codec<infer Id extends string, unknown, unknown>\n        ? Id\n        : never;\n      readonly scalar: K;\n      readonly codec: ScalarNames[K];\n      readonly input: CodecInput<ScalarNames[K]>;\n      readonly output: CodecOutput<ScalarNames[K]>;\n      readonly jsType: CodecOutput<ScalarNames[K]>;\n    };\n  };\n\n  readonly dataTypes: {\n    readonly [K in keyof ScalarNames]: {\n      readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n    }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n  };\n}\n\n/**\n * Implementation of CodecDefBuilder.\n */\nclass CodecDefBuilderImpl<\n  ScalarNames extends { readonly [K in keyof ScalarNames]: Codec<string> } = Record<never, never>,\n> implements CodecDefBuilder<ScalarNames>\n{\n  private readonly _codecs: ScalarNames;\n\n  public readonly CodecTypes: ExtractCodecTypes<ScalarNames>;\n  public readonly dataTypes: {\n    readonly [K in keyof ScalarNames]: {\n      readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n    }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n  };\n\n  constructor(codecs: ScalarNames) {\n    this._codecs = codecs;\n\n    // Populate CodecTypes from codecs\n    const codecTypes: Record<string, { readonly input: unknown; readonly output: unknown }> = {};\n    for (const [, codecImpl] of Object.entries(this._codecs)) {\n      const codecImplTyped = codecImpl as Codec<string>;\n      codecTypes[codecImplTyped.id] = {\n        input: undefined as unknown as CodecInput<typeof codecImplTyped>,\n        output: undefined as unknown as CodecOutput<typeof codecImplTyped>,\n      };\n    }\n    this.CodecTypes = codecTypes as ExtractCodecTypes<ScalarNames>;\n\n    // Populate dataTypes from codecs - extract id property from each codec\n    // Build object preserving keys from ScalarNames\n    // Type assertion is safe because we know ScalarNames structure matches the return type\n    // biome-ignore lint/suspicious/noExplicitAny: dynamic codec mapping requires any\n    const dataTypes = {} as any;\n    for (const key in this._codecs) {\n      if (Object.hasOwn(this._codecs, key)) {\n        const codec = this._codecs[key] as Codec<string>;\n        dataTypes[key] = codec.id;\n      }\n    }\n    this.dataTypes = dataTypes as {\n      readonly [K in keyof ScalarNames]: {\n        readonly [Id in keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>]: Id;\n      }[keyof ExtractCodecTypes<Record<K, ScalarNames[K]>>];\n    };\n  }\n\n  add<ScalarName extends string, CodecImpl extends Codec<string>>(\n    scalarName: ScalarName,\n    codecImpl: CodecImpl,\n  ): CodecDefBuilder<\n    O.Overwrite<ScalarNames, Record<ScalarName, CodecImpl>> & Record<ScalarName, CodecImpl>\n  > {\n    return new CodecDefBuilderImpl({\n      ...this._codecs,\n      [scalarName]: codecImpl,\n    } as O.Overwrite<ScalarNames, Record<ScalarName, CodecImpl>> & Record<ScalarName, CodecImpl>);\n  }\n\n  /**\n   * Derive codecDefinitions structure.\n   */\n  get codecDefinitions(): {\n    readonly [K in keyof ScalarNames]: {\n      readonly typeId: ScalarNames[K] extends Codec<infer Id, unknown, unknown> ? Id : never;\n      readonly scalar: K;\n      readonly codec: ScalarNames[K];\n      readonly input: CodecInput<ScalarNames[K]>;\n      readonly output: CodecOutput<ScalarNames[K]>;\n      readonly jsType: CodecOutput<ScalarNames[K]>;\n    };\n  } {\n    const result: Record<\n      string,\n      {\n        typeId: string;\n        scalar: string;\n        codec: Codec;\n        input: unknown;\n        output: unknown;\n        jsType: unknown;\n      }\n    > = {};\n\n    for (const [scalarName, codecImpl] of Object.entries(this._codecs)) {\n      const codec = codecImpl as Codec<string>;\n      result[scalarName] = {\n        typeId: codec.id,\n        scalar: scalarName,\n        codec: codec,\n        input: undefined as unknown as CodecInput<typeof codec>,\n        output: undefined as unknown as CodecOutput<typeof codec>,\n        jsType: undefined as unknown as CodecOutput<typeof codec>,\n      };\n    }\n\n    return result as {\n      readonly [K in keyof ScalarNames]: {\n        readonly typeId: ScalarNames[K] extends Codec<infer Id extends string, unknown, unknown>\n          ? Id\n          : never;\n        readonly scalar: K;\n        readonly codec: ScalarNames[K];\n        readonly input: CodecInput<ScalarNames[K]>;\n        readonly output: CodecOutput<ScalarNames[K]>;\n        readonly jsType: CodecOutput<ScalarNames[K]>;\n      };\n    };\n  }\n}\n\n/**\n * Create a new codec registry.\n */\nexport function createCodecRegistry(): CodecRegistry {\n  return new CodecRegistryImpl();\n}\n\n/**\n * Create a new codec definition builder.\n */\nexport function defineCodecs(): CodecDefBuilder<Record<never, never>> {\n  return new CodecDefBuilderImpl({});\n}\n","export function compact<T extends Record<string, unknown>>(o: T): T {\n  const out: Record<string, unknown> = {};\n  for (const [k, v] of Object.entries(o)) {\n    if (v === undefined || v === null) continue;\n    if (Array.isArray(v) && v.length === 0) continue;\n    out[k] = v;\n  }\n  return out as T;\n}\n","import type { ColumnRef, LiteralExpr, OperationExpr, ParamRef, TableRef } from './types';\nimport { compact } from './util';\n\nexport function createTableRef(name: string): TableRef {\n  return {\n    kind: 'table',\n    name,\n  };\n}\n\nexport function createColumnRef(table: string, column: string): ColumnRef {\n  return {\n    kind: 'col',\n    table,\n    column,\n  };\n}\n\nexport function createParamRef(index: number, name?: string): ParamRef {\n  return compact({\n    kind: 'param',\n    index,\n    name,\n  }) as ParamRef;\n}\n\nexport function createOperationExpr(operation: OperationExpr): OperationExpr {\n  return operation;\n}\n\nexport function createLiteralExpr(value: unknown): LiteralExpr {\n  return {\n    kind: 'literal',\n    value,\n  };\n}\n","import type { BinaryExpr, ColumnRef, DeleteAst, TableRef } from './types';\nimport { compact } from './util';\n\nexport interface CreateDeleteAstOptions {\n  readonly table: TableRef;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport function createDeleteAst(options: CreateDeleteAstOptions): DeleteAst {\n  return compact({\n    kind: 'delete',\n    table: options.table,\n    where: options.where,\n    returning: options.returning,\n  }) as DeleteAst;\n}\n","import type { ColumnRef, InsertAst, ParamRef, TableRef } from './types';\nimport { compact } from './util';\n\nexport interface CreateInsertAstOptions {\n  readonly table: TableRef;\n  readonly values: Record<string, ColumnRef | ParamRef>;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport function createInsertAst(options: CreateInsertAstOptions): InsertAst {\n  return compact({\n    kind: 'insert',\n    table: options.table,\n    values: options.values,\n    returning: options.returning,\n  }) as InsertAst;\n}\n","import { planInvalid } from '@prisma-next/plan';\nimport type { AnyColumnBuilder, JoinOnBuilder, JoinOnPredicate } from '../types';\nimport { isColumnBuilder } from '../types';\nimport type { ColumnRef, JoinAst, JoinOnExpr, TableRef } from './types';\n\nexport function createJoin(\n  joinType: 'inner' | 'left' | 'right' | 'full',\n  table: TableRef,\n  on: JoinOnExpr,\n): JoinAst {\n  return {\n    kind: 'join',\n    joinType,\n    table,\n    on,\n  };\n}\n\nexport function createJoinOnExpr(left: ColumnRef, right: ColumnRef): JoinOnExpr {\n  return {\n    kind: 'eqCol',\n    left,\n    right,\n  };\n}\n\nclass JoinOnBuilderImpl implements JoinOnBuilder {\n  eqCol(left: AnyColumnBuilder, right: AnyColumnBuilder): JoinOnPredicate {\n    if (!left || !isColumnBuilder(left)) {\n      throw planInvalid('Join ON left operand must be a column');\n    }\n\n    if (!right || !isColumnBuilder(right)) {\n      throw planInvalid('Join ON right operand must be a column');\n    }\n\n    // TypeScript can't narrow ColumnBuilder properly, so we assert\n    const leftCol = left as unknown as { table: string; column: string };\n    const rightCol = right as unknown as { table: string; column: string };\n    if (leftCol.table === rightCol.table) {\n      throw planInvalid('Self-joins are not supported in MVP');\n    }\n\n    return {\n      kind: 'join-on',\n      left: left as AnyColumnBuilder,\n      right: right as AnyColumnBuilder,\n    };\n  }\n}\n\nexport function createJoinOnBuilder(): JoinOnBuilder {\n  return new JoinOnBuilderImpl();\n}\n","import type { ColumnRef, Direction, OperationExpr } from './types';\n\nexport function createOrderByItem(\n  expr: ColumnRef | OperationExpr,\n  dir: 'asc' | 'desc',\n): { expr: ColumnRef | OperationExpr; dir: Direction } {\n  return {\n    expr,\n    dir,\n  };\n}\n","import type {\n  BinaryExpr,\n  BinaryOp,\n  ColumnRef,\n  ExistsExpr,\n  OperationExpr,\n  ParamRef,\n  SelectAst,\n} from './types';\n\nexport function createBinaryExpr(\n  op: BinaryOp,\n  left: ColumnRef | OperationExpr,\n  right: ParamRef,\n): BinaryExpr {\n  return {\n    kind: 'bin',\n    op,\n    left,\n    right,\n  };\n}\n\nexport function createExistsExpr(not: boolean, subquery: SelectAst): ExistsExpr {\n  return {\n    kind: 'exists',\n    not,\n    subquery,\n  };\n}\n","import type {\n  BinaryExpr,\n  ColumnRef,\n  Direction,\n  ExistsExpr,\n  IncludeAst,\n  IncludeRef,\n  JoinAst,\n  OperationExpr,\n  SelectAst,\n  TableRef,\n} from './types';\nimport { compact } from './util';\n\nexport interface CreateSelectAstOptions {\n  readonly from: TableRef;\n  readonly joins?: ReadonlyArray<JoinAst>;\n  readonly includes?: ReadonlyArray<IncludeAst>;\n  readonly project: ReadonlyArray<{\n    alias: string;\n    expr: ColumnRef | IncludeRef | OperationExpr;\n  }>;\n  readonly where?: BinaryExpr | ExistsExpr;\n  readonly orderBy?: ReadonlyArray<{ expr: ColumnRef | OperationExpr; dir: Direction }>;\n  readonly limit?: number;\n}\n\nexport function createSelectAst(options: CreateSelectAstOptions): SelectAst {\n  return compact({\n    kind: 'select',\n    from: options.from,\n    joins: options.joins,\n    includes: options.includes,\n    project: options.project,\n    where: options.where,\n    orderBy: options.orderBy,\n    limit: options.limit,\n  }) as SelectAst;\n}\n","import type { ReturnSpec } from '@prisma-next/operations';\nimport type { SqlLoweringSpec } from '@prisma-next/sql-operations';\n\n// SQL-specific AST types and supporting types\n// These types are needed by adapters and runtime for SQL query execution\n\nexport type Direction = 'asc' | 'desc';\n\nexport interface TableRef {\n  readonly kind: 'table';\n  readonly name: string;\n}\n\nexport interface ColumnRef {\n  readonly kind: 'col';\n  readonly table: string;\n  readonly column: string;\n}\n\nexport interface ParamRef {\n  readonly kind: 'param';\n  readonly index: number;\n  readonly name?: string;\n}\n\nexport interface LiteralExpr {\n  readonly kind: 'literal';\n  readonly value: unknown;\n}\n\nexport interface OperationExpr {\n  readonly kind: 'operation';\n  readonly method: string;\n  readonly forTypeId: string;\n  readonly self: ColumnRef | OperationExpr;\n  readonly args: ReadonlyArray<ColumnRef | ParamRef | LiteralExpr | OperationExpr>;\n  readonly returns: ReturnSpec;\n  readonly lowering: SqlLoweringSpec;\n}\n\nexport function isOperationExpr(expr: ColumnRef | OperationExpr): expr is OperationExpr {\n  return expr.kind === 'operation';\n}\n\nexport type BinaryOp = 'eq' | 'neq' | 'gt' | 'lt' | 'gte' | 'lte';\n\nexport interface BinaryExpr {\n  readonly kind: 'bin';\n  readonly op: BinaryOp;\n  readonly left: ColumnRef | OperationExpr;\n  readonly right: ParamRef;\n}\n\nexport interface ExistsExpr {\n  readonly kind: 'exists';\n  readonly not: boolean;\n  readonly subquery: SelectAst;\n}\n\nexport type JoinOnExpr = {\n  readonly kind: 'eqCol';\n  readonly left: ColumnRef;\n  readonly right: ColumnRef;\n};\n\nexport interface JoinAst {\n  readonly kind: 'join';\n  readonly joinType: 'inner' | 'left' | 'right' | 'full';\n  readonly table: TableRef;\n  readonly on: JoinOnExpr;\n}\n\nexport interface IncludeRef {\n  readonly kind: 'includeRef';\n  readonly alias: string;\n}\n\nexport interface IncludeAst {\n  readonly kind: 'includeMany';\n  readonly alias: string;\n  readonly child: {\n    readonly table: TableRef;\n    readonly on: JoinOnExpr;\n    readonly where?: BinaryExpr | ExistsExpr;\n    readonly orderBy?: ReadonlyArray<{ expr: ColumnRef | OperationExpr; dir: Direction }>;\n    readonly limit?: number;\n    readonly project: ReadonlyArray<{ alias: string; expr: ColumnRef | OperationExpr }>;\n  };\n}\n\nexport interface SelectAst {\n  readonly kind: 'select';\n  readonly from: TableRef;\n  readonly joins?: ReadonlyArray<JoinAst>;\n  readonly includes?: ReadonlyArray<IncludeAst>;\n  readonly project: ReadonlyArray<{\n    alias: string;\n    expr: ColumnRef | IncludeRef | OperationExpr | LiteralExpr;\n  }>;\n  readonly where?: BinaryExpr | ExistsExpr;\n  readonly orderBy?: ReadonlyArray<{ expr: ColumnRef | OperationExpr; dir: Direction }>;\n  readonly limit?: number;\n}\n\nexport interface InsertAst {\n  readonly kind: 'insert';\n  readonly table: TableRef;\n  readonly values: Record<string, ColumnRef | ParamRef>;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport interface UpdateAst {\n  readonly kind: 'update';\n  readonly table: TableRef;\n  readonly set: Record<string, ColumnRef | ParamRef>;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport interface DeleteAst {\n  readonly kind: 'delete';\n  readonly table: TableRef;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport type QueryAst = SelectAst | InsertAst | UpdateAst | DeleteAst;\n\nexport interface LoweredStatement {\n  readonly sql: string;\n  readonly params: readonly unknown[];\n  readonly annotations?: Record<string, unknown>;\n}\n","import type { BinaryExpr, ColumnRef, ParamRef, TableRef, UpdateAst } from './types';\nimport { compact } from './util';\n\nexport interface CreateUpdateAstOptions {\n  readonly table: TableRef;\n  readonly set: Record<string, ColumnRef | ParamRef>;\n  readonly where: BinaryExpr;\n  readonly returning?: ReadonlyArray<ColumnRef>;\n}\n\nexport function createUpdateAst(options: CreateUpdateAstOptions): UpdateAst {\n  return compact({\n    kind: 'update',\n    table: options.table,\n    set: options.set,\n    where: options.where,\n    returning: options.returning,\n  }) as UpdateAst;\n}\n"],"mappings":";;;;;AA4EA,IAAM,oBAAN,MAAiD;AAAA,EAC9B,QAAQ,oBAAI,IAA2B;AAAA,EACvC,YAAY,oBAAI,IAA6B;AAAA;AAAA;AAAA;AAAA;AAAA,EAM9D,IAAI,IAAuC;AACzC,WAAO,KAAK,MAAM,IAAI,EAAE;AAAA,EAC1B;AAAA;AAAA;AAAA;AAAA,EAKA,IAAI,IAAqB;AACvB,WAAO,KAAK,MAAM,IAAI,EAAE;AAAA,EAC1B;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAOA,YAAY,QAA0C;AACpD,WAAO,KAAK,UAAU,IAAI,MAAM,KAAK,OAAO,OAAO,CAAC,CAAC;AAAA,EACvD;AAAA;AAAA;AAAA;AAAA;AAAA,EAMA,gBAAgB,QAA2C;AACzD,UAAM,UAAU,KAAK,UAAU,IAAI,MAAM;AACzC,WAAO,UAAU,CAAC;AAAA,EACpB;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EASA,SAASA,QAA4B;AACnC,QAAI,KAAK,MAAM,IAAIA,OAAM,EAAE,GAAG;AAC5B,YAAM,IAAI,MAAM,kBAAkBA,OAAM,EAAE,yBAAyB;AAAA,IACrE;AAEA,SAAK,MAAM,IAAIA,OAAM,IAAIA,MAAK;AAG9B,eAAW,cAAcA,OAAM,aAAa;AAC1C,YAAM,WAAW,KAAK,UAAU,IAAI,UAAU;AAC9C,UAAI,UAAU;AACZ,iBAAS,KAAKA,MAAK;AAAA,MACrB,OAAO;AACL,aAAK,UAAU,IAAI,YAAY,CAACA,MAAK,CAAC;AAAA,MACxC;AAAA,IACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA;AAAA,EAMA,EAAE,OAAO,QAAQ,IAA6B;AAC5C,eAAWA,UAAS,KAAK,MAAM,OAAO,GAAG;AACvC,YAAMA;AAAA,IACR;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,SAA0C;AACxC,WAAO,KAAK,MAAM,OAAO;AAAA,EAC3B;AACF;AAKO,SAAS,MAAqC,QAM3B;AACxB,SAAO;AAAA,IACL,IAAI,OAAO;AAAA,IACX,aAAa,OAAO;AAAA,IACpB,GAAI,OAAO,OAAO,EAAE,MAAM,OAAO,KAAK,IAAI,CAAC;AAAA,IAC3C,QAAQ,OAAO;AAAA,IACf,QAAQ,OAAO;AAAA,EACjB;AACF;AAgFA,IAAM,sBAAN,MAAM,qBAGN;AAAA,EACmB;AAAA,EAED;AAAA,EACA;AAAA,EAMhB,YAAY,QAAqB;AAC/B,SAAK,UAAU;AAGf,UAAM,aAAoF,CAAC;AAC3F,eAAW,CAAC,EAAE,SAAS,KAAK,OAAO,QAAQ,KAAK,OAAO,GAAG;AACxD,YAAM,iBAAiB;AACvB,iBAAW,eAAe,EAAE,IAAI;AAAA,QAC9B,OAAO;AAAA,QACP,QAAQ;AAAA,MACV;AAAA,IACF;AACA,SAAK,aAAa;AAMlB,UAAM,YAAY,CAAC;AACnB,eAAW,OAAO,KAAK,SAAS;AAC9B,UAAI,OAAO,OAAO,KAAK,SAAS,GAAG,GAAG;AACpC,cAAMA,SAAQ,KAAK,QAAQ,GAAG;AAC9B,kBAAU,GAAG,IAAIA,OAAM;AAAA,MACzB;AAAA,IACF;AACA,SAAK,YAAY;AAAA,EAKnB;AAAA,EAEA,IACE,YACA,WAGA;AACA,WAAO,IAAI,qBAAoB;AAAA,MAC7B,GAAG,KAAK;AAAA,MACR,CAAC,UAAU,GAAG;AAAA,IAChB,CAA4F;AAAA,EAC9F;AAAA;AAAA;AAAA;AAAA,EAKA,IAAI,mBASF;AACA,UAAM,SAUF,CAAC;AAEL,eAAW,CAAC,YAAY,SAAS,KAAK,OAAO,QAAQ,KAAK,OAAO,GAAG;AAClE,YAAMA,SAAQ;AACd,aAAO,UAAU,IAAI;AAAA,QACnB,QAAQA,OAAM;AAAA,QACd,QAAQ;AAAA,QACR,OAAOA;AAAA,QACP,OAAO;AAAA,QACP,QAAQ;AAAA,QACR,QAAQ;AAAA,MACV;AAAA,IACF;AAEA,WAAO;AAAA,EAYT;AACF;AAKO,SAAS,sBAAqC;AACnD,SAAO,IAAI,kBAAkB;AAC/B;AAKO,SAAS,eAAsD;AACpE,SAAO,IAAI,oBAAoB,CAAC,CAAC;AACnC;;;ACtXO,SAAS,QAA2C,GAAS;AAClE,QAAM,MAA+B,CAAC;AACtC,aAAW,CAAC,GAAG,CAAC,KAAK,OAAO,QAAQ,CAAC,GAAG;AACtC,QAAI,MAAM,UAAa,MAAM,KAAM;AACnC,QAAI,MAAM,QAAQ,CAAC,KAAK,EAAE,WAAW,EAAG;AACxC,QAAI,CAAC,IAAI;AAAA,EACX;AACA,SAAO;AACT;;;ACLO,SAAS,eAAe,MAAwB;AACrD,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,EACF;AACF;AAEO,SAAS,gBAAgB,OAAe,QAA2B;AACxE,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF;AACF;AAEO,SAAS,eAAe,OAAe,MAAyB;AACrE,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF,CAAC;AACH;AAEO,SAAS,oBAAoB,WAAyC;AAC3E,SAAO;AACT;AAEO,SAAS,kBAAkB,OAA6B;AAC7D,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,EACF;AACF;;;AC1BO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,OAAO,QAAQ;AAAA,IACf,OAAO,QAAQ;AAAA,IACf,WAAW,QAAQ;AAAA,EACrB,CAAC;AACH;;;ACPO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,OAAO,QAAQ;AAAA,IACf,QAAQ,QAAQ;AAAA,IAChB,WAAW,QAAQ;AAAA,EACrB,CAAC;AACH;;;AChBA,SAAS,mBAAmB;AAKrB,SAAS,WACd,UACA,OACA,IACS;AACT,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,IACA;AAAA,EACF;AACF;AAEO,SAAS,iBAAiB,MAAiB,OAA8B;AAC9E,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF;AACF;AAEA,IAAM,oBAAN,MAAiD;AAAA,EAC/C,MAAM,MAAwB,OAA0C;AACtE,QAAI,CAAC,QAAQ,CAAC,gBAAgB,IAAI,GAAG;AACnC,YAAM,YAAY,uCAAuC;AAAA,IAC3D;AAEA,QAAI,CAAC,SAAS,CAAC,gBAAgB,KAAK,GAAG;AACrC,YAAM,YAAY,wCAAwC;AAAA,IAC5D;AAGA,UAAM,UAAU;AAChB,UAAM,WAAW;AACjB,QAAI,QAAQ,UAAU,SAAS,OAAO;AACpC,YAAM,YAAY,qCAAqC;AAAA,IACzD;AAEA,WAAO;AAAA,MACL,MAAM;AAAA,MACN;AAAA,MACA;AAAA,IACF;AAAA,EACF;AACF;AAEO,SAAS,sBAAqC;AACnD,SAAO,IAAI,kBAAkB;AAC/B;;;ACnDO,SAAS,kBACd,MACA,KACqD;AACrD,SAAO;AAAA,IACL;AAAA,IACA;AAAA,EACF;AACF;;;ACAO,SAAS,iBACd,IACA,MACA,OACY;AACZ,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,IACA;AAAA,EACF;AACF;AAEO,SAAS,iBAAiB,KAAc,UAAiC;AAC9E,SAAO;AAAA,IACL,MAAM;AAAA,IACN;AAAA,IACA;AAAA,EACF;AACF;;;ACFO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,MAAM,QAAQ;AAAA,IACd,OAAO,QAAQ;AAAA,IACf,UAAU,QAAQ;AAAA,IAClB,SAAS,QAAQ;AAAA,IACjB,OAAO,QAAQ;AAAA,IACf,SAAS,QAAQ;AAAA,IACjB,OAAO,QAAQ;AAAA,EACjB,CAAC;AACH;;;ACEO,SAAS,gBAAgB,MAAwD;AACtF,SAAO,KAAK,SAAS;AACvB;;;AChCO,SAAS,gBAAgB,SAA4C;AAC1E,SAAO,QAAQ;AAAA,IACb,MAAM;AAAA,IACN,OAAO,QAAQ;AAAA,IACf,KAAK,QAAQ;AAAA,IACb,OAAO,QAAQ;AAAA,IACf,WAAW,QAAQ;AAAA,EACrB,CAAC;AACH;","names":["codec"]}

dist/chunk-PWV44G7K.js

-// src/types.ts
-function isColumnBuilder(value) {
-  return typeof value === "object" && value !== null && "kind" in value && value.kind === "column";
-}
-
-export {
-  isColumnBuilder
-};
-//# sourceMappingURL=chunk-PWV44G7K.js.map

dist/chunk-PWV44G7K.js.map

-{"version":3,"sources":["../src/types.ts"],"sourcesContent":["import type {\n  ResultType as CoreResultType,\n  ExecutionPlan,\n  PlanRefs,\n} from '@prisma-next/contract/types';\nimport type { ArgSpec, ReturnSpec } from '@prisma-next/operations';\nimport type { SqlContract, SqlStorage, StorageColumn } from '@prisma-next/sql-contract/types';\nimport type { SqlLoweringSpec } from '@prisma-next/sql-operations';\nimport type {\n  BinaryOp,\n  ColumnRef,\n  Direction,\n  OperationExpr,\n  ParamRef,\n  QueryAst,\n} from './ast/types';\nimport type { SqlQueryPlan } from './plan';\nimport type { QueryLaneContext } from './query-lane-context';\n\nexport interface ParamPlaceholder {\n  readonly kind: 'param-placeholder';\n  readonly name: string;\n}\n\nexport interface OrderBuilder<\n  ColumnName extends string = string,\n  ColumnMeta extends StorageColumn = StorageColumn,\n  JsType = unknown,\n> {\n  readonly kind: 'order';\n  readonly expr: ColumnBuilder<ColumnName, ColumnMeta, JsType> | OperationExpr;\n  readonly dir: Direction;\n}\n\n/**\n * ColumnBuilder with optional operation methods based on the column's typeId.\n * When Operations is provided and the column's typeId matches, operation methods are included.\n */\nexport type ColumnBuilder<\n  ColumnName extends string = string,\n  ColumnMeta extends StorageColumn = StorageColumn,\n  JsType = unknown,\n  Operations extends OperationTypes = Record<string, never>,\n> = {\n  readonly kind: 'column';\n  readonly table: string;\n  readonly column: ColumnName;\n  readonly columnMeta: ColumnMeta;\n  eq(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  gt(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  lt(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  gte(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  lte(value: ParamPlaceholder): BinaryBuilder<ColumnName, ColumnMeta, JsType>;\n  asc(): OrderBuilder<ColumnName, ColumnMeta, JsType>;\n  desc(): OrderBuilder<ColumnName, ColumnMeta, JsType>;\n  // Helper property for type extraction (not used at runtime)\n  readonly __jsType: JsType;\n} & (ColumnMeta['codecId'] extends string\n  ? ColumnMeta['codecId'] extends keyof Operations\n    ? OperationMethods<\n        OperationsForTypeId<ColumnMeta['codecId'] & string, Operations>,\n        ColumnName,\n        StorageColumn,\n        JsType\n      >\n    : Record<string, never>\n  : Record<string, never>);\n\nexport interface BinaryBuilder<\n  ColumnName extends string = string,\n  ColumnMeta extends StorageColumn = StorageColumn,\n  JsType = unknown,\n> {\n  readonly kind: 'binary';\n  readonly op: BinaryOp;\n  readonly left: ColumnBuilder<ColumnName, ColumnMeta, JsType> | OperationExpr;\n  readonly right: ParamPlaceholder;\n}\n\n// Helper aliases for usage sites where the specific column parameters are irrelevant\n// Accepts any ColumnBuilder regardless of its Operations parameter\n// Note: We use `any` here because TypeScript's variance rules don't allow us to express\n// \"any type that extends OperationTypes\" in a way that works for assignment.\n// Contract-specific OperationTypes (e.g., PgVectorOperationTypes) are not assignable\n// to the base OperationTypes in generic parameter position, even though they extend it structurally.\n// Helper type that accepts any ColumnBuilder regardless of its generic parameters\n// This is needed because conditional types in ColumnBuilder create incompatible intersection types\n// when Operations differs, even though structurally they're compatible\ntype AnyColumnBuilderBase = {\n  readonly kind: 'column';\n  readonly table: string;\n  readonly column: string;\n  readonly columnMeta: StorageColumn;\n  eq(value: ParamPlaceholder): AnyBinaryBuilder;\n  gt(value: ParamPlaceholder): AnyBinaryBuilder;\n  lt(value: ParamPlaceholder): AnyBinaryBuilder;\n  gte(value: ParamPlaceholder): AnyBinaryBuilder;\n  lte(value: ParamPlaceholder): AnyBinaryBuilder;\n  asc(): AnyOrderBuilder;\n  desc(): AnyOrderBuilder;\n  readonly __jsType: unknown;\n  // Allow any operation methods (from conditional type)\n  readonly [key: string]: unknown;\n};\n\nexport type AnyColumnBuilder =\n  | ColumnBuilder<\n      string,\n      StorageColumn,\n      unknown,\n      // biome-ignore lint/suspicious/noExplicitAny: AnyColumnBuilder must accept column builders with any operation types\n      any\n    >\n  | AnyColumnBuilderBase;\nexport type AnyBinaryBuilder = BinaryBuilder<string, StorageColumn, unknown>;\nexport type AnyOrderBuilder = OrderBuilder<string, StorageColumn, unknown>;\n\nexport function isColumnBuilder(value: unknown): value is AnyColumnBuilder {\n  return (\n    typeof value === 'object' &&\n    value !== null &&\n    'kind' in value &&\n    (value as { kind: unknown }).kind === 'column'\n  );\n}\n\nexport interface JoinOnBuilder {\n  eqCol(left: AnyColumnBuilder, right: AnyColumnBuilder): JoinOnPredicate;\n}\n\nexport interface JoinOnPredicate {\n  readonly kind: 'join-on';\n  readonly left: AnyColumnBuilder;\n  readonly right: AnyColumnBuilder;\n}\n\nexport type Expr = ColumnRef | ParamRef;\n\n/**\n * Helper type to extract codec output type from CodecTypes.\n * Returns never if the codecId is not found in CodecTypes.\n */\ntype ExtractCodecOutputType<\n  CodecId extends string,\n  CodecTypes extends Record<string, { readonly output: unknown }>,\n> = CodecId extends keyof CodecTypes\n  ? CodecTypes[CodecId] extends { readonly output: infer Output }\n    ? Output\n    : never\n  : never;\n\n/**\n * Type-level operation signature.\n * Represents an operation at the type level, similar to OperationSignature at runtime.\n */\nexport type OperationTypeSignature = {\n  readonly args: ReadonlyArray<ArgSpec>;\n  readonly returns: ReturnSpec;\n  readonly lowering: SqlLoweringSpec;\n  readonly capabilities?: ReadonlyArray<string>;\n};\n\n/**\n * Type-level operation registry.\n * Maps typeId → operations, where operations is a record of method name → operation signature.\n *\n * Example:\n * ```typescript\n * type MyOperations: OperationTypes = {\n *   'pg/vector@1': {\n *     cosineDistance: {\n *       args: [{ kind: 'typeId'; type: 'pg/vector@1' }];\n *       returns: { kind: 'builtin'; type: 'number' };\n *       lowering: { targetFamily: 'sql'; strategy: 'function'; template: '...' };\n *     };\n *   };\n * };\n * ```\n */\nexport type OperationTypes = Record<string, Record<string, OperationTypeSignature>>;\n\n/**\n * CodecTypes represents a map of typeId to codec definitions.\n * Each codec definition must have an `output` property indicating the JavaScript type.\n *\n * Example:\n * ```typescript\n * type MyCodecTypes: CodecTypes = {\n *   'pg/int4@1': { output: number };\n *   'pg/text@1': { output: string };\n * };\n * ```\n */\nexport type CodecTypes = Record<string, { readonly output: unknown }>;\n\n/**\n * Extracts operations for a given typeId from the operation registry.\n * Returns an empty record if the typeId is not found.\n *\n * @example\n * ```typescript\n * type Ops = OperationsForTypeId<'pg/vector@1', MyOperations>;\n * // Ops = { cosineDistance: { ... }, l2Distance: { ... } }\n * ```\n */\nexport type OperationsForTypeId<\n  TypeId extends string,\n  Operations extends OperationTypes,\n> = Operations extends Record<string, never>\n  ? Record<string, never>\n  : TypeId extends keyof Operations\n    ? Operations[TypeId]\n    : Record<string, never>;\n\n/**\n * Maps operation signatures to method signatures on ColumnBuilder.\n * Each operation becomes a method that returns a ColumnBuilder or BinaryBuilder\n * based on the return type.\n */\ntype OperationMethods<\n  Ops extends Record<string, OperationTypeSignature>,\n  ColumnName extends string,\n  ColumnMeta extends StorageColumn,\n  JsType,\n> = {\n  [K in keyof Ops]: Ops[K] extends OperationTypeSignature\n    ? (\n        ...args: OperationArgs<Ops[K]['args']>\n      ) => OperationReturn<Ops[K]['returns'], ColumnName, ColumnMeta, JsType>\n    : never;\n};\n\n/**\n * Maps operation argument specs to TypeScript argument types.\n * - typeId args: ColumnBuilder (accepts base columns or operation results)\n * - param args: ParamPlaceholder\n * - literal args: unknown (could be more specific in future)\n */\ntype OperationArgs<Args extends ReadonlyArray<ArgSpec>> = Args extends readonly [\n  infer First,\n  ...infer Rest,\n]\n  ? First extends ArgSpec\n    ? [ArgToType<First>, ...(Rest extends ReadonlyArray<ArgSpec> ? OperationArgs<Rest> : [])]\n    : []\n  : [];\n\ntype ArgToType<Arg extends ArgSpec> = Arg extends { kind: 'typeId' }\n  ? AnyColumnBuilder\n  : Arg extends { kind: 'param' }\n    ? ParamPlaceholder\n    : Arg extends { kind: 'literal' }\n      ? unknown\n      : never;\n\n/**\n * Maps operation return spec to return type.\n * - builtin types: ColumnBuilder with appropriate JsType (matches runtime behavior)\n * - typeId types: ColumnBuilder (for now, could be more specific in future)\n */\ntype OperationReturn<\n  Returns extends ReturnSpec,\n  ColumnName extends string,\n  ColumnMeta extends StorageColumn,\n  _JsType,\n> = Returns extends { kind: 'builtin'; type: infer T }\n  ? T extends 'number'\n    ? ColumnBuilder<ColumnName, ColumnMeta, number>\n    : T extends 'boolean'\n      ? ColumnBuilder<ColumnName, ColumnMeta, boolean>\n      : T extends 'string'\n        ? ColumnBuilder<ColumnName, ColumnMeta, string>\n        : ColumnBuilder<ColumnName, ColumnMeta, unknown>\n  : Returns extends { kind: 'typeId' }\n    ? AnyColumnBuilder\n    : ColumnBuilder<ColumnName, ColumnMeta, unknown>;\n\n/**\n * Computes JavaScript type for a column at column creation time.\n *\n * Type inference:\n * - Read columnMeta.codecId as typeId string literal\n * - Look up CodecTypes[typeId].output\n * - Apply nullability: nullable ? Output | null : Output\n */\ntype ColumnMetaTypeId<ColumnMeta> = ColumnMeta extends { codecId: infer CodecId extends string }\n  ? CodecId\n  : ColumnMeta extends { type: infer TypeId extends string }\n    ? TypeId\n    : never;\n\nexport type ComputeColumnJsType<\n  _Contract extends SqlContract<SqlStorage>,\n  _TableName extends string,\n  _ColumnName extends string,\n  ColumnMeta extends StorageColumn,\n  CodecTypes extends Record<string, { readonly output: unknown }>,\n> = ColumnMeta extends { nullable: infer Nullable }\n  ? ColumnMetaTypeId<ColumnMeta> extends infer TypeId\n    ? TypeId extends string\n      ? ExtractCodecOutputType<TypeId, CodecTypes> extends infer CodecOutput\n        ? [CodecOutput] extends [never]\n          ? unknown // Codec not found in CodecTypes\n          : Nullable extends true\n            ? CodecOutput | null\n            : CodecOutput\n        : unknown\n      : unknown\n    : unknown\n  : unknown;\n\n/**\n * Infers Row type from a projection object.\n * Maps Record<string, ColumnBuilder> to Record<string, JSType>\n *\n * Extracts the pre-computed JsType from each ColumnBuilder in the projection.\n */\n/**\n * Extracts the inferred JsType carried by a ColumnBuilder.\n */\ntype ExtractJsTypeFromColumnBuilder<CB extends AnyColumnBuilder> = CB extends ColumnBuilder<\n  infer _ColumnName extends string,\n  infer _ColumnMeta extends StorageColumn,\n  infer JsType,\n  infer _Ops\n>\n  ? JsType\n  : never;\n\nexport type InferProjectionRow<P extends Record<string, AnyColumnBuilder>> = {\n  [K in keyof P]: ExtractJsTypeFromColumnBuilder<P[K]>;\n};\n\n/**\n * Nested projection type - allows recursive nesting of ColumnBuilder or nested objects.\n */\nexport type NestedProjection = Record<\n  string,\n  | AnyColumnBuilder\n  | Record<\n      string,\n      | AnyColumnBuilder\n      | Record<\n          string,\n          AnyColumnBuilder | Record<string, AnyColumnBuilder | Record<string, AnyColumnBuilder>>\n        >\n    >\n>;\n\n/**\n * Helper type to extract include type from Includes map.\n * Returns the value type if K is a key of Includes, otherwise returns unknown.\n */\ntype ExtractIncludeType<\n  K extends string,\n  Includes extends Record<string, unknown>,\n> = K extends keyof Includes ? Includes[K] : unknown;\n\n/**\n * Infers Row type from a nested projection object.\n * Recursively maps Record<string, ColumnBuilder | boolean | NestedProjection> to nested object types.\n *\n * Extracts the pre-computed JsType from each ColumnBuilder at leaves.\n * When a value is `true`, it represents an include reference and infers `Array<ChildShape>`\n * by looking up the include alias in the Includes type map.\n */\nexport type InferNestedProjectionRow<\n  P extends Record<string, AnyColumnBuilder | boolean | NestedProjection>,\n  CodecTypes extends Record<string, { readonly output: unknown }> = Record<string, never>,\n  Includes extends Record<string, unknown> = Record<string, never>,\n> = {\n  [K in keyof P]: P[K] extends AnyColumnBuilder\n    ? ExtractJsTypeFromColumnBuilder<P[K]>\n    : P[K] extends true\n      ? Array<ExtractIncludeType<K & string, Includes>> // Include reference - infers Array<ChildShape> from Includes map\n      : P[K] extends NestedProjection\n        ? InferNestedProjectionRow<P[K], CodecTypes, Includes>\n        : never;\n};\n\n/**\n * Infers Row type from a tuple of ColumnBuilders used in returning() clause.\n * Extracts column name and JsType from each ColumnBuilder and creates a Record.\n */\nexport type InferReturningRow<Columns extends readonly AnyColumnBuilder[]> =\n  Columns extends readonly [infer First, ...infer Rest]\n    ? First extends ColumnBuilder<\n        infer Name,\n        infer _Meta,\n        infer JsType,\n        infer _Ops extends OperationTypes\n      >\n      ? Name extends string\n        ? Rest extends readonly AnyColumnBuilder[]\n          ? { [K in Name]: JsType } & InferReturningRow<Rest>\n          : { [K in Name]: JsType }\n        : never\n      : never\n    : Record<string, never>;\n\n/**\n * Utility type to check if a contract has the required capabilities for includeMany.\n * Requires both `lateral` and `jsonAgg` to be `true` in the contract's capabilities for the target.\n * Capabilities are nested by target: `{ [target]: { lateral: true, jsonAgg: true } }`\n */\nexport type HasIncludeManyCapabilities<TContract extends SqlContract<SqlStorage>> =\n  TContract extends { capabilities: infer C; target: infer T }\n    ? T extends string\n      ? C extends Record<string, Record<string, boolean>>\n        ? C extends { [K in T]: infer TargetCaps }\n          ? TargetCaps extends { lateral: true; jsonAgg: true }\n            ? true\n            : false\n          : false\n        : false\n      : false\n    : false;\n\n/**\n * SQL-specific Plan type that refines the ast field to use QueryAst.\n * This is the type used by SQL query builders.\n */\nexport type SqlPlan<Row = unknown> = ExecutionPlan<Row, QueryAst>;\n\n/**\n * Helper types for extracting contract structure.\n */\nexport type TablesOf<TContract> = TContract extends {\n  storage: { tables: infer U };\n}\n  ? U\n  : never;\n\nexport type TableKey<TContract> = Extract<keyof TablesOf<TContract>, string>;\n\n// Common types for contract.d.ts generation (SQL-specific)\n// These types are used by emitted contract.d.ts files to provide type-safe DSL/ORM types\n\n/**\n * Unique symbol for metadata property to avoid collisions with user-defined properties\n */\nexport declare const META: unique symbol;\n\n/**\n * Extracts metadata from a type that has a META property\n */\nexport type Meta<T extends { [META]: unknown }> = T[typeof META];\n\n/**\n * Metadata interface for table definitions\n */\nexport interface TableMetadata<Name extends string> {\n  name: Name;\n}\n\n/**\n * Metadata interface for model definitions\n */\nexport interface ModelMetadata<Name extends string> {\n  name: Name;\n}\n\n/**\n * Base interface for table definitions with metadata\n * Used in contract.d.ts to define storage-level table types\n */\nexport interface TableDef<Name extends string> {\n  readonly [META]: TableMetadata<Name>;\n}\n\n/**\n * Base interface for model definitions with metadata\n * Used in contract.d.ts to define application-level model types\n */\nexport interface ModelDef<Name extends string> {\n  readonly [META]: ModelMetadata<Name>;\n}\n\nexport type ColumnsOf<\n  TContract,\n  K extends TableKey<TContract>,\n> = K extends keyof TablesOf<TContract>\n  ? TablesOf<TContract>[K] extends { columns: infer C }\n    ? C\n    : never\n  : never;\n\nexport interface RawTemplateOptions {\n  readonly refs?: PlanRefs;\n  readonly annotations?: Record<string, unknown>;\n  readonly projection?: ReadonlyArray<string>;\n}\n\nexport interface RawFunctionOptions extends RawTemplateOptions {\n  readonly params: ReadonlyArray<unknown>;\n}\n\nexport type RawTemplateFactory = (\n  strings: TemplateStringsArray,\n  ...values: readonly unknown[]\n) => ExecutionPlan;\n\nexport interface RawFactory extends RawTemplateFactory {\n  (text: string, options: RawFunctionOptions): ExecutionPlan;\n  with(options: RawTemplateOptions): RawTemplateFactory;\n}\n\nexport type { RuntimeError } from '@prisma-next/plan';\n\nexport interface BuildParamsMap {\n  readonly [name: string]: unknown;\n}\n\nexport interface BuildOptions {\n  readonly params?: BuildParamsMap;\n}\n\nexport interface SqlBuilderOptions<\n  TContract extends SqlContract<SqlStorage> = SqlContract<SqlStorage>,\n> {\n  readonly context: QueryLaneContext<TContract>;\n}\n\n/**\n * SQL-specific ResultType that works with both Plan and SqlQueryPlan.\n * This extends the core ResultType to also handle SqlQueryPlan.\n * Example: `type Row = ResultType<typeof plan>`\n */\nexport type ResultType<P> = P extends SqlQueryPlan<infer R> ? R : CoreResultType<P>;\n"],"mappings":";AAqHO,SAAS,gBAAgB,OAA2C;AACzE,SACE,OAAO,UAAU,YACjB,UAAU,QACV,UAAU,SACT,MAA4B,SAAS;AAE1C;","names":[]}

No alert changes

Improved metrics

Total package byte prevSize

141964

0.19%

Lines of code

1670

0.12%

Dependency changes

• + Added

  @prisma-next/contract@0.1.0-pr.36.2
  (transitive)

• + Added

  @prisma-next/operations@0.1.0-pr.36.2
  (transitive)

• + Added

  @prisma-next/plan@0.1.0-pr.36.2
  (transitive)

• + Added

  @prisma-next/sql-contract@0.1.0-pr.36.2
  (transitive)

• + Added

  @prisma-next/sql-operations@0.1.0-pr.36.2
  (transitive)

• - Removed

  @prisma-next/contract@0.1.0-pr.36.1
  (transitive)

• - Removed

  @prisma-next/operations@0.1.0-pr.36.1
  (transitive)

• - Removed

  @prisma-next/plan@0.1.0-pr.36.1
  (transitive)

• - Removed

  @prisma-next/sql-contract@0.1.0-pr.36.1
  (transitive)

• - Removed

  @prisma-next/sql-operations@0.1.0-pr.36.1
  (transitive)

• Updated

  @prisma-next/contract@0.1.0-pr.36.2

• Updated

  @prisma-next/operations@0.1.0-pr.36.2

• Updated

  @prisma-next/plan@0.1.0-pr.36.2

• Updated

  @prisma-next/sql-contract@0.1.0-pr.36.2

• Updated

  @prisma-next/sql-operations@0.1.0-pr.36.2