forked from clan/clan-core
implement backup cli for borgbackup
This commit is contained in:
parent
4ace326aeb
commit
e772d29f44
@ -16,7 +16,7 @@
|
||||
{
|
||||
clanCore.machineName = "machine";
|
||||
clanCore.clanDir = ./.;
|
||||
clanCore.state."/etc/state" = { };
|
||||
clanCore.state.testState.folders = [ "/etc/state" ];
|
||||
environment.etc.state.text = "hello world";
|
||||
clan.borgbackup = {
|
||||
enable = true;
|
||||
|
@ -33,7 +33,7 @@ in
|
||||
config = lib.mkIf cfg.enable {
|
||||
services.borgbackup.jobs = lib.mapAttrs
|
||||
(_: dest: {
|
||||
paths = map (state: state.folder) (lib.attrValues config.clanCore.state);
|
||||
paths = lib.flatten (map (state: state.folders) (lib.attrValues config.clanCore.state));
|
||||
exclude = [
|
||||
"*.pyc"
|
||||
];
|
||||
@ -58,16 +58,23 @@ in
|
||||
clanCore.backups.providers.borgbackup = {
|
||||
list = ''
|
||||
${lib.concatMapStringsSep "\n" (dest: ''
|
||||
echo listing backups for ${dest}
|
||||
borg-job-${dest} list
|
||||
'') cfg.destinations}
|
||||
(
|
||||
export BORG_REPO=${lib.escapeShellArg dest.repo}
|
||||
export BORG_RSH=${lib.escapeShellArg dest.rsh}
|
||||
${lib.getExe config.services.borgbackup.package} list
|
||||
)
|
||||
'') (lib.attrValues cfg.destinations)}
|
||||
'';
|
||||
start = ''
|
||||
${lib.concatMapStringsSep "\n" (dest: ''
|
||||
systemctl start borgbackup-job-${dest}
|
||||
'') cfg.destinations}
|
||||
ssh ${config.clan.networking.deploymentAddress} -- '
|
||||
${lib.concatMapStringsSep "\n" (dest: ''
|
||||
systemctl start borgbackup-job-${dest.name}
|
||||
'') (lib.attrValues cfg.destinations)}
|
||||
'
|
||||
'';
|
||||
|
||||
restore = ''
|
||||
'';
|
||||
};
|
||||
};
|
||||
}
|
||||
|
@ -3,15 +3,22 @@
|
||||
options.clanCore.state = lib.mkOption {
|
||||
default = { };
|
||||
type = lib.types.attrsOf
|
||||
(lib.types.submodule ({ name, ... }: {
|
||||
(lib.types.submodule ({ ... }: {
|
||||
options = {
|
||||
folder = lib.mkOption {
|
||||
type = lib.types.str;
|
||||
default = name;
|
||||
folders = lib.mkOption {
|
||||
type = lib.types.listOf lib.types.str;
|
||||
description = ''
|
||||
Folder where state resides in
|
||||
'';
|
||||
};
|
||||
restoreScript = lib.mkOption {
|
||||
type = lib.types.str;
|
||||
default = ":";
|
||||
description = ''
|
||||
script to restore the service after the state dir was restored from a backup
|
||||
'';
|
||||
|
||||
};
|
||||
};
|
||||
}));
|
||||
};
|
||||
@ -32,10 +39,11 @@
|
||||
script to list backups
|
||||
'';
|
||||
};
|
||||
delete = lib.mkOption {
|
||||
restore = lib.mkOption {
|
||||
type = lib.types.str;
|
||||
description = ''
|
||||
script to delete a backup
|
||||
script to restore a backup
|
||||
should take an optional service name as argument
|
||||
'';
|
||||
};
|
||||
start = lib.mkOption {
|
||||
|
@ -147,6 +147,8 @@ in
|
||||
--network-id "$facts/zerotier-network-id"
|
||||
'';
|
||||
};
|
||||
clanCore.state.zerotier.folders = [ "/var/lib/zerotier-one" ];
|
||||
|
||||
environment.systemPackages = [ config.clanCore.clanPkgs.zerotier-members ];
|
||||
})
|
||||
(lib.mkIf (config.clanCore.secretsUploadDirectory != null && !cfg.controller.enable && cfg.networkId != null) {
|
||||
|
@ -5,7 +5,7 @@ from pathlib import Path
|
||||
from types import ModuleType
|
||||
from typing import Any, Optional, Sequence
|
||||
|
||||
from . import config, flakes, machines, secrets, vms, webui, backups
|
||||
from . import backups, config, flakes, machines, secrets, vms, webui
|
||||
from .custom_logger import setup_logging
|
||||
from .dirs import get_clan_flake_toplevel
|
||||
from .ssh import cli as ssh_cli
|
||||
|
@ -1,8 +1,8 @@
|
||||
# !/usr/bin/env python3
|
||||
import argparse
|
||||
|
||||
from .list import register_list_parser
|
||||
from .create import register_create_parser
|
||||
from .list import register_list_parser
|
||||
from .restore import register_restore_parser
|
||||
|
||||
|
||||
|
@ -1,34 +1,45 @@
|
||||
import argparse
|
||||
import pprint
|
||||
from pathlib import Path
|
||||
import json
|
||||
import subprocess
|
||||
from typing import Optional
|
||||
|
||||
from ..errors import ClanError
|
||||
from ..machines.machines import Machine
|
||||
|
||||
|
||||
def create_backup(flake_dir: Path, machine: Optional[str] = None, provider: Optional[str] = None) -> None:
|
||||
if machine is None:
|
||||
# TODO get all machines here
|
||||
machines = [ "machine1", "machine2" ]
|
||||
else:
|
||||
machines = [ machine ]
|
||||
|
||||
def create_backup(machine: Machine, provider: Optional[str] = None) -> None:
|
||||
backup_scripts = json.loads(
|
||||
machine.eval_nix(f"nixosConfigurations.{machine.name}.config.clanCore.backups")
|
||||
)
|
||||
if provider is None:
|
||||
# TODO get all providers here
|
||||
providers = [ "provider1", "provider2" ]
|
||||
for provider in backup_scripts["providers"]:
|
||||
proc = subprocess.run(
|
||||
["bash", "-c", backup_scripts["providers"][provider]["start"]],
|
||||
)
|
||||
if proc.returncode != 0:
|
||||
raise ClanError("failed to start backup")
|
||||
else:
|
||||
print("successfully started backup")
|
||||
else:
|
||||
providers = [ provider ]
|
||||
|
||||
print("would create backups for machines: ", machines, " with providers: ", providers)
|
||||
if provider not in backup_scripts["providers"]:
|
||||
raise ClanError(f"provider {provider} not found")
|
||||
proc = subprocess.run(
|
||||
["bash", "-c", backup_scripts["providers"][provider]["start"]],
|
||||
)
|
||||
if proc.returncode != 0:
|
||||
raise ClanError("failed to start backup")
|
||||
else:
|
||||
print("successfully started backup")
|
||||
|
||||
|
||||
def create_command(args: argparse.Namespace) -> None:
|
||||
if args.flake is None:
|
||||
raise ClanError("Could not find clan flake toplevel directory")
|
||||
create_backup(Path(args.flake), machine=args.machine, provider=args.provider)
|
||||
machine = Machine(name=args.machine, flake_dir=args.flake)
|
||||
create_backup(machine=machine, provider=args.provider)
|
||||
|
||||
|
||||
def register_create_parser(parser: argparse.ArgumentParser) -> None:
|
||||
parser.add_argument("--machine", type=str, help="machine in the flake to create backups of")
|
||||
parser.add_argument(
|
||||
"machine", type=str, help="machine in the flake to create backups of"
|
||||
)
|
||||
parser.add_argument("--provider", type=str, help="backup provider to use")
|
||||
parser.set_defaults(func=create_command)
|
||||
|
@ -6,25 +6,27 @@ from typing import Optional
|
||||
from ..errors import ClanError
|
||||
|
||||
|
||||
def list_backups(flake_dir: Path, machine: Optional[str] = None, provider: Optional[str] = None) -> dict[str, dict[str, list[str]]]:
|
||||
def list_backups(
|
||||
flake_dir: Path, machine: str, provider: Optional[str] = None
|
||||
) -> dict[str, dict[str, list[dict[str, str]]]]:
|
||||
dummy_data = {
|
||||
"testhostname": {
|
||||
"borgbackup": [
|
||||
"2021-01-01T00:00:00Z",
|
||||
"2022-01-01T00:00:00Z",
|
||||
"2023-01-01T00:00:00Z",
|
||||
{"date": "2021-01-01T00:00:00Z", "id": "1"},
|
||||
{"date": "2022-01-01T00:00:00Z", "id": "2"},
|
||||
{"date": "2023-01-01T00:00:00Z", "id": "3"},
|
||||
],
|
||||
"restic" : [
|
||||
"2021-01-01T00:00:00Z",
|
||||
"2022-01-01T00:00:00Z",
|
||||
"2023-01-01T00:00:00Z",
|
||||
"restic": [
|
||||
{"date": "2021-01-01T00:00:00Z", "id": "1"},
|
||||
{"date": "2022-01-01T00:00:00Z", "id": "2"},
|
||||
{"date": "2023-01-01T00:00:00Z", "id": "3"},
|
||||
],
|
||||
},
|
||||
"another host": {
|
||||
"borgbackup": [
|
||||
"2021-01-01T00:00:00Z",
|
||||
"2022-01-01T00:00:00Z",
|
||||
"2023-01-01T00:00:00Z",
|
||||
{"date": "2021-01-01T00:00:00Z", "id": "1"},
|
||||
{"date": "2022-01-01T00:00:00Z", "id": "2"},
|
||||
{"date": "2023-01-01T00:00:00Z", "id": "3"},
|
||||
],
|
||||
},
|
||||
}
|
||||
@ -41,16 +43,21 @@ def list_backups(flake_dir: Path, machine: Optional[str] = None, provider: Optio
|
||||
else:
|
||||
return {machine: dummy_data[machine]}
|
||||
|
||||
|
||||
def list_command(args: argparse.Namespace) -> None:
|
||||
if args.flake is None:
|
||||
raise ClanError("Could not find clan flake toplevel directory")
|
||||
backups = list_backups(Path(args.flake), machine=args.machine, provider=args.provider)
|
||||
backups = list_backups(
|
||||
Path(args.flake), machine=args.machine, provider=args.provider
|
||||
)
|
||||
if len(backups) > 0:
|
||||
pp = pprint.PrettyPrinter(depth=4)
|
||||
pp.pprint(backups)
|
||||
|
||||
|
||||
def register_list_parser(parser: argparse.ArgumentParser) -> None:
|
||||
parser.add_argument("--machine", type=str, help="machine in the flake to show backups of")
|
||||
parser.add_argument(
|
||||
"machine", type=str, help="machine in the flake to show backups of"
|
||||
)
|
||||
parser.add_argument("--provider", type=str, help="backup provider to filter by")
|
||||
parser.set_defaults(func=list_command)
|
||||
|
@ -1,26 +1,41 @@
|
||||
import argparse
|
||||
import pprint
|
||||
from pathlib import Path
|
||||
from typing import Optional
|
||||
|
||||
from ..errors import ClanError
|
||||
|
||||
|
||||
def restore_backup(flake_dir: Path, machine: str, provider: str, backup_id: str, service: Optional[str] = None) -> None:
|
||||
def restore_backup(
|
||||
flake_dir: Path,
|
||||
machine: str,
|
||||
provider: str,
|
||||
backup_id: str,
|
||||
service: Optional[str] = None,
|
||||
) -> None:
|
||||
if service is None:
|
||||
print("would restore backup", machine, provider, backup_id)
|
||||
print("would restore backup", machine, provider, backup_id)
|
||||
else:
|
||||
print("would restore backup", machine, provider, backup_id, "of service:", service)
|
||||
print(
|
||||
"would restore backup", machine, provider, backup_id, "of service:", service
|
||||
)
|
||||
|
||||
|
||||
def restore_command(args: argparse.Namespace) -> None:
|
||||
if args.flake is None:
|
||||
raise ClanError("Could not find clan flake toplevel directory")
|
||||
restore_backup(Path(args.flake), machine=args.machine, provider=args.provider, backup_id=args.backup_id, service=args.service)
|
||||
restore_backup(
|
||||
Path(args.flake),
|
||||
machine=args.machine,
|
||||
provider=args.provider,
|
||||
backup_id=args.backup_id,
|
||||
service=args.service,
|
||||
)
|
||||
|
||||
|
||||
def register_restore_parser(parser: argparse.ArgumentParser) -> None:
|
||||
parser.add_argument("machine", type=str, help="machine in the flake to create backups of")
|
||||
parser.add_argument(
|
||||
"machine", type=str, help="machine in the flake to create backups of"
|
||||
)
|
||||
parser.add_argument("provider", type=str, help="backup provider to use")
|
||||
parser.add_argument("backup_id", type=str, help="id of the backup to restore")
|
||||
parser.add_argument("--service", type=str, help="name of the service to restore")
|
||||
|
22
pkgs/clan-cli/tests/test_backups.py
Normal file
22
pkgs/clan-cli/tests/test_backups.py
Normal file
@ -0,0 +1,22 @@
|
||||
import logging
|
||||
|
||||
from cli import Cli
|
||||
from fixtures_flakes import FlakeForTest
|
||||
|
||||
log = logging.getLogger(__name__)
|
||||
|
||||
|
||||
def test_backups(
|
||||
test_flake: FlakeForTest,
|
||||
) -> None:
|
||||
cli = Cli()
|
||||
|
||||
cli.run(
|
||||
[
|
||||
"--flake",
|
||||
str(test_flake.path),
|
||||
"backups",
|
||||
"list",
|
||||
"testhostname",
|
||||
]
|
||||
)
|
Loading…
Reference in New Issue
Block a user