如何检测MessageActivityAsync上的活动对话

// 建立WebSocket连接
const socket = new WebSocket('wss://example.com/socket');

// 监听连接打开事件
socket.addEventListener('open', (event) => {
    console.log('WebSocket连接已打开');
});

// 监听消息接收事件
socket.addEventListener('message', (event) => {
    const message = JSON.parse(event.data);
    if (message.type === 'MessageActivityAsync') {
        console.log('检测到活动对话:', message.content);
        // 处理活动对话的逻辑
    }
});

// 监听连接关闭事件
socket.addEventListener('close', (event) => {
    console.log('WebSocket连接已关闭');
});

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

wss.on('connection', (ws) => {
    ws.on('message', (message) => {
        console.log('收到消息:', message);
        // 处理接收到的消息并广播给其他客户端
        wss.clients.forEach((client) => {
            if (client.readyState === WebSocket.OPEN) {
                client.send(JSON.stringify({
                    type: 'MessageActivityAsync',
                    content: '新的活动对话'
                }));
            }
        });
    });
});