Skip to content

Commit b0acff8

Browse files
committed
fix: unit test and frozen options usages
1 parent 5f57838 commit b0acff8

File tree

9 files changed

+17
-15
lines changed

9 files changed

+17
-15
lines changed

src/client-side-encryption/auto_encrypter.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -310,7 +310,7 @@ export class AutoEncrypter {
310310
// eslint-disable-next-line @typescript-eslint/ban-ts-comment
311311
// @ts-ignore: TS complains as this always returns true on versions where it is present.
312312
if (net.getDefaultAutoSelectFamily) {
313-
Object.assign(clientOptions, autoSelectSocketOptions(this._client.options));
313+
Object.assign(clientOptions, autoSelectSocketOptions(this._client.s.options));
314314
}
315315

316316
this._mongocryptdClient = new MongoClient(this._mongocryptdManager.uri, clientOptions);
@@ -392,7 +392,7 @@ export class AutoEncrypter {
392392
promoteLongs: false,
393393
proxyOptions: this._proxyOptions,
394394
tlsOptions: this._tlsOptions,
395-
socketOptions: autoSelectSocketOptions(this._client.options)
395+
socketOptions: autoSelectSocketOptions(this._client.s.options
396396
});
397397

398398
return deserialize(await stateMachine.execute(this, context), {
@@ -413,7 +413,7 @@ export class AutoEncrypter {
413413
...options,
414414
proxyOptions: this._proxyOptions,
415415
tlsOptions: this._tlsOptions,
416-
socketOptions: autoSelectSocketOptions(this._client.options)
416+
socketOptions: autoSelectSocketOptions(this._client.s.options)
417417
});
418418

419419
return await stateMachine.execute(this, context);

src/client-side-encryption/client_encryption.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,7 @@ export class ClientEncryption {
217217
const stateMachine = new StateMachine({
218218
proxyOptions: this._proxyOptions,
219219
tlsOptions: this._tlsOptions,
220-
socketOptions: autoSelectSocketOptions(this._client.options)
220+
socketOptions: autoSelectSocketOptions(this._client.s.options)
221221
});
222222

223223
const dataKey = deserialize(await stateMachine.execute(this, context)) as DataKey;
@@ -275,7 +275,7 @@ export class ClientEncryption {
275275
const stateMachine = new StateMachine({
276276
proxyOptions: this._proxyOptions,
277277
tlsOptions: this._tlsOptions,
278-
socketOptions: autoSelectSocketOptions(this._client.options)
278+
socketOptions: autoSelectSocketOptions(this._client.s.options)
279279
});
280280

281281
const timeoutContext = TimeoutContext.create(
@@ -664,7 +664,7 @@ export class ClientEncryption {
664664
const stateMachine = new StateMachine({
665665
proxyOptions: this._proxyOptions,
666666
tlsOptions: this._tlsOptions,
667-
socketOptions: autoSelectSocketOptions(this._client.options)
667+
socketOptions: autoSelectSocketOptions(this._client.s.options)
668668
});
669669

670670
const { v } = deserialize(await stateMachine.execute(this, context));
@@ -743,7 +743,7 @@ export class ClientEncryption {
743743
const stateMachine = new StateMachine({
744744
proxyOptions: this._proxyOptions,
745745
tlsOptions: this._tlsOptions,
746-
socketOptions: autoSelectSocketOptions(this._client.options)
746+
socketOptions: autoSelectSocketOptions(this._client.s.options)
747747
});
748748
const context = this._mongoCrypt.makeExplicitEncryptionContext(valueBuffer, contextOptions);
749749

src/cursor/abstract_cursor.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -833,7 +833,7 @@ export abstract class AbstractCursor<
833833
if (this.cursorOptions.timeoutMS != null) {
834834
this.timeoutContext ??= new CursorTimeoutContext(
835835
TimeoutContext.create({
836-
serverSelectionTimeoutMS: this.client.options.serverSelectionTimeoutMS,
836+
serverSelectionTimeoutMS: this.client.s.options.serverSelectionTimeoutMS,
837837
timeoutMS: this.cursorOptions.timeoutMS
838838
}),
839839
this
@@ -923,7 +923,7 @@ export abstract class AbstractCursor<
923923
this.timeoutContext?.clear();
924924
return new CursorTimeoutContext(
925925
TimeoutContext.create({
926-
serverSelectionTimeoutMS: this.client.options.serverSelectionTimeoutMS,
926+
serverSelectionTimeoutMS: this.client.s.options.serverSelectionTimeoutMS,
927927
timeoutMS
928928
}),
929929
this

src/gridfs/index.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ export class GridFSBucket extends TypedEventEmitter<GridFSBucketEvents> {
161161
if (timeoutMS) {
162162
timeoutContext = new CSOTTimeoutContext({
163163
timeoutMS,
164-
serverSelectionTimeoutMS: this.s.db.client.options.serverSelectionTimeoutMS
164+
serverSelectionTimeoutMS: this.s.db.client.s.options.serverSelectionTimeoutMS
165165
});
166166
}
167167

@@ -241,7 +241,7 @@ export class GridFSBucket extends TypedEventEmitter<GridFSBucketEvents> {
241241
if (timeoutMS) {
242242
timeoutContext = new CSOTTimeoutContext({
243243
timeoutMS,
244-
serverSelectionTimeoutMS: this.s.db.client.options.serverSelectionTimeoutMS
244+
serverSelectionTimeoutMS: this.s.db.client.s.options.serverSelectionTimeoutMS
245245
});
246246
}
247247

src/gridfs/upload.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ export class GridFSBucketWriteStream extends Writable {
143143
if (options.timeoutMS != null)
144144
this.timeoutContext = new CSOTTimeoutContext({
145145
timeoutMS: options.timeoutMS,
146-
serverSelectionTimeoutMS: this.bucket.s.db.client.options.serverSelectionTimeoutMS
146+
serverSelectionTimeoutMS: this.bucket.s.db.client.s.options.serverSelectionTimeoutMS
147147
});
148148
}
149149

src/operations/client_bulk_write/executor.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ export class ClientBulkWriteExecutor {
5656

5757
// If no write concern was provided, we inherit one from the client.
5858
if (!this.options.writeConcern) {
59-
this.options.writeConcern = WriteConcern.fromOptions(this.client.options);
59+
this.options.writeConcern = WriteConcern.fromOptions(this.client.s.options);
6060
}
6161

6262
if (this.options.writeConcern?.w === 0) {

src/operations/create_collection.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ export class CreateCollectionOperation extends CommandOperation<Collection> {
137137

138138
const encryptedFields: Document | undefined =
139139
options.encryptedFields ??
140-
db.client.options.autoEncryption?.encryptedFieldsMap?.[`${db.databaseName}.${name}`];
140+
db.client.s.options.autoEncryption?.encryptedFieldsMap?.[`${db.databaseName}.${name}`];
141141

142142
if (encryptedFields) {
143143
// Creating a QE collection required min server of 7.0.0

src/operations/drop.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ export class DropCollectionOperation extends CommandOperation<boolean> {
3939
const options = this.options;
4040
const name = this.name;
4141

42-
const encryptedFieldsMap = db.client.options.autoEncryption?.encryptedFieldsMap;
42+
const encryptedFieldsMap = db.client.s.options.autoEncryption?.encryptedFieldsMap;
4343
let encryptedFields: Document | undefined =
4444
options.encryptedFields ?? encryptedFieldsMap?.[`${db.databaseName}.${name}`];
4545

test/unit/client-side-encryption/client_encryption.test.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,11 @@ const { EJSON } = BSON;
2020

2121
class MockClient {
2222
options: any;
23+
s: { options: any };
2324

2425
constructor(options?: any) {
2526
this.options = { options: options || {} };
27+
this.s = { options: this.options };
2628
}
2729
db(dbName) {
2830
return {

0 commit comments

Comments
 (0)