misc/chomens-bot-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: more weird kind of "fixes"

Browse Source
This commit is contained in:
ChomeNS
2024-12-05 11:27:51 +07:00
parent d0d28cc55b
commit 55f4d1fece
3 changed files with 38 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
src/main/java/me/chayapak1/chomens_bot/plugins/PlayersPersistentDataPlugin.java
View File

@@ -29,43 +29,47 @@ public class PlayersPersistentDataPlugin extends PlayersPlugin.Listener {
public synchronized void playerJoined(PlayerEntry target) {
lock.lock();
final JsonNode originalElement = playersObject.get(target.profile.getName());
try {
final JsonNode originalElement = playersObject.get(target.profile.getName());
ObjectNode object;
ObjectNode object;
if (originalElement == null || originalElement.isNull()) {
object = JsonNodeFactory.instance.objectNode();
object.put("uuid", target.profile.getIdAsString());
object.set("ips", JsonNodeFactory.instance.objectNode());
} else if (originalElement instanceof ObjectNode) {
object = (ObjectNode) originalElement;
} else {
lock.unlock();
return;
}
lock.unlock();
bot.executorService.submit(() -> {
final CompletableFuture<String> future = bot.players.getPlayerIP(target);
if (future == null) {
setPersistentEntry(target, object);
if (originalElement == null || originalElement.isNull()) {
object = JsonNodeFactory.instance.objectNode();
object.put("uuid", target.profile.getIdAsString());
object.set("ips", JsonNodeFactory.instance.objectNode());
} else if (originalElement instanceof ObjectNode) {
object = (ObjectNode) originalElement;
} else {
lock.unlock();
return;
}
future.completeOnTimeout(null, 5, TimeUnit.SECONDS);
lock.unlock();
future.thenApplyAsync(output -> {
if (output != null) {
((ObjectNode) object.get("ips")).put(bot.host + ":" + bot.port, output);
bot.executorService.submit(() -> {
final CompletableFuture<String> future = bot.players.getPlayerIP(target);
if (future == null) {
setPersistentEntry(target, object);
return;
}
setPersistentEntry(target, object);
future.completeOnTimeout(null, 5, TimeUnit.SECONDS);
return output;
future.thenApplyAsync(output -> {
if (output != null) {
((ObjectNode) object.get("ips")).put(bot.host + ":" + bot.port, output);
}
setPersistentEntry(target, object);
return output;
});
});
});
} catch (Exception e) {
e.printStackTrace();
}
}
// is this bad?