Webhook Kullanım Rehberi

# Uç noktanız yönlendirme (3xx) dönmemeli; Paraşüt yönlendirmeleri takip etmez.
curl -sS -o /dev/null -w "%{http_code}\n" -X POST https://website.com/webhooks \
  -H "Content-Type: application/json" \
  -d '{}'
# Beklenen: 3xx dışında bir kod (X-Client-Key olmadığı için ör. 401)

openssl rand -hex 32
# Örnek çıktı (64 karakter):
# 3f9a1c27b84e4d6a9e0f5b2c7d18a4e6f0b3c9d2e5a7184b6c0d2f4e8a1b3c5d

# Node.js ile:
node -e "console.log(require('crypto').randomBytes(32).toString('hex'))"

curl -X POST https://api.parasut.com/v4/{company_id}/webhooks \
  -H "Authorization: Bearer ACCESS_TOKEN" \
  -H "Content-Type: application/vnd.api+json" \
  -d '{
    "data": {
      "type": "webhook",
      "attributes": {
        "model": "contact",
        "action": "update",
        "uri": "https://website.com/webhooks",
        "client_key": "3f9a1c27b84e4d6a9e0f5b2c7d18a4e6f0b3c9d2e5a7184b6c0d2f4e8a1b3c5d"
      }
    }
  }'

{
  "data": {
    "id": "42",
    "type": "webhook",
    "attributes": {
      "model": "contact",
      "action": "update",
      "uri": "https://website.com/webhooks",
      "company_id": 123,
      "created_at": "2025-01-10T10:00:00.000Z",
      "updated_at": "2025-01-10T10:00:00.000Z"
    }
  }
}

POST /webhooks HTTP/1.1
Host: website.com
Content-Type: application/json
X-Client-Key: <client_key>

{
  "event_id": "9f2c4e7a1b3d5f60718293a4b5c6d7e8",
  "company_id": 123,
  "resource": "contact",
  "action": "update",
  "event_date": "2025-01-10T10:55:00Z",
  "data": {
    "id": 456,
    "company_id": 123,
    "created_at": "2025-01-09T08:00:00.000Z",
    "updated_at": "2025-01-10T10:54:59.123Z",
    "data": { "id": "456", "type": "contacts", "attributes": { "name": "..." } }
  }
}

const crypto = require('crypto');
const express = require('express');

const app = express();
// Webhook'u oluştururken gönderdiğiniz client_key; güvenli bir yerden okuyun.
const CLIENT_KEY = Buffer.from(process.env.WEBHOOK_CLIENT_KEY || '');

function hasValidClientKey(req) {
  const received = Buffer.from(req.get('X-Client-Key') || '');
  // timingSafeEqual farklı uzunluklarda hata fırlatır; önce uzunlukları karşılaştırın.
  if (CLIENT_KEY.length !== 64 || received.length !== CLIENT_KEY.length) return false;
  return crypto.timingSafeEqual(received, CLIENT_KEY);
}

// jobs: kendi kalıcı kuyruğunuz (ör. bir veritabanı tablosu ya da mesaj kuyruğu)
// Varsayılan 100kb sınırı büyük gövdelerde 413 döner; 413 yeniden denenmez.
app.post('/webhooks', express.json({ limit: '5mb' }), async (req, res) => {
  if (!hasValidClientKey(req)) {
    return res.sendStatus(401); // Önerimizdir; durum kodu belirtilmemiştir.
  }
  await jobs.enqueue(req.body); // Kısa sürmeli: event'i yalnızca kuyruğa yazın.
  res.sendStatus(200);          // Hemen 2xx dönün (5. adım).
});

// Kuyruktaki event'leri HTTP isteğinden bağımsız, ayrı bir süreçte işleyin.
jobs.process(async (event) => {
  await handleEvent(event); // Tekrar ve sıra kontrolü: 6. adım
});

async function handleEvent(event) {
  // event_id webhook başınadır; firma + model + action ile birlikte saklayın.
  const eventKey = [event.company_id, event.resource, event.action, event.event_id].join(':');

  // 1) Tekrar: aynı event_id daha önce işlendiyse atlayın.
  if (await db.processedEvents.has(eventKey)) return;

  // 2) Sıra: aynı kaydı resource + data.id ile bulun.
  const key = event.resource + ':' + event.data.id;
  const record = await db.records.get(key);

  if (record && record.deleted) {
    // Silinmiş kayıt için sonradan gelen create/update işlenmez.
  } else if (event.action === 'delete') {
    await db.records.set(key, { deleted: true });
  } else if (!record || Date.parse(event.data.updated_at) >= Date.parse(record.updated_at)) {
    // updated_at değeri daha eski olan isteği uygulamayın.
    await db.records.set(key, { updated_at: event.data.updated_at, data: event.data });
  }

  await db.processedEvents.add(eventKey);
}

curl -X GET https://api.parasut.com/v4/{company_id}/contacts/{id} \
  -H "Authorization: Bearer ACCESS_TOKEN"

curl -X GET https://api.parasut.com/v4/{company_id}/webhooks \
  -H "Authorization: Bearer ACCESS_TOKEN"

curl -X GET https://api.parasut.com/v4/{company_id}/webhooks/{id} \
  -H "Authorization: Bearer ACCESS_TOKEN"

curl -X PATCH https://api.parasut.com/v4/{company_id}/webhooks/{id} \
  -H "Authorization: Bearer ACCESS_TOKEN" \
  -H "Content-Type: application/vnd.api+json" \
  -d '{
    "data": {
      "type": "webhook",
      "attributes": {
        "client_key": "72dd4f0ed26ed1e46303a06fb37b856e4df9276490fe18ac97ad3268229c9e38"
      }
    }
  }'

curl -X DELETE https://api.parasut.com/v4/{company_id}/webhooks/{id} \
  -H "Authorization: Bearer ACCESS_TOKEN"
# Başarılı yanıt: 204 No Content (gövde yok)