jellyfin-web/dashboard-ui/components/syncjoblist/syncjoblist.js

define(['serverNotifications', 'events', 'loading', 'connectionManager', 'imageLoader', 'dom', 'globalize', 'listViewStyle'], function (serverNotifications, events, loading, connectionManager, imageLoader, dom, globalize) {

    function onSyncJobsUpdated(e, apiClient, data) {

        var listInstance = this;
        renderList(listInstance, data);
    }

    function refreshList(listInstance, jobs) {
        for (var i = 0, length = jobs.length; i < length; i++) {

            var job = jobs[i];
            refreshJob(listInstance, job);
        }
    }

    function cancelJob(listInstance, id) {

        require(['confirm'], function (confirm) {

            var msg = listInstance.options.isLocalSync ?
globalize.translate('ConfirmRemoveDownload') :
globalize.translate('CancelSyncJobConfirmation');

            confirm(msg).then(function () {

                loading.show();
                var apiClient = getApiClient(listInstance);

                apiClient.ajax({

                    url: apiClient.getUrl('Sync/Jobs/' + id),
                    type: 'DELETE'

                }).then(function () {

                    fetchData(listInstance);
                });
            });
        });
    }

    function refreshJob(listInstance, job) {

        var listItem = listInstance.options.element.querySelector('.listItem[data-id=\'' + job.Id + '\']');

        if (!listItem) {
            return;
        }

        var progress = job.Progress || 0;
        var statusIcon = listItem.querySelector('.statusIcon');

        if (progress === 0) {
            statusIcon.innerHTML = 'file_download';
            statusIcon.classList.add('md-icon');
            statusIcon.classList.remove('status-text-icon');
            statusIcon.classList.add('zeroProgressStatus');
        } else if (progress >= 100) {
            statusIcon.innerHTML = 'file_download';
            statusIcon.classList.add('md-icon');
            statusIcon.classList.remove('status-text-icon');
            statusIcon.classList.remove('zeroProgressStatus');
        } else {
            statusIcon.classList.remove('md-icon');
            statusIcon.classList.remove('zeroProgressStatus');
            statusIcon.classList.add('status-text-icon');
            statusIcon.innerHTML = (Math.round(progress)) + '%';
        }
    }

    function getSyncJobHtml(listInstance, job) {

        var html = '';

        html += '<div class="listItem" data-id="' + job.Id + '" data-status="' + job.Status + '">';

        var progress = job.Progress || 0;

        if (progress === 0) {
            html += '<i class="md-icon listItemIcon statusIcon zeroProgressStatus">file_download</i>';
        } else if (progress >= 100) {
            html += '<i class="md-icon listItemIcon statusIcon">file_download</i>';
        } else {
            html += '<i class="listItemIcon statusIcon status-text-icon">' + (Math.round(progress)) + '%</i>';
        }

        var textLines = [];

        if (job.ParentName) {
            textLines.push(job.ParentName);
        }

        textLines.push(job.Name);

        if (job.ItemCount == 1) {
            textLines.push(globalize.translate('ValueItemCount', job.ItemCount));
        } else {
            textLines.push(globalize.translate('ValueItemCountPlural', job.ItemCount));
        }

        if (textLines >= 3) {
            html += '<div class="listItemBody three-line">';
        } else {
            html += '<div class="listItemBody two-line">';
        }

        for (var i = 0, length = textLines.length; i < length; i++) {

            if (i == 0) {
                html += '<h3 class="listItemBodyText">';
                html += textLines[i];
                html += '</h3>';
            } else {
                html += '<div class="listItemBodyText secondary">';
                html += textLines[i];
                html += '</div>';
            }
        }

        html += '</div>';

        html += '<button type="button" is="paper-icon-button-light" class="btnJobMenu listItemButton"><i class="md-icon">more_vert</i></button>';

        html += '</div>';

        return html;
    }

    function renderList(listInstance, jobs) {

        if ((new Date().getTime() - listInstance.lastDataLoad) < 60000) {
            refreshList(listInstance, jobs);
            return;
        }

        listInstance.lastDataLoad = new Date().getTime();

        var html = '';
        var lastTargetName = '';

        var showTargetName = !listInstance.options.isLocalSync;

        var hasOpenSection = false;

        for (var i = 0, length = jobs.length; i < length; i++) {

            var job = jobs[i];
            if (showTargetName) {
                var targetName = job.TargetName || 'Unknown';

                if (targetName != lastTargetName) {

                    if (lastTargetName) {
                        html += '</div>';
                        html += '<br/>';
                        html += '<br/>';
                        html += '<br/>';
                        hasOpenSection = false;
                    }

                    lastTargetName = targetName;

                    html += '<div class="detailSectionHeader">';

                    html += '<div>' + targetName + '</div>';

                    html += '</div>';
                    html += '<div class="itemsContainer vertical-list">';
                    hasOpenSection = true;
                }
            }

            html += getSyncJobHtml(listInstance, job);
        }

        if (hasOpenSection) {
            html += '</div>';
        }

        var elem = listInstance.options.element;
        elem.innerHTML = html;

        imageLoader.lazyChildren(elem);
    }

    function fetchData(listInstance) {

        listInstance.lastDataLoad = 0;
        loading.show();

        var options = {};
        var apiClient = getApiClient(listInstance);

        if (listInstance.options.userId) {
            options.UserId = listInstance.options.userId;
        }

        if (listInstance.options.isLocalSync) {
            options.TargetId = apiClient.deviceId();
        }

        return apiClient.getJSON(ApiClient.getUrl('Sync/Jobs', options)).then(function (response) {

            renderList(listInstance, response.Items);
            loading.hide();
        });
    }

    function startListening(listInstance) {

        var startParams = "0,1500";

        var apiClient = getApiClient(listInstance);

        if (listInstance.options.userId) {
            startParams += "," + listInstance.options.userId;
        }
        if (listInstance.options.isLocalSync) {
            startParams += "," + apiClient.deviceId();
        }

        if (apiClient.isWebSocketOpen()) {
            apiClient.sendWebSocketMessage("SyncJobsStart", startParams);
        }
    }

    function stopListening(listInstance) {

        var apiClient = getApiClient(listInstance);
        if (apiClient.isWebSocketOpen()) {
            apiClient.sendWebSocketMessage("SyncJobsStop", "");
        }
    }

    function getApiClient(listInstance) {
        return connectionManager.getApiClient(listInstance.options.serverId);
    }

    function showJobMenu(listInstance, elem) {

        var item = dom.parentWithClass(elem, 'listItem');
        var jobId = item.getAttribute('data-id');
        var status = item.getAttribute('data-status');

        var menuItems = [];

        if (status == 'Cancelled') {
            menuItems.push({
                name: globalize.translate('ButtonDelete'),
                id: 'delete'
            });
        } else {
            menuItems.push({
                name: globalize.translate('ButtonCancelSyncJob'),
                id: 'cancel'
            });
        }

        require(['actionsheet'], function (actionsheet) {

            actionsheet.show({
                items: menuItems,
                positionTo: elem,
                callback: function (id) {

                    switch (id) {

                        case 'delete':
                            cancelJob(listInstance, jobId);
                            break;
                        case 'cancel':
                            cancelJob(listInstance, jobId);
                            break;
                        default:
                            break;
                    }
                }
            });

        });
    }

    function onElementClick(e) {

        var listInstance = this;

        var btnJobMenu = dom.parentWithClass(e.target, 'btnJobMenu');
        if (btnJobMenu) {
            showJobMenu(this, btnJobMenu);
            return;
        }

        var listItem = dom.parentWithClass(e.target, 'listItem');
        if (listItem) {
            var jobId = listItem.getAttribute('data-id');
            // edit job
            events.trigger(listInstance, 'jobedit', [jobId, listInstance.options.serverId]);
        }
    }

    function syncJobList(options) {
        this.options = options;

        var onSyncJobsUpdatedHandler = onSyncJobsUpdated.bind(this);
        this.onSyncJobsUpdatedHandler = null;
        events.on(serverNotifications, 'SyncJobs', onSyncJobsUpdatedHandler);

        var onClickHandler = onElementClick.bind(this);
        options.element.addEventListener('click', onClickHandler);
        this.onClickHandler = onClickHandler;

        fetchData(this);
        startListening(this);
    }

    syncJobList.prototype.destroy = function () {

        stopListening(this);

        this.options = null;

        var onSyncJobsUpdatedHandler = this.onSyncJobsUpdatedHandler;
        this.onSyncJobsUpdatedHandler = null;
        events.off(serverNotifications, 'SyncJobs', onSyncJobsUpdatedHandler);

        var onClickHandler = this.onClickHandler;
        this.onClickHandler = null;
        options.element.removeEventListener('click', onClickHandler);
    };

    return syncJobList;
});