#533 a lot of stuff

build.gradle

@@ -229,7 +229,7 @@ graalvmNative {
 
     configureEach {
       if(it.name == "intTest"){
-      println "> configuring for: ${it.getName()}"
+        println "> configuring for: ${it.getName()}"
         buildArgs.add("-Ob")
       }
     }

src/main/java/com/mageddo/dnsproxyserver/App.java

@@ -20,6 +20,7 @@ public class App {
   private final String[] args;
   private Config config;
   private ConfigFlag flags;
+  private Context context;
 
   public App(String[] args) {
     this.args = args;
@@ -51,10 +52,12 @@ void mustStart() {
 
     this.checkExitCommands();
 
-    this.config = this.findConfig(args);
+    this.config = this.findConfig(this.args);
 
     this.setupLogs();
 
+    log.trace("pid={}", ProcessHandle.current().pid());
+
     this.startContext();
 
     // todo install as service
@@ -79,11 +82,9 @@ void setupLogs() {
   }
 
   void startContext() {
-    final var context = Context.create();
-
-    // start webserver
-    // start dns server
-    context.start();
+    Context.create()
+      .start()
+    ;
   }
 
   void checkExitCommands() {

src/main/java/com/mageddo/dnsproxyserver/di/module/ModuleEager.java

@@ -1,6 +1,8 @@
 package com.mageddo.dnsproxyserver.di.module;
 
 import com.mageddo.di.Eager;
+import com.mageddo.dnsproxyserver.healthcheck.entrypoint.HealthCheckSignalEntrypoint;
+import com.mageddo.dnsproxyserver.in.entrypoint.InputStreamEntrypoint;
 import dagger.Module;
 import dagger.Provides;
 import dagger.multibindings.ElementsIntoSet;
@@ -13,7 +15,11 @@ public class ModuleEager {
   @Provides
   @Singleton
   @ElementsIntoSet
-  Set<Eager> beans() {
-    return Set.of();
+  Set<Eager> beans(
+    HealthCheckSignalEntrypoint b1, InputStreamEntrypoint b2
+  ) {
+    return Set.of(
+      b1, b2
+    );
   }
 }

src/main/java/com/mageddo/dnsproxyserver/healthcheck/HealthCheck.java

@@ -0,0 +1,16 @@
+package com.mageddo.dnsproxyserver.healthcheck;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import javax.inject.Inject;
+import javax.inject.Singleton;
+
+@Slf4j
+@Singleton
+@RequiredArgsConstructor(onConstructor = @__({@Inject}))
+public class HealthCheck {
+  public boolean isHealth(){
+    return true;
+  }
+}

src/main/java/com/mageddo/dnsproxyserver/healthcheck/entrypoint/HealthCheckSignalEntrypoint.java

@@ -0,0 +1,36 @@
+package com.mageddo.dnsproxyserver.healthcheck.entrypoint;
+
+import com.mageddo.di.Eager;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import sun.misc.Signal;
+
+import javax.inject.Inject;
+import javax.inject.Singleton;
+
+@Slf4j
+@Singleton
+@RequiredArgsConstructor(onConstructor = @__({@Inject}))
+public class HealthCheckSignalEntrypoint implements Eager {
+
+  private static final String USER_DEFINED_SIGNAL = "USR1";
+  private final HealthCheckStreamEntrypoint streamEntrypoint;
+
+  @Override
+  public void run() {
+    this.safeRegisterHandler();
+  }
+
+  void safeRegisterHandler() {
+    try {
+      this.registerHandler();
+    } catch (Throwable t){
+      log.warn("status=couldntRegisterHandler, msg={}", t.getMessage(), t);
+    }
+  }
+
+  void registerHandler() {
+    Signal.handle(new Signal(USER_DEFINED_SIGNAL), sig -> this.streamEntrypoint.printHealthCheck());
+    log.debug("status=healthCheckSignalRegistered, signal={}", USER_DEFINED_SIGNAL);
+  }
+}

src/main/java/com/mageddo/dnsproxyserver/healthcheck/entrypoint/HealthCheckStreamEntrypoint.java

@@ -0,0 +1,18 @@
+package com.mageddo.dnsproxyserver.healthcheck.entrypoint;
+
+import com.mageddo.dnsproxyserver.healthcheck.HealthCheck;
+import lombok.RequiredArgsConstructor;
+
+import javax.inject.Inject;
+import javax.inject.Singleton;
+
+@Singleton
+@RequiredArgsConstructor(onConstructor = @__({@Inject}))
+public class HealthCheckStreamEntrypoint {
+
+  private final HealthCheck healthCheck;
+
+  public void printHealthCheck() {
+    System.out.printf("dps.healthCheck.health=%b%n", this.healthCheck.isHealth());
+  }
+}

src/main/java/com/mageddo/dnsproxyserver/in/entrypoint/InputStreamEntrypoint.java

@@ -0,0 +1,58 @@
+package com.mageddo.dnsproxyserver.in.entrypoint;
+
+import com.mageddo.commons.concurrent.Threads;
+import com.mageddo.di.Eager;
+import com.mageddo.dnsproxyserver.healthcheck.entrypoint.HealthCheckStreamEntrypoint;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import javax.inject.Inject;
+import javax.inject.Singleton;
+import java.util.NoSuchElementException;
+import java.util.Scanner;
+
+@Slf4j
+@Singleton
+@RequiredArgsConstructor(onConstructor = @__({@Inject}))
+public class InputStreamEntrypoint implements Eager {
+
+  private final HealthCheckStreamEntrypoint healthCheckStreamEntrypoint;
+  private boolean inShell;
+
+  @Override
+  public void run() {
+    Thread.ofVirtual()
+      .start(this::readInputStream)
+    ;
+  }
+
+  private void readInputStream() {
+    log.debug("status=scanningInputStream");
+    final var scanner = new Scanner(System.in);
+    while (true) {
+      final var line = safeReadLine(scanner);
+      if (line == null) {
+        break;
+      }
+      this.checkHealthCheck(line);
+      Threads.sleep(1000 / 15);
+    }
+  }
+
+  private static String safeReadLine(Scanner scanner) {
+    try {
+      return scanner.nextLine();
+    } catch (NoSuchElementException e) {
+      return null;
+    }
+  }
+
+  private void checkHealthCheck(String line) {
+    if (line.equals("shell")) {
+      this.inShell = true;
+    }
+    if (this.inShell && line.equals("dps.healthCheck.health")) {
+      this.healthCheckStreamEntrypoint.printHealthCheck();
+    }
+  }
+}

src/main/java/com/mageddo/os/linux/kill/Kill.java

@@ -0,0 +1,18 @@
+package com.mageddo.os.linux.kill;
+
+import com.mageddo.commons.exec.CommandLines;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.exec.CommandLine;
+
+@Slf4j
+public class Kill {
+  public static void sendSignal(int signal, long pid) {
+    final var result = CommandLines.exec(
+      new CommandLine("kill")
+        .addArgument("-" + signal)
+        .addArgument(pid + "")
+    );
+    result.checkExecution();
+    log.debug("status=signalSentWithSuccess, signal={}, pid={}", signal, pid);
+  }
+}

src/test/java/com/mageddo/dnsproxyserver/healthcheck/entrypoint/HealthCheckSignalEntrypointTest.java

@@ -0,0 +1,39 @@
+package com.mageddo.dnsproxyserver.healthcheck.entrypoint;
+
+import com.mageddo.dnsproxyserver.healthcheck.HealthCheck;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.Spy;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import static org.mockito.Mockito.doThrow;
+
+@ExtendWith(MockitoExtension.class)
+class HealthCheckSignalEntrypointTest {
+
+  @Mock
+  HealthCheck healthCheck;
+
+  @Spy
+  @InjectMocks
+  HealthCheckSignalEntrypoint entrypoint;
+
+  @Test
+  void mustRegisterHandler() {
+    this.entrypoint.registerHandler();
+  }
+
+  @Test
+  void mustCatchFatalErrorsWhenRegisteringHandler() {
+
+    doThrow(new AssertionError("mocked error"))
+      .when(this.entrypoint)
+      .registerHandler();
+
+    this.entrypoint.safeRegisterHandler();
+
+  }
+
+}

src/test/java/com/mageddo/net/SocketUtilsTest.java

@@ -2,12 +2,13 @@
 
 import org.junit.jupiter.api.Test;
 
-import static org.junit.jupiter.api.Assertions.*;
+import static org.junit.jupiter.api.Assertions.assertNotEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 class SocketUtilsTest {
 
   @Test
-  void mustFindRandomFreePort(){
+  void mustFindRandomFreePort() {
     // arrange
 
     // act
@@ -16,4 +17,12 @@ void mustFindRandomFreePort(){
     // assert
     assertTrue(port > 0);
   }
+
+  @Test
+  void mustFindTwoDifferentPortsForConsecutiveCalls() {
+    for (int i = 0; i < 3; i++) {
+      assertNotEquals(SocketUtils.findRandomFreePort(), SocketUtils.findRandomFreePort());
+    }
+  }
+
 }

src/test/java/dagger/sheath/templates/SignatureTemplates.java

@@ -3,7 +3,7 @@
 import com.fasterxml.jackson.core.type.TypeReference;
 import dagger.sheath.reflection.Signature;
 import org.apache.commons.lang3.reflect.MethodUtils;
-import org.graalvm.collections.Pair;
+import org.graalvm.collections.Pair; // fixme #533 wrong pair, use apache commons lang3
 
 import java.lang.reflect.Method;
 import java.util.List;

src/test/java/testing/templates/solver/remote/RemoteResolversTemplates.java

@@ -0,0 +1,12 @@
+package testing.templates.solver.remote;
+
+import com.mageddo.dnsproxyserver.solver.Resolver;
+
+import java.util.List;
+
+public class RemoteResolversTemplates {
+
+  public static List<Resolver> buildSuccessAnswerResolverStub() {
+    return List.of(ResolverTemplates.successAAcmeAnswer());
+  }
+}

src/test/java/testing/templates/solver/remote/ResolverTemplates.java

@@ -2,12 +2,37 @@
 
 import com.mageddo.dnsproxyserver.solver.Resolver;
 import com.mageddo.dnsproxyserver.solver.SimpleResolver;
+import lombok.SneakyThrows;
 import testing.templates.InetSocketAddressTemplates;
+import testing.templates.MessageTemplates;
 
 import java.util.List;
+import java.util.concurrent.Executor;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.doReturn;
 
 public class ResolverTemplates {
   public static List<Resolver> googleDnsAsList() {
     return List.of(new SimpleResolver(InetSocketAddressTemplates._8_8_8_8()));
   }
+
+  @SneakyThrows
+  public static Resolver successAAcmeAnswer() {
+    final var resolver = new SimpleResolver();
+
+    doReturn(MessageTemplates.acmeAResponse())
+      .when(resolver)
+      .send(any());
+    ;
+    doReturn(MessageTemplates.acmeAResponse())
+      .when(resolver)
+      .sendAsync(any())
+    ;
+    doReturn(MessageTemplates.acmeAResponse())
+      .when(resolver)
+      .sendAsync(any(), any(Executor.class));
+    ;
+    return resolver;
+  }
 }