class_name LoginServer


signal received_packet(packet: Packet)
signal logged_in(packet: LoginServerLoginSuccessPacket)

var host: String
var port: int = 6900
var stream: PacketPeerStream = PacketPeerStream.new()
var peer: StreamPeerTCP = StreamPeerTCP.new()


@warning_ignore("shadowed_variable")
func _init(host: String, port: int = 6900) -> void:
	self.host = host
	self.port = port
	
	stream.stream_peer = peer
	peer.connect_to_host(host, port)
	peer.poll()


## Emits [signal received_packet].
func listen() -> void:
	if peer.get_status() == StreamPeerTCP.Status.STATUS_CONNECTED:
		var raw_packet: PackedByteArray = peer.get_partial_data(2)[1]
		if raw_packet.size() > 0:
			raw_packet += peer.get_data(peer.get_available_bytes())[1]
			var header = raw_packet.decode_u16(0)
			var packet_type = Constants.PacketDB[header]
			var packet = packet_type.from_bytes(raw_packet)
		
			received_packet.emit(packet)


func login(username: String, password: String):
	var login_server_login_packet = LoginServerLoginPacket.new()
	login_server_login_packet.username = username
	login_server_login_packet.password = password
	
	peer.put_data(login_server_login_packet.to_bytes())
	
	var packet = await received_packet
	if packet is LoginServerLoginSuccessPacket:
		print(inst_to_dict(packet))
		logged_in.emit(packet)