[pull] main from activepieces:main

package.json

@@ -151,7 +151,7 @@
     "bullmq": "5.61.0",
     "bullmq-otel": "1.0.1",
     "canvas-confetti": "^1.9.4",
-    "checkly": "6.1.1",
+    "checkly": "6.9.10",
     "chokidar": "4.0.3",
     "class-variance-authority": "0.7.0",
     "clear-module": "4.1.2",
@@ -218,6 +218,8 @@
     "jszip": "3.10.1",
     "jwks-rsa": "3.1.0",
     "jwt-decode": "4.0.0",
+    "keyv": "^4.5.4",
+    "@keyv/sqlite": "^3.0.0",
     "lottie-web": "5.12.2",
     "lucide-react": "0.407.0",
     "mime": "4.0.1",

packages/pieces/community/activepieces/src/i18n/translation.json

@@ -23,6 +23,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Id of the project": "Id of the project",
   "Authorization headers are injected automatically from your connection.": "Authorization headers are injected automatically from your connection.",
   "Enable for files like PDFs, images, etc.": "Enable for files like PDFs, images, etc.",

packages/pieces/community/acuity-scheduling/src/i18n/translation.json

@@ -62,6 +62,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The start date and time for the block (ISO 8601 format).": "The start date and time for the block (ISO 8601 format).",
   "The end date and time for the block (ISO 8601 format).": "The end date and time for the block (ISO 8601 format).",
   "The numeric ID of the calendar to add this block to.": "The numeric ID of the calendar to add this block to.",

packages/pieces/community/ai/src/lib/actions/agents/tools.ts

@@ -2,10 +2,47 @@ import { dynamicTool, LanguageModel, Tool } from "ai";
 import z from "zod";
 import { agentUtils } from "./utils";
 import { agentOutputBuilder } from "./agent-output-builder";
-import { AgentMcpTool, AgentOutputField, AgentTaskStatus, AgentTool, AgentToolType, buildAuthHeaders, createTransportConfig, isNil, McpServerTools, TASK_COMPLETION_TOOL_NAME } from "@activepieces/shared";
+import { AgentMcpTool, AgentOutputField, AgentTaskStatus, AgentTool, AgentToolType, buildAuthHeaders, isNil, McpProtocol, TASK_COMPLETION_TOOL_NAME } from "@activepieces/shared";
+import { StreamableHTTPClientTransport } from '@modelcontextprotocol/sdk/client/streamableHttp.js'
 import { ActionContext } from "@activepieces/pieces-framework";
 import { experimental_createMCPClient as createMCPClient, MCPClient, MCPTransport } from '@ai-sdk/mcp';
 
+function createTransportConfig(
+    protocol: McpProtocol,
+    serverUrl: string,
+    headers: Record<string, string> = {},
+) {
+    const url = new URL(serverUrl)
+
+    switch (protocol) {
+        case McpProtocol.SIMPLE_HTTP: {
+            return {
+                type: 'http',
+                url: serverUrl,
+                headers,
+            }
+        }
+        case McpProtocol.STREAMABLE_HTTP: {
+            const sessionId = crypto.randomUUID()
+            return new StreamableHTTPClientTransport(url, {
+                sessionId,
+                requestInit: {
+                    headers,
+                },
+            })
+        }
+        case McpProtocol.SSE: {
+            return {
+                type: 'sse',
+                url: serverUrl,
+                headers,
+            }
+        }
+        default:
+            throw new Error(`Unsupported MCP protocol type: ${protocol}`)
+    }
+}
+
 type FlattenedMcpResult = {
   mcpClients: MCPClient[];
   tools: Record<string, Tool>;
@@ -145,4 +182,10 @@ type ConstructAgentToolParams = {
   agentTools: AgentTool[];
   context: ActionContext
   model: LanguageModel
-};
+};
+
+export type McpServerTools = {
+    mcpName: string
+    mcpClient: MCPClient
+    tools: Record<string, Tool>
+}

packages/pieces/community/aianswer/src/i18n/translation.json

@@ -28,6 +28,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Enter the phone number, along with country code, in format (e.g., +919876543210)": "Enter the phone number, along with country code, in format (e.g., +919876543210)",
   "Optional details with key-value pairs (e.g., customer_id, priority)": "Optional details with key-value pairs (e.g., customer_id, priority)",
   "Time to schedule the call in YYYY-MM-DD HH:MM:SS format.": "Time to schedule the call in YYYY-MM-DD HH:MM:SS format.",

packages/pieces/community/aidbase/src/i18n/translation.json

@@ -35,6 +35,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The URL of the YouTube video to add as a knowledge source.": "The URL of the YouTube video to add as a knowledge source.",
   "The URL of the website to add as a knowledge source (e.g., https://www.example.com).": "The URL of the website to add as a knowledge source (e.g., https://www.example.com).",
   "Select the FAQ to which the item will be added.": "Select the FAQ to which the item will be added.",

packages/pieces/community/air-ops/src/i18n/translation.json

@@ -22,6 +22,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Select the workflow to execute.": "Select the workflow to execute.",
   "Input values for the workflow.": "Input values for the workflow.",
   "Schema defining the workflow inputs (advanced).": "Schema defining the workflow inputs (advanced).",

