$(document).ready(function() {
  // Setup initial state

    var ids = [];
    $.each(KT.repo_status, function(repo_id, status){
      if (status.is_running) {
          ids.push(repo_id);
          KT.content.draw_syncing(repo_id, status.progress.progress, status.sync_id);
      }
    });
    KT.content.reset_products(KT.repo_status);
    KT.content_actions.addSyncing(ids);

    $('#select_all').click(KT.content.select_all);
    $('#select_none').click(KT.content.select_none);
    $('#collapse_all').click(KT.content.collapse_all);
    $('#expand_all').click(KT.content.expand_all);

    KT.content.showAll();
    KT.content.select_repo();

    $("#products_table").delegate(".cancel_sync", "click", function(){
        var repo_id = $(this).parents("tr").attr("data-id");
        KT.content_actions.cancelSync(repo_id, $(this));
    });

    $('#sync_product_form').bind("ajax:success",
      function(evt, data, status, xhr){
       var ids = [];
       $.each(data, function(index, item){
          ids.push(item.id);
          KT.content.draw_syncing(item.id, 0, undefined);
          KT.content.updateProduct(item.product_id, false, 0);
       });
       KT.content_actions.addSyncing(ids);
    })
    .bind("ajax:beforeSend",
      function(evt, data, status, xhr) {
        if ($("input[name='repoids[]']:checked").length === 0) {
          return false;
        }
    });

    $("#sync_toggle").change(function(){
        var img = "<img  src='" + KT.common.spinner_path() + "'>";
        $("#sync_toggle_cont").append(img);
        if ($(this).is(":checked")){
            KT.content.showOnlySyncing();
        }
        else {
            KT.content.showAll();
        }
        $("#sync_toggle_cont").find("img").remove();
    });

    $.each($("input[name='repoids[]']"), function(index, checkbox) {
      $(checkbox).click(KT.content.select_repo);
    });

});

KT.content_actions = (function(){
    var syncing = [],
    updater,
    getOrg = function() {
        return $('#organization_id').val();
    },
    addSyncing = function(repo_ids){
        if (repo_ids.length === 0){
            return;
        }
        //nothing in the list before adding and updater already exists
        var start = syncing.length === 0 && updater;
        $.each(repo_ids, function(index, id){
            syncing.push(id + "");
        });
        if (!updater){
            startUpdater();
        }
        else if (start){
            updater.restart();
        }
    },
    removeSyncing = function(repo_id){
      syncing.splice($.inArray(repo_id + "", syncing), 1);
      if (syncing.length === 0 && updater){
          updater.stop();
      }
    },
    getSyncing = function(){
        return syncing;
    },
    cancelSync = function(repo_id){
        var button = $("#repo-" + repo_id).find(".result .cancel_sync");

        if( !$(button).hasClass('disabled') ){
            button.addClass('disabled');

            $.ajax({
              type: 'DELETE',
              url: foreman_url('/katello/sync_management/' + repo_id + '?organization_id=' + getOrg()),
              dataType: 'json',
              success: function(data) {
              },
              error: function(data) {
                    button.removeClass('disabled');
              }
            });
        }
    },
    startUpdater = function(){
        if (syncing.length ===0){
            return;
        }
        var url = foreman_url('/katello/sync_management/sync_status');
        updater = $.PeriodicalUpdater(url, {
              data: function(){return {repoids:getSyncing(), organization_id:getOrg()}},
              method: 'get',
              type: 'json',
              global: false
            },
            function(data,success) {
               if (success === "notmodified") {
                 return;
               }
               $.each(data, function(index, repo){
                   // Only stop when we reach 100% and the finish_time is done sometimes they are not both complete
                   if (!repo.is_running && (repo.raw_state !== 'waiting')) {
                        removeSyncing(repo.id);
                        KT.content.updateRepo(repo.id, repo.start_time, repo.duration, repo.progress.progress, repo.display_size, repo.packages, repo.size, repo.sync_id);
                        KT.content.finishRepo(repo.id, repo.state, repo.duration, repo.raw_state, repo.error_details, repo.sync_id);
                        KT.content.updateProduct(repo.product_id, false, false, true);
                   }
                   else {
                    KT.content.updateRepo(  repo.id,
                                            repo.start_time,
                                            repo.duration,
                                            repo.progress.progress,
                                            repo.display_size,
                                            repo.packages,
                                            repo.size,
                                            repo.sync_id);
                   }
               });
               KT.content.reset_products(data);
            },
            function(){
                updater.stop();
            }
        );

    };

    return {
        cancelSync: cancelSync,
        addSyncing: addSyncing,
        startUpdater: startUpdater,
        getSyncing: function(){return syncing}
    };
})();

