From dc9232c420600d428cdacaf55a1f610692940c80 Mon Sep 17 00:00:00 2001
From: Alex <alex@roese.dev>
Date: Sun, 20 Mar 2022 21:22:14 +0100
Subject: [PATCH] implement Redis

---
 .../krakatoa/proxy/listener/PlayerDisconnectListener.java   | 6 +++---
 src/main/java/net/krakatoa/proxy/redis/RedisManager.java    | 5 ++---
 2 files changed, 5 insertions(+), 6 deletions(-)

diff --git a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
index 47ac99c..67dea0d 100644
--- a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
+++ b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java
@@ -12,10 +12,10 @@ public class PlayerDisconnectListener implements Listener {
   public void onDisconnect(PlayerDisconnectEvent event) {
     ProxiedPlayer proxiedPlayer = event.getPlayer();
 
-    ProxySystem.getInstance().getRedisManager().getKeyReactiveCommands()
-        .del("player:" + proxiedPlayer.getUniqueId().toString());
+    String value = ProxySystem.getInstance().getRedisManager().getCommands()
+        .getdel("player:" + proxiedPlayer.getUniqueId().toString());
 
-    ProxySystem.getInstance().getLogger().info("player disconnected: " + proxiedPlayer.getName());
+    ProxySystem.getInstance().getLogger().info("val: " + value);
 
     //String uuid = ProxySystem.getInstance().getFormatter()
     //  .formatUuid(proxiedPlayer.getUniqueId().toString());
diff --git a/src/main/java/net/krakatoa/proxy/redis/RedisManager.java b/src/main/java/net/krakatoa/proxy/redis/RedisManager.java
index b0ee049..fbe2f1f 100644
--- a/src/main/java/net/krakatoa/proxy/redis/RedisManager.java
+++ b/src/main/java/net/krakatoa/proxy/redis/RedisManager.java
@@ -2,7 +2,6 @@ package net.krakatoa.proxy.redis;
 
 import io.lettuce.core.RedisClient;
 import io.lettuce.core.api.StatefulRedisConnection;
-import io.lettuce.core.api.reactive.RedisKeyReactiveCommands;
 import io.lettuce.core.api.sync.RedisStringCommands;
 import lombok.Data;
 
@@ -14,13 +13,13 @@ public class RedisManager {
   private RedisClient client;
   private StatefulRedisConnection<String, String> connection;
   private RedisStringCommands<String, String> commands;
-  private RedisKeyReactiveCommands<String, String> keyReactiveCommands;
+  //private RedisKeyReactiveCommands<String, String> keyReactiveCommands;
 
   public void connect() {
     this.client = RedisClient.create(this.getConnectionUri());
     this.connection = client.connect();
     this.commands = connection.sync();
-    this.keyReactiveCommands = this.connection.reactive();
+    //this.keyReactiveCommands = this.connection.reactive();
   }
 }
 // RedisKeyReactiveCommands
\ No newline at end of file