diff --git a/README.md b/README.md
index cd994bdc6c4..4255a7214b6 100644
--- a/README.md
+++ b/README.md
@@ -5,6 +5,8 @@
Are you sure you want to proceed?
" @@ -1208,7 +1208,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "llmModel": "chatOpenAI" } }, diff --git a/packages/server/marketplaces/agentflowsv2/Interacting With API.json b/packages/server/marketplaces/agentflowsv2/Interacting With API.json index 5638a8c079a..6d505f5be8c 100644 --- a/packages/server/marketplaces/agentflowsv2/Interacting With API.json +++ b/packages/server/marketplaces/agentflowsv2/Interacting With API.json @@ -582,7 +582,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "agentModel": "chatOpenAI" } }, diff --git a/packages/server/marketplaces/agentflowsv2/Iterations.json b/packages/server/marketplaces/agentflowsv2/Iterations.json index 39eb72bd61a..810d3addff6 100644 --- a/packages/server/marketplaces/agentflowsv2/Iterations.json +++ b/packages/server/marketplaces/agentflowsv2/Iterations.json @@ -1217,7 +1217,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "agentModel": "chatOpenAI" } }, diff --git a/packages/server/marketplaces/agentflowsv2/SQL Agent.json b/packages/server/marketplaces/agentflowsv2/SQL Agent.json index 4c86fede165..02af729b82a 100644 --- a/packages/server/marketplaces/agentflowsv2/SQL Agent.json +++ b/packages/server/marketplaces/agentflowsv2/SQL Agent.json @@ -743,7 +743,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "conditionAgentModel": "chatOpenAI" } }, diff --git a/packages/server/marketplaces/agentflowsv2/Simple RAG.json b/packages/server/marketplaces/agentflowsv2/Simple RAG.json index b37887c0e25..c868cc5eb88 100644 --- a/packages/server/marketplaces/agentflowsv2/Simple RAG.json +++ b/packages/server/marketplaces/agentflowsv2/Simple RAG.json @@ -533,7 +533,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "agentModel": "chatOpenAI" } }, diff --git a/packages/server/marketplaces/agentflowsv2/Supervisor Worker.json b/packages/server/marketplaces/agentflowsv2/Supervisor Worker.json index 510b820c083..1c8d86c9bac 100644 --- a/packages/server/marketplaces/agentflowsv2/Supervisor Worker.json +++ b/packages/server/marketplaces/agentflowsv2/Supervisor Worker.json @@ -818,7 +818,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "agentModel": "chatOpenAI" } }, @@ -1168,7 +1168,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "agentModel": "chatOpenAI" } }, @@ -1975,7 +1975,7 @@ "proxyUrl": "", "baseOptions": "", "allowImageUploads": "", - "reasoningEffort": "medium", + "reasoningEffort": "", "llmModel": "chatOpenAI" } }, diff --git a/packages/server/marketplaces/agentflowsv2/Workplace Chat.json b/packages/server/marketplaces/agentflowsv2/Workplace Chat.json index 3fce5322fed..4cc327021a0 100644 --- a/packages/server/marketplaces/agentflowsv2/Workplace Chat.json +++ b/packages/server/marketplaces/agentflowsv2/Workplace Chat.json @@ -493,7 +493,7 @@ "baseOptions": "", "allowImageUploads": "", "imageResolution": "low", - "reasoningEffort": "medium", + "reasoningEffort": "", "llmModel": "chatOpenAI" } }, diff --git a/packages/server/marketplaces/chatflows/Tool Agent.json b/packages/server/marketplaces/chatflows/Tool Agent.json index 057b2b6e221..fb4400bdfe7 100644 --- a/packages/server/marketplaces/chatflows/Tool Agent.json +++ b/packages/server/marketplaces/chatflows/Tool Agent.json @@ -394,7 +394,7 @@ "baseOptions": "", "allowImageUploads": true, "imageResolution": "low", - "reasoningEffort": "medium" + "reasoningEffort": "" }, "outputAnchors": [ { diff --git a/packages/server/package.json b/packages/server/package.json index b04437ea49a..3262b605a04 100644 --- a/packages/server/package.json +++ b/packages/server/package.json @@ -1,6 +1,6 @@ { "name": "flowise", - "version": "3.0.4", + "version": "3.0.5", "description": "Flowiseai Server", "main": "dist/index", "types": "dist/index.d.ts", @@ -61,6 +61,8 @@ "license": "SEE LICENSE IN LICENSE.md", "dependencies": { "@aws-sdk/client-secrets-manager": "^3.699.0", + "@bull-board/api": "^6.11.0", + "@bull-board/express": "^6.11.0", "@google-cloud/logging-winston": "^6.0.0", "@keyv/redis": "^4.2.0", "@oclif/core": "4.0.7", @@ -79,7 +81,7 @@ "@opentelemetry/sdk-trace-base": "1.27.0", "@opentelemetry/semantic-conventions": "1.27.0", "@types/bcryptjs": "^2.4.6", - "@types/lodash": "^4.14.202", + "@types/lodash": "^4.17.20", "@types/passport": "^1.0.16", "@types/passport-jwt": "^4.0.1", "@types/passport-local": "^1.0.38", @@ -87,7 +89,6 @@ "async-mutex": "^0.4.0", "axios": "1.7.9", "bcryptjs": "^2.4.3", - "bull-board": "^2.1.3", "bullmq": "5.45.2", "cache-manager": "^6.3.2", "connect-pg-simple": "^10.0.0", @@ -169,7 +170,7 @@ "cypress": "^13.13.0", "jest": "^29.7.0", "nodemon": "^2.0.22", - "oclif": "^3", + "oclif": "^4.20.5", "rimraf": "^5.0.5", "run-script-os": "^1.1.6", "shx": "^0.3.3", diff --git a/packages/server/src/CachePool.ts b/packages/server/src/CachePool.ts index e978d89de1a..bacb01a58c1 100644 --- a/packages/server/src/CachePool.ts +++ b/packages/server/src/CachePool.ts @@ -8,6 +8,8 @@ export class CachePool { private redisClient: Redis | null = null activeLLMCache: IActiveCache = {} activeEmbeddingCache: IActiveCache = {} + activeMCPCache: { [key: string]: any } = {} + ssoTokenCache: { [key: string]: any } = {} constructor() { if (process.env.MODE === MODE.QUEUE) { @@ -41,6 +43,46 @@ export class CachePool { } } + /** + * Add to the sso token cache pool + * @param {string} ssoToken + * @param {any} value + */ + async addSSOTokenCache(ssoToken: string, value: any) { + if (process.env.MODE === MODE.QUEUE) { + if (this.redisClient) { + const serializedValue = JSON.stringify(value) + await this.redisClient.set(`ssoTokenCache:${ssoToken}`, serializedValue, 'EX', 120) + } + } else { + this.ssoTokenCache[ssoToken] = value + } + } + + async getSSOTokenCache(ssoToken: string): Promise