fix(pipedrive): move activity writes and pipeline listing to API v2, send lead visible_to as a string, guard path ids

Author: waleedlatif1

apps/sim/blocks/blocks/pipedrive.ts

@@ -399,7 +399,7 @@ Return ONLY the date string in YYYY-MM-DD format - no explanations, no quotes, n
       placeholder: 'Pagination cursor from previous response',
       condition: {
         field: 'operation',
-        value: ['get_all_deals', 'get_projects'],
+        value: ['get_all_deals', 'get_projects', 'get_pipelines'],
       },
     },
     {
@@ -415,7 +415,6 @@ Return ONLY the date string in YYYY-MM-DD format - no explanations, no quotes, n
           'get_files',
           'get_pipeline_deals',
           'get_mail_messages',
-          'get_pipelines',
         ],
       },
     },
@@ -448,6 +447,7 @@ Return ONLY the date string in YYYY-MM-DD format - no explanations, no quotes, n
         { label: 'All', id: '' },
         { label: 'Open', id: 'open' },
         { label: 'Completed', id: 'completed' },
+        { label: 'Canceled', id: 'canceled' },
       ],
       value: () => '',
       condition: { field: 'operation', value: ['get_projects'] },

apps/sim/tools/pipedrive/create_activity.ts

@@ -76,7 +76,7 @@ export const pipedriveCreateActivityTool: ToolConfig<
       type: 'string',
       required: false,
       visibility: 'user-or-llm',
-      description: 'ID of the person to associate with (e.g., "456")',
+      description: 'ID of the person to associate with as the primary participant (e.g., "456")',
     },
     org_id: {
       type: 'string',
@@ -93,7 +93,7 @@ export const pipedriveCreateActivityTool: ToolConfig<
   },
 
   request: {
-    url: () => 'https://api.pipedrive.com/v1/activities',
+    url: () => 'https://api.pipedrive.com/api/v2/activities',
     method: 'POST',
     headers: (params) => ({
       ...getPipedriveAuthHeaders(params),
@@ -109,7 +109,9 @@ export const pipedriveCreateActivityTool: ToolConfig<
       if (params.due_time) body.due_time = params.due_time
       if (params.duration) body.duration = params.duration
       if (params.deal_id) body.deal_id = Number(params.deal_id)
-      if (params.person_id) body.person_id = Number(params.person_id)
+      if (params.person_id) {
+        body.participants = [{ person_id: Number(params.person_id), primary: true }]
+      }
       if (params.org_id) body.org_id = Number(params.org_id)
       if (params.note) body.note = params.note
 

apps/sim/tools/pipedrive/create_lead.ts

@@ -82,7 +82,8 @@ export const pipedriveCreateLeadTool: ToolConfig<
       type: 'string',
       required: false,
       visibility: 'user-or-llm',
-      description: 'Visibility: 1 (Owner & followers), 3 (Entire company)',
+      description:
+        "Visibility group: 1 (owner only / owner & followers), 3 (owner's visibility group / entire company), 5 (owner's group and sub-groups), 7 (entire company); 5 and 7 are Premium/Ultimate only",
     },
   },
 
@@ -115,7 +116,7 @@ export const pipedriveCreateLeadTool: ToolConfig<
       }
 
       if (params.expected_close_date) body.expected_close_date = params.expected_close_date
-      if (params.visible_to) body.visible_to = Number(params.visible_to)
+      if (params.visible_to) body.visible_to = String(params.visible_to)
 
       return body
     },

apps/sim/tools/pipedrive/delete_lead.ts

@@ -5,6 +5,7 @@ import type {
 } from '@/tools/pipedrive/types'
 import { getPipedriveAuthHeaders } from '@/tools/pipedrive/utils'
 import type { ToolConfig } from '@/tools/types'
+import { safeUrlPathSegment } from '@/tools/url-path'
 
 const logger = createLogger('PipedriveDeleteLead')
 
