2 files changed, 60 insertions, 0 deletions

diff --git a/src/test/java/org/onap/dcae/common/publishing/DMaaPEventPublisherTest.java b/src/test/java/org/onap/dcae/common/publishing/DMaaPEventPublisherTest.java
index 4ea6482..2a138b2 100644
--- a/src/test/java/org/onap/dcae/common/publishing/DMaaPEventPublisherTest.java
+++ b/src/test/java/org/onap/dcae/common/publishing/DMaaPEventPublisherTest.java
@@ -72,4 +72,19 @@ public class DMaaPEventPublisherTest {
         dMaaPEventPublisher.sendEvent(jo,"test");
         assertEquals("test", publisherCache.get()._1);
     }
+
+    @Test
+    public void sendEventclosePublisherTest () throws Exception {
+        List<String> destination = List.of("test");
+        PublisherConfig publisherConfig = new PublisherConfig(destination, "Test", "test",
+                "test123");
+        DMaaPPublishersCache.CambriaPublishersCacheLoader publishersCache =
+                Mockito.mock(DMaaPPublishersCache.CambriaPublishersCacheLoader.class);
+        Map<String, PublisherConfig> publisherCache = HashMap.of("test", publisherConfig);
+        publisherCache.put("test", publisherConfig);
+        DMaaPEventPublisher dMaaPEventPublisher = new DMaaPEventPublisher(publisherCache);
+        JSONObject jo = null;
+        dMaaPEventPublisher.sendEvent(jo,"test");
+        assertEquals("test", publisherCache.get()._1);
+    }
 }
diff --git a/src/test/java/org/onap/dcae/common/publishing/MessageRouterHttpStatusMapperTest.java b/src/test/java/org/onap/dcae/common/publishing/MessageRouterHttpStatusMapperTest.java
index 12f0479..ce1d22c 100644
--- a/src/test/java/org/onap/dcae/common/publishing/MessageRouterHttpStatusMapperTest.java
+++ b/src/test/java/org/onap/dcae/common/publishing/MessageRouterHttpStatusMapperTest.java
@@ -22,15 +22,20 @@ package org.onap.dcae.common.publishing;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.EnumSource;
+import org.onap.dcae.restapi.ApiException;
 import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.model.MessageRouterPublishResponse;
 import org.springframework.http.HttpStatus;
 
 import static org.junit.jupiter.api.Assertions.assertSame;
+import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 import static org.onap.dcae.ApplicationSettings.responseCompatibility;
 import static org.onap.dcae.common.publishing.MessageRouterHttpStatusMapper.getHttpStatus;
+import static org.onap.dcae.common.publishing.MessageRouterHttpStatusMapper.resolveHttpCode;
+import static org.onap.dcae.common.publishing.MessageRouterHttpStatusMapper.responseBody;
 
 class MessageRouterHttpStatusMapperTest {
 
@@ -52,6 +57,20 @@ class MessageRouterHttpStatusMapperTest {
     }
 
     @Test
+    void shouldResponse202Test() {
+        //given
+        responseCompatibility = BACKWARDS_COMPATIBILITY;
+        MessageRouterPublishResponse messageRouterPublishResponse = mock(MessageRouterPublishResponse.class);
+        when(messageRouterPublishResponse.successful()).thenReturn(true);
+
+        //when
+        HttpStatus httpStatusResponse = getHttpStatus(messageRouterPublishResponse);
+
+        //then
+        assertSame(HttpStatus.ACCEPTED, httpStatusResponse);
+    }
+
+    @Test
     void shouldResponse200WhenBackwardsCompatibilityIsNone() {
         //given
         responseCompatibility = BACKWARDS_COMPATIBILITY_NONE;
@@ -81,4 +100,30 @@ class MessageRouterHttpStatusMapperTest {
         //then
         assertThrows(RuntimeException.class,()->getHttpStatus(messageRouterPublishResponse));
     }
+
+    @Test
+    public void responseBodyTest () throws Exception {
+        ApiException result = responseBody("404");
+        assertEquals(404, result.httpStatusCode);
+        result = responseBody("408");
+        assertEquals(408, result.httpStatusCode);
+        result = responseBody("429");
+        assertEquals(429, result.httpStatusCode);
+        result = responseBody("502");
+        assertEquals(502, result.httpStatusCode);
+        result = responseBody("503");
+        assertEquals(503, result.httpStatusCode);
+        result = responseBody("504");
+        assertEquals(504, result.httpStatusCode);
+        result = responseBody("test");
+        assertEquals(500, result.httpStatusCode);
+    }
+
+    @Test
+    public void resolveHttpCodeTest () throws Exception {
+        MessageRouterPublishResponse messageRouterPublishResponse = mock(MessageRouterPublishResponse.class);
+        when(messageRouterPublishResponse.failReason()).thenReturn("error code");
+        String result = resolveHttpCode(messageRouterPublishResponse);
+        assertNotNull(result);
+    }
 }