feat: Adds retries for hard-failures

Author: thecodedrift

package.json

@@ -19,8 +19,7 @@
       "src/index.ts"
     ],
     "format": [
-      "esm",
-      "cjs"
+      "esm"
     ],
     "splitting": false,
     "sourcemap": true,
@@ -29,14 +28,14 @@
     "minify": false
   },
   "type": "module",
-  "main": "dist/index.cjs",
+  "main": "dist/index.js",
   "module": "dist/index.js",
   "types": "dist/index.d.ts",
   "exports": {
     ".": {
       "types": "./dist/index.d.ts",
       "import": "./dist/index.js",
-      "require": "./dist/index.cjs"
+      "require": null
     }
   },
   "files": [
@@ -46,12 +45,13 @@
     "src"
   ],
   "engines": {
-    "node": ">=14.19.0",
+    "node": ">=18.0.0",
     "pnpm": "8.x"
   },
   "dependencies": {
     "bson": "^6.2.0",
     "mongodb": "^6.2.0",
+    "p-retry": "^6.1.0",
     "tslib": "^2.6.2"
   },
   "devDependencies": {

pnpm-lock.yaml

@@ -9,6 +9,7 @@ import type {
   WithoutId,
   Document,
 } from "mongodb";
+import pRetry from "p-retry";
 import type { AuthOptions } from "./authTypes.js";
 import { MongoDataAPIError } from "./errors.js";
 
@@ -435,16 +436,26 @@ export class Collection<TSchema = Document> {
     const { endpoint, dataSource, headers } = this.client;
     const url = `${endpoint}/action/${method}`;
 
-    const response = await this.client.fetch(url, {
-      method: "POST",
-      headers,
-      body: EJSON.stringify({
-        collection: this.name,
-        database: this.database.name,
-        dataSource,
-        ...removeEmptyKeys(body),
-      }),
-    });
+    const response = await pRetry(
+      async () => {
+        const r = await this.client.fetch(url, {
+          method: "POST",
+          headers,
+          body: EJSON.stringify({
+            collection: this.name,
+            database: this.database.name,
+            dataSource,
+            ...removeEmptyKeys(body),
+          }),
+        });
+
+        return r;
+      },
+      {
+        minTimeout: 10,
+        maxTimeout: 1000,
+      }
+    );
 
     // interpret response code. Log error for anything outside of 2xx 3xx
     // https://www.mongodb.com/docs/atlas/api/data-api-resources/#error-codes