marketo_get_lead_activities
Retrieve lead activity data from Marketo by specifying a lead ID, with options to filter by activity types, paginate results, and control batch size for API efficiency.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| leadId | Yes | ||
| activityTypeIds | No | ||
| nextPageToken | No | ||
| batchSize | No |
Implementation Reference
- src/index.ts:529-557 (handler)Handler function that fetches lead activities from Marketo API for a given lead ID. Supports optional activityTypeIds, pagination via nextPageToken, and batchSize. Uses makeApiRequest helper and returns formatted response or error.async ({ leadId, activityTypeIds, nextPageToken, batchSize = 100 }) => { try { const params = new URLSearchParams({ batchSize: batchSize.toString(), }); if (activityTypeIds) { params.append('activityTypeIds', activityTypeIds.join(',')); } if (nextPageToken) { params.append('nextPageToken', nextPageToken); } const response = await makeApiRequest( `/rest/v1/activities/lead/${leadId}.json?${params.toString()}`, 'GET' ); return { content: [{ type: 'text', text: JSON.stringify(response, null, 2) }], }; } catch (error: any) { return { content: [ { type: 'text', text: `Error: ${error.response?.data?.message || error.message}` }, ], }; } }
- src/index.ts:524-528 (schema)Zod input schema defining parameters for the tool: leadId (required number), activityTypeIds (optional array of numbers), nextPageToken (optional string), batchSize (optional number).leadId: z.number(), activityTypeIds: z.array(z.number()).optional(), nextPageToken: z.string().optional(), batchSize: z.number().optional(), },
- src/index.ts:521-558 (registration)Registration of the 'marketo_get_lead_activities' tool on the MCP server using server.tool(), including inline schema and handler function.server.tool( 'marketo_get_lead_activities', { leadId: z.number(), activityTypeIds: z.array(z.number()).optional(), nextPageToken: z.string().optional(), batchSize: z.number().optional(), }, async ({ leadId, activityTypeIds, nextPageToken, batchSize = 100 }) => { try { const params = new URLSearchParams({ batchSize: batchSize.toString(), }); if (activityTypeIds) { params.append('activityTypeIds', activityTypeIds.join(',')); } if (nextPageToken) { params.append('nextPageToken', nextPageToken); } const response = await makeApiRequest( `/rest/v1/activities/lead/${leadId}.json?${params.toString()}`, 'GET' ); return { content: [{ type: 'text', text: JSON.stringify(response, null, 2) }], }; } catch (error: any) { return { content: [ { type: 'text', text: `Error: ${error.response?.data?.message || error.message}` }, ], }; } } );
- src/index.ts:22-52 (helper)Shared helper function for making authenticated HTTP requests to Marketo APIs, used by the tool handler.async function makeApiRequest( endpoint: string, method: string, data?: any, contentType: string = 'application/json' ) { const token = await tokenManager.getToken(); const headers: any = { Authorization: `Bearer ${token}`, }; if (contentType) { headers['Content-Type'] = contentType; } try { const response = await axios({ url: `${MARKETO_BASE_URL}${endpoint}`, method: method, data: contentType === 'application/x-www-form-urlencoded' ? new URLSearchParams(data).toString() : data, headers, }); return response.data; } catch (error: any) { console.error('API request failed:', error.response?.data || error.message); throw error; } }