mirror of https://github.com/portainer/portainer
89 lines
3.2 KiB
JavaScript
89 lines
3.2 KiB
JavaScript
import KubernetesNamespaceHelper from 'Kubernetes/helpers/namespaceHelper';
|
|
|
|
export default class KubernetesRegistryAccessController {
|
|
/* @ngInject */
|
|
constructor($async, $scope, $state, ModalService, EndpointService, Notifications, RegistryService, KubernetesResourcePoolService) {
|
|
this.$async = $async;
|
|
this.$scope = $scope;
|
|
this.$state = $state;
|
|
this.ModalService = ModalService;
|
|
this.Notifications = Notifications;
|
|
this.KubernetesResourcePoolService = KubernetesResourcePoolService;
|
|
this.RegistryService = RegistryService;
|
|
this.EndpointService = EndpointService;
|
|
|
|
this.state = {
|
|
actionInProgress: false,
|
|
};
|
|
|
|
this.selectedResourcePools = [];
|
|
this.resourcePools = [];
|
|
this.savedResourcePools = [];
|
|
|
|
this.handleRemove = this.handleRemove.bind(this);
|
|
this.onChangeResourcePools = this.onChangeResourcePools.bind(this);
|
|
}
|
|
|
|
async submit() {
|
|
return this.updateNamespaces([...this.savedResourcePools.map(({ value }) => value), ...this.selectedResourcePools]);
|
|
}
|
|
|
|
handleRemove(namespaces) {
|
|
const removeNamespaces = namespaces.map(({ value }) => value);
|
|
const nsToUpdate = this.savedResourcePools.map(({ value }) => value).filter((value) => !removeNamespaces.includes(value));
|
|
|
|
const displayedMessage =
|
|
'This registry might be used by one or more applications inside this environment. Removing the registry access could lead to a service interruption for these applications.<br/><br/>Do you wish to continue?';
|
|
this.ModalService.confirmDeletion(displayedMessage, (confirmed) => {
|
|
if (confirmed) {
|
|
return this.updateNamespaces(nsToUpdate);
|
|
}
|
|
});
|
|
}
|
|
|
|
updateNamespaces(namespaces) {
|
|
return this.$async(async () => {
|
|
try {
|
|
await this.EndpointService.updateRegistryAccess(this.endpoint.Id, this.registry.Id, {
|
|
namespaces,
|
|
});
|
|
this.$state.reload(this.$state.current);
|
|
} catch (err) {
|
|
this.Notifications.error('Failure', err, 'Failed saving registry access');
|
|
}
|
|
});
|
|
}
|
|
|
|
onChangeResourcePools(resourcePools) {
|
|
return this.$scope.$evalAsync(() => {
|
|
this.selectedResourcePools = resourcePools;
|
|
});
|
|
}
|
|
|
|
$onInit() {
|
|
return this.$async(async () => {
|
|
try {
|
|
this.state = {
|
|
registryId: this.$state.params.id,
|
|
};
|
|
this.registry = await this.RegistryService.registry(this.state.registryId, this.endpoint.Id);
|
|
if (this.registry.RegistryAccesses && this.registry.RegistryAccesses[this.endpoint.Id]) {
|
|
this.savedResourcePools = this.registry.RegistryAccesses[this.endpoint.Id].Namespaces.map((value) => ({ value }));
|
|
}
|
|
} catch (err) {
|
|
this.Notifications.error('Failure', err, 'Unable to retrieve registry details');
|
|
}
|
|
|
|
try {
|
|
const resourcePools = await this.KubernetesResourcePoolService.get();
|
|
|
|
this.resourcePools = resourcePools
|
|
.filter((pool) => !KubernetesNamespaceHelper.isSystemNamespace(pool.Namespace.Name) && !this.savedResourcePools.find(({ value }) => value === pool.Namespace.Name))
|
|
.map((pool) => ({ name: pool.Namespace.Name, id: pool.Namespace.Id }));
|
|
} catch (err) {
|
|
this.Notifications.error('Failure', err, 'Unable to retrieve namespaces');
|
|
}
|
|
});
|
|
}
|
|
}
|