godot-xterm/examples/socat_terminal/socat_terminal.gd

53 lines
1.3 KiB
GDScript
Raw Normal View History

extends "res://addons/godot_xterm/nodes/terminal/terminal.gd"
export (String) var exec_path := "bash"
export (String) var socat_path := "socat" # E.g. /usr/bin/socat
export (int) var port := 2023
export (bool) var verbose := false
var _timeout = 30
var _pid: int
var _stream := StreamPeerTCP.new()
func _ready():
var args = ["-v"] if verbose else []
args.append("tcp-l:%d,reuseaddr,fork" % port)
args.append("exec:%s,pty,setsid,setpgid,stderr,ctty" % exec_path)
_pid = OS.execute(socat_path, args, false)
func _process(delta):
match _stream.get_status():
StreamPeerTCP.STATUS_NONE, StreamPeerTCP.STATUS_CONNECTING:
_timeout -= 1
if _timeout < 1:
_error("Timeout: could not connect to socat")
if not _stream.is_connected_to_host():
if _stream.connect_to_host("127.0.0.1", port) != OK:
_error("Could not connect to socat")
StreamPeerTCP.STATUS_CONNECTED:
var avail = _stream.get_available_bytes()
var data = PoolByteArray()
for i in range(avail):
data.append(_stream.get_u8())
call_deferred("write", data)
func _on_Terminal_data_sent(data):
if _stream.get_status() == StreamPeerTCP.STATUS_CONNECTED:
_stream.put_data(data)
func _error(message):
push_error(message)
set_process(false)
func _exit_tree():
if OS.kill(_pid) != OK:
push_error("Failed to kill socat")