Upstream/LuckPerms
1
0
Fork 0
mirror of https://github.com/LuckPerms/LuckPerms.git synced 2025-01-01 05:57:51 +01:00
Code Issues Projects Releases Wiki Activity

Don't run commands through the buffer system

Browse Source
This commit is contained in:
Luck 2016-10-26 19:52:03 +01:00
parent 3929ce0dfc
commit 1c15f8462f
No known key found for this signature in database
GPG Key ID: EFA9B3EC5FD90F8B
1 changed files with 21 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
common/src/main/java/me/lucko/luckperms/common/commands/SubCommand.java
View File

@ -162,44 +162,35 @@ public abstract class SubCommand<T> {
} }
public static void save(User user, Sender sender, LuckPermsPlugin plugin) { public static void save(User user, Sender sender, LuckPermsPlugin plugin) {
plugin.doAsync(() -> { boolean success = plugin.getDatastore().force().saveUser(user).getUnchecked();
boolean success = plugin.getDatastore().saveUser(user).getUnchecked(); user.getRefreshBuffer().requestDirectly();
user.getRefreshBuffer().request().getUnchecked();
if (success) {
Message.USER_SAVE_SUCCESS.send(sender);
} else {
Message.USER_SAVE_ERROR.send(sender);
}
});
if (success) {
Message.USER_SAVE_SUCCESS.send(sender);
} else {
Message.USER_SAVE_ERROR.send(sender);
}
} }
public static void save(Group group, Sender sender, LuckPermsPlugin plugin) { public static void save(Group group, Sender sender, LuckPermsPlugin plugin) {
plugin.doAsync(() -> { boolean success = plugin.getDatastore().force().saveGroup(group).getUnchecked();
boolean success = plugin.getDatastore().saveGroup(group).getUnchecked(); plugin.getUpdateTaskBuffer().requestDirectly();
plugin.getUpdateTaskBuffer().request().getUnchecked();
if (success) {
Message.GROUP_SAVE_SUCCESS.send(sender);
} else {
Message.GROUP_SAVE_ERROR.send(sender);
}
});
if (success) {
Message.GROUP_SAVE_SUCCESS.send(sender);
} else {
Message.GROUP_SAVE_ERROR.send(sender);
}
} }
public static void save(Track track, Sender sender, LuckPermsPlugin plugin) { public static void save(Track track, Sender sender, LuckPermsPlugin plugin) {
plugin.doAsync(() -> { boolean success = plugin.getDatastore().force().saveTrack(track).getUnchecked();
boolean success = plugin.getDatastore().saveTrack(track).getUnchecked(); plugin.getUpdateTaskBuffer().requestDirectly();
plugin.getUpdateTaskBuffer().request().getUnchecked();
if (success) {
Message.TRACK_SAVE_SUCCESS.send(sender);
} else {
Message.TRACK_SAVE_ERROR.send(sender);
}
});
if (success) {
Message.TRACK_SAVE_SUCCESS.send(sender);
} else {
Message.TRACK_SAVE_ERROR.send(sender);
}
} }
} }