Merge branch 'release/5.6.10'

5.6.9 stable release

LaunchServer/build.gradle

@@ -13,20 +13,24 @@
     maven {
         url "https://jitpack.io/"
     }
+    maven {
+        url 'https://maven.gravit-support.ru/repository/jitpack'
+        credentials {
+            username = 'gravitlauncher'
+            password = 'gravitlauncher'
+        }
+    }
 }
 
 sourceCompatibility = '21'
 targetCompatibility = '21'
 
 configurations {
-    compileOnlyA
     bundleOnly
     bundle
-    hikari
     pack
-    launch4j
     bundleOnly.extendsFrom bundle
-    api.extendsFrom bundle, hikari, pack, launch4j
+    api.extendsFrom bundle, pack
 }
 
 jar {
@@ -81,6 +85,13 @@ pack project(':LauncherAPI')
     bundle group: 'io.netty', name: 'netty-transport-classes-epoll', version: rootProject['verNetty']
     bundle group: 'io.netty', name: 'netty-transport-native-epoll', version: rootProject['verNetty'], classifier: 'linux-x86_64'
     bundle group: 'io.netty', name: 'netty-transport-native-epoll', version: rootProject['verNetty'], classifier: 'linux-aarch_64'
+    bundle group: 'io.netty', name: 'netty-transport-classes-io_uring', version: rootProject['verNetty']
+    bundle group: 'io.netty', name: 'netty-transport-native-io_uring', version: rootProject['verNetty'], classifier: 'linux-x86_64'
+    bundle group: 'io.netty', name: 'netty-transport-native-io_uring', version: rootProject['verNetty'], classifier: 'linux-aarch_64'
+    // Netty
+    bundle 'org.jboss.marshalling:jboss-marshalling:1.4.11.Final'
+    bundle 'com.google.protobuf.nano:protobuf-javanano:3.1.0'
+    //
     bundle group: 'org.slf4j', name: 'slf4j-api', version: rootProject['verSlf4j']
     bundle group: 'com.mysql', name: 'mysql-connector-j', version: rootProject['verMySQLConn']
     bundle group: 'org.mariadb.jdbc', name: 'mariadb-java-client', version: rootProject['verMariaDBConn']
@@ -96,40 +107,26 @@ pack project(':LauncherAPI')
     annotationProcessor(group: 'org.apache.logging.log4j', name: 'log4j-core', version: rootProject['verLog4j'])
     testImplementation group: 'org.junit.jupiter', name: 'junit-jupiter', version: rootProject['verJunit']
 
-    hikari 'io.micrometer:micrometer-core:1.13.1'
-    hikari('com.zaxxer:HikariCP:5.1.0') {
+    bundle 'io.micrometer:micrometer-core:1.14.4'
+    bundle('com.zaxxer:HikariCP:6.2.1') {
         exclude group: 'javassist'
         exclude group: 'io.micrometer'
         exclude group: 'org.slf4j'
     }
 }
 
-tasks.register('hikari', Copy) {
-    duplicatesStrategy = 'EXCLUDE'
-    into "$buildDir/libs/libraries/hikaricp"
-    from configurations.hikari
-}
-
 tasks.register('dumpLibs', Copy) {
     duplicatesStrategy = 'EXCLUDE'
-    dependsOn tasks.hikari
     into "$buildDir/libs/libraries"
     from configurations.bundleOnly
 }
 
-tasks.register('dumpCompileOnlyLibs', Copy) {
-    duplicatesStrategy = 'EXCLUDE'
-    into "$buildDir/libs/launcher-libraries-compile"
-    from configurations.compileOnlyA
-}
-
 tasks.register('bundle', Zip) {
     duplicatesStrategy = 'EXCLUDE'
-    dependsOn parent.childProjects.Launcher.tasks.build, tasks.dumpLibs, tasks.dumpCompileOnlyLibs, tasks.jar
+    dependsOn parent.childProjects.Launcher.tasks.build, tasks.dumpLibs, tasks.jar
     archiveFileName = 'LaunchServer.zip'
     destinationDirectory = file("$buildDir")
     from(tasks.dumpLibs.destinationDir) { into 'libraries' }
-    from(tasks.dumpCompileOnlyLibs.destinationDir) { into 'launcher-libraries-compile' }
     from(tasks.jar)
     from(parent.childProjects.Launcher.tasks.dumpLibs) { into 'launcher-libraries' }
 }
@@ -140,7 +137,7 @@ pack project(':LauncherAPI')
     from parent.childProjects.Launcher.tasks.dumpLibs
 }
 
