Merge pull request #46 from torusresearch/develop

Release: fix concurrency issue of nonce

package.json

@@ -36,6 +36,7 @@
     "elliptic": "^6.5.4",
     "express": "^4.18.2",
     "helmet": "^6.1.5",
+    "ioredis": "^5.3.2",
     "js-sha3": "^0.8.0",
     "json-stable-stringify": "^1.0.2",
     "knex": "^2.4.2",
@@ -46,6 +47,7 @@
     "multihashing-async": "^2.1.4",
     "mysql": "^2.18.1",
     "redis": "^4.6.6",
+    "redlock": "^5.0.0-beta.2",
     "socket.io": "^4.6.1"
   },
   "devDependencies": {

src/database/redis.ts

@@ -1,5 +1,7 @@
+import Client from "ioredis";
 import log from "loglevel";
 import { createClient } from "redis";
+import Redlock, { ResourceLockedError } from "redlock";
 
 const { REDIS_PORT, REDIS_HOSTNAME } = process.env;
 const client = createClient({ socket: { host: REDIS_HOSTNAME, port: Number(REDIS_PORT) } });
@@ -12,4 +14,20 @@ client.on("ready", () => {
   log.info("Connected to redis");
 });
 
+export const redlock = new Redlock([new Client({ host: REDIS_HOSTNAME, port: Number(REDIS_PORT) })], {
+  driftFactor: 0.01, // multiplied by lock ttl to determine drift time
+  retryCount: 10,
+  retryDelay: 200, // time in ms
+  retryJitter: 200, // time in ms
+  automaticExtensionThreshold: 500, // time in ms
+});
+
+redlock.on("error", (error) => {
+  // Ignore cases where a resource is explicitly marked as locked on a client.
+  if (error instanceof ResourceLockedError) {
+    return;
+  }
+  log.error(error);
+});
+
 export default client;