From 71dbd42b5c452f039a895199f693e860f34f5ade Mon Sep 17 00:00:00 2001 From: Alex Date: Thu, 14 Apr 2022 14:34:22 +0200 Subject: [PATCH] debug: mongodb document subscriber --- .../krakatoa/proxy/listener/PostLoginListener.java | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) diff --git a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java index 1768217..7d6c604 100755 --- a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java +++ b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java @@ -1,9 +1,6 @@ package net.krakatoa.proxy.listener; import com.mongodb.client.model.Filters; -import io.reactivex.rxjava3.annotations.NonNull; -import io.reactivex.rxjava3.core.Maybe; -import io.reactivex.rxjava3.core.Observable; import java.io.IOException; import java.security.SecureRandom; import net.krakatoa.proxy.ProxySystem; @@ -45,7 +42,10 @@ public class PostLoginListener implements Listener { @Override public void onNext(Document document) { + ProxySystem.getInstance().getLogger().info("Inserted"); ProxySystem.getInstance().getLogger().info("Inserted: " + document); + + } @Override @@ -58,14 +58,9 @@ public class PostLoginListener implements Listener { ProxySystem.getInstance().getLogger().info("Completed"); } }); + ProxySystem.getInstance().getLogger().info("debug2 testa"); - @NonNull Maybe playerDocument = Observable.fromPublisher( - ProxySystem.getInstance().getMongoManager().getPlayersCollection() - .find(Filters.eq("uuid", uuid)).first()).firstElement(); - - ProxySystem.getInstance().getLogger().info("playerDocument " + playerDocument.isEmpty()); - /*