git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/blob

   1 import { Component, OnInit } from '@angular/core';
   2 import { UntypedFormArray, UntypedFormControl, Validators } from '@angular/forms';
   3
   4 import { CdFormBuilder } from '~/app/shared/forms/cd-form-builder';
   5 import { ActionLabelsI18n, URLVerbs } from '~/app/shared/constants/app.constants';
   6 import { CdFormGroup } from '~/app/shared/forms/cd-form-group';
   7 import { CdValidators } from '~/app/shared/forms/cd-validators';
   8 import { Permission } from '~/app/shared/models/permissions';
   9 import { AuthStorageService } from '~/app/shared/services/auth-storage.service';
  10 import { TaskWrapperService } from '~/app/shared/services/task-wrapper.service';
  11 import { FinishedTask } from '~/app/shared/models/finished-task';
  12 import { ActivatedRoute, Router } from '@angular/router';
  13 import { InitiatorRequest, NvmeofService } from '~/app/shared/api/nvmeof.service';
  14
  15 @Component({
  16   selector: 'cd-nvmeof-initiators-form',
  17   templateUrl: './nvmeof-initiators-form.component.html',
  18   styleUrls: ['./nvmeof-initiators-form.component.scss']
  19 })
  20 export class NvmeofInitiatorsFormComponent implements OnInit {
  21   permission: Permission;
  22   initiatorForm: CdFormGroup;
  23   action: string;
  24   resource: string;
  25   pageURL: string;
  26   remove: boolean = false;
  27   subsystemNQN: string;
  28   removeHosts: { name: string; value: boolean; id: number }[] = [];
  29   group: string;
  30
  31   constructor(
  32     private authStorageService: AuthStorageService,
  33     public actionLabels: ActionLabelsI18n,
  34     private nvmeofService: NvmeofService,
  35     private taskWrapperService: TaskWrapperService,
  36     private router: Router,
  37     private route: ActivatedRoute,
  38     private formBuilder: CdFormBuilder
  39   ) {
  40     this.permission = this.authStorageService.getPermissions().nvmeof;
  41     this.resource = $localize`Initiator`;
  42     this.pageURL = 'block/nvmeof/subsystems';
  43   }
  44
  45   NQN_REGEX = /^nqn\.(19|20)\d\d-(0[1-9]|1[0-2])\.\D{2,3}(\.[A-Za-z0-9-]+)+(:[A-Za-z0-9-\.]+(:[A-Za-z0-9-\.]+)*)$/;
  46   NQN_REGEX_UUID = /^nqn\.2014-08\.org\.nvmexpress:uuid:[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$/;
  47   ALLOW_ALL_HOST = '*';
  48
  49   customNQNValidator = CdValidators.custom(
  50     'pattern',
  51     (nqnInput: string) =>
  52       !!nqnInput && !(this.NQN_REGEX.test(nqnInput) || this.NQN_REGEX_UUID.test(nqnInput))
  53   );
  54
  55   ngOnInit() {
  56     this.route.queryParams.subscribe((params) => {
  57       this.group = params?.['group'];
  58     });
  59     this.createForm();
  60     this.action = this.actionLabels.ADD;
  61     this.route.params.subscribe((params: { subsystem_nqn: string }) => {
  62       this.subsystemNQN = params.subsystem_nqn;
  63     });
  64   }
  65
  66   createForm() {
  67     this.initiatorForm = new CdFormGroup({
  68       allowAnyHost: new UntypedFormControl(false),
  69       addHost: new CdFormGroup({
  70         addHostCheck: new UntypedFormControl(false),
  71         addedHosts: this.formBuilder.array(
  72           [],
  73           [
  74             CdValidators.custom(
  75               'duplicate',
  76               (hosts: string[]) => !!hosts.length && new Set(hosts)?.size !== hosts.length
  77             )
  78           ]
  79         )
  80       })
  81     });
  82   }
  83
  84   get addedHosts(): UntypedFormArray {
  85     return this.initiatorForm.get('addHost.addedHosts') as UntypedFormArray;
  86   }
  87
  88   addHost() {
  89     let newHostFormGroup;
  90     newHostFormGroup = this.formBuilder.control('', [this.customNQNValidator, Validators.required]);
  91     this.addedHosts.push(newHostFormGroup);
  92   }
  93
  94   removeHost(index: number) {
  95     this.addedHosts.removeAt(index);
  96   }
  97
  98   setAddHostCheck() {
  99     const addHostCheck = this.initiatorForm.get('addHost.addHostCheck').value;
 100     if (!addHostCheck) {
 101       while (this.addedHosts.length !== 0) {
 102         this.addedHosts.removeAt(0);
 103       }
 104     } else {
 105       this.addHost();
 106     }
 107   }
 108
 109   onSubmit() {
 110     const component = this;
 111     const allowAnyHost: boolean = this.initiatorForm.getValue('allowAnyHost');
 112     const hosts: string[] = this.addedHosts.value;
 113     let taskUrl = `nvmeof/initiator/${URLVerbs.ADD}`;
 114
 115     const request: InitiatorRequest = {
 116       host_nqn: hosts.join(','),
 117       gw_group: this.group
 118     };
 119
 120     if (allowAnyHost) {
 121       hosts.push('*');
 122       request['host_nqn'] = hosts.join(',');
 123     }
 124     this.taskWrapperService
 125       .wrapTaskAroundCall({
 126         task: new FinishedTask(taskUrl, {
 127           nqn: this.subsystemNQN
 128         }),
 129         call: this.nvmeofService.addInitiators(this.subsystemNQN, request)
 130       })
 131       .subscribe({
 132         error() {
 133           component.initiatorForm.setErrors({ cdSubmitButton: true });
 134         },
 135         complete: () => {
 136           this.router.navigate([this.pageURL, { outlets: { modal: null } }]);
 137         }
 138       });
 139   }
 140 }