fix(logfire): honor numeric-string limits and surface token validity fields

- accept a numeric-string limit so agent-invoked calls stop silently
  falling back to Logfire's 100-row default
- keep an hour-only UTC offset intact instead of producing +05Z
- surface expiresAt and spendingCapReachedAt on Get Token Info
- document pending_span as a fourth record kind

Author: waleedlatif1

apps/docs/content/docs/en/integrations/logfire.mdx

@@ -95,7 +95,7 @@ Search Logfire spans and logs using structured filters for message text, service
 |   ↳ `level` | string | Severity name, such as info, warn, or error |
 |   ↳ `message` | string | Human-readable message |
 |   ↳ `spanName` | string | Template label for similar records |
-|   ↳ `kind` | string | Record kind: span, log, or span_event |
+|   ↳ `kind` | string | Record kind: span, log, span_event, or pending_span |
 |   ↳ `serviceName` | string | Service that emitted the record |
 |   ↳ `deploymentEnvironment` | string | Deployment environment of the record |
 |   ↳ `traceId` | string | Trace this record belongs to |
@@ -134,7 +134,7 @@ Fetch every span and log belonging to a Logfire trace, ordered from earliest to
 |   ↳ `level` | string | Severity name, such as info, warn, or error |
 |   ↳ `message` | string | Human-readable message |
 |   ↳ `spanName` | string | Template label for similar records |
-|   ↳ `kind` | string | Record kind: span, log, or span_event |
+|   ↳ `kind` | string | Record kind: span, log, span_event, or pending_span |
 |   ↳ `serviceName` | string | Service that emitted the record |
 |   ↳ `deploymentEnvironment` | string | Deployment environment of the record |
 |   ↳ `traceId` | string | Trace this record belongs to |
@@ -164,5 +164,7 @@ Resolve which Logfire organization and project a read token belongs to. Useful f
 | --------- | ---- | ----------- |
 | `organizationName` | string | Logfire organization the read token belongs to |
 | `projectName` | string | Logfire project the read token belongs to |
+| `expiresAt` | string | When the read token expires. Null when it never expires. |
+| `spendingCapReachedAt` | string | When the organization's spending cap was reached, which stops queries. Null when it has not been reached. |
 
 

apps/sim/blocks/blocks/logfire.ts

