webhooks_example.php

<?php

require_once __DIR__ . '/../../vendor/autoload.php';

use Oyi77\MetaapiCloudPhpSdk\CopyFactory;

/**
 * CopyFactory Webhooks Example
 *
 * Demonstrates how to:
 * - Create webhooks for a strategy
 * - List webhooks
 * - Update webhooks
 * - Delete webhooks
 */

$token = getenv('TOKEN') ?: '<put your token here>';
$strategyId = getenv('STRATEGY_ID') ?: '<put your strategy ID here>';

try {
    // Initialize CopyFactory API
    $copyFactory = new CopyFactory($token);

    // Create a webhook
    echo "Creating webhook for strategy {$strategyId}...\n";
    $webhook = $copyFactory->createWebhook($strategyId, [
        'url' => 'https://example.com/webhook',
        'method' => 'POST',
        'headers' => [
            'Authorization' => 'Bearer secret-token',
        ],
        'type' => 'subscriber', // 'subscriber' or 'provider'
    ]);

    if (is_array($webhook)) {
        $webhookId = $webhook['_id'] ?? $webhook['id'] ?? null;
        echo "Webhook created: {$webhookId}\n";
        print_r($webhook);
    } else {
        echo "Webhook response: {$webhook}\n";
    }
    echo "\n";

    // List all webhooks
    echo "Listing all webhooks for strategy {$strategyId}...\n";
    $webhooks = $copyFactory->webhooksWithInfiniteScroll($strategyId);

    if (is_array($webhooks)) {
        echo "Found " . count($webhooks) . " webhook(s)\n";
        foreach ($webhooks as $wh) {
            echo "  - " . ($wh['_id'] ?? $wh['id'] ?? 'unknown') . ": " . ($wh['url'] ?? 'no url') . "\n";
        }
    } else {
        echo "Webhooks response: {$webhooks}\n";
    }
    echo "\n";

    // Update webhook (if we have one)
    if (isset($webhookId)) {
        echo "Updating webhook {$webhookId}...\n";
        $updatedWebhook = $copyFactory->updateWebhook($strategyId, $webhookId, [
            'url' => 'https://example.com/webhook/updated',
            'method' => 'POST',
            'headers' => [
                'Authorization' => 'Bearer updated-token',
                'X-Custom-Header' => 'custom-value',
            ],
        ]);

        if (is_array($updatedWebhook)) {
            echo "Webhook updated successfully\n";
            print_r($updatedWebhook);
        } else {
            echo "Update response: {$updatedWebhook}\n";
        }
        echo "\n";

        // Delete webhook
        echo "Deleting webhook {$webhookId}...\n";
        $deleteResponse = $copyFactory->deleteWebhook($strategyId, $webhookId);
        echo "Webhook deleted\n";
        if (is_string($deleteResponse)) {
            echo "Response: {$deleteResponse}\n";
        }
    } else {
        echo "Skipping update/delete (no webhook ID available)\n";
    }

    echo "\nWebhook operations complete!\n";

} catch (Exception $e) {
    echo "Error: " . $e->getMessage() . "\n";
    echo $e->getTraceAsString() . "\n";
}