aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2019-04-27 18:34:58 +0100
committerLuck <git@lucko.me>2019-04-27 18:34:58 +0100
commit51fa2b3e64f021c3c0535f9f931d3fae27ca7adc (patch)
tree8c17193be30335db15cbdfe7cc45fe80c4f4907d /spark-common/src/main/java
parent3cf9c7e31d2244db8155082512b439885cef8c3b (diff)
downloadspark-51fa2b3e64f021c3c0535f9f931d3fae27ca7adc.tar.gz
spark-51fa2b3e64f021c3c0535f9f931d3fae27ca7adc.tar.bz2
spark-51fa2b3e64f021c3c0535f9f931d3fae27ca7adc.zip
Use text components instead of legacy formatting codes throughout the project
Diffstat (limited to 'spark-common/src/main/java')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java36
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/SparkPlugin.java5
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/command/CommandResponseHandler.java33
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/command/modules/HealthModule.java233
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/command/modules/MemoryModule.java116
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java53
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/command/modules/TickMonitoringModule.java9
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/monitor/tick/TickMonitor.java70
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/monitor/tick/TpsCalculator.java32
9 files changed, 390 insertions, 197 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java b/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java
index 7a33c39..6b3eb21 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java
@@ -33,6 +33,10 @@ import me.lucko.spark.common.command.tabcomplete.TabCompleter;
import me.lucko.spark.common.monitor.tick.TpsCalculator;
import me.lucko.spark.common.sampler.TickCounter;
import me.lucko.spark.common.util.BytebinClient;
+import net.kyori.text.Component;
+import net.kyori.text.TextComponent;
+import net.kyori.text.format.TextColor;
+import net.kyori.text.format.TextDecoration;
import okhttp3.OkHttpClient;
import java.util.ArrayList;
@@ -116,7 +120,7 @@ public class SparkPlatform<S> {
command.executor().execute(this, sender, resp, new Arguments(rawArgs));
} catch (IllegalArgumentException e) {
e.printStackTrace();
- resp.replyPrefixed("&c" + e.getMessage());
+ resp.replyPrefixed(TextComponent.of(e.getMessage(), TextColor.RED));
}
return;
}
@@ -146,14 +150,36 @@ public class SparkPlatform<S> {
}
private void sendUsage(CommandResponseHandler<S> sender) {
- sender.replyPrefixed("&fspark &7v" + getPlugin().getVersion());
+ sender.replyPrefixed(TextComponent.builder()
+ .append(TextComponent.of("spark", TextColor.WHITE))
+ .append(Component.space())
+ .append(TextComponent.of("v" + getPlugin().getVersion(), TextColor.GRAY))
+ .build()
+ );
for (Command<S> command : this.commands) {
- sender.reply("&6&l> &7/" + getPlugin().getLabel() + " " + command.aliases().get(0));
+ sender.reply(TextComponent.builder()
+ .append(TextComponent.builder(">").color(TextColor.GOLD).decoration(TextDecoration.BOLD, true).build())
+ .append(Component.space())
+ .append(TextComponent.of("/" + getPlugin().getLabel() + " " + command.aliases().get(0), TextColor.GRAY))
+ .build()
+ );
for (Command.ArgumentInfo arg : command.arguments()) {
if (arg.requiresParameter()) {
- sender.reply(" &8[&7--" + arg.argumentName() + "&8 <" + arg.parameterDescription() + ">]");
+ sender.reply(TextComponent.builder(" ")
+ .append(TextComponent.of("[", TextColor.DARK_GRAY))
+ .append(TextComponent.of("--" + arg.argumentName(), TextColor.GRAY))
+ .append(Component.space())
+ .append(TextComponent.of("<" + arg.parameterDescription() + ">", TextColor.DARK_GRAY))
+ .append(TextComponent.of("]", TextColor.DARK_GRAY))
+ .build()
+ );
} else {
- sender.reply(" &8[&7--" + arg.argumentName() + "]");
+ sender.reply(TextComponent.builder(" ")
+ .append(TextComponent.of("[", TextColor.DARK_GRAY))
+ .append(TextComponent.of("--" + arg.argumentName(), TextColor.GRAY))
+ .append(TextComponent.of("]", TextColor.DARK_GRAY))
+ .build()
+ );
}
}
}
diff --git a/spark-common/src/main/java/me/lucko/spark/common/SparkPlugin.java b/spark-common/src/main/java/me/lucko/spark/common/SparkPlugin.java
index 481a615..19eb3d3 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/SparkPlugin.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/SparkPlugin.java
@@ -22,6 +22,7 @@ package me.lucko.spark.common;
import me.lucko.spark.common.sampler.ThreadDumper;
import me.lucko.spark.common.sampler.TickCounter;
+import net.kyori.text.Component;
import java.nio.file.Path;
import java.util.Set;
@@ -36,9 +37,7 @@ public interface SparkPlugin<S> {
Set<S> getSendersWithPermission(String permission);
- void sendMessage(S sender, String message);
-
- void sendLink(S sender, String url);
+ void sendMessage(S sender, Component message);
void runAsync(Runnable r);
diff --git a/spark-common/src/main/java/me/lucko/spark/common/command/CommandResponseHandler.java b/spark-common/src/main/java/me/lucko/spark/common/command/CommandResponseHandler.java
index 9d604bd..94e1946 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/command/CommandResponseHandler.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/command/CommandResponseHandler.java
@@ -21,14 +21,24 @@
package me.lucko.spark.common.command;
import me.lucko.spark.common.SparkPlatform;
+import net.kyori.text.Component;
+import net.kyori.text.TextComponent;
+import net.kyori.text.event.ClickEvent;
+import net.kyori.text.format.TextColor;
+import net.kyori.text.format.TextDecoration;
import java.util.Set;
import java.util.function.Consumer;
public class CommandResponseHandler<S> {
- /** The prefix used in all messages */
- private static final String PREFIX = "&8[&e&l⚡&8] &7";
+ /** The prefix used in all messages "&8[&e&l⚡&8] &7" */
+ private static final TextComponent PREFIX = TextComponent.builder().color(TextColor.GRAY)
+ .append(TextComponent.of("[", TextColor.DARK_GRAY))
+ .append(TextComponent.builder("⚡").color(TextColor.YELLOW).decoration(TextDecoration.BOLD, TextDecoration.State.TRUE).build())
+ .append(TextComponent.of("]", TextColor.DARK_GRAY))
+ .append(TextComponent.of(" "))
+ .build();
private final SparkPlatform<S> platform;
private final S sender;
@@ -48,28 +58,21 @@ public class CommandResponseHandler<S> {
senders.forEach(action);
}
- public void reply(String message) {
+ public void reply(Component message) {
this.platform.getPlugin().sendMessage(this.sender, message);
}
- public void broadcast(String message) {
+ public void broadcast(Component message) {
allSenders(sender -> this.platform.getPlugin().sendMessage(sender, message));
}
- public void replyPrefixed(String message) {
- this.platform.getPlugin().sendMessage(this.sender, PREFIX + message);
+ public void replyPrefixed(Component message) {
+ reply(PREFIX.append(message));
}
- public void broadcastPrefixed(String message) {
- allSenders(sender -> this.platform.getPlugin().sendMessage(sender, PREFIX + message));
+ public void broadcastPrefixed(Component message) {
+ broadcast(PREFIX.append(message));
}
- public void replyLink(String link) {
- this.platform.getPlugin().sendLink(this.sender, link);
- }
-
- public void broadcastLink(String link) {
- allSenders(sender -> this.platform.getPlugin().sendLink(sender, link));
- }
}
diff --git a/spark-common/src/main/java/me/lucko/spark/common/command/modules/HealthModule.java b/spark-common/src/main/java/me/lucko/spark/common/command/modules/HealthModule.java
index 66cee54..097d264 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/command/modules/HealthModule.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/command/modules/HealthModule.java
@@ -26,6 +26,10 @@ import me.lucko.spark.common.command.CommandModule;
import me.lucko.spark.common.command.tabcomplete.TabCompleter;
import me.lucko.spark.common.monitor.cpu.CpuMonitor;
import me.lucko.spark.common.monitor.tick.TpsCalculator;
+import net.kyori.text.Component;
+import net.kyori.text.TextComponent;
+import net.kyori.text.format.TextColor;
+import net.kyori.text.format.TextDecoration;
import java.io.IOException;
import java.lang.management.ManagementFactory;
@@ -45,50 +49,77 @@ public class HealthModule<S> implements CommandModule<S> {
@Override
public void registerCommands(Consumer<Command<S>> consumer) {
consumer.accept(Command.<S>builder()
- .aliases("tps")
- .executor((platform, sender, resp, arguments) -> {
- TpsCalculator tpsCalculator = platform.getTpsCalculator();
- if (tpsCalculator != null) {
- resp.replyPrefixed("TPS from last 5s, 10s, 1m, 5m, 15m:");
- resp.replyPrefixed(" " + tpsCalculator.toFormattedString());
- } else {
- resp.replyPrefixed("Not supported!");
- }
- })
- .tabCompleter(Command.TabCompleter.empty())
- .build()
+ .aliases("tps")
+ .executor((platform, sender, resp, arguments) -> {
+ TpsCalculator tpsCalculator = platform.getTpsCalculator();
+ if (tpsCalculator != null) {
+ resp.replyPrefixed(TextComponent.of("TPS from last 5s, 10s, 1m, 5m, 15m:"));
+ resp.replyPrefixed(TextComponent.builder(" ").append(tpsCalculator.toFormattedComponent()).build());
+ } else {
+ resp.replyPrefixed(TextComponent.of("Not supported!"));
+ }
+ })
+ .tabCompleter(Command.TabCompleter.empty())
+ .build()
);
consumer.accept(Command.<S>builder()
.aliases("healthreport", "health", "ht")
.argumentUsage("memory", null)
.executor((platform, sender, resp, arguments) -> {
- resp.replyPrefixed("&7Generating server health report...");
+ resp.replyPrefixed(TextComponent.of("Generating server health report..."));
platform.getPlugin().runAsync(() -> {
- List<String> report = new ArrayList<>(15);
- report.add("");
+ List<Component> report = new ArrayList<>(15);
+ report.add(Component.empty());
TpsCalculator tpsCalculator = platform.getTpsCalculator();
if (tpsCalculator != null) {
- report.add("&8&l>&6 TPS from last 5s, 10s, 1m, 5m, 15m:");
- report.add(" " + tpsCalculator.toFormattedString());
- report.add("");
+ report.add(TextComponent.builder()
+ .append(TextComponent.builder(">").color(TextColor.DARK_GRAY).decoration(TextDecoration.BOLD, true).build())
+ .append(Component.space())
+ .append(TextComponent.of("TPS from last 5s, 10s, 1m, 5m, 15m:", TextColor.GOLD))
+ .build()
+ );
+ report.add(TextComponent.builder(" ").append(tpsCalculator.toFormattedComponent()).build());
+ report.add(Component.empty());
}
MemoryMXBean memoryMXBean = ManagementFactory.getMemoryMXBean();
-
MemoryUsage heapUsage = memoryMXBean.getHeapMemoryUsage();
- report.add("&8&l>&6 Memory usage: ");
- report.add(" &f" + formatBytes(heapUsage.getUsed()) + " &7/ &f" + formatBytes(heapUsage.getMax()) +
- " &7(&a" + percent(heapUsage.getUsed(), heapUsage.getMax()) + "&7)");
- report.add(" " + generateMemoryUsageDiagram(heapUsage, 40));
- report.add("");
+ report.add(TextComponent.builder()
+ .append(TextComponent.builder(">").color(TextColor.DARK_GRAY).decoration(TextDecoration.BOLD, true).build())
+ .append(Component.space())
+ .append(TextComponent.of("Memory usage:", TextColor.GOLD))
+ .build()
+ );
+ report.add(TextComponent.builder(" ")
+ .append(TextComponent.of(formatBytes(heapUsage.getUsed()), TextColor.WHITE))
+ .append(Component.space())
+ .append(TextComponent.of("/", TextColor.GRAY))
+ .append(Component.space())
+ .append(TextComponent.of(formatBytes(heapUsage.getMax()), TextColor.WHITE))
+ .append(TextComponent.of(" "))
+ .append(TextComponent.of("(", TextColor.GRAY))
+ .append(TextComponent.of(percent(heapUsage.getUsed(), heapUsage.getMax()), TextColor.GREEN))
+ .append(TextComponent.of(")", TextColor.GRAY))
+ .build()
+ );
+ report.add(TextComponent.builder(" ").append(generateMemoryUsageDiagram(heapUsage, 40)).build());
+ report.add(Component.empty());
if (arguments.boolFlag("memory")) {
MemoryUsage nonHeapUsage = memoryMXBean.getNonHeapMemoryUsage();
- report.add("&8&l>&6 Non-heap memory usage: ");
- report.add(" &f" + formatBytes(nonHeapUsage.getUsed()));
- report.add("");
+ report.add(TextComponent.builder()
+ .append(TextComponent.builder(">").color(TextColor.DARK_GRAY).decoration(TextDecoration.BOLD, true).build())
+ .append(Component.space())
+ .append(TextComponent.of("Non-heap memory usage:", TextColor.GOLD))
+ .build()
+ );
+ report.add(TextComponent.builder(" ")
+ .append(TextComponent.of(formatBytes(nonHeapUsage.getUsed()), TextColor.WHITE))
+ .build()
+ );
+ report.add(Component.empty());
List<MemoryPoolMXBean> memoryPoolMXBeans = ManagementFactory.getMemoryPoolMXBeans();
for (MemoryPoolMXBean memoryPool : memoryPoolMXBeans) {
@@ -103,16 +134,37 @@ public class HealthModule<S> implements CommandModule<S> {
usage = new MemoryUsage(usage.getInit(), usage.getUsed(), usage.getCommitted(), usage.getCommitted());
}
- report.add("&8&l>&6 " + memoryPool.getName() + " pool usage: ");
- report.add(" &f" + formatBytes(usage.getUsed()) + " &7/ &f" + formatBytes(usage.getMax()) +
- " &7(&a" + percent(usage.getUsed(), usage.getMax()) + "&7)");
- report.add(" " + generateMemoryPoolDiagram(usage, collectionUsage,40));
-
+ report.add(TextComponent.builder()
+ .append(TextComponent.builder(">").color(TextColor.DARK_GRAY).decoration(TextDecoration.BOLD, true).build())
+ .append(Component.space())
+ .append(TextComponent.of(memoryPool.getName() + " pool usage:", TextColor.GOLD))
+ .build()
+ );
+ report.add(TextComponent.builder(" ")
+ .append(TextComponent.of(formatBytes(usage.getUsed()), TextColor.WHITE))
+ .append(Component.space())
+ .append(TextComponent.of("/", TextColor.GRAY))
+ .append(Component.space())
+ .append(TextComponent.of(formatBytes(usage.getMax()), TextColor.WHITE))
+ .append(TextComponent.of(" "))
+ .append(TextComponent.of("(", TextColor.GRAY))
+ .append(TextComponent.of(percent(usage.getUsed(), usage.getMax()), TextColor.GREEN))
+ .append(TextComponent.of(")", TextColor.GRAY))
+ .build()
+ );
+ report.add(TextComponent.builder(" ").append(generateMemoryPoolDiagram(usage, collectionUsage, 40)).build());
if (collectionUsage != null) {
- report.add(" &c- &7Usage at last GC: &f" + formatBytes(collectionUsage.getUsed()));
+ report.add(TextComponent.builder(" ")
+ .append(TextComponent.of("-", TextColor.RED))
+ .append(Component.space())
+ .append(TextComponent.of("Usage at last GC:", TextColor.GRAY))
+ .append(Component.space())
+ .append(TextComponent.of(formatBytes(collectionUsage.getUsed()), TextColor.WHITE))
+ .build()
+ );
}
- report.add("");
+ report.add(Component.empty());
}
}
@@ -120,17 +172,30 @@ public class HealthModule<S> implements CommandModule<S> {
double processCpuLoad = CpuMonitor.getProcessCpuLoad();
if (systemCpuLoad >= 0 || processCpuLoad >= 0) {
- report.add("&8&l>&6 CPU usage: ");
+ report.add(TextComponent.builder()
+ .append(TextComponent.builder(">").color(TextColor.DARK_GRAY).decoration(TextDecoration.BOLD, true).build())
+ .append(Component.space())
+ .append(TextComponent.of("CPU usage:", TextColor.GOLD))
+ .build()
+ );
if (systemCpuLoad >= 0) {
- report.add(" &7System: &a" + percent(systemCpuLoad, 1.0d));
- report.add(" " + generateCpuUsageDiagram(systemCpuLoad, 40));
- report.add("");
+ report.add(TextComponent.builder(" ")
+ .append(TextComponent.of("System: ", TextColor.GRAY))
+ .append(TextComponent.of(percent(systemCpuLoad, 1.0d), TextColor.GREEN))
+ .build()
+ );
+ report.add(TextComponent.builder(" ").append(generateCpuUsageDiagram(systemCpuLoad, 40)).build());
+ report.add(Component.empty());
}
if (processCpuLoad >= 0) {
- report.add(" &7Process: &a" + percent(processCpuLoad, 1.0d));
- report.add(" " + generateCpuUsageDiagram(processCpuLoad, 40));
- report.add("");
+ report.add(TextComponent.builder(" ")
+ .append(TextComponent.of("Process: ", TextColor.GRAY))
+ .append(TextComponent.of(percent(processCpuLoad, 1.0d), TextColor.GREEN))
+ .build()
+ );
+ report.add(TextComponent.builder(" ").append(generateCpuUsageDiagram(processCpuLoad, 40)).build());
+ report.add(Component.empty());
}
}
@@ -138,17 +203,33 @@ public class HealthModule<S> implements CommandModule<S> {
FileStore fileStore = Files.getFileStore(Paths.get("."));
long totalSpace = fileStore.getTotalSpace();
long usedSpace = totalSpace - fileStore.getUsableSpace();
-
- report.add("&8&l>&6 Disk usage: ");
- report.add(" &f" + formatBytes(usedSpace) + " &7/ &f" + formatBytes(totalSpace) +
- " &7(&a" + percent(usedSpace, totalSpace) + "&7)");
- report.add(" " + generateDiskUsageDiagram(usedSpace, totalSpace, 40));
- report.add("");
+ report.add(TextComponent.builder()
+ .append(TextComponent.builder(">").color(TextColor.DARK_GRAY).decoration(TextDecoration.BOLD, true).build())
+ .append(Component.space())
+ .append(TextComponent.of("Disk usage:", TextColor.GOLD))
+ .build()
+ );
+ report.add(TextComponent.builder(" ")
+ .append(TextComponent.of(formatBytes(usedSpace), TextColor.WHITE))
+ .append(Component.space())
+ .append(TextComponent.of("/", TextColor.GRAY))
+ .append(Component.space())
+ .append(TextComponent.of(formatBytes(totalSpace), TextColor.WHITE))
+ .append(TextComponent.of(" "))
+ .append(TextComponent.of("(", TextColor.GRAY))
+ .append(TextComponent.of(percent(usedSpace, totalSpace), TextColor.GREEN))
+ .append(TextComponent.of(")", TextColor.GRAY))
+ .build()
+ );
+ report.add(TextComponent.builder(" ").append(generateDiskUsageDiagram(usedSpace, totalSpace, 40)).build());
+ report.add(Component.empty());
} catch (IOException e) {
e.printStackTrace();
}
- report.forEach(resp::reply);
+ TextComponent.Builder builder = TextComponent.builder();
+ report.forEach(line -> builder.append(line).append(Component.newline()));
+ resp.reply(builder.build());
});
})
.tabCompleter((platform, sender, arguments) -> TabCompleter.completeForOpts(arguments, "--memory"))
@@ -161,7 +242,7 @@ public class HealthModule<S> implements CommandModule<S> {
return (int) percent + "%";
}
- private static String generateMemoryUsageDiagram(MemoryUsage usage, int length) {
+ private static TextComponent generateMemoryUsageDiagram(MemoryUsage usage, int length) {
double used = usage.getUsed();
double committed = usage.getCommitted();
double max = usage.getMax();
@@ -169,18 +250,23 @@ public class HealthModule<S> implements CommandModule<S> {
int usedChars = (int) ((used * length) / max);
int committedChars = (int) ((committed * length) / max);
- String line = "&7" + Strings.repeat("/", usedChars);
+ TextComponent.Builder line = TextComponent.builder(Strings.repeat("/", usedChars)).color(TextColor.GRAY);
if (committedChars > usedChars) {
- line += Strings.repeat(" ", (committedChars - usedChars) - 1) + "&e|";
+ line.append(TextComponent.of(Strings.repeat(" ", (committedChars - usedChars) - 1)));
+ line.append(TextComponent.of("|", TextColor.YELLOW));
}
if (length > committedChars) {
- line += Strings.repeat(" ", (length - committedChars));
+ line.append(TextComponent.of(Strings.repeat(" ", (length - committedChars))));
}
- return "&8[" + line + "&8]";
+ return TextComponent.builder()
+ .append(TextComponent.of("[", TextColor.DARK_GRAY))
+ .append(line.build())
+ .append(TextComponent.of("]", TextColor.DARK_GRAY))
+ .build();
}
- private static String generateMemoryPoolDiagram(MemoryUsage usage, MemoryUsage collectionUsage, int length) {
+ private static TextComponent generateMemoryPoolDiagram(MemoryUsage usage, MemoryUsage collectionUsage, int length) {
double used = usage.getUsed();
double collectionUsed = used;
if (collectionUsage != null) {
@@ -193,32 +279,45 @@ public class HealthModule<S> implements CommandModule<S> {
int collectionUsedChars = (int) ((collectionUsed * length) / max);
int committedChars = (int) ((committed * length) / max);
- String line = "&7" + Strings.repeat("/", collectionUsedChars);
+ TextComponent.Builder line = TextComponent.builder(Strings.repeat("/", collectionUsedChars)).color(TextColor.GRAY);
+
if (usedChars > collectionUsedChars) {
- line += "&c|&7" + Strings.repeat("/", (usedChars - collectionUsedChars) - 1);
+ line.append(TextComponent.of("|", TextColor.RED));
+ line.append(TextComponent.of(Strings.repeat("/", (usedChars - collectionUsedChars) - 1), TextColor.GRAY));
}
if (committedChars > usedChars) {
- line += Strings.repeat(" ", (committedChars - usedChars) - 1) + "&e|";
+ line.append(TextComponent.of(Strings.repeat(" ", (committedChars - usedChars) - 1)));
+ line.append(TextComponent.of("|", TextColor.YELLOW));
}
if (length > committedChars) {
- line += Strings.repeat(" ", (length - committedChars));
+ line.append(TextComponent.of(Strings.repeat(" ", (length - committedChars))));
}
- return "&8[" + line + "&8]";
+ return TextComponent.builder()
+ .append(TextComponent.of("[", TextColor.DARK_GRAY))
+ .append(line.build())
+ .append(TextComponent.of("]", TextColor.DARK_GRAY))
+ .build();
}
- private static String generateCpuUsageDiagram(double usage, int length) {
+ private static TextComponent generateCpuUsageDiagram(double usage, int length) {
int usedChars = (int) ((usage * length));
-
- String line = "&7" + Strings.repeat("/", usedChars) + Strings.repeat(" ", length - usedChars);
- return "&8[" + line + "&8]";
+ String line = Strings.repeat("/", usedChars) + Strings.repeat(" ", length - usedChars);
+ return TextComponent.builder()
+ .append(TextComponent.of("[", TextColor.DARK_GRAY))
+ .append(TextComponent.of(line, TextColor.GRAY))
+ .append(TextComponent.of("]", TextColor.DARK_GRAY))
+ .build();
}
- private static String generateDiskUsageDiagram(double used, double max, int length) {
+ private static TextComponent generateDiskUsageDiagram(double used, double max, int length) {
int usedChars = (int) ((used * length) / max);
-
- String line = "&7" + Strings.repeat("/", usedChars) + Strings.repeat(" ", length - usedChars);
- return "&8[" + line + "&8]";
+ String line = Strings.repeat("/", usedChars) + Strings.repeat(" ", length - usedChars);
+ return TextComponent.builder()
+ .append(TextComponent.of("[", TextColor.DARK_GRAY))
+ .append(TextComponent.of(line, TextColor.GRAY))
+ .append(TextComponent.of("]", TextColor.DARK_GRAY))
+ .build();
}
private static String formatBytes(long bytes) {
diff --git a/spark-common/src/main/java/me/lucko/spark/common/command/modules/MemoryModule.java b/spark-common/src/main/java/me/lucko/spark/common/command/modules/MemoryModule.java
index 583b1b6..e2d817d 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/command/modules/MemoryModule.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/command/modules/MemoryModule.java
@@ -26,6 +26,9 @@ import me.lucko.spark.common.command.CommandModule;
import me.lucko.spark.common.command.tabcomplete.TabCompleter;
import me.lucko.spark.common.heapdump.HeapDump;
import me.lucko.spark.common.heapdump.HeapDumpSummary;
+import net.kyori.text.TextComponent;
+import net.kyori.text.event.ClickEvent;
+import net.kyori.text.format.TextColor;
import okhttp3.MediaType;
import java.io.IOException;
@@ -45,32 +48,38 @@ public class MemoryModule<S> implements CommandModule<S> {
.argumentUsage("run-gc-before", null)
.executor((platform, sender, resp, arguments) -> {
platform.getPlugin().runAsync(() -> {
- if (arguments.boolFlag("run-gc-before")) {
- resp.broadcastPrefixed("&7Running garbage collector...");
- System.gc();
- }
-
- resp.broadcastPrefixed("&7Creating a new heap dump summary, please wait...");
-
- HeapDumpSummary heapDump;
- try {
- heapDump = HeapDumpSummary.createNew();
- } catch (Exception e) {
- resp.broadcastPrefixed("&cAn error occurred whilst inspecting the heap.");
- e.printStackTrace();
- return;
- }
-
- byte[] output = heapDump.formCompressedDataPayload();
- try {
- String key = SparkPlatform.BYTEBIN_CLIENT.postContent(output, JSON_TYPE, false).key();
- resp.broadcastPrefixed("&6Heap dump summmary output:");
- resp.broadcastLink(SparkPlatform.VIEWER_URL + key);
- } catch (IOException e) {
- resp.broadcastPrefixed("&cAn error occurred whilst uploading the data.");
- e.printStackTrace();
- }
- });
+ if (arguments.boolFlag("run-gc-before")) {
+ resp.broadcastPrefixed(TextComponent.of("Running garbage collector..."));
+ System.gc();
+ }
+
+ resp.broadcastPrefixed(TextComponent.of("Creating a new heap dump summary, please wait..."));
+
+ HeapDumpSummary heapDump;
+ try {
+ heapDump = HeapDumpSummary.createNew();
+ } catch (Exception e) {
+ resp.broadcastPrefixed(TextComponent.of("An error occurred whilst inspecting the heap.", TextColor.RED));
+ e.printStackTrace();
+ return;
+ }
+
+ byte[] output = heapDump.formCompressedDataPayload();
+ try {
+ String key = SparkPlatform.BYTEBIN_CLIENT.postContent(output, JSON_TYPE, false).key();
+ String url = SparkPlatform.VIEWER_URL + key;
+
+ resp.broadcastPrefixed(TextComponent.of("Heap dump summmary output:", TextColor.GOLD));
+ resp.broadcast(TextComponent.builder(url)
+ .color(TextColor.GRAY)
+ .clickEvent(new ClickEvent(ClickEvent.Action.OPEN_URL, url))
+ .build()
+ );
+ } catch (IOException e) {
+ resp.broadcastPrefixed(TextComponent.of("An error occurred whilst uploading the data.", TextColor.RED));
+ e.printStackTrace();
+ }
+ });
})
.tabCompleter((platform, sender, arguments) -> TabCompleter.completeForOpts(arguments, "--run-gc-before"))
.build()
@@ -81,35 +90,34 @@ public class MemoryModule<S> implements CommandModule<S> {
.argumentUsage("run-gc-before", null)
.argumentUsage("include-non-live", null)
.executor((platform, sender, resp, arguments) -> {
- // ignore
platform.getPlugin().runAsync(() -> {
- Path pluginFolder = platform.getPlugin().getPluginFolder();
- try {
- Files.createDirectories(pluginFolder);
- } catch (IOException e) {
- // ignore
- }
-
- Path file = pluginFolder.resolve("heap-" + DateTimeFormatter.ofPattern("yyyy-MM-dd_HH.mm.ss").format(LocalDateTime.now()) + (HeapDump.isOpenJ9() ? ".phd" : ".hprof"));
- boolean liveOnly = !arguments.boolFlag("include-non-live");
-
- if (arguments.boolFlag("run-gc-before")) {
- resp.broadcastPrefixed("&7Running garbage collector...");
- System.gc();
- }
-
- resp.broadcastPrefixed("&7Creating a new heap dump, please wait...");
-
- try {
- HeapDump.dumpHeap(file, liveOnly);
- } catch (Exception e) {
- resp.broadcastPrefixed("&cAn error occurred whilst creating a heap dump.");
- e.printStackTrace();
- return;
- }
-
- resp.broadcastPrefixed("&6Heap dump written to: " + file.toString());
- });
+ Path pluginFolder = platform.getPlugin().getPluginFolder();
+ try {
+ Files.createDirectories(pluginFolder);
+ } catch (IOException e) {
+ // ignore
+ }
+
+ Path file = pluginFolder.resolve("heap-" + DateTimeFormatter.ofPattern("yyyy-MM-dd_HH.mm.ss").format(LocalDateTime.now()) + (HeapDump.isOpenJ9() ? ".phd" : ".hprof"));
+ boolean liveOnly = !arguments.boolFlag("include-non-live");
+
+ if (arguments.boolFlag("run-gc-before")) {
+ resp.broadcastPrefixed(TextComponent.of("Running garbage collector..."));
+ System.gc();
+ }
+
+ resp.broadcastPrefixed(TextComponent.of("Creating a new heap dump, please wait..."));
+
+ try {
+ HeapDump.dumpHeap(file, liveOnly);
+ } catch (Exception e) {
+ resp.broadcastPrefixed(TextComponent.of("An error occurred whilst creating a heap dump.", TextColor.RED));
+ e.printStackTrace();
+ return;
+ }
+
+ resp.broadcastPrefixed(TextComponent.of("Heap dump written to: " + file.toString(), TextColor.GOLD));
+ });
})
.tabCompleter((platform, sender, arguments) -> TabCompleter.completeForOpts(arguments, "--run-gc-before", "--include-non-live"))
.build()
diff --git a/spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java b/spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java
index 88430f9..e450b0b 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java
+++ b/