xos/synchronizer/steps/sync_vnaaseline.py

# Copyright 2017-present Open Networking Foundation
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.


import os
import sys
import requests
import json
from synchronizers.new_base.syncstep import SyncStep
from synchronizers.new_base.modelaccessor import *
from xos.logger import Logger, logging

from requests.auth import HTTPBasicAuth
logger = Logger(level=logging.INFO)

parentdir = os.path.join(os.path.dirname(__file__), "..")
sys.path.insert(0, parentdir)


class SyncvNaaSEline(SyncStep):
    provides = [ELine]

    observes = ELine

    requested_interval = 0

    def __init__(self, *args, **kwargs):
        super(SyncvNaaSEline, self).__init__(*args, **kwargs)

    def get_onos_global_addr(self, onos):
        #Fetching ip and port from the Global ONOS, append the CE specif API

        onos_url = "http://%s:%s/" % (onos.onos_ip, onos.onos_port)
        evc_endpoint = "carrierethernet/evc"
        return onos_url + evc_endpoint

    def get_onos_global_auth(self, onos):
        #Fetching username and password from the Global ONOS

        return HTTPBasicAuth(onos.onos_username, onos.onos_password)

    def sync_record(self, evc):
        logger.info("Syncing Edited EVC: %s" % evc.name)
        logger.info("POST %s " % (evc))

        # json to configure ONOS to start the EVC.
        # {
        #     "evcId": "evc1",
        #     "evcCfgId": "evpl1",
        #     "uniList": [
        #         "netconf:192.168.56.10:830/0",
        #         "netconf:192.168.56.20:830/0"
        #     ],
        #     "evcType": "POINT_TO_POINT",
        #     "vlanId": 100,
        #     "cir": "400",
        #     "eir": "200",
        #     "cbs": "3000",
        #     "ebs": "2000"
        # }

        data = {}
        data["evcId"] = evc.name
        data["evcCfgId"] = evc.name
        data["uniList"] = [evc.connect_point_1.cpe_id, evc.connect_point_2.cpe_id]
        data["evcType"] = "POINT_TO_POINT"
        data["vlanId"] = int(evc.vlanids.split(",")[0]) # FIXME - should be list (CORD-2075)
        data["cbs"] = evc.bwp.cbs
        data["ebs"] = evc.bwp.ebs
        data["cir"] = evc.bwp.cir
        data["eir"] = evc.bwp.eir
        logger.info("data %s" % data)
        # assuming that the CPEs are controller by the fabric ONOS
        onos = OnosModel.objects.get(onos_type="global")
        onos_addr = self.get_onos_global_addr(onos)

        auth = self.get_onos_global_auth(onos)

        logger.info("POST %s for evc %s, data = %s" % (onos_addr, evc.name, data))

        r = requests.post(onos_addr, data=json.dumps(data), auth=auth)

        #TODO XOS might fail to connect to ONOS.
        if (r.status_code != 200):
            logger.info("result = %s" % r)
            raise Exception("Received error from EVC Installation update (%d)" % r.status_code)

    def delete_record(self, evc):
        logger.info("Syncing delete EVC: %s" % evc.name)

        onos = OnosModel.objects.get(onos_type="global")
        onos_addr = self.get_onos_global_addr(onos)

        auth = self.get_onos_global_auth(onos)

        logger.info("Delete %s for evc %s" % (onos_addr, evc.name))

        data = {}
        data['evcId'] = evc.name

        r = requests.delete(onos_addr + "/" + evc.name, auth=auth)

        # TODO XOS might fail to connect to ONOS.
        if (r.status_code != 200):
            logger.info("result = %s" % r)
            raise Exception("Received error from EVC Removal update (%d)" % r.status_code)