在事件之前处理消息% ws nodejs

const WebSocket = require('ws');

const wss = new WebSocket.Server({ port: 8080 });

// 预处理函数
function preprocessMessage(message) {
    console.log('Received message:', message);
    // 这里可以添加更多的预处理逻辑，如数据验证、权限检查等
    return message; // 返回处理后的消息
}

wss.on('connection', (ws) => {
    ws.on('message', (rawMessage) => {
        try {
            let message = preprocessMessage(rawMessage);
            // 假设我们有一个处理消息的函数 handleMessage
            handleMessage(ws, message);
        } catch (error) {
            console.error('Error processing message:', error);
            ws.send('Invalid message format');
        }
    });
});

function handleMessage(ws, message) {
    // 这里是实际的消息处理逻辑
    console.log('Handling message:', message);
    ws.send('Message received and processed');
}