upgrader.js

Go to the documentation of this file.

define(['jquery', 'elgg/Ajax', 'elgg/spinner', 'elgg/popup', 'elgg/system_messages', 'elgg/i18n', 'jquery-ui/widgets/progressbar'], function($, Ajax, spinner, popup, system_messages, i18n) {

    var UNKNOWN_COUNT = -1;
    var upgrades = $('.elgg-item-object-elgg_upgrade');
    var upgrade;
    var guid;
    var progressbar;
    var upgradeStartTime;
    var timer;
    var counter;
    var percent;
    var errorCounter;
    var errorMessages = [];
    var numSuccess;
    var numError;
    var numProcessed = 0;
    var total;
    var messages = [];
    var messageList;
    var percentage = 0;

    // used to fake the progressbar if we don't know the total
    var FAKE_TOTAL = 1000000;
    var fakeDone = 0;

    function run(event) {
        event.preventDefault();

        // Replace button with spinner when upgrade starts
        $('#elgg-upgrades-run').addClass('hidden');
        spinner.start();

        upgrade = upgrades.first();
        runUpgrade();

        return false;
    }
    
    function runSingle() {
        var guid = $(this).data().guid;
        
        if (!$('#elgg-object-' + guid).length) {
            return;
        }
        
        spinner.start();
        upgrade = $('#elgg-object-' + guid);
        
        runUpgrade(false);
        
        popup.close();
    }

    function runUpgrade(advanceToNextWhenDone) {
        
        if (typeof advanceToNextWhenDone !== 'boolean') {
            // IE doesn't support default function params
            advanceToNextWhenDone = true;
        }
        
        upgrade = $(upgrade);
        progressbar = upgrade.find('.elgg-progressbar');
        counter = upgrade.find('.upgrade-counter');
        percent = upgrade.find('.upgrade-percent');
        timer = upgrade.find('.upgrade-timer');
        messageList = upgrade.find('.upgrade-messages');
        errorCounter = upgrade.find('.upgrade-error-counter');
        data = upgrade.find('.upgrade-data');

        // The total amount of items to be upgraded
        total = data.attr('data-total');

        // Get the GUID from the element id: elgg-object-123
        guid = upgrade.attr('id').replace('elgg-object-', '');

        // Initialize progressbar
        $(upgrade).find('.elgg-progressbar').progressbar({
            value: 0,
            max: (total == UNKNOWN_COUNT) ? FAKE_TOTAL : total
        });

        upgradeStartTime = new Date().getTime();
        percentage = 0;

        processBatch(advanceToNextWhenDone);
    }

    function processBatch(advanceToNextWhenDone) {
        
        if (typeof advanceToNextWhenDone !== 'boolean') {
            // IE doesn't support default function params
            advanceToNextWhenDone = true;
        }
        
        var options = {
            data: {
                guid: guid
            },
            error: function(result) {
                // Append possible errors after the progressbar
                if (result.system_messages.error.length) {
                    // Display only the errors that haven't already been shown
                    $(result.error).each(function(key, message) {
                        if ($.inArray(message, errorMessages) === -1) {
                            var msg = '<li>' + message + '</li>';
                            messageList.append(msg);
                            messages.push(message);
                        }
                    });
                }
    
                $(result.errors).each(function(key, message) {
                    var msg = '<li>' + message + '</li>';
                    messageList.append(msg);
                    messages.push(message);
                });
            },
            success: function(result) {

                numSuccess = parseInt(result.numSuccess);
                numError = parseInt(result.numErrors);
    
                numProcessed += (numSuccess + numError);
    
                // Increase success statistics
                if (total == UNKNOWN_COUNT) {
                    counter.text(numProcessed + '/???');
                } else {
                    counter.text(numProcessed + '/' + total);
                }
    
                // Increase the progress bar
                if (total == UNKNOWN_COUNT) {
                    fakeDone = Math.round(FAKE_TOTAL - (FAKE_TOTAL - fakeDone) / 2);
                    progressbar.progressbar({value: fakeDone});
                } else {
                    percentage = parseInt(numProcessed * 100 / total);
                    progressbar.progressbar({value: numProcessed});
                }
    
                if (numError > 0) {
                    errorCounter
                        .text(i18n.echo('upgrade:error_count', [messages.length]))
                        .css('color', 'red');
                }
    
                updateCounter();
    
                var done;
                if (total == UNKNOWN_COUNT || result.isComplete) {
                    done = result.isComplete;
                } else {
                    done = numProcessed >= total;
                }
    
                if (done) {
                    if (numError > 0) {
                        // Upgrade finished with errors. Give instructions on how to proceed.
                        system_messages.error(i18n.echo('upgrade:finished_with_errors'));
                    }
    
                    if (total == UNKNOWN_COUNT) {
                        counter.text(numProcessed + '/' + numProcessed);
                        progressbar.progressbar({value: FAKE_TOTAL});
                    }
    
                    // Increase percentage
                    percent.html('100%');
    
                    // Reset all counters
                    numSuccess = numError = numProcessed = percentage = 0;
                    messages = [];
    
                    if (advanceToNextWhenDone) {
                        // Get next upgrade
                        upgrade = upgrade.next();
                    } else {
                        upgrade = '';
                    }
    
                    if (upgrade.length) {
                        // Continue to next upgrade
                        runUpgrade(advanceToNextWhenDone);
                    } else {
                        spinner.stop();
                    }
                    
                    return;
                }
    
                // carry on...
                if (total != UNKNOWN_COUNT) {
                    percentage = parseInt(numProcessed * 100 / total);
                    // Increase percentage
                    percent.html(percentage + '%');
                }
    
                // Start next upgrade call
                processBatch(advanceToNextWhenDone);
            }
        };

        var ajax = new Ajax(false);
        return ajax.action('admin/upgrade', options);
    }

    function updateCounter() {
        var now = new Date().getTime();

        // How many milliseconds ago the last batch was started
        var difference = (now - upgradeStartTime) / 1000;

        // How many items are waiting to be processed
        var unProcessed = total - numProcessed;

        var timeLeft = Math.round((difference / numProcessed) * unProcessed);

        if (timeLeft < 60) {
            var hours = '00';
            var minutes = '00';
            var seconds = timeLeft;
        } else {
            if (timeLeft < 3600) {
                var minutes = Math.floor(timeLeft / 60);
                var seconds = timeLeft % 60;
                var hours = '00';
            } else {
                var hours = Math.floor(timeLeft / 3600);
                var timeLeft = timeLeft % 3600;
                var minutes = Math.floor(timeLeft / 60);
                var seconds = timeLeft % 60;
            }
        }

        hours = formatDigits(hours);
        minutes = formatDigits(minutes);
        seconds = formatDigits(seconds);

        var value = hours + ':' + minutes + ':' + seconds;

        timer.html(value);
    }

    function formatDigits(time) {
        time = Math.floor(time);

        if (time < 1) {
            return '00';
        }

        if (time < 10) {
            return '0' + time;
        }

        return time;
    }

    // Display the button only if there are pending upgrades
    if ($('.elgg-item-object-elgg_upgrade').length) {
        $('#elgg-upgrades-run').removeClass('hidden').click(run);
    }
    
    $(document).on('click', '.elgg-menu-item-run-upgrade > a', runSingle);

    upgrades.each(function(key, value) {
        // Initialize progressbar
        $(value).find('.elgg-progressbar').progressbar();
    });
});