fixes for 3rd practical

api-gateway/build.gradle.kts

@@ -1,24 +0,0 @@
-plugins {
-    id("java")
-    alias(libs.plugins.spring.boot)
-}
-
-group = "ua.com.dxrkness"
-version = "1.0-SNAPSHOT"
-
-repositories {
-    mavenCentral()
-}
-
-dependencies {
-    // spring
-    implementation(platform(org.springframework.boot.gradle.plugin.SpringBootPlugin.BOM_COORDINATES))
-    implementation(platform(libs.spring.cloud.dependencies))
-    implementation("org.springframework.cloud:spring-cloud-starter-gateway-server-webflux")
-    implementation("org.springframework.cloud:spring-cloud-starter-netflix-eureka-client")
-    implementation("org.springframework.cloud:spring-cloud-starter-loadbalancer")
-}
-
-tasks.test {
-    useJUnitPlatform()
-}

api-gateway/src/main/java/ua/com/dxrkness/gateway/ApiGatewayApplication.java

@@ -1,11 +0,0 @@
-package ua.com.dxrkness.gateway;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-@SpringBootApplication
-public class ApiGatewayApplication {
-    static void main(String[] args) {
-        SpringApplication.run(ApiGatewayApplication.class, args);
-    }
-}

api-gateway/src/main/resources/application.yaml

@@ -1,18 +0,0 @@
-server:
-  port: 8079
-spring:
-  cloud:
-    gateway:
-      server:
-        webflux:
-          discovery:
-            locator:
-              enabled: true
-              lower-case-service-id: true
-  application:
-    name: api-gateway
-eureka:
-  client:
-    service-url:
-      defaultZone: http://localhost:8070/eureka
-    register-with-eureka: false

eureka-server/build.gradle.kts

@@ -1,22 +0,0 @@
-plugins {
-    id("java")
-    alias(libs.plugins.spring.boot)
-}
-
-group = "ua.com.dxrkness"
-version = "1.0-SNAPSHOT"
-
-repositories {
-    mavenCentral()
-}
-
-dependencies {
-    // spring
-    implementation(platform(org.springframework.boot.gradle.plugin.SpringBootPlugin.BOM_COORDINATES))
-    implementation(platform(libs.spring.cloud.dependencies))
-    implementation("org.springframework.cloud:spring-cloud-starter-netflix-eureka-server")
-}
-
-tasks.test {
-    useJUnitPlatform()
-}

eureka-server/src/main/java/ua/com/dxrkness/EurekaServerApplication.java

@@ -1,13 +0,0 @@
-package ua.com.dxrkness;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
-
-@SpringBootApplication
-@EnableEurekaServer
-public class EurekaServerApplication {
-    static void main(String[] args) {
-        SpringApplication.run(EurekaServerApplication.class, args);
-    }
-}

eureka-server/src/main/resources/application.yaml

@@ -1,11 +0,0 @@
-server:
-  port: 8070
-spring:
-  application:
-    name: eureka-server
-eureka:
-  instance:
-    hostname: localhost
-  client:
-    register-with-eureka: false
-    fetch-registry: false

freight-service/build.gradle.kts

