Added maintainers

README.md

@@ -1,6 +1,16 @@
+# Maintainers: 
+Daniil Teptin, Tagir Minibaev
+
 # Java Junior Developer Training Course.
 88 hours training + 32 hours work project = 120 hr.
 
+# Recordings
+- [11.10](https://us02web.zoom.us/rec/share/4K_bvC_0q8nvkzo26fSbcMVPM2uWzlQ9kqT2BbdbcQe-qeAdinWuF-rPfFBA0Pyp.R2IQ39ujDDEZjv1C)
+- [12.10](https://us02web.zoom.us/rec/share/IwiS9NXzVEhoBHgAwCJX6SIVhnfKfq2YeTctQMByD4n_UrFCdeaEkGXDxzPBgxZy.4wsHSeX8T1s4IYNk)
+- [13.10](https://us02web.zoom.us/rec/share/_OVUvUZVlz2vRyM2nXZKOp9dPsbeEZhevRc1iuU-YMyfIhaAJ_mjjQ8sAcM_P6_V.IsA920-72jNMeF5i)
+- [14.10](https://us02web.zoom.us/rec/share/FLno-ISY6mZZDbzwtfZ0DUWKSlUPNwTOK-hFO5jrd3ed1hSOzGaOHLbl3yFX7yEu.b-uJykoOquFRQCY0)
+- [15.10](https://us02web.zoom.us/rec/share/9ZC-sDNnL9VtDWp6JcfTa0BxeEURuszfEUva7rHm7DEUXgNqy0CHXckKltTQUAyu.iNA5x7BXdlq_VfWc)
+
 ---
 
 # Introduction to Java and Java Technology (*1* hour theory / *including 0.5* hour practice)
@@ -633,3 +643,8 @@ assertMessageEquals("3")
 - PM and Business Customers accept product with six demo sessions
 
 ---
+
+# Парковка
+- Spring: Core, MVC, Boot
+- DB: JDBC, Templates, JPA
+- CI: Jenkins, Sonar

pom.xml

@@ -18,18 +18,96 @@
         <artifactId>maven-compiler-plugin</artifactId>
         <version>3.3</version>
         <configuration>
-          <source>1.8</source>
-          <target>1.8</target>
+          <source>11</source>
+          <target>11</target>
         </configuration>
       </plugin>
+
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-surefire-plugin</artifactId>
+        <version>3.0.0-M5</version>
+      </plugin>
+      <plugin>
+        <groupId>org.jacoco</groupId>
+        <artifactId>jacoco-maven-plugin</artifactId>
+        <version>0.8.7</version>
+        <executions>
+          <execution>
+            <goals>
+              <goal>prepare-agent</goal>
+            </goals>
+          </execution>
+          <execution>
+            <id>report</id>
+            <phase>verify</phase>
+            <goals>
+              <goal>report</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <groupId>org.pitest</groupId>
+        <artifactId>pitest-maven</artifactId>
+        <version>1.7.2</version>
+        <dependencies>
+          <dependency>
+            <groupId>org.pitest</groupId>
+            <artifactId>pitest-junit5-plugin</artifactId>
+            <version>0.15</version>
+          </dependency>
+        </dependencies>
+        <configuration>
+          <targetClasses>
+            <param>com.acme.edu.*</param>
+          </targetClasses>
+          <targetTests>
+            <param>com.acme.edu.*</param>
+          </targetTests>
+          <verbose>true</verbose>
+        </configuration>
+        <executions>
+          <execution>
+            <id>mutation-coverage</id>
+            <goals>
+              <goal>mutationCoverage</goal>
+            </goals>
+          </execution>
+          <execution>
+            <id>mutation-report</id>
+            <goals>
+              <goal>report</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
     </plugins>
   </build>
 
   <dependencies>
     <dependency>
-      <groupId>junit</groupId>
-      <artifactId>junit</artifactId>
-      <version>4.12</version>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-api</artifactId>
+      <version>5.8.1</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-engine</artifactId>
+      <version>5.8.1</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.assertj</groupId>
+      <artifactId>assertj-core</artifactId>
+      <version>3.21.0</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <version>4.0.0</version>
       <scope>test</scope>
     </dependency>
     <dependency>

src/main/java/com/acme/edu/Logger.java

@@ -1,11 +1,64 @@
 package com.acme.edu;
 
+import com.acme.edu.controller.Controller;
+import com.acme.edu.message.*;
+import com.acme.edu.saver.ConsoleSaver;
+
 public class Logger {
+
+    private static final Controller controller = new Controller(new ConsoleSaver());
+
+    private static void arrayLog(int message) {
+        controller.log(new ArrayNumberMessage(Integer.MAX_VALUE, Integer.MIN_VALUE, message));
+    }
+
+    public static void log(int... message) {
+        for (int i : message) {
+            arrayLog(i);
+        }
+    }
+
+    public static void log(int[][] message) {
+        for (int[] arr : message) {
+            log(arr);
+        }
+    }
+
     public static void log(int message) {
-        System.out.println("primitive: " + message);
+        controller.log(new SingleNumberMessage(Integer.MAX_VALUE, Integer.MIN_VALUE, message));
     }
 
     public static void log(byte message) {
-        System.out.println("primitive: " + message);
+        controller.log(new SingleNumberMessage(Byte.MAX_VALUE, Byte.MIN_VALUE, message));
+    }
+
+    public static void flush() {
+        controller.flush();
+    }
+
+    public static void log(String... message) {
+        for (String str : message) {
+            log(str);
+        }
+    }
+
+    public static void log(String message) {
+        controller.log(new StringMessage(message));
+    }
+
+    public static void log(char message) {
+        controller.log(new CharMessage(message));
+    }
+
+    public static void log(boolean message) {
+        controller.log(new BooleanMessage(message));
+    }
+
+    public static void log(Object message) {
+        controller.log(new ReferenceMessage(message));
     }
+
+    private Logger() {
+    }
+
 }

src/main/java/com/acme/edu/Utils.java

@@ -0,0 +1,15 @@
+package com.acme.edu;
+
+import java.util.Arrays;
+import java.util.stream.Stream;
+
+public class Utils {
+    private static Stream<Object> flatten(Object[] array) {
+        return Arrays.stream(array)
+                .flatMap(o -> o instanceof Object[] ? flatten((Object[])o) : Stream.of(o));
+    }
+
+    public static Object[] getFlatArray(Object[] array) {
+        return flatten(array).toArray();
+    }
+}

src/main/java/com/acme/edu/controller/Controller.java

@@ -0,0 +1,43 @@
+package com.acme.edu.controller;
+
+import com.acme.edu.exception.LogException;
+import com.acme.edu.message.Message;
+import com.acme.edu.saver.Saver;
+
+public class Controller {
+
+    private final Saver saver;
+
+    private Message messageBuffer;
+
+    public Controller(Saver saver) {
+        this.saver = saver;
+    }
+
+    public void log(Message message) {
+        if (message == null) throw new IllegalArgumentException("Received message is null");
+
+        if (messageBuffer == null) {
+            messageBuffer = message;
+        } else if (messageBuffer.canAppend(message)) {
+            Message[] messageArray = messageBuffer.append(message);
+            flushAllOverflowingMessages(messageArray);
+            messageBuffer = messageArray[messageArray.length - 1];
+        } else {
+            flush();
+            messageBuffer = message;
+        }
+    }
+
+    public void flush() {
+        saver.save(messageBuffer.getBody());
+        messageBuffer = null;
+    }
+
+    private void flushAllOverflowingMessages(Message[] messageArray) {
+        for (int i = 0; i < messageArray.length - 1; i++) {
+            messageBuffer = messageArray[i];
+            flush();
+        }
+    }
+}

src/main/java/com/acme/edu/exception/IllegalMessageStateException.java

@@ -0,0 +1,7 @@
+package com.acme.edu.exception;
+
+public class IllegalMessageStateException extends LogException {
+    public IllegalMessageStateException(String message) {
+        super(message);
+    }
+}

src/main/java/com/acme/edu/exception/LogException.java

@@ -0,0 +1,7 @@
+package com.acme.edu.exception;
+
+public class LogException extends RuntimeException {
+    public LogException(String message) {
+        super(message);
+    }
+}

src/main/java/com/acme/edu/exception/SavingException.java

@@ -0,0 +1,7 @@
+package com.acme.edu.exception;
+
+public class SavingException extends LogException {
+    public SavingException(String message) {
+        super(message);
+    }
+}

src/main/java/com/acme/edu/message/ArrayNumberMessage.java

@@ -0,0 +1,18 @@
+package com.acme.edu.message;
+
+public class ArrayNumberMessage extends OverflowingMessage {
+
+    public ArrayNumberMessage(long maxLimit, long minLimit, long number) {
+        super(maxLimit, minLimit, number);
+    }
+
+    @Override
+    protected OverflowingMessage createSpecificMessage(long number) {
+        return new ArrayNumberMessage(maxLimit, minLimit, number);
+    }
+
+    @Override
+    public boolean canAppend(Message message) {
+        return message instanceof ArrayNumberMessage && checkLimits((ArrayNumberMessage) message);
+    }
+}

src/main/java/com/acme/edu/message/BooleanMessage.java

@@ -0,0 +1,27 @@
+package com.acme.edu.message;
+
+public class BooleanMessage implements Message {
+
+    protected static final String BOOLEAN_PREFIX = "primitive: ";
+
+    private final boolean accumulator;
+
+    public BooleanMessage(boolean bool) {
+        this.accumulator = bool;
+    }
+
+    @Override
+    public Message[] append(Message message) {
+        return new Message[]{ message };
+    }
+
+    @Override
+    public String getBody() {
+        return BOOLEAN_PREFIX + accumulator;
+    }
+
+    @Override
+    public boolean canAppend(Message message) {
+        return false;
+    }
+}

src/main/java/com/acme/edu/message/CharMessage.java

@@ -0,0 +1,27 @@
+package com.acme.edu.message;
+
+public class CharMessage implements Message {
+
+    protected static final String CHAR_PREFIX = "char: ";
+
+    private final char accumulator;
+
+    public CharMessage(char ch) {
+        this.accumulator = ch;
+    }
+
+    @Override
+    public Message[] append(Message message) {
+        return new Message[]{message};
+    }
+
+    @Override
+    public String getBody() {
+        return CHAR_PREFIX + accumulator;
+    }
+
+    @Override
+    public boolean canAppend(Message message) {
+        return false;
+    }
+}

src/main/java/com/acme/edu/message/Message.java

@@ -0,0 +1,15 @@
+package com.acme.edu.message;
+
+public interface Message {
+    /**
+     * @return First messages of the array contain data about overflow.
+     * The last one message (with index = Message[].lenght - 1) contains remainder of
+     * append operation.
+     * If there is no overflow, it returns an array with one message.
+     */
+    Message[] append(Message message);
+
+    String getBody();
+
+    boolean canAppend(Message message);
+}