@@ -45,7 +46,8 @@ export const pipedriveDeleteLeadTool: ToolConfig<
   },
 
   request: {
-    url: (params) => `https://api.pipedrive.com/v1/leads/${params.lead_id}`,
+    url: (params) =>
+      `https://api.pipedrive.com/v1/leads/${safeUrlPathSegment(params.lead_id, 'lead_id')}`,
     method: 'DELETE',
     headers: (params) => getPipedriveAuthHeaders(params),
   },

apps/sim/tools/pipedrive/get_deal.ts

@@ -2,6 +2,7 @@ import { createLogger } from '@sim/logger'
 import type { PipedriveGetDealParams, PipedriveGetDealResponse } from '@/tools/pipedrive/types'
 import { getPipedriveAuthHeaders } from '@/tools/pipedrive/utils'
 import type { ToolConfig } from '@/tools/types'
+import { safeUrlPathSegment } from '@/tools/url-path'
 
 const logger = createLogger('PipedriveGetDeal')
 
@@ -39,7 +40,8 @@ export const pipedriveGetDealTool: ToolConfig<PipedriveGetDealParams, PipedriveG
   },
 
   request: {
-    url: (params) => `https://api.pipedrive.com/api/v2/deals/${params.deal_id}`,
+    url: (params) =>
+      `https://api.pipedrive.com/api/v2/deals/${safeUrlPathSegment(params.deal_id, 'deal_id')}`,
     method: 'GET',
     headers: (params) => getPipedriveAuthHeaders(params),
   },

apps/sim/tools/pipedrive/get_leads.ts

@@ -3,6 +3,7 @@ import type { PipedriveGetLeadsParams, PipedriveGetLeadsResponse } from '@/tools
 import { PIPEDRIVE_LEAD_OUTPUT_PROPERTIES } from '@/tools/pipedrive/types'
 import { getPipedriveAuthHeaders } from '@/tools/pipedrive/utils'
 import type { ToolConfig } from '@/tools/types'
+import { safeUrlPathSegment } from '@/tools/url-path'
 
 const logger = createLogger('PipedriveGetLeads')
 
