Method fetchOrderBookSnapshot

js/src/pro/woo.js:250–282

(client, message, subscription)

        this.spawn(this.fetchOrderBookSnapshot, client, message, subscription);
    }
    async fetchOrderBookSnapshot(client, message, subscription) {
        const symbol = this.safeString(subscription, 'symbol');
        const messageHash = this.safeString(message, 'topic');
        try {
            const defaultLimit = this.safeInteger(this.options, 'watchOrderBookLimit', 1000);
            const limit = this.safeInteger(subscription, 'limit', defaultLimit);
            const params = this.safeValue(subscription, 'params');
            const snapshot = await this.fetchRestOrderBookSafe(symbol, limit, params);
            if (this.safeValue(this.orderbooks, symbol) === undefined) {
                // if the orderbook is dropped before the snapshot is received
                return;
            }
            const orderbook = this.orderbooks[symbol];
            orderbook.reset(snapshot);
            const messages = orderbook.cache;
            for (let i = 0; i < messages.length; i++) {
                const messageItem = messages[i];
                const ts = this.safeInteger(messageItem, 'ts');
                if (ts < orderbook['timestamp']) {
                    continue;
                }
                else {
                    this.handleOrderBookMessage(client, messageItem, orderbook);
                }
            }
            this.orderbooks[symbol] = orderbook;
            client.resolve(orderbook, messageHash);
        }
        catch (e) {
            delete client.subscriptions[messageHash];
            client.reject(e, messageHash);
        }
    }
    handleOrderBookMessage(client, message, orderbook) {
        const data = this.safeDict(message, 'data');
        this.handleDeltas(orderbook['asks'], this.safeValue(data, 'asks', []));