Spotless apply (#109)

* initial spotless

* add license

* change pom indentation to 2 from 4

* mvn spotless:apply

src/main/java/com/teragrep/rlp_03/EncryptionInfo.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,7 +43,6 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import javax.net.ssl.SSLPeerUnverifiedException;

src/main/java/com/teragrep/rlp_03/EncryptionInfoStub.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,7 +43,6 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import javax.net.ssl.SSLPeerUnverifiedException;

src/main/java/com/teragrep/rlp_03/EncryptionInfoTLS.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,7 +43,6 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import tlschannel.TlsChannel;
@@ -65,22 +64,22 @@ public EncryptionInfoTLS(TlsChannel tlsChannel) {
     public boolean isEncrypted() {
         return true;
     }
-    
+
     @Override
     public String getSessionCipherSuite() {
         return tlsChannel.getSslEngine().getSession().getCipherSuite();
     }
-    
+
     @Override
     public Certificate[] getLocalCertificates() {
         return tlsChannel.getSslEngine().getSession().getLocalCertificates();
     }
-    
+
     @Override
     public Principal getLocalPrincipal() {
         return tlsChannel.getSslEngine().getSession().getLocalPrincipal();
     }
-    
+
     @Override
     public X509Certificate[] getPeerCertificateChain() throws SSLPeerUnverifiedException {
         return tlsChannel.getSslEngine().getSession().getPeerCertificateChain();
@@ -90,7 +89,7 @@ public X509Certificate[] getPeerCertificateChain() throws SSLPeerUnverifiedExcep
     public Certificate[] getPeerCertificates() throws SSLPeerUnverifiedException {
         return tlsChannel.getSslEngine().getSession().getPeerCertificates();
     }
-    
+
     @Override
     public Principal getPeerPrincipal() throws SSLPeerUnverifiedException {
         return tlsChannel.getSslEngine().getSession().getPeerPrincipal();

src/main/java/com/teragrep/rlp_03/FrameContext.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,13 +43,13 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import com.teragrep.rlp_03.context.ConnectionContext;
 import com.teragrep.rlp_03.context.frame.RelpFrame;
 
 public class FrameContext {
+
     private final ConnectionContext connectionContext;
     private final RelpFrame relpFrame;
 
@@ -66,5 +66,4 @@ public RelpFrame relpFrame() {
         return relpFrame;
     }
 
-
 }

src/main/java/com/teragrep/rlp_03/Server.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,7 +43,6 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import com.teragrep.rlp_03.context.channel.SocketFactory;
@@ -60,6 +59,7 @@
 import java.util.function.Supplier;
 
 public class Server implements Runnable {
+
     private static final Logger LOGGER = LoggerFactory.getLogger(Server.class);
 
     public final ThreadPoolExecutor executorService;
@@ -74,7 +74,6 @@ public class Server implements Runnable {
 
     public final Status startup;
 
-
     public Server(
             ThreadPoolExecutor threadPoolExecutor,
             Supplier<FrameDelegate> frameDelegateSupplier,
@@ -106,7 +105,15 @@ public void stop() {
 
     @Override
     public void run() {
-        try (SocketPoll socketPoll = new SocketPoll(executorService,socketFactory, selector, serverSocketChannel, frameDelegateSupplier)) {
+        try (
+                SocketPoll socketPoll = new SocketPoll(
+                        executorService,
+                        socketFactory,
+                        selector,
+                        serverSocketChannel,
+                        frameDelegateSupplier
+                )
+        ) {
             startup.complete(); // indicate successful startup
             LOGGER.debug("Started");
             while (!stop.get()) {
@@ -138,4 +145,4 @@ public void run() {
         }
         LOGGER.debug("Stopped");
     }
-}
+}

src/main/java/com/teragrep/rlp_03/ServerFactory.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,7 +43,6 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import com.teragrep.rlp_03.config.Config;
@@ -75,23 +74,23 @@ public class ServerFactory {
     final ConnectionContextStub connectionContextStub;
     final InetSocketAddress listenSocketAddress;
 
-
     public ServerFactory(Config config, Supplier<FrameDelegate> frameDelegateSupplier) {
         this(config, new TLSConfig(), frameDelegateSupplier);
     }
 
-
-    public ServerFactory(
-            Config config,
-            TLSConfig tlsConfig,
-            Supplier<FrameDelegate> frameDelegateSupplier
-    ) {
+    public ServerFactory(Config config, TLSConfig tlsConfig, Supplier<FrameDelegate> frameDelegateSupplier) {
 
         this.config = config;
         this.tlsConfig = tlsConfig;
         this.frameDelegateSupplier = frameDelegateSupplier;
 
-        this.executorService = new ThreadPoolExecutor(config.numberOfThreads, config.numberOfThreads, Long.MAX_VALUE, TimeUnit.SECONDS, new LinkedBlockingQueue<>());
+        this.executorService = new ThreadPoolExecutor(
+                config.numberOfThreads,
+                config.numberOfThreads,
+                Long.MAX_VALUE,
+                TimeUnit.SECONDS,
+                new LinkedBlockingQueue<>()
+        );
         this.connectionContextStub = new ConnectionContextStub();
         this.listenSocketAddress = new InetSocketAddress(config.port);
     }

src/main/java/com/teragrep/rlp_03/SocketPoll.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,7 +43,6 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import com.teragrep.rlp_03.context.*;
@@ -62,6 +61,7 @@
 import java.util.function.Supplier;
 
 public class SocketPoll implements Closeable {
+
     private static final Logger LOGGER = LoggerFactory.getLogger(SocketPoll.class);
 
     private final ExecutorService executorService;
@@ -75,7 +75,6 @@ public class SocketPoll implements Closeable {
 
     private final ConnectionContextStub connectionContextStub;
 
-
     public SocketPoll(
             ExecutorService executorService,
             SocketFactory socketFactory,
@@ -94,31 +93,25 @@ public SocketPoll(
     public void poll() throws IOException {
         int readyKeys = selector.select();
 
-        LOGGER.debug("readyKeys <{}>",readyKeys);
+        LOGGER.debug("readyKeys <{}>", readyKeys);
 
         Set<SelectionKey> selectionKeys = selector.selectedKeys();
         LOGGER.debug("selectionKeys <{}> ", selectionKeys);
         for (SelectionKey selectionKey : selectionKeys) {
             if (LOGGER.isDebugEnabled()) {
-                LOGGER.debug(
-                        "selectionKey <{}>: " +
-                                "isValid <{}>, " +
-                                "isConnectable <{}>, " +
-                                "isAcceptable <{}>, " +
-                                "isReadable <{}>, " +
-                                "isWritable <{}>",
-                        selectionKey,
-                        selectionKey.isValid(),
-                        selectionKey.isConnectable(),
-                        selectionKey.isAcceptable(),
-                        selectionKey.isReadable(),
-                        selectionKey.isWritable()
-                );
+                LOGGER
+                        .debug(
+                                "selectionKey <{}>: " + "isValid <{}>, " + "isConnectable <{}>, "
+                                        + "isAcceptable <{}>, " + "isReadable <{}>, " + "isWritable <{}>",
+                                selectionKey, selectionKey.isValid(), selectionKey.isConnectable(),
+                                selectionKey.isAcceptable(), selectionKey.isReadable(), selectionKey.isWritable()
+                        );
             }
             try {
                 if (selectionKey.isAcceptable()) {
                     processAccept(serverSocketChannel, selectionKey);
-                } else {
+                }
+                else {
                     // submit readTask/writeTask based on clientContext states
                     ConnectionContext connectionContext = (ConnectionContext) selectionKey.attachment();
                     try {
@@ -129,7 +122,8 @@ public void poll() throws IOException {
                         connectionContext.close();
                     }
                 }
-            } catch (CancelledKeyException cke) { // TODO is this proper to catch here?
+            }
+            catch (CancelledKeyException cke) { // TODO is this proper to catch here?
                 LOGGER.warn("SocketPoll.poll CancelledKeyException caught: {}", cke.getMessage());
                 selectionKey.channel().close();
             }
@@ -155,24 +149,23 @@ private void processAccept(ServerSocketChannel serverSocketChannel, SelectionKey
                     SocketAddress localAddress = serverSocketChannel.getLocalAddress();
                     SocketAddress remoteAddress = clientSocketChannel.getRemoteAddress();
                     LOGGER.debug("ServerSocket <{}> accepting ClientSocket <{}> ", localAddress, remoteAddress);
-                } catch (IOException ioException) {
+                }
+                catch (IOException ioException) {
                     LOGGER.warn("Exception while getAddress", ioException);
                 }
             }
 
             // tls/plain wrapper
             Socket socket = socketFactory.create(clientSocketChannel);
 
-
-
             // non-blocking
             clientSocketChannel.configureBlocking(false);
 
-            SelectionKey clientSelectionKey = clientSocketChannel.register(
-                    selector,
-                    0, // interestOps: none at this point
-                    connectionContextStub
-            );
+            SelectionKey clientSelectionKey = clientSocketChannel
+                    .register(
+                            selector, 0, // interestOps: none at this point
+                            connectionContextStub
+                    );
 
             InterestOps interestOps = new InterestOpsImpl(clientSelectionKey);
 

src/main/java/com/teragrep/rlp_03/Status.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,7 +43,6 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -57,8 +56,6 @@ public class Status {
     private final Condition pending;
     private final AtomicBoolean done;
 
-
-
     Status() {
         this.lock = new ReentrantLock();
         this.pending = lock.newCondition();
@@ -70,7 +67,8 @@ void complete() {
         try {
             done.set(true);
             pending.signal();
-        } finally {
+        }
+        finally {
             lock.unlock();
         }
     }

src/main/java/com/teragrep/rlp_03/TransportInfo.java

@@ -1,6 +1,6 @@
 /*
  * Java Reliable Event Logging Protocol Library Server Implementation RLP-03
- * Copyright (C) 2021  Suomen Kanuuna Oy
+ * Copyright (C) 2021-2024 Suomen Kanuuna Oy
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU Affero General Public License as published by
@@ -43,10 +43,10 @@
  * Teragrep, the applicable Commercial License may apply to this file if you as
  * a licensee so wish it.
  */
-
 package com.teragrep.rlp_03;
 
 public interface TransportInfo {
+
     String getLocalAddress();
 
     int getLocalPort();