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=b80389cf3e549916a8831824ddf3a36615d98754;hb=c666f5e9ddadbe4ab6064b746189f5ff142f6d83;hp=258086d6dc994d5a18c41afd897b315876ad6cf6;hpb=bbc4aa48f60dc70154ff07c2143918053f1c9154;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..b80389cf 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,34 +19,34 @@ */ 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.Collection; +import java.util.List; +import java.util.Map; +import java.util.Vector; +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.HttpStatus; +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()); @@ -54,14 +54,14 @@ public class PolicyAgentApiImpl implements PolicyAgentApi { RestTemplate restTemplate = new 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) { logger.debug("ctor prefix '{}'", urlPrefix); this.urlPrefix = urlPrefix; } @@ -79,62 +79,70 @@ 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); + public ResponseEntity getAllPolicyTypes() throws RestClientException { + String url = baseUrl() + "/policy_schemas"; + ResponseEntity rsp = this.restTemplate.getForEntity(url, String.class); + if (!rsp.getStatusCode().is2xxSuccessful()) { + return new ResponseEntity<>(rsp.getStatusCode()); + } PolicyTypes result = new PolicyTypes(); - for (PolicyTypeInfo i : rspParsed) { - result.add(toPolicyType(i)); + 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 result; + return new ResponseEntity<>(result, rsp.getStatusCode()); } @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); + ResponseEntity rsp = this.restTemplate.getForEntity(url, String.class, uriVariables); + if (!rsp.getStatusCode().is2xxSuccessful()) { + return new ResponseEntity<>(rsp.getStatusCode()); + } - Type listType = new TypeToken>() { - }.getType(); - List rspParsed = gson.fromJson(rsp, listType); + Type listType = new TypeToken>() {}.getType(); + List rspParsed = gson.fromJson(rsp.getBody(), listType); PolicyInstances result = new PolicyInstances(); for (PolicyInfo p : rspParsed) { result.add(p); } - return result; + return new ResponseEntity<>(result, rsp.getStatusCode()); } @Override - public String getPolicyInstance(String id) throws RestClientException { + public ResponseEntity getPolicyInstance(String id) throws RestClientException { 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, String.class, uriVariables); } @Override - public void putPolicy(String policyTypeIdString, String policyInstanceId, String json, String ric) - throws RestClientException { + public ResponseEntity putPolicy(String policyTypeIdString, String policyInstanceId, String json, String ric) + throws RestClientException { 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, json, uriVariables); + return new ResponseEntity<>(HttpStatus.OK); + } catch (Exception e) { + return new ResponseEntity<>(e.getMessage(), HttpStatus.NOT_FOUND); + } } @Override @@ -155,20 +163,19 @@ 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(); + 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()); } - return result; + return new ResponseEntity<>(result, HttpStatus.OK); } }