@@ -13,8 +13,6 @@ repositories {
 dependencies {
     // spring
     implementation(platform(org.springframework.boot.gradle.plugin.SpringBootPlugin.BOM_COORDINATES))
-    implementation(platform(libs.spring.cloud.dependencies))
-    implementation("org.springframework.cloud:spring-cloud-starter-netflix-eureka-client")
     implementation(libs.spring.boot.starter.web)
     implementation(libs.spring.boot.starter.web.test)
 

freight-service/src/main/java/ua/com/dxrkness/controller/FreightController.java

@@ -7,6 +7,7 @@ import io.swagger.v3.oas.annotations.tags.Tag;
 import org.jspecify.annotations.Nullable;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.*;
+import ua.com.dxrkness.dto.FreightRequest;
 import ua.com.dxrkness.model.Freight;
 import ua.com.dxrkness.service.FreightService;
 
@@ -74,8 +75,8 @@ public class FreightController {
             description = "Invalid freight data (e.g., weight exceeds vehicle capacity)"
     )
     @PostMapping
-    public Freight add(@RequestBody Freight newFreight) {
-        return service.add(newFreight);
+    public Freight add(@RequestBody FreightRequest newFreight) {
+        return service.add(newFreight.toEntity());
     }
 
     @Operation(
@@ -91,8 +92,8 @@ public class FreightController {
             description = "Invalid input"
     )
     @PutMapping("/{id}")
-    public Freight update(@PathVariable("id") long id, @RequestBody Freight newFreight) {
-        return service.update(id, newFreight);
+    public Freight update(@PathVariable("id") long id, @RequestBody FreightRequest newFreight) {
+        return service.update(id, newFreight.toEntity());
     }
 
     @Operation(
@@ -108,8 +109,8 @@ public class FreightController {
             description = "Invalid input"
     )
     @PatchMapping("/{id}")
-    public Freight updatePatch(@PathVariable("id") long id, @RequestBody Freight newFreight) {
-        return service.update(id, newFreight);
+    public Freight updatePatch(@PathVariable("id") long id, @RequestBody FreightRequest newFreight) {
+        return service.update(id, newFreight.toEntity());
     }
 
     @Operation(

freight-service/src/main/resources/application.yaml

@@ -3,7 +3,3 @@ spring:
     name: freight-service
 server:
   port: 8080
-eureka:
-  client:
-    service-url:
-      defaultZone: http://localhost:8070/eureka

gradle/libs.versions.toml

@@ -5,7 +5,6 @@ jspecify = "1.0.0"
 springdoc = "3.0.0"
 apache-http-client = "4.5.14"
 json-schema-validator = "3.0.0"
-spring-cloud = "2025.1.0"
 
 [plugins]
 spring-boot = { id = "org.springframework.boot", version.ref = "spring-boot-plugin" }
@@ -16,7 +15,6 @@ spring-boot-starter-web = { group = "org.springframework.boot", name = "spring-b
 spring-boot-starter-web-test = { group = "org.springframework.boot", name = "spring-boot-starter-webmvc-test" }
 spring-boot-starter-hateoas = { group = "org.springframework.boot", name = "spring-boot-starter-hateoas" }
 spring-boot-devtools = { group = "org.springframework.boot", name = "spring-boot-devtools" }
-spring-cloud-dependencies = { group = "org.springframework.cloud", name = "spring-cloud-dependencies", version.ref = "spring-cloud" }
 
 # http client
 apache-http-client = { group = "org.apache.httpcomponents", name = "httpclient", version.ref = "apache-http-client" }
@@ -27,7 +25,6 @@ springdoc-openapi-starter-webmvc-ui = { group = "org.springdoc", name = "springd
 # jackson
 jackson-dataformat-xml = { group = "tools.jackson.dataformat", name = "jackson-dataformat-xml" }
 oldjackson-databind = { group = "com.fasterxml.jackson.core", name = "jackson-databind" }
-oldjackson-dataformat-xml = { group = "com.fasterxml.jackson.dataformat", name = "jackson-dataformat-xml" }
 
 # testing
 junit-bom = { group = "org.junit", name = "junit-bom", version.ref = "junit" }

models/build.gradle.kts

@@ -16,6 +16,5 @@ dependencies {
 
     // jackson
     api(libs.jackson.dataformat.xml)
-    api(libs.oldjackson.dataformat.xml)
     implementation(libs.oldjackson.databind)
 }

models/src/main/java/ua/com/dxrkness/dto/FreightRequest.java

@@ -0,0 +1,19 @@
+package ua.com.dxrkness.dto;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+import ua.com.dxrkness.model.Freight;
+
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+@tools.jackson.databind.annotation.JsonNaming(tools.jackson.databind.PropertyNamingStrategies.SnakeCaseStrategy.class)
+public record FreightRequest(
+        String name,
+        String description,
+        int weightKg,
+        Freight.Dimensions dimensions,
+        Freight.Status status
+) {
+    public Freight toEntity() {
+        return new Freight(0, name, description, weightKg, dimensions, status);
+    }
+}

models/src/main/java/ua/com/dxrkness/dto/RouteRequest.java

@@ -0,0 +1,21 @@
+package ua.com.dxrkness.dto;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+import ua.com.dxrkness.model.Route;
+
+import java.util.List;
+
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+@tools.jackson.databind.annotation.JsonNaming(tools.jackson.databind.PropertyNamingStrategies.SnakeCaseStrategy.class)
+public record RouteRequest(long vehicleId,
+                           List<Long> freightId,
+                           String startLocation,
+                           String endLocation,
+                           Double distanceKm,
+                           Double estimatedDurationHours,
+                           Route.Status status) {
+    public Route toEntity() {
+        return new Route(0, vehicleId, freightId, startLocation, endLocation, distanceKm, estimatedDurationHours, status);
+    }
+}

models/src/main/java/ua/com/dxrkness/dto/VehicleRequest.java

@@ -0,0 +1,20 @@
+package ua.com.dxrkness.dto;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+import ua.com.dxrkness.model.Vehicle;
+
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+@tools.jackson.databind.annotation.JsonNaming(tools.jackson.databind.PropertyNamingStrategies.SnakeCaseStrategy.class)
+public record VehicleRequest(
+        String brand,
+        String model,
+        String licensePlate,
+        int year,
+        int capacityKg,
+        Vehicle.Status status
+) {
+    public Vehicle toEntity() {
+        return new Vehicle(0, brand, model, licensePlate, year, capacityKg, status);
+    }
+}

populate.fish

@@ -51,22 +51,22 @@ function publish_correct
     }'
 
     printf '\n\n'
-    curl -X POST http://localhost:8079/vehicle-service/vehicles \
+    curl -X POST http://localhost:8081/vehicles \
       -H "Content-Type: application/json" \
       -d $vehicle
 
     printf '\n\n'
-    curl -X POST http://localhost:8079/freight-service/freights \
+    curl -X POST http://localhost:8080/freights \
       -H "Content-Type: application/json" \
       -d $freight1
 
     printf '\n\n'
-    curl -X POST http://localhost:8079/freight-service/freights \
+    curl -X POST http://localhost:8080/freights \
       -H "Content-Type: application/json" \
       -d $freight2
 
     printf '\n\n'
-    curl -X POST http://localhost:8079/route-service/routes \
+    curl -X POST http://localhost:8082/routes \
       -H "Content-Type: application/json" \
       -d $route
 end
@@ -86,8 +86,7 @@ function add_invalid_route
       "status": "PLANNED"
     }'
 
-  # 404 status is expected, since vehicle svc propagates it's error code to route svc
-    curl -X POST http://localhost:8082/routes \ 
+    curl -X POST http://localhost:8082/routes \
       -H "Content-Type: application/json" \
       -d $route
 end

route-service/build.gradle.kts

@@ -13,9 +13,6 @@ repositories {
 dependencies {
     // spring
     implementation(platform(org.springframework.boot.gradle.plugin.SpringBootPlugin.BOM_COORDINATES))
-    implementation(platform(libs.spring.cloud.dependencies))
-    implementation("org.springframework.cloud:spring-cloud-starter-netflix-eureka-client")
-    implementation("org.springframework.cloud:spring-cloud-starter-loadbalancer")
     implementation(libs.spring.boot.starter.web)
     implementation(libs.spring.boot.starter.web.test)
 

route-service/src/main/java/ua/com/dxrkness/client/FreightClient.java

@@ -2,10 +2,10 @@ package ua.com.dxrkness.client;
 
 import com.networknt.schema.InputFormat;
 import com.networknt.schema.Schema;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.http.HttpStatusCode;
 import org.springframework.http.MediaType;
 import org.springframework.stereotype.Component;
+import org.springframework.web.ErrorResponseException;
 import org.springframework.web.client.RestClient;
 import org.springframework.web.server.ResponseStatusException;
 import tools.jackson.core.type.TypeReference;
@@ -20,8 +20,8 @@ public class FreightClient {
     private final Schema freightSchema;
     private final JsonMapper mapper = JsonMapper.shared();
 
-    public FreightClient(@Qualifier("freightRestClient") RestClient.Builder freightRestClient, Schema freightSchema) {
-        this.freightRestClient = freightRestClient.build();
+    public FreightClient(RestClient freightRestClient, Schema freightSchema) {
+        this.freightRestClient = freightRestClient;
         this.freightSchema = freightSchema;
     }
 

route-service/src/main/java/ua/com/dxrkness/client/VehicleClient.java

@@ -3,7 +3,6 @@ package ua.com.dxrkness.client;
 import com.networknt.schema.Error;
 import com.networknt.schema.InputFormat;
 import com.networknt.schema.Schema;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.http.HttpStatusCode;
 import org.springframework.http.MediaType;
 import org.springframework.stereotype.Component;
@@ -21,8 +20,8 @@ public class VehicleClient {
     private final Schema vehicleSchema;
     private final JsonMapper mapper = JsonMapper.shared();
 
-    public VehicleClient(@Qualifier("vehicleRestClient") RestClient.Builder vehicleRestClient, Schema vehicleSchema) {
-        this.vehicleRestClient = vehicleRestClient.build();
+    public VehicleClient(RestClient vehicleRestClient, Schema vehicleSchema) {
+        this.vehicleRestClient = vehicleRestClient;
         this.vehicleSchema = vehicleSchema;
     }
 

route-service/src/main/java/ua/com/dxrkness/config/ClientConfiguration.java

@@ -1,28 +1,18 @@
 package ua.com.dxrkness.config;
 
-import org.springframework.cloud.client.loadbalancer.LoadBalanced;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.context.annotation.Primary;
 import org.springframework.web.client.RestClient;
 
 @Configuration
 public class ClientConfiguration {
     @Bean
-    @LoadBalanced
-    public RestClient.Builder vehicleRestClient() {
-       return RestClient.builder().baseUrl("http://vehicle-service/vehicles");
+    public RestClient vehicleRestClient() {
+       return RestClient.create("http://localhost:8081/vehicles");
     }
 
     @Bean
-    @LoadBalanced
-    public RestClient.Builder freightRestClient() {
-        return RestClient.builder().baseUrl("http://freight-service/freights");
-    }
-
-    @Bean
-    @Primary
-    public RestClient.Builder defaultRestClient() {
-        return RestClient.builder();
+    public RestClient freightRestClient() {
+        return RestClient.create("http://localhost:8080/freights");
     }
 }

route-service/src/main/java/ua/com/dxrkness/controller/RouteController.java

@@ -10,6 +10,7 @@ import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.*;
 import ua.com.dxrkness.client.FreightClient;
 import ua.com.dxrkness.client.VehicleClient;
+import ua.com.dxrkness.dto.RouteRequest;
 import ua.com.dxrkness.model.Freight;
 import ua.com.dxrkness.model.Route;
 import ua.com.dxrkness.model.Vehicle;
@@ -153,8 +154,8 @@ public class RouteController {
                     description = "Route object to be created. Must include valid vehicleId and freightId list.",
                     required = true
             )
-            @RequestBody Route newRoute) {
-        return routeService.add(newRoute);
+            @RequestBody RouteRequest newRoute) {
+        return routeService.add(newRoute.toEntity());
     }
 
     @Operation(
@@ -177,8 +178,8 @@ public class RouteController {
                     description = "Updated route object",
                     required = true
             )
-            @RequestBody Route newRoute) {
-        return routeService.update(id, newRoute);
+            @RequestBody RouteRequest newRoute) {
+        return routeService.update(id, newRoute.toEntity());
     }
 
     @Operation(
@@ -201,8 +202,8 @@ public class RouteController {
                     description = "Route object with fields to update",
                     required = true
             )
-            @RequestBody Route newRoute) {
-        return routeService.update(id, newRoute);
+            @RequestBody RouteRequest newRoute) {
+        return routeService.update(id, newRoute.toEntity());
     }
 
 

route-service/src/main/resources/application.yaml

@@ -1,13 +1,5 @@
 spring:
   application:
     name: route-service
-  cloud:
-    loadbalancer:
-      cache:
-        enabled: false
 server:
-  port: 8082
-eureka:
-  client:
-    service-url:
-      defaultZone: http://localhost:8070/eureka
+  port: 8082

settings.gradle.kts

@@ -1,4 +1,4 @@
 rootProject.name = "itroi"
 enableFeaturePreview("STABLE_CONFIGURATION_CACHE")
 
-include("models", "vehicle-service", "route-service", "freight-service", "shared", "api-gateway", "eureka-server")
+include("models", "vehicle-service", "route-service", "freight-service", "shared")

shared/src/main/java/ua/com/dxrkness/client/ApplicationClient.java

@@ -7,8 +7,11 @@ import org.apache.http.impl.client.HttpClients;
 import org.apache.http.util.EntityUtils;
 import org.springframework.http.HttpMethod;
 import org.springframework.http.HttpStatus;
-import tools.jackson.databind.json.JsonMapper;
+import tools.jackson.databind.ObjectMapper;
 import tools.jackson.dataformat.xml.XmlMapper;
+import ua.com.dxrkness.dto.FreightRequest;
+import ua.com.dxrkness.dto.RouteRequest;
+import ua.com.dxrkness.dto.VehicleRequest;
 import ua.com.dxrkness.model.Freight;
 import ua.com.dxrkness.model.Route;
 import ua.com.dxrkness.model.Vehicle;
@@ -16,9 +19,11 @@ import ua.com.dxrkness.model.Vehicle;
 import java.util.List;
 
 public class ApplicationClient {
-    private static final String BASE_URL = "http://localhost:8079";
-    private static final JsonMapper jsonMapper = JsonMapper.builder().build();
-    private static final XmlMapper xmlMapper = XmlMapper.builder().build();
+    private static final String FREIGHTS_BASE_URL = "http://localhost:8080";
+    private static final String VEHICLES_BASE_URL = "http://localhost:8081";
+    private static final String ROUTES_BASE_URL = "http://localhost:8082";
+    private static final ObjectMapper jsonMapper = new ObjectMapper();
+    private static final XmlMapper xmlMapper = new XmlMapper();
 
     static void main() {
         try (CloseableHttpClient client = HttpClients.createDefault()) {
@@ -31,170 +36,176 @@ public class ApplicationClient {
             testInterServiceValidation(client);
 
         } catch (Exception e) {
-            IO.println("error: " + e.getMessage());
+            System.out.println("error: " + e.getMessage());
             e.printStackTrace();
         }
     }
 
-    private static void testVehicles(CloseableHttpClient client) {
-        IO.println("--- VEHICLES ---");
+    private static void testVehicles(CloseableHttpClient client) throws Exception {
+        System.out.println("--- VEHICLES ---");
 
-        execute(client, new HttpGet(BASE_URL + "/vehicle-service/vehicles"), "GET all vehicles");
+        execute(client, new HttpGet(VEHICLES_BASE_URL + "/vehicles"), "GET all vehicles");
 
-        Vehicle newVehicle = new Vehicle(0, "Mercedes", "Actros", "AA1234BB", 2023, 18000, Vehicle.Status.AVAILABLE);
+        var newVehicle = new VehicleRequest("Mercedes", "Actros", "AA1234BB", 2023, 18000, Vehicle.Status.AVAILABLE);
         String vehicleXml = xmlMapper.writeValueAsString(newVehicle);
-        HttpPost post = new HttpPost(BASE_URL + "/vehicle-service/vehicles");
+        HttpPost post = new HttpPost(VEHICLES_BASE_URL + "/vehicles");
         post.setEntity(new StringEntity(vehicleXml, "UTF-8"));
         post.setHeader("Content-Type", "application/xml");
         post.setHeader("Accept", "application/xml");
         String createdVehicle = execute(client, post, "POST new vehicle");
 
-        var get = new HttpGet(BASE_URL + "/vehicle-service/vehicles/1");
+        var get = new HttpGet(VEHICLES_BASE_URL + "/vehicles/1");
         get.setHeader("Content-Type", "application/xml");
         execute(client, get, "GET vehicle by ID=1");
-        execute(client, new HttpGet(BASE_URL + "/vehicle-service/vehicles/999"), "GET vehicle by ID=999 (not found)");
+        execute(client, new HttpGet(VEHICLES_BASE_URL + "/vehicles/999"), "GET vehicle by ID=999 (not found)");
 
-        Vehicle updateVehicle = new Vehicle(1, "Volvo", "FH16", "BB5678CC", 2024, 20000, Vehicle.Status.MAINTENANCE);
-        var vehiclePut = createHttpRequest(updateVehicle, "/vehicle-service/vehicles/1", HttpMethod.PUT);
+        var updateVehicle = new VehicleRequest("Volvo", "FH16", "BB5678CC", 2024, 20000, Vehicle.Status.MAINTENANCE);
+        var vehiclePut = createHttpRequest(updateVehicle, "/vehicles/1", HttpMethod.PUT);
         execute(client, vehiclePut, "PUT update vehicle ID=1");
 
-        Vehicle patchVehicle = new Vehicle(1, "Volvo", "FH16", "BB5678CC", 2024, 20000, Vehicle.Status.IN_TRANSIT);
-        var vehiclePatch = createHttpRequest(patchVehicle, "/vehicle-service/vehicles/1", HttpMethod.PATCH);
+        var patchVehicle = new VehicleRequest("Volvo", "FH16", "BB5678CC", 2024, 20000, Vehicle.Status.IN_TRANSIT);
+        var vehiclePatch = createHttpRequest(patchVehicle, "/vehicles/1", HttpMethod.PATCH);
         execute(client, vehiclePatch, "PATCH update vehicle ID=1");
 
-        execute(client, new HttpDelete(BASE_URL + "/vehicle-service/vehicles/999"), "DELETE vehicle ID=999 (not found)");
+        execute(client, new HttpDelete(VEHICLES_BASE_URL + "/vehicles/999"), "DELETE vehicle ID=999 (not found)");
 
-        IO.println();
+        System.out.println();
     }
 
-    private static void testFreights(CloseableHttpClient client) {
-        IO.println("--- FREIGHTS ---");
+    private static void testFreights(CloseableHttpClient client) throws Exception {
+        System.out.println("--- FREIGHTS ---");
 
-        execute(client, new HttpGet(BASE_URL + "/freight-service" + "/freights"), "GET all freights");
+        execute(client, new HttpGet(FREIGHTS_BASE_URL + "/freights"), "GET all freights");
 
-        Freight.Dimensions dims = new Freight.Dimensions(120, 100, 200);
-        Freight newFreight = new Freight(1, "Electronics", "Laptops and monitors", 500, dims, Freight.Status.PENDING);
-        var freightPost = createHttpRequest(newFreight, "/freight-service/freights", HttpMethod.POST);
+        var dims = new Freight.Dimensions(120, 100, 200);
+        var newFreight = new FreightRequest("Electronics", "Laptops and monitors", 500, dims, Freight.Status.PENDING);
+        var freightPost = createHttpRequest(newFreight, "/freights", HttpMethod.POST);
         execute(client, freightPost, "POST new freight");
 
-        execute(client, new HttpGet(BASE_URL + "/freight-service/freights/1"), "GET freight by ID=1");
-        execute(client, new HttpGet(BASE_URL + "/freight-service/freights/999"), "GET freight by ID=999 (not found)");
+        execute(client, new HttpGet(FREIGHTS_BASE_URL + "/freights/1"), "GET freight by ID=1");
+        execute(client, new HttpGet(FREIGHTS_BASE_URL + "/freights/999"), "GET freight by ID=999 (not found)");
 
-        Freight updateFreight = new Freight(1, "Furniture", "Office desks", 800, dims, Freight.Status.IN_TRANSIT);
-        var freightPut = createHttpRequest(updateFreight, "/freight-service/freights/1", HttpMethod.PUT);
+        var updateFreight = new FreightRequest("Furniture", "Office desks", 800, dims, Freight.Status.IN_TRANSIT);
+        var freightPut = createHttpRequest(updateFreight, "/freights/1", HttpMethod.PUT);
         execute(client, freightPut, "PUT update freight ID=1");
 
-        Freight patchFreight = new Freight(1, "Furniture", "Office desks", 800, dims, Freight.Status.DELIVERED);
-        var freightPatch = createHttpRequest(patchFreight, "/freight-service/freights/1", HttpMethod.PATCH);
+        var patchFreight = new FreightRequest("Furniture", "Office desks", 800, dims, Freight.Status.DELIVERED);
+        var freightPatch = createHttpRequest(patchFreight, "/freights/1", HttpMethod.PATCH);
         execute(client, freightPatch, "PATCH update freight ID=1");
 
-        execute(client, new HttpDelete(BASE_URL + "/freight-service/freights/999"), "DELETE freight ID=999 (not found)");
+        execute(client, new HttpDelete(FREIGHTS_BASE_URL + "/freights/999"), "DELETE freight ID=999 (not found)");
 
-        IO.println();
+        System.out.println();
     }
 
-    private static void testRoutes(CloseableHttpClient client) {
-        IO.println("--- ROUTES ---");
+    private static void testRoutes(CloseableHttpClient client) throws Exception {
+        System.out.println("--- ROUTES ---");
 
-        Route newRoute = new Route(1, 1, List.of(1L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
-        var routePost = createHttpRequest(newRoute, "/route-service/routes", HttpMethod.POST);
+        var newRoute = new RouteRequest(1, List.of(1L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
+        var routePost = createHttpRequest(newRoute, "/routes", HttpMethod.POST);
         execute(client, routePost, "POST new route");
 
-        execute(client, new HttpGet(BASE_URL + "/route-service" + "/routes"), "GET all routes");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes"), "GET all routes");
 
-        execute(client, new HttpGet(BASE_URL + "/route-service" + "/routes/1"), "GET route by ID=1");
-        execute(client, new HttpGet(BASE_URL + "/route-service" + "/routes/999"), "GET route by ID=999 (not found)");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes/1"), "GET route by ID=1");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes/999"), "GET route by ID=999 (not found)");
 
-        Route updateRoute = new Route(1, 1, List.of(1L), "Kyiv", "Odesa", 480.0, 7.0, Route.Status.IN_PROGRESS);
-        var routePut = createHttpRequest(updateRoute, "/route-service/routes/1", HttpMethod.PUT);
+        var updateRoute = new RouteRequest(1, List.of(1L), "Kyiv", "Odesa", 480.0, 7.0, Route.Status.IN_PROGRESS);
+        var routePut = createHttpRequest(updateRoute, "/routes/1", HttpMethod.PUT);
         execute(client, routePut, "PUT update route ID=1");
 
-        Route patchRoute = new Route(1, 1, List.of(1L), "Kyiv", "Odesa", 480.0, 7.0, Route.Status.COMPLETED);
-        var routePatch = createHttpRequest(patchRoute, "/route-service/routes/1", HttpMethod.PATCH);
+        var patchRoute = new RouteRequest(1, List.of(1L), "Kyiv", "Odesa", 480.0, 7.0, Route.Status.COMPLETED);
+        var routePatch = createHttpRequest(patchRoute, "/routes/1", HttpMethod.PATCH);
         execute(client, routePatch, "PATCH update route ID=1");
 
-        execute(client, new HttpDelete(BASE_URL + "/route-service" + "/routes/999"), "DELETE route ID=999 (not found)");
+        execute(client, new HttpDelete(ROUTES_BASE_URL + "/routes/999"), "DELETE route ID=999 (not found)");
 
-        IO.println();
+        System.out.println();
     }
 
-    private static void testSubResources(CloseableHttpClient client) {
-        IO.println("--- SUB-RESOURCES ---");
+    private static void testSubResources(CloseableHttpClient client) throws Exception {
+        System.out.println("--- SUB-RESOURCES ---");
 
-        execute(client, new HttpGet(BASE_URL + "/route-service/routes/1/freights"), "GET freights for route ID=1 (sub-resource)");
-        execute(client, new HttpGet(BASE_URL + "/route-service/routes/1/vehicle"), "GET vehicle for route ID=1 (sub-resource)");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes/1/freights"), "GET freights for route ID=1 (sub-resource)");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes/1/vehicle"), "GET vehicle for route ID=1 (sub-resource)");
 
-        IO.println();
+        System.out.println();
     }
 
-    private static void testStatusFiltering(CloseableHttpClient client) {
-        IO.println("--- STATUS FILTERING ---");
+    private static void testStatusFiltering(CloseableHttpClient client) throws Exception {
+        System.out.println("--- STATUS FILTERING ---");
 
-        execute(client, new HttpGet(BASE_URL + "/vehicle-service/vehicles?status=AVAILABLE"), "GET vehicles with status=AVAILABLE");
-        execute(client, new HttpGet(BASE_URL + "/vehicle-service/vehicles?status=IN_TRANSIT"), "GET vehicles with status=IN_TRANSIT");
-        execute(client, new HttpGet(BASE_URL + "/freight-service/freights?status=PENDING"), "GET freights with status=PENDING");
-        execute(client, new HttpGet(BASE_URL + "/freight-service/freights?status=DELIVERED"), "GET freights with status=DELIVERED");
-        execute(client, new HttpGet(BASE_URL + "/route-service/routes?status=PLANNED"), "GET routes with status=PLANNED");
-        execute(client, new HttpGet(BASE_URL + "/route-service/routes?status=COMPLETED"), "GET routes with status=COMPLETED");
+        execute(client, new HttpGet(VEHICLES_BASE_URL + "/vehicles?status=AVAILABLE"), "GET vehicles with status=AVAILABLE");
+        execute(client, new HttpGet(VEHICLES_BASE_URL + "/vehicles?status=IN_TRANSIT"), "GET vehicles with status=IN_TRANSIT");
+        execute(client, new HttpGet(FREIGHTS_BASE_URL + "/freights?status=PENDING"), "GET freights with status=PENDING");
+        execute(client, new HttpGet(FREIGHTS_BASE_URL + "/freights?status=DELIVERED"), "GET freights with status=DELIVERED");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes?status=PLANNED"), "GET routes with status=PLANNED");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes?status=COMPLETED"), "GET routes with status=COMPLETED");
 
-        IO.println();
+        System.out.println();
     }
 
-    private static void testErrorCases(CloseableHttpClient client) {
-        IO.println("--- ERROR CASES (TESTING EXCEPTION HANDLING) ---");
+    private static void testErrorCases(CloseableHttpClient client) throws Exception {
+        System.out.println("--- ERROR CASES (TESTING EXCEPTION HANDLING) ---");
 
-        execute(client, new HttpGet(BASE_URL + "/vehicle-service/vehicles/999"), "GET non-existent vehicle (404 Not Found)");
-        execute(client, new HttpGet(BASE_URL + "/freight-service/freights/-1"), "GET freight with invalid ID (404 Not Found)");
-        execute(client, new HttpGet(BASE_URL + "/route-service/routes/-1"), "GET route with invalid ID (404 Not Found)");
+        execute(client, new HttpGet(VEHICLES_BASE_URL + "/vehicles/999"), "GET non-existent vehicle (404 Not Found)");
+        execute(client, new HttpGet(FREIGHTS_BASE_URL + "/freights/-1"), "GET freight with invalid ID (404 Not Found)");
+        execute(client, new HttpGet(ROUTES_BASE_URL + "/routes/-1"), "GET route with invalid ID (404 Not Found)");
 
-        IO.println();
+        System.out.println();
     }
 
-    private static void testInterServiceValidation(CloseableHttpClient client) {
-        IO.println("--- INTER-SERVICE COMMUNICATION & VALIDATION ---");
+    private static void testInterServiceValidation(CloseableHttpClient client) throws Exception {
+        System.out.println("--- INTER-SERVICE COMMUNICATION & VALIDATION ---");
 
         // Test 1: Create route with valid references (should succeed)
-        IO.println("[INTER-SERVICE TEST 1] Creating route with valid vehicle and freight references:");
-        Route validRoute = new Route(1, 1, List.of(1L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
-        var validRoutePost = createHttpRequest(validRoute, "/route-service/routes", HttpMethod.POST);
+        System.out.println("[INTER-SERVICE TEST 1] Creating route with valid vehicle and freight references:");
+        var validRoute = new RouteRequest(1, List.of(1L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
+        var validRoutePost = createHttpRequest(validRoute, "/routes", HttpMethod.POST);
         execute(client, validRoutePost, "POST route with valid vehicle and freights (should succeed)");
 
         // Test 2: Create route with invalid vehicle (should fail with 404)
-        IO.println("[INTER-SERVICE TEST 2] Creating route with INVALID vehicle ID:");
-        Route invalidVehicleRoute = new Route(1, -999, List.of(1L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
-        var invalidRoutePost = createHttpRequest(invalidVehicleRoute, "/route-service/routes", HttpMethod.POST);
+        System.out.println("[INTER-SERVICE TEST 2] Creating route with INVALID vehicle ID:");
+        var invalidVehicleRoute = new RouteRequest(-999, List.of(1L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
+        var invalidRoutePost = createHttpRequest(invalidVehicleRoute, "/routes", HttpMethod.POST);
         execute(client, invalidRoutePost, "POST route with invalid vehicle ID, should result in 404");
 
         // Test 3: Create route with invalid freight (should fail with 404)
-        IO.println("[INTER-SERVICE TEST 3] Creating route with INVALID freight ID:");
-        Route invalidFreightRoute = new Route(1, 1, List.of(-999L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
-        var invalidFreightPost = createHttpRequest(invalidFreightRoute, "/route-service/routes", HttpMethod.POST);
+        System.out.println("[INTER-SERVICE TEST 3] Creating route with INVALID freight ID:");
+        var invalidFreightRoute = new RouteRequest(1, List.of(-999L), "Kyiv", "Lviv", 540.0, 8.5, Route.Status.PLANNED);
+        var invalidFreightPost = createHttpRequest(invalidFreightRoute, "/routes", HttpMethod.POST);
         execute(client, invalidFreightPost, "POST route with invalid freight ID, should result in 404");
     }
 
     private static <T> HttpUriRequest createHttpRequest(T entity, String path, HttpMethod method) {
         String entityJson = jsonMapper.writeValueAsString(entity);
         HttpEntityEnclosingRequestBase req;
+        final String baseUrl = switch(entity) {
+            case FreightRequest _ -> FREIGHTS_BASE_URL;
+            case VehicleRequest _ -> VEHICLES_BASE_URL;
+            case RouteRequest _ -> ROUTES_BASE_URL;
+            default -> throw new IllegalArgumentException();
+        };
 
         if (method == HttpMethod.GET) {
-            return new HttpGet(BASE_URL + path);
+            return new HttpGet(baseUrl + path);
         } else if (method == HttpMethod.POST) {
-            req = new HttpPost(BASE_URL + path);
+            req = new HttpPost(baseUrl + path);
             req.setEntity(new StringEntity(entityJson, "UTF-8"));
             req.setHeader("Content-Type", "application/json");
             return req;
         } else if (method == HttpMethod.PUT) {
-            req = new HttpPut(BASE_URL + path);
+            req = new HttpPut(baseUrl + path);
             req.setEntity(new StringEntity(entityJson, "UTF-8"));
             req.setHeader("Content-Type", "application/json");
             return req;
         } else if (method == HttpMethod.PATCH) {
-            req = new HttpPatch(BASE_URL + path);
+            req = new HttpPatch(baseUrl + path);
             req.setEntity(new StringEntity(entityJson, "UTF-8"));
             req.setHeader("Content-Type", "application/json");
             return req;
         } else if (method == HttpMethod.DELETE) {
-            return new HttpDelete(BASE_URL + path);
+            return new HttpDelete(baseUrl + path);
         } else {
             throw new IllegalArgumentException("method is invalid");
         }
@@ -202,26 +213,26 @@ public class ApplicationClient {
 
     private static String execute(CloseableHttpClient client, HttpUriRequest request, String description) {
         try {
-            IO.println("[" + request.getMethod() + "] " + description);
+            System.out.println("[" + request.getMethod() + "] " + description);
             CloseableHttpResponse response = client.execute(request);
             int statusCode = response.getStatusLine().getStatusCode();
             String body = response.getEntity() != null ? EntityUtils.toString(response.getEntity()) : "";
 
-            IO.println("Status: " + statusCode);
+            System.out.println("Status: " + statusCode);
             if (!body.isEmpty()) {
-                IO.println("Response: " + body);
+                System.out.println("Response: " + body);
             }
 
             if (HttpStatus.valueOf(statusCode).isError()) {
-                IO.println("ERROR: Request failed with status " + statusCode);
+                System.out.println("ERROR: Request failed with status " + statusCode);
             }
 
-            IO.println();
+            System.out.println();
             return body;
         } catch (Exception e) {
-            IO.println("EXCEPTION: " + e.getMessage());
+            System.out.println("EXCEPTION: " + e.getMessage());
             e.printStackTrace();
-            IO.println();
+            System.out.println();
             return null;
         }
     }

vehicle-service/build.gradle.kts

@@ -13,9 +13,6 @@ repositories {
 dependencies {
     // spring
     implementation(platform(org.springframework.boot.gradle.plugin.SpringBootPlugin.BOM_COORDINATES))
-    implementation(platform(libs.spring.cloud.dependencies))
-    implementation("org.springframework.cloud:spring-cloud-starter-netflix-eureka-client")
-    implementation("org.springframework.boot:spring-boot-starter-aop:4.0.0-M2")
     implementation(libs.spring.boot.starter.web)
     implementation(libs.spring.boot.starter.web.test)
 

vehicle-service/src/main/java/ua/com/dxrkness/aspect/LoggingAspect.java

@@ -1,24 +0,0 @@
-package ua.com.dxrkness.aspect;
-
-import org.aspectj.lang.JoinPoint;
-import org.aspectj.lang.annotation.Aspect;
-import org.aspectj.lang.annotation.Before;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Component;
-
-@Aspect
-@Component
-public class LoggingAspect {
-    private static final Logger logger = LoggerFactory.getLogger(LoggingAspect.class);
-
-    @Value("${server.port}")
-    private String port;
-
-    @Before("execution(* ua.com.dxrkness.controller.VehicleController.*(..))")
-    public void logBeforeMethod(JoinPoint joinPoint) {
-        String methodName = joinPoint.getSignature().getName();
-        logger.info(">>> [Instance Port: {}] - Calling method: {}", port, methodName);
-    }
-}

vehicle-service/src/main/java/ua/com/dxrkness/controller/VehicleController.java

@@ -8,6 +8,7 @@ import org.jspecify.annotations.NullMarked;
 import org.jspecify.annotations.Nullable;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.*;
+import ua.com.dxrkness.dto.VehicleRequest;
 import ua.com.dxrkness.model.Vehicle;
 import ua.com.dxrkness.service.VehicleService;
 
@@ -68,8 +69,8 @@ public class VehicleController {
                     description = "Vehicle object to be created",
                     required = true
             )
-            @RequestBody Vehicle newVehicle) {
-        return service.add(newVehicle);
+            @RequestBody VehicleRequest newVehicle) {
+        return service.add(newVehicle.toEntity());
     }
 
     @Operation(
@@ -86,8 +87,8 @@ public class VehicleController {
                     description = "Updated vehicle object",
                     required = true
             )
-            @RequestBody Vehicle newVehicle) {
-        return service.update(id, newVehicle);
+            @RequestBody VehicleRequest newVehicle) {
+        return service.update(id, newVehicle.toEntity());
     }
 
     @Operation(
@@ -104,8 +105,8 @@ public class VehicleController {
                     description = "Vehicle object with fields to update",
                     required = true
             )
-            @RequestBody Vehicle newVehicle) {
-        return service.update(id, newVehicle);
+            @RequestBody VehicleRequest newVehicle) {
+        return service.update(id, newVehicle.toEntity());
     }
 
 

vehicle-service/src/main/resources/application.yaml

@@ -2,8 +2,4 @@ spring:
   application:
     name: vehicle-service
 server:
-  port: 8081
-eureka:
-  client:
-    service-url:
-      defaultZone: http://localhost:8070/eureka
+  port: 8081