X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=webapp-frontend%2Fsrc%2Fapp%2Fservices%2Fac-xapp%2Fac-xapp.service.ts;h=dbe4cd6e3f3ce59367c975f5f6da8f65efb53723;hb=refs%2Fchanges%2F72%2F2272%2F8;hp=907c3258d13b49580430551d07fd4cc8f17b17b9;hpb=9d33149c7bdc8566d0135406b601fc1a901ff2f5;p=portal%2Fric-dashboard.git diff --git a/webapp-frontend/src/app/services/ac-xapp/ac-xapp.service.ts b/webapp-frontend/src/app/services/ac-xapp/ac-xapp.service.ts index 907c3258..dbe4cd6e 100644 --- a/webapp-frontend/src/app/services/ac-xapp/ac-xapp.service.ts +++ b/webapp-frontend/src/app/services/ac-xapp/ac-xapp.service.ts @@ -2,14 +2,14 @@ * ========================LICENSE_START================================= * O-RAN-SC * %% - * Copyright (C) 2019 AT&T Intellectual Property and Nokia + * Copyright (C) 2019 AT&T Intellectual Property * %% * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -18,55 +18,64 @@ * ========================LICENSE_END=================================== */ - import { Injectable } from '@angular/core'; - import { HttpClient } from '@angular/common/http'; - import { Observable } from 'rxjs'; - import { map } from 'rxjs/operators'; +import { HttpClient } from '@angular/common/http'; +import { Injectable } from '@angular/core'; +import { Observable } from 'rxjs'; +import { map } from 'rxjs/operators'; import { ACAdmissionIntervalControl, ACAdmissionIntervalControlAck } from '../../interfaces/ac-xapp.types'; import { DashboardSuccessTransport } from '../../interfaces/dashboard.types'; +import { DashboardService } from '../dashboard/dashboard.service'; /** - * Services for calling the Dashboard's AC endpoints. + * Services for calling the Dashboard's A1 endpoints to get/put AC policies. */ @Injectable({ providedIn: 'root' }) export class ACXappService { - private basePath = 'api/xapp/ac'; + private component = 'a1-p'; + private policyTypePath = 'poltype'; + private policyInstPath = 'polinst'; + private acPolicyType = '21000'; + private acPolicyInst = 'admission_control_policy'; - private buildPath(...args: any[]) { - let result = this.basePath; - args.forEach(part => { - result = result + '/' + part; - }); - return result; - } - - constructor(private httpClient: HttpClient) { - // injects to variable httpClient + constructor( + private dashboardSvc: DashboardService, + private httpClient: HttpClient) { } /** - * Gets version details - * @returns Observable that should yield a String + * Gets AC client version details + * @returns Observable that yields a String */ - getVersion(): Observable { - const url = this.buildPath('version'); - return this.httpClient.get(url).pipe( + getVersion(instanceKey: string): Observable { + const path = this.dashboardSvc.buildPath(this.component, null, 'version'); + return this.httpClient.get(path).pipe( // Extract the string here map(res => res['data']) ); } /** - * Puts admission control parameters. + * Gets admission control policy. + * @returns Observable that yields an ACAdmissionIntervalControl + */ + getPolicy(instanceKey: string): Observable { + const path = this.dashboardSvc.buildPath(this.component, instanceKey, this.policyTypePath, this.acPolicyType, + this.policyInstPath, this.acPolicyInst); + return this.httpClient.get(path); + } + + /** + * Puts admission control policy. * @param policy an instance of ACAdmissionIntervalControl - * @returns Observable that should yield a response code, no data + * @returns Observable that yields a response code, no data */ - putPolicy(policy: ACAdmissionIntervalControl): Observable { - const url = this.buildPath('catime'); - return this.httpClient.put(url, policy, { observe: 'response' }); + putPolicy(instanceKey: string, policy: ACAdmissionIntervalControl): Observable { + const path = this.dashboardSvc.buildPath(this.component, instanceKey, this.policyTypePath, this.acPolicyType, + this.policyInstPath, this.acPolicyInst); + return this.httpClient.put(path, policy, { observe: 'response' }); } }