|
@@ -35,6 +35,14 @@ class KeyfileNotFoundError(Error):
|
|
|
"""No key file for repository {} found in {}."""
|
|
|
|
|
|
|
|
|
+class KeyfileInvalidError(Error):
|
|
|
+ """Invalid key file for repository {} found in {}."""
|
|
|
+
|
|
|
+
|
|
|
+class KeyfileMismatchError(Error):
|
|
|
+ """Mismatch between repository {} and key file {}."""
|
|
|
+
|
|
|
+
|
|
|
class RepoKeyNotFoundError(Error):
|
|
|
"""No key entry found in the config of repository {}."""
|
|
|
|
|
@@ -404,17 +412,33 @@ class KeyfileKey(KeyfileKeyBase):
|
|
|
TYPE = 0x00
|
|
|
FILE_ID = 'BORG_KEY'
|
|
|
|
|
|
+ def sanity_check(self, filename, id):
|
|
|
+ with open(filename, 'r') as fd:
|
|
|
+ line = fd.readline().strip()
|
|
|
+ if not line.startswith(self.FILE_ID):
|
|
|
+ raise KeyfileInvalidError(self.repository._location.canonical_path(), filename)
|
|
|
+ if line[len(self.FILE_ID) + 1:] != id:
|
|
|
+ raise KeyfileMismatchError(self.repository._location.canonical_path(), filename)
|
|
|
+ return filename
|
|
|
+
|
|
|
def find_key(self):
|
|
|
+ id = self.repository.id_str
|
|
|
+ keyfile = os.environ.get('BORG_KEY_FILE')
|
|
|
+ if keyfile:
|
|
|
+ return self.sanity_check(keyfile, id)
|
|
|
keys_dir = get_keys_dir()
|
|
|
for name in os.listdir(keys_dir):
|
|
|
filename = os.path.join(keys_dir, name)
|
|
|
- with open(filename, 'r') as fd:
|
|
|
- line = fd.readline().strip()
|
|
|
- if line.startswith(self.FILE_ID) and line[len(self.FILE_ID) + 1:] == self.repository.id_str:
|
|
|
- return filename
|
|
|
+ try:
|
|
|
+ return self.sanity_check(filename, id)
|
|
|
+ except (KeyfileInvalidError, KeyfileMismatchError):
|
|
|
+ pass
|
|
|
raise KeyfileNotFoundError(self.repository._location.canonical_path(), get_keys_dir())
|
|
|
|
|
|
def get_new_target(self, args):
|
|
|
+ keyfile = os.environ.get('BORG_KEY_FILE')
|
|
|
+ if keyfile:
|
|
|
+ return keyfile
|
|
|
filename = args.location.to_key_filename()
|
|
|
path = filename
|
|
|
i = 1
|