Verify if mongodb is gte 3.6 to allow usage of changestreams

RocketChat · Sep 14, 2020 · 335f45e · 335f45e
1 parent 58d9caf
commit 335f45e
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 5 deletions.
diff --git a/app/models/server/models/_oplogHandle.ts b/app/models/server/models/_oplogHandle.ts
@@ -1,5 +1,7 @@
+
 import { Meteor } from 'meteor/meteor';
 import { MongoInternals } from 'meteor/mongo';
+import semver from 'semver';
 import s from 'underscore.string';
 import { MongoClient, Cursor, Timestamp, Db } from 'mongodb';
 
@@ -22,8 +24,8 @@ class OplogHandle {
 		}
 
 		const { mongo } = MongoInternals.defaultRemoteCollectionDriver();
-		const { storageEngine } = await mongo.db.command({ serverStatus: 1 });
-		return storageEngine?.name === 'wiredTiger';
+		const { version, storageEngine } = await mongo.db.command({ serverStatus: 1 });
+		return storageEngine?.name === 'wiredTiger' && semver.satisfies(semver.coerce(version), '>=3.6.0');
 	}
 
 	async start(): Promise<OplogHandle> {

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -70,6 +70,7 @@
 		"@types/moment-timezone": "^0.5.30",
 		"@types/mongodb": "^3.5.26",
 		"@types/react-dom": "^16.9.8",
+		"@types/semver": "^7.3.3",
 		"@types/toastr": "^2.1.38",
 		"@typescript-eslint/eslint-plugin": "^2.34.0",
 		"@typescript-eslint/parser": "^2.34.0",