📸 chore: Creature Recruitment | snapshots - dwelling data needs to be public

Author: MateuszNaKodach

generated-requests.http

@@ -1,7 +1,7 @@
 ### BuildDwelling
-@gameId = scenario-1
-@playerId = player-1
-@dwellingId = dwelling-1
+@gameId = scenario-3
+@playerId = player-3
+@dwellingId = dwelling-3
 
 ### BuildDwelling
 PUT http://localhost:8080/games/{{gameId}}/dwellings/{{dwellingId}}

src/main/java/com/dddheroes/heroesofddd/GameConfiguration.java

@@ -1,13 +1,19 @@
 package com.dddheroes.heroesofddd;
 
 import com.dddheroes.heroesofddd.shared.application.GameMetaData;
+import com.dddheroes.heroesofddd.shared.infrastructure.serialization.DwellingIdSerializationModule;
+import com.fasterxml.jackson.databind.Module;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.axonframework.eventhandling.EventMessage;
 import org.axonframework.eventhandling.async.SequencingPolicy;
 import org.axonframework.messaging.correlation.CorrelationDataProvider;
 import org.axonframework.messaging.correlation.MessageOriginProvider;
 import org.axonframework.messaging.correlation.SimpleCorrelationDataProvider;
+import org.axonframework.serialization.Serializer;
+import org.axonframework.serialization.json.JacksonSerializer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 
 @Configuration
 public class GameConfiguration {
@@ -26,4 +32,18 @@ public CorrelationDataProvider gameDataProvider() {
     public CorrelationDataProvider messageOriginProvider() {
         return new MessageOriginProvider();
     }
+
+    @Bean
+    public Module dwellingIdSerializationModule() {
+        return new DwellingIdSerializationModule();
+    }
+
+    @Bean
+    @Primary
+    public Serializer defaultSerializer(ObjectMapper objectMapper) {
+        objectMapper.registerModule(dwellingIdSerializationModule());
+        return JacksonSerializer.builder()
+                .objectMapper(objectMapper)
+                .build();
+    }
 }

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

@@ -26,10 +26,10 @@
 public class Dwelling {
 
     @AggregateIdentifier
-    private DwellingId dwellingId;
-    private CreatureId creatureId;
-    private Resources costPerTroop;
-    private Amount availableCreatures;
+    public DwellingId dwellingId;
+    public CreatureId creatureId;
+    public Resources costPerTroop;
+    public Amount availableCreatures;
 
     @CommandHandler
     @CreationPolicy(AggregateCreationPolicy.CREATE_IF_MISSING) // performance downside in comparison to constructor

src/main/java/com/dddheroes/heroesofddd/shared/infrastructure/serialization/DwellingIdSerializationModule.java

@@ -0,0 +1,35 @@
+package com.dddheroes.heroesofddd.shared.infrastructure.serialization;
+
+import com.dddheroes.heroesofddd.creaturerecruitment.write.DwellingId;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonDeserializer;
+import com.fasterxml.jackson.databind.JsonSerializer;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.module.SimpleModule;
+
+import java.io.IOException;
+
+public class DwellingIdSerializationModule extends SimpleModule {
+
+    public DwellingIdSerializationModule() {
+        addSerializer(DwellingId.class, new DwellingIdSerializer());
+        addDeserializer(DwellingId.class, new DwellingIdDeserializer());
+    }
+
+    private static class DwellingIdSerializer extends JsonSerializer<DwellingId> {
+        @Override
+        public void serialize(DwellingId value, JsonGenerator gen, SerializerProvider serializers) throws IOException {
+            gen.writeString(value.raw());
+        }
+    }
+
+    private static class DwellingIdDeserializer extends JsonDeserializer<DwellingId> {
+        @Override
+        public DwellingId deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
+            String value = p.getValueAsString();
+            return DwellingId.of(value);
+        }
+    }
+}

src/main/resources/application.yaml

@@ -17,8 +17,6 @@ spring:
       hibernate:
         dialect: org.hibernate.dialect.PostgreSQLDialect
 axon:
-  serializer:
-    general: jackson
   axonserver:
     enabled: true
   eventhandling: