|
1
|
|
|
"""Main module of kytos/pathfinder Kytos Network Application.""" |
|
2
|
|
|
|
|
3
|
1 |
|
from flask import jsonify, request |
|
4
|
1 |
|
from kytos.core import KytosNApp, log, rest |
|
5
|
1 |
|
from kytos.core.helpers import listen_to |
|
6
|
|
|
|
|
7
|
|
|
# pylint: disable=import-error |
|
8
|
1 |
|
from napps.kytos.pathfinder.graph import KytosGraph |
|
9
|
|
|
|
|
10
|
|
|
# pylint: enable=import-error |
|
11
|
|
|
|
|
12
|
|
|
|
|
13
|
1 |
|
class Main(KytosNApp): |
|
14
|
|
|
"""Main class of kytos/pathfinder NApp. |
|
15
|
|
|
|
|
16
|
|
|
This class is the entry point for this napp. |
|
17
|
|
|
""" |
|
18
|
|
|
|
|
19
|
1 |
|
def setup(self): |
|
20
|
|
|
"""Create a graph to handle the nodes and edges.""" |
|
21
|
1 |
|
self.graph = KytosGraph() |
|
22
|
1 |
|
self._topology = None |
|
23
|
|
|
|
|
24
|
1 |
|
def execute(self): |
|
25
|
|
|
"""Do nothing.""" |
|
26
|
|
|
|
|
27
|
1 |
|
def shutdown(self): |
|
28
|
|
|
"""Shutdown the napp.""" |
|
29
|
|
|
|
|
30
|
1 |
|
def _filter_paths(self, paths, desired, undesired): |
|
31
|
|
|
"""Apply filters to the paths list. |
|
32
|
|
|
|
|
33
|
|
|
Make sure that each path in the list has all the desired links and none |
|
34
|
|
|
of the undesired ones. |
|
35
|
|
|
""" |
|
36
|
1 |
|
filtered_paths = [] |
|
37
|
|
|
|
|
38
|
1 |
View Code Duplication |
if desired: |
|
|
|
|
|
|
39
|
1 |
|
for link_id in desired: |
|
40
|
1 |
|
try: |
|
41
|
1 |
|
endpoint_a = self._topology.links[link_id].endpoint_a.id |
|
42
|
1 |
|
endpoint_b = self._topology.links[link_id].endpoint_b.id |
|
43
|
|
|
except KeyError: |
|
44
|
|
|
return [] |
|
45
|
|
|
|
|
46
|
1 |
|
for path in paths: |
|
47
|
1 |
|
head = path['hops'][:-1] |
|
48
|
1 |
|
tail = path['hops'][1:] |
|
49
|
1 |
|
if (((endpoint_a, endpoint_b) in zip(head, tail)) or |
|
50
|
|
|
((endpoint_b, endpoint_a) in zip(head, tail))): |
|
51
|
1 |
|
filtered_paths.append(path) |
|
52
|
|
|
else: |
|
53
|
1 |
|
filtered_paths = paths |
|
54
|
|
|
|
|
55
|
1 |
View Code Duplication |
if undesired: |
|
|
|
|
|
|
56
|
1 |
|
for link_id in undesired: |
|
57
|
1 |
|
try: |
|
58
|
1 |
|
endpoint_a = self._topology.links[link_id].endpoint_a.id |
|
59
|
1 |
|
endpoint_b = self._topology.links[link_id].endpoint_b.id |
|
60
|
|
|
except KeyError: |
|
61
|
|
|
continue |
|
62
|
|
|
|
|
63
|
1 |
|
for path in paths: |
|
64
|
1 |
|
head = path['hops'][:-1] |
|
65
|
1 |
|
tail = path['hops'][1:] |
|
66
|
1 |
|
if (((endpoint_a, endpoint_b) in zip(head, tail)) or |
|
67
|
|
|
((endpoint_b, endpoint_a) in zip(head, tail))): |
|
68
|
|
|
|
|
69
|
1 |
|
filtered_paths.remove(path) |
|
70
|
|
|
|
|
71
|
1 |
|
return filtered_paths |
|
72
|
|
|
|
|
73
|
1 |
|
@rest('v2/', methods=['POST']) |
|
74
|
|
|
def shortest_path(self): |
|
75
|
|
|
"""Calculate the best path between the source and destination.""" |
|
76
|
1 |
|
data = request.get_json() |
|
77
|
|
|
|
|
78
|
1 |
|
desired = data.get('desired_links') |
|
79
|
1 |
|
undesired = data.get('undesired_links') |
|
80
|
1 |
|
parameter = data.get('parameter') |
|
81
|
|
|
|
|
82
|
1 |
|
paths = [] |
|
83
|
1 |
|
for path in self.graph.shortest_paths(data['source'], |
|
84
|
|
|
data['destination'], |
|
85
|
|
|
parameter): |
|
86
|
|
|
|
|
87
|
1 |
|
paths.append({'hops': path}) |
|
88
|
|
|
|
|
89
|
1 |
|
paths = self._filter_paths(paths, desired, undesired) |
|
90
|
1 |
|
return jsonify({'paths': paths}) |
|
91
|
|
|
|
|
92
|
1 |
|
@listen_to('kytos.topology.updated') |
|
93
|
|
|
def update_topology(self, event): |
|
94
|
|
|
"""Update the graph when the network topology was updated. |
|
95
|
|
|
|
|
96
|
|
|
Clear the current graph and create a new with the most topoly updated. |
|
97
|
|
|
""" |
|
98
|
1 |
|
if 'topology' not in event.content: |
|
99
|
1 |
|
return |
|
100
|
1 |
|
topology = event.content['topology'] |
|
101
|
1 |
|
self._topology = topology |
|
102
|
1 |
|
self.graph.update_topology(topology) |
|
103
|
|
|
log.debug('Topology graph updated.') |
|
104
|
|
|
|
kytos /
pathfinder
Loading history...