blob: 29722f939dd70c015cb612011a72a813b2ddc20e [file] [log] [blame]
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -08001# Copyright 2017-present Open Networking Foundation
2#
3# Licensed under the Apache License, Version 2.0 (the "License");
4# you may not use this file except in compliance with the License.
5# You may obtain a copy of the License at
6#
7# http://www.apache.org/licenses/LICENSE-2.0
8#
9# Unless required by applicable law or agreed to in writing, software
10# distributed under the License is distributed on an "AS IS" BASIS,
11# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12# See the License for the specific language governing permissions and
13# limitations under the License.
14
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080015from time import sleep
Matteo Scandolod44ca992018-05-17 15:02:10 -070016
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080017import requests
Matteo Scandolod44ca992018-05-17 15:02:10 -070018from multistructlog import create_logger
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080019from requests.auth import HTTPBasicAuth
Matteo Scandolo6be6ee92018-05-24 15:07:51 -070020from synchronizers.new_base.syncstep import SyncStep, DeferredException
Matteo Scandolod44ca992018-05-17 15:02:10 -070021from synchronizers.new_base.modelaccessor import OLTDevice, model_accessor
22from xosconfig import Config
23
24import os, sys
25sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
26
Matteo Scandolof6337eb2018-04-05 15:58:37 -070027from helpers import Helpers
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080028
29log = create_logger(Config().get('logging'))
30
31class SyncOLTDevice(SyncStep):
32 provides = [OLTDevice]
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080033 observes = OLTDevice
34
35 @staticmethod
Matteo Scandolof6337eb2018-04-05 15:58:37 -070036 def get_ids_from_logical_device(o):
Luca Preteca974c82018-05-01 18:06:16 -070037 voltha = Helpers.get_voltha_info(o.volt_service)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080038
Luca Preteca974c82018-05-01 18:06:16 -070039 request = requests.get("%s:%d/api/v1/logical_devices" % (voltha['url'], voltha['port']))
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080040
Luca Preteca974c82018-05-01 18:06:16 -070041 if request.status_code != 200:
42 raise Exception("Failed to retrieve logical devices from VOLTHA: %s" % request.text)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080043
Luca Preteca974c82018-05-01 18:06:16 -070044 response = request.json()
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080045
Luca Preteca974c82018-05-01 18:06:16 -070046 for ld in response["items"]:
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080047 if ld["root_device_id"] == o.device_id:
Matteo Scandolof6337eb2018-04-05 15:58:37 -070048 o.of_id = ld["id"]
Luca Preteca974c82018-05-01 18:06:16 -070049 o.dp_id = "of:%s" % (Helpers.datapath_id_to_hex(ld["datapath_id"])) # Convert to hex
Matteo Scandolof6337eb2018-04-05 15:58:37 -070050 return o
51
Matteo Scandolo2c144932018-05-04 14:06:24 -070052 raise Exception("Can't find a logical_device for OLT device id: %s" % o.device_id)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080053
Matteo Scandolo2c144932018-05-04 14:06:24 -070054 def pre_provision_olt_device(self, model):
55 log.info("Pre-provisioning OLT device in VOLTHA", object=str(model), **model.tologdict())
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080056
Matteo Scandolo2c144932018-05-04 14:06:24 -070057 voltha = Helpers.get_voltha_info(model.volt_service)
Luca Preteca974c82018-05-01 18:06:16 -070058
Matteo Scandolo2c144932018-05-04 14:06:24 -070059 data = {
Matteo Scandolo2ed64b92018-06-18 10:32:56 -070060 "type": model.device_type
Matteo Scandolo2c144932018-05-04 14:06:24 -070061 }
62
Matteo Scandolo2ed64b92018-06-18 10:32:56 -070063 if hasattr(model, "host") and hasattr(model, "port"):
64 data["host_and_port"] = "%s:%s" % (model.host, model.port)
65 elif hasattr(model, "mac_address"):
66 data["mac_address"] = model.mac_address
Matteo Scandolo2c144932018-05-04 14:06:24 -070067
68 log.info("Pushing OLT to Voltha", data=data)
69
70 request = requests.post("%s:%d/api/v1/devices" % (voltha['url'], voltha['port']), json=data)
71
72 if request.status_code != 200:
73 raise Exception("Failed to add OLT device: %s" % request.text)
74
75 log.info("Add device response", text=request.text)
76
77 res = request.json()
78
79 log.info("Add device json res", res=res)
80
81 if not res['id']:
82 raise Exception(
83 'VOLTHA Device Id is empty. This probably means that the OLT device is already provisioned in VOLTHA')
84 else:
85 model.device_id = res['id'];
86
87 return model
88
89 def activate_olt(self, model):
90
91 voltha = Helpers.get_voltha_info(model.volt_service)
92
93 # Enable device
94 request = requests.post("%s:%d/api/v1/devices/%s/enable" % (voltha['url'], voltha['port'], model.device_id))
95
96 if request.status_code != 200:
97 raise Exception("Failed to enable OLT device: %s" % request.text)
98
99 # Read state
100 request = requests.get("%s:%d/api/v1/devices/%s" % (voltha['url'], voltha['port'], model.device_id)).json()
101 while request['oper_status'] == "ACTIVATING":
102 log.info("Waiting for OLT device %s (%s) to activate" % (model.name, model.device_id))
103 sleep(5)
104 request = requests.get("%s:%d/api/v1/devices/%s" % (voltha['url'], voltha['port'], model.device_id)).json()
105
106 model.admin_state = request['admin_state']
107 model.oper_status = request['oper_status']
108
109 # Find the of_id of the device
110 model = self.get_ids_from_logical_device(model)
111 model.save()
112
113 return model
114
115 def configure_onos(self, model):
116
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700117 log.info("Adding OLT device in onos-voltha", object=str(model), **model.tologdict())
118
Matteo Scandolo2c144932018-05-04 14:06:24 -0700119 onos_voltha = Helpers.get_onos_voltha_info(model.volt_service)
Luca Preteca974c82018-05-01 18:06:16 -0700120 onos_voltha_basic_auth = HTTPBasicAuth(onos_voltha['user'], onos_voltha['pass'])
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800121
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700122 try:
123 # NOTE For now, we assume that each OLT has only one pon port
124 vlan = model.pon_ports.all()[0].s_tag
125 except Exception as e:
126 raise DeferredException("Waiting for pon_ports to come up")
127
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800128
Luca Preteca974c82018-05-01 18:06:16 -0700129 # Add device info to onos-voltha
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800130 data = {
131 "devices": {
Matteo Scandolo2c144932018-05-04 14:06:24 -0700132 model.dp_id: {
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800133 "basic": {
Matteo Scandolo2c144932018-05-04 14:06:24 -0700134 "driver": model.driver
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800135 },
136 "accessDevice": {
Matteo Scandolo2c144932018-05-04 14:06:24 -0700137 "uplink": model.uplink,
Matteo Scandolob8621cd2018-04-04 17:12:37 -0700138 "vlan": vlan
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800139 }
140 }
141 }
142 }
143
Matteo Scandolo2c144932018-05-04 14:06:24 -0700144 url = "%s:%d/onos/v1/network/configuration/" % (onos_voltha['url'], onos_voltha['port'])
145 request = requests.post(url, json=data, auth=onos_voltha_basic_auth)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800146
Luca Preteca974c82018-05-01 18:06:16 -0700147 if request.status_code != 200:
148 log.error(request.text)
Matteo Scandolo2c144932018-05-04 14:06:24 -0700149 raise Exception("Failed to add OLT device %s into ONOS" % model.name)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800150 else:
151 try:
Luca Preteca974c82018-05-01 18:06:16 -0700152 print request.json()
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800153 except Exception:
Luca Preteca974c82018-05-01 18:06:16 -0700154 print request.text
Matteo Scandolo2c144932018-05-04 14:06:24 -0700155 return model
156
Matteo Scandolo2c144932018-05-04 14:06:24 -0700157 def sync_record(self, model):
158 log.info("Synching device", object=str(model), **model.tologdict())
159
160 # If the device has feedback_state is already present in voltha
161 if not model.device_id and not model.admin_state and not model.oper_status and not model.of_id:
162 log.info("Pushing OLT device to VOLTHA", object=str(model), **model.tologdict())
163 model = self.pre_provision_olt_device(model)
164 self.activate_olt(model)
165 else:
166 log.info("OLT device already exists in VOLTHA", object=str(model), **model.tologdict())
167
168 self.configure_onos(model)
169
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700170 def delete_record(self, model):
171 log.info("Deleting OLT device", object=str(model), **model.tologdict())
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800172
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700173 voltha = Helpers.get_voltha_info(model.volt_service)
174 onos_voltha = Helpers.get_onos_voltha_info(model.volt_service)
Luca Preteca974c82018-05-01 18:06:16 -0700175 onos_voltha_basic_auth = HTTPBasicAuth(onos_voltha['user'], onos_voltha['pass'])
176
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700177 if not model.device_id:
178 log.error("OLTDevice %s has no device_id" % model.name)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800179 else:
Matteo Scandolo2c144932018-05-04 14:06:24 -0700180 # Disable the OLT device
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700181 request = requests.post("%s:%d/api/v1/devices/%s/disable" % (voltha['url'], voltha['port'], model.device_id))
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800182
Luca Preteca974c82018-05-01 18:06:16 -0700183 if request.status_code != 200:
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700184 log.error("Failed to disable OLT device in VOLTHA: %s - %s" % (model.name, model.device_id), rest_response=request.text, rest_status_code=request.status_code)
Matteo Scandolo2c144932018-05-04 14:06:24 -0700185 raise Exception("Failed to disable OLT device in VOLTHA")
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800186
Matteo Scandolo2c144932018-05-04 14:06:24 -0700187 # Delete the OLT device
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700188 request = requests.delete("%s:%d/api/v1/devices/%s/delete" % (voltha['url'], voltha['port'], model.device_id))
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800189
Luca Preteca974c82018-05-01 18:06:16 -0700190 if request.status_code != 200:
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700191 log.error("Failed to delete OLT device from VOLTHA: %s - %s" % (model.name, model.device_id), rest_response=request.text, rest_status_code=request.status_code)
Matteo Scandolo2c144932018-05-04 14:06:24 -0700192 raise Exception("Failed to delete OLT device from VOLTHA")
193
194 # Remove the device from ONOS
195 request = requests.delete("%s:%d/onos/v1/network/configuration/devices/%s" % (
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700196 onos_voltha['url'], onos_voltha['port'], model.of_id), auth=onos_voltha_basic_auth)
Matteo Scandolo2c144932018-05-04 14:06:24 -0700197
198 if request.status_code != 204:
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700199 log.error("Failed to remove OLT device from ONOS: %s - %s" % (model.name, model.of_id), rest_response=request.text, rest_status_code=request.status_code)
Matteo Scandolo2c144932018-05-04 14:06:24 -0700200 raise Exception("Failed to remove OLT device from ONOS")