Console Preparations

Author: AttAditya

setup_hook.py

@@ -17,6 +17,7 @@ def run_hook(release_path: str, data_path: str) -> None:
       "editor",
       "desktop-service",
       "runtimes",
+      "console",
     ])
   }
 

src/utils/shellhost.py

@@ -0,0 +1,79 @@
+from typing import IO, Self, Callable, TypeAlias
+
+from subprocess import Popen, PIPE, STDOUT
+from threading import Thread
+
+OutputCallback: TypeAlias = Callable[[str], None]
+FinishedCallback: TypeAlias = Callable[[], None]
+
+class ShellProcess:
+  process: Popen[str] | None = None
+  output_callbacks: list[OutputCallback] = []
+  finished_callbacks: list[FinishedCallback] = []
+
+  def __init__(
+    self: Self,
+    args: list[str],
+    output_callbacks: list[OutputCallback],
+    finished_callbacks: list[FinishedCallback] = [],
+  ) -> None:
+    self.output_callbacks = output_callbacks
+    self.finished_callbacks = finished_callbacks
+    self.process = Popen(
+      args,
+      stdin=PIPE,
+      stdout=PIPE,
+      stderr=STDOUT,
+      universal_newlines=True
+    )
+
+    thread = Thread(
+      target=self.reader_thread,
+      args=(self.process.stdout,)
+    )
+
+    thread.daemon = True
+    thread.start()
+
+  def on_flush(self: Self, chunk: str):
+    for callback in self.output_callbacks:
+      callback(chunk)
+
+  def alert_finished(self: Self) -> None:
+    for callback in self.finished_callbacks:
+      callback()
+  
+  def reader_thread(self: Self, stdout_pipe: IO[str] | None):
+    if not stdout_pipe:
+      return
+    
+    buffer = ""
+
+    while True:
+      char = stdout_pipe.read(1)
+
+      if not char:
+        if buffer:
+          self.on_flush(buffer)
+          buffer = ""
+        
+        self.alert_finished()
+        break
+
+      buffer += char
+
+      if char in ['\n', '\r']:
+        self.on_flush(buffer)
+        buffer = ""
+  
+  def push_input(self: Self, input_data: str) -> None:
+    if self.process and self.process.stdin:
+      self.process.stdin.write(input_data + "\n")
+      self.process.stdin.flush()
+
+  def terminate(self: Self) -> None:
+    if self.process:
+      self.process.terminate()
+      self.process.wait()
+      self.process = None
+

src/windows/base.py

@@ -16,13 +16,15 @@ def __init__(
     frameless: bool = True,
     fulldrag: bool = False,
     resizable: bool = True,
+    min_dims: tuple[int, int] = (200, 100),
   ) -> None:
     self.window = create_window(
       title=title,
       url=url,
       js_api=self,
       width=dims[0],
       height=dims[1],
+      min_size=min_dims,
       transparent=acryllic,
       vibrancy=acryllic,
       frameless=frameless,

src/windows/console.py

@@ -0,0 +1,52 @@
+from typing import Self
+
+from utils.updater import Updater
+from utils.shellhost import ShellProcess
+
+from windows.base import Base
+
+class Console(Base):
+  updater: Updater
+  shell: ShellProcess
+  filepath: str
+
+  def __init__(
+    self: Self,
+    url: str,
+    filepath: str,
+  ) -> None:
+    super().__init__(
+      url=url,
+      title="GraphScript Launcher",
+      dims=(900, 600),
+      min_dims=(480, 320),
+    )
+
+    self.filepath = filepath
+    self.window.events.loaded += self.start_shell
+
+  def close(self: Self) -> None:
+    if self.shell: self.shell.terminate()
+    super().close()
+  
+  def add_console_output(self: Self, message: str) -> None:
+    self.window.evaluate_js(
+      f"window.pushConsoleOutput({repr(message)});"
+    )
+  
+  def emit_finished(self: Self) -> None:
+    self.window.evaluate_js("window.emitFinished();")
+
+  def start_shell(self: Self) -> None:
+    self.shell = ShellProcess(
+      [
+        "gsam",
+        self.filepath,
+      ],
+      [self.add_console_output],
+      [self.emit_finished]
+    )
+
+  def push_input(self: Self, input_data: str) -> None:
+    self.shell.push_input(input_data)
+