@@ -292,7 +292,7 @@ Return ONLY the IANA timezone string - no explanations or quotes.`,
           host: params.host,
         }
 
-        const window = {
+        const timeWindow = {
           minTimestamp: params.minTimestamp,
           maxTimestamp: params.maxTimestamp,
           limit: toNumber(params.limit),
@@ -302,7 +302,7 @@ Return ONLY the IANA timezone string - no explanations or quotes.`,
           case 'logfire_query':
             return {
               ...baseParams,
-              ...window,
+              ...timeWindow,
               sql: params.sql,
               timezone: params.timezone,
               environment: params.environment,
@@ -311,7 +311,7 @@ Return ONLY the IANA timezone string - no explanations or quotes.`,
           case 'logfire_get_trace':
             return {
               ...baseParams,
-              ...window,
+              ...timeWindow,
               traceId: params.traceId,
             }
 
@@ -321,7 +321,7 @@ Return ONLY the IANA timezone string - no explanations or quotes.`,
           default:
             return {
               ...baseParams,
-              ...window,
+              ...timeWindow,
               query: params.query,
               service: params.service,
               spanName: params.spanName,
@@ -389,6 +389,17 @@ Return ONLY the IANA timezone string - no explanations or quotes.`,
       description: 'Project the read token belongs to',
       condition: { field: 'operation', value: 'logfire_get_token_info' },
     },
+    expiresAt: {
+      type: 'string',
+      description: 'When the read token expires. Null when it never expires.',
+      condition: { field: 'operation', value: 'logfire_get_token_info' },
+    },
+    spendingCapReachedAt: {
+      type: 'string',
+      description:
+        "When the organization's spending cap was reached, which stops queries. Null when it has not been reached.",
+      condition: { field: 'operation', value: 'logfire_get_token_info' },
+    },
   },
 }
 

apps/sim/tools/logfire/get_token_info.test.ts

@@ -24,20 +24,52 @@ describe('logfireGetTokenInfoTool request', () => {
 describe('logfireGetTokenInfoTool transformResponse', () => {
   it('maps the snake_case token info into the block outputs', async () => {
     const response = new Response(
-      JSON.stringify({ organization_name: 'acme', project_name: 'backend' }),
+      JSON.stringify({
+        organization_name: 'acme',
+        project_name: 'backend',
+        expires_at: '2027-01-01T00:00:00Z',
+        spending_cap_reached_at: '2026-08-01T12:00:00Z',
+      }),
       { status: 200 }
     )
 
     const result = await logfireGetTokenInfoTool.transformResponse?.(response, baseParams)
 
     expect(result?.success).toBe(true)
-    expect(result?.output).toEqual({ organizationName: 'acme', projectName: 'backend' })
+    expect(result?.output).toEqual({
+      organizationName: 'acme',
+      projectName: 'backend',
+      expiresAt: '2027-01-01T00:00:00Z',
+      spendingCapReachedAt: '2026-08-01T12:00:00Z',
+    })
+  })
+
+  it('keeps a non-expiring, under-cap token distinguishable from a missing field', async () => {
+    const response = new Response(
+      JSON.stringify({
+        organization_name: 'acme',
+        project_name: 'backend',
+        expires_at: null,
+        spending_cap_reached_at: null,
+      }),
+      { status: 200 }
+    )
+
+    const result = await logfireGetTokenInfoTool.transformResponse?.(response, baseParams)
+
+    expect(result?.output.expiresAt).toBeNull()
+    expect(result?.output.spendingCapReachedAt).toBeNull()
   })
 
   it('nulls fields the API omitted', async () => {
     const response = new Response(JSON.stringify({}), { status: 200 })
     const result = await logfireGetTokenInfoTool.transformResponse?.(response, baseParams)
 
-    expect(result?.output).toEqual({ organizationName: null, projectName: null })
+    expect(result?.output).toEqual({
+      organizationName: null,
+      projectName: null,
+      expiresAt: null,
+      spendingCapReachedAt: null,
+    })
   })
 })

apps/sim/tools/logfire/get_token_info.ts

@@ -57,6 +57,8 @@ export const logfireGetTokenInfoTool: ToolConfig<
       output: {
         organizationName: info.organization_name ?? null,
         projectName: info.project_name ?? null,
+        expiresAt: info.expires_at ?? null,
+        spendingCapReachedAt: info.spending_cap_reached_at ?? null,
       },
     }
   },
@@ -72,5 +74,16 @@ export const logfireGetTokenInfoTool: ToolConfig<
       description: 'Logfire project the read token belongs to',
       nullable: true,
     },
+    expiresAt: {
+      type: 'string',
+      description: 'When the read token expires. Null when it never expires.',
+      nullable: true,
+    },
+    spendingCapReachedAt: {
+      type: 'string',
+      description:
+        "When the organization's spending cap was reached, which stops queries. Null when it has not been reached.",
+      nullable: true,
+    },
   },
 }

apps/sim/tools/logfire/types.ts

@@ -58,10 +58,19 @@ export interface LogfireQueryApiResponse {
   data?: Record<string, unknown>[] | null
 }
 
-/** Shape of `GET /v1/read-token-info`. */
+/**
+ * Shape of `GET /v1/read-token-info`. The endpoint is not covered by the public
+ * API reference; these fields are taken from the official SDK's `ReadTokenInfo`
+ * and from Logfire's own recorded response fixtures. It returns further billing
+ * and ownership internals that are deliberately not surfaced.
+ */
 export interface LogfireReadTokenInfo {
   organization_name?: string | null
   project_name?: string | null
+  /** Null when the token never expires. */
+  expires_at?: string | null
+  /** Set once the organization's spending cap has been hit, which stops queries. */
+  spending_cap_reached_at?: string | null
 }
 
 /**
@@ -111,7 +120,7 @@ export const LOGFIRE_RECORD_OUTPUT_ITEM: NonNullable<ToolOutputProperty['items']
     spanName: { type: 'string', description: 'Template label for similar records', nullable: true },
     kind: {
       type: 'string',
-      description: 'Record kind: span, log, or span_event',
+      description: 'Record kind: span, log, span_event, or pending_span',
       nullable: true,
     },
     serviceName: { type: 'string', description: 'Service that emitted the record', nullable: true },
@@ -182,6 +191,8 @@ export interface LogfireGetTokenInfoResponse extends ToolResponse {
   output: {
     organizationName: string | null
     projectName: string | null
+    expiresAt: string | null
+    spendingCapReachedAt: string | null
   }
 }
 

apps/sim/tools/logfire/utils.test.ts

@@ -188,13 +188,36 @@ describe('buildLogfireQueryBody', () => {
     })
   })
 
+  it('preserves an hour-only UTC offset instead of appending a second designator', () => {
+    expect(
+      buildLogfireQueryBody({ sql: 'SELECT 1', minTimestamp: '2026-07-01T00:00:00+05' })
+    ).toMatchObject({
+      min_timestamp: '2026-07-01T00:00:00+05',
+    })
+  })
+
   it('clamps limit into the range Logfire accepts', () => {
     expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: 50 }).limit).toBe(50)
     expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: 99999 }).limit).toBe(10000)
     expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: 0 }).limit).toBe(1)
     expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: 12.7 }).limit).toBe(12)
   })
 
+  it('accepts a numeric string limit, which agents calling the tool directly emit', () => {
+    expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: '50' as never }).limit).toBe(50)
+    expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: '99999' as never }).limit).toBe(10000)
+  })
+
+  it('omits limit entirely when it is absent or not a number', () => {
+    expect(buildLogfireQueryBody({ sql: 'SELECT 1' })).not.toHaveProperty('limit')
+    expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: '' as never })).not.toHaveProperty(
+      'limit'
+    )
+    expect(buildLogfireQueryBody({ sql: 'SELECT 1', limit: 'fifty' as never })).not.toHaveProperty(
+      'limit'
+    )
+  })
+
   it('sends deployment_environment as an array', () => {
     expect(buildLogfireQueryBody({ sql: 'SELECT 1', environment: 'production' })).toMatchObject({
       deployment_environment: ['production'],

apps/sim/tools/logfire/utils.ts

@@ -159,8 +159,13 @@ export const sqlLiteral = (value: string): string => `'${value.replace(/'/g, "''
 export const sqlContains = (column: string, value: string): string =>
   `contains(lower(${column}), ${sqlLiteral(value.toLowerCase())})`
 
-/** Matches a trailing UTC designator or numeric offset, e.g. `Z`, `+00:00`, `-0530`. */
-const TIMESTAMP_OFFSET_PATTERN = /(?:[Zz]|[+-]\d{2}:?\d{2})$/
+/**
+ * Matches a trailing UTC designator or numeric offset, e.g. `Z`, `+00:00`,
+ * `-0530`, `+05`. The minute component is optional because ISO 8601 permits an
+ * hour-only offset, and appending `Z` to one would produce `+05Z`, which no
+ * parser accepts.
+ */
+const TIMESTAMP_OFFSET_PATTERN = /(?:[Zz]|[+-]\d{2}(?::?\d{2})?)$/
 const DATE_ONLY_PATTERN = /^\d{4}-\d{2}-\d{2}$/
 
 /**
@@ -175,6 +180,21 @@ function normalizeTimestamp(value?: string): string | undefined {
   return TIMESTAMP_OFFSET_PATTERN.test(trimmed) ? trimmed : `${trimmed}Z`
 }
 
+/**
+ * Coerce a row limit that may arrive as a numeric string. The block already
+ * converts its text input, but tools are also callable directly by agents,
+ * which routinely emit numbers as JSON strings — dropping those silently would
+ * fall back to Logfire's default of 100 rows instead of the requested limit.
+ */
+const toFiniteNumber = (value: unknown): number | undefined => {
+  if (typeof value === 'number' && Number.isFinite(value)) return value
+  if (typeof value === 'string' && value.trim()) {
+    const parsed = Number(value)
+    if (Number.isFinite(parsed)) return parsed
+  }
+  return undefined
+}
+
 interface LogfireQueryBodyInput {
   sql: string
   minTimestamp?: string
@@ -194,8 +214,9 @@ export function buildLogfireQueryBody(input: LogfireQueryBodyInput): Record<stri
   const maxTimestamp = normalizeTimestamp(input.maxTimestamp)
   if (maxTimestamp) body.max_timestamp = maxTimestamp
 
-  if (input.limit !== undefined && Number.isFinite(input.limit)) {
-    body.limit = Math.min(Math.max(Math.trunc(input.limit), LOGFIRE_MIN_LIMIT), LOGFIRE_MAX_LIMIT)
+  const limit = toFiniteNumber(input.limit)
+  if (limit !== undefined) {
+    body.limit = Math.min(Math.max(Math.trunc(limit), LOGFIRE_MIN_LIMIT), LOGFIRE_MAX_LIMIT)
   }
 
   const timezone = cleanOptionalString(input.timezone)