Newer
Older
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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
from typing import List
from bgpls_speaker.service.tools.Tools import UpdateRequest,NodeInfo,LinkInfo
from common.proto.bgpls_pb2 import NodeDescriptors
from common.proto.context_pb2 import ContextId, ContextList,Topology,TopologyId,Device,DeviceDriverEnum,ContextId,Empty, TopologyList
from common.Constants import DEFAULT_CONTEXT_NAME
from common.tools.object_factory.Context import json_context_id
from context.client.ContextClient import ContextClient
import logging
LOGGER = logging.getLogger(__name__)
class DiscoveredDBManager:
def __init__(self):
self.discoveredDB=[]
# Añadir topoDB
def AddToDB(self,update_request : UpdateRequest):
"""
Add BGP Update message to discoveredDB. Checks if node exists in discoveredDB.
TODO: check if node exists in context
"""
# TODO: with self.lock
# Check if node info message
if(self.checkIfNodeInUpdate(update_request)):
# Check if node exists
to_add=True
for node in update_request.nodes:
if(self.CheckIfNodeNameInDb(node) or CheckIfNodeInContext(node.node_name)):
# Replace info from node if exists
LOGGER.debug("(AddToDB) Node already in DB!!!")
to_add=False
else:
LOGGER.debug("(AddToDB) Node NOT in DB!!!")
if(to_add):
self.discoveredDB.append(update_request)
else:
# is a link
# Compare and update
self.discoveredDB.append(update_request)
return True
def GetDiscoveredDB(self):
return self.discoveredDB
def checkIfNodeInUpdate(self,update_request : UpdateRequest):
"""
Returns true if the update message contains a node info type .
"""
if(update_request.nodes):
return True
return False
def CheckIfNodeNameInDb(self,new_node : NodeInfo) -> bool:
"""
Returns true if new node is in the discovered data base already
"""
for update in self.discoveredDB:
for node in update.nodes:
if(node.igp_id==new_node.igp_id):
return True
return False
def GetNodeNamesFromDiscoveredDB(self):
"""
Return a list of node_names from the current discovered devices
saved in the discoveredDB
"""
node_list =[update_request.nodes for update_request in self.discoveredDB if update_request.nodes]
# LOGGER.info("nodes (GetNodeNamesFromDiscoveredDB) %s",node_list )
# Inside an update there is a list of nodes , TODO posible FIX:
node_info= [node for nodes in node_list for node in nodes]
return [node.node_name for node in node_info]
def GetNodesFromDiscoveredDB(self):
"""
Return a list of nodes of class type: tools.NodeInfo from the current discovered devices
saved in the discoveredDB. Skips the ones already addded to context.
"""
node_list =[update_request.nodes for update_request in self.discoveredDB if update_request.nodes]
return [node for nodes in node_list for node in nodes if (not CheckIfNodeInContext(node.node_name))]
def GetLinksFromDiscoveredDB(self):
"""
Return a list of links of class type: tools.LinkInfo from the current discovered links
saved in the discoveredDB
"""
link_list= [update_request.links for update_request in self.discoveredDB if update_request.links]
return [link for links in link_list for link in links]
def UpdateDiscoveredDBWithContext(self):
"""
Check if device discovered by bgpls is already in the topology.
"""
# device_names,device_ips=AddContextDevices(context_client)
return True
def GetNodeNameFromLinkId(self,link_igpid):
"""
Return the node name given an igp id if exists in the discoveredDB.
"""
for update in self.discoveredDB:
for node in update.nodes:
if(node.igp_id==link_igpid):
return node.node_name
return None
def UpdateNodeNameInLink(self):
"""
Check if the igp id has a node name asigned in the discoveredDB and
assign it to the NodeDescriptor name.
"""
for update in self.discoveredDB:
for link in update.links:
if(self.GetNodeNameFromLinkId(link.local.bgpls_id) is not None):
LOGGER.info("(UpdateNodeNameInLink) local %s: %s",link.local.bgpls_id, self.GetNodeNameFromLinkId(link.local.bgpls_id))
link.local.node_name=self.GetNodeNameFromLinkId(link.local.bgpls_id)
else:
link.local.node_name=link.local.bgpls_id
if(self.GetNodeNameFromLinkId(link.remote.bgpls_id) is not None):
LOGGER.info("(UpdateNodeNameInLink) remote %s: %s",link.remote.bgpls_id, self.GetNodeNameFromLinkId(link.remote.bgpls_id))
link.remote.node_name=self.GetNodeNameFromLinkId(link.remote.bgpls_id)
else:
link.remote.node_name=link.remote.bgpls_id
return True
def RemoveLinkFromDB(self):
"""
Removes a link from the DB if matches the source and the destination.
"""
return True
def FindConnectedNodes(self,new_node):
"""
Returns a list of nodes connected to the actual node using the discovered
link list. Returns None in case there are no connections.
"""
# encontrar links donde aparezca el nodo
links_to_node=[]
nodes_conected=[]
for update in self.discoveredDB:
for link in update.links:
if(link.local.node_name == new_node):
links_to_node.append(link)
nodes_conected.append(link.remote.node_name)
if(link.remote.node_name == new_node):
links_to_node.append(link)
nodes_conected.append(link.local.node_name)
if(nodes_conected):
LOGGER.debug("(FindConnectedNodes) links to local node:%s",new_node)
LOGGER.debug("(FindConnectedNodes) %s", nodes_conected)
return nodes_conected
LOGGER.debug("(FindConnectedNodes) NO LINKS TO OTHER NODES")
return None
def DeleteNodeFromDiscoveredDB(self, node_name) -> bool:
"""
Deletes a node from de DiscoveredDB given the node name. TODO: igpid¿
"""
LOGGER.info("(DeleteNodeFromDiscoveredDB)")
for i,update in enumerate(self.discoveredDB):
for node in update.nodes:
if(node_name==node.node_name):
del self.discoveredDB[i]
return True
def AddContextDevicesFull(context_client : ContextClient) -> bool:
"""
debug purposes
"""
LOGGER.info("(AddContextDevices)")
contexts : ContextList = context_client.ListContexts(Empty())
for context_ in contexts.contexts:
context_uuid : str = context_.context_id.context_uuid.uuid
context_name : str = context_.name
topologies : TopologyList = context_client.ListTopologies(context_.context_id)
# topologies : TopologyList=context_client.ListTopologies(context_client)
for topology_ in topologies.topologies:
#topology_uuid : str = topology_.topology_id.topology_uuid.uuid
topology_name : str = topology_.name
context_topology_name = 'Context({:s}):Topology({:s})'.format(context_name, topology_name)
# Topos=context.GetTopology(list_topo.topology_id)
LOGGER.debug("topo (AddContextDevices) %s",topology_)
# details=context_client.GetTopologyDetails(topology_.topology_id)
# LOGGER.info("details (AddContextDevices) %s",details)
devices=context_client.ListDevices(Empty())
# LOGGER.info("devices (driverSettings) %s",devices)
device_names=[]
device_ips=[]
for device_ in devices.devices:
LOGGER.info("device_ (AddContextDevices) %s",device_.name)
device_names.append(device_.name)
for config_rule_ in device_.device_config.config_rules:
if config_rule_.custom.resource_key == "_connect/address":
LOGGER.info("device_.resource_value-addr (driverSettings) %s",
config_rule_.custom.resource_value)
device_ips=config_rule_.custom.resource_value
return device_names,device_ips
def GetContextDevices(context_client : ContextClient) -> bool:
"""
Returns de device name and its corresponding device_ip existing in context.
"""
LOGGER.info("(AddContextDevices)")
devices=context_client.ListDevices(Empty())
device_names=[]
device_ips=[]
for device_ in devices.devices:
LOGGER.debug("device_ (AddContextDevices) %s",device_.name)
device_names.append(device_.name)
for config_rule_ in device_.device_config.config_rules:
if config_rule_.custom.resource_key == "_connect/address":
LOGGER.info("device_.resource_value-addr (driverSettings) %s",
config_rule_.custom.resource_value)
device_ips=config_rule_.custom.resource_value
return device_names,device_ips
def CheckIfNodeInContext(node_name) -> bool:
"""
Returns true if the node exists in the context.
"""
context_client=ContextClient()
context_client.connect()
device_names,device_ips=GetContextDevices(context_client)
LOGGER.info("(CheckIfNodeInContext) device_names: %s nodena %s",device_names,node_name)
for node in device_names:
if(node==node_name):
LOGGER.info("(CheckIfNodeInContext) Node already in context")
return True
LOGGER.info("(CheckIfNodeInContext) Node NOT in context")
return False