format

Author: SentryMan

avaje-jex-freemarker/src/test/java/io/avaje/jex/render/freemarker/FreeMarkerServiceLoaderTest.java

@@ -14,8 +14,15 @@ class FreeMarkerServiceLoaderTest {
   static TestPair pair = init();
 
   static TestPair init() {
-    var app = Jex.create().routing(routing -> routing.get("/noModel", ctx -> ctx.render("one.ftl"))
-        .get("/withModel", ctx -> ctx.render("two.ftl", Map.of("message", "hello"))));
+    var app =
+        Jex.create()
+            .routing(
+                routing ->
+                    routing
+                        .get("/noModel", ctx -> ctx.render("one.ftl"))
+                        .get(
+                            "/withModel",
+                            ctx -> ctx.render("two.ftl", Map.of("message", "hello"))));
     // not explicitly registered so auto registered via service loader
     return TestPair.create(app);
   }

avaje-jex-htmx/src/main/java/io/avaje/jex/htmx/HxHandler.java

@@ -5,8 +5,8 @@
 /**
  * Wrap a Handler with filtering for Htmx specific headers.
  *
- * <p>The underlying Handler will not be invoked unless the request is a Htmx request and matches the required
- * attributes.
+ * <p>The underlying Handler will not be invoked unless the request is a Htmx request and matches
+ * the required attributes.
  */
 public interface HxHandler {
 

avaje-jex-mustache/src/test/java/io/avaje/jex/render/mustache/MustacheRenderTest.java

@@ -15,8 +15,15 @@ class MustacheRenderTest {
   static TestPair pair1 = init(false);
 
   static TestPair init(boolean explicit) {
-    var app = Jex.create().routing(routing -> routing.get("/noModel", ctx -> ctx.render("one.mustache"))
-        .get("/withModel", ctx -> ctx.render("two.mustache", Map.of("message", "hello"))));
+    var app =
+        Jex.create()
+            .routing(
+                routing ->
+                    routing
+                        .get("/noModel", ctx -> ctx.render("one.mustache"))
+                        .get(
+                            "/withModel",
+                            ctx -> ctx.render("two.mustache", Map.of("message", "hello"))));
     if (explicit) {
       app.register(new MustacheRender(), "mustache");
     }

avaje-jex-static-content/src/main/java/io/avaje/jex/staticcontent/AbstractStaticHandler.java

@@ -70,10 +70,12 @@ protected String getExt(String path) {
 
   protected String lookupMime(String path) {
     var lower = path.toLowerCase();
-    return Objects.requireNonNullElseGet(MIME_MAP.getContentTypeFor(path), () -> {
-      String ext = getExt(lower);
-      return mimeTypes.getOrDefault(ext, "application/octet-stream");
-    });
+    return Objects.requireNonNullElseGet(
+        MIME_MAP.getContentTypeFor(path),
+        () -> {
+          String ext = getExt(lower);
+          return mimeTypes.getOrDefault(ext, "application/octet-stream");
+        });
   }
 
   protected boolean isCached(final String path) {

avaje-jex-static-content/src/main/java/io/avaje/jex/staticcontent/ClassResourceLoader.java

@@ -5,10 +5,11 @@
 /**
  * Loading resources from the classpath or module path.
  *
- * <p>When not specified Avaje Jex provides a default implementation that looks to find resources using the class loader
- * associated with the ClassResourceLoader.
+ * <p>When not specified Avaje Jex provides a default implementation that looks to find resources
+ * using the class loader associated with the ClassResourceLoader.
  *
- * <p>As a fallback, {@link ClassLoader#getSystemResourceAsStream(String)} is used if the loader returns null.
+ * <p>As a fallback, {@link ClassLoader#getSystemResourceAsStream(String)} is used if the loader
+ * returns null.
  */
 public interface ClassResourceLoader {
 

avaje-jex-static-content/src/main/java/io/avaje/jex/staticcontent/DefaultResourceLoader.java

@@ -21,9 +21,10 @@ public URL loadResource(String resourcePath) {
     var url = clazz.getResource(resourcePath);
     if (url == null) {
       // search the module path for top level resource
-      url = Optional.ofNullable(ClassLoader.getSystemResource(resourcePath))
-          .orElseGet(
-              () -> Thread.currentThread().getContextClassLoader().getResource(resourcePath));
+      url =
+          Optional.ofNullable(ClassLoader.getSystemResource(resourcePath))
+              .orElseGet(
+                  () -> Thread.currentThread().getContextClassLoader().getResource(resourcePath));
     }
     return Objects.requireNonNull(url, "Unable to locate resource: " + resourcePath);
   }

avaje-jex-static-content/src/main/java/io/avaje/jex/staticcontent/StaticClassResourceHandler.java

@@ -24,7 +24,14 @@ final class StaticClassResourceHandler extends AbstractStaticHandler {
       URL singleFile,
       boolean precompress,
       CompressionConfig compressionConfig) {
-    super(urlPrefix, filesystemRoot, mimeTypes, headers, skipFilePredicate, precompress, compressionConfig);
+    super(
+        urlPrefix,
+        filesystemRoot,
+        mimeTypes,
+        headers,
+        skipFilePredicate,
+        precompress,
+        compressionConfig);
 
     this.resourceLoader = resourceLoader;
     this.indexFile = indexFile;

avaje-jex-static-content/src/main/java/io/avaje/jex/staticcontent/StaticContent.java

@@ -1,11 +1,10 @@
 package io.avaje.jex.staticcontent;
 
-import java.net.URLConnection;
-import java.util.function.Predicate;
-
 import io.avaje.jex.http.Context;
 import io.avaje.jex.security.Role;
 import io.avaje.jex.spi.JexPlugin;
+import java.net.URLConnection;
+import java.util.function.Predicate;
 
 /**
  * Static content resource handler.

avaje-jex-static-content/src/main/java/io/avaje/jex/staticcontent/StaticFileHandler.java

@@ -25,7 +25,14 @@ final class StaticFileHandler extends AbstractStaticHandler {
       File singleFile,
       boolean precompress,
       CompressionConfig compressionConfig) {
-    super(urlPrefix, filesystemRoot, mimeTypes, headers, skipFilePredicate, precompress, compressionConfig);
+    super(
+        urlPrefix,
+        filesystemRoot,
+        mimeTypes,
+        headers,
+        skipFilePredicate,
+        precompress,
+        compressionConfig);
     this.indexFile = welcomeFile;
     this.singleFile = singleFile;
   }

avaje-jex-static-content/src/main/java/io/avaje/jex/staticcontent/StaticResourceHandlerBuilder.java

@@ -15,7 +15,8 @@
 final class StaticResourceHandlerBuilder implements StaticContent.Builder, StaticContent {
 
   private static final String FAILED_TO_LOCATE_FILE = "Failed to locate file: ";
-  private static final String DIRECTORY_INDEX_FAILURE = "Failed to locate Directory Index Resource: ";
+  private static final String DIRECTORY_INDEX_FAILURE =
+      "Failed to locate Directory Index Resource: ";
   private static final Predicate<Context> NO_OP_PREDICATE = ctx -> false;
   private static final ClassResourceLoader DEFAULT_LOADER = new DefaultResourceLoader();
 
@@ -49,17 +50,20 @@ public StaticContent build() {
   }
 
   ExchangeHandler createHandler(CompressionConfig compress) {
-    path = Objects.requireNonNull(path)
-        .transform(this::prependSlash)
-        .transform(s -> s.endsWith("/*") ? s.substring(0, s.length() - 2) : s);
+    path =
+        Objects.requireNonNull(path)
+            .transform(this::prependSlash)
+            .transform(s -> s.endsWith("/*") ? s.substring(0, s.length() - 2) : s);
 
     root = isClasspath ? root.transform(this::prependSlash) : root;
     if (isClasspath && "/".equals(root)) {
-      throw new IllegalArgumentException("Cannot serve full classpath, please configure a classpath prefix");
+      throw new IllegalArgumentException(
+          "Cannot serve full classpath, please configure a classpath prefix");
     }
 
     if (root.endsWith("/") && directoryIndex == null) {
-      throw new IllegalArgumentException("Directory Index file is required when serving directories");
+      throw new IllegalArgumentException(
+          "Directory Index file is required when serving directories");
     }
 
     if (!isClasspath) {
@@ -147,7 +151,15 @@ private StaticFileHandler fileLoader(CompressionConfig compress) {
     }
 
     return new StaticFileHandler(
-        path, fsRoot, mimeTypes, headers, skipFilePredicate, dirIndex, singleFile, precompress, compress);
+        path,
+        fsRoot,
+        mimeTypes,
+        headers,
+        skipFilePredicate,
+        dirIndex,
+        singleFile,
+        precompress,
+        compress);
   }
 
   private StaticClassResourceHandler classPathHandler(CompressionConfig compress) {

avaje-jex-static-content/src/main/java/module-info.java

@@ -1,6 +1,6 @@
 /**
- * Defines the Static Content API for serving static resources with Jex - see
- * {@link io.avaje.jex.staticcontent.StaticContent}.
+ * Defines the Static Content API for serving static resources with Jex - see {@link
+ * io.avaje.jex.staticcontent.StaticContent}.
  *
  * <pre>{@code
  * var staticContent = StaticContentService.createCP("/public").httpPath("/").directoryIndex("index.html");

avaje-jex-static-content/src/test/java/io/avaje/jex/staticcontent/CompressedStaticFileTest.java

@@ -2,15 +2,13 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+import io.avaje.jex.Jex;
+import io.avaje.jex.test.TestPair;
 import java.net.http.HttpResponse;
 import java.time.Duration;
-
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.Test;
 
-import io.avaje.jex.Jex;
-import io.avaje.jex.test.TestPair;
-
 class CompressedStaticFileTest {
 
   static TestPair pair = init();
@@ -28,7 +26,8 @@ static TestPair init() {
             .plugin(StaticContent.ofClassPath("/logback.xml").route("/single").build())
             .plugin(
                 StaticContent.ofFile("src/test/resources/logback.xml")
-                    .route("/singleFile").build());
+                    .route("/singleFile")
+                    .build());
 
     return TestPair.create(app);
   }
@@ -40,9 +39,7 @@ private static StaticContent.Builder defaultFile() {
   }
 
   private static StaticContent.Builder defaultCP() {
-    return StaticContent.ofClassPath("/public")
-      .directoryIndex("index.html")
-      .preCompress();
+    return StaticContent.ofClassPath("/public").directoryIndex("index.html").preCompress();
   }
 
   @AfterAll

avaje-jex-static-content/src/test/java/io/avaje/jex/staticcontent/StaticFileTest.java

@@ -2,15 +2,13 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+import io.avaje.jex.Jex;
+import io.avaje.jex.test.TestPair;
 import java.net.http.HttpResponse;
 import java.time.Duration;
-
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.Test;
 
-import io.avaje.jex.Jex;
-import io.avaje.jex.test.TestPair;
-
 class StaticFileTest {
 
   static TestPair pair = init();
@@ -28,14 +26,14 @@ static TestPair init() {
             .plugin(StaticContent.ofClassPath("/logback.xml").route("/single").build())
             .plugin(
                 StaticContent.ofFile("src/test/resources/logback.xml")
-                    .route("/singleFile").build());
+                    .route("/singleFile")
+                    .build());
 
     return TestPair.create(app);
   }
 
   private static StaticContent.Builder defaultFile() {
-    return StaticContent.ofFile("src/test/resources/public")
-        .directoryIndex("index.html");
+    return StaticContent.ofFile("src/test/resources/public").directoryIndex("index.html");
   }
 
   private static StaticContent.Builder defaultCP() {

avaje-jex-test/src/main/java/io/avaje/jex/test/JexInjectPlugin.java

@@ -10,9 +10,9 @@
 /**
  * avaje-inject-test plugin that:
  *
- * <p>- Detects when a http client is being used in a test - Starts Jex server on random port - Creates the appropriate
- * client for the port (to be injected into the test class) - Shutdown the server on test completion (Plugin.Scope
- * close)
+ * <p>- Detects when a http client is being used in a test - Starts Jex server on random port -
+ * Creates the appropriate client for the port (to be injected into the test class) - Shutdown the
+ * server on test completion (Plugin.Scope close)
  */
 public final class JexInjectPlugin implements Plugin {
 
@@ -57,21 +57,19 @@ private static class LocalScope implements Plugin.Scope {
     private final HttpClient httpClient;
 
     LocalScope(BeanScope beanScope) {
-      Jex jex = beanScope
-          .getOptional(Jex.class)
-          .orElse(Jex.create())
-          .configureWith(beanScope)
-          .port(0);
+      Jex jex =
+          beanScope.getOptional(Jex.class).orElse(Jex.create()).configureWith(beanScope).port(0);
 
       // get a HttpClientContext.Builder provided by dependency injection test scope or new one up
       this.server = jex.start();
       int port = server.port();
-      this.httpClient = beanScope
-          .getOptional(HttpClient.Builder.class)
-          .orElse(HttpClient.builder())
-          .configureWith(beanScope)
-          .baseUrl("http://localhost:" + port)
-          .build();
+      this.httpClient =
+          beanScope
+              .getOptional(HttpClient.Builder.class)
+              .orElse(HttpClient.builder())
+              .configureWith(beanScope)
+              .baseUrl("http://localhost:" + port)
+              .build();
     }
 
     @Override

avaje-jex-test/src/main/java/io/avaje/jex/test/TestPair.java

@@ -1,10 +1,9 @@
 package io.avaje.jex.test;
 
-import java.net.http.HttpClient.Version;
-
 import io.avaje.http.client.HttpClient;
 import io.avaje.http.client.HttpClientRequest;
 import io.avaje.jex.Jex;
+import java.net.http.HttpClient.Version;
 
 /** Server and Client pair for a test. */
 public class TestPair {

avaje-jex/src/main/java/io/avaje/jex/AppLifecycle.java

@@ -21,7 +21,8 @@ enum Status {
   void onShutdown(Runnable onShutdown);
 
   /**
-   * Registers a runnable to be executed when the application server is shutting down, with a specific order.
+   * Registers a runnable to be executed when the application server is shutting down, with a
+   * specific order.
    *
    * <p>Runnables with lower order values will be executed first.
    *
@@ -35,7 +36,8 @@ enum Status {
   /**
    * Registers a runnable as a shutdown hook with the JVM.
    *
-   * <p>This runnable will be executed when the JVM is shutting down, regardless of the application server's state.
+   * <p>This runnable will be executed when the JVM is shutting down, regardless of the application
+   * server's state.
    *
    * @param onShutdown The runnable to register as a shutdown hook.
    */

avaje-jex/src/main/java/io/avaje/jex/DJexConfig.java

@@ -48,18 +48,20 @@ public String contextPath() {
   public JexConfig contextPath(String contextPath) {
     if (!this.contextPath.equals(contextPath)) {
 
-      this.contextPath = contextPath
-          .transform(s -> s.startsWith("/") ? s : "/" + s)
-          .transform(s -> s.endsWith("/") ? s.substring(0, s.lastIndexOf("/")) : s);
+      this.contextPath =
+          contextPath
+              .transform(s -> s.startsWith("/") ? s : "/" + s)
+              .transform(s -> s.endsWith("/") ? s.substring(0, s.lastIndexOf("/")) : s);
     }
     return this;
   }
 
   @Override
   public Executor executor() {
     if (executor == null) {
-      executor = Executors.newThreadPerTaskExecutor(
-          Thread.ofVirtual().name("avaje-jex-http-", 0).factory());
+      executor =
+          Executors.newThreadPerTaskExecutor(
+              Thread.ofVirtual().name("avaje-jex-http-", 0).factory());
     }
     return executor;
   }

avaje-jex/src/main/java/io/avaje/jex/DefaultRouting.java

@@ -36,7 +36,8 @@ public Map<Class<?>, ExceptionHandler<?>> errorHandlers() {
   }
 
   private String path(String path) {
-    return String.join("", pathDeque) + ((path.startsWith("/") || path.isEmpty()) ? path : "/" + path);
+    return String.join("", pathDeque)
+        + ((path.startsWith("/") || path.isEmpty()) ? path : "/" + path);
   }
 
   private void addEndpoints(String path, HttpService group) {