zulip/static/js/local_message.js

var local_message = (function () {

var exports = {};

function truncate_precision(float) {
    return parseFloat(float.toFixed(3));
}

exports.now = function () {
    var timestamp = new XDate().getTime() / 1000;

    return timestamp;
};

exports.insert_message = function (message) {
    // It is a little bit funny to go through the message_events
    // codepath, but it's sort of the idea behind local echo that
    // we are simulating server events before they actually arrive.
    message_events.insert_new_messages([message], true);
};

exports.get_next_id = (function () {

    var already_used = {};

    return function () {
        var local_id_increment = 0.01;
        var latest = page_params.max_message_id;
        if (typeof message_list.all !== 'undefined' && message_list.all.last() !== undefined) {
            latest = message_list.all.last().id;
        }
        latest = Math.max(0, latest);
        var next_local_id = truncate_precision(latest + local_id_increment);

        if (already_used[next_local_id]) {
            // If our id is already used, it is probably an edge case like we had
            // to abort a very recent message.
            blueslip.warn("We don't reuse ids for local echo.");
            return;
        }

        if (next_local_id % 1 > local_id_increment * 5) {
            blueslip.warn("Turning off local echo for this message to let host catch up");
            return;
        }

        if (next_local_id % 1 === 0) {
            // The logic to stop at 0.05 should prevent us from ever wrapping around
            // to the next integer.
            blueslip.error("Programming error");
            return;
        }

        already_used[next_local_id] = true;

        return next_local_id;
    };
}());

return exports;

}());
if (typeof module !== 'undefined') {
    module.exports = local_message;
}