zendesk v2 with paginated output

Author: abhinavDhulipala

apps/sim/blocks/blocks/zendesk.ts

@@ -533,6 +533,7 @@ Return ONLY the search query - no explanations.`,
   tools: {
     access: [
       'zendesk_get_tickets',
+      'zendesk_get_tickets_v2',
       'zendesk_get_ticket',
       'zendesk_create_ticket',
       'zendesk_create_tickets_bulk',
@@ -563,7 +564,7 @@ Return ONLY the search query - no explanations.`,
       tool: (params) => {
         switch (params.operation) {
           case 'get_tickets':
-            return 'zendesk_get_tickets'
+            return 'zendesk_get_tickets_v2'
           case 'get_ticket':
             return 'zendesk_get_ticket'
           case 'create_ticket':

apps/sim/lib/paginated-cache/index.ts

@@ -1,14 +1,14 @@
 export type { PaginatedCacheStorageAdapter } from '@/lib/paginated-cache/adapter'
-export { RedisPaginatedCache } from '@/lib/paginated-cache/redis-cache'
 export {
   autoPaginate,
   cleanupPaginatedCache,
   hydrateCacheReferences,
 } from '@/lib/paginated-cache/paginate'
+export { RedisPaginatedCache } from '@/lib/paginated-cache/redis-cache'
 export {
-  isPaginatedCacheReference,
   type CachedPage,
   type CacheMetadata,
+  isPaginatedCacheReference,
   type PaginatedCacheReference,
   type ToolPaginationConfig,
 } from '@/lib/paginated-cache/types'

apps/sim/lib/paginated-cache/paginate.test.ts

@@ -126,8 +126,9 @@ describe('autoPaginate', () => {
     expect(result.output.tickets).toEqual(
       expect.objectContaining({ _type: 'paginated_cache_ref', totalPages: 3, totalItems: 3 })
     )
-    expect(result.output.paging).toEqual({ has_more: false, after_cursor: null })
-    expect(result.output.metadata).toEqual({ total_returned: 1, has_more: false })
+    expect(result.output.paging).toBeUndefined()
+    expect(result.output.metadata).toBeUndefined()
+    expect(Object.keys(result.output)).toEqual(['tickets'])
   })
 
   it('respects maxPages', async () => {
@@ -235,10 +236,7 @@ describe('autoPaginate', () => {
     })
 
     const outputKeys = Object.keys(result.output)
-    expect(outputKeys).toContain('items')
-    expect(outputKeys).toContain('cursor')
-    expect(outputKeys).not.toContain('metadata')
-    expect(outputKeys).not.toContain('paging')
+    expect(outputKeys).toEqual(['items'])
   })
 })
 

apps/sim/lib/paginated-cache/paginate.ts

@@ -50,7 +50,6 @@ export async function autoPaginate(options: AutoPaginateOptions): Promise<ToolRe
 
   let totalItems = 0
   let pageIndex = 0
-  let lastOutput = initialResult.output
 
   const initialItems = config.getItems(initialResult.output)
   await cache.storePage(cacheId, pageIndex, initialItems)
@@ -71,7 +70,6 @@ export async function autoPaginate(options: AutoPaginateOptions): Promise<ToolRe
     const pageItems = config.getItems(pageResult.output)
     await cache.storePage(cacheId, pageIndex, pageItems)
     totalItems += pageItems.length
-    lastOutput = pageResult.output
     pageIndex++
 
     nextToken = config.getNextPageToken(pageResult.output)
@@ -94,7 +92,6 @@ export async function autoPaginate(options: AutoPaginateOptions): Promise<ToolRe
   return {
     ...initialResult,
     output: {
-      ...lastOutput,
       [config.pageField]: reference,
     },
   }

apps/sim/lib/paginated-cache/redis-cache.ts

@@ -9,7 +9,7 @@ const logger = createLogger('RedisPaginatedCache')
 const REDIS_KEY_PREFIX = 'pagcache:'
 
 /** Safety-net TTL: 2× the max async execution timeout. Explicit cleanup is the primary mechanism. */
