/*- * ========================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 { JobInfo, ProducerStatus, ProducerRegistrationInfo } from '@interfaces/producer.types'; /** * Services for calling the EI endpoints. */ @Injectable({ providedIn: 'root' }) export class ProducerService { private basePath = '/data-producer/v1'; readonly jobsPath = 'info-jobs'; readonly producersPath = 'info-producers'; readonly producerStatusPath = 'status'; private buildPath(...args: any[]) { let result = this.basePath; args.forEach(part => { result = result + '/' + part; }); return result; } constructor(private httpClient: HttpClient) { // injects to variable httpClient } getProducerIds(): Observable { const url = this.buildPath(this.producersPath); return this.httpClient.get(url); } getJobsForProducer(producerId: string): Observable { const url = this.buildPath(this.producersPath, producerId, this.jobsPath); return this.httpClient.get(url); } getProducer(producerId: string): Observable { const url = this.buildPath(this.producersPath, producerId); return this.httpClient.get(url); } getProducerStatus(producerId: string): Observable { const url = this.buildPath(this.producersPath, producerId, this.producerStatusPath); return this.httpClient.get(url); } }