2020-09-15 09:30:19 +02:00
|
|
|
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)
|
|
|
|
|
|
2020-09-15 12:36:22 +02:00
|
|
|
func _process(_delta):
|
2020-09-15 09:30:19 +02:00
|
|
|
if _s.is_connection_available():
|
|
|
|
|
if _connected:
|
|
|
|
|
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:
|
|
|
|
|
_c.put_utf8_string(text)
|
|
|
|
|
else:
|
|
|
|
|
push_error("Trying to send data on closed connection")
|
