ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/api/rgw-bucket.service.ts

   1 import { HttpClient, HttpParams } from '@angular/common/http';
   2 import { Injectable } from '@angular/core';
   3
   4 import _ from 'lodash';
   5 import { of as observableOf } from 'rxjs';
   6 import { mergeMap } from 'rxjs/operators';
   7
   8 import { RgwDaemonService } from '~/app/shared/api/rgw-daemon.service';
   9 import { cdEncode } from '~/app/shared/decorators/cd-encode';
  10
  11 @cdEncode
  12 @Injectable({
  13   providedIn: 'root'
  14 })
  15 export class RgwBucketService {
  16   private url = 'api/rgw/bucket';
  17
  18   constructor(private http: HttpClient, private rgwDaemonService: RgwDaemonService) {}
  19
  20   /**
  21    * Get the list of buckets.
  22    * @return Observable<Object[]>
  23    */
  24   list() {
  25     return this.rgwDaemonService.request((params: HttpParams) => {
  26       params = params.append('stats', 'true');
  27       return this.http.get(this.url, { params: params });
  28     });
  29   }
  30
  31   /**
  32    * Get the list of bucket names.
  33    * @return Observable<string[]>
  34    */
  35   enumerate() {
  36     return this.rgwDaemonService.request((params: HttpParams) => {
  37       return this.http.get(this.url, { params: params });
  38     });
  39   }
  40
  41   get(bucket: string) {
  42     return this.rgwDaemonService.request((params: HttpParams) => {
  43       return this.http.get(`${this.url}/${bucket}`, { params: params });
  44     });
  45   }
  46
  47   create(
  48     bucket: string,
  49     uid: string,
  50     zonegroup: string,
  51     placementTarget: string,
  52     lockEnabled: boolean,
  53     lock_mode: 'GOVERNANCE' | 'COMPLIANCE',
  54     lock_retention_period_days: string,
  55     lock_retention_period_years: string
  56   ) {
  57     return this.rgwDaemonService.request((params: HttpParams) => {
  58       return this.http.post(this.url, null, {
  59         params: new HttpParams({
  60           fromObject: {
  61             bucket,
  62             uid,
  63             zonegroup,
  64             placement_target: placementTarget,
  65             lock_enabled: String(lockEnabled),
  66             lock_mode,
  67             lock_retention_period_days,
  68             lock_retention_period_years,
  69             daemon_name: params.get('daemon_name')
  70           }
  71         })
  72       });
  73     });
  74   }
  75
  76   update(
  77     bucket: string,
  78     bucketId: string,
  79     uid: string,
  80     versioningState: string,
  81     mfaDelete: string,
  82     mfaTokenSerial: string,
  83     mfaTokenPin: string,
  84     lockMode: 'GOVERNANCE' | 'COMPLIANCE',
  85     lockRetentionPeriodDays: string,
  86     lockRetentionPeriodYears: string
  87   ) {
  88     return this.rgwDaemonService.request((params: HttpParams) => {
  89       params = params.append('bucket_id', bucketId);
  90       params = params.append('uid', uid);
  91       params = params.append('versioning_state', versioningState);
  92       params = params.append('mfa_delete', mfaDelete);
  93       params = params.append('mfa_token_serial', mfaTokenSerial);
  94       params = params.append('mfa_token_pin', mfaTokenPin);
  95       params = params.append('lock_mode', lockMode);
  96       params = params.append('lock_retention_period_days', lockRetentionPeriodDays);
  97       params = params.append('lock_retention_period_years', lockRetentionPeriodYears);
  98       return this.http.put(`${this.url}/${bucket}`, null, { params: params });
  99     });
 100   }
 101
 102   delete(bucket: string, purgeObjects = true) {
 103     return this.rgwDaemonService.request((params: HttpParams) => {
 104       params = params.append('purge_objects', purgeObjects ? 'true' : 'false');
 105       return this.http.delete(`${this.url}/${bucket}`, { params: params });
 106     });
 107   }
 108
 109   /**
 110    * Check if the specified bucket exists.
 111    * @param {string} bucket The bucket name to check.
 112    * @return Observable<boolean>
 113    */
 114   exists(bucket: string) {
 115     return this.enumerate().pipe(
 116       mergeMap((resp: string[]) => {
 117         const index = _.indexOf(resp, bucket);
 118         return observableOf(-1 !== index);
 119       })
 120     );
 121   }
 122 }