Marketo MCP Server

Implementation Reference

• src/index.ts:669-698 (handler)

  Complete inline implementation of the 'marketo_remove_lead_from_list' tool: registers the tool with Zod input schema (listId: number, leadIds: array of numbers), and handler that maps leadIds to input format, POSTs to Marketo API endpoint `/rest/v1/lists/{listId}/leads/delete.json` using shared makeApiRequest, returns JSON response or formatted error.

  server.tool(
    'marketo_remove_lead_from_list',
    {
      listId: z.number(),
      leadIds: z.array(z.number()),
    },
    async ({ listId, leadIds }) => {
      try {
        const data = {
          input: leadIds.map(id => ({ id })),
        };
  
        const response = await makeApiRequest(
          `/rest/v1/lists/${listId}/leads/delete.json`,
          'POST',
          data
        );
  
        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:672-674 (schema)

  Zod schema for tool inputs.

    listId: z.number(),
    leadIds: z.array(z.number()),
  },

• src/index.ts:22-52 (helper)

  Shared utility function to make authenticated API requests to Marketo using axios and bearer token from TokenManager.

  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;
    }
  }