unit_db_list_collections.test.js

'use strict';

const mock = require('../tools/mock');
const expect = require('chai').expect;

describe('db.listCollections', function () {
  const testHarness = {};
  afterEach(() => mock.cleanup());
  beforeEach(() => {
    return mock.createServer().then(server => {
      server.setMessageHandler(request => {
        const doc = request.document;

        if (doc.ismaster || doc.hello) {
          return request.reply(Object.assign({}, mock.DEFAULT_ISMASTER));
        }

        if (doc.listCollections) {
          return request.reply({
            ok: 1,
            cursor: {
              id: 0,
              ns: 'test.$cmd.listCollections',
              firstBatch: [{ name: 'test', type: 'collection' }]
            }
          });
        }
      });
      testHarness.server = server;
    });
  });

  [
    {
      description: 'should always send nameOnly option, defaulting to false',
      command: db => db.listCollections().toArray(() => {}),
      listCollectionsOptions: { nameOnly: false }
    },
    {
      description: 'should propagate the nameOnly option',
      command: db => db.listCollections({}, { nameOnly: true }).toArray(() => {}),
      listCollectionsOptions: { nameOnly: true }
    },
    {
      description: 'should always send authorizedCollections option, defaulting to false',
      command: db => db.listCollections().toArray(() => {}),
      listCollectionsOptions: { authorizedCollections: false }
    },
    {
      description: 'should propagate the authorizedCollections option',
      command: db => db.listCollections({}, { authorizedCollections: true }).toArray(() => {}),
      listCollectionsOptions: { authorizedCollections: true }
    },
    {
      description: 'should send nameOnly: true for db.collections',
      command: db => db.collections(() => {}),
      listCollectionsOptions: { nameOnly: true }
    }
  ].forEach(config => {
    function testFn(done) {
      const configuration = this.configuration;
      const client = configuration.newClient(`mongodb://${testHarness.server.uri()}/test`, {
        monitorCommands: true
      });

      client.connect((err, client) => {
        const db = client.db('foo');

        client.on('commandStarted', e => {
          if (e.commandName === 'listCollections') {
            try {
              for (const [name, value] of Object.entries(config.listCollectionsOptions)) {
                expect(e).to.have.nested.property(`command.${name}`, value);
              }
              client.close(done);
            } catch (err) {
              client.close(() => done(err));
            }
          }
        });

        config.command(db);
      });
    }

    it(config.description, { test: testFn, metadata: { requires: { mongodb: '>=2.7.6' } } });
  });
});