Skip to main content
apollo-webhooks-events Implement Apollo.io webhook and event-driven integrations.
Use when receiving Apollo notifications, syncing data on changes,
or building event-driven pipelines from Apollo activity.
Trigger with phrases like "apollo webhooks", "apollo events",
"apollo notifications", "apollo webhook handler", "apollo triggers".
跳到安装 Skills Marketplace 发现并探索由社区构建的 Agent Skills
用 Codex 或 Claude 帮你安装 复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。
直接命令不会经过审查 Prompt；运行前请先检查来源。
npx skills add https://github.com/jeremylongshore/claude-code-plugins-plus-skills --skill apollo-webhooks-events命令会保持在同一行。复制前请横向滚动并检查完整内容。
想先保存到本地？可下载 SkillsMP 当前能够提供的文件。
下载 Zip 下载中... 同仓库更多 Skills Implement user sign-up and sign-in flows with Clerk.
Use when building authentication UI, customizing sign-in experience,
or implementing OAuth social login.
Trigger with phrases like "clerk sign-in", "clerk sign-up",
"clerk login flow", "clerk OAuth", "clerk social login".
Implement session management and middleware with Clerk.
Use when managing user sessions, configuring route protection,
or implementing token refresh and custom JWT templates.
Trigger with phrases like "clerk session", "clerk middleware",
"clerk route protection", "clerk token", "clerk JWT".
Configure enterprise SSO, role-based access control, and organization management.
Use when implementing SSO integration, configuring role-based permissions,
or setting up organization-level controls.
Trigger with phrases like "clerk SSO", "clerk RBAC",
"clerk enterprise", "clerk roles", "clerk permissions", "clerk organizations".
jeremylongshore
jeremylongshore/claude-code-plugins-plus-skills
打开 GitHub 仓库 name apollo-webhooks-events description Implement Apollo.io webhook and event-driven integrations.
Use when receiving Apollo notifications, syncing data on changes,
or building event-driven pipelines from Apollo activity.
Trigger with phrases like "apollo webhooks", "apollo events",
"apollo notifications", "apollo webhook handler", "apollo triggers".
allowed-tools Read, Write, Edit, Bash(gh:*), Bash(curl:*) version 1.13.0 license MIT author Jeremy Longshore <jeremy@intentsolutions.io> tags ["saas","apollo","webhooks"] compatibility Designed for Claude Code, also compatible with Codex and OpenClaw
Apollo Webhooks & Events
Overview
Build event-driven integrations with Apollo.io. Apollo does not have a native webhook system like Stripe — instead, you build real-time sync by polling the API for changes or using third-party webhook platforms (Zapier, Pipedream, Make) that trigger on Apollo events. This skill covers both approaches plus the Contact Stages and Tasks APIs for workflow automation.
Prerequisites
Apollo account with master API key
Node.js 18+ with Express
For polling: a scheduler (cron, Cloud Scheduler, BullMQ)
For webhook platforms: Zapier/Pipedream/Make account
Instructions
Step 1: Poll for Contact Changes
Since Apollo lacks native webhooks, poll the Contacts Search API for recently updated records.
import axios from 'axios' ;
const client = axios.create ({
baseURL : 'https://api.apollo.io/api/v1' ,
headers : { 'Content-Type' : 'application/json' , 'x-api-key' : process.env .APOLLO_API_KEY ! },
});
interface SyncState {
lastSyncAt : string ;
}
export async function pollContactChanges (state : SyncState const { data } = await client.post ('/contacts/search' , {
sort_by_field : 'contact_updated_at' ,
sort_ascending : false ,
per_page
100
const
new
Date
lastSyncAt
const
contacts
filter
(c : any
new
Date
updated_at
if
length
0
console
log
`Found ${newChanges.length} contact changes since ${state.lastSyncAt} `
for
const
of
await
handleContactChange
lastSyncAt
new
Date
toISOString
return
async
function
handleContactChange
contact : any
console
log
`Contact updated: ${contact.name} (${contact.email} ) — stage: ${contact.contact_stage_id} `
Step 2: Track Contact Stage Changes Apollo has a Contact Stages system. Use the List Contact Stages endpoint to get stage IDs, then filter contacts by stage.
export async function getContactStages (const { data } = await client.get ('/contact_stages' );
return data.contact_stages .map ((s : any ({
id : s.id ,
name : s.name ,
order : s.display_order ,
}));
}
export async function getContactsByStage (stageId : string const { data } = await client.post ('/contacts/search' , {
contact_stage_ids : [stageId],
sort_by_field : 'contact_updated_at' ,
sort_ascending : false ,
per_page : 50 ,
});
return data.contacts ;
}
export async function updateContactStage (contactId : string , stageId : string await client.put (`/contacts/${contactId} ` , {
contact_stage_id : stageId,
});
}
Step 3: Monitor Sequence Engagement Poll sequence data for replies, bounces, and engagement events.
export async function checkSequenceEngagement (sequenceId : string const { data } = await client.post ('/emailer_campaigns/search' , {
ids : [sequenceId],
per_page : 1 ,
});
const seq = data.emailer_campaigns ?.[0 ];
if (!seq) return null ;
return {
name : seq.name ,
active : seq.active ,
metrics : {
scheduled : seq.unique_scheduled ?? 0 ,
delivered : seq.unique_delivered ?? 0 ,
opened : seq.unique_opened ?? 0 ,
replied : seq.unique_replied ?? 0 ,
bounced : seq.unique_bounced ?? 0 ,
unsubscribed : seq.unique_unsubscribed ?? 0 ,
},
rates : {
openRate : pct (seq.unique_opened , seq.unique_delivered ),
replyRate : pct (seq.unique_replied , seq.unique_delivered ),
bounceRate : pct (seq.unique_bounced , seq.unique_scheduled ),
},
};
}
function pct (num ?: number , denom ?: number string {
if (!denom) return '0%' ;
return `${(((num ?? 0 ) / denom) * 100 ).toFixed(1 )} %` ;
}
Step 4: Create Tasks for Follow-Up Actions Use Apollo's Tasks API to create actionable follow-ups triggered by your polling logic.
export async function createFollowUpTask (params : {
contactId: string ;
type : 'call' | 'action_item' | 'email' ;
dueDate: string ;
note: string ;
assigneeId?: string ;
}const { data } = await client.post ('/tasks' , {
contact_id : params.contactId ,
type : params.type ,
due_date : params.dueDate ,
note : params.note ,
user_id : params.assigneeId ,
priority : 'high' ,
status : 'open' ,
});
return { taskId : data.task .id , type : data.task .type , dueDate : data.task .due_date };
}
async function onSequenceReply (contactId : string , sequenceName : string await createFollowUpTask ({
contactId,
type : 'call' ,
dueDate : new Date (Date .now () + 24 * 60 * 60 * 1000 ).toISOString ().split ('T' )[0 ],
note : `Reply detected on sequence "${sequenceName} ". Follow up immediately.` ,
});
}
Step 5: Set Up a Cron-Based Sync Service
import cron from 'node-cron' ;
import { pollContactChanges } from './contact-poller' ;
import { checkSequenceEngagement } from './sequence-monitor' ;
const syncState = { lastSyncAt : new Date (Date .now () - 60 * 60 * 1000 ).toISOString () };
cron.schedule ('*/5 * * * *' , async () => {
try {
const changes = await pollContactChanges (syncState);
console .log (`Sync complete: ${changes.length} changes` );
} catch (err) {
console .error ('Contact sync failed:' , err);
}
});
cron.schedule ('*/15 * * * *' , async () => {
const activeSequenceIds = ['seq-1' , 'seq-2' ];
for (const id of activeSequenceIds) {
const stats = await checkSequenceEngagement (id);
if (stats && parseInt (stats.rates .replyRate ) > 10 ) {
console .log (`High reply rate on "${stats.name} ": ${stats.rates.replyRate} ` );
}
}
});
console .log ('Apollo sync scheduler started' );
Output
Contact change poller with timestamp-based incremental sync
Contact stage tracking and updates via the Stages API
Sequence engagement monitoring with reply/bounce/open rates
Task creation API for automated follow-ups
Cron-based scheduler for periodic sync
Error Handling Issue Resolution Missed changes between polls Reduce poll interval or use sort_by_field: contact_updated_at Rate limited during polling Add backoff, reduce per_page, increase poll interval Duplicate task creation Track processed contact IDs in a Set or database Third-party webhook delays Zapier/Pipedream polling intervals vary (1-15 min on free tiers)
Resources
Next Steps Proceed to apollo-performance-tuning for optimization.
