مستندات اتصال

Accept: application/json
X-SOCKET-KEY: {YOUR_ACCESS_KEY}

{
  "products": [
    {
      "product_id": 12,
      "product_name": "طلا ۱۸ عیار",
      "buy": {
        "p": 789600000,
        "v": 28835,
        "e": 1785185236,
        "r": 90,
        "t": "u"
      },
      "sell": {
        "p": 791000000,
        "v": 28836,
        "e": 1785185236,
        "r": 90,
        "t": "u"
      }
    }
  ]
}

use Illuminate\Support\Facades\Http;

$snapshot = Http::withHeaders([
    'Accept' => 'application/json',
    'X-SOCKET-KEY' => env('GOLD_PRICE_ACCESS_KEY'),
])->get(config('services.gold.prices_url'))
  ->throw()
  ->json();

foreach ($snapshot['products'] as $row) {
    $productId = $row['product_id'];
    $productName = $row['product_name'] ?? '';

    $buy = $row['buy'] ?? [];
    $sell = $row['sell'] ?? [];
}

use Illuminate\Support\Facades\Http;

$auth = Http::withHeaders([
    'Accept' => 'application/json',
    'X-SOCKET-KEY' => env('GOLD_PRICE_ACCESS_KEY'),
])->asForm()->post(config('services.gold.auth_url'), [
    'socket_id' => $socketId,
    'channel_name' => config('services.gold.channel'),
])->throw()->json('auth');

{
  "product_id": 12,
  "price_type": "buy",
  "p": 789600000,
  "v": 28835,
  "e": 1785185236,
  "r": 90,
  "t": "u"
}

use Illuminate\Support\Facades\Http;
use WebSocket\Client;

$host = config('services.gold.pusher_host');
$port = config('services.gold.pusher_port', 443);
$appKey = config('services.gold.pusher_app_key');
$channel = config('services.gold.channel');
$accessKey = env('GOLD_PRICE_ACCESS_KEY');

$wsUrl = sprintf(
    'wss://%s:%s/app/%s?protocol=7&client=php&version=1.0&flash=false',
    $host,
    $port,
    $appKey
);

$backoff = 1;

while (true) {
    try {
        $client = new Client($wsUrl, ['timeout' => 30, 'filter' => ['text']]);

        $established = json_decode($client->receive(), true);
        $socketId = json_decode($established['data'] ?? '{}', true)['socket_id'] ?? null;

        if (! is_string($socketId) || $socketId === '') {
            throw new RuntimeException('socket_id missing');
        }

        $auth = Http::withHeaders([
            'Accept' => 'application/json',
            'X-SOCKET-KEY' => $accessKey,
        ])->asForm()->post(config('services.gold.auth_url'), [
            'socket_id' => $socketId,
            'channel_name' => $channel,
        ])->throw()->json('auth');

        $client->text(json_encode([
            'event' => 'pusher:subscribe',
            'data' => ['channel' => $channel, 'auth' => $auth],
        ]));

        Http::withHeaders([
            'Accept' => 'application/json',
            'X-SOCKET-KEY' => $accessKey,
        ])->get(config('services.gold.prices_url'))->throw();

        $backoff = 1;

        while (true) {
            $message = json_decode($client->receive(), true);
            $event = $message['event'] ?? '';

            if ($event === 'pusher:ping') {
                $client->text(json_encode(['event' => 'pusher:pong', 'data' => []]));
                continue;
            }

            if ($event !== 'external.price.changed') {
                continue;
            }

            $payload = is_string($message['data'] ?? null)
                ? json_decode($message['data'], true)
                : ($message['data'] ?? []);

            // اینجا payload را روی دفتر قیمت product_id / price_type اعمال کنید.
        }
    } catch (Throwable $e) {
        report($e);
        sleep($backoff);
        $backoff = min(30, $backoff * 2);
    }
}