2 files changed, 0 insertions, 110 deletions
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<ServerCommandSource> 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<String, Long> 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<LogEntry> collection = db.getCollection(
-//                            DatabaseUtil.DB_CONFIG.getTableName(), LogEntry.class
-//                    );
-//                    Collection<String> ids = VersionedLogEntryHelper.getLoggedSubjectsId(collection);
-//
-//                    // count by distinct subjects
-//                    Map<String, Long> 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<String, Long> countMap;
-
-        public BlameStat(Map<String, Long> countMap) {
-            this.countMap = countMap;
-        }
-
-        public Map<String, Long> 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);
-    }
-
-}