1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
import { Location } from '@angular/common';
import { Component, OnDestroy, OnInit } from '@angular/core';
import { AbstractControl, FormControl, Validators } from '@angular/forms';
import { ActivatedRoute } from '@angular/router';
import { NgbActiveModal } from '@ng-bootstrap/ng-bootstrap';
import { Subscription } from 'rxjs';
import { RbdMirroringService } from '~/app/shared/api/rbd-mirroring.service';
import { ActionLabelsI18n } from '~/app/shared/constants/app.constants';
import { CdFormGroup } from '~/app/shared/forms/cd-form-group';
import { FinishedTask } from '~/app/shared/models/finished-task';
import { TaskWrapperService } from '~/app/shared/services/task-wrapper.service';
import { PoolEditModeResponseModel } from './pool-edit-mode-response.model';
@Component({
selector: 'cd-pool-edit-mode-modal',
templateUrl: './pool-edit-mode-modal.component.html',
styleUrls: ['./pool-edit-mode-modal.component.scss']
})
export class PoolEditModeModalComponent implements OnInit, OnDestroy {
poolName: string;
subs: Subscription;
editModeForm: CdFormGroup;
bsConfig = {
containerClass: 'theme-default'
};
pattern: string;
response: PoolEditModeResponseModel;
peerExists = false;
mirrorModes: Array<{ id: string; name: string }> = [
{ id: 'disabled', name: $localize`Disabled` },
{ id: 'pool', name: $localize`Pool` },
{ id: 'image', name: $localize`Image` }
];
constructor(
public activeModal: NgbActiveModal,
public actionLabels: ActionLabelsI18n,
private rbdMirroringService: RbdMirroringService,
private taskWrapper: TaskWrapperService,
private route: ActivatedRoute,
private location: Location
) {
this.createForm();
}
createForm() {
this.editModeForm = new CdFormGroup({
mirrorMode: new FormControl('', {
validators: [Validators.required, this.validateMode.bind(this)]
})
});
}
ngOnInit() {
this.route.params.subscribe((params: { pool_name: string }) => {
this.poolName = params.pool_name;
});
this.pattern = `${this.poolName}`;
this.rbdMirroringService.getPool(this.poolName).subscribe((resp: PoolEditModeResponseModel) => {
this.setResponse(resp);
});
this.subs = this.rbdMirroringService.subscribeSummary((data) => {
this.peerExists = false;
const poolData = data.content_data.pools;
const pool = poolData.find((o: any) => this.poolName === o['name']);
this.peerExists = pool && pool['peer_uuids'].length;
});
}
ngOnDestroy(): void {
this.subs.unsubscribe();
}
validateMode(control: AbstractControl) {
if (control.value === 'disabled' && this.peerExists) {
return { cannotDisable: { value: control.value } };
}
return null;
}
setResponse(response: PoolEditModeResponseModel) {
this.editModeForm.get('mirrorMode').setValue(response.mirror_mode);
}
update() {
const request = new PoolEditModeResponseModel();
request.mirror_mode = this.editModeForm.getValue('mirrorMode');
const action = this.taskWrapper.wrapTaskAroundCall({
task: new FinishedTask('rbd/mirroring/pool/edit', {
pool_name: this.poolName
}),
call: this.rbdMirroringService.updatePool(this.poolName, request)
});
action.subscribe({
error: () => this.editModeForm.setErrors({ cdSubmitButton: true }),
complete: () => {
this.rbdMirroringService.refresh();
this.location.back();
}
});
}
}
|
