API Dokümantasyonu

<?php
// webhook_handler.php

header('Content-Type: application/json');

// Get the request body
$input = file_get_contents('php://input');
$data = json_decode($input, true);
// productData içindeki JSON nesnelerini nesne olarak koruyun.
$rawObject = json_decode($input);
if (is_array($data) && is_object($rawObject) && isset($rawObject->productData)) {
    $data['productData'] = $rawObject->productData;
}

// Validate JSON
if (json_last_error() !== JSON_ERROR_NONE) {
    http_response_code(400);
    echo json_encode(['error' => 'Invalid JSON']);
    exit;
}

// Validate required fields
$required_fields = ['userAccountName', 'userEmail', 'userID', 'orderID', 'productData', 'status', 'hash'];
foreach ($required_fields as $field) {
    if (!isset($data[$field])) {
        http_response_code(400);
        echo json_encode(['error' => "Missing required field: $field"]);
        exit;
    }
}

// Webhook imzası SHA-256 hex formatındadır; link oluşturma hash’i ile farklıdır.
function verifyHash($data, $receivedHash) {
    // Alan sırasını koruyun; Unicode escape edilir, / karakteri escape edilmez.
    $dataToHash = $data['userAccountName'] . $data['userEmail'] . 
                  $data['userID'] . $data['orderID'] . 
                  str_replace(chr(127), '\u007f', json_encode($data['productData'], JSON_UNESCAPED_SLASHES | JSON_THROW_ON_ERROR));
    $secretKey = getenv('KALEGAME_SECRET_KEY');
    if (!$secretKey) { throw new RuntimeException('KALEGAME_SECRET_KEY eksik'); }
    $expectedHash = hash('sha256', $dataToHash . $secretKey);
    return hash_equals($expectedHash, $receivedHash);
}

// Verify the hash
if (!is_string($data['hash']) || !verifyHash($data, $data['hash'])) {
    http_response_code(401);
    echo json_encode(['error' => 'Invalid hash']);
    exit;
}

if (!in_array($data['status'], ['success', 'failed'], true)) {
    http_response_code(400); exit;
}
if ($data['status'] === 'failed') {
    http_response_code(200); echo json_encode(['success' => true]); exit;
}
// Hash doğrulandı - burada kendi iş mantığınızı uygulayabilirsiniz
// Örneğin: database güncellemesi, email gönderimi, vb.

// Başarılı yanıt döndür
http_response_code(200);
echo json_encode([
    'success' => true,
    'message' => 'Webhook successfully verified',
    'orderID' => $data['orderID']
]);
?>

// webhook_handler.js
const express = require('express');
const crypto = require('crypto');

if (!process.env.KALEGAME_SECRET_KEY) throw new Error('KALEGAME_SECRET_KEY eksik');
const app = express();
app.use(express.json());

// Hash doğrulama için gerekli modüller

// Hash verification function
function verifyHash(data, receivedHash) {
    const dataToHash = data.userAccountName + data.userEmail + 
                      data.userID + data.orderID + 
                      JSON.stringify(data.productData).replace(/[\u007F-\uFFFF]/g, c =>
                        '\\u' + c.charCodeAt(0).toString(16).padStart(4, '0'));
    const expectedHash = crypto.createHash('sha256')
                              .update(dataToHash + process.env.KALEGAME_SECRET_KEY)
                              .digest('hex');
    if (typeof receivedHash !== 'string' || !/^[a-f0-9]{64}$/.test(receivedHash)) return false;
    return crypto.timingSafeEqual(Buffer.from(expectedHash, 'hex'), Buffer.from(receivedHash, 'hex'));
}

// Webhook endpoint
app.post('/webhook', async (req, res) => {
    try {
        const data = req.body;
        
        // Validate required fields
        const requiredFields = ['userAccountName', 'userEmail', 'userID', 'orderID', 'productData', 'status', 'hash'];
        for (const field of requiredFields) {
            if (!data[field]) {
                return res.status(400).json({ error: `Missing required field: ${field}` });
            }
        }
        
        // Verify hash
        if (!verifyHash(data, data.hash)) {
            return res.status(401).json({ error: 'Invalid hash' });
        }
        
        if (!['success', 'failed'].includes(data.status)) return res.status(400).json({ error: 'Invalid status' });
        if (data.status === 'failed') return res.json({ success: true });

        // Hash doğrulandı - burada kendi iş mantığınızı uygulayabilirsiniz
        // Örneğin: database güncellemesi, email gönderimi, vb.
        
        // Başarılı yanıt döndür
        res.json({
            success: true,
            message: 'Webhook successfully verified',
            orderID: data.orderID
        });
        
    } catch (error) {
        console.error('Webhook processing error:', error);
        res.status(500).json({ error: 'Internal server error' });
    }
});



const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
    console.log(`Webhook server running on port ${PORT}`);
});

module.exports = app;