fm-dx-webserver/server/stream/ws.js

const WebSocket = require('ws');
const audio_pipe = require('./index.js');
const storage = require('../storage');

const audioWss = new WebSocket.Server({ noServer: true, skipUTF8Validation: true });

audio_pipe.on('data', (chunk) => {
    audioWss.clients.forEach((client) => {
        if (client.readyState === WebSocket.OPEN) client.send(chunk, {binary: true, compress: false});
    });
});

audio_pipe.on('end', () => {
    audioWss.clients.forEach((client) => client.close(1001, "Audio stream ended"));
});

storage.websocket_delegation.set("/audio", audioWss);