✨ feat: Astrologers | automation: DayStarted (day == 1) -> ProclaimWeekSymbol (#8)

Author: MateuszNaKodach

src/main/java/com/dddheroes/heroesofddd/astrologers/AstrologersConfiguration.java

@@ -0,0 +1,21 @@
+package com.dddheroes.heroesofddd.astrologers;
+
+import com.dddheroes.heroesofddd.astrologers.automation.whenweekstartedthenproclaimweeksymbol.WeekSymbolCalculator;
+import com.dddheroes.heroesofddd.astrologers.write.WeekSymbol;
+import com.dddheroes.heroesofddd.shared.CreatureId;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class AstrologersConfiguration {
+
+    // todo: add more options than angel
+    @Bean
+    WeekSymbolCalculator inMemoryWeekSymbolCalculator() {
+        return __ -> WeekSymbol.of(CreatureId.of("angel"), random(1, 5));
+    }
+
+    private static int random(int min, int max) {
+        return (int) (Math.random() * (max - min + 1) + min);
+    }
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/automation/whenweekstartedthenproclaimweeksymbol/WeekSymbolCalculator.java

@@ -0,0 +1,11 @@
+package com.dddheroes.heroesofddd.astrologers.automation.whenweekstartedthenproclaimweeksymbol;
+
+import com.dddheroes.heroesofddd.astrologers.write.MonthWeek;
+import com.dddheroes.heroesofddd.astrologers.write.WeekSymbol;
+
+import java.util.function.Function;
+
+@FunctionalInterface
+public interface WeekSymbolCalculator extends Function<MonthWeek, WeekSymbol> {
+
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/automation/whenweekstartedthenproclaimweeksymbol/WhenWeekStartedThenProclaimWeekSymbolProcessor.java

@@ -0,0 +1,44 @@
+package com.dddheroes.heroesofddd.astrologers.automation.whenweekstartedthenproclaimweeksymbol;
+
+
+import com.dddheroes.heroesofddd.astrologers.write.MonthWeek;
+import com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol.ProclaimWeekSymbol;
+import com.dddheroes.heroesofddd.calendar.write.startday.DayStarted;
+import org.axonframework.commandhandling.gateway.CommandGateway;
+import org.axonframework.config.ProcessingGroup;
+import org.axonframework.eventhandling.DisallowReplay;
+import org.axonframework.eventhandling.EventHandler;
+import org.springframework.stereotype.Component;
+
+@ProcessingGroup("Automation_WhenWeekStartedThenProclaimWeekSymbolProcessor_Processor")
+@DisallowReplay
+@Component
+class WhenWeekStartedThenProclaimWeekSymbolProcessor {
+
+    private final CommandGateway commandGateway;
+    private final WeekSymbolCalculator weekSymbolCalculator;
+
+    WhenWeekStartedThenProclaimWeekSymbolProcessor(
+            CommandGateway commandGateway,
+            WeekSymbolCalculator weekSymbolCalculator
+    ) {
+        this.commandGateway = commandGateway;
+        this.weekSymbolCalculator = weekSymbolCalculator;
+    }
+
+    @EventHandler
+    void react(DayStarted event) {
+        var isWeekStarted = event.day() == 1;
+        if (isWeekStarted) {
+            var weekSymbol = weekSymbolCalculator.apply(MonthWeek.of(event.month(), event.week()));
+            var command = ProclaimWeekSymbol.command(
+                    event.calendarId(),
+                    event.month(),
+                    event.week(),
+                    weekSymbol.weekOf().raw(),
+                    weekSymbol.growth()
+            );
+            commandGateway.sendAndWait(command);
+        }
+    }
+}

src/main/java/com/dddheroes/heroesofddd/creaturerecruitment/automation/WhenCreatureRecruitedThenAddToArmyProcessor.java

@@ -20,7 +20,7 @@ class WhenCreatureRecruitedThenAddToArmyProcessor {
     }
 
     @EventHandler
-    void on(CreatureRecruited event) {
+    void react(CreatureRecruited event) {
         var command = AddCreatureToArmy.command(
                 event.toArmy(),
                 event.creatureId(),

src/test/java/com/dddheroes/heroesofddd/astrologers/automation/whenweekstartedthenproclaimweeksymbol/WhenWeekStartedThenProclaimWeekSymbolTest.java

@@ -0,0 +1,66 @@
+package com.dddheroes.heroesofddd.astrologers.automation.whenweekstartedthenproclaimweeksymbol;
+
+import com.dddheroes.heroesofddd.TestcontainersConfiguration;
+import com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol.ProclaimWeekSymbol;
+import com.dddheroes.heroesofddd.calendar.write.CalendarEvent;
+import com.dddheroes.heroesofddd.calendar.write.CalendarId;
+import com.dddheroes.heroesofddd.calendar.write.startday.DayStarted;
+import org.axonframework.commandhandling.gateway.CommandGateway;
+import org.axonframework.eventhandling.DomainEventMessage;
+import org.axonframework.eventhandling.GenericDomainEventMessage;
+import org.axonframework.eventhandling.gateway.EventGateway;
+import org.junit.jupiter.api.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Import;
+import org.springframework.test.context.bean.override.mockito.MockitoSpyBean;
+
+import java.util.UUID;
+
+import static com.dddheroes.heroesofddd.utils.AwaitilityUtils.awaitUntilAsserted;
+import static org.mockito.Mockito.*;
+
+@Import(TestcontainersConfiguration.class)
+@SpringBootTest
+class WhenWeekStartedThenProclaimWeekSymbolTest {
+
+    @Autowired
+    private EventGateway eventGateway;
+
+    @MockitoSpyBean
+    private CommandGateway commandGateway;
+
+    @Test
+    void whenDayStartedForFirstDayOfTheWeek_ThenProclaimWeekSymbol() {
+        // given
+        var gameId = UUID.randomUUID().toString();
+        var calendarId = CalendarId.of(gameId);
+        givenCalendarEvents(
+                gameId,
+                new DayStarted(calendarId.raw(), 1, 1, 1)
+        );
+
+        // when
+        // processed by the automation
+
+        // then
+        awaitUntilAsserted(() -> verify(commandGateway, times(1))
+                .sendAndWait(ProclaimWeekSymbol.command(gameId, 1, 1, "angel", any()))
+        );
+    }
+
+    private void givenCalendarEvents(String gameId, CalendarEvent... events) {
+        for (int i = 0; i < events.length; i++) {
+            eventGateway.publish(calendarDomainEvent(gameId, i, events[i]));
+        }
+    }
+
+    private DomainEventMessage<?> calendarDomainEvent(String identifier, int sequenceNumber, CalendarEvent payload) {
+        return new GenericDomainEventMessage<>(
+                "Calendar",
+                identifier,
+                sequenceNumber,
+                payload
+        );
+    }
+}