Adding Heading support

Author: luismr

docker-compose.yml

@@ -1,4 +1,3 @@
-version: '3.8'
 
 services:
   redis:

pom.xml

@@ -143,6 +143,11 @@
             <artifactId>h2</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>com.fasterxml.jackson.datatype</groupId>
+            <artifactId>jackson-datatype-jsr310</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/dev/luismachadoreis/flighttracker/server/common/infrastructure/JacksonConfig.java

@@ -0,0 +1,25 @@
+package dev.luismachadoreis.flighttracker.server.common.infrastructure;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Configuration for Jackson ObjectMapper.
+ */
+@Configuration
+public class JacksonConfig {
+
+    /**
+     * Creates a new ObjectMapper with the JavaTimeModule registered.
+     * @return the ObjectMapper
+     */
+    @Bean
+    public ObjectMapper objectMapper() {
+        ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.registerModule(new JavaTimeModule());
+        return objectMapper;
+    }
+
+} 

src/main/java/dev/luismachadoreis/flighttracker/server/common/utils/JsonUtils.java

@@ -2,20 +2,25 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-
+import org.springframework.stereotype.Component;
 /**
  * Utility class for JSON serialization and deserialization.
  */
+@Component
 public class JsonUtils {
 
-    private static final ObjectMapper objectMapper = new ObjectMapper();
+    private final ObjectMapper objectMapper;
+
+    public JsonUtils(ObjectMapper objectMapper) {
+        this.objectMapper = objectMapper;
+    }
 
     /**
      * Serializes an object to a JSON string.
      * @param object the object to serialize
      * @return the JSON string
      */
-    public static String toJson(Object object) {
+    public String toJson(Object object) {
         try {
             return objectMapper.writeValueAsString(object);
         } catch (JsonProcessingException e) {

src/main/java/dev/luismachadoreis/flighttracker/server/ping/domain/Ping.java

@@ -196,6 +196,7 @@ public void registerPingCreated() {
             this.aircraft.callsign(),
             this.position.latitude(),
             this.position.longitude(),
+            this.vector.trueTrack(),
             this.position.geoAltitude(),
             this.position.baroAltitude(),
             this.position.onGround(),

src/main/java/dev/luismachadoreis/flighttracker/server/ping/domain/event/PingCreated.java

@@ -15,6 +15,8 @@ public record PingCreated  (
     Double latitude,
     @JsonProperty("longitude")
     Double longitude,
+    @JsonProperty("true_track")
+    Double trueTrack,
     @JsonProperty("geo_altitude")
     Double geoAltitude,
     @JsonProperty("baro_altitude")

src/main/java/dev/luismachadoreis/flighttracker/server/ping/infrastructure/pubsub/PingEventPublisher.java

@@ -16,13 +16,16 @@
 public class PingEventPublisher {
 
     private final MapUpdatesHandler mapUpdatesHandler;
-   
+    private final JsonUtils jsonUtils;
+
     /**
      * Constructor for PingEventPublisher.
      * @param mapUpdatesHandler the MapUpdatesHandler to publish to
+     * @param jsonUtils the JsonUtils to use for serialization
      */
-    public PingEventPublisher(MapUpdatesHandler mapUpdatesHandler) {
+    public PingEventPublisher(MapUpdatesHandler mapUpdatesHandler, JsonUtils jsonUtils) {
         this.mapUpdatesHandler = mapUpdatesHandler;
+        this.jsonUtils = jsonUtils;
     }
 
     /**
@@ -31,7 +34,7 @@ public PingEventPublisher(MapUpdatesHandler mapUpdatesHandler) {
      */ 
     @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)   
     public void handlePingCreated(PingCreated event) {
-        mapUpdatesHandler.sendMessage(JsonUtils.toJson(event));
+        mapUpdatesHandler.sendMessage(jsonUtils.toJson(event));
     }
 
 }