feat(tinybird): added tinybird block

apps/docs/components/icons.tsx

@@ -1872,6 +1872,19 @@ export function TelegramIcon(props: SVGProps<SVGSVGElement>) {
   )
 }
 
+export function TinybirdIcon(props: SVGProps<SVGSVGElement>) {
+  return (
+    <svg {...props} xmlns='http://www.w3.org/2000/svg' viewBox='0 0 24 24' fill='none'>
+      <rect x='0' y='0' width='24' height='24' fill='#2EF598' rx='6' />
+      <g transform='translate(2, 2) scale(0.833)'>
+        <path d='M25 2.64 17.195.5 14.45 6.635z' fill='#1E7F63' />
+        <path d='M17.535 17.77 10.39 15.215 6.195 25.5z' fill='#1E7F63' />
+        <path d='M0 11.495 17.535 17.77 20.41 4.36z' fill='#1F2437' />
+      </g>
+    </svg>
+  )
+}
+
 export function ClayIcon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg {...props} xmlns='http://www.w3.org/2000/svg' width='40' height='40' viewBox='0 0 400 400'>

apps/docs/components/ui/icon-mapping.ts

@@ -105,6 +105,7 @@ import {
   SupabaseIcon,
   TavilyIcon,
   TelegramIcon,
+  TinybirdIcon,
   TranslateIcon,
   TrelloIcon,
   TTSIcon,
@@ -227,6 +228,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   tavily: TavilyIcon,
   telegram: TelegramIcon,
   thinking: BrainIcon,
+  tinybird: TinybirdIcon,
   translate: TranslateIcon,
   trello: TrelloIcon,
   tts: TTSIcon,

apps/docs/content/docs/en/tools/google_drive.mdx

@@ -96,13 +96,13 @@ Download a file from Google Drive with complete metadata (exports Google Workspa
 | `fileId` | string | Yes | The ID of the file to download |
 | `mimeType` | string | No | The MIME type to export Google Workspace files to \(optional\) |
 | `fileName` | string | No | Optional filename override |
-| `includeRevisions` | boolean | No | Whether to include revision history in the metadata \(default: true\) |
+| `includeRevisions` | boolean | No | Whether to include revision history in the metadata \(default: true, returns first 100 revisions\) |
 
 #### Output
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `file` | object | Downloaded file stored in execution files |
+| `file` | object | Downloaded file data |
 
 ### `google_drive_list`
 

apps/docs/content/docs/en/tools/meta.json

@@ -102,6 +102,7 @@
     "tavily",
     "telegram",
     "thinking",
+    "tinybird",
     "translate",
     "trello",
     "tts",

apps/docs/content/docs/en/tools/tinybird.mdx

@@ -0,0 +1,70 @@
+---
+title: Tinybird
+description: Send events and query data with Tinybird
+---
+
+import { BlockInfoCard } from "@/components/ui/block-info-card"
+
+<BlockInfoCard 
+  type="tinybird"
+  color="#2EF598"
+/>
+
+## Usage Instructions
+
+Interact with Tinybird using the Events API to stream JSON or NDJSON events, or use the Query API to execute SQL queries against Pipes and Data Sources.
+
+
+
+## Tools
+
+### `tinybird_events`
+
+Send events to a Tinybird Data Source using the Events API. Supports JSON and NDJSON formats with optional gzip compression.
+
+#### Input
+
+| Parameter | Type | Required | Description |
+| --------- | ---- | -------- | ----------- |
+| `base_url` | string | Yes | Tinybird API base URL \(e.g., https://api.tinybird.co or https://api.us-east.tinybird.co\) |
+| `datasource` | string | Yes | Name of the Tinybird Data Source to send events to |
+| `data` | string | Yes | Data to send as NDJSON \(newline-delimited JSON\) or JSON string. Each event should be a valid JSON object. |
+| `wait` | boolean | No | Wait for database acknowledgment before responding. Enables safer retries but introduces latency. Defaults to false. |
+| `format` | string | No | Format of the events data: "ndjson" \(default\) or "json" |
+| `compression` | string | No | Compression format: "none" \(default\) or "gzip" |
+| `token` | string | Yes | Tinybird API Token with DATASOURCE:APPEND or DATASOURCE:CREATE scope |
+
+#### Output
+
+| Parameter | Type | Description |
+| --------- | ---- | ----------- |
+| `successful_rows` | number | Number of rows successfully ingested |
+| `quarantined_rows` | number | Number of rows quarantined \(failed validation\) |
+
+### `tinybird_query`
+
+Execute SQL queries against Tinybird Pipes and Data Sources using the Query API.
+
+#### Input
+
+| Parameter | Type | Required | Description |
+| --------- | ---- | -------- | ----------- |
+| `base_url` | string | Yes | Tinybird API base URL \(e.g., https://api.tinybird.co\) |
+| `query` | string | Yes | SQL query to execute. Specify your desired output format \(e.g., FORMAT JSON, FORMAT CSV, FORMAT TSV\). JSON format provides structured data, while other formats return raw text. |
+| `pipeline` | string | No | Optional pipe name. When provided, enables SELECT * FROM _ syntax |
+| `token` | string | Yes | Tinybird API Token with PIPE:READ scope |
+
+#### Output
+
+| Parameter | Type | Description |
+| --------- | ---- | ----------- |
+| `data` | json | Query result data. For FORMAT JSON: array of objects. For other formats \(CSV, TSV, etc.\): raw text string. |
+| `rows` | number | Number of rows returned \(only available with FORMAT JSON\) |
+| `statistics` | json | Query execution statistics - elapsed time, rows read, bytes read \(only available with FORMAT JSON\) |
+
+
+
+## Notes
+
+- Category: `tools`
+- Type: `tinybird`

apps/sim/blocks/blocks/tinybird.ts

@@ -0,0 +1,206 @@
+import { TinybirdIcon } from '@/components/icons'
+import type { BlockConfig } from '@/blocks/types'
+import { AuthMode } from '@/blocks/types'
+import type { TinybirdResponse } from '@/tools/tinybird/types'
+
+export const TinybirdBlock: BlockConfig<TinybirdResponse> = {
+  type: 'tinybird',
+  name: 'Tinybird',
+  description: 'Send events and query data with Tinybird',
+  authMode: AuthMode.ApiKey,
+  longDescription:
+    'Interact with Tinybird using the Events API to stream JSON or NDJSON events, or use the Query API to execute SQL queries against Pipes and Data Sources.',
+  docsLink: 'https://www.tinybird.co/docs/api-reference',
+  category: 'tools',
+  bgColor: '#2EF598',
+  icon: TinybirdIcon,
+  subBlocks: [
+    {
+      id: 'operation',
+      title: 'Operation',
+      type: 'dropdown',
+      options: [
+        { label: 'Send Events', id: 'tinybird_events' },
+        { label: 'Query', id: 'tinybird_query' },
+      ],
+      value: () => 'tinybird_events',
+    },
+    {
+      id: 'base_url',
+      title: 'Base URL',
+      type: 'short-input',
+      placeholder: 'https://api.tinybird.co',
+      required: true,
+    },
+    {
+      id: 'token',
+      title: 'API Token',
+      type: 'short-input',
+      placeholder: 'Enter your Tinybird API token',
+      password: true,
+      required: true,
+    },
+    // Send Events operation inputs
+    {
+      id: 'datasource',
+      title: 'Data Source',
+      type: 'short-input',
+      placeholder: 'my_events_datasource',
+      condition: { field: 'operation', value: 'tinybird_events' },
+      required: true,
+    },
+    {
+      id: 'data',
+      title: 'Data',
+      type: 'code',
+      placeholder:
+        '{"event": "click", "timestamp": "2024-01-01T12:00:00Z"}\n{"event": "view", "timestamp": "2024-01-01T12:00:01Z"}',
+      condition: { field: 'operation', value: 'tinybird_events' },
+      required: true,
+    },
+    {
+      id: 'format',
+      title: 'Format',
+      type: 'dropdown',
+      options: [
+        { label: 'NDJSON (Newline-delimited JSON)', id: 'ndjson' },
+        { label: 'JSON', id: 'json' },
+      ],
+      value: () => 'ndjson',
+      condition: { field: 'operation', value: 'tinybird_events' },
+    },
+    {
+      id: 'compression',
+      title: 'Compression',
+      type: 'dropdown',
+      options: [
+        { label: 'None', id: 'none' },
+        { label: 'Gzip', id: 'gzip' },
+      ],
+      value: () => 'none',
+      mode: 'advanced',
+      condition: { field: 'operation', value: 'tinybird_events' },
+    },
+    {
+      id: 'wait',
+      title: 'Wait for Acknowledgment',
+      type: 'switch',
+      value: () => 'false',
+      mode: 'advanced',
+      condition: { field: 'operation', value: 'tinybird_events' },
+    },
+    // Query operation inputs
+    {
+      id: 'query',
+      title: 'SQL Query',
+      type: 'code',
+      placeholder: 'SELECT * FROM my_pipe FORMAT JSON\nOR\nSELECT * FROM my_pipe FORMAT CSV',
+      condition: { field: 'operation', value: 'tinybird_query' },
+      required: true,
+    },
+    {
+      id: 'pipeline',
+      title: 'Pipeline Name',
+      type: 'short-input',
+      placeholder: 'my_pipe (optional)',
+      condition: { field: 'operation', value: 'tinybird_query' },
+    },
+  ],
+  tools: {
+    access: ['tinybird_events', 'tinybird_query'],
+    config: {
+      tool: (params) => params.operation || 'tinybird_events',
+      params: (params) => {
+        const operation = params.operation || 'tinybird_events'
+        const result: Record<string, any> = {
+          base_url: params.base_url,
+          token: params.token,
+        }
+
+        if (operation === 'tinybird_events') {
+          // Send Events operation
+          if (!params.datasource) {
+            throw new Error('Data Source is required for Send Events operation')
+          }
+          if (!params.data) {
+            throw new Error('Data is required for Send Events operation')
+          }
+
+          result.datasource = params.datasource
+          result.data = params.data
+          result.format = params.format || 'ndjson'
+          result.compression = params.compression || 'none'
+
+          // Convert wait from string to boolean
+          // Convert wait from string to boolean
+          if (params.wait !== undefined) {
+            const waitValue = typeof params.wait === 'string' ? params.wait.toLowerCase() : params.wait
+            result.wait = waitValue === 'true' || waitValue === true
+          }
+        } else if (operation === 'tinybird_query') {
+          // Query operation
+          if (!params.query) {
+            throw new Error('SQL Query is required for Query operation')
+          }
+
+          result.query = params.query
+          if (params.pipeline) {
+            result.pipeline = params.pipeline
+          }
+        }
+
+        return result
+      },
+    },
+  },
+  inputs: {
+    operation: { type: 'string', description: 'Operation to perform' },
+    base_url: { type: 'string', description: 'Tinybird API base URL' },
+    // Send Events inputs
+    datasource: {
+      type: 'string',
+      description: 'Name of the Tinybird Data Source',
+    },
+    data: {
+      type: 'string',
+      description: 'Data to send as JSON or NDJSON string',
+    },
+    wait: { type: 'boolean', description: 'Wait for database acknowledgment' },
+    format: {
+      type: 'string',
+      description: 'Format of the events (ndjson or json)',
+    },
+    compression: {
+      type: 'string',
+      description: 'Compression format (none or gzip)',
+    },
+    // Query inputs
+    query: { type: 'string', description: 'SQL query to execute' },
+    pipeline: { type: 'string', description: 'Optional pipeline name' },
+    // Common
+    token: { type: 'string', description: 'Tinybird API Token' },
+  },
+  outputs: {
+    // Send Events outputs
+    successful_rows: {
+      type: 'number',
+      description: 'Number of rows successfully ingested',
+    },
+    quarantined_rows: {
+      type: 'number',
+      description: 'Number of rows quarantined (failed validation)',
+    },
+    // Query outputs
+    data: {
+      type: 'json',
+      description:
+        'Query result data. FORMAT JSON: array of objects. Other formats (CSV, TSV, etc.): raw text string.',
+    },
+    rows: { type: 'number', description: 'Number of rows returned (only with FORMAT JSON)' },
+    statistics: {
+      type: 'json',
+      description:
+        'Query execution statistics - elapsed time, rows read, bytes read (only with FORMAT JSON)',
+    },
+  },
+}

apps/sim/blocks/registry.ts

@@ -119,6 +119,7 @@ import { SupabaseBlock } from '@/blocks/blocks/supabase'
 import { TavilyBlock } from '@/blocks/blocks/tavily'
 import { TelegramBlock } from '@/blocks/blocks/telegram'
 import { ThinkingBlock } from '@/blocks/blocks/thinking'
+import { TinybirdBlock } from '@/blocks/blocks/tinybird'
 import { TranslateBlock } from '@/blocks/blocks/translate'
 import { TrelloBlock } from '@/blocks/blocks/trello'
 import { TtsBlock } from '@/blocks/blocks/tts'
@@ -271,6 +272,7 @@ export const registry: Record<string, BlockConfig> = {
   tavily: TavilyBlock,
   telegram: TelegramBlock,
   thinking: ThinkingBlock,
+  tinybird: TinybirdBlock,
   translate: TranslateBlock,
   trello: TrelloBlock,
   twilio_sms: TwilioSMSBlock,

apps/sim/components/icons.tsx

@@ -1872,6 +1872,19 @@ export function TelegramIcon(props: SVGProps<SVGSVGElement>) {
   )
 }
 
+export function TinybirdIcon(props: SVGProps<SVGSVGElement>) {
+  return (
+    <svg {...props} xmlns='http://www.w3.org/2000/svg' viewBox='0 0 24 24' fill='none'>
+      <rect x='0' y='0' width='24' height='24' fill='#2EF598' rx='6' />
+      <g transform='translate(2, 2) scale(0.833)'>
+        <path d='M25 2.64 17.195.5 14.45 6.635z' fill='#1E7F63' />
+        <path d='M17.535 17.77 10.39 15.215 6.195 25.5z' fill='#1E7F63' />
+        <path d='M0 11.495 17.535 17.77 20.41 4.36z' fill='#1F2437' />
+      </g>
+    </svg>
+  )
+}
+
 export function ClayIcon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg {...props} xmlns='http://www.w3.org/2000/svg' width='40' height='40' viewBox='0 0 400 400'>

apps/sim/tools/registry.ts

@@ -1259,6 +1259,7 @@ import {
   telegramSendVideoTool,
 } from '@/tools/telegram'
 import { thinkingTool } from '@/tools/thinking'
+import { tinybirdEventsTool, tinybirdQueryTool } from '@/tools/tinybird'
 import {
   trelloAddCommentTool,
   trelloCreateCardTool,
@@ -2016,6 +2017,8 @@ export const tools: Record<string, ToolConfig> = {
   apollo_email_accounts: apolloEmailAccountsTool,
   mistral_parser: mistralParserTool,
   thinking_tool: thinkingTool,
+  tinybird_events: tinybirdEventsTool,
+  tinybird_query: tinybirdQueryTool,
   stagehand_extract: stagehandExtractTool,
   stagehand_agent: stagehandAgentTool,
   mem0_add_memories: mem0AddMemoriesTool,