diff options
Diffstat (limited to '')
-rw-r--r-- | src/pybind/mgr/dashboard/frontend/src/app/shared/api/rgw-bucket.service.ts | 199 |
1 files changed, 199 insertions, 0 deletions
diff --git a/src/pybind/mgr/dashboard/frontend/src/app/shared/api/rgw-bucket.service.ts b/src/pybind/mgr/dashboard/frontend/src/app/shared/api/rgw-bucket.service.ts new file mode 100644 index 000000000..7207d0b5c --- /dev/null +++ b/src/pybind/mgr/dashboard/frontend/src/app/shared/api/rgw-bucket.service.ts @@ -0,0 +1,199 @@ +import { HttpClient, HttpParams } from '@angular/common/http'; +import { Injectable } from '@angular/core'; + +import _ from 'lodash'; +import { of as observableOf } from 'rxjs'; +import { catchError, mapTo } from 'rxjs/operators'; + +import { ApiClient } from '~/app/shared/api/api-client'; +import { RgwDaemonService } from '~/app/shared/api/rgw-daemon.service'; +import { cdEncode } from '~/app/shared/decorators/cd-encode'; + +@cdEncode +@Injectable({ + providedIn: 'root' +}) +export class RgwBucketService extends ApiClient { + private url = 'api/rgw/bucket'; + + constructor(private http: HttpClient, private rgwDaemonService: RgwDaemonService) { + super(); + } + + /** + * Get the list of buckets. + * @return Observable<Object[]> + */ + list(stats: boolean = false, uid: string = '') { + return this.rgwDaemonService.request((params: HttpParams) => { + params = params.append('stats', stats.toString()); + if (uid) { + params = params.append('uid', uid); + } + return this.http.get(this.url, { + headers: { Accept: this.getVersionHeaderValue(1, 1) }, + params: params + }); + }); + } + + get(bucket: string) { + return this.rgwDaemonService.request((params: HttpParams) => { + return this.http.get(`${this.url}/${bucket}`, { params: params }); + }); + } + + getTotalBucketsAndUsersLength() { + return this.rgwDaemonService.request((params: HttpParams) => { + return this.http.get(`ui-${this.url}/buckets_and_users_count`, { params: params }); + }); + } + + create( + bucket: string, + uid: string, + zonegroup: string, + placementTarget: string, + lockEnabled: boolean, + lock_mode: 'GOVERNANCE' | 'COMPLIANCE', + lock_retention_period_days: string, + encryption_state: boolean, + encryption_type: string, + key_id: string + ) { + return this.rgwDaemonService.request((params: HttpParams) => { + return this.http.post(this.url, null, { + params: new HttpParams({ + fromObject: { + bucket, + uid, + zonegroup, + placement_target: placementTarget, + lock_enabled: String(lockEnabled), + lock_mode, + lock_retention_period_days, + encryption_state: String(encryption_state), + encryption_type, + key_id, + daemon_name: params.get('daemon_name') + } + }) + }); + }); + } + + update( + bucket: string, + bucketId: string, + uid: string, + versioningState: string, + encryptionState: boolean, + encryptionType: string, + keyId: string, + mfaDelete: string, + mfaTokenSerial: string, + mfaTokenPin: string, + lockMode: 'GOVERNANCE' | 'COMPLIANCE', + lockRetentionPeriodDays: string + ) { + return this.rgwDaemonService.request((params: HttpParams) => { + params = params.appendAll({ + bucket_id: bucketId, + uid: uid, + versioning_state: versioningState, + encryption_state: String(encryptionState), + encryption_type: encryptionType, + key_id: keyId, + mfa_delete: mfaDelete, + mfa_token_serial: mfaTokenSerial, + mfa_token_pin: mfaTokenPin, + lock_mode: lockMode, + lock_retention_period_days: lockRetentionPeriodDays + }); + return this.http.put(`${this.url}/${bucket}`, null, { params: params }); + }); + } + + delete(bucket: string, purgeObjects = true) { + return this.rgwDaemonService.request((params: HttpParams) => { + params = params.append('purge_objects', purgeObjects ? 'true' : 'false'); + return this.http.delete(`${this.url}/${bucket}`, { params: params }); + }); + } + + /** + * Check if the specified bucket exists. + * @param {string} bucket The bucket name to check. + * @return Observable<boolean> + */ + exists(bucket: string) { + return this.get(bucket).pipe( + mapTo(true), + catchError((error: Event) => { + if (_.isFunction(error.preventDefault)) { + error.preventDefault(); + } + return observableOf(false); + }) + ); + } + + getLockDays(bucketData: object): number { + if (bucketData['lock_retention_period_years'] > 0) { + return Math.floor(bucketData['lock_retention_period_years'] * 365.242); + } + + return bucketData['lock_retention_period_days'] || 0; + } + + setEncryptionConfig( + encryption_type: string, + kms_provider: string, + auth_method: string, + secret_engine: string, + secret_path: string, + namespace: string, + address: string, + token: string, + owner: string, + ssl_cert: string, + client_cert: string, + client_key: string + ) { + return this.rgwDaemonService.request((params: HttpParams) => { + params = params.appendAll({ + encryption_type: encryption_type, + kms_provider: kms_provider, + auth_method: auth_method, + secret_engine: secret_engine, + secret_path: secret_path, + namespace: namespace, + address: address, + token: token, + owner: owner, + ssl_cert: ssl_cert, + client_cert: client_cert, + client_key: client_key + }); + return this.http.put(`${this.url}/setEncryptionConfig`, null, { params: params }); + }); + } + + getEncryption(bucket: string) { + return this.rgwDaemonService.request((params: HttpParams) => { + return this.http.get(`${this.url}/${bucket}/getEncryption`, { params: params }); + }); + } + + deleteEncryption(bucket: string) { + return this.rgwDaemonService.request((params: HttpParams) => { + return this.http.get(`${this.url}/${bucket}/deleteEncryption`, { params: params }); + }); + } + + getEncryptionConfig() { + return this.rgwDaemonService.request((params: HttpParams) => { + return this.http.get(`${this.url}/getEncryptionConfig`, { params: params }); + }); + } +} |