create imperative version of user service

Author: rarycoringa

Dockerfile

@@ -10,4 +10,4 @@ RUN mvn clean package -DskipTests
 FROM eclipse-temurin:21-jdk-alpine
 WORKDIR /app
 COPY --from=build /app/target/user-0.0.1-SNAPSHOT.jar app.jar
-ENTRYPOINT ["java", "-jar", "app.jar", "--spring.profiles.active=webflux"]
+ENTRYPOINT ["java", "-jar", "app.jar", "--spring.profiles.active=webmvc"]

docker-compose.yaml

@@ -1,7 +1,7 @@
 services:
-  user-webflux:
+  user-webmvc:
     build: .
-    container_name: user-webflux
+    container_name: user-webmvc
     environment:
       - SERVER_PORT=8181
     ports:

justfile

@@ -3,7 +3,7 @@ build:
 
 run:
     mvn spring-boot:run \
-        -Dspring-boot.run.profiles=webflux
+        -Dspring-boot.run.profiles=webmvc
 
 up:
     docker compose up --build --detach

pom.xml

@@ -12,7 +12,7 @@
 	<artifactId>user</artifactId>
 	<version>0.0.1-SNAPSHOT</version>
 	<name>user</name>
-	<description>User Webflux Service</description>
+	<description>User WebMVC Service</description>
 	<url/>
 	<licenses>
 		<license/>
@@ -38,17 +38,17 @@
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-webflux</artifactId>
+			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 
 		<!-- Storage dependencies -->
 		<dependency>
             <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
+            <artifactId>spring-boot-starter-data-mongodb</artifactId>
         </dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
+			<artifactId>spring-boot-starter-data-redis</artifactId>
 		</dependency>
 
 		<!-- Cloud dependencies -->

src/main/java/br/edu/ufrn/user/UserApplication.java

@@ -2,10 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.web.reactive.config.EnableWebFlux;
+import org.springframework.web.servlet.config.annotation.EnableWebMvc;
 
+@EnableWebMvc
 @SpringBootApplication
