Fix failing to start shell being hidden from user

Signed-off-by: Sebastian Malton <[email protected]>

Author: Nokel81

src/common/terminal/channels.ts

@@ -10,6 +10,7 @@ export enum TerminalChannels {
   CONNECTED = "connected",
   RESIZE = "resize",
   PING = "ping",
+  ERROR = "error",
 }
 
 export type TerminalMessage = {
@@ -28,4 +29,7 @@ export type TerminalMessage = {
   };
 } | {
   type: TerminalChannels.PING;
+} | {
+  type: TerminalChannels.ERROR;
+  data: string;
 };

src/main/shell-session/local-shell-session/local-shell-session.ts

@@ -11,6 +11,8 @@ import type { ClusterId } from "../../../common/cluster-types";
 import { ShellSession } from "../shell-session";
 import type { Kubectl } from "../../kubectl/kubectl";
 import { baseBinariesDir } from "../../../common/vars";
+import { TerminalChannels } from "../../../common/terminal/channels";
+import logger from "../../logger";
 
 export class LocalShellSession extends ShellSession {
   ShellType = "shell";
@@ -36,7 +38,13 @@ export class LocalShellSession extends ShellSession {
     const shell = env.PTYSHELL;
 
     if (!shell) {
-      throw new Error("PTYSHELL is not defined with the environment");
+      this.send({
+        type: TerminalChannels.ERROR,
+        data: "PTYSHELL is not defined with the environment",
+      });
+      logger.warn(`[LOCAL-SHELL-SESSION]: PTYSHELL env var is not defined for ${this.terminalId}`);
+
+      return;
     }
 
     const args = await this.getShellArgs(shell);

src/main/shell-session/shell-session.ts

@@ -133,23 +133,35 @@ export abstract class ShellSession {
 
   protected abstract get cwd(): string | undefined;
 
-  protected ensureShellProcess(shell: string, args: string[], env: Record<string, string | undefined>, cwd: string): { shellProcess: pty.IPty; resume: boolean } {
-    const resume = ShellSession.processes.has(this.terminalId);
-    const shellProcess = getOrInsertWith(ShellSession.processes, this.terminalId, () => (
-      pty.spawn(shell, args, {
-        rows: 30,
-        cols: 80,
-        cwd,
-        env: env as Record<string, string>,
-        name: "xterm-256color",
-        // TODO: Something else is broken here so we need to force the use of winPty on windows
-        useConpty: false,
-      })
-    ));
-
-    logger.info(`[SHELL-SESSION]: PTY for ${this.terminalId} is ${resume ? "resumed" : "started"} with PID=${shellProcess.pid}`);
+  protected ensureShellProcess(shell: string, args: string[], env: Record<string, string | undefined>, cwd: string): { shellProcess: pty.IPty; resume: boolean } | null {
+    try {
+      const resume = ShellSession.processes.has(this.terminalId);
+
+      throw new Error("failed");
+      const shellProcess = getOrInsertWith(ShellSession.processes, this.terminalId, () => (
+        pty.spawn(shell, args, {
+          rows: 30,
+          cols: 80,
+          cwd,
+          env: env as Record<string, string>,
+          name: "xterm-256color",
+          // TODO: Something else is broken here so we need to force the use of winPty on windows
+          useConpty: false,
+        })
+      ));
+
+      logger.info(`[SHELL-SESSION]: PTY for ${this.terminalId} is ${resume ? "resumed" : "started"} with PID=${shellProcess.pid}`);
+
+      return { shellProcess, resume };
+    } catch (error) {
+      this.send({
+        type: TerminalChannels.ERROR,
+        data: `Failed to start shell (${shell}): ${error}`,
+      });
+      logger.warn(`[SHELL-SESSION]: Failed to start PTY for ${this.terminalId}: ${error}`, { shell });
 
-    return { shellProcess, resume };
+      return null;
+    }
   }
 
   constructor(protected readonly kubectl: Kubectl, protected readonly websocket: WebSocket, protected readonly cluster: Cluster, terminalId: string) {
@@ -205,7 +217,13 @@ export abstract class ShellSession {
 
   protected async openShellProcess(shell: string, args: string[], env: Record<string, string | undefined>) {
     const cwd = await this.getCwd(env);
-    const { shellProcess, resume } = this.ensureShellProcess(shell, args, env, cwd);
+    const ensured = this.ensureShellProcess(shell, args, env, cwd);
+
+    if (!ensured) {
+      return;
+    }
+
+    const { shellProcess, resume } = ensured;
 
     if (resume) {
       this.send({ type: TerminalChannels.CONNECTED });

src/renderer/api/terminal-api.ts

@@ -34,6 +34,7 @@ export interface TerminalApiQuery extends Record<string, string | undefined> {
 export interface TerminalEvents extends WebSocketEvents {
   ready: () => void;
   connected: () => void;
+  error: (error: string) => void;
 }
 
 export interface TerminalApiDependencies {
@@ -144,6 +145,9 @@ export class TerminalApi extends WebSocketApi<TerminalEvents> {
         case TerminalChannels.CONNECTED:
           this.emit("connected");
           break;
+        case TerminalChannels.ERROR:
+          this.emit("error", message.data);
+          break;
         default:
           logger.warn(`[TERMINAL-API]: unknown or unhandleable message type`, message);
           break;

src/renderer/components/dock/terminal/terminal.ts

@@ -106,6 +106,7 @@ export class Terminal {
     this.api.once("ready", clearOnce);
     this.api.once("connected", clearOnce);
     this.api.on("data", this.onApiData);
+    this.api.on("error", this.onApiError);
     window.addEventListener("resize", this.onResize);
 
     this.disposer.push(
@@ -153,6 +154,10 @@ export class Terminal {
     this.xterm.write(data);
   };
 
+  onApiError = (data: string) => {
+    this.xterm.writeln(data);
+  };
+
   onData = (data: string) => {
     if (!this.api.isReady) return;
     this.api.sendMessage({