From ccb49a2655ee3ed1a4d8134af8c906ecdda7c422 Mon Sep 17 00:00:00 2001
From: Colin DAMON <cdamon@ippon.fr>
Date: Wed, 6 Jan 2021 17:40:57 +0100
Subject: [PATCH] Java streams code & coffee code
---
.gitlab-ci.yml | 1 +
README.md | 1 +
java-streams/.gitlab-ci.yml | 11 ++++
java-streams/pom.xml | 29 +++++++++
java-streams/readme.md | 9 +++
.../main/java/fr/ippon/streams/Employee.java | 19 ++++++
.../src/main/java/fr/ippon/streams/Mall.java | 60 +++++++++++++++++++
.../src/main/java/fr/ippon/streams/Shop.java | 22 +++++++
.../java/fr/ippon/streams/MallUnitTest.java | 41 +++++++++++++
9 files changed, 193 insertions(+)
create mode 100644 java-streams/.gitlab-ci.yml
create mode 100644 java-streams/pom.xml
create mode 100644 java-streams/readme.md
create mode 100644 java-streams/src/main/java/fr/ippon/streams/Employee.java
create mode 100644 java-streams/src/main/java/fr/ippon/streams/Mall.java
create mode 100644 java-streams/src/main/java/fr/ippon/streams/Shop.java
create mode 100644 java-streams/src/test/java/fr/ippon/streams/MallUnitTest.java
diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml
index d973ee18..8e05cf05 100644
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -22,3 +22,4 @@ include:
- local: "/trip-service-kata-typescript/.gitlab-ci.yml"
- local: "/roman-calculator/.gitlab-ci.yml"
- local: "/h2g2/.gitlab-ci.yml"
+ - local: "/java-streams/.gitlab-ci.yml"
diff --git a/README.md b/README.md
index fcfc29ee..c7b7f35f 100644
--- a/README.md
+++ b/README.md
@@ -46,3 +46,4 @@ Ce dépôt Git a pour but de partager les différents ateliers pouvant être ré
| [Roman calculator](/roman-calculator) | Kata | Moyenne |
| [Atomic Design I and II](https://gitlab.ippon.fr/arey/pattern-library) | Front | Moyenne |
| [H2G2 (TypeScript)](/h2g2) | Kata | Moyenne |
+| [Java streams](/java-streams) | Code&coffee | Moyenne |
diff --git a/java-streams/.gitlab-ci.yml b/java-streams/.gitlab-ci.yml
new file mode 100644
index 00000000..af95a330
--- /dev/null
+++ b/java-streams/.gitlab-ci.yml
@@ -0,0 +1,11 @@
+package-java-streams:
+ variables:
+ PROJECT_FOLDER: "java-streams"
+ extends: .java
+ only:
+ refs:
+ - master
+ - merge_requests
+ changes:
+ - ".gitlab-common-ci.yml"
+ - "java-streams/**/*"
diff --git a/java-streams/pom.xml b/java-streams/pom.xml
new file mode 100644
index 00000000..c2cdc21e
--- /dev/null
+++ b/java-streams/pom.xml
@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <version>1.0.0</version>
+ <groupId>fr.ippon.kata</groupId>
+ <artifactId>java-parent</artifactId>
+ <relativePath>../java-parent</relativePath>
+ </parent>
+
+ <version>1.0.0-SNAPSHOT</version>
+ <artifactId>java-streams</artifactId>
+
+ <name>JavaStreams</name>
+
+ <developers>
+ <developer>
+ <email>arey@ippon.fr</email>
+ <name>Anthony REY</name>
+ </developer>
+ <developer>
+ <email>cdamon@ippon.fr</email>
+ <name>Colin DAMON</name>
+ </developer>
+ </developers>
+</project>
diff --git a/java-streams/readme.md b/java-streams/readme.md
new file mode 100644
index 00000000..97d95693
--- /dev/null
+++ b/java-streams/readme.md
@@ -0,0 +1,9 @@
+# Java streams
+
+Code & coffee pour parler des streams en Java
+
+- **Auteurs** : Anthony REY & Colin DAMON
+- **Date** : 06/01/2021
+- **Langage** : Java
+- **Niveau** : Moyen
+- **Replay** : TODO
diff --git a/java-streams/src/main/java/fr/ippon/streams/Employee.java b/java-streams/src/main/java/fr/ippon/streams/Employee.java
new file mode 100644
index 00000000..52950711
--- /dev/null
+++ b/java-streams/src/main/java/fr/ippon/streams/Employee.java
@@ -0,0 +1,19 @@
+package fr.ippon.streams;
+
+public class Employee {
+ private final String name;
+ private final int age;
+
+ public Employee(String name, int age) {
+ this.name = name;
+ this.age = age;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public int getAge() {
+ return age;
+ }
+}
diff --git a/java-streams/src/main/java/fr/ippon/streams/Mall.java b/java-streams/src/main/java/fr/ippon/streams/Mall.java
new file mode 100644
index 00000000..33fe8555
--- /dev/null
+++ b/java-streams/src/main/java/fr/ippon/streams/Mall.java
@@ -0,0 +1,60 @@
+package fr.ippon.streams;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+public class Mall {
+ private final List<Shop> shops;
+
+ public Mall(Shop... shops) {
+ this.shops = Arrays.asList(shops);
+ }
+
+ public Collection<String> getShopNames() {
+ return shops.stream().map(Shop::getName).sorted().collect(Collectors.toList());
+ }
+
+ public String getEmployeesMeanAge() {
+ return employeesAgeStream()
+ .map(BigDecimal::valueOf)
+ .reduce(BigDecimal::add)
+ .map(this::toAverage)
+ .orElse(BigDecimal.ZERO)
+ .toPlainString();
+ }
+
+ private Stream<Integer> employeesAgeStream() {
+ return shops.stream().flatMap(this::toEmployeesAges);
+ }
+
+ private Stream<Integer> toEmployeesAges(Shop shop) {
+ return toEmployees(shop).map(Employee::getAge);
+ }
+
+ private BigDecimal toAverage(BigDecimal sum) {
+ return sum.divide(new BigDecimal(employeesAgeStream().count()), 2, RoundingMode.HALF_UP);
+ }
+
+ public Collection<String> getEmployeesOver(int age) {
+ return shops
+ .stream()
+ .flatMap(this::toEmployees)
+ .filter(employee -> overAge(age, employee))
+ .map(Employee::getName)
+ .sorted()
+ .collect(Collectors.toList());
+ }
+
+ private Stream<Employee> toEmployees(Shop shop) {
+ return shop.getEmployees().stream();
+ }
+
+ private boolean overAge(int age, Employee employee) {
+ return employee.getAge() > age;
+ }
+}
diff --git a/java-streams/src/main/java/fr/ippon/streams/Shop.java b/java-streams/src/main/java/fr/ippon/streams/Shop.java
new file mode 100644
index 00000000..1c4d1c30
--- /dev/null
+++ b/java-streams/src/main/java/fr/ippon/streams/Shop.java
@@ -0,0 +1,22 @@
+package fr.ippon.streams;
+
+import java.util.Arrays;
+import java.util.Collection;
+
+public class Shop {
+ private final String name;
+ private final Collection<Employee> employees;
+
+ public Shop(String name, Employee... employees) {
+ this.name = name;
+ this.employees = Arrays.asList(employees);
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public Collection<Employee> getEmployees() {
+ return employees;
+ }
+}
diff --git a/java-streams/src/test/java/fr/ippon/streams/MallUnitTest.java b/java-streams/src/test/java/fr/ippon/streams/MallUnitTest.java
new file mode 100644
index 00000000..4bdfd540
--- /dev/null
+++ b/java-streams/src/test/java/fr/ippon/streams/MallUnitTest.java
@@ -0,0 +1,41 @@
+package fr.ippon.streams;
+
+import static org.assertj.core.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+
+public class MallUnitTest {
+ private static final Mall mall = mall(shop("Nature", employee("Michel", 25)), shop("Beer", employee("Bob", 42), employee("John", 19)));
+
+ @Test
+ void shouldGetShopNames() {
+ assertThat(mall.getShopNames()).containsExactly("Beer", "Nature");
+ }
+
+ @Test
+ void shouldGetZeroAverageAgeWithoutShopInMall() {
+ assertThat(new Mall().getEmployeesMeanAge()).isEqualTo("0");
+ }
+
+ @Test
+ void shouldGetEmployeesAverageAge() {
+ assertThat(mall.getEmployeesMeanAge()).isEqualTo("28.67");
+ }
+
+ @Test
+ void shouldGetEmployeesOverAge() {
+ assertThat(mall.getEmployeesOver(20)).containsExactly("Bob", "Michel");
+ }
+
+ private static Mall mall(Shop... shops) {
+ return new Mall(shops);
+ }
+
+ private static Shop shop(String name, Employee... employees) {
+ return new Shop(name, employees);
+ }
+
+ private static Employee employee(String name, int age) {
+ return new Employee(name, age);
+ }
+}
--
GitLab