Webhook Entegrasyonu

import express from 'express'
import crypto from 'crypto'
 
const app    = express()
const SECRET = process.env.SOSYALKOPRU_WEBHOOK_SECRET
 
// ⚠️ Ham body için express.raw kullanın (json() değil)
app.use('/webhooks/sosyalkopru', express.raw({ type: 'application/json' }))
 
app.post('/webhooks/sosyalkopru', (req, res) => {
  // İmzayı doğrula
  const gelen    = req.headers['x-sosyalkopru-signature'] ?? ''
  const beklenen = 'sha256=' + crypto
    .createHmac('sha256', SECRET)
    .update(req.body)
    .digest('hex')
 
  if (!crypto.timingSafeEqual(Buffer.from(gelen), Buffer.from(beklenen))) {
    return res.status(401).json({ error: 'İmza geçersiz' })
  }
 
  // Olayı işle
  const olay = JSON.parse(req.body.toString())
  console.log(`[WEBHOOK] ${olay.event}:`, olay.data?.postId)
 
  // Hemen 200 dön, işlemi arka planda yap
  res.status(200).json({ received: true })
 
  // Arka plan işlemi
  setImmediate(() => olayIisle(olay))
})
 
async function olayIisle(olay) {
  switch (olay.event) {
    case 'post.publishing':
      console.log('Yayınlanıyor:', olay.data.postId)
      break
    case 'post.published':
      console.log('Gönderi yayınlandı:', olay.data.postId)
      // Veritabanını güncelle, bildirim gönder vb.
      break
    case 'post.failed':
      console.error('Gönderi başarısız:', olay.data.postId)
      // Hata raporla, yeniden dene vb.
      break
    case 'post.scheduled':
      console.log('Gönderi planlandı:', olay.data.postId)
      break
    case 'post.updated':
      console.log('Gönderi güncellendi:', olay.data.postId)
      break
  }
}
 
app.listen(3000, () => console.log('Webhook sunucusu çalışıyor: :3000'))

import hmac
import hashlib
import os
import json
from flask import Flask, request, jsonify
from threading import Thread
 
app    = Flask(__name__)
SECRET = os.environ['SOSYALKOPRU_WEBHOOK_SECRET'].encode()
 
@app.route('/webhooks/sosyalkopru', methods=['POST'])
def webhook_al():
    # İmzayı doğrula
    imza_basligi = request.headers.get('X-SosyalKopru-Signature', '')
    payload      = request.get_data()
    beklenen     = 'sha256=' + hmac.new(SECRET, payload, hashlib.sha256).hexdigest()
 
    if not hmac.compare_digest(beklenen, imza_basligi):
        return jsonify({'error': 'İmza geçersiz'}), 401
 
    olay = request.json
 
    # Hemen 200 dön, arka planda işle
    Thread(target=olayIisle, args=(olay,), daemon=True).start()
    return jsonify({'received': True})
 
def olayIisle(olay: dict):
    event = olay.get('event')
    if event == 'post.published':
        print(f"Gönderi yayınlandı: {olay['data']['postId']}")
    elif event == 'post.failed':
        print(f"Gönderi başarısız: {olay['data']['postId']}")
 
if __name__ == '__main__':
    app.run(port=3000)

<?php
 
$secret = getenv('SOSYALKOPRU_WEBHOOK_SECRET');
 
// Ham body oku
$payload = file_get_contents('php://input');
$imza    = $_SERVER['HTTP_X_SOSYALKOPRU_SIGNATURE'] ?? '';
 
// İmzayı doğrula
$beklenen = 'sha256=' . hash_hmac('sha256', $payload, $secret);
if (!hash_equals($beklenen, $imza)) {
    http_response_code(401);
    echo json_encode(['error' => 'İmza geçersiz']);
    exit;
}
 
// Hemen 200 dön
http_response_code(200);
echo json_encode(['received' => true]);
 
// Flush et ve işle
if (function_exists('fastcgi_finish_request')) {
    fastcgi_finish_request();
}
 
$olay = json_decode($payload, true);
switch ($olay['event']) {
    case 'post.published':
        error_log("Gönderi yayınlandı: {$olay['data']['postId']}");
        break;
    case 'post.failed':
        error_log("Gönderi başarısız: {$olay['data']['postId']}");
        break;
}