feat: prevent duplicate jwt fetches (#43)

Author: guanzo

package-lock.json

@@ -31,7 +31,8 @@
     "idb": "^7.1.1",
     "ipfs-unixfs-exporter": "https://gitpkg.now.sh/filecoin-saturn/js-ipfs-unixfs/packages/ipfs-unixfs-exporter?build",
     "msw": "^1.3.2",
-    "multiformats": "^12.1.1"
+    "multiformats": "^12.1.1",
+    "p-limit": "^5.0.0"
   },
   "devDependencies": {
     "eslint": "^8.24.0",
@@ -61,4 +62,4 @@
   "publishConfig": {
     "access": "public"
   }
-}
+}

package.json

@@ -1,6 +1,7 @@
 // @ts-check
 
 import { CID } from 'multiformats'
+import pLimit from 'p-limit'
 
 import { extractVerifiedContent } from './utils/car.js'
 import { asAsyncIterable, asyncIteratorToBuffer } from './utils/itr.js'
@@ -57,6 +58,7 @@ export class Saturn {
     }
     this.storage = this.config.storage || memoryStorage()
     this.loadNodesPromise = this.config.experimental ? this._loadNodes(this.config) : null
+    this.authLimiter = pLimit(1)
   }
 
   /**
@@ -72,7 +74,7 @@ export class Saturn {
       CID.parse(cid)
 
       if (options.clientKey) {
-        options.jwt = await getJWT(options, this.storage)
+        options.jwt = await this.authLimiter(() => getJWT(options, this.storage))
       }
     }
 
@@ -166,7 +168,7 @@ export class Saturn {
       CID.parse(cid)
 
       if (options.clientKey) {
-        options.jwt = await getJWT(options, this.storage)
+        options.jwt = await this.authLimiter(() => getJWT(options, this.storage))
       }
     }