Bump Up Mongodb SDK back to 4.13.0 (#15836)

Bump Up Mongodb SDK to 4.13.0

Revert Mongodb downgrade

server/routerlicious/kubernetes/routerlicious/templates/fluid-configmap.yaml

@@ -25,7 +25,6 @@ data:
             "globalDbEnabled": {{ .Values.mongodb.globalDbEnabled }},
             "expireAfterSeconds": {{ .Values.mongodb.expireAfterSeconds }},
             "createCosmosDBIndexes": {{ .Values.mongodb.createCosmosDBIndexes }},
-            "bufferMaxEntries": {{ .Values.mongodb.bufferMaxEntries }},
             "softDeletionRetentionPeriodMs": {{ .Values.mongodb.softDeletionRetentionPeriodMs }},
             "offlineWindowMs": {{ .Values.mongodb.offlineWindowMs }},
             "softDeletionEnabled": {{ .Values.mongodb.softDeletionEnabled }},

server/routerlicious/kubernetes/routerlicious/values.yaml

@@ -117,7 +117,6 @@ mongodb:
   globalDbEnabled: false
   expireAfterSeconds: -1
   createCosmosDBIndexes: false
-  bufferMaxEntries: 50
   softDeletionRetentionPeriodMs: 2592000000
   offlineWindowMs: 86400000
   softDeletionEnabled: false

server/routerlicious/packages/routerlicious/config/config.json

@@ -13,7 +13,6 @@
 		"globalDbEnabled": false,
 		"expireAfterSeconds": -1,
 		"createCosmosDBIndexes": false,
-		"bufferMaxEntries": 50,
 		"softDeletionRetentionPeriodMs": 2592000000,
 		"offlineWindowMs": 86400000,
 		"softDeletionEnabled": false,

server/routerlicious/packages/services-core/src/database.ts

@@ -161,7 +161,7 @@ export interface ICollection<T> {
 	 * @param value - data to insert to the database if we cannot find query
 	 * @param options - optional. If set, provide customized options to the implementations
 	 */
-	findOrCreate(query: any, value: T, options?: any): Promise<{ value: T; existing: boolean }>;
+	findOrCreate(query: any, value: any, options?: any): Promise<{ value: T; existing: boolean }>;
 
 	/**
 	 * Finds query in the database and replace its value.
@@ -173,7 +173,7 @@ export interface ICollection<T> {
 	 */
 	findAndUpdate(
 		query: any,
-		value: T,
+		value: any,
 		options?: any,
 	): Promise<{
 		value: T;

server/routerlicious/packages/services/package.json

@@ -69,7 +69,7 @@
 		"events": "^3.1.0",
 		"ioredis": "^4.24.2",
 		"lru-cache": "^6.0.0",
-		"mongodb": "3.2.2",
+		"mongodb": "4.13.0",
 		"nconf": "^0.12.0",
 		"socket.io": "^4.5.3",
 		"telegrafjs": "^0.1.3",

server/routerlicious/packages/services/src/mongodb.ts

@@ -8,9 +8,11 @@ import * as core from "@fluidframework/server-services-core";
 import {
 	AggregationCursor,
 	Collection,
-	FindOneOptions,
+	FindOneAndUpdateOptions,
+	FindOptions,
 	MongoClient,
 	MongoClientOptions,
+	OptionalUnlessRequiredId,
 } from "mongodb";
 import { BaseTelemetryProperties, Lumberjack } from "@fluidframework/server-services-telemetry";
 import { MongoErrorRetryAnalyzer } from "./mongoExceptionRetryRules";
@@ -67,7 +69,7 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 
 	public async find(query: object, sort: any, limit = MaxFetchSize, skip?: number): Promise<T[]> {
 		const req: () => Promise<T[]> = async () => {
-			let queryCursor = this.collection.find(query).sort(sort).limit(limit);
+			let queryCursor = this.collection.find<T>(query).sort(sort).limit(limit);
 
 			if (skip) {
 				queryCursor = queryCursor.skip(skip);
@@ -77,8 +79,8 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 		return this.requestWithRetry(req, "MongoCollection.find", query);
 	}
 
-	public async findOne(query: object, options?: FindOneOptions): Promise<T> {
-		const req: () => Promise<T> = async () => this.collection.findOne(query, options);
+	public async findOne(query: object, options?: FindOptions): Promise<T> {
+		const req: () => Promise<T> = async () => this.collection.findOne<T>(query, options);
 		return this.requestWithRetry(
 			req, // request
 			"MongoCollection.findOne", // callerName
@@ -87,7 +89,7 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 	}
 
 	public async findAll(): Promise<T[]> {
-		const req: () => Promise<T[]> = async () => this.collection.find({}).toArray();
+		const req: () => Promise<T[]> = async () => this.collection.find<T>({}).toArray();
 		return this.requestWithRetry(
 			req, // request
 			"MongoCollection.findAll", // callerName
@@ -190,7 +192,9 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 	public async insertOne(value: T): Promise<any> {
 		const req = async () => {
 			try {
-				const result = await this.collection.insertOne(value);
+				const result = await this.collection.insertOne(
+					value as OptionalUnlessRequiredId<T>,
+				);
 				// Older mongo driver bug, this insertedId was objectId or 3.2 but changed to any ID type consumer provided.
 				// eslint-disable-next-line @typescript-eslint/no-unsafe-return
 				return result.insertedId;
@@ -209,7 +213,9 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 	public async insertMany(values: T[], ordered: boolean): Promise<void> {
 		const req = async () => {
 			try {
-				await this.collection.insertMany(values, { ordered: false });
+				await this.collection.insertMany(values as OptionalUnlessRequiredId<T>[], {
+					ordered: false,
+				});
 			} catch (error) {
 				this.sanitizeError(error);
 				throw error;
@@ -257,7 +263,7 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 
 	public async findOrCreate(
 		query: any,
-		value: T,
+		value: any,
 		options = {
 			returnOriginal: true,
 			upsert: true,
@@ -267,9 +273,7 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 			try {
 				const result = await this.collection.findOneAndUpdate(
 					query,
-					{
-						$setOnInsert: value,
-					},
+					{ $setOnInsert: value },
 					options,
 				);
 
@@ -290,18 +294,15 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 
 	public async findAndUpdate(
 		query: any,
-		value: T,
-		options = {
-			returnOriginal: true,
-		},
+		value: any,
+		options: FindOneAndUpdateOptions = { returnDocument: "before" },
 	): Promise<{ value: T; existing: boolean }> {
 		const req = async () => {
 			try {
+				// eslint-disable-next-line @typescript-eslint/await-thenable
 				const result = await this.collection.findOneAndUpdate(
 					query,
-					{
-						$set: value,
-					},
+					{ $set: value },
 					options,
 				);
 
@@ -320,7 +321,7 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 		);
 	}
 
-	private async updateCore(filter: any, set: any, addToSet: any, options: any): Promise<void> {
+	private async updateCore(filter: any, set: any, addToSet: any, options: any): Promise<any> {
 		const update: any = {};
 		if (set) {
 			update.$set = set;
@@ -333,12 +334,7 @@ export class MongoCollection<T> implements core.ICollection<T>, core.IRetryable
 		return this.collection.updateOne(filter, update, options);
 	}
 
-	private async updateManyCore(
-		filter: any,
-		set: any,
-		addToSet: any,
-		options: any,
-	): Promise<void> {
+	private async updateManyCore(filter: any, set: any, addToSet: any, options: any): Promise<any> {
 		const update: any = {};
 		if (set) {
 			update.$set = set;
@@ -452,7 +448,6 @@ export type ConnectionNotAvailableMode = "ruleBehavior" | "stop"; // Ideally we
 
 interface IMongoDBConfig {
 	operationsDbEndpoint: string;
-	bufferMaxEntries: number | undefined;
 	globalDbEndpoint?: string;
 	globalDbEnabled?: boolean;
 	connectionPoolMinSize?: number;
@@ -465,7 +460,6 @@ interface IMongoDBConfig {
 
 export class MongoDbFactory implements core.IDbFactory {
 	private readonly operationsDbEndpoint: string;
-	private readonly bufferMaxEntries?: number;
 	private readonly globalDbEndpoint?: string;
 	private readonly connectionPoolMinSize?: number;
 	private readonly connectionPoolMaxSize?: number;
@@ -476,7 +470,6 @@ export class MongoDbFactory implements core.IDbFactory {
 	constructor(config: IMongoDBConfig) {
 		const {
 			operationsDbEndpoint,
-			bufferMaxEntries,
 			globalDbEnabled,
 			globalDbEndpoint,
 			connectionPoolMinSize,
@@ -488,7 +481,6 @@ export class MongoDbFactory implements core.IDbFactory {
 		}
 		assert(!!operationsDbEndpoint, `No endpoint provided`);
 		this.operationsDbEndpoint = operationsDbEndpoint;
-		this.bufferMaxEntries = bufferMaxEntries;
 		this.connectionPoolMinSize = connectionPoolMinSize;
 		this.connectionPoolMaxSize = connectionPoolMaxSize;
 		this.connectionNotAvailableMode = connectionNotAvailableMode ?? "ruleBehavior";
@@ -507,21 +499,16 @@ export class MongoDbFactory implements core.IDbFactory {
 		);
 		// Need to cast to any before MongoClientOptions due to missing properties in d.ts
 		const options: MongoClientOptions = {
-			autoReconnect: true,
-			bufferMaxEntries: this.bufferMaxEntries ?? 50,
 			keepAlive: true,
 			keepAliveInitialDelay: 180000,
-			reconnectInterval: 1000,
-			reconnectTries: 100,
 			socketTimeoutMS: 120000,
-			useNewUrlParser: true,
 		};
 		if (this.connectionPoolMinSize) {
-			options.minSize = this.connectionPoolMinSize;
+			options.minPoolSize = this.connectionPoolMinSize;
 		}
 
 		if (this.connectionPoolMaxSize) {
-			options.poolSize = this.connectionPoolMaxSize;
+			options.maxPoolSize = this.connectionPoolMaxSize;
 		}
 
 		const connection = await MongoClient.connect(