Class HttpSession

webiojs/src/session.ts:179–348

export class HttpSession implements Session {
    interval_pull_id: number = null;
    webio_session_id: string = '';
    debug = false;

    private sender: ReliableSender = null;
    private _executed_command_msg_id = -1;
    private _closed = false;
    private _session_create_callbacks: (() => void)[] = [];
    private _session_close_callbacks: (() => void)[] = [];
    private _on_server_message: (msg: Command) => void = () => {
    };


    constructor(public api_url: string, app_name = 'index', public pull_interval_ms = 1000) {
        let url = new URL(api_url, window.location.href);
        url.search = "?app=" + app_name;
        this.api_url = url.href;
        this.sender = new ReliableSender(this._send.bind(this));
    }

    on_session_create(callback: () => void): void {
        this._session_create_callbacks.push(callback);
    }

    on_session_close(callback: () => void): void {
        this._session_close_callbacks.push(callback);
    }

    on_server_message(callback: (msg: Command) => void): void {
        this._on_server_message = callback;
    }

    start_session(debug: boolean = false): void {
        this.debug = debug;
        this.webio_session_id = "NEW-" + randomid(24);
        this.pull();
        this.interval_pull_id = setInterval(() => {
            this.pull()
        }, this.pull_interval_ms);
    }

    pull() {
        let that = this;
        $.ajax({
            type: "GET",
            url: `${this.api_url}&ack=${this._executed_command_msg_id}`,
            contentType: "application/json; charset=utf-8",
            dataType: "json",
            headers: {"webio-session-id": this.webio_session_id},
            success: function (data: { commands: Command[][], seq: number, event: number, ack: number },
                               textStatus: string, jqXHR: JQuery.jqXHR) {
                safe_poprun_callbacks(that._session_create_callbacks, 'session_create_callback');
                that._on_request_success(data, textStatus, jqXHR);
                if (that.webio_session_id.startsWith("NEW-")) {
                    that.webio_session_id = that.webio_session_id.substring(4);
                }
            }