-const DEFAULT_TTL_MS = Number(env.EXECUTION_TIMEOUT_ASYNC_ENTERPRISE) * 1000 * 2
+const DEFAULT_TTL_MS = (Number(env.EXECUTION_TIMEOUT_ASYNC_ENTERPRISE) || 5400) * 1000 * 2
 
 export class RedisPaginatedCache implements PaginatedCacheStorageAdapter {
   constructor(

apps/sim/lib/paginated-cache/types.test.ts

@@ -2,7 +2,6 @@
  * @vitest-environment node
  */
 import { describe, expect, it } from 'vitest'
-
 import { isPaginatedCacheReference } from '@/lib/paginated-cache/types'
 
 describe('isPaginatedCacheReference', () => {

apps/sim/tools/index.ts

@@ -620,10 +620,6 @@ async function maybeAutoPaginate(
   ) {
     return finalResult
   }
-  const nextToken = tool.pagination.getNextPageToken(finalResult.output)
-  if (nextToken === null) {
-    return finalResult
-  }
   return autoPaginate({
     initialResult: finalResult,
     params: contextParams,

apps/sim/tools/registry.ts

@@ -2669,6 +2669,7 @@ import {
   zendeskGetOrganizationsTool,
   zendeskGetOrganizationTool,
   zendeskGetTicketsTool,
+  zendeskGetTicketsV2Tool,
   zendeskGetTicketTool,
   zendeskGetUsersTool,
   zendeskGetUserTool,
@@ -5016,6 +5017,7 @@ export const tools: Record<string, ToolConfig> = {
   mailchimp_create_batch_operation: mailchimpCreateBatchOperationTool,
   mailchimp_delete_batch_operation: mailchimpDeleteBatchOperationTool,
   zendesk_get_tickets: zendeskGetTicketsTool,
+  zendesk_get_tickets_v2: zendeskGetTicketsV2Tool,
   zendesk_get_ticket: zendeskGetTicketTool,
   zendesk_create_ticket: zendeskCreateTicketTool,
   zendesk_create_tickets_bulk: zendeskCreateTicketsBulkTool,

apps/sim/tools/zendesk/get_tickets.ts

@@ -1,5 +1,6 @@
 import type { ToolConfig } from '@/tools/types'
 import {
+  appendCursorPaginationParams,
   buildZendeskUrl,
   extractCursorPagingInfo,
   handleZendeskError,
@@ -18,7 +19,7 @@ export interface ZendeskGetTicketsParams {
   assigneeId?: string
   organizationId?: string
   sort?: string
-  /** Internal: set by auto-pagination via buildNextPageParams */
+  perPage?: string
   pageAfter?: string
 }
 
@@ -43,7 +44,7 @@ export const zendeskGetTicketsTool: ToolConfig<ZendeskGetTicketsParams, ZendeskG
     id: 'zendesk_get_tickets',
     name: 'Get Tickets from Zendesk',
     description: 'Retrieve a list of tickets from Zendesk with optional filtering',
-    version: '2.0.0',
+    version: '1.0.0',
 
     params: {
       email: {
@@ -101,6 +102,18 @@ export const zendeskGetTicketsTool: ToolConfig<ZendeskGetTicketsParams, ZendeskG
         description:
           'Sort field for ticket listing (only applies without filters): "updated_at", "id", or "status". Prefix with "-" for descending (e.g., "-updated_at")',
       },
+      perPage: {
+        type: 'string',
+        required: false,
+        visibility: 'user-or-llm',
+        description: 'Results per page as a number string (default: "100", max: "100")',
+      },
+      pageAfter: {
+        type: 'string',
+        required: false,
+        visibility: 'user-or-llm',
+        description: 'Cursor from a previous response to fetch the next page of results',
+      },
     },
 
     request: {
@@ -125,16 +138,15 @@ export const zendeskGetTicketsTool: ToolConfig<ZendeskGetTicketsParams, ZendeskG
           const queryParams = new URLSearchParams()
           queryParams.append('query', searchTerms.join(' '))
           queryParams.append('filter[type]', 'ticket')
-          queryParams.append('page[size]', '100')
-          if (params.pageAfter) queryParams.append('page[after]', params.pageAfter)
+          appendCursorPaginationParams(queryParams, params)
 
           return `${buildZendeskUrl(params.subdomain, '/search/export')}?${queryParams.toString()}`
         }
 
+        // No filters - use the simple /tickets endpoint with cursor-based pagination
         const queryParams = new URLSearchParams()
         if (params.sort) queryParams.append('sort', params.sort)
-        queryParams.append('page[size]', '100')
-        if (params.pageAfter) queryParams.append('page[after]', params.pageAfter)
+        appendCursorPaginationParams(queryParams, params)
 
         const query = queryParams.toString()
         const url = buildZendeskUrl(params.subdomain, '/tickets')
@@ -182,19 +194,4 @@ export const zendeskGetTicketsTool: ToolConfig<ZendeskGetTicketsParams, ZendeskG
       paging: PAGING_OUTPUT,
       metadata: METADATA_OUTPUT,
     },
-
-    pagination: {
-      pageField: 'tickets',
-      getItems: (output) => output.tickets ?? [],
-      getNextPageToken: (output) => {
-        if (output.paging?.has_more && output.paging?.after_cursor) {
-          return output.paging.after_cursor
-        }
-        return null
-      },
-      buildNextPageParams: (params, token) => ({
-        ...params,
-        pageAfter: String(token),
-      }),
-    },
   }