package de.zh32.teleportsigns.server.status;

import com.google.gson.Gson;

import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.nio.charset.Charset;

/**
 * @author zh32
 */
public class QueryHandler {
	private final ServerListPing.ServerConnection connection;
	private static final Gson gson = new Gson();

	public QueryHandler(ServerListPing.ServerConnection connection) {
		this.connection = connection;
	}

	public void doHandShake() throws IOException {
		ByteArrayOutputStream bs = new ByteArrayOutputStream();
		DataOutputStream out = new DataOutputStream(bs);
		out.write(0x00); //packet id
		writeVarInt(out, 4); //protocol version
		writeString(out, connection.getHost().getHostString());
		out.writeShort(connection.getHost().getPort());
		writeVarInt(out, 1); //target state 1
		sendPacket(bs.toByteArray());
	}

	public StatusResponse doStatusQuery() throws Exception {
		sendPacket(new byte[]{0x00});
		int size = readVarInt(connection.getDataInputStream());
		int packetId = readVarInt(connection.getDataInputStream());
		if (packetId != 0x00) {
			throw new IOException("Invalid packetId");
		}
		int stringLength = readVarInt(connection.getDataInputStream());
		if (stringLength < 1) {
			throw new IOException("Invalid string length.");
		}
		byte[] responseData = new byte[stringLength];
		connection.getDataInputStream().readFully(responseData);
		String jsonString = new String(responseData, Charset.forName("utf-8"));
		StatusResponse response = gson.fromJson(jsonString, StatusResponse.class);
		return response;
	}

	private void sendPacket(byte[] data) throws IOException {
		writeVarInt(connection.getDataOutputStream(), data.length);
		connection.getDataOutputStream().write(data);
	}

	private int readVarInt(DataInputStream in) throws IOException {
		int i = 0;
		int j = 0;
		while (true) {
			int k = in.readByte();
			i |= (k & 0x7F) << j++ * 7;
			if (j > 5) {
				throw new RuntimeException("VarInt too big");
			}
			if ((k & 0x80) != 128) {
				break;
			}
		}
		return i;
	}

	private void writeVarInt(DataOutputStream out, int paramInt) throws IOException {
		while (true) {
			if ((paramInt & 0xFFFFFF80) == 0) {
				out.write(paramInt);
				return;
			}
			out.write(paramInt & 0x7F | 0x80);
			paramInt >>>= 7;
		}
	}

	private void writeString(DataOutputStream out, String string) throws IOException {
		writeVarInt(out, string.length());
		out.write(string.getBytes(Charset.forName("utf-8")));
	}

}

@@ -1530,33 +1530,14 @@
 ;%0A%09%09
-StatusResponse response =
+return
  gso
@@ -1586,27 +1586,8 @@
 s);%0A
-%09%09return response;%0A
 %09%7D%0A%0A

Refactor code