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

fix: fix for unlimited

Browse Source
This commit is contained in:
ChomeNS
2024-12-05 14:47:17 +07:00
parent 4600eaf942
commit 2c517b7326
3 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -9,7 +9,6 @@ import me.chayapak1.chomens_bot.util.PersistentDataUtilities;
import java.time.Instant;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;
public class PlayersPersistentDataPlugin extends PlayersPlugin.Listener {
@@ -49,8 +48,6 @@ public class PlayersPersistentDataPlugin extends PlayersPlugin.Listener {
return;
}
future.completeOnTimeout(null, 5, TimeUnit.SECONDS);
future.thenApplyAsync(output -> {
if (output != null) {
((ObjectNode) object.get("ips")).put(bot.host + ":" + bot.port, output);
@@ -66,7 +63,7 @@ public class PlayersPersistentDataPlugin extends PlayersPlugin.Listener {
}
// is this bad?
private synchronized void setPersistentEntry (PlayerEntry target, ObjectNode object) {
private void setPersistentEntry (PlayerEntry target, ObjectNode object) {
lock.lock();
try {
playersObject.set(getName(target), object);
@@ -83,21 +80,21 @@ public class PlayersPersistentDataPlugin extends PlayersPlugin.Listener {
}
@Override
public synchronized void playerLeft(PlayerEntry target) {
lock.lock();
public void playerLeft(PlayerEntry target) {
bot.executorService.submit(() -> {
if (!playersObject.has(getName(target))) return;
if (!playersObject.has(getName(target))) return;
final ObjectNode player = (ObjectNode) playersObject.get(getName(target));
final ObjectNode player = (ObjectNode) playersObject.get(getName(target));
final ObjectNode object = JsonNodeFactory.instance.objectNode();
object.put("time", Instant.now().toEpochMilli());
object.put("server", bot.host + ":" + bot.port);
final ObjectNode object = JsonNodeFactory.instance.objectNode();
object.put("time", Instant.now().toEpochMilli());
object.put("server", bot.host + ":" + bot.port);
player.set("lastSeen", object);
player.set("lastSeen", object);
PersistentDataUtilities.put("players", playersObject);
PersistentDataUtilities.put("players", playersObject);
lock.unlock();
lock.unlock();
});
}
}

3
src/main/java/me/chayapak1/chomens_bot/plugins/PlayersPlugin.java
View File

@@ -19,6 +19,7 @@ import java.util.EnumSet;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
public class PlayersPlugin extends Bot.Listener {
private final Bot bot;
@@ -68,6 +69,8 @@ public class PlayersPlugin extends Bot.Listener {
if (trackedCoreFuture == null) return null;
trackedCoreFuture.completeOnTimeout(null, 5, TimeUnit.SECONDS);
trackedCoreFuture.thenApplyAsync(output -> {
final List<Component> children = output.children();