d25e9db95543596315a123510f3dab00d13677d7
[portal/ric-dashboard.git] / webapp-frontend / src / app / services / ac-xapp / ac-xapp.service.ts
1 /*-
2  * ========================LICENSE_START=================================
3  * O-RAN-SC
4  * %%
5  * Copyright (C) 2019 AT&T Intellectual Property
6  * %%
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  * 
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  * 
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ========================LICENSE_END===================================
19  */
20
21  import { Injectable } from '@angular/core';
22  import { HttpClient } from '@angular/common/http';
23  import { Observable } from 'rxjs';
24  import { map } from 'rxjs/operators';
25 import { ACAdmissionIntervalControl, ACAdmissionIntervalControlAck } from '../../interfaces/ac-xapp.types';
26 import { DashboardSuccessTransport } from '../../interfaces/dashboard.types';
27
28 /**
29  * Services for calling the Dashboard's A1 endpoints to get/put AC policies.
30  */
31 @Injectable({
32   providedIn: 'root'
33 })
34 export class ACXappService {
35
36   private basePath = 'api/a1-p';
37   private policyPath = 'policies';
38   private acPolicyName = 'admission_control_policy';
39
40   private buildPath(...args: any[]) {
41     let result = this.basePath;
42     args.forEach(part => {
43       result = result + '/' + part;
44     });
45     return result;
46   }
47
48   constructor(private httpClient: HttpClient) {
49     // injects to variable httpClient
50   }
51
52   /**
53    * Gets version details
54    * @returns Observable that should yield a String
55    */
56   getVersion(): Observable<string> {
57     const url = this.buildPath('version');
58     return this.httpClient.get<DashboardSuccessTransport>(url).pipe(
59       // Extract the string here
60       map(res => res['data'])
61     );
62   }
63
64   /**
65    * Gets admission control policy.
66    * @returns Observable that should yield an ACAdmissionIntervalControl
67    */
68   getPolicy(): Observable<ACAdmissionIntervalControl> {
69     const url = this.buildPath(this.policyPath, this.acPolicyName);
70     return this.httpClient.get<ACAdmissionIntervalControl>(url);
71   }
72
73   /**
74    * Puts admission control policy.
75    * @param policy an instance of ACAdmissionIntervalControl
76    * @returns Observable that should yield a response code, no data
77    */
78   putPolicy(policy: ACAdmissionIntervalControl): Observable<any> {
79     const url = this.buildPath(this.policyPath, this.acPolicyName);
80     return this.httpClient.put<ACAdmissionIntervalControlAck>(url, policy, { observe: 'response' });
81   }
82
83 }