Initial commit

src/main/java/emu/grasscutter/server/game/GameServer.java

@@ -0,0 +1,160 @@
+package emu.grasscutter.server.game;
+
+import java.net.InetSocketAddress;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.Timer;
+import java.util.TimerTask;
+import java.util.concurrent.ConcurrentHashMap;
+
+import emu.grasscutter.GenshinConstants;
+import emu.grasscutter.Grasscutter;
+import emu.grasscutter.database.DatabaseHelper;
+import emu.grasscutter.game.GenshinPlayer;
+import emu.grasscutter.game.dungeons.DungeonManager;
+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.shop.ShopManager;
+import emu.grasscutter.net.packet.PacketHandler;
+import emu.grasscutter.net.proto.SocialDetailOuterClass.SocialDetail;
+import emu.grasscutter.netty.MihoyoKcpServer;
+
+public class GameServer extends MihoyoKcpServer {
+	private final InetSocketAddress address;
+	private final GameServerPacketHandler packetHandler;
+	private final Timer gameLoop;
+	
+	private final Map<Integer, GenshinPlayer> players;
+	
+	private final ChatManager chatManager;
+	private final InventoryManager inventoryManager;
+	private final GachaManager gachaManager;
+	private final ShopManager shopManager;
+	private final MultiplayerManager multiplayerManager;
+	private final DungeonManager dungeonManager;
+	
+	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.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);
+		
+		// Ticker
+		this.gameLoop = new Timer();
+		this.gameLoop.scheduleAtFixedRate(new TimerTask() {
+			@Override
+			public void run() {
+				try {
+					onTick();
+				} catch (Exception e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+		}, new Date(), 1000L);
+		
+		// Shutdown hook
+		Runtime.getRuntime().addShutdownHook(new Thread(this::onServerShutdown));
+	}
+	
+	public GameServerPacketHandler getPacketHandler() {
+		return packetHandler;
+	}
+
+	public Map<Integer, GenshinPlayer> getPlayers() {
+		return players;
+	}
+
+	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 DungeonManager getDungeonManager() {
+		return dungeonManager;
+	}
+	
+	public void registerPlayer(GenshinPlayer player) {
+		getPlayers().put(player.getId(), player);
+	}
+
+	public GenshinPlayer getPlayerById(int id) {
+		return this.getPlayers().get(id);
+	}
+	
+	public GenshinPlayer forceGetPlayerById(int id) {
+		// Console check
+		if (id == GenshinConstants.SERVER_CONSOLE_UID) {
+			return null;
+		}
+		
+		// Get from online players
+		GenshinPlayer player = this.getPlayerById(id);
+		
+		// Check database if character isnt here
+		if (player == null) {
+			player = DatabaseHelper.getPlayerById(id);
+		}
+		
+		return player;
+	}
+	
+	public SocialDetail.Builder getSocialDetailById(int id) {
+		// Get from online players
+		GenshinPlayer player = this.forceGetPlayerById(id);
+	
+		if (player == null) {
+			return null;
+		}
+		
+		return player.getSocialDetail();
+	}
+	
+	public void onTick() throws Exception {
+		for (GenshinPlayer player : this.getPlayers().values()) {
+			player.onTick();
+		}
+	}
+
+	@Override
+	public void onStartFinish() {
+		Grasscutter.getLogger().info("Game Server started on port " + address.getPort());
+	}
+	
+	public void onServerShutdown() {
+		// Kick and save all players
+		List<GenshinPlayer> list = new ArrayList<>(this.getPlayers().size());
+		list.addAll(this.getPlayers().values());
+		
+		for (GenshinPlayer player : list) {
+			player.getSession().close();
+		}
+	}
+}