diff options
author | Jennie Jia <Jennie.Jia@amdocs.com> | 2018-09-11 15:06:39 +0000 |
---|---|---|
committer | Jennie Jia <Jennie.Jia@amdocs.com> | 2018-09-11 21:31:32 +0000 |
commit | 5a34dbbd091db590a9a38e5398140933ae9ed639 (patch) | |
tree | 5d328b1fbe880311718de905b6dbc159f55d1abe /src | |
parent | 797bf1d50236fddcbbb2ca091729e2e64b047f73 (diff) |
Update API and common model mapping
Issue-ID: LOG-646
Change-Id: Ie56d3f697abbafecf9c2d9f73fa52bee1833a469
Signed-off-by: Jennie Jia <Jennie.Jia@amdocs.com>
Diffstat (limited to 'src')
8 files changed, 578 insertions, 188 deletions
diff --git a/src/main/java/org/onap/pomba/contextbuilder/aai/AAIConfiguration.java b/src/main/java/org/onap/pomba/contextbuilder/aai/AAIConfiguration.java index 7befdc9..22f7b5e 100644 --- a/src/main/java/org/onap/pomba/contextbuilder/aai/AAIConfiguration.java +++ b/src/main/java/org/onap/pomba/contextbuilder/aai/AAIConfiguration.java @@ -56,10 +56,6 @@ public class AAIConfiguration { private Integer readTimeout; @Autowired - @Value("${aai.serviceInstancePath}") - private String serviceInstancePath; - - @Autowired @Value("${http.userId}") private String httpUserId; @@ -99,10 +95,6 @@ public class AAIConfiguration { } - @Bean(name="aaiServiceInstancePath") - public String getserviceInstancePathL() { - return serviceInstancePath; - } @Value("${aai.searchNodeQuery}") private String searchNodeQuery; diff --git a/src/main/java/org/onap/pomba/contextbuilder/aai/datatype/Vserver.java b/src/main/java/org/onap/pomba/contextbuilder/aai/datatype/Vserver.java new file mode 100644 index 0000000..368dd90 --- /dev/null +++ b/src/main/java/org/onap/pomba/contextbuilder/aai/datatype/Vserver.java @@ -0,0 +1,203 @@ +/* + * ============LICENSE_START=================================================== + * Copyright (c) 2018 Amdocs + * ============================================================================ + * 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===================================================== + */ +package org.onap.pomba.contextbuilder.aai.datatype; + +import com.google.gson.Gson; +import com.google.gson.GsonBuilder; +import com.google.gson.annotations.Expose; +import com.google.gson.annotations.SerializedName; +import org.apache.commons.lang3.builder.EqualsBuilder; +import org.apache.commons.lang3.builder.HashCodeBuilder; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.onap.pomba.contextbuilder.aai.exception.AuditError; +import org.onap.pomba.contextbuilder.aai.exception.AuditException; + +public class Vserver { + + @SerializedName("vserver-id") + @Expose + private String vserverId; + @SerializedName("vserver-name") + @Expose + private String vserverName; + @SerializedName("vserver-name2") + @Expose + private String vserverName2; + @SerializedName("prov-status") + @Expose + private String provStatus; + @SerializedName("vserver-selflink") + @Expose + private String vserverSelflink; + @SerializedName("in-maint") + @Expose + private Boolean inMaint; + @SerializedName("is-closed-loop-disabled") + @Expose + private Boolean isClosedLoopDisabled; + @SerializedName("resource-version") + @Expose + private String resourceVersion; + @SerializedName("relationship-list") + @Expose + private RelationshipList relationshipList; + + private static final Gson gson = new GsonBuilder().disableHtmlEscaping().create(); + + public String toJson() { + return gson.toJson(this); + } + + public static Vserver fromJson(String payload) throws AuditException { + try { + if (payload == null || payload.isEmpty()) { + throw new AuditException("Empty Json response"); + } + return gson.fromJson(payload, Vserver.class); + } catch (Exception ex) { + throw new AuditException(AuditError.JSON_READER_PARSE_ERROR, ex); + } + } + + /** + * No args constructor for use in serialization + * + */ + public Vserver() { + } + + /** + * + * @param relationshipList + * @param provStatus + * @param inMaint + * @param vserverName2 + * @param resourceVersion + * @param vserverSelflink + * @param vserverName + * @param vserverId + * @param isClosedLoopDisabled + */ + public Vserver(String vserverId, String vserverName, String vserverName2, String provStatus, String vserverSelflink, Boolean inMaint, Boolean isClosedLoopDisabled, String resourceVersion, RelationshipList relationshipList) { + super(); + this.vserverId = vserverId; + this.vserverName = vserverName; + this.vserverName2 = vserverName2; + this.provStatus = provStatus; + this.vserverSelflink = vserverSelflink; + this.inMaint = inMaint; + this.isClosedLoopDisabled = isClosedLoopDisabled; + this.resourceVersion = resourceVersion; + this.relationshipList = relationshipList; + } + + public String getVserverId() { + return vserverId; + } + + public void setVserverId(String vserverId) { + this.vserverId = vserverId; + } + + public String getVserverName() { + return vserverName; + } + + public void setVserverName(String vserverName) { + this.vserverName = vserverName; + } + + public String getVserverName2() { + return vserverName2; + } + + public void setVserverName2(String vserverName2) { + this.vserverName2 = vserverName2; + } + + public String getProvStatus() { + return provStatus; + } + + public void setProvStatus(String provStatus) { + this.provStatus = provStatus; + } + + public String getVserverSelflink() { + return vserverSelflink; + } + + public void setVserverSelflink(String vserverSelflink) { + this.vserverSelflink = vserverSelflink; + } + + public Boolean getInMaint() { + return inMaint; + } + + public void setInMaint(Boolean inMaint) { + this.inMaint = inMaint; + } + + public Boolean getIsClosedLoopDisabled() { + return isClosedLoopDisabled; + } + + public void setIsClosedLoopDisabled(Boolean isClosedLoopDisabled) { + this.isClosedLoopDisabled = isClosedLoopDisabled; + } + + public String getResourceVersion() { + return resourceVersion; + } + + public void setResourceVersion(String resourceVersion) { + this.resourceVersion = resourceVersion; + } + + public RelationshipList getRelationshipList() { + return relationshipList; + } + + public void setRelationshipList(RelationshipList relationshipList) { + this.relationshipList = relationshipList; + } + + @Override + public String toString() { + return new ToStringBuilder(this).append("vserverId", vserverId).append("vserverName", vserverName).append("vserverName2", vserverName2).append("provStatus", provStatus).append("vserverSelflink", vserverSelflink).append("inMaint", inMaint).append("isClosedLoopDisabled", isClosedLoopDisabled).append("resourceVersion", resourceVersion).append("relationshipList", relationshipList).toString(); + } + + @Override + public int hashCode() { + return new HashCodeBuilder().append(relationshipList).append(provStatus).append(inMaint).append(vserverName2).append(resourceVersion).append(vserverSelflink).append(vserverName).append(vserverId).append(isClosedLoopDisabled).toHashCode(); + } + + @Override + public boolean equals(Object other) { + if (other == this) { + return true; + } + if ((other instanceof Vserver) == false) { + return false; + } + Vserver rhs = ((Vserver) other); + return new EqualsBuilder().append(relationshipList, rhs.relationshipList).append(provStatus, rhs.provStatus).append(inMaint, rhs.inMaint).append(vserverName2, rhs.vserverName2).append(resourceVersion, rhs.resourceVersion).append(vserverSelflink, rhs.vserverSelflink).append(vserverName, rhs.vserverName).append(vserverId, rhs.vserverId).append(isClosedLoopDisabled, rhs.isClosedLoopDisabled).isEquals(); + } + +} diff --git a/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringService.java b/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringService.java index aa28e2b..59ee36d 100644 --- a/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringService.java +++ b/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringService.java @@ -23,5 +23,5 @@ import org.onap.pomba.contextbuilder.aai.exception.AuditException; public interface SpringService { - public ModelContext getContext(String serviceInstanceId, String modelVersionId, String modelInvariantId, String serviceType, String customerId, String transactionId) throws AuditException; + public ModelContext getContext(String serviceInstanceId, String modelVersionId, String modelInvariantId, String transactionId) throws AuditException; } diff --git a/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringServiceImpl.java b/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringServiceImpl.java index 2ec49f3..bce3a2e 100644 --- a/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringServiceImpl.java +++ b/src/main/java/org/onap/pomba/contextbuilder/aai/service/SpringServiceImpl.java @@ -35,8 +35,7 @@ public class SpringServiceImpl implements SpringService { private RestClient aaiClient; @Autowired private String aaiBaseUrl; - @Autowired - private String aaiServiceInstancePath; + @Autowired private String aaiBasicAuthorization; @Autowired @@ -46,18 +45,16 @@ public class SpringServiceImpl implements SpringService { // needed for instantiation } - @Override - public ModelContext getContext(String serviceInstanceId, String modelVersionId, String modelInvariantId, String serviceType, String customerId, String tranId) throws AuditException { + public ModelContext getContext(String serviceInstanceId, String modelVersionId, String modelInvariantId, String tranId) throws AuditException { - String url = "serviceInstanceId=" + serviceInstanceId + " modelVersion="+modelVersionId + - " modelInvariantId="+ modelInvariantId + " serviceType="+serviceType + " customerId="+ customerId; + String url = "serviceInstanceId=" + serviceInstanceId + " modelVersion="+modelVersionId + " modelInvariantId="+ modelInvariantId ; log.info(LogMessages.AAI_CONTEXT_BUILDER_URL, url); ModelContext context = null; // Retrieve the service instance information from AAI try { - context= RestUtil.retrieveAAIModelData(aaiClient, aaiBaseUrl, aaiPathToSearchNodeQuery, aaiServiceInstancePath, tranId, serviceInstanceId, modelVersionId, modelInvariantId, serviceType, customerId,aaiBasicAuthorization); + context= RestUtil.retrieveAAIModelData(aaiClient, aaiBaseUrl, aaiPathToSearchNodeQuery, tranId, serviceInstanceId, modelVersionId, modelInvariantId, aaiBasicAuthorization); } catch (AuditException ae) { throw ae; } catch (Exception e) { diff --git a/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestService.java b/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestService.java index dcc3382..22efa35 100644 --- a/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestService.java +++ b/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestService.java @@ -44,19 +44,17 @@ public interface RestService { value = "Respond AAIContext Model Data", notes = "Returns a JSON object which represents the AAIConetxt model data", response = GenericResponse.class - ) + ) @ApiResponses( value = { @ApiResponse(code = 200, message = "OK"), @ApiResponse(code = 400, message = "Bad Request"), @ApiResponse(code = 404, message = "Service not available"), @ApiResponse(code = 500, message = "Unexpected Runtime error") - }) + }) public Response getContext(@Context HttpHeaders headers, @QueryParam("serviceInstanceId") String serviceInstanceId, @QueryParam("modelVersionId") String modelVersionId, - @QueryParam("modelInvariantId") String modelInvariantId, - @QueryParam("serviceType") String serviceType, - @QueryParam("customerId") String customerId + @QueryParam("modelInvariantId") String modelInvariantId ); }
\ No newline at end of file diff --git a/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestServiceImpl.java b/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestServiceImpl.java index 6fc2c8a..824e251 100644 --- a/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestServiceImpl.java +++ b/src/main/java/org/onap/pomba/contextbuilder/aai/service/rs/RestServiceImpl.java @@ -43,10 +43,9 @@ public class RestServiceImpl implements RestService { private String httpBasicAuthorization; @Override - public Response getContext(HttpHeaders headers, String serviceInstanceId, String modelVersionId, String modelInvariantId, String serviceType, String customerId) { + public Response getContext(HttpHeaders headers, String serviceInstanceId, String modelVersionId, String modelInvariantId) { - String url = "serviceInstanceId=" + serviceInstanceId + " modelVersion="+modelVersionId + - " modelInvariantId="+ modelInvariantId + " serviceType="+serviceType + " customerId="+ customerId; + String url = "serviceInstanceId=" + serviceInstanceId + " modelVersion="+modelVersionId + " modelInvariantId="+ modelInvariantId; if(log.isDebugEnabled()) { log.debug(LogMessages.AAI_CONTEXT_BUILDER_URL, url); } @@ -60,14 +59,14 @@ public class RestServiceImpl implements RestService { try { // Do some validation on Http headers and URL parameters - RestUtil.validateBasicAuthorization(headers, httpBasicAuthorization); + RestUtil.validateBasicAuthorization(headers, httpBasicAuthorization); RestUtil.validateHeader(headers); - RestUtil.validateURL(serviceInstanceId, modelVersionId, modelInvariantId, serviceType, customerId); + RestUtil.validateURL(serviceInstanceId, modelVersionId, modelInvariantId); // Keep the same transaction id for logging purpose transactionId= RestUtil.extractTranIdHeader(headers); - aaiContext = service.getContext(serviceInstanceId, modelVersionId, modelInvariantId, serviceType, customerId, transactionId); + aaiContext = service.getContext(serviceInstanceId, modelVersionId, modelInvariantId, transactionId); if (aaiContext==null) { // Return empty JSON diff --git a/src/main/java/org/onap/pomba/contextbuilder/aai/util/RestUtil.java b/src/main/java/org/onap/pomba/contextbuilder/aai/util/RestUtil.java index 905a8bc..60bbd61 100644 --- a/src/main/java/org/onap/pomba/contextbuilder/aai/util/RestUtil.java +++ b/src/main/java/org/onap/pomba/contextbuilder/aai/util/RestUtil.java @@ -14,9 +14,7 @@ package org.onap.pomba.contextbuilder.aai.util; - import com.sun.jersey.core.util.MultivaluedMapImpl; -import java.text.MessageFormat; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; @@ -35,21 +33,27 @@ import org.json.JSONException; import org.json.JSONObject; import org.onap.aai.restclient.client.OperationResult; import org.onap.aai.restclient.client.RestClient; +import org.onap.pomba.common.datatypes.Attribute; +import org.onap.pomba.common.datatypes.DataQuality; import org.onap.pomba.common.datatypes.ModelContext; import org.onap.pomba.common.datatypes.Service; import org.onap.pomba.common.datatypes.VF; import org.onap.pomba.common.datatypes.VFModule; +import org.onap.pomba.common.datatypes.VM; import org.onap.pomba.common.datatypes.VNFC; import org.onap.pomba.contextbuilder.aai.common.LogMessages; +import org.onap.pomba.contextbuilder.aai.datatype.Relationship; +import org.onap.pomba.contextbuilder.aai.datatype.RelationshipList; import org.onap.pomba.contextbuilder.aai.datatype.ServiceInstance; import org.onap.pomba.contextbuilder.aai.datatype.VfModule; import org.onap.pomba.contextbuilder.aai.datatype.VnfInstance; import org.onap.pomba.contextbuilder.aai.datatype.VnfcInstance; +import org.onap.pomba.contextbuilder.aai.datatype.Vserver; import org.onap.pomba.contextbuilder.aai.exception.AuditError; import org.onap.pomba.contextbuilder.aai.exception.AuditException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.beans.factory.annotation.Autowired; + public class RestUtil { @@ -60,8 +64,7 @@ public class RestUtil { private static final String SERVICE_INSTANCE_ID = "serviceInstanceId"; private static final String MODEL_VERSION_ID = "modelVersionId"; private static final String MODEL_INVARIANT_ID = "modelInvariantId"; - private static final String CUSTOMER_ID = "customerId"; - private static final String SERVICE_TYPE = "serviceType"; + // HTTP headers private static final String TRANSACTION_ID = "X-TransactionId"; @@ -70,10 +73,16 @@ public class RestUtil { private static final String APP_NAME = "aaiCtxBuilder"; - // Service Catalog + // Service Catalog - "related-to" private static final String CATALOG_GENERIC_VNF = "generic-vnf"; private static final String CATALOG_VNFC = "vnfc"; private static final String CATALOG_SERVICE_INSTANCE = "service-instance"; + private static final String CATALOG_VSERVER = "vserver"; + private static final String CATALOG_IMAGE = "image"; + private static final String CATALOG_PSERVER = "pserver"; + private static final String VF_MODULES = "vf-modules"; + private static final String VF_MODULE = "vf-module"; + // Relationship Json Path private static final String RELATIONSHIP_LIST = "relationship-list"; @@ -95,8 +104,8 @@ public class RestUtil { * * @throws AuditException if there is missing parameter */ - public static void validateURL(String serviceInstanceId, String modelVersionId, String modelInvariantId, - String serviceType, String customerId) throws AuditException { + public static void validateURL(String serviceInstanceId, String modelVersionId, String modelInvariantId) + throws AuditException { if (serviceInstanceId == null || serviceInstanceId.isEmpty()) { throw new AuditException(AuditError.INVALID_REQUEST_URL_MISSING_PARAMETER + SERVICE_INSTANCE_ID, @@ -112,18 +121,10 @@ public class RestUtil { Status.BAD_REQUEST); } - // serviceType - if (serviceType == null || serviceType.isEmpty()) { - throw new AuditException(AuditError.INVALID_REQUEST_URL_MISSING_PARAMETER + SERVICE_TYPE, Status.BAD_REQUEST); - } - // customerId - if (customerId == null || customerId.isEmpty()) { - throw new AuditException(AuditError.INVALID_REQUEST_URL_MISSING_PARAMETER + CUSTOMER_ID, Status.BAD_REQUEST); - } } public static void validateBasicAuthorization(HttpHeaders headers, String basicAuthorization) throws AuditException { - String authorization = null; + String authorization = null; // validation on HTTP Authorization Header authorization = headers.getRequestHeaders().getFirst(AUTHORIZATION); @@ -166,25 +167,25 @@ public class RestUtil { } /* - * Trigger external API call to AAI to retrieve Service Instance data (i.e. genericVNF and VNFC) + * Trigger external API call to AAI to collect the data in order to transform to common model + * */ - public static ModelContext retrieveAAIModelData(RestClient aaiClient, String baseURL, String aaiPathToSearchNodeQuery, String aaiServiceInstancePath, - String transactionId, String serviceInstanceId, String modelVersionId, String modelInvariantId, - String serviceType, String customerId, String aaiBasicAuthorization) throws AuditException { + public static ModelContext retrieveAAIModelData(RestClient aaiClient, String baseURL, String aaiPathToSearchNodeQuery, + String transactionId, String serviceInstanceId, String modelVersionId, String modelInvariantId, String aaiBasicAuthorization) throws AuditException { String serviceInstancePayload = null; String genericVNFPayload = null; - String vnfcPayload = null; - // Follow two variables for transform purpose List<VnfInstance> vnfLst = new ArrayList<VnfInstance>(); // List of the VNF POJO object - Map<String, List<VnfcInstance>> vnfMap = new HashMap<String, List<VnfcInstance>>(); // MAP the vnf-id as the - // key, and list of the vNFC - // pojo object + //Map to track multiple vnfc under the Gerneric VNF id. The key = vnf-id. The value = list of vnfc instance + Map<String, List<VnfcInstance>> vnfcMap = new HashMap<String, List<VnfcInstance>>(); + + //Map to track the relationship between vnf->vfmodule->verver + Map<String, Map<String, List<Vserver>>> vnf_vfmodule_vserver_Map = new HashMap<String, Map<String, List<Vserver>>>(); + // Obtain resource-link based on resource-type = service-Instance String resourceLink = obtainResouceLinkBasedOnServiceInstanceFromAAI(aaiClient, baseURL, aaiPathToSearchNodeQuery, serviceInstanceId, transactionId, aaiBasicAuthorization); + String url = baseURL + resourceLink; - String url = baseURL - + generateServiceInstanceURL(aaiServiceInstancePath, customerId, serviceType, serviceInstanceId); // Response from service instance API call serviceInstancePayload = getResource(aaiClient, url, aaiBasicAuthorization, transactionId, MediaType.valueOf(MediaType.APPLICATION_JSON)); @@ -200,7 +201,6 @@ public class RestUtil { log.info(LogMessages.NUMBER_OF_API_CALLS, "genericVNF", genericVNFLinkLst.size()); log.info(LogMessages.API_CALL_LIST, "genericVNF", printOutAPIList(genericVNFLinkLst)); - for (String genericVNFLink : genericVNFLinkLst) { // With latest AAI development, in order to retrieve the both generic VNF + vf_module, we can use // one API call but with depth=2 @@ -212,50 +212,121 @@ public class RestUtil { if (isEmptyJson(genericVNFPayload)) { log.info(LogMessages.NOT_FOUND, "GenericVNF with url ", genericVNFLink); } else { - // Logic to Create the Generic VNF Instance POJO object VnfInstance vnfInstance = VnfInstance.fromJson(genericVNFPayload); vnfLst.add(vnfInstance); - List<String> vnfcLinkLst = extractRelatedLink(genericVNFPayload, CATALOG_VNFC); - log.info(LogMessages.NUMBER_OF_API_CALLS, "vnfc", vnfcLinkLst.size()); - log.info(LogMessages.API_CALL_LIST, "vnfc", printOutAPIList(vnfcLinkLst)); - - List<VnfcInstance> vnfcLst = new ArrayList<VnfcInstance>(); - for (String vnfcLink : vnfcLinkLst) { - String vnfcURL = baseURL + vnfcLink; - vnfcPayload = getResource(aaiClient, vnfcURL, aaiBasicAuthorization, transactionId, - MediaType.valueOf(MediaType.APPLICATION_XML)); - - if (isEmptyJson(vnfcPayload)) { - log.info(LogMessages.NOT_FOUND, "VNFC with url", vnfcLink); - } else { - // Logic to Create the VNFC POJO object - VnfcInstance vnfcInstance = VnfcInstance.fromJson(vnfcPayload); - vnfcLst.add(vnfcInstance); - } - } + // Build the vnf_vnfc relationship map + vnfcMap = buildVnfcMap(genericVNFPayload, aaiClient, baseURL, transactionId, aaiBasicAuthorization ); + + // Build vnf_vfmodule_vserver relationship map + vnf_vfmodule_vserver_Map= buildVfmoduleVserverMap(genericVNFPayload, aaiClient, baseURL, transactionId, aaiBasicAuthorization); - // Assume the vnf-id is unique as a key - vnfMap.put(vnfInstance.getVnfId(), vnfcLst); } } // Transform to common model and return - return transform(ServiceInstance.fromJson(serviceInstancePayload), vnfLst, vnfMap); + return transform(ServiceInstance.fromJson(serviceInstancePayload), vnfLst, vnfcMap, vnf_vfmodule_vserver_Map); } + /* + * The map is to track the relationship of vnf-id with multiple vnfc relationship + */ + private static Map<String, List<VnfcInstance>> buildVnfcMap(String genericVNFPayload, RestClient aaiClient, String baseURL, + String transactionId, String aaiBasicAuthorization) throws AuditException { + + String vnfcPayload = null; + Map<String, List<VnfcInstance>> vnfcMap = new HashMap<String, List<VnfcInstance>>(); + + List<String> vnfcLinkLst = extractRelatedLink(genericVNFPayload, CATALOG_VNFC); + log.info(LogMessages.NUMBER_OF_API_CALLS, "vnfc", vnfcLinkLst.size()); + log.info(LogMessages.API_CALL_LIST, "vnfc", printOutAPIList(vnfcLinkLst)); + + List<VnfcInstance> vnfcLst = new ArrayList<VnfcInstance>(); + for (String vnfcLink : vnfcLinkLst) { + String vnfcURL = baseURL + vnfcLink; + vnfcPayload = getResource(aaiClient, vnfcURL, aaiBasicAuthorization, transactionId, + MediaType.valueOf(MediaType.APPLICATION_XML)); + + if (isEmptyJson(vnfcPayload)) { + log.info(LogMessages.NOT_FOUND, "VNFC with url", vnfcLink); + } else { + // Logic to Create the VNFC POJO object + VnfcInstance vnfcInstance = VnfcInstance.fromJson(vnfcPayload); + vnfcLst.add(vnfcInstance); + } + } + // Assume the vnf-id is unique as a key + vnfcMap.put(getVnfId(genericVNFPayload), vnfcLst); + + return vnfcMap; + } + + /* + * This is a two layer map to track the relationship between vnf->vfmodule->verver + * + * The Map<String, List<Vserver> is to track multiple vserver under the vfModule. + * Key: combination of the model_version_id and model_invariant_id. + * Value: list of Vserver + * + * The Map<String, Map<String, List<Vserver>>> key: vnf-id + */ + private static Map<String, Map<String, List<Vserver>>> buildVfmoduleVserverMap(String genericVNFPayload, RestClient aaiClient, String baseURL, String transactionId, String aaiBasicAuthorization) throws AuditException { + + Map<String, Map<String, List<Vserver>>> vnf_vfmodule_vserver_Map = new HashMap<String, Map<String, List<Vserver>>>(); + + Map<String, List<Vserver>> vServerMap = new HashMap<String, List<Vserver>>(); + + Map<String, List<String>> vServerRelatedLinkMap = extractRelatedLinkFromVfmodule(genericVNFPayload, CATALOG_VSERVER); + String vnfId= getVnfId(genericVNFPayload); + String vserverPayload = null; + + for(Map.Entry<String, List<String>> entry : vServerRelatedLinkMap.entrySet()) { + + List<String> vserverLinkLst = entry.getValue(); + log.info(LogMessages.NUMBER_OF_API_CALLS, "vserver", vserverLinkLst.size()); + log.info(LogMessages.API_CALL_LIST, "vserver", printOutAPIList(vserverLinkLst)); + + List<Vserver> vserverLst = new ArrayList<Vserver>(); + for (String vserverLink : vserverLinkLst) { + String vserverURL = baseURL + vserverLink; + vserverPayload = getResource(aaiClient, vserverURL, aaiBasicAuthorization, transactionId, + MediaType.valueOf(MediaType.APPLICATION_XML)); + + if (isEmptyJson(vserverPayload)) { + log.info(LogMessages.NOT_FOUND, "VSERVER with url", vserverURL); + } else { + // Logic to Create the Vserver POJO object + Vserver vserver = Vserver.fromJson(vserverPayload); + vserverLst.add(vserver); + } + } + + vServerMap.put(entry.getKey(), vserverLst); + } + + vnf_vfmodule_vserver_Map.put(vnfId, vServerMap); + + return vnf_vfmodule_vserver_Map; + } + + + private static String getVnfId(String genericVNFPayload) throws AuditException { + + VnfInstance vnfInstance = VnfInstance.fromJson(genericVNFPayload); + return vnfInstance.getVnfId(); + } /* * Transform AAI Representation to Common Model */ private static ModelContext transform(ServiceInstance svcInstance, List<VnfInstance> vnfLst, - Map<String, List<VnfcInstance>> vnfMap) { + Map<String, List<VnfcInstance>> vnfcMap, Map<String, Map<String, List<Vserver>>> vnf_vfmodule_vserver_Map) { ModelContext context = new ModelContext(); Service service = new Service(); service.setInvariantUuid(svcInstance.getModelInvariantId()); service.setName(svcInstance.getServiceInstanceName()); service.setUuid(svcInstance.getModelVersionId()); - + service.setDataQuality(DataQuality.ok()); List<VF> vfLst = new ArrayList<VF>(); for (VnfInstance vnf : vnfLst) { @@ -264,12 +335,13 @@ public class RestUtil { vf.setName(vnf.getVnfName()); vf.setUuid(vnf.getModelVersionId()); vf.setType(vnf.getVnfType()); - vf.setNfNamingCode(vnf.getNfNamingCode()); + vf.setDataQuality(DataQuality.ok()); - String key = vnf.getVnfId(); - List<VNFC> vnfcLst = new ArrayList<VNFC>(); + String key = vnf.getVnfId(); // generic vnf-id (top level of the key) - for (Map.Entry<String, List<VnfcInstance>> entry : vnfMap.entrySet()) { + // ---------------- Handle VNFC data + List<VNFC> vnfcLst = new ArrayList<VNFC>(); + for (Map.Entry<String, List<VnfcInstance>> entry : vnfcMap.entrySet()) { if (key.equals(entry.getKey())) { List<VnfcInstance> vnfcInstanceLst = entry.getValue(); @@ -278,55 +350,141 @@ public class RestUtil { VNFC vnfcModel = new VNFC(); vnfcModel.setInvariantUuid(vnfc.getModelInvariantId()); vnfcModel.setName(vnfc.getVnfcName()); - vnfcModel.setNfcNamingCode(vnfc.getNfcNamingCode()); vnfcModel.setUuid(vnfc.getModelVersionId()); vnfcLst.add(vnfcModel); } } } + vf.setVnfcs(vnfcLst); - vf.setVnfc(vnfcLst); - // Add the vfModule - List<VFModule> vfModuleLst = new ArrayList<VFModule>(); - if (vnf.getVfModules() != null) { - ConcurrentMap<String, AtomicInteger> vnfModulemap = - buildMaxInstanceMap(vnf.getVfModules().getVfModule()); + // --------------- Handle the vfModule + //Map to calculate the Vf Module MaxInstance. + ConcurrentMap<String, AtomicInteger> maxInstanceMap = + buildMaxInstanceMap(vnf.getVfModules().getVfModule()); - for (Map.Entry<String, AtomicInteger> entry : vnfModulemap.entrySet()) { - String[] s = entry.getKey().split("\\" + DELIMITER); + List<VFModule> vfModuleLst = new ArrayList<VFModule>(); + for ( Map.Entry<String, Map<String, List<Vserver>>> entry: vnf_vfmodule_vserver_Map.entrySet() ) { + // find the vnf-id + if (key.equals(entry.getKey())) { + + Map<String, List<Vserver>> vfmodule_vserver_map= entry.getValue(); + + for ( Map.Entry<String, List<Vserver>> vfmoduleEntry: vfmodule_vserver_map.entrySet() ){ + // The key is modelversionId$modelInvariantid + String[] s = vfmoduleEntry.getKey().split("\\" + DELIMITER); + String modelVersionId = s[0]; + String modelInvariantId = s[1]; + + VFModule vfModule = new VFModule(); + vfModule.setUuid(modelVersionId); + vfModule.setInvariantUuid(modelInvariantId); + vfModule.setMaxInstances(getMaxInstance(vfmoduleEntry.getKey(), maxInstanceMap)); + vfModule.setDataQuality(DataQuality.ok()); + + List<Vserver> vserverList = vfmoduleEntry.getValue(); + + // Handle VM + List<VM> vmList = new ArrayList<VM>(); + for (Vserver vserver: vserverList) { + + List<Attribute> attributeList = new ArrayList<Attribute>(); + + // Iterate through the ENUM Attribute list + for (Attribute.Name name: Attribute.Name.values()) { + if (name.toString().equals("lockedBoolean")) { + Attribute att = new Attribute(); + att.setDataQuality(DataQuality.ok()); + att.setName(Attribute.Name.lockedBoolean); + att.setValue(String.valueOf(vserver.getInMaint())); + attributeList.add(att); + } + + if (name.toString().equals("hostName")) { + Attribute att = new Attribute(); + att.setDataQuality(DataQuality.ok()); + att.setName(Attribute.Name.hostName); + att.setValue(getVserverAttribute(vserver, CATALOG_PSERVER)); + attributeList.add(att); + } + + if (name.toString().equals("imageId")) { + Attribute att = new Attribute(); + att.setDataQuality(DataQuality.ok()); + att.setName(Attribute.Name.imageId); + att.setValue(getVserverAttribute(vserver, CATALOG_IMAGE)); + attributeList.add(att); + } + } + VM vm = new VM(); + vm.setUuid(vserver.getVserverId()); + vm.setName(vserver.getVserverName()); + vm.setAttributes(attributeList); + vmList.add(vm); + } + vfModule.setVms(vmList); + vfModuleLst.add(vfModule); + } - String modelVersionId = s[0]; - String modelInvariantId = s[1]; - VFModule vfModule = new VFModule(); - vfModule.setUuid(modelVersionId); - vfModule.setInvariantUuid(modelInvariantId); - vfModule.setMaxInstances(entry.getValue().intValue()); - vfModuleLst.add(vfModule); } } - vf.setVfModules(vfModuleLst); + vf.setVfModules(vfModuleLst); vfLst.add(vf); } // done the vnfInstance context.setService(service); - context.setVf(vfLst); + context.setVfs(vfLst); return context; } + /* + * Return the Vserver Attribute value by looking through the relationship. i.e. if "related-to" is "pserver", we will get + * the value of the attribute "hostname" from the last substring of the "related-link" + * { + * "related-to": "pserver", + * "related-link": "/aai/v11/cloud-infrastructure/pservers/pserver/rdm5r10c008.rdm5a.cci.att.com", + * "relationship-data": [ { + * "relationship-key": "pserver.hostname", + * "relationship-value": "rdm5r10c008.rdm5a.cci.att.com" + * }], + * "related-to-property": [{"property-key": "pserver.pserver-name2"}] + * }, + * + */ + private static String getVserverAttribute(Vserver vserver, String key) { + RelationshipList lst = vserver.getRelationshipList(); + if (lst != null) { + List<Relationship> relations = lst.getRelationship(); + for (Relationship re: relations) { + if (re.getRelatedTo().equals(key)) { + return extractAttValue(re.getRelatedLink()); + } + } + } + return null; + } + + + + /* + * Get the last substring from the related-link + * For example the value of the attribute "hostname" will be "rdm5r10c008.rdm5a.cci.att.com" + * "related-to": "pserver", + * "related-link": "/aai/v11/cloud-infrastructure/pservers/pserver/rdm5r10c008.rdm5a.cci.att.com", + */ + private static String extractAttValue(String relatedLink) { + return relatedLink.substring(relatedLink.lastIndexOf("/")+1); + } /* * Build the map with key (model_version_id and model_invariant_id), and with the max occurrences of * the value in the map * - * @param vfModuleList - * - * @return */ private static ConcurrentMap<String, AtomicInteger> buildMaxInstanceMap(List<VfModule> vfModuleList) { @@ -348,6 +506,20 @@ public class RestUtil { } + /* + * Return the occurrence of the VfModule complex key: (model-version-id)+(model-invariant-id) + */ + private static int getMaxInstance(String key, ConcurrentMap<String, AtomicInteger> maxInstanceMap) { + + for (Map.Entry<String, AtomicInteger> entry : maxInstanceMap.entrySet()) { + + if (entry.getKey().equals(key)) { + return entry.getValue().intValue(); + } + + } + return 0; + } public static boolean isEmptyJson(String serviceInstancePayload) { @@ -355,7 +527,9 @@ public class RestUtil { return (serviceInstancePayload.equals(EMPTY_JSON_STRING)); } - + /* + * Debug purpose - Display the related-link list + */ private static String printOutAPIList(List<String> relatedLinkLst) { StringBuilder builder = new StringBuilder(); @@ -383,7 +557,7 @@ public class RestUtil { JSONObject jsonPayload = new JSONObject(payload); JSONArray relationships = null; List<String> relatedLinkList = new ArrayList<String>(); - log.info("Fetching the vnfc related link"); + log.debug("Fetching the related link"); try { JSONObject relationshipList = jsonPayload.getJSONObject(RELATIONSHIP_LIST); @@ -417,9 +591,67 @@ public class RestUtil { return relatedLinkList; } + /* + * Return the Map with key: Vfmodule->model-version-id + Vfmoduel->model-invariant-id + * with value: list of the related-link based on the catalog + * The catalog can be "vserver" or "l3-network" based on common model requirement. + */ + private static Map<String, List<String>> extractRelatedLinkFromVfmodule(String payload, String catalog) throws AuditException { + + Map<String, List<String>> vServerRelatedLinkMap = new HashMap<String, List<String>>(); + + JSONObject jsonPayload = new JSONObject(payload); + JSONArray vfmoduleArray = null; + JSONArray relationships = null; + + try { + log.debug("Fetching the Vf-module"); + JSONObject vfmodules = jsonPayload.getJSONObject(VF_MODULES); + if (vfmodules != null) { + vfmoduleArray = vfmodules.getJSONArray(VF_MODULE); + } + + if (vfmoduleArray != null && vfmoduleArray.length() > 0) { + for (int i = 0; i < vfmoduleArray.length(); i++) { + List<String> relatedLinkList = new ArrayList<String>(); + JSONObject obj = vfmoduleArray.optJSONObject(i); + String key = (String)obj.get("model-version-id") + DELIMITER + (String)obj.get("model-invariant-id"); + + log.debug("Fetching the relationship"); + JSONObject relationshipList = obj.getJSONObject(RELATIONSHIP_LIST); + if (relationshipList != null) { + relationships = relationshipList.getJSONArray(RELATIONSHIP); + } + if (relationships != null && relationships.length() > 0) { + for (int j = 0; j < relationships.length(); j++) { + Object relatedToObj = null; + Object relatedLinkObj = null; + + JSONObject obj2 = relationships.optJSONObject(j); + relatedToObj = obj2.get(JSON_ATT_RELATED_TO); + + if (relatedToObj.toString().equals(catalog)) { + relatedLinkObj = obj2.get(JSON_ATT_RELATED_LINK); + if (relatedLinkObj != null) { + relatedLinkList.add(relatedLinkObj.toString()); + } + } + } //relationship + } + + vServerRelatedLinkMap.put(key, relatedLinkList); + } //vf-module + } + + } catch (Exception e) { + log.error(e.getMessage()); + throw new AuditException(AuditError.JSON_READER_PARSE_ERROR + " " + e.getMessage()); + } + + return vServerRelatedLinkMap; + } - @SuppressWarnings("unchecked") private static Map<String, List<String>> buildHeaders(String aaiBasicAuthorization, String transactionId) { MultivaluedMap<String, String> headers = new MultivaluedMapImpl(); headers.put(TRANSACTION_ID, Collections.singletonList(transactionId)); @@ -446,11 +678,6 @@ public class RestUtil { } - private static String generateServiceInstanceURL(String siPath, String customerId, String serviceType, - String serviceInstanceId) { - return MessageFormat.format(siPath, customerId, serviceType, serviceInstanceId); - } - public static String obtainResouceLinkBasedOnServiceInstanceFromAAI(RestClient aaiClient, String baseURL, String aaiPathToSearchNodeQuery, String serviceInstanceId, String transactionId, String aaiBasicAuthorization) throws AuditException { @@ -467,7 +694,7 @@ public class RestUtil { return extractResourceLinkBasedOnResourceType(customerInfoString, CATALOG_SERVICE_INSTANCE); } - private static String generateGetCustomerInfoUrl (String baseURL, String aaiPathToSearchNodeQuery ,String serviceInstanceId) { + private static String generateGetCustomerInfoUrl (String baseURL, String aaiPathToSearchNodeQuery,String serviceInstanceId) { return baseURL + aaiPathToSearchNodeQuery + serviceInstanceId; } diff --git a/src/test/java/org/onap/logging_analytics/pomba/pomba_aai_context_builder/RestUtilTest.java b/src/test/java/org/onap/logging_analytics/pomba/pomba_aai_context_builder/RestUtilTest.java index f8991c1..8b3fe63 100644 --- a/src/test/java/org/onap/logging_analytics/pomba/pomba_aai_context_builder/RestUtilTest.java +++ b/src/test/java/org/onap/logging_analytics/pomba/pomba_aai_context_builder/RestUtilTest.java @@ -61,80 +61,54 @@ public class RestUtilTest { @Rule public WireMockRule aaiEnricherRule = new WireMockRule(wireMockConfig().port(9808)); - @Test - public void testValidateURL() { - // Missing ServiceInstanceId or it is null - try { - RestUtil.validateURL("", "modelVersionId", "modelInvariantId", "serviceType", "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: serviceInstanceId")); - } - - try { - RestUtil.validateURL(null, "modelVersionId", "modelInvariantId", "serviceType", "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: serviceInstanceId")); - } - - // Missing ModelVersionId or it is null - try { - RestUtil.validateURL("serviceInstanceId", "", "modelInvariantId", "serviceType", "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelVersionId")); - } - - try { - RestUtil.validateURL("serviceInstanceId", null, "modelInvariantId", "serviceType", "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelVersionId")); - } - - // Missing ModelInvariantId or it is null - try { - RestUtil.validateURL("serviceInstanceId", "modelVersionId", "", "serviceType", "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelInvariantId")); - } - - try { - RestUtil.validateURL("serviceInstanceId", "modelVersionId", null, "serviceType", "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelInvariantId")); - } - - // Missing ServiceType or it is null - try { - RestUtil.validateURL("serviceInstanceId", "modelVersionId", "modelInvariantId", "", "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: serviceType")); - } - - try { - RestUtil.validateURL("serviceInstanceId", "modelVersionId", "modelInvariantId", null, "customerId"); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: serviceType")); - } - - // Missing CustomerId or it is null - try { - RestUtil.validateURL("serviceInstanceId", "modelVersionId", "modelInvariantId", "serviceType", ""); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: customerId")); - } - - - try { - RestUtil.validateURL("serviceInstanceId", "modelVersionId", "modelInvariantId", "serviceType", null); - } catch (AuditException e) { - assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: customerId")); - } - } - - @Test - public void testIsEmptyJson() { - assertTrue(RestUtil.isEmptyJson("{}")); - assertTrue(!RestUtil.isEmptyJson("{Not Empty}")); - } + @Test + public void testValidateURL() { + // Missing ServiceInstanceId or it is null + try { + RestUtil.validateURL("", "modelVersionId", "modelInvariantId"); + } catch (AuditException e) { + assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: serviceInstanceId")); + } + + try { + RestUtil.validateURL(null, "modelVersionId", "modelInvariantId"); + } catch (AuditException e) { + assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: serviceInstanceId")); + } + + // Missing ModelVersionId or it is null + try { + RestUtil.validateURL("serviceInstanceId", "", "modelInvariantId"); + } catch (AuditException e) { + assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelVersionId")); + } + + try { + RestUtil.validateURL("serviceInstanceId", null, "modelInvariantId"); + } catch (AuditException e) { + assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelVersionId")); + } + + // Missing ModelInvariantId or it is null + try { + RestUtil.validateURL("serviceInstanceId", "modelVersionId", ""); + } catch (AuditException e) { + assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelInvariantId")); + } + + try { + RestUtil.validateURL("serviceInstanceId", "modelVersionId", null); + } catch (AuditException e) { + assertTrue(e.getMessage().contains("Invalid request URL, missing parameter: modelInvariantId")); + } + + } + + @Test + public void testIsEmptyJson() { + assertTrue(RestUtil.isEmptyJson("{}")); + assertTrue(!RestUtil.isEmptyJson("{Not Empty}")); + } @Test public void testObtainResouceLinkBasedOnServiceInstanceFromAAI() throws Exception { |