Feat [ notifier ]: new notification pattern

jest.setup.redis-mock.js

@@ -1,4 +1,25 @@
+const { GenericContainer } = require('testcontainers');
+
+let redisTestContainer;
+
 /**
- * Mock redis library
+ * Create test container with Redis, which could be used in tests
  */
-jest.mock('redis', () => jest.requireActual('redis-mock'));
+beforeAll(async () => {
+  redisTestContainer = await new GenericContainer('redis')
+    .withExposedPorts(6379)
+    .start();
+
+  const port = redisTestContainer.getMappedPort(6379);
+  const host = redisTestContainer.getContainerIpAddress();
+
+  /**
+   * Set environment variable for redisHelper to connect to redis container
+   */
+  process.env.REDIS_URL = `redis://${host}:${port}`;
+}
+);
+
+afterAll(async () => {
+  await redisTestContainer.stop();
+});

package.json

@@ -67,16 +67,18 @@
         "typescript": "^3.8.3",
         "uuid": "^8.3.0",
         "winston": "^3.2.1",
-        "yup": "^0.28.5"
+        "yup": "^0.28.5",        
+        "@types/redis": "^2.8.28",
+        "redis": "^4.7.0"
     },
     "devDependencies": {
         "@shelf/jest-mongodb": "^1.2.3",
+        "testcontainers": "^3.0.0",
         "eslint": "^7.14.0",
         "eslint-config-codex": "^1.6.1",
         "jest": "25.5.4",
         "nodemon": "^2.0.3",
         "random-words": "^1.1.1",
-        "redis-mock": "^0.56.3",
         "ts-jest": "25.4.0",
         "wait-for-expect": "^3.0.2",
         "webpack": "^4.43.0",

workers/notifier/.env.sample

@@ -0,0 +1,2 @@
+# Url for connecting to Redis
+REDIS_URL=redis://redis:6379

workers/notifier/package.json

@@ -3,5 +3,9 @@
   "version": "1.0.0",
   "main": "src/index.ts",
   "license": "MIT",
-  "workerType": "notifier"
+  "workerType": "notifier",
+  "dependencies": {
+    "@types/redis": "^2.8.28",
+    "redis": "^4.7.0"
+}
 }