Merge pull request #31 from BentoBoxWorld/develop

Version 1.14.0

Author: tastybento

pom.xml

@@ -66,7 +66,7 @@
         <!-- Do not change unless you want different name for local builds. -->
         <build.number>-LOCAL</build.number>
         <!-- This allows to change between versions. -->
-        <build.version>1.13.0</build.version>
+        <build.version>1.14.0</build.version>
         <!-- Sonar Cloud -->
         <sonar.projectKey>BentoBoxWorld_addon-invSwitcher</sonar.projectKey>
         <sonar.organization>bentobox-world</sonar.organization>

src/main/java/com/wasteofplastic/invswitcher/Store.java

@@ -31,6 +31,7 @@
 import java.util.Map;
 import java.util.Objects;
 import java.util.UUID;
+import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
 
 import org.bukkit.Bukkit;
@@ -56,6 +57,7 @@
  *
  */
 public class Store {
+    private static final Material[] MAT = Material.values();
     private static final CharSequence THE_END = "_the_end";
     private static final CharSequence NETHER = "_nether";
     private final Database<InventoryStorage> database;
@@ -247,50 +249,56 @@ public void storeAndSave(Player player, World world) {
             store.setEnderChest(overworldName, contents);
         }
         if (addon.getSettings().isStatistics()) {
-            saveStats(store, player, overworldName);
+            saveStats(store, player, overworldName).thenAccept(database::saveObjectAsync);
+            return;
         }
         database.saveObjectAsync(store);
     }
 
-    private void saveStats(InventoryStorage store, Player player, String worldName) {
+    private CompletableFuture<InventoryStorage> saveStats(InventoryStorage store, Player player, String worldName) {
+        CompletableFuture<InventoryStorage> result = new CompletableFuture<>();
         store.clearStats(worldName);
         // Statistics
-        Arrays.stream(Statistic.values()).forEach(s -> {
-            Map<Material, Integer> map;
-            Map<EntityType, Integer> entMap;
-            switch (s.getType()) {
-            case BLOCK -> {
-                map = Arrays.stream(Material.values()).filter(Material::isBlock).filter(m -> !m.isLegacy())
-                        .filter(m -> player.getStatistic(s, m) > 0)
-                        .collect(Collectors.toMap(k -> k, v -> player.getStatistic(s, v)));
-                if (!map.isEmpty()) {
-                    store.getBlockStats(worldName).put(s, map);
+        Bukkit.getScheduler().runTaskAsynchronously(addon.getPlugin(), () -> {
+            Arrays.stream(Statistic.values()).forEach(s -> {
+                Map<Material, Integer> map;
+                Map<EntityType, Integer> entMap;
+                switch (s.getType()) {
+                case BLOCK -> {
+                    map = Arrays.stream(MAT).filter(Material::isBlock).filter(m -> !m.isLegacy())
+                            .filter(m -> player.getStatistic(s, m) > 0)
+                            .collect(Collectors.toMap(k -> k, v -> player.getStatistic(s, v)));
+                    if (!map.isEmpty()) {
+                        store.getBlockStats(worldName).put(s, map);
+                    }
                 }
-            }
-            case ITEM -> {
-                map = Arrays.stream(Material.values()).filter(Material::isItem).filter(m -> !m.isLegacy())
-                        .filter(m -> player.getStatistic(s, m) > 0)
-                        .collect(Collectors.toMap(k -> k, v -> player.getStatistic(s, v)));
-                if (!map.isEmpty()) {
-                    store.getItemStats(worldName).put(s, map);
+                case ITEM -> {
+                    map = Arrays.stream(MAT).filter(Material::isItem).filter(m -> !m.isLegacy())
+                            .filter(m -> player.getStatistic(s, m) > 0)
+                            .collect(Collectors.toMap(k -> k, v -> player.getStatistic(s, v)));
+                    if (!map.isEmpty()) {
+                        store.getItemStats(worldName).put(s, map);
+                    }
                 }
-            }
-            case ENTITY -> {
-                entMap = Arrays.stream(EntityType.values()).filter(EntityType::isAlive)
-                        .filter(m -> player.getStatistic(s, m) > 0)
-                        .collect(Collectors.toMap(k -> k, v -> player.getStatistic(s, v)));
-                if (!entMap.isEmpty()) {
-                    store.getEntityStats(worldName).put(s, entMap);
+                case ENTITY -> {
+                    entMap = Arrays.stream(EntityType.values()).filter(EntityType::isAlive)
+                            .filter(m -> player.getStatistic(s, m) > 0)
+                            .collect(Collectors.toMap(k -> k, v -> player.getStatistic(s, v)));
+                    if (!entMap.isEmpty()) {
+                        store.getEntityStats(worldName).put(s, entMap);
+                    }
                 }
-            }
-            case UNTYPED -> {
-                int sc = player.getStatistic(s);
-                if (sc > 0) {
-                    store.getUntypedStats(worldName).put(s, sc);
+                case UNTYPED -> {
+                    int sc = player.getStatistic(s);
+                    if (sc > 0) {
+                        store.getUntypedStats(worldName).put(s, sc);
+                    }
                 }
-            }
-            }
+                }
+            });
+            result.complete(store);
         });
+        return result;
 
     }