Implement mongo repo

Author: jurna

build.gradle

@@ -13,17 +13,21 @@ repositories {
 }
 
 dependencies {
-//    implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'
     implementation 'org.springframework.boot:spring-boot-starter'
+    implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'
     implementation 'com.amazonaws.serverless:aws-serverless-java-container-springboot3:2.0.2'
     implementation 'com.amazonaws:aws-lambda-java-core:1.2.3'
     implementation 'com.amazonaws:aws-lambda-java-events:3.14.0'
 
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    testImplementation "org.springframework.boot:spring-boot-testcontainers"
+    testImplementation 'org.testcontainers:mongodb'
+    testImplementation "org.testcontainers:junit-jupiter"
 
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
     testRuntimeOnly 'org.springframework.boot:spring-boot-starter-tomcat'
 
+
     compileOnly 'org.projectlombok:lombok'
 
     annotationProcessor 'org.projectlombok:lombok'

…a/com/example/springlambda/Customer.java …mple/springlambda/customer/Customer.javasrc/main/java/com/example/springlambda/Customer.java renamed to src/main/java/com/example/springlambda/customer/Customer.java src/main/java/com/example/springlambda/Customer.java renamed to src/main/java/com/example/springlambda/customer/Customer.java

@@ -1,4 +1,8 @@
-package com.example.springlambda;
+package com.example.springlambda.customer;
+
+import java.util.List;
+
+import org.bson.types.ObjectId;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;
@@ -8,7 +12,9 @@
 @AllArgsConstructor
 @NoArgsConstructor
 public class Customer {
-    private String id;
+    private ObjectId id;
     private String firstName;
     private String lastName;
+
+    private List<String> log;
 }

…ple/springlambda/CustomerController.java …glambda/customer/CustomerController.javasrc/main/java/com/example/springlambda/CustomerController.java renamed to src/main/java/com/example/springlambda/customer/CustomerController.java src/main/java/com/example/springlambda/CustomerController.java renamed to src/main/java/com/example/springlambda/customer/CustomerController.java

@@ -1,17 +1,21 @@
-package com.example.springlambda;
+package com.example.springlambda.customer;
 
 import java.util.List;
 
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import lombok.AllArgsConstructor;
+
 @RestController
 @RequestMapping("/customer")
+@AllArgsConstructor
 public class CustomerController {
 
+    private final CustomerRepository customerRepository;
     @GetMapping
-    public List<Customer> getCustomers() {
-        return List.of(new Customer("1", "John", "Doe"));
+    public List<CustomerView> getCustomers() {
+        return customerRepository.listCustomers();
     }
 }

src/main/java/com/example/springlambda/customer/CustomerRepository.java

@@ -0,0 +1,27 @@
+package com.example.springlambda.customer;
+
+import java.util.List;
+import java.util.Optional;
+
+import org.springframework.data.mongodb.core.MongoOperations;
+import org.springframework.stereotype.Component;
+
+import lombok.AllArgsConstructor;
+
+@Component
+@AllArgsConstructor
+public class CustomerRepository {
+
+    private final MongoOperations mongoOperations;
+    public Optional<Customer> getCustomer(String id) {
+        return Optional.ofNullable(mongoOperations.findById(id, Customer.class));
+    }
+
+    public Customer saveCustomer(Customer customer) {
+        return mongoOperations.save(customer);
+    }
+
+    public List<CustomerView> listCustomers() {
+        return mongoOperations.query(Customer.class).as(CustomerView.class).all();
+    }
+}

src/main/java/com/example/springlambda/customer/CustomerView.java

@@ -0,0 +1,4 @@
+package com.example.springlambda.customer;
+
+public record CustomerView(String id, String firstName, String lastName) {
+}

src/main/resources/application.properties

@@ -0,0 +1,11 @@
+spring:
+  application:
+    name: spring-lambda
+  data:
+    mongodb:
+      repositories:
+        type: NONE
+
+logging:
+  level:
+    org.springframework.data.mongodb.core: DEBUG

src/main/resources/application.yaml

@@ -0,0 +1,36 @@
+package com.example.springlambda.customer;
+
+import java.util.List;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest;
+import org.springframework.test.context.bean.override.mockito.MockitoBean;
+import org.springframework.test.web.servlet.MockMvc;
+
+import jakarta.annotation.Resource;
+
+import static org.mockito.Mockito.when;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+
+@WebMvcTest(CustomerController.class)
+class CustomerControllerTest {
+    @MockitoBean
+    private CustomerRepository customerRepository;
+
+    @Resource
+    private MockMvc mockMvc;
+
+    @Test
+    void testGetCustomers() throws Exception {
+        var customer = new CustomerView("1", "John", "Doe");
+        when(customerRepository.listCustomers()).thenReturn(List.of(customer));
+
+        mockMvc.perform(get("/customer"))
+               .andExpect(status().isOk())
+               .andExpect(jsonPath("$[0].id").value("1"))
+               .andExpect(jsonPath("$[0].firstName").value("John"))
+               .andExpect(jsonPath("$[0].lastName").value("Doe"));
+    }
+}

src/test/java/com/example/springlambda/customer/CustomerControllerTest.java

@@ -0,0 +1,37 @@
+package com.example.springlambda.customer;
+
+import java.util.List;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
+import org.testcontainers.containers.MongoDBContainer;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
+
+import jakarta.annotation.Resource;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+@SpringBootTest
+@Testcontainers
+class CustomerRepositoryTest {
+
+    @Container
+    @ServiceConnection
+    private static final MongoDBContainer MONGO_DB_CONTAINER = new MongoDBContainer();
+    @Resource
+    private CustomerRepository customerRepository;
+
+    @Test
+    public void testListCustomer() {
+        var customer = new Customer(null, "John", "Doe", List.of("log1", "log2"));
+        var savedCustomer = customerRepository.saveCustomer(customer);
+
+        var result = customerRepository.listCustomers();
+
+        assertEquals(1, result.size());
+        assertEquals(savedCustomer.getId().toString(), result.getFirst().id());
+    }
+
+}