Disable message saving to DB via an environment variable

CONTRIBUTING.md

@@ -149,6 +149,7 @@ Flowise support different environment variables to configure your instance. You
 | SECRETKEY_PATH               | Location where encryption key (used to encrypt/decrypt credentials) is saved                    | String                                           | `your-path/Flowise/packages/server` |
 | FLOWISE_SECRETKEY_OVERWRITE  | Encryption key to be used instead of the key stored in SECRETKEY_PATH                           | String                                           |                                     |
 | DISABLE_FLOWISE_TELEMETRY    | Turn off telemetry                                                                              | Boolean                                          |                                     |
+| DISABLE_MESSAGE_SAVING    | Turn off message saving to the database. Analytics integrations will still work if enabled.                                                                              | Boolean                                          |                                     |
 | MODEL_LIST_CONFIG_JSON       | File path to load list of models from your local config file                                    | String                                           | `/your_model_list_config_file_path` |
 | STORAGE_TYPE                 | Type of storage for uploaded files. default is `local`                                          | Enum String: `s3`, `local`                       | `local`                             |
 | BLOB_STORAGE_PATH            | Local folder path where uploaded files are stored when `STORAGE_TYPE` is `local`                | String                                           | `your-home-dir/.flowise/storage`    |

docker/.env.example

@@ -36,6 +36,7 @@ BLOB_STORAGE_PATH=/root/.flowise/storage
 # LANGCHAIN_PROJECT=your_project
 
 # DISABLE_FLOWISE_TELEMETRY=true
+# DISABLE_MESSAGE_SAVING=false
 
 # Uncomment the following line to enable model list config, load the list of models from your local config file
 # see https://raw.githubusercontent.com/FlowiseAI/Flowise/main/packages/components/models.json for the format

packages/server/.env.example

@@ -36,6 +36,7 @@ PORT=3000
 # LANGCHAIN_PROJECT=your_project
 
 # DISABLE_FLOWISE_TELEMETRY=true
+# DISABLE_MESSAGE_SAVING=false
 
 # Uncomment the following line to enable model list config, load the list of models from your local config file
 # see https://raw.githubusercontent.com/FlowiseAI/Flowise/main/packages/components/models.json for the format

packages/server/src/NodesPool.ts

