✨ feat: Astrologers | write slice: ProclaimWeekSymbol -> WeekSymbolProclaimed (#7)

Author: MateuszNaKodach

src/main/java/com/dddheroes/heroesofddd/astrologers/write/Astrologers.java

@@ -0,0 +1,45 @@
+package com.dddheroes.heroesofddd.astrologers.write;
+
+import com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol.OnlyOneSymbolPerWeek;
+import com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol.ProclaimWeekSymbol;
+import com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol.WeekSymbolProclaimed;
+import org.axonframework.commandhandling.CommandHandler;
+import org.axonframework.eventsourcing.EventSourcingHandler;
+import org.axonframework.modelling.command.AggregateCreationPolicy;
+import org.axonframework.modelling.command.AggregateIdentifier;
+import org.axonframework.modelling.command.CreationPolicy;
+import org.axonframework.spring.stereotype.Aggregate;
+
+import static org.axonframework.modelling.command.AggregateLifecycle.apply;
+
+@Aggregate
+class Astrologers {
+
+    @AggregateIdentifier
+    private AstrologersId astrologersId;
+    private MonthWeek week;
+
+    @CommandHandler
+    @CreationPolicy(AggregateCreationPolicy.CREATE_IF_MISSING)
+    void decide(ProclaimWeekSymbol command) {
+        new OnlyOneSymbolPerWeek(command, week).verify();
+
+        apply(
+                WeekSymbolProclaimed.event(
+                        command.astrologersId(),
+                        command.week(),
+                        command.symbol()
+                )
+        );
+    }
+
+    @EventSourcingHandler
+    void evolve(WeekSymbolProclaimed event) {
+        this.astrologersId = new AstrologersId(event.astrologersId());
+        this.week = new MonthWeek(event.month(), event.day());
+    }
+
+    Astrologers() {
+        // required by Axon
+    }
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/AstrologersCommand.java

@@ -0,0 +1,7 @@
+package com.dddheroes.heroesofddd.astrologers.write;
+
+
+public interface AstrologersCommand {
+
+    AstrologersId astrologersId();
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/AstrologersEvent.java

@@ -0,0 +1,6 @@
+package com.dddheroes.heroesofddd.astrologers.write;
+
+public interface AstrologersEvent {
+
+    String astrologersId();
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/AstrologersId.java

@@ -0,0 +1,25 @@
+package com.dddheroes.heroesofddd.astrologers.write;
+
+import java.util.UUID;
+
+public record AstrologersId(String raw) {
+
+    public AstrologersId {
+        if (raw == null || raw.isBlank()) {
+            throw new IllegalArgumentException("Astrologers id cannot be null or empty");
+        }
+    }
+
+    public static AstrologersId of(String raw) {
+        return new AstrologersId(raw);
+    }
+
+    public static AstrologersId random() {
+        return new AstrologersId(UUID.randomUUID().toString());
+    }
+
+    @Override
+    public String toString() {
+        return raw;
+    }
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/MonthWeek.java

@@ -0,0 +1,13 @@
+package com.dddheroes.heroesofddd.astrologers.write;
+
+public record MonthWeek(Integer month, Integer week) {
+
+    public static MonthWeek of(Integer month, Integer week) {
+        // todo: validation
+        return new MonthWeek(month, week);
+    }
+
+    public int weekNumber() {
+        return ((month - 1) * 4) + week;
+    }
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/WeekSymbol.java

@@ -0,0 +1,11 @@
+package com.dddheroes.heroesofddd.astrologers.write;
+
+import com.dddheroes.heroesofddd.shared.CreatureId;
+
+// todo: polymorphism, support symbols which are not creatures
+public record WeekSymbol(CreatureId weekOf, Integer growth) {
+
+    public static WeekSymbol of(CreatureId weekOf, Integer growth) {
+        return new WeekSymbol(weekOf, growth);
+    }
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/proclaimweeksymbol/OnlyOneSymbolPerWeek.java

@@ -0,0 +1,24 @@
+package com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol;
+
+import com.dddheroes.heroesofddd.astrologers.write.MonthWeek;
+import com.dddheroes.heroesofddd.calendar.write.Day;
+import com.dddheroes.heroesofddd.calendar.write.Month;
+import com.dddheroes.heroesofddd.calendar.write.Week;
+import com.dddheroes.heroesofddd.calendar.write.finishday.FinishDay;
+import com.dddheroes.heroesofddd.shared.DomainRule;
+
+public record OnlyOneSymbolPerWeek(
+        ProclaimWeekSymbol command,
+        MonthWeek lastlyProclaimed
+) implements DomainRule {
+
+    @Override
+    public boolean isViolated() {
+        return lastlyProclaimed != null && lastlyProclaimed.weekNumber() >= command.week().weekNumber();
+    }
+
+    @Override
+    public String message() {
+        return "Only one symbol can be proclaimed per week";
+    }
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/proclaimweeksymbol/ProclaimWeekSymbol.java

@@ -0,0 +1,30 @@
+package com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol;
+
+import com.dddheroes.heroesofddd.astrologers.write.AstrologersCommand;
+import com.dddheroes.heroesofddd.astrologers.write.AstrologersId;
+import com.dddheroes.heroesofddd.astrologers.write.MonthWeek;
+import com.dddheroes.heroesofddd.astrologers.write.WeekSymbol;
+import com.dddheroes.heroesofddd.shared.CreatureId;
+import org.axonframework.modelling.command.TargetAggregateIdentifier;
+
+public record ProclaimWeekSymbol(
+        @TargetAggregateIdentifier
+        AstrologersId astrologersId,
+        MonthWeek week,
+        WeekSymbol symbol
+) implements AstrologersCommand {
+
+    public static ProclaimWeekSymbol command(
+            String astrologersId,
+            Integer month,
+            Integer week,
+            String creatureId,
+            Integer growth
+    ) {
+        return new ProclaimWeekSymbol(
+                AstrologersId.of(astrologersId),
+                MonthWeek.of(month, week),
+                WeekSymbol.of(CreatureId.of(creatureId), growth)
+        );
+    }
+}

src/main/java/com/dddheroes/heroesofddd/astrologers/write/proclaimweeksymbol/WeekSymbolProclaimed.java

@@ -0,0 +1,29 @@
+package com.dddheroes.heroesofddd.astrologers.write.proclaimweeksymbol;
+
+import com.dddheroes.heroesofddd.astrologers.write.AstrologersEvent;
+import com.dddheroes.heroesofddd.astrologers.write.AstrologersId;
+import com.dddheroes.heroesofddd.astrologers.write.MonthWeek;
+import com.dddheroes.heroesofddd.astrologers.write.WeekSymbol;
+
+public record WeekSymbolProclaimed(
+        String astrologersId,
+        Integer month,
+        Integer day,
+        String weekOf,
+        Integer growth
+) implements AstrologersEvent {
+
+    public static WeekSymbolProclaimed event(
+            AstrologersId astrologersId,
+            MonthWeek monthWeek,
+            WeekSymbol symbol
+    ) {
+        return new WeekSymbolProclaimed(
+                astrologersId.raw(),
+                monthWeek.month(),
+                monthWeek.week(),
+                symbol.weekOf().raw(),
+                symbol.growth()
+        );
+    }
+}

src/test/java/com/dddheroes/heroesofddd/astrologers/write/AstrologersTest.java

@@ -0,0 +1,14 @@
+package com.dddheroes.heroesofddd.astrologers.write;
+
+import org.axonframework.test.aggregate.AggregateTestFixture;
+import org.junit.jupiter.api.*;
+
+public class AstrologersTest {
+
+    protected AggregateTestFixture<?> fixture;
+
+    @BeforeEach
+    void setUp() {
+        fixture = new AggregateTestFixture<>(Astrologers.class);
+    }
+}