Compare commits

..

3 Commits

3 changed files with 35 additions and 3 deletions

View File

@ -8,6 +8,7 @@ import net.md_5.bungee.api.CommandSender;
import net.md_5.bungee.api.chat.TextComponent;
import net.md_5.bungee.api.connection.ProxiedPlayer;
import net.md_5.bungee.api.plugin.Command;
import org.redisson.api.RMap;
public class KrakatoapCommand extends Command {
@ -31,6 +32,20 @@ public class KrakatoapCommand extends Command {
.getSendQueueMessages().size(), ProxySystem.getInstance()
.getKraSocketClientProtocol()
.getReceivedQueueMessages().size())));
String uuid = ProxySystem.getInstance().getFormatter()
.formatUuid(player.getUniqueId().toString());
RMap<String, String> map = ProxySystem.getInstance().getRedisManager()
.getRedissonClient()
.getMap("player:" + uuid);
if (!map.isEmpty()) {
player.sendMessage(new TextComponent("\n§7Redis player data:"));
map.forEach((key, value) -> {
player.sendMessage(new TextComponent("§7key: §e" + key + " §7value: §e" + value));
});
}
}
}
}

View File

@ -1,9 +1,11 @@
package net.krakatoa.proxy.listener;
import net.krakatoa.proxy.ProxySystem;
import net.md_5.bungee.api.connection.ProxiedPlayer;
import net.md_5.bungee.api.event.PlayerDisconnectEvent;
import net.md_5.bungee.api.plugin.Listener;
import net.md_5.bungee.event.EventHandler;
import org.redisson.api.RMap;
public class PlayerDisconnectListener implements Listener {
@ -11,6 +13,18 @@ public class PlayerDisconnectListener implements Listener {
public void onDisconnect(PlayerDisconnectEvent event) {
ProxiedPlayer proxiedPlayer = event.getPlayer();
String uuid = ProxySystem.getInstance().getFormatter()
.formatUuid(proxiedPlayer.getUniqueId().toString());
// redis
RMap<String, String> map = ProxySystem.getInstance().getRedisManager()
.getRedissonClient()
.getMap("player:" + uuid);
if (!map.isEmpty()) {
map.delete();
}
/*Long res = ProxySystem.getInstance().getRedisManager().getRedisKeyCommands()
.del("player:" + proxiedPlayer.getUniqueId().toString());

View File

@ -8,6 +8,7 @@ import earth.krakatao.protocol.KraSocketClientProtocolMessage;
import earth.krakatao.protocol.KraSocketClientProtocolStatus;
import java.io.IOException;
import java.security.SecureRandom;
import java.util.Objects;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
import net.krakatoa.proxy.ProxySystem;
@ -80,9 +81,11 @@ public class PostLoginListener implements Listener {
map.put("voiceWebCode", "voiceWebCode");
document.forEach((key, value) -> {
ProxySystem.getInstance().getLogger()
.info("key " + key + " value " + value.toString());
map.put(key, value.toString());
if (!Objects.equals(key, "_id")) {
ProxySystem.getInstance().getLogger()
.info("key " + key + " value " + value.toString());
map.put(key, value.toString());
}
});
ProxySystem.getInstance().getLogger().info("PUT !");
} else {