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
83
84
85
86
87
88
89
90
91
92
93
94
|
#!/usr/bin/python
import anydbm
import ldap
import ldap.syncrepl
import ldapurl
from pykolab import utils
class DNSync(ldap.ldapobject.LDAPObject,ldap.syncrepl.SyncreplConsumer):
callback = None
def __init__(self, filename, *args, **kwargs):
if kwargs.has_key('callback'):
self.callback = kwargs['callback']
del kwargs['callback']
ldap.ldapobject.LDAPObject.__init__(self, *args, **kwargs)
self.__db = anydbm.open(filename, 'c', 0640)
self.__presentUUIDs = {}
def syncrepl_set_cookie(self,cookie):
self.__db['cookie'] = cookie
def syncrepl_get_cookie(self):
if 'cookie' in self.__db:
return self.__db['cookie']
def syncrepl_delete(self, uuids):
for uuid in uuids:
dn = self.__db[uuid]
if not self.callback == None:
self.callback(
change_type='delete',
previous_dn=None,
change_number=None,
dn=dn,
entry={}
)
del self.__db[uuid]
def syncrepl_present(self, uuids, refreshDeletes=False):
if uuids is None:
if refreshDeletes is False:
nonpresent = []
for uuid in self.__db.keys():
if uuid == 'cookie': continue
if uuid in self.__presentUUIDs: continue
nonpresent.append(uuid)
self.syncrepl_delete(nonpresent)
self.__presentUUIDs = {}
else:
for uuid in uuids:
self.__presentUUIDs[uuid] = True
def syncrepl_entry(self, dn, attrs, uuid):
attrs = utils.normalize(attrs)
if uuid in self.__db:
odn = self.__db[uuid]
if odn != dn:
if not self.callback == None:
self.callback(
change_type='moddn',
previous_dn=odn,
change_number=None,
dn=dn,
entry=attrs
)
else:
if not self.callback == None:
self.callback(
change_type='modify',
previous_dn=None,
change_number=None,
dn=self.__db[uuid],
entry=attrs
)
else:
if not self.callback == None:
self.callback(
change_type='add',
previous_dn=None,
change_number=None,
dn=dn,
entry=attrs
)
self.__db[uuid] = dn
|
