node_modules/mquery/lib/collection/node.js - master - 1Rrd0/Course

node_modules/mquery/lib/collection/node.js
128 строк3 KB
dima
13 дек 2025, 10:58
13 дек 2025, 10:58ce5a48e
'use strict';

/**
 * Module dependencies
 */

const Collection = require('./collection');

class NodeCollection extends Collection {
  constructor(col) {
    super();

    this.collection = col;
    this.collectionName = col.collectionName;
  }

  /**
   * find(match, options)
   */
  async find(match, options) {
    const cursor = this.collection.find(match, options);

    return cursor.toArray();
  }

  /**
   * findOne(match, options)
   */
  async findOne(match, options) {
    return this.collection.findOne(match, options);
  }

  /**
   * countDocuments(match, options)
   */
  async countDocuments(match, options) {
    return this.collection.countDocuments(match, options);
  }

  /**
   * estimatedDocumentCount(match, options)
   */
  async estimatedDocumentCount(match, options) {
    return this.collection.estimatedDocumentCount(match, options);
  }

  /**
   * distinct(prop, match, options)
   */
  async distinct(prop, match, options) {
    return this.collection.distinct(prop, match, options);
  }

  /**
   * updateMany(match, update, options)
   */
  async updateMany(match, update, options) {
    return this.collection.updateMany(match, update, options);
  }

  /**
   * updateOne(match, update, options)
   */
  async updateOne(match, update, options) {
    return this.collection.updateOne(match, update, options);
  }

  /**
   * replaceOne(match, update, options)
   */
  async replaceOne(match, update, options) {
    return this.collection.replaceOne(match, update, options);
  }

  /**
   * deleteOne(match, options)
   */
  async deleteOne(match, options) {
    return this.collection.deleteOne(match, options);
  }

  /**
   * deleteMany(match, options)
   */
  async deleteMany(match, options) {
    return this.collection.deleteMany(match, options);
  }

  /**
   * findOneAndDelete(match, options, function(err[, result])
   */
  async findOneAndDelete(match, options) {
    return this.collection.findOneAndDelete(match, options);
  }

  /**
   * findOneAndUpdate(match, update, options)
   */
  async findOneAndUpdate(match, update, options) {
    return this.collection.findOneAndUpdate(match, update, options);
  }

  /**
   * findOneAndReplace(match, update, options)
   */
  async findOneAndReplace(match, update, options) {
    return this.collection.findOneAndReplace(match, update, options);
  }

  /**
   * var cursor = findCursor(match, options)
   */
  findCursor(match, options) {
    return this.collection.find(match, options);
  }

  /**
   * aggregation(operators...)
   * TODO
   */
}


/**
 * Expose
 */

module.exports = exports = NodeCollection;