31 lines
838 B
JavaScript
31 lines
838 B
JavaScript
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
|
|
console.log(`Channel: ${msg.data.fromChannel}, 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.');
|
|
}); |