Fix cache invalidation when group data changes (#1010)

common/src/main/java/me/lucko/luckperms/common/listener/AbstractConnectionListener.java

@@ -77,7 +77,8 @@ public abstract class AbstractConnectionListener implements ConnectionListener {
         User user = this.plugin.getStorage().loadUser(u, username).join();
         if (user == null) {
             throw new NullPointerException("User is null");
-        } else {
+        }
+
         // Setup defaults for the user
         boolean save = false;
         for (AssignmentRule rule : this.plugin.getConfiguration().get(ConfigKeys.DEFAULT_ASSIGNMENTS)) {
@@ -90,7 +91,6 @@ public abstract class AbstractConnectionListener implements ConnectionListener {
         if (save) {
             this.plugin.getStorage().saveUser(user).join();
         }
-        }
 
         final long time = System.currentTimeMillis() - startTime;
         if (time >= 1000) {

common/src/main/java/me/lucko/luckperms/common/storage/AbstractStorage.java

@@ -80,6 +80,11 @@ public class AbstractStorage implements Storage {
         return this.dao;
     }
 
+    @Override
+    public ApiStorage getApiDelegate() {
+        return this.apiDelegate;
+    }
+
     private <T> CompletableFuture<T> makeFuture(Callable<T> supplier) {
         return CompletableFuture.supplyAsync(() -> {
             try {
@@ -102,11 +107,6 @@ public class AbstractStorage implements Storage {
         }, this.dao.getPlugin().getBootstrap().getScheduler().async());
     }
 
-    @Override
-    public ApiStorage getApiDelegate() {
-        return this.apiDelegate;
-    }
-
     private interface ThrowingRunnable {
         void run() throws Exception;
     }

common/src/main/java/me/lucko/luckperms/common/storage/dao/file/AbstractConfigurateDao.java

@@ -203,6 +203,7 @@ public abstract class AbstractConfigurateDao extends AbstractDao {
         } catch (Exception e) {
             throw reportException(uuid.toString(), e);
         } finally {
+            user.invalidateCachedData();
             user.getIoLock().unlock();
         }
         return user;
@@ -258,6 +259,7 @@ public abstract class AbstractConfigurateDao extends AbstractDao {
         } catch (Exception e) {
             throw reportException(name, e);
         } finally {
+            group.invalidateCachedData();
             group.getIoLock().unlock();
         }
         return group;
@@ -290,6 +292,7 @@ public abstract class AbstractConfigurateDao extends AbstractDao {
             throw reportException(name, e);
         } finally {
             if (group != null) {
+                group.invalidateCachedData();
                 group.getIoLock().unlock();
             }
         }

common/src/main/java/me/lucko/luckperms/common/storage/dao/mongodb/MongoDao.java

@@ -286,6 +286,7 @@ public class MongoDao extends AbstractDao {
                 }
             }
         } finally {
+            user.invalidateCachedData();
             user.getIoLock().unlock();
         }
         return user;
@@ -356,6 +357,7 @@ public class MongoDao extends AbstractDao {
                 }
             }
         } finally {
+            group.invalidateCachedData();
             group.getIoLock().unlock();
         }
         return group;
@@ -385,6 +387,7 @@ public class MongoDao extends AbstractDao {
             }
         } finally {
             if (group != null) {
+                group.invalidateCachedData();
                 group.getIoLock().unlock();
             }
         }

common/src/main/java/me/lucko/luckperms/common/storage/dao/sql/SqlDao.java

@@ -355,6 +355,7 @@ public class SqlDao extends AbstractDao {
                 }
             }
         } finally {
+            user.invalidateCachedData();
             user.getIoLock().unlock();
         }
         return user;
@@ -596,6 +597,7 @@ public class SqlDao extends AbstractDao {
                 group.clearNodes();
             }
         } finally {
+            group.invalidateCachedData();
             group.getIoLock().unlock();
         }
         return Optional.of(group);