Function toORM

packages/core/fumadb/src/query/orm/index.ts:320–446

(
  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 create(name, values) {
      const table = toTable(name);
      await runCreatePolicies(table, values, context);
      return await internal.create(table, values);
    },
    async createMany(name, values) {
      const table = toTable(name);
      for (const value of values) {