mirror of
https://github.com/lihop/godot-xterm.git
synced 2024-09-20 08:26:20 +02:00
60 lines
1.7 KiB
GDScript
60 lines
1.7 KiB
GDScript
# Copyright (c) 2020 The GodotTerm authors. All rights reserved.
|
|
# License MIT
|
|
extends Control
|
|
|
|
|
|
signal data_received(data)
|
|
|
|
|
|
# The user must have these programs installed for this to work.
|
|
const dependencies = PoolStringArray(['which', 'socat', 'bash'])
|
|
const host = '127.0.0.1'
|
|
const port = 17154
|
|
|
|
|
|
var socat_pid = -1
|
|
var stream_peer = StreamPeerTCP.new()
|
|
|
|
|
|
func _ready():
|
|
# First check that dependencies are installed and in $PATH.
|
|
var exit_code = OS.execute("which", dependencies)
|
|
if exit_code != 0:
|
|
OS.alert("Make sure the following programs are installed and in your $PATH: " + \
|
|
dependencies.join(", ") + ".", "Misssing Dependencies!")
|
|
|
|
# Start socat.
|
|
socat_pid = OS.execute("socat",
|
|
["-d", "-d", "tcp-l:%d,bind=%s,reuseaddr,fork" % [port, host],
|
|
"exec:bash,pty,setsid,stderr,login,ctty"], false)
|
|
|
|
# Create a StreamPeerTCP to connect to socat.
|
|
var err = stream_peer.connect_to_host(host, port)
|
|
if err != OK:
|
|
OS.alert("Couldn't connect to socat on %s:%d" % [host, port], "Connection Failed!")
|
|
|
|
|
|
var status = stream_peer.get_status()
|
|
var connected = stream_peer.is_connected_to_host()
|
|
|
|
# Connect the Terminal and StreamPeer.
|
|
$Terminal.connect('data_sent', self, 'send_data')
|
|
connect("data_received", $Terminal, "receive_data")
|
|
|
|
|
|
func send_data(data: PoolByteArray):
|
|
stream_peer.put_data(data)
|
|
|
|
|
|
func _process(delta):
|
|
if stream_peer.get_status() == StreamPeerTCP.STATUS_CONNECTED:
|
|
var res = stream_peer.get_data(stream_peer.get_available_bytes())
|
|
var error = res[0]
|
|
var data = res[1]
|
|
if error == OK and not data.empty():
|
|
emit_signal("data_received", data)
|
|
|
|
|
|
func _exit_tree():
|
|
if socat_pid != -1:
|
|
OS.execute("kill", ["-9", socat_pid], false)
|