chore: final code version - meetup SouJava Florianopolis

Signed-off-by: Maximillian Arruda <[email protected]>
JNOSQL · Nov 10, 2023 · b4a91d9 · b4a91d9
1 parent 703b02b
commit b4a91d9
Show file tree

Hide file tree

Showing 2 changed files with 46 additions and 2 deletions.
diff --git a/jnopo-talk/src/main/java/br/org/soujava/coffewithjava/jnopo/PlayoffsResource.java b/jnopo-talk/src/main/java/br/org/soujava/coffewithjava/jnopo/PlayoffsResource.java
@@ -50,8 +50,21 @@ public Set<String> getWinners(
     public Set<String> getLosers(
             @QueryParam("name") String name
     ) {
-        // TODO
-        throw new WebApplicationException(Response.Status.SERVICE_UNAVAILABLE);
+        if (name != null)
+            return playoffs.findByLoserNameLike(name)
+                    .stream()
+                    .map(g -> g.loser().name())
+                    .collect(Collectors.toSet());
+        return playoffs.listPlayoffsWithWinnerAndLoser()
+                .stream()
+                .map(g -> g.loser().name())
+                .collect(Collectors.toSet());
     }
 
+    @GET
+    @Path("/ranking")
+    @WithSpan
+    public Ranking getRanking(){
+        return Ranking.winnerRanking(playoffs);
+    }
 }
diff --git a/jnopo-talk/src/main/java/br/org/soujava/coffewithjava/jnopo/Ranking.java b/jnopo-talk/src/main/java/br/org/soujava/coffewithjava/jnopo/Ranking.java
@@ -0,0 +1,31 @@
+package br.org.soujava.coffewithjava.jnopo;
+
+import io.opentelemetry.instrumentation.annotations.WithSpan;
+
+import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+public record Ranking(Map<String, Integer> players) {
+    @WithSpan
+    public static Ranking winnerRanking(Playoffs playoffs) {
+        return of(playoffs, g -> g.winner().name());
+    }
+
+    private static Ranking of(Playoffs playoffs, Function<GameMatch, String> groupingFunction) {
+        var data =
+                playoffs.listPlayoffsWithWinnerAndLoser()
+                        .stream()
+                        .collect(
+                                Collectors.groupingBy(
+                                        groupingFunction,
+                                        Collectors.collectingAndThen(Collectors.toList(), Collection::size))
+                        ).entrySet()
+                        .stream()
+                        .sorted(Map.Entry.comparingByValue(Comparator.reverseOrder()))
+                        .collect(Collectors.toMap(
+                                Map.Entry::getKey, Map.Entry::getValue, (e1, e2) -> e1, LinkedHashMap::new));
+
+        return new Ranking(data);
+    }
+}