backupmanager_ynh/sources/jobs/transfer.py

import os
import re
import subprocess


def generate_key(dest_name, data_dir):
    """Génère une paire de clés ed25519 pour cette destination si elle n'existe pas encore."""
    key_name = f"dest_{_slugify(dest_name)}_ed25519"
    key_path = os.path.join(data_dir, "keys", key_name)
    if not os.path.exists(key_path):
        subprocess.run(
            [
                "ssh-keygen", "-t", "ed25519",
                "-f", key_path,
                "-N", "",
                "-C", f"backupmanager@{dest_name}",
            ],
            check=True,
            capture_output=True,
        )
        os.chmod(key_path, 0o600)
    return key_name


def get_public_key(key_name, data_dir):
    """Retourne la clé publique à copier dans authorized_keys sur le serveur distant."""
    pub_path = os.path.join(data_dir, "keys", key_name + ".pub")
    try:
        with open(pub_path) as f:
            return f.read().strip()
    except FileNotFoundError:
        return None


def transfer_archive(archive_name, destination, backup_dir, data_dir):
    """Transfère .tar + .info.json vers la destination via rsync SSH."""
    key_path = os.path.join(data_dir, "keys", destination.key_name)
    if not os.path.exists(key_path):
        raise FileNotFoundError(
            f"Clé SSH introuvable : {key_path}\n"
            "Accédez à la page de la destination pour afficher la clé publique."
        )

    files = []
    for ext in (".tar", ".info.json"):
        path = os.path.join(backup_dir, archive_name + ext)
        if os.path.exists(path):
            files.append(path)

    if not files:
        raise FileNotFoundError(f"Aucun fichier à transférer pour {archive_name}.")

    remote = f"{destination.user}@{destination.host}:{destination.remote_path}/"
    ssh_opts = (
        f"ssh -i {key_path} -p {destination.port}"
        " -o StrictHostKeyChecking=accept-new"
        " -o BatchMode=yes"
        " -o ConnectTimeout=30"
    )

    # sudo car les archives YNH (ynh_app/ynh_system) sont owned root
    cmd = ["sudo", "rsync", "-az", "--stats", "-e", ssh_opts] + files + [remote]
    result = subprocess.run(cmd, capture_output=True, text=True, timeout=7200)
    log = (result.stdout + result.stderr).strip()

    if result.returncode != 0:
        raise RuntimeError(
            f"rsync vers {destination.host} échoué (code {result.returncode}) :\n{log}"
        )
    return log


def test_connection(destination, data_dir):
    """Teste la connexion SSH vers la destination. Retourne (True, msg) ou (False, msg)."""
    key_path = os.path.join(data_dir, "keys", destination.key_name)
    if not os.path.exists(key_path):
        return False, "Clé SSH non générée. Affichez la destination pour la créer."

    result = subprocess.run(
        [
            "ssh",
            "-i", key_path,
            "-p", str(destination.port),
            "-o", "StrictHostKeyChecking=accept-new",
            "-o", "BatchMode=yes",
            "-o", "ConnectTimeout=10",
            f"{destination.user}@{destination.host}",
            "echo ok",
        ],
        capture_output=True,
        text=True,
        timeout=20,
    )
    if result.returncode == 0:
        return True, f"Connexion réussie vers {destination.host}:{destination.port}."
    return False, result.stderr.strip() or f"Connexion échouée (code {result.returncode})."


def _slugify(s):
    return re.sub(r'[^a-z0-9]+', '-', s.lower().strip()).strip('-')