mirror of
https://github.com/farcasclaudiu/Flowise.git
synced 2026-06-28 21:00:58 +03:00
add abstract methods
This commit is contained in:
@@ -306,6 +306,10 @@ class BufferMemoryExtended extends FlowiseMemory implements MemoryMethods {
|
|||||||
await this.dynamodbClient.send(new DeleteItemCommand(params))
|
await this.dynamodbClient.send(new DeleteItemCommand(params))
|
||||||
await this.clear()
|
await this.clear()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async resumeMessages(): Promise<void> {
|
||||||
|
return
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = { nodeClass: DynamoDb_Memory }
|
module.exports = { nodeClass: DynamoDb_Memory }
|
||||||
|
|||||||
@@ -221,6 +221,10 @@ class BufferMemoryExtended extends FlowiseMemory implements MemoryMethods {
|
|||||||
await this.collection.deleteOne({ sessionId: id })
|
await this.collection.deleteOne({ sessionId: id })
|
||||||
await this.clear()
|
await this.clear()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async resumeMessages(): Promise<void> {
|
||||||
|
return
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = { nodeClass: MongoDB_Memory }
|
module.exports = { nodeClass: MongoDB_Memory }
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { INode, INodeData, INodeParams, ICommonObject, IMessage, MessageType } from '../../../src/Interface'
|
import { INode, INodeData, INodeParams, ICommonObject, IMessage, MessageType, FlowiseMemory, MemoryMethods } from '../../../src/Interface'
|
||||||
import {
|
import {
|
||||||
convertBaseMessagetoIMessage,
|
convertBaseMessagetoIMessage,
|
||||||
getBaseClasses,
|
getBaseClasses,
|
||||||
@@ -187,7 +187,7 @@ interface BufferMemoryExtendedInput {
|
|||||||
sessionId: string
|
sessionId: string
|
||||||
}
|
}
|
||||||
|
|
||||||
class BufferMemoryExtended extends BufferMemory {
|
class BufferMemoryExtended extends FlowiseMemory implements MemoryMethods {
|
||||||
isSessionIdUsingChatMessageId? = false
|
isSessionIdUsingChatMessageId? = false
|
||||||
sessionId = ''
|
sessionId = ''
|
||||||
redisClient: Redis
|
redisClient: Redis
|
||||||
@@ -236,6 +236,10 @@ class BufferMemoryExtended extends BufferMemory {
|
|||||||
await this.redisClient.del(id)
|
await this.redisClient.del(id)
|
||||||
await this.clear()
|
await this.clear()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async resumeMessages(): Promise<void> {
|
||||||
|
return
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = { nodeClass: RedisBackedChatMemory_Memory }
|
module.exports = { nodeClass: RedisBackedChatMemory_Memory }
|
||||||
|
|||||||
+4
@@ -186,6 +186,10 @@ class BufferMemoryExtended extends FlowiseMemory implements MemoryMethods {
|
|||||||
await this.redisClient.del(id)
|
await this.redisClient.del(id)
|
||||||
await this.clear()
|
await this.clear()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async resumeMessages(): Promise<void> {
|
||||||
|
return
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = { nodeClass: UpstashRedisBackedChatMemory_Memory }
|
module.exports = { nodeClass: UpstashRedisBackedChatMemory_Memory }
|
||||||
|
|||||||
Reference in New Issue
Block a user