X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dashboard%2Fwebapp-backend%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fric%2Fportal%2Fdashboard%2Fpolicyagentapi%2FPolicyAgentApiImpl.java;h=b41c30e3b2c2a57a41a9ce7cdd793f8686fbd130;hb=f2c4406acbb8c7ff00535acb1d4bccf067295976;hp=258086d6dc994d5a18c41afd897b315876ad6cf6;hpb=cd9e9862fa9a5898f3595b397686861749f72953;p=nonrtric.git diff --git a/dashboard/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/policyagentapi/PolicyAgentApiImpl.java b/dashboard/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/policyagentapi/PolicyAgentApiImpl.java index 258086d6..b41c30e3 100644 --- a/dashboard/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/policyagentapi/PolicyAgentApiImpl.java +++ b/dashboard/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/policyagentapi/PolicyAgentApiImpl.java @@ -7,9 +7,9 @@ * 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. @@ -19,51 +19,60 @@ */ package org.oransc.ric.portal.dashboard.policyagentapi; -import org.oransc.ric.portal.dashboard.DashboardConstants; +import com.google.gson.GsonBuilder; +import com.google.gson.JsonArray; +import com.google.gson.JsonElement; +import com.google.gson.JsonObject; +import com.google.gson.JsonParser; +import com.google.gson.reflect.TypeToken; + +import java.lang.invoke.MethodHandles; +import java.lang.reflect.Type; +import java.util.ArrayList; +import java.util.Collection; +import java.util.List; +import java.util.Map; + +import org.immutables.gson.Gson; +import org.immutables.value.Value; import org.oransc.ric.portal.dashboard.model.ImmutablePolicyInfo; import org.oransc.ric.portal.dashboard.model.PolicyInfo; import org.oransc.ric.portal.dashboard.model.PolicyInstances; import org.oransc.ric.portal.dashboard.model.PolicyType; import org.oransc.ric.portal.dashboard.model.PolicyTypes; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; - +import org.springframework.http.HttpEntity; +import org.springframework.http.HttpHeaders; +import org.springframework.http.HttpStatus; +import org.springframework.http.MediaType; +import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Component; -import org.springframework.web.client.RestClientException; import org.springframework.web.client.RestTemplate; -import java.util.Collection; -import java.util.List; -import java.util.Map; -import java.util.Vector; -import java.lang.invoke.MethodHandles; -import java.lang.reflect.Type; - -import com.google.gson.GsonBuilder; -import com.google.gson.annotations.SerializedName; -import com.google.gson.reflect.TypeToken; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.immutables.gson.Gson; -import org.immutables.value.Value; - @Component("PolicyAgentApi") public class PolicyAgentApiImpl implements PolicyAgentApi { private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass()); - RestTemplate restTemplate = new RestTemplate(); + RestTemplate restTemplate; private static com.google.gson.Gson gson = new GsonBuilder() // - .serializeNulls() // - .create(); // + .serializeNulls() // + .create(); // private final String urlPrefix; @Autowired public PolicyAgentApiImpl( - @org.springframework.beans.factory.annotation.Value("${policycontroller.url.prefix}") final String urlPrefix) { + @org.springframework.beans.factory.annotation.Value("${policycontroller.url.prefix}") final String urlPrefix) { + this(urlPrefix, new RestTemplate()); logger.debug("ctor prefix '{}'", urlPrefix); + } + + public PolicyAgentApiImpl(String urlPrefix, RestTemplate restTemplate) { this.urlPrefix = urlPrefix; + this.restTemplate = restTemplate; } private String baseUrl() { @@ -79,75 +88,97 @@ public class PolicyAgentApiImpl implements PolicyAgentApi { public String schema(); } - private PolicyType toPolicyType(PolicyTypeInfo i) { - return new PolicyType(i.name(), i.schema()); - } - @Override - public PolicyTypes getAllPolicyTypes() throws RestClientException { - String url = baseUrl() + "/policy_types"; - String rsp = this.restTemplate.getForObject(url, String.class); - - Type listType = new TypeToken>() { - }.getType(); - List rspParsed = gson.fromJson(rsp, listType); - - PolicyTypes result = new PolicyTypes(); - for (PolicyTypeInfo i : rspParsed) { - result.add(toPolicyType(i)); + public ResponseEntity getAllPolicyTypes() { + try { + String url = baseUrl() + "/policy_schemas"; + ResponseEntity rsp = this.restTemplate.getForEntity(url, String.class); + if (!rsp.getStatusCode().is2xxSuccessful()) { + return rsp; + } + + PolicyTypes result = new PolicyTypes(); + JsonParser jsonParser = new JsonParser(); + + JsonArray schemas = jsonParser.parse(rsp.getBody()).getAsJsonArray(); + for (JsonElement schema : schemas) { + JsonObject schemaObj = schema.getAsJsonObject(); + String title = schemaObj.get("title").getAsString(); + String schemaAsStr = schemaObj.toString(); + PolicyType pt = new PolicyType(title, schemaAsStr); + result.add(pt); + } + return new ResponseEntity<>(gson.toJson(result), rsp.getStatusCode()); + } catch (Exception e) { + return new ResponseEntity<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR); } - return result; } @Override - public PolicyInstances getPolicyInstancesForType(String type) { + public ResponseEntity getPolicyInstancesForType(String type) { String url = baseUrl() + "/policies?type={type}"; Map uriVariables = Map.of("type", type); - String rsp = this.restTemplate.getForObject(url, String.class, uriVariables); - - Type listType = new TypeToken>() { - }.getType(); - List rspParsed = gson.fromJson(rsp, listType); + ResponseEntity rsp = this.restTemplate.getForEntity(url, String.class, uriVariables); + if (!rsp.getStatusCode().is2xxSuccessful()) { + return rsp; + } - PolicyInstances result = new PolicyInstances(); - for (PolicyInfo p : rspParsed) { - result.add(p); + try { + Type listType = new TypeToken>() {}.getType(); + List rspParsed = gson.fromJson(rsp.getBody(), listType); + PolicyInstances result = new PolicyInstances(); + for (PolicyInfo p : rspParsed) { + result.add(p); + } + return new ResponseEntity<>(gson.toJson(result), rsp.getStatusCode()); + } catch (Exception e) { + return new ResponseEntity<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR); } - return result; } @Override - public String getPolicyInstance(String id) throws RestClientException { + public ResponseEntity getPolicyInstance(String id) { String url = baseUrl() + "/policy?instance={id}"; Map uriVariables = Map.of("id", id); - return this.restTemplate.getForObject(url, String.class, uriVariables); + return this.restTemplate.getForEntity(url, Object.class, uriVariables); } @Override - public void putPolicy(String policyTypeIdString, String policyInstanceId, String json, String ric) - throws RestClientException { + public ResponseEntity putPolicy(String policyTypeIdString, String policyInstanceId, Object json, + String ric) { String url = baseUrl() + "/policy?type={type}&instance={instance}&ric={ric}&service={service}"; Map uriVariables = Map.of( // - "type", policyTypeIdString, // - "instance", policyInstanceId, // - "ric", ric, // - "service", "dashboard"); - - this.restTemplate.put(url, json, uriVariables); + "type", policyTypeIdString, // + "instance", policyInstanceId, // + "ric", ric, // + "service", "dashboard"); + + try { + this.restTemplate.put(url, createJsonHttpEntity(json), uriVariables); + return new ResponseEntity<>(HttpStatus.OK); + } catch (Exception e) { + return new ResponseEntity<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR); + } } @Override - public void deletePolicy(String policyInstanceId) throws RestClientException { + public ResponseEntity deletePolicy(String policyInstanceId) { String url = baseUrl() + "/policy?instance={instance}"; Map uriVariables = Map.of("instance", policyInstanceId); - this.restTemplate.delete(url, uriVariables); + try { + this.restTemplate.delete(url, uriVariables); + return new ResponseEntity<>(HttpStatus.OK); + } catch (Exception e) { + return new ResponseEntity<>(e.getMessage(), HttpStatus.NOT_FOUND); + } + } @Value.Immutable @Gson.TypeAdapters interface RicInfo { - public String name(); + public String ricName(); public Collection nodeNames(); @@ -155,20 +186,28 @@ public class PolicyAgentApiImpl implements PolicyAgentApi { } @Override - public Collection getRicsSupportingType(String typeName) { + public ResponseEntity getRicsSupportingType(String typeName) { String url = baseUrl() + "/rics?policyType={typeName}"; Map uriVariables = Map.of("typeName", typeName); String rsp = this.restTemplate.getForObject(url, String.class, uriVariables); - Type listType = new TypeToken>() { - }.getType(); - List rspParsed = gson.fromJson(rsp, listType); - - Collection result = new Vector<>(rspParsed.size()); - for (RicInfo ric : rspParsed) { - result.add(ric.name()); + try { + Type listType = new TypeToken>() {}.getType(); + List rspParsed = gson.fromJson(rsp, listType); + Collection result = new ArrayList<>(rspParsed.size()); + for (RicInfo ric : rspParsed) { + result.add(ric.ricName()); + } + return new ResponseEntity<>(gson.toJson(result), HttpStatus.OK); + } catch (Exception e) { + return new ResponseEntity<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR); } - return result; + } + + private HttpEntity createJsonHttpEntity(Object content) { + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + return new HttpEntity<>(content, headers); } }