farcasclaudiu/Flowise
1
0
Fork 0
mirror of https://github.com/farcasclaudiu/Flowise.git synced 2026-06-28 21:00:58 +03:00
Code Issues Packages Projects Releases Wiki Activity

Migrating all TLS/SSL settings into additionalConfig so that there is consistency in how every function connects with Postgres in the same manner.

Browse Source
This commit is contained in:
Darien Kindlund
2024-02-08 10:46:30 -05:00
parent 5da3e3cc3e
commit e110a49a32
1 changed files with 1 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/components/nodes/vectorstores/Postgres/Postgres.ts
+1 -18
View File
@@ -60,13 +60,6 @@ class Postgres_VectorStores implements INode {
name: 'database', name: 'database',
type: 'string' type: 'string'
}, },
{
label: 'SSL Connection',
name: 'sslConnection',
type: 'boolean',
default: false,
optional: false
},
{ {
label: 'Port', label: 'Port',
name: 'port', name: 'port',
@@ -124,7 +117,6 @@ class Postgres_VectorStores implements INode {
const docs = nodeData.inputs?.document as Document[] const docs = nodeData.inputs?.document as Document[]
const embeddings = nodeData.inputs?.embeddings as Embeddings const embeddings = nodeData.inputs?.embeddings as Embeddings
const additionalConfig = nodeData.inputs?.additionalConfig as string const additionalConfig = nodeData.inputs?.additionalConfig as string
const sslConnection = nodeData.inputs?.sslConnection as boolean
let additionalConfiguration = {} let additionalConfiguration = {}
if (additionalConfig) { if (additionalConfig) {
@@ -143,7 +135,6 @@ class Postgres_VectorStores implements INode {
username: user, username: user,
password: password, password: password,
database: nodeData.inputs?.database as string, database: nodeData.inputs?.database as string,
ssl: sslConnection
} }
const args = { const args = {
@@ -248,15 +239,7 @@ const similaritySearchVectorWithScore = async (
ORDER BY "_distance" ASC ORDER BY "_distance" ASC
LIMIT $3;` LIMIT $3;`
const poolOptions = { const pool = new Pool(postgresConnectionOptions)
host: postgresConnectionOptions.host,
port: postgresConnectionOptions.port,
user: postgresConnectionOptions.username,
password: postgresConnectionOptions.password,
database: postgresConnectionOptions.database,
ssl: postgresConnectionOptions.extra?.ssl
}
const pool = new Pool(poolOptions)
const conn = await pool.connect() const conn = await pool.connect()
const documents = await conn.query(queryString, [embeddingString, _filter, k]) const documents = await conn.query(queryString, [embeddingString, _filter, k])