oh-my-git/scenes/tcp_server.gd

extends Node

signal data_received(string)
signal new_connection

@export var port: int

var _s = TCPServer.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()
			helpers.crash("Dropping active connection")
		_c = _s.take_connection()
		_connected = true
		emit_signal("new_connection")
		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_utf8_string(text)
		var response = _c.get_utf8_string()
		emit_signal("data_received", response)
	else:
		helpers.crash("Trying to send data on closed connection")