-assemble.dependsOn tasks.dumpLibs, tasks.dumpCompileOnlyLibs, tasks.dumpClientLibs, tasks.bundle, tasks.cleanjar
+assemble.dependsOn tasks.dumpLibs, tasks.dumpClientLibs, tasks.bundle, tasks.cleanjar
 
 
 publishing {

LaunchServer/src/main/java/pro/gravit/launchserver/LaunchServer.java

@@ -21,6 +21,7 @@
 import pro.gravit.launchserver.modules.events.*;
 import pro.gravit.launchserver.modules.impl.LaunchServerModulesManager;
 import pro.gravit.launchserver.socket.Client;
+import pro.gravit.launchserver.socket.SocketCommandServer;
 import pro.gravit.launchserver.socket.handlers.NettyServerSocketHandler;
 import pro.gravit.launchserver.socket.response.auth.ProfilesResponse;
 import pro.gravit.launchserver.socket.response.auth.RestoreResponse;
@@ -85,6 +86,7 @@ public final class LaunchServer implements Runnable, AutoCloseable, Reconfigurab
     public final Path modulesDir;
     public final Path launcherModulesDir;
     public final Path librariesDir;
+    public final Path controlFile;
     /**
      * This object contains runtime configuration
      */
@@ -113,6 +115,7 @@ public final class LaunchServer implements Runnable, AutoCloseable, Reconfigurab
     // Server
     public final CommandHandler commandHandler;
     public final NettyServerSocketHandler nettyServerSocketHandler;
+    public final SocketCommandServer socketCommandServer;
     public final ScheduledExecutorService service;
     public final AtomicBoolean started = new AtomicBoolean(false);
     public final LauncherModuleLoader launcherModuleLoader;
@@ -139,6 +142,7 @@ public LaunchServer(LaunchServerDirectories directories, LaunchServerEnv env, La
         modulesDir = directories.modules;
         launcherModulesDir = directories.launcherModules;
         librariesDir = directories.librariesDir;
+        controlFile = directories.controlFile;
         this.shardId = shardId;
         if(!Files.isDirectory(launcherPack)) {
             Files.createDirectories(launcherPack);
@@ -190,6 +194,7 @@ public LaunchServer(LaunchServerDirectories directories, LaunchServerEnv env, La
         }
         launcherModuleLoader.init();
         nettyServerSocketHandler = new NettyServerSocketHandler(this);
+        socketCommandServer = new SocketCommandServer(commandHandler, controlFile);
         if(config.sign.checkCertificateExpired) {
             checkCertificateExpired();
             service.scheduleAtFixedRate(this::checkCertificateExpired, 24, 24, TimeUnit.HOURS);
@@ -353,6 +358,7 @@ public void run() {
                 }
             }));
             CommonHelper.newThread("Command Thread", true, commandHandler).start();
+            CommonHelper.newThread("Socket Command Thread", true, socketCommandServer).start();
             // Sync updates dir
             CommonHelper.newThread("Profiles and updates sync", true, () -> {
                 try {
@@ -461,7 +467,7 @@ public interface LaunchServerConfigManager {
     public static class LaunchServerDirectories {
         public static final String UPDATES_NAME = "updates",
                 TRUSTSTORE_NAME = "truststore", LAUNCHERLIBRARIES_NAME = "launcher-libraries",
-                LAUNCHERLIBRARIESCOMPILE_NAME = "launcher-libraries-compile", LAUNCHERPACK_NAME = "launcher-pack", KEY_NAME = ".keys", MODULES = "modules", LAUNCHER_MODULES = "launcher-modules", LIBRARIES = "libraries";
+                LAUNCHERLIBRARIESCOMPILE_NAME = "launcher-libraries-compile", LAUNCHERPACK_NAME = "launcher-pack", KEY_NAME = ".keys", MODULES = "modules", LAUNCHER_MODULES = "launcher-modules", LIBRARIES = "libraries", CONTROL_FILE = "control-file";
         public Path updatesDir;
         public Path librariesDir;
         public Path launcherLibrariesDir;
@@ -473,6 +479,7 @@ public static class LaunchServerDirectories {
         public Path tmpDir;
         public Path modules;
         public Path launcherModules;
+        public Path controlFile;
 
         public void collect() {
             if (updatesDir == null) updatesDir = getPath(UPDATES_NAME);
@@ -486,6 +493,7 @@ public void collect() {
             if (modules == null) modules = getPath(MODULES);
             if (launcherModules == null) launcherModules = getPath(LAUNCHER_MODULES);
             if (librariesDir == null) librariesDir = getPath(LIBRARIES);
+            if (controlFile == null) controlFile = getPath(CONTROL_FILE);
             if (tmpDir == null)
                 tmpDir = Paths.get(System.getProperty("java.io.tmpdir")).resolve("launchserver-%s".formatted(SecurityHelper.randomStringToken()));
         }

LaunchServer/src/main/java/pro/gravit/launchserver/LaunchServerStarter.java

@@ -63,7 +63,7 @@ public static void main(String[] args) throws Exception {
         directories.collect();
         CertificateManager certificateManager = new CertificateManager();
         try {
-            certificateManager.readTrustStore(dir.resolve("truststore"));
+            certificateManager.readTrustStore(directories.trustStore);
         } catch (CertificateException e) {
             throw new IOException(e);
         }

LaunchServer/src/main/java/pro/gravit/launchserver/Main.java

@@ -18,7 +18,7 @@
 import java.util.stream.Stream;
 
 public class Main {
-    private static final List<String> classpathOnly = List.of("proguard", "jline", "progressbar", "kotlin", "epoll");
+    private static final List<String> classpathOnly = List.of("proguard", "jline", "progressbar", "kotlin");
     private static final String LOG4J_PROPERTY = "log4j2.configurationFile";
     private static final String DEBUG_PROPERTY = "launchserver.main.debug";
     private static final String LIBRARIES_PROPERTY = "launchserver.dir.libraries";

LaunchServer/src/main/java/pro/gravit/launchserver/auth/core/AbstractSQLCoreProvider.java

@@ -295,7 +295,9 @@ private SQLUser queryUser(String sql, String value) throws SQLException {
                 user = constructUser(set);
             }
         }
-        user.permissions = requestPermissions(user.uuid.toString());
+        if(user != null) {
+            user.permissions = requestPermissions(user.uuid.toString());
+        }
         return user;
     }
 

LaunchServer/src/main/java/pro/gravit/launchserver/auth/core/SQLCoreProvider.java

@@ -7,8 +7,10 @@
 import pro.gravit.launchserver.auth.MySQLSourceConfig;
 import pro.gravit.launchserver.auth.SQLSourceConfig;
 import pro.gravit.launchserver.auth.core.interfaces.UserHardware;
+import pro.gravit.launchserver.auth.core.interfaces.provider.AuthSupportExtendedCheckServer;
 import pro.gravit.launchserver.auth.core.interfaces.provider.AuthSupportHardware;
 import pro.gravit.launchserver.auth.core.interfaces.session.UserSessionSupportHardware;
+import pro.gravit.launchserver.socket.Client;
 import pro.gravit.utils.helper.IOHelper;
 
 import java.io.ByteArrayInputStream;
@@ -19,7 +21,7 @@
 import java.util.List;
 import java.util.UUID;
 
-public class SQLCoreProvider extends AbstractSQLCoreProvider implements AuthSupportHardware {
+public class SQLCoreProvider extends AbstractSQLCoreProvider implements AuthSupportHardware, AuthSupportExtendedCheckServer {
     public HikariSQLSourceConfig holder;
 
     @Override
@@ -291,6 +293,18 @@ protected AbstractSQLCoreProvider.SQLUserSession createSession(AbstractSQLCorePr
         return new SQLUserSession(user);
     }
 
+    @Override
+    public UserSession extendedCheckServer(Client client, String username, String serverID) throws IOException {
+        AbstractSQLCoreProvider.SQLUser user = (AbstractSQLCoreProvider.SQLUser) getUserByUsername(username);
+        if (user == null) {
+            return null;
+        }
+        if (user.getUsername().equals(username) && user.getServerId().equals(serverID)) {
+            return createSession(user);
+        }
+        return null;
+    }
+
     public class SQLUserSession extends AbstractSQLCoreProvider.SQLUserSession implements UserSessionSupportHardware {
         private transient SQLUser SQLUser;
         protected transient SQLUserHardware hardware;

LaunchServer/src/main/java/pro/gravit/launchserver/command/basic/DebugCommand.java

@@ -32,6 +32,7 @@ public void invoke(String... args) throws Exception {
         boolean value = Boolean.parseBoolean(args[0]);
         LoggerContext ctx = (LoggerContext) LogManager.getContext(false);
         Configuration config = ctx.getConfiguration();
+        config.getWatchManager().setIntervalSeconds(-1);
         LoggerConfig loggerConfig = config.getLoggerConfig("pro.gravit");
         loggerConfig.setLevel(value ? Level.TRACE : Level.DEBUG);
         ctx.updateLoggers();

LaunchServer/src/main/java/pro/gravit/launchserver/config/LaunchServerConfig.java

@@ -19,6 +19,7 @@
 import pro.gravit.launchserver.components.AuthLimiterComponent;
 import pro.gravit.launchserver.components.Component;
 import pro.gravit.launchserver.components.ProGuardComponent;
+import pro.gravit.launchserver.socket.NettyObjectFactory;
 
 import java.util.*;
 
@@ -64,12 +65,7 @@ public static LaunchServerConfig getDefault(LaunchServer.LaunchServerEnv env) {
         newConfig.netty.fileServerEnabled = true;
         newConfig.netty.binds = new NettyBindAddress[]{new NettyBindAddress("0.0.0.0", 9274)};
         newConfig.netty.performance = new NettyPerformanceConfig();
-        try {
-            newConfig.netty.performance.usingEpoll = Epoll.isAvailable();
-        } catch (Throwable e) {
-            // Epoll class line 51+ catch (Exception) but Error will be thrown by System.load
-            newConfig.netty.performance.usingEpoll = false;
-        } // such as on ARM
+        newConfig.netty.performance.mode = NettyObjectFactory.NettyFactoryMode.AUTO;
         newConfig.netty.performance.bossThread = 2;
         newConfig.netty.performance.workerThread = 8;
         newConfig.netty.performance.schedulerThread = 2;
@@ -277,7 +273,7 @@ public static class NettyConfig {
     }
 
     public static class NettyPerformanceConfig {
-        public boolean usingEpoll;
+        public NettyObjectFactory.NettyFactoryMode mode = NettyObjectFactory.NettyFactoryMode.AUTO;
         public int bossThread;
         public int workerThread;
         public int schedulerThread;

LaunchServer/src/main/java/pro/gravit/launchserver/manangers/CertificateManager.java

@@ -29,6 +29,7 @@
 public class CertificateManager {
     private transient final Logger logger = LogManager.getLogger();
     public LauncherTrustManager trustManager;
+    private Path truststorePath;
 
     public void writePrivateKey(Path file, PrivateKey privateKey) throws IOException {
         writePrivateKey(IOHelper.newWriter(file), privateKey);
@@ -91,6 +92,7 @@ public X509CertificateHolder readCertificate(Reader reader) throws IOException {
     }
 
     public void readTrustStore(Path dir) throws IOException, CertificateException {
+        this.truststorePath = dir;
         if (!IOHelper.isDir(dir)) {
             Files.createDirectories(dir);
             try {
@@ -131,4 +133,8 @@ public LauncherTrustManager.CheckClassResult checkClass(Class<?> clazz) {
         X509Certificate[] certificates = JVMHelper.getCertificates(clazz);
         return trustManager.checkCertificates(certificates, trustManager::stdCertificateChecker);
     }
+
+    public Path getTruststorePath() {
+        return truststorePath;
+    }
 }

LaunchServer/src/main/java/pro/gravit/launchserver/socket/LauncherNettyServer.java

@@ -36,14 +36,9 @@ public class LauncherNettyServer implements AutoCloseable {
 
     public LauncherNettyServer(LaunchServer server) {
         LaunchServerConfig.NettyConfig config = server.config.netty;
-        NettyObjectFactory.setUsingEpoll(config.performance.usingEpoll);
+        NettyObjectFactory.setMode(config.performance.mode);
         Logger logger = LogManager.getLogger();
-        if (config.performance.usingEpoll) {
-            logger.debug("Netty: Epoll enabled");
-        }
-        if (config.performance.usingEpoll && !Epoll.isAvailable()) {
-            logger.error("Epoll is not available: (netty,perfomance.usingEpoll configured wrongly)", Epoll.unavailabilityCause());
-        }
+        logger.info("Netty usage {} transport mode", NettyObjectFactory.getMode());
         bossGroup = NettyObjectFactory.newEventLoopGroup(config.performance.bossThread, "LauncherNettyServer.bossGroup");
         workerGroup = NettyObjectFactory.newEventLoopGroup(config.performance.workerThread, "LauncherNettyServer.workerGroup");
         serverBootstrap = new ServerBootstrap();

LaunchServer/src/main/java/pro/gravit/launchserver/socket/NettyObjectFactory.java

@@ -2,30 +2,60 @@
 
 import io.netty.channel.ChannelFactory;
 import io.netty.channel.EventLoopGroup;
+import io.netty.channel.MultiThreadIoEventLoopGroup;
 import io.netty.channel.ServerChannel;
+import io.netty.channel.epoll.Epoll;
 import io.netty.channel.epoll.EpollEventLoopGroup;
+import io.netty.channel.epoll.EpollIoHandler;
 import io.netty.channel.epoll.EpollServerSocketChannel;
 import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.nio.NioIoHandler;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.channel.uring.IoUring;
+import io.netty.channel.uring.IoUringIoHandler;
+import io.netty.channel.uring.IoUringServerSocketChannel;
 
 public class NettyObjectFactory {
-    private static boolean epoll = false;
+    private static NettyFactoryMode mode;
 
-    public static void setUsingEpoll(boolean value) {
-        epoll = value;
+    public static void setMode(NettyFactoryMode mode) {
+        NettyObjectFactory.mode = mode;
+        if(mode == NettyFactoryMode.AUTO) {
+            if(IoUring.isAvailable()) {
+                NettyObjectFactory.mode = NettyFactoryMode.IO_URING;
+                return;
+            }
+            if(Epoll.isAvailable()) {
+                NettyObjectFactory.mode = NettyFactoryMode.EPOLL;
+                return;
+            }
+            NettyObjectFactory.mode = NettyFactoryMode.NIO;
+        }
+    }
+
+    public static NettyFactoryMode getMode() {
+        return mode;
     }
 
     public static EventLoopGroup newEventLoopGroup(int threads, String poolName) {
-        if (epoll)
-            return new EpollEventLoopGroup(threads);
-        else
-            return new NioEventLoopGroup(threads);
+        return switch (mode) {
+            case AUTO -> null;
+            case NIO -> new MultiThreadIoEventLoopGroup(threads, NioIoHandler.newFactory());
+            case EPOLL -> new MultiThreadIoEventLoopGroup(threads, EpollIoHandler.newFactory());
+            case IO_URING -> new MultiThreadIoEventLoopGroup(threads, IoUringIoHandler.newFactory());
+        };
     }
 
     public static ChannelFactory<? extends ServerChannel> getServerSocketChannelFactory() {
-        if (epoll)
-            return EpollServerSocketChannel::new;
-        else
-            return NioServerSocketChannel::new;
+        return switch (mode) {
+            case AUTO -> null;
+            case NIO -> NioServerSocketChannel::new;
+            case EPOLL -> EpollServerSocketChannel::new;
+            case IO_URING -> IoUringServerSocketChannel::new;
+        };
+    }
+
+    public enum NettyFactoryMode {
+        AUTO, NIO, EPOLL, IO_URING
     }
 }

LaunchServer/src/main/java/pro/gravit/launchserver/socket/SocketCommandServer.java

@@ -0,0 +1,96 @@
+package pro.gravit.launchserver.socket;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import pro.gravit.launchserver.config.log4j.LogAppender;
+import pro.gravit.utils.command.CommandHandler;
+
+import java.io.IOException;
+import java.net.StandardProtocolFamily;
+import java.net.UnixDomainSocketAddress;
+import java.nio.ByteBuffer;
+import java.nio.channels.ServerSocketChannel;
+import java.nio.channels.SocketChannel;
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Path;
+
+public class SocketCommandServer implements Runnable {
+    private final Logger logger = LogManager.getLogger(SocketCommandServer.class);
+    private ServerSocketChannel channel;
+    private Path path;
+    private UnixDomainSocketAddress address;
+    private ServerSocketChannel serverChannel;
+    private CommandHandler commandHandler;
+    private transient SocketChannel clientChannel;
+
+    public SocketCommandServer(CommandHandler commandHandler, Path path) {
+        this.commandHandler = commandHandler;
+        this.path = path;
+    }
+
+    private void runCommand(SocketChannel channel, String command) {
+        logger.info("Command '{}' from socket", command);
+        clientChannel = channel;
+        try {
+            commandHandler.evalNative(command, false);
+        } catch (Throwable e) {
+            logger.error("Error when execute command", e);
+        } finally {
+            clientChannel = null;
+
+        }
+    }
+
+    @Override
+    public void run() {
+        try {
+            Files.deleteIfExists(path);
+            this.address = UnixDomainSocketAddress.of(path);
+            serverChannel = ServerSocketChannel.open(StandardProtocolFamily.UNIX);
+            serverChannel.configureBlocking(true);
+            serverChannel.bind(address);
+            LogAppender.getInstance().addListener((logEvent -> {
+                if(clientChannel != null && clientChannel.isOpen()) {
+                    try {
+                        String s = logEvent.getMessage().getFormattedMessage()+"\n";
+                        byte[] bytes = s.getBytes(StandardCharsets.UTF_8);
+                        ByteBuffer buffer = ByteBuffer.wrap(bytes);
+                        clientChannel.write(buffer);
+                    } catch (Throwable ignored) {
+                    }
+                }
+            }));
+            ByteBuffer buffer = ByteBuffer.allocate(1024);
+            while (true) {
+                SocketChannel channel = serverChannel.accept();
+                channel.configureBlocking(true);
+                String command = null;
+                try {
+                    mark:
+                    while (true) {
+                        int bytesRead = channel.read(buffer);
+                        if (bytesRead < 0) {
+                            break;
+                        }
+                        for (var i=0;i<buffer.limit();i++) {
+                            if(buffer.get(i) == '\n') {
+                                command = new String(buffer.array(), 0, i);
+                                break mark;
+                            }
+                        }
+
+                    }
+                    if(command != null) {
+                        runCommand(channel, command);
+                    }
+                } finally {
+                    buffer.clear();
+                    channel.close();
+                }
+            }
+        } catch (Throwable e) {
+            logger.error("Unix command socket server error", e);
+        }
+    }
+}

LauncherClient/src/main/java/pro/gravit/launcher/client/ClientLauncherEntryPoint.java

@@ -88,7 +88,7 @@ private static void realMain(String[] args) throws Throwable {
         ClientParams params = readParams(new InetSocketAddress("127.0.0.1", Launcher.getConfig().clientPort));
         ClientLauncherMethods.verifyNoAgent();
         if(params.timestamp > System.currentTimeMillis() || params.timestamp + 30*1000 < System.currentTimeMillis() ) {
-            LogHelper.error("Timestamp failed. Exit");
+            LogHelper.error("Timestamp failed: current %d | params %d | diff %d", System.currentTimeMillis(), params.timestamp, System.currentTimeMillis() - params.timestamp);
             ClientLauncherMethods.exitLauncher(-662);
             return;
         }

LauncherCore/src/main/java/pro/gravit/utils/Version.java

@@ -6,7 +6,7 @@ public final class Version implements Comparable<Version> {
 
     public static final int MAJOR = 5;
     public static final int MINOR = 6;
-    public static final int PATCH = 7;
+    public static final int PATCH = 10;
     public static final int BUILD = 1;
     public static final Version.Type RELEASE = Type.STABLE;
     public final int major;

LauncherCore/src/main/java/pro/gravit/utils/command/CommandHandler.java

@@ -10,8 +10,18 @@
 import java.util.Map;
 
 public abstract class CommandHandler implements Runnable {
-    private final List<Category> categories = new ArrayList<>();
-    private final CommandCategory baseCategory = new BaseCommandCategory();
+    protected final List<Category> categories;
+    protected final CommandCategory baseCategory;
+
+    public CommandHandler() {
+        this.categories = new ArrayList<>();
+        this.baseCategory = new BaseCommandCategory();
+    }
+
+    protected CommandHandler(List<Category> categories, CommandCategory baseCategory) {
+        this.categories = categories;
+        this.baseCategory = baseCategory;
+    }
 
     public void eval(String line, boolean bell) {
         LogHelper.info("Command '%s'", line);

LauncherCore/src/main/java/pro/gravit/utils/command/StdCommandHandler.java

@@ -5,6 +5,8 @@
 
 import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStream;
+import java.util.List;
 
 public class StdCommandHandler extends CommandHandler {
     private final BufferedReader reader;
@@ -14,6 +16,31 @@ public StdCommandHandler(boolean readCommands) {
         reader = readCommands ? IOHelper.newReader(System.in) : null;
     }
 
+    public StdCommandHandler(InputStream stream) {
+        super();
+        this.reader = IOHelper.newReader(stream);
+    }
+
+    public StdCommandHandler(BufferedReader reader) {
+        super();
+        this.reader = reader;
+    }
+
+    protected StdCommandHandler(List<Category> categories, CommandCategory baseCategory, boolean readCommands) {
+        super(categories, baseCategory);
+        this.reader = readCommands ? IOHelper.newReader(System.in) : null;
+    }
+
+    protected StdCommandHandler(List<Category> categories, CommandCategory baseCategory, InputStream stream) {
+        super(categories, baseCategory);
+        this.reader = IOHelper.newReader(stream);
+    }
+
+    protected StdCommandHandler(List<Category> categories, CommandCategory baseCategory, BufferedReader reader) {
+        super(categories, baseCategory);
+        this.reader = reader;
+    }
+
     @Override
     public void bell() {
     }
@@ -37,4 +64,16 @@ public void clear() throws IOException {
     public String readLine() throws IOException {
         return reader == null ? null : reader.readLine();
     }
+
+    public StdCommandHandler ofHandler(CommandHandler commandHandler, boolean readCommands) {
+        return new StdCommandHandler(commandHandler.categories, commandHandler.baseCategory, readCommands);
+    }
+
+    public StdCommandHandler ofHandler(CommandHandler commandHandler, InputStream stream) {
+        return new StdCommandHandler(commandHandler.categories, commandHandler.baseCategory, stream);
+    }
+
+    public StdCommandHandler ofHandler(CommandHandler commandHandler, BufferedReader reader) {
+        return new StdCommandHandler(commandHandler.categories, commandHandler.baseCategory, reader);
+    }
 }

LauncherCore/src/main/java/pro/gravit/utils/launch/LegacyLaunch.java

@@ -123,6 +123,9 @@ protected Class<?> findClass(String name) throws ClassNotFoundException {
 
         @Override
         public String findLibrary(String name) {
+            if(nativePath == null) {
+                return null;
+            }
             return nativePath.concat(IOHelper.PLATFORM_SEPARATOR).concat(JVMHelper.NATIVE_PREFIX).concat(name).concat(JVMHelper.NATIVE_EXTENSION);
         }
 

LauncherCore/src/main/java/pro/gravit/utils/launch/ModuleLaunch.java

@@ -262,6 +262,9 @@ protected Class<?> findClass(String moduleName, String name) {
 
         @Override
         public String findLibrary(String name) {
+            if(nativePath == null) {
+                return null;
+            }
             return nativePath.concat(IOHelper.PLATFORM_SEPARATOR).concat(JVMHelper.NATIVE_PREFIX).concat(name).concat(JVMHelper.NATIVE_EXTENSION);
         }
 

build.gradle

@@ -1,11 +1,11 @@
 plugins {
-    id 'com.github.johnrengelman.shadow' version '7.1.2' apply false
+    id 'com.github.johnrengelman.shadow' version '8.1.1' apply false
     id 'maven-publish'
     id 'signing'
     id 'org.openjfx.javafxplugin' version '0.1.0' apply false
 }
 group = 'pro.gravit.launcher'
-version = '5.6.7'
+version = '5.6.10'
 
 apply from: 'props.gradle'
 
@@ -30,6 +30,13 @@
         maven {
             url "https://jitpack.io/"
         }
+        maven {
+            url 'https://maven.gravit-support.ru/repository/jitpack'
+            credentials {
+                username = 'gravitlauncher'
+                password = 'gravitlauncher'
+            }
+        }
     }
 
     jar {

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.9-all.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.12-all.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME

gradlew

@@ -86,8 +86,7 @@ done
 # shellcheck disable=SC2034
 APP_BASE_NAME=${0##*/}
 # Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
-APP_HOME=$( cd -P "${APP_HOME:-./}" > /dev/null && printf '%s
-' "$PWD" ) || exit
+APP_HOME=$( cd -P "${APP_HOME:-./}" > /dev/null && printf '%s\n' "$PWD" ) || exit
 
 # Use the maximum available, or set MAX_FD != -1 to use that value.
 MAX_FD=maximum

modules

@@ -1 +1 @@
-Subproject commit 65f882bd90623aa1581ad24cfa4f52563ea95bc0
+Subproject commit aa5ab332d65dd14ce5321453aa809e30b87a186d

props.gradle

@@ -1,18 +1,18 @@
 project.ext {
-    verAsm = '9.7'
-    verNetty = '4.1.111.Final'
-    verOshiCore = '6.6.4'
-    verJunit = '5.10.2'
+    verAsm = '9.7.1'
+    verNetty = '4.2.0.RC3'
+    verOshiCore = '6.6.6'
+    verJunit = '5.11.4'
     verJansi = '2.4.1'
-    verJline = '3.26.3'
-    verJwt = '0.12.5'
-    verGson = '2.11.0'
-    verBcpkix = '1.78.1'
-    verSlf4j = '2.0.13'
-    verLog4j = '2.23.1'
-    verMySQLConn = '9.0.0'
-    verMariaDBConn = '3.4.0'
-    verPostgreSQLConn = '42.7.4'
+    verJline = '3.29.0'
+    verJwt = '0.12.6'
+    verGson = '2.12.1'
+    verBcpkix = '1.80'
+    verSlf4j = '2.0.16'
+    verLog4j = '2.24.3'
+    verMySQLConn = '9.2.0'
+    verMariaDBConn = '3.5.1'
+    verPostgreSQLConn = '42.7.5'
     verH2Conn = '2.3.232'
-    verProguard = '7.5.0'
+    verProguard = '7.6.1'
 }