1 files changed, 114 insertions, 0 deletions
diff --git a/src/pybind/mgr/dashboard/frontend/src/app/shared/api/rbd-mirroring.service.ts b/src/pybind/mgr/dashboard/frontend/src/app/shared/api/rbd-mirroring.service.ts
new file mode 100644
index 000000000..4958382e2
--- /dev/null
+++ b/src/pybind/mgr/dashboard/frontend/src/app/shared/api/rbd-mirroring.service.ts
@@ -0,0 +1,114 @@
+import { HttpClient } from '@angular/common/http';
+import { Injectable } from '@angular/core';
+
+import { BehaviorSubject, Observable, Subscription } from 'rxjs';
+import { filter } from 'rxjs/operators';
+
+import { cdEncode, cdEncodeNot } from '../decorators/cd-encode';
+import { MirroringSummary } from '../models/mirroring-summary';
+import { TimerService } from '../services/timer.service';
+
+@cdEncode
+@Injectable({
+  providedIn: 'root'
+})
+export class RbdMirroringService {
+  readonly REFRESH_INTERVAL = 30000;
+  // Observable sources
+  private summaryDataSource = new BehaviorSubject<MirroringSummary>(null);
+  // Observable streams
+  summaryData$ = this.summaryDataSource.asObservable();
+
+  constructor(private http: HttpClient, private timerService: TimerService) {}
+
+  startPolling(): Subscription {
+    return this.timerService
+      .get(() => this.retrieveSummaryObservable(), this.REFRESH_INTERVAL)
+      .subscribe(this.retrieveSummaryObserver());
+  }
+
+  refresh(): Subscription {
+    return this.retrieveSummaryObservable().subscribe(this.retrieveSummaryObserver());
+  }
+
+  private retrieveSummaryObservable(): Observable<MirroringSummary> {
+    return this.http.get('api/block/mirroring/summary');
+  }
+
+  private retrieveSummaryObserver(): (data: MirroringSummary) => void {
+    return (data: any) => {
+      this.summaryDataSource.next(data);
+    };
+  }
+
+  /**
+   * Subscribes to the summaryData,
+   * which is updated periodically or when a new task is created.
+   */
+  subscribeSummary(
+    next: (summary: MirroringSummary) => void,
+    error?: (error: any) => void
+  ): Subscription {
+    return this.summaryData$.pipe(filter((value) => !!value)).subscribe(next, error);
+  }
+
+  getPool(poolName: string) {
+    return this.http.get(`api/block/mirroring/pool/${poolName}`);
+  }
+
+  updatePool(poolName: string, request: any) {
+    return this.http.put(`api/block/mirroring/pool/${poolName}`, request, { observe: 'response' });
+  }
+
+  getSiteName() {
+    return this.http.get(`api/block/mirroring/site_name`);
+  }
+
+  setSiteName(@cdEncodeNot siteName: string) {
+    return this.http.put(
+      `api/block/mirroring/site_name`,
+      { site_name: siteName },
+      { observe: 'response' }
+    );
+  }
+
+  createBootstrapToken(poolName: string) {
+    return this.http.post(`api/block/mirroring/pool/${poolName}/bootstrap/token`, {});
+  }
+
+  importBootstrapToken(
+    poolName: string,
+    @cdEncodeNot direction: string,
+    @cdEncodeNot token: string
+  ) {
+    const request = {
+      direction: direction,
+      token: token
+    };
+    return this.http.post(`api/block/mirroring/pool/${poolName}/bootstrap/peer`, request, {
+      observe: 'response'
+    });
+  }
+
+  getPeer(poolName: string, peerUUID: string) {
+    return this.http.get(`api/block/mirroring/pool/${poolName}/peer/${peerUUID}`);
+  }
+
+  addPeer(poolName: string, request: any) {
+    return this.http.post(`api/block/mirroring/pool/${poolName}/peer`, request, {
+      observe: 'response'
+    });
+  }
+
+  updatePeer(poolName: string, peerUUID: string, request: any) {
+    return this.http.put(`api/block/mirroring/pool/${poolName}/peer/${peerUUID}`, request, {
+      observe: 'response'
+    });
+  }
+
+  deletePeer(poolName: string, peerUUID: string) {
+    return this.http.delete(`api/block/mirroring/pool/${poolName}/peer/${peerUUID}`, {
+      observe: 'response'
+    });
+  }
+}