Merge pull request #95 from skgndi12/feature/issue-88/generate-redis-…

…client [#88] Generate Redis client
MovieReviewComment · Dec 27, 2023 · f2a0c0a · f2a0c0a
2 parents be86e45 + 39e3a22
commit f2a0c0a
Show file tree

Hide file tree

Showing 3 changed files with 109 additions and 0 deletions.
diff --git a/api/package-lock.json b/api/package-lock.json
diff --git a/api/package.json b/api/package.json
@@ -59,6 +59,7 @@
         "js-yaml": "^4.1.0",
         "jsonwebtoken": "^9.0.2",
         "prisma": "^5.5.2",
+        "redis": "^4.6.12",
         "rimraf": "^5.0.0",
         "swagger-ui-express": "^5.0.0",
         "tsc-alias": "^1.8.5",

diff --git a/api/src/infrastructure/redis/redis.client.ts b/api/src/infrastructure/redis/redis.client.ts
@@ -0,0 +1,25 @@
+import redis, { RedisClientType, createClient } from 'redis';
+import { Logger } from 'winston';
+
+import { RedisConfig } from '@src/infrastructure/repositories/types';
+
+export type RedisClient = RedisClientType<
+  redis.RedisModules,
+  redis.RedisFunctions,
+  redis.RedisScripts
+>;
+
+export async function generateRedisClient(
+  logger: Logger,
+  config: RedisConfig
+): Promise<RedisClient> {
+  const client = createClient({
+    url: `redis://:${config.password}@${config.host}:${config.port}`
+  });
+
+  client.on('error', (e) => logger.error('Redis Client Error', { error: e }));
+
+  await client.connect();
+
+  return client;
+}