Terracotta | 陶瓦联机

.github/workflows/check-codes.yml

@@ -22,4 +22,4 @@ jobs:
           java-version: '17'
           java-package: 'jdk+fx'
       - name: Check Codes
-        run: ./gradlew checkstyle checkTranslations --no-daemon --parallel
+        run: ./gradlew checkstyle checkTranslations --no-daemon --parallel --stacktrace

HMCL/build.gradle.kts

@@ -121,8 +121,25 @@ tasks.compileJava {
     options.compilerArgs.add("--add-exports=java.base/jdk.internal.loader=ALL-UNNAMED")
 }
 
+val addOpens = listOf(
+    "java.base/java.lang",
+    "java.base/java.lang.reflect",
+    "java.base/jdk.internal.loader",
+    "javafx.base/com.sun.javafx.binding",
+    "javafx.base/com.sun.javafx.event",
+    "javafx.base/com.sun.javafx.runtime",
+    "javafx.graphics/javafx.css",
+    "javafx.graphics/com.sun.javafx.stage",
+    "javafx.graphics/com.sun.prism",
+    "javafx.controls/com.sun.javafx.scene.control",
+    "javafx.controls/com.sun.javafx.scene.control.behavior",
+    "javafx.controls/javafx.scene.control.skin",
+    "jdk.attach/sun.tools.attach",
+)
+
 val hmclProperties = buildList {
     add("hmcl.version" to project.version.toString())
+    add("hmcl.add-opens" to addOpens.joinToString(" "))
     System.getenv("GITHUB_SHA")?.let {
         add("hmcl.version.hash" to it)
     }
@@ -149,22 +166,6 @@ val createPropertiesFile by tasks.registering {
     }
 }
 
