From f4f99a30b2bf6c6f0ea1fd2e4d2a053974e2e158 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Thu, 22 Sep 2022 11:17:02 +0800
Subject: [PATCH] Add redis tls and cert

---
 packages/text-to-speech/src/index.ts |  5 ++++-
 packages/text-to-speech/src/redis.ts | 12 ++++++++++--
 2 files changed, 14 insertions(+), 3 deletions(-)

diff --git a/packages/text-to-speech/src/index.ts b/packages/text-to-speech/src/index.ts
index 24ea470a0..b7d5618d1 100644
--- a/packages/text-to-speech/src/index.ts
+++ b/packages/text-to-speech/src/index.ts
@@ -181,7 +181,10 @@ export const textToSpeechStreamingHandler = Sentry.GCPFunction.wrapHttpFunction(
       const ssml = `${startSsml(ssmlOptions)}${utteranceInput.text}${endSsml()}`
       // hash ssml to get the cache key
       const cacheKey = crypto.createHash('md5').update(ssml).digest('hex')
-      const redisClient = await createRedisClient()
+      const redisClient = await createRedisClient(
+        process.env.REDIS_URL,
+        process.env.REDIS_CERT
+      )
       // find audio data in cache
       const cacheResult = await redisClient.get(cacheKey)
       if (cacheResult) {
diff --git a/packages/text-to-speech/src/redis.ts b/packages/text-to-speech/src/redis.ts
index b62ee8891..ba0180452 100644
--- a/packages/text-to-speech/src/redis.ts
+++ b/packages/text-to-speech/src/redis.ts
@@ -1,11 +1,19 @@
 import { createClient } from 'redis'
 
-export const createRedisClient = async () => {
-  const redisClient = createClient({ url: process.env.REDIS_URL })
+export const createRedisClient = async (url?: string, cert?: string) => {
+  const redisClient = createClient({
+    url,
+    socket: {
+      tls: url?.startsWith('rediss://'),
+      cert: cert?.replace(/\\n/g, '\n'),
+      rejectUnauthorized: false,
+    },
+  })
 
   redisClient.on('error', (err) => console.error('Redis Client Error', err))
 
   await redisClient.connect()
+  console.log('Redis Client Connected:', url)
 
   return redisClient
 }