2 # Thierry Parmentelat - INRIA
8 from PLC.Faults import *
9 from PLC.Method import Method
10 from PLC.Parameter import Parameter, Mixed
11 from PLC.Auth import Auth
13 from PLC.Peers import Peer, Peers
15 from PLC.Sites import Site, Sites
16 from PLC.Keys import Key, Keys
17 from PLC.Nodes import Node, Nodes
18 from PLC.Persons import Person, Persons
19 from PLC.Slices import Slice, Slices
20 from PLC.SliceTags import SliceTags
22 class GetPeerData(Method):
24 Returns lists of local objects that a peer should cache in its
25 database as foreign objects. Also returns the list of foreign
26 nodes in this database, for which the calling peer is
27 authoritative, to assist in synchronization of slivers.
29 See the implementation of RefreshPeer for how this data is used.
32 roles = ['admin', 'peer']
37 'Sites': Parameter([dict], "List of local sites"),
38 'Keys': Parameter([dict], "List of local keys"),
39 'Nodes': Parameter([dict], "List of local nodes"),
40 'Persons': Parameter([dict], "List of local users"),
41 'Slices': Parameter([dict], "List of local slices"),
42 'db_time': Parameter(float, "(Debug) Database fetch time"),
45 def call (self, auth):
48 # Filter out various secrets
49 node_fields = filter(lambda field: field not in \
50 ['boot_nonce', 'key', 'session', 'root_person_ids'],
52 nodes = Nodes(self.api, {'peer_id': None}, node_fields);
53 # filter out whitelisted nodes
54 nodes = [ n for n in nodes if not n['slice_ids_whitelist']]
57 person_fields = filter(lambda field: field not in \
58 ['password', 'verification_key', 'verification_expires'],
61 # XXX Optimize to return only those Persons, Keys, and Slices
62 # necessary for slice creation on the calling peer's nodes.
64 # filter out special person
65 persons = Persons(self.api, {'~email':[self.api.config.PLC_API_MAINTENANCE_USER,
66 self.api.config.PLC_ROOT_USER],
67 'peer_id': None}, person_fields)
69 # filter out system slices
70 system_slice_ids = SliceTags(self.api, {'name': 'system', 'value': '1'}).dict('slice_id')
71 slices = Slices(self.api, {'peer_id': None,
72 '~slice_id':system_slice_ids.keys()})
75 'Sites': Sites(self.api, {'peer_id': None}),
76 'Keys': Keys(self.api, {'peer_id': None}),
82 if isinstance(self.caller, Peer):
83 result['PeerNodes'] = Nodes(self.api, {'peer_id': self.caller['peer_id']})
85 result['db_time'] = time.time() - start