Real-Time Sync
& Webhooks

// Express.js webhook endpoint
app.post('/webhooks/unipile', (req, res) => {
  const { event, data, account_id } = req.body;
  
  switch(event) {
    case 'message.created':
      notifyUser(data.message);
      break;
    case 'email.received':
      syncInbox(data.email);
      break;
    case 'event.created':
      updateCalendar(data.event);
      break;
  }
  
  res.status(200).send('OK');
});

# Flask webhook endpoint
@app.route('/webhooks/unipile', methods=['POST'])
def handle_webhook():
    payload = request.get_json()
    event = payload['event']
    data = payload['data']
    
    if event == 'message.created':
        notify_user(data['message'])
    elif event == 'email.received':
        sync_inbox(data['email'])
    elif event == 'event.created':
        update_calendar(data['event'])
    
    return 'OK', 200

// PHP webhook endpoint
$payload = json_decode(
    file_get_contents('php://input'), true
);
$event = $payload['event'];
$data = $payload['data'];

switch($event) {
    case 'message.created':
        notifyUser($data['message']);
        break;
    case 'email.received':
        syncInbox($data['email']);
        break;
    case 'event.created':
        updateCalendar($data['event']);
        break;
}

http_response_code(200);
echo 'OK';

{
  "event": "message.created",
  "timestamp": "2025-01-09T14:32:00Z",
  "account_id": "acc_01jgpb44tjf...",
  "data": {
    "id": "msg_xyz123",
    "provider": "linkedin",
    "sender": {
      "name": "Sarah Johnson",
      "profile_url": "https://..."
    },
    "content": "Thanks for connecting!",
    "thread_id": "thread_abc"
  }
}