blob: 7bdee170e2866482d59bd81ca9e9930cd3ce2485 [file] [log] [blame]
Scott Bakerb3a80de2016-09-06 16:51:27 -07001import os
2import requests
3import socket
4import sys
5import base64
6from django.db.models import F, Q
7from xos.config import Config
8from synchronizers.base.syncstep import SyncStep
9from core.models import Service, Network, Port
10from core.models.service import COARSE_KIND
11from services.vtn.vtnnetport import VTNNetwork, VTNPort
12from services.vtn.models import VTNService
13from xos.logger import Logger, logging
14from requests.auth import HTTPBasicAuth
15
16# hpclibrary will be in steps/..
17parentdir = os.path.join(os.path.dirname(__file__),"..")
18sys.path.insert(0,parentdir)
19
20logger = Logger(level=logging.INFO)
21
22# XXX should save and load this
23glo_saved_vtn_maps = []
24glo_saved_networks = {}
25glo_saved_ports = {}
26
27class SyncVTNService(SyncStep):
28 provides=[Service]
29 observes=Service
30 requested_interval=0
31
32 def __init__(self, **args):
33 SyncStep.__init__(self, **args)
34
35 def get_vtn_onos_service(self):
36 from services.onos.models import ONOSService
37
38 vtn_service = ONOSService.get_service_objects().filter(name="ONOS_CORD") # XXX fixme - harcoded
39 if not vtn_service:
40 raise "No VTN Onos Service"
41
42 return vtn_service[0]
43
44 def get_vtn_auth(self):
45 return HTTPBasicAuth('karaf', 'karaf') # XXX fixme - hardcoded auth
46
47 def get_vtn_addr(self):
48 vtn_service = self.get_vtn_onos_service()
49
50 if vtn_service.rest_hostname:
51 return vtn_service.rest_hostname
52
53 if not vtn_service.slices.exists():
54 raise "VTN Service has no slices"
55
56 vtn_slice = vtn_service.slices.all()[0]
57
58 if not vtn_slice.instances.exists():
59 raise "VTN Slice has no instances"
60
61 vtn_instance = vtn_slice.instances.all()[0]
62
63 return vtn_instance.node.name
64
65 def sync_legacy_vtn_api(self):
66 global glo_saved_vtn_maps
67
68 logger.info("sync'ing vtn services")
69
70 vtn_maps = []
71 for service in Service.objects.all():
72 for id in service.get_vtn_src_ids():
73 dependencies = service.get_vtn_dependencies_ids()
74 if dependencies:
75 for dependency in dependencies:
76 vtn_maps.append( (id, dependency) )
77
78 for vtn_map in vtn_maps:
79 if not (vtn_map in glo_saved_vtn_maps):
80 # call vtn rest api to add map
81 url = "http://" + self.get_vtn_addr() + ":8181/onos/cordvtn/service-dependency/%s/%s" % (vtn_map[0], vtn_map[1])
82
83 print "POST %s" % url
84 r = requests.post(url, auth=self.get_vtn_auth() )
85 if (r.status_code != 200):
86 raise Exception("Received error from vtn service (%d)" % r.status_code)
87
88 for vtn_map in glo_saved_vtn_maps:
89 if not vtn_map in vtn_maps:
90 # call vtn rest api to delete map
91 url = "http://" + self.get_vtn_addr() + ":8181/onos/cordvtn/service-dependency/%s/%s" % (vtn_map[0],vtn_map[1])
92
93 print "DELETE %s" % url
94 r = requests.delete(url, auth=self.get_vtn_auth() )
95 if (r.status_code != 200):
96 raise Exception("Received error from vtn service (%d)" % r.status_code)
97
98 glo_saved_vtn_maps = vtn_maps
99 # TODO: save this
100
Scott Baker90f780d2016-09-07 22:57:28 -0700101 def get_method(self, url, id):
102 url_with_id = "%s/%s" % (url, id)
103 r = requests.get(url_with_id, auth=self.get_vtn_auth())
104 if (r.status_code==200):
105 method="PUT"
106 url = url_with_id
107 req_func = requests.put
108 exists=True
109 else:
110 method="POST"
111 req_func = requests.post
112 exists=False
113 return (exists, url, method, req_func)
114
Scott Bakerb3a80de2016-09-06 16:51:27 -0700115 def sync_service_networks(self):
116 valid_ids = []
117 for network in Network.objects.all():
118 network = VTNNetwork(network)
Scott Bakerf2291012016-09-08 13:19:45 -0700119
120 if not network.id:
121 continue
122
Scott Bakerb3a80de2016-09-06 16:51:27 -0700123 valid_ids.append(network.id)
Scott Bakerf2291012016-09-08 13:19:45 -0700124
Scott Bakerb3a80de2016-09-06 16:51:27 -0700125 if (glo_saved_networks.get(network.id, None) != network.to_dict()):
Scott Baker90f780d2016-09-07 22:57:28 -0700126 (exists, url, method, req_func) = self.get_method("http://" + self.get_vtn_addr() + ":8181/onos/cordvtn/serviceNetworks", network.id)
Scott Bakerb3a80de2016-09-06 16:51:27 -0700127
Scott Baker90f780d2016-09-07 22:57:28 -0700128 logger.info("%sing VTN API for network %s" % (method, network.id))
129
Scott Bakerb3a80de2016-09-06 16:51:27 -0700130 logger.info("URL: %s" % url)
131
Scott Baker90f780d2016-09-07 22:57:28 -0700132 # clean the providerNetworks list
133 providerNetworks = [{"id": x["id"], "bidirectional": x["bidirectional"]} for x in network.providerNetworks]
134
135 data = {"ServiceNetwork": {"id": network.id,
Scott Bakerb3a80de2016-09-06 16:51:27 -0700136 "type": network.type,
Scott Baker90f780d2016-09-07 22:57:28 -0700137 "providerNetworks": providerNetworks} }
Scott Bakerb3a80de2016-09-06 16:51:27 -0700138 logger.info("DATA: %s" % str(data))
139
Scott Baker90f780d2016-09-07 22:57:28 -0700140 r=req_func(url, json=data, auth=self.get_vtn_auth() )
141 if (r.status_code in [200,201]):
Scott Bakerb3a80de2016-09-06 16:51:27 -0700142 glo_saved_networks[network.id] = network.to_dict()
143 else:
144 logger.error("Received error from vtn service (%d)" % r.status_code)
145
Scott Baker90f780d2016-09-07 22:57:28 -0700146
Scott Bakerb3a80de2016-09-06 16:51:27 -0700147 for network_id in glo_saved_networks.keys():
148 if network_id not in valid_ids:
149 logger.info("DELETEing VTN API for network %s" % network_id)
150
Scott Baker90f780d2016-09-07 22:57:28 -0700151 url = "http://" + self.get_vtn_addr() + ":8181/onos/cordvtn/serviceNetworks/%s" % network_id
Scott Bakerb3a80de2016-09-06 16:51:27 -0700152 logger.info("URL: %s" % url)
153
154 r = requests.delete(url, auth=self.get_vtn_auth() )
155 if (r.status_code in [200,204]):
156 del glo_saved_networks[network_id]
157 else:
158 logger.error("Received error from vtn service (%d)" % r.status_code)
159
160 def sync_service_ports(self):
161 valid_ids = []
162 for port in Port.objects.all():
163 port = VTNPort(port)
Scott Bakerf2291012016-09-08 13:19:45 -0700164
165 if not port.id:
166 continue
167
Scott Bakerb3a80de2016-09-06 16:51:27 -0700168 valid_ids.append(port.id)
Scott Bakerf2291012016-09-08 13:19:45 -0700169
Scott Bakerb3a80de2016-09-06 16:51:27 -0700170 if (glo_saved_ports.get(port.id, None) != port.to_dict()):
Scott Baker90f780d2016-09-07 22:57:28 -0700171 (exists, url, method, req_func) = self.get_method("http://" + self.get_vtn_addr() + ":8181/onos/cordvtn/servicePorts", port.id)
Scott Bakerb3a80de2016-09-06 16:51:27 -0700172
Scott Baker90f780d2016-09-07 22:57:28 -0700173 logger.info("%sing VTN API for port %s" % (method, port.id))
174
Scott Bakerb3a80de2016-09-06 16:51:27 -0700175 logger.info("URL: %s" % url)
176
Scott Baker90f780d2016-09-07 22:57:28 -0700177 data = {"ServicePort": {"id": port.id,
Scott Bakerb3a80de2016-09-06 16:51:27 -0700178 "vlan_id": port.vlan_id,
Scott Baker90f780d2016-09-07 22:57:28 -0700179 "floating_address_pairs": port.floating_address_pairs} }
Scott Bakerb3a80de2016-09-06 16:51:27 -0700180 logger.info("DATA: %s" % str(data))
181
Scott Baker90f780d2016-09-07 22:57:28 -0700182 r=req_func(url, json=data, auth=self.get_vtn_auth() )
Scott Bakerf2291012016-09-08 13:19:45 -0700183 if (r.status_code in [200,201]):
Scott Bakerb3a80de2016-09-06 16:51:27 -0700184 glo_saved_ports[port.id] = port.to_dict()
185 else:
186 logger.error("Received error from vtn service (%d)" % r.status_code)
187
188 for port_id in glo_saved_ports.keys():
189 if port_id not in valid_ids:
190 logger.info("DELETEing VTN API for port %s" % port_id)
191
Scott Baker90f780d2016-09-07 22:57:28 -0700192 url = "http://" + self.get_vtn_addr() + ":8181/onos/cordvtn/servicePorts/%s" % port_id
Scott Bakerb3a80de2016-09-06 16:51:27 -0700193 logger.info("URL: %s" % url)
194
195 r = requests.delete(url, auth=self.get_vtn_auth() )
196 if (r.status_code in [200,204]):
197 del glo_saved_ports[port_id]
198 else:
199 logger.error("Received error from vtn service (%d)" % r.status_code)
200
201 def call(self, **args):
202 vtn_service = VTNService.get_service_objects().all()
203 if not vtn_service:
204 raise Exception("No VTN Service")
205
206 vtn_service = vtn_service[0]
207
Scott Baker855a9df2016-09-09 09:23:50 -0700208 if vtn_service.vtnAPIVersion>=2:
Scott Bakerb3a80de2016-09-06 16:51:27 -0700209 # version 2 means use new API
210 logger.info("Using New API")
211 self.sync_service_networks()
212 self.sync_service_ports()
213 else:
214 # default to legacy
215 logger.info("Using Old API")
216 self.sync_legacy_vtn_api()
217
218