Merge pull request #15

Delete user

Author: mickablondo

src/main/java/dev/mikablondo/hibernate_reactive_test/controller/UserController.java

@@ -1,14 +1,16 @@
 package dev.mikablondo.hibernate_reactive_test.controller;
 
-import dev.mikablondo.hibernate_reactive_test.services.UserService;
 import dev.mikablondo.hibernate_reactive_test.dto.User;
+import dev.mikablondo.hibernate_reactive_test.services.UserService;
 import io.smallrye.mutiny.Multi;
 import io.smallrye.mutiny.Uni;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.UUID;
+
 /**
  * This class is a REST controller for managing User entities.
  * It provides an endpoint to retrieve all users from the database.
@@ -31,4 +33,17 @@ public Uni<ResponseEntity<Void>> createUser(@RequestBody User user) {
         return userService.createUser(user)
                 .map(v -> ResponseEntity.status(HttpStatus.CREATED).build());
     }
+
+    @DeleteMapping("/{id}")
+    public Uni<ResponseEntity<Void>> deleteUser(@PathVariable String id) {
+        try {
+            UUID uuid = UUID.fromString(id);
+            return userService.deleteUser(uuid)
+                    .map(deleted -> deleted
+                            ? ResponseEntity.status(HttpStatus.NO_CONTENT).build()
+                            : ResponseEntity.status(HttpStatus.NOT_FOUND).build());
+        } catch (IllegalArgumentException e) {
+            return Uni.createFrom().item(ResponseEntity.status(HttpStatus.BAD_REQUEST).build());
+        }
+    }
 }

src/main/java/dev/mikablondo/hibernate_reactive_test/dto/User.java

@@ -4,6 +4,8 @@
 import lombok.Builder;
 import lombok.Data;
 
+import java.util.UUID;
+
 /**
  * This class represents a User DTO (Data Transfer Object).
  * It contains fields for the user's name, surname, age, and profession.
@@ -14,6 +16,7 @@
 @Builder
 @AllArgsConstructor
 public class User {
+    private UUID id;
     private String nom;
     private String prenom;
     private int age;

src/main/java/dev/mikablondo/hibernate_reactive_test/repository/UserRepository.java

@@ -7,6 +7,8 @@
 import org.hibernate.reactive.mutiny.Mutiny;
 import org.springframework.stereotype.Repository;
 
+import java.util.UUID;
+
 /**
  * This class is a repository for managing UserEntity objects.
  * It uses Hibernate Reactive to perform database operations in a non-blocking way.
@@ -43,4 +45,32 @@ public Uni<Void> createUser(UserEntity entity) {
                         .onFailure().invoke((Throwable t) -> System.err.println("Failed to create user: " + t.getMessage()))
         ).replaceWithVoid();
     }
+
+    /**
+     * This method retrieves a user by its UUID from the database.
+     *
+     * @param uuid the UUID of the user to be retrieved
+     * @return a Uni<UserEntity> containing the user entity if found, or null if not found
+     */
+    public Uni<UserEntity> findById(UUID uuid) {
+        return sessionFactory.withTransaction((session, tx) ->
+                session.find(UserEntity.class, uuid)
+                        .onItem().invoke(user -> System.out.println("User found: " + user))
+                        .onFailure().invoke((Throwable t) -> System.err.println("Failed to find user: " + t.getMessage()))
+        );
+    }
+
+    /**
+     * This method deletes a user by its ID from the database.
+     *
+     * @param userId the ID of the user to be deleted
+     * @return a Uni<Boolean> indicating if user is deleted successfully or not
+     */
+    public Uni<Boolean> deleteUser(UUID userId) {
+        return sessionFactory.withTransaction((session, tx) ->
+                session.find(UserEntity.class, userId)
+                        .onItem().ifNotNull().transformToUni(user -> session.remove(user).replaceWith(true))
+                        .onItem().ifNull().continueWith(false)
+        );
+    }
 }

src/main/java/dev/mikablondo/hibernate_reactive_test/services/UserService.java

@@ -29,6 +29,7 @@ public class UserService {
     public Multi<User> getAllUsers() {
         return userRepository.findAll()
                 .onItem().transform(userEntity -> User.builder()
+                        .id(userEntity.getId())
                         .nom(userEntity.getNom())
                         .prenom(userEntity.getPrenom())
                         .age(userEntity.getAge())
@@ -51,4 +52,14 @@ public Uni<Void> createUser(User user) {
                         .metier(user.getMetier())
                         .build());
     }
+
+    /**
+     * This method deletes a user from the database.
+     *
+     * @param id the ID of the user to be deleted
+     * @return a Uni<Boolean> indicating if user is deleted successfully or not
+     */
+    public Uni<Boolean> deleteUser(UUID id) {
+        return userRepository.deleteUser(id);
+    }
 }