-val addOpens = listOf(
-    "java.base/java.lang",
-    "java.base/java.lang.reflect",
-    "java.base/jdk.internal.loader",
-    "javafx.base/com.sun.javafx.binding",
-    "javafx.base/com.sun.javafx.event",
-    "javafx.base/com.sun.javafx.runtime",
-    "javafx.graphics/javafx.css",
-    "javafx.graphics/com.sun.javafx.stage",
-    "javafx.graphics/com.sun.prism",
-    "javafx.controls/com.sun.javafx.scene.control",
-    "javafx.controls/com.sun.javafx.scene.control.behavior",
-    "javafx.controls/javafx.scene.control.skin",
-    "jdk.attach/sun.tools.attach",
-)
-
 tasks.jar {
     enabled = false
     dependsOn(tasks["shadowJar"])

HMCL/src/main/java/org/jackhuang/hmcl/game/LauncherHelper.java

@@ -915,7 +915,15 @@ public void onExit(int exitCode, ExitType exitType) {
 
     }
 
-    public static final Queue<WeakReference<ManagedProcess>> PROCESSES = new ConcurrentLinkedQueue<>();
+    private static final Queue<WeakReference<ManagedProcess>> PROCESSES = new ConcurrentLinkedQueue<>();
+
+    public static int countMangedProcesses() {
+        PROCESSES.removeIf(it -> {
+            ManagedProcess process = it.get();
+            return process == null || !process.isRunning();
+        });
+        return PROCESSES.size();
+    }
 
     public static void stopManagedProcesses() {
         while (!PROCESSES.isEmpty())

HMCL/src/main/java/org/jackhuang/hmcl/terracotta/TerracottaManager.java

@@ -0,0 +1,325 @@
+/*
+ * Hello Minecraft! Launcher
+ * Copyright (C) 2025  huangyuhui <huanghongxun2008@126.com> and contributors
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+package org.jackhuang.hmcl.terracotta;
+
+import com.google.gson.JsonObject;
+import com.google.gson.reflect.TypeToken;
+import javafx.application.Platform;
+import javafx.beans.property.ReadOnlyDoubleWrapper;
+import javafx.beans.property.ReadOnlyObjectProperty;
+import javafx.beans.property.ReadOnlyObjectWrapper;
+import org.jackhuang.hmcl.auth.Account;
+import org.jackhuang.hmcl.setting.Accounts;
+import org.jackhuang.hmcl.task.DownloadException;
+import org.jackhuang.hmcl.task.GetTask;
+import org.jackhuang.hmcl.task.Schedulers;
+import org.jackhuang.hmcl.task.Task;
+import org.jackhuang.hmcl.terracotta.provider.ITerracottaProvider;
+import org.jackhuang.hmcl.ui.FXUtils;
+import org.jackhuang.hmcl.util.InvocationDispatcher;
+import org.jackhuang.hmcl.util.Lang;
+import org.jackhuang.hmcl.util.gson.JsonUtils;
+import org.jackhuang.hmcl.util.io.FileUtils;
+import org.jackhuang.hmcl.util.io.NetworkUtils;
+import org.jackhuang.hmcl.util.platform.ManagedProcess;
+import org.jackhuang.hmcl.util.platform.SystemUtils;
+import org.jackhuang.hmcl.util.tree.TarFileTree;
+import org.jetbrains.annotations.Nullable;
+
+import java.io.IOException;
+import java.net.URI;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.concurrent.ThreadLocalRandom;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.concurrent.locks.LockSupport;
+
+import static org.jackhuang.hmcl.util.i18n.I18n.i18n;
+import static org.jackhuang.hmcl.util.logging.Logger.LOG;
+
+public final class TerracottaManager {
+    private TerracottaManager() {
+    }
+
+    private static final AtomicReference<TerracottaState> STATE_V = new AtomicReference<>(TerracottaState.Bootstrap.INSTANCE);
+    private static final ReadOnlyObjectWrapper<TerracottaState> STATE = new ReadOnlyObjectWrapper<>(STATE_V.getPlain());
+    private static final InvocationDispatcher<TerracottaState> STATE_D = InvocationDispatcher.runOn(Platform::runLater, STATE::set);
+
+    static {
+        Task.runAsync(() -> {
+            if (TerracottaMetadata.PROVIDER == null) {
+                setState(new TerracottaState.Fatal(TerracottaState.Fatal.Type.OS));
+                LOG.warning("Terracotta hasn't support your OS: " + org.jackhuang.hmcl.util.platform.Platform.SYSTEM_PLATFORM);
+            } else {
+                switch (TerracottaMetadata.PROVIDER.status()) {
+                    case NOT_EXIST -> setState(new TerracottaState.Uninitialized(false));
+                    case LEGACY_VERSION -> setState(new TerracottaState.Uninitialized(true));
+                    case READY -> launch(setState(new TerracottaState.Launching()));
+                }
+            }
+        }).whenComplete(exception -> {
+            if (exception != null) {
+                compareAndSet(TerracottaState.Bootstrap.INSTANCE, new TerracottaState.Fatal(TerracottaState.Fatal.Type.UNKNOWN));
+            }
+        }).start();
+    }
+
+    public static ReadOnlyObjectProperty<TerracottaState> stateProperty() {
+        return STATE.getReadOnlyProperty();
+    }
+
+    static {
+        Lang.thread(() -> {
+            while (true) {
+                TerracottaState state = STATE_V.get();
+                if (!(state instanceof TerracottaState.PortSpecific portSpecific)) {
+                    LockSupport.parkNanos(500_000);
+                    continue;
+                }
+
+                int port = portSpecific.port;
+                int index = state instanceof TerracottaState.Ready ready ? ready.index : Integer.MIN_VALUE;
+
+                TerracottaState next;
+                try {
+                    next = new GetTask(URI.create(String.format("http://127.0.0.1:%d/state", port)))
+                            .setSignificance(Task.TaskSignificance.MINOR)
+                            .thenApplyAsync(jsonString -> {
+                                TerracottaState.Ready object = JsonUtils.fromNonNullJson(jsonString, TypeToken.get(TerracottaState.Ready.class));
+                                if (object.index <= index) {
+                                    return null;
+                                }
+
+                                object.port = port;
+                                return object;
+                            })
+                            .setSignificance(Task.TaskSignificance.MINOR)
+                            .run();
+                } catch (Exception e) {
+                    LOG.warning("Cannot fetch state from Terracotta.", e);
+                    next = new TerracottaState.Fatal(TerracottaState.Fatal.Type.TERRACOTTA);
+                }
+
+                if (next != null) {
+                    compareAndSet(state, next);
+                }
+
+                LockSupport.parkNanos(500_000);
+            }
+        }, "Terracotta Background Daemon", true);
+    }
+
+    public static boolean validate(Path file) {
+        return FileUtils.getName(file).equalsIgnoreCase(TerracottaMetadata.PACKAGE_NAME);
+    }
+
+    public static TerracottaState.Preparing install(@Nullable Path file) {
+        FXUtils.checkFxUserThread();
+
+        TerracottaState state = STATE_V.get();
+        if (!(state instanceof TerracottaState.Uninitialized ||
+                state instanceof TerracottaState.Preparing preparing && preparing.hasInstallFence() ||
+                state instanceof TerracottaState.Fatal && ((TerracottaState.Fatal) state).isRecoverable())
+        ) {
+            return null;
+        }
+
+        if (file != null && !FileUtils.getName(file).equalsIgnoreCase(TerracottaMetadata.PACKAGE_NAME)) {
+            return null;
+        }
+
+        TerracottaState.Preparing preparing;
+        if (state instanceof TerracottaState.Preparing it) {
+            preparing = it;
+        } else {
+            preparing = new TerracottaState.Preparing(new ReadOnlyDoubleWrapper(-1));
+        }
+
+        Task.supplyAsync(Schedulers.io(), () -> {
+            return file != null ? TarFileTree.open(file) : null;
+        }).thenComposeAsync(Schedulers.javafx(), tree -> {
+            return getProvider().install(preparing, tree).whenComplete(exception -> {
+                if (tree != null) {
+                    tree.close();
+                }
+                if (exception != null) {
+                    throw exception;
+                }
+            });
+        }).whenComplete(exception -> {
+            if (exception == null) {
+                try {
+                    TerracottaMetadata.removeLegacyVersionFiles();
+                } catch (IOException e) {
+                    LOG.warning("Unable to remove legacy terracotta files.", e);
+                }
+
+                TerracottaState.Launching launching = new TerracottaState.Launching();
+                if (compareAndSet(preparing, launching)) {
+                    launch(launching);
+                }
+            } else if (exception instanceof ITerracottaProvider.ArchiveFileMissingException) {
+                LOG.warning("Cannot install terracotta from local package.", exception);
+                compareAndSet(preparing, new TerracottaState.Fatal(TerracottaState.Fatal.Type.INSTALL));
+            } else if (exception instanceof DownloadException) {
+                compareAndSet(preparing, new TerracottaState.Fatal(TerracottaState.Fatal.Type.NETWORK));
+            } else {
+                compareAndSet(preparing, new TerracottaState.Fatal(TerracottaState.Fatal.Type.INSTALL));
+            }
+        }).start();
+
+        return setState(preparing);
+    }
+
+    private static ITerracottaProvider getProvider() {
+        ITerracottaProvider provider = TerracottaMetadata.PROVIDER;
+        if (provider == null) {
+            throw new AssertionError("Terracotta Provider must NOT be null.");
+        }
+        return provider;
+    }
+
+    public static TerracottaState recover(@Nullable Path file) {
+        FXUtils.checkFxUserThread();
+
+        TerracottaState state = STATE_V.get();
+        if (!(state instanceof TerracottaState.Fatal && ((TerracottaState.Fatal) state).isRecoverable())) {
+            return null;
+        }
+
+        try {
+            return switch (getProvider().status()) {
+                case NOT_EXIST, LEGACY_VERSION -> install(file);
+                case READY -> {
+                    TerracottaState.Launching launching = setState(new TerracottaState.Launching());
+                    launch(launching);
+                    yield launching;
+                }
+            };
+        } catch (NullPointerException | IOException e) {
+            LOG.warning("Cannot determine Terracotta state.", e);
+            return setState(new TerracottaState.Fatal(TerracottaState.Fatal.Type.UNKNOWN));
+        }
+    }
+
+    private static void launch(TerracottaState.Launching state) {
+        Task.supplyAsync(() -> {
+            Path path = Files.createTempDirectory(String.format("hmcl-terracotta-%d", ThreadLocalRandom.current().nextLong())).resolve("http").toAbsolutePath();
+            ManagedProcess process = new ManagedProcess(new ProcessBuilder(getProvider().ofCommandLine(path)));
+            process.pumpInputStream(SystemUtils::onLogLine);
+            process.pumpErrorStream(SystemUtils::onLogLine);
+
+            long exitTime = -1;
+            while (true) {
+                if (Files.exists(path)) {
+                    JsonObject object = JsonUtils.fromNonNullJson(Files.readString(path), JsonObject.class);
+                    return object.get("port").getAsInt();
+                }
+
+                if (!process.isRunning()) {
+                    if (exitTime == -1) {
+                        exitTime = System.currentTimeMillis();
+                    } else if (System.currentTimeMillis() - exitTime >= 10000) {
+                        throw new IllegalStateException("Process has exited for 10s.");
+                    }
+                }
+            }
+        }).whenComplete(Schedulers.javafx(), (port, exception) -> {
+            TerracottaState next;
+            if (exception == null) {
+                next = new TerracottaState.Unknown(port);
+            } else {
+                next = new TerracottaState.Fatal(TerracottaState.Fatal.Type.TERRACOTTA);
+            }
+            compareAndSet(state, next);
+        }).start();
+    }
+
+    public static Task<String> exportLogs() {
+        if (STATE_V.get() instanceof TerracottaState.PortSpecific portSpecific) {
+            return new GetTask(URI.create(String.format("http://127.0.0.1:%d/log?fetch=true", portSpecific.port)))
+                    .setSignificance(Task.TaskSignificance.MINOR);
+        }
+        return Task.completed(null);
+    }
+
+    public static TerracottaState.Waiting setWaiting() {
+        TerracottaState state = STATE_V.get();
+        if (state instanceof TerracottaState.PortSpecific portSpecific) {
+            new GetTask(URI.create(String.format("http://127.0.0.1:%d/state/ide", portSpecific.port)))
+                    .setSignificance(Task.TaskSignificance.MINOR)
+                    .start();
+            return new TerracottaState.Waiting(-1, -1, null);
+        }
+        return null;
+    }
+
+    private static String getPlayerName() {
+        Account account = Accounts.getSelectedAccount();
+        return account != null ? account.getCharacter() : i18n("terracotta.player_anonymous");
+    }
+
+    public static TerracottaState.HostScanning setScanning() {
+        TerracottaState state = STATE_V.get();
+        if (state instanceof TerracottaState.PortSpecific portSpecific) {
+            new GetTask(NetworkUtils.toURI(String.format(
+                    "http://127.0.0.1:%d/state/scanning?player=%s", portSpecific.port, getPlayerName()))
+            ).setSignificance(Task.TaskSignificance.MINOR).start();
+
+            return new TerracottaState.HostScanning(-1, -1, null);
+        }
+        return null;
+    }
+
+    public static Task<TerracottaState.GuestStarting> setGuesting(String room) {
+        TerracottaState state = STATE_V.get();
+        if (state instanceof TerracottaState.PortSpecific portSpecific) {
+            return new GetTask(NetworkUtils.toURI(String.format(
+                    "http://127.0.0.1:%d/state/guesting?room=%s&player=%s", portSpecific.port, room, getPlayerName()
+            )))
+                    .setSignificance(Task.TaskSignificance.MINOR)
+                    .thenSupplyAsync(() -> new TerracottaState.GuestStarting(-1, -1, null))
+                    .setSignificance(Task.TaskSignificance.MINOR);
+        } else {
+            return null;
+        }
+    }
+
+    private static <T extends TerracottaState> T setState(T value) {
+        if (value == null) {
+            throw new AssertionError();
+        }
+
+        STATE_V.set(value);
+        STATE_D.accept(value);
+        return value;
+    }
+
+    private static boolean compareAndSet(TerracottaState previous, TerracottaState next) {
+        if (next == null) {
+            throw new AssertionError();
+        }
+
+        if (STATE_V.compareAndSet(previous, next)) {
+            STATE_D.accept(next);
+            return true;
+        } else {
+            return false;
+        }
+    }
+}