chore: 初步完成network

src/onebot/network/passive-websocket.ts

@@ -29,8 +29,7 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
                 }
             }
             wsClient.on('message', (message) => {
-                // TODO: extract action name and payload from the message, then call the corresponding action.
+                this.handleMessage(message);
-                // TODO: consider using a utility function
             });
             wsClient.once('close', () => {
                 this.wsClientsMutex.runExclusive(async () => {
@@ -51,15 +50,22 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
     }
 
     registerHeartBeat() {
-        //WS正向心跳
+        setInterval(() => {
+            this.wsClientsMutex.runExclusive(async () => {
+                this.wsClients.forEach((wsClient) => {
+                    if (wsClient.readyState === WebSocket.OPEN) {
+                        wsClient.ping();
+                    }
+                });
+            });
+        }, this.heartbeatInterval);
     }
 
     onEvent<T extends OB11EmitEventContent>(event: T) {
         this.wsClientsMutex.runExclusive(async () => {
             this.wsClients.forEach((wsClient) => {
-                // wsClient.send(JSON.stringify(event));
+                const wrappedEvent = this.wrapEvent(event);
-                // TODO: wrap the event, and send the wrapped to the client.
+                wsClient.send(JSON.stringify(wrappedEvent));
-                // TODO: consider using a utility function
             });
         });
     }
@@ -76,4 +82,24 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
         this.hasBeenClosed = true;
         this.wsServer.close();
     }
+
+    private handleMessage(message: any) {
+        try {
+            const parsedMessage = JSON.parse(message);
+            const action = this.actionMap.get(parsedMessage.actionName);
+            if (action) {
+                action.handle(parsedMessage.payload);
+            }
+        } catch (e) {
+            console.error('Failed to handle message:', e);
+        }
+    }
+
+    private wrapEvent<T extends OB11EmitEventContent>(event: T) {
+        return {
+            type: 'event',
+            data: event
+        };
+    }
 }
+