424 lines
10 KiB
JavaScript
424 lines
10 KiB
JavaScript
/* global H5PAdminIntegration H5PUtils */
|
|
|
|
(function ($, Version) {
|
|
var info, $container, librariesCache = {}, scriptsCache = {};
|
|
|
|
// Initialize
|
|
$(document).ready(function () {
|
|
// Get library info
|
|
info = H5PAdminIntegration.libraryInfo;
|
|
|
|
// Get and reset container
|
|
$container = $('#h5p-admin-container').html('<p>' + info.message + '</p>');
|
|
|
|
// Make it possible to select version
|
|
var $version = $(getVersionSelect(info.versions)).appendTo($container);
|
|
|
|
// Add "go" button
|
|
$('<button/>', {
|
|
class: 'h5p-admin-upgrade-button',
|
|
text: info.buttonLabel,
|
|
click: function () {
|
|
// Start new content upgrade
|
|
new ContentUpgrade($version.val());
|
|
}
|
|
}).appendTo($container);
|
|
});
|
|
|
|
/**
|
|
* Generate html for version select.
|
|
*
|
|
* @param {Object} versions
|
|
* @returns {String}
|
|
*/
|
|
var getVersionSelect = function (versions) {
|
|
var html = '';
|
|
for (var id in versions) {
|
|
html += '<option value="' + id + '">' + versions[id] + '</option>';
|
|
}
|
|
if (html !== '') {
|
|
html = '<select>' + html + '</select>';
|
|
return html;
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Displays a throbber in the status field.
|
|
*
|
|
* @param {String} msg
|
|
* @returns {_L1.Throbber}
|
|
*/
|
|
function Throbber(msg) {
|
|
var $throbber = H5PUtils.throbber(msg);
|
|
$container.html('').append($throbber);
|
|
|
|
/**
|
|
* Makes it possible to set the progress.
|
|
*
|
|
* @param {String} progress
|
|
*/
|
|
this.setProgress = function (progress) {
|
|
$throbber.text(msg + ' ' + progress);
|
|
};
|
|
}
|
|
|
|
/**
|
|
* Start a new content upgrade.
|
|
*
|
|
* @param {Number} libraryId
|
|
* @returns {_L1.ContentUpgrade}
|
|
*/
|
|
function ContentUpgrade(libraryId) {
|
|
var self = this;
|
|
|
|
// Get selected version
|
|
self.version = new Version(info.versions[libraryId]);
|
|
self.version.libraryId = libraryId;
|
|
|
|
// Create throbber with loading text and progress
|
|
self.throbber = new Throbber(info.inProgress.replace('%ver', self.version));
|
|
|
|
self.started = new Date().getTime();
|
|
self.io = 0;
|
|
|
|
// Track number of working
|
|
self.working = 0;
|
|
|
|
var start = function () {
|
|
// Get the next batch
|
|
self.nextBatch({
|
|
libraryId: libraryId,
|
|
token: info.token
|
|
});
|
|
};
|
|
|
|
if (window.Worker !== undefined) {
|
|
// Prepare our workers
|
|
self.initWorkers();
|
|
start();
|
|
}
|
|
else {
|
|
// No workers, do the job ourselves
|
|
self.loadScript(info.scriptBaseUrl + '/h5p-content-upgrade-process.js' + info.buster, start);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Initialize workers
|
|
*/
|
|
ContentUpgrade.prototype.initWorkers = function () {
|
|
var self = this;
|
|
|
|
// Determine number of workers (defaults to 4)
|
|
var numWorkers = (window.navigator !== undefined && window.navigator.hardwareConcurrency ? window.navigator.hardwareConcurrency : 4);
|
|
self.workers = new Array(numWorkers);
|
|
|
|
// Register message handlers
|
|
var messageHandlers = {
|
|
done: function (result) {
|
|
self.workDone(result.id, result.params, this);
|
|
},
|
|
error: function (error) {
|
|
self.printError(error.err);
|
|
|
|
// Stop everything
|
|
self.terminate();
|
|
},
|
|
loadLibrary: function (details) {
|
|
var worker = this;
|
|
self.loadLibrary(details.name, new Version(details.version), function (err, library) {
|
|
if (err) {
|
|
// Reset worker?
|
|
return;
|
|
}
|
|
|
|
worker.postMessage({
|
|
action: 'libraryLoaded',
|
|
library: library
|
|
});
|
|
});
|
|
}
|
|
};
|
|
|
|
for (var i = 0; i < numWorkers; i++) {
|
|
self.workers[i] = new Worker(info.scriptBaseUrl + '/h5p-content-upgrade-worker.js' + info.buster);
|
|
self.workers[i].onmessage = function (event) {
|
|
if (event.data.action !== undefined && messageHandlers[event.data.action]) {
|
|
messageHandlers[event.data.action].call(this, event.data);
|
|
}
|
|
};
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Get the next batch and start processing it.
|
|
*
|
|
* @param {Object} outData
|
|
*/
|
|
ContentUpgrade.prototype.nextBatch = function (outData) {
|
|
var self = this;
|
|
|
|
// Track time spent on IO
|
|
var start = new Date().getTime();
|
|
$.post(info.infoUrl, outData, function (inData) {
|
|
self.io += new Date().getTime() - start;
|
|
if (!(inData instanceof Object)) {
|
|
// Print errors from backend
|
|
return self.setStatus(inData);
|
|
}
|
|
if (inData.left === 0) {
|
|
var total = new Date().getTime() - self.started;
|
|
|
|
if (window.console && console.log) {
|
|
console.log('The upgrade process took ' + (total / 1000) + ' seconds. (' + (Math.round((self.io / (total / 100)) * 100) / 100) + ' % IO)' );
|
|
}
|
|
|
|
// Terminate workers
|
|
self.terminate();
|
|
|
|
// Nothing left to process
|
|
return self.setStatus(info.done);
|
|
}
|
|
|
|
self.left = inData.left;
|
|
self.token = inData.token;
|
|
|
|
// Start processing
|
|
self.processBatch(inData.params);
|
|
});
|
|
};
|
|
|
|
/**
|
|
* Set current status message.
|
|
*
|
|
* @param {String} msg
|
|
*/
|
|
ContentUpgrade.prototype.setStatus = function (msg) {
|
|
$container.html(msg);
|
|
};
|
|
|
|
/**
|
|
* Process the given parameters.
|
|
*
|
|
* @param {Object} parameters
|
|
*/
|
|
ContentUpgrade.prototype.processBatch = function (parameters) {
|
|
var self = this;
|
|
|
|
// Track upgraded params
|
|
self.upgraded = {};
|
|
|
|
// Track current batch
|
|
self.parameters = parameters;
|
|
|
|
// Create id mapping
|
|
self.ids = [];
|
|
for (var id in parameters) {
|
|
if (parameters.hasOwnProperty(id)) {
|
|
self.ids.push(id);
|
|
}
|
|
}
|
|
|
|
// Keep track of current content
|
|
self.current = -1;
|
|
|
|
if (self.workers !== undefined) {
|
|
// Assign each worker content to upgrade
|
|
for (var i = 0; i < self.workers.length; i++) {
|
|
self.assignWork(self.workers[i]);
|
|
}
|
|
}
|
|
else {
|
|
|
|
self.assignWork();
|
|
}
|
|
};
|
|
|
|
/**
|
|
*
|
|
*/
|
|
ContentUpgrade.prototype.assignWork = function (worker) {
|
|
var self = this;
|
|
|
|
var id = self.ids[self.current + 1];
|
|
if (id === undefined) {
|
|
return false; // Out of work
|
|
}
|
|
self.current++;
|
|
self.working++;
|
|
|
|
if (worker) {
|
|
worker.postMessage({
|
|
action: 'newJob',
|
|
id: id,
|
|
name: info.library.name,
|
|
oldVersion: info.library.version,
|
|
newVersion: self.version.toString(),
|
|
params: self.parameters[id]
|
|
});
|
|
}
|
|
else {
|
|
new H5P.ContentUpgradeProcess(info.library.name, new Version(info.library.version), self.version, self.parameters[id], id, function loadLibrary(name, version, next) {
|
|
self.loadLibrary(name, version, function (err, library) {
|
|
if (library.upgradesScript) {
|
|
self.loadScript(library.upgradesScript, function (err) {
|
|
if (err) {
|
|
err = info.errorScript.replace('%lib', name + ' ' + version);
|
|
}
|
|
next(err, library);
|
|
});
|
|
}
|
|
else {
|
|
next(null, library);
|
|
}
|
|
});
|
|
|
|
}, function done(err, result) {
|
|
if (err) {
|
|
self.printError(err);
|
|
return ;
|
|
}
|
|
|
|
self.workDone(id, result);
|
|
});
|
|
}
|
|
};
|
|
|
|
/**
|
|
*
|
|
*/
|
|
ContentUpgrade.prototype.workDone = function (id, result, worker) {
|
|
var self = this;
|
|
|
|
self.working--;
|
|
self.upgraded[id] = result;
|
|
|
|
// Update progress message
|
|
self.throbber.setProgress(Math.round((info.total - self.left + self.current) / (info.total / 100)) + ' %');
|
|
|
|
// Assign next job
|
|
if (self.assignWork(worker) === false && self.working === 0) {
|
|
// All workers have finsihed.
|
|
self.nextBatch({
|
|
libraryId: self.version.libraryId,
|
|
token: self.token,
|
|
params: JSON.stringify(self.upgraded)
|
|
});
|
|
}
|
|
};
|
|
|
|
/**
|
|
*
|
|
*/
|
|
ContentUpgrade.prototype.terminate = function () {
|
|
var self = this;
|
|
|
|
if (self.workers) {
|
|
// Stop all workers
|
|
for (var i = 0; i < self.workers.length; i++) {
|
|
self.workers[i].terminate();
|
|
}
|
|
}
|
|
};
|
|
|
|
var librariesLoadedCallbacks = {};
|
|
|
|
/**
|
|
* Load library data needed for content upgrade.
|
|
*
|
|
* @param {String} name
|
|
* @param {Version} version
|
|
* @param {Function} next
|
|
*/
|
|
ContentUpgrade.prototype.loadLibrary = function (name, version, next) {
|
|
var self = this;
|
|
|
|
var key = name + '/' + version.major + '/' + version.minor;
|
|
|
|
if (librariesCache[key] === true) {
|
|
// Library is being loaded, que callback
|
|
if (librariesLoadedCallbacks[key] === undefined) {
|
|
librariesLoadedCallbacks[key] = [next];
|
|
return;
|
|
}
|
|
librariesLoadedCallbacks[key].push(next);
|
|
return;
|
|
}
|
|
else if (librariesCache[key] !== undefined) {
|
|
// Library has been loaded before. Return cache.
|
|
next(null, librariesCache[key]);
|
|
return;
|
|
}
|
|
|
|
// Track time spent loading
|
|
var start = new Date().getTime();
|
|
librariesCache[key] = true;
|
|
$.ajax({
|
|
dataType: 'json',
|
|
cache: true,
|
|
url: info.libraryBaseUrl + '/' + key
|
|
}).fail(function () {
|
|
self.io += new Date().getTime() - start;
|
|
next(info.errorData.replace('%lib', name + ' ' + version));
|
|
}).done(function (library) {
|
|
self.io += new Date().getTime() - start;
|
|
librariesCache[key] = library;
|
|
next(null, library);
|
|
|
|
if (librariesLoadedCallbacks[key] !== undefined) {
|
|
for (var i = 0; i < librariesLoadedCallbacks[key].length; i++) {
|
|
librariesLoadedCallbacks[key][i](null, library);
|
|
}
|
|
}
|
|
delete librariesLoadedCallbacks[key];
|
|
});
|
|
};
|
|
|
|
/**
|
|
* Load script with upgrade hooks.
|
|
*
|
|
* @param {String} url
|
|
* @param {Function} next
|
|
*/
|
|
ContentUpgrade.prototype.loadScript = function (url, next) {
|
|
var self = this;
|
|
|
|
if (scriptsCache[url] !== undefined) {
|
|
next();
|
|
return;
|
|
}
|
|
|
|
// Track time spent loading
|
|
var start = new Date().getTime();
|
|
$.ajax({
|
|
dataType: 'script',
|
|
cache: true,
|
|
url: url
|
|
}).fail(function () {
|
|
self.io += new Date().getTime() - start;
|
|
next(true);
|
|
}).done(function () {
|
|
scriptsCache[url] = true;
|
|
self.io += new Date().getTime() - start;
|
|
next();
|
|
});
|
|
};
|
|
|
|
/**
|
|
*
|
|
*/
|
|
ContentUpgrade.prototype.printError = function (error) {
|
|
var self = this;
|
|
|
|
if (error.type === 'errorParamsBroken') {
|
|
error = info.errorContent.replace('%id', error.id) + ' ' + info.errorParamsBroken;
|
|
}
|
|
else if (error.type === 'scriptMissing') {
|
|
error = info.errorScript.replace('%lib', error.library);
|
|
}
|
|
|
|
self.setStatus('<p>' + info.error + '<br/>' + error + '</p>');
|
|
};
|
|
|
|
})(H5P.jQuery, H5P.Version);
|