diff options
| author |   Marcus G K Williams <marcus.williams@intel.com> | 2018-11-30 13:38:15 -0800 |
|---|---|---|
| committer | Marcus G K Williams <marcus.williams@intel.com> | 2018-11-30 13:38:26 -0800 |
| commit | 8d05d604f0f0ea81d835d29b2379a1417a689f32 (patch) | |
| tree | 2202ef38ee4bcd388a2a9aa755a19cb8ff98622c /bpmn/MSOCommonBPMN/src/main/java/org/onap | |
| parent | a0f26d934ed91a68553b3d9991ac9126ddb08735 (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/onap')
| -rw-r--r-- | bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/common/util/OofInfraUtils.java | 27 |
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); } + + } /** |