websocket.php

<?php

declare(strict_types=1);

/**
 * WebSocket gerçek zamanlı örnek.
 *
 * Çalıştırma:
 *   ALTINAPI_KEY=hapi_xxx php examples/websocket.php
 */

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

use Altinapi\AltinapiClient;

$apiKey = getenv('ALTINAPI_KEY');
if ($apiKey === false || $apiKey === '') {
    fwrite(STDERR, "ALTINAPI_KEY environment değişkeni eksik\n");
    exit(1);
}

$client = new AltinapiClient(['apiKey' => $apiKey]);

$client->on('connect', function () {
    echo "✅ altinapi WebSocket'e bağlandı\n";
});

$client->on('prices:snapshot', function (array $fiyatlar) {
    echo "\n📸 Snapshot alındı (" . count($fiyatlar) . " sembol)\n";
    foreach (array_slice($fiyatlar, 0, 5) as $f) {
        printf("  %-15s %s / %s\n", $f['symbol'] ?? '?', $f['bid'] ?? '?', $f['ask'] ?? '?');
    }
});

$client->on('prices:update', function (array $guncellemeler) {
    foreach ($guncellemeler as $f) {
        $saat = date('H:i:s');
        printf("[%s] %-15s alış=%s satış=%s\n",
            $saat,
            $f['symbol'] ?? '?',
            $f['bid'] ?? '?',
            $f['ask'] ?? '?'
        );
    }
});

$client->on('data:stale', function () {
    echo "⚠️  Kaynak bağlantısı koptu — fiyatlar eski olabilir\n";
});

$client->on('data:live', function () {
    echo "✅ Kaynak yeniden bağlandı\n";
});

$client->on('connect_error', function (\Throwable $err) {
    fwrite(STDERR, "Bağlantı hatası: {$err->getMessage()}\n");
});

// Ctrl+C ile çıkış için
pcntl_signal(SIGINT, function () use ($client) {
    echo "\n👋 Kapanıyor...\n";
    $client->disconnect();
    exit(0);
});

echo "🔌 altinapi'ye bağlanılıyor... (Ctrl+C ile çıkış)\n";
$client->connect();
$client->subscribe(['USDTRY', 'EURTRY', 'ALTIN', 'CEYREK_YENI']);
echo "📡 Abone olundu: USDTRY, EURTRY, ALTIN, CEYREK_YENI\n";

// 60 saniye boyunca dinle
$client->listen(60);
$client->disconnect();