-@EnableWebFlux
 public class UserApplication {
 
 	public static void main(String[] args) {

src/main/java/br/edu/ufrn/user/config/WebConfig.java

@@ -2,14 +2,14 @@
 
 import org.springframework.context.annotation.Configuration;
 import org.springframework.web.bind.annotation.RestController;
-import org.springframework.web.reactive.config.PathMatchConfigurer;
-import org.springframework.web.reactive.config.WebFluxConfigurer;
+import org.springframework.web.servlet.config.annotation.PathMatchConfigurer;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
 @Configuration
-public class WebConfig implements WebFluxConfigurer {
+public class WebConfig implements WebMvcConfigurer {
 
     @Override
-    public void configurePathMatching(PathMatchConfigurer configurer) {
+    public void configurePathMatch(PathMatchConfigurer configurer) {
         configurer.addPathPrefix(
             "/restapi",
             c -> c.isAnnotationPresent(RestController.class)

src/main/java/br/edu/ufrn/user/controller/UserGraphQLController.java

@@ -1,5 +1,7 @@
 package br.edu.ufrn.user.controller;
 
+import java.util.List;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.graphql.data.method.annotation.Argument;
 import org.springframework.graphql.data.method.annotation.MutationMapping;
@@ -9,8 +11,6 @@
 import br.edu.ufrn.user.record.CreateUserDTO;
 import br.edu.ufrn.user.record.UserDTO;
 import br.edu.ufrn.user.service.UserService;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
 
 @Controller
 public class UserGraphQLController {
@@ -19,23 +19,23 @@ public class UserGraphQLController {
     private UserService userService;
 
     @QueryMapping
-    public Flux<UserDTO> getAll() {
+    public List<UserDTO> getAll() {
         return userService.getAll();
     }
 
     @QueryMapping
-    public Mono<UserDTO> getById(@Argument String id) {
+    public UserDTO getById(@Argument String id) {
         return userService.getById(id);
     }
 
     @MutationMapping
-    public Mono<UserDTO> save(@Argument("createUserInput") CreateUserDTO createUserDTO) {
+    public UserDTO save(@Argument("createUserInput") CreateUserDTO createUserDTO) {
         return userService.save(createUserDTO);
     }
 
     @MutationMapping
-    public Mono<Void> delete(@Argument String id) {
-        return userService.delete(id);
+    public void delete(@Argument String id) {
+        userService.delete(id);
     }
 
 }

src/main/java/br/edu/ufrn/user/controller/UserRestAPIController.java

@@ -1,7 +1,8 @@
 package br.edu.ufrn.user.controller;
 
+import java.util.List;
+
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -13,8 +14,6 @@
 import br.edu.ufrn.user.record.CreateUserDTO;
 import br.edu.ufrn.user.record.UserDTO;
 import br.edu.ufrn.user.service.UserService;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
 
 @RestController
 @RequestMapping("/users")
@@ -23,24 +22,24 @@ public class UserRestAPIController {
     @Autowired
     private UserService userService;
 
-    @GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
-    public Flux<UserDTO> getAll() {
+    @GetMapping
+    public List<UserDTO> getAll() {
         return userService.getAll();
     }
 
     @GetMapping("/{id}")
-    public Mono<UserDTO> getById(@PathVariable String id) {
+    public UserDTO getById(@PathVariable String id) {
         return userService.getById(id);
     }
 
     @PostMapping
-    public Mono<UserDTO> save(@RequestBody CreateUserDTO createUserDTO) {
+    public UserDTO save(@RequestBody CreateUserDTO createUserDTO) {
         return userService.save(createUserDTO);
     }
 
     @DeleteMapping("/{id}")
-    public Mono<Void> delete(@PathVariable String id) {
-        return userService.delete(id);
+    public void delete(@PathVariable String id) {
+        userService.delete(id);
     }
 
 }

src/main/java/br/edu/ufrn/user/repository/UserRepository.java

@@ -1,9 +1,9 @@
 package br.edu.ufrn.user.repository;
 
-import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.data.mongodb.repository.MongoRepository;
 import org.springframework.stereotype.Repository;
 
 import br.edu.ufrn.user.model.User;
 
 @Repository
-public interface UserRepository extends ReactiveMongoRepository<User, String> {}
+public interface UserRepository extends MongoRepository<User, String> {}

src/main/java/br/edu/ufrn/user/service/UserService.java

@@ -1,64 +1,59 @@
 package br.edu.ufrn.user.service;
 
+import java.util.List;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import br.edu.ufrn.user.model.User;
 import br.edu.ufrn.user.record.CreateUserDTO;
 import br.edu.ufrn.user.record.UserDTO;
 import br.edu.ufrn.user.repository.UserRepository;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
 
 @Service
 public class UserService {
 
     @Autowired
     private UserRepository userRepository;
 
-    public Flux<UserDTO> getAll() {
+    public List<UserDTO> getAll() {
         return userRepository.findAll()
-            .map(
-                user -> new UserDTO(
-                    user.getId(),
-                    user.getName(),
-                    user.getAge(),
-                    user.getCreatedAt()
-                )
-            );
+            .stream()
+            .map(user -> new UserDTO(
+                user.getId(),
+                user.getName(),
+                user.getAge(),
+                user.getCreatedAt()
+                ))
+            .toList();
     }
 
-    public Mono<UserDTO> getById(String id) {
-        return userRepository.findById(id)
-            .map(
-                user -> new UserDTO(
-                    user.getId(),
-                    user.getName(),
-                    user.getAge(),
-                    user.getCreatedAt()
-                )
-            );
+    public UserDTO getById(String id) {
+        User user = userRepository.findById(id).get();
+        return new UserDTO(
+            user.getId(),
+            user.getName(),
+            user.getAge(),
+            user.getCreatedAt());
     }
 
-    public Mono<UserDTO> save(CreateUserDTO createUserDTO) {
-        User userModel = new User(
+    public UserDTO save(CreateUserDTO createUserDTO) {
+        User user = new User(
             createUserDTO.name(),
             createUserDTO.age()
         );
 
-        return userRepository.save(userModel)
-            .map(
-                user -> new UserDTO(
-                    user.getId(),
-                    user.getName(),
-                    user.getAge(),
-                    user.getCreatedAt()
-                )
-            );
+        User savedUser = userRepository.save(user);
+
+        return new UserDTO(
+            savedUser.getId(),
+            savedUser.getName(),
+            savedUser.getAge(),
+            savedUser.getCreatedAt());
     }
 
-    public Mono<Void> delete(String id) {
-        return userRepository.deleteById(id);
+    public void delete(String id) {
+        userRepository.deleteById(id);
     }
 
 }