aboutsummaryrefslogtreecommitdiffstats
path: root/bpmn/MSOCommonBPMN/src/main/java/org
diff options
context:
space:
mode:
authorMarcus G K Williams <marcus.williams@intel.com>2018-11-30 13:38:15 -0800
committerMarcus G K Williams <marcus.williams@intel.com>2018-11-30 13:38:26 -0800
commit8d05d604f0f0ea81d835d29b2379a1417a689f32 (patch)
tree2202ef38ee4bcd388a2a9aa755a19cb8ff98622c /bpmn/MSOCommonBPMN/src/main/java/org
parenta0f26d934ed91a68553b3d9991ac9126ddb08735 (diff)
Fix cloudSite creation in homing
This change fixes the use of optional in OofInfraUtils.java, so that cloudSites can be created if one is not found in catalogDB. Issue-ID: SO-1262 Change-Id: Ifec9083950758c650a369e9c5ebd386715ed9df8 Signed-off-by: Marcus G K Williams <marcus.williams@intel.com>
Diffstat (limited to 'bpmn/MSOCommonBPMN/src/main/java/org')
-rw-r--r--bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/common/util/OofInfraUtils.java27
1 files changed, 18 insertions, 9 deletions
diff --git a/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/common/util/OofInfraUtils.java b/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/common/util/OofInfraUtils.java
index b62d8be281..df7b57f3a3 100644
--- a/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/common/util/OofInfraUtils.java
+++ b/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/common/util/OofInfraUtils.java
@@ -45,18 +45,27 @@ public class OofInfraUtils {
public void createCloudSite(CloudSite cloudSite, DelegateExecution execution) {
String endpoint = UrnPropertiesReader.getVariable("mso.catalog.db.spring.endpoint", execution);
String auth = UrnPropertiesReader.getVariable("mso.db.auth", execution);
- Optional <CloudSite> optCloudsite = Optional.empty();
-
- CatalogDbClient client = new CatalogDbClient(endpoint, auth);
try {
- optCloudsite = Optional.ofNullable(client.getCloudSite(cloudSite.getId(), endpoint + "/cloudSite/"));
+ CloudSite getCloudsite;
+
+ CatalogDbClient client = new CatalogDbClient(endpoint, auth);
+
+ getCloudsite = Optional.ofNullable(client.getCloudSite(cloudSite.getId(), endpoint + "/cloudSite/")).orElse(new CloudSite());
+ if (!cloudSite.getId().equals(getCloudsite.getId())) {
+ client.postCloudSite(cloudSite);
+ LOGGER.debug("Did not findd cloudsite : " + cloudSite.getId());
+ LOGGER.debug("Will create cloudSite: " + cloudSite.toString());
+ }
+ else {
+ LOGGER.debug("Found cloudsite : " + cloudSite.getId());
+ LOGGER.debug("Will not create cloudSite: " + cloudSite.toString());
+ }
} catch (Exception e) {
- LOGGER.debug("Could not find cloudsite : " + cloudSite.getId());
- LOGGER.debug("Creating cloudSite: " + cloudSite.toString());
- }
- if (optCloudsite.isPresent() && (cloudSite.getId()) != optCloudsite.get().getId()) {
- client.postCloudSite(cloudSite);
+ LOGGER.debug("Error looking up or creating cloudsite : " + cloudSite.getId());
+ LOGGER.debug("CloudSite Lookup/Creation Error: " + e);
}
+
+
}
/**