(self, client: Client, message)
| 657 | return await self.watch(url, messageHash, request, messageHash) |
| 658 | |
| 659 | def handle_ticker(self, client: Client, message): |
| 660 | # |
| 661 | # { |
| 662 | # "channel": "market_e_btcusdt_ticker", |
| 663 | # "ts": 1506584998239, |
| 664 | # "tick": { |
| 665 | # "amount": 123.1221, |
| 666 | # "vol": 1212.12211, |
| 667 | # "open": 2233.22, |
| 668 | # "close": 1221.11, |
| 669 | # "high": 22322.22, |
| 670 | # "low": 2321.22, |
| 671 | # "rose": -0.2922 |
| 672 | # }, |
| 673 | # "status": "ok" |
| 674 | # } |
| 675 | # |
| 676 | channel = self.safe_string(message, 'channel') |
| 677 | parts = channel.split('_') |
| 678 | wsBaseQuote = self.safe_string_lower(parts, 2) |
| 679 | market = self.find_swap_market_by_ws_base_quote(wsBaseQuote) |
| 680 | if market is None: |
| 681 | return |
| 682 | symbol = market['symbol'] |
| 683 | tick = self.safe_value(message, 'tick') |
| 684 | if tick is None: |
| 685 | return |
| 686 | timestamp = self.safe_integer(message, 'ts') |
| 687 | parsed = self.parse_ws_ticker(tick, market, timestamp) |
| 688 | self.tickers[symbol] = parsed |
| 689 | messageHash = 'ticker:' + symbol |
| 690 | client.resolve(parsed, messageHash) |
| 691 | |
| 692 | def parse_ws_ticker(self, tick, market, timestamp: Int = None) -> Ticker: |
| 693 | symbol = market['symbol'] |
no test coverage detected