Method _find

packages/mongodb/src/MongoConnection.ts:208–277

(
    entityName: EntityName<T>,
    where: FilterQuery<T>,
    opts: MongoFindOptions<T> = {},
  )

  }

  private async _find<T extends object>(
    entityName: EntityName<T>,
    where: FilterQuery<T>,
    opts: MongoFindOptions<T> = {},
  ): Promise<{ cursor: FindCursor<T>; query: string }> {
    await this.ensureConnection();
    const collection = this.getCollectionName(entityName);
    const options: FindOptions & Abortable = opts.ctx ? { session: opts.ctx } : {};

    if (opts.fields) {
      options.projection = opts.fields.reduce((o, k) => Object.assign(o, { [k]: 1 }), {});
    }

    if (opts.collation) {
      options.collation = opts.collation;
    }

    if (opts.indexHint != null) {
      options.hint = opts.indexHint;
    }

    if (opts.maxTimeMS != null) {
      options.maxTimeMS = opts.maxTimeMS;
    }

    if (opts.allowDiskUse != null) {
      options.allowDiskUse = opts.allowDiskUse;
    }
    if (opts.chunkSize != null) {
      options.batchSize = opts.chunkSize;
    }

    if (opts.signal) {
      options.signal = opts.signal;
    }

    const resultSet = this.getCollection<T>(entityName).find(where as Filter<T>, options);
    let query = `db.getCollection('${collection}').find(${this.logObject(where)}, ${this.logObject(options)})`;
    const orderBy = Utils.asArray(opts.orderBy);

    if (orderBy.length > 0) {
      const orderByTuples: [string, SortDirection][] = [];
      orderBy.forEach(o => {
        Utils.keys(o).forEach(k => {
          const direction = o[k] as SortDirection;
          if (typeof direction === 'string') {
            orderByTuples.push([k.toString(), direction.toUpperCase() === QueryOrder.ASC ? 1 : -1]);
          } else {
            orderByTuples.push([k.toString(), direction]);
          }
        });
      });
      if (orderByTuples.length > 0) {
        query += `.sort(${this.logObject(orderByTuples)})`;
        resultSet.sort(orderByTuples);
      }
    }