Sultan
/
Flowise
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added boolean flag which enables ssl connection for redis nodes. 

This is needed for example connecting to the azure redis sever.
This commit is contained in:
tuxBurner 2023-12-13 18:47:25 +01:00
parent 6dc7508968
commit 871dea249c
4 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/components/credentials/RedisCacheApi.credential.ts
View File

@ -35,6 +35,11 @@ class RedisCacheApi implements INodeCredential {
name: 'redisCachePwd', name: 'redisCachePwd',
type: 'password', type: 'password',
placeholder: '<REDIS_PASSWORD>' placeholder: '<REDIS_PASSWORD>'
},
{
label: 'Use SSL',
name: 'redisCacheSslEnabled',
type: 'boolean'
} }
] ]
} }

6
packages/components/nodes/cache/RedisCache/RedisCache.ts vendored
View File

@ -56,12 +56,16 @@ class RedisCache implements INode {
const password = getCredentialParam('redisCachePwd', credentialData, nodeData) const password = getCredentialParam('redisCachePwd', credentialData, nodeData)
const portStr = getCredentialParam('redisCachePort', credentialData, nodeData) const portStr = getCredentialParam('redisCachePort', credentialData, nodeData)
const host = getCredentialParam('redisCacheHost', credentialData, nodeData) const host = getCredentialParam('redisCacheHost', credentialData, nodeData)
const sslEnabled = getCredentialParam('redisCacheSslEnabled', credentialData, nodeData)
const tlsOptions = sslEnabled === true ? { tls: { rejectUnauthorized: false } } : {};
client = new Redis({ client = new Redis({
port: portStr ? parseInt(portStr) : 6379, port: portStr ? parseInt(portStr) : 6379,
host, host,
username, username,
password password,
...tlsOptions
}) })
} else { } else {
client = new Redis(redisUrl) client = new Redis(redisUrl)

6
packages/components/nodes/cache/RedisCache/RedisEmbeddingsCache.ts vendored
View File

@ -71,12 +71,16 @@ class RedisEmbeddingsCache implements INode {
const password = getCredentialParam('redisCachePwd', credentialData, nodeData) const password = getCredentialParam('redisCachePwd', credentialData, nodeData)
const portStr = getCredentialParam('redisCachePort', credentialData, nodeData) const portStr = getCredentialParam('redisCachePort', credentialData, nodeData)
const host = getCredentialParam('redisCacheHost', credentialData, nodeData) const host = getCredentialParam('redisCacheHost', credentialData, nodeData)
const sslEnabled = getCredentialParam('redisCacheSslEnabled', credentialData, nodeData)
const tlsOptions = sslEnabled === true ? { tls: { rejectUnauthorized: false } } : {};
client = new Redis({ client = new Redis({
port: portStr ? parseInt(portStr) : 6379, port: portStr ? parseInt(portStr) : 6379,
host, host,
username, username,
password password,
...tlsOptions
}) })
} else { } else {
client = new Redis(redisUrl) client = new Redis(redisUrl)

6
packages/components/nodes/memory/RedisBackedChatMemory/RedisBackedChatMemory.ts
View File

@ -103,12 +103,16 @@ const initalizeRedis = async (nodeData: INodeData, options: ICommonObject): Prom
const password = getCredentialParam('redisCachePwd', credentialData, nodeData) const password = getCredentialParam('redisCachePwd', credentialData, nodeData)
const portStr = getCredentialParam('redisCachePort', credentialData, nodeData) const portStr = getCredentialParam('redisCachePort', credentialData, nodeData)
const host = getCredentialParam('redisCacheHost', credentialData, nodeData) const host = getCredentialParam('redisCacheHost', credentialData, nodeData)
const sslEnabled = getCredentialParam('redisCacheSslEnabled', credentialData, nodeData)
const tlsOptions = sslEnabled === true ? { tls: { rejectUnauthorized: false } } : {};
client = new Redis({ client = new Redis({
port: portStr ? parseInt(portStr) : 6379, port: portStr ? parseInt(portStr) : 6379,
host, host,
username, username,
password password,
...tlsOptions
}) })
} else { } else {
client = new Redis(redisUrl) client = new Redis(redisUrl)