connection_request.sent

{
  "eventId": "evt_1708456789123_abc123def",
  "eventType": "connection_request.sent",
  "timestamp": "2024-02-24T10:30:00.000Z",
  "workspaceId": "ws_abc123xyz",
  "data": {
    "leadId": "lead_abc123",
    "campaignId": "camp_xyz789",
    "linkedinUrl": "https://www.linkedin.com/in/john-doe",
    "senderId": "sender_def456",
    "note": "Hi John, I noticed we share an interest in SaaS growth..."
  }
}

app.post('/webhooks/sendpilot', async (req, res) => {
  const event = req.body;
  
  if (event.eventType === 'connection_request.sent') {
    const { leadId, campaignId, linkedinUrl, note } = event.data;
    
    // Log to CRM
    await crm.logActivity({
      leadId,
      type: 'connection_request_sent',
      message: note || 'Connection request sent (no note)',
      campaignId
    });
    
    // Schedule a follow-up task if no response in 7 days
    await taskQueue.schedule({
      type: 'check_connection_status',
      leadId,
      executeAt: new Date(Date.now() + 7 * 24 * 60 * 60 * 1000)
    });
    
    console.log(`Connection request sent to ${linkedinUrl}`);
  }
  
  res.status(200).send('OK');
});