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

update

Browse Source
This commit is contained in:
Ashes47
2024-01-28 21:48:15 +05:30
parent 36ab1681ac
commit 51388d5057
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/components/nodes/memory/MongoDBMemory/MongoDBMemory.ts
+7 -4
View File
@@ -5,12 +5,15 @@ import { mapStoredMessageToChatMessage, AIMessage, HumanMessage, BaseMessage } f
import { convertBaseMessagetoIMessage, getBaseClasses, getCredentialData, getCredentialParam } from '../../../src/utils' import { convertBaseMessagetoIMessage, getBaseClasses, getCredentialData, getCredentialParam } from '../../../src/utils'
import { FlowiseMemory, ICommonObject, IMessage, INode, INodeData, INodeParams, MemoryMethods, MessageType } from '../../../src/Interface' import { FlowiseMemory, ICommonObject, IMessage, INode, INodeData, INodeParams, MemoryMethods, MessageType } from '../../../src/Interface'
let mongoClientSingleton = null let mongoClientSingleton: MongoClient
let mongoUrl: string
const getMongoClient = async (mongoDBConnectUrl) => { const getMongoClient = async (newMongoUrl: string) => {
if (!mongoClientSingleton) { if (!mongoClientSingleton || newMongoUrl !== mongoUrl) {
mongoClientSingleton = new MongoClient(mongoDBConnectUrl, { useNewUrlParser: true, useUnifiedTopology: true }) mongoClientSingleton = new MongoClient(newMongoUrl)
mongoUrl = newMongoUrl
await mongoClientSingleton.connect() await mongoClientSingleton.connect()
return mongoClientSingleton
} }
return mongoClientSingleton return mongoClientSingleton
} }