aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org
diff options
context:
space:
mode:
authorsebdet <sebastien.determe@intl.att.com>2019-05-09 16:50:17 +0200
committersebdet <sebastien.determe@intl.att.com>2019-05-09 17:05:36 +0200
commitaa7fd8ddced2e3218fa85e131e1eff59ff33e22f (patch)
tree4ee111943c0b1054c647d576c371c440ea724017 /src/main/java/org
parentce3e2f425911b6a4cc68e61b482bcd73a2cff8a4 (diff)
Generate Random UUID for DCAE
Generate random UUI for DCAE deployment during deploy action Issue-ID: CLAMP-376 Change-Id: Idfc1959891738f0142d2c20e1f43f1ad45d8eaa7 Signed-off-by: sebdet <sebastien.determe@intl.att.com>
Diffstat (limited to 'src/main/java/org')
-rw-r--r--src/main/java/org/onap/clamp/loop/LoopOperation.java74
1 files changed, 48 insertions, 26 deletions
diff --git a/src/main/java/org/onap/clamp/loop/LoopOperation.java b/src/main/java/org/onap/clamp/loop/LoopOperation.java
index 518830aa0..172b77c28 100644
--- a/src/main/java/org/onap/clamp/loop/LoopOperation.java
+++ b/src/main/java/org/onap/clamp/loop/LoopOperation.java
@@ -30,6 +30,7 @@ import com.google.gson.JsonObject;
import java.io.IOException;
import java.util.Iterator;
import java.util.Set;
+import java.util.UUID;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
@@ -52,8 +53,7 @@ public class LoopOperation {
private static final String DCAE_STATUS_FIELD = "status";
private static final String DCAE_SERVICETYPE_ID = "serviceTypeId";
private static final String DCAE_INPUTS = "inputs";
- private static final String DCAE_DEPLOYMENT_PREFIX = "closedLoop_";
- private static final String DCAE_DEPLOYMENT_SUFIX = "_deploymentId";
+ private static final String DCAE_DEPLOYMENT_PREFIX = "CLAMP_";
private static final String DEPLOYMENT_PARA = "dcaeDeployParameters";
private final LoopService loopService;
@@ -63,8 +63,11 @@ public class LoopOperation {
/**
* The constructor.
- * @param loopService The loop service
- * @param refProp The clamp properties
+ *
+ * @param loopService
+ * The loop service
+ * @param refProp
+ * The clamp properties
*/
@Autowired
public LoopOperation(LoopService loopService) {
@@ -74,9 +77,11 @@ public class LoopOperation {
/**
* Get the payload used to send the deploy closed loop request.
*
- * @param loop The loop
+ * @param loop
+ * The loop
* @return The payload used to send deploy closed loop request
- * @throws IOException IOException
+ * @throws IOException
+ * IOException
*/
public String getDeployPayload(Loop loop) throws IOException {
JsonObject globalProp = loop.getGlobalPropertiesJson();
@@ -98,9 +103,11 @@ public class LoopOperation {
/**
* Get the deployment id.
*
- * @param loop The loop
+ * @param loop
+ * The loop
* @return The deployment id
- * @throws IOException IOException
+ * @throws IOException
+ * IOException
*/
public String getDeploymentId(Loop loop) {
// Set the deploymentId if not present yet
@@ -109,7 +116,7 @@ public class LoopOperation {
if (loop.getDcaeDeploymentId() != null && !loop.getDcaeDeploymentId().isEmpty()) {
deploymentId = loop.getDcaeDeploymentId();
} else {
- deploymentId = DCAE_DEPLOYMENT_PREFIX + loop.getName() + DCAE_DEPLOYMENT_SUFIX;
+ deploymentId = DCAE_DEPLOYMENT_PREFIX + UUID.randomUUID();
}
return deploymentId;
}
@@ -117,10 +124,14 @@ public class LoopOperation {
/**
* Update the loop info.
*
- * @param camelExchange The camel exchange
- * @param loop The loop
- * @param deploymentId The deployment id
- * @throws ParseException The parse exception
+ * @param camelExchange
+ * The camel exchange
+ * @param loop
+ * The loop
+ * @param deploymentId
+ * The deployment id
+ * @throws ParseException
+ * The parse exception
*/
public void updateLoopInfo(Exchange camelExchange, Loop loop, String deploymentId) throws ParseException {
Message in = camelExchange.getIn();
@@ -133,8 +144,9 @@ public class LoopOperation {
JSONObject linksObj = (JSONObject) jsonObj.get(DCAE_LINK_FIELD);
String statusUrl = (String) linksObj.get(DCAE_STATUS_FIELD);
- // use http4 instead of http, because camel http4 component is used to do the http call
- String newStatusUrl = statusUrl.replaceAll("http:", "http4:");
+ // use http4 instead of http, because camel http4 component is used to do the
+ // http call
+ String newStatusUrl = statusUrl.replaceAll("http:", "http4:").replaceAll("https:", "https4:");
loop.setDcaeDeploymentId(deploymentId);
loop.setDcaeDeploymentStatusUrl(newStatusUrl);
@@ -144,9 +156,11 @@ public class LoopOperation {
/**
* Get the Closed Loop status based on the reply from Policy.
*
- * @param statusCode The status code
+ * @param statusCode
+ * The status code
* @return The state based on policy response
- * @throws ParseException The parse exception
+ * @throws ParseException
+ * The parse exception
*/
public String analysePolicyResponse(int statusCode) {
if (statusCode == 200) {
@@ -160,11 +174,12 @@ public class LoopOperation {
/**
* Get the name of the first Operational policy.
*
- * @param loop The closed loop
+ * @param loop
+ * The closed loop
* @return The name of the first operational policy
*/
public String getOperationalPolicyName(Loop loop) {
- Set<OperationalPolicy> opSet = (Set<OperationalPolicy>)loop.getOperationalPolicies();
+ Set<OperationalPolicy> opSet = loop.getOperationalPolicies();
Iterator<OperationalPolicy> iterator = opSet.iterator();
while (iterator.hasNext()) {
OperationalPolicy policy = iterator.next();
@@ -176,9 +191,11 @@ public class LoopOperation {
/**
* Get the Closed Loop status based on the reply from DCAE.
*
- * @param camelExchange The camel exchange
+ * @param camelExchange
+ * The camel exchange
* @return The state based on DCAE response
- * @throws ParseException The parse exception
+ * @throws ParseException
+ * The parse exception
*/
public String analyseDcaeResponse(Exchange camelExchange, Integer statusCode) throws ParseException {
if (statusCode == null) {
@@ -212,12 +229,17 @@ public class LoopOperation {
}
/**
- * Update the status of the closed loop based on the response from Policy and DCAE.
+ * Update the status of the closed loop based on the response from Policy and
+ * DCAE.
*
- * @param loop The closed loop
- * @param policyState The state get from Policy
- * @param dcaeState The state get from DCAE
- * @throws ParseException The parse exception
+ * @param loop
+ * The closed loop
+ * @param policyState
+ * The state get from Policy
+ * @param dcaeState
+ * The state get from DCAE
+ * @throws ParseException
+ * The parse exception
*/
public LoopState updateLoopStatus(Loop loop, TempLoopState policyState, TempLoopState dcaeState) {
LoopState clState = LoopState.IN_ERROR;