10.0.0 Major enhancements to connection stability for autoplug web users. 🎉

      Using Netty as networking library under the hood to achieve this.
      Make sure you update if you are using the web panel since the old client won't be able to connect to the panel anymore.
      I currently have more time to focus on this project, thus feel free to dm me any ideas and bugs/annoyances that you have when using the web panel. 🙌

Author: Osiris-Team

pom.xml

@@ -11,11 +11,11 @@ AUTO-GENERATED FILE, CHANGES SHOULD BE DONE IN ./JPM.java or ./src/main/java/JPM
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.osiris.autoplug.client</groupId>
     <artifactId>AutoPlug-Client</artifactId>
-    <version>9.0.2</version>
+    <version>10.0.0</version>
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <java.version>9</java.version>
-        <version>9.0.2</version>
+        <version>10.0.0</version>
         <main-class>com.osiris.autoplug.client.Main</main-class>
         <slf4j.version>2.0.13</slf4j.version>
         <name>AutoPlug-Client</name>
@@ -297,6 +297,12 @@ AUTO-GENERATED FILE, CHANGES SHOULD BE DONE IN ./JPM.java or ./src/main/java/JPM
             <version>20250107</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.101.Final</version>
+            <scope>compile</scope>
+        </dependency>
         <dependency>
             <groupId>com.google.api-client</groupId>
             <artifactId>google-api-client</artifactId>

src/main/java/JPM.java

