Krakatoa-Earth
/
ProxySystem
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

debug: mongodb document subscriber

master
Alex 2022-04-14 14:34:22 +02:00
parent a92703fb3a
commit 71dbd42b5c
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java
View File

@ -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<Document> playerDocument = Observable.fromPublisher(
ProxySystem.getInstance().getMongoManager().getPlayersCollection()
.find(Filters.eq("uuid", uuid)).first()).firstElement();
ProxySystem.getInstance().getLogger().info("playerDocument " + playerDocument.isEmpty());
/*