123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051 |
- 'use strict';
- const Topology = require('mongodb-core').Topology;
- const ServerCapabilities = require('./topology_base').ServerCapabilities;
- const Cursor = require('../cursor');
- const translateOptions = require('../utils').translateOptions;
- class NativeTopology extends Topology {
- constructor(servers, options) {
- options = options || {};
- let clonedOptions = Object.assign(
- {},
- {
- cursorFactory: Cursor,
- reconnect: false,
- emitError: options.emitError,
- size: options.poolSize,
- monitorCommands: options.monitorCommands
- }
- );
- // Translate any SSL options and other connectivity options
- clonedOptions = translateOptions(clonedOptions, options);
- // Socket options
- var socketOptions =
- options.socketOptions && Object.keys(options.socketOptions).length > 0
- ? options.socketOptions
- : options;
- // Translate all the options to the mongodb-core ones
- clonedOptions = translateOptions(clonedOptions, socketOptions);
- super(servers, clonedOptions);
- // Do we have an application specific string
- if (options.appname) {
- this.s.clientInfo.application = { name: options.appname };
- }
- }
- capabilities() {
- if (this.s.sCapabilities) return this.s.sCapabilities;
- if (this.lastIsMaster() == null) return null;
- this.s.sCapabilities = new ServerCapabilities(this.lastIsMaster());
- return this.s.sCapabilities;
- }
- }
- module.exports = NativeTopology;
|