add response serializer test

Author: jenschude

commercetools/commercetools-monitoring-datadog/src/main/java/com/commercetools/monitoring/datadog/DatadogResponseSerializer.java

@@ -25,6 +25,11 @@ public class DatadogResponseSerializer implements ResponseSerializer {
 
     private final MetricsApi apiInstance;
 
+    public DatadogResponseSerializer(final ResponseSerializer serializer, final MetricsApi apiInstance) {
+        this.serializer = serializer;
+        this.apiInstance = apiInstance;
+    }
+
     public DatadogResponseSerializer(final ResponseSerializer serializer, final ApiClient ddApiClient) {
         this.serializer = serializer;
         this.apiInstance = new MetricsApi(ddApiClient);

commercetools/commercetools-monitoring-datadog/src/test/java/example/ResponseSerializerTest.java

@@ -0,0 +1,58 @@
+
+package example;
+
+import com.commercetools.api.models.common.Reference;
+import com.commercetools.api.models.product.ProductReference;
+import com.commercetools.monitoring.datadog.DatadogResponseSerializer;
+import com.datadog.api.client.ApiException;
+import com.datadog.api.client.v2.api.MetricsApi;
+import com.fasterxml.jackson.core.JsonProcessingException;
+
+import io.vrap.rmf.base.client.ApiHttpHeaders;
+import io.vrap.rmf.base.client.ApiHttpResponse;
+import io.vrap.rmf.base.client.ResponseSerializer;
+
+import org.assertj.core.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
+
+public class ResponseSerializerTest {
+
+    @Test
+    public void testSerialize() throws ApiException, JsonProcessingException {
+        MetricsApi metricsApi = Mockito.mock(MetricsApi.class);
+        Mockito.when(metricsApi.submitMetrics(Mockito.any())).thenReturn(null);
+        DatadogResponseSerializer serializer = new DatadogResponseSerializer(ResponseSerializer.of(), metricsApi);
+
+        Reference reference = ProductReference.builder().id("abc").build();
+
+        serializer.toJsonByteArray(reference);
+
+        Mockito.verify(metricsApi).submitMetrics(Mockito.argThat(metricPayload -> {
+            Assertions.assertThat(metricPayload).isNotNull();
+            Assertions.assertThat(metricPayload.getSeries().get(0).getMetric())
+                    .isEqualTo("commercetools.json.serialization");
+            return true;
+        }));
+    }
+
+    @Test
+    public void testDeserialize() throws ApiException, JsonProcessingException {
+        MetricsApi metricsApi = Mockito.mock(MetricsApi.class);
+        Mockito.when(metricsApi.submitMetrics(Mockito.any())).thenReturn(null);
+        DatadogResponseSerializer serializer = new DatadogResponseSerializer(ResponseSerializer.of(), metricsApi);
+
+        String responseBody = "{ \"typeId\": \"product\", \"id\": \"abc\" }";
+        ApiHttpResponse<byte[]> response = new ApiHttpResponse<>(200, new ApiHttpHeaders(), responseBody.getBytes());
+
+        ApiHttpResponse<Reference> reference = serializer.convertResponse(response, Reference.class);
+
+        Assertions.assertThat(reference.getBody()).isInstanceOf(ProductReference.class);
+        Mockito.verify(metricsApi).submitMetrics(Mockito.argThat(metricPayload -> {
+            Assertions.assertThat(metricPayload).isNotNull();
+            Assertions.assertThat(metricPayload.getSeries().get(0).getMetric())
+                    .isEqualTo("commercetools.json.deserialization");
+            return true;
+        }));
+    }
+}