Eliminate the technical debt identified in the drools-applications/controlloop/common/model-impl/aai module by Sonar
Change-Id: I72125baacc217386a4984be04bfc023439eddd13
Signed-off-by: Liam Fallon <liam.fallon@ericsson.com>
Issue-ID: POLICY-455
Signed-off-by: Liam Fallon <liam.fallon@ericsson.com>
break;
}
else {
- if((item.items != null) && (item.items.inventoryResponseItems != null)) {
- vnfId = parseAAIResponse(item.items.inventoryResponseItems, resourceId);
+ if((item.items != null) && (item.items.getInventoryResponseItems() != null)) {
+ vnfId = parseAAIResponse(item.items.getInventoryResponseItems(), resourceId);
}
}
}
filter.put("generic-vnf", filterItem);
aaiRequest.instanceFilters = new AAINQInstanceFilters();
- aaiRequest.instanceFilters.instanceFilter.add(filter);
+ aaiRequest.instanceFilters.getInstanceFilter().add(filter);
/*
* Obtain A&AI credentials from properties.environment file
throw new AAIException("The named query response was null");
}
- String targetVnfId = parseAAIResponse(aaiResponse.inventoryResponseItems, resourceId);
+ String targetVnfId = parseAAIResponse(aaiResponse.getInventoryResponseItems(), resourceId);
if (targetVnfId == null) {
throw new AAIException("Target vnf-id could not be found");
}
Map<String, String> aainqinstancefiltermapitem = new HashMap<>();
aainqinstancefiltermapitem.put("vserver-name", onset.AAI.get("vserver.vserver-name")); // TO DO: get vserver.vname from dcae onset.AAI.get("vserver.vserver-name")
aainqinstancefiltermap.put("vserver", aainqinstancefiltermapitem);
- aainqinstancefilter.instanceFilter.add(aainqinstancefiltermap);
+ aainqinstancefilter.getInstanceFilter().add(aainqinstancefiltermap);
aainqrequest.instanceFilters = aainqinstancefilter;
//
// print aainqrequest for debug
if (logger.isDebugEnabled()) {
logger.debug("AAI Named Query Response: ");
- logger.debug(Serialization.gsonPretty.toJson(aainqResponseWrapper.aainqresponse));
+ logger.debug(Serialization.gsonPretty.toJson(aainqResponseWrapper.getAainqresponse()));
}
extractSOFieldsFromNamedQuery(aainqResponseWrapper, onset);
try {
// vnfItem
- setVnfItemVnfId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).genericVNF.vnfID);
- setVnfItemVnfType(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).genericVNF.vnfType);
+ setVnfItemVnfId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).genericVNF.vnfID);
+ setVnfItemVnfType(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).genericVNF.vnfType);
setVnfItemVnfType(vnfItemVnfType.substring(vnfItemVnfType.lastIndexOf("/")+1));
- setVnfItemModelInvariantId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).genericVNF.modelInvariantId);
- setVnfItemModelVersionId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).genericVNF.modelVersionId);
- setVnfItemModelName(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).extraProperties.extraProperty.get(1).propertyValue);
- setVnfItemModelNameVersionId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).extraProperties.extraProperty.get(0).propertyValue);
- setVnfItemModelVersion(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).extraProperties.extraProperty.get(4).propertyValue);
+ setVnfItemModelInvariantId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).genericVNF.modelInvariantId);
+ setVnfItemModelVersionId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).genericVNF.modelVersionId);
+ setVnfItemModelName(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).extraProperties.getExtraProperty().get(1).propertyValue);
+ setVnfItemModelNameVersionId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).extraProperties.getExtraProperty().get(0).propertyValue);
+ setVnfItemModelVersion(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).extraProperties.getExtraProperty().get(4).propertyValue);
// serviceItem
- setServiceItemServiceInstanceId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).serviceInstance.serviceInstanceID);
- setServiceItemModelInvariantId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).serviceInstance.modelInvariantId);
- setServiceItemModelName(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).extraProperties.extraProperty.get(1).propertyValue);
- setServiceItemModelType(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).extraProperties.extraProperty.get(1).propertyValue);
- setServiceItemModelNameVersionId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).serviceInstance.modelVersionId);
- setServiceItemModelVersion(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).extraProperties.extraProperty.get(4).propertyValue);
+ setServiceItemServiceInstanceId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).serviceInstance.serviceInstanceID);
+ setServiceItemModelInvariantId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).serviceInstance.modelInvariantId);
+ setServiceItemModelName(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).extraProperties.getExtraProperty().get(1).propertyValue);
+ setServiceItemModelType(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).extraProperties.getExtraProperty().get(1).propertyValue);
+ setServiceItemModelNameVersionId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).serviceInstance.modelVersionId);
+ setServiceItemModelVersion(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).extraProperties.getExtraProperty().get(4).propertyValue);
// Find the index for base vf module and non-base vf module
int baseIndex = -1;
int nonBaseIndex = -1;
- List<AAINQInventoryResponseItem> inventoryItems = namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems;
+ List<AAINQInventoryResponseItem> inventoryItems = namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems();
for (AAINQInventoryResponseItem m : inventoryItems) {
if (m.vfModule != null) {
if (m.vfModule.isBaseVfModule) {
}
// This comes from the base module
- setVfModuleItemVfModuleName(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(baseIndex).vfModule.vfModuleName);
+ setVfModuleItemVfModuleName(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(baseIndex).vfModule.vfModuleName);
setVfModuleItemVfModuleName(vfModuleItemVfModuleName.replace("Vfmodule", "vDNS"));
// vfModuleItem - NOT the base module
- setVfModuleItemModelInvariantId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(nonBaseIndex).vfModule.modelInvariantId);
- setVfModuleItemModelNameVersionId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(nonBaseIndex).vfModule.modelVersionId);
- setVfModuleItemModelName(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(nonBaseIndex).extraProperties.extraProperty.get(1).propertyValue);
- setVfModuleItemModelVersionId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(0).items.inventoryResponseItems.get(nonBaseIndex).extraProperties.extraProperty.get(4).propertyValue);
+ setVfModuleItemModelInvariantId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(nonBaseIndex).vfModule.modelInvariantId);
+ setVfModuleItemModelNameVersionId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(nonBaseIndex).vfModule.modelVersionId);
+ setVfModuleItemModelName(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(nonBaseIndex).extraProperties.getExtraProperty().get(1).propertyValue);
+ setVfModuleItemModelVersionId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(nonBaseIndex).extraProperties.getExtraProperty().get(4).propertyValue);
// tenantItem
- setTenantItemTenantId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(1).tenant.tenantId);
+ setTenantItemTenantId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(1).tenant.tenantId);
// cloudRegionItem
- setCloudRegionItemCloudRegionId(namedQueryResponseWrapper.aainqresponse.inventoryResponseItems.get(0).items.inventoryResponseItems.get(1).items.inventoryResponseItems.get(0).cloudRegion.cloudRegionId);
+ setCloudRegionItemCloudRegionId(namedQueryResponseWrapper.getAainqresponse().getInventoryResponseItems().get(0).items.getInventoryResponseItems().get(1).items.getInventoryResponseItems().get(0).cloudRegion.cloudRegionId);
} catch (Exception e) {
logger.warn("Problem extracting SO data from AAI query response because of {}", e.getMessage(), e);
relationshipDataItem.relationshipKey = "customer.global-customer-id";
relationshipDataItem.relationshipValue = "MSO_1610_ST";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-subscription.service-type";
relationshipDataItem.relationshipValue = "MSO-dev-service-type";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-instance.service-instance-id";
relationshipDataItem.relationshipValue = "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
RelatedToProperty relatedToProperty = new RelatedToProperty();
RelatedToPropertyItem item = new RelatedToPropertyItem();
item.propertyKey = "service-instance.service-instance-name";
item.propertyValue = "lll_svc_010317";
- relatedToProperty.relatedTo.add(item);
+ relatedToProperty.getRelatedTo().add(item);
relationship.relatedTo = "service-instance";
relationship.relatedLink = "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription/MSO-dev-service-type/service-instances/service-instance/e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
relationship.relationshipData = relationshipData;
relationship.relatedToProperty = relatedToProperty;
- relationshipList.relationshipList.add(relationship);
+ relationshipList.getRelationshipList().add(relationship);
response.relationshipList = relationshipList;
return response;
relationshipDataItem.relationshipKey = "customer.global-customer-id";
relationshipDataItem.relationshipValue = "MSO_1610_ST";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-subscription.service-type";
relationshipDataItem.relationshipValue = "MSO-dev-service-type";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-instance.service-instance-id";
relationshipDataItem.relationshipValue = "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
RelatedToProperty relatedToProperty = new RelatedToProperty();
RelatedToPropertyItem item = new RelatedToPropertyItem();
item.propertyKey = "service-instance.service-instance-name";
item.propertyValue = "lll_svc_010317";
- relatedToProperty.relatedTo.add(item);
+ relatedToProperty.getRelatedTo().add(item);
relationship.relatedTo = "service-instance";
relationship.relatedLink = "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription/MSO-dev-service-type/service-instances/service-instance/e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
relationship.relationshipData = relationshipData;
relationship.relatedToProperty = relatedToProperty;
- relationshipList.relationshipList.add(relationship);
+ relationshipList.getRelationshipList().add(relationship);
response.relationshipList = relationshipList;
return response;
relationshipDataItem.relationshipKey = "customer.global-customer-id";
relationshipDataItem.relationshipValue = "MSO_1610_ST";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-subscription.service-type";
relationshipDataItem.relationshipValue = "MSO-dev-service-type";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-instance.service-instance-id";
relationshipDataItem.relationshipValue = "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
RelatedToProperty relatedToProperty = new RelatedToProperty();
RelatedToPropertyItem item = new RelatedToPropertyItem();
item.propertyKey = "service-instance.service-instance-name";
item.propertyValue = "lll_svc_010317";
- relatedToProperty.relatedTo.add(item);
+ relatedToProperty.getRelatedTo().add(item);
relationship.relatedTo = "service-instance";
relationship.relatedLink = "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription/MSO-dev-service-type/service-instances/service-instance/e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
relationship.relationshipData = relationshipData;
relationship.relatedToProperty = relatedToProperty;
- relationshipList.relationshipList.add(relationship);
+ relationshipList.getRelationshipList().add(relationship);
response.relationshipList = relationshipList;
return response;
@SerializedName("requestError")
public AAINQRequestError requestError;
-
- public AAIGETResponse() {
- }
-
}
@SerializedName("orchestration-status")
public String orchestrationStatus;
-
- public AAIGETVnfResponse() {
- }
-
}
\ No newline at end of file
@SerializedName("vserver-selflink")
public String vserverSelflink;
-
- public AAIGETVserverResponse() {
- }
-
}
import com.google.gson.JsonSyntaxException;
public final class AAIManager {
+ private static final String LINE_SEPARATOR = System.lineSeparator();
+
+ /**
+ * Private constructor added to avoid instantiation of static class
+ */
+ private AAIManager() {
+ }
+
private static final Logger logger = LoggerFactory.getLogger(AAIManager.class);
private static final Logger netLogger = LoggerFactory.getLogger(org.onap.policy.drools.event.comm.Topic.NETWORK_LOGGER);
-
+
public static AAINQResponse postQuery(String url, String username, String password, AAINQRequest request, UUID requestID) {
-
- Map<String, String> headers = new HashMap<>();
- headers.put("X-FromAppId", "POLICY");
- headers.put("X-TransactionId", requestID.toString());
- headers.put("Accept", "application/json");
-
+
+ Map<String, String> headers = createHeaders(requestID);
+
url = url + "/aai/search/named-query";
logger.debug("RESTManager.post before");
String requestJson = Serialization.gsonPretty.toJson(request);
- netLogger.info("[OUT|{}|{}|]{}{}", "AAI", url, System.lineSeparator(), requestJson);
+ netLogger.info("[OUT|{}|{}|]{}{}", "AAI", url, LINE_SEPARATOR, requestJson);
Pair<Integer, String> httpDetails = RESTManager.post(url, username, password, headers, "application/json", requestJson);
logger.debug("RESTManager.post after");
-
+
if (httpDetails == null) {
- logger.info("AAI POST Null Response to " + url);
+ logger.info("AAI POST Null Response to {}", url);
return null;
}
+
+ int httpResponseCode = httpDetails.a;
logger.info(url);
- logger.info(httpDetails.a.toString());
+ logger.info("{}", httpResponseCode);
logger.info(httpDetails.b);
+
if (httpDetails.b != null) {
- try {
- AAINQResponse response = Serialization.gsonPretty.fromJson(httpDetails.b, AAINQResponse.class);
- netLogger.info("[IN|{}|{}|]{}{}", "AAI", url, System.lineSeparator(), httpDetails.b);
- return response;
- } catch (JsonSyntaxException e) {
- logger.error("postQuery threw: ", e);
- }
+ return composeResponse(httpDetails, url, AAINQResponse.class);
}
return null;
}
-
+
public static AAIGETVserverResponse getQueryByVserverName(String urlGet, String username, String password, UUID requestID, String key) {
-
- Map<String, String> headers = new HashMap<>();
- headers.put("X-FromAppId", "POLICY");
- headers.put("X-TransactionId", requestID.toString());
- headers.put("Accept", "application/json");
-
+
+ Map<String, String> headers = createHeaders(requestID);
+
urlGet = urlGet + key;
-
+
int attemptsLeft = 3;
- AAIGETVserverResponse responseGet = null;
-
+
while(attemptsLeft-- > 0){
netLogger.info("[OUT|{}|{}|]", "AAI", urlGet);
Pair<Integer, String> httpDetailsGet = RESTManager.get(urlGet, username, password, headers);
if (httpDetailsGet == null) {
- logger.info("AAI GET Null Response to " + urlGet);
+ logger.info("AAI GET Null Response to {}", urlGet);
return null;
}
+
+ int httpResponseCode = httpDetailsGet.a;
logger.info(urlGet);
- logger.info(httpDetailsGet.a.toString());
+ logger.info("{}", httpResponseCode);
logger.info(httpDetailsGet.b);
-
- if (httpDetailsGet.a == 200) {
- try {
- responseGet = Serialization.gsonPretty.fromJson(httpDetailsGet.b, AAIGETVserverResponse.class);
- netLogger.info("[IN|{}|{}|]{}{}", "AAI", urlGet, System.lineSeparator(), httpDetailsGet.b);
+
+ if (httpResponseCode == 200) {
+ AAIGETVserverResponse responseGet = composeResponse(httpDetailsGet, urlGet, AAIGETVserverResponse.class);
+ if (responseGet != null) {
return responseGet;
- } catch (JsonSyntaxException e) {
- logger.error("postQuery threw: ", e);
}
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) { Thread.currentThread().interrupt(); }
- }
-
+ }
+
return null;
}
-
+
public static AAIGETVnfResponse getQueryByVnfID(String urlGet, String username, String password, UUID requestID, String key) {
-
- Map<String, String> headers = new HashMap<>();
- headers.put("X-FromAppId", "POLICY");
- headers.put("X-TransactionId", requestID.toString());
- headers.put("Accept", "application/json");
-
+
+ Map<String, String> headers = createHeaders(requestID);
+
urlGet = urlGet + key;
-
+
int attemptsLeft = 3;
- AAIGETVnfResponse responseGet = null;
-
+
while(attemptsLeft-- > 0){
netLogger.info("[OUT|{}|{}|]", "AAI", urlGet);
Pair<Integer, String> httpDetailsGet = RESTManager.get(urlGet, username, password, headers);
if (httpDetailsGet == null) {
- logger.info("AAI GET Null Response to " + urlGet);
+ logger.info("AAI GET Null Response to {}", urlGet);
return null;
}
+
+ int httpResponseCode = httpDetailsGet.a;
logger.info(urlGet);
- logger.info(httpDetailsGet.a.toString());
+ logger.info("{}", httpResponseCode);
logger.info(httpDetailsGet.b);
-
- if (httpDetailsGet.a == 200) {
- try {
- responseGet = Serialization.gsonPretty.fromJson(httpDetailsGet.b, AAIGETVnfResponse.class);
- netLogger.info("[IN|{}|{}|]{}{}", "AAI", urlGet, System.lineSeparator(), httpDetailsGet.b);
+
+ if (httpResponseCode == 200) {
+ AAIGETVnfResponse responseGet = composeResponse(httpDetailsGet, urlGet, AAIGETVnfResponse.class);
+ if (responseGet != null) {
return responseGet;
- } catch (JsonSyntaxException e) {
- logger.error("postQuery threw: ", e);
}
}
try {
} catch (InterruptedException e) { Thread.currentThread().interrupt(); }
}
-
+
return null;
}
-
+
public static AAIGETVnfResponse getQueryByVnfName(String urlGet, String username, String password, UUID requestID, String key) {
-
+ return getQueryByVnfID(urlGet, username, password, requestID, key);
+ }
+
+ /**
+ * Create the headers for the HTTP request
+ * @param requestID the request ID to insert in the headers
+ * @return the HTTP headers
+ */
+ private static Map<String, String> createHeaders(final UUID requestID) {
Map<String, String> headers = new HashMap<>();
+
headers.put("X-FromAppId", "POLICY");
headers.put("X-TransactionId", requestID.toString());
headers.put("Accept", "application/json");
-
- urlGet = urlGet + key;
-
- int attemptsLeft = 3;
- AAIGETVnfResponse responseGet = null;
-
- while(attemptsLeft-- > 0){
- netLogger.info("[OUT|{}|{}|]", "AAI", urlGet);
- Pair<Integer, String> httpDetailsGet = RESTManager.get(urlGet, username, password, headers);
- if (httpDetailsGet == null) {
- logger.info("AAI GET Null Response to " + urlGet);
- return null;
- }
-
- logger.info(urlGet);
- logger.info(httpDetailsGet.a.toString());
- logger.info(httpDetailsGet.b);
-
- if (httpDetailsGet.a == 200) {
- try {
- responseGet = Serialization.gsonPretty.fromJson(httpDetailsGet.b, AAIGETVnfResponse.class);
- netLogger.info("[IN|{}|{}|]{}{}", "AAI", urlGet, System.lineSeparator(), httpDetailsGet.b);
- return responseGet;
- } catch (JsonSyntaxException e) {
- logger.error("postQuery threw: ", e);
- }
- }
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) { Thread.currentThread().interrupt(); }
+ return headers;
+ }
+
+ /**
+ * This method uses Google's GSON to create a response object from a JSON string
+ * @param httpDetails the HTTP response
+ * @param url the URL from which the response came
+ * @param classOfT The response class
+ * @return an instance of the response class
+ * @throws JsonSyntaxException on GSON errors instantiating the response
+ */
+ private static <T> T composeResponse(final Pair<Integer, String> httpDetails, final String url, final Class<T> classOfT) {
+ try {
+ T response = Serialization.gsonPretty.fromJson(httpDetails.b, classOfT);
+ netLogger.info("[IN|{}|{}|]{}{}", "AAI", url, LINE_SEPARATOR, httpDetails.b);
+ return response;
+ } catch (JsonSyntaxException e) {
+ logger.error("postQuery threw: ", e);
+ return null;
}
-
- return null;
}
}
@SerializedName("resource-version")
public String resourceVersion;
-
- public AAINQCloudRegion() {
- }
}
private static final long serialVersionUID = 4109625574744702319L;
@SerializedName("extra-property")
- public List<AAINQExtraProperty> extraProperty = new LinkedList<AAINQExtraProperty>();
-
- public AAINQExtraProperties() {
+ private List<AAINQExtraProperty> extraProperty = new LinkedList<>();
+
+ public List<AAINQExtraProperty> getExtraProperty() {
+ return extraProperty;
+ }
+
+ public void setExtraProperty(List<AAINQExtraProperty> extraProperty) {
+ this.extraProperty = extraProperty;
}
-
}
@SerializedName("model-version-id")
public String modelVersionId;
-
- public AAINQGenericVNF() {
- }
-
}
private static final long serialVersionUID = 8993824591338121185L;
@SerializedName("instance-filter")
- public List<Map<String, Map<String, String>>> instanceFilter = new LinkedList<>();
-
- public AAINQInstanceFilters() {
+ private List<Map<String, Map<String, String>>> instanceFilter = new LinkedList<>();
+
+ public List<Map<String, Map<String, String>>> getInstanceFilter() {
+ return instanceFilter;
}
+ public void setInstanceFilter(List<Map<String, Map<String, String>>> instanceFilter) {
+ this.instanceFilter = instanceFilter;
+ }
}
@SerializedName("inventory-response-items")
public AAINQInventoryResponseItems items;
-
- public AAINQInventoryResponseItem() {
- }
-
}
private static final long serialVersionUID = 7602807659381179004L;
@SerializedName("inventory-response-item")
- public List<AAINQInventoryResponseItem> inventoryResponseItems = new LinkedList<>();
-
- public AAINQInventoryResponseItems() {
+ private List<AAINQInventoryResponseItem> inventoryResponseItems = new LinkedList<>();
+
+ public List<AAINQInventoryResponseItem> getInventoryResponseItems() {
+ return inventoryResponseItems;
}
+ public void setInventoryResponseItems(List<AAINQInventoryResponseItem> inventoryResponseItems) {
+ this.inventoryResponseItems = inventoryResponseItems;
+ }
}
@SerializedName("named-query-uuid")
public UUID namedQueryUUID;
-
- public AAINQNamedQuery() {
- }
-
}
@SerializedName("named-query")
public AAINQNamedQuery namedQuery;
-
- public AAINQQueryParameters() {
- }
-
}
public AAINQQueryParameters queryParameters;
@SerializedName("instance-filters")
public AAINQInstanceFilters instanceFilters;
-
- public AAINQRequest() {
- }
-
}
private static final long serialVersionUID = 8411407444051746101L;
@SerializedName("inventory-response-item")
- p
ublic List<AAINQInventoryResponseItem> inventoryResponseItems = new LinkedList<>();
+ p
rivate List<AAINQInventoryResponseItem> inventoryResponseItems = new LinkedList<>();
@SerializedName("requestError")
- public AAINQRequestError requestError;
+ private AAINQRequestError requestError;
- public AAINQResponse() {
+ public List<AAINQInventoryResponseItem> getInventoryResponseItems() {
+ return inventoryResponseItems;
}
+ public void setInventoryResponseItems(List<AAINQInventoryResponseItem> inventoryResponseItems) {
+ this.inventoryResponseItems = inventoryResponseItems;
+ }
+
+ public AAINQRequestError getRequestError() {
+ return requestError;
+ }
+
+ public void setRequestError(AAINQRequestError requestError) {
+ this.requestError = requestError;
+ }
}
\ No newline at end of file
public class AAINQResponseWrapper {
- public UUID requestID;
- public AAINQResponse aainqresponse;
+ private UUID requestID;
+ private AAINQResponse aainqresponse;
public AAINQResponseWrapper() {
-
}
public AAINQResponseWrapper(UUID requestID, AAINQResponse aainqresponse){
this.requestID = requestID;
this.aainqresponse = aainqresponse;
}
+
+ public UUID getRequestID() {
+ return requestID;
+ }
+
+ public void setRequestID(UUID requestID) {
+ this.requestID = requestID;
+ }
+
+ public AAINQResponse getAainqresponse() {
+ return aainqresponse;
+ }
+
+ public void setAainqresponse(AAINQResponse aainqresponse) {
+ this.aainqresponse = aainqresponse;
+ }
}
@SerializedName("model-version-id")
public String modelVersionId;
-
- public AAINQServiceInstance() {
- }
-
}
@SerializedName("resource-version")
public String resourceVersion;
-
- public AAINQTenant() {
- }
}
@SerializedName("resource-version")
public String resourceVersion;
-
- public AAINQVServer() {
- }
-
}
@SerializedName("model-version-id")
public String modelVersionId;
-
- public AAINQVfModule() {
- }
}
*/
private static final long serialVersionUID = -3535108358668248501L;
- public String PNFName;
- public PNFType PNFType;
+ private String pnfName;
+ private PNFType pnfType;
public PNF() {
}
public PNF(PNF pnf) {
- this.PNFName = pnf.PNFName;
- this.PNFType = pnf.PNFType;
+ this.pnfName = pnf.pnfName;
+ this.pnfType = pnf.pnfType;
}
+ public String getPNFName() {
+ return pnfName;
+ }
+
+ public void setPNFName(String pNFName) {
+ pnfName = pNFName;
+ }
+
+ public PNFType getPNFType() {
+ return pnfType;
+ }
+
+ public void setPNFType(PNFType pNFType) {
+ pnfType = pNFType;
+ }
+
@Override
public String toString() {
- return "PNF [PNFName=" + PNFName + ", PNFType=" + PNFType + "]";
+ return "PNF [PNFName=" + pnfName + ", PNFType=" + pnfType + "]";
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
- result = prime * result + ((PNFName == null) ? 0 : PNFName.hashCode());
- result = prime * result + ((PNFType == null) ? 0 : PNFType.hashCode());
+ result = prime * result + ((pnfName == null) ? 0 : pnfName.hashCode());
+ result = prime * result + ((pnfType == null) ? 0 : pnfType.hashCode());
return result;
}
@Override
if (getClass() != obj.getClass())
return false;
PNF other = (PNF) obj;
- if (PNFName == null) {
- if (other.PNFName != null)
+ if (pnfName == null) {
+ if (other.pnfName != null)
return false;
- } else if (!PNFName.equals(other.PNFName))
+ } else if (!pnfName.equals(other.pnfName))
return false;
- if (PNFType != other.PNFType)
- return false;
- return true;
+ return pnfType == other.pnfType;
}
-
}
*/
private static final long serialVersionUID = -3694152433472165034L;
- public String PNFName;
- public String PNFInstanceName;
- public PNFType PNFType;
- public String PNFSerial;
+ private String pnfName;
+ private String pnfInstanceName;
+ private PNFType pnfType;
+ private String pnfSerial;
public PNFInstance() {
if (instance == null) {
return;
}
- this.PNFName = instance.PNFName;
- this.PNFInstanceName = instance.PNFInstanceName;
- this.PNFType = instance.PNFType;
- this.PNFSerial = instance.PNFSerial;
+ this.pnfName = instance.pnfName;
+ this.pnfInstanceName = instance.pnfInstanceName;
+ this.pnfType = instance.pnfType;
+ this.pnfSerial = instance.pnfSerial;
+ }
+
+ public String getPNFName() {
+ return pnfName;
+ }
+
+ public void setPNFName(String pNFName) {
+ pnfName = pNFName;
+ }
+
+ public String getPNFInstanceName() {
+ return pnfInstanceName;
+ }
+
+ public void setPNFInstanceName(String pNFInstanceName) {
+ pnfInstanceName = pNFInstanceName;
+ }
+
+ public PNFType getPNFType() {
+ return pnfType;
+ }
+
+ public void setPNFType(PNFType pNFType) {
+ pnfType = pNFType;
+ }
+
+ public String getPNFSerial() {
+ return pnfSerial;
+ }
+
+ public void setPNFSerial(String pNFSerial) {
+ pnfSerial = pNFSerial;
}
@Override
public String toString() {
- return "PNFInstance [PNFName=" + PNFName + ", PNFInstanceName=" + PNFInstanceName + ", PNFType=" + PNFType
- + ", PNFSerial=" + PNFSerial + "]";
+ return "PNFInstance [PNFName=" + pnfName + ", PNFInstanceName=" + pnfInstanceName + ", PNFType=" + pnfType
+ + ", PNFSerial=" + pnfSerial + "]";
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
- result = prime * result + ((PNFInstanceName == null) ? 0 : PNFInstanceName.hashCode());
- result = prime * result + ((PNFName == null) ? 0 : PNFName.hashCode());
- result = prime * result + ((PNFSerial == null) ? 0 : PNFSerial.hashCode());
- result = prime * result + ((PNFType == null) ? 0 : PNFType.hashCode());
+ result = prime * result + ((pnfInstanceName == null) ? 0 : pnfInstanceName.hashCode());
+ result = prime * result + ((pnfName == null) ? 0 : pnfName.hashCode());
+ result = prime * result + ((pnfSerial == null) ? 0 : pnfSerial.hashCode());
+ result = prime * result + ((pnfType == null) ? 0 : pnfType.hashCode());
return result;
}
if (getClass() != obj.getClass())
return false;
PNFInstance other = (PNFInstance) obj;
- if (PNFInstanceName == null) {
- if (other.PNFInstanceName != null)
+ if (pnfInstanceName == null) {
+ if (other.pnfInstanceName != null)
return false;
- } else if (!PNFInstanceName.equals(other.PNFInstanceName))
+ } else if (!pnfInstanceName.equals(other.pnfInstanceName))
return false;
- if (PNFName == null) {
- if (other.PNFName != null)
+ if (pnfName == null) {
+ if (other.pnfName != null)
return false;
- } else if (!PNFName.equals(other.PNFName))
+ } else if (!pnfName.equals(other.pnfName))
return false;
- if (PNFSerial == null) {
- if (other.PNFSerial != null)
+ if (pnfSerial == null) {
+ if (other.pnfSerial != null)
return false;
- } else if (!PNFSerial.equals(other.PNFSerial))
+ } else if (!pnfSerial.equals(other.pnfSerial))
return false;
- if (PNFType != other.PNFType)
- return false;
- return true;
+ return pnfType == other.pnfType;
}
-
}
*/
private static final long serialVersionUID = 2088088164920423658L;
@SerializedName("related-to-property")
- public List<RelatedToPropertyItem> relatedTo = new LinkedList<RelatedToPropertyItem>();
+ private List<RelatedToPropertyItem> relatedTo = new LinkedList<>();
- public RelatedToProperty() {
+ public List<RelatedToPropertyItem> getRelatedTo() {
+ return relatedTo;
+ }
+ public void setRelatedTo(List<RelatedToPropertyItem> relatedTo) {
+ this.relatedTo = relatedTo;
}
}
public String propertyKey;
@SerializedName("property-value")
public String propertyValue;
-
- public RelatedToPropertyItem() {
- }
-
}
@SerializedName("related-to-property")
public RelatedToProperty relatedToProperty = new RelatedToProperty();
-
- public Relationship() {
- }
}
*/
private static final long serialVersionUID = 6809180843309562121L;
@SerializedName("relationship-data")
- public List<RelationshipDataItem> relationshipData = new LinkedList<>();
-
- public RelationshipData() {
+ private List<RelationshipDataItem> relationshipDataList = new LinkedList<>();
+
+ public List<RelationshipDataItem> getRelationshipData() {
+ return relationshipDataList;
+ }
+
+ public void setRelationshipData(List<RelationshipDataItem> relationshipData) {
+ this.relationshipDataList = relationshipData;
}
}
public String relationshipKey;
@SerializedName("relationship-value")
public String relationshipValue;
-
- public RelationshipDataItem() {
- }
-
}
private static final long serialVersionUID = 1543404460741069628L;
@SerializedName("related-to-property")
- public List<RelatedToPropertyItem> relatedToProperty = new LinkedList<RelatedToPropertyItem>();
-
- public RelationshipItem() {
+ private List<RelatedToPropertyItem> relatedToProperty = new LinkedList<>();
+
+ public List<RelatedToPropertyItem> getRelatedToProperty() {
+ return relatedToProperty;
}
+ public void setRelatedToProperty(List<RelatedToPropertyItem> relatedToProperty) {
+ this.relatedToProperty = relatedToProperty;
+ }
}
*/
private static final long serialVersionUID = 6115655704973981989L;
@SerializedName("relationship-list")
- public List<Relationship> relationshipList = new LinkedList<>();
+ private List<Relationship> relationships = new LinkedList<>();
- public RelationshipList() {
+ public List<Relationship> getRelationshipList() {
+ return relationships;
}
+ public void setRelationshipList(List<Relationship> relationshipList) {
+ this.relationships = relationshipList;
+ }
+
+
}
relationshipDataItem.relationshipKey = "customer.global-customer-id";
relationshipDataItem.relationshipValue = "MSO_1610_ST";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-subscription.service-type";
relationshipDataItem.relationshipValue = "MSO-dev-service-type";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-instance.service-instance-id";
relationshipDataItem.relationshipValue = "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
RelatedToProperty relatedToProperty = new RelatedToProperty();
RelatedToPropertyItem item = new RelatedToPropertyItem();
item.propertyKey = "service-instance.service-instance-name";
item.propertyValue = "lll_svc_010317";
- relatedToProperty.relatedTo.add(item);
+ relatedToProperty.getRelatedTo().add(item);
relationship.relatedTo = "service-instance";
relationship.relatedLink = "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription/MSO-dev-service-type/service-instances/service-instance/e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
relationship.relationshipData = relationshipData;
relationship.relatedToProperty = relatedToProperty;
- relationshipList.relationshipList.add(relationship);
+ relationshipList.getRelationshipList().add(relationship);
response.relationshipList = relationshipList;
logger.info(Serialization.gsonPretty.toJson(response));
relationshipDataItem.relationshipKey = "customer.global-customer-id";
relationshipDataItem.relationshipValue = "MSO_1610_ST";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-subscription.service-type";
relationshipDataItem.relationshipValue = "MSO-dev-service-type";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationshipDataItem.relationshipKey = "service-instance.service-instance-id";
relationshipDataItem.relationshipValue = "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
RelatedToProperty relatedToProperty = new RelatedToProperty();
RelatedToPropertyItem item = new RelatedToPropertyItem();
item.propertyKey = "service-instance.service-instance-name";
item.propertyValue = "lll_svc_010317";
- relatedToProperty.relatedTo.add(item);
+ relatedToProperty.getRelatedTo().add(item);
relationship.relatedTo = "service-instance";
relationship.relatedLink = "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription/MSO-dev-service-type/service-instances/service-instance/e1e9c97c-02c0-4919-9b4c-eb5d5ef68970";
relationship.relationshipData = relationshipData;
relationship.relatedToProperty = relatedToProperty;
- relationshipList.relationshipList.add(relationship);
+ relationshipList.getRelationshipList().add(relationship);
response.relationshipList = relationshipList;
logger.info(Serialization.gsonPretty.toJson(response));
@Test
public void test() {
AAINQExtraProperties aaiNQExtraProperties = new AAINQExtraProperties();
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "service-instance"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "service-instance"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
assertNotNull(aaiNQExtraProperties);
}
aaiNQCloudRegion.resourceVersion = "1485365988";
aaiNQInventoryResponseItem.cloudRegion = aaiNQCloudRegion;
AAINQExtraProperties aaiNQExtraProperties = new AAINQExtraProperties();
- aaiNQExtraProperties.extraProperty = new LinkedList<>();
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
- aaiNQExtraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
+ aaiNQExtraProperties.setExtraProperty(new LinkedList<>());
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
+ aaiNQExtraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
aaiNQInventoryResponseItem.extraProperties = aaiNQExtraProperties;
AAINQGenericVNF aaiNQGenericVNF = new AAINQGenericVNF();
aaiNQGenericVNF.vnfID = "dhv-test-gvnf";
serviceItem.serviceInstance.serviceInstanceLocationId = "dhv-test-service-instance-location-id1";
serviceItem.serviceInstance.resourceVersion = "1485366092";
serviceItem.extraProperties = new AAINQExtraProperties();
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "service-instance"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "service-instance"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
AAINQInventoryResponseItem vfModuleItem = new AAINQInventoryResponseItem();
vfModuleItem.modelName = "vf-module";
vfModuleItem.vfModule.widgetModelVersion = "example-widget-model-version-val-83317";
vfModuleItem.vfModule.contrailServiceInstanceFqdn = "example-contrail-service-instance-fqdn-val-86796";
vfModuleItem.extraProperties = new AAINQExtraProperties();
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "vf-module"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "vf-module"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
- aaiNQInventoryResponseItems.inventoryResponseItems.add(serviceItem);
- aaiNQInventoryResponseItems.inventoryResponseItems.add(vfModuleItem);
+ aaiNQInventoryResponseItems.getInventoryResponseItems().add(serviceItem);
+ aaiNQInventoryResponseItems.getInventoryResponseItems().add(vfModuleItem);
aaiNQInventoryResponseItem.items = aaiNQInventoryResponseItems;
aaiNQInventoryResponseItem.modelName = "model-name";
AAINQServiceInstance serviceInstance = new AAINQServiceInstance();
serviceItem.serviceInstance.serviceInstanceLocationId = "dhv-test-service-instance-location-id1";
serviceItem.serviceInstance.resourceVersion = "1485366092";
serviceItem.extraProperties = new AAINQExtraProperties();
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "service-instance"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "service-instance"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
AAINQInventoryResponseItem vfModuleItem = new AAINQInventoryResponseItem();
vfModuleItem.modelName = "vf-module";
vfModuleItem.vfModule.widgetModelVersion = "example-widget-model-version-val-83317";
vfModuleItem.vfModule.contrailServiceInstanceFqdn = "example-contrail-service-instance-fqdn-val-86796";
vfModuleItem.extraProperties = new AAINQExtraProperties();
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "vf-module"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "vf-module"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
AAINQInventoryResponseItem genericVNFItem = new AAINQInventoryResponseItem();
genericVNFItem.modelName = "generic-vnf";
genericVNFItem.genericVNF.personaModelId = "acc6edd8-a8d4-4b93-afaa-0994068be14c";
genericVNFItem.genericVNF.personaModelVersion = "1.0";
genericVNFItem.extraProperties = new AAINQExtraProperties();
- genericVNFItem.extraProperties.extraProperty = new LinkedList<>();
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
+ genericVNFItem.extraProperties.setExtraProperty(new LinkedList<>());
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
genericVNFItem.items = new AAINQInventoryResponseItems();
- genericVNFItem.items.inventoryResponseItems = new LinkedList<>();
- genericVNFItem.items.inventoryResponseItems.add(serviceItem);
- genericVNFItem.items.inventoryResponseItems.add(vfModuleItem);
+ genericVNFItem.items.setInventoryResponseItems(new LinkedList<>());
+ genericVNFItem.items.getInventoryResponseItems().add(serviceItem);
+ genericVNFItem.items.getInventoryResponseItems().add(vfModuleItem);
AAINQInventoryResponseItem cloudItem = new AAINQInventoryResponseItem();
cloudItem.cloudRegion = new AAINQCloudRegion();
tenantItem.tenant.tenantName = "dhv-test-tenant-name";
tenantItem.tenant.resourceVersion = "1485366334";
tenantItem.items = new AAINQInventoryResponseItems();
- tenantItem.items.inventoryResponseItems = new LinkedList<>();
- tenantItem.items.inventoryResponseItems.add(cloudItem);
+ tenantItem.items.setInventoryResponseItems(new LinkedList<>());
+ tenantItem.items.getInventoryResponseItems().add(cloudItem);
AAINQInventoryResponseItem vserverItem = new AAINQInventoryResponseItem();
vserverItem.vserver = new AAINQVServer();
vserverItem.vserver.vserverId = "dhv-test-vserver";
vserverItem.vserver.isClosedLoopDisabled = false;
vserverItem.vserver.resourceVersion = "1485366417";
vserverItem.items = new AAINQInventoryResponseItems();
- vserverItem.items.inventoryResponseItems = new LinkedList<>();
- vserverItem.items.inventoryResponseItems.add(genericVNFItem);
- vserverItem.items.inventoryResponseItems.add(tenantItem);
- aaiNQInventoryResponseItems.inventoryResponseItems.add(vserverItem);
+ vserverItem.items.setInventoryResponseItems(new LinkedList<>());
+ vserverItem.items.getInventoryResponseItems().add(genericVNFItem);
+ vserverItem.items.getInventoryResponseItems().add(tenantItem);
+ aaiNQInventoryResponseItems.getInventoryResponseItems().add(vserverItem);
assertNotNull(aaiNQInventoryResponseItems);
logger.info(Serialization.gsonPretty.toJson(aaiNQInventoryResponseItems));
}
serviceItem.serviceInstance.serviceInstanceLocationId = "dhv-test-service-instance-location-id1";
serviceItem.serviceInstance.resourceVersion = "1485366092";
serviceItem.extraProperties = new AAINQExtraProperties();
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "service-instance"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "service-instance"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
AAINQInventoryResponseItem vfModuleItem = new AAINQInventoryResponseItem();
vfModuleItem.modelName = "vf-module";
vfModuleItem.vfModule.widgetModelVersion = "example-widget-model-version-val-83317";
vfModuleItem.vfModule.contrailServiceInstanceFqdn = "example-contrail-service-instance-fqdn-val-86796";
vfModuleItem.extraProperties = new AAINQExtraProperties();
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "vf-module"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "vf-module"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
AAINQInventoryResponseItem genericVNFItem = new AAINQInventoryResponseItem();
genericVNFItem.modelName = "generic-vnf";
genericVNFItem.genericVNF.personaModelId = "acc6edd8-a8d4-4b93-afaa-0994068be14c";
genericVNFItem.genericVNF.personaModelVersion = "1.0";
genericVNFItem.extraProperties = new AAINQExtraProperties();
- genericVNFItem.extraProperties.extraProperty = new LinkedList<>();
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
+ genericVNFItem.extraProperties.setExtraProperty(new LinkedList<>());
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
genericVNFItem.items = new AAINQInventoryResponseItems();
- genericVNFItem.items.inventoryResponseItems = new LinkedList<>();
- genericVNFItem.items.inventoryResponseItems.add(serviceItem);
- genericVNFItem.items.inventoryResponseItems.add(vfModuleItem);
+ genericVNFItem.items.setInventoryResponseItems(new LinkedList<>());
+ genericVNFItem.items.getInventoryResponseItems().add(serviceItem);
+ genericVNFItem.items.getInventoryResponseItems().add(vfModuleItem);
AAINQInventoryResponseItem cloudItem = new AAINQInventoryResponseItem();
cloudItem.cloudRegion = new AAINQCloudRegion();
tenantItem.tenant.tenantName = "dhv-test-tenant-name";
tenantItem.tenant.resourceVersion = "1485366334";
tenantItem.items = new AAINQInventoryResponseItems();
- tenantItem.items.inventoryResponseItems = new LinkedList<>();
- tenantItem.items.inventoryResponseItems.add(cloudItem);
+ tenantItem.items.setInventoryResponseItems(new LinkedList<>());
+ tenantItem.items.getInventoryResponseItems().add(cloudItem);
AAINQInventoryResponseItem vserverItem = new AAINQInventoryResponseItem();
vserverItem.vserver = new AAINQVServer();
vserverItem.vserver.isClosedLoopDisabled = false;
vserverItem.vserver.resourceVersion = "1485366417";
vserverItem.items = new AAINQInventoryResponseItems();
- vserverItem.items.inventoryResponseItems = new LinkedList<>();
- vserverItem.items.inventoryResponseItems.add(genericVNFItem);
- vserverItem.items.inventoryResponseItems.add(tenantItem);
+ vserverItem.items.setInventoryResponseItems(new LinkedList<>());
+ vserverItem.items.getInventoryResponseItems().add(genericVNFItem);
+ vserverItem.items.getInventoryResponseItems().add(tenantItem);
AAINQResponse aaiResponse = new AAINQResponse();
- aaiResponse.inventoryResponseItems.add(vserverItem);
+ aaiResponse.getInventoryResponseItems().add(vserverItem);
logger.info(Serialization.gsonPretty.toJson(aaiResponse));
}
}
serviceItem.serviceInstance.serviceInstanceLocationId = "dhv-test-service-instance-location-id1";
serviceItem.serviceInstance.resourceVersion = "1485366092";
serviceItem.extraProperties = new AAINQExtraProperties();
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "service-instance"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
- serviceItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "service-instance"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "82194af1-3c2c-485a-8f44-420e22a9eaa4"));
+ serviceItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "46b92144-923a-4d20-b85a-3cbd847668a9"));
AAINQInventoryResponseItem vfModuleItem = new AAINQInventoryResponseItem();
vfModuleItem.modelName = "vf-module";
vfModuleItem.vfModule.widgetModelVersion = "example-widget-model-version-val-83317";
vfModuleItem.vfModule.contrailServiceInstanceFqdn = "example-contrail-service-instance-fqdn-val-86796";
vfModuleItem.extraProperties = new AAINQExtraProperties();
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "vf-module"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
- vfModuleItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "vf-module"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "ef86f9c5-2165-44f3-8fc3-96018b609ea5"));
+ vfModuleItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "c00563ae-812b-4e62-8330-7c4d0f47088a"));
AAINQInventoryResponseItem genericVNFItem = new AAINQInventoryResponseItem();
genericVNFItem.modelName = "generic-vnf";
genericVNFItem.genericVNF.personaModelId = "acc6edd8-a8d4-4b93-afaa-0994068be14c";
genericVNFItem.genericVNF.personaModelVersion = "1.0";
genericVNFItem.extraProperties = new AAINQExtraProperties();
- genericVNFItem.extraProperties.extraProperty = new LinkedList<>();
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-type", "widget"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-version", "1.0"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
- genericVNFItem.extraProperties.extraProperty.add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
+ genericVNFItem.extraProperties.setExtraProperty(new LinkedList<>());
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name", "generic-vnf"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-type", "widget"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-version", "1.0"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-id", "acc6edd8-a8d4-4b93-afaa-0994068be14c"));
+ genericVNFItem.extraProperties.getExtraProperty().add(new AAINQExtraProperty("model.model-name-version-id", "93a6166f-b3d5-4f06-b4ba-aed48d009ad9"));
genericVNFItem.items = new AAINQInventoryResponseItems();
- genericVNFItem.items.inventoryResponseItems = new LinkedList<>();
- genericVNFItem.items.inventoryResponseItems.add(serviceItem);
- genericVNFItem.items.inventoryResponseItems.add(vfModuleItem);
+ genericVNFItem.items.setInventoryResponseItems(new LinkedList<>());
+ genericVNFItem.items.getInventoryResponseItems().add(serviceItem);
+ genericVNFItem.items.getInventoryResponseItems().add(vfModuleItem);
AAINQInventoryResponseItem cloudItem = new AAINQInventoryResponseItem();
cloudItem.cloudRegion = new AAINQCloudRegion();
tenantItem.tenant.tenantName = "dhv-test-tenant-name";
tenantItem.tenant.resourceVersion = "1485366334";
tenantItem.items = new AAINQInventoryResponseItems();
- tenantItem.items.inventoryResponseItems = new LinkedList<>();
- tenantItem.items.inventoryResponseItems.add(cloudItem);
+ tenantItem.items.setInventoryResponseItems(new LinkedList<>());
+ tenantItem.items.getInventoryResponseItems().add(cloudItem);
AAINQInventoryResponseItem vserverItem = new AAINQInventoryResponseItem();
vserverItem.vserver = new AAINQVServer();
vserverItem.vserver.isClosedLoopDisabled = false;
vserverItem.vserver.resourceVersion = "1485366417";
vserverItem.items = new AAINQInventoryResponseItems();
- vserverItem.items.inventoryResponseItems = new LinkedList<>();
- vserverItem.items.inventoryResponseItems.add(genericVNFItem);
- vserverItem.items.inventoryResponseItems.add(tenantItem);
+ vserverItem.items.setInventoryResponseItems(new LinkedList<>());
+ vserverItem.items.getInventoryResponseItems().add(genericVNFItem);
+ vserverItem.items.getInventoryResponseItems().add(tenantItem);
AAINQResponse aaiResponse = new AAINQResponse();
- aaiResponse.inventoryResponseItems.add(vserverItem);
+ aaiResponse.getInventoryResponseItems().add(vserverItem);
AAINQResponseWrapper aaiNQResponseWarapper = new AAINQResponseWrapper();
- aaiNQResponseWarapper.aainqresponse = aaiResponse;
- aaiNQResponseWarapper.requestID = UUID.randomUUID();
+ aaiNQResponseWarapper.setAainqresponse(aaiResponse);
+ aaiNQResponseWarapper.setRequestID(UUID.randomUUID());
assertNotNull(aaiNQResponseWarapper);
logger.info(Serialization.gsonPretty.toJson(aaiNQResponseWarapper));
}
@Test
public void test() {
PNFInstance pnfInstance = new PNFInstance();
- pnfInstance.PNFInstanceName = "pnf-instance-name-test";
- pnfInstance.PNFName = "pnf-name-test";
- pnfInstance.PNFSerial = "pnf-serial-test";
+ pnfInstance.setPNFInstanceName("pnf-instance-name-test");
+ pnfInstance.setPNFName("pnf-name-test");
+ pnfInstance.setPNFSerial("pnf-serial-test");
assertNotNull(pnfInstance);
logger.info(Serialization.gsonPretty.toJson(pnfInstance));
}
@Test
public void test() {
PNF pnf = new PNF();
- pnf.PNFName = "pnf-name-test";
- pnf.PNFType = PNFType.ENODEB;
+ pnf.setPNFName("pnf-name-test");
+ pnf.setPNFType(PNFType.ENODEB);
assertNotNull(pnf);
logger.info(Serialization.gsonPretty.toJson(pnf));
}
RelatedToPropertyItem relatedToPropertyItem = new RelatedToPropertyItem();
relatedToPropertyItem.propertyKey = "model.model-name";
relatedToPropertyItem.propertyValue = "service-instance";
- relatedToProperty.relatedTo.add(relatedToPropertyItem);
+ relatedToProperty.getRelatedTo().add(relatedToPropertyItem);
RelatedToPropertyItem relatedToPropertyItem2 = new RelatedToPropertyItem();
relatedToPropertyItem2.propertyKey = "model.model-name2";
relatedToPropertyItem2.propertyValue = "service-instance2";
- relatedToProperty.relatedTo.add(relatedToPropertyItem2);
+ relatedToProperty.getRelatedTo().add(relatedToPropertyItem2);
assertNotNull(relatedToProperty);
logger.info(Serialization.gsonPretty.toJson(relatedToProperty));
}
relationshipDataItem.relationshipKey = "relationship-key";
relationshipDataItem.relationshipValue = "relationship-value";
assertNotNull(relationshipDataItem);
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
RelationshipDataItem relationshipDataItem2 = new RelationshipDataItem();
relationshipDataItem2.relationshipKey = "relationship-key2";
relationshipDataItem2.relationshipValue = "relationship-value2";
- relationshipData.relationshipData.add(relationshipDataItem2);
+ relationshipData.getRelationshipData().add(relationshipDataItem2);
assertNotNull(relationshipData);
logger.info(Serialization.gsonPretty.toJson(relationshipData));
}
RelatedToPropertyItem relatedToPropertyItem = new RelatedToPropertyItem();
relatedToPropertyItem.propertyKey = "model.model-name";
relatedToPropertyItem.propertyValue = "service-instance";
- relationshipItem.relatedToProperty.add(relatedToPropertyItem);
+ relationshipItem.getRelatedToProperty().add(relatedToPropertyItem);
assertNotNull(relationshipItem);
logger.info(Serialization.gsonPretty.toJson(relationshipItem));
}
RelatedToPropertyItem relatedToPropertyItem = new RelatedToPropertyItem();
relatedToPropertyItem.propertyKey = "model.model-name";
relatedToPropertyItem.propertyValue = "service-instance";
- relatedToProperty.relatedTo.add(relatedToPropertyItem);
+ relatedToProperty.getRelatedTo().add(relatedToPropertyItem);
RelatedToPropertyItem relatedToPropertyItem2 = new RelatedToPropertyItem();
relatedToPropertyItem2.propertyKey = "model.model-name2";
relatedToPropertyItem2.propertyValue = "service-instance2";
- relatedToProperty.relatedTo.add(relatedToPropertyItem2);
+ relatedToProperty.getRelatedTo().add(relatedToPropertyItem2);
relationship.relatedToProperty = relatedToProperty;
RelationshipDataItem relationshipDataItem = new RelationshipDataItem();
relationshipDataItem.relationshipKey = "relationship-key";
relationshipDataItem.relationshipValue = "relationship-value";
RelationshipData relationshipData = new RelationshipData();
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationship.relationshipData = relationshipData;
- relationshipList.relationshipList.add(relationship);
+ relationshipList.getRelationshipList().add(relationship);
assertNotNull(relationshipList);
logger.info(Serialization.gsonPretty.toJson(relationshipList));
RelatedToPropertyItem relatedToPropertyItem = new RelatedToPropertyItem();
relatedToPropertyItem.propertyKey = "model.model-name";
relatedToPropertyItem.propertyValue = "service-instance";
- relatedToProperty.relatedTo.add(relatedToPropertyItem);
+ relatedToProperty.getRelatedTo().add(relatedToPropertyItem);
RelatedToPropertyItem relatedToPropertyItem2 = new RelatedToPropertyItem();
relatedToPropertyItem2.propertyKey = "model.model-name2";
relatedToPropertyItem2.propertyValue = "service-instance2";
- relatedToProperty.relatedTo.add(relatedToPropertyItem2);
+ relatedToProperty.getRelatedTo().add(relatedToPropertyItem2);
relationship.relatedToProperty = relatedToProperty;
RelationshipDataItem relationshipDataItem = new RelationshipDataItem();
relationshipDataItem.relationshipKey = "relationship-key";
relationshipDataItem.relationshipValue = "relationship-value";
RelationshipData relationshipData = new RelationshipData();
- relationshipData.relationshipData.add(relationshipDataItem);
+ relationshipData.getRelationshipData().add(relationshipDataItem);
relationship.relationshipData = relationshipData;
assertNotNull(relationship);
logger.info(Serialization.gsonPretty.toJson(relationship));
import org.yaml.snakeyaml.Yaml;
public class ControlLoopPolicyBuilderImpl implements ControlLoopPolicyBuilder {
- private static Logger logger = LoggerFactory.getLogger(ControlLoopPolicyBuilderImpl.class.getName());
- private ControlLoopPolicy policy;
-
- public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout) throws BuilderException {
- policy = new ControlLoopPolicy();
- ControlLoop controlLoop = new ControlLoop();
- controlLoop.setControlLoopName(controlLoopName);
- controlLoop.setTimeout(timeout);
- policy.setControlLoop(controlLoop);
- }
-
- public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout, Resource resource, Service... services) throws BuilderException {
- this(controlLoopName, timeout);
- this.addResource(resource);
- this.addService(services);
- }
-
- public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout, PNF pnf) throws BuilderException {
- this(controlLoopName, timeout);
- this.setPNF(pnf);
- }
-
- public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout, Service service, Resource[] resources) throws BuilderException {
- this(controlLoopName, timeout);
- this.addService(service);
- this.addResource(resources);
- }
-
- @Override
- public ControlLoopPolicyBuilder removePNF() throws BuilderException {
- policy.getControlLoop().setPnf(null);
- return this;
- }
-
- @Override
- public ControlLoopPolicyBuilder addService(Service... services) throws BuilderException {
- if (services == null) {
- throw new BuilderException("Service must not be null");
- }
- for (Service service : services) {
- if (service.getServiceUUID() == null) {
- if (service.getServiceName() == null || service.getServiceName().length() < 1) {
- throw new BuilderException("Invalid service - need either a serviceUUID or serviceName");
- }
- if(policy.getControlLoop().getServices()==null){
- policy.getControlLoop().setServices(new LinkedList<>());
- }
- policy.getControlLoop().getServices().add(service);
- }
- }
- return this;
- }
-
- @Override
- public ControlLoopPolicyBuilder removeService(Service... services) throws BuilderException {
- if (services == null) {
- throw new BuilderException("Service must not be null");
- }
- if (policy.getControlLoop().getServices() == null) {
- throw new BuilderException("No existing services to remove");
- }
- for (Service service : services) {
- if (service.getServiceUUID() == null) {
- if (service.getServiceName() == null || service.getServiceName().length() < 1) {
- throw new BuilderException("Invalid service - need either a serviceUUID or serviceName");
- }
- }
- boolean removed = policy.getControlLoop().getServices().remove(service);
- if (!removed) {
- throw new BuilderException("Unknown service " + service.getServiceName());
- }
- }
- return this;
- }
-
- @Override
- public ControlLoopPolicyBuilder removeAllServices() throws BuilderException {
- policy.getControlLoop().getServices().clear();
- return this;
- }
-
-
- @Override
- public ControlLoopPolicyBuilder addResource(Resource... resources) throws BuilderException {
- if (resources == null) {
- throw new BuilderException("resources must not be null");
- }
- for (Resource resource : resources) {
- if (resource.getResourceUUID() == null) {
- if (resource.getResourceName() == null || resource.getResourceName().length() <= 0) {
- throw new BuilderException("Invalid resource - need either resourceUUID or resourceName");
- }
- }
- if(policy.getControlLoop().getResources()==null){
- policy.getControlLoop().setResources(new LinkedList<>());
- }
- policy.getControlLoop().getResources().add(resource);
- }
- return this;
- }
-
- @Override
- public ControlLoopPolicyBuilder setPNF(PNF pnf) throws BuilderException {
- if (pnf == null) {
- throw new BuilderException("PNF must not be null");
- }
- if (pnf.PNFName == null) {
- if (pnf.PNFType == null) {
- throw new BuilderException("Invalid PNF - need either pnfName or pnfType");
- }
- }
- policy.getControlLoop().setPnf(pnf);
- return this;
- }
-
- @Override
- public ControlLoopPolicyBuilder setAbatement(Boolean abatement) throws BuilderException{
- if (abatement == null) {
- throw new BuilderException("abatement must not be null");
- }
- policy.getControlLoop().setAbatement(abatement);
- return this;
- }
-
- @Override
- public ControlLoopPolicyBuilder setTimeout(Integer timeout) {
- policy.getControlLoop().setTimeout(timeout);
- return this;
- }
-
- @Override
- public Policy setTriggerPolicy(String name, String description, String actor, Target target, String recipe,
- Map<String, String> payload, Integer retries, Integer timeout) throws BuilderException {
-
- Policy trigger = new Policy(UUID.randomUUID().toString(), name, description, actor, payload, target, recipe, retries, timeout);
-
- policy.getControlLoop().setTrigger_policy(trigger.getId());
-
- this.addNewPolicy(trigger);
- //
- // Return a copy of the policy
- //
- return new Policy(trigger);
- }
-
- @Override
- public Policy setPolicyForPolicyResult(String name, String description, String actor,
- Target target, String recipe, Map<String, String> payload, Integer retries, Integer timeout, String policyID, PolicyResult... results) throws BuilderException {
- //
- // Find the existing policy
- //
- Policy existingPolicy = this.findPolicy(policyID);
- if (existingPolicy == null) {
- throw new BuilderException("Unknown policy " + policyID);
- }
- //
- // Create the new Policy
- //
- Policy newPolicy = new Policy(UUID.randomUUID().toString(), name, description, actor, payload, target, recipe, retries, timeout);
- //
- // Connect the results
- //
- for (PolicyResult result : results) {
- switch (result) {
- case FAILURE:
- existingPolicy.setFailure(newPolicy.getId());
- break;
- case FAILURE_EXCEPTION:
- existingPolicy.setFailure_exception(newPolicy.getId());
- break;
- case FAILURE_RETRIES:
- existingPolicy.setFailure_retries(newPolicy.getId());
- break;
- case FAILURE_TIMEOUT:
- existingPolicy.setFailure_timeout(newPolicy.getId());
- break;
- case FAILURE_GUARD:
- existingPolicy.setFailure_guard(newPolicy.getId());
- break;
- case SUCCESS:
- existingPolicy.setSuccess(newPolicy.getId());
- break;
- default:
- throw new BuilderException("Invalid PolicyResult " + result);
- }
- }
- //
- // Add it to our list
- //
- this.policy.getPolicies().add(newPolicy);
- //
- // Return a policy to them
- //
- return new Policy(newPolicy);
- }
-
- private class BuilderCompilerCallback implements ControlLoopCompilerCallback {
-
- private ResultsImpl results = new ResultsImpl();
-
- @Override
- public boolean onWarning(String message) {
- results.addMessage(new MessageImpl(message, MessageLevel.WARNING));
- return false;
- }
-
- @Override
- public boolean onError(String message) {
- results.addMessage(new MessageImpl(message, MessageLevel.ERROR));
- return false;
- }
- }
-
- @Override
- public Results buildSpecification() {
- //
- // Dump the specification
- //
- DumperOptions options = new DumperOptions();
- options.setDefaultFlowStyle(FlowStyle.BLOCK);
- options.setPrettyFlow(true);
- Yaml yaml = new Yaml(options);
- String dumpedYaml = yaml.dump(policy);
- //
- // This is our callback class for our compiler
- //
- BuilderCompilerCallback callback = new BuilderCompilerCallback();
- //
- // Compile it
- //
- try {
- ControlLoopCompiler.compile(policy, callback);
- } catch (CompilerException e) {
- logger.error(e.getMessage() + e);
- callback.results.addMessage(new MessageImpl(e.getMessage(), MessageLevel.EXCEPTION));
- }
- //
- // Save the spec
- //
- callback.results.setSpecification(dumpedYaml);
- return callback.results;
- }
-
- private void addNewPolicy(Policy policy) {
- if (this.policy.getPolicies() == null) {
- this.policy.setPolicies(new LinkedList<>());
- }
- this.policy.getPolicies().add(policy);
- }
-
- private Policy findPolicy(String id) {
- for (Policy policy : this.policy.getPolicies()) {
- if (policy.getId().equals(id)) {
- return policy;
- }
- }
- return null;
- }
-
- @Override
- public ControlLoopPolicyBuilder removeResource(Resource... resources) throws BuilderException {
- if (resources == null) {
- throw new BuilderException("Resource must not be null");
- }
- if (policy.getControlLoop().getResources() == null) {
- throw new BuilderException("No existing resources to remove");
- }
- for (Resource resource : resources) {
- if (resource.getResourceUUID() == null) {
- if (resource.getResourceName() == null || resource.getResourceName().length() < 1) {
- throw new BuilderException("Invalid resource - need either a resourceUUID or resourceName");
- }
- }
- boolean removed = policy.getControlLoop().getResources().remove(resource);
- if (!removed) {
- throw new BuilderException("Unknown resource " + resource.getResourceName());
- }
- }
- return this;
- }
-
- @Override
- public ControlLoopPolicyBuilder removeAllResources() throws BuilderException {
- policy.getControlLoop().getResources().clear();
- return this;
- }
-
- @Override
- public Integer calculateTimeout() {
- int sum = 0;
- for (Policy policy : this.policy.getPolicies()) {
- sum += policy.getTimeout().intValue();
- }
- return new Integer(sum);
- }
-
- @Override
- public ControlLoop setTriggerPolicy(String id) throws BuilderException {
- if (id == null) {
- throw new BuilderException("Id must not be null");
- }
- Policy trigger = this.findPolicy(id);
- if (trigger == null) {
- throw new BuilderException("Unknown policy " + id);
- }
- else {
- this.policy.getControlLoop().setTrigger_policy(id);
- }
- return new ControlLoop(this.policy.getControlLoop());
- }
-
- @Override
- public boolean isOpenLoop() {
- if (this.policy.getControlLoop().getTrigger_policy().equals(FinalResult.FINAL_OPENLOOP.toString())) {
- return true;
- }
- else {
- return false;
- }
- }
-
- @Override
- public Policy getTriggerPolicy() throws BuilderException {
- if (this.policy.getControlLoop().getTrigger_policy().equals(FinalResult.FINAL_OPENLOOP.toString())) {
- return null;
- }
- else {
- Policy trigger = new Policy(this.findPolicy(this.policy.getControlLoop().getTrigger_policy()));
- return trigger;
- }
- }
-
- @Override
- public ControlLoop getControlLoop() {
- ControlLoop loop = new ControlLoop(this.policy.getControlLoop());
- return loop;
- }
-
- @Override
- public Policy setPolicyForPolicyResult(String policyResultID, String policyID, PolicyResult... results)
- throws BuilderException {
- //
- // Find the existing policy
- //
- Policy existingPolicy = this.findPolicy(policyID);
- if (existingPolicy == null) {
- throw new BuilderException(policyID + " does not exist");
- }
- if (this.findPolicy(policyResultID) == null) {
- throw new BuilderException("Operational policy " + policyResultID + " does not exist");
- }
- //
- // Connect the results
- //
- for (PolicyResult result : results) {
- switch (result) {
- case FAILURE:
- existingPolicy.setFailure(policyResultID);
- break;
- case FAILURE_EXCEPTION:
- existingPolicy.setFailure_exception(policyResultID);
- break;
- case FAILURE_RETRIES:
- existingPolicy.setFailure_retries(policyResultID);
- break;
- case FAILURE_TIMEOUT:
- existingPolicy.setFailure_timeout(policyResultID);
- break;
- case FAILURE_GUARD:
- existingPolicy.setFailure_guard(policyResultID);
- break;
- case SUCCESS:
- existingPolicy.setSuccess(policyResultID);
- break;
- default:
- throw new BuilderException("Invalid PolicyResult " + result);
- }
- }
- return new Policy(this.findPolicy(policyResultID));
- }
-
- @Override
- public boolean removePolicy(String policyID) throws BuilderException {
- Policy existingPolicy = this.findPolicy(policyID);
- if (existingPolicy == null) {
- throw new BuilderException("Unknown policy " + policyID);
- }
- //
- // Check if the policy to remove is trigger_policy
- //
- if (this.policy.getControlLoop().getTrigger_policy().equals(policyID)) {
- this.policy.getControlLoop().setTrigger_policy(FinalResult.FINAL_OPENLOOP.toString());
- }
- else {
- //
- // Update policies
- //
- for (Policy policy : this.policy.getPolicies()) {
- int index = this.policy.getPolicies().indexOf(policy);
- if (policy.getSuccess().equals(policyID)) {
- policy.setSuccess(FinalResult.FINAL_SUCCESS.toString());
- }
- if (policy.getFailure().equals(policyID)) {
- policy.setFailure(FinalResult.FINAL_FAILURE.toString());
- }
- if (policy.getFailure_retries().equals(policyID)) {
- policy.setFailure_retries(FinalResult.FINAL_FAILURE_RETRIES.toString());
- }
- if (policy.getFailure_timeout().equals(policyID)) {
- policy.setFailure_timeout(FinalResult.FINAL_FAILURE_TIMEOUT.toString());
- }
- if (policy.getFailure_exception().equals(policyID)) {
- policy.setFailure_exception(FinalResult.FINAL_FAILURE_EXCEPTION.toString());
- }
- if (policy.getFailure_guard().equals(policyID)) {
- policy.setFailure_guard(FinalResult.FINAL_FAILURE_GUARD.toString());
- }
- this.policy.getPolicies().set(index, policy);
- }
- }
- //
- // remove the policy
- //
- boolean removed = this.policy.getPolicies().remove(existingPolicy);
- return removed;
- }
-
- @Override
- public Policy resetPolicyResults(String policyID) throws BuilderException {
- Policy existingPolicy = this.findPolicy(policyID);
- if (existingPolicy == null) {
- throw new BuilderException("Unknown policy " + policyID);
- }
- //
- // reset policy results
- //
- existingPolicy.setSuccess(FinalResult.FINAL_SUCCESS.toString());
- existingPolicy.setFailure(FinalResult.FINAL_FAILURE.toString());
- existingPolicy.setFailure_retries(FinalResult.FINAL_FAILURE_RETRIES.toString());
- existingPolicy.setFailure_timeout(FinalResult.FINAL_FAILURE_TIMEOUT.toString());
- existingPolicy.setFailure_exception(FinalResult.FINAL_FAILURE_EXCEPTION.toString());
- existingPolicy.setFailure_guard(FinalResult.FINAL_FAILURE_GUARD.toString());
- return new Policy(existingPolicy);
- }
-
- @Override
- public ControlLoopPolicyBuilder removeAllPolicies() {
- //
- // Remove all existing operational policies
- //
- this.policy.getPolicies().clear();
- //
- // Revert controlLoop back to an open loop
- //
- this.policy.getControlLoop().setTrigger_policy(FinalResult.FINAL_OPENLOOP.toString());
- return this;
- }
-
- @Override
- public Policy addOperationsAccumulateParams(String policyID, OperationsAccumulateParams operationsAccumulateParams) throws BuilderException {
- Policy existingPolicy = this.findPolicy(policyID);
- if (existingPolicy == null) {
- throw new BuilderException("Unknown policy " + policyID);
- }
- //
- // Add operationsAccumulateParams to existingPolicy
- //
- existingPolicy.setOperationsAccumulateParams(operationsAccumulateParams);
- return new Policy(existingPolicy);
- }
+ private static Logger logger = LoggerFactory.getLogger(ControlLoopPolicyBuilderImpl.class.getName());
+ private ControlLoopPolicy policy;
+
+ public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout) throws BuilderException {
+ policy = new ControlLoopPolicy();
+ ControlLoop controlLoop = new ControlLoop();
+ controlLoop.setControlLoopName(controlLoopName);
+ controlLoop.setTimeout(timeout);
+ policy.setControlLoop(controlLoop);
+ }
+
+ public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout, Resource resource, Service... services) throws BuilderException {
+ this(controlLoopName, timeout);
+ this.addResource(resource);
+ this.addService(services);
+ }
+
+ public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout, PNF pnf) throws BuilderException {
+ this(controlLoopName, timeout);
+ this.setPNF(pnf);
+ }
+
+ public ControlLoopPolicyBuilderImpl(String controlLoopName, Integer timeout, Service service, Resource[] resources) throws BuilderException {
+ this(controlLoopName, timeout);
+ this.addService(service);
+ this.addResource(resources);
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder removePNF() throws BuilderException {
+ policy.getControlLoop().setPnf(null);
+ return this;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder addService(Service... services) throws BuilderException {
+ if (services == null) {
+ throw new BuilderException("Service must not be null");
+ }
+ for (Service service : services) {
+ if (service.getServiceUUID() == null) {
+ if (service.getServiceName() == null || service.getServiceName().length() < 1) {
+ throw new BuilderException("Invalid service - need either a serviceUUID or serviceName");
+ }
+ if(policy.getControlLoop().getServices()==null){
+ policy.getControlLoop().setServices(new LinkedList<>());
+ }
+ policy.getControlLoop().getServices().add(service);
+ }
+ }
+ return this;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder removeService(Service... services) throws BuilderException {
+ if (services == null) {
+ throw new BuilderException("Service must not be null");
+ }
+ if (policy.getControlLoop().getServices() == null) {
+ throw new BuilderException("No existing services to remove");
+ }
+ for (Service service : services) {
+ if (service.getServiceUUID() == null) {
+ if (service.getServiceName() == null || service.getServiceName().length() < 1) {
+ throw new BuilderException("Invalid service - need either a serviceUUID or serviceName");
+ }
+ }
+ boolean removed = policy.getControlLoop().getServices().remove(service);
+ if (!removed) {
+ throw new BuilderException("Unknown service " + service.getServiceName());
+ }
+ }
+ return this;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder removeAllServices() throws BuilderException {
+ policy.getControlLoop().getServices().clear();
+ return this;
+ }
+
+
+ @Override
+ public ControlLoopPolicyBuilder addResource(Resource... resources) throws BuilderException {
+ if (resources == null) {
+ throw new BuilderException("resources must not be null");
+ }
+ for (Resource resource : resources) {
+ if (resource.getResourceUUID() == null) {
+ if (resource.getResourceName() == null || resource.getResourceName().length() <= 0) {
+ throw new BuilderException("Invalid resource - need either resourceUUID or resourceName");
+ }
+ }
+ if(policy.getControlLoop().getResources()==null){
+ policy.getControlLoop().setResources(new LinkedList<>());
+ }
+ policy.getControlLoop().getResources().add(resource);
+ }
+ return this;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder setPNF(PNF pnf) throws BuilderException {
+ if (pnf == null) {
+ throw new BuilderException("PNF must not be null");
+ }
+ if (pnf.getPNFName() == null && pnf.getPNFType() == null) {
+ throw new BuilderException("Invalid PNF - need either pnfName or pnfType");
+ }
+ policy.getControlLoop().setPnf(pnf);
+ return this;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder setAbatement(Boolean abatement) throws BuilderException{
+ if (abatement == null) {
+ throw new BuilderException("abatement must not be null");
+ }
+ policy.getControlLoop().setAbatement(abatement);
+ return this;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder setTimeout(Integer timeout) {
+ policy.getControlLoop().setTimeout(timeout);
+ return this;
+ }
+
+ @Override
+ public Policy setTriggerPolicy(String name, String description, String actor, Target target, String recipe,
+ Map<String, String> payload, Integer retries, Integer timeout) throws BuilderException {
+
+ Policy trigger = new Policy(UUID.randomUUID().toString(), name, description, actor, payload, target, recipe, retries, timeout);
+
+ policy.getControlLoop().setTrigger_policy(trigger.getId());
+
+ this.addNewPolicy(trigger);
+ //
+ // Return a copy of the policy
+ //
+ return new Policy(trigger);
+ }
+
+ @Override
+ public Policy setPolicyForPolicyResult(String name, String description, String actor,
+ Target target, String recipe, Map<String, String> payload, Integer retries, Integer timeout, String policyID, PolicyResult... results) throws BuilderException {
+ //
+ // Find the existing policy
+ //
+ Policy existingPolicy = this.findPolicy(policyID);
+ if (existingPolicy == null) {
+ throw new BuilderException("Unknown policy " + policyID);
+ }
+ //
+ // Create the new Policy
+ //
+ Policy newPolicy = new Policy(UUID.randomUUID().toString(), name, description, actor, payload, target, recipe, retries, timeout);
+ //
+ // Connect the results
+ //
+ for (PolicyResult result : results) {
+ switch (result) {
+ case FAILURE:
+ existingPolicy.setFailure(newPolicy.getId());
+ break;
+ case FAILURE_EXCEPTION:
+ existingPolicy.setFailure_exception(newPolicy.getId());
+ break;
+ case FAILURE_RETRIES:
+ existingPolicy.setFailure_retries(newPolicy.getId());
+ break;
+ case FAILURE_TIMEOUT:
+ existingPolicy.setFailure_timeout(newPolicy.getId());
+ break;
+ case FAILURE_GUARD:
+ existingPolicy.setFailure_guard(newPolicy.getId());
+ break;
+ case SUCCESS:
+ existingPolicy.setSuccess(newPolicy.getId());
+ break;
+ default:
+ throw new BuilderException("Invalid PolicyResult " + result);
+ }
+ }
+ //
+ // Add it to our list
+ //
+ this.policy.getPolicies().add(newPolicy);
+ //
+ // Return a policy to them
+ //
+ return new Policy(newPolicy);
+ }
+
+ private class BuilderCompilerCallback implements ControlLoopCompilerCallback {
+
+ private ResultsImpl results = new ResultsImpl();
+
+ @Override
+ public boolean onWarning(String message) {
+ results.addMessage(new MessageImpl(message, MessageLevel.WARNING));
+ return false;
+ }
+
+ @Override
+ public boolean onError(String message) {
+ results.addMessage(new MessageImpl(message, MessageLevel.ERROR));
+ return false;
+ }
+ }
+
+ @Override
+ public Results buildSpecification() {
+ //
+ // Dump the specification
+ //
+ DumperOptions options = new DumperOptions();
+ options.setDefaultFlowStyle(FlowStyle.BLOCK);
+ options.setPrettyFlow(true);
+ Yaml yaml = new Yaml(options);
+ String dumpedYaml = yaml.dump(policy);
+ //
+ // This is our callback class for our compiler
+ //
+ BuilderCompilerCallback callback = new BuilderCompilerCallback();
+ //
+ // Compile it
+ //
+ try {
+ ControlLoopCompiler.compile(policy, callback);
+ } catch (CompilerException e) {
+ logger.error(e.getMessage() + e);
+ callback.results.addMessage(new MessageImpl(e.getMessage(), MessageLevel.EXCEPTION));
+ }
+ //
+ // Save the spec
+ //
+ callback.results.setSpecification(dumpedYaml);
+ return callback.results;
+ }
+
+ private void addNewPolicy(Policy policy) {
+ if (this.policy.getPolicies() == null) {
+ this.policy.setPolicies(new LinkedList<>());
+ }
+ this.policy.getPolicies().add(policy);
+ }
+
+ private Policy findPolicy(String id) {
+ for (Policy policy : this.policy.getPolicies()) {
+ if (policy.getId().equals(id)) {
+ return policy;
+ }
+ }
+ return null;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder removeResource(Resource... resources) throws BuilderException {
+ if (resources == null) {
+ throw new BuilderException("Resource must not be null");
+ }
+ if (policy.getControlLoop().getResources() == null) {
+ throw new BuilderException("No existing resources to remove");
+ }
+ for (Resource resource : resources) {
+ if (resource.getResourceUUID() == null) {
+ if (resource.getResourceName() == null || resource.getResourceName().length() < 1) {
+ throw new BuilderException("Invalid resource - need either a resourceUUID or resourceName");
+ }
+ }
+ boolean removed = policy.getControlLoop().getResources().remove(resource);
+ if (!removed) {
+ throw new BuilderException("Unknown resource " + resource.getResourceName());
+ }
+ }
+ return this;
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder removeAllResources() throws BuilderException {
+ policy.getControlLoop().getResources().clear();
+ return this;
+ }
+
+ @Override
+ public Integer calculateTimeout() {
+ int sum = 0;
+ for (Policy policy : this.policy.getPolicies()) {
+ sum += policy.getTimeout().intValue();
+ }
+ return new Integer(sum);
+ }
+
+ @Override
+ public ControlLoop setTriggerPolicy(String id) throws BuilderException {
+ if (id == null) {
+ throw new BuilderException("Id must not be null");
+ }
+ Policy trigger = this.findPolicy(id);
+ if (trigger == null) {
+ throw new BuilderException("Unknown policy " + id);
+ }
+ else {
+ this.policy.getControlLoop().setTrigger_policy(id);
+ }
+ return new ControlLoop(this.policy.getControlLoop());
+ }
+
+ @Override
+ public boolean isOpenLoop() {
+ if (this.policy.getControlLoop().getTrigger_policy().equals(FinalResult.FINAL_OPENLOOP.toString())) {
+ return true;
+ }
+ else {
+ return false;
+ }
+ }
+
+ @Override
+ public Policy getTriggerPolicy() throws BuilderException {
+ if (this.policy.getControlLoop().getTrigger_policy().equals(FinalResult.FINAL_OPENLOOP.toString())) {
+ return null;
+ }
+ else {
+ return new Policy(this.findPolicy(this.policy.getControlLoop().getTrigger_policy()));
+ }
+ }
+
+ @Override
+ public ControlLoop getControlLoop() {
+ return new ControlLoop(this.policy.getControlLoop());
+ }
+
+ @Override
+ public Policy setPolicyForPolicyResult(String policyResultID, String policyID, PolicyResult... results)
+ throws BuilderException {
+ //
+ // Find the existing policy
+ //
+ Policy existingPolicy = this.findPolicy(policyID);
+ if (existingPolicy == null) {
+ throw new BuilderException(policyID + " does not exist");
+ }
+ if (this.findPolicy(policyResultID) == null) {
+ throw new BuilderException("Operational policy " + policyResultID + " does not exist");
+ }
+ //
+ // Connect the results
+ //
+ for (PolicyResult result : results) {
+ switch (result) {
+ case FAILURE:
+ existingPolicy.setFailure(policyResultID);
+ break;
+ case FAILURE_EXCEPTION:
+ existingPolicy.setFailure_exception(policyResultID);
+ break;
+ case FAILURE_RETRIES:
+ existingPolicy.setFailure_retries(policyResultID);
+ break;
+ case FAILURE_TIMEOUT:
+ existingPolicy.setFailure_timeout(policyResultID);
+ break;
+ case FAILURE_GUARD:
+ existingPolicy.setFailure_guard(policyResultID);
+ break;
+ case SUCCESS:
+ existingPolicy.setSuccess(policyResultID);
+ break;
+ default:
+ throw new BuilderException("Invalid PolicyResult " + result);
+ }
+ }
+ return new Policy(this.findPolicy(policyResultID));
+ }
+
+ @Override
+ public boolean removePolicy(String policyID) throws BuilderException {
+ Policy existingPolicy = this.findPolicy(policyID);
+ if (existingPolicy == null) {
+ throw new BuilderException("Unknown policy " + policyID);
+ }
+ //
+ // Check if the policy to remove is trigger_policy
+ //
+ if (this.policy.getControlLoop().getTrigger_policy().equals(policyID)) {
+ this.policy.getControlLoop().setTrigger_policy(FinalResult.FINAL_OPENLOOP.toString());
+ }
+ else {
+ //
+ // Update policies
+ //
+ for (Policy policy : this.policy.getPolicies()) {
+ int index = this.policy.getPolicies().indexOf(policy);
+ if (policy.getSuccess().equals(policyID)) {
+ policy.setSuccess(FinalResult.FINAL_SUCCESS.toString());
+ }
+ if (policy.getFailure().equals(policyID)) {
+ policy.setFailure(FinalResult.FINAL_FAILURE.toString());
+ }
+ if (policy.getFailure_retries().equals(policyID)) {
+ policy.setFailure_retries(FinalResult.FINAL_FAILURE_RETRIES.toString());
+ }
+ if (policy.getFailure_timeout().equals(policyID)) {
+ policy.setFailure_timeout(FinalResult.FINAL_FAILURE_TIMEOUT.toString());
+ }
+ if (policy.getFailure_exception().equals(policyID)) {
+ policy.setFailure_exception(FinalResult.FINAL_FAILURE_EXCEPTION.toString());
+ }
+ if (policy.getFailure_guard().equals(policyID)) {
+ policy.setFailure_guard(FinalResult.FINAL_FAILURE_GUARD.toString());
+ }
+ this.policy.getPolicies().set(index, policy);
+ }
+ }
+ //
+ // remove the policy
+ //
+ boolean removed = this.policy.getPolicies().remove(existingPolicy);
+ return removed;
+ }
+
+ @Override
+ public Policy resetPolicyResults(String policyID) throws BuilderException {
+ Policy existingPolicy = this.findPolicy(policyID);
+ if (existingPolicy == null) {
+ throw new BuilderException("Unknown policy " + policyID);
+ }
+ //
+ // reset policy results
+ //
+ existingPolicy.setSuccess(FinalResult.FINAL_SUCCESS.toString());
+ existingPolicy.setFailure(FinalResult.FINAL_FAILURE.toString());
+ existingPolicy.setFailure_retries(FinalResult.FINAL_FAILURE_RETRIES.toString());
+ existingPolicy.setFailure_timeout(FinalResult.FINAL_FAILURE_TIMEOUT.toString());
+ existingPolicy.setFailure_exception(FinalResult.FINAL_FAILURE_EXCEPTION.toString());
+ existingPolicy.setFailure_guard(FinalResult.FINAL_FAILURE_GUARD.toString());
+ return new Policy(existingPolicy);
+ }
+
+ @Override
+ public ControlLoopPolicyBuilder removeAllPolicies() {
+ //
+ // Remove all existing operational policies
+ //
+ this.policy.getPolicies().clear();
+ //
+ // Revert controlLoop back to an open loop
+ //
+ this.policy.getControlLoop().setTrigger_policy(FinalResult.FINAL_OPENLOOP.toString());
+ return this;
+ }
+
+ @Override
+ public Policy addOperationsAccumulateParams(String policyID, OperationsAccumulateParams operationsAccumulateParams) throws BuilderException {
+ Policy existingPolicy = this.findPolicy(policyID);
+ if (existingPolicy == null) {
+ throw new BuilderException("Unknown policy " + policyID);
+ }
+ //
+ // Add operationsAccumulateParams to existingPolicy
+ //
+ existingPolicy.setOperationsAccumulateParams(operationsAccumulateParams);
+ return new Policy(existingPolicy);
+ }
}
{
AAINQRequest request = Serialization.gsonPretty.fromJson(req, AAINQRequest.class);
- if (request.instanceFilters.instanceFilter.get(0).containsKey("vserver"))
+ if (request.instanceFilters.getInstanceFilter().get(0).containsKey("vserver"))
{
- String vserverName = request.instanceFilters.instanceFilter.get(0).get("vserver").get("vserver-name");
+ String vserverName = request.instanceFilters.getInstanceFilter().get(0).get("vserver").get("vserver-name");
if ("error".equals(vserverName)) {
return "{\"requestError\":{\"serviceException\":{\"messageId\":\"SVC3001\",\"text\":\"Resource not found for %1 using id %2 (msg=%3) (ec=%4)\",\"variables\":[\"POST Search\",\"getNamedQueryResponse\",\"Node Not Found:No Node of type vserver found for properties\",\"ERR.5.4.6114\"]}}}";
}
}
else
{
- String vnfID = request.instanceFilters.instanceFilter.get(0).get("generic-vnf").get("vnf-id");
+ String vnfID = request.instanceFilters.getInstanceFilter().get(0).get("generic-vnf").get("vnf-id");
if ("error".equals(vnfID)) {
return "{\"requestError\":{\"serviceException\":{\"messageId\":\"SVC3001\",\"text\":\"Resource not found for %1 using id %2 (msg=%3) (ec=%4)\",\"variables\":[\"POST Search\",\"getNamedQueryResponse\",\"Node Not Found:No Node of type generic-vnf found for properties\",\"ERR.5.4.6114\"]}}}";
}
List<Map<String, Map<String, String>>> tempInstanceFilter = new LinkedList<>();
tempInstanceFilter.add(tempOuterMap);
AAINQInstanceFilters tempInstanceFilters = new AAINQInstanceFilters();
- tempInstanceFilters.instanceFilter = tempInstanceFilter;
+ tempInstanceFilters.setInstanceFilter(tempInstanceFilter);
request.instanceFilters = tempInstanceFilters;
AAINQResponse response = AAIManager.postQuery("http://localhost:6666", "testUser", "testPass",
request, UUID.randomUUID());
assertNotNull(response);
- assertNotNull(response.inventoryResponseItems);
+ assertNotNull(response.getInventoryResponseItems());
tempNamedQuery.namedQueryUUID = UUID.fromString("a93ac487-409c-4e8c-9e5f-334ae8f99087");
tempQueryParameters.namedQuery = tempNamedQuery;
tempInstanceFilter = new LinkedList<>();
tempInstanceFilter.add(tempOuterMap);
tempInstanceFilters = new AAINQInstanceFilters();
- tempInstanceFilters.instanceFilter = tempInstanceFilter;
+ tempInstanceFilters.setInstanceFilter(tempInstanceFilter);
request.instanceFilters = tempInstanceFilters;
response = AAIManager.postQuery("http://localhost:6666", "testUser", "testPass", request,
UUID.randomUUID());
assertNotNull(response);
- assertNotNull(response.inventoryResponseItems);
+ assertNotNull(response.getInventoryResponseItems());
}
}
Code Review / policy / drools-applications.git / commitdiff