websocket_bot_sanple.py 文件源码

def __init__(self, board_id, access_token, user_id):
        self.board_id = board_id
        self.access_token = access_token
        self.user_id = user_id
        self.turn = None
        self.v_board = ReversiBoard()
        ws = websocket.WebSocketApp(
            f"ws://localhost:8000/v1/board/{self.board_id}/ws",
            header=[f"Authorization: Bearer {self.access_token}"],
            on_open=self.on_open,
            on_message=self.on_message,
            on_error=self.on_error,
            on_close=self.on_close,
        )
        try:
            ws.run_forever()
        except KeyboardInterrupt:
            ws.close()