Class Mem0MemoryExtended

packages/components/nodes/memory/Mem0/Mem0.ts:221–389

}

class Mem0MemoryExtended extends BaseMem0Memory implements MemoryMethods {
    initialUserId: string
    userId: string
    orgId: string
    memoryKey: string
    inputKey: string
    appDataSource: DataSource
    databaseEntities: IDatabaseEntity
    chatflowid: string
    searchOnly: boolean
    useFlowiseChatId: boolean
    input: string

    constructor(fields: NodeFields) {
        super(fields)
        this.initialUserId = fields.memoryOptions?.user_id ?? ''
        this.userId = this.initialUserId
        this.memoryKey = 'history'
        this.inputKey = fields.inputKey ?? 'input'
        this.appDataSource = fields.appDataSource
        this.databaseEntities = fields.databaseEntities
        this.chatflowid = fields.chatflowid
        this.searchOnly = fields.searchOnly
        this.useFlowiseChatId = fields.useFlowiseChatId
        this.input = fields.input
        this.orgId = fields.orgId
    }

    // Selects Mem0 user_id based on toggle state (Flowise chat ID or input field)
    private getEffectiveUserId(overrideUserId?: string): string {
        let effectiveUserId: string | undefined

        if (this.useFlowiseChatId) {
            if (overrideUserId) {
                effectiveUserId = overrideUserId
            } else {
                throw new Error('Mem0: "Use Flowise Chat ID" is ON, but no runtime chat ID (overrideUserId) was provided.')
            }
        } else {
            // If toggle is OFF, ALWAYS use the ID from the input field.
            effectiveUserId = this.initialUserId
        }

        // This check is now primarily for the case where the toggle is OFF and the initialUserId was somehow empty (should be caught by init validation).
        if (!effectiveUserId) {
            throw new Error('Mem0: Could not determine a valid User ID for the operation. Check User ID input field.')
        }
        return effectiveUserId
    }

    async loadMemoryVariables(values: InputValues, overrideUserId = ''): Promise<MemoryVariables> {
        const effectiveUserId = this.getEffectiveUserId(overrideUserId)
        this.userId = effectiveUserId
        if (this.memoryOptions) {
            this.memoryOptions.user_id = effectiveUserId
        }
        return super.loadMemoryVariables(values)
    }