package rt4;

import org.openrs2.deob.annotation.OriginalArg;
import org.openrs2.deob.annotation.OriginalMember;
import org.openrs2.deob.annotation.Pc;

import java.io.IOException;
import java.net.Socket;

public class CreateManager {

	@OriginalMember(owner = "client!oe", name = "l", descriptor = "I")
	public static int step = 0;

	@OriginalMember(owner = "client!sf", name = "a", descriptor = "I")
	public static int loops = 0;

	@OriginalMember(owner = "client!eg", name = "v", descriptor = "I")
	public static int errors = 0;

	@OriginalMember(owner = "client!sc", name = "y", descriptor = "I")
	public static int reply = -2;

	@OriginalMember(owner = "client!si", name = "S", descriptor = "[Lclient!na;")
	public static JagString[] suggestedNames;

	@OriginalMember(owner = "client!mh", name = "f", descriptor = "(B)V")
	public static void loop() {
		if (step == 0) {
			return;
		}
		try {
			if (++loops > 2000) {
				if (Protocol.socket != null) {
					Protocol.socket.close();
					Protocol.socket = null;
				}
				if (errors >= 1) {
					reply = -5;
					step = 0;
					return;
				}
				step = 1;
				loops = 0;
				errors++;
				if (client.port == client.defaultPort) {
					client.port = client.alternatePort;
				} else {
					client.port = client.defaultPort;
				}
			}
			if (step == 1) {
				Protocol.socketRequest = GameShell.signLink.openSocket(client.hostname, client.port);
				step = 2;
			}
			@Pc(120) int local120;
			if (step == 2) {
				if (Protocol.socketRequest.status == 2) {
					throw new IOException();
				}
				if (Protocol.socketRequest.status != 1) {
					return;
				}
				Protocol.socket = new BufferedSocket((Socket) Protocol.socketRequest.result, GameShell.signLink);
				Protocol.socketRequest = null;
				Protocol.socket.write(Protocol.outboundBuffer.data, Protocol.outboundBuffer.offset);
				if (client.musicChannel != null) {
					client.musicChannel.method3571();
				}
				if (client.soundChannel != null) {
					client.soundChannel.method3571();
				}
				local120 = Protocol.socket.read();
				if (client.musicChannel != null) {
					client.musicChannel.method3571();
				}
				if (client.soundChannel != null) {
					client.soundChannel.method3571();
				}
				if (local120 != 21) {
					reply = local120;
					step = 0;
					Protocol.socket.close();
					Protocol.socket = null;
					return;
				}
				step = 3;
			}
			if (step == 3) {
				if (Protocol.socket.available() < 1) {
					return;
				}
				suggestedNames = new JagString[Protocol.socket.read()];
				step = 4;
			}
			if (step == 4) {
				if (Protocol.socket.available() < suggestedNames.length * 8) {
					return;
				}
				Protocol.inboundBuffer.offset = 0;
				Protocol.socket.read(0, suggestedNames.length * 8, Protocol.inboundBuffer.data);
				for (local120 = 0; local120 < suggestedNames.length; local120++) {
					suggestedNames[local120] = Base37.decode37(Protocol.inboundBuffer.g8());
				}
				reply = 21;
				step = 0;
				Protocol.socket.close();
				Protocol.socket = null;
			}
		} catch (@Pc(238) IOException ignored) {
			if (Protocol.socket != null) {
				Protocol.socket.close();
				Protocol.socket = null;
			}
			if (errors < 1) {
				errors++;
				if (client.defaultPort == client.port) {
					client.port = client.alternatePort;
				} else {
					client.port = client.defaultPort;
				}
				loops = 0;
				step = 1;
			} else {
				reply = -4;
				step = 0;
			}
		}
	}

	@OriginalMember(owner = "client!gd", name = "a", descriptor = "(JI)V")
	public static void checkName(@OriginalArg(0) long name) {
		Protocol.outboundBuffer.offset = 0;
		Protocol.outboundBuffer.p1(186);
		if (GlobalConfig.LOGIN_USE_STRINGS) {
			Protocol.outboundBuffer.pjstr(Base37.decode37(name));
		} else {
			Protocol.outboundBuffer.p8(name);
		}
		step = 1;
		loops = 0;
		errors = 0;
		reply = -3;
	}

	@OriginalMember(owner = "client!jl", name = "a", descriptor = "(IIIII)V")
	public static void checkInfo(@OriginalArg(0) int year, @OriginalArg(1) int country, @OriginalArg(2) int day, @OriginalArg(3) int month) {
		Protocol.outboundBuffer.offset = 0;
		Protocol.outboundBuffer.p1(147);
		Protocol.outboundBuffer.p1(day);
		Protocol.outboundBuffer.p1(month);
		Protocol.outboundBuffer.p2(year);
		Protocol.outboundBuffer.p2(country);
		loops = 0;
		errors = 0;
		step = 1;
		reply = -3;
	}

	@OriginalMember(owner = "client!da", name = "a", descriptor = "(IIIILclient!na;JI)V")
	public static void createAccount(@OriginalArg(0) int arg0, @OriginalArg(2) int arg1, @OriginalArg(3) int arg2, @OriginalArg(4) JagString password, @OriginalArg(5) long name, @OriginalArg(6) int arg5) {
		@Pc(8) Buffer buffer = new Buffer(GlobalConfig.LOGIN_USE_STRINGS ? 129 : 128);
		buffer.p1(10);
		buffer.p2((int) (Math.random() * 99999.0D));
		buffer.p2(530);
		if (GlobalConfig.LOGIN_USE_STRINGS) {
			buffer.pjstr(Base37.decode37(name));
		} else {
			buffer.p8(name);
		}
		buffer.p4((int) (Math.random() * 9.9999999E7D));
		buffer.pjstr(password);
		buffer.p4((int) (Math.random() * 9.9999999E7D));
		buffer.p2(client.affiliate);
		buffer.p1(arg0);
		buffer.p1(arg2);
		buffer.p4((int) (Math.random() * 9.9999999E7D));
		buffer.p2(arg5);
		buffer.p2(arg1);
		buffer.p4((int) (Math.random() * 9.9999999E7D));
		buffer.rsaenc(GlobalConfig.RSA_EXPONENT, GlobalConfig.RSA_MODULUS);
		Protocol.outboundBuffer.offset = 0;
		Protocol.outboundBuffer.p1(36);
		Protocol.outboundBuffer.p1(buffer.offset);
		Protocol.outboundBuffer.pdata(buffer.data, buffer.offset);
		reply = -3;
		step = 1;
		loops = 0;
		errors = 0;
	}
}