Method _dequeBatch

seq_logger.js:190–233

()

        }

        _dequeBatch() {
            var bytes = HEADER_FOOTER_BYTES;
            let batch = [];
            var i = 0;
            var delimSize = 0;
            while (i < this._queue.length) {
                let next = this._queue[i];
                let json;
                try {
                    json = JSON.stringify(next);
                } catch (e) {
                    const cleaned = removeCirculars(next);
                    json = JSON.stringify(cleaned);
                    // Log that this event to be able to detect circular structures
                    // using same timestamp as cleaned event to make finding it easier
                    this.emit({
                        timestamp: cleaned.Timestamp,
                        level: "Error",
                        messageTemplate: "[seq] Circular structure found"
                    });
                }
                var jsonLen = new safeGlobalBlob([json]).size;
                if (jsonLen > this._eventSizeLimit) {
                    this._onError("[seq] Event body is larger than " + this._eventSizeLimit + " bytes: " + json);
                    this._queue[i] = next = this._eventTooLargeErrorEvent(next);
                    json = JSON.stringify(next);
                    jsonLen = new safeGlobalBlob([json]).size;
                }

                // Always try to send a batch of at least one event, even if the batch size is
                // tiny.
                if (i !== 0 && bytes + jsonLen + delimSize > this._batchSizeLimit) {
                    break;
                }

                i = i + 1;
                bytes += jsonLen + delimSize;
                delimSize = 1; // ","
                batch.push(json);
            }

            this._queue.splice(0, i);
            return {batch, bytes};
        }

        _httpOrNetworkError(res) {
            const networkErrors = ['ECONNRESET', 'ENOTFOUND', 'ESOCKETTIMEDOUT', 'ETIMEDOUT', 'ECONNREFUSED', 'EHOSTUNREACH', 'EPIPE', 'EAI_AGAIN', 'EBUSY'];