@@ -24,7 +24,16 @@ export class NodesPool {
      * Initialize nodes
      */
     private async initializeNodes() {
-        const disabled_nodes = process.env.DISABLED_NODES ? process.env.DISABLED_NODES.split(',') : []
+        let disabled_nodes = process.env.DISABLED_NODES ? process.env.DISABLED_NODES.split(',') : []
+        if (process.env.DISABLE_MESSAGE_SAVING === 'true') {
+            disabled_nodes = disabled_nodes.concat([
+                'bufferMemory',
+                'bufferWindowMemory',
+                'conversationSummaryBufferMemory',
+                'conversationSummaryMemory'
+            ])
+        }
+
         const packagePath = getNodeModulesPackagePath('flowise-components')
         const nodesPath = path.join(packagePath, 'dist', 'nodes')
         const nodeFiles = await this.getFiles(nodesPath)

packages/server/src/commands/start.ts

@@ -48,6 +48,7 @@ export default class Start extends Command {
         LANGCHAIN_API_KEY: Flags.string(),
         LANGCHAIN_PROJECT: Flags.string(),
         DISABLE_FLOWISE_TELEMETRY: Flags.string(),
+        DISABLE_MESSAGE_SAVING: Flags.string(),
         MODEL_LIST_CONFIG_JSON: Flags.string(),
         STORAGE_TYPE: Flags.string(),
         S3_STORAGE_BUCKET_NAME: Flags.string(),
@@ -144,6 +145,9 @@ export default class Start extends Command {
         // Telemetry
         if (flags.DISABLE_FLOWISE_TELEMETRY) process.env.DISABLE_FLOWISE_TELEMETRY = flags.DISABLE_FLOWISE_TELEMETRY
 
+        // Message logs
+        if (flags.DISABLE_MESSAGE_SAVING) process.env.DISABLE_MESSAGE_SAVING = flags.DISABLE_MESSAGE_SAVING
+
         // Model list config
         if (flags.MODEL_LIST_CONFIG_JSON) process.env.MODEL_LIST_CONFIG_JSON = flags.MODEL_LIST_CONFIG_JSON
 

packages/server/src/controllers/chat-messages/index.ts

@@ -33,6 +33,7 @@ const getFeedbackTypeFilters = (_feedbackTypeFilters: ChatMessageRatingType[]):
 }
 
 const createChatMessage = async (req: Request, res: Response, next: NextFunction) => {
+    // createChatMessage handles DISABLE_MESSAGE_SAVING check for us and will return null
     try {
         if (!req.body) {
             throw new InternalFlowiseError(
@@ -41,13 +42,21 @@ const createChatMessage = async (req: Request, res: Response, next: NextFunction
             )
         }
         const apiResponse = await chatMessagesService.createChatMessage(req.body)
+        if (apiResponse === null) {
+            return res.status(500).send('Error: chatMessagesController.createChatMessage - chat message storage disabled!')
+        }
+
         return res.json(parseAPIResponse(apiResponse))
     } catch (error) {
         next(error)
     }
 }
 
 const getAllChatMessages = async (req: Request, res: Response, next: NextFunction) => {
+    if (process.env.DISABLE_MESSAGE_SAVING === 'true') {
+        return res.status(500).send('Error: chatMessagesController.createChatMessage - chat message storage disabled!')
+    }
+
     try {
         let chatTypeFilter = req.query?.chatType as ChatType | undefined
         if (chatTypeFilter) {

packages/server/src/utils/addChatMesage.ts

@@ -6,8 +6,13 @@ import { getRunningExpressApp } from '../utils/getRunningExpressApp'
  * Method that add chat messages.
  * @param {Partial<IChatMessage>} chatMessage
  */
-export const utilAddChatMessage = async (chatMessage: Partial<IChatMessage>): Promise<ChatMessage> => {
+export const utilAddChatMessage = async (chatMessage: Partial<IChatMessage>): Promise<ChatMessage | null> => {
     const appServer = getRunningExpressApp()
+
+    if (process.env.DISABLE_MESSAGE_SAVING === 'true') {
+        return null
+    }
+
     const newChatMessage = new ChatMessage()
     Object.assign(newChatMessage, chatMessage)
     if (!newChatMessage.createdDate) {

packages/ui/src/ui-component/dialog/ViewMessagesDialog.jsx

@@ -672,10 +672,12 @@ const ViewMessagesDialog = ({ show, dialogProps, onCancel }) => {
                     getChatmessageFromPKApi.request(dialogProps.chatflow.id, transformChatPKToParams(chatPK))
                 }
             }
+        } else if (getChatmessageApi.error) {
+            setChatLogs(null)
         }
 
         // eslint-disable-next-line react-hooks/exhaustive-deps
-    }, [getChatmessageApi.data])
+    }, [getChatmessageApi.data, getChatmessageApi.error])
 
     useEffect(() => {
         if (getStatsApi.data) {
@@ -935,6 +937,19 @@ const ViewMessagesDialog = ({ show, dialogProps, onCancel }) => {
                         />
                     </div>
                     <div style={{ display: 'flex', flexDirection: 'row' }}>
+                        {chatlogs == null && (
+                            <Stack sx={{ alignItems: 'center', justifyContent: 'center', width: '100%' }} flexDirection='column'>
+                                <Box sx={{ p: 5, height: 'auto' }}>
+                                    <img
+                                        style={{ objectFit: 'cover', height: '20vh', width: 'auto' }}
+                                        src={msgEmptySVG}
+                                        alt='msgEmptySVG'
+                                    />
+                                </Box>
+                                <div>Messages logs are disabled.</div>
+                                <div>Please reconfigure your Flowise instance or enable an analytics integration</div>
+                            </Stack>
+                        )}
                         {chatlogs && chatlogs.length == 0 && (
                             <Stack sx={{ alignItems: 'center', justifyContent: 'center', width: '100%' }} flexDirection='column'>
                                 <Box sx={{ p: 5, height: 'auto' }}>