import java.awt.*;
import java.io.IOException;
import java.math.BigInteger;

public abstract class Login extends SocketConnecter {

	protected final void login(String user, String pass) {
		try {
			username = user;
			user = DataOperations.addCharacters(user, 20);
			password = pass;
			pass = DataOperations.addCharacters(pass, 20);
			if (user.trim().length() == 0) {
				loginScreenPrint("You must enter both a username",
						"and a password - Please try again");
				return;
			}
			loginScreenPrint("Please wait...", "Connecting to server");
			streamClass = new StreamClass(makeSocket(SERVER_IP, SERVER_PORT),
					this);
			streamClass.maxPacketReadCount = maxPacketReadCount;
			long l = DataOperations.stringLength12ToLong(user);
			streamClass.createPacket(32);
			streamClass.addByte((int) (l >> 16 & 31L));
			streamClass.addString(this.getClass().getName().toUpperCase());
			streamClass.finalisePacket();
			long sessionID = streamClass.read8ByteLong();
			if (sessionID == 0L) {
				loginScreenPrint("Login server offline.",
						"Please try again in a few mins");
				return;
			}
			System.out.print("Session ID: " + sessionID);
			int sessionRotationKeys[] = new int[4];
			sessionRotationKeys[0] = (int) (Math.random() * 99999999D);
			sessionRotationKeys[1] = (int) (Math.random() * 99999999D);
			sessionRotationKeys[2] = (int) (sessionID >> 32);
			sessionRotationKeys[3] = (int) sessionID;
			DataEncryption dataEncryption = new DataEncryption(new byte[500]);
			dataEncryption.offset = 0;
			dataEncryption.add4ByteInt(sessionRotationKeys[0]);
			dataEncryption.add4ByteInt(sessionRotationKeys[1]);
			dataEncryption.add4ByteInt(sessionRotationKeys[2]);
			dataEncryption.add4ByteInt(sessionRotationKeys[3]);
			dataEncryption.add4ByteInt(0); // UID
			dataEncryption.addString(user);
			dataEncryption.addString(pass);
			dataEncryption.encryptPacketWithKeys(key, modulus);
			streamClass.createPacket(0);
			streamClass.addByte(0);
			streamClass.add2ByteInt(26);
			streamClass.addBytes(dataEncryption.packet, 0,
					dataEncryption.offset);
			streamClass.finalisePacket();
			int loginResponse = streamClass.readInputStream();
			System.out.println(" - Login Response:" + loginResponse);
			sendPingPacketReadPacketData();
			if (loginResponse == 99) {
				reconnectTries = 0;
				return;
			}
			if (loginResponse == 0) {
				reconnectTries = 0;
				return;
			}
			if (loginResponse == 1) {
				reconnectTries = 0;
				return;
			}
			if (loginResponse == -1) {
				loginScreenPrint("Error unable to login.", "Server timed out");
				return;
			}
			// 0 = Valid
			// 1 = Reconnecting
			if (loginResponse == 2) {
				loginScreenPrint("Invalid username or password.",
						"Try again, or create a new account");
				return;
			}
			if (loginResponse == 3) {
				loginScreenPrint("That username is already logged in.",
						"Wait 60 seconds then retry");
				return;
			}
			if (loginResponse == 4) {
				loginScreenPrint("The client has been updated.",
						"Please download the newest one");
				return;
			}
			if (loginResponse == 5) {
				loginScreenPrint("Error unable to login.",
						"Server rejected session");
				return;
			}
			if (loginResponse == 6) {
				loginScreenPrint("Account disabled.",
						"Contact an admin for details");
				return;
			}
			if (loginResponse == 7) {
				loginScreenPrint("Error - failed to decode profile.",
						"Contact an admin");
				return;
			}
			if (loginResponse == 8) {
				loginScreenPrint("IP Already in use.",
						"You may only login once at a time");
				return;
			}
			if (loginResponse == 9) {
				loginScreenPrint("Account already in use.",
						"You may only login to one character at a time");
				return;
			}
			// 99 = Mod/Admin
			loginScreenPrint("Error unable to login.",
					"Unrecognised response code");
			return;
		} catch (Exception exception) {
			System.out.println(String.valueOf(exception));
		}
		if (reconnectTries > 0) {
			try {
				Thread.sleep(5000L);
			} catch (Exception _ex) {
			}
			reconnectTries--;
			login(username, password);
		}
		loginScreenPrint("Sorry! Unable to connect.",
				"Check internet settings or try another world");
	}

	private void loginScreenPrint(String string, String string2) {
		System.out.println(string + " " + string2);
	}

	protected final void sendPingPacketReadPacketData() {
		while (Running) {
			System.err.println(packetData[0] & 0xff);
			long l = System.currentTimeMillis();
			if (streamClass.containsData())
				lastPing = l;
			if (l - lastPing > 5000L) {
				lastPing = l;
				streamClass.createPacket(5);
				streamClass.formatPacket();
			}
			try {
				streamClass.writePacket(20);
			} catch (IOException _ex) {
				return;
			}
			int packetLength = streamClass.readPacket(packetData);
			if (packetLength > 0) {
				streamClass.createPacket(5);
				streamClass.formatPacket();
			}
		}
	}

	public Login() {
		username = "";
		password = "";
		packetData = new byte[5000];
	}

	public static int maxPacketReadCount;
	String username;
	String password;
	public static String SERVER_IP = "127.0.0.1";
	public static int SERVER_PORT = 43594;
	public StreamClass streamClass;
	protected byte[] packetData;
	int reconnectTries;
	private static BigInteger key = new BigInteger(
			"1370158896620336158431733257575682136836100155721926632321599369132092701295540721504104229217666225601026879393318399391095704223500673696914052239029335");
	private static BigInteger modulus = new BigInteger(
			"1549611057746979844352781944553705273443228154042066840514290174539588436243191882510185738846985723357723362764835928526260868977814405651690121789896823");
	long lastPing;
	public boolean Running = true;

}