X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FDriverController.java;h=d38927126ab58dd55a2c884ec0cbb104db08dc60;hb=b9a482c8228e0b9197d7cb0c3f6b8849e5cd66da;hp=5d6c1a8d0ca1657b96a516b52e9153d83ba906d0;hpb=2d84eda74475aaffff11ddfebe56d309b9aff2e9;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/DriverController.java b/src/main/java/de/juplo/kafka/DriverController.java index 5d6c1a8..d389271 100644 --- a/src/main/java/de/juplo/kafka/DriverController.java +++ b/src/main/java/de/juplo/kafka/DriverController.java @@ -6,7 +6,9 @@ import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.*; import java.util.Map; +import java.util.Optional; import java.util.concurrent.ExecutionException; +import java.util.stream.Collectors; @RestController @@ -14,7 +16,7 @@ import java.util.concurrent.ExecutionException; public class DriverController { private final EndlessConsumer consumer; - private final WordcountRecordHandler wordcount; + private final ApplicationRecordHandler recordHandler; @PostMapping("start") @@ -30,20 +32,27 @@ public class DriverController } - @GetMapping("seen") - public Map>> seen() + @GetMapping("state") + public Map> state() { - return wordcount.getSeen(); + return + recordHandler + .getState() + .entrySet() + .stream() + .collect(Collectors.toMap( + entry -> entry.getKey(), + entry -> entry.getValue().getState())); } - @GetMapping("seen/{user}") - public ResponseEntity> seen(@PathVariable String user) + @GetMapping("state/{user}") + public ResponseEntity seen(@PathVariable String user) { - for (Map> users : wordcount.getSeen().values()) + for (AdderBusinessLogic adder : recordHandler.getState().values()) { - Map words = users.get(user); - if (words != null) - return ResponseEntity.ok(words); + Optional sum = adder.getSum(user); + if (sum.isPresent()) + return ResponseEntity.ok(sum.get()); } return ResponseEntity.notFound().build();