@@ -80,7 +81,7 @@ export const pipedriveGetLeadsTool: ToolConfig<PipedriveGetLeadsParams, Pipedriv
       url: (params) => {
         // If lead_id is provided, get specific lead
         if (params.lead_id) {
-          return `https://api.pipedrive.com/v1/leads/${params.lead_id}`
+          return `https://api.pipedrive.com/v1/leads/${safeUrlPathSegment(params.lead_id, 'lead_id')}`
         }
 
         // Get archived or active leads with optional filters

apps/sim/tools/pipedrive/get_mail_thread.ts

@@ -5,6 +5,7 @@ import type {
 } from '@/tools/pipedrive/types'
 import { getPipedriveAuthHeaders } from '@/tools/pipedrive/utils'
 import type { ToolConfig } from '@/tools/types'
+import { safeUrlPathSegment } from '@/tools/url-path'
 
 const logger = createLogger('PipedriveGetMailThread')
 
@@ -46,7 +47,7 @@ export const pipedriveGetMailThreadTool: ToolConfig<
 
   request: {
     url: (params) =>
-      `https://api.pipedrive.com/v1/mailbox/mailThreads/${params.thread_id}/mailMessages`,
+      `https://api.pipedrive.com/v1/mailbox/mailThreads/${safeUrlPathSegment(params.thread_id, 'thread_id')}/mailMessages`,
     method: 'GET',
     headers: (params) => getPipedriveAuthHeaders(params),
   },

apps/sim/tools/pipedrive/get_pipeline_deals.ts

@@ -5,6 +5,7 @@ import type {
 } from '@/tools/pipedrive/types'
 import { getPipedriveAuthHeaders } from '@/tools/pipedrive/utils'
 import type { ToolConfig } from '@/tools/types'
+import { safeUrlPathSegment } from '@/tools/url-path'
 
 const logger = createLogger('PipedriveGetPipelineDeals')
 
@@ -64,7 +65,7 @@ export const pipedriveGetPipelineDealsTool: ToolConfig<
 
   request: {
     url: (params) => {
-      const baseUrl = `https://api.pipedrive.com/v1/pipelines/${params.pipeline_id}/deals`
+      const baseUrl = `https://api.pipedrive.com/v1/pipelines/${safeUrlPathSegment(params.pipeline_id, 'pipeline_id')}/deals`
       const queryParams = new URLSearchParams()
 
       if (params.stage_id) queryParams.append('stage_id', params.stage_id)

apps/sim/tools/pipedrive/get_pipelines.ts

@@ -56,22 +56,28 @@ export const pipedriveGetPipelinesTool: ToolConfig<
       description: 'Number of results to return (e.g., "50", default: 100, max: 500)',
     },
     start: {
+      type: 'string',
+      required: false,
+      visibility: 'user-only',
+      description: 'Ignored: Pipedrive API v2 pages pipelines with cursor instead of an offset',
+    },
+    cursor: {
       type: 'string',
       required: false,
       visibility: 'user-or-llm',
-      description: 'Pagination start offset (0-based index of the first item to return)',
+      description: 'For pagination, the marker representing the first item on the next page',
     },
   },
 
   request: {
     url: (params) => {
-      const baseUrl = 'https://api.pipedrive.com/v1/pipelines'
+      const baseUrl = 'https://api.pipedrive.com/api/v2/pipelines'
       const queryParams = new URLSearchParams()
 
       if (params.sort_by) queryParams.append('sort_by', params.sort_by)
       if (params.sort_direction) queryParams.append('sort_direction', params.sort_direction)
       if (params.limit) queryParams.append('limit', params.limit)
-      if (params.start) queryParams.append('start', params.start)
+      if (params.cursor) queryParams.append('cursor', params.cursor)
 
       const queryString = queryParams.toString()
       return queryString ? `${baseUrl}?${queryString}` : baseUrl
@@ -89,16 +95,16 @@ export const pipedriveGetPipelinesTool: ToolConfig<
     }
 
     const pipelines = data.data || []
-    const hasMore = data.additional_data?.pagination?.more_items_in_collection || false
-    const nextStart = data.additional_data?.pagination?.next_start ?? null
+    const nextCursor = data.additional_data?.next_cursor ?? null
 
     return {
       success: true,
       output: {
         pipelines,
         total_items: pipelines.length,
-        has_more: hasMore,
-        next_start: nextStart,
+        has_more: nextCursor !== null,
+        next_start: null,
+        next_cursor: nextCursor,
         success: true,
       },
     }
@@ -121,7 +127,12 @@ export const pipedriveGetPipelinesTool: ToolConfig<
     },
     next_start: {
       type: 'number',
-      description: 'Offset for fetching the next page',
+      description: 'Always null: API v2 pages with next_cursor instead of an offset',
+      optional: true,
+    },
+    next_cursor: {
+      type: 'string',
+      description: 'Cursor for fetching the next page',
       optional: true,
     },
     success: { type: 'boolean', description: 'Operation success status' },

apps/sim/tools/pipedrive/get_projects.ts

@@ -5,6 +5,7 @@ import type {
 } from '@/tools/pipedrive/types'
 import { getPipedriveAuthHeaders } from '@/tools/pipedrive/utils'
 import type { ToolConfig } from '@/tools/types'
+import { safeUrlPathSegment } from '@/tools/url-path'
 
 const logger = createLogger('PipedriveGetProjects')
 
@@ -46,7 +47,8 @@ export const pipedriveGetProjectsTool: ToolConfig<
       type: 'string',
       required: false,
       visibility: 'user-or-llm',
-      description: 'Filter by project status: open, completed, deleted (only for listing all)',
+      description:
+        'Filter by project status: open, completed, canceled, deleted (only for listing all)',
     },
     limit: {
       type: 'string',
@@ -67,7 +69,7 @@ export const pipedriveGetProjectsTool: ToolConfig<
     url: (params) => {
       // If project_id is provided, get specific project
       if (params.project_id) {
-        return `https://api.pipedrive.com/v1/projects/${params.project_id}`
+        return `https://api.pipedrive.com/v1/projects/${safeUrlPathSegment(params.project_id, 'project_id')}`
       }
 
       // Otherwise, get all projects with optional filters