define(['userSettings', 'emby-button'], function (userSettings) {
return function (options) {
var button = options.button;
function pollTasks() {
ApiClient.getScheduledTasks({
IsEnabled: true
}).then(updateTasks);
}
function updateTasks(tasks) {
var task = tasks.filter(function (t) {
return t.Key == options.taskKey;
})[0];
if (options.panel) {
if (task) {
options.panel.classList.remove('hide');
} else {
options.panel.classList.add('hide');
}
}
if (!task) {
return;
}
if (task.State == 'Idle') {
button.removeAttribute('disabled');
} else {
button.setAttribute('disabled', 'disabled');
}
button.setAttribute('data-taskid', task.Id);
var progress = (task.CurrentProgressPercentage || 0).toFixed(1);
if (options.progressElem) {
options.progressElem.value = progress;
if (task.State == 'Running') {
options.progressElem.classList.remove('hide');
} else {
options.progressElem.classList.add('hide');
}
}
if (options.lastResultElem) {
var lastResult = task.LastExecutionResult ? task.LastExecutionResult.Status : '';
if (lastResult == "Failed") {
options.lastResultElem.html('(' + Globalize.translate('LabelFailed') + ')');
}
else if (lastResult == "Cancelled") {
options.lastResultElem.html('(' + Globalize.translate('LabelCancelled') + ')');
}
else if (lastResult == "Aborted") {
options.lastResultElem.html('' + Globalize.translate('LabelAbortedByServerShutdown') + '');
} else {
options.lastResultElem.html(lastResult);
}
}
}
function onScheduledTaskMessageConfirmed(id) {
ApiClient.startScheduledTask(id).then(pollTasks);
}
function onButtonClick() {
var button = this;
var buttonTextElement = this.querySelector('span') || this;
var text = buttonTextElement.textContent || buttonTextElement.innerText;
var taskId = button.getAttribute('data-taskid');
var key = 'scheduledTaskButton' + options.taskKey;
var expectedValue = new Date().getMonth() + '6';
if (userSettings.get(key) == expectedValue) {
onScheduledTaskMessageConfirmed(taskId);
} else {
require(['dialog'], function (dialog) {
var msg = Globalize.translate('ConfirmMessageScheduledTaskButton');
var menuItems = [];
menuItems.push({
name: text,
id: 'task'
});
menuItems.push({
name: Globalize.translate('ButtonScheduledTasks'),
id: 'tasks'
});
menuItems.push({
name: Globalize.translate('ButtonCancel'),
id: 'cancel'
});
dialog({
buttons: menuItems,
text: msg
}).then(function (id) {
switch (id) {
case 'task':
userSettings.set(key, expectedValue);
onScheduledTaskMessageConfirmed(taskId);
break;
case 'tasks':
userSettings.set(key, expectedValue);
Dashboard.navigate('scheduledtasks.html');
break;
default:
break;
}
});
});
}
}
function onSocketOpen() {
startInterval();
}
function onSocketMessage(e, msg) {
if (msg.MessageType == "ScheduledTasksInfo") {
var tasks = msg.Data;
updateTasks(tasks);
}
}
var pollInterval;
function onPollIntervalFired() {
if (!ApiClient.isWebSocketOpen()) {
pollTasks();
}
}
function startInterval() {
if (ApiClient.isWebSocketOpen()) {
ApiClient.sendWebSocketMessage("ScheduledTasksInfoStart", "1000,1000");
}
if (pollInterval) {
clearInterval(pollInterval);
}
pollInterval = setInterval(onPollIntervalFired, 5000);
}
function stopInterval() {
if (ApiClient.isWebSocketOpen()) {
ApiClient.sendWebSocketMessage("ScheduledTasksInfoStop");
}
if (pollInterval) {
clearInterval(pollInterval);
}
}
if (options.panel) {
options.panel.classList.add('hide');
}
if (options.mode == 'off') {
button.removeEventListener('click', onButtonClick);
Events.off(ApiClient, 'websocketmessage', onSocketMessage);
Events.off(ApiClient, 'websocketopen', onSocketOpen);
stopInterval();
} else {
button.addEventListener('click', onButtonClick);
pollTasks();
startInterval();
Events.on(ApiClient, 'websocketmessage', onSocketMessage);
Events.on(ApiClient, 'websocketopen', onSocketOpen);
}
};
});