mirror of
https://github.com/lihop/godot-xterm.git
synced 2024-11-10 04:40:25 +01:00
e830db667c
* Godot 4.x seems to require call StreamPeerTCP.poll * add missing signal connection (data from terminal to network)
53 lines
1.3 KiB
GDScript
53 lines
1.3 KiB
GDScript
extends Terminal
|
|
|
|
@export var exec_path := "bash"
|
|
@export var socat_path := "socat" # E.g. /usr/bin/socat
|
|
@export var port := 2023
|
|
@export 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.create_process(socat_path, args)
|
|
|
|
|
|
func _process(delta):
|
|
_stream.poll()
|
|
match _stream.get_status():
|
|
StreamPeerTCP.STATUS_NONE, StreamPeerTCP.STATUS_CONNECTING:
|
|
_timeout -= 1
|
|
if _timeout < 1:
|
|
_error("Timeout: could not connect to socat")
|
|
|
|
if _stream.get_connected_host().is_empty():
|
|
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 = PackedByteArray()
|
|
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")
|