packages/pieces/community/aircall/src/i18n/translation.json

@@ -39,6 +39,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Additional information about the contact.": "Additional information about the contact.",
   "Array of email addresses (optional, max 20)": "Array of email addresses (optional, max 20)",
   "Filter by call direction": "Filter by call direction",

packages/pieces/community/airtable/src/i18n/translation.json

@@ -57,6 +57,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The ID of the record.": "The ID of the record.",
   "The ID of the record to which you want to upload the file.": "The ID of the record to which you want to upload the file.",
   "The file to be uploaded, which can be provided either as a public file URL or in Base64 encoded format.": "The file to be uploaded, which can be provided either as a public file URL or in Base64 encoded format.",

packages/pieces/community/airtop/src/i18n/translation.json

@@ -89,6 +89,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Name of a profile to load into the session.": "Name of a profile to load into the session.",
   "List of Chrome extension IDs from Google Web Store.": "List of Chrome extension IDs from Google Web Store.",
   "Enable Airtop-provided proxy. If disabled, configure a custom proxy.": "Enable Airtop-provided proxy. If disabled, configure a custom proxy.",

packages/pieces/community/alt-text-ai/src/i18n/translation.json

@@ -16,6 +16,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "keywords / phrases to be considered when generating the alt text.": "keywords / phrases to be considered when generating the alt text.",
   "negative keywords / phrases to be removed from any generated alt text.": "negative keywords / phrases to be removed from any generated alt text.",
   "Text to use as the source of keywords for the alt text.": "Text to use as the source of keywords for the alt text.",

packages/pieces/community/alttextify/src/i18n/translation.json

@@ -16,6 +16,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Specifies the language for the alt text. Supported language codes are accepted.": "Specifies the language for the alt text. Supported language codes are accepted.",
   "List of keywords/phrases for SEO-optimized alt text.": "List of keywords/phrases for SEO-optimized alt text.",
   "List of negative keywords/phrases for SEO-optimized alt text.": "List of negative keywords/phrases for SEO-optimized alt text.",

packages/pieces/community/ampeco/src/i18n/translation.json

@@ -781,6 +781,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Charge Point": "Charge Point",
   "Evse Network Id": "Evse Network Id",
   "Type": "Type",

packages/pieces/community/apitable/src/i18n/translation.json

@@ -31,6 +31,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The fields to add to the record.": "The fields to add to the record.",
   "The ID of the record to update.": "The ID of the record to update.",
   "The IDs of the records to find.": "The IDs of the records to find.",

packages/pieces/community/apitemplate-io/src/i18n/translation.json

@@ -67,6 +67,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "JSON data with overrides array to populate the template. Format: {\"overrides\": [{\"name\": \"object_name\", \"property\": \"value\"}]}.": "JSON data with overrides array to populate the template. Format: {\"overrides\": [{\"name\": \"object_name\", \"property\": \"value\"}]}.",
   "Delay in milliseconds before PDF generation": "Delay in milliseconds before PDF generation",
   "Specify an external reference ID for your own reference": "Specify an external reference ID for your own reference",

packages/pieces/community/apollo/src/i18n/translation.json

@@ -42,6 +42,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   " The email address of the person to be matched": " The email address of the person to be matched",
   "Store the response in the project store for future use.": "Store the response in the project store for future use.",
   "The Apollo IDs for the companies you want to include in your search results. To find IDs, call the Organization Search endpoint.": "The Apollo IDs for the companies you want to include in your search results. To find IDs, call the Organization Search endpoint.",

packages/pieces/community/appfollow/src/i18n/translation.json

@@ -24,6 +24,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Name of the user to be added": "Name of the user to be added",
   "Email of the user to be added": "Email of the user to be added",
   "Role of the user to be added": "Role of the user to be added",

packages/pieces/community/asana/src/i18n/translation.json

@@ -19,6 +19,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Asana workspace to create the task in": "Asana workspace to create the task in",
   "Asana Project to create the task in": "Asana Project to create the task in",
   "The name of the task to create": "The name of the task to create",

packages/pieces/community/ashby/src/i18n/translation.json

@@ -10,6 +10,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Authorization headers are injected automatically from your connection.": "Authorization headers are injected automatically from your connection.",
   "Enable for files like PDFs, images, etc.": "Enable for files like PDFs, images, etc.",
   "GET": "GET",

packages/pieces/community/assembled/src/i18n/translation.json

@@ -21,6 +21,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Query": "Query",
   "Parameters": "Parameters",
   "Mock Mode": "Mock Mode",

packages/pieces/community/assemblyai/src/i18n/translation.json

@@ -98,6 +98,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The File or URL of the audio or video file.": "The File or URL of the audio or video file.",
   "The URL of the audio or video file to transcribe.": "The URL of the audio or video file to transcribe.",
   "The language of your audio file. Possible values are found in [Supported Languages](https://www.assemblyai.com/docs/concepts/supported-languages).\nThe default value is 'en_us'.\n": "The language of your audio file. Possible values are found in [Supported Languages](https://www.assemblyai.com/docs/concepts/supported-languages).\nThe default value is 'en_us'.\n",

