From b54518cf1454a0e1c9eb861a122219d88dcccc60 Mon Sep 17 00:00:00 2001
From: alex <alex@roese.dev>
Date: Sun, 10 Apr 2022 21:30:15 +0200
Subject: [PATCH] mongodb find document test

---
 .../proxy/listener/PostLoginListener.java     | 40 +++++++++++++------
 1 file changed, 27 insertions(+), 13 deletions(-)

diff --git a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
index 855e9d0..46334ac 100755
--- a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
+++ b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
@@ -1,32 +1,23 @@
 package net.krakatoa.proxy.listener;
 
 import com.mongodb.client.model.Filters;
-import com.mongodb.client.model.UpdateOptions;
-import com.mongodb.client.model.Updates;
-import earth.krakatao.protocol.KraSocketClientProtocolDest;
-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;
-import net.md_5.bungee.api.ProxyServer;
 import net.md_5.bungee.api.chat.ClickEvent;
 import net.md_5.bungee.api.chat.HoverEvent;
 import net.md_5.bungee.api.chat.HoverEvent.Action;
 import net.md_5.bungee.api.chat.TextComponent;
 import net.md_5.bungee.api.chat.hover.content.Text;
-import net.md_5.bungee.api.config.ServerInfo;
 import net.md_5.bungee.api.connection.ProxiedPlayer;
 import net.md_5.bungee.api.event.PostLoginEvent;
 import net.md_5.bungee.api.event.ServerSwitchEvent;
 import net.md_5.bungee.api.plugin.Listener;
 import net.md_5.bungee.event.EventHandler;
 import org.bson.Document;
-import org.bson.conversions.Bson;
-import org.redisson.api.RMap;
+import org.reactivestreams.Publisher;
+import org.reactivestreams.Subscriber;
+import org.reactivestreams.Subscription;
 
 public class PostLoginListener implements Listener {
 
@@ -37,10 +28,33 @@ public class PostLoginListener implements Listener {
     String uuid = ProxySystem.getInstance().getFormatter()
         .formatUuid(proxiedPlayer.getUniqueId().toString());
 
-    Document document = (Document) ProxySystem.getInstance().getMongoManager()
+    Publisher<Document> document = ProxySystem.getInstance().getMongoManager()
         .getPlayersCollection()
         .find(Filters.eq("uuid", uuid)).first();
 
+    document.subscribe(new Subscriber<Document>() {
+      @Override
+      public void onSubscribe(Subscription subscription) {
+        subscription.request(1);
+        ProxySystem.getInstance().getLogger().info("subscripe");
+      }
+
+      @Override
+      public void onNext(Document document) {
+        ProxySystem.getInstance().getLogger().info(("Inserted: " + document));
+      }
+
+      @Override
+      public void onError(Throwable throwable) {
+        ProxySystem.getInstance().getLogger().info("Failed " + throwable);
+      }
+
+      @Override
+      public void onComplete() {
+        ProxySystem.getInstance().getLogger().info("Completed");
+      }
+    });
+    /*
     if (document == null) { // new player - create entries in databases
       System.out.println("create player in db");
       String voiceWebCode = generateVoiceWebCode(uuid);