Method aggregate

packages/mongodb/src/MongoConnection.ts:330–350

(
    entityName: EntityName<T>,
    pipeline: any[],
    ctx?: Transaction<ClientSession>,
    loggerContext?: LoggingOptions,
    signal?: AbortSignal,
  )

  }

  async aggregate<T extends object = any>(
    entityName: EntityName<T>,
    pipeline: any[],
    ctx?: Transaction<ClientSession>,
    loggerContext?: LoggingOptions,
    signal?: AbortSignal,
  ): Promise<T[]> {
    await this.ensureConnection();
    const collection = this.getCollectionName(entityName);
    /* v8 ignore next */
    const options: Dictionary = ctx ? { session: ctx } : {};
    if (signal) {
      options.signal = signal;
    }
    const query = `db.getCollection('${collection}').aggregate(${this.logObject(pipeline)}, ${this.logObject(options)}).toArray();`;
    const now = Date.now();
    const res = await this.getCollection(entityName).aggregate<T>(pipeline, options).toArray();
    this.logQuery(query, { took: Date.now() - now, results: res.length, ...loggerContext });

    return res;
  }

  async *streamAggregate<T extends object>(
    entityName: EntityName<T>,