|
|
@ -25,22 +25,22 @@ def remote_call(arguments): |
|
|
|
""" |
|
|
|
""" |
|
|
|
cmd = ["ssh", "-i", SSH_KEY_FILE, SSH_REMOTE] |
|
|
|
cmd = ["ssh", "-i", SSH_KEY_FILE, SSH_REMOTE] |
|
|
|
cmd.extend(arguments) |
|
|
|
cmd.extend(arguments) |
|
|
|
result = subprocess.run(" ".join(cmd), as_text=True, check=True, |
|
|
|
result = subprocess.run(" ".join(cmd), check=True, |
|
|
|
stdout=subprocess.PIPE, |
|
|
|
stdout=subprocess.PIPE, |
|
|
|
universal_newlines=as_text, shell=True) |
|
|
|
universal_newlines=True, shell=True) |
|
|
|
return result.stdout |
|
|
|
return result.stdout |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def get_local_backup_members(): |
|
|
|
def get_local_backup_members(): |
|
|
|
tmp_folder = pathlib.Path(TMP_BACKUP_FOLDER) |
|
|
|
tmp_folder = pathlib.Path(TMP_BACKUP_FOLDER) |
|
|
|
backups = (i for i in tmp_folder.iterdir() if i.suffix==".gz") |
|
|
|
backups = (i for i in tmp_folder.iterdir() if i.suffix==".gz") |
|
|
|
return (get_member_name(b.name) for b in backups) |
|
|
|
return {get_member_name(b.name) for b in backups} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def get_remote_checksums(): |
|
|
|
def get_remote_checksums(): |
|
|
|
result = {} |
|
|
|
result = {} |
|
|
|
for member in get_local_backup_members(): |
|
|
|
for member in get_local_backup_members(): |
|
|
|
remote_path = f"~/{REMOTE_PATH}/{member}/\*" |
|
|
|
remote_path = f"{REMOTE_PATH}/{member}/\*" |
|
|
|
cmd_result = remote_call(["sha256sum", remote_path]) |
|
|
|
cmd_result = remote_call(["sha256sum", remote_path]) |
|
|
|
print(cmd_result) |
|
|
|
print(cmd_result) |
|
|
|
|
|
|
|
|
|
|
|