CraftAttack/teamLobby
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added periodic teams refetch

Browse Source
This commit is contained in:
Elias Müller 2025-05-30 00:44:33 +02:00
parent da6fbf6e4b
commit db98f4e5b7
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/eu/mhsl/craftattack/teamLobby/LobbyManager.java
View File

@ -3,7 +3,9 @@ package eu.mhsl.craftattack.teamLobby;
import com.google.common.reflect.TypeToken; import com.google.common.reflect.TypeToken;
import eu.mhsl.craftattack.teamLobby.data.Team; import eu.mhsl.craftattack.teamLobby.data.Team;
import eu.mhsl.craftattack.teamLobby.http.Request; import eu.mhsl.craftattack.teamLobby.http.Request;
import net.minestom.server.MinecraftServer;
import net.minestom.server.entity.Player; import net.minestom.server.entity.Player;
import net.minestom.server.timer.TaskSchedule;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import java.net.http.HttpRequest; import java.net.http.HttpRequest;
@ -11,7 +13,11 @@ import java.util.*;
public class LobbyManager { public class LobbyManager {
public LobbyManager() { public LobbyManager() {
this.loadTeams(); MinecraftServer.getSchedulerManager().scheduleTask(
this::loadTeams,
TaskSchedule.seconds(3),
TaskSchedule.minutes(1)
);
} }
private Set<Team> teams = Set.of(); private Set<Team> teams = Set.of();

3
src/main/java/eu/mhsl/craftattack/teamLobby/Main.java
View File

@ -42,8 +42,6 @@ public class Main {
.build() .build()
.load(); .load();
lobbyManager = new LobbyManager();
ConfigurationNode serverCfg = config.node("server"); ConfigurationNode serverCfg = config.node("server");
MinecraftServer server = MinecraftServer.init(); MinecraftServer server = MinecraftServer.init();
@ -77,6 +75,7 @@ public class Main {
int port = config.node("server", "port").getInt(25565); int port = config.node("server", "port").getInt(25565);
server.start(new InetSocketAddress("0.0.0.0", port)); server.start(new InetSocketAddress("0.0.0.0", port));
lobbyManager = new LobbyManager();
System.out.println("Server is running!"); System.out.println("Server is running!");
} }