1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.springframework.http.HttpStatus;
5 import org.springframework.http.ResponseEntity;
6 import org.springframework.web.bind.annotation.*;
10 import java.util.Optional;
11 import java.util.stream.Collectors;
15 @RequiredArgsConstructor
16 public class DriverController
18 private final ApplicationRecordHandler recordHandler;
19 private final AdderResults results;
23 public Map<Integer, Map<String, AdderResult>> state()
30 .collect(Collectors.toMap(
31 entry -> entry.getKey(),
32 entry -> entry.getValue().getState()));
35 @GetMapping("state/{user}")
36 public ResponseEntity<Long> state(@PathVariable String user)
38 for (AdderBusinessLogic adder : recordHandler.getState().values())
40 Optional<Long> sum = adder.getSum(user);
42 return ResponseEntity.ok(sum.get());
45 return ResponseEntity.notFound().build();
48 @GetMapping("results")
49 public Map<Integer, Map<String, List<AdderResult>>> results()
51 return results.getState();
54 @GetMapping("results/{user}")
55 public ResponseEntity<List<AdderResult>> results(@PathVariable String user)
57 for (Map<String, List<AdderResult>> resultsByUser : this.results.getState().values())
59 List<AdderResult> results = resultsByUser.get(user);
61 return ResponseEntity.ok(results);
64 return ResponseEntity.notFound().build();
69 @ResponseStatus(HttpStatus.BAD_REQUEST)
70 public ErrorResponse illegalStateException(IllegalStateException e)
72 return new ErrorResponse(e.getMessage(), HttpStatus.BAD_REQUEST.value());