From 2b176ff0fb9b992d2fc6225e6476fa85c9fd7581 Mon Sep 17 00:00:00 2001 From: Keuin Date: Sat, 21 Oct 2023 20:22:30 +0800 Subject: remove stat command --- src/main/java/com/keuin/blame/Blame.java | 5 - .../com/keuin/blame/command/BlameStatCommand.java | 105 --------------------- 2 files changed, 110 deletions(-) delete mode 100644 src/main/java/com/keuin/blame/command/BlameStatCommand.java (limited to 'src/main/java') diff --git a/src/main/java/com/keuin/blame/Blame.java b/src/main/java/com/keuin/blame/Blame.java index 23a1830..4031e65 100644 --- a/src/main/java/com/keuin/blame/Blame.java +++ b/src/main/java/com/keuin/blame/Blame.java @@ -6,7 +6,6 @@ import com.keuin.blame.adapter.handler.EndGatewayTeleportHandler; import com.keuin.blame.adapter.handler.PlaceBlockHandler; import com.keuin.blame.command.BlameBlockCommand; import com.keuin.blame.command.BlameLimitCommand; -import com.keuin.blame.command.BlameStatCommand; import com.keuin.blame.config.BlameConfig; import com.keuin.blame.lookup.QueryExecutor; import com.keuin.blame.util.PrintUtil; @@ -127,10 +126,6 @@ public class Blame implements ModInitializer { .then(CommandManager.argument("limit", IntegerArgumentType.integer(1, 255)) .executes(BlameLimitCommand::setLimit))) ); - commandDispatcher.register( - CommandManager.literal("blame").then(CommandManager.literal("stat") - .executes(BlameStatCommand::showStat)) - ); }); } } diff --git a/src/main/java/com/keuin/blame/command/BlameStatCommand.java b/src/main/java/com/keuin/blame/command/BlameStatCommand.java deleted file mode 100644 index 34c3faf..0000000 --- a/src/main/java/com/keuin/blame/command/BlameStatCommand.java +++ /dev/null @@ -1,105 +0,0 @@ -package com.keuin.blame.command; - -import com.google.common.base.Strings; -import com.keuin.blame.data.entry.LogEntry; -import com.keuin.blame.util.DatabaseUtil; -import com.keuin.blame.util.PrintUtil; -import com.mojang.brigadier.context.CommandContext; -import net.minecraft.server.command.ServerCommandSource; -import net.minecraft.util.Formatting; -import org.jetbrains.annotations.Nullable; - -import java.util.*; -import java.util.logging.Logger; - -public class BlameStatCommand { - - private static final Logger logger = Logger.getLogger(BlameStatCommand.class.getName()); - - public static int showStat(CommandContext context) { - PrintUtil.message(context, Formatting.ITALIC, "Collecting statistics. This may take a few seconds..."); - showStat(stat -> { - PrintUtil.Printer sb = PrintUtil.newPrinter(); - if (stat != null) { - sb.append("Logs grouped by subjects:").newline(); - boolean isFirst = true; - for (Map.Entry entry : stat.getCountMap().entrySet()) { - if (!isFirst) - sb.newline(); - isFirst = false; - final String subjectId = entry.getKey(); - final long count = entry.getValue(); - sb.append(Formatting.YELLOW, Optional.ofNullable(Strings.emptyToNull(subjectId)).orElse("null")) - .append(": ").append(count); - } - } else { - sb.append(Formatting.RED, "Failed to get statistics. Please refer to server log for more information."); - } - sb.sendTo(context); - }); - return Commands.SUCCESS; - } - - public static void showStat(ShowStatCallback callback) { - Objects.requireNonNull(callback); - new Thread(new Runnable() { - @Override - public void run() { - logger.info("Collecting statistics..."); -// try (final MongoClient mongoClient = MongoClients.create(DatabaseUtil.CLIENT_SETTINGS)) { -// final MongoDatabase db = mongoClient.getDatabase( -// DatabaseUtil.DB_CONFIG.getDatabaseName() -// ); -// final MongoCollection collection = db.getCollection( -// DatabaseUtil.DB_CONFIG.getTableName(), LogEntry.class -// ); -// Collection ids = VersionedLogEntryHelper.getLoggedSubjectsId(collection); -// -// // count by distinct subjects -// Map countMap = new HashMap<>(); -// for (String subjectId : ids) { -// long count = VersionedLogEntryHelper.countBySubjectId(collection, subjectId); -// countMap.put(subjectId, count); -// } -// -// // invoke callback -// callback.showStat(new BlameStat(countMap)); -// } catch (MongoClientException exception) { -// logger.severe("Failed when querying the database: " + exception + -// ". Failed to get statistics."); -// callback.showStat(null); -// } - } - }, "BlameStatCommandThread").start(); - } - - public static class BlameStat { - private final Map countMap; - - public BlameStat(Map countMap) { - this.countMap = countMap; - } - - public Map getCountMap() { - return Collections.unmodifiableMap(countMap); - } - - @Override - public boolean equals(Object o) { - if (this == o) return true; - if (o == null || getClass() != o.getClass()) return false; - BlameStat blameStat = (BlameStat) o; - return Objects.equals(countMap, blameStat.countMap); - } - - @Override - public int hashCode() { - return Objects.hash(countMap); - } - } - - public interface ShowStatCallback { - void showStat(@Nullable BlameStat stat); - } - -} -- cgit v1.2.3