fix: cannot connect redis sentinel (#1511)

consolelabs · Oct 4, 2023 · 06a3e2d · 06a3e2d
1 parent fff5199
commit 06a3e2d
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 6 deletions.
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
diff --git a/src/adapters/fetcher/index.ts b/src/adapters/fetcher/index.ts
@@ -7,11 +7,13 @@ import { attachAuthorization, convertToSnakeCase, makeLog } from "./utils"
 import toCurl from "fetch-to-curl"
 import { kafkaQueue } from "queue/kafka/queue"
 import { stack } from "utils/stack-trace"
+
 import {
   CACHE_TTL_SECONDS,
   FETCH_TIMEOUT_SECONDS,
   REDIS_HOST,
   REDIS_DB,
+  REDIS_MASTER_NAME,
   TEST,
 } from "env"
 import {
@@ -54,7 +56,14 @@ let cache = {
 
 if (!TEST) {
   logger.info("Connecting to Redis...")
-  const redis = new Redis(`redis://${REDIS_HOST}/${REDIS_DB}`)
+
+  let redis = new Redis(`redis://${REDIS_HOST}/${REDIS_DB}`)
+  // add redis sentinel support
+  if (REDIS_MASTER_NAME != "") {
+    redis = new Redis(`redis://${REDIS_HOST}/${REDIS_DB}`, {
+      name: REDIS_MASTER_NAME,
+    })
+  }
 
   redis
     .on("ready", () => {

diff --git a/src/env.ts b/src/env.ts
@@ -92,6 +92,7 @@ export const FETCH_TIMEOUT_SECONDS = process.env.FETCH_TIMEOUT_SECONDS || 5
 export const CACHE_TTL_SECONDS = process.env.CACHE_TTL_SECONDS || 1800
 export const REDIS_HOST = process.env.REDIS_HOST || "localhost:6379"
 export const REDIS_DB = process.env.REDIS_DB || "0"
+export const REDIS_MASTER_NAME = process.env.REDIS_MASTER_NAME || ""
 
 export const MOCHI_GUESS_API_KEY = process.env.MOCHI_GUESS_API_KEY || ""
 export const MOCHI_GUESS_API_HOST = process.env.MOCHI_GUESS_API_HOST || ""