X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Ftrion%2Fkafka%2Foutbox%2FOutboxController.java;h=e1f89190a81c61810d61b316c3fcce5474c62735;hb=5dea0011f01dac3a691a30bb0cd9495252f67d8b;hp=934ca1fe84b5fa5336e3eab2bf54497b737eed69;hpb=a498c7ae070b064dc7ea9a453b389ecff5c190ce;p=demos%2Fkafka%2Foutbox

diff --git a/src/main/java/de/trion/kafka/outbox/OutboxController.java b/src/main/java/de/trion/kafka/outbox/OutboxController.java
index 934ca1f..e1f8919 100644
--- a/src/main/java/de/trion/kafka/outbox/OutboxController.java
+++ b/src/main/java/de/trion/kafka/outbox/OutboxController.java
@@ -2,26 +2,44 @@ package de.trion.kafka.outbox;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.context.request.async.DeferredResult;
+import org.springframework.web.servlet.support.ServletUriComponentsBuilder;
+import org.springframework.web.util.UriComponents;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.time.LocalDateTime;
 
 @RestController
+@Transactional
+@RequestMapping("/users")
 public class OutboxController {
 
     private static final Logger LOG = LoggerFactory.getLogger(OutboxController.class);
 
 
-    private final OutboxService service;
+    private final UserRepository repository;
 
 
-    public OutboxController(OutboxService service) {
-        this.service = service;
+    public OutboxController(UserRepository repository) {
+        this.repository = repository;
     }
 
 
-    @PostMapping("/create")
-    public ResponseEntity<Void> getVorgang(@RequestBody String user) {
+    @PostMapping
+    public ResponseEntity<Void> getVorgang(
+            ServletUriComponentsBuilder builder,
+            @RequestBody String username) {
+        String cleaned = username.trim().toLowerCase();
+        User user = new User(cleaned, LocalDateTime.now(), false);
+        repository.save(user);
+        // TODO: Not-Unique Fehler auslösen
+        UriComponents uri =
+                builder
+                    .fromCurrentRequest()
+                    .path("{username}")
+                    .buildAndExpand(cleaned);
+        return ResponseEntity.created(uri.toUri()).build();
     }
 }