(self, client: Client, message)
| 909 | return await self.watch_private([topic], [messageHash], params, True) |
| 910 | |
| 911 | def handle_order(self, client: Client, message): |
| 912 | # |
| 913 | # { |
| 914 | # data: { |
| 915 | # E: '1754939110175843', |
| 916 | # O: 'USER', |
| 917 | # Q: '4.30', |
| 918 | # S: 'Bid', |
| 919 | # T: '1754939110174703', |
| 920 | # V: 'RejectTaker', |
| 921 | # X: 'New', |
| 922 | # Z: '0', |
| 923 | # e: 'orderAccepted', |
| 924 | # f: 'GTC', |
| 925 | # i: '5406825793', |
| 926 | # o: 'MARKET', |
| 927 | # q: '0.0010', |
| 928 | # r: False, |
| 929 | # s: 'ETH_USDC', |
| 930 | # t: null, |
| 931 | # z: '0' |
| 932 | # }, |
| 933 | # stream: 'account.orderUpdate.ETH_USDC' |
| 934 | # } |
| 935 | # |
| 936 | messageHash = 'orders' |
| 937 | data = self.safe_dict(message, 'data', {}) |
| 938 | marketId = self.safe_string(data, 's') |
| 939 | market = self.safe_market(marketId) |
| 940 | symbol = market['symbol'] |
| 941 | parsed = self.parse_ws_order(data, market) |
| 942 | orders = self.orders |
| 943 | if orders is None: |
| 944 | limit = self.safe_integer(self.options, 'ordersLimit', 1000) |
| 945 | orders = ArrayCacheBySymbolById(limit) |
| 946 | self.orders = orders |
| 947 | orders.append(parsed) |
| 948 | client.resolve(orders, messageHash) |
| 949 | symbolSpecificMessageHash = messageHash + ':' + symbol |
| 950 | client.resolve(orders, symbolSpecificMessageHash) |
| 951 | |
| 952 | def parse_ws_order(self, order, market: Market = None): |
| 953 | # |
no test coverage detected