forked from borgmatic-collective/borgmatic
95 lines
4.0 KiB
Python
95 lines
4.0 KiB
Python
import logging
|
|
import os
|
|
|
|
|
|
def normalize(config_filename, config):
|
|
'''
|
|
Given a configuration filename and a configuration dict of its loaded contents, apply particular
|
|
hard-coded rules to normalize the configuration to adhere to the current schema. Return any log
|
|
message warnings produced based on the normalization performed.
|
|
'''
|
|
logs = []
|
|
location = config.get('location') or {}
|
|
storage = config.get('storage') or {}
|
|
consistency = config.get('consistency') or {}
|
|
hooks = config.get('hooks') or {}
|
|
|
|
# Upgrade exclude_if_present from a string to a list.
|
|
exclude_if_present = location.get('exclude_if_present')
|
|
if isinstance(exclude_if_present, str):
|
|
config['location']['exclude_if_present'] = [exclude_if_present]
|
|
|
|
# Upgrade various monitoring hooks from a string to a dict.
|
|
healthchecks = hooks.get('healthchecks')
|
|
if isinstance(healthchecks, str):
|
|
config['hooks']['healthchecks'] = {'ping_url': healthchecks}
|
|
|
|
cronitor = hooks.get('cronitor')
|
|
if isinstance(cronitor, str):
|
|
config['hooks']['cronitor'] = {'ping_url': cronitor}
|
|
|
|
pagerduty = hooks.get('pagerduty')
|
|
if isinstance(pagerduty, str):
|
|
config['hooks']['pagerduty'] = {'integration_key': pagerduty}
|
|
|
|
cronhub = hooks.get('cronhub')
|
|
if isinstance(cronhub, str):
|
|
config['hooks']['cronhub'] = {'ping_url': cronhub}
|
|
|
|
# Upgrade consistency checks from a list of strings to a list of dicts.
|
|
checks = consistency.get('checks')
|
|
if isinstance(checks, list) and len(checks) and isinstance(checks[0], str):
|
|
config['consistency']['checks'] = [{'name': check_type} for check_type in checks]
|
|
|
|
# Rename various configuration options.
|
|
numeric_owner = location.pop('numeric_owner', None)
|
|
if numeric_owner is not None:
|
|
config['location']['numeric_ids'] = numeric_owner
|
|
|
|
bsd_flags = location.pop('bsd_flags', None)
|
|
if bsd_flags is not None:
|
|
config['location']['flags'] = bsd_flags
|
|
|
|
remote_rate_limit = storage.pop('remote_rate_limit', None)
|
|
if remote_rate_limit is not None:
|
|
config['storage']['upload_rate_limit'] = remote_rate_limit
|
|
|
|
# Upgrade remote repositories to ssh:// syntax, required in Borg 2.
|
|
repositories = location.get('repositories')
|
|
if repositories:
|
|
config['location']['repositories'] = []
|
|
for repository in repositories:
|
|
if '~' in repository:
|
|
logs.append(
|
|
logging.makeLogRecord(
|
|
dict(
|
|
levelno=logging.WARNING,
|
|
levelname='WARNING',
|
|
msg=f'{config_filename}: Repository paths containing "~" are deprecated in borgmatic and no longer work in Borg 2.x+.',
|
|
)
|
|
)
|
|
)
|
|
if ':' in repository:
|
|
if repository.startswith('file://'):
|
|
config['location']['repositories'].append(
|
|
os.path.abspath(repository.partition('file://')[-1])
|
|
)
|
|
elif repository.startswith('ssh://'):
|
|
config['location']['repositories'].append(repository)
|
|
else:
|
|
rewritten_repository = f"ssh://{repository.replace(':~', '/~').replace(':/', '/').replace(':', '/./')}"
|
|
logs.append(
|
|
logging.makeLogRecord(
|
|
dict(
|
|
levelno=logging.WARNING,
|
|
levelname='WARNING',
|
|
msg=f'{config_filename}: Remote repository paths without ssh:// syntax are deprecated. Interpreting "{repository}" as "{rewritten_repository}"',
|
|
)
|
|
)
|
|
)
|
|
config['location']['repositories'].append(rewritten_repository)
|
|
else:
|
|
config['location']['repositories'].append(repository)
|
|
|
|
return logs
|