feathersjs-ecosystem/feathers-mongodb-management

import Service from './service.js';

// Create the service.
class CollectionService extends Service {
  constructor (options) {
    super(options);

    if (!options || !options.db) {
      throw new Error('MongoDB DB options have to be provided');
    }
    this.db = options.db;
  }

  // Helper function to process stats object
  processObjectInfos (infos) {
    // In Mongo the collection name key is ns and prefixed by the db name, change to the more intuitive name just as in create
    const namespace = infos.ns.split('.');
    if (namespace.length > 1) {
      infos.name = namespace[1];
    }
    delete infos.ns;
    return infos;
  }

  createImplementation (id, options) {
    return this.db.createCollection(id, options)
      .then(collection => collection.stats())
      .then(infos => this.processObjectInfos(infos));
  }

  getImplementation (id) {
    return Promise.resolve(this.db.collection(id));
  }

  listImplementation () {
    return this.db.collections();
  }

  removeImplementation (item) {
    return item.drop();
  }
}

export default function init (options) {
  return new CollectionService(options);
}

init.Service = CollectionService;