package emu.grasscutter.server.game; import emu.grasscutter.GameConstants; import emu.grasscutter.Grasscutter; import emu.grasscutter.command.CommandMap; import emu.grasscutter.database.DatabaseHelper; import emu.grasscutter.game.Account; import emu.grasscutter.game.combine.CombineManger; import emu.grasscutter.game.drop.DropManager; import emu.grasscutter.game.dungeons.DungeonManager; import emu.grasscutter.game.expedition.ExpeditionManager; import emu.grasscutter.game.gacha.GachaManager; import emu.grasscutter.game.managers.ChatManager; import emu.grasscutter.game.managers.InventoryManager; import emu.grasscutter.game.managers.MultiplayerManager; import emu.grasscutter.game.player.Player; import emu.grasscutter.game.shop.ShopManager; import emu.grasscutter.game.tower.TowerScheduleManager; import emu.grasscutter.game.world.World; import emu.grasscutter.net.packet.PacketHandler; import emu.grasscutter.net.proto.SocialDetailOuterClass.SocialDetail; import emu.grasscutter.netty.KcpServer; import emu.grasscutter.server.event.types.ServerEvent; import emu.grasscutter.server.event.game.ServerTickEvent; import emu.grasscutter.server.event.internal.ServerStartEvent; import emu.grasscutter.server.event.internal.ServerStopEvent; import emu.grasscutter.task.TaskMap; import java.net.InetSocketAddress; import java.time.OffsetDateTime; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import static emu.grasscutter.utils.Language.translate; public final class GameServer extends KcpServer { private final InetSocketAddress address; private final GameServerPacketHandler packetHandler; private final Map players; private final Set worlds; private final ChatManager chatManager; private final InventoryManager inventoryManager; private final GachaManager gachaManager; private final ShopManager shopManager; private final MultiplayerManager multiplayerManager; private final DungeonManager dungeonManager; private final ExpeditionManager expeditionManager; private final CommandMap commandMap; private final TaskMap taskMap; private final DropManager dropManager; private final CombineManger combineManger; private final TowerScheduleManager towerScheduleManager; public GameServer() { this(new InetSocketAddress( Grasscutter.getConfig().getGameServerOptions().Ip, Grasscutter.getConfig().getGameServerOptions().Port )); } public GameServer(InetSocketAddress address) { super(address); this.setServerInitializer(new GameServerInitializer(this)); this.address = address; this.packetHandler = new GameServerPacketHandler(PacketHandler.class); this.players = new ConcurrentHashMap<>(); this.worlds = Collections.synchronizedSet(new HashSet<>()); this.chatManager = new ChatManager(this); this.inventoryManager = new InventoryManager(this); this.gachaManager = new GachaManager(this); this.shopManager = new ShopManager(this); this.multiplayerManager = new MultiplayerManager(this); this.dungeonManager = new DungeonManager(this); this.commandMap = new CommandMap(true); this.taskMap = new TaskMap(true); this.dropManager = new DropManager(this); this.expeditionManager = new ExpeditionManager(this); this.combineManger = new CombineManger(this); this.towerScheduleManager = new TowerScheduleManager(this); // Hook into shutdown event. Runtime.getRuntime().addShutdownHook(new Thread(this::onServerShutdown)); } public GameServerPacketHandler getPacketHandler() { return packetHandler; } public Map getPlayers() { return players; } public Set getWorlds() { return worlds; } public ChatManager getChatManager() { return chatManager; } public InventoryManager getInventoryManager() { return inventoryManager; } public GachaManager getGachaManager() { return gachaManager; } public ShopManager getShopManager() { return shopManager; } public MultiplayerManager getMultiplayerManager() { return multiplayerManager; } public DropManager getDropManager() { return dropManager; } public DungeonManager getDungeonManager() { return dungeonManager; } public ExpeditionManager getExpeditionManager() { return expeditionManager; } public CommandMap getCommandMap() { return this.commandMap; } public CombineManger getCombineManger(){ return this.combineManger; } public TowerScheduleManager getTowerScheduleManager() { return towerScheduleManager; } public TaskMap getTaskMap() { return this.taskMap; } public void registerPlayer(Player player) { getPlayers().put(player.getUid(), player); } public Player getPlayerByUid(int id) { return this.getPlayerByUid(id, false); } public Player getPlayerByUid(int id, boolean allowOfflinePlayers) { // Console check if (id == GameConstants.SERVER_CONSOLE_UID) { return null; } // Get from online players Player player = this.getPlayers().get(id); if (!allowOfflinePlayers) { return player; } // Check database if character isnt here if (player == null) { player = DatabaseHelper.getPlayerById(id); } return player; } public SocialDetail.Builder getSocialDetailByUid(int id) { // Get from online players Player player = this.getPlayerByUid(id, true); if (player == null) { return null; } return player.getSocialDetail(); } public Account getAccountByName(String username) { Optional playerOpt = getPlayers().values().stream().filter(player -> player.getAccount().getUsername().equals(username)).findFirst(); if (playerOpt.isPresent()) { return playerOpt.get().getAccount(); } return DatabaseHelper.getAccountByName(username); } public void onTick() throws Exception { Iterator it = this.getWorlds().iterator(); while (it.hasNext()) { World world = it.next(); if (world.getPlayerCount() == 0) { it.remove(); } world.onTick(); } for (Player player : this.getPlayers().values()) { player.onTick(); } ServerTickEvent event = new ServerTickEvent(); event.call(); } public void registerWorld(World world) { this.getWorlds().add(world); } public void deregisterWorld(World world) { // TODO Auto-generated method stub } @Override public synchronized void start() { // Schedule game loop. Timer gameLoop = new Timer(); gameLoop.scheduleAtFixedRate(new TimerTask() { @Override public void run() { try { onTick(); } catch (Exception e) { Grasscutter.getLogger().error(translate("messages.game.game_update_error"), e); } } }, new Date(), 1000L); super.start(); } @Override public void onStartFinish() { Grasscutter.getLogger().info(translate("messages.status.free_software")); Grasscutter.getLogger().info(translate("messages.game.port_bind", Integer.toString(address.getPort()))); ServerStartEvent event = new ServerStartEvent(ServerEvent.Type.GAME, OffsetDateTime.now()); event.call(); } public void onServerShutdown() { ServerStopEvent event = new ServerStopEvent(ServerEvent.Type.GAME, OffsetDateTime.now()); event.call(); // Kick and save all players List list = new ArrayList<>(this.getPlayers().size()); list.addAll(this.getPlayers().values()); for (Player player : list) { player.getSession().close(); } } }