✨ feat: Creature Recruitment | automation: CreatureRecruited -> AddCreatureToArmy (#5)

Author: MateuszNaKodach

src/main/java/com/dddheroes/heroesofddd/armies/write/addcreature/AddCreatureToArmy.java

@@ -18,7 +18,7 @@ public record AddCreatureToArmy(
         }
     }
 
-    public AddCreatureToArmy command(String armyId, String creatureId, int quantity) {
+    public static AddCreatureToArmy command(String armyId, String creatureId, int quantity) {
         return new AddCreatureToArmy(new ArmyId(armyId), new CreatureId(creatureId), new Amount(quantity));
     }
 }

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

@@ -0,0 +1,32 @@
+package com.dddheroes.heroesofddd.creaturerecruitment.automation;
+
+import com.dddheroes.heroesofddd.armies.write.addcreature.AddCreatureToArmy;
+import com.dddheroes.heroesofddd.creaturerecruitment.write.recruitcreature.CreatureRecruited;
+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_WhenCreatureRecruitedThenAddToArmy_Processor")
+@DisallowReplay
+@Component
+class WhenCreatureRecruitedThenAddToArmyProcessor {
+
+    private final CommandGateway commandGateway;
+
+    WhenCreatureRecruitedThenAddToArmyProcessor(CommandGateway commandGateway) {
+        this.commandGateway = commandGateway;
+    }
+
+    @EventHandler
+    void on(CreatureRecruited event) {
+        var command = AddCreatureToArmy.command(
+                event.toArmy(),
+                event.creatureId(),
+                event.quantity()
+        );
+
+        commandGateway.sendAndWait(command);
+    }
+}

src/main/java/com/dddheroes/heroesofddd/creaturerecruitment/read/DwellingReadModelProjector.java

@@ -3,9 +3,11 @@
 import com.dddheroes.heroesofddd.creaturerecruitment.write.builddwelling.DwellingBuilt;
 import com.dddheroes.heroesofddd.creaturerecruitment.write.changeavailablecreatures.AvailableCreaturesChanged;
 import com.dddheroes.heroesofddd.creaturerecruitment.write.recruitcreature.CreatureRecruited;
+import org.axonframework.config.ProcessingGroup;
 import org.axonframework.eventhandling.EventHandler;
 import org.springframework.stereotype.Component;
 
