- Notifications
You must be signed in to change notification settings - Fork68
Expand file tree
/
Copy pathref.py
More file actions
82 lines (69 loc) · 2.53 KB
/
ref.py
File metadata and controls
82 lines (69 loc) · 2.53 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
# Copyright (C) 2010, 2011 Sebastian Thiel (byronimo@gmail.com) and contributors
#
# This module is part of GitDB and is released under
# the New BSD License: https://opensource.org/license/bsd-3-clause/
importcodecs
fromgitdb.db.baseimport (
CompoundDB,
)
__all__= ('ReferenceDB', )
classReferenceDB(CompoundDB):
"""A database consisting of database referred to in a file"""
# Configuration
# Specifies the object database to use for the paths found in the alternates
# file. If None, it defaults to the GitDB
ObjectDBCls=None
def__init__(self,ref_file):
super().__init__()
self._ref_file=ref_file
def_set_cache_(self,attr):
ifattr=='_dbs':
self._dbs=list()
self._update_dbs_from_ref_file()
else:
super()._set_cache_(attr)
# END handle attrs
def_update_dbs_from_ref_file(self):
dbcls=self.ObjectDBCls
ifdbclsisNone:
# late import
fromgitdb.db.gitimportGitDB
dbcls=GitDB
# END get db type
# try to get as many as possible, don't fail if some are unavailable
ref_paths=list()
try:
withcodecs.open(self._ref_file,'r',encoding="utf-8")asf:
ref_paths= [l.strip()forlinf]
exceptOSError:
pass
# END handle alternates
ref_paths_set=set(ref_paths)
cur_ref_paths_set= {db.root_path()fordbinself._dbs}
# remove existing
forpathin (cur_ref_paths_set-ref_paths_set):
fori,dbinenumerate(self._dbs[:]):
ifdb.root_path()==path:
del(self._dbs[i])
continue
# END del matching db
# END for each path to remove
# add new
# sort them to maintain order
added_paths=sorted(ref_paths_set-cur_ref_paths_set,key=lambdap:ref_paths.index(p))
forpathinadded_paths:
try:
db=dbcls(path)
# force an update to verify path
ifisinstance(db,CompoundDB):
db.databases()
# END verification
self._dbs.append(db)
exceptException:
# ignore invalid paths or issues
pass
# END for each path to add
defupdate_cache(self,force=False):
# re-read alternates and update databases
self._update_dbs_from_ref_file()
returnsuper().update_cache(force)