package net.minecraft.server; import java.net.Socket; import java.util.Iterator; import java.util.Random; import java.util.logging.Logger; public class NetLoginHandler extends NetHandler { public static Logger logger = Logger.getLogger("Minecraft"); private static Random random = new Random(); public NetworkManager networkManager; public boolean c = false; private MinecraftServer server; private int f = 0; private String g = null; private Packet1Login h = null; private String loginKey = Long.toString(random.nextLong(), 16); // CraftBukkit - Security fix public String hostname = ""; // CraftBukkit - add field public NetLoginHandler(MinecraftServer minecraftserver, Socket socket, String s) { this.server = minecraftserver; this.networkManager = new NetworkManager(socket, s, this); this.networkManager.f = 0; } // CraftBukkit start public Socket getSocket() { return this.networkManager.socket; } // CraftBukkit end public void a() { if (this.h != null) { this.b(this.h); this.h = null; } if (this.f++ == 600) { this.disconnect("Took too long to log in"); } else { this.networkManager.b(); } } public void disconnect(String s) { try { logger.info("Disconnecting " + this.getName() + ": " + s); this.networkManager.queue(new Packet255KickDisconnect(s)); this.networkManager.d(); this.c = true; } catch (Exception exception) { exception.printStackTrace(); } } public void a(Packet2Handshake packet2handshake) { // CraftBukkit start - 1.3 detection if (packet2handshake.a == null) { disconnect("Outdated server!"); return; } // CraftBukkit end // CraftBukkit start int i = packet2handshake.a.indexOf(';'); if (i == -1) { this.hostname = ""; } else this.hostname = packet2handshake.a.substring(i + 1); // CraftBukkit end if (this.server.onlineMode) { this.loginKey = Long.toString(random.nextLong(), 16); this.networkManager.queue(new Packet2Handshake(this.loginKey)); } else { this.networkManager.queue(new Packet2Handshake("-")); } } public void a(Packet1Login packet1login) { this.g = packet1login.name; if (packet1login.a != 29) { if (packet1login.a > 29) { this.disconnect("Outdated server!"); } else { this.disconnect("Outdated client!"); } } else { if (!this.server.onlineMode) { // CraftBukkit start - disallow colour in names if (!packet1login.name.equals(org.bukkit.ChatColor.stripColor(packet1login.name))) { this.disconnect("Colourful names are not permitted!"); return; } // CraftBukkit end this.b(packet1login); } else { (new ThreadLoginVerifier(this, packet1login, this.server.server)).start(); // CraftBukkit } } } public void b(Packet1Login packet1login) { EntityPlayer entityplayer = this.server.serverConfigurationManager.attemptLogin(this, packet1login.name, this.hostname); // CraftBukkit - add hostname parameter if (entityplayer != null) { //this.server.serverConfigurationManager.b(entityplayer); // CraftBukkit - Moved to attemptLogin // entityplayer.a((World) this.server.a(entityplayer.dimension)); // CraftBukkit - set by Entity entityplayer.itemInWorldManager.a((WorldServer) entityplayer.world); // CraftBukkit - add world and location to 'logged in' message. logger.info(this.getName() + " logged in with entity id " + entityplayer.id + " at ([" + entityplayer.world.worldData.name + "] " + entityplayer.locX + ", " + entityplayer.locY + ", " + entityplayer.locZ + ")"); WorldServer worldserver = (WorldServer) entityplayer.world; // CraftBukkit ChunkCoordinates chunkcoordinates = worldserver.getSpawn(); entityplayer.itemInWorldManager.b(worldserver.getWorldData().getGameType()); NetServerHandler netserverhandler = new NetServerHandler(this.server, this.networkManager, entityplayer); // CraftBukkit start -- Don't send a higher than 60 MaxPlayer size, otherwise the PlayerInfo window won't render correctly. int maxPlayers = this.server.serverConfigurationManager.getMaxPlayers(); if (maxPlayers > 60) { maxPlayers = 60; } netserverhandler.sendPacket(new Packet1Login("", entityplayer.id, worldserver.getWorldData().getType(), entityplayer.itemInWorldManager.getGameMode(), worldserver.worldProvider.dimension, (byte) worldserver.difficulty, (byte) worldserver.getHeight(), (byte) maxPlayers)); entityplayer.getBukkitEntity().sendSupportedChannels(); // CraftBukkit end netserverhandler.sendPacket(new Packet6SpawnPosition(chunkcoordinates.x, chunkcoordinates.y, chunkcoordinates.z)); netserverhandler.sendPacket(new Packet202Abilities(entityplayer.abilities)); this.server.serverConfigurationManager.a(entityplayer, worldserver); // this.server.serverConfigurationManager.sendAll(new Packet3Chat("\u00A7e" + entityplayer.name + " joined the game.")); // CraftBukkit - message moved to join event this.server.serverConfigurationManager.c(entityplayer); netserverhandler.a(entityplayer.locX, entityplayer.locY, entityplayer.locZ, entityplayer.yaw, entityplayer.pitch); this.server.networkListenThread.a(netserverhandler); netserverhandler.sendPacket(new Packet4UpdateTime(entityplayer.getPlayerTime())); // CraftBukkit - add support for player specific time Iterator iterator = entityplayer.getEffects().iterator(); while (iterator.hasNext()) { MobEffect mobeffect = (MobEffect) iterator.next(); netserverhandler.sendPacket(new Packet41MobEffect(entityplayer.id, mobeffect)); } entityplayer.syncInventory(); } this.c = true; } public void a(String s, Object[] aobject) { logger.info(this.getName() + " lost connection"); this.c = true; } public void a(Packet254GetInfo packet254getinfo) { if (this.networkManager.getSocket() == null) return; // CraftBukkit - fix NPE when a client queries a server that is unable to handle it. try { // CraftBukkit start org.bukkit.event.server.ServerListPingEvent pingEvent = org.bukkit.craftbukkit.event.CraftEventFactory.callServerListPingEvent(this.server.server, getSocket().getInetAddress(), this.server.motd, this.server.serverConfigurationManager.getPlayerCount(), this.server.serverConfigurationManager.getMaxPlayers()); String s = pingEvent.getMotd() + "\u00A7" + this.server.serverConfigurationManager.getPlayerCount() + "\u00A7" + pingEvent.getMaxPlayers(); // CraftBukkit end this.server.networkListenThread.a(this.networkManager.getSocket()); // CraftBukkit - cleanup before killing connection this.networkManager.queue(new Packet255KickDisconnect(s)); this.networkManager.d(); // this.server.networkListenThread.a(this.networkManager.getSocket()); // CraftBukkit - moved up this.c = true; } catch (Exception exception) { exception.printStackTrace(); } } public void onUnhandledPacket(Packet packet) { this.disconnect("Protocol error"); } public String getName() { return this.g != null ? this.g + " [" + this.networkManager.getSocketAddress().toString() + "]" : this.networkManager.getSocketAddress().toString(); } public boolean c() { return true; } static String a(NetLoginHandler netloginhandler) { return netloginhandler.loginKey; } static Packet1Login a(NetLoginHandler netloginhandler, Packet1Login packet1login) { return netloginhandler.h = packet1login; } }