Method _send

webiojs/src/session.ts:279–328

(params: { [key: string]: any; }[], seq: number)

    }

    _send(params: { [key: string]: any; }[], seq: number): Promise<void> {
        if (this.closed()) {
            this.sender.stop();
            error_alert(t("disconnected_with_server"));
            return Promise.reject();
        }
        let data: any, ajax_options: any;
        let json = params.some(p => p.json);
        if (json) {
            data = JSON.stringify(params.map(p => p.data));
            ajax_options = {
                contentType: "application/json; charset=utf-8",
            }
        } else {
            data = params[0].data;
            ajax_options = {
                cache: false,
                processData: false,
                contentType: 'application/octet-stream',
            }
        }
        return new Promise((resolve, reject) => {
            $.ajax({
                data: data,
                ...ajax_options,
                type: "POST",
                url: `${this.api_url}&ack=${this._executed_command_msg_id}&seq=${seq}`,
                dataType: "json",
                headers: {"webio-session-id": this.webio_session_id},
                success: this._on_request_success.bind(this),
                xhr: function () {
                    let xhr = new window.XMLHttpRequest();
                    // Upload progress
                    xhr.upload.addEventListener("progress", function (evt) {
                        if (evt.lengthComputable) {
                            params.forEach(p => {
                                if (p.onprogress) // only the first one
                                    p.onprogress(evt.loaded, evt.total);
                                p.onprogress = null;
                            });
                        }
                    }, false);
                    return xhr;
                },
                error: function () {
                    console.error('Http push event failed, will retry');
                }
            }).always(() => resolve());
        });
    }

    close_session(): void {
        this._closed = true;