Reformating (#649)

Author: mageddo

RELEASE-NOTES.md

@@ -1,3 +1,6 @@
+## 4.2.0
+* Activating Config v3 for beta testing
+
 ## 4.1.0
 * Refactoring config module to support config v3
 * Commited Arc Drawio to the source code

build.gradle

@@ -86,8 +86,8 @@ dependencies {
   stressTestCompileOnly('org.projectlombok:lombok:1.18.+')
   stressTestAnnotationProcessor('org.projectlombok:lombok:1.18.+')
 
-  testImplementation("org.junit.jupiter:junit-jupiter:5.11.3")
-  testImplementation("org.mockito:mockito-junit-jupiter:5.11.0")
+  testImplementation("org.junit.jupiter:junit-jupiter:5.10.+")
+  testImplementation('org.mockito:mockito-junit-jupiter:5.12.+')
   testImplementation('org.hamcrest:hamcrest:3.0')
   testImplementation('org.assertj:assertj-core:3.27.6')
   testImplementation('io.rest-assured:rest-assured:5.5.0')

gradle.properties

@@ -1 +1 @@
-version=4.1.0-snapshot
+version=4.2.0-snapshot

src/main/java/com/mageddo/circuitbreaker/failsafe/CircuitStatusRefresh.java

@@ -15,7 +15,8 @@ public static boolean refresh(CircuitBreaker<?> circuitBreaker) {
   }
 
   private static boolean readyToChangeToHalOpen(CircuitBreaker<?> circuitBreaker) {
-    return circuitBreaker.isOpen() && circuitBreaker.getRemainingDelay().isZero();
+    return circuitBreaker.isOpen() && circuitBreaker.getRemainingDelay()
+        .isZero();
   }
 
 }

src/main/java/com/mageddo/commons/exec/CommandLines.java

@@ -1,21 +1,22 @@
 package com.mageddo.commons.exec;
 
-import lombok.extern.slf4j.Slf4j;
+import java.io.IOException;
+import java.io.UncheckedIOException;
+import java.time.Duration;
+
 import org.apache.commons.exec.CommandLine;
 import org.apache.commons.exec.ExecuteException;
 import org.apache.commons.exec.ExecuteResultHandler;
 import org.apache.commons.exec.ExecuteWatchdog;
 
-import java.io.IOException;
-import java.io.UncheckedIOException;
-import java.time.Duration;
+import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 public class CommandLines {
 
   public static Result exec(String commandLine, Object... args) {
     return exec(CommandLine.parse(String.format(commandLine, args)),
-      ExecuteWatchdog.INFINITE_TIMEOUT
+        ExecuteWatchdog.INFINITE_TIMEOUT
     );
   }
 
@@ -29,25 +30,25 @@ public static Result exec(CommandLine commandLine) {
 
   public static Result exec(CommandLine commandLine, long timeout) {
     return exec(
-      Request.builder()
-        .commandLine(commandLine)
-        .timeout(Duration.ofMillis(timeout))
-        .build()
+        Request.builder()
+            .commandLine(commandLine)
+            .timeout(Duration.ofMillis(timeout))
+            .build()
     );
   }
 
   private static void registerProcessWatch(ProcessAccessibleDaemonExecutor executor) {
     ProcessesWatchDog.instance()
-      .watch(executor::getProcess)
+        .watch(executor::getProcess)
     ;
   }
 
   public static Result exec(CommandLine commandLine, ExecuteResultHandler handler) {
     return exec(Request
-      .builder()
-      .commandLine(commandLine)
-      .handler(handler)
-      .build()
+        .builder()
+        .commandLine(commandLine)
+        .handler(handler)
+        .build()
     );
   }
 
@@ -65,21 +66,22 @@ public static Result exec(Request request) {
       }
     } catch (ExecuteException e) {
       if (request.getHandler() != null) {
-        request.getHandler().onProcessFailed(e);
+        request.getHandler()
+            .onProcessFailed(e);
       } else {
         exitCode = e.getExitValue();
       }
     } catch (IOException e) {
       throw new UncheckedIOException(e);
     }
     return Result
-      .builder()
-      .executor(executor)
-      .processSupplier(executor::getProcess)
-      .out(request.getBestOut())
-      .exitCode(exitCode)
-      .request(request)
-      .build();
+        .builder()
+        .executor(executor)
+        .processSupplier(executor::getProcess)
+        .out(request.getBestOut())
+        .exitCode(exitCode)
+        .request(request)
+        .build();
   }
 
   private static ProcessAccessibleDaemonExecutor createExecutor() {

src/main/java/com/mageddo/commons/exec/DelegateOutputStream.java

@@ -10,7 +10,8 @@ public class DelegateOutputStream extends OutputStream {
   private final List<OutputStream> delegateOuts;
 
   public DelegateOutputStream(OutputStream... delegateOuts) {
-    this.delegateOuts = Stream.of(delegateOuts).toList();
+    this.delegateOuts = Stream.of(delegateOuts)
+        .toList();
   }
 
   public DelegateOutputStream(List<OutputStream> delegateOuts) {

src/main/java/com/mageddo/commons/exec/PipedStream.java

@@ -1,13 +1,13 @@
 package com.mageddo.commons.exec;
 
-import lombok.Getter;
-
 import java.io.IOException;
 import java.io.OutputStream;
 import java.io.PipedInputStream;
 import java.io.PipedOutputStream;
 import java.io.UncheckedIOException;
 
+import lombok.Getter;
+
 public class PipedStream extends OutputStream {
 
   @Getter

src/main/java/com/mageddo/commons/exec/ProcessAccessibleDaemonExecutor.java

@@ -1,20 +1,22 @@
 package com.mageddo.commons.exec;
 
-import lombok.Getter;
-import org.apache.commons.exec.CommandLine;
-import org.apache.commons.exec.DaemonExecutor;
-
 import java.io.File;
 import java.io.IOException;
 import java.util.Map;
 
+import org.apache.commons.exec.CommandLine;
+import org.apache.commons.exec.DaemonExecutor;
+
+import lombok.Getter;
+
 @Getter
 class ProcessAccessibleDaemonExecutor extends DaemonExecutor {
 
   private Process process = null;
 
   @Override
-  protected Process launch(CommandLine command, Map<String, String> env, File dir) throws IOException {
+  protected Process launch(CommandLine command, Map<String, String> env, File dir)
+      throws IOException {
     return this.process = super.launch(command, env, dir);
   }
 }

src/main/java/com/mageddo/commons/exec/ProcessesWatchDog.java

@@ -1,13 +1,14 @@
 package com.mageddo.commons.exec;
 
-import com.mageddo.commons.lang.Singletons;
-import lombok.extern.slf4j.Slf4j;
-
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
 import java.util.function.Supplier;
 
+import com.mageddo.commons.lang.Singletons;
+
+import lombok.extern.slf4j.Slf4j;
+
 @Slf4j
 public class ProcessesWatchDog {
 
@@ -28,22 +29,26 @@ public void watch(Process process) {
   public void killAllProcesses() {
     final var validProcesses = this.findValidProcesses();
 
-    log.debug("status=killing all processes, processes={}, valid={}", this.processes.size(), validProcesses.size());
+    log.debug("status=killing all processes, processes={}, valid={}", this.processes.size(),
+        validProcesses.size()
+    );
 
     validProcesses.forEach(process -> {
       try {
         process.destroy();
         log.trace("status=killed, pid={}", process.pid());
       } catch (Exception e) {
-        log.warn("status=unable to destroy, processId={}, msg={}", process.pid(), e.getMessage(), e);
+        log.warn("status=unable to destroy, processId={}, msg={}", process.pid(), e.getMessage(),
+            e
+        );
       }
     });
   }
 
   private List<Process> findValidProcesses() {
     return this.processes.stream()
-      .map(Supplier::get)
-      .filter(Objects::nonNull)
-      .toList();
+        .map(Supplier::get)
+        .filter(Objects::nonNull)
+        .toList();
   }
 }

src/main/java/com/mageddo/commons/exec/Request.java

@@ -1,21 +1,23 @@
 package com.mageddo.commons.exec;
 
+import java.io.ByteArrayOutputStream;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.time.Duration;
+import java.util.Map;
+
 import com.mageddo.io.LogPrinter;
-import lombok.Builder;
-import lombok.NonNull;
-import lombok.Value;
-import lombok.experimental.NonFinal;
+
 import org.apache.commons.exec.CommandLine;
 import org.apache.commons.exec.ExecuteResultHandler;
 import org.apache.commons.exec.ExecuteStreamHandler;
 import org.apache.commons.exec.ExecuteWatchdog;
 import org.apache.commons.exec.PumpStreamHandler;
 
-import java.io.ByteArrayOutputStream;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.time.Duration;
-import java.util.Map;
+import lombok.Builder;
+import lombok.NonNull;
+import lombok.Value;
+import lombok.experimental.NonFinal;
 
 @Value
 @Builder(toBuilder = true, builderClassName = "RequestBuilder", buildMethodName = "build0")
@@ -34,8 +36,8 @@ public class Request {
 
   @Builder.Default
   private final Streams streams = Streams.builder()
-    .outAndErr(new ByteArrayOutputStream())
-    .build();
+      .outAndErr(new ByteArrayOutputStream())
+      .build();
 
   public ExecuteStreamHandler getStreamHandler() {
     return this.streams.toStreamHandler();
@@ -97,7 +99,8 @@ public PipedStream getBestOut() {
     }
 
     public OutputStream getBestOriginalOutput() {
-      return this.getBestOut().getOriginalOut();
+      return this.getBestOut()
+          .getOriginalOut();
     }
 
     public static class StreamsBuilder {