(self, client: Client, message)
| 2377 | future.resolve(True) |
| 2378 | |
| 2379 | def handle_error_message(self, client: Client, message) -> Bool: |
| 2380 | # |
| 2381 | # {event: "error", code: 30015, msg: "Invalid sign"} |
| 2382 | # |
| 2383 | event = self.safe_string(message, 'event') |
| 2384 | try: |
| 2385 | if event == 'error': |
| 2386 | code = self.safe_string(message, 'code') |
| 2387 | feedback = self.id + ' ' + self.json(message) |
| 2388 | self.throw_exactly_matched_exception(self.exceptions['ws']['exact'], code, feedback) |
| 2389 | msg = self.safe_string(message, 'msg', '') |
| 2390 | self.throw_broadly_matched_exception(self.exceptions['ws']['broad'], msg, feedback) |
| 2391 | raise ExchangeError(feedback) |
| 2392 | return False |
| 2393 | except Exception as e: |
| 2394 | if isinstance(e, AuthenticationError): |
| 2395 | messageHash = 'authenticated' |
| 2396 | client.reject(e, messageHash) |
| 2397 | if messageHash in client.subscriptions: |
| 2398 | del client.subscriptions[messageHash] |
| 2399 | else: |
| 2400 | # Note: if error happens on a subscribe event, user will have to close exchange to resubscribe. Issue #19041 |
| 2401 | client.reject(e) |
| 2402 | return True |
| 2403 | |
| 2404 | def handle_message(self, client: Client, message): |
| 2405 | # |
no test coverage detected