clan/clan-core
11
2
Fork 14
Code Issues 92 Pull Requests 3 Actions 2 Packages Projects 1 Releases Wiki Activity

ssh: add interactive flag

Browse Source
This commit is contained in:
Jörg Thalheim 2024-03-26 12:39:27 +01:00
parent 0e2cb172e6
commit c5db14dea8
1 changed files with 40 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
pkgs/clan-cli/clan_cli/ssh/__init__.py
View File

@ -270,30 +270,37 @@ class Host:
cwd: None | str | Path = None,
check: bool = True,
timeout: float = math.inf,
interactive: bool = False,
) -> subprocess.CompletedProcess[str]:
with ExitStack() as stack:
read_std_fd, write_std_fd = (None, None)
read_err_fd, write_err_fd = (None, None)
if stdout is None or stderr is None:
if not interactive and (stdout is None or stderr is None):
read_std_fd, write_std_fd = stack.enter_context(_pipe())
read_err_fd, write_err_fd = stack.enter_context(_pipe())
if stdout is None:
if interactive:
stdout_read = None
stdout_write = write_std_fd
elif stdout == subprocess.PIPE:
stdout_read, stdout_write = stack.enter_context(_pipe())
else:
raise Exception(f"unsupported value for stdout parameter: {stdout}")
if stderr is None:
stderr_read = None
stderr_write = write_err_fd
elif stderr == subprocess.PIPE:
stderr_read, stderr_write = stack.enter_context(_pipe())
stdout_write: IO[str] | None = sys.stdout
stderr_write: IO[str] | None = sys.stderr
else:
raise Exception(f"unsupported value for stderr parameter: {stderr}")
if stdout is None:
stdout_read = None
stdout_write = write_std_fd
elif stdout == subprocess.PIPE:
stdout_read, stdout_write = stack.enter_context(_pipe())
else:
raise Exception(f"unsupported value for stdout parameter: {stdout}")
if stderr is None:
stderr_read = None
stderr_write = write_err_fd
elif stderr == subprocess.PIPE:
stderr_read, stderr_write = stack.enter_context(_pipe())
else:
raise Exception(f"unsupported value for stderr parameter: {stderr}")
env = os.environ.copy()
env.update(extra_env)
@ -319,14 +326,17 @@ class Host:
stderr_write.close()
start = time.time()
stdout_data, stderr_data = self._prefix_output(
displayed_cmd,
read_std_fd,
read_err_fd,
stdout_read,
stderr_read,
timeout,
)
if interactive:
stdout_data, stderr_data = "", ""
else:
stdout_data, stderr_data = self._prefix_output(
displayed_cmd,
read_std_fd,
read_err_fd,
stdout_read,
stderr_read,
timeout,
)
try:
ret = p.wait(timeout=max(0, timeout - (time.time() - start)))
except subprocess.TimeoutExpired:
@ -356,6 +366,7 @@ class Host:
cwd: None | str | Path = None,
check: bool = True,
timeout: float = math.inf,
interactive: bool = False,
) -> subprocess.CompletedProcess[str]:
"""
Command to run locally for the host
@ -387,6 +398,7 @@ class Host:
cwd=cwd,
check=check,
timeout=timeout,
interactive=interactive,
)
def run(
@ -398,8 +410,9 @@ class Host:
extra_env: dict[str, str] = {},
cwd: None | str | Path = None,
check: bool = True,
verbose_ssh: bool = False,
timeout: float = math.inf,
interactive: bool = False,
verbose_ssh: bool = False,
tty: bool = True,
) -> subprocess.CompletedProcess[str]:
"""
@ -458,6 +471,7 @@ class Host:
cwd=cwd,
check=check,
timeout=timeout,
interactive=interactive,
)
def ssh_cmd(
@ -623,9 +637,10 @@ class HostGroup:
extra_env: dict[str, str] = {},
cwd: None | str | Path = None,
check: bool = True,
timeout: float = math.inf,
interactive: bool = False,
verbose_ssh: bool = False,
tty: bool = True,
timeout: float = math.inf,
) -> Results:
results: Results = []
threads = []
@ -642,8 +657,9 @@ class HostGroup:
extra_env=extra_env,
cwd=cwd,
check=check,
verbose_ssh=verbose_ssh,
timeout=timeout,
interactive=interactive,
verbose_ssh=verbose_ssh,
tty=tty,
),
)