servers : score.values()) {
+ while (!servers.isEmpty()) {
+ RegisteredServer next = servers.get(random.nextInt(servers.size()));
+ map.put(next.getServerInfo().getName(), next);
+ servers.remove(next);
+ }
+ }
+ return map;
+ }
+
+ /**
+ * Add a Fallback Server Inspector
+ *
+ * @param inspector Inspector
+ */
+ public static void addInspector(FallbackInspector inspector) {
+ if (Util.isNull(inspector)) throw new NullPointerException();
+ inspectors.add(inspector);
+ }
+
+ /**
+ * Remove a Fallback Server Inspector
+ *
+ * @param inspector Inspector
+ */
+ public static void removeInspector(FallbackInspector inspector) {
+ if (Util.isNull(inspector)) throw new NullPointerException();
+ Util.isException(() -> inspectors.remove(inspector));
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Library/Metrics.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Library/Metrics.java
new file mode 100644
index 00000000..0516849e
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Library/Metrics.java
@@ -0,0 +1,1026 @@
+package net.ME1312.SubServers.Velocity.Library;
+
+import com.google.inject.Inject;
+import com.velocitypowered.api.plugin.PluginContainer;
+import com.velocitypowered.api.plugin.PluginDescription;
+import com.velocitypowered.api.plugin.annotation.DataDirectory;
+import com.velocitypowered.api.proxy.ProxyServer;
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.ByteArrayOutputStream;
+import java.io.DataOutputStream;
+import java.io.File;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.URL;
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Path;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.Set;
+import java.util.UUID;
+import java.util.concurrent.Callable;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+import java.util.function.BiConsumer;
+import java.util.function.Consumer;
+import java.util.function.Supplier;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+import java.util.zip.GZIPOutputStream;
+import javax.net.ssl.HttpsURLConnection;
+import org.slf4j.Logger;
+
+public class Metrics {
+
+ /** A factory to create new Metrics classes. */
+ public static class Factory {
+
+ private final ProxyServer server;
+
+ private final Logger logger;
+
+ private final Path dataDirectory;
+
+ // The constructor is not meant to be called by the user.
+ // The instance is created using Dependency Injection
+ @Inject
+ private Factory(ProxyServer server, Logger logger, @DataDirectory Path dataDirectory) {
+ this.server = server;
+ this.logger = logger;
+ this.dataDirectory = dataDirectory;
+ }
+
+ /**
+ * Creates a new Metrics class.
+ *
+ * @param plugin The plugin instance.
+ * @param serviceId The id of the service. It can be found at What is my plugin id?
+ * Not to be confused with Velocity's {@link PluginDescription#getId()} method!
+ * @return A Metrics instance that can be used to register custom charts.
+ *
The return value can be ignored, when you do not want to register custom charts.
+ */
+ public Metrics make(Object plugin, int serviceId) {
+ return new Metrics(plugin, server, logger, dataDirectory, serviceId);
+ }
+ }
+
+ private final PluginContainer pluginContainer;
+
+ private final ProxyServer server;
+
+ private MetricsBase metricsBase;
+
+ private Metrics(
+ Object plugin, ProxyServer server, Logger logger, Path dataDirectory, int serviceId) {
+ pluginContainer =
+ server
+ .getPluginManager()
+ .fromInstance(plugin)
+ .orElseThrow(
+ () -> new IllegalArgumentException("The provided instance is not a plugin"));
+ this.server = server;
+ File configFile = dataDirectory.getParent().resolve("bStats").resolve("config.txt").toFile();
+ MetricsConfig config;
+ try {
+ config = new MetricsConfig(configFile, true);
+ } catch (IOException e) {
+ logger.error("Failed to create bStats config", e);
+ return;
+ }
+ metricsBase =
+ new MetricsBase(
+ "velocity",
+ config.getServerUUID(),
+ serviceId,
+ config.isEnabled(),
+ this::appendPlatformData,
+ this::appendServiceData,
+ task -> server.getScheduler().buildTask(plugin, task).schedule(),
+ () -> true,
+ logger::warn,
+ logger::info,
+ config.isLogErrorsEnabled(),
+ config.isLogSentDataEnabled(),
+ config.isLogResponseStatusTextEnabled());
+ if (!config.didExistBefore()) {
+ // Send an info message when the bStats config file gets created for the first time
+ logger.info(
+ "Velocity and some of its plugins collect metrics and send them to bStats (https://bStats.org).");
+ logger.info(
+ "bStats collects some basic information for plugin authors, like how many people use");
+ logger.info(
+ "their plugin and their total player count. It's recommend to keep bStats enabled, but");
+ logger.info(
+ "if you're not comfortable with this, you can opt-out by editing the config.txt file in");
+ logger.info("the '/plugins/bStats/' folder and setting enabled to false.");
+ }
+ }
+
+ /**
+ * Adds a custom chart.
+ *
+ * @param chart The chart to add.
+ */
+ public void addCustomChart(CustomChart chart) {
+ if (metricsBase != null) {
+ metricsBase.addCustomChart(chart);
+ }
+ }
+
+ private void appendPlatformData(JsonObjectBuilder builder) {
+ builder.appendField("playerAmount", server.getPlayerCount());
+ builder.appendField("managedServers", server.getAllServers().size());
+ builder.appendField("onlineMode", server.getConfiguration().isOnlineMode() ? 1 : 0);
+ builder.appendField("velocityVersionVersion", server.getVersion().getVersion());
+ builder.appendField("velocityVersionName", server.getVersion().getName());
+ builder.appendField("velocityVersionVendor", server.getVersion().getVendor());
+ builder.appendField("javaVersion", System.getProperty("java.version"));
+ builder.appendField("osName", System.getProperty("os.name"));
+ builder.appendField("osArch", System.getProperty("os.arch"));
+ builder.appendField("osVersion", System.getProperty("os.version"));
+ builder.appendField("coreCount", Runtime.getRuntime().availableProcessors());
+ }
+
+ private void appendServiceData(JsonObjectBuilder builder) {
+ builder.appendField(
+ "pluginVersion", pluginContainer.getDescription().getVersion().orElse("unknown"));
+ }
+
+ public static class MetricsBase {
+
+ /** The version of the Metrics class. */
+ public static final String METRICS_VERSION = "2.2.1";
+
+ private static final ScheduledExecutorService scheduler =
+ Executors.newScheduledThreadPool(1, task -> new Thread(task, "bStats-Metrics"));
+
+ private static final String REPORT_URL = "https://bStats.org/api/v2/data/%s";
+
+ private final String platform;
+
+ private final String serverUuid;
+
+ private final int serviceId;
+
+ private final Consumer appendPlatformDataConsumer;
+
+ private final Consumer appendServiceDataConsumer;
+
+ private final Consumer submitTaskConsumer;
+
+ private final Supplier checkServiceEnabledSupplier;
+
+ private final BiConsumer errorLogger;
+
+ private final Consumer infoLogger;
+
+ private final boolean logErrors;
+
+ private final boolean logSentData;
+
+ private final boolean logResponseStatusText;
+
+ private final Set customCharts = new HashSet<>();
+
+ private final boolean enabled;
+
+ /**
+ * Creates a new MetricsBase class instance.
+ *
+ * @param platform The platform of the service.
+ * @param serviceId The id of the service.
+ * @param serverUuid The server uuid.
+ * @param enabled Whether or not data sending is enabled.
+ * @param appendPlatformDataConsumer A consumer that receives a {@code JsonObjectBuilder} and
+ * appends all platform-specific data.
+ * @param appendServiceDataConsumer A consumer that receives a {@code JsonObjectBuilder} and
+ * appends all service-specific data.
+ * @param submitTaskConsumer A consumer that takes a runnable with the submit task. This can be
+ * used to delegate the data collection to a another thread to prevent errors caused by
+ * concurrency. Can be {@code null}.
+ * @param checkServiceEnabledSupplier A supplier to check if the service is still enabled.
+ * @param errorLogger A consumer that accepts log message and an error.
+ * @param infoLogger A consumer that accepts info log messages.
+ * @param logErrors Whether or not errors should be logged.
+ * @param logSentData Whether or not the sent data should be logged.
+ * @param logResponseStatusText Whether or not the response status text should be logged.
+ */
+ public MetricsBase(
+ String platform,
+ String serverUuid,
+ int serviceId,
+ boolean enabled,
+ Consumer appendPlatformDataConsumer,
+ Consumer appendServiceDataConsumer,
+ Consumer submitTaskConsumer,
+ Supplier checkServiceEnabledSupplier,
+ BiConsumer errorLogger,
+ Consumer infoLogger,
+ boolean logErrors,
+ boolean logSentData,
+ boolean logResponseStatusText) {
+ this.platform = platform;
+ this.serverUuid = serverUuid;
+ this.serviceId = serviceId;
+ this.enabled = enabled;
+ this.appendPlatformDataConsumer = appendPlatformDataConsumer;
+ this.appendServiceDataConsumer = appendServiceDataConsumer;
+ this.submitTaskConsumer = submitTaskConsumer;
+ this.checkServiceEnabledSupplier = checkServiceEnabledSupplier;
+ this.errorLogger = errorLogger;
+ this.infoLogger = infoLogger;
+ this.logErrors = logErrors;
+ this.logSentData = logSentData;
+ this.logResponseStatusText = logResponseStatusText;
+ checkRelocation();
+ if (enabled) {
+ startSubmitting();
+ }
+ }
+
+ public void addCustomChart(CustomChart chart) {
+ this.customCharts.add(chart);
+ }
+
+ private void startSubmitting() {
+ final Runnable submitTask =
+ () -> {
+ if (!enabled || !checkServiceEnabledSupplier.get()) {
+ // Submitting data or service is disabled
+ scheduler.shutdown();
+ return;
+ }
+ if (submitTaskConsumer != null) {
+ submitTaskConsumer.accept(this::submitData);
+ } else {
+ this.submitData();
+ }
+ };
+ // Many servers tend to restart at a fixed time at xx:00 which causes an uneven distribution
+ // of requests on the
+ // bStats backend. To circumvent this problem, we introduce some randomness into the initial
+ // and second delay.
+ // WARNING: You must not modify and part of this Metrics class, including the submit delay or
+ // frequency!
+ // WARNING: Modifying this code will get your plugin banned on bStats. Just don't do it!
+ long initialDelay = (long) (1000 * 60 * (3 + Math.random() * 3));
+ long secondDelay = (long) (1000 * 60 * (Math.random() * 30));
+ scheduler.schedule(submitTask, initialDelay, TimeUnit.MILLISECONDS);
+ scheduler.scheduleAtFixedRate(
+ submitTask, initialDelay + secondDelay, 1000 * 60 * 30, TimeUnit.MILLISECONDS);
+ }
+
+ private void submitData() {
+ final JsonObjectBuilder baseJsonBuilder = new JsonObjectBuilder();
+ appendPlatformDataConsumer.accept(baseJsonBuilder);
+ final JsonObjectBuilder serviceJsonBuilder = new JsonObjectBuilder();
+ appendServiceDataConsumer.accept(serviceJsonBuilder);
+ JsonObjectBuilder.JsonObject[] chartData =
+ customCharts.stream()
+ .map(customChart -> customChart.getRequestJsonObject(errorLogger, logErrors))
+ .filter(Objects::nonNull)
+ .toArray(JsonObjectBuilder.JsonObject[]::new);
+ serviceJsonBuilder.appendField("id", serviceId);
+ serviceJsonBuilder.appendField("customCharts", chartData);
+ baseJsonBuilder.appendField("service", serviceJsonBuilder.build());
+ baseJsonBuilder.appendField("serverUUID", serverUuid);
+ baseJsonBuilder.appendField("metricsVersion", METRICS_VERSION);
+ JsonObjectBuilder.JsonObject data = baseJsonBuilder.build();
+ scheduler.execute(
+ () -> {
+ try {
+ // Send the data
+ sendData(data);
+ } catch (Exception e) {
+ // Something went wrong! :(
+ if (logErrors) {
+ errorLogger.accept("Could not submit bStats metrics data", e);
+ }
+ }
+ });
+ }
+
+ private void sendData(JsonObjectBuilder.JsonObject data) throws Exception {
+ if (logSentData) {
+ infoLogger.accept("Sent bStats metrics data: " + data.toString());
+ }
+ String url = String.format(REPORT_URL, platform);
+ HttpsURLConnection connection = (HttpsURLConnection) new URL(url).openConnection();
+ // Compress the data to save bandwidth
+ byte[] compressedData = compress(data.toString());
+ connection.setRequestMethod("POST");
+ connection.addRequestProperty("Accept", "application/json");
+ connection.addRequestProperty("Connection", "close");
+ connection.addRequestProperty("Content-Encoding", "gzip");
+ connection.addRequestProperty("Content-Length", String.valueOf(compressedData.length));
+ connection.setRequestProperty("Content-Type", "application/json");
+ connection.setRequestProperty("User-Agent", "Metrics-Service/1");
+ connection.setDoOutput(true);
+ try (DataOutputStream outputStream = new DataOutputStream(connection.getOutputStream())) {
+ outputStream.write(compressedData);
+ }
+ StringBuilder builder = new StringBuilder();
+ try (BufferedReader bufferedReader =
+ new BufferedReader(new InputStreamReader(connection.getInputStream()))) {
+ String line;
+ while ((line = bufferedReader.readLine()) != null) {
+ builder.append(line);
+ }
+ }
+ if (logResponseStatusText) {
+ infoLogger.accept("Sent data to bStats and received response: " + builder);
+ }
+ }
+
+ /** Checks that the class was properly relocated. */
+ private void checkRelocation() {
+ // You can use the property to disable the check in your test environment
+ if (System.getProperty("bstats.relocatecheck") == null
+ || !System.getProperty("bstats.relocatecheck").equals("false")) {
+ // Maven's Relocate is clever and changes strings, too. So we have to use this little
+ // "trick" ... :D
+ final String defaultPackage =
+ new String(new byte[] {'o', 'r', 'g', '.', 'b', 's', 't', 'a', 't', 's'});
+ final String examplePackage =
+ new String(new byte[] {'y', 'o', 'u', 'r', '.', 'p', 'a', 'c', 'k', 'a', 'g', 'e'});
+ // We want to make sure no one just copy & pastes the example and uses the wrong package
+ // names
+ if (MetricsBase.class.getPackage().getName().startsWith(defaultPackage)
+ || MetricsBase.class.getPackage().getName().startsWith(examplePackage)) {
+ throw new IllegalStateException("bStats Metrics class has not been relocated correctly!");
+ }
+ }
+ }
+
+ /**
+ * Gzips the given string.
+ *
+ * @param str The string to gzip.
+ * @return The gzipped string.
+ */
+ private static byte[] compress(final String str) throws IOException {
+ if (str == null) {
+ return null;
+ }
+ ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+ try (GZIPOutputStream gzip = new GZIPOutputStream(outputStream)) {
+ gzip.write(str.getBytes(StandardCharsets.UTF_8));
+ }
+ return outputStream.toByteArray();
+ }
+ }
+
+ public static class AdvancedBarChart extends CustomChart {
+
+ private final Callable> callable;
+
+ /**
+ * Class constructor.
+ *
+ * @param chartId The id of the chart.
+ * @param callable The callable which is used to request the chart data.
+ */
+ public AdvancedBarChart(String chartId, Callable> callable) {
+ super(chartId);
+ this.callable = callable;
+ }
+
+ @Override
+ protected JsonObjectBuilder.JsonObject getChartData() throws Exception {
+ JsonObjectBuilder valuesBuilder = new JsonObjectBuilder();
+ Map map = callable.call();
+ if (map == null || map.isEmpty()) {
+ // Null = skip the chart
+ return null;
+ }
+ boolean allSkipped = true;
+ for (Map.Entry entry : map.entrySet()) {
+ if (entry.getValue().length == 0) {
+ // Skip this invalid
+ continue;
+ }
+ allSkipped = false;
+ valuesBuilder.appendField(entry.getKey(), entry.getValue());
+ }
+ if (allSkipped) {
+ // Null = skip the chart
+ return null;
+ }
+ return new JsonObjectBuilder().appendField("values", valuesBuilder.build()).build();
+ }
+ }
+
+ public static class SimpleBarChart extends CustomChart {
+
+ private final Callable> callable;
+
+ /**
+ * Class constructor.
+ *
+ * @param chartId The id of the chart.
+ * @param callable The callable which is used to request the chart data.
+ */
+ public SimpleBarChart(String chartId, Callable> callable) {
+ super(chartId);
+ this.callable = callable;
+ }
+
+ @Override
+ protected JsonObjectBuilder.JsonObject getChartData() throws Exception {
+ JsonObjectBuilder valuesBuilder = new JsonObjectBuilder();
+ Map map = callable.call();
+ if (map == null || map.isEmpty()) {
+ // Null = skip the chart
+ return null;
+ }
+ for (Map.Entry entry : map.entrySet()) {
+ valuesBuilder.appendField(entry.getKey(), new int[] {entry.getValue()});
+ }
+ return new JsonObjectBuilder().appendField("values", valuesBuilder.build()).build();
+ }
+ }
+
+ public static class MultiLineChart extends CustomChart {
+
+ private final Callable> callable;
+
+ /**
+ * Class constructor.
+ *
+ * @param chartId The id of the chart.
+ * @param callable The callable which is used to request the chart data.
+ */
+ public MultiLineChart(String chartId, Callable> callable) {
+ super(chartId);
+ this.callable = callable;
+ }
+
+ @Override
+ protected JsonObjectBuilder.JsonObject getChartData() throws Exception {
+ JsonObjectBuilder valuesBuilder = new JsonObjectBuilder();
+ Map map = callable.call();
+ if (map == null || map.isEmpty()) {
+ // Null = skip the chart
+ return null;
+ }
+ boolean allSkipped = true;
+ for (Map.Entry entry : map.entrySet()) {
+ if (entry.getValue() == 0) {
+ // Skip this invalid
+ continue;
+ }
+ allSkipped = false;
+ valuesBuilder.appendField(entry.getKey(), entry.getValue());
+ }
+ if (allSkipped) {
+ // Null = skip the chart
+ return null;
+ }
+ return new JsonObjectBuilder().appendField("values", valuesBuilder.build()).build();
+ }
+ }
+
+ public static class AdvancedPie extends CustomChart {
+
+ private final Callable> callable;
+
+ /**
+ * Class constructor.
+ *
+ * @param chartId The id of the chart.
+ * @param callable The callable which is used to request the chart data.
+ */
+ public AdvancedPie(String chartId, Callable> callable) {
+ super(chartId);
+ this.callable = callable;
+ }
+
+ @Override
+ protected JsonObjectBuilder.JsonObject getChartData() throws Exception {
+ JsonObjectBuilder valuesBuilder = new JsonObjectBuilder();
+ Map map = callable.call();
+ if (map == null || map.isEmpty()) {
+ // Null = skip the chart
+ return null;
+ }
+ boolean allSkipped = true;
+ for (Map.Entry entry : map.entrySet()) {
+ if (entry.getValue() == 0) {
+ // Skip this invalid
+ continue;
+ }
+ allSkipped = false;
+ valuesBuilder.appendField(entry.getKey(), entry.getValue());
+ }
+ if (allSkipped) {
+ // Null = skip the chart
+ return null;
+ }
+ return new JsonObjectBuilder().appendField("values", valuesBuilder.build()).build();
+ }
+ }
+
+ public abstract static class CustomChart {
+
+ private final String chartId;
+
+ protected CustomChart(String chartId) {
+ if (chartId == null) {
+ throw new IllegalArgumentException("chartId must not be null");
+ }
+ this.chartId = chartId;
+ }
+
+ public JsonObjectBuilder.JsonObject getRequestJsonObject(
+ BiConsumer errorLogger, boolean logErrors) {
+ JsonObjectBuilder builder = new JsonObjectBuilder();
+ builder.appendField("chartId", chartId);
+ try {
+ JsonObjectBuilder.JsonObject data = getChartData();
+ if (data == null) {
+ // If the data is null we don't send the chart.
+ return null;
+ }
+ builder.appendField("data", data);
+ } catch (Throwable t) {
+ if (logErrors) {
+ errorLogger.accept("Failed to get data for custom chart with id " + chartId, t);
+ }
+ return null;
+ }
+ return builder.build();
+ }
+
+ protected abstract JsonObjectBuilder.JsonObject getChartData() throws Exception;
+ }
+
+ public static class SingleLineChart extends CustomChart {
+
+ private final Callable callable;
+
+ /**
+ * Class constructor.
+ *
+ * @param chartId The id of the chart.
+ * @param callable The callable which is used to request the chart data.
+ */
+ public SingleLineChart(String chartId, Callable callable) {
+ super(chartId);
+ this.callable = callable;
+ }
+
+ @Override
+ protected JsonObjectBuilder.JsonObject getChartData() throws Exception {
+ int value = callable.call();
+ if (value == 0) {
+ // Null = skip the chart
+ return null;
+ }
+ return new JsonObjectBuilder().appendField("value", value).build();
+ }
+ }
+
+ public static class SimplePie extends CustomChart {
+
+ private final Callable callable;
+
+ /**
+ * Class constructor.
+ *
+ * @param chartId The id of the chart.
+ * @param callable The callable which is used to request the chart data.
+ */
+ public SimplePie(String chartId, Callable callable) {
+ super(chartId);
+ this.callable = callable;
+ }
+
+ @Override
+ protected JsonObjectBuilder.JsonObject getChartData() throws Exception {
+ String value = callable.call();
+ if (value == null || value.isEmpty()) {
+ // Null = skip the chart
+ return null;
+ }
+ return new JsonObjectBuilder().appendField("value", value).build();
+ }
+ }
+
+ public static class DrilldownPie extends CustomChart {
+
+ private final Callable>> callable;
+
+ /**
+ * Class constructor.
+ *
+ * @param chartId The id of the chart.
+ * @param callable The callable which is used to request the chart data.
+ */
+ public DrilldownPie(String chartId, Callable>> callable) {
+ super(chartId);
+ this.callable = callable;
+ }
+
+ @Override
+ public JsonObjectBuilder.JsonObject getChartData() throws Exception {
+ JsonObjectBuilder valuesBuilder = new JsonObjectBuilder();
+ Map> map = callable.call();
+ if (map == null || map.isEmpty()) {
+ // Null = skip the chart
+ return null;
+ }
+ boolean reallyAllSkipped = true;
+ for (Map.Entry> entryValues : map.entrySet()) {
+ JsonObjectBuilder valueBuilder = new JsonObjectBuilder();
+ boolean allSkipped = true;
+ for (Map.Entry valueEntry : map.get(entryValues.getKey()).entrySet()) {
+ valueBuilder.appendField(valueEntry.getKey(), valueEntry.getValue());
+ allSkipped = false;
+ }
+ if (!allSkipped) {
+ reallyAllSkipped = false;
+ valuesBuilder.appendField(entryValues.getKey(), valueBuilder.build());
+ }
+ }
+ if (reallyAllSkipped) {
+ // Null = skip the chart
+ return null;
+ }
+ return new JsonObjectBuilder().appendField("values", valuesBuilder.build()).build();
+ }
+ }
+
+ /**
+ * An extremely simple JSON builder.
+ *
+ * While this class is neither feature-rich nor the most performant one, it's sufficient enough
+ * for its use-case.
+ */
+ public static class JsonObjectBuilder {
+
+ private StringBuilder builder = new StringBuilder();
+
+ private boolean hasAtLeastOneField = false;
+
+ public JsonObjectBuilder() {
+ builder.append("{");
+ }
+
+ /**
+ * Appends a null field to the JSON.
+ *
+ * @param key The key of the field.
+ * @return A reference to this object.
+ */
+ public JsonObjectBuilder appendNull(String key) {
+ appendFieldUnescaped(key, "null");
+ return this;
+ }
+
+ /**
+ * Appends a string field to the JSON.
+ *
+ * @param key The key of the field.
+ * @param value The value of the field.
+ * @return A reference to this object.
+ */
+ public JsonObjectBuilder appendField(String key, String value) {
+ if (value == null) {
+ throw new IllegalArgumentException("JSON value must not be null");
+ }
+ appendFieldUnescaped(key, "\"" + escape(value) + "\"");
+ return this;
+ }
+
+ /**
+ * Appends an integer field to the JSON.
+ *
+ * @param key The key of the field.
+ * @param value The value of the field.
+ * @return A reference to this object.
+ */
+ public JsonObjectBuilder appendField(String key, int value) {
+ appendFieldUnescaped(key, String.valueOf(value));
+ return this;
+ }
+
+ /**
+ * Appends an object to the JSON.
+ *
+ * @param key The key of the field.
+ * @param object The object.
+ * @return A reference to this object.
+ */
+ public JsonObjectBuilder appendField(String key, JsonObject object) {
+ if (object == null) {
+ throw new IllegalArgumentException("JSON object must not be null");
+ }
+ appendFieldUnescaped(key, object.toString());
+ return this;
+ }
+
+ /**
+ * Appends a string array to the JSON.
+ *
+ * @param key The key of the field.
+ * @param values The string array.
+ * @return A reference to this object.
+ */
+ public JsonObjectBuilder appendField(String key, String[] values) {
+ if (values == null) {
+ throw new IllegalArgumentException("JSON values must not be null");
+ }
+ String escapedValues =
+ Arrays.stream(values)
+ .map(value -> "\"" + escape(value) + "\"")
+ .collect(Collectors.joining(","));
+ appendFieldUnescaped(key, "[" + escapedValues + "]");
+ return this;
+ }
+
+ /**
+ * Appends an integer array to the JSON.
+ *
+ * @param key The key of the field.
+ * @param values The integer array.
+ * @return A reference to this object.
+ */
+ public JsonObjectBuilder appendField(String key, int[] values) {
+ if (values == null) {
+ throw new IllegalArgumentException("JSON values must not be null");
+ }
+ String escapedValues =
+ Arrays.stream(values).mapToObj(String::valueOf).collect(Collectors.joining(","));
+ appendFieldUnescaped(key, "[" + escapedValues + "]");
+ return this;
+ }
+
+ /**
+ * Appends an object array to the JSON.
+ *
+ * @param key The key of the field.
+ * @param values The integer array.
+ * @return A reference to this object.
+ */
+ public JsonObjectBuilder appendField(String key, JsonObject[] values) {
+ if (values == null) {
+ throw new IllegalArgumentException("JSON values must not be null");
+ }
+ String escapedValues =
+ Arrays.stream(values).map(JsonObject::toString).collect(Collectors.joining(","));
+ appendFieldUnescaped(key, "[" + escapedValues + "]");
+ return this;
+ }
+
+ /**
+ * Appends a field to the object.
+ *
+ * @param key The key of the field.
+ * @param escapedValue The escaped value of the field.
+ */
+ private void appendFieldUnescaped(String key, String escapedValue) {
+ if (builder == null) {
+ throw new IllegalStateException("JSON has already been built");
+ }
+ if (key == null) {
+ throw new IllegalArgumentException("JSON key must not be null");
+ }
+ if (hasAtLeastOneField) {
+ builder.append(",");
+ }
+ builder.append("\"").append(escape(key)).append("\":").append(escapedValue);
+ hasAtLeastOneField = true;
+ }
+
+ /**
+ * Builds the JSON string and invalidates this builder.
+ *
+ * @return The built JSON string.
+ */
+ public JsonObject build() {
+ if (builder == null) {
+ throw new IllegalStateException("JSON has already been built");
+ }
+ JsonObject object = new JsonObject(builder.append("}").toString());
+ builder = null;
+ return object;
+ }
+
+ /**
+ * Escapes the given string like stated in https://www.ietf.org/rfc/rfc4627.txt.
+ *
+ *
This method escapes only the necessary characters '"', '\'. and '\u0000' - '\u001F'.
+ * Compact escapes are not used (e.g., '\n' is escaped as "\u000a" and not as "\n").
+ *
+ * @param value The value to escape.
+ * @return The escaped value.
+ */
+ private static String escape(String value) {
+ final StringBuilder builder = new StringBuilder();
+ for (int i = 0; i < value.length(); i++) {
+ char c = value.charAt(i);
+ if (c == '"') {
+ builder.append("\\\"");
+ } else if (c == '\\') {
+ builder.append("\\\\");
+ } else if (c <= '\u000F') {
+ builder.append("\\u000").append(Integer.toHexString(c));
+ } else if (c <= '\u001F') {
+ builder.append("\\u00").append(Integer.toHexString(c));
+ } else {
+ builder.append(c);
+ }
+ }
+ return builder.toString();
+ }
+
+ /**
+ * A super simple representation of a JSON object.
+ *
+ *
This class only exists to make methods of the {@link JsonObjectBuilder} type-safe and not
+ * allow a raw string inputs for methods like {@link JsonObjectBuilder#appendField(String,
+ * JsonObject)}.
+ */
+ public static class JsonObject {
+
+ private final String value;
+
+ private JsonObject(String value) {
+ this.value = value;
+ }
+
+ @Override
+ public String toString() {
+ return value;
+ }
+ }
+ }
+
+ /**
+ * A simple config for bStats.
+ *
+ *
This class is not used by every platform.
+ */
+ public static class MetricsConfig {
+
+ private final File file;
+
+ private final boolean defaultEnabled;
+
+ private String serverUUID;
+
+ private boolean enabled;
+
+ private boolean logErrors;
+
+ private boolean logSentData;
+
+ private boolean logResponseStatusText;
+
+ private boolean didExistBefore = true;
+
+ public MetricsConfig(File file, boolean defaultEnabled) throws IOException {
+ this.file = file;
+ this.defaultEnabled = defaultEnabled;
+ setupConfig();
+ }
+
+ public String getServerUUID() {
+ return serverUUID;
+ }
+
+ public boolean isEnabled() {
+ return enabled;
+ }
+
+ public boolean isLogErrorsEnabled() {
+ return logErrors;
+ }
+
+ public boolean isLogSentDataEnabled() {
+ return logSentData;
+ }
+
+ public boolean isLogResponseStatusTextEnabled() {
+ return logResponseStatusText;
+ }
+
+ /**
+ * Checks whether the config file did exist before or not.
+ *
+ * @return If the config did exist before.
+ */
+ public boolean didExistBefore() {
+ return didExistBefore;
+ }
+
+ /** Creates the config file if it does not exist and read its content. */
+ private void setupConfig() throws IOException {
+ if (!file.exists()) {
+ // Looks like it's the first time we create it (or someone deleted it).
+ didExistBefore = false;
+ writeConfig();
+ }
+ readConfig();
+ if (serverUUID == null) {
+ // Found a malformed config file with no UUID. Let's recreate it.
+ writeConfig();
+ readConfig();
+ }
+ }
+
+ /** Creates a config file with teh default content. */
+ private void writeConfig() throws IOException {
+ List configContent = new ArrayList<>();
+ configContent.add(
+ "# bStats (https://bStats.org) collects some basic information for plugin authors, like");
+ configContent.add(
+ "# how many people use their plugin and their total player count. It's recommended to keep");
+ configContent.add(
+ "# bStats enabled, but if you're not comfortable with this, you can turn this setting off.");
+ configContent.add(
+ "# There is no performance penalty associated with having metrics enabled, and data sent to");
+ configContent.add("# bStats is fully anonymous.");
+ configContent.add("enabled=" + defaultEnabled);
+ configContent.add("server-uuid=" + UUID.randomUUID().toString());
+ configContent.add("log-errors=false");
+ configContent.add("log-sent-data=false");
+ configContent.add("log-response-status-text=false");
+ writeFile(file, configContent);
+ }
+
+ /** Reads the content of the config file. */
+ private void readConfig() throws IOException {
+ List lines = readFile(file);
+ if (lines == null) {
+ throw new AssertionError("Content of newly created file is null");
+ }
+ enabled = getConfigValue("enabled", lines).map("true"::equals).orElse(true);
+ serverUUID = getConfigValue("server-uuid", lines).orElse(null);
+ logErrors = getConfigValue("log-errors", lines).map("true"::equals).orElse(false);
+ logSentData = getConfigValue("log-sent-data", lines).map("true"::equals).orElse(false);
+ logResponseStatusText =
+ getConfigValue("log-response-status-text", lines).map("true"::equals).orElse(false);
+ }
+
+ /**
+ * Gets a config setting from the given list of lines of the file.
+ *
+ * @param key The key for the setting.
+ * @param lines The lines of the file.
+ * @return The value of the setting.
+ */
+ private Optional getConfigValue(String key, List lines) {
+ return lines.stream()
+ .filter(line -> line.startsWith(key + "="))
+ .map(line -> line.replaceFirst(Pattern.quote(key + "="), ""))
+ .findFirst();
+ }
+
+ /**
+ * Reads the text content of the given file.
+ *
+ * @param file The file to read.
+ * @return The lines of the given file.
+ */
+ private List readFile(File file) throws IOException {
+ if (!file.exists()) {
+ return null;
+ }
+ try (FileReader fileReader = new FileReader(file);
+ BufferedReader bufferedReader = new BufferedReader(fileReader)) {
+ return bufferedReader.lines().collect(Collectors.toList());
+ }
+ }
+
+ /**
+ * Writes the given lines to the given file.
+ *
+ * @param file The file to write to.
+ * @param lines The lines to write.
+ */
+ private void writeFile(File file, List lines) throws IOException {
+ if (!file.exists()) {
+ file.getParentFile().mkdirs();
+ file.createNewFile();
+ }
+ try (FileWriter fileWriter = new FileWriter(file);
+ BufferedWriter bufferedWriter = new BufferedWriter(fileWriter)) {
+ for (String line : lines) {
+ bufferedWriter.write(line);
+ bufferedWriter.newLine();
+ }
+ }
+ }
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Library/SubEvent.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Library/SubEvent.java
new file mode 100644
index 00000000..38d746a3
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Library/SubEvent.java
@@ -0,0 +1,7 @@
+package net.ME1312.SubServers.Velocity.Library;
+
+/**
+ * SubEvent Layout Class
+ */
+public interface SubEvent {
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketCheckPermission.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketCheckPermission.java
new file mode 100644
index 00000000..38b33572
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketCheckPermission.java
@@ -0,0 +1,61 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Callback.Callback;
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.Galaxi.Library.Util;
+import net.ME1312.SubData.Client.Protocol.Forwardable;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.Protocol.PacketObjectOut;
+import net.ME1312.SubData.Client.SubDataSender;
+
+import java.util.HashMap;
+import java.util.UUID;
+
+/**
+ * Check Permission Packet
+ */
+public class PacketCheckPermission implements Forwardable, PacketObjectIn, PacketObjectOut {
+ static HashMap[]> callbacks = new HashMap[]>();
+ private UUID player;
+ private String permission;
+ private UUID tracker;
+
+ /**
+ * New PacketCheckPermission (In)
+ */
+ public PacketCheckPermission() {}
+
+ /**
+ * New PacketCheckPermission (Out)
+ *
+ * @param player Player to check on
+ * @param permission Permission to check
+ * @param callback Callbacks
+ */
+ @SafeVarargs
+ public PacketCheckPermission(UUID player, String permission, Callback... callback) {
+ this.player = player;
+ this.permission = permission;
+ this.tracker = Util.getNew(callbacks.keySet(), UUID::randomUUID);
+ callbacks.put(tracker, callback);
+ }
+
+ @Override
+ public ObjectMap send(SubDataSender client) throws Throwable {
+ ObjectMap data = new ObjectMap();
+ data.set(0x0000, tracker);
+ data.set(0x0001, player);
+ data.set(0x0002, permission);
+ return data;
+ }
+
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) throws Throwable {
+ client.sendPacket(new PacketCheckPermissionResponse(data.getUUID(0x0001), data.getRawString(0x0002), (data.contains(0x0000))?data.getUUID(0x0000):null));
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketCheckPermissionResponse.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketCheckPermissionResponse.java
new file mode 100644
index 00000000..85de7798
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketCheckPermissionResponse.java
@@ -0,0 +1,59 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Callback.Callback;
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.Galaxi.Library.Util;
+import net.ME1312.SubData.Client.Protocol.Forwardable;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.Protocol.PacketObjectOut;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.ExProxy;
+
+import java.util.UUID;
+
+import static net.ME1312.SubServers.Velocity.Network.Packet.PacketCheckPermission.callbacks;
+
+
+/**
+ * Check Permission Response Packet
+ */
+public class PacketCheckPermissionResponse implements Forwardable, PacketObjectIn, PacketObjectOut {
+ private boolean result;
+ private UUID tracker;
+
+ /**
+ * New PacketCheckPermissionResponse (In)
+ */
+ public PacketCheckPermissionResponse() {}
+
+ /**
+ * New PacketCheckPermissionResponse (Out)
+ *
+ * @param player Player to check on
+ * @param permission Permission to check
+ * @param tracker Receiver ID
+ */
+ public PacketCheckPermissionResponse(UUID player, String permission, UUID tracker) {
+ this.result = Util.getDespiteException(() -> ExProxy.getInstance().getPlayer(player).get().hasPermission(permission), false);
+ this.tracker = tracker;
+ }
+
+ @Override
+ public ObjectMap send(SubDataSender client) throws Throwable {
+ ObjectMap data = new ObjectMap();
+ data.set(0x0000, tracker);
+ data.set(0x0001, result);
+ return data;
+ }
+
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) throws Throwable {
+ for (Callback callback : callbacks.get(data.getUUID(0x0000))) callback.run(data.getBoolean(0x0001));
+ callbacks.remove(data.getUUID(0x0000));
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketDownloadLang.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketDownloadLang.java
new file mode 100644
index 00000000..c4042177
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketDownloadLang.java
@@ -0,0 +1,49 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Container.ContainedPair;
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.Galaxi.Library.Util;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.Protocol.PacketOut;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.ExProxy;
+import net.ME1312.SubServers.Velocity.Library.Compatibility.Logger;
+
+import java.util.Calendar;
+
+/**
+ * Download Lang Packet
+ */
+public class PacketDownloadLang implements PacketObjectIn, PacketOut {
+ private ExProxy plugin;
+
+ /**
+ * New PacketDownloadLang (In)
+ *
+ * @param plugin SubServers.Client
+ */
+ public PacketDownloadLang(ExProxy plugin) {
+ if (Util.isNull(plugin)) throw new NullPointerException();
+ this.plugin = plugin;
+ }
+
+ /**
+ * New PacketDownloadLang (Out)
+ */
+ public PacketDownloadLang() {}
+
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) {
+ try {
+ Util.reflect(ExProxy.class.getDeclaredField("lang"), plugin, new ContainedPair<>(Calendar.getInstance().getTime().getTime(), data.getObject(0x0001)));
+ Logger.get("SubData").info("Lang Settings Downloaded");
+ } catch (IllegalAccessException | NoSuchFieldException e) {
+ e.printStackTrace();
+ }
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExDisconnectPlayer.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExDisconnectPlayer.java
new file mode 100644
index 00000000..8e66a0f8
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExDisconnectPlayer.java
@@ -0,0 +1,79 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.Protocol.PacketObjectOut;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.ExProxy;
+import net.ME1312.SubServers.Velocity.Library.Compatibility.ChatColor;
+
+import com.velocitypowered.api.proxy.Player;
+import net.kyori.adventure.text.Component;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+/**
+ * Disconnect External Player Packet
+ */
+public class PacketExDisconnectPlayer implements PacketObjectIn, PacketObjectOut {
+ private ExProxy plugin;
+ private int response;
+ private UUID tracker;
+
+ /**
+ * New PacketExDisconnectPlayer (In)
+ */
+ public PacketExDisconnectPlayer(ExProxy plugin) {
+ this.plugin = plugin;
+ }
+
+ /**
+ * New PacketExDisconnectPlayer (Out)
+ *
+ * @param response Response ID
+ * @param tracker Receiver ID
+ */
+ public PacketExDisconnectPlayer(int response, UUID tracker) {
+ this.response = response;
+ this.tracker = tracker;
+ }
+
+ @Override
+ public ObjectMap send(SubDataSender client) {
+ ObjectMap json = new ObjectMap();
+ if (tracker != null) json.set(0x0000, tracker);
+ json.set(0x0001, response);
+ return json;
+ }
+
+ @SuppressWarnings("deprecation")
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) {
+ UUID tracker = (data.contains(0x0000)?data.getUUID(0x0000):null);
+ List ids = data.getUUIDList(0x0001);
+ try {
+ Component message = (data.contains(0x0002))? ChatColor.convertColor(data.getRawString(0x0002)) : Component.text().build();
+ int failures = 0;
+ for (UUID id : ids) {
+ Optional local = ExProxy.getInstance().getPlayer(id);
+ if (local.isPresent()) {
+ local.get().disconnect(message);
+ } else {
+ ++failures;
+ }
+ }
+ client.sendPacket(new PacketExDisconnectPlayer(failures, tracker));
+ } catch (Throwable e) {
+ client.sendPacket(new PacketExDisconnectPlayer(ids.size(), tracker));
+ e.printStackTrace();
+ }
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExMessagePlayer.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExMessagePlayer.java
new file mode 100644
index 00000000..791eda38
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExMessagePlayer.java
@@ -0,0 +1,103 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.Protocol.PacketObjectOut;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.ExProxy;
+import net.ME1312.SubServers.Velocity.Library.Compatibility.ChatColor;
+
+import com.velocitypowered.api.proxy.Player;
+import net.kyori.adventure.text.Component;
+import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+/**
+ * Message External Player Packet
+ */
+public class PacketExMessagePlayer implements PacketObjectIn, PacketObjectOut {
+ private ExProxy plugin;
+ private int response;
+ private UUID tracker;
+
+ /**
+ * New PacketExMessagePlayer (In)
+ */
+ public PacketExMessagePlayer(ExProxy plugin) {
+ this.plugin = plugin;
+ }
+
+ /**
+ * New PacketExMessagePlayer (Out)
+ *
+ * @param response Response ID
+ * @param tracker Receiver ID
+ */
+ public PacketExMessagePlayer(int response, UUID tracker) {
+ this.response = response;
+ this.tracker = tracker;
+ }
+
+ @Override
+ public ObjectMap send(SubDataSender client) {
+ ObjectMap json = new ObjectMap();
+ if (tracker != null) json.set(0x0000, tracker);
+ json.set(0x0001, response);
+ return json;
+ }
+
+ @SuppressWarnings("deprecation")
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) {
+ UUID tracker = (data.contains(0x0000)?data.getUUID(0x0000):null);
+ List ids = (data.contains(0x0001)?data.getUUIDList(0x0001):null);
+ try {
+ Component[] legacy = null;
+ Component[] components = null;
+
+ if (data.contains(0x0002)) {
+ List messages = data.getRawStringList(0x0002);
+ legacy = new Component[messages.size()];
+ for (int i = 0; i < legacy.length; ++i) legacy[i] = ChatColor.convertColor(messages.get(i));
+ }
+ if (data.contains(0x0003)) {
+ List messages = data.getRawStringList(0x0003);
+ components = new Component[messages.size()];
+ for (int i = 0; i < components.length; ++i) components[i] = GsonComponentSerializer.gson().deserialize(messages.get(i));
+ }
+
+ int failures = 0;
+ if (ids == null || ids.size() == 0) {
+ if (legacy != null) for (Component c : legacy)
+ ExProxy.getInstance().sendMessage(c);
+ if (components != null) for (Component c : components)
+ ExProxy.getInstance().sendMessage(c);
+ } else {
+ for (UUID id : ids) {
+ Optional local = ExProxy.getInstance().getPlayer(id);
+ if (local.isPresent()) {
+ if (legacy != null) for (Component c : legacy)
+ local.get().sendMessage(c);
+ if (components != null) for (Component c : components)
+ local.get().sendMessage(c);
+ } else {
+ ++failures;
+ }
+ }
+ }
+ client.sendPacket(new PacketExMessagePlayer(failures, tracker));
+ } catch (Throwable e) {
+ client.sendPacket(new PacketExMessagePlayer((ids == null || ids.size() == 0)? 1 : ids.size(), tracker));
+ e.printStackTrace();
+ }
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExSyncPlayer.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExSyncPlayer.java
new file mode 100644
index 00000000..bed8da72
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExSyncPlayer.java
@@ -0,0 +1,100 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.Galaxi.Library.Util;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.Protocol.PacketObjectOut;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.ExProxy;
+import net.ME1312.SubServers.Velocity.Server.CachedPlayer;
+import net.ME1312.SubServers.Velocity.Server.ServerData;
+
+import com.velocitypowered.api.proxy.server.RegisteredServer;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
+/**
+ * External Player Sync Packet
+ */
+public class PacketExSyncPlayer implements PacketObjectIn, PacketObjectOut {
+ private ExProxy plugin;
+ private Boolean mode;
+ private CachedPlayer[] values;
+
+ /**
+ * New PacketExSyncPlayer (In)
+ *
+ * @param plugin SubPlugin
+ */
+ public PacketExSyncPlayer(ExProxy plugin) {
+ if (Util.isNull(plugin)) throw new NullPointerException();
+ this.plugin = plugin;
+ }
+
+ /**
+ * New PacketExSyncPlayer (Out)
+ *
+ * @param mode Update Mode (true for add, false for remove, null for reset)
+ * @param values RemotePlayers
+ */
+ public PacketExSyncPlayer(Boolean mode, CachedPlayer... values) {
+ this.mode = mode;
+ this.values = values;
+ }
+
+ @Override
+ public ObjectMap send(SubDataSender client) {
+ ObjectMap data = new ObjectMap();
+ data.set(0x0001, mode);
+ if (values != null) {
+ ArrayList> list = new ArrayList>();
+ for (CachedPlayer value : values) list.add(value.getRaw());
+ data.set(0x0002, list);
+ }
+ return data;
+ }
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) {
+ String proxy = (data.contains(0x0000)?data.getRawString(0x0000).toLowerCase():null);
+ synchronized (plugin.rPlayers) {
+ if (data.getBoolean(0x0001) == null) {
+ for (UUID id : Util.getBackwards(plugin.rPlayerLinkP, proxy)) {
+ plugin.rPlayerLinkS.remove(id);
+ plugin.rPlayerLinkP.remove(id);
+ plugin.rPlayers.remove(id);
+ }
+ }
+ if (data.getBoolean(0x0001) != Boolean.FALSE) {
+ if (data.contains(0x0002)) for (Map object : (List>) data.getObjectList(0x0002)) {
+ ServerData server = (object.getOrDefault("server", null) != null)?ExProxy.getInstance().getServer(object.get("server").toString()).map(RegisteredServer::getServerInfo).map(plugin::getData).orElse(null):null;
+ CachedPlayer player = new CachedPlayer(new ObjectMap<>(object));
+
+ plugin.rPlayerLinkP.put(player.getUniqueId(), proxy);
+ plugin.rPlayers.put(player.getUniqueId(), player);
+ if (server != null) plugin.rPlayerLinkS.put(player.getUniqueId(), server);
+ }
+ } else {
+ if (data.contains(0x0002)) for (Map object : (List>) data.getObjectList(0x0002)) {
+ UUID id = UUID.fromString(object.get("id").toString());
+
+ // Don't accept removal requests when we're managing players
+ if ((!plugin.rPlayerLinkP.containsKey(id) || !plugin.rPlayerLinkP.get(id).equalsIgnoreCase(plugin.api.getName().toLowerCase()))) {
+ plugin.rPlayerLinkS.remove(id);
+ plugin.rPlayerLinkP.remove(id);
+ plugin.rPlayers.remove(id);
+ }
+ }
+ }
+ }
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExTransferPlayer.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExTransferPlayer.java
new file mode 100644
index 00000000..addcd2df
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketExTransferPlayer.java
@@ -0,0 +1,80 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.Protocol.PacketObjectOut;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.ExProxy;
+
+import com.velocitypowered.api.proxy.Player;
+import com.velocitypowered.api.proxy.server.RegisteredServer;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+/**
+ * Transfer External Player Packet
+ */
+public class PacketExTransferPlayer implements PacketObjectIn, PacketObjectOut {
+ private ExProxy plugin;
+ private int response;
+ private UUID tracker;
+
+ /**
+ * New PacketExTransferPlayer (In)
+ */
+ public PacketExTransferPlayer(ExProxy plugin) {
+ this.plugin = plugin;
+ }
+
+ /**
+ * New PacketExTransferPlayer (Out)
+ *
+ * @param response Response ID
+ * @param tracker Receiver ID
+ */
+ public PacketExTransferPlayer(int response, UUID tracker) {
+ this.response = response;
+ this.tracker = tracker;
+ }
+
+ @Override
+ public ObjectMap send(SubDataSender client) {
+ ObjectMap json = new ObjectMap();
+ if (tracker != null) json.set(0x0000, tracker);
+ json.set(0x0001, response);
+ return json;
+ }
+
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) {
+ UUID tracker = (data.contains(0x0000)?data.getUUID(0x0000):null);
+ List ids = data.getUUIDList(0x0001);
+ try {
+ Optional server = ExProxy.getInstance().getServer(data.getRawString(0x0002).toLowerCase());
+ if (server.isPresent()) {
+ int failures = 0;
+ for (UUID id : ids) {
+ Optional local = ExProxy.getInstance().getPlayer(id);
+ if (local.isPresent()) {
+ local.get().createConnectionRequest(server.get()).fireAndForget();
+ } else {
+ ++failures;
+ }
+ }
+ client.sendPacket(new PacketExTransferPlayer(failures, tracker));
+ } else {
+ client.sendPacket(new PacketExTransferPlayer(ids.size(), tracker));
+ }
+ } catch (Throwable e) {
+ client.sendPacket(new PacketExTransferPlayer(ids.size(), tracker));
+ e.printStackTrace();
+ }
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExEditServer.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExEditServer.java
new file mode 100644
index 00000000..f996b564
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExEditServer.java
@@ -0,0 +1,65 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.ExProxy;
+import net.ME1312.SubServers.Velocity.Library.Compatibility.ChatColor;
+import net.ME1312.SubServers.Velocity.Server.ServerData;
+
+import com.velocitypowered.api.proxy.server.RegisteredServer;
+
+/**
+ * Server Edit Notification Packet
+ */
+public class PacketInExEditServer implements PacketObjectIn {
+ private ExProxy plugin;
+
+ /**
+ * New PacketExControlServer (In)
+ */
+ public PacketInExEditServer(ExProxy plugin) {
+ this.plugin = plugin;
+ }
+
+ @Override
+ public void receive(SubDataSender client, ObjectMap data) {
+ ServerData server = ExProxy.getInstance().getServer(data.getRawString(0x0000)).map(RegisteredServer::getServerInfo).map(plugin::getData).orElse(null);
+ if (server != null) {
+ switch (data.getInt(0x0001)) {
+ case 0:
+ server.setDisplayName(data.getList(0x0002).get(0).asRawString());
+ break;
+ case 1:
+ server.setMotd(ChatColor.parseColor('&', data.getList(0x0002).get(0).asRawString()));
+ break;
+ case 2:
+ server.setRestricted(data.getList(0x0002).get(0).asBoolean());
+ break;
+ case 3:
+ server.setHidden(data.getList(0x0002).get(0).asBoolean());
+ break;
+ case 4:
+ server.setSubData(data.getList(0x0002).get(1).asUUID(), data.getList(0x0002).get(0).asInt());
+ break;
+ case 5:
+ server.setSubData(null, data.getList(0x0002).get(0).asInt());
+ break;
+ case 6:
+ server.whitelist = data.getList(0x0002).get(0).asUUIDList();
+ break;
+ case 7:
+ server.whitelist(data.getList(0x0002).get(0).asUUID());
+ break;
+ case 8:
+ server.unwhitelist(data.getList(0x0002).get(0).asUUID());
+ break;
+ }
+ }
+ }
+
+ @Override
+ public int version() {
+ return 0x0002;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExReset.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExReset.java
new file mode 100644
index 00000000..e5db8684
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExReset.java
@@ -0,0 +1,21 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.SubData.Client.Protocol.PacketIn;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.SubAPI;
+
+/**
+ * Reset Packet
+ */
+public class PacketInExReset implements PacketIn {
+
+ @Override
+ public void receive(SubDataSender client) {
+ SubAPI.getInstance().getInternals().servers.clear();
+ }
+
+ @Override
+ public int version() {
+ return 0x0001;
+ }
+}
diff --git a/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExRunEvent.java b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExRunEvent.java
new file mode 100644
index 00000000..df45a701
--- /dev/null
+++ b/SubServers.Sync/velocity/src/net/ME1312/SubServers/Velocity/Network/Packet/PacketInExRunEvent.java
@@ -0,0 +1,150 @@
+package net.ME1312.SubServers.Velocity.Network.Packet;
+
+import net.ME1312.Galaxi.Library.Callback.Callback;
+import net.ME1312.Galaxi.Library.Container.ContainedPair;
+import net.ME1312.Galaxi.Library.Map.ObjectMap;
+import net.ME1312.SubData.Client.Protocol.PacketObjectIn;
+import net.ME1312.SubData.Client.SubDataSender;
+import net.ME1312.SubServers.Velocity.Event.*;
+import net.ME1312.SubServers.Velocity.ExProxy;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Run Event Packet
+ */
+public class PacketInExRunEvent implements PacketObjectIn {
+ private static HashMap>>> callbacks = new HashMap>>>();
+
+ /**
+ * New PacketInExRunEvent
+ */
+ public PacketInExRunEvent(ExProxy plugin) {
+ callback("SubAddHostEvent", new Callback>() {
+ @Override
+ public void run(ObjectMap data) {
+ ExProxy.getInstance().getEventManager().fire(new SubAddHostEvent((data.contains("player"))?data.getUUID("player"):null, data.getRawString("host")));
+ callback("SubAddHostEvent", this);
+ }
+ });
+ callback("SubAddProxyEvent", new Callback>() {
+ @Override
+ public void run(ObjectMap data) {
+ ExProxy.getInstance().getEventManager().fire(new SubAddProxyEvent(data.getRawString("proxy")));
+ callback("SubAddProxyEvent", this);
+ }
+ });
+ callback("SubAddServerEvent", new Callback