Method _post

seq_logger.js:240–287

(batch, bytes)

        }

        _post(batch, bytes) {
            let attempts = 0;

            return new Promise((resolve, reject) => {
                const sendRequest = (batch, bytes) => {
                    const controller = new safeGlobalAbortController();
                    attempts++;
                    const timerId = setTimeout(() => {
                        controller.abort();
                        if (attempts > this._maxRetries) {
                            reject('HTTP log shipping failed, reached timeout (' + this._requestTimeout + ' ms)');
                        } else {
                            setTimeout(() => sendRequest(batch, bytes), this._retryDelay);
                        }
                    }, this._requestTimeout);

                    safeGlobalFetch(this._endpoint, {
                        keepalive: true,
                        method: "POST",
                        headers: {
                            "Content-Type": "application/json",
                            "X-Seq-ApiKey": this._apiKey ? this._apiKey : null,
                            "Content-Length": bytes,
                        },
                        body: `${HEADER}${batch.join(',')}${FOOTER}`,
                        signal: controller.signal,
                    })
                        .then((res) => {
                            clearTimeout(timerId);
                            let httpErr = null;
                            if (res.status !== 200 && res.status !== 201) {
                                httpErr = 'HTTP log shipping failed: ' + res.status;
                                if (this._httpOrNetworkError(res) && attempts < this._maxRetries) {
                                    return setTimeout(() => sendRequest(batch, bytes), this._retryDelay);
                                }
                                return reject(httpErr);
                            }
                            return resolve(true);
                        })
                        .catch((err) => {
                            clearTimeout(timerId);
                            reject(err);
                        })
                }

                return sendRequest(batch, bytes);
            });
        }
    }