import 15.2.0 Octopus source

[ceph.git] / ceph / src / pybind / mgr / dashboard / frontend / src / app / shared / api / cephfs.service.ts

diff --git a/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/api/cephfs.service.ts b/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/api/cephfs.service.ts
index 745f2589243db13c23ce1ce1b96077be18c179d6..246b5213fe510ec1b9968700085729c082a0e624 100644 (file)
--- a/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/api/cephfs.service.ts
+++ b/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/api/cephfs.service.ts
@@ -1,13 +1,20 @@
-import { HttpClient } from '@angular/common/http';
+import { HttpClient, HttpParams } from '@angular/common/http';
 import { Injectable } from '@angular/core';
 
+import * as _ from 'lodash';
+import { Observable } from 'rxjs';
+
+import { cdEncode } from '../decorators/cd-encode';
+import { CephfsDir, CephfsQuotas } from '../models/cephfs-directory-models';
 import { ApiModule } from './api.module';
 
+@cdEncode
 @Injectable({
   providedIn: ApiModule
 })
 export class CephfsService {
   baseURL = 'api/cephfs';
+  baseUiURL = 'ui-api/cephfs';
 
   constructor(private http: HttpClient) {}
 
@@ -15,15 +22,56 @@ export class CephfsService {
     return this.http.get(`${this.baseURL}`);
   }
 
-  getCephfs(id) {
+  lsDir(id: number, path?: string): Observable<CephfsDir[]> {
+    let apiPath = `${this.baseUiURL}/${id}/ls_dir?depth=2`;
+    if (path) {
+      apiPath += `&path=${encodeURIComponent(path)}`;
+    }
+    return this.http.get<CephfsDir[]>(apiPath);
+  }
+
+  getCephfs(id: number) {
     return this.http.get(`${this.baseURL}/${id}`);
   }
 
-  getClients(id) {
+  getTabs(id: number) {
+    return this.http.get(`ui-api/cephfs/${id}/tabs`);
+  }
+
+  getClients(id: number) {
     return this.http.get(`${this.baseURL}/${id}/clients`);
   }
 
-  getMdsCounters(id) {
+  evictClient(fsId: number, clientId: number) {
+    return this.http.delete(`${this.baseURL}/${fsId}/client/${clientId}`);
+  }
+
+  getMdsCounters(id: string) {
     return this.http.get(`${this.baseURL}/${id}/mds_counters`);
   }
+
+  mkSnapshot(id: number, path: string, name?: string) {
+    let params = new HttpParams();
+    params = params.append('path', path);
+    if (!_.isUndefined(name)) {
+      params = params.append('name', name);
+    }
+    return this.http.post(`${this.baseURL}/${id}/mk_snapshot`, null, { params });
+  }
+
+  rmSnapshot(id: number, path: string, name: string) {
+    let params = new HttpParams();
+    params = params.append('path', path);
+    params = params.append('name', name);
+    return this.http.post(`${this.baseURL}/${id}/rm_snapshot`, null, { params });
+  }
+
+  updateQuota(id: number, path: string, quotas: CephfsQuotas) {
+    let params = new HttpParams();
+    params = params.append('path', path);
+    return this.http.post(`${this.baseURL}/${id}/set_quotas`, quotas, {
+      observe: 'response',
+      params
+    });
+  }
 }