blob: 5ec0328a2e401c2fd299712f7b4f804d6b3149fc [file] [log] [blame]
Matteo Scandolof6337eb2018-04-05 15:58:37 -07001# 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 Scandolod44ca992018-05-17 15:02:10 -070015import os, sys
16sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
Matteo Scandolof6337eb2018-04-05 15:58:37 -070017
Matteo Scandolof6337eb2018-04-05 15:58:37 -070018from helpers import Helpers
19
Matteo Scandolod44ca992018-05-17 15:02:10 -070020import requests
21from multistructlog import create_logger
22from requests.auth import HTTPBasicAuth
Matteo Scandolod8ed60e2018-06-18 17:00:57 -070023from synchronizers.new_base.modelaccessor import VOLTService, VOLTServiceInstance, ServiceInstance, model_accessor
Matteo Scandolod44ca992018-05-17 15:02:10 -070024from synchronizers.new_base.syncstep import SyncStep, DeferredException
25from xosconfig import Config
26
Matteo Scandolof6337eb2018-04-05 15:58:37 -070027log = create_logger(Config().get("logging"))
28
29class SyncVOLTServiceInstance(SyncStep):
30 provides = [VOLTServiceInstance]
31
32 observes = VOLTServiceInstance
33
34 def sync_record(self, o):
35
Matteo Scandolo80912942018-07-25 20:51:30 -070036 if o.policy_code != 1:
37 raise DeferredException("Waiting for ModelPolicy to complete")
38
Matteo Scandolof6337eb2018-04-05 15:58:37 -070039 volt_service = VOLTService.objects.get(id=o.owner_id)
40
Luca Preteca974c82018-05-01 18:06:16 -070041 log.info("Synching OLTServiceInstance", object=str(o), **o.tologdict())
Matteo Scandolof6337eb2018-04-05 15:58:37 -070042
Matteo Scandolod8ed60e2018-06-18 17:00:57 -070043 olt_device = o.onu_device.pon_port.olt_device
Matteo Scandolof6337eb2018-04-05 15:58:37 -070044
Matteo Scandolo80912942018-07-25 20:51:30 -070045 try:
46 # NOTE each ONU has only one UNI port!
47 uni_port_id = o.onu_device.uni_ports.first().port_no
48 except AttributeError:
49 # This is because the ONUDevice is set by model_policy
50 raise DeferredException("Waiting for ONUDevice %s " % olt_device.name)
Matteo Scandolof6337eb2018-04-05 15:58:37 -070051
52 if not olt_device.dp_id:
53 raise DeferredException("Waiting for OLTDevice %s to be synchronized" % olt_device.name)
54
55 log.debug("Adding subscriber with info",
Luca Preteca974c82018-05-01 18:06:16 -070056 uni_port_id = uni_port_id,
Matteo Scandolo25ad2902018-08-14 17:02:05 -070057 dp_id = olt_device.dp_id
58 )
Matteo Scandolof6337eb2018-04-05 15:58:37 -070059
Luca Preteca974c82018-05-01 18:06:16 -070060 # Send request to ONOS
61 onos_voltha = Helpers.get_onos_voltha_info(volt_service)
62 onos_voltha_basic_auth = HTTPBasicAuth(onos_voltha['user'], onos_voltha['pass'])
Matteo Scandolof6337eb2018-04-05 15:58:37 -070063
Matteo Scandolo18358822018-08-15 17:17:43 -070064 handle = "%s/%s" % (olt_device.dp_id, uni_port_id)
65
66 full_url = "%s:%d/onos/olt/oltapp/%s" % (onos_voltha['url'], onos_voltha['port'], handle)
Matteo Scandolof6337eb2018-04-05 15:58:37 -070067
Matteo Scandolo25ad2902018-08-14 17:02:05 -070068 log.info("Sending request to onos-voltha", url=full_url)
Matteo Scandolof6337eb2018-04-05 15:58:37 -070069
Matteo Scandolo25ad2902018-08-14 17:02:05 -070070 request = requests.post(full_url, auth=onos_voltha_basic_auth)
Matteo Scandolof6337eb2018-04-05 15:58:37 -070071
Luca Preteca974c82018-05-01 18:06:16 -070072 if request.status_code != 200:
73 raise Exception("Failed to add subscriber in onos-voltha: %s" % request.text)
Matteo Scandolof6337eb2018-04-05 15:58:37 -070074
Matteo Scandolo18358822018-08-15 17:17:43 -070075 o.backend_handle = handle
76 o.save(update_fields=["backend_handle"])
77
Matteo Scandoloe48a4642018-06-26 10:08:34 -070078 log.info("Added Subscriber in onos voltha", response=request.text)
79
80 def delete_record(self, o):
81
82 log.info("Removing OLTServiceInstance", object=str(o), **o.tologdict())
83
84 volt_service = VOLTService.objects.get(id=o.owner_id)
85 onos_voltha = Helpers.get_onos_voltha_info(volt_service)
86 onos_voltha_basic_auth = HTTPBasicAuth(onos_voltha['user'], onos_voltha['pass'])
87
Matteo Scandolo18358822018-08-15 17:17:43 -070088 full_url = "%s:%d/onos/olt/oltapp/%s" % (onos_voltha['url'], onos_voltha['port'], o.backend_handle)
Matteo Scandoloe48a4642018-06-26 10:08:34 -070089
90 request = requests.delete(full_url, auth=onos_voltha_basic_auth)
91
92 if request.status_code != 204:
93 raise Exception("Failed to remove subscriber from onos-voltha: %s" % request.text)
94
95 log.info("Removed Subscriber from onos voltha", response=request.text)