mirror of
https://github.com/lihop/godot-xterm.git
synced 2024-11-25 18:50:25 +01:00
53 lines
1.3 KiB
GDScript3
53 lines
1.3 KiB
GDScript3
|
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")
|