mongodb.js

/* eslint-disable import/no-extraneous-dependencies */
import { LocalCollection } from 'meteor-standalone-minimongo';

const collections = {};

class Collection {
  constructor(name) {
    if (!collections[name]) {
      collections[name] = new LocalCollection();
    }
    this.collection = collections[name];
  }

  insertOne(...args) {
    return {
      insertedId: this.collection.insert(...args),
    };
  }

  find(...args) {
    const cursor = this.collection.find(...args);
    const res = {
      // XXX: unimplemented, I guess they need to re-do the cursor
      sort: () => res,
      limit: () => res,
      toArray: () => Promise.resolve(cursor.fetch()),
    };
    return res;
  }

  findOne(...args) {
    return Promise.resolve(this.collection.findOne(...args));
  }

  update(...args) {
    return Promise.resolve(this.collection.update(...args));
  }

  remove(...args) {
    return Promise.resolve(this.collection.remove(...args));
  }
}

export const MongoDatabase = {
  collection(name) {
    return new Collection(name);
  },
};

export const MongoClient = {
  connect() {
    return Promise.resolve(MongoDatabase);
  },
};

export function ObjectId(str) {
  return str || Math.random().toString(36);
}