Function ExecuteQemuShellWith

internal/ssh/client.go:313–341

ExecuteQemuShellWith attempts to connect to a QEMU VM using SSH with custom execution context. This function provides full control over the execution context and command executor for connecting directly to QEMU VMs via SSH. The function automatically sets TERM=xterm-256color for better terminal co

(ctx context.Context, execer CommandExecutor, user, vmIP string, jumphost config.SSHJumpHost)

//
// Returns an error if the VM IP is empty or if the SSH connection fails.
func ExecuteQemuShellWith(ctx context.Context, execer CommandExecutor, user, vmIP string, jumphost config.SSHJumpHost) error {
	if vmIP == "" {
		return fmt.Errorf("no IP address available for VM")
	}

	args := buildSSHArgs(user, vmIP, jumphost)
	sshLogger().Debug("SSH QEMU shell: user=%s host=%s jumphost=%+v args=%v", user, vmIP, jumphost, args)
	sshCmd := execer.CommandContext(ctx, "ssh", args...)
	sshCmd.Stdin = os.Stdin
	sshCmd.Stdout = os.Stdout
	sshCmd.Stderr = os.Stderr

	// Set environment variables for better terminal compatibility
	// Override TERM to xterm-256color for better compatibility with remote systems
	// This fixes issues with terminals like Kitty (xterm-kitty) that aren't recognized on all systems
	sshCmd.Env = append(os.Environ(), "TERM=xterm-256color")

	// Execute command using the current process environment and stdin/stdout
	err := sshCmd.Run()

	// Show completion status and wait for user input before returning
	utils.WaitForEnterToReturn(err, "VM SSH session completed successfully", "VM SSH session ended with error")

	if err != nil {
		return fmt.Errorf("failed to connect to VM via SSH: %w", err)
	}

	return nil
}

func buildSSHArgs(user, host string, jumphost config.SSHJumpHost) []string {
	return buildSSHArgsBase(user, host, jumphost)