*/\r
public class RackspaceAPIKeyWrapper extends AuthenticationWrapper {\r
\r
- /**\r
- * \r
- */\r
- public RackspaceAPIKeyWrapper() {\r
- // TODO Auto-generated constructor stub\r
- }\r
-\r
- /* (non-Javadoc)\r
- * @see org.openecomp.mso.cloud.authentication.AuthenticationWrapper#getAuthentication(org.openecomp.mso.cloud.CloudIdentity)\r
- */\r
@Override\r
public Authentication getAuthentication(CloudIdentity cloudIdentity) {\r
if (cloudIdentity == null) {\r
/**\r
* This class implements the authentication wrapper for Openstack provided for\r
* user name and password authentication.\r
- *\r
*/\r
public class UsernamePasswordWrapper extends AuthenticationWrapper {\r
\r
- /**\r
- * \r
- */\r
- public UsernamePasswordWrapper() {\r
- }\r
-\r
- /* (non-Javadoc)\r
- * @see org.openecomp.mso.cloud.authentication.AuthenticationWrapper#getAuthentication(org.openecomp.mso.cloud.CloudIdentity)\r
- */\r
@Override\r
public Authentication getAuthentication(CloudIdentity cloudIdentity) {\r
if (cloudIdentity == null) {\r
--- /dev/null
+/*
+ * ============LICENSE_START==========================================
+ * ===================================================================
+ * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+ * ===================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END============================================
+ *
+ * ECOMP and OpenECOMP are trademarks
+ * and service marks of AT&T Intellectual Property.
+ *
+ */
+
+package org.openecomp.mso.cloud.authentication.wrappers;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+import com.woorea.openstack.keystone.model.Authentication;
+import org.junit.Test;
+import org.openecomp.mso.cloud.authentication.models.RackspaceAuthentication;
+
+public class RackspaceAPIKeyWrapperTest {
+
+ @Test
+ public void getAuthenticationSuccessful() {
+ RackspaceAPIKeyWrapper testedObject = new RackspaceAPIKeyWrapper();
+ Authentication authentication = testedObject.getAuthentication(WrapperTestUtility.createCloudIdentity());
+
+ assertThat(authentication).isInstanceOf(RackspaceAuthentication.class);
+ RackspaceAuthentication rackspaceAuthentication = (RackspaceAuthentication) authentication;
+ assertThat(rackspaceAuthentication.getToken().getUsername())
+ .isEqualTo(WrapperTestUtility.CLOUD_IDENTITY_MSO_ID);
+ assertThat(rackspaceAuthentication.getToken().getApiKey())
+ .isEqualTo(WrapperTestUtility.CLOUD_IDENTITY_MSO_PASS);
+ }
+
+ @Test
+ public void getAuthenticationThrowsException() {
+ assertThatThrownBy(() -> new RackspaceAPIKeyWrapper().getAuthentication(null))
+ .isInstanceOf(IllegalArgumentException.class)
+ .hasMessage(WrapperTestUtility.EXCEPTION_MESSAGE);
+ }
+
+}
--- /dev/null
+/*
+ * ============LICENSE_START==========================================
+ * ===================================================================
+ * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+ * ===================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END============================================
+ *
+ * ECOMP and OpenECOMP are trademarks
+ * and service marks of AT&T Intellectual Property.
+ *
+ */
+
+package org.openecomp.mso.cloud.authentication.wrappers;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+import com.woorea.openstack.keystone.model.Authentication;
+import com.woorea.openstack.keystone.model.authentication.UsernamePassword;
+import org.junit.Test;
+
+public class UsernamePasswordWrapperTest {
+
+ @Test
+ public void getAuthenticationSuccessful() {
+ UsernamePasswordWrapper testedObject = new UsernamePasswordWrapper();
+ Authentication authentication = testedObject.getAuthentication(WrapperTestUtility.createCloudIdentity());
+
+ assertThat(authentication).isInstanceOf(UsernamePassword.class);
+ UsernamePassword usernamePassword = (UsernamePassword) authentication;
+ assertThat(usernamePassword.getPasswordCredentials().getUsername())
+ .isEqualTo(WrapperTestUtility.CLOUD_IDENTITY_MSO_ID);
+ assertThat(usernamePassword.getPasswordCredentials().getPassword())
+ .isEqualTo(WrapperTestUtility.CLOUD_IDENTITY_MSO_PASS);
+ }
+
+ @Test
+ public void getAuthenticationThrowsException() {
+ assertThatThrownBy(() -> new UsernamePasswordWrapper().getAuthentication(null)).
+ isInstanceOf(IllegalArgumentException.class).
+ hasMessage(WrapperTestUtility.EXCEPTION_MESSAGE);
+ }
+
+}
--- /dev/null
+/*
+ * ============LICENSE_START==========================================
+ * ===================================================================
+ * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+ * ===================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END============================================
+ *
+ * ECOMP and OpenECOMP are trademarks
+ * and service marks of AT&T Intellectual Property.
+ *
+ */
+
+package org.openecomp.mso.cloud.authentication.wrappers;
+
+import org.openecomp.mso.cloud.CloudIdentity;
+
+final class WrapperTestUtility {
+
+ static final String CLOUD_IDENTITY_MSO_ID = "msoIdTest";
+ static final String CLOUD_IDENTITY_MSO_PASS = "msoPassTest";
+ static final String EXCEPTION_MESSAGE = "Provided cloud identity is null, cannot extract username and "
+ + "password";
+
+ private WrapperTestUtility() {
+ }
+
+ static CloudIdentity createCloudIdentity() {
+ CloudIdentity cloudIdentity = new CloudIdentity();
+ cloudIdentity.setMsoId(CLOUD_IDENTITY_MSO_ID);
+ cloudIdentity.setMsoPass(CloudIdentity.encryptPassword(CLOUD_IDENTITY_MSO_PASS));
+ return cloudIdentity;
+ }
+}
put(valueMap, "MODEL_INVARIANT_ID", vfNull ? null : o.getVfModule().getModelInvariantUuid());
put(valueMap, "MODEL_VERSION", vfNull ? null : o.getVfModule().getVersion());
put(valueMap, "MODEL_CUSTOMIZATION_UUID", o.getModelCustomizationUuid());
- put(valueMap, "IS_BASE", vfNull ? false : Boolean.valueOf(o.getVfModule().isBase() ? true : false));
+ put(valueMap, "IS_BASE", vfNull ? false : o.getVfModule().isBase() ? true : false);
put(valueMap, "VF_MODULE_LABEL", o.getLabel());
put(valueMap, "INITIAL_COUNT", o.getInitialCount());
- put(valueMap, "HAS_VOLUME_GROUP", Boolean.valueOf(hasVolumeGroup));
+ put(valueMap, "HAS_VOLUME_GROUP", hasVolumeGroup);
buf.append(sep+ this.setTemplate(template, valueMap));
sep = ",\n";
DataOutputStream out = null;
BufferedReader in = null;
SDNCResponse sdncResp = new SDNCResponse(rt.getReqId());
- StringBuffer response = new StringBuffer();
+ StringBuilder response = new StringBuilder();
msoLogger.info(MessageEnum.RA_SEND_REQUEST_SDNC, rt.toString(), "SDNC", "");
msoLogger.debug("SDNC Request Body:\n" + sdncReqBody);
List<String> controllerNames = ASDCConfiguration.getAllDefinedControllers();
- StringBuffer controllerListLog = new StringBuffer("List of controllers loaded:");
+ StringBuilder controllerListLog = new StringBuilder("List of controllers loaded:");
for (String controllerName : controllerNames) {
controllers.put(controllerName, new ASDCController(controllerName));
controllerListLog.append(controllerName);
*/
@Override
public final String toString() {
- StringBuffer sb = new StringBuffer();
+ StringBuilder sb = new StringBuilder();
List<String> aggregatedElements = new ArrayList<>();
for (Entry<String, String> entry : this.getElementInfoMap().entrySet()) {
aggregatedElements.add(entry.getKey() + ": " + entry.getValue());
public static BigDecimal castAndCheckNotificationVersion(String version) {
// Truncate the version if bad type
String[] splitVersion = version.split("\\.");
- StringBuffer newVersion = new StringBuffer();
+ StringBuilder newVersion = new StringBuilder();
if (splitVersion.length > 1) {
newVersion.append(splitVersion[0]);
newVersion.append(".");
return body; \r
} \r
\r
- StringBuffer sb = new StringBuffer(body.length()); \r
+ StringBuilder sb = new StringBuilder(body.length());\r
\r
int currentIndex = 0; \r
int startIndex = 0; \r
return body;
}
- StringBuffer sb = new StringBuffer(body.length());
+ StringBuilder sb = new StringBuilder(body.length());
int currentIndex = 0;
int startIndex = 0;
if (asdcNotification == null) {
return "NULL";
}
- StringBuffer buffer = new StringBuffer("ASDC Notification:");
+ StringBuilder buffer = new StringBuilder("ASDC Notification:");
buffer.append(System.lineSeparator());
buffer.append("DistributionID:");
}
- StringBuffer buffer = new StringBuffer("CSAR Notification:");
+ StringBuilder buffer = new StringBuilder("CSAR Notification:");
buffer.append(System.lineSeparator());
buffer.append(System.lineSeparator());
return null;
}
- StringBuffer buffer = new StringBuffer("VfModuleMetaData List:");
+ StringBuilder buffer = new StringBuilder("VfModuleMetaData List:");
buffer.append(System.lineSeparator());
buffer.append("{");
return "NULL";
}
- StringBuffer buffer = new StringBuffer("VfModuleMetaData:");
+ StringBuilder buffer = new StringBuilder("VfModuleMetaData:");
buffer.append(System.lineSeparator());
buffer.append("VfModuleModelName:");
return null;
}
- StringBuffer buffer = new StringBuffer();
+ StringBuilder buffer = new StringBuilder();
buffer.append("{");
for (IResourceInstance resourceInstanceElem:asdcNotification.getResources()) {
return null;
}
- StringBuffer buffer = new StringBuffer("Resource Instance Info:");
+ StringBuilder buffer = new StringBuilder("Resource Instance Info:");
buffer.append(System.lineSeparator());
buffer.append("ResourceInstanceName:");
return null;
}
- StringBuffer buffer = new StringBuffer();
+ StringBuilder buffer = new StringBuilder();
buffer.append("{");
for (IArtifactInfo artifactInfoElem:artifactsList) {
buffer.append(System.lineSeparator());
return null;
}
- StringBuffer buffer = new StringBuffer("Service Artifacts Info:");
+ StringBuilder buffer = new StringBuilder("Service Artifacts Info:");
buffer.append(System.lineSeparator());
buffer.append("ArtifactName:");
return "EMPTY"; // No declared methods in this class !!!
}
- StringBuffer buffer = new StringBuffer("ASDC Notification:");
+ StringBuilder buffer = new StringBuilder("ASDC Notification:");
buffer.append(System.lineSeparator());
for (Method m : declaredMethods) {
*/
@XmlElementDecl(namespace = "http://org.openecomp.mso/vnfNotify", name = "rollbackVnfNotification")
public JAXBElement<RollbackVnfNotification> createRollbackVnfNotification(RollbackVnfNotification value) {
- return new JAXBElement<RollbackVnfNotification>(_RollbackVnfNotification_QNAME, RollbackVnfNotification.class, null, value);
+ return new JAXBElement<>(_RollbackVnfNotification_QNAME, RollbackVnfNotification.class, null, value);
}
/**
*/
@XmlElementDecl(namespace = "http://org.openecomp.mso/vnfNotify", name = "deleteVnfNotification")
public JAXBElement<DeleteVnfNotification> createDeleteVnfNotification(DeleteVnfNotification value) {
- return new JAXBElement<DeleteVnfNotification>(_DeleteVnfNotification_QNAME, DeleteVnfNotification.class, null, value);
+ return new JAXBElement<>(_DeleteVnfNotification_QNAME, DeleteVnfNotification.class, null, value);
}
/**
*/
@XmlElementDecl(namespace = "http://org.openecomp.mso/vnfNotify", name = "createVnfNotification")
public JAXBElement<CreateVnfNotification> createCreateVnfNotification(CreateVnfNotification value) {
- return new JAXBElement<CreateVnfNotification>(_CreateVnfNotification_QNAME, CreateVnfNotification.class, null, value);
+ return new JAXBElement<>(_CreateVnfNotification_QNAME, CreateVnfNotification.class, null, value);
}
/**
*/
@XmlElementDecl(namespace = "http://org.openecomp.mso/vnfNotify", name = "updateVnfNotification")
public JAXBElement<UpdateVnfNotification> createUpdateVnfNotification(UpdateVnfNotification value) {
- return new JAXBElement<UpdateVnfNotification>(_UpdateVnfNotification_QNAME, UpdateVnfNotification.class, null, value);
+ return new JAXBElement<>(_UpdateVnfNotification_QNAME, UpdateVnfNotification.class, null, value);
}
/**
*/
@XmlElementDecl(namespace = "http://org.openecomp.mso/vnfNotify", name = "queryVnfNotification")
public JAXBElement<QueryVnfNotification> createQueryVnfNotification(QueryVnfNotification value) {
- return new JAXBElement<QueryVnfNotification>(_QueryVnfNotification_QNAME, QueryVnfNotification.class, null, value);
+ return new JAXBElement<>(_QueryVnfNotification_QNAME, QueryVnfNotification.class, null, value);
}
}
\r
\r
private static String byteArrayToHexString(byte[] b){\r
- StringBuffer sb = new StringBuffer(b.length * 2);\r
- for (int i = 0; i < b.length; i++){\r
- int v = b[i] & 0xff;\r
+ StringBuilder sb = new StringBuilder(b.length * 2);\r
+ for (byte aB : b) {\r
+ int v = aB & 0xff;\r
if (v < 16) {\r
- sb.append('0');\r
+ sb.append('0');\r
}\r
sb.append(Integer.toHexString(v));\r
- }\r
+ }\r
return sb.toString().toUpperCase();\r
}\r
\r
+ (message == null ? "" : System.lineSeparator()) + message);\r
\r
try {\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
\r
if (injectedVariables != null) {\r
variables.putAll(injectedVariables);\r
\r
int count = waitingProcesses.size();\r
\r
- List<ExecInfo> execInfoList = new ArrayList<ExecInfo>(count);\r
+ List<ExecInfo> execInfoList = new ArrayList<>(count);\r
for (Execution execution : waitingProcesses) {\r
execInfoList.add(new ExecInfo(execution));\r
}\r
+ ":" + execution.getId() + "]";\r
}\r
}\r
-}
+}\r
String correlationValue = correlator;\r
String contentTypeVariable = messageType + "_CONTENT_TYPE";\r
\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
\r
if (contentType != null) {\r
variables.put(contentTypeVariable, contentType);\r
Object responseCodeObject = getVariableFromHistory(historyService, processInstanceId, prefix + "ResponseCode");\r
String responseCode = responseCodeObject == null ? null : String.valueOf(responseCodeObject);\r
msoLogger.debug(LOGMARKER + prefix + "ResponseCode: " + responseCode);\r
- responseMap = new HashMap<String, Object>();\r
+ responseMap = new HashMap<>();\r
responseMap.put("WorkflowResponse", workflowResponse);\r
responseMap.put("ResponseCode", responseCode);\r
responseMap.put("Status", "Success");\r
if(workflowExceptionObject instanceof WorkflowException) {\r
workflowException = (WorkflowException) workflowExceptionObject;\r
workflowExceptionText = workflowException.toString();\r
- responseMap = new HashMap<String, Object>();\r
+ responseMap = new HashMap<>();\r
responseMap.put("WorkflowException", workflowExceptionText);\r
responseMap.put("ResponseCode", workflowException.getErrorCode());\r
responseMap.put("Status", "Fail");\r
Object object = getVariableFromHistory(historyService, processInstanceId, prefix + "ResponseCode");\r
String responseCode = object == null ? null : String.valueOf(object);\r
workflowExceptionText = (String) workflowExceptionObject;\r
- responseMap = new HashMap<String, Object>();\r
+ responseMap = new HashMap<>();\r
responseMap.put("WorkflowException", workflowExceptionText);\r
responseMap.put("ResponseCode", responseCode);\r
responseMap.put("Status", "Fail");\r
object = getVariableFromHistory(historyService, processInstanceId, prefix + "ResponseCode");\r
String responseCode = object == null ? null : String.valueOf(object);\r
msoLogger.debug(LOGMARKER + prefix + "ResponseCode: " + responseCode);\r
- responseMap = new HashMap<String, Object>();\r
+ responseMap = new HashMap<>();\r
responseMap.put("Response", response);\r
responseMap.put("ResponseCode", responseCode);\r
responseMap.put("Status", "Success");\r
object = getVariableFromHistory(historyService, processInstanceId, prefix + "ResponseCode");\r
String responseCode = object == null ? null : String.valueOf(object);\r
msoLogger.debug(LOGMARKER + prefix + "ResponseCode: " + responseCode);\r
- responseMap = new HashMap<String, Object>();\r
+ responseMap = new HashMap<>();\r
responseMap.put("Response", errorResponse);\r
responseMap.put("ResponseCode", responseCode);\r
responseMap.put("Status", "Fail");\r
try {\r
ProcessEngineServices engine = getProcessEngineServices();\r
List<HistoricVariableInstance> variables = engine.getHistoryService().createHistoricVariableInstanceQuery().processInstanceId(processInstanceId).list();\r
- Map<String,String> variablesMap = new HashMap<String,String>();\r
+ Map<String,String> variablesMap = new HashMap<>();\r
for (HistoricVariableInstance variableInstance: variables) {\r
variablesMap.put(variableInstance.getName(), variableInstance.getValue().toString());\r
}\r
\r
@ApplicationPath("/")\r
public class WorkflowResourceApplication extends Application {\r
- private Set<Object> singletons = new HashSet<Object>();\r
- private Set<Class<?>> classes = new HashSet<Class<?>>();\r
+ private Set<Object> singletons = new HashSet<>();\r
+ private Set<Class<?>> classes = new HashSet<>();\r
\r
public WorkflowResourceApplication() {\r
}\r
@JsonProperty("input")
private Input input;
@JsonIgnore
- private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+ private Map<String, Object> additionalProperties = new HashMap<>();
private final static long serialVersionUID = 9101706044452851559L;
@JsonProperty("input")
private RequestHealthDiagnostic RequestHealthDiagnostic;
@JsonIgnore
- private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+ private Map<String, Object> additionalProperties = new HashMap<>();
private final static long serialVersionUID = 7155546785389227528L;
@JsonProperty("request-healthdiagnostic")
@JsonProperty("health-diagnostic-code")
private String healthDiagnosticCode;
@JsonIgnore
- private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+ private Map<String, Object> additionalProperties = new HashMap<>();
private final static long serialVersionUID = 1166788526178388021L;
@JsonProperty("request-client-name")
@JsonProperty("status")
private String status;
@JsonIgnore
-private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+private Map<String, Object> additionalProperties = new HashMap<>();
@JsonProperty("client-name")
public String getClientName() {
@JsonProperty("body")
private Body body;
@JsonIgnore
- private Map<String, Object> additionalProperties = new HashMap<String, Object>();
+ private Map<String, Object> additionalProperties = new HashMap<>();
private final static long serialVersionUID = -5303297382564282650L;
@JsonProperty("operation")
\r
\r
private static void buildVariable(String key, String value, Map<String,Object> variableValueType) {\r
- Map<String, Object> host = new HashMap<String, Object>();\r
+ Map<String, Object> host = new HashMap<>();\r
host.put("value", value);\r
host.put("type", "String");\r
variableValueType.put(key, host);\r
WorkflowResource workflowResource = new WorkflowResource();\r
VariableMapImpl variableMap = new VariableMapImpl();\r
\r
- Map<String, Object> variableValueType = new HashMap<String, Object>();\r
+ Map<String, Object> variableValueType = new HashMap<>();\r
for (String key : variables.keySet()) {\r
buildVariable(key, variables.get(key), variableValueType);\r
}\r
WorkflowAsyncResource workflowResource = new WorkflowAsyncResource();\r
VariableMapImpl variableMap = new VariableMapImpl();\r
\r
- Map<String, Object> variableValueType = new HashMap<String, Object>();\r
+ Map<String, Object> variableValueType = new HashMap<>();\r
for (String key : variables.keySet()) {\r
buildVariable(key, variables.get(key), variableValueType);\r
}\r
mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");\r
\r
//String changeFeatureActivateRequest = FileUtil.readResourceFile("__files/SDN-ETHERNET-INTERNET/ChangeFeatureActivateV1/" + inputRequestFile);\r
- Map<String, String> variables = new HashMap<String, String>(); \r
+ Map<String, String> variables = new HashMap<>();\r
variables.put("CompleteMsoProcessRequest",inputRequestFile);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "CompleteMsoProcess", variables);\r
System.out.println("Before starting process");
RuntimeService runtimeService = processEngineRule.getRuntimeService();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("isDebugLogEnabled","true");
variables.put("ConfirmVolumeGroupName_volumeGroupId", "VOLUME_GROUP_ID_1");
variables.put("ConfirmVolumeGroupName_volumeGroupName", "VOLUME_GROUP_ID_1_NAME");
System.out.println("Before starting process");
RuntimeService runtimeService = processEngineRule.getRuntimeService();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("isDebugLogEnabled","true");
variables.put("ConfirmVolumeGroupName_volumeGroupId", "VOLUME_GROUP_ID_THAT_DOES_NOT_EXIST");
variables.put("ConfirmVolumeGroupName_volumeGroupName", "cee6d136-e378-4678-a024-2cd15f0ee0cg");
System.out.println("Before starting process");
RuntimeService runtimeService = processEngineRule.getRuntimeService();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("isDebugLogEnabled","true");
variables.put("ConfirmVolumeGroupName_volumeGroupId", "VOLUME_GROUP_ID_1");
variables.put("ConfirmVolumeGroupName_volumeGroupName", "BAD_VOLUME_GROUP_NAME");
public void testRemoveLayer3Service_success() throws Exception{
MockGetVolumeGroupById("MDTWNJ21", "a8399879-31b3-4973-be26-0a0cbe776b58", "CRTGVNF_queryAAIResponseVolume.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables);
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "ConfirmVolumeGroupTenant", variables);
public void testRemoveLayer3Service_idsNotMatch() throws Exception{
MockGetVolumeGroupById("MDTWNJ21", "a8399879-31b3-4973-be26-0a0cbe776b58", "CRTGVNF_queryAAIResponseVolume_idsNotMatch.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables);
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "ConfirmVolumeGroupTenant", variables);
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("isVidRequest", "false");\r
variables.put("vnfName", "STMTN5MMSC22");\r
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("isVidRequest", "false");\r
variables.put("vnfId", "a27ce5a9-29c4-4c22-a017-6615ac73c721");\r
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true"); \r
variables.put("isVidRequest", "false");\r
variables.put("vnfName", "STMTN5MMSC23");\r
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true"); \r
variables.put("isVidRequest", "false");\r
variables.put("vnfName", "STMTN5MMSC21");\r
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true"); \r
variables.put("isVidRequest", "false");\r
variables.put("vnfId", "2f6aee38-1e2a-11e6-82d1-ffc7d9ee8aa4");\r
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true"); \r
variables.put("isVidRequest", "false");\r
variables.put("vnfName", "STMTN5MMSC22");\r
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true"); \r
variables.put("isVidRequest", "false");\r
variables.put("vnfId", "768073c7-f41f-4822-9323-b75962763d74");\r
MockAAICreateGenericVnf();\r
MockAAIVfModulePUT(true);\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true"); \r
variables.put("isVidRequest", "false");\r
variables.put("vnfId", "a27ce5a9-29c4-4c22-a017-6615ac73c721");\r
MockPutVfModuleIdNoResponse("skask", "PCRF", "lukewarm");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("CreateAAIVfModuleVolumeGroupRequest", updateAAIVfModuleRequest);\r
MockGetVfModuleId("skask", ".*", "VfModularity/VfModule-supercool.xml", 404);\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("CreateAAIVfModuleVolumeGroupRequest", updateAAIVfModuleRequest);\r
MockGetVfModuleId("skask", "lukewarm", "VfModularity/VfModule-lukewarm.xml", 200);\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("CreateAAIVfModuleVolumeGroupRequest", updateAAIVfModuleRequest);\r
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariablesSuccess(variables, "testRequestId123", "ff5256d2-5a33-55df-13ab-12abad84e7ff");
invokeSubProcess("DecomposeService", businessKey, variables);
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariablesSuccess(variables, "testRequestId123", "ff5256d2-5a33-55df-13ab-12abad84e7ff");
invokeSubProcess("DecomposeService", businessKey, variables);
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest","<vnf-request xmlns=\"http://openecomp.org/mso/infra/vnf-request/v1\"> <request-info> <action>DELETE_VF_MODULE</action> <source>PORTAL</source> </request-info> <vnf-inputs> <vnf-id>a27ce5a9-29c4-4c22-a017-6615ac73c721</vnf-id> <vnf-name>STMTN5MMSC21</vnf-name> <vf-module-id>973ed047-d251-4fb9-bf1a-65b8949e0a73</vf-module-id> <vf-module-name>STMTN5MMSC21-MMSC::module-0-0</vf-module-name> </vnf-inputs> <vnf-params xmlns:tns=\"http://openecomp.org/mso/infra/vnf-request/v1\"/> </vnf-request>");\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest",request);\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest",request);\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest",request);\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest",request);\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest",request);\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest",request);\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
MockAAIDeleteGenericVnf();\r
MockAAIDeleteVfModule();\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("DeleteAAIVfModuleRequest","<vnf-request xmlns=\"http://openecomp.org/mso/infra/vnf-request/v1\"> <request-info> <action>DELETE_VF_MODULE</action> <source>PORTAL</source> </request-info> <vnf-inputs> <vnf-id>a27ce5a9-29c4-4c22-a017-6615ac73c720</vnf-id> <vnf-name>STMTN5MMSC20</vnf-name> <vf-module-id>973ed047-d251-4fb9-bf1a-65b8949e0a76</vf-module-id> <vf-module-name>STMTN5MMSC20-MMSC::module-2-0</vf-module-name> </vnf-inputs> <vnf-params xmlns:tns=\"http://openecomp.org/mso/infra/vnf-request/v1\"/> </vnf-request>");\r
runtimeService.startProcessInstanceByKey("DeleteAAIVfModule", variables);\r
System.out.println("STARTED TEST: " + method);\r
\r
//String changeFeatureActivateRequest = FileUtil.readResourceFile("__files/SDN-ETHERNET-INTERNET/ChangeFeatureActivateV1/" + inputRequestFile);\r
- Map<String, String> variables = new HashMap<String, String>(); \r
+ Map<String, String> variables = new HashMap<>();\r
variables.put("FalloutHandlerRequest",inputRequestFile);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "FalloutHandler", variables);\r
@Deployment(resources = {"subprocess/GenericDeleteService.bpmn"})
public void testGenericDeleteService_success_serviceInstance() throws Exception{
MockDeleteServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET", "1234");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", "1604-MVM-26", "SDN-ETHERNET-INTERNET", "1234");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
waitForWorkflowToFinish(processEngineRule, workflowResponse.getProcessInstanceID());
MockDeleteServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "1234", 204);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesSubscription(variables, "", "1604-MVM-26", "SDN-ETHERNET-INTERNET", "1234");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
MockGetServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceSubscription.xml");
MockDeleteServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET", "1234");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", "1604-MVM-26", "SDN-ETHERNET-INTERNET", null);
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
MockGetServiceSubscription("1604-MVM-26", "SDN-ETHERNET-INTERNET", "GenericFlows/getServiceSubscription.xml");
MockDeleteServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "1234", 204);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesSubscription(variables, null, "1604-MVM-26", "SDN-ETHERNET-INTERNET", null);
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
MockGetServiceInstance_404("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", "1604-MVM-26", "SDN-ETHERNET-INTERNET", null);
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
public void testGenericDeleteService_success_subscriptionGetEmpty200() throws Exception{
MockGetServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "1234", 200);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesSubscription(variables, "", "1604-MVM-26", "SDN-ETHERNET-INTERNET", "");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
MockGetServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET", "GENDSI_getServiceInstanceResponse.xml");
MockDeleteServiceInstance_404("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET", "1234");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", "1604-MVM-26", "SDN-ETHERNET-INTERNET", "1234");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
@Deployment(resources = {"subprocess/GenericDeleteService.bpmn"})
public void testGenericDeleteService_error_invalidVariables() throws Exception{
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, "SDN-ETHERNET-INTERNET", "1234");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
MockGetServiceInstance_500("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET", "aaiFault.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", "1604-MVM-26", "SDN-ETHERNET-INTERNET", null);
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteService", variables);
public void testGenericDeleteVnf_success_genericVnf() throws Exception{
MockDeleteGenericVnf("testVnfId123", "testReVer123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "generic-vnf", "testReVer123");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
public void testGenericDeleteVnf_success_vce() throws Exception{
MockDeleteVce("testVnfId123", "testReVer123", 204);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "vce", "testReVer123");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
MockGetGenericVnfById("/testVnfId123", "GenericFlows/getGenericVnfByNameResponse.xml", 200);
MockDeleteGenericVnf("testVnfId123", "testReVer123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "generic-vnf", "");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
MockDeleteVce("testVnfId123", "testReVer123", 204);
MockGetVceById("testVnfId123", "GenericFlows/getVceResponse.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "vce", null);
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
public void testGenericDeleteVnf_success_genericVnf404() throws Exception{
MockDeleteGenericVnf("testVnfId123", "testReVer123", 404);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "generic-vnf", "testReVer123");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
public void testGenericDeleteVnf_success_vce404() throws Exception{
MockDeleteVce("testVnfId123", "testReVer123", 404);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "vce", "testReVer123");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
public void testGenericDeleteVnf_success_genericVnfNoResourceVersion404() throws Exception{
MockGetGenericVnfById_404("testVnfId123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "generic-vnf", "");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
@Deployment(resources = {"subprocess/GenericDeleteVnf.bpmn"})
public void testGenericDeleteVnf_error_missingVariables() throws Exception{
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "", "testReVer123");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
public void testGenericDeleteVnf_error_genericVnf500() throws Exception{
MockDeleteGenericVnf_500("testVnfId123", "testReVer123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "generic-vnf", "testReVer123");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
public void testGenericDeleteVnf_error_genericVnf412() throws Exception{
MockDeleteGenericVnf("testVnfId123", "testReVer123", 412);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "generic-vnf", "testReVer123");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericDeleteVnf", variables);
@Deployment(resources = {"subprocess/GenericGetService.bpmn"})\r
public void testGenericGetService_success_serviceInstance() throws Exception{\r
MockGetServiceInstance("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceInstance.xml");\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, "SDN-ETHERNET-INTERNET", "123456789");\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
waitForWorkflowToFinish(processEngineRule, workflowResponse.getProcessInstanceID());\r
\r
MockGetServiceSubscription("1604-MVM-26", "SDN-ETHERNET-INTERNET", "GenericFlows/getServiceSubscription.xml");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesSubscription(variables, "", null , "1604-MVM-26", "SDN-ETHERNET-INTERNET");\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
MockNodeQueryServiceInstanceByName("1604-MVM-26", "GenericFlows/getSIUrlByName.xml");\r
MockGetServiceInstance("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceInstance.xml");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, null, "1604-MVM-26", null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
MockNodeQueryServiceInstanceById("MIS%2F1604%2F0026%2FSW_INTERNET", "GenericFlows/getSIUrlById.xml");\r
MockGetServiceInstance("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceInstance.xml");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockGetServiceInstance_404("SDN-ETHERNET-INTERNET", "123456789", "MIS%2F1604%2F0026%2FSW_INTERNET");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, "SDN-ETHERNET-INTERNET", "123456789");\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
public void testGenericGetService_success_serviceSubscription404() throws Exception{\r
MockGetServiceSubscription("1604-MVM-26", "SDN-ETHERNET-INTERNET", 404);\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesSubscription(variables, "", "", "SDN-ETHERNET-INTERNET", "1604-MVM-26");\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockNodeQueryServiceInstanceByName_404("1604-MVM-26");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "", "1604-MVM-26", null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockNodeQueryServiceInstanceById_404("MIS%2F1604%2F0026%2FSW_INTERNET");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockGetServiceInstance("1604-MVM-26", "SDN-ETHERNET-INTERNET", "MIS%252F1604%252F0026%252FSW_INTERNET", " ");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, "SDN-ETHERNET-INTERNET", "123456789");\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
public void testGenericGetService_success_serviceInstanceByNameEmpty() throws Exception{\r
MockNodeQueryServiceInstanceByName("1604-MVM-26", "");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "", "1604-MVM-26", null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockNodeQueryServiceInstanceById("MIS[%]2F1604[%]2F0026[%]2FSW_INTERNET", "");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
@Deployment(resources = {"subprocess/GenericGetService.bpmn"})\r
public void testGenericGetService_error_serviceInstanceInvalidVariables() throws Exception{\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, null, null, "SDN-ETHERNET-INTERNET", null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
@Deployment(resources = {"subprocess/GenericGetService.bpmn"})\r
public void testGenericGetService_success_serviceSubscriptionInvalidVariables() throws Exception{\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesSubscription(variables, "", "", "SDN-ETHERNET-INTERNET", null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockGetServiceInstance_500("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", "1604-MVM-26", "SDN-ETHERNET-INTERNET", "123456789");\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockNodeQueryServiceInstanceById_500("MIS%2F1604%2F0026%2FSW_INTERNET");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, "MIS%2F1604%2F0026%2FSW_INTERNET", null, null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
\r
MockNodeQueryServiceInstanceByName_500("1604-MVM-26");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, null, "1604-MVM-26", null, null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
MockNodeQueryServiceInstanceByName("1604-MVM-26", "GenericFlows/getSIUrlByNameMultiCustomer.xml");\r
MockGetServiceInstance("XyCorporation", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceInstance.xml");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, null, "1604-MVM-26", "XyCorporation", null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
MockNodeQueryServiceInstanceByName("1604-MVM-26", "GenericFlows/getSIUrlByNameMultiCustomer.xml");\r
MockGetServiceInstance("CorporationNotPresent", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceInstance.xml");\r
\r
- Map<String, String> variables = new HashMap<String, String>();\r
+ Map<String, String> variables = new HashMap<>();\r
setVariablesInstance(variables, null, "1604-MVM-26", "CorporationNotPresent", null);\r
\r
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetService", variables);\r
public void testGenericGetVnf_success_genericVnf() throws Exception{
MockGetGenericVnfByIdWithDepth("testVnfId123", 1, "GenericFlows/getGenericVnfByNameResponse.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "testVnfName123", "generic-vnf");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetVnf", variables);
public void testGenericGetVnf_success_vce() throws Exception{
MockGetVceById("testVnfId123[?]depth=1", "GenericFlows/getVceResponse.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "testVnfName123", "vce");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetVnf", variables);
public void testGenericGetVnf_success_genericVnfByName() throws Exception{
MockGetGenericVnfByNameWithDepth("testVnfName123", 1, "GenericFlows/getGenericVnfResponse.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "", "testVnfName123", "generic-vnf");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetVnf", variables);
public void testGenericGetVnf_success_vceByName() throws Exception{
MockGetGenericVceByNameWithDepth("testVnfName123", 1, "GenericFlows/getVceByNameResponse.xml");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, null, "testVnfName123", "vce");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetVnf", variables);
MockGetGenericVnfById_500("testVnfId123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", "testVnfName123", "generic-vnf");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericGetVnf", variables);
MockPutGenericVnf("testVnfId123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", genericVnfPayload, "generic-vnf");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericPutVnf", variables);
MockPutVce("testVnfId123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", vcePayload, "vce");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericPutVnf", variables);
MockPutGenericVnf("testVnfId123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", genericVnfPayload, "");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericPutVnf", variables);
MockPutGenericVnf("testVnfId123");
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", genericVnfPayload, "");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericPutVnf", variables);
@Deployment(resources = {"subprocess/GenericPutVnf.bpmn"})
public void testGenericPutVnf_error_404() throws Exception{
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", genericVnfPayload, "generic-vnf");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericPutVnf", variables);
MockPutGenericVnf("/testVnfId123", 400);
- Map<String, String> variables = new HashMap<String, String>();
+ Map<String, String> variables = new HashMap<>();
setVariables(variables, "testVnfId123", genericVnfPayload, "generic-vnf");
WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "GenericPutVnf", variables);
mockSNIRO();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariables(variables);
invokeSubProcess("Homing", businessKey, variables);
mockSNIRO();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariables2(variables);
invokeSubProcess("Homing", businessKey, variables);
//System.out.println("At start of testHoming_success_vnfResourceList");
MockGetServiceResourcesCatalogData("1cc4e2e4-eb6e-404d-a66f-c8733cedcce8", "5.0", "/BuildingBlocks/catalogResp.json");
String busKey = UUID.randomUUID().toString();
- Map<String, Object> vars = new HashMap<String, Object>();
+ Map<String, Object> vars = new HashMap<>();
setVariablesForServiceDecomposition(vars, "testRequestId123", "ff5256d2-5a33-55df-13ab-12abad84e7ff");
invokeSubProcess("DecomposeService", busKey, vars);
mockSNIRO();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("isDebugLogEnabled", "true");
variables.put("msoRequestId", "testRequestId");
variables.put("serviceInstanceId", "testServiceInstanceId");
public void testHoming_error_inputVariable() throws Exception {
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariables3(variables);
invokeSubProcess("Homing", businessKey, variables);
mockSNIRO_500();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariables(variables);
invokeSubProcess("Homing", businessKey, variables);
mockSNIRO();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariables(variables);
invokeSubProcess("Homing", businessKey, variables);
mockSNIRO();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariables(variables);
invokeSubProcess("Homing", businessKey, variables);
mockSNIRO();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
setVariables(variables);
invokeSubProcess("Homing", businessKey, variables);
public void TestManualHandlingSuccess() {
RuntimeService runtimeService = processEngineRule.getRuntimeService();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("isDebugLogEnabled","true");
variables.put("msoRequestId", "testRequestId");
variables.put("serviceType", "X");
System.out.println("TASK NAME: " + task.getName());
try {
System.out.println("Completing the task");
- Map<String,Object> completeVariables = new HashMap<String,Object>();
+ Map<String,Object> completeVariables = new HashMap<>();
completeVariables.put("responseValue", "skip");
taskService.complete(task.getId(), completeVariables);
}
MockPatchVfModuleId("skask", "supercool");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("PrepareUpdateAAIVfModuleRequest", prepareUpdateAAIVfModuleRequest);\r
MockGetGenericVnfById_404("skask[?]depth=1");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("PrepareUpdateAAIVfModuleRequest", prepareUpdateAAIVfModuleRequest);\r
MockGetGenericVnfByIdWithDepth("skask", 1, "VfModularity/GenericVnf.xml");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("PrepareUpdateAAIVfModuleRequest", prepareUpdateAAIVfModuleRequest);\r
MockGetGenericVnfByIdWithDepth("skask", 1, "VfModularity/GenericVnf.xml"); \r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("PrepareUpdateAAIVfModuleRequest", prepareUpdateAAIVfModuleRequest);\r
MockAAIVfModuleBadPatch("/aai/v[0-9]+/network/generic-vnfs/generic-vnf/skask/vf-modules/vf-module/supercool", 404);\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("PrepareUpdateAAIVfModuleRequest", prepareUpdateAAIVfModuleRequest);\r
public void TestRainyDayHandlingSuccess() {\r
\r
RuntimeService runtimeService = processEngineRule.getRuntimeService(); \r
- Map<String, Object> variables = new HashMap<String, Object>(); \r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("isDebugLogEnabled","true");\r
variables.put("msoRequestId", "testRequestId");\r
variables.put("serviceType", "X");\r
logStart();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", "dffbae0e-5588-4bd6-9749-b0f0adb52312");
variables.put("isDebugLogEnabled", "true");
variables.put("RCVWFMSG_timeout", "PT1M");
logStart();
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", "dffbae0e-5588-4bd6-9749-b0f0adb52312");
variables.put("isDebugLogEnabled", "true");
variables.put("RCVWFMSG_timeout", "PT0.1S");
\r
private WorkflowResponse invokeFlow(String workflowRequest) {\r
\r
- Map<String, Object>valueMap = new HashMap<String, Object>();\r
+ Map<String, Object>valueMap = new HashMap<>();\r
valueMap.put("value", workflowRequest);\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("sdncAdapterWorkflowRequest", valueMap);\r
\r
- Map<String, Object> valueMap2 = new HashMap<String, Object>();\r
+ Map<String, Object> valueMap2 = new HashMap<>();\r
valueMap2.put("value", "true");\r
variables.put("isDebugLogEnabled", valueMap2);\r
\r
MockPatchGenericVnf("skask");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("UpdateAAIGenericVnfRequest", updateAAIGenericVnfRequest);\r
MockGetGenericVnfByIdWithDepth("skask", 1, "VfModularity/GenericVnf.xml");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("UpdateAAIGenericVnfRequest", updateAAIGenericVnfRequest);\r
MockGetGenericVnfById_404("skask[?]depth=1");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("UpdateAAIGenericVnfRequest", updateAAIGenericVnfRequest);\r
MockAAIVfModuleBadPatch("/aai/v[0-9]+/network/generic-vnfs/generic-vnf/skask", 404);\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("UpdateAAIGenericVnfRequest", updateAAIGenericVnfRequest);\r
MockPatchVfModuleId("skask", "supercool");\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("UpdateAAIVfModuleRequest", updateAAIVfModuleRequest);\r
MockGetGenericVnfById("/skask/vf-modules/vf-module/.*", "VfModularity/VfModule-supercool.xml", 404);\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("UpdateAAIVfModuleRequest", updateAAIVfModuleRequest);\r
MockAAIVfModuleBadPatch("/aai/v[0-9]+/network/generic-vnfs/generic-vnf/skask/vf-modules/vf-module/supercool", 404);\r
\r
String businessKey = UUID.randomUUID().toString();\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
variables.put("mso-request-id", "999-99-9999");\r
variables.put("isDebugLogEnabled","true");\r
variables.put("UpdateAAIVfModuleRequest", updateAAIVfModuleRequest);\r
String request = CREATE_VF_MODULE_REQUEST.replace("{{MESSAGE-ID}}", messageId);
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", requestId);
variables.put("isDebugLogEnabled", "true");
variables.put("vnfAdapterRestV1Request", request);
String request = UPDATE_VF_MODULE_REQUEST.replace("{{MESSAGE-ID}}", messageId);
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", requestId);
variables.put("isDebugLogEnabled", "true");
variables.put("vnfAdapterRestV1Request", request);
String request = DELETE_VF_MODULE_REQUEST.replace("{{MESSAGE-ID}}", messageId);
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", requestId);
variables.put("isDebugLogEnabled", "true");
variables.put("vnfAdapterRestV1Request", request);
String request = ROLLBACK_VF_MODULE_REQUEST.replace("{{MESSAGE-ID}}", messageId);
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", requestId);
variables.put("isDebugLogEnabled", "true");
variables.put("vnfAdapterRestV1Request", request);
String request = CREATE_VF_MODULE_REQUEST.replace("{{MESSAGE-ID}}", messageId);
String businessKey = UUID.randomUUID().toString();
- Map<String, Object> variables = new HashMap<String, Object>();
+ Map<String, Object> variables = new HashMap<>();
variables.put("mso-request-id", requestId);
variables.put("isDebugLogEnabled", "true");
variables.put("vnfAdapterRestV1Request", request);
//it can be any request which asynchronously processed by the workflow
String request = "<aetgt:CreateTenantRequest xmlns:aetgt=\"http://org.openecomp/mso/workflow/schema/v1\" xmlns:sdncadapterworkflow=\"http://org.openecomp/mso/workflow/schema/v1\" xmlns:ns5=\"http://org.openecomp/mso/request/types/v1\"> <msoservtypes:service-information xmlns:msoservtypes=\"http://org.openecomp/mso/request/types/v1\"> <msoservtypes:service-type>SDN-ETHERNET-INTERNET</msoservtypes:service-type> <msoservtypes:service-instance-id>HI/VLXM/950604//SW_INTERNET</msoservtypes:service-instance-id> <msoservtypes:subscriber-name>SubName01</msoservtypes:subscriber-name> </msoservtypes:service-information> </aetgt:CreateTenantRequest>";
- Map<String,String> variables = new HashMap<String,String>();
+ Map<String,String> variables = new HashMap<>();
variables.put("testAsyncRequestMsg", request);
variables.put("mso-request-id", UUID.randomUUID().toString());
variables.put("mso-service-request-timeout", "5");
WorkflowAsyncResource workflowResource = new WorkflowAsyncResource();
VariableMapImpl variableMap = new VariableMapImpl();
- Map<String, Object> variableValueType = new HashMap<String, Object>();
+ Map<String, Object> variableValueType = new HashMap<>();
- Map<String, Object> requestMsg = new HashMap<String, Object>();
+ Map<String, Object> requestMsg = new HashMap<>();
requestMsg.put("value", request);
requestMsg.put("type", "String");
- Map<String, Object> msorequestId = new HashMap<String, Object>();
+ Map<String, Object> msorequestId = new HashMap<>();
msorequestId.put("type", "String");
msorequestId.put("value",requestId);
- Map<String, Object> timeout = new HashMap<String, Object>();
+ Map<String, Object> timeout = new HashMap<>();
timeout.put("type", "String");
timeout.put("value","5");
String businessKey, String request, Map<String, Object> injectedVariables,\r
boolean serviceInstantiationModel) {\r
\r
- Map<String, Object> variables = new HashMap<String, Object>();\r
+ Map<String, Object> variables = new HashMap<>();\r
\r
// These variables may be overridded by injected variables.\r
variables.put("mso-service-request-timeout", "180");\r
* @return a VariableMap\r
*/\r
private VariableMapImpl createVariableMapImpl(Map<String, Object> variables) {\r
- Map<String, Object> wrappedVariables = new HashMap<String, Object>();\r
+ Map<String, Object> wrappedVariables = new HashMap<>();\r
\r
for (String key : variables.keySet()) {\r
Object value = variables.get(key);\r
* @return the wrapped variable\r
*/\r
private Map<String, Object> wrapVariableValue(Object value) {\r
- HashMap<String, Object> valueMap = new HashMap<String, Object>();\r
+ HashMap<String, Object> valueMap = new HashMap<>();\r
valueMap.put("value", value);\r
return valueMap;\r
}\r
return null;\r
}\r
\r
- processInstanceList.sort(new Comparator<HistoricProcessInstance>() {\r
- public int compare(HistoricProcessInstance m1, HistoricProcessInstance m2) {\r
- return m1.getStartTime().compareTo(m2.getStartTime());\r
- }\r
- });\r
+ processInstanceList.sort((m1, m2) -> m1.getStartTime().compareTo(m2.getStartTime()));\r
\r
HistoricProcessInstance processInstance = processInstanceList.get(0);\r
\r
return null;\r
}\r
\r
- processInstanceList.sort(new Comparator<HistoricProcessInstance>() {\r
- public int compare(HistoricProcessInstance m1, HistoricProcessInstance m2) {\r
- return m1.getStartTime().compareTo(m2.getStartTime());\r
- }\r
- });\r
+ processInstanceList.sort((m1, m2) -> m1.getStartTime().compareTo(m2.getStartTime()));\r
\r
HistoricProcessInstance processInstance = processInstanceList.get(subflowInstanceIndex);\r
\r
* An object that contains callback data for a "program".\r
*/\r
public class CallbackSet {\r
- private final Map<String, CallbackData> map = new HashMap<String, CallbackData>();\r
+ private final Map<String, CallbackData> map = new HashMap<>();\r
\r
/**\r
* Add untyped callback data to the set.\r
* A NamespaceContext class based on a Map.\r
*/\r
private class SimpleNamespaceContext implements NamespaceContext {\r
- private Map<String, String> prefixMap = new HashMap<String, String>();\r
- private Map<String, String> uriMap = new HashMap<String, String>();\r
+ private Map<String, String> prefixMap = new HashMap<>();\r
+ private Map<String, String> uriMap = new HashMap<>();\r
\r
public synchronized void add(String prefix, String uri) {\r
prefixMap.put(prefix, uri);\r
\r
@Override\r
public Iterator<String> getPrefixes(String uri) {\r
- List<String> list = new ArrayList<String>();\r
+ List<String> list = new ArrayList<>();\r
String prefix = uriMap.get(uri);\r
if (prefix != null) {\r
list.add(prefix);\r
private boolean started = false;
private final Integer defaultPort = 28090;
private WireMockServer wireMockServer = null;
- private static Map<String,String> mockProperties = new HashMap<String,String>();
+ private static Map<String,String> mockProperties = new HashMap<>();
public static String getMockProperties(String key) {
return mockProperties.get(key);
@ApplicationPath("/console")
public class MockResourceApplication extends Application {
- private Set<Object> singletons = new HashSet<Object>();
- private Set<Class<?>> classes = new HashSet<Class<?>>();
+ private Set<Object> singletons = new HashSet<>();
+ private Set<Class<?>> classes = new HashSet<>();
public MockResourceApplication() {
singletons.add(new MockResource());
BPMNLogger.debug(healthcheckDebugEnabled, "Post url is: " + url);
//now create a soap request message as follows:
- final StringBuffer payload = new StringBuffer();
+ final StringBuilder payload = new StringBuilder();
payload.append("\n");
payload.append("<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:req=\"" + adapterNamespace + "/requestsdb\">\n");
payload.append("<soapenv:Header/>\n");
BufferedReader rd = new BufferedReader(
new InputStreamReader(response.getEntity().getContent()));
- StringBuffer result = new StringBuffer();
+ StringBuilder result = new StringBuilder();
String line = "";
while ((line = rd.readLine()) != null) {
result.append(line);
*/\r
@JsonIgnore\r
public String getServiceResourcesJsonString(){\r
- StringBuffer serviceResourcesJsonStringBuffer = new StringBuffer();\r
+ StringBuilder serviceResourcesJsonStringBuffer = new StringBuilder();\r
serviceResourcesJsonStringBuffer.append(listToJson((this.getServiceNetworks())));\r
serviceResourcesJsonStringBuffer.append(listToJson((this.getServiceVnfs())));\r
serviceResourcesJsonStringBuffer.append(listToJson((this.getServiceAllottedResources())));\r
* @return String containing the XML translation\r
*/\r
public static String toXMLString(Object obj, String tagName) throws JSONException {\r
- StringBuffer strBuf = new StringBuffer();\r
+ StringBuilder strBuf = new StringBuilder();\r
int i;\r
JSONArray jsonArr;\r
JSONObject jsonObj;\r
private static final Map<String, Integer> ENTITIES = new HashMap<>();
private static final MsoLogger LOGGER = MsoLogger.getMsoLogger (MsoLogger.Catalog.BPEL);
static {
- ENTITIES.put("amp", new Integer(38));
- ENTITIES.put("quot", new Integer(34));
- ENTITIES.put("lt", new Integer(60));
- ENTITIES.put("gt", new Integer(62));
+ ENTITIES.put("amp", 38);
+ ENTITIES.put("quot", 34);
+ ENTITIES.put("lt", 60);
+ ENTITIES.put("gt", 62);
}
/**
@Override
public String toString() {
- StringBuffer response = new StringBuffer();
+ StringBuilder response = new StringBuilder();
response.append("Config file " + propertiesFileName + "(Timer:" + automaticRefreshInMinutes + "mins):"
+ System.getProperty("line.separator"));
response.append(this.jsonRootNode.toString());
}
public static String byteArrayToHexString (byte[] b) {
- StringBuffer sb = new StringBuffer (b.length * 2);
- for (int i = 0; i < b.length; i++) {
- int v = b[i] & 0xff;
+ StringBuilder sb = new StringBuilder(b.length * 2);
+ for (byte aB : b) {
+ int v = aB & 0xff;
if (v < 16) {
- sb.append ('0');
+ sb.append('0');
}
- sb.append (Integer.toHexString (v));
+ sb.append(Integer.toHexString(v));
}
return sb.toString ().toUpperCase ();
}
if ((status == Status.FAILED) || (status == Status.COMPLETE)) {
aq.setStatusMessage (this.errorMessage);
aq.setResponseBody (this.responseBody);
- aq.setProgress(new Long(100));
+ aq.setProgress(100L);
Timestamp endTimeStamp = new Timestamp (System.currentTimeMillis());
aq.setEndTime (endTimeStamp);
private String translateNetworkRequests (List <NetworkRequest> queryResponseList) {
NetworkRequests queryResponses = new NetworkRequests ();
- for (int i = 0; i < queryResponseList.size (); i++) {
- queryResponses.getNetworkRequest ().add (queryResponseList.get (i));
+ for (NetworkRequest aQueryResponseList : queryResponseList) {
+ queryResponses.getNetworkRequest().add(aQueryResponseList);
}
StringWriter stringWriter = new StringWriter ();
private String translateNetworkRequests (List <NetworkRequest> queryResponseList) {
NetworkRequests queryResponses = new NetworkRequests ();
- for (int i = 0; i < queryResponseList.size (); i++) {
- queryResponses.getNetworkRequest ().add (queryResponseList.get (i));
+ for (NetworkRequest aQueryResponseList : queryResponseList) {
+ queryResponses.getNetworkRequest().add(aQueryResponseList);
}
StringWriter stringWriter = new StringWriter ();
ObjectFactory beansObjectFactory = new ObjectFactory ();
NetworkTypes networkTypes = beansObjectFactory.createNetworkTypes ();
- for (int i = 0; i < networkResources.size (); i++) {
- NetworkType networkType = beansObjectFactory.createNetworkType ();
- NetworkResource vr = networkResources.get (i);
- networkType.setType (vr.getModelName());
- networkType.setDescription (vr.getDescription ());
- networkType.setId (String.valueOf (vr.getModelUUID()));
- networkTypes.getNetworkType ().add (networkType);
+ for (NetworkResource networkResource : networkResources) {
+ NetworkType networkType = beansObjectFactory.createNetworkType();
+ NetworkResource vr = networkResource;
+ networkType.setType(vr.getModelName());
+ networkType.setDescription(vr.getDescription());
+ networkType.setId(String.valueOf(vr.getModelUUID()));
+ networkTypes.getNetworkType().add(networkType);
}
StringWriter stringWriter = new StringWriter ();
ObjectFactory beansObjectFactory = new ObjectFactory ();
VfModuleModelNames vfModuleModelNames = beansObjectFactory.createVfModuleModelNames ();
- for (int i = 0; i < vfModules.size (); i++) {
- VfModuleModelName vfModuleModelName = beansObjectFactory.createVfModuleModelName ();
- VfModule vm = vfModules.get (i);
- vfModuleModelName.setModelName (vm.getModelName ());
- vfModuleModelName.setModelVersion (vm.getVersion ());
- vfModuleModelName.setModelInvariantUuid (vm.getModelInvariantUuid ());
+ for (VfModule vfModule : vfModules) {
+ VfModuleModelName vfModuleModelName = beansObjectFactory.createVfModuleModelName();
+ VfModule vm = vfModule;
+ vfModuleModelName.setModelName(vm.getModelName());
+ vfModuleModelName.setModelVersion(vm.getVersion());
+ vfModuleModelName.setModelInvariantUuid(vm.getModelInvariantUuid());
vfModuleModelName.setIsBase(vm.isBase());
- vfModuleModelName.setDescription (vm.getDescription ());
- vfModuleModelName.setId (String.valueOf (vm.getModelUUID()));
- vfModuleModelName.setAsdcServiceModelVersion(vm.getVersion ());
- vfModuleModelNames.getVfModuleModelName ().add (vfModuleModelName);
+ vfModuleModelName.setDescription(vm.getDescription());
+ vfModuleModelName.setId(String.valueOf(vm.getModelUUID()));
+ vfModuleModelName.setAsdcServiceModelVersion(vm.getVersion());
+ vfModuleModelNames.getVfModuleModelName().add(vfModuleModelName);
}
StringWriter stringWriter = new StringWriter ();
private String translateVnfRequests (List <VnfRequest> queryResponseList) {
VnfRequests queryResponses = new VnfRequests ();
- for (int i = 0; i < queryResponseList.size (); i++) {
- queryResponses.getVnfRequest ().add (queryResponseList.get (i));
+ for (VnfRequest aQueryResponseList : queryResponseList) {
+ queryResponses.getVnfRequest().add(aQueryResponseList);
}
StringWriter stringWriter = new StringWriter ();
private String translateVnfRequests (List <VnfRequest> queryResponseList) {
VnfRequests queryResponses = new VnfRequests ();
- for (int i = 0; i < queryResponseList.size (); i++) {
- queryResponses.getVnfRequest ().add (queryResponseList.get (i));
+ for (VnfRequest aQueryResponseList : queryResponseList) {
+ queryResponses.getVnfRequest().add(aQueryResponseList);
}
StringWriter stringWriter = new StringWriter ();
ObjectFactory beansObjectFactory = new ObjectFactory ();
VnfTypes vnfTypes = beansObjectFactory.createVnfTypes ();
- for (int i = 0; i < vnfResources.size (); i++) {
- VnfType vnfType = beansObjectFactory.createVnfType ();
- VnfResource vr = vnfResources.get (i);
- vnfType.setDescription (vr.getDescription ());
- vnfType.setId (String.valueOf (vr.getModelUuid()));
- vnfTypes.getVnfType ().add (vnfType);
+ for (VnfResource vnfResource : vnfResources) {
+ VnfType vnfType = beansObjectFactory.createVnfType();
+ VnfResource vr = vnfResource;
+ vnfType.setDescription(vr.getDescription());
+ vnfType.setId(String.valueOf(vr.getModelUuid()));
+ vnfTypes.getVnfType().add(vnfType);
}
StringWriter stringWriter = new StringWriter ();
private String translateVolumeRequests (List <VolumeRequest> queryResponseList) {
VolumeRequests queryResponses = new VolumeRequests ();
- for (int i = 0; i < queryResponseList.size (); i++) {
- queryResponses.getVolumeRequest ().add (queryResponseList.get (i));
+ for (VolumeRequest aQueryResponseList : queryResponseList) {
+ queryResponses.getVolumeRequest().add(aQueryResponseList);
}
StringWriter stringWriter = new StringWriter ();
private String translateVolumeRequests (List <VolumeRequest> queryResponseList) {
VolumeRequests queryResponses = new VolumeRequests ();
- for (int i = 0; i < queryResponseList.size (); i++) {
- queryResponses.getVolumeRequest ().add (queryResponseList.get (i));
+ for (VolumeRequest aQueryResponseList : queryResponseList) {
+ queryResponses.getVolumeRequest().add(aQueryResponseList);
}
StringWriter stringWriter = new StringWriter ();
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Restrictions;
import org.openecomp.mso.db.AbstractSessionFactoryManager;
+import org.openecomp.mso.requestsdb.RequestsDbConstant.Status;
import org.openecomp.mso.requestsdb.RequestsDbSessionFactoryManager;
import org.openecomp.mso.logger.MsoLogger;
int resourceCount = lstResourceStatus.size();
int progress = 0;
boolean isFinished = true;
- for(int i = 0; i < resourceCount; i++) {
- progress = progress + Integer.valueOf(lstResourceStatus.get(i).getProgress()) / resourceCount;
- if(RequestsDbConstant.Status.PROCESSING.equals(lstResourceStatus.get(i).getStatus())) {
+ for (ResourceOperationStatus lstResourceStatu : lstResourceStatus) {
+ progress = progress + Integer.valueOf(lstResourceStatu.getProgress()) / resourceCount;
+ if (Status.PROCESSING.equals(lstResourceStatu.getStatus())) {
isFinished = false;
}
}
@Override
public String toString () {
- StringBuffer sb = new StringBuffer();
+ StringBuilder sb = new StringBuilder();
sb.append("modelCustomizationUuid=");
sb.append(this.modelCustomizationUuid);
sb.append(",modelInstanceName=");
@Override
public String toString () {
- StringBuffer buf = new StringBuffer();
+ StringBuilder buf = new StringBuilder();
buf.append("VFModule:");
buf.append("modelName=");
@Override
public String toString () {
- StringBuffer sb = new StringBuffer();
+ StringBuilder sb = new StringBuilder();
sb.append(super.toString());
sb.append (",vnfComponentParamXSD=" + vnfComponentParamXSD);
sb.append (",serviceType=" + getServiceType ());
@Override
public String toString () {
- StringBuffer sb = new StringBuffer();
+ StringBuilder sb = new StringBuilder();
sb.append(super.toString());
sb.append (",vnfParamXSD=" + vnfParamXSD);
sb.append (",serviceType=" + getServiceType ());
@Override
public String toString () {
- StringBuffer buf = new StringBuffer();
+ StringBuilder buf = new StringBuilder();
buf.append("VNF=");
buf.append(",modelVersion=");
Code Review / so.git / commitdiff