X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fboot%2Fdata%2Fjdbc%2FUserController.java;h=0aaefd5d704de5b910e4f798ea316914edebe9bf;hb=9a913cd7691592c38257a705123a8d16677be2cb;hp=4eb10941aa9d1155ead8011b5353b043d5311710;hpb=ec8e83ec01ee3ac203619f675b696a758351ca72;p=demos%2Fkafka%2Foutbox

diff --git a/src/main/java/de/juplo/boot/data/jdbc/UserController.java b/src/main/java/de/juplo/boot/data/jdbc/UserController.java
index 4eb1094..0aaefd5 100644
--- a/src/main/java/de/juplo/boot/data/jdbc/UserController.java
+++ b/src/main/java/de/juplo/boot/data/jdbc/UserController.java
@@ -2,6 +2,8 @@ package de.juplo.boot.data.jdbc;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.dao.IncorrectResultSizeDataAccessException;
 import org.springframework.http.ResponseEntity;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
@@ -10,6 +12,9 @@ import org.springframework.web.util.UriComponents;
 
 import java.time.LocalDateTime;
 
+import static de.juplo.boot.data.jdbc.UserEvent.Type.CREATED;
+import static de.juplo.boot.data.jdbc.UserEvent.Type.DELETED;
+
 @RestController
 @Transactional
 @RequestMapping("/users")
@@ -19,10 +24,15 @@ public class UserController {
 
 
     private final UserRepository repository;
+    private final ApplicationEventPublisher publisher;
 
 
-    public UserController(UserRepository repository) {
+    public UserController(
+            UserRepository repository,
+            ApplicationEventPublisher publisher)
+    {
         this.repository = repository;
+        this.publisher = publisher;
     }
 
 
@@ -32,7 +42,12 @@ public class UserController {
             @RequestBody String username) {
         String sanitizedUsername = UserController.sanitize(username);
         User user = new User(sanitizedUsername, LocalDateTime.now(), false);
+
+        // Triggering a unique-error for username prevents persistence
         repository.save(user);
+        publisher.publishEvent(new UserEvent(this, CREATED, sanitizedUsername));
+        user = repository.findByUsername(sanitizedUsername);
+
         UriComponents uri =
             builder
                 .fromCurrentRequest()
@@ -59,6 +74,7 @@ public class UserController {
             return ResponseEntity.notFound().build();
 
         repository.delete(user);
+        publisher.publishEvent(new UserEvent(this, DELETED, username));
 
         return ResponseEntity.ok(user);
     }
@@ -75,4 +91,13 @@ public class UserController {
 
         return string.trim().toLowerCase();
     }
+
+    @ExceptionHandler
+    public ResponseEntity<?> incorrectResultSizeDataAccessException(
+        IncorrectResultSizeDataAccessException e
+        )
+    {
+      LOG.info("User already exists!");
+      return ResponseEntity.badRequest().build();
+    }
 }