const WebSocket = require('ws');

const wsUrl = 'wss://iem-alerter.ko4wal.radio/iem'; // Replace with actual WebSocket URL

const ws = new WebSocket(wsUrl,  {headers: {
    'User-Agent': 'iem-debugger/1.0',
}});

ws.on('open', () => {
    console.log('WebSocket connection opened.');
    ws.send(JSON.stringify({"type":"subscribe"}));
});

ws.on('message', (data) => {
    console.log("msg rx")
    try {
        const msg = JSON.parse(data);
        // Assuming the message has 'channel' and 'product_id' fields
        if (msg.channel && msg.product_data) {
            console.log(`Channel: ${msg.channel}, Product ID: ${msg.product_data}`);
        }
    } catch (err) {
        console.error('Error parsing message:', err);
    }
});

ws.on('error', (err) => {
    console.error('WebSocket error:', err);
});

ws.on('close', () => {
    console.log('WebSocket connection closed.');
});