[Update] WebSocket server: Add message handler for processing incoming messages

This commit is contained in:
misyaguziya
2025-05-18 15:23:58 +09:00
parent e7304247c7
commit 1cc22d35c3

View File

@@ -834,6 +834,10 @@ class Model:
self.th_watchdog.join() self.th_watchdog.join()
self.th_watchdog = None self.th_watchdog = None
def message_handler(websocket, message):
"""WebSocketメッセージ受信時の処理"""
pass
def startWebSocketServer(self): def startWebSocketServer(self):
"""WebSocketサーバーを起動し、別スレッドで実行する""" """WebSocketサーバーを起動し、別スレッドで実行する"""
self.websocket_server_loop = True self.websocket_server_loop = True
@@ -845,6 +849,7 @@ class Model:
host=config.WEBSOCKET_HOST, host=config.WEBSOCKET_HOST,
port=config.WEBSOCKET_PORT, port=config.WEBSOCKET_PORT,
) )
self.websocket_server.set_message_handler(self.message_handler)
self.websocket_server.start() self.websocket_server.start()
self.websocket_server_alive = True self.websocket_server_alive = True