/*- * ========================LICENSE_START================================= * O-RAN-SC * %% * Copyright (C) 2019 Nordix Foundation * %% * 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. * See the License for the specific language governing permissions and * limitations under the License. * ========================LICENSE_END=================================== */ import { Injectable } from '@angular/core'; import { HttpClient } from '@angular/common/http'; import { Observable } from 'rxjs'; import { map } from 'rxjs/operators'; import { CreatePolicyInstance, PolicyInstance, PolicyInstanceAck, PolicyInstances, PolicyStatus, PolicyType, PolicyTypes } from '../../interfaces/policy.types'; import { ControlpanelSuccessTransport } from '../../interfaces/controlpanel.types'; import { Ric } from 'src/app/interfaces/ric'; /** * Services for calling the policy endpoints. */ @Injectable({ providedIn: 'root' }) export class PolicyService { private apiVersion2 = '/v2' private basePath = '/a1-policy'; policyTypesPath = 'policy-types'; policyPath = 'policies'; private buildPath(...args: any[]) { let result = this.basePath + this.apiVersion2; args.forEach(part => { result = result + '/' + part; }); return result; } constructor(private httpClient: HttpClient) { // injects to variable httpClient } getPolicyTypes(): Observable { const url = this.buildPath(this.policyTypesPath); return this.httpClient.get(url); } getPolicyType(policyTypeId: string): Observable { const url = this.buildPath(this.policyTypesPath + '/' + policyTypeId); return this.httpClient.get(url); } getPolicyInstancesByType(policyTypeId: string): Observable { const url = this.buildPath(this.policyPath + '?' + 'policytype_id=' + policyTypeId); return this.httpClient.get(url); } getPolicyInstance(policyId: string): Observable { const url = this.buildPath(this.policyPath) + '/' + policyId; return this.httpClient.get(url); } getPolicyStatus(policyId: string): Observable { const url = this.buildPath(this.policyPath) + '/' + policyId + '/status'; return this.httpClient.get(url); } /** * Gets policy parameters. * @returns Observable that should yield a policy instance */ getPolicy(policyTypeId: string, policyInstanceId: string): Observable { const url = this.buildPath(this.policyPath, policyInstanceId) + '?type=' + policyTypeId; return this.httpClient.get(url); } /** * Creates or replaces policy instance. * @param policyTypeId ID of the policy type that the instance will have * @param policyInstanceId ID of the instance * @param policyJson Json with the policy content * @returns Observable that should yield a response code, no data */ putPolicy(createPolicyInstance: CreatePolicyInstance): Observable { const url = this.buildPath(this.policyPath); return this.httpClient.put(url, createPolicyInstance, { observe: 'response' }); } /** * Deletes a policy instance. * @param policyTypeId ID of the policy type that the instance belong to * @param policyInstanceId ID of the instance * @returns Observable that should yield a response code, no data */ deletePolicy(policyInstanceId: string): Observable { const url = this.buildPath(this.policyPath, policyInstanceId); return this.httpClient.delete(url, { observe: 'response' }); } getRics(policyTypeId: string): Observable { const url = this.buildPath('rics') + '?policytype_id=' + policyTypeId; return this.httpClient.get(url); } }