Add base api controller

Author: rgomezcasas

apps/main/tv/codely/apps/backoffice/backend/controller/courses/CoursesGetController.java

@@ -3,9 +3,11 @@
 import org.springframework.web.bind.annotation.*;
 import tv.codely.backoffice.courses.application.BackofficeCoursesResponse;
 import tv.codely.backoffice.courses.application.search_by_criteria.SearchBackofficeCoursesByCriteriaQuery;
+import tv.codely.shared.domain.bus.command.CommandBus;
 import tv.codely.shared.domain.bus.query.QueryBus;
 import tv.codely.shared.domain.bus.query.QueryHandlerExecutionError;
 import tv.codely.shared.domain.bus.query.QueryNotRegisteredError;
+import tv.codely.shared.infrastructure.spring.ApiController;
 
 import java.io.Serializable;
 import java.util.ArrayList;
@@ -16,18 +18,16 @@
 
 @RestController
 @CrossOrigin(origins = "*", methods = {RequestMethod.GET})
-public final class CoursesGetController {
-    private final QueryBus bus;
-
-    public CoursesGetController(QueryBus bus) {
-        this.bus = bus;
+public final class CoursesGetController extends ApiController {
+    public CoursesGetController(QueryBus queryBus, CommandBus commandBus) {
+        super(queryBus, commandBus);
     }
 
     @GetMapping("/courses")
     public List<HashMap<String, String>> index(
         @RequestParam HashMap<String, Serializable> params
     ) throws QueryNotRegisteredError, QueryHandlerExecutionError {
-        BackofficeCoursesResponse courses = bus.ask(
+        BackofficeCoursesResponse courses = ask(
             new SearchBackofficeCoursesByCriteriaQuery(
                 parseFilters(params),
                 Optional.ofNullable((String) params.get("order_by")),

apps/main/tv/codely/apps/backoffice/backend/controller/health_check/HealthCheckGetController.java

@@ -2,11 +2,21 @@
 
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
+import tv.codely.shared.domain.bus.command.CommandBus;
+import tv.codely.shared.domain.bus.query.QueryBus;
+import tv.codely.shared.infrastructure.spring.ApiController;
 
 import java.util.HashMap;
 
 @RestController
-public final class HealthCheckGetController {
+public final class HealthCheckGetController extends ApiController {
+    public HealthCheckGetController(
+        QueryBus queryBus,
+        CommandBus commandBus
+    ) {
+        super(queryBus, commandBus);
+    }
+
     @GetMapping("/health-check")
     public HashMap<String, String> index() {
         HashMap<String, String> status = new HashMap<>();

apps/main/tv/codely/apps/mooc/backend/controller/courses/CoursesPutController.java

@@ -10,21 +10,24 @@
 import tv.codely.shared.domain.bus.command.CommandBus;
 import tv.codely.shared.domain.bus.command.CommandHandlerExecutionError;
 import tv.codely.shared.domain.bus.command.CommandNotRegisteredError;
+import tv.codely.shared.domain.bus.query.QueryBus;
+import tv.codely.shared.infrastructure.spring.ApiController;
 
 @RestController
-public final class CoursesPutController {
-    private final CommandBus bus;
-
-    public CoursesPutController(CommandBus bus) {
-        this.bus = bus;
+public final class CoursesPutController extends ApiController {
+    public CoursesPutController(
+        QueryBus queryBus,
+        CommandBus commandBus
+    ) {
+        super(queryBus, commandBus);
     }
 
     @PutMapping(value = "/courses/{id}")
     public ResponseEntity<String> index(
         @PathVariable String id,
         @RequestBody Request request
     ) throws CommandNotRegisteredError, CommandHandlerExecutionError {
-        bus.dispatch(new CreateCourseCommand(id, request.name(), request.duration()));
+        dispatch(new CreateCourseCommand(id, request.name(), request.duration()));
 
         return new ResponseEntity<>(HttpStatus.CREATED);
     }

apps/main/tv/codely/apps/mooc/backend/controller/courses_counter/CoursesCounterGetController.java

@@ -4,23 +4,23 @@
 import org.springframework.web.bind.annotation.RestController;
 import tv.codely.mooc.courses_counter.application.find.CoursesCounterResponse;
 import tv.codely.mooc.courses_counter.application.find.FindCoursesCounterQuery;
+import tv.codely.shared.domain.bus.command.CommandBus;
 import tv.codely.shared.domain.bus.query.QueryBus;
 import tv.codely.shared.domain.bus.query.QueryHandlerExecutionError;
 import tv.codely.shared.domain.bus.query.QueryNotRegisteredError;
+import tv.codely.shared.infrastructure.spring.ApiController;
 
 import java.util.HashMap;
 
 @RestController
-public final class CoursesCounterGetController {
-    QueryBus bus;
-
-    public CoursesCounterGetController(QueryBus bus) {
-        this.bus = bus;
+public final class CoursesCounterGetController extends ApiController {
+    public CoursesCounterGetController(QueryBus queryBus, CommandBus commandBus) {
+        super(queryBus, commandBus);
     }
 
     @GetMapping("/courses-counter")
     public HashMap<String, Integer> index() throws QueryNotRegisteredError, QueryHandlerExecutionError {
-        CoursesCounterResponse response = bus.ask(new FindCoursesCounterQuery());
+        CoursesCounterResponse response = ask(new FindCoursesCounterQuery());
 
         return new HashMap<String, Integer>() {{
             put("total", response.total());

apps/main/tv/codely/apps/mooc/backend/controller/health_check/HealthCheckGetController.java

@@ -2,11 +2,21 @@
 
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
+import tv.codely.shared.domain.bus.command.CommandBus;
+import tv.codely.shared.domain.bus.query.QueryBus;
+import tv.codely.shared.infrastructure.spring.ApiController;
 
 import java.util.HashMap;
 
 @RestController
-public final class HealthCheckGetController {
+public final class HealthCheckGetController extends ApiController {
+    public HealthCheckGetController(
+        QueryBus queryBus,
+        CommandBus commandBus
+    ) {
+        super(queryBus, commandBus);
+    }
+
     @GetMapping("/health-check")
     public HashMap<String, String> index() {
         HashMap<String, String> status = new HashMap<>();

apps/main/tv/codely/apps/mooc/backend/controller/notifications/NewsletterNotificationPutController.java

@@ -9,20 +9,23 @@
 import tv.codely.shared.domain.bus.command.CommandBus;
 import tv.codely.shared.domain.bus.command.CommandHandlerExecutionError;
 import tv.codely.shared.domain.bus.command.CommandNotRegisteredError;
+import tv.codely.shared.domain.bus.query.QueryBus;
+import tv.codely.shared.infrastructure.spring.ApiController;
 
 @RestController
-public final class NewsletterNotificationPutController {
-    private final CommandBus bus;
-
-    public NewsletterNotificationPutController(CommandBus bus) {
-        this.bus = bus;
+public final class NewsletterNotificationPutController extends ApiController {
+    public NewsletterNotificationPutController(
+        QueryBus queryBus,
+        CommandBus commandBus
+    ) {
+        super(queryBus, commandBus);
     }
 
     @PutMapping(value = "/newsletter/{id}")
     public ResponseEntity<String> index(
         @PathVariable String id
     ) throws CommandNotRegisteredError, CommandHandlerExecutionError {
-        bus.dispatch(new SendNewCoursesNewsletterCommand(id));
+        dispatch(new SendNewCoursesNewsletterCommand(id));
 
         return new ResponseEntity<>(HttpStatus.CREATED);
     }

src/shared/main/tv/codely/shared/infrastructure/spring/ApiController.java

@@ -0,0 +1,28 @@
+package tv.codely.shared.infrastructure.spring;
+
+import tv.codely.shared.domain.bus.command.Command;
+import tv.codely.shared.domain.bus.command.CommandBus;
+import tv.codely.shared.domain.bus.command.CommandHandlerExecutionError;
+import tv.codely.shared.domain.bus.command.CommandNotRegisteredError;
+import tv.codely.shared.domain.bus.query.Query;
+import tv.codely.shared.domain.bus.query.QueryBus;
+import tv.codely.shared.domain.bus.query.QueryHandlerExecutionError;
+import tv.codely.shared.domain.bus.query.QueryNotRegisteredError;
+
+public abstract class ApiController {
+    private final QueryBus queryBus;
+    private final CommandBus commandBus;
+
+    public ApiController(QueryBus queryBus, CommandBus commandBus) {
+        this.queryBus   = queryBus;
+        this.commandBus = commandBus;
+    }
+
+    protected void dispatch(Command command) throws CommandNotRegisteredError, CommandHandlerExecutionError {
+        commandBus.dispatch(command);
+    }
+
+    protected <R> R ask(Query query) throws QueryNotRegisteredError, QueryHandlerExecutionError {
+        return queryBus.ask(query);
+    }
+}