feature(entitlements): leader election for entitlements client cache update

Author: arturwolny-frontegg

package-lock.json

@@ -27,6 +27,7 @@
     "axios": "^0.27.2",
     "jsonwebtoken": "^9.0.0",
     "node-cache": "^5.1.2",
+    "tiny-typed-emitter": "^2.1.0",
     "winston": "^3.8.2"
   },
   "peerDependencies": {
@@ -46,10 +47,9 @@
     "@semantic-release/git": "^10.0.1",
     "@types/axios-mock-adapter": "^1.10.0",
     "@types/express": "^4.17.14",
-    "@types/ioredis": "^5.0.0",
     "@types/jest": "^29.2.0",
     "@types/jsonwebtoken": "^9.0.0",
-    "@types/node": "^12.20.55",
+    "@types/node": "^13.13.52",
     "@types/sinon": "^10.0.15",
     "@typescript-eslint/eslint-plugin": "^5.38.1",
     "@typescript-eslint/parser": "^5.38.1",
@@ -68,6 +68,7 @@
     "semantic-release": "^21.0.5",
     "sinon": "^15.2.0",
     "ts-jest": "^28.0.8",
+    "ts-node": "^10.9.1",
     "typescript": "^4.8.4"
   }
 }

package.json

@@ -0,0 +1,37 @@
+import { EntitlementsClient } from './entitlements-client';
+import { FronteggContext } from '../../components/frontegg-context';
+import Logger from '../../components/logger';
+
+const instanceId = process.argv[2] || `rnd-${0 + Math.floor(Math.random() * 100)}`;
+
+Logger.info(`Starting with instance ID: [${instanceId}]`);
+
+FronteggContext.init(
+  {
+    FRONTEGG_CLIENT_ID: process.env.FRONTEGG_CLIENT_ID!,
+    FRONTEGG_API_KEY: process.env.FRONTEGG_API_KEY!,
+  },
+  {
+    cache: {
+      type: 'redis',
+      options: {
+        url: 'redis://localhost:36279',
+      },
+    },
+  },
+);
+
+EntitlementsClient.init(undefined, {
+  instanceId,
+  leaderElection: {
+    expireInMs: 10000,
+    prolongLeadershipIntervalMs: 7000,
+    key: 'my-app-leadership',
+  },
+}).then((client) => {
+  process.on('SIGTERM', () => {
+    Logger.info(`Closing app [${instanceId}]`);
+
+    client.destroy();
+  });
+});

src/clients/entitlements/entitlements-app.ts

@@ -1,4 +1,4 @@
-export enum EntitlementsClientEvents {
+export enum EntitlementsClientEventsEnum {
   INITIALIZED = 'initialized',
   SNAPSHOT_UPDATED = 'snapshot-updated',
 }