API Webhooks

<?php

$accessToken = 'YOUR_ACCESS_TOKEN';
$baseUrl = 'https://my.sepay.vn/api/v1/webhooks';

// Hàm lấy danh sách webhooks
function getWebhooks($accessToken, $filters = []) {
    global $baseUrl;
    
    $queryString = http_build_query($filters);
    $url = $queryString ? "$baseUrl?$queryString" : $baseUrl;
    
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $accessToken
    ]);
    
    $response = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    
    if ($status == 200) {
        return json_decode($response, true);
    } else {
        return ['error' => $status, 'message' => $response];
    }
}

// Hàm lấy chi tiết webhook
function getWebhookDetails($accessToken, $webhookId) {
    global $baseUrl;
    
    $ch = curl_init("$baseUrl/$webhookId");
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $accessToken
    ]);
    
    $response = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    
    if ($status == 200) {
        return json_decode($response, true);
    } else {
        return ['error' => $status, 'message' => $response];
    }
}

// Hàm tạo webhook mới
function createWebhook($accessToken, $data) {
    global $baseUrl;
    
    $ch = curl_init($baseUrl);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $accessToken,
        'Content-Type: application/json'
    ]);
    
    $response = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    
    return json_decode($response, true);
}

// Hàm cập nhật webhook
function updateWebhook($accessToken, $webhookId, $data) {
    global $baseUrl;
    
    $ch = curl_init("$baseUrl/$webhookId");
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $accessToken,
        'Content-Type: application/json'
    ]);
    
    $response = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    
    return json_decode($response, true);
}

// Hàm xóa webhook
function deleteWebhook($accessToken, $webhookId) {
    global $baseUrl;
    
    $ch = curl_init("$baseUrl/$webhookId");
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $accessToken
    ]);
    
    $response = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    
    return json_decode($response, true);
}

// Ví dụ sử dụng
$webhooks = getWebhooks($accessToken, ['active' => 1]);
$webhookDetails = getWebhookDetails($accessToken, 23);

// Tạo webhook mới
$newWebhook = createWebhook($accessToken, [
    'bank_account_id' => 19,
    'name' => 'Tích hợp với shop online',
    'event_type' => 'In_only',
    'authen_type' => 'Api_Key',
    'webhook_url' => 'https://example.com/webhook/payment',
    'is_verify_payment' => 1,
    'skip_if_no_code' => 1,
    'active' => 1,
    'api_key' => 'a7c3b4e5f6a7b8c9d0e1f2a3b4c5d6e7',
    'request_content_type' => 'Json'
]);

// Cập nhật webhook
$updateResult = updateWebhook($accessToken, 23, [
    'active' => 0
]);

// Xóa webhook
$deleteResult = deleteWebhook($accessToken, 23);

const accessToken = 'YOUR_ACCESS_TOKEN';
const baseUrl = 'https://my.sepay.vn/api/v1/webhooks';

// Hàm lấy danh sách webhooks
async function getWebhooks(filters = {}) {
    try {
        // Tạo query string từ filters
        const queryParams = new URLSearchParams();
        for (const [key, value] of Object.entries(filters)) {
            if (value !== undefined && value !== null) {
                queryParams.append(key, value);
            }
        }
        
        const url = queryParams.toString() 
            ? `${baseUrl}?${queryParams.toString()}` 
            : baseUrl;
        
        const response = await fetch(url, {
            headers: {
                'Authorization': `Bearer ${accessToken}`
            }
        });
        
        if (!response.ok) {
            throw new Error(`HTTP error! Status: ${response.status}`);
        }
        
        return await response.json();
    } catch (error) {
        console.error('Error fetching webhooks:', error.message);
        throw error;
    }
}

// Hàm lấy chi tiết webhook
async function getWebhookDetails(webhookId) {
    try {
        const response = await fetch(`${baseUrl}/${webhookId}`, {
            headers: {
                'Authorization': `Bearer ${accessToken}`
            }
        });
        
        if (!response.ok) {
            throw new Error(`HTTP error! Status: ${response.status}`);
        }
        
        return await response.json();
    } catch (error) {
        console.error(`Error fetching webhook ${webhookId}:`, error.message);
        throw error;
    }
}

// Hàm tạo webhook mới
async function createWebhook(webhookData) {
    try {
        const response = await fetch(baseUrl, {
            method: 'POST',
            headers: {
                'Authorization': `Bearer ${accessToken}`,
                'Content-Type': 'application/json'
            },
            body: JSON.stringify(webhookData)
        });
        
        if (!response.ok) {
            throw new Error(`HTTP error! Status: ${response.status}`);
        }
        
        return await response.json();
    } catch (error) {
        console.error('Error creating webhook:', error.message);
        throw error;
    }
}

// Hàm cập nhật webhook
async function updateWebhook(webhookId, webhookData) {
    try {
        const response = await fetch(`${baseUrl}/${webhookId}`, {
            method: 'PUT',
            headers: {
                'Authorization': `Bearer ${accessToken}`,
                'Content-Type': 'application/json'
            },
            body: JSON.stringify(webhookData)
        });
        
        if (!response.ok) {
            throw new Error(`HTTP error! Status: ${response.status}`);
        }
        
        return await response.json();
    } catch (error) {
        console.error(`Error updating webhook ${webhookId}:`, error.message);
        throw error;
    }
}

// Hàm xóa webhook
async function deleteWebhook(webhookId) {
    try {
        const response = await fetch(`${baseUrl}/${webhookId}`, {
            method: 'DELETE',
            headers: {
                'Authorization': `Bearer ${accessToken}`
            }
        });
        
        if (!response.ok) {
            throw new Error(`HTTP error! Status: ${response.status}`);
        }
        
        return await response.json();
    } catch (error) {
        console.error(`Error deleting webhook ${webhookId}:`, error.message);
        throw error;
    }
}

// Ví dụ sử dụng
async function exampleUsage() {
    try {
        // Lấy danh sách webhooks
        const webhooks = await getWebhooks({active: 1});
        console.log('Webhooks:', webhooks);
        
        // Lấy chi tiết webhook
        const webhookDetails = await getWebhookDetails(23);
        console.log('Webhook details:', webhookDetails);
        
        // Tạo webhook mới
        const newWebhook = await createWebhook({
            bank_account_id: 19,
            name: 'Tích hợp với shop online',
            event_type: 'In_only',
            authen_type: 'Api_Key',
            webhook_url: 'https://example.com/webhook/payment',
            is_verify_payment: 1,
            skip_if_no_code: 1,
            active: 1,
            api_key: 'a7c3b4e5f6a7b8c9d0e1f2a3b4c5d6e7',
            request_content_type: 'Json'
        });
        console.log('New webhook created:', newWebhook);
        
        // Cập nhật webhook
        const updateResult = await updateWebhook(23, {
            active: 0
        });
        console.log('Update result:', updateResult);
        
        // Xóa webhook
        const deleteResult = await deleteWebhook(23);
        console.log('Delete result:', deleteResult);
    } catch (error) {
        console.error('Example usage error:', error);
    }
}

exampleUsage();