harbor/static/resources/js/components/replication/create-policy.directive.js

(function() {
  
  'use strict';
  
  angular
    .module('harbor.replication')
    .directive('createPolicy', createPolicy);
  
  CreatePolicyController.$inject = ['$scope', 'ListReplicationPolicyService', 'ListDestinationService', 'UpdateDestinationService', 'PingDestinationService', 'CreateReplicationPolicyService', 'UpdateReplicationPolicyService', '$location', 'getParameterByName'];
  
  function CreatePolicyController($scope, ListReplicationPolicyService, ListDestinationService, UpdateDestinationService, PingDestinationService, CreateReplicationPolicyService, UpdateReplicationPolicyService, $location, getParameterByName) {
    var vm = this;
    
    //Since can not set value for textarea by using vm
    //use $scope for instead.
    $scope.replication = {};
    $scope.replication.policy = {};
    $scope.replication.destination = {};
    
    var vm0 = $scope.replication.policy;
    var vm1 = $scope.replication.destination;
            
    vm.selectDestination = selectDestination;
    vm.projectId = getParameterByName('project_id', $location.absUrl());
    
    $scope.$on('$locationChangeSuccess', function() {
      vm.projectId = getParameterByName('project_id', $location.absUrl());
    });
    
    vm.addNew = addNew;
    vm.edit = edit;
    vm.prepareDestination = prepareDestination;
    vm.create = create;
    vm.update = update;
    vm.pingDestination = pingDestination;
        
    $scope.$watch('vm.destinations', function(current) {
      if(current) {
        vm1.selection = current[0]; 
        vm1.endpoint = vm1.selection.endpoint;
        vm1.username = vm1.selection.username;
        vm1.password = vm1.selection.password;
      }
    });
                             
    $scope.$watch('vm.action+","+vm.policyId', function(current) {
      if(current) {
        console.log('Current action for replication policy:' + current);
        var parts = current.split(',');
        vm.action = parts[0];
        vm.policyId = Number(parts[1]);
        switch(parts[0]) {
        case 'ADD_NEW':
          vm.addNew(); 
          break;
        case 'EDIT':
          vm.edit(vm.policyId); 
          break;
        }    
      }
    });
    
    function selectDestination(item) {
      vm1.selection = item;
      vm1.endpoint = item.endpoint;
      vm1.username = item.username;
      vm1.password = item.password;
    }
    
    function prepareDestination() {
      ListDestinationService('')
        .success(listDestinationSuccess)
        .error(listDestinationFailed);
    }

    function addNew() {       
      vm0.name = '';
      vm0.description = '';
      vm0.enabled = true;
    }
    
    function edit(policyId) {
      console.log('Edit policy ID:' + policyId);
      ListReplicationPolicyService(policyId)
        .success(listReplicationPolicySuccess)
        .error(listReplicationPolicyFailed);
    }
    
    function create(policy) {
      CreateReplicationPolicyService(policy)
        .success(createReplicationPolicySuccess)
        .error(createReplicationPolicyFailed);
    }
    
    function update(policy) {
      console.log('Update policy ID:' + vm.policyId);
      UpdateReplicationPolicyService(vm.policyId, policy)
        .success(updateReplicationPolicySuccess)
        .error(updateReplicationPolicyFailed);
        
      var targetId = vm1.selection.id;
      console.log('Update target ID:' + targetId);
      var target = {
        'name': vm1.selection.name,
        'endpoint': vm1.endpoint,
        'username': vm1.username,
        'password': vm1.password
      };
      UpdateDestinationService(targetId, target)
        .success(updateDestinationSuccess)
        .error(updateDestinationFailed);
    }
    
    function pingDestination() {
      var target = {
        'name': vm1.selection.name,
        'endpoint': vm1.endpoint,
        'username': vm1.username,
        'password': vm1.password
      };
      PingDestinationService(target)
        .success(pingDestinationSuccess)
        .error(pingDestinationFailed);
    }
    
    function listDestinationSuccess(data, status) {
      vm.destinations = data || [];
    }
    function listDestinationFailed(data, status) {
      console.log('Failed list destination:' + data);
    }
    function listReplicationPolicySuccess(data, status) {
      var replicationPolicy = data;
      vm0.name = replicationPolicy.name;
      vm0.description = replicationPolicy.description;
      vm0.enabled = replicationPolicy.enabled == 1;
      vm.targetId = replicationPolicy.target_id;
    }
    function listReplicationPolicyFailed(data, status) {
      console.log('Failed list replication policy:' + data);
    }
    function createReplicationPolicySuccess(data, status) {
      console.log('Successful create replication policy.');
      vm.reload();
    }
    function createReplicationPolicyFailed(data, status) {
      if(status === 409) {
        alert('Policy name already exists.');
      }
      console.log('Failed create replication policy.');
    }
    function updateReplicationPolicySuccess(data, status) {
      console.log('Successful update replication policy.');
      vm.reload();
    }
    function updateReplicationPolicyFailed(data, status) {
      console.log('Failed update replication policy.');
    }
    function updateDestinationSuccess(data, status) {
      console.log('Successful update destination.');
    }
    function updateDestinationFailed(data, status) {
      console.log('Failed update destination.');
    }
    function pingDestinationSuccess(data, status) {
      alert('Successful ping target.');
    }
    function pingDestinationFailed(data, status) {
      alert('Failed ping target:' + data);
    }
  }
  
  function createPolicy() {
    var directive = {
      'restrict': 'E',
      'templateUrl': '/static/resources/js/components/replication/create-policy.directive.html',
      'scope': {
        'policyId': '@',
        'modalTitle': '@',
        'reload': '&',
        'action': '='
      },
      'link': link,
      'controller': CreatePolicyController,
      'controllerAs': 'vm',
      'bindToController': true
    };
    return directive;
    
    function link(scope, element, attr, ctrl) {  
      
      element.find('#createPolicyModal').on('show.bs.modal', function() {    
        ctrl.prepareDestination();
        scope.form.$setPristine();
        scope.form.$setUntouched();
      });  
            
      ctrl.save = save;
    
      function save(form) {
        var postPayload = {
          'projectId': Number(ctrl.projectId),
          'targetId': form.destination.selection.id,
          'name': form.policy.name,
          'enabled': form.policy.enabled ? 1 : 0,
          'description': form.policy.description,
          'cron_str': '',
          'start_time': ''
        };
        switch(ctrl.action) {
        case 'ADD_NEW':
          ctrl.create(postPayload);
          break;
        case 'EDIT':
          ctrl.update(postPayload);
          break;
        }
        element.find('#createPolicyModal').modal('hide');
      }
    }
  }
  
})();