Method handle_orders

python/ccxt/pro/lighter.py:1056–1098

(self, client: Client, message)

        return await self.unsubscribe(messageHash, self.extend(request, params))

    def handle_orders(self, client: Client, message):
        #
        #    {
        #        "account": {ACCOUNT_INDEX},
        #        "channel": "account_orders:{MARKET_INDEX}",
        #        "nonce": INTEGER,
        #        "orders": {
        #            "{MARKET_INDEX}": [Order]  # the only present market index will be the one provided
        #        },
        #        "type": "update/account_orders"
        #    }
        #
        #    {
        #        "channel": "account_all_orders:{ACCOUNT_ID}",
        #        "orders": {
        #            "{MARKET_INDEX}": [Order]
        #        },
        #        "type": "update/account_all_orders"
        #    }
        #
        data = self.safe_dict(message, 'orders', {})
        marketIds = list(data.keys())
        idsLength = len(marketIds)
        if idsLength == 0:
            return False  # nothing to process
        if self.orders is None:
            limit = self.safe_integer(self.options, 'ordersLimit', 1000)
            self.orders = ArrayCache(limit)
        stored = self.orders
        messageHash = self.get_message_hash('orders')
        for i in range(0, len(marketIds)):
            marketId = marketIds[i]
            market = self.safe_market(marketId)
            orders = self.safe_list(data, marketId, [])
            for j in range(0, len(orders)):
                order = self.parse_order(orders[j], market)
                stored.append(order)
                symbol = order['symbol']
                if symbol is not None:
                    symbolSpecificMessageHash = self.get_message_hash('orders', symbol)
                    client.resolve(stored, symbolSpecificMessageHash)
        client.resolve(stored, messageHash)
        return True

    def handle_error_message(self, client, message):
        #