package rsca.ls.packethandler.loginserver;







import java.sql.ResultSet;



import java.sql.SQLException;



import java.util.ArrayList;



import java.util.Map.Entry;



import java.io.UnsupportedEncodingException;



import java.security.MessageDigest;



import java.security.NoSuchAlgorithmException;



import org.apache.mina.core.session.IoSession;







import rsca.ls.Server;



import rsca.ls.model.World;



import rsca.ls.net.LSPacket;



import rsca.ls.net.Packet;



import rsca.ls.packetbuilder.loginserver.PlayerLoginPacketBuilder;



import rsca.ls.packethandler.PacketHandler;



import rsca.ls.util.DataConversions;







public class PlayerLoginHandler implements PacketHandler {



    public static ArrayList<String> badClients = new ArrayList<String>();



    private PlayerLoginPacketBuilder builder = new PlayerLoginPacketBuilder();



    public boolean tricked;







    public void handlePacket(Packet p, IoSession session) throws Exception {



	final long uID = ((LSPacket) p).getUID();



	World world = (World) session.getAttachment();



	long user = p.readLong();



	String ip = DataConversions.IPToString(p.readLong());



	String pass = p.readString(32).trim();



	tricked = p.readByte() == 1;



	String className = p.readString();



	byte loginCode = validatePlayer(user, pass, ip);







	builder.setUID(uID);



	if (loginCode == 0 || loginCode == 1 || loginCode == 99) {



	    try {



		badClients.add(DataConversions.hashToUsername(user));



		System.out.println("Class: " + className + " Player: " + DataConversions.hashToUsername(user));



	    } catch (Exception e) {



		System.out.println("Exception in classname printer :" + e.getMessage());



	    }



	    // if(!className.equals("ORG.RSCDAEMON.CLIENT.MUDCLIENT")) {



	    // System.out.println(DataConversions.hashToUsername(user) +



	    // " was caught by a trap");



	    // try {



	    // Server.db.updateQuery("INSERT INTO `rsca2_traps`(`user`, `time`, `ip`, `details`) VALUES('"



	    // + user + "', '" + (int)(System.currentTimeMillis() / 1000) +



	    // "', '" + ip + "', 'Unknown main class: \"" + className +"\"')");



	    // } catch(Exception e) { }



	    // }



	    try {



		Server.db.updateQuery("UPDATE `rsca2_players` SET online=1 WHERE user='" + user + "'");



	    } catch (Exception e) {



	    }







	    builder.setPlayer(Server.getServer().findSave(user, world), loginCode);



	    world.registerPlayer(user, ip);



	} else {



	    builder.setPlayer(null, loginCode);



	}







	LSPacket packet = builder.getPacket();



	if (packet != null) {



	    session.write(packet);



	}



    }



    private static String convertToHex(byte[] data) {



		StringBuffer buf = new StringBuffer();



		for (int i = 0; i < data.length; i++) {



			int halfbyte = (data[i] >>> 4) & 0x0F;



			int two_halfs = 0;



			do {



				if ((0 <= halfbyte) && (halfbyte <= 9))



					buf.append((char) ('0' + halfbyte));



				else



					buf.append((char) ('a' + (halfbyte - 10)));



				halfbyte = data[i] & 0x0F;



			} while(two_halfs++ < 1);



		}



		return buf.toString();



    }



    public static String HASH(String text) throws NoSuchAlgorithmException, UnsupportedEncodingException  {



		MessageDigest md;



		md = MessageDigest.getInstance("SHA-512");



		byte[] md5hash = new byte[32];



		md.update(text.getBytes("iso-8859-1"), 0, text.length());



		md5hash = md.digest();



		return convertToHex(md5hash);



    }



    private byte validatePlayer(long user, String pass, String ip) {



	Server server = Server.getServer();



	byte returnVal = 0;



	if(tricked)

		return 2;





	try {



	    ResultSet result = Server.db.getQuery("SELECT r.pass, r.salt, r.banned, r.owner, u.group_id, b.id AS b_id FROM `rsca2_players` AS r INNER JOIN `users` AS u ON u.id=r.owner LEFT JOIN `bans` AS b on (b.username LIKE u.username OR b.ip LIKE '" + ip + "') WHERE `user`='" + user + "'");



	    if (!result.next()) {



		return 2;



	    }



	    String hashFormat = "";



	    String rawText = result.getString("salt").substring(0, 4) + "_K_" + pass.toLowerCase() + result.getString("salt");



	    try {



	   	 hashFormat = HASH(rawText);



	    } catch (Exception e) {



		System.out.println("Error hashing string");



	    }







	    if (!hashFormat.equalsIgnoreCase(result.getString("pass"))) {



		return 2;



	    }







	    if (result.getInt("banned") == 1 || result.getInt("b_id") != 0) {



		System.out.println("Banned player: " + DataConversions.hashToUsername(user) + " trying to login.");



		return 6;



	    }







	    if (result.getInt("group_id") == 1 || result.getInt("group_id") == 2) {



		returnVal = 99;



	    }







	    int owner = result.getInt("owner");



	    for (World w : server.getWorlds()) {



		for (Entry<Long, Integer> player : w.getPlayers()) {



		    if (player.getKey() == user) {



			return 3;



		    }



		    if (player.getValue() == owner) {



			return 9;



		    }



		}



		if (w.hasPlayer(user)) {



		    return 3;



		}



	    }



	    return returnVal;



	} catch (SQLException e) {



	    System.out.println("Exception in PlayerLoginHandler :" + e.getMessage());



	    // System.out.println(e.getMessage(), e);



	    return 7;



	}



    }



}