feat: basic template and structure for tasks handler

Author: Ricardo Campos

README.md

@@ -2,10 +2,10 @@
 Java REST API to play with AWS technologies
 
 Tasks:
-- receive a task through HTTP Request
-- Get task description template from AWS S3
-- Replace and fill task template with values
-- Send to SQS to be sent through email as finished
+- List all tasks available through GET http request: http://localhost:8080/tasks/get-list
+- Receive a task name through POST HTTP request to be processed: http://localhost:8080/tasks/handle-task/CODE_REVIEW
+  - Get task description from AWS S3 given the task name
+  - Send to SQS to be sent through email as finished
 
 ### Packaging
 

src/main/java/br/com/campos/ricardo/awsjavarestapi/AwsJavaRestApiApplication.java

@@ -6,8 +6,7 @@
 @SpringBootApplication
 public class AwsJavaRestApiApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(AwsJavaRestApiApplication.class, args);
-	}
-
+  public static void main(String[] args) {
+    SpringApplication.run(AwsJavaRestApiApplication.class, args);
+  }
 }

src/main/java/br/com/campos/ricardo/awsjavarestapi/Task.java

@@ -0,0 +1,3 @@
+package br.com.campos.ricardo.awsjavarestapi;
+
+public record Task(String name, String description) {}

src/main/java/br/com/campos/ricardo/awsjavarestapi/TaskController.java

@@ -0,0 +1,27 @@
+package br.com.campos.ricardo.awsjavarestapi;
+
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+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.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/tasks")
+public class TaskController {
+
+  @Autowired private TaskService taskService;
+
+  @GetMapping(path = "/get-list", produces = MediaType.APPLICATION_JSON_VALUE)
+  public List<String> getTasksList() {
+    return taskService.getTaskList();
+  }
+
+  @PostMapping(path = "/handle-task/{taskName}", produces = MediaType.APPLICATION_JSON_VALUE)
+  public TaskResponse doTask(@PathVariable String taskName) {
+    return taskService.handleTask(taskName);
+  }
+}

src/main/java/br/com/campos/ricardo/awsjavarestapi/TaskEnum.java

@@ -0,0 +1,21 @@
+package br.com.campos.ricardo.awsjavarestapi;
+
+public enum TaskEnum {
+  CODE_REVIEW("CODE_REVIEW"),
+  HELP_COLLEAGUES("HELP_COLLEAGUES");
+
+  private String code;
+
+  TaskEnum(String code) {
+    this.code = code;
+  }
+
+  public static TaskEnum getByCode(String code) {
+    for (TaskEnum taskEnum : values()) {
+      if (taskEnum.code.equals(code)) {
+        return taskEnum;
+      }
+    }
+    return null;
+  }
+}

src/main/java/br/com/campos/ricardo/awsjavarestapi/TaskResponse.java

@@ -0,0 +1,12 @@
+package br.com.campos.ricardo.awsjavarestapi;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class TaskResponse {
+
+  private String message;
+  private Task task;
+}

src/main/java/br/com/campos/ricardo/awsjavarestapi/TaskService.java

@@ -0,0 +1,67 @@
+package br.com.campos.ricardo.awsjavarestapi;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatus;
+import org.springframework.stereotype.Service;
+import org.springframework.web.server.ResponseStatusException;
+
+@Slf4j
+@Service
+public class TaskService {
+
+  public List<String> getTaskList() {
+    List<String> tasks = new ArrayList<>();
+    Arrays.asList(TaskEnum.values())
+        .forEach(
+            task -> {
+              tasks.add(task.toString());
+            });
+    return tasks;
+  }
+
+  public TaskResponse handleTask(String taskName) {
+    TaskEnum taskEnum = TaskEnum.getByCode(taskName);
+    if (taskEnum == null) {
+      throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "Invalid Task!");
+    }
+
+    log.info("Handling task: {}", taskName);
+
+    // Get from AWS S3
+    String template = getTemplate(taskEnum);
+    if (template.isBlank()) {
+      throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "No template for this Task!");
+    }
+
+    // Send to SQS to be sent through email
+    Task task = new Task(taskEnum.name(), template);
+    sendToSqs(task);
+
+    TaskResponse response = new TaskResponse();
+    response.setTask(task);
+    response.setMessage("Task processed and sent to the Queue!");
+
+    return response;
+  }
+
+  private String getTemplate(TaskEnum task) {
+    log.info("Getting task template from AWS S3");
+
+    if (task.equals(TaskEnum.CODE_REVIEW)) {
+      log.info("Template found for task CODE_REVIEW");
+      return "Here 1";
+    } else if (task.equals(TaskEnum.HELP_COLLEAGUES)) {
+      log.info("Template found for task HELP_COLLEAGUES");
+      return "Here 2";
+    }
+    log.warn("No template found for task :(");
+    return "";
+  }
+
+  private void sendToSqs(Task task) {
+    log.info("Sending task to SQS {}", task.name());
+  }
+}