实时弹幕聚合显示：增加心跳机制

Added heartbeat functionality to maintain WebSocket connection.

Author: ISeekFree

plugins/aggregate/index.html

@@ -487,7 +487,7 @@
                 }
 
                 const result = await response.json();
-                alert("getWssUrl resp:" + JSON.stringify(result));
+                //alert("getWssUrl resp:" + JSON.stringify(result));
                 if (result.code === 0 && result.data) {
                     console.log('WSS URL retrieved successfully:', result.data);
                     return result.data;
@@ -598,11 +598,10 @@
                     }else if (event.data.type === 'StreamHawk') {
                         var message = event.data.data;
                         var msgType = message.type;
-                        //var bullet = {id:item.id,'icon':formatIcon(item.type),'roomId':route.query.roomId,platform: route.query.platform,roomName:route.query.roomName,type:item.type,userId:item.userId,'userName':item.userName,userAvatar:item.userAvatar,userShortId:item.userShortId,userGender:item.userGender,userFollowers:item.userFollowers,userFollowing:item.userFollowing,userPosts:item.userPosts,userCountry:item.userCountry,userProvince:item.userProvince,userCity:item.userCity,userDescription:item.userDescription,'content':item.content,'statusText':'🔄️'};
                         if(msgType == 'text' || msgType == 'gift' || msgType == 'entrance' || msgType == 'like' || msgType == 'streamer'){//合法消息类型
-                            incrLiveData();
                             if(ws && ws.readyState === ReconnectingWebSocket.OPEN) {
-                                //ws.send(JSON.stringify(message));
+                                incrLiveData();
+                                ws.send(JSON.stringify({"cmd":4014,"payload":message}));
                                 console.log('Aggr message sent via WebSocket:',message);
                             }else{
                                 console.warn('Aggr WebSocket is not connected. Cannot send danmaku message.');
@@ -626,6 +625,15 @@
 
         // Initialize when page loads
         document.addEventListener('DOMContentLoaded', init);
+
+        function heartBeat(){
+            if(ws && ws.readyState === ReconnectingWebSocket.OPEN){
+                ws.send(JSON.stringify({"cmd":8002}));
+            }
+        }
+        setInterval(() => {
+            heartBeat();
+        },30000);
     </script>
 </body>
 </html>