Create CustomErrorReporter to enable custom error reporting (Work in progress)

Author: dbuos

async/async-commons/src/main/java/org/reactivecommons/async/impl/ext/CustomErrorReporter.java

@@ -0,0 +1,32 @@
+package org.reactivecommons.async.impl.ext;
+
+import org.reactivecommons.api.domain.Command;
+import org.reactivecommons.api.domain.DomainEvent;
+import org.reactivecommons.async.api.AsyncQuery;
+import org.reactivecommons.async.impl.communications.Message;
+import reactor.core.publisher.Mono;
+
+public interface CustomErrorReporter {
+
+    String COMMAND_CLASS = "org.reactivecommons.api.domain.Command";
+    String EVENT_CLASS = "org.reactivecommons.api.domain.DomainEvent";
+    String QUERY_CLASS = "org.reactivecommons.async.api.AsyncQuery";
+
+    default Mono<Void> reportError(Throwable ex, Message rawMessage, Object message) {
+        switch (message.getClass().getName()){
+            case COMMAND_CLASS:
+                return reportError(ex, rawMessage, (Command<?>) message);
+            case EVENT_CLASS:
+                return reportError(ex, rawMessage, (DomainEvent<?>) message);
+            case QUERY_CLASS:
+                return reportError(ex, rawMessage, (AsyncQuery<?>) message);
+            default:
+                return Mono.empty();
+        }
+    }
+
+    Mono<Void> reportError(Throwable ex, Message rawMessage, Command<?> message);
+    Mono<Void> reportError(Throwable ex, Message rawMessage, DomainEvent<?> message);
+    Mono<Void> reportError(Throwable ex, Message rawMessage, AsyncQuery<?> message);
+
+}

async/async-commons/src/test/java/org/reactivecommons/async/impl/ext/CustomErrorReporterTest.java

@@ -0,0 +1,88 @@
+package org.reactivecommons.async.impl.ext;
+
+import org.junit.Test;
+import org.reactivecommons.api.domain.Command;
+import org.reactivecommons.api.domain.DomainEvent;
+import org.reactivecommons.async.api.AsyncQuery;
+import org.reactivecommons.async.impl.communications.Message;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+import reactor.test.publisher.PublisherProbe;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.mockito.Mockito.mock;
+
+public class CustomErrorReporterTest {
+
+    private final PublisherProbe<Void> commandProbe = PublisherProbe.empty();
+    private final PublisherProbe<Void> eventProbe = PublisherProbe.empty();
+    private final PublisherProbe<Void> queryProbe = PublisherProbe.empty();
+
+    private final TestCustomReporter customReporter = new TestCustomReporter();
+    private final Message rawMessage = mock(Message.class);
+
+    @Test
+    public void reportErrorCommand() {
+        final Command<Object> message = new Command<>("", "", null);
+
+        assertReportError(message);
+
+        commandProbe.assertWasSubscribed();
+    }
+
+    @Test
+    public void testReportErrorEvent() {
+        final DomainEvent<Object> message = new DomainEvent<>("", "", null);
+
+        assertReportError(message);
+
+        eventProbe.assertWasSubscribed();
+    }
+
+    @Test
+    public void testReportErrorQuery() {
+        final AsyncQuery<Object> message = new AsyncQuery<>("", null);
+
+        assertReportError(message);
+
+        queryProbe.assertWasSubscribed();
+    }
+
+    @Test
+    public void shouldIgnoreUnknownMessageType() {
+        final Map<?,?> message = new HashMap<>();
+
+        assertReportError(message);
+
+        queryProbe.assertWasNotSubscribed();
+        commandProbe.assertWasNotSubscribed();
+        eventProbe.assertWasNotSubscribed();
+    }
+
+    private void assertReportError(Object message){
+        customReporter.reportError(new RuntimeException(), rawMessage, message)
+            .as(StepVerifier::create)
+            .verifyComplete();
+    }
+
+    class TestCustomReporter implements CustomErrorReporter{
+        @Override
+        public Mono<Void> reportError(Throwable ex, Message rawMessage, Command<?> message) {
+            return commandProbe.mono();
+        }
+
+        @Override
+        public Mono<Void> reportError(Throwable ex, Message rawMessage, DomainEvent<?> message) {
+            return eventProbe.mono();
+        }
+
+        @Override
+        public Mono<Void> reportError(Throwable ex, Message rawMessage, AsyncQuery<?> message) {
+            return queryProbe.mono();
+        }
+    }
+
+}
+