mirror of https://github.com/portainer/portainer
113 lines
4.1 KiB
JavaScript
113 lines
4.1 KiB
JavaScript
|
angular.module('portainer.docker')
|
||
|
.controller('ServicesController', ['$q', '$scope', '$state', 'Service', 'ServiceService', 'ServiceHelper', 'Notifications', 'Task', 'Node', 'NodeHelper', 'ModalService',
|
||
|
function ($q, $scope, $state, Service, ServiceService, ServiceHelper, Notifications, Task, Node, NodeHelper, ModalService) {
|
||
|
|
||
|
$scope.scaleAction = function scaleService(service) {
|
||
|
var config = ServiceHelper.serviceToConfig(service.Model);
|
||
|
config.Mode.Replicated.Replicas = service.Replicas;
|
||
|
ServiceService.update(service, config)
|
||
|
.then(function success(data) {
|
||
|
Notifications.success('Service successfully scaled', 'New replica count: ' + service.Replicas);
|
||
|
$state.reload();
|
||
|
})
|
||
|
.catch(function error(err) {
|
||
|
Notifications.error('Failure', err, 'Unable to scale service');
|
||
|
service.Scale = false;
|
||
|
service.Replicas = service.ReplicaCount;
|
||
|
});
|
||
|
};
|
||
|
|
||
|
$scope.forceUpdateAction = function(selectedItems) {
|
||
|
ModalService.confirmServiceForceUpdate(
|
||
|
'Do you want to force update of selected service(s)? All the tasks associated to the selected service(s) will be recreated.',
|
||
|
function onConfirm(confirmed) {
|
||
|
if(!confirmed) { return; }
|
||
|
forceUpdateServices(selectedItems);
|
||
|
}
|
||
|
);
|
||
|
};
|
||
|
|
||
|
function forceUpdateServices(services) {
|
||
|
var actionCount = services.length;
|
||
|
angular.forEach(services, function (service) {
|
||
|
var config = ServiceHelper.serviceToConfig(service.Model);
|
||
|
// As explained in https://github.com/docker/swarmkit/issues/2364 ForceUpdate can accept a random
|
||
|
// value or an increment of the counter value to force an update.
|
||
|
config.TaskTemplate.ForceUpdate++;
|
||
|
ServiceService.update(service, config)
|
||
|
.then(function success(data) {
|
||
|
Notifications.success('Service successfully updated', service.Name);
|
||
|
})
|
||
|
.catch(function error(err) {
|
||
|
Notifications.error('Failure', err, 'Unable to force update service', service.Name);
|
||
|
})
|
||
|
.finally(function final() {
|
||
|
--actionCount;
|
||
|
if (actionCount === 0) {
|
||
|
$state.reload();
|
||
|
}
|
||
|
});
|
||
|
});
|
||
|
}
|
||
|
|
||
|
$scope.removeAction = function(selectedItems) {
|
||
|
ModalService.confirmDeletion(
|
||
|
'Do you want to remove the selected service(s)? All the containers associated to the selected service(s) will be removed too.',
|
||
|
function onConfirm(confirmed) {
|
||
|
if(!confirmed) { return; }
|
||
|
removeServices(selectedItems);
|
||
|
}
|
||
|
);
|
||
|
};
|
||
|
|
||
|
function removeServices(services) {
|
||
|
var actionCount = services.length;
|
||
|
angular.forEach(services, function (service) {
|
||
|
ServiceService.remove(service)
|
||
|
.then(function success() {
|
||
|
Notifications.success('Service successfully removed', service.Name);
|
||
|
var index = $scope.services.indexOf(service);
|
||
|
$scope.services.splice(index, 1);
|
||
|
})
|
||
|
.catch(function error(err) {
|
||
|
Notifications.error('Failure', err, 'Unable to remove service');
|
||
|
})
|
||
|
.finally(function final() {
|
||
|
--actionCount;
|
||
|
if (actionCount === 0) {
|
||
|
$state.reload();
|
||
|
}
|
||
|
});
|
||
|
});
|
||
|
}
|
||
|
|
||
|
function initView() {
|
||
|
$q.all({
|
||
|
services: Service.query({}).$promise,
|
||
|
tasks: Task.query({filters: {'desired-state': ['running','accepted']}}).$promise,
|
||
|
nodes: Node.query({}).$promise
|
||
|
})
|
||
|
.then(function success(data) {
|
||
|
$scope.swarmManagerIP = NodeHelper.getManagerIP(data.nodes);
|
||
|
$scope.services = data.services.map(function (service) {
|
||
|
var runningTasks = data.tasks.filter(function (task) {
|
||
|
return task.ServiceID === service.ID && task.Status.State === 'running';
|
||
|
});
|
||
|
var allTasks = data.tasks.filter(function (task) {
|
||
|
return task.ServiceID === service.ID;
|
||
|
});
|
||
|
var taskNodes = data.nodes.filter(function (node) {
|
||
|
return node.Spec.Availability === 'active' && node.Status.State === 'ready';
|
||
|
});
|
||
|
return new ServiceViewModel(service, runningTasks, allTasks, taskNodes);
|
||
|
});
|
||
|
})
|
||
|
.catch(function error(err) {
|
||
|
$scope.services = [];
|
||
|
Notifications.error('Failure', err, 'Unable to retrieve services');
|
||
|
});
|
||
|
}
|
||
|
|
||
|
initView();
|
||
|
}]);
|