Christopher Cookman
f865daaf3b
Some checks are pending
ptero-push / build (push) Waiting to run
Reviewed-on: #1 Co-authored-by: ChrisChrome <chris@chrischro.me> Co-committed-by: ChrisChrome <chris@chrischro.me>
34 lines
769 B
JavaScript
34 lines
769 B
JavaScript
const WebSocket = require('ws');
|
|
const config = require('./config.json');
|
|
|
|
const ws = new WebSocket(
|
|
config.WS_URL || "wss://iembot.dev/iem",
|
|
{
|
|
headers: {
|
|
"user-agent": "IEM-Alerter-DiscordBot/1.0 (+https://git.chrischro.me/iem-alerter/discord-bot; contact: me@ko4wal.radio)"
|
|
}
|
|
}
|
|
);
|
|
|
|
ws.on('open', () => {
|
|
console.log('Connected to WebSocket');
|
|
ws.send(JSON.stringify({ type: 'subscribe', channel: '*' }));
|
|
});
|
|
|
|
ws.on('message', (rawData) => {
|
|
try {
|
|
const data = JSON.parse(rawData);
|
|
console.log(JSON.stringify(data, null, 2));
|
|
} catch (err) {
|
|
console.log('Raw (non-JSON):', rawData.toString());
|
|
}
|
|
});
|
|
|
|
ws.on('close', () => {
|
|
console.log('WebSocket connection closed.');
|
|
});
|
|
|
|
ws.on('error', (err) => {
|
|
console.error('WebSocket error:', err);
|
|
});
|