packages/pieces/community/attio/src/i18n/translation.json

@@ -31,6 +31,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The unique identifier of the record to update.": "The unique identifier of the record to update.",
   "The unique identifier of the entry to update.": "The unique identifier of the entry to update.",
   "Authorization headers are injected automatically from your connection.": "Authorization headers are injected automatically from your connection.",

packages/pieces/community/bamboohr/src/i18n/translation.json

@@ -13,6 +13,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Authorization headers are injected automatically from your connection.": "Authorization headers are injected automatically from your connection.",
   "Enable for files like PDFs, images, etc.": "Enable for files like PDFs, images, etc.",
   "GET": "GET",

packages/pieces/community/bannerbear/src/i18n/translation.json

@@ -19,6 +19,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The template to use in image creation.": "The template to use in image creation.",
   "Create image based on a specific version of the template.": "Create image based on a specific version of the template.",
   "A list of modifications you want to make on the template.": "A list of modifications you want to make on the template.",

packages/pieces/community/baserow/src/i18n/translation.json

@@ -29,6 +29,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Please enter the table ID where the row must be created in. You can find the ID by clicking on the three dots next to the table. It's the number between brackets.": "Please enter the table ID where the row must be created in. You can find the ID by clicking on the three dots next to the table. It's the number between brackets.",
   "Please enter the table ID where the row must be deleted in.You can find the ID by clicking on the three dots next to the table. It's the number between brackets.": "Please enter the table ID where the row must be deleted in.You can find the ID by clicking on the three dots next to the table. It's the number between brackets.",
   "Please enter the row ID that needs to be deleted.": "Please enter the row ID that needs to be deleted.",

packages/pieces/community/beamer/src/i18n/translation.json

@@ -37,6 +37,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Enter the Title of the post": "Enter the Title of the post",
   "Enter the description of the post": "Enter the description of the post",
   "Set Category": "Set Category",

packages/pieces/community/beehiiv/src/i18n/translation.json

@@ -46,6 +46,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The email address of the new subscription.": "The email address of the new subscription.",
   "Whether to reactivate the subscription if they have already unsubscribed. Use only if the subscription is knowingly resubscribing.": "Whether to reactivate the subscription if they have already unsubscribed. Use only if the subscription is knowingly resubscribing.",
   "Whether to send the default welcome email to the subscription.": "Whether to send the default welcome email to the subscription.",

packages/pieces/community/bettermode/src/i18n/translation.json

@@ -35,6 +35,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The space to create the discussion in": "The space to create the discussion in",
   "The title of the discussion": "The title of the discussion",
   "The content of the discussion": "The content of the discussion",

packages/pieces/community/bexio/src/i18n/translation.json

@@ -181,6 +181,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Choose the type of manual entry": "Choose the type of manual entry",
   "Date of the booking (YYYY-MM-DD)": "Date of the booking (YYYY-MM-DD)",
   "Reference number for the booking": "Reference number for the booking",

packages/pieces/community/bigcommerce/src/i18n/translation.json

@@ -68,6 +68,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Customer email address": "Customer email address",
   "Customer first name": "Customer first name",
   "Customer last name": "Customer last name",

packages/pieces/community/bika/src/i18n/translation.json

@@ -30,6 +30,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The fields to add to the record.": "The fields to add to the record.",
   "How many records are returned in total.": "How many records are returned in total.",
   "How many records are returned per page (max 1000).": "How many records are returned per page (max 1000).",

packages/pieces/community/bitly/src/i18n/translation.json

@@ -63,6 +63,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "The group where the item will be managed.": "The group where the item will be managed.",
   "Select the Bitlink to modify.": "Select the Bitlink to modify.",
   "The URL to shorten (must include http:// or https://).": "The URL to shorten (must include http:// or https://).",

packages/pieces/community/bokio/src/i18n/translation.json

@@ -68,6 +68,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Name of the customer": "Name of the customer",
   "Type of the customer": "Type of the customer",
   "Customer VAT number": "Customer VAT number",

packages/pieces/community/bolna/src/i18n/translation.json

@@ -17,6 +17,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Select the Bolna Voice AI agent": "Select the Bolna Voice AI agent",
   "Phone number of the recipient with country code (E.164 format, e.g., +10123456789)": "Phone number of the recipient with country code (E.164 format, e.g., +10123456789)",
   "Phone number of the sender with country code (E.164 format, e.g., +19876543007). Optional.": "Phone number of the sender with country code (E.164 format, e.g., +19876543007). Optional.",

packages/pieces/community/bonjoro/src/i18n/translation.json

@@ -23,6 +23,7 @@
   "Response is Binary ?": "Response is Binary ?",
   "No Error on Failure": "No Error on Failure",
   "Timeout (in seconds)": "Timeout (in seconds)",
+  "Follow redirects": "Follow redirects",
   "Note to send with the greet": "Note to send with the greet",
   "Email to send the greet to": "Email to send the greet to",
   "First name of the person to greet": "First name of the person to greet",