From 871dea249cdaa2ce2dcaf1e48577c03de5ff8471 Mon Sep 17 00:00:00 2001
From: tuxBurner <s.hardt@micromata.de>
Date: Wed, 13 Dec 2023 18:47:25 +0100
Subject: [PATCH] Added boolean flag which enables ssl connection for redis
 nodes.

This is needed for example connecting to the azure redis sever.
---
 packages/components/credentials/RedisCacheApi.credential.ts | 5 +++++
 packages/components/nodes/cache/RedisCache/RedisCache.ts    | 6 +++++-
 .../nodes/cache/RedisCache/RedisEmbeddingsCache.ts          | 6 +++++-
 .../memory/RedisBackedChatMemory/RedisBackedChatMemory.ts   | 6 +++++-
 4 files changed, 20 insertions(+), 3 deletions(-)

diff --git a/packages/components/credentials/RedisCacheApi.credential.ts b/packages/components/credentials/RedisCacheApi.credential.ts
index 4d1a2498f..2b4ad6187 100644
--- a/packages/components/credentials/RedisCacheApi.credential.ts
+++ b/packages/components/credentials/RedisCacheApi.credential.ts
@@ -35,6 +35,11 @@ class RedisCacheApi implements INodeCredential {
                 name: 'redisCachePwd',
                 type: 'password',
                 placeholder: '<REDIS_PASSWORD>'
+            },
+            {
+                label: 'Use SSL',
+                name: 'redisCacheSslEnabled',
+                type: 'boolean'
             }
         ]
     }
diff --git a/packages/components/nodes/cache/RedisCache/RedisCache.ts b/packages/components/nodes/cache/RedisCache/RedisCache.ts
index 8128b6e32..657fd1bc3 100644
--- a/packages/components/nodes/cache/RedisCache/RedisCache.ts
+++ b/packages/components/nodes/cache/RedisCache/RedisCache.ts
@@ -56,12 +56,16 @@ class RedisCache implements INode {
             const password = getCredentialParam('redisCachePwd', credentialData, nodeData)
             const portStr = getCredentialParam('redisCachePort', credentialData, nodeData)
             const host = getCredentialParam('redisCacheHost', credentialData, nodeData)
+            const sslEnabled = getCredentialParam('redisCacheSslEnabled', credentialData, nodeData)
+
+            const tlsOptions = sslEnabled === true ? { tls: { rejectUnauthorized: false } } : {};
 
             client = new Redis({
                 port: portStr ? parseInt(portStr) : 6379,
                 host,
                 username,
-                password
+                password,
+                ...tlsOptions
             })
         } else {
             client = new Redis(redisUrl)
diff --git a/packages/components/nodes/cache/RedisCache/RedisEmbeddingsCache.ts b/packages/components/nodes/cache/RedisCache/RedisEmbeddingsCache.ts
index f15869d79..5d6c4bfb8 100644
--- a/packages/components/nodes/cache/RedisCache/RedisEmbeddingsCache.ts
+++ b/packages/components/nodes/cache/RedisCache/RedisEmbeddingsCache.ts
@@ -71,12 +71,16 @@ class RedisEmbeddingsCache implements INode {
             const password = getCredentialParam('redisCachePwd', credentialData, nodeData)
             const portStr = getCredentialParam('redisCachePort', credentialData, nodeData)
             const host = getCredentialParam('redisCacheHost', credentialData, nodeData)
+            const sslEnabled = getCredentialParam('redisCacheSslEnabled', credentialData, nodeData)
+
+            const tlsOptions = sslEnabled === true ? { tls: { rejectUnauthorized: false } } : {};
 
             client = new Redis({
                 port: portStr ? parseInt(portStr) : 6379,
                 host,
                 username,
-                password
+                password,
+                ...tlsOptions
             })
         } else {
             client = new Redis(redisUrl)
diff --git a/packages/components/nodes/memory/RedisBackedChatMemory/RedisBackedChatMemory.ts b/packages/components/nodes/memory/RedisBackedChatMemory/RedisBackedChatMemory.ts
index 7fe447ad5..08a166318 100644
--- a/packages/components/nodes/memory/RedisBackedChatMemory/RedisBackedChatMemory.ts
+++ b/packages/components/nodes/memory/RedisBackedChatMemory/RedisBackedChatMemory.ts
@@ -103,12 +103,16 @@ const initalizeRedis = async (nodeData: INodeData, options: ICommonObject): Prom
         const password = getCredentialParam('redisCachePwd', credentialData, nodeData)
         const portStr = getCredentialParam('redisCachePort', credentialData, nodeData)
         const host = getCredentialParam('redisCacheHost', credentialData, nodeData)
+        const sslEnabled = getCredentialParam('redisCacheSslEnabled', credentialData, nodeData)
+
+        const tlsOptions = sslEnabled === true ? { tls: { rejectUnauthorized: false } } : {};
 
         client = new Redis({
             port: portStr ? parseInt(portStr) : 6379,
             host,
             username,
-            password
+            password,
+            ...tlsOptions
         })
     } else {
         client = new Redis(redisUrl)