Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 7 additions & 2 deletions src/cmap/connection_pool_events.ts
Original file line number Diff line number Diff line change
Expand Up @@ -28,12 +28,17 @@ export class ConnectionPoolMonitoringEvent {
*/
export class ConnectionPoolCreatedEvent extends ConnectionPoolMonitoringEvent {
/** The options used to create this connection pool */
options?: ConnectionPoolOptions;
options: Omit<ConnectionPoolOptions, 'credentials'> & { credentials?: Record<never, never> };

/** @internal */
constructor(pool: ConnectionPool) {
super(pool);
this.options = pool.options;
if (pool.options.credentials != null) {
// Intentionally remove credentials: NODE-5460
this.options = { ...pool.options, credentials: {} };
} else {
this.options = pool.options;
}
}
}

Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,7 @@
import { expect } from 'chai';
import { once } from 'events';

import { MongoClient, MongoCredentials } from '../../../src';
import { loadSpecTests } from '../../spec';
import { CmapTest, runCmapTestSuite } from '../../tools/cmap_spec_runner';

Expand All @@ -16,4 +20,49 @@ describe('Connection Monitoring and Pooling (Node Driver)', function () {
}
]
});

describe('ConnectionPoolCreatedEvent', () => {
let client: MongoClient;
beforeEach(async function () {
client = this.configuration.newClient();
});

afterEach(async function () {
await client.close();
});

describe('constructor()', () => {
it('when auth is enabled redacts credentials from options', {
metadata: { requires: { auth: 'enabled' } },
async test() {
const poolCreated = once(client, 'connectionPoolCreated');
await client.connect();
const [event] = await poolCreated;
expect(event).to.have.deep.nested.property('options.credentials', {});

const poolOptions = Array.from(client.topology?.s.servers.values() ?? []).map(
s => s.s.pool.options
);
expect(poolOptions).to.have.length.of.at.least(1);

for (const { credentials = {} } of poolOptions) {
expect(
Object.keys(credentials),
'pool.options.credentials must exist and have keys'
).to.not.equal(0);
}
}
});

it('when auth is disabled does not add a credentials property to options', {
metadata: { requires: { auth: 'disabled' } },
async test() {
const poolCreated = once(client, 'connectionPoolCreated');
await client.connect();
const [event] = await poolCreated;
expect(event).to.not.have.nested.property('options.credentials');
}
});
});
});
});