diff --git a/apps/sim/components/ui/alert.tsx b/apps/sim/components/ui/alert.tsx
index 03e20be29..ce2162f28 100644
--- a/apps/sim/components/ui/alert.tsx
+++ b/apps/sim/components/ui/alert.tsx
@@ -27,12 +27,14 @@ const Alert = React.forwardRef<
Alert.displayName = 'Alert'
const AlertTitle = React.forwardRef
>(
- ({ className, ...props }, ref) => (
+ ({ className, children, ...props }, ref) => (
+ >
+ {children}
+
)
)
AlertTitle.displayName = 'AlertTitle'
diff --git a/apps/sim/lib/blog/mdx.tsx b/apps/sim/lib/blog/mdx.tsx
index 1094a6d98..6065e7b8c 100644
--- a/apps/sim/lib/blog/mdx.tsx
+++ b/apps/sim/lib/blog/mdx.tsx
@@ -16,26 +16,32 @@ export const mdxComponents: MDXRemoteProps['components'] = {
unoptimized
/>
),
- h2: (props: any) => (
+ h2: ({ children, className, ...props }: any) => (
+ className={clsx('font-medium text-black leading-tight', className)}
+ >
+ {children}
+
),
- h3: (props: any) => (
+ h3: ({ children, className, ...props }: any) => (
+ className={clsx('font-medium leading-tight', className)}
+ >
+ {children}
+
),
- h4: (props: any) => (
+ h4: ({ children, className, ...props }: any) => (
+ className={clsx('font-medium leading-tight', className)}
+ >
+ {children}
+
),
p: (props: any) => (
[] = []
const currentMessages = [...allMessages]
let iterationCount = 0
@@ -577,15 +578,11 @@ async function executeChatCompletionsRequest(
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore - Adding timing property to the error
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
}
diff --git a/apps/sim/providers/bedrock/index.ts b/apps/sim/providers/bedrock/index.ts
index e602627b7..1d36af786 100644
--- a/apps/sim/providers/bedrock/index.ts
+++ b/apps/sim/providers/bedrock/index.ts
@@ -22,11 +22,13 @@ import {
} from '@/providers/bedrock/utils'
import { getProviderDefaultModel, getProviderModels } from '@/providers/models'
import type {
+ FunctionCallResponse,
ProviderConfig,
ProviderRequest,
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -419,8 +421,8 @@ export const bedrockProvider: ProviderConfig = {
pricing: initialCost.pricing,
}
- const toolCalls: any[] = []
- const toolResults: any[] = []
+ const toolCalls: FunctionCallResponse[] = []
+ const toolResults: Record[] = []
const currentMessages = [...messages]
let iterationCount = 0
let hasUsedForcedTool = false
@@ -561,7 +563,7 @@ export const bedrockProvider: ProviderConfig = {
let resultContent: any
if (result.success) {
- toolResults.push(result.output)
+ toolResults.push(result.output!)
resultContent = result.output
} else {
resultContent = {
@@ -903,15 +905,11 @@ export const bedrockProvider: ProviderConfig = {
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/cerebras/index.ts b/apps/sim/providers/cerebras/index.ts
index c18560048..23daff85f 100644
--- a/apps/sim/providers/cerebras/index.ts
+++ b/apps/sim/providers/cerebras/index.ts
@@ -11,6 +11,7 @@ import type {
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -539,15 +540,11 @@ export const cerebrasProvider: ProviderConfig = {
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore - Adding timing property to error for debugging
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/deepseek/index.ts b/apps/sim/providers/deepseek/index.ts
index 9ac7faa1d..693bf50c5 100644
--- a/apps/sim/providers/deepseek/index.ts
+++ b/apps/sim/providers/deepseek/index.ts
@@ -10,6 +10,7 @@ import type {
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -538,15 +539,11 @@ export const deepseekProvider: ProviderConfig = {
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/groq/index.ts b/apps/sim/providers/groq/index.ts
index bf253bc7d..cf3d45c78 100644
--- a/apps/sim/providers/groq/index.ts
+++ b/apps/sim/providers/groq/index.ts
@@ -10,6 +10,7 @@ import type {
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -496,15 +497,11 @@ export const groqProvider: ProviderConfig = {
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/mistral/index.ts b/apps/sim/providers/mistral/index.ts
index 0195c04fb..5b261c947 100644
--- a/apps/sim/providers/mistral/index.ts
+++ b/apps/sim/providers/mistral/index.ts
@@ -11,6 +11,7 @@ import type {
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -551,15 +552,11 @@ export const mistralProvider: ProviderConfig = {
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore - Adding timing property to error for debugging
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/ollama/index.ts b/apps/sim/providers/ollama/index.ts
index 921c1afd0..f8485bdfe 100644
--- a/apps/sim/providers/ollama/index.ts
+++ b/apps/sim/providers/ollama/index.ts
@@ -12,6 +12,7 @@ import type {
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import { calculateCost, prepareToolExecution } from '@/providers/utils'
import { useProvidersStore } from '@/stores/providers'
import { executeTool } from '@/tools'
@@ -554,15 +555,11 @@ export const ollamaProvider: ProviderConfig = {
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/openai/core.ts b/apps/sim/providers/openai/core.ts
index 6e6d42cb4..6833181dc 100644
--- a/apps/sim/providers/openai/core.ts
+++ b/apps/sim/providers/openai/core.ts
@@ -3,6 +3,7 @@ import type OpenAI from 'openai'
import type { StreamingExecution } from '@/executor/types'
import { MAX_TOOL_ITERATIONS } from '@/providers'
import type { Message, ProviderRequest, ProviderResponse, TimeSegment } from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -806,14 +807,10 @@ export async function executeResponsesProviderRequest(
duration: totalDuration,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore - Adding timing property to the error
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
}
diff --git a/apps/sim/providers/openrouter/index.ts b/apps/sim/providers/openrouter/index.ts
index 0444fc35e..edbed1b7c 100644
--- a/apps/sim/providers/openrouter/index.ts
+++ b/apps/sim/providers/openrouter/index.ts
@@ -10,11 +10,14 @@ import {
supportsNativeStructuredOutputs,
} from '@/providers/openrouter/utils'
import type {
+ FunctionCallResponse,
+ Message,
ProviderConfig,
ProviderRequest,
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
generateSchemaInstructions,
@@ -90,7 +93,7 @@ export const openRouterProvider: ProviderConfig = {
stream: !!request.stream,
})
- const allMessages = [] as any[]
+ const allMessages: Message[] = []
if (request.systemPrompt) {
allMessages.push({ role: 'system', content: request.systemPrompt })
@@ -237,8 +240,8 @@ export const openRouterProvider: ProviderConfig = {
output: currentResponse.usage?.completion_tokens || 0,
total: currentResponse.usage?.total_tokens || 0,
}
- const toolCalls = [] as any[]
- const toolResults = [] as any[]
+ const toolCalls: FunctionCallResponse[] = []
+ const toolResults: Record[] = []
const currentMessages = [...allMessages]
let iterationCount = 0
let modelTime = firstResponseTime
@@ -352,7 +355,7 @@ export const openRouterProvider: ProviderConfig = {
let resultContent: any
if (result.success) {
- toolResults.push(result.output)
+ toolResults.push(result.output!)
resultContent = result.output
} else {
resultContent = {
@@ -593,14 +596,11 @@ export const openRouterProvider: ProviderConfig = {
}
logger.error('Error in OpenRouter request:', errorDetails)
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/types.ts b/apps/sim/providers/types.ts
index cb75153c5..2c59bfcc1 100644
--- a/apps/sim/providers/types.ts
+++ b/apps/sim/providers/types.ts
@@ -59,6 +59,7 @@ export interface FunctionCallResponse {
result?: Record
output?: Record
input?: Record
+ success?: boolean
}
export interface TimeSegment {
@@ -177,4 +178,21 @@ export interface ProviderRequest {
previousInteractionId?: string
}
+/**
+ * Typed error class for provider failures that includes timing information.
+ */
+export class ProviderError extends Error {
+ timing: {
+ startTime: string
+ endTime: string
+ duration: number
+ }
+
+ constructor(message: string, timing: { startTime: string; endTime: string; duration: number }) {
+ super(message)
+ this.name = 'ProviderError'
+ this.timing = timing
+ }
+}
+
export const providers: Record = {}
diff --git a/apps/sim/providers/vllm/index.ts b/apps/sim/providers/vllm/index.ts
index 0df587264..5e704c654 100644
--- a/apps/sim/providers/vllm/index.ts
+++ b/apps/sim/providers/vllm/index.ts
@@ -6,11 +6,13 @@ import type { StreamingExecution } from '@/executor/types'
import { MAX_TOOL_ITERATIONS } from '@/providers'
import { getProviderDefaultModel, getProviderModels } from '@/providers/models'
import type {
+ Message,
ProviderConfig,
ProviderRequest,
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -98,7 +100,7 @@ export const vllmProvider: ProviderConfig = {
baseURL: `${baseUrl}/v1`,
})
- const allMessages = [] as any[]
+ const allMessages: Message[] = []
if (request.systemPrompt) {
allMessages.push({
@@ -635,23 +637,11 @@ export const vllmProvider: ProviderConfig = {
duration: totalDuration,
})
- const enhancedError = new Error(errorMessage)
- // @ts-ignore
- enhancedError.timing = {
+ throw new ProviderError(errorMessage, {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
- if (errorType) {
- // @ts-ignore
- enhancedError.vllmErrorType = errorType
- }
- if (errorCode) {
- // @ts-ignore
- enhancedError.vllmErrorCode = errorCode
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/providers/xai/index.ts b/apps/sim/providers/xai/index.ts
index 8138265a3..98cbf52c1 100644
--- a/apps/sim/providers/xai/index.ts
+++ b/apps/sim/providers/xai/index.ts
@@ -5,11 +5,13 @@ import type { StreamingExecution } from '@/executor/types'
import { MAX_TOOL_ITERATIONS } from '@/providers'
import { getProviderDefaultModel, getProviderModels } from '@/providers/models'
import type {
+ Message,
ProviderConfig,
ProviderRequest,
ProviderResponse,
TimeSegment,
} from '@/providers/types'
+import { ProviderError } from '@/providers/types'
import {
calculateCost,
prepareToolExecution,
@@ -52,7 +54,7 @@ export const xAIProvider: ProviderConfig = {
streaming: !!request.stream,
})
- const allMessages: any[] = []
+ const allMessages: Message[] = []
if (request.systemPrompt) {
allMessages.push({
@@ -587,15 +589,11 @@ export const xAIProvider: ProviderConfig = {
hasResponseFormat: !!request.responseFormat,
})
- const enhancedError = new Error(error instanceof Error ? error.message : String(error))
- // @ts-ignore - Adding timing property to error for debugging
- enhancedError.timing = {
+ throw new ProviderError(error instanceof Error ? error.message : String(error), {
startTime: providerStartTimeISO,
endTime: providerEndTimeISO,
duration: totalDuration,
- }
-
- throw enhancedError
+ })
}
},
}
diff --git a/apps/sim/tools/incidentio/actions_list.ts b/apps/sim/tools/incidentio/actions_list.ts
index ddfaa41f4..35e2fe02c 100644
--- a/apps/sim/tools/incidentio/actions_list.ts
+++ b/apps/sim/tools/incidentio/actions_list.ts
@@ -26,12 +26,6 @@ export const actionsListTool: ToolConfig<
visibility: 'user-or-llm',
description: 'Filter actions by incident ID (e.g., "01FCNDV6P870EA6S7TK1DSYDG0")',
},
- page_size: {
- type: 'number',
- required: false,
- visibility: 'user-or-llm',
- description: 'Number of actions to return per page (e.g., 10, 25, 50)',
- },
},
request: {
@@ -42,10 +36,6 @@ export const actionsListTool: ToolConfig<
url.searchParams.append('incident_id', params.incident_id)
}
- if (params.page_size) {
- url.searchParams.append('page_size', params.page_size.toString())
- }
-
return url.toString()
},
method: 'GET',
diff --git a/apps/sim/tools/incidentio/escalations_list.ts b/apps/sim/tools/incidentio/escalations_list.ts
index d09ad9528..5d5f76f7b 100644
--- a/apps/sim/tools/incidentio/escalations_list.ts
+++ b/apps/sim/tools/incidentio/escalations_list.ts
@@ -20,22 +20,10 @@ export const escalationsListTool: ToolConfig<
visibility: 'user-only',
description: 'incident.io API Key',
},
- page_size: {
- type: 'number',
- required: false,
- visibility: 'user-or-llm',
- description: 'Number of results per page (e.g., 10, 25, 50). Default: 25',
- },
},
request: {
- url: (params) => {
- const url = new URL('https://api.incident.io/v2/escalations')
- if (params.page_size) {
- url.searchParams.append('page_size', params.page_size.toString())
- }
- return url.toString()
- },
+ url: () => 'https://api.incident.io/v2/escalations',
method: 'GET',
headers: (params) => ({
'Content-Type': 'application/json',
diff --git a/apps/sim/tools/incidentio/follow_ups_list.ts b/apps/sim/tools/incidentio/follow_ups_list.ts
index be6a55669..603547b43 100644
--- a/apps/sim/tools/incidentio/follow_ups_list.ts
+++ b/apps/sim/tools/incidentio/follow_ups_list.ts
@@ -26,12 +26,6 @@ export const followUpsListTool: ToolConfig<
visibility: 'user-or-llm',
description: 'Filter follow-ups by incident ID (e.g., "01FCNDV6P870EA6S7TK1DSYDG0")',
},
- page_size: {
- type: 'number',
- required: false,
- visibility: 'user-or-llm',
- description: 'Number of follow-ups to return per page (e.g., 10, 25, 50)',
- },
},
request: {
@@ -42,10 +36,6 @@ export const followUpsListTool: ToolConfig<
url.searchParams.append('incident_id', params.incident_id)
}
- if (params.page_size) {
- url.searchParams.append('page_size', params.page_size.toString())
- }
-
return url.toString()
},
method: 'GET',
diff --git a/apps/sim/tools/incidentio/types.ts b/apps/sim/tools/incidentio/types.ts
index b342de3a1..356803adc 100644
--- a/apps/sim/tools/incidentio/types.ts
+++ b/apps/sim/tools/incidentio/types.ts
@@ -396,7 +396,6 @@ export interface IncidentioIncidentsUpdateResponse extends ToolResponse {
// Action types
export interface IncidentioActionsListParams extends IncidentioBaseParams {
incident_id?: string
- page_size?: number
}
export interface IncidentioAction {
@@ -446,7 +445,6 @@ export interface IncidentioActionsShowResponse extends ToolResponse {
// Follow-up types
export interface IncidentioFollowUpsListParams extends IncidentioBaseParams {
incident_id?: string
- page_size?: number
}
export interface IncidentioFollowUp {
@@ -664,6 +662,7 @@ export interface CustomFieldsDeleteResponse extends ToolResponse {
// Users list tool types
export interface IncidentioUsersListParams extends IncidentioBaseParams {
page_size?: number
+ after?: string
}
export interface IncidentioUser {
@@ -676,6 +675,11 @@ export interface IncidentioUser {
export interface IncidentioUsersListResponse extends ToolResponse {
output: {
users: IncidentioUser[]
+ pagination_meta?: {
+ after: string
+ page_size: number
+ total_record_count?: number
+ }
}
}
@@ -786,9 +790,7 @@ export type IncidentioResponse =
| IncidentioEscalationPathsDeleteResponse
// Escalations types
-export interface IncidentioEscalationsListParams extends IncidentioBaseParams {
- page_size?: number
-}
+export interface IncidentioEscalationsListParams extends IncidentioBaseParams {}
export interface IncidentioEscalation {
id: string
diff --git a/apps/sim/tools/incidentio/users_list.ts b/apps/sim/tools/incidentio/users_list.ts
index 226e5bd2d..cbf982911 100644
--- a/apps/sim/tools/incidentio/users_list.ts
+++ b/apps/sim/tools/incidentio/users_list.ts
@@ -1,6 +1,7 @@
-import type {
- IncidentioUsersListParams,
- IncidentioUsersListResponse,
+import {
+ INCIDENTIO_PAGINATION_OUTPUT_PROPERTIES,
+ type IncidentioUsersListParams,
+ type IncidentioUsersListResponse,
} from '@/tools/incidentio/types'
import type { ToolConfig } from '@/tools/types'
@@ -24,15 +25,27 @@ export const usersListTool: ToolConfig {
- const baseUrl = 'https://api.incident.io/v2/users'
+ const url = new URL('https://api.incident.io/v2/users')
+
if (params.page_size) {
- return `${baseUrl}?page_size=${params.page_size}`
+ url.searchParams.append('page_size', params.page_size.toString())
}
- return baseUrl
+
+ if (params.after) {
+ url.searchParams.append('after', params.after)
+ }
+
+ return url.toString()
},
method: 'GET',
headers: (params) => ({
@@ -53,6 +66,13 @@ export const usersListTool: ToolConfig ({
accessToken: params.accessToken,
- deal_id: params.deal_id,
- person_id: params.person_id,
- org_id: params.org_id,
+ sort: params.sort,
limit: params.limit,
+ start: params.start,
downloadFiles: params.downloadFiles,
}),
},
@@ -79,6 +72,16 @@ export const pipedriveGetFilesTool: ToolConfig
// Common Pipedrive types
@@ -355,6 +365,7 @@ export interface PipedriveGetAllDealsParams {
pipeline_id?: string
updated_since?: string
limit?: string
+ cursor?: string
}
export interface PipedriveGetAllDealsOutput {
@@ -362,6 +373,7 @@ export interface PipedriveGetAllDealsOutput {
metadata: {
total_items: number
has_more: boolean
+ next_cursor?: string
}
success: boolean
}
@@ -431,10 +443,9 @@ export interface PipedriveUpdateDealResponse extends ToolResponse {
// GET Files
export interface PipedriveGetFilesParams {
accessToken: string
- deal_id?: string
- person_id?: string
- org_id?: string
+ sort?: string
limit?: string
+ start?: string
downloadFiles?: boolean
}
@@ -442,6 +453,8 @@ export interface PipedriveGetFilesOutput {
files: PipedriveFile[]
downloadedFiles?: ToolFileData[]
total_items: number
+ has_more?: boolean
+ next_start?: number
success: boolean
}
@@ -453,11 +466,14 @@ export interface PipedriveGetMailMessagesParams {
accessToken: string
folder?: string
limit?: string
+ start?: string
}
export interface PipedriveGetMailMessagesOutput {
messages: PipedriveMailMessage[]
total_items: number
+ has_more?: boolean
+ next_start?: number
success: boolean
}
@@ -490,12 +506,14 @@ export interface PipedriveGetPipelinesParams {
sort_by?: string
sort_direction?: string
limit?: string
- cursor?: string
+ start?: string
}
export interface PipedriveGetPipelinesOutput {
pipelines: PipedrivePipeline[]
total_items: number
+ has_more?: boolean
+ next_start?: number
success: boolean
}
@@ -508,8 +526,8 @@ export interface PipedriveGetPipelineDealsParams {
accessToken: string
pipeline_id: string
stage_id?: string
- status?: string
limit?: string
+ start?: string
}
export interface PipedriveGetPipelineDealsOutput {
@@ -517,6 +535,8 @@ export interface PipedriveGetPipelineDealsOutput {
metadata: {
pipeline_id: string
total_items: number
+ has_more?: boolean
+ next_start?: number
}
success: boolean
}
@@ -531,12 +551,15 @@ export interface PipedriveGetProjectsParams {
project_id?: string
status?: string
limit?: string
+ cursor?: string
}
export interface PipedriveGetProjectsOutput {
projects?: PipedriveProject[]
project?: PipedriveProject
total_items?: number
+ has_more?: boolean
+ next_cursor?: string
success: boolean
}
@@ -565,17 +588,18 @@ export interface PipedriveCreateProjectResponse extends ToolResponse {
// GET All Activities
export interface PipedriveGetActivitiesParams {
accessToken: string
- deal_id?: string
- person_id?: string
- org_id?: string
+ user_id?: string
type?: string
done?: string
limit?: string
+ start?: string
}
export interface PipedriveGetActivitiesOutput {
activities: PipedriveActivity[]
total_items: number
+ has_more?: boolean
+ next_start?: number
success: boolean
}
@@ -636,12 +660,15 @@ export interface PipedriveGetLeadsParams {
person_id?: string
organization_id?: string
limit?: string
+ start?: string
}
export interface PipedriveGetLeadsOutput {
leads?: PipedriveLead[]
lead?: PipedriveLead
total_items?: number
+ has_more?: boolean
+ next_start?: number
success: boolean
}
diff --git a/apps/sim/tools/supabase/query.ts b/apps/sim/tools/supabase/query.ts
index c72ba7252..95653bacc 100644
--- a/apps/sim/tools/supabase/query.ts
+++ b/apps/sim/tools/supabase/query.ts
@@ -51,6 +51,12 @@ export const queryTool: ToolConfig =
visibility: 'user-or-llm',
description: 'Maximum number of rows to return',
},
+ offset: {
+ type: 'number',
+ required: false,
+ visibility: 'user-or-llm',
+ description: 'Number of rows to skip (for pagination)',
+ },
apiKey: {
type: 'string',
required: true,
@@ -91,10 +97,15 @@ export const queryTool: ToolConfig =
}
// Add limit if provided
- if (params.limit) {
+ if (params.limit !== undefined && params.limit !== null) {
url += `&limit=${Number(params.limit)}`
}
+ // Add offset if provided
+ if (params.offset !== undefined && params.offset !== null) {
+ url += `&offset=${Number(params.offset)}`
+ }
+
return url
},
method: 'GET',
diff --git a/apps/sim/tools/supabase/text_search.ts b/apps/sim/tools/supabase/text_search.ts
index add29afe6..ee7581493 100644
--- a/apps/sim/tools/supabase/text_search.ts
+++ b/apps/sim/tools/supabase/text_search.ts
@@ -57,6 +57,12 @@ export const textSearchTool: ToolConfig = {
- plain: 'fts',
+ plain: 'plfts',
phrase: 'phfts',
websearch: 'wfts',
}
@@ -86,10 +93,15 @@ export const textSearchTool: ToolConfig {
const queryParams = new URLSearchParams()
queryParams.append('name', params.name)
- if (params.page) queryParams.append('page', params.page)
if (params.perPage) queryParams.append('per_page', params.perPage)
+ if (params.page) queryParams.append('page', params.page)
const query = queryParams.toString()
const url = buildZendeskUrl(params.subdomain, '/organizations/autocomplete')
@@ -112,19 +112,22 @@ export const zendeskAutocompleteOrganizationsTool: ToolConfig<
const data = await response.json()
const organizations = data.organizations || []
+ const hasMore = data.next_page !== null && data.next_page !== undefined
return {
success: true,
output: {
organizations,
+ // /organizations/autocomplete uses offset pagination (page/per_page), not cursor pagination.
+ // after_cursor is always null; use next_page URL or page param for subsequent pages.
paging: {
+ after_cursor: null,
+ has_more: hasMore,
next_page: data.next_page ?? null,
- previous_page: data.previous_page ?? null,
- count: data.count || organizations.length,
},
metadata: {
total_returned: organizations.length,
- has_more: !!data.next_page,
+ has_more: hasMore,
},
success: true,
},
diff --git a/apps/sim/tools/zendesk/get_organizations.ts b/apps/sim/tools/zendesk/get_organizations.ts
index 728f0b4b1..e5e6bbf84 100644
--- a/apps/sim/tools/zendesk/get_organizations.ts
+++ b/apps/sim/tools/zendesk/get_organizations.ts
@@ -1,6 +1,8 @@
import type { ToolConfig } from '@/tools/types'
import {
+ appendCursorPaginationParams,
buildZendeskUrl,
+ extractCursorPagingInfo,
handleZendeskError,
METADATA_OUTPUT,
ORGANIZATIONS_ARRAY_OUTPUT,
@@ -12,7 +14,7 @@ export interface ZendeskGetOrganizationsParams {
apiToken: string
subdomain: string
perPage?: string
- page?: string
+ pageAfter?: string
}
export interface ZendeskGetOrganizationsResponse {
@@ -20,9 +22,8 @@ export interface ZendeskGetOrganizationsResponse {
output: {
organizations: any[]
paging?: {
- next_page?: string | null
- previous_page?: string | null
- count: number
+ after_cursor: string | null
+ has_more: boolean
}
metadata: {
total_returned: number
@@ -66,19 +67,18 @@ export const zendeskGetOrganizationsTool: ToolConfig<
visibility: 'user-or-llm',
description: 'Results per page as a number string (default: "100", max: "100")',
},
- page: {
+ pageAfter: {
type: 'string',
required: false,
visibility: 'user-or-llm',
- description: 'Page number as a string (e.g., "1", "2")',
+ description: 'Cursor from a previous response to fetch the next page of results',
},
},
request: {
url: (params) => {
const queryParams = new URLSearchParams()
- if (params.page) queryParams.append('page', params.page)
- if (params.perPage) queryParams.append('per_page', params.perPage)
+ appendCursorPaginationParams(queryParams, params)
const query = queryParams.toString()
const url = buildZendeskUrl(params.subdomain, '/organizations')
@@ -103,19 +103,16 @@ export const zendeskGetOrganizationsTool: ToolConfig<
const data = await response.json()
const organizations = data.organizations || []
+ const paging = extractCursorPagingInfo(data)
return {
success: true,
output: {
organizations,
- paging: {
- next_page: data.next_page ?? null,
- previous_page: data.previous_page ?? null,
- count: data.count || organizations.length,
- },
+ paging,
metadata: {
total_returned: organizations.length,
- has_more: !!data.next_page,
+ has_more: paging.has_more,
},
success: true,
},
diff --git a/apps/sim/tools/zendesk/get_tickets.ts b/apps/sim/tools/zendesk/get_tickets.ts
index fde19c325..ffda867b0 100644
--- a/apps/sim/tools/zendesk/get_tickets.ts
+++ b/apps/sim/tools/zendesk/get_tickets.ts
@@ -1,6 +1,8 @@
import type { ToolConfig } from '@/tools/types'
import {
+ appendCursorPaginationParams,
buildZendeskUrl,
+ extractCursorPagingInfo,
handleZendeskError,
METADATA_OUTPUT,
PAGING_OUTPUT,
@@ -16,10 +18,9 @@ export interface ZendeskGetTicketsParams {
type?: string
assigneeId?: string
organizationId?: string
- sortBy?: string
- sortOrder?: string
+ sort?: string
perPage?: string
- page?: string
+ pageAfter?: string
}
export interface ZendeskGetTicketsResponse {
@@ -27,9 +28,8 @@ export interface ZendeskGetTicketsResponse {
output: {
tickets: any[]
paging?: {
- next_page?: string | null
- previous_page?: string | null
- count: number
+ after_cursor: string | null
+ has_more: boolean
}
metadata: {
total_returned: number
@@ -95,17 +95,12 @@ export const zendeskGetTicketsTool: ToolConfig {
const queryParams = new URLSearchParams()
queryParams.append('query', params.query)
- if (params.sortBy) queryParams.append('sort_by', params.sortBy)
- if (params.sortOrder) queryParams.append('sort_order', params.sortOrder)
- if (params.page) queryParams.append('page', params.page)
- if (params.perPage) queryParams.append('per_page', params.perPage)
+ queryParams.append('filter[type]', params.filterType)
+ appendCursorPaginationParams(queryParams, params)
const query = queryParams.toString()
- const url = buildZendeskUrl(params.subdomain, '/search')
+ const url = buildZendeskUrl(params.subdomain, '/search/export')
return `${url}?${query}`
},
method: 'GET',
@@ -125,19 +116,16 @@ export const zendeskSearchTool: ToolConfig): ZendeskPagingInfo {
+ const meta = (data.meta as Record) || {}
+ const links = (data.links as Record) || {}
+ return {
+ after_cursor: (meta.after_cursor as string) ?? null,
+ has_more: Boolean(meta.has_more),
+ next_page: (links.next as string) ?? null,
+ }
+}
+
/**
* Output definition for the "via" object in ticket responses.
* Contains information about how the ticket was created.
@@ -377,13 +403,13 @@ export const ORGANIZATION_OUTPUT_PROPERTIES = {
* Pagination output properties for list endpoints
*/
export const PAGING_OUTPUT_PROPERTIES = {
- next_page: { type: 'string', description: 'URL for next page of results', optional: true },
- previous_page: {
+ after_cursor: {
type: 'string',
- description: 'URL for previous page of results',
+ description: 'Cursor for fetching the next page of results',
optional: true,
},
- count: { type: 'number', description: 'Total count of items' },
+ has_more: { type: 'boolean', description: 'Whether more results are available' },
+ next_page: { type: 'string', description: 'URL for next page of results', optional: true },
} as const satisfies Record
/**
@@ -391,7 +417,7 @@ export const PAGING_OUTPUT_PROPERTIES = {
*/
export const PAGING_OUTPUT: OutputProperty = {
type: 'object',
- description: 'Pagination information',
+ description: 'Cursor-based pagination information',
properties: PAGING_OUTPUT_PROPERTIES,
}
diff --git a/bun.lock b/bun.lock
index 2de15e089..d46a5090c 100644
--- a/bun.lock
+++ b/bun.lock
@@ -13,7 +13,7 @@
"glob": "13.0.0",
"husky": "9.1.7",
"lint-staged": "16.0.0",
- "turbo": "2.8.3",
+ "turbo": "2.8.9",
},
},
"apps/docs": {
@@ -3437,19 +3437,19 @@
"tunnel-agent": ["tunnel-agent@0.6.0", "", { "dependencies": { "safe-buffer": "^5.0.1" } }, "sha512-McnNiV1l8RYeY8tBgEpuodCC1mLUdbSN+CYBL7kJsJNInOP8UjDDEwdk6Mw60vdLLrr5NHKZhMAOSrR2NZuQ+w=="],
- "turbo": ["turbo@2.8.3", "", { "optionalDependencies": { "turbo-darwin-64": "2.8.3", "turbo-darwin-arm64": "2.8.3", "turbo-linux-64": "2.8.3", "turbo-linux-arm64": "2.8.3", "turbo-windows-64": "2.8.3", "turbo-windows-arm64": "2.8.3" }, "bin": { "turbo": "bin/turbo" } }, "sha512-8Osxz5Tu/Dw2kb31EAY+nhq/YZ3wzmQSmYa1nIArqxgCAldxv9TPlrAiaBUDVnKA4aiPn0OFBD1ACcpc5VFOAQ=="],
+ "turbo": ["turbo@2.8.9", "", { "optionalDependencies": { "turbo-darwin-64": "2.8.9", "turbo-darwin-arm64": "2.8.9", "turbo-linux-64": "2.8.9", "turbo-linux-arm64": "2.8.9", "turbo-windows-64": "2.8.9", "turbo-windows-arm64": "2.8.9" }, "bin": { "turbo": "bin/turbo" } }, "sha512-G+Mq8VVQAlpz/0HTsxiNNk/xywaHGl+dk1oiBREgOEVCCDjXInDlONWUn5srRnC9s5tdHTFD1bx1N19eR4hI+g=="],
- "turbo-darwin-64": ["turbo-darwin-64@2.8.3", "", { "os": "darwin", "cpu": "x64" }, "sha512-4kXRLfcygLOeNcP6JquqRLmGB/ATjjfehiojL2dJkL7GFm3SPSXbq7oNj8UbD8XriYQ5hPaSuz59iF1ijPHkTw=="],
+ "turbo-darwin-64": ["turbo-darwin-64@2.8.9", "", { "os": "darwin", "cpu": "x64" }, "sha512-KnCw1ZI9KTnEAhdI9avZrnZ/z4wsM++flMA1w8s8PKOqi5daGpFV36qoPafg4S8TmYMe52JPWEoFr0L+lQ5JIw=="],
- "turbo-darwin-arm64": ["turbo-darwin-arm64@2.8.3", "", { "os": "darwin", "cpu": "arm64" }, "sha512-xF7uCeC0UY0Hrv/tqax0BMbFlVP1J/aRyeGQPZT4NjvIPj8gSPDgFhfkfz06DhUwDg5NgMo04uiSkAWE8WB/QQ=="],
+ "turbo-darwin-arm64": ["turbo-darwin-arm64@2.8.9", "", { "os": "darwin", "cpu": "arm64" }, "sha512-CbD5Y2NKJKBXTOZ7z7Cc7vGlFPZkYjApA7ri9lH4iFwKV1X7MoZswh9gyRLetXYWImVX1BqIvP8KftulJg/wIA=="],
- "turbo-linux-64": ["turbo-linux-64@2.8.3", "", { "os": "linux", "cpu": "x64" }, "sha512-vxMDXwaOjweW/4etY7BxrXCSkvtwh0PbwVafyfT1Ww659SedUxd5rM3V2ZCmbwG8NiCfY7d6VtxyHx3Wh1GoZA=="],
+ "turbo-linux-64": ["turbo-linux-64@2.8.9", "", { "os": "linux", "cpu": "x64" }, "sha512-OXC9HdCtsHvyH+5KUoH8ds+p5WU13vdif0OPbsFzZca4cUXMwKA3HWwUuCgQetk0iAE4cscXpi/t8A263n3VTg=="],
- "turbo-linux-arm64": ["turbo-linux-arm64@2.8.3", "", { "os": "linux", "cpu": "arm64" }, "sha512-mQX7uYBZFkuPLLlKaNe9IjR1JIef4YvY8f21xFocvttXvdPebnq3PK1Zjzl9A1zun2BEuWNUwQIL8lgvN9Pm3Q=="],
+ "turbo-linux-arm64": ["turbo-linux-arm64@2.8.9", "", { "os": "linux", "cpu": "arm64" }, "sha512-yI5n8jNXiFA6+CxnXG0gO7h5ZF1+19K8uO3/kXPQmyl37AdiA7ehKJQOvf9OPAnmkGDHcF2HSCPltabERNRmug=="],
- "turbo-windows-64": ["turbo-windows-64@2.8.3", "", { "os": "win32", "cpu": "x64" }, "sha512-YLGEfppGxZj3VWcNOVa08h6ISsVKiG85aCAWosOKNUjb6yErWEuydv6/qImRJUI+tDLvDvW7BxopAkujRnWCrw=="],
+ "turbo-windows-64": ["turbo-windows-64@2.8.9", "", { "os": "win32", "cpu": "x64" }, "sha512-/OztzeGftJAg258M/9vK2ZCkUKUzqrWXJIikiD2pm8TlqHcIYUmepDbyZSDfOiUjMy6NzrLFahpNLnY7b5vNgg=="],
- "turbo-windows-arm64": ["turbo-windows-arm64@2.8.3", "", { "os": "win32", "cpu": "arm64" }, "sha512-afTUGKBRmOJU1smQSBnFGcbq0iabAPwh1uXu2BVk7BREg30/1gMnJh9DFEQTah+UD3n3ru8V55J83RQNFfqoyw=="],
+ "turbo-windows-arm64": ["turbo-windows-arm64@2.8.9", "", { "os": "win32", "cpu": "arm64" }, "sha512-xZ2VTwVTjIqpFZKN4UBxDHCPM3oJ2J5cpRzCBSmRpJ/Pn33wpiYjs+9FB2E03svKaD04/lSSLlEUej0UYsugfg=="],
"tweetnacl": ["tweetnacl@0.14.5", "", {}, "sha512-KXXFFdAbFXY4geFIwoyNK+f5Z1b7swfXABfL7HXCmoIWMKU3dmS26672A4EeQtDzLKy7SXmfBu51JolvEKwtGA=="],
diff --git a/package.json b/package.json
index cca04b0b5..169f31272 100644
--- a/package.json
+++ b/package.json
@@ -42,7 +42,7 @@
"glob": "13.0.0",
"husky": "9.1.7",
"lint-staged": "16.0.0",
- "turbo": "2.8.3"
+ "turbo": "2.8.9"
},
"lint-staged": {
"*.{js,jsx,ts,tsx,json,css,scss}": [