WebSocket API

const WebSocket = require('ws');

const ws = new WebSocket('ws://zone.test:8086/app/1');

ws.on('open', () => {
    console.log('Bağlantı kuruldu');
    ws.send(JSON.stringify({ event: 'pusher:subscribe', data: { channel: 'dialog-socket' } }));
});

ws.on('message', (data) => {
    const msg = JSON.parse(data.toString());
    if (msg.event?.startsWith('pusher:')) return;
    
    const payload = msg.data ? JSON.parse(msg.data) : {};
    
    switch(msg.event) {
        case 'exit.plate.detection':
            console.log('Çıkış:', payload.plate, payload.price + ' TL');
            break;
        case 'hgs.payment.success':
        case 'pos.payment.success':
            console.log('Ödeme OK - Bariyer aç');
            break;
        case 'hgs.payment.failed':
        case 'pos.payment.failed':
            console.log('Ödeme HATA');
            break;
    }
});

ws.on('error', (err) => console.error('Hata:', err));
ws.on('close', () => console.log('Bağlantı kapandı'));

<?php
require 'vendor/autoload.php';

use WebSocket\Client;

$client = new Client('ws://zone.test:8086/app/1');

$client->send(json_encode([
    'event' => 'pusher:subscribe',
    'data' => ['channel' => 'dialog-socket']
]));

while (true) {
    try {
        $message = $client->receive();
        $msg = json_decode($message, true);
        
        if (str_starts_with($msg['event'] ?? '', 'pusher:')) continue;
        
        $data = isset($msg['data']) ? json_decode($msg['data'], true) : [];
        
        switch ($msg['event']) {
            case 'exit.plate.detection':
                echo "Çıkış: {$data['plate']} - {$data['price']} TL\n";
                break;
            case 'hgs.payment.success':
            case 'pos.payment.success':
                echo "Ödeme OK - Bariyer aç\n";
                break;
            case 'hgs.payment.failed':
            case 'pos.payment.failed':
                echo "Ödeme HATA\n";
                break;
        }
    } catch (Exception $e) {
        echo "Hata: " . $e->getMessage() . "\n";
        break;
    }
}

using System.Net.WebSockets;
using System.Text;
using System.Text.Json;

var ws = new ClientWebSocket();
await ws.ConnectAsync(new Uri("ws://zone.test:8086/app/1"), CancellationToken.None);

var subscribe = JsonSerializer.Serialize(new { 
    @event = "pusher:subscribe", 
    data = new { channel = "dialog-socket" } 
});
await ws.SendAsync(Encoding.UTF8.GetBytes(subscribe), WebSocketMessageType.Text, true, CancellationToken.None);

var buffer = new byte[4096];
while (ws.State == WebSocketState.Open)
{
    var result = await ws.ReceiveAsync(buffer, CancellationToken.None);
    var message = Encoding.UTF8.GetString(buffer, 0, result.Count);
    var msg = JsonSerializer.Deserialize<JsonElement>(message);
    
    var eventName = msg.GetProperty("event").GetString();
    if (eventName?.StartsWith("pusher:") == true) continue;
    
    var data = msg.TryGetProperty("data", out var d) 
        ? JsonSerializer.Deserialize<JsonElement>(d.GetString() ?? "{}") 
        : new JsonElement();
    
    switch (eventName)
    {
        case "exit.plate.detection":
            Console.WriteLine($"Çıkış: {data.GetProperty("plate")} - {data.GetProperty("price")} TL");
            break;
        case "hgs.payment.success":
        case "pos.payment.success":
            Console.WriteLine("Ödeme OK - Bariyer aç");
            break;
        case "hgs.payment.failed":
        case "pos.payment.failed":
            Console.WriteLine("Ödeme HATA");
            break;
    }
}

import websocket
import json

def on_message(ws, message):
    msg = json.loads(message)
    if msg.get('event', '').startswith('pusher:'):
        return

    data = json.loads(msg.get('data', '{}')) if msg.get('data') else {}
    
    if msg['event'] == 'exit.plate.detection':
        print(f"Çıkış: {data.get('plate')} - {data.get('price')} TL")
    elif msg['event'] in ['hgs.payment.success', 'pos.payment.success']:
        print("Ödeme OK - Bariyer aç")
    elif msg['event'] in ['hgs.payment.failed', 'pos.payment.failed']:
        print("Ödeme HATA")

def on_open(ws):
    print("Bağlantı kuruldu")
    subscribe_msg = {
        "event": "pusher:subscribe",
        "data": {"channel": "dialog-socket"}
    }
    ws.send(json.dumps(subscribe_msg))

def on_error(ws, error):
    print(f"Hata: {error}")

def on_close(ws, close_status_code, close_msg):
    print("Bağlantı kapandı")

if __name__ == "__main__":
    # websocket-client
    ws_url = "ws://zone.test:8086/app/1"
    ws = websocket.WebSocketApp(ws_url,
                              on_open=on_open,
                              on_message=on_message,
                              on_error=on_error,
                              on_close=on_close)
    ws.run_forever()