一棒打死重构改名的

.gitignore

@@ -21,4 +21,4 @@
 hs_err_pid*
 .gradle/4.3.1/
 .idea
-target
+target

pom.xml

@@ -72,12 +72,6 @@
             <artifactId>activejdbc</artifactId>
             <version>2.0</version>
         </dependency>
-        <dependency>
-            <groupId>javax.servlet</groupId>
-            <artifactId>servlet-api</artifactId>
-            <version>2.5</version>
-            <scope>provided</scope>
-        </dependency>
         <dependency>
             <groupId>com.h2database</groupId>
             <artifactId>h2</artifactId>

src/main/java/com/ilummc/tlib/inject/TConfigWatcher.java

@@ -19,7 +19,8 @@ import java.util.function.Consumer;
  */
 public class TConfigWatcher {
 
-    private final ScheduledExecutorService service = Executors.newScheduledThreadPool(1, new BasicThreadFactory.Builder().namingPattern("tconfig-watcher-schedule-pool-%d").daemon(true).build());
+    private final ScheduledExecutorService service = Executors.newScheduledThreadPool(1,
+            new BasicThreadFactory.Builder().namingPattern("TConfigWatcherService-%d").build());
 
     private final Map<WatchService, Triple<File, Object, Consumer<Object>>> map = new HashMap<>();
 
@@ -54,7 +55,16 @@ public class TConfigWatcher {
 
     public void removeListener(File file) {
         synchronized (map) {
-            map.entrySet().removeIf(entry -> entry.getValue().getLeft().equals(file));
+            map.entrySet().removeIf(entry -> {
+                if (entry.getValue().getLeft().equals(file)) {
+                    try {
+                        entry.getKey().close();
+                    } catch (IOException ignored) {
+                    }
+                    return true;
+                }
+                return false;
+            });
         }
     }
 

src/main/java/com/ilummc/tlib/resources/TLocaleInstance.java

@@ -24,7 +24,6 @@ class TLocaleInstance {
 
     private final Map<String, List<TLocaleSendable>> map = new HashMap<>();
     private final Plugin plugin;
-    private int updateNodes;
 
     TLocaleInstance(Plugin plugin) {
         this.plugin = plugin;
@@ -47,10 +46,6 @@ class TLocaleInstance {
         return plugin;
     }
 
-    public int getUpdateNodes() {
-        return updateNodes;
-    }
-
     public void sendTo(String path, CommandSender sender, String... args) {
         try {
             map.getOrDefault(path, ImmutableList.of(TLocaleSendable.getEmpty(path))).forEach(sendable -> {
@@ -75,32 +70,34 @@ class TLocaleInstance {
         return map.getOrDefault(path, ImmutableList.of(TLocaleSendable.getEmpty(path))).get(0).asStringList(args);
     }
 
-    public void load(YamlConfiguration configuration) {
-        updateNodes = 0;
-        configuration.getKeys(true).forEach(s -> {
-            boolean isCover = false;
-            Object object = configuration.get(s);
-            if (object instanceof TLocaleSendable) {
-                isCover = map.put(s, Collections.singletonList((TLocaleSendable) object)) != null;
-            } else if (object instanceof List && !((List) object).isEmpty()) {
-                isCover = map.put(s, ((List<?>) object).stream().map(TO_SENDABLE).collect(Collectors.toList())) != null;
-            } else if (!(object instanceof ConfigurationSection)) {
-                String str = String.valueOf(object);
-                isCover = map.put(s, Collections.singletonList(str.length() == 0 ? TLocaleSendable.getEmpty() : TLocaleText.of(str))) != null;
-            }
-            if (isCover) {
-                updateNodes++;
-            }
-        });
-    }
-
     private static final Function<Object, TLocaleSendable> TO_SENDABLE = o -> {
         if (o instanceof TLocaleSendable) {
             return ((TLocaleSendable) o);
-        } else if (o instanceof String) {
+        } else if (o instanceof String || (o instanceof List && isListString(((List) o)))) {
-            return TLocaleText.of(((String) o));
+            return TLocaleText.of(o);
         } else {
             return TLocaleText.of(String.valueOf(o));
         }
     };
+
+    private static boolean isListString(List list) {
+        for (Object o : list) {
+            if (!(o instanceof String)) return false;
+        }
+        return true;
+    }
+
+    public void load(YamlConfiguration configuration) {
+        configuration.getKeys(true).forEach(s -> {
+            Object object = configuration.get(s);
+            if (object instanceof TLocaleSendable) {
+                map.put(s, Collections.singletonList((TLocaleSendable) object));
+            } else if (object instanceof List && !((List) object).isEmpty()) {
+                map.put(s, ((List<?>) object).stream().map(TO_SENDABLE).collect(Collectors.toList()));
+            } else if (!(object instanceof ConfigurationSection)) {
+                String str = String.valueOf(object);
+                map.put(s, Collections.singletonList(str.length() == 0 ? TLocaleSendable.getEmpty() : TLocaleText.of(str)));
+            }
+        });
+    }
 }

src/main/java/com/ilummc/tlib/resources/TLocaleLoader.java

@@ -1,5 +1,6 @@
 package com.ilummc.tlib.resources;
 
+import com.google.common.io.Files;
 import com.ilummc.tlib.TLib;
 import com.ilummc.tlib.annotations.TLocalePlugin;
 import com.ilummc.tlib.logger.TLogger;
@@ -14,14 +15,14 @@ import org.bukkit.command.CommandSender;
 import org.bukkit.configuration.file.YamlConfiguration;
 import org.bukkit.configuration.serialization.ConfigurationSerialization;
 import org.bukkit.plugin.Plugin;
+import org.yaml.snakeyaml.DumperOptions;
+import org.yaml.snakeyaml.Yaml;
 
 import java.io.File;
+import java.io.IOException;
 import java.io.InputStream;
 import java.nio.charset.Charset;
-import java.util.Collections;
+import java.util.*;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
 
 public class TLocaleLoader {
@@ -75,23 +76,20 @@ public class TLocaleLoader {
             if (isLoadLocale(plugin, isCover)) {
                 // 获取文件
                 File localeFile = getLocaleFile(plugin);
-                if (localeFile == null) {
-                    return;
-                }
 
                 // 加载文件
                 infoLogger("TRY-LOADING-LANG", plugin.getName(), localeFile.getName());
-                YamlConfiguration localeConfiguration = ConfigUtils.loadYaml(plugin, localeFile);
+                Map<String, Object> originMap = getLocaleAtStream(plugin, localeFile);
-                YamlConfiguration localeConfigurationAtStream = getLocaleAtStream(plugin, localeFile);
+
+                TLib.getTLib().getConfigWatcher().removeListener(localeFile);
 
                 // 载入配置
-                loadPluginLocale(plugin, localeFile, localeConfiguration, localeConfigurationAtStream);
+                updateAndLoad(plugin, localeFile, originMap);
 
                 // 注册监听
-                TLib.getTLib().getConfigWatcher().removeListener(localeFile);
                 TLib.getTLib().getConfigWatcher().addListener(localeFile, null, obj -> {
                     infoLogger("RELOADING-LANG", plugin.getName());
-                    loadPluginLocale(plugin, localeFile, ConfigUtils.loadYaml(plugin, localeFile), getLocaleAtStream(plugin, localeFile));
+                    updateAndLoad(plugin, localeFile, getLocaleAtStream(plugin, localeFile));
                 });
             }
         } catch (Exception e) {
@@ -117,22 +115,22 @@ public class TLocaleLoader {
 
     private static File getLocaleFile(Plugin plugin) {
         releaseLocales(plugin);
-        return getLocalePriority().stream().map(localeName -> new File(plugin.getDataFolder(), "lang/" + localeName + ".yml")).filter(File::exists).findFirst().orElse(null);
+        return getLocalePriority().stream().map(localeName -> new File(plugin.getDataFolder(), "lang/" + localeName + ".yml")).filter(File::exists).findFirst().orElseThrow(NullPointerException::new);
     }
 
     private static void releaseLocales(Plugin plugin) {
         getLocalePriority().stream().filter(localeName -> !new File(plugin.getDataFolder(), "lang/" + localeName + ".yml").exists() && plugin.getResource("lang/" + localeName + ".yml") != null).forEach(localeName -> plugin.saveResource("lang/" + localeName + ".yml", true));
     }
 
-    public static boolean isLocaleLoaded(Plugin plugin) {
+    private static boolean isLocaleLoaded(Plugin plugin) {
         return map.containsKey(plugin.getName());
     }
 
-    public static boolean isDependWithTabooLib(Plugin plugin) {
+    private static boolean isDependWithTabooLib(Plugin plugin) {
         return plugin.getClass().getAnnotation(TLocalePlugin.class) != null || plugin.getDescription().getDepend().contains(Main.getInst().getName()) || plugin.getDescription().getSoftDepend().contains(Main.getInst().getName());
     }
 
-    public static List<String> getLocalePriority() {
+    private static List<String> getLocalePriority() {
         return Main.getInst().getConfig().contains("LOCALE.PRIORITY") ? Main.getInst().getConfig().getStringList("LOCALE.PRIORITY") : Collections.singletonList("zh_CN");
     }
 
@@ -142,29 +140,63 @@ public class TLocaleLoader {
         return instance;
     }
 
-    private static YamlConfiguration getLocaleAtStream(Plugin plugin, File localeFile) {
+    private static Map<String, Object> getLocaleAtStream(Plugin plugin, File localeFile) {
         InputStream localeInputSteam = plugin.getClass().getResourceAsStream("/lang/" + localeFile.getName());
         try {
             String yamlText = new String(IO.readFully(localeInputSteam), Charset.forName("utf-8"));
-            YamlConfiguration yaml = new YamlConfiguration();
+            Object load = new Yaml().load(yamlText);
-            yaml.loadFromString(yamlText);
+            return load instanceof Map ? (Map<String, Object>) load : new HashMap<>(0);
-            return yaml;
+        } catch (Exception e) {
-        } catch (Exception ignored) {
+            return new HashMap<>(0);
-            return null;
         }
     }
 
-    private static void loadPluginLocale(Plugin plugin, File localeFile, YamlConfiguration localeConfiguration, YamlConfiguration localeConfigurationAtStream) {
+    private static Map<String, Object> currentLocaleMap(File localeFile) {
-        TLocaleInstance localeInstance = getLocaleInstance(plugin);
+        try {
-        boolean versionOutOfDate = isVersionOutOfDate(localeConfiguration, localeConfigurationAtStream);
+            Object load = new Yaml().load(Files.toString(localeFile, Charset.forName("utf-8")));
-        if (versionOutOfDate) {
+            return load instanceof Map ? (Map<String, Object>) load : new HashMap<>(0);
-            localeInstance.load(localeConfigurationAtStream);
+        } catch (Exception e) {
+            return new HashMap<>(0);
         }
+    }
+
+    private static int compareAndSet(Map<String, Object> origin, Map<String, Object> current, File file) {
+        int i = compareMaps(origin, current);
+        DumperOptions options = new DumperOptions();
+        options.setDefaultFlowStyle(DumperOptions.FlowStyle.BLOCK);
+        options.setAllowUnicode(false);
+        Yaml yaml = new Yaml(options);
+        String dump = yaml.dump(current);
+        try {
+            Files.write(dump.getBytes(Charset.forName("utf-8")), file);
+        } catch (IOException ignored) {
+        }
+        return i;
+    }
+
+    @SuppressWarnings("unchecked")
+    private static int compareMaps(Map<String, Object> origin, Map<String, Object> current) {
+        int res = 0;
+        for (Map.Entry<String, Object> entry : origin.entrySet()) {
+            if (current.putIfAbsent(entry.getKey(), entry.getValue()) != null) {
+                if (entry.getValue() instanceof Map && !((Map) entry.getValue()).containsKey("==") && current.get(entry.getKey()) instanceof Map) {
+                    res += compareMaps((Map<String, Object>) entry.getValue(), (Map<String, Object>) current.get(entry.getKey()));
+                }
+            } else ++res;
+        }
+        return res;
+    }
+
+    private static void updateAndLoad(Plugin plugin, File localeFile, Map<String, Object> originMap) {
+        Map<String, Object> currentMap = currentLocaleMap(localeFile);
+        int update = compareAndSet(originMap, currentMap, localeFile);
+        TLocaleInstance localeInstance = getLocaleInstance(plugin);
+        YamlConfiguration localeConfiguration = ConfigUtils.loadYaml(plugin, localeFile);
         localeInstance.load(localeConfiguration);
-        if (!versionOutOfDate || localeInstance.size() - localeInstance.getUpdateNodes() == 0) {
+        if (update == 0) {
             infoLogger("SUCCESS-LOADING-LANG-NORMAL", plugin.getName(), localeFile.getName().split("\\.")[0], String.valueOf(localeInstance.size()));
         } else {
-            infoLogger("SUCCESS-LOADING-LANG-UPDATE", plugin.getName(), localeFile.getName().split("\\.")[0], String.valueOf(localeInstance.size()), String.valueOf(localeInstance.size() - localeInstance.getUpdateNodes()));
+            infoLogger("SUCCESS-LOADING-LANG-UPDATE", plugin.getName(), localeFile.getName().split("\\.")[0], String.valueOf(localeInstance.size()), String.valueOf(update));
         }
     }
 }

src/main/java/com/ilummc/tlib/resources/type/TLocaleJson.java

@@ -40,28 +40,41 @@ public class TLocaleJson implements TLocaleSendable, ConfigurationSerializable {
 
     public static TLocaleJson valueOf(Map<String, Object> map) {
         boolean papi = (boolean) map.getOrDefault("papi", Main.getInst().getConfig().getBoolean("LOCALE.USE_PAPI", false));
+
+        // text 里面的东西
         List<String> textList = getTextList(map.getOrDefault("text", "Empty Node"));
+
+        // 分析 args 并替换
         Object argsObj = map.get("args");
         if (argsObj instanceof Map) {
             Map<String, Object> section = new HashMap<>(((Map<?, ?>) argsObj).size());
+
+            // valueOf(k) 是因为这个键可能加载为一个 Integer 导致 contains(String) 返回 false
             ((Map<?, ?>) argsObj).forEach((k, v) -> section.put(String.valueOf(k), v));
             List<BaseComponent[]> collect = textList.stream().map(s -> {
                 int index = 0;
                 String[] template = pattern.split(s);
                 Matcher matcher = pattern.matcher(s);
+                // 有可能开头和结尾是替换文本，所以做个特判
                 List<BaseComponent> builder = template.length > index ? new ArrayList<>(Arrays.asList(TextComponent.fromLegacyText(template[index++]))) : new ArrayList<>();
                 while (matcher.find()) {
                     String replace = matcher.group();
+                    // 假的 <@>
                     if (replace.length() <= 2) {
                         continue;
                     }
+                    // 真的 <@xxx>
                     replace = replace.substring(1, replace.length() - 1);
                     String[] split = replace.split("@");
+                    // @ 前面的字符串
                     String text = split.length > 1 ? split[0] : "";
+                    // @ 后面的节点名
                     String node = split.length > 1 ? split[1] : split[0];
+                    // 如果 args 有这个 xxx
                     if (section.containsKey(node)) {
                         Map<String, Object> arg = (Map<String, Object>) section.get(node);
                         text = ChatColor.translateAlternateColorCodes('&', String.valueOf(arg.getOrDefault("text", text)));
+                        // 可能有很多个 BaseComponent，于是为每个 component 单独设置各种事件
                         BaseComponent[] component = TextComponent.fromLegacyText(text);
                         arg.forEach((key, value) -> {
                             if ("suggest".equalsIgnoreCase(key)) {
@@ -72,11 +85,14 @@ public class TLocaleJson implements TLocaleSendable, ConfigurationSerializable {
                                 Arrays.stream(component).forEach(baseComponent -> baseComponent.setHoverEvent(new HoverEvent(HoverEvent.Action.SHOW_TEXT, new ComponentBuilder(ChatColor.translateAlternateColorCodes('&', String.valueOf(value))).create())));
                             }
                         });
+                        // 添加到原来的 list 里面
                         builder.addAll(Arrays.asList(component));
                     } else {
+                        // 这个参数节点并没有找到，于是随便放点字符串进去
                         builder.addAll(Arrays.asList(TextComponent.fromLegacyText(text)));
                         TLib.getTLib().getLogger().warn(Strings.replaceWithOrder(TLib.getInternalLanguage().getString("MISSING-ARGUMENT"), node));
                     }
+                    // 有可能一开头就是 <@xxx>，然后 split 出来就少了一些，于是直接加上
                     if (index < template.length) {
                         builder.addAll(Arrays.asList(TextComponent.fromLegacyText(template[index++])));
                     }

src/main/java/com/ilummc/tlib/resources/type/TLocaleText.java

@@ -63,6 +63,10 @@ public class TLocaleText implements TLocaleSendable, ConfigurationSerializable {
         return new TLocaleText(ChatColor.translateAlternateColorCodes('&', s), Main.getInst().getConfig().getBoolean("LOCALE.USE_PAPI", false));
     }
 
+    public static TLocaleText of(Object o) {
+        return o instanceof String ? of(((String) o)) : new TLocaleText(o, false);
+    }
+
     @Override
     public void sendTo(CommandSender sender, String... args) {
         if (text instanceof String) {

src/main/resources/lang/zh_CN.yml

@@ -462,6 +462,4 @@ COMMANDS:
 
 DATABASE:
   CONNECTION-ESTABLISHED: '成功连接到 {0} 数据库，连接池大小 {1}'
-  CONNECTION-ERROR: '连接到数据库错误：{0}'
+  CONNECTION-ERROR: '连接到数据库错误：{0}'
-      
-VERSION: 4.0