snapshot filter involved in both

Author: MateuszNaKodach

README.md

@@ -162,4 +162,5 @@ Please reach me out on LinkedIn [linkedin.com/in/mateusznakodach/](https://www.l
 
 ### Helpful:
 CHECK snapshot content!
-```TO read snapshot data: SELECT lo_get(18333) AS payload;```
+```TO read snapshot data: SELECT lo_get(18333) AS payload;```
+```Error reading snapshot for aggregate [{}]. Reconstructing from entire event stream.```

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

@@ -3,6 +3,10 @@
 import com.dddheroes.heroesofddd.astrologers.automation.whenweekstartedthenproclaimweeksymbol.WeekSymbolCalculator;
 import com.dddheroes.heroesofddd.astrologers.write.WeekSymbol;
 import com.dddheroes.heroesofddd.shared.domain.identifiers.CreatureId;
+import org.axonframework.eventsourcing.EventCountSnapshotTriggerDefinition;
+import org.axonframework.eventsourcing.SnapshotTriggerDefinition;
+import org.axonframework.eventsourcing.Snapshotter;
+import org.axonframework.eventsourcing.snapshotting.SnapshotFilter;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -18,4 +22,17 @@ WeekSymbolCalculator inMemoryWeekSymbolCalculator() {
     private static int random(int min, int max) {
         return (int) (Math.random() * (max - min + 1) + min);
     }
+
+    @Bean
+    public SnapshotFilter astrologersSnapshotFilter() {
+        return snapshotData -> {
+            // Allow all snapshots for dwellings, as they are always in the correct format
+            return true;
+        };
+    }
+
+    @Bean
+    SnapshotTriggerDefinition astrologersSnapshotTrigger(Snapshotter snapshotter) {
+        return new EventCountSnapshotTriggerDefinition(snapshotter, 5);
+    }
 }

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

@@ -12,7 +12,7 @@
 
 import static org.axonframework.modelling.command.AggregateLifecycle.apply;
 
-@Aggregate
+@Aggregate(snapshotFilter = "astrologersSnapshotFilter", snapshotTriggerDefinition = "astrologersSnapshotTrigger")
 class Astrologers {
 
     @AggregateIdentifier

src/main/java/com/dddheroes/heroesofddd/creaturerecruitment/CreatureRecruitmentConfiguration.java

@@ -6,6 +6,7 @@
 import org.axonframework.eventsourcing.EventCountSnapshotTriggerDefinition;
 import org.axonframework.eventsourcing.SnapshotTriggerDefinition;
 import org.axonframework.eventsourcing.Snapshotter;
+import org.axonframework.eventsourcing.snapshotting.SnapshotFilter;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -31,4 +32,12 @@ public Class<? extends RecruitCreature> supportedCommandType() {
     SnapshotTriggerDefinition dwellingSnapshotTrigger(Snapshotter snapshotter) {
         return new EventCountSnapshotTriggerDefinition(snapshotter, 5);
     }
+
+    @Bean
+    public SnapshotFilter dwellingSnapshotFilter() {
+        return snapshotData -> {
+            // Allow all snapshots for dwellings, as they are always in the correct format
+            return true;
+        };
+    }
 }

src/main/java/com/dddheroes/heroesofddd/creaturerecruitment/write/Dwelling.java

@@ -24,7 +24,7 @@
 
 import static org.axonframework.modelling.command.AggregateLifecycle.*;
 
-@Aggregate(snapshotTriggerDefinition = "dwellingSnapshotTrigger")
+@Aggregate(snapshotTriggerDefinition = "dwellingSnapshotTrigger", snapshotFilter = "dwellingSnapshotFilter")
 public class Dwelling {
 
     private static final Logger logger = LoggerFactory.getLogger(Dwelling.class);