@@ -21,7 +21,7 @@ public ThisProject(List<String> args) {
         // Override default configurations
         this.groupId = "com.osiris.autoplug.client";
         this.artifactId = "AutoPlug-Client";
-        this.version = "9.0.2";
+        this.version = "10.0.0";
         this.mainClass = "com.osiris.autoplug.client.Main";
         this.jarName = "AutoPlug-Client-original.jar";
         this.fatJarName = "AutoPlug-Client.jar";
@@ -74,6 +74,7 @@ public ThisProject(List<String> args) {
         implementation("com.formdev:flatlaf:2.2");
         implementation("org.apache.sshd:sshd-core:2.13.0");
         implementation("org.json:json:20250107");
+        implementation("io.netty:netty-all:4.1.101.Final");
 
         // Google Drive
         implementation("com.google.api-client:google-api-client:2.0.0");

src/main/java/com/osiris/autoplug/client/console/Commands.java

@@ -163,7 +163,7 @@ public static boolean execute(@NotNull String command) {
                     new BeforeServerStartupTasks();
                     return true;
                 } else if (command.equals(".con info") || command.equals(".ci")) {
-                    AL.info("Main connection: connected=" + Main.CON.isConnected() + " interrupted=" + Main.CON.isInterrupted() + " user/staff active=" + Main.CON.isUserActive.get());
+                    AL.info("Main connection: connected=" + Main.CON.isConnected() + " user/staff active=" + Main.CON.isUserActive.get());
                     AL.info(Main.CON.CON_PUBLIC_DETAILS.toString());
                     AL.info(Main.CON.CON_PRIVATE_DETAILS.toString());
                     AL.info(Main.CON.CON_CONSOLE_SEND.toString());

src/main/java/com/osiris/autoplug/client/network/online/ConMain.java

@@ -1,42 +1,29 @@
-/*
- * Copyright (c) 2021-2024 Osiris-Team.
- * All rights reserved.
- *
- * This software is copyrighted work, licensed under the terms
- * of the MIT-License. Consult the "LICENSE" file for details.
- */
-
 package com.osiris.autoplug.client.network.online;
 
 import com.osiris.autoplug.client.network.online.connections.*;
 import com.osiris.jlib.logger.AL;
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.ReplayingDecoder;
+import io.netty.handler.timeout.IdleStateHandler;
 
-import java.io.IOException;
 import java.security.InvalidKeyException;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
-/**
- * This is the main connection to AutoPlugs online server/website.
- * It stays active all the time and sends/receives true/false values, regarding the users login status.
- * When the user is logged in, it creates the secondary connections and holds them until the user logs out.
- * The main connection authenticates using the server_key.
- * If it receives a true boolean it means that the user is logged in and opens new connections.
- */
 public class ConMain extends DefaultConnection {
     public final ConSendPublicDetails CON_PUBLIC_DETAILS = new ConSendPublicDetails();
-
-
-    // Secondary connections:
     public final ConAutoPlugConsoleReceive CON_CONSOLE_RECEIVE = new ConAutoPlugConsoleReceive();
     public final ConAutoPlugConsoleSend CON_CONSOLE_SEND = new ConAutoPlugConsoleSend();
     public final ConSystemConsoleSend CON_SYSTEM_CONSOLE_SEND = new ConSystemConsoleSend();
     public final ConSystemConsoleReceive CON_SYSTEM_CONSOLE_RECEIVE = new ConSystemConsoleReceive();
     public final ConSendPrivateDetails CON_PRIVATE_DETAILS = new ConSendPrivateDetails();
     public final ConFileManager CON_FILE_MANAGER = new ConFileManager();
+
     public boolean isDone = false; // So that the log isn't a mess because of the processes which start right after this.
     public AtomicBoolean isUserActive = new AtomicBoolean(false);
-    public boolean isUserActiveOld = false; // Local variable that holds the auth boolean before the current one
-
+    public boolean isUserActiveOld = false;
     public int msUntilRetry = 30000;
 
     public ConMain() {
@@ -49,97 +36,83 @@ public boolean open() {
             AL.info("Authenticating server...");
             super.open();
             AL.info("Authentication success!");
-            socket.setSoTimeout(60000); // 60 seconds for when AP-Web is overloaded
             CON_PUBLIC_DETAILS.open();
+            msUntilRetry = 30000;
             isDone = true;
         } catch (Exception e) {
-            AL.warn(e);
             isDone = true;
-            if (e instanceof InvalidKeyException)
-                return false; // Abort directly since no valid key exists
-            // else we continue below and retry the connection
+            AL.warn(e);
+            if (e instanceof InvalidKeyException) return false;
+            scheduleReconnect();
+            return false;
         }
-        super.setAndStartAsync(() -> {
-            try {
-                if (!super.isConnected()) {
-                    AL.info("Authenticating server...");
-                    super.open();
-                    AL.info("Authentication success!");
-                    CON_PUBLIC_DETAILS.open();
-                    msUntilRetry = 30000;
-                }
-
-                isDone = true;
-                while (true) {
-                    isUserActive.set(super.in.readBoolean()); // Ping
-                    super.out.writeBoolean(true); // Pong true/false doesn't matter
-
-                    if (isUserActive.get()) {
-                        if (!isUserActiveOld) {
-                            AL.debug(this.getClass(), "Owner/Staff is online/active.");
-                            // User is online, so open secondary connections if they weren't already
-                            if (CON_CONSOLE_RECEIVE.isConnected()) CON_CONSOLE_RECEIVE.close();
-                            CON_CONSOLE_RECEIVE.open();
-                            if (CON_CONSOLE_SEND.isConnected()) CON_CONSOLE_SEND.close();
-                            CON_CONSOLE_SEND.open();
-                            if (CON_SYSTEM_CONSOLE_RECEIVE.isConnected()) CON_SYSTEM_CONSOLE_RECEIVE.close();
-                            CON_SYSTEM_CONSOLE_RECEIVE.open();
-                            if (CON_SYSTEM_CONSOLE_SEND.isConnected()) CON_SYSTEM_CONSOLE_SEND.close();
-                            CON_SYSTEM_CONSOLE_SEND.open();
-                            if (CON_FILE_MANAGER.isConnected()) CON_FILE_MANAGER.close();
-                            CON_FILE_MANAGER.open();
-                            if (CON_PRIVATE_DETAILS.isConnected()) CON_PRIVATE_DETAILS.close();
-                            CON_PRIVATE_DETAILS.open();
-                            //if (!CON_PLUGINS_UPDATER.isConnected()) CON_PLUGINS_UPDATER.open(); Only is used at restarts!
-                        }
-                    } else {
-                        if (isUserActiveOld) {
-                            AL.debug(this.getClass(), "Owner/Staff is offline/inactive.");
-                            // Close secondary connections when user is offline/logged out
-                            if (CON_CONSOLE_RECEIVE.isConnected()) CON_CONSOLE_RECEIVE.close();
-                            if (CON_CONSOLE_SEND.isConnected()) CON_CONSOLE_SEND.close();
-                            if (CON_SYSTEM_CONSOLE_RECEIVE.isConnected()) CON_SYSTEM_CONSOLE_RECEIVE.close();
-                            if (CON_SYSTEM_CONSOLE_SEND.isConnected()) CON_SYSTEM_CONSOLE_SEND.close();
-                            if (CON_FILE_MANAGER.isConnected()) CON_FILE_MANAGER.close();
-                            if (CON_PRIVATE_DETAILS.isConnected()) CON_PRIVATE_DETAILS.close();
-                            //if (CON_PLUGINS_UPDATER.isConnected()) CON_PLUGINS_UPDATER.close(); Only is used at restarts!
-                        }
-                    }
-                    isUserActiveOld = isUserActive.get();
-                    Thread.sleep(3000);
-                }
-            } catch (Exception e) {
-                isDone = true;
-                if (isClosing.get()) {
-                    AL.info("Closed main connection to AutoPlug-Web.");
-                    return;
-                }
 
-                // Since we didn't meant to close, create a new thread that tries to reconnect
-                new Thread(() -> {
-                    try {
-                        while (true) {
-                            AL.warn("Connection problems! Reconnecting in " + msUntilRetry / 1000 + " seconds...", e);
-                            Thread.sleep(msUntilRetry);
+        // Add IdleStateHandler FIRST: Wait some seconds for a read. (0 means disable write/all idle checking)
+        channel.pipeline().addLast(new IdleStateHandler(30, 0, 0, TimeUnit.SECONDS));
+        channel.pipeline().addLast(new ReplayingDecoder<Void>() {
+            @Override
+            protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {
+                boolean active = in.readBoolean();
+                isUserActive.set(active);
+
+                ByteBuf pong = ctx.alloc().buffer(1);
+                pong.writeBoolean(true);
+                ctx.writeAndFlush(pong);
+
+                try {
+                    if (active && !isUserActiveOld) {
+                        AL.debug(ConMain.class, "Owner/Staff is online/active.");
+                        // Offload to a virtual thread so Netty can keep working
+                        Thread.startVirtualThread(() -> {
                             try {
-                                if (open())
-                                    break;
-                                else
-                                    AL.warn("Failed to reconnect!");
-                            } catch (Exception ex) {
-                                AL.warn("Failed to reconnect!", ex);
+                                if (!CON_CONSOLE_RECEIVE.isConnected()) CON_CONSOLE_RECEIVE.open();
+                                if (!CON_CONSOLE_SEND.isConnected()) CON_CONSOLE_SEND.open();
+                                if (!CON_SYSTEM_CONSOLE_RECEIVE.isConnected()) CON_SYSTEM_CONSOLE_RECEIVE.open();
+                                if (!CON_SYSTEM_CONSOLE_SEND.isConnected()) CON_SYSTEM_CONSOLE_SEND.open();
+                                if (!CON_FILE_MANAGER.isConnected()) CON_FILE_MANAGER.open();
+                                if (!CON_PRIVATE_DETAILS.isConnected()) CON_PRIVATE_DETAILS.open();
+                            } catch (Exception e) {
+                                AL.warn(e);
                             }
-                            msUntilRetry += 30000;
-                        }
-                    } catch (Exception exception) {
-                        AL.warn("Connection problems, unexpected error! Reconnect manually by entering '.con reload'.", exception);
+                        });
+                    } else if (!active && isUserActiveOld) {
+                        AL.debug(ConMain.class, "Owner/Staff is offline/inactive.");
+                        closeTempCons();
                     }
-                }).start();
+                    isUserActiveOld = active;
+                } catch (Exception e) {
+                    AL.warn(e);
+                }
+                checkpoint();
+            }
 
-                close();
+            @Override
+            public void channelInactive(ChannelHandlerContext ctx) {
+                if (!isClosing.get()) scheduleReconnect();
+            }
+
+            @Override
+            public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
+                if (!isClosing.get()) scheduleReconnect();
             }
         });
-        return true; // Success
+
+        return true;
+    }
+
+    private void scheduleReconnect() {
+        if (isClosing.get()) return;
+        new Thread(() -> {
+            try {
+                AL.warn("Connection problems! Reconnecting in " + msUntilRetry / 1000 + " seconds...");
+                Thread.sleep(msUntilRetry);
+                msUntilRetry += 30000;
+                if (!open()) scheduleReconnect();
+            } catch (Exception e) {
+                AL.warn("Reconnect error", e);
+            }
+        }).start();
+        close();
     }
 
     @Override
@@ -148,58 +121,19 @@ public void close() {
         closePermCons();
     }
 
-    /**
-     * Close connections that are alive all the time.
-     */
     public void closePermCons() {
-        try {
-            // Reset booleans
-            isUserActiveOld = false;
-            isUserActive.set(false);
-            super.close();
-        } catch (Exception e) {
-            AL.warn(e);
-        }
-
-        try {
-            if (CON_PUBLIC_DETAILS.isConnected())
-                CON_PUBLIC_DETAILS.close();
-        } catch (Exception e1) {
-            AL.warn(e1);
-        }
+        isUserActiveOld = false;
+        isUserActive.set(false);
+        super.close();
+        try { if (CON_PUBLIC_DETAILS.isConnected()) CON_PUBLIC_DETAILS.close(); } catch (Exception ignored) {}
     }
 
-    /**
-     * Close connections that are online alive when the user is logged in.
-     */
     public void closeTempCons() {
-        try {
-            if (CON_CONSOLE_RECEIVE.isConnected())
-                CON_CONSOLE_RECEIVE.close();
-        } catch (Exception e1) {
-            AL.warn(e1);
-        }
-
-        try {
-            if (CON_CONSOLE_SEND.isConnected())
-                CON_CONSOLE_SEND.close();
-        } catch (IOException e1) {
-            AL.warn(e1);
-        }
-
-        try {
-            if (CON_PRIVATE_DETAILS.isConnected())
-                CON_PRIVATE_DETAILS.close();
-        } catch (Exception e1) {
-            AL.warn(e1);
-        }
-
-        try {
-            if (CON_FILE_MANAGER.isConnected())
-                CON_FILE_MANAGER.close();
-        } catch (Exception e1) {
-            AL.warn(e1);
-        }
+        try { if (CON_CONSOLE_RECEIVE.isConnected()) CON_CONSOLE_RECEIVE.close(); } catch (Exception ignored) {}
+        try { if (CON_CONSOLE_SEND.isConnected()) CON_CONSOLE_SEND.close(); } catch (Exception ignored) {}
+        try { if (CON_PRIVATE_DETAILS.isConnected()) CON_PRIVATE_DETAILS.close(); } catch (Exception ignored) {}
+        try { if (CON_FILE_MANAGER.isConnected()) CON_FILE_MANAGER.close(); } catch (Exception ignored) {}
+        try { if (CON_SYSTEM_CONSOLE_RECEIVE.isConnected()) CON_SYSTEM_CONSOLE_RECEIVE.close(); } catch (Exception ignored) {}
+        try { if (CON_SYSTEM_CONSOLE_SEND.isConnected()) CON_SYSTEM_CONSOLE_SEND.close(); } catch (Exception ignored) {}
     }
-
-}
+}