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=78d4999622b712fcbd1c39146f0b09d663bba00b;hpb=27982748e3e226a7dcb06397a3855e3ed2181ec8;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 78d4999..e1f8919 100644 --- a/src/main/java/de/trion/kafka/outbox/OutboxController.java +++ b/src/main/java/de/trion/kafka/outbox/OutboxController.java @@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory; import org.springframework.http.ResponseEntity; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; +import org.springframework.web.servlet.support.ServletUriComponentsBuilder; import org.springframework.web.util.UriComponents; import org.springframework.web.util.UriComponentsBuilder; @@ -26,14 +27,19 @@ public class OutboxController { } - @PostMapping() + @PostMapping public ResponseEntity getVorgang( - UriComponentsBuilder builder, + ServletUriComponentsBuilder builder, @RequestBody String username) { - User user = new User(username, LocalDateTime.now(), false); + 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.path("/{username}").buildAndExpand(username); + UriComponents uri = + builder + .fromCurrentRequest() + .path("{username}") + .buildAndExpand(cleaned); return ResponseEntity.created(uri.toUri()).build(); } }