MCPcopy Create free account
hub / github.com/ccxt/ccxt / handle_order

Method handle_order

python/ccxt/pro/backpack.py:911–950  ·  view source on GitHub ↗
(self, client: Client, message)

Source from the content-addressed store, hash-verified

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 #

Callers 1

handle_messageMethod · 0.95

Calls 8

parse_ws_orderMethod · 0.95
appendMethod · 0.95
safe_dictMethod · 0.80
safe_stringMethod · 0.80
safe_integerMethod · 0.80
resolveMethod · 0.65
safe_marketMethod · 0.45

Tested by

no test coverage detected