X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=webapp-frontend%2Fsrc%2Fapp%2Fservices%2Fe2-mgr%2Fe2-mgr.service.ts;h=3f586fb3f92cb09e05f3091f440ae189172be99c;hb=refs%2Fchanges%2F14%2F414%2F9;hp=f08facee21e62ba33bbcbd7af4a09077cbc27a20;hpb=c40f0d5d74bfa57a8ee28ba818b7fcd67633177d;p=portal%2Fric-dashboard.git diff --git a/webapp-frontend/src/app/services/e2-mgr/e2-mgr.service.ts b/webapp-frontend/src/app/services/e2-mgr/e2-mgr.service.ts index f08facee..3f586fb3 100644 --- a/webapp-frontend/src/app/services/e2-mgr/e2-mgr.service.ts +++ b/webapp-frontend/src/app/services/e2-mgr/e2-mgr.service.ts @@ -18,10 +18,16 @@ * ========================LICENSE_END=================================== */ import { Injectable } from '@angular/core'; -import { HttpClient } from '@angular/common/http'; -import { E2SetupRequest } from '../../interfaces/e2-mgr.types'; +import { HttpClient, HttpResponse } from '@angular/common/http'; +import { Observable } from 'rxjs'; +import { map } from 'rxjs/operators'; +import { E2RanDetails, E2SetupRequest } from '../../interfaces/e2-mgr.types'; +import { DashboardSuccessTransport } from '../../interfaces/dashboard.types'; + +@Injectable({ + providedIn: 'root' +}) -@Injectable() export class E2ManagerService { private basePath = 'api/e2mgr/'; @@ -31,39 +37,47 @@ export class E2ManagerService { } /** - * Gets E2 manager client version details - * @returns Observable that should yield a DashboardSuccessTransport object + * Gets E2 client version details + * @returns Observable that should yield a String */ - getE2ManagerVersion() { - return this.httpClient.get(this.basePath + 'version'); + getVersion(): Observable { + const url = this.basePath + 'version'; + return this.httpClient.get(url).pipe( + // Extract the string here + map(res => res['data']) + ); } /** - * Gets setup request history + * Gets RAN details * @returns Observable that should yield an array of objects */ - getAll() { - return this.httpClient.get(this.basePath + 'setup'); + getRan(): Observable> { + return this.httpClient.get>(this.basePath + 'ran'); } /** * Sends a request to setup an ENDC/gNodeB connection - * @returns Observable + * @returns Observable. On success there is no data, only a code. */ - endcSetup(req: E2SetupRequest) { - return this.httpClient.post(this.basePath + 'endcSetup', req); + endcSetup(req: E2SetupRequest): Observable> { + return this.httpClient.post(this.basePath + 'endcSetup', req, { observe: 'response' }); } /** * Sends a request to setup an X2/eNodeB connection - * @returns Observable + * @returns Observable. On success there is no data, only a code. */ - x2Setup(req: E2SetupRequest) { - return this.httpClient.post(this.basePath + 'x2Setup', req); + x2Setup(req: E2SetupRequest): Observable> { + return this.httpClient.post(this.basePath + 'x2Setup', req, { observe: 'response' }); } - disconnectAllRAN() { - return this.httpClient.delete((this.basePath + 'disconnectAllRAN'), { observe: 'response' }); + /** + * Sends a request to drop all RAN connections + * @returns Observable. Response code indicates result. + */ + nodebDelete(): Observable> { + return this.httpClient.delete((this.basePath + 'nodeb'), { observe: 'response' }); } }