feat: push
This commit is contained in:
23
velocity/.classpath
Normal file
23
velocity/.classpath
Normal file
@@ -0,0 +1,23 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<classpath>
|
||||
<classpathentry kind="src" output="bin/main" path="src/main/java">
|
||||
<attributes>
|
||||
<attribute name="gradle_scope" value="main"/>
|
||||
<attribute name="gradle_used_by_scope" value="main,test"/>
|
||||
</attributes>
|
||||
</classpathentry>
|
||||
<classpathentry kind="src" output="bin/main" path="src/main/resources">
|
||||
<attributes>
|
||||
<attribute name="gradle_scope" value="main"/>
|
||||
<attribute name="gradle_used_by_scope" value="main,test"/>
|
||||
</attributes>
|
||||
</classpathentry>
|
||||
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-21/"/>
|
||||
<classpathentry kind="con" path="org.eclipse.buildship.core.gradleclasspathcontainer"/>
|
||||
<classpathentry kind="src" path="bin/generated-sources/annotations">
|
||||
<attributes>
|
||||
<attribute name="optional" value="true"/>
|
||||
</attributes>
|
||||
</classpathentry>
|
||||
<classpathentry kind="output" path="bin/default"/>
|
||||
</classpath>
|
||||
40
velocity/.factorypath
Normal file
40
velocity/.factorypath
Normal file
@@ -0,0 +1,40 @@
|
||||
<factorypath>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/org.yaml/snakeyaml/1.33/2cd0a87ff7df953f810c344bdf2fe3340b954c69/snakeyaml-1.33.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/b421526c5f297295adef1c886e5246c39d4ac629/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/org.spongepowered/configurate-gson/4.1.2/3e5c7a0ea73e95ce6139fa72f1b6d36eb531ab81/configurate-gson-4.1.2.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-key/4.25.0/eadeff9eeaa46f76de3f31fdff1d8e952273cf04/adventure-key-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-logger-slf4j/4.25.0/7800e20f422798c0011eadce9bfa6bef159d7ae9/adventure-text-logger-slf4j-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.guava/failureaccess/1.0.1/1dcf1de382a0bf95a3d8b0849546c88bac1292c9/failureaccess-1.0.1.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/io.leangen.geantyref/geantyref/1.3.11/bc9c03b53917314d21fe6276aceb08aa84bf80dd/geantyref-1.3.11.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/org.spongepowered/configurate-core/4.1.2/d6728b04738e73847f6a26349cf4368362feab97/configurate-core-4.1.2.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-serializer-legacy/4.25.0/b12eaaac78d2534b9b1556049a8d95a046b0812d/adventure-text-serializer-legacy-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.guava/guava/31.0.1-jre/119ea2b2bc205b138974d351777b20f02b92704b/guava-31.0.1-jre.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/javax.inject/javax.inject/1/6975da39a7040257bd51d21a231b76c915872d38/javax.inject-1.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.errorprone/error_prone_annotations/2.21.1/6d9b10773b5237df178a7b3c1b4208df7d0e7f94/error_prone_annotations-2.21.1.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-serializer-gson/4.25.0/e312e240fe82f4207ff2232b33ee4433855bdfff/adventure-text-serializer-gson-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-api/4.25.0/6bd10494eeb2f8eadce7226db4445e8728985cbb/adventure-api-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-serializer-commons/4.25.0/58708c96ea4292800f08360ca1ce8a31ef0cdf97/adventure-text-serializer-commons-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.typesafe/config/1.4.1/19058a07624a87f90d129af7cd9c68bee94535a9/config-1.4.1.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-serializer-ansi/4.25.0/bdd2546ac76e725072b26bb22a73afbfc077ba73/adventure-text-serializer-ansi-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/3.0.2/25ea2e8b0c338a877313bd4672d3fe056ea78f0d/jsr305-3.0.2.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/examination-api/1.3.0/8a2d185275307f1e2ef2adf7152b9a0d1d44c30b/examination-api-1.3.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.moandjiezana.toml/toml4j/0.7.2/a03337911d0bd2c40932aca3946edb30d0e7d0c/toml4j-0.7.2.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.code.gson/gson/2.10.1/b3add478d4382b78ea20b1671390a858002feb6c/gson-2.10.1.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.inject/guice/6.0.0/9b422c69c4fa1ea95b2615444a94fede9b02fc40/guice-6.0.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-minimessage/4.25.0/38f8f778c92f1ea848f79f992c99c4b98f96f23b/adventure-text-minimessage-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/option/1.1.0/593fecb9c42688eebc7d8da5d6ea127f4d4c92a2/option-1.1.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/aopalliance/aopalliance/1.0/235ba8b489512805ac13a8f9ea77a1ca5ebe3e8/aopalliance-1.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/2.0.17/d9e58ac9c7779ba3bf8142aff6c830617a7fe60f/slf4j-api-2.0.17.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/org.spongepowered/configurate-hocon/4.1.2/3953a4aef8ff62c72d34e405d6df333f3876592a/configurate-hocon-4.1.2.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.velocitypowered/velocity-api/3.4.0-SNAPSHOT/623b21e318b5fe8ad20ae62d52e55e34a6fc184/velocity-api-3.4.0-SNAPSHOT.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/ansi/1.1.1/beeb71e49b25cac87c22975014e74c7b5940d1b7/ansi-1.1.1.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-serializer-json/4.25.0/ff6b4381dd8be9a40a1127937a4b71b9b010fcd6/adventure-text-serializer-json-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/examination-string/1.3.0/6f34afef5c54ccce4996bc321abf77518b55b4bd/examination-string-1.3.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/net.kyori/adventure-text-serializer-plain/4.25.0/82f5d4188f3cb6da9654b4ceea8b4093af5f1243/adventure-text-serializer-plain-4.25.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/jakarta.inject/jakarta.inject-api/2.0.1/4c28afe1991a941d7702fe1362c365f0a8641d1e/jakarta.inject-api-2.0.1.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.google.j2objc/j2objc-annotations/1.3/ba035118bc8bac37d7eff77700720999acd9986d/j2objc-annotations-1.3.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/org.checkerframework/checker-qual/3.42.0/638ec33f363a94d41a4f03c3e7d3dcfba64e402d/checker-qual-3.42.0.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/org.spongepowered/configurate-yaml/4.1.2/f726180c21ec387be5b8a2e04d916443c4046207/configurate-yaml-4.1.2.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.github.ben-manes.caffeine/caffeine/3.1.8/24795585df8afaf70a2cd534786904ea5889c047/caffeine-3.1.8.jar" enabled="true" runInBatchMode="false"/>
|
||||
<factorypathentry kind="EXTJAR" id="/Users/mrxzx/.gradle/caches/modules-2/files-2.1/com.velocitypowered/velocity-brigadier/1.0.0-SNAPSHOT/c85456381b9942f529995996793190c091ef57a9/velocity-brigadier-1.0.0-SNAPSHOT.jar" enabled="true" runInBatchMode="false"/>
|
||||
</factorypath>
|
||||
51
velocity/build.gradle.kts
Normal file
51
velocity/build.gradle.kts
Normal file
@@ -0,0 +1,51 @@
|
||||
/*
|
||||
* This file was generated by the Gradle 'init' task.
|
||||
*
|
||||
* This generated file contains a sample Java library project to get you started.
|
||||
* For more details on building Java & JVM projects, please refer to https://docs.gradle.org/9.2.1/userguide/building_java_projects.html in the Gradle documentation.
|
||||
*/
|
||||
|
||||
plugins {
|
||||
`java-library`
|
||||
|
||||
id("com.gradleup.shadow") version "9.3.0"
|
||||
id("xyz.jpenilla.run-velocity") version "3.0.2"
|
||||
}
|
||||
|
||||
repositories {
|
||||
mavenCentral()
|
||||
maven {
|
||||
name = "papermc"
|
||||
url = uri("https://repo.papermc.io/repository/maven-public/")
|
||||
}
|
||||
}
|
||||
|
||||
dependencies {
|
||||
// This dependency is exported to consumers, that is to say found on their compile classpath.
|
||||
api(libs.commons.math3)
|
||||
|
||||
// This dependency is used internally, and not exposed to consumers on their own compile classpath.
|
||||
implementation(libs.guava)
|
||||
|
||||
compileOnly("com.velocitypowered:velocity-api:3.4.0-SNAPSHOT")
|
||||
annotationProcessor("com.velocitypowered:velocity-api:3.4.0-SNAPSHOT")
|
||||
}
|
||||
|
||||
// Apply a specific Java toolchain to ease working on different environments.
|
||||
java {
|
||||
toolchain {
|
||||
languageVersion = JavaLanguageVersion.of(21)
|
||||
}
|
||||
}
|
||||
|
||||
tasks {
|
||||
shadowJar {
|
||||
archiveFileName.set("mineroo-velocity.jar")
|
||||
}
|
||||
runVelocity {
|
||||
// Configure the Velocity version for our task.
|
||||
// This is the only required configuration besides applying the plugin.
|
||||
// Your plugin's jar (or shadowJar if present) will be used automatically.
|
||||
velocityVersion("3.4.0-SNAPSHOT")
|
||||
}
|
||||
}
|
||||
60
velocity/src/main/java/online/mineroo/velocity/Config.java
Normal file
60
velocity/src/main/java/online/mineroo/velocity/Config.java
Normal file
@@ -0,0 +1,60 @@
|
||||
package online.mineroo.velocity;
|
||||
|
||||
import org.spongepowered.configurate.objectmapping.ConfigSerializable;
|
||||
import org.spongepowered.configurate.objectmapping.meta.Comment;
|
||||
import org.spongepowered.configurate.objectmapping.meta.Setting;
|
||||
|
||||
@ConfigSerializable
|
||||
public class Config {
|
||||
|
||||
@Comment("Server Bind Name")
|
||||
private String serverName = "";
|
||||
|
||||
@Comment("Server Bind Description")
|
||||
private String description = "A minecraft server";
|
||||
|
||||
@Setting("bind")
|
||||
private ServerSection server = new ServerSection();
|
||||
|
||||
@ConfigSerializable
|
||||
public static class ServerSection {
|
||||
|
||||
@Setting("address")
|
||||
@Comment("Server Address")
|
||||
private String address = "";
|
||||
|
||||
@Setting("port")
|
||||
@Comment("Server Port")
|
||||
private Integer port = null;
|
||||
|
||||
@Setting("token")
|
||||
@Comment("Server Bind Token")
|
||||
private String bindToken = "get token from `mineroo.online/resources/servers` page!";
|
||||
|
||||
public String getAddress() {
|
||||
return address;
|
||||
}
|
||||
|
||||
public Integer getPort() {
|
||||
return port;
|
||||
}
|
||||
|
||||
public String getBindToken() {
|
||||
return bindToken;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public String getServerName() {
|
||||
return serverName;
|
||||
}
|
||||
|
||||
public String getDescription() {
|
||||
return description;
|
||||
}
|
||||
|
||||
public ServerSection getServer() {
|
||||
return server;
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,112 @@
|
||||
package online.mineroo.velocity;
|
||||
|
||||
import com.google.inject.Inject;
|
||||
import com.velocitypowered.api.command.CommandManager;
|
||||
import com.velocitypowered.api.event.Subscribe;
|
||||
import com.velocitypowered.api.event.proxy.ProxyInitializeEvent;
|
||||
import com.velocitypowered.api.plugin.Plugin;
|
||||
import com.velocitypowered.api.plugin.annotation.DataDirectory;
|
||||
import com.velocitypowered.api.proxy.ProxyServer;
|
||||
|
||||
import online.mineroo.velocity.commands.MainCommand;
|
||||
import online.mineroo.velocity.listeners.BindListener;
|
||||
import online.mineroo.velocity.utils.MessageManager;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.spongepowered.configurate.CommentedConfigurationNode;
|
||||
import org.spongepowered.configurate.loader.ConfigurationLoader;
|
||||
import org.spongepowered.configurate.yaml.NodeStyle;
|
||||
import org.spongepowered.configurate.yaml.YamlConfigurationLoader;
|
||||
|
||||
@Plugin(id = "mineroo-velocity", name = "Mineroo Velocity", version = "0.1.0-SNAPSHOT", url = "https://mineroo.online", description = "Mineroo main plugin", authors = {
|
||||
"YuKun Liu" })
|
||||
public class MinerooPlugin {
|
||||
|
||||
private final ProxyServer server;
|
||||
private final Logger logger;
|
||||
|
||||
private final Path dataDirectory;
|
||||
private Config config;
|
||||
|
||||
private BindListener bindListener;
|
||||
|
||||
private MessageManager messageManager;
|
||||
|
||||
@Inject
|
||||
public MinerooPlugin(ProxyServer server, Logger logger, @DataDirectory Path dataDirectory) {
|
||||
this.server = server;
|
||||
this.logger = logger;
|
||||
this.dataDirectory = dataDirectory;
|
||||
}
|
||||
|
||||
@Subscribe
|
||||
public void onProxyInitialization(ProxyInitializeEvent event) {
|
||||
|
||||
this.bindListener = new BindListener();
|
||||
server.getEventManager().register(this, bindListener);
|
||||
|
||||
reloadConfig();
|
||||
|
||||
this.messageManager = new MessageManager(config);
|
||||
|
||||
CommandManager commandManager = server.getCommandManager();
|
||||
commandManager.register(commandManager.metaBuilder("mineroo").build(),
|
||||
new MainCommand(this));
|
||||
}
|
||||
|
||||
// load & create config
|
||||
public boolean reloadConfig() {
|
||||
try {
|
||||
if (Files.notExists(dataDirectory)) {
|
||||
Files.createDirectories(dataDirectory);
|
||||
}
|
||||
|
||||
Path configPath = dataDirectory.resolve("config.yaml");
|
||||
|
||||
ConfigurationLoader<CommentedConfigurationNode> loader = YamlConfigurationLoader.builder()
|
||||
.path(configPath)
|
||||
.nodeStyle(NodeStyle.BLOCK)
|
||||
.build();
|
||||
|
||||
if (Files.notExists(configPath)) {
|
||||
logger.warn("Configuration file not found, creating default config.yaml...");
|
||||
this.config = new Config();
|
||||
CommentedConfigurationNode node = loader.createNode();
|
||||
node.set(Config.class, this.config);
|
||||
loader.save(node);
|
||||
} else {
|
||||
logger.info("Reloading configuration...");
|
||||
CommentedConfigurationNode node = loader.load();
|
||||
this.config = node.get(Config.class);
|
||||
}
|
||||
return true;
|
||||
} catch (IOException e) {
|
||||
logger.error("Failed to reload config!", e);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
public ProxyServer getServer() {
|
||||
return this.server;
|
||||
}
|
||||
|
||||
public Logger getLogger() {
|
||||
return logger;
|
||||
}
|
||||
|
||||
public Config getConfig() {
|
||||
return config;
|
||||
}
|
||||
|
||||
public BindListener getBindListener() {
|
||||
return bindListener;
|
||||
}
|
||||
|
||||
public MessageManager getMessageManager() {
|
||||
return messageManager;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,157 @@
|
||||
package online.mineroo.velocity.commands;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
|
||||
import com.velocitypowered.api.command.CommandSource;
|
||||
import com.velocitypowered.api.command.SimpleCommand;
|
||||
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.format.NamedTextColor;
|
||||
import online.mineroo.velocity.Config;
|
||||
import online.mineroo.velocity.MinerooPlugin;
|
||||
import online.mineroo.velocity.utils.BindRequest;
|
||||
import online.mineroo.velocity.utils.MessageManager;
|
||||
|
||||
public class MainCommand implements SimpleCommand {
|
||||
|
||||
private final MinerooPlugin plugin;
|
||||
|
||||
public MainCommand(MinerooPlugin plugin) {
|
||||
this.plugin = plugin;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void execute(Invocation invocation) {
|
||||
String[] args = invocation.arguments();
|
||||
if (args.length < 1) {
|
||||
sendHelp(invocation.source());
|
||||
return;
|
||||
}
|
||||
|
||||
String subCommand = args[0];
|
||||
|
||||
if (subCommand.equals("bind")) {
|
||||
bindServer(invocation.source());
|
||||
}
|
||||
|
||||
if (subCommand.equalsIgnoreCase("reload")) {
|
||||
reload(invocation.source());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<String> suggest(Invocation invocation) {
|
||||
String[] args = invocation.arguments();
|
||||
|
||||
if (args.length == 0) {
|
||||
return List.of("bind", "reload");
|
||||
}
|
||||
|
||||
if (args.length == 1) {
|
||||
String input = args[0].toLowerCase();
|
||||
return Stream.of("bind", "reload")
|
||||
.filter(cmd -> cmd.startsWith(input))
|
||||
.collect(Collectors.toList());
|
||||
}
|
||||
|
||||
return List.of();
|
||||
}
|
||||
|
||||
public void reload(CommandSource source) {
|
||||
MessageManager msg = plugin.getMessageManager();
|
||||
|
||||
long start = System.currentTimeMillis();
|
||||
boolean success = plugin.reloadConfig();
|
||||
|
||||
if (success) {
|
||||
long time = System.currentTimeMillis() - start;
|
||||
source.sendMessage(msg.get("command.reload.success", "time", String.valueOf(time)));
|
||||
} else {
|
||||
|
||||
source.sendMessage(msg.get("command.reload.failed"));
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
public void bindServer(CommandSource source) {
|
||||
|
||||
Config config = plugin.getConfig();
|
||||
MessageManager msg = plugin.getMessageManager();
|
||||
|
||||
String bind_name = config.getServerName();
|
||||
String bind_description = config.getDescription();
|
||||
|
||||
String bind_token = config.getServer().getBindToken();
|
||||
String bind_address = config.getServer().getAddress();
|
||||
Integer bind_port = config.getServer().getPort();
|
||||
|
||||
source.sendMessage(msg.get("command.bind.server.start"));
|
||||
|
||||
Logger logger = plugin.getLogger();
|
||||
|
||||
plugin.getServer().getScheduler().buildTask(plugin, () -> {
|
||||
|
||||
BindRequest request = new BindRequest(logger, bind_token);
|
||||
|
||||
try {
|
||||
boolean inital_bind = request.initalMotdVerifyRequest(bind_address, bind_port);
|
||||
if (inital_bind) {
|
||||
String motdToken = request.getMotdToken();
|
||||
plugin.getBindListener().setVerificationToken(motdToken);
|
||||
|
||||
source.sendMessage(msg.get("command.bind.server.wait"));
|
||||
|
||||
Thread.sleep(2 * 60 * 1000 + 5000);
|
||||
|
||||
// Final Bind
|
||||
boolean success = false;
|
||||
int maxRetries = 3;
|
||||
|
||||
for (int i = 1; i <= maxRetries; i++) {
|
||||
if (request.finalizeServerBinding(bind_name, bind_description)) {
|
||||
success = true;
|
||||
break;
|
||||
}
|
||||
|
||||
if (i < maxRetries) {
|
||||
|
||||
source.sendMessage(msg.get("command.bind.server.retry",
|
||||
"current", String.valueOf(i),
|
||||
"max", String.valueOf(maxRetries)));
|
||||
Thread.sleep(10000);
|
||||
}
|
||||
}
|
||||
|
||||
if (success) {
|
||||
source.sendMessage(msg.get("command.bind.server.success"));
|
||||
} else {
|
||||
source.sendMessage(msg.get("command.bind.server.failed"));
|
||||
}
|
||||
|
||||
} else {
|
||||
source.sendMessage(
|
||||
Component.text("Initial handshake failed. Check your token or network.", NamedTextColor.RED));
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
logger.error("Mineroo Bind: " + e.toString());
|
||||
} finally {
|
||||
plugin.getBindListener().clearVerificationToken();
|
||||
}
|
||||
|
||||
}).schedule();
|
||||
|
||||
}
|
||||
|
||||
public void sendHelp(CommandSource source) {
|
||||
source.sendMessage(Component.text("=== # @Mineroo # ===", NamedTextColor.AQUA));
|
||||
source.sendMessage(Component.text(" /mineroo bind - Start to bind server", NamedTextColor.YELLOW));
|
||||
source.sendMessage(Component.text(" /mineroo reload - Reload config", NamedTextColor.YELLOW));
|
||||
source.sendMessage(Component.text("=== mineroo.online ===", NamedTextColor.AQUA));
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
package online.mineroo.velocity.listeners;
|
||||
|
||||
import com.velocitypowered.api.event.Subscribe;
|
||||
import com.velocitypowered.api.event.proxy.ProxyPingEvent;
|
||||
import com.velocitypowered.api.proxy.server.ServerPing;
|
||||
import net.kyori.adventure.text.Component;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicReference;
|
||||
|
||||
public class BindListener {
|
||||
|
||||
private final AtomicReference<String> verificationToken = new AtomicReference<>(null);
|
||||
|
||||
public void setVerificationToken(String token) {
|
||||
this.verificationToken.set(token);
|
||||
}
|
||||
|
||||
public void clearVerificationToken() {
|
||||
this.verificationToken.set(null);
|
||||
}
|
||||
|
||||
@Subscribe
|
||||
public void onPing(ProxyPingEvent event) {
|
||||
String token = verificationToken.get();
|
||||
|
||||
if (token == null) {
|
||||
return;
|
||||
}
|
||||
|
||||
ServerPing.Builder builder = event.getPing().asBuilder();
|
||||
|
||||
builder.description(Component.text(token));
|
||||
|
||||
event.setPing(builder.build());
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,22 @@
|
||||
package online.mineroo.velocity.listeners;
|
||||
|
||||
import com.google.common.io.ByteArrayDataInput;
|
||||
import com.velocitypowered.api.event.Subscribe;
|
||||
import com.velocitypowered.api.event.connection.PluginMessageEvent;
|
||||
import com.velocitypowered.api.proxy.ServerConnection;
|
||||
|
||||
public class ChannelListener {
|
||||
@Subscribe
|
||||
public void onPluginMessage(PluginMessageEvent event) {
|
||||
if (!event.getIdentifier().getId().equals("mineroo:api"))
|
||||
return;
|
||||
|
||||
if (!(event.getSource() instanceof ServerConnection))
|
||||
return;
|
||||
|
||||
ByteArrayDataInput in = event.dataAsDataStream();
|
||||
String subChannel = in.readUTF();
|
||||
|
||||
// TODO:
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,112 @@
|
||||
package online.mineroo.velocity.utils;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.net.URI;
|
||||
import java.net.http.HttpClient;
|
||||
import java.net.http.HttpRequest;
|
||||
import java.net.http.HttpResponse;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.util.Base64;
|
||||
|
||||
import org.jetbrains.annotations.Nullable;
|
||||
import org.slf4j.Logger;
|
||||
|
||||
import com.google.gson.JsonObject;
|
||||
import com.google.gson.JsonParseException;
|
||||
import com.google.gson.JsonParser;
|
||||
|
||||
public class BindRequest {
|
||||
|
||||
private static final String endpoint = "https://oapi.mineroo.online";
|
||||
|
||||
private final Logger logger;
|
||||
private final HttpClient httpClient;
|
||||
|
||||
private final String bindToken;
|
||||
|
||||
private String motdToken = "";
|
||||
private String sessionToken = "";
|
||||
|
||||
public BindRequest(Logger logger, String bindToken) {
|
||||
|
||||
this.logger = logger;
|
||||
this.bindToken = bindToken;
|
||||
|
||||
this.httpClient = HttpClient.newHttpClient();
|
||||
}
|
||||
|
||||
public boolean initalMotdVerifyRequest(String hostname, Integer port)
|
||||
throws IOException, InterruptedException, JsonParseException {
|
||||
|
||||
// generate uri
|
||||
String uri = endpoint + "/server/motd-verify";
|
||||
|
||||
// build jsonBody
|
||||
JsonObject json = new JsonObject();
|
||||
json.addProperty("server_address", hostname);
|
||||
json.addProperty("server_port", port);
|
||||
|
||||
String basicAuth = "mbind:" + bindToken;
|
||||
String encodedAuth = Base64.getEncoder().encodeToString(basicAuth.getBytes(StandardCharsets.UTF_8));
|
||||
|
||||
HttpRequest request = HttpRequest.newBuilder().uri(URI.create(uri))
|
||||
.header("Content-Type", "application/json")
|
||||
.header("Authorization", "Basic " + encodedAuth)
|
||||
.POST(HttpRequest.BodyPublishers.ofString(json.toString())).build();
|
||||
|
||||
HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
|
||||
|
||||
if (response.statusCode() == 200) {
|
||||
String body = response.body();
|
||||
JsonObject responseData = JsonParser.parseString(body).getAsJsonObject();
|
||||
|
||||
if (responseData.has("motd_token")) {
|
||||
motdToken = responseData.get("motd_token").getAsString();
|
||||
} else {
|
||||
logger.error("Mineroo Bind: MOTD Token not received.");
|
||||
return false;
|
||||
}
|
||||
|
||||
if (responseData.has("session_token")) {
|
||||
sessionToken = responseData.get("session_token").getAsString();
|
||||
} else {
|
||||
logger.error("Mineroo Bind: Session Token not received.");
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
|
||||
} else {
|
||||
logger.error("Mineroo Bind: " + response.body().toString());
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
public boolean finalizeServerBinding(@Nullable String name, @Nullable String description)
|
||||
throws IOException, InterruptedException, JsonParseException {
|
||||
String uri = endpoint + "/server/server-bind";
|
||||
|
||||
JsonObject json = new JsonObject();
|
||||
json.addProperty("session_token", sessionToken);
|
||||
json.addProperty("name", name);
|
||||
json.addProperty("description", description);
|
||||
|
||||
String basicAuth = "mbind:" + bindToken;
|
||||
String encodedAuth = Base64.getEncoder().encodeToString(basicAuth.getBytes(StandardCharsets.UTF_8));
|
||||
|
||||
HttpRequest request = HttpRequest.newBuilder().uri(URI.create(uri))
|
||||
.header("Content-Type", "application/json")
|
||||
.header("Authorization", "Basic " + encodedAuth)
|
||||
.POST(HttpRequest.BodyPublishers.ofString(json.toString())).build();
|
||||
|
||||
HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
|
||||
|
||||
return response.statusCode() == 200;
|
||||
|
||||
}
|
||||
|
||||
public String getMotdToken() {
|
||||
return motdToken;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,67 @@
|
||||
package online.mineroo.velocity.utils;
|
||||
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.minimessage.MiniMessage;
|
||||
import net.kyori.adventure.text.minimessage.tag.resolver.Placeholder;
|
||||
import net.kyori.adventure.text.minimessage.tag.resolver.TagResolver;
|
||||
import online.mineroo.velocity.Config;
|
||||
|
||||
import java.util.Locale;
|
||||
import java.util.ResourceBundle;
|
||||
|
||||
public class MessageManager {
|
||||
|
||||
private final Config config;
|
||||
private ResourceBundle bundle;
|
||||
private final MiniMessage miniMessage;
|
||||
|
||||
public MessageManager(Config config) {
|
||||
this.config = config;
|
||||
this.miniMessage = MiniMessage.miniMessage();
|
||||
reload();
|
||||
}
|
||||
|
||||
public void reload() {
|
||||
String lang = "zh-CN";
|
||||
|
||||
Locale locale;
|
||||
if (lang.contains("-")) {
|
||||
String[] parts = lang.split("-");
|
||||
locale = Locale.of(parts[0], parts[1]);
|
||||
} else {
|
||||
locale = Locale.of(lang);
|
||||
}
|
||||
|
||||
try {
|
||||
this.bundle = ResourceBundle.getBundle("mineroo.messages", locale);
|
||||
} catch (Exception e) {
|
||||
this.bundle = ResourceBundle.getBundle("mineroo.messages", Locale.ROOT);
|
||||
}
|
||||
}
|
||||
|
||||
public Component get(String key) {
|
||||
String raw = getString(key);
|
||||
return miniMessage.deserialize(raw);
|
||||
}
|
||||
|
||||
public Component get(String key, String... placeholders) {
|
||||
String raw = getString(key);
|
||||
|
||||
TagResolver.Builder builder = TagResolver.builder();
|
||||
for (int i = 0; i < placeholders.length; i += 2) {
|
||||
if (i + 1 < placeholders.length) {
|
||||
builder.resolver(Placeholder.parsed(placeholders[i], placeholders[i + 1]));
|
||||
}
|
||||
}
|
||||
|
||||
return miniMessage.deserialize(raw, builder.build());
|
||||
}
|
||||
|
||||
private String getString(String key) {
|
||||
try {
|
||||
return bundle.getString(key);
|
||||
} catch (Exception e) {
|
||||
return "<red>Missing key: " + key;
|
||||
}
|
||||
}
|
||||
}
|
||||
11
velocity/src/main/resources/mineroo/messages.properties
Normal file
11
velocity/src/main/resources/mineroo/messages.properties
Normal file
@@ -0,0 +1,11 @@
|
||||
# Command Bind
|
||||
command.bind.server.start=<gray>开始服务器绑定流程，请稍等...</gray>
|
||||
command.bind.server.inital.failed=<red>初次握手失败。检查您的令牌或网络。</red>
|
||||
command.bind.server.wait=<aqua>正在验证服务器所有权... 数据同步可能需要 2 分钟，请稍候。</aqua>
|
||||
command.bind.server.success=<green>绑定成功！<green>
|
||||
command.bind.server.failed=<red>绑定失败。</red>
|
||||
command.bind.server.retry=<yellow>验证未通过，10 秒后重试 (<current>/<max>) ...</yellow>
|
||||
|
||||
# Command Reload
|
||||
command.reload.success=<green>配置文件重载成功！耗时 <time>ms</green>
|
||||
command.reload.failed=<red>配置文件重载失败，请查看控制台日志。</red>
|
||||
Reference in New Issue
Block a user