feat(logs): add Logs block for querying execution logs from workflows

Author: TheodoreSpeaks

apps/sim/app/api/logs/[id]/route.ts

@@ -10,7 +10,7 @@ import { createLogger } from '@sim/logger'
 import { and, eq } from 'drizzle-orm'
 import { type NextRequest, NextResponse } from 'next/server'
 import { logIdParamsSchema } from '@/lib/api/contracts/logs'
-import { getSession } from '@/lib/auth'
+import { checkSessionOrInternalAuth } from '@/lib/auth/hybrid'
 import { generateRequestId } from '@/lib/core/utils/request'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 
@@ -19,17 +19,20 @@ const logger = createLogger('LogDetailsByIdAPI')
 export const revalidate = 0
 
 export const GET = withRouteHandler(
-  async (_request: NextRequest, { params }: { params: Promise<{ id: string }> }) => {
+  async (request: NextRequest, { params }: { params: Promise<{ id: string }> }) => {
     const requestId = generateRequestId()
 
     try {
-      const session = await getSession()
-      if (!session?.user?.id) {
+      const authResult = await checkSessionOrInternalAuth(request, { requireWorkflowId: false })
+      if (!authResult.success || !authResult.userId) {
         logger.warn(`[${requestId}] Unauthorized log details access attempt`)
-        return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
+        return NextResponse.json(
+          { error: authResult.error || 'Authentication required' },
+          { status: 401 }
+        )
       }
 
-      const userId = session.user.id
+      const userId = authResult.userId
       const { id } = logIdParamsSchema.parse(await params)
 
       const rows = await db

apps/sim/app/api/logs/route.ts

@@ -27,7 +27,7 @@ import {
 import { type NextRequest, NextResponse } from 'next/server'
 import { listLogsQuerySchema } from '@/lib/api/contracts/logs'
 import { isZodError } from '@/lib/api/server'
-import { getSession } from '@/lib/auth'
+import { checkSessionOrInternalAuth } from '@/lib/auth/hybrid'
 import { generateRequestId } from '@/lib/core/utils/request'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 import { buildFilterConditions } from '@/lib/logs/filters'
@@ -40,13 +40,16 @@ export const GET = withRouteHandler(async (request: NextRequest) => {
   const requestId = generateRequestId()
 
   try {
-    const session = await getSession()
-    if (!session?.user?.id) {
+    const authResult = await checkSessionOrInternalAuth(request, { requireWorkflowId: false })
+    if (!authResult.success || !authResult.userId) {
       logger.warn(`[${requestId}] Unauthorized logs access attempt`)
-      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
+      return NextResponse.json(
+        { error: authResult.error || 'Authentication required' },
+        { status: 401 }
+      )
     }
 
-    const userId = session.user.id
+    const userId = authResult.userId
 
     try {
       const { searchParams } = new URL(request.url)

apps/sim/blocks/blocks/logs.ts

@@ -0,0 +1,232 @@
+import { Library } from '@/components/emcn/icons'
+import type { BlockConfig } from '@/blocks/types'
+
+export const LogsBlock: BlockConfig = {
+  type: 'logs',
+  name: 'Logs',
+  description: 'Query workflow execution logs',
+  longDescription:
+    'Search workflow execution logs in the current workspace, fetch a single log by id, or load full execution details with the per-block state snapshot.',
+  bgColor: '#EAB308',
+  bestPractices: `
+  - The block always operates on the current workspace; you cannot query other workspaces.
+  - 'Query Logs' returns metadata only by default. Switch the Detail Level to 'Full' only when you specifically need executionData and trace spans — those payloads can be large.
+  - Use 'Get Execution Details' (with an executionId) to inspect per-block state for a single run.
+  `,
+  icon: Library,
+  category: 'blocks',
+  docsLink: 'https://docs.sim.ai/api-reference/logs/getExecutionDetails',
+  subBlocks: [
+    {
+      id: 'operation',
+      title: 'Operation',
+      type: 'dropdown',
+      options: [
+        { label: 'Query Logs', id: 'query' },
+        { label: 'Get Log by ID', id: 'get_log' },
+        { label: 'Get Execution Details', id: 'get_execution' },
+      ],
+      placeholder: 'Select operation',
+      value: () => 'query',
+    },
+    {
+      id: 'workflowIds',
+      title: 'Workflow IDs',
+      type: 'short-input',
+      placeholder: 'Comma-separated workflow IDs',
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'executionId',
+      title: 'Execution ID',
+      type: 'short-input',
+      placeholder: 'Filter by a single execution ID',
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'level',
+      title: 'Level',
+      type: 'dropdown',
+      options: [
+        { label: 'All', id: 'all' },
+        { label: 'Info', id: 'info' },
+        { label: 'Error', id: 'error' },
+        { label: 'Running', id: 'running' },
+        { label: 'Pending', id: 'pending' },
+      ],
+      value: () => 'all',
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'triggers',
+      title: 'Triggers',
+      type: 'short-input',
+      placeholder: 'api,webhook,schedule,manual,chat,mothership',
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'limit',
+      title: 'Limit',
+      type: 'short-input',
+      placeholder: '100',
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'startDate',
+      title: 'Start Date',
+      type: 'short-input',
+      placeholder: 'ISO 8601 timestamp',
+      mode: 'advanced',
+      wandConfig: {
+        enabled: true,
+        prompt:
+          'Generate an ISO 8601 timestamp from the user description. Return ONLY the timestamp string.',
+        generationType: 'timestamp',
+      },
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'endDate',
+      title: 'End Date',
+      type: 'short-input',
+      placeholder: 'ISO 8601 timestamp',
+      mode: 'advanced',
+      wandConfig: {
+        enabled: true,
+        prompt:
+          'Generate an ISO 8601 timestamp from the user description. Return ONLY the timestamp string.',
+        generationType: 'timestamp',
+      },
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'search',
+      title: 'Search',
+      type: 'short-input',
+      placeholder: 'Free-text search',
+      mode: 'advanced',
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'details',
+      title: 'Detail Level',
+      type: 'dropdown',
+      options: [
+        { label: 'Basic', id: 'basic' },
+        { label: 'Full (includes executionData)', id: 'full' },
+      ],
+      value: () => 'basic',
+      mode: 'advanced',
+      condition: { field: 'operation', value: 'query' },
+    },
+    {
+      id: 'logId',
+      title: 'Log ID',
+      type: 'short-input',
+      placeholder: 'Log entry ID',
+      condition: { field: 'operation', value: 'get_log' },
+      required: true,
+    },
+    {
+      id: 'executionIdLookup',
+      title: 'Execution ID',
+      type: 'short-input',
+      placeholder: 'Execution ID',
+      condition: { field: 'operation', value: 'get_execution' },
+      required: true,
+    },
+  ],
+  tools: {
+    access: ['logs_query', 'logs_get', 'logs_get_execution'],
+    config: {
+      tool: (params: Record<string, any>) => {
+        const operation = params.operation || 'query'
+        if (operation === 'get_log') return 'logs_get'
+        if (operation === 'get_execution') return 'logs_get_execution'
+        return 'logs_query'
+      },
+      params: (params: Record<string, any>) => {
+        const operation = params.operation || 'query'
+
+        if (operation === 'get_log') {
+          if (!params.logId) {
+            throw new Error('Logs Block Error: Log ID is required for get_log operation')
+          }
+          return { id: params.logId }
+        }
+
+        if (operation === 'get_execution') {
+          if (!params.executionIdLookup) {
+            throw new Error(
+              'Logs Block Error: Execution ID is required for get_execution operation'
+            )
+          }
+          return { executionId: params.executionIdLookup }
+        }
+
+        const rawLimit =
+          params.limit !== undefined && params.limit !== null && params.limit !== ''
+            ? Number(params.limit)
+            : undefined
+        const userLimit = Number.isFinite(rawLimit) ? rawLimit : undefined
+        const isFullDetails = params.details === 'full'
+        const FULL_DETAILS_MAX = 10
+        const limit = isFullDetails
+          ? Math.min(userLimit ?? FULL_DETAILS_MAX, FULL_DETAILS_MAX)
+          : userLimit
+
+        return {
+          workflowIds: params.workflowIds || undefined,
+          executionId: params.executionId || undefined,
+          level: params.level && params.level !== 'all' ? params.level : undefined,
+          triggers: params.triggers || undefined,
+          limit,
+          startDate: params.startDate || undefined,
+          endDate: params.endDate || undefined,
+          search: params.search || undefined,
+          details: params.details || undefined,
+        }
+      },
+    },
+  },
+  inputs: {
+    operation: { type: 'string', description: 'Operation to perform' },
+    workflowIds: { type: 'string', description: 'Comma-separated workflow IDs' },
+    executionId: { type: 'string', description: 'Execution ID filter (query operation)' },
+    level: { type: 'string', description: 'Log level filter' },
+    triggers: { type: 'string', description: 'Comma-separated triggers' },
+    limit: { type: 'number', description: 'Max logs to return' },
+    startDate: { type: 'string', description: 'ISO 8601 lower bound' },
+    endDate: { type: 'string', description: 'ISO 8601 upper bound' },
+    search: { type: 'string', description: 'Free-text search term' },
+    details: { type: 'string', description: "'basic' or 'full'" },
+    logId: { type: 'string', description: 'Log entry ID (get_log operation)' },
+    executionIdLookup: {
+      type: 'string',
+      description: 'Execution ID (get_execution operation)',
+    },
+  },
+  outputs: {
+    logs: { type: 'json', description: 'Array of log entries (query operation)' },
+    total: { type: 'number', description: 'Total matching logs (query operation)' },
+    page: { type: 'number', description: 'Current page (query operation)' },
+    pageSize: { type: 'number', description: 'Page size (query operation)' },
+    totalPages: { type: 'number', description: 'Total pages (query operation)' },
+    log: { type: 'json', description: 'Single log entry (get_log operation)' },
+    executionId: { type: 'string', description: 'Execution ID (get_execution operation)' },
+    workflowId: { type: 'string', description: 'Workflow ID (get_execution operation)' },
+    workflowState: {
+      type: 'json',
+      description: 'Per-block state snapshot (get_execution operation)',
+    },
+    childWorkflowSnapshots: {
+      type: 'json',
+      description: 'Snapshots for child workflows (get_execution operation)',
+    },
+    executionMetadata: {
+      type: 'json',
+      description:
+        'Trigger, timestamps, totalDurationMs, cost, totalTokens (get_execution operation)',
+    },
+  },
+}

apps/sim/blocks/registry.ts

@@ -113,6 +113,7 @@ import { LemlistBlock } from '@/blocks/blocks/lemlist'
 import { LinearBlock, LinearV2Block } from '@/blocks/blocks/linear'
 import { LinkedInBlock } from '@/blocks/blocks/linkedin'
 import { LinkupBlock } from '@/blocks/blocks/linkup'
+import { LogsBlock } from '@/blocks/blocks/logs'
 import { LoopsBlock } from '@/blocks/blocks/loops'
 import { LumaBlock } from '@/blocks/blocks/luma'
 import { MailchimpBlock } from '@/blocks/blocks/mailchimp'
@@ -361,6 +362,7 @@ export const registry: Record<string, BlockConfig> = {
   linear_v2: LinearV2Block,
   linkedin: LinkedInBlock,
   linkup: LinkupBlock,
+  logs: LogsBlock,
   loops: LoopsBlock,
   luma: LumaBlock,
   mailchimp: MailchimpBlock,

apps/sim/tools/logs/get_execution.ts

@@ -0,0 +1,50 @@
+import type { LogsGetExecutionParams, LogsGetExecutionResponse } from '@/tools/logs/types'
+import type { ToolConfig } from '@/tools/types'
+
+export const logsGetExecutionTool: ToolConfig<LogsGetExecutionParams, LogsGetExecutionResponse> = {
+  id: 'logs_get_execution',
+  name: 'Get Execution Details',
+  description:
+    'Fetch full execution details for a workflow run, including the per-block state snapshot.',
+  version: '1.0.0',
+
+  params: {
+    executionId: {
+      type: 'string',
+      required: true,
+      visibility: 'user-or-llm',
+      description: 'Execution ID returned by a workflow run',
+    },
+  },
+
+  request: {
+    url: (params) => `/api/logs/execution/${encodeURIComponent(params.executionId)}`,
+    method: 'GET',
+    headers: () => ({
+      'Content-Type': 'application/json',
+    }),
+  },
+
+  transformResponse: async (response): Promise<LogsGetExecutionResponse> => {
+    const data = await response.json()
+    return {
+      success: true,
+      output: data,
+    }
+  },
+
+  outputs: {
+    executionId: { type: 'string', description: 'Execution ID' },
+    workflowId: { type: 'string', description: 'Workflow ID this execution belongs to' },
+    workflowState: { type: 'json', description: 'Per-block state snapshot for the execution' },
+    childWorkflowSnapshots: {
+      type: 'json',
+      description: 'Snapshots for any child workflows invoked during the run',
+      optional: true,
+    },
+    executionMetadata: {
+      type: 'json',
+      description: 'Trigger, timestamps, totalDurationMs, cost, and totalTokens for the run',
+    },
+  },
+}