Migrating CQS to Spring Commander package

Author: luismr

pom.xml

@@ -25,8 +25,17 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <springdoc.version>2.3.0</springdoc.version>
+        <spring-commander.version>0.0.2</spring-commander.version>
     </properties>
 
+    <repositories>
+        <repository>
+            <id>github</id>
+            <name>Spring Commander GitHub Packages</name>
+            <url>https://maven.pkg.github.com/luismr/spring-commander</url>
+        </repository>
+    </repositories>
+    
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -65,7 +74,13 @@
             <artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
             <version>${springdoc.version}</version>
         </dependency>
-        
+
+        <dependency>
+            <groupId>dev.luismachadoreis.blueprint</groupId>
+            <artifactId>spring-commander</artifactId>
+            <version>${spring-commander.version}</version>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>

src/main/java/dev/luismachadoreis/flighttracker/server/common/application/cqs/command/Command.java

@@ -45,7 +45,7 @@ public DataSource dataSource(
             ReadWriteRoutingProperties props
     ) {
         if (!props.isEnabled()) {
-            return writer; // routing is OFF
+            return writer;
         }
 
         RoutingDataSource routingDataSource = new RoutingDataSource(writer, reader);

src/main/java/dev/luismachadoreis/flighttracker/server/common/application/cqs/command/CommandHandler.java

@@ -1,6 +1,6 @@
 package dev.luismachadoreis.flighttracker.server.flightdata.infrastructure.pubsub;
 
-import dev.luismachadoreis.flighttracker.server.common.application.cqs.mediator.Mediator;
+import dev.luismachadoreis.blueprint.cqs.SpringCommanderMediator;
 import dev.luismachadoreis.flighttracker.server.ping.application.CreatePingCommand;
 import dev.luismachadoreis.flighttracker.server.ping.application.dto.FlightDataDTO;
 import dev.luismachadoreis.flighttracker.server.ping.application.dto.PingDTOMapper;
@@ -14,7 +14,7 @@
 @RequiredArgsConstructor
 public class FlightDataSubscriber {
 
-    private final Mediator mediator;
+    private final SpringCommanderMediator mediator;
 
     @KafkaListener(topics = "${spring.kafka.topic.flight-positions}", groupId = "${spring.kafka.consumer.group-id}")
     public void consumeFlightData(FlightDataDTO data) {

src/main/java/dev/luismachadoreis/flighttracker/server/common/application/cqs/mediator/Mediator.java

@@ -3,7 +3,7 @@
 import dev.luismachadoreis.flighttracker.server.ping.application.CreatePingCommand;
 import dev.luismachadoreis.flighttracker.server.ping.application.GetRecentPingsQuery;
 import dev.luismachadoreis.flighttracker.server.ping.application.dto.PingDTO;
-import dev.luismachadoreis.flighttracker.server.common.application.cqs.mediator.Mediator;
+import dev.luismachadoreis.blueprint.cqs.SpringCommanderMediator;
 
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
@@ -29,10 +29,10 @@
 @Tag(name = "Ping API", description = "API for managing flight position pings")
 public class PingController {
 
-    private final Mediator mediator;
+    private final SpringCommanderMediator mediator;
     private final Integer defaultRequestLimit;
 
-    public PingController(Mediator mediator, @Value("${default.request.limit:50}") Integer defaultRequestLimit) {
+    public PingController(SpringCommanderMediator mediator, @Value("${default.request.limit:50}") Integer defaultRequestLimit) {
         this.mediator = mediator;
         this.defaultRequestLimit = defaultRequestLimit;
     }