yadunut/clan-core
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

clan-cli: Make host upload function support uploading single files too

Browse Source
This commit is contained in:
Qubasa
2025-03-01 17:10:39 +01:00
parent bcd6c7108a
commit 6099aeb0c6
1 changed files with 70 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
pkgs/clan-cli/clan_cli/ssh/upload.py
View File

@@ -4,7 +4,6 @@ from tempfile import TemporaryDirectory
from clan_cli.cmd import Log, RunOpts from clan_cli.cmd import Log, RunOpts
from clan_cli.cmd import run as run_local from clan_cli.cmd import run as run_local
from clan_cli.errors import ClanError
from clan_cli.ssh.host import Host from clan_cli.ssh.host import Host
@@ -17,15 +16,6 @@ def upload(
dir_mode: int = 0o700, dir_mode: int = 0o700,
file_mode: int = 0o400, file_mode: int = 0o400,
) -> None: ) -> None:
# check if the remote destination is a directory (no suffix)
if remote_dest.suffix:
msg = "Only directories are allowed"
raise ClanError(msg)
if not local_src.is_dir():
msg = "Only directories are allowed"
raise ClanError(msg)
# Create the tarball from the temporary directory # Create the tarball from the temporary directory
with TemporaryDirectory(prefix="facts-upload-") as tardir: with TemporaryDirectory(prefix="facts-upload-") as tardir:
tar_path = Path(tardir) / "upload.tar.gz" tar_path = Path(tardir) / "upload.tar.gz"
@@ -33,6 +23,8 @@ def upload(
# As first uploading the tarball and then changing the permissions can lead an attacker to # As first uploading the tarball and then changing the permissions can lead an attacker to
# do a race condition attack # do a race condition attack
with tarfile.open(str(tar_path), "w:gz") as tar: with tarfile.open(str(tar_path), "w:gz") as tar:
if local_src.is_dir():
# Handle directory upload
for root, dirs, files in local_src.walk(): for root, dirs, files in local_src.walk():
for mdir in dirs: for mdir in dirs:
dir_path = Path(root) / mdir dir_path = Path(root) / mdir
@@ -54,7 +46,16 @@ def upload(
tarinfo.gname = file_group tarinfo.gname = file_group
with file_path.open("rb") as f: with file_path.open("rb") as f:
tar.addfile(tarinfo, f) tar.addfile(tarinfo, f)
else:
# Handle single file upload
tarinfo = tar.gettarinfo(local_src, arcname=remote_dest.name)
tarinfo.mode = file_mode
tarinfo.uname = file_user
tarinfo.gname = file_group
with local_src.open("rb") as f:
tar.addfile(tarinfo, f)
if local_src.is_dir():
cmd = [ cmd = [
*host.ssh_cmd(), *host.ssh_cmd(),
"rm", "rm",
@@ -73,6 +74,26 @@ def upload(
"-xzf", "-xzf",
"-", "-",
] ]
else:
# For single file, extract to parent directory and ensure correct name
cmd = [
*host.ssh_cmd(),
"rm",
"-f",
str(remote_dest),
";",
"mkdir",
"-m",
f"{dir_mode:o}",
"-p",
str(remote_dest.parent),
"&&",
"tar",
"-C",
str(remote_dest.parent),
"-xzf",
"-",
]
# TODO accept `input` to be an IO object instead of bytes so that we don't have to read the tarfile into memory. # TODO accept `input` to be an IO object instead of bytes so that we don't have to read the tarfile into memory.
with tar_path.open("rb") as f: with tar_path.open("rb") as f: