Function toORM

packages/core/fumadb/src/query/orm/index.ts:398–628

(
  adapter: ORMAdapter<S>,
  options: ToORMOptions = {},
)

}

export function toORM<S extends AnySchema>(
  adapter: ORMAdapter<S>,
  options: ToORMOptions = {},
): AbstractQuery<S> {
  const context = options.context ?? adapter.context;
  const internal: ORMAdapter<S> =
    context === adapter.context ? adapter : { ...adapter, context };

  function toTable<TableName extends keyof S["tables"]>(
    name: TableName,
  ): S["tables"][TableName] {
    const table = internal.tables[name];
    if (!table) throw new Error(`[FumaDB] Invalid table name ${String(name)}.`);

    return table;
  }

  const query = {
    internal,
    async count(name, { where } = {}) {
      const table = toTable(name);
      let conditions = where ? buildCondition(table.columns, where) : undefined;
      if (conditions === true) conditions = undefined;
      if (conditions === false) return 0;

      const constrainedWhere = await applyReadPolicies(table, conditions, context);
      if (constrainedWhere === false) return 0;
      return await internal.count(table, { where: constrainedWhere });
    },
    async upsert(name, { where, ...options }) {
      const table = toTable(name);
      const conditions = where ? buildCondition(table.columns, where) : undefined;
      if (conditions === false) return;
      let compiledWhere: Condition | undefined | false = conditions === true ? undefined : conditions;

      compiledWhere = await applyUpdatePolicies(
        table,
        compiledWhere,
        options.update,
        context,
        "upsert",
        options.create,
      );
      if (compiledWhere === false) return;
      await runCreatePolicies(table, options.create, context);
      await internal.upsert(table, {
        where: compiledWhere,
        ...options,
      });
    },
    async upsertMany(name, { target, update, values }) {
      const table = toTable(name);
      if (values.length === 0) return;
      if (target.length === 0) {
        // oxlint-disable-next-line executor/no-try-catch-or-throw, executor/no-error-constructor -- boundary: public query rejects invalid upsert shape
        throw new Error("[FumaDB] upsertMany requires at least one target column.");
      }
      if (update.length === 0) {