Skip to main content Inicio Creadores jeremylongshore tons-of-skills-marketplace instantly-webhooks-events
instantly-webhooks-events Implement Instantly.ai webhook event handling with real API v2 event types.
Use when setting up webhook endpoints, processing email events,
or building CRM sync pipelines from Instantly notifications.
Trigger with phrases like "instantly webhook", "instantly events",
"instantly webhook handler", "handle instantly events", "instantly notifications".
Ir a la instalación Skills Marketplace Descubre y explora habilidades de IA creadas por la comunidad.
Instalar con Codex o Claude Copia este prompt, pégalo en Codex, Claude u otro asistente, y deja que revise la página de la skill y la instale por ti.
Mostrar detalles del prompt Un comando directo omite el prompt de revisión. Revisa el origen antes de ejecutarlo.
npx skills add https://github.com/jeremylongshore/tons-of-skills-marketplace --skill instantly-webhooks-eventsEl comando permanece en una sola línea. Desplázate horizontalmente para revisarlo antes de copiarlo.
¿Prefieres una copia local? Descarga los archivos que SkillsMP tiene disponibles ahora.
Descargar Zip Descargando... Más de este repositorio langchain-deploy-integration Deploy a LangChain 1.0 / LangGraph 1.0 app to Cloud Run, Vercel, or LangServe correctly — with timeouts sized for chain length, cold-start mitigation, SSE anti-buffering headers, and Secret Manager over .env. Use when prepping a first production deploy, debugging a stream that hangs behind a proxy, or diagnosing p99 latency spikes. Trigger with "langchain deploy", "langchain cloud run", "langchain vercel python", "langchain langserve", or "langchain docker".
langchain-langgraph-agents Build a correct LangGraph 1.0 ReAct agent with create_react_agent — typed tools, error propagation, recursion caps, and stop conditions that actually stop. Use when writing a first tool-calling agent, migrating from AgentExecutor or initialize_agent, or diagnosing an agent that loops on vague prompts. Trigger with "langgraph agent", "create_react_agent", "langgraph tool calling", "AgentExecutor migration", or "agent loop cost".
langchain-langgraph-human-in-loop Build LangGraph 1.0 human-in-the-loop approval flows with interrupt_before /
interrupt_after and Command(resume=...) — JSON-serializable state, clean
resume semantics, and UI wiring for approval decisions. Use when adding an
approval gate before an expensive tool call, wiring a Slack/web UI for agent
approvals, or debugging a graph that crashes on interrupt.
Trigger with "langgraph human in loop", "langgraph interrupt_before",
"langgraph approval flow", "Command resume", "langgraph HITL".
name instantly-webhooks-events description Implement Instantly.ai webhook event handling with real API v2 event types.
Use when setting up webhook endpoints, processing email events,
or building CRM sync pipelines from Instantly notifications.
Trigger with phrases like "instantly webhook", "instantly events",
"instantly webhook handler", "handle instantly events", "instantly notifications".
allowed-tools Read, Write, Edit, Bash(curl:*), Bash(npm:*), Grep version 1.12.0 license MIT author Jeremy Longshore <jeremy@intentsolutions.io> tags ["saas","instantly","webhooks","events","crm-sync"] compatibility Designed for Claude Code
Instantly Webhooks & Events
Overview
Handle Instantly API v2 webhooks for real-time email outreach event notifications. Instantly fires events when emails are sent, opened, clicked, replied to, or bounced, and when leads change interest status. Webhooks require Hypergrowth plan ($97/mo) or higher. Delivery retries: 3 times within 30 seconds on failure.
Prerequisites
Instantly Hypergrowth plan or higher (required for webhooks)
API key with all:all or appropriate webhook scopes
Public HTTPS endpoint for receiving webhook payloads
INSTANTLY_API_KEY environment variable set
Webhook Event Types
Event Type Trigger Key Payload Fields email_sentEmail delivered to recipient lead_email, campaign_id, stepemail_openedRecipient opens email lead_email, campaign_id, open_countemail_link_clickedRecipient clicks a link lead_email, campaign_id, link_urlreply_receivedRecipient replies lead_email, campaign_id, reply_textemail_bouncedEmail bounces lead_email, bounce_type, reasonlead_unsubscribedLead unsubscribes lead_email, campaign_idcampaign_completedAll leads in campaign processed campaign_id, campaign_nameaccount_errorSending account error email, error_type
lead_interestedLead marked interested lead_email, campaign_id
lead_not_interestedLead marked not interested lead_email, campaign_id
lead_meeting_bookedMeeting booked lead_email, campaign_id
lead_meeting_completedMeeting completed lead_email
lead_closedLead closed/won lead_email
lead_out_of_officeOOO reply detected lead_email
lead_wrong_personWrong person response lead_email
all_eventsSubscribe to everything Varies by event
Instructions
Step 1: Create Webhook via API import { instantly } from "./src/instantly" ;
async function createWebhook (const webhook = await instantly<{ id : string ; name : string }>("/webhooks" , {
method : "POST" ,
body : JSON .stringify ({
name : "CRM Sync — Replies & Meetings" ,
target_hook_url : "https://api.yourapp.com/webhooks/instantly" ,
event_type : "reply_received" ,
headers : {
"X-Webhook-Secret" : process.env .INSTANTLY_WEBHOOK_SECRET ,
},
}),
});
console .log (`Webhook created: ${webhook.id} ` );
for (const event of ["lead_interested" , "lead_meeting_booked" , "email_bounced" ]) {
await instantly ("/webhooks" , {
method : "POST" ,
body : JSON .stringify ({
name : `CRM Sync — ${event} ` ,
target_hook_url : "https://api.yourapp.com/webhooks/instantly" ,
event_type : event,
headers : { "X-Webhook-Secret" : process.env .INSTANTLY_WEBHOOK_SECRET },
}),
});
}
await instantly ("/webhooks" , {
method : "POST" ,
body : JSON .stringify ({
name : "All Events Monitor" ,
target_hook_url : "https://api.yourapp.com/webhooks/instantly/all" ,
event_type : "all_events" ,
headers : { "X-Webhook-Secret" : process.env .INSTANTLY_WEBHOOK_SECRET },
}),
});
}
Step 2: Build Event Handler import express from "express" ;
const app = express ();
app.use (express.json ());
app.post ("/webhooks/instantly" , async (req, res) => {
if (req.headers ["x-webhook-secret" ] !== process.env .INSTANTLY_WEBHOOK_SECRET ) {
return res.status (401 ).json ({ error : "Unauthorized" });
}
res.status (200 ).json ({ received : true });
const { event_type, data } = req.body ;
console .log (`Event: ${event_type} ` , JSON .stringify (data).slice (0 , 300 ));
try {
await routeEvent (event_type, data);
} catch (err) {
console .error (`Failed to process ${event_type} :` , err);
}
});
async function routeEvent (eventType : string , data : any switch (eventType) {
case "reply_received" :
await handleReply (data);
break ;
case "email_bounced" :
await handleBounce (data);
break ;
case "lead_interested" :
case "lead_meeting_booked" :
case "lead_closed" :
await handlePositiveOutcome (eventType, data);
break ;
case "lead_unsubscribed" :
await handleUnsubscribe (data);
break ;
case "campaign_completed" :
await handleCampaignComplete (data);
break ;
case "account_error" :
await handleAccountError (data);
break ;
default :
console .log (`Unhandled event: ${eventType} ` );
}
}
Step 3: Implement Event Handlers async function handleReply (data : {
lead_email: string ;
campaign_id: string ;
reply_text: string ;
}console .log (`Reply from ${data.lead_email} in campaign ${data.campaign_id} ` );
await crmClient.updateContact (data.lead_email , {
status : "replied" ,
lastReply : data.reply_text ,
lastActivity : new Date (),
});
await slackNotify ("#sales-replies" , {
text : `Reply from ${data.lead_email} :\n${data.reply_text.slice(0 , 500 )} ` ,
});
}
async function handleBounce (data : {
lead_email: string ;
bounce_type: string ;
reason: string ;
}console .log (`Bounce: ${data.lead_email} (${data.bounce_type} )` );
if (data.bounce_type === "hard" ) {
await instantly ("/block-lists-entries" , {
method : "POST" ,
body : JSON .stringify ({ bl_value : data.lead_email }),
});
console .log (`Added ${data.lead_email} to block list` );
}
}
async function handlePositiveOutcome (
eventType : string ,
data : { lead_email: string ; campaign_id: string }
) {
const statusMap : Record <string , string > = {
lead_interested : "interested" ,
lead_meeting_booked : "meeting_scheduled" ,
lead_closed : "closed_won" ,
};
await crmClient.updateContact (data.lead_email , {
status : statusMap[eventType] || eventType,
lastActivity : new Date (),
});
if (eventType === "lead_meeting_booked" ) {
await slackNotify ("#sales-wins" , {
text : `Meeting booked with ${data.lead_email} !` ,
});
}
}
async function handleUnsubscribe (data : { lead_email: string }await instantly ("/block-lists-entries" , {
method : "POST" ,
body : JSON .stringify ({ bl_value : data.lead_email }),
});
console .log (`Unsubscribed + blocked: ${data.lead_email} ` );
}
async function handleCampaignComplete (data : { campaign_id: string }const analytics = await instantly (`/campaigns/analytics?id=${data.campaign_id} ` );
console .log (`Campaign complete:` , analytics);
}
async function handleAccountError (data : { email: string ; error_type: string }console .error (`Account error: ${data.email} — ${data.error_type} ` );
await slackNotify ("#ops-alerts" , {
text : `Instantly account error: ${data.email} \nType: ${data.error_type} ` ,
});
}
Step 4: Manage Webhooks
async function listWebhooks (const webhooks = await instantly<Array <{
id : string ; name : string ; event_type : string ; target_hook_url : string ;
}>>("/webhooks?limit=50" );
for (const w of webhooks) {
console .log (`${w.id} : ${w.name} [${w.event_type} ] -> ${w.target_hook_url} ` );
}
}
async function testWebhook (webhookId : string await instantly (`/webhooks/${webhookId} /test` , { method : "POST" });
}
async function resumeWebhook (webhookId : string await instantly (`/webhooks/${webhookId} /resume` , { method : "POST" });
}
async function checkDeliveryHealth (const summary = await instantly ("/webhook-events/summary" );
console .log ("Webhook delivery summary:" , summary);
const byDate = await instantly ("/webhook-events/summary-by-date" );
console .log ("By date:" , byDate);
}
async function deleteWebhook (webhookId : string await instantly (`/webhooks/${webhookId} ` , { method : "DELETE" });
}
Key API Endpoints Method Path Purpose POST/webhooksCreate webhook subscription GET/webhooksList webhooks PATCH/webhooks/{id}Update webhook DELETE/webhooks/{id}Delete webhook POST/webhooks/{id}/testSend test event POST/webhooks/{id}/resumeResume paused webhook GET/webhook-eventsList webhook events GET/webhook-events/summaryDelivery summary
Error Handling Issue Cause Solution No events delivered Webhook not registered or paused Check GET /webhooks, resume if paused Duplicate events Retry delivery Deduplicate by event ID + timestamp Webhook paused automatically Too many delivery failures Fix endpoint, then POST /webhooks/{id}/resume 30s timeout Handler takes too long Return 200 immediately, process async Missing event_type Using custom label events Check custom_interest_value field
Resources
Next Steps For performance optimization, see instantly-performance-tuning.
