feat: add [email protected] support

.github/workflows/ci.yml

@@ -31,9 +31,7 @@ jobs:
       matrix:
         node-version: [12.x, 14.x, 16.x]
         mongodb-version: ['4.0', '4.2', '4.4']
-        # these should match the minimum peerDependencies definitions
-        mongodb-types: ['3.6.20', '^3.6.20']
-        mongodb-lib: ['3.6.7', '^3.6.7']
+        mongodb-lib: ['4.3.1', '^4.3.1']
 
     env:
       NODE: ${{ matrix.node-version }}
@@ -56,7 +54,6 @@ jobs:
       - run: yarn install --frozen-lockfile
 
       # peerDeps installs
-      - run: yarn add -D @types/mongodb@${{matrix.mongodb-types}}
       - run: yarn add -D mongodb@${{matrix.mongodb-lib}}
 
       - run: yarn test --coverage

package.json

@@ -22,8 +22,7 @@
     "test": "jest"
   },
   "peerDependencies": {
-    "@types/mongodb": "^3.6.20",
-    "mongodb": "^3.6.7"
+    "mongodb": "^4.3.1"
   },
   "peerDependenciesMeta": {
     "@types/mongodb": {
@@ -40,7 +39,7 @@
     "@rollup/plugin-commonjs": "^21.0.1",
     "@rollup/plugin-node-resolve": "^13.1.3",
     "@types/jest": "^27.4.0",
-    "@types/mongodb": "^3.6.20",
+    "@types/mongodb": "^4.0.7",
     "@typescript-eslint/eslint-plugin": "^5.9.1",
     "@typescript-eslint/parser": "^5.9.1",
     "builtin-modules": "^3.2.0",
@@ -51,7 +50,7 @@
     "husky": "^7.0.4",
     "jest": "^27.4.7",
     "lint-staged": "^12.1.7",
-    "mongodb": "^3.6.7",
+    "mongodb": "^4.3.1",
     "prettier": "^2.5.1",
     "rollup": "^2.64.0",
     "standard-version": "^9.3.2",

src/mongodb-queue.ts

@@ -7,15 +7,14 @@
  */
 
 import crypto from 'crypto';
-import type { Db, FilterQuery, ObjectId, UpdateQuery } from 'mongodb';
+import type { Db, Filter, UpdateFilter } from 'mongodb';
 
 // some helper functions
 function id() {
   return crypto.randomBytes(16).toString('hex');
 }
 
 type MessageSchema = {
-  _id: ObjectId;
   createdAt: Date;
   updatedAt?: Date;
   visible: Date;
@@ -104,7 +103,7 @@ class MongoDbQueueImpl<T = unknown> implements MongoDbQueue {
       return result.insertedId.toHexString();
     }
 
-    let filter: FilterQuery<MessageSchema> = {
+    let filter: Filter<MessageSchema> = {
       payload: { $eq: hashKey },
     };
 
@@ -144,7 +143,7 @@ class MongoDbQueueImpl<T = unknown> implements MongoDbQueue {
       deleted: null,
       visible: { $lte: new Date(now) },
     };
-    const update: UpdateQuery<MessageSchema> = {
+    const update: UpdateFilter<MessageSchema> = {
       $inc: { tries: 1 },
       $set: {
         updatedAt: new Date(now),

src/specs/__helpers__/setup-mongo.ts

@@ -5,10 +5,6 @@ class SetupMongo {
   private _dbName: string;
 
   get client() {
-    if (!this._client.isConnected()) {
-      throw new Error('Please wait for `connection()` on `beforeAll` hook');
-    }
-
     return this._client;
   }
 
@@ -17,7 +13,7 @@ class SetupMongo {
   }
 
   constructor(url: string, dbName: string) {
-    this._client = new MongoClient(url, { useUnifiedTopology: true });
+    this._client = new MongoClient(url);
     this._dbName = dbName;
   }