Function fromConvex

packages/core/fumadb/src/convex/query.ts:15–129

(schema: AnySchema, options: ConvexOptions)

// TODO: join, sort
export function fromConvex(schema: AnySchema, options: ConvexOptions) {
  const { secret, client, generatedAPI } = options;
  const api = generatedAPI as (typeof GeneratedAPI.fullApi)["test"];

  const orm = createTransaction({
    tables: schema.tables,
    async count(table, v) {
      return (await client.query(api.queryHandler, {
        tableName: table.ormName,
        query: {
          type: "count",
          where: v.where ? serializeWhere(v.where) : undefined,
        },
        secret,
      })) as number;
    },
    async findFirst(table, v) {
      const result = await client.query(api.queryHandler, {
        tableName: table.ormName,
        query: {
          type: "find",
          select: serializeSelect(table, v.select),
          where: v.where ? serializeWhere(v.where) : undefined,
          limit: 1,
        },
        secret,
      });

      if (Array.isArray(result) && result.length > 0)
        return result[0] as Record<string, unknown>;
      return null;
    },
    async findMany(table, v) {
      const result = await client.query(api.queryHandler, {
        tableName: table.ormName,
        query: {
          type: "find",
          select: serializeSelect(table, v.select),
          where: v.where ? serializeWhere(v.where) : undefined,
          limit: v.limit,
          offset: v.offset,
        },
        secret,
      });

      if (Array.isArray(result)) return result as Record<string, unknown>[];
      return [];
    },
    async updateMany(table, v) {
      await client.mutation(api.mutationHandler, {
        tableName: table.ormName,
        action: {
          type: "update",
          set: v.set,
          where: v.where ? serializeWhere(v.where) : undefined,
        },
        secret,
      });