package org.onap.appc.listener.LCM.conv;
import static org.junit.Assert.assertEquals;
+import static org.onap.appc.listener.TestUtil.JSON_INPUT_BODY_STR;
+import static org.onap.appc.listener.TestUtil.JSON_OUTPUT_BODY_STR;
+import static org.onap.appc.listener.TestUtil.buildDmaapIncomingMessage;
+import static org.onap.appc.listener.TestUtil.buildDmaapOutgoingMessage;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JsonNode;
public class ConverterTest {
- private static final String jsonInputBodyStr =
- "{\"input\":{ \"common-header\": { \"timestamp\": \"2016-08-03T08:50:18.97Z\", "
- + "\"api-ver\": \"1\", \"originator-id\": \"1\", \"request-id\": \"123\", \"sub-request-id\": \"1\", "
- + "\"flags\": { \"force\":\"TRUE\", \"ttl\":\"9900\" } }, \"action\": \"Stop\", "
- + "\"action-identifiers\": { \"vnf-id\": \"TEST\" } }}";
-
- private static final String jsonOutputBodyStr =
- "{\"output\":{\"common-header\":{\"timestamp\":\"2016-08-03T08:50:18.97Z\","
- + "\"api-ver\":\"1\",\"flags\":{\"force\":\"TRUE\",\"ttl\":\"9900\"},\"sub-request-id\":\"1\","
- + "\"request-id\":\"123\",\"originator-id\":\"1\"},\"status\":{\"value\":\"TestException\",\"code\":200}}}";
-
- private static final String expectedDmaapOutgoingMessageAsJsonString = "{\"body\":{\"output\":{\"common-header\":"
- + "{\"timestamp\":\"2016-08-03T08:50:18.97Z\",\"api-ver\":\"1\",\"flags\":{\"force\":\"TRUE\",\"ttl\":\"9900\"},"
- + "\"sub-request-id\":\"1\",\"request-id\":\"123\",\"originator-id\":\"1\"},\"status\":"
- + "{\"value\":\"TestException\",\"code\":200}}},\"cambria.partition\":\"MSO\",\"rpc-name\":\"test\"}";
-
+ private static final String EXPECTED_DMAAP_OUTGOING_MESSAGE_AS_JSON_STRING =
+ "{\"body\":{\"output\":{\"common-header\":"
+ + "{\"timestamp\":\"2016-08-03T08:50:18.97Z\",\"api-ver\":\"1\",\"flags\":{\"force\":\"TRUE\",\"ttl\":\"9900\"},"
+ + "\"sub-request-id\":\"1\",\"request-id\":\"123\",\"originator-id\":\"1\"},\"locked\":\"test-locked\",\""
+ + "status\":{\"message\":\"test message\",\"code\":200}}},\"cambria.partition\":\"MSO\",\"rpc-name\":\"test\"}";
@Test(expected = IllegalArgumentException.class)
public void convertJsonNodeToDmaapOutgoingMessage_should_throw_when_given_null_arguments() {
message.setRpcName("test");
message.setCorrelationID("test-1");
message.setVersion("v1");
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_INPUT_BODY_STR);
message.setBody(jsonNode);
DmaapOutgoingMessage result = Converter.convertJsonNodeToDmaapOutgoingMessage(message, jsonNode);
DmaapOutgoingMessage message = new DmaapOutgoingMessage();
message.setRpcName("test");
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonOutputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_OUTPUT_BODY_STR);
message.setBody(jsonNode);
- assertEquals(expectedDmaapOutgoingMessageAsJsonString,
+ assertEquals(EXPECTED_DMAAP_OUTGOING_MESSAGE_AS_JSON_STRING,
Converter.convertDmaapOutgoingMessageToJsonString(message));
}
assertEquals(200L, statusCode.longValue());
}
- private DmaapIncomingMessage buildDmaapIncomingMessage() {
- DmaapIncomingMessage dmaapIncomingMessage = new DmaapIncomingMessage();
- dmaapIncomingMessage.setRpcName("test");
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
- dmaapIncomingMessage.setBody(jsonNode);
- return dmaapIncomingMessage;
-
- }
-
- private DmaapOutgoingMessage buildDmaapOutgoingMessage() {
- DmaapOutgoingMessage dmaapOutgoingMessage = new DmaapOutgoingMessage();
- dmaapOutgoingMessage.setRpcName("test");
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonOutputBodyStr);
- dmaapOutgoingMessage.setBody(jsonNode);
- return dmaapOutgoingMessage;
-
- }
}
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
+import static org.onap.appc.listener.TestUtil.JSON_OUTPUT_BODY_STR;
+import static org.onap.appc.listener.TestUtil.buildDmaapMessage;
import com.fasterxml.jackson.databind.JsonNode;
import org.junit.Test;
import org.onap.appc.exceptions.APPCException;
import org.onap.appc.listener.EventHandler;
-import org.onap.appc.listener.LCM.model.DmaapMessage;
import org.onap.appc.listener.LCM.operation.ProviderOperations;
import org.onap.appc.listener.util.Mapper;
public class WorkerImplTest {
- private static final String jsonInputBodyStr =
- "{\"input\":{ \"common-header\": { \"timestamp\": \"2016-08-03T08:50:18.97Z\", "
- + "\"api-ver\": \"1\", \"originator-id\": \"1\", \"request-id\": \"123\", \"sub-request-id\": \"1\", "
- + "\"flags\": { \"force\":\"TRUE\", \"ttl\":\"9900\" } }, \"action\": \"Stop\", "
- + "\"action-identifiers\": { \"vnf-id\": \"TEST\" } }}";
-
- private static final String jsonOutputBodyStr = "{\"output\":{\"common-header\":{\"timestamp\":\"2016-08-03T08:50:18.97Z\","
- + "\"api-ver\":\"1\",\"flags\":{\"force\":\"TRUE\",\"ttl\":\"9900\"},\"sub-request-id\":\"1\","
- + "\"request-id\":\"123\",\"originator-id\":\"1\"},\"status\":{\"value\":\"TestException\",\"code\":200}}}";
-
private EventHandler mockEventHandler = mock(EventHandler.class);
private ProviderOperations mockProviderOperations = mock(ProviderOperations.class);
@Test
public void should_post_message_to_dmaap_on_successful_run() throws APPCException {
- JsonNode testOutputJsonNode = Mapper.toJsonNodeFromJsonString(jsonOutputBodyStr);
+ JsonNode testOutputJsonNode = Mapper.toJsonNodeFromJsonString(JSON_OUTPUT_BODY_STR);
when(mockProviderOperations.topologyDG(anyString(), any(JsonNode.class)))
.thenReturn(testOutputJsonNode);
verify(mockEventHandler).postStatus(anyString(), anyString());
}
-
-
- private DmaapMessage buildDmaapMessage() {
-
- DmaapMessage dmaapMessage = new DmaapMessage();
- dmaapMessage.setRpcName("test");
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
- dmaapMessage.setBody(jsonNode);
- return dmaapMessage;
- }
}
package org.onap.appc.listener.LCM.model;
import static org.junit.Assert.assertEquals;
+import static org.onap.appc.listener.TestUtil.JSON_INPUT_BODY_STR;
import com.fasterxml.jackson.databind.JsonNode;
import org.junit.Before;
public class DmaapIncomingMessageTest {
- private static final String jsonInputBodyStr =
- "{\"input\":{ \"common-header\": { \"timestamp\": \"2016-08-03T08:50:18.97Z\", "
- + "\"api-ver\": \"1\", \"originator-id\": \"1\", \"request-id\": \"123\", \"sub-request-id\": \"1\", "
- + "\"flags\": { \"force\":\"TRUE\", \"ttl\":\"9900\" } }, \"action\": \"Stop\", "
- + "\"action-identifiers\": { \"vnf-id\": \"TEST\" } }}";
-
private DmaapIncomingMessage dmaapIncomingMessage;
@Before
@Test
public void toString_should_return_valid_string_representation() {
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_INPUT_BODY_STR);
dmaapIncomingMessage.setVersion("test-version");
dmaapIncomingMessage.setType("test-type");
package org.onap.appc.listener.LCM.model;
import static org.junit.Assert.assertEquals;
+import static org.onap.appc.listener.TestUtil.JSON_INPUT_BODY_STR;
import com.fasterxml.jackson.databind.JsonNode;
import org.junit.Before;
public class DmaapMessageTest {
- private static final String jsonInputBodyStr =
- "{\"input\":{ \"common-header\": { \"timestamp\": \"2016-08-03T08:50:18.97Z\", "
- + "\"api-ver\": \"1\", \"originator-id\": \"1\", \"request-id\": \"123\", \"sub-request-id\": \"1\", "
- + "\"flags\": { \"force\":\"TRUE\", \"ttl\":\"9900\" } }, \"action\": \"Stop\", "
- + "\"action-identifiers\": { \"vnf-id\": \"TEST\" } }}";
-
private DmaapMessage dmaapMessage;
@Before
@Test
public void should_set_properties() {
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_INPUT_BODY_STR);
dmaapMessage.setVersion("test-version");
dmaapMessage.setType("test-type");
@Test
public void toString_should_return_valid_string_representation() {
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_INPUT_BODY_STR);
dmaapMessage.setVersion("test-version");
dmaapMessage.setType("test-type");
package org.onap.appc.listener.LCM.model;
import static org.junit.Assert.assertEquals;
+import static org.onap.appc.listener.TestUtil.JSON_INPUT_BODY_STR;
import com.fasterxml.jackson.databind.JsonNode;
import org.junit.Before;
public class DmaapOutgoingMessageTest {
- private static final String jsonInputBodyStr =
- "{\"input\":{ \"common-header\": { \"timestamp\": \"2016-08-03T08:50:18.97Z\", "
- + "\"api-ver\": \"1\", \"originator-id\": \"1\", \"request-id\": \"123\", \"sub-request-id\": \"1\", "
- + "\"flags\": { \"force\":\"TRUE\", \"ttl\":\"9900\" } }, \"action\": \"Stop\", "
- + "\"action-identifiers\": { \"vnf-id\": \"TEST\" } }}";
-
private DmaapOutgoingMessage dmaapOutgoingMessage;
@Before
@Test
public void toString_should_return_valid_string_representation() {
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_INPUT_BODY_STR);
dmaapOutgoingMessage.setVersion("test-version");
dmaapOutgoingMessage.setType("test-type");
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
+import static org.onap.appc.listener.TestUtil.buildActionIdentifiers;
+import static org.onap.appc.listener.TestUtil.buildCommonHeader;
-import java.util.HashMap;
-import java.util.Map;
import org.junit.Before;
import org.junit.Test;
}
- private CommonHeader buildCommonHeader() {
-
- CommonHeader commonHeader = new CommonHeader();
- commonHeader.setTimeStamp("test-timestamp");
- commonHeader.setApiVer("test-api-version");
- commonHeader.setOriginatorId("test-originator-id");
- commonHeader.setRequestID("test-request-id");
- commonHeader.setSubRequestId("test-subrequest-id");
-
- Map<String, String> flags = new HashMap<>();
- flags.put("key1", "flag1");
- flags.put("key2", "flag2");
- flags.put("key3", "flag3");
-
- commonHeader.setFlags(flags);
- return commonHeader;
- }
-
- private ActionIdentifiers buildActionIdentifiers() {
-
- ActionIdentifiers actionIdentifiers = new ActionIdentifiers();
- actionIdentifiers.setServiceInstanceId("test-instance-id");
- actionIdentifiers.setVnfID("test-vnf-id");
- actionIdentifiers.setVnfcName("test-name");
- actionIdentifiers.setVserverId("test-vserver-id");
-
- return actionIdentifiers;
- }
}
import static junit.framework.TestCase.assertNotNull;
import static org.junit.Assert.assertEquals;
+import static org.onap.appc.listener.TestUtil.buildCommonHeader;
import java.util.HashMap;
import java.util.Map;
assertEquals("test-locked", response.get("locked"));
assertEquals("{\"payload\": \"value\"", response.get("payload"));
}
-
- private CommonHeader buildCommonHeader() {
-
- CommonHeader commonHeader = new CommonHeader();
- commonHeader.setTimeStamp("test-timestamp");
- commonHeader.setApiVer("test-api-version");
- commonHeader.setOriginatorId("test-originator-id");
- commonHeader.setRequestID("test-request-id");
- commonHeader.setSubRequestId("test-subrequest-id");
-
- Map<String, String> flags = new HashMap<>();
- flags.put("key1", "flag1");
- flags.put("key2", "flag2");
- flags.put("key3", "flag3");
-
- commonHeader.setFlags(flags);
- return commonHeader;
- }
}
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
+import static org.onap.appc.listener.TestUtil.JSON_OUTPUT_BODY_STR;
import com.fasterxml.jackson.databind.JsonNode;
import java.net.MalformedURLException;
public class GenericProviderOperationsRequestFormatterTest {
- private static final String jsonOutputBodyStr =
- "{\"output\":{\"common-header\":{\"timestamp\":\"2016-08-03T08:50:18.97Z\","
- + "\"api-ver\":\"1\",\"flags\":{\"force\":\"TRUE\",\"ttl\":\"9900\"},\"sub-request-id\":\"1\","
- + "\"request-id\":\"123\",\"originator-id\":\"1\"},\"locked\": \"test-locked\","
- + "\"status\":{\"message\":\"test message\",\"code\":200}}}";
-
- private static final String invalidJsonOutputBodyStr =
+ private static final String INVALID_JSON_OUTPUT_BODY_STR =
"{\"output\":{\"common-header\":{\"timestamp\":\"2016-08-03T08:50:18.97Z\","
+ "\"api-ver\":\"1\",\"flags\":{\"force\":\"TRUE\",\"ttl\":\"9900\"},\"sub-request-id\":\"1\","
+ "\"request-id\":\"123\",\"originator-id\":\"1\"}}}";
@Test(expected = APPCException.class)
public void should_throw_when_invalid_json() throws APPCException {
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(invalidJsonOutputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(INVALID_JSON_OUTPUT_BODY_STR);
requestFormatter.getResponseStatus(jsonNode);
}
@Test
public void should_extract_response_status() throws APPCException {
- JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonOutputBodyStr);
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_OUTPUT_BODY_STR);
ResponseStatus status = requestFormatter.getResponseStatus(jsonNode);
assertEquals("test message", status.getValue());
@Test
public void should_return_extract_locked_field() throws APPCException {
- assertNull(requestFormatter.getLocked(new JSONObject(invalidJsonOutputBodyStr)));
- assertEquals("test-locked", requestFormatter.getLocked(new JSONObject(jsonOutputBodyStr)));
+ assertNull(requestFormatter.getLocked(new JSONObject(INVALID_JSON_OUTPUT_BODY_STR)));
+ assertEquals("test-locked", requestFormatter.getLocked(new JSONObject(JSON_OUTPUT_BODY_STR)));
}
}
import static org.mockito.Matchers.anyString;
import com.att.aft.dme2.internal.jersey.core.util.Base64;
-import com.fasterxml.jackson.databind.JsonNode;
import java.io.IOException;
import java.net.Socket;
import java.net.SocketException;
import org.mockito.Mock;
import org.onap.appc.exceptions.APPCException;
import org.onap.appc.listener.LCM.operation.ProviderOperations.MySSLSocketFactory;
-import org.onap.appc.listener.util.Mapper;
public class ProviderOperationsTest {
- private static final String jsonInputBodyStr =
- "{\"input\":{ \"common-header\": { \"timestamp\": \"2016-08-03T08:50:18.97Z\", "
- + "\"api-ver\": \"1\", \"originator-id\": \"1\", \"request-id\": \"123\", \"sub-request-id\": \"1\", "
- + "\"flags\": { \"force\":\"TRUE\", \"ttl\":\"9900\" } }, \"action\": \"Stop\", "
- + "\"action-identifiers\": { \"vnf-id\": \"TEST\" } }}";
- private final JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(jsonInputBodyStr);
-
private ProviderOperations providerOperations;
private MySSLSocketFactory socketFactory;
providerOperations.topologyDG("test-rpc-name", null);
}
- @Test
- public void todo() throws APPCException {
- //TODO write some test cases for topologyDG method
-// JsonNode result = providerOperations.topologyDG("test", jsonNode);
- }
-
@Test(expected = SocketException.class)
public void sslSocketFactory_should_throw_when_socket_not_connected() throws IOException {
Socket socket = socketFactory.createSocket();
socketFactory.createSocket(socket, "127.0.0.1", 123, true);
}
+
+ //TODO write some test cases for topologyDG method
}
--- /dev/null
+package org.onap.appc.listener;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import java.util.HashMap;
+import java.util.Map;
+import org.onap.appc.listener.LCM.model.ActionIdentifiers;
+import org.onap.appc.listener.LCM.model.CommonHeader;
+import org.onap.appc.listener.LCM.model.DmaapIncomingMessage;
+import org.onap.appc.listener.LCM.model.DmaapMessage;
+import org.onap.appc.listener.LCM.model.DmaapOutgoingMessage;
+import org.onap.appc.listener.util.Mapper;
+
+public class TestUtil {
+
+ public static final String JSON_INPUT_BODY_STR =
+ "{\"input\":{ \"common-header\": { \"timestamp\": \"2016-08-03T08:50:18.97Z\", "
+ + "\"api-ver\": \"1\", \"originator-id\": \"1\", \"request-id\": \"123\", \"sub-request-id\": \"1\", "
+ + "\"flags\": { \"force\":\"TRUE\", \"ttl\":\"9900\" } }, \"action\": \"Stop\", "
+ + "\"action-identifiers\": { \"vnf-id\": \"TEST\" } }}";
+
+ public static final String JSON_OUTPUT_BODY_STR =
+ "{\"output\":{\"common-header\":{\"timestamp\":\"2016-08-03T08:50:18.97Z\","
+ + "\"api-ver\":\"1\",\"flags\":{\"force\":\"TRUE\",\"ttl\":\"9900\"},\"sub-request-id\":\"1\","
+ + "\"request-id\":\"123\",\"originator-id\":\"1\"},\"locked\": \"test-locked\", "
+ + "\"status\":{\"message\":\"test message\",\"code\":200}}}";
+
+ public static DmaapMessage buildDmaapMessage() {
+
+ DmaapMessage dmaapMessage = new DmaapMessage();
+ dmaapMessage.setRpcName("test");
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_INPUT_BODY_STR);
+ dmaapMessage.setBody(jsonNode);
+ return dmaapMessage;
+ }
+
+ public static DmaapIncomingMessage buildDmaapIncomingMessage() {
+ DmaapIncomingMessage dmaapIncomingMessage = new DmaapIncomingMessage();
+ dmaapIncomingMessage.setRpcName("test");
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_INPUT_BODY_STR);
+ dmaapIncomingMessage.setBody(jsonNode);
+ return dmaapIncomingMessage;
+
+ }
+
+ public static DmaapOutgoingMessage buildDmaapOutgoingMessage() {
+ DmaapOutgoingMessage dmaapOutgoingMessage = new DmaapOutgoingMessage();
+ dmaapOutgoingMessage.setRpcName("test");
+ JsonNode jsonNode = Mapper.toJsonNodeFromJsonString(JSON_OUTPUT_BODY_STR);
+ dmaapOutgoingMessage.setBody(jsonNode);
+ return dmaapOutgoingMessage;
+
+ }
+
+ public static CommonHeader buildCommonHeader() {
+
+ CommonHeader commonHeader = new CommonHeader();
+ commonHeader.setTimeStamp("test-timestamp");
+ commonHeader.setApiVer("test-api-version");
+ commonHeader.setOriginatorId("test-originator-id");
+ commonHeader.setRequestID("test-request-id");
+ commonHeader.setSubRequestId("test-subrequest-id");
+
+ Map<String, String> flags = new HashMap<>();
+ flags.put("key1", "flag1");
+ flags.put("key2", "flag2");
+ flags.put("key3", "flag3");
+
+ commonHeader.setFlags(flags);
+ return commonHeader;
+ }
+
+ public static ActionIdentifiers buildActionIdentifiers() {
+
+ ActionIdentifiers actionIdentifiers = new ActionIdentifiers();
+ actionIdentifiers.setServiceInstanceId("test-instance-id");
+ actionIdentifiers.setVnfID("test-vnf-id");
+ actionIdentifiers.setVnfcName("test-name");
+ actionIdentifiers.setVserverId("test-vserver-id");
+
+ return actionIdentifiers;
+ }
+}