feature: configuration key to break test if events consumer fail

it-testbook/src/test/resources/configuration.yml

@@ -45,7 +45,7 @@ testBook:
           total: 3
           successful: 2
 
-# these will fail since the slack consumer is lacking the token. We use them to check the log file and verify they're consumed
+# these will fail since custom events lack the extension context used in the default slack.json template. We use them to check the log file and verify they're consumed
 eventsConsumers:
   - slack:
       events:

it/src/test/resources/configuration.yaml

@@ -31,7 +31,7 @@ extent:
     name: { }
 
 eventsConsumers:
-  - slack: # these will fail since the slack consumer is lacking the token. We use them to check the log file and verify they're consumed
+  - slack: # these will fail since custom events lack the extension context used in the default slack.json template. We use them to check the log file and verify they're consumed
       events:
         - primaryId: primary.*  # custom event by primaryId regex
           reason: custom-event

spectrum/src/main/java/io/github/giulong/spectrum/utils/events/EventsConsumer.java

@@ -33,6 +33,10 @@ public abstract class EventsConsumer implements Consumer<Event> {
     @JsonPropertyDescription("List of events that will be consumed")
     protected List<Event> events;
 
+    @SuppressWarnings("unused")
+    @JsonPropertyDescription("Set to true to fail the test on consumer's exceptions")
+    private boolean failOnError;
+
     public void match(final Event event) {
         events
                 .stream()
@@ -96,6 +100,10 @@ void acceptSilently(final Event event) {
             accept(event);
         } catch (Exception e) {
             log.error(String.format("%s: %s", getClass().getSimpleName(), e.getMessage()), e);
+
+            if (failOnError) {
+                throw e;
+            }
         }
     }
 }

spectrum/src/test/java/io/github/giulong/spectrum/utils/events/EventsConsumerTest.java

@@ -2,6 +2,7 @@
 
 import io.github.giulong.spectrum.enums.Result;
 import io.github.giulong.spectrum.pojos.events.Event;
+import io.github.giulong.spectrum.utils.Reflections;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
@@ -194,6 +195,22 @@ void acceptSilently() {
         assertDoesNotThrow(() -> eventsConsumer.acceptSilently(event), exceptionMessage);
     }
 
+    @Test
+    @DisplayName("acceptSilently should rethrow the exception if failOnError is true")
+    void acceptSilentlyThrow() {
+        final String exceptionMessage = "THE STACKTRACE BELOW IS EXPECTED!!!";
+        final Event event = mock(Event.class);
+
+        Reflections.setField("failOnError", eventsConsumer, true);
+
+        when(event.getContext()).thenThrow(new RuntimeException(exceptionMessage));
+
+        eventsConsumer.events = List.of(event);
+        final Exception exception = assertThrows(RuntimeException.class, () -> eventsConsumer.acceptSilently(event));
+
+        assertEquals(exceptionMessage, exception.getMessage());
+    }
+
     private static class DummyEventsConsumer extends EventsConsumer {
 
         DummyEventsConsumer() {