KT.content = (function(){

     var draw_syncing = function(repo_id, progress, task_id){
            var element = $("#repo-" + repo_id).find(".result"),
                cancelButton = $('<a/>').attr("class", "cancel_sync").text(katelloI18n.cancel),
                progressBar = $('<a/>').attr('class', 'progress').text(" ");

            if(task_id !== undefined) {
                progressBar.attr('href', foreman_url('/foreman_tasks/tasks/' + task_id));
            }

            progress = progress ? progress : 0;
            progressBar.progressbar({
                value: progress
            });
            element.find('.result-info').html("");
            element.find('.result-info').append(progressBar);
            element.find('.info-tipsy').addClass('hidden');

            if( KT.permissions.syncable ){
                element.find('.result-info').append(cancelButton);
            }
        },
        updateRepo = function(repo_id, starttime, duration, progress, display_size, packages, size, task_id){
            var repo = $("#repo-" + repo_id);
            update_item(repo, starttime, duration, progress, display_size, packages, size, task_id);
        },
        finishRepo = function(repo_id, state, duration, raw_state, error_details, task_id){
            var element = $("#repo-" + repo_id);
            var messages = [];
            var url = foreman_url('/foreman_tasks/tasks/' + task_id);
            state = '<a href="' + url + '">' + state + '</a>';
            element.find(".result .result-info").html(state);
            fadeUpdate(element.find(".duration"), duration);

            if (raw_state === 'error') {
                element.find('.result .info-tipsy').removeClass('hidden');

                KT.utils.forEach(error_details['messages'], function (message) {
                    messages.push('<li>' + message + '</li>');
                });

                element.find('.result .info-tipsy ul').html(messages.join(''));
            }
        },
        update_item = function(element, starttime, duration, progress, display_size, packages, size, task_id) {
            var pg = element.find(".progress"),
                value = pg.find(".ui-progressbar-value");

            starttime = starttime === null ? katelloI18n.no_start_time : starttime;

            if(task_id !== undefined) {
                pg.attr('href', foreman_url('/foreman_tasks/tasks/' + task_id));
            }

            fadeUpdate(element.find(".start_time"), starttime);
            // clear duration during active sync
            fadeUpdate(element.find(".duration"), '');
            fadeUpdate(element.find(".size"), display_size);
            element.find('.size').data('size', size);
            element.find('.info-tipsy').attr('href', foreman_url('/foreman_tasks/tasks/' + task_id));
            progress = progress === 100 ? 99 : progress;
            value.show();
            value.animate({'width': progress },{ queue:false,
                                           duration:"slow", easing:"easeInSine" });
        },
        updateProduct = function (prod_id, done, percent, size) {
            var product_element = $("#product-" + prod_id),
                element = product_element.find(".result"),
                oldpg = element.find('.progress');

            if( size ){
                size = KT.utils.reduce($('table').find("[data-product_id=" + prod_id + "]").find('.size'), function(memo, num){ return $(num).data('size') + memo;}, 0);
                fadeUpdate(product_element.find('.size'), KT.common.to_human_readable_bytes(size));
            } else if(done){
                element.html("");
            }
            else{
                if (oldpg.length === 0){
                    element.html($('<div/>').attr('class', 'progress').text(" "));
                    element.find(".progress").progressbar({value: 0});
                }
                else {
                    var value = oldpg.find(".ui-progressbar-value");
                    percent = percent === 100 ? 99 : percent;
                    value.animate({'width': percent },{ queue:false,
                          duration:"slow", easing:"easeInSine" });
                }
            }
        },
        fadeUpdate = function(element, text) {
            //element.fadeOut('fast').text(text);
            //element.fadeIn('fast');
            element.text(text);
        },
        select_all = function(){
            $("#products_table").find("input[type=checkbox]").prop('checked',true);
            KT.content.select_repo();
        },
        select_none = function(){
            $("#products_table").find("input[type=checkbox]").removeAttr('checked');
            KT.content.select_repo();
        },
        select_repo = function(){
            if($("input[name='repoids[]']:checked").length > 0) {
                $("#sync_button").removeClass("disabled");
            } else {
                $("#sync_button").addClass("disabled");
            }
        },
        reset_products = function(status_set){
            var products = {};
            $.each(status_set, function(index, item){
                var pid = item.product_id;
                if(products[pid] === undefined){
                    products[pid] = [];
                }
                if (item.is_running){
                    products[pid].push(item.progress.progress);
                }
            });
            $.each(products, function(prod_id, percentages){
                var total = 0;
                $.each(percentages, function(i, val){total += val;});
                updateProduct(prod_id, percentages.length === 0, total/percentages.length);
            });
        },
        showOnlySyncing = function(){
            $("#products_table").find("tbody").find("tr").hide();
            $.each(KT.content_actions.getSyncing(), function(index, repoid){
                var repo = $("#repo-" + repoid);
                showChain(repo);
            });
        },
        showChain = function(element){
            element.show().addClass("expanded").removeClass("collapsed");
            $.each(element.attr("class").split(" "), function(index, claz){
                if (claz.indexOf("child-of-") === 0){
                    var found = claz.split("child-of-")[1];
                    showChain($("#" + found));
                }
            });
        },
        showAll = function(){
            var rows = $("#products_table").find("tbody").find("tr").show().removeClass("expanded").addClass("collapsed");

            $("#products_table").treeTable({
                clickableNodeNames: true,
                indent: 15
            });
        },
        expand_all = function() {
          var sync_toggle = $("#sync_toggle");
          if($(sync_toggle).is(":checked")) {
            $(sync_toggle).removeAttr("checked");
            KT.content.showAll();
          }
          $("#products_table").find("tr").removeClass("collapsed").addClass("expanded").each(function(){
            $(this).expand();
          });
        },
        collapse_all = function() {
          $("#products_table").find("tr").removeClass("expanded").addClass("collapsed").each(function(){
            $(this).collapse();
          });
        };

    return {
        updateProduct: updateProduct,
        updateRepo: updateRepo,
        finishRepo: finishRepo,
        select_all : select_all,
        select_none: select_none,
        select_repo: select_repo,
        draw_syncing: draw_syncing,
        reset_products: reset_products,
        showOnlySyncing: showOnlySyncing,
        showAll: showAll,
        expand_all: expand_all,
        collapse_all: collapse_all
    };
})();