+@ProcessingGroup("ReadModel_Dwelling")
 @Component
 class DwellingReadModelProjector {
 

src/main/resources/application.yaml

@@ -21,3 +21,11 @@ axon:
     general: jackson
   axonserver:
     enabled: true
+  eventhandling:
+    processors:
+      Automation_WhenCreatureRecruitedThenAddToArmy_Processor:
+        mode: pooled
+        dlq:
+          enabled: true
+      ReadModel_Dwelling:
+        mode: pooled

src/test/java/com/dddheroes/heroesofddd/creaturerecruitment/automation/WhenCreatureRecruitedThenAddToArmyTest.java

@@ -0,0 +1,79 @@
+package com.dddheroes.heroesofddd.creaturerecruitment.automation;
+
+import com.dddheroes.heroesofddd.TestcontainersConfiguration;
+import com.dddheroes.heroesofddd.armies.write.addcreature.AddCreatureToArmy;
+import com.dddheroes.heroesofddd.creaturerecruitment.write.DwellingEvent;
+import com.dddheroes.heroesofddd.creaturerecruitment.write.DwellingId;
+import com.dddheroes.heroesofddd.creaturerecruitment.write.builddwelling.DwellingBuilt;
+import com.dddheroes.heroesofddd.creaturerecruitment.write.changeavailablecreatures.AvailableCreaturesChanged;
+import com.dddheroes.heroesofddd.creaturerecruitment.write.recruitcreature.CreatureRecruited;
+import com.dddheroes.heroesofddd.shared.ArmyId;
+import com.dddheroes.heroesofddd.shared.CreatureIds;
+import com.dddheroes.heroesofddd.shared.ResourceType;
+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.Map;
+
+import static com.dddheroes.heroesofddd.utils.AwaitilityUtils.awaitUntilAsserted;
+import static org.mockito.Mockito.*;
+
+@Import(TestcontainersConfiguration.class)
+@SpringBootTest
+class WhenCreatureRecruitedThenAddToArmyTest {
+
+    private static final Map<String, Integer> PHOENIX_COST = Map.of(
+            ResourceType.GOLD.name(), 2000,
+            ResourceType.MERCURY.name(), 1
+    );
+
+    @Autowired
+    private EventGateway eventGateway;
+
+    @MockitoSpyBean
+    private CommandGateway commandGateway;
+
+    @Test
+    void whenCreatureRecruited_ThenAddCreatureToArmy() {
+        // given
+        var dwellingId = DwellingId.random().raw();
+        var creatureId = CreatureIds.phoenix().raw();
+        var armyId = ArmyId.random().raw();
+        givenDwellingEvents(
+                dwellingId,
+                new DwellingBuilt(dwellingId, creatureId, PHOENIX_COST),
+                new AvailableCreaturesChanged(dwellingId, creatureId, 3),
+                new CreatureRecruited(dwellingId, creatureId, armyId, 1, PHOENIX_COST)
+        );
+
+        // when
+        // processed by the automation
+
+        // then
+        awaitUntilAsserted(() -> verify(commandGateway, times(1))
+                .sendAndWait(AddCreatureToArmy.command(armyId, creatureId, 1))
+        );
+    }
+
+    private void givenDwellingEvents(String dwellingId, DwellingEvent... events) {
+        for (int i = 0; i < events.length; i++) {
+            eventGateway.publish(dwellingDomainEvent(dwellingId, i, events[i]));
+        }
+    }
+
+    private DomainEventMessage<?> dwellingDomainEvent(String dwellingId, int sequenceNumber, DwellingEvent payload) {
+        return new GenericDomainEventMessage<>(
+                "Dwelling",
+                dwellingId,
+                sequenceNumber,
+                payload
+        );
+    }
+}

src/test/java/com/dddheroes/heroesofddd/creaturerecruitment/read/getdwellingbyid/GetDwellingByIdTest.java

@@ -10,6 +10,7 @@
 import com.dddheroes.heroesofddd.shared.ArmyId;
 import com.dddheroes.heroesofddd.shared.CreatureIds;
 import com.dddheroes.heroesofddd.shared.ResourceType;
+import com.dddheroes.heroesofddd.utils.AwaitilityUtils;
 import org.awaitility.Awaitility;
 import org.axonframework.eventhandling.DomainEventMessage;
 import org.axonframework.eventhandling.GenericDomainEventMessage;
@@ -24,13 +25,14 @@
 import java.util.HashMap;
 import java.util.Map;
 
+import static com.dddheroes.heroesofddd.utils.AwaitilityUtils.*;
 import static org.assertj.core.api.Assertions.*;
 
 @Import(TestcontainersConfiguration.class)
 @SpringBootTest
 class GetDwellingByIdTest {
 
-    public static final Map<String, Integer> PHOENIX_COST = Map.of(
+    private static final Map<String, Integer> PHOENIX_COST = Map.of(
             ResourceType.GOLD.name(), 2000,
             ResourceType.MERCURY.name(), 1
     );
@@ -150,11 +152,4 @@ private DomainEventMessage<?> dwellingDomainEvent(String dwellingId, int sequenc
                 payload
         );
     }
-
-    private void awaitUntilAsserted(Runnable assertion) {
-        Awaitility.await()
-                  .pollInSameThread()
-                  .atMost(Duration.ofSeconds(5))
-                  .untilAsserted(assertion::run);
-    }
 }

src/test/java/com/dddheroes/heroesofddd/utils/AwaitilityUtils.java

@@ -0,0 +1,19 @@
+package com.dddheroes.heroesofddd.utils;
+
+import org.awaitility.Awaitility;
+
+import java.time.Duration;
+
+public class AwaitilityUtils {
+
+    public static void awaitUntilAsserted(Runnable assertion) {
+        Awaitility.await()
+                  .pollInSameThread()
+                  .atMost(Duration.ofSeconds(5))
+                  .untilAsserted(assertion::run);
+    }
+
+    private AwaitilityUtils() {
+        throw new UnsupportedOperationException("Utility class");
+    }
+}