Add processor injection to infra components and mongo compose configu…

…ration

common/src/main/java/com/temelt/Processor.java

@@ -0,0 +1,11 @@
+package com.temelt;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.TYPE)
+public @interface Processor {
+}

employee-service/domain/pom.xml

@@ -23,5 +23,11 @@
             <artifactId>lombok</artifactId>
             <optional>true</optional>
         </dependency>
+        <dependency>
+            <groupId>com.temelt</groupId>
+            <artifactId>common</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 </project>

employee-service/domain/src/main/java/com/temelt/employee/model/CreateEmployeeRequest.java

@@ -0,0 +1,6 @@
+package com.temelt.employee.model;
+
+import com.temelt.common.Scenario;
+
+public class CreateEmployeeRequest implements Scenario {
+}

employee-service/domain/src/main/java/com/temelt/employee/port/EmployeePort.java

@@ -1,9 +1,12 @@
 package com.temelt.employee.port;
 
+import com.temelt.employee.model.CreateEmployeeRequest;
 import com.temelt.employee.model.Employee;
 import java.util.Optional;
 
 public interface EmployeePort {
 
     Optional<Employee> getEmployee(String id);
+
+    Employee createEmployee(CreateEmployeeRequest request);
 }

employee-service/domain/src/main/java/com/temelt/employee/processor/CreateEmployeeRequestProcessor.java

@@ -0,0 +1,16 @@
+package com.temelt.employee.processor;
+
+import com.temelt.Processor;
+import com.temelt.common.ScenarioProcessor;
+import com.temelt.employee.model.CreateEmployeeRequest;
+import com.temelt.employee.model.Employee;
+import lombok.RequiredArgsConstructor;
+
+@Processor
+@RequiredArgsConstructor
+public class CreateEmployeeRequestProcessor implements ScenarioProcessor<Employee, CreateEmployeeRequest> {
+    @Override
+    public Employee process(CreateEmployeeRequest item) {
+        throw new UnsupportedOperationException();
+    }
+}

employee-service/infrastructure/src/main/java/com/temelt/employee/EmployeeServiceApp.java

@@ -1,8 +1,16 @@
 package com.temelt.employee;
 
+import com.temelt.Processor;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.FilterType;
 
+@ComponentScan(
+        includeFilters = {
+                @ComponentScan.Filter(type = FilterType.ANNOTATION, value = {Processor.class})
+        }
+)
 @SpringBootApplication
 public class EmployeeServiceApp {
 

employee-service/infrastructure/src/main/java/com/temelt/employee/adapters/rest/EmployeeRest.java

@@ -1,18 +1,31 @@
 package com.temelt.employee.adapters.rest;
 
+import com.temelt.common.ScenarioProcessor;
+import com.temelt.employee.model.CreateEmployeeRequest;
 import com.temelt.employee.model.Employee;
+import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 @RequestMapping("employee")
+@RequiredArgsConstructor
 public class EmployeeRest {
+    private final ScenarioProcessor<Employee, CreateEmployeeRequest> createEmployeeRequestProcessor;
 
     @GetMapping("/id")
     public ResponseEntity<Employee> getEmployee(@PathVariable String id) {
         return ResponseEntity.ok(new Employee(id));
     }
+
+    @PostMapping
+    public ResponseEntity<Employee> createEmployee(@RequestBody CreateEmployeeRequest request) {
+        var result = createEmployeeRequestProcessor.process(request);
+        return ResponseEntity.ok(result);
+    }
 }

inventory-service/domain/src/main/java/com/temelt/inventory/processor/InventoryCreationProcessor.java → inventory-service/domain/src/main/java/com/temelt/inventory/processor/CreateInventoryRequestProcessor.java

@@ -1,16 +1,20 @@
 package com.temelt.inventory.processor;
 
+import com.temelt.Processor;
 import com.temelt.common.ScenarioProcessor;
 import com.temelt.inventory.exception.InvalidDescriptionException;
 import com.temelt.inventory.model.CreateInventoryRequest;
 import com.temelt.inventory.model.Inventory;
+import lombok.RequiredArgsConstructor;
 
-public class InventoryCreationProcessor implements ScenarioProcessor<Inventory, CreateInventoryRequest> {
+@Processor
+@RequiredArgsConstructor
+public class CreateInventoryRequestProcessor implements ScenarioProcessor<Inventory, CreateInventoryRequest> {
 
     @Override
     public Inventory process(CreateInventoryRequest item) {
         if (item.getDescription() == null || item.getDescription().trim().length() < 3) {
-            throw new InvalidDescriptionException("inventory.create.description");
+            throw new InvalidDescriptionException("inventory.create.description.invalid");
         }
         throw new UnsupportedOperationException();
     }

inventory-service/infrastructure/src/main/java/com/temel/inventory/InventoryServiceApp.java

@@ -1,8 +1,16 @@
 package com.temel.inventory;
 
+import com.temelt.Processor;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.FilterType;
 
+@ComponentScan(
+        includeFilters = {
+                @ComponentScan.Filter(type = FilterType.ANNOTATION, value = {Processor.class})
+        }
+)
 @SpringBootApplication
 public class InventoryServiceApp {
 

tools/docker-compose.dev.yml

@@ -0,0 +1,8 @@
+version: '3.9'
+services:
+  mongo:
+    image: mongo
+    profiles:
+      - dev
+    ports:
+      - "27017:27017"

tools/start.sh

@@ -0,0 +1,10 @@
+#!/bin/bash
+
+if [[ "$#" -eq 0 ]];
+then
+    docker-compose -f docker-compose.dev.yml --profile dev up -d --build
+    exit
+else
+    docker-compose -f docker-compose.dev.yml --profile dev "$@" up -d --build
+    exit
+fi