oh-my-git/tcp_server.gd

extends Node

signal data_received(string)

export var port: int

var _s = TCP_Server.new()
var _c
var _connected = false

func _ready():
	start()

func start():
	_s.listen(port)
		
func _process(_delta):
	if _s.is_connection_available():
		if _connected:
			_c.disconnect_from_host()
			push_error("Dropping active connection")
		_c = _s.take_connection()
		_connected = true
		print("connected!")
	
	if _connected:
		if _c.get_status() != StreamPeerTCP.STATUS_CONNECTED:
			_connected = false
			print("disconnected")
		var available = _c.get_available_bytes()
		while available > 0:
			var data = _c.get_utf8_string(available)
			emit_signal("data_received", data)
			available = _c.get_available_bytes()

func send(text):
	if _connected:
		text += "\n"
		_c.put_data(text.to_utf8())
	else:
		push_error("Trying to send data on closed connection")