RSWW-56 transport-service: add write part of cqrs

Signed-off-by: Paweł Cichowski <[email protected]>

transport-service/src/main/java/org/microarchitecturovisco/transport/controllers/TransportsController.java

@@ -34,10 +34,15 @@ public String test() {
 
     @RabbitListener(queues = "transports.requests.getTransportsBySearchQuery")
     public void consumeGetTransportsRequest(String requestDtoJson) {
+        long startTime = System.currentTimeMillis();
+
         GetTransportsBySearchQueryRequestDto requestDto = JsonReader.readGetTransportsBySearchQueryRequestFromJson(requestDtoJson);
+
         GetTransportsBySearchQueryResponseDto responseDto = transportsService.getTransportsBySearchQuery(requestDto);
 
+        long endTime = System.currentTimeMillis();
         System.out.println("Send transports response size " + responseDto.getTransportDtoList().size());
+        System.out.println("Service call took " + (endTime - startTime) + " ms");
 
         rabbitTemplate.convertAndSend("transports.responses.getTransportsBySearchQuery", JsonConverter.convertGetTransportsBySearchQueryResponseDto(responseDto));
     }

transport-service/src/main/java/org/microarchitecturovisco/transport/model/cqrs/aggregates/TransportAggregate.java

@@ -0,0 +1,26 @@
+package org.microarchitecturovisco.transport.model.cqrs.aggregates;
+
+import lombok.RequiredArgsConstructor;
+import org.microarchitecturovisco.transport.model.cqrs.commands.CreateTransportCommand;
+import org.microarchitecturovisco.transport.model.cqrs.commands.UpdateTransportCommand;
+import org.microarchitecturovisco.transport.model.domain.Transport;
+import org.microarchitecturovisco.transport.repositories.TransportRepository;
+import org.springframework.stereotype.Component;
+
+@RequiredArgsConstructor
+@Component
+public class TransportAggregate {
+
+    private TransportRepository transportRepository;
+
+    public Transport handleCreateTransportCommand(CreateTransportCommand command) {
+
+        // TODO create transport logic
+        return null;
+    }
+
+    public Transport handleUpdateTransportCommand(UpdateTransportCommand command) {
+        // TODO update transport logic
+        return null;
+    }
+}

transport-service/src/main/java/org/microarchitecturovisco/transport/model/cqrs/commands/CreateTransportCommand.java

@@ -0,0 +1,12 @@
+package org.microarchitecturovisco.transport.model.cqrs.commands;
+
+import org.microarchitecturovisco.transport.model.dto.TransportDto;
+
+import java.time.LocalDateTime;
+
+public class CreateTransportCommand {
+    private String uuid;
+    private LocalDateTime commandCreatedTime;
+
+    private TransportDto transportDto;
+}

transport-service/src/main/java/org/microarchitecturovisco/transport/model/cqrs/commands/UpdateTransportCommand.java

@@ -0,0 +1,16 @@
+package org.microarchitecturovisco.transport.model.cqrs.commands;
+
+import lombok.Builder;
+import lombok.Data;
+import org.microarchitecturovisco.transport.model.dto.TransportDto;
+
+import java.time.LocalDateTime;
+
+@Data
+@Builder
+public class UpdateTransportCommand {
+    private String uuid;
+    private LocalDateTime commandCreatedTime;
+
+    private TransportDto transportDto;
+}

transport-service/src/main/java/org/microarchitecturovisco/transport/model/cqrs/projections/TransportProjection.java

@@ -0,0 +1,11 @@
+package org.microarchitecturovisco.transport.model.cqrs.projections;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@RequiredArgsConstructor
+@Component
+public class TransportProjection {
+
+
+}

transport-service/src/main/java/org/microarchitecturovisco/transport/model/cqrs/queries/QueryTransport.java

@@ -0,0 +1,5 @@
+package org.microarchitecturovisco.transport.model.cqrs.queries;
+
+public class QueryTransport {
+
+}

transport-service/src/main/resources/application.properties

@@ -2,7 +2,7 @@ spring.application.name=transport-service
 
 server.port=0
 
-eureka.client.service-url.defaultZone=http://discovery:8010/eureka
+eureka.client.service-url.defaultZone=http://localhost:8010/eureka
 
 eureka.instance.prefer-ip-address=true
 eureka.instance.instance-id=${spring.application.name}:${spring.application.instance_id:${random.value}}