diff --git a/common/src/main/java/net/william278/husksync/command/EnderChestCommand.java b/common/src/main/java/net/william278/husksync/command/EnderChestCommand.java index 18c0102c..62a7024d 100644 --- a/common/src/main/java/net/william278/husksync/command/EnderChestCommand.java +++ b/common/src/main/java/net/william278/husksync/command/EnderChestCommand.java @@ -23,6 +23,8 @@ import de.themoep.minedown.adventure.MineDown; import net.william278.husksync.HuskSync; import net.william278.husksync.data.Data; import net.william278.husksync.data.DataSnapshot; +import net.william278.husksync.redis.RedisKeyType; +import net.william278.husksync.redis.RedisManager; import net.william278.husksync.user.OnlineUser; import net.william278.husksync.user.User; import org.jetbrains.annotations.NotNull; @@ -87,8 +89,11 @@ public class EnderChestCommand extends ItemsCommand { plugin.getSettings().getSynchronization().doAutoPin(DataSnapshot.SaveCause.ENDERCHEST_COMMAND) ); }); + + final RedisManager redis = plugin.getRedisManager(); plugin.getDatabase().addSnapshot(user, snapshot); - plugin.getRedisManager().sendUserDataUpdate(user, snapshot); + redis.sendUserDataUpdate(user, snapshot); + redis.getUserData(user).ifPresent(data -> redis.setUserData(user, snapshot, RedisKeyType.TTL_1_YEAR)); } } diff --git a/common/src/main/java/net/william278/husksync/command/InventoryCommand.java b/common/src/main/java/net/william278/husksync/command/InventoryCommand.java index da0f174e..b5b1918e 100644 --- a/common/src/main/java/net/william278/husksync/command/InventoryCommand.java +++ b/common/src/main/java/net/william278/husksync/command/InventoryCommand.java @@ -23,6 +23,8 @@ import de.themoep.minedown.adventure.MineDown; import net.william278.husksync.HuskSync; import net.william278.husksync.data.Data; import net.william278.husksync.data.DataSnapshot; +import net.william278.husksync.redis.RedisKeyType; +import net.william278.husksync.redis.RedisManager; import net.william278.husksync.user.OnlineUser; import net.william278.husksync.user.User; import org.jetbrains.annotations.NotNull; @@ -87,8 +89,11 @@ public class InventoryCommand extends ItemsCommand { plugin.getSettings().getSynchronization().doAutoPin(DataSnapshot.SaveCause.INVENTORY_COMMAND) ); }); + + final RedisManager redis = plugin.getRedisManager(); plugin.getDatabase().addSnapshot(user, snapshot); - plugin.getRedisManager().sendUserDataUpdate(user, snapshot); + redis.sendUserDataUpdate(user, snapshot); + redis.getUserData(user).ifPresent(data -> redis.setUserData(user, snapshot, RedisKeyType.TTL_1_YEAR)); } }