Function fromMongoDB

packages/core/fumadb/src/adapters/mongodb/query.ts:263–467

(
  schema: AnySchema,
  client: MongoClient,
  session?: ClientSession
)

 * This adapter uses string ids instead of object id, which is better suited for the API design of FumaDB.
 */
export function fromMongoDB(
  schema: AnySchema,
  client: MongoClient,
  session?: ClientSession
): AbstractQuery<AnySchema> {
  const db = client.db();

  function buildFindPipeline(
    table: AnyTable,
    v: SimplifyFindOptions<FindManyOptions>
  ) {
    const pipeline: Document[] = [];
    const where = v.where ? buildWhere(v.where) : undefined;

    if (where) pipeline.push({ $match: where });
    if (v.limit !== undefined)
      pipeline.push({
        $limit: v.limit,
      });
    if (v.offset !== undefined)
      pipeline.push({
        $skip: v.offset,
      });
    if (v.orderBy) {
      pipeline.push({ $sort: mapSort(v.orderBy) });
    }
    const project = mapProjection(v.select, table);

    if (v.join) {
      for (const { relation, options: joinOptions } of v.join) {
        project[relation.name] = 1;

        if (joinOptions === false) continue;
        const vars: Record<string, string> = {};

        for (const column of Object.values(table.columns)) {
          vars[`${table.ormName}_${column.ormName}`] =
            `$${column.names.mongodb}`;
        }

        const targetTable = relation.table;
        pipeline.push({
          $lookup: {
            from: targetTable.names.mongodb,
            let: vars,
            pipeline: [
              ...relation.on.map(([left, right]) => {
                return {
                  $match: {
                    $expr: {
                      $eq: [
                        `$${targetTable.columns[right].names.mongodb}`,
                        `$$${table.ormName}_${left}`,
                      ],
                    },
                  },
                };
              }),