build.main

Complexity

Total Complexity

72

Size/Duplication

Total Lines	463
Duplicated Lines	0 %

Test Coverage

Coverage

44.37%

Importance

Changes

0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	Main.setup()	0	16	1
A	Main.get_circuit()	0	13	2
A	Main.shutdown()	0	2	1
A	Main.execute()	0	2	1
A	Main.list_circuits()	0	8	2
A	Main.update()	0	25	3
A	Main.uni_from_dict()	0	18	4
B	Main.update_schedule()	0	55	7
A	Main.is_duplicated_evc()	0	21	5
A	Main.handle_link_up()	0	15	5
A	Main.link_from_dict()	0	20	4
B	Main.delete_schedule()	0	37	5
A	Main.handle_link_down()	0	15	4
A	Main.list_schedules()	0	14	4
B	Main.create_circuit()	0	57	5
C	Main.evc_from_dict()	0	30	11
A	Main.get_schedule()	0	14	2
B	Main.create_schedule()	0	39	5
A	Main.delete_circuit()	0	18	1

"""Main module of kytos/mef_eline Kytos Network Application.

NApp to provision circuits from user request.
"""
from flask import jsonify, request

from kytos.core import KytosNApp, log, rest
from kytos.core.events import KytosEvent
from kytos.core.helpers import listen_to
from kytos.core.interface import TAG, UNI
from kytos.core.link import Link
from napps.kytos.mef_eline.models import EVC, DynamicPathManager
from napps.kytos.mef_eline.scheduler import CircuitSchedule, Scheduler
from napps.kytos.mef_eline.storehouse import StoreHouse


class Main(KytosNApp):
    """Main class of amlight/mef_eline NApp.

    This class is the entry point for this napp.
    """

    def setup(self):
        """Replace the '__init__' method for the KytosNApp subclass.

        The setup method is automatically called by the controller when your
        application is loaded.

        So, if you have any setup routine, insert it here.
        """
        # object used to scheduler circuit events
        self.sched = Scheduler()

        # object to save and load circuits
        self.storehouse = StoreHouse(self.controller)

        # set the controller that will manager the dynamic paths
        DynamicPathManager.set_controller(self.controller)

    def execute(self):
        """Execute once when the napp is running."""

    def shutdown(self):
        """Execute when your napp is unloaded.

        If you have some cleanup procedure, insert it here.
        """

    @rest('/v2/evc/', methods=['GET'])
    def list_circuits(self):
        """Endpoint to return all circuits stored."""
        circuits = self.storehouse.get_data()
        if not circuits:
            return jsonify({}), 200

        return jsonify(circuits), 200

    @rest('/v2/evc/<circuit_id>', methods=['GET'])
    def get_circuit(self, circuit_id):
        """Endpoint to return a circuit based on id."""
        circuits = self.storehouse.get_data()

        if circuit_id in circuits:
            result = circuits[circuit_id]
            status = 200
        else:
            result = {'response': f'circuit_id {circuit_id} not found'}
            status = 400

        return jsonify(result), status

    @rest('/v2/evc/', methods=['POST'])
    def create_circuit(self):
        """Try to create a new circuit.

        Firstly, for EVPL: E-Line NApp verifies if UNI_A's requested C-VID and
        UNI_Z's requested C-VID are available from the interfaces' pools. This
        is checked when creating the UNI object.

        Then, E-Line NApp requests a primary and a backup path to the
        Pathfinder NApp using the attributes primary_links and backup_links
        submitted via REST

        # For each link composing paths in #3:
        #  - E-Line NApp requests a S-VID available from the link VLAN pool.
        #  - Using the S-VID obtained, generate abstract flow entries to be
        #    sent to FlowManager

        Push abstract flow entries to FlowManager and FlowManager pushes
        OpenFlow entries to datapaths

        E-Line NApp generates an event to notify all Kytos NApps of a new EVC
        creation

        Finnaly, notify user of the status of its request.
        """
        # Try to create the circuit object
        data = request.get_json()

        if not data:
            return jsonify("Bad request: The request do not have a json."), 400

        try:
            evc = self.evc_from_dict(data)
        except ValueError as exception:
            log.error(exception)
            return jsonify("Bad request: {}".format(exception)), 400

        # verify duplicated evc
        if self.is_duplicated_evc(evc):
            return jsonify("Not Acceptable: This evc already exists."), 409

        # save circuit
        self.storehouse.save_evc(evc)

        # Schedule the circuit deploy
        self.sched.add(evc)

        # Circuit has no schedule, deploy now
        if not evc.circuit_scheduler:
            evc.deploy()

        # Notify users
        event = KytosEvent(name='kytos.mef_eline.created',
                           content=evc.as_dict())
        self.controller.buffers.app.put(event)

        return jsonify({"circuit_id": evc.id}), 201

    @rest('/v2/evc/<circuit_id>', methods=['PATCH'])
    def update(self, circuit_id):
        """Update a circuit based on payload.

        The EVC required attributes (name, uni_a, uni_z) can't be updated.
        """
        data = request.get_json()
        circuits = self.storehouse.get_data()

        if circuit_id not in circuits:
            result = {'response': f'circuit_id {circuit_id} not found'}
            return jsonify(result), 404

        try:
            evc = self.evc_from_dict(circuits.get(circuit_id))
            evc.update(**data)
            self.storehouse.save_evc(evc)
            result = {evc.id: evc.as_dict()}
            status = 200
        except ValueError as exception:
            log.error(exception)
            result = "Bad request: {}".format(exception)
            status = 400

        return jsonify(result), status

    @rest('/v2/evc/<circuit_id>', methods=['DELETE'])
    def delete_circuit(self, circuit_id):
        """Remove a circuit.

        First, the flows are removed from the switches, and then the EVC is
        disabled.
        """
        circuits = self.storehouse.get_data()
        log.info("Removing %s" % circuit_id)
        evc = self.evc_from_dict(circuits.get(circuit_id))
        evc.remove_current_flows()
        evc.deactivate()
        evc.disable()
        self.sched.remove(evc)
        evc.archive()
        evc.sync()

        return jsonify("Circuit removed"), 200

    @rest('/v2/evc/schedule', methods=['GET'])
    def list_schedules(self):
        """Endpoint to return all circuits stored."""
        circuits = self.storehouse.get_data().values()
        if not circuits:
            return jsonify({}), 200

        result = []
        for circuit in circuits:
            if circuit["circuit_scheduler"]:
                schedule = {circuit["id"]: circuit["circuit_scheduler"]}
                result.append(schedule)

        return jsonify(result), 200

    @rest('/v2/evc/<circuit_id>/schedule/', methods=['GET'])
    def get_schedule(self, circuit_id):
        """Endpoint to return list all schedule from a circuit."""
        circuits = self.storehouse.get_data()

        if circuit_id in circuits:
            circuit = circuits[circuit_id]
            result = circuit["circuit_scheduler"]
            status = 200
        else:
            result = {'response': f'circuit_id {circuit_id} not found'}
            status = 400

        return jsonify(result), status

    @rest('/v2/evc/<circuit_id>/schedule/', methods=['POST'])
    def create_schedule(self, circuit_id):
        """
        Create a new schedule for a given circuit.

        This service do no check if there are conflicts with another schedule.
        """
        # Try to create the circuit object
        data = request.get_json()

        if not data:
            return jsonify("Bad request: The request do not have a json."), 400

        try:
            # new schedule from dict
            new_schedule = CircuitSchedule.from_dict(data)
        except ValueError as exception:
            log.error(exception)
            return jsonify("Bad request: {}".format(exception)), 400

        # get the circuit
        circuits = self.storehouse.get_data()
        if circuit_id not in circuits:
            result = {'response': f'circuit_id {circuit_id} not found'}
            return jsonify(result), 404

        evc = self.evc_from_dict(circuits.get(circuit_id))

        # If there is no schedule, create the list
        if not evc.circuit_scheduler:
            evc.circuit_scheduler = []

        # Add the new schedule
        evc.circuit_scheduler.append(new_schedule)

        # save circuit
        self.storehouse.save_evc(evc)

        return jsonify({"schedule_id": new_schedule.id}), 201

    @rest('/v2/evc/<circuit_id>/schedule/<schedule_id>', methods=['PATCH'])
    def update_schedule(self, circuit_id, schedule_id):
        """Update a schedule.

        Change all attributes from the given schedule from a EVC circuit.
        The schedule ID is preserved as default, but it can also be modified.

        The scheduler is notified and refresh all the schedules from
        the given EVC circuit.
        """
        data = request.get_json()
        circuits = self.storehouse.get_data()

        if circuit_id not in circuits:
            result = {'response': f'circuit_id {circuit_id} not found'}
            return jsonify(result), 404

        try:
            evc = self.evc_from_dict(circuits.get(circuit_id))

            # Try to find a circuit schedule
            found_schedule = None
            for schedule in evc.circuit_scheduler:
                if schedule.id == schedule_id:
                    found_schedule = schedule
                    break

            if found_schedule:
                new_schedule = CircuitSchedule.from_dict(data)
                new_schedule.id = found_schedule.id
                # Remove the old schedule
                evc.circuit_scheduler.remove(found_schedule)
                # Append the modified schedule
                evc.circuit_scheduler.append(new_schedule)

                # Cancel all schedule jobs
                for schedule in evc.circuit_scheduler:
                    self.sched.cancel_job(schedule.id)
                # Add all the circuit schedules again
                self.sched.add(evc)
                # Save EVC to the storehouse
                self.storehouse.save_evc(evc)

                result = {evc.id: evc.as_dict()}
                status = 200
            else:
                result = {'response': f'schedule_id {schedule_id} not found'}
                status = 404

        except ValueError as exception:
            log.error(exception)
            result = "Bad request: {}".format(exception)
            status = 400

        return jsonify(result), status

    @rest('/v2/evc/<circuit_id>/schedule/<schedule_id>', methods=['DELETE'])
    def delete_schedule(self, circuit_id, schedule_id):
        """Remove a circuit schedule.

        Remove the Schedule from EVC.
        Remove the Schedule from cron job.
        Save the EVC to the Storehouse.
        """
        circuits = self.storehouse.get_data()
        evc = self.evc_from_dict(circuits.get(circuit_id))

        # Try to find a circuit schedule
        found_schedule = None
        for schedule in evc.circuit_scheduler:
            if schedule.id == schedule_id:
                found_schedule = schedule
                break

        if found_schedule:
            # Remove the old schedule
            evc.circuit_scheduler.remove(found_schedule)

            # Cancel all schedule jobs
            for schedule in evc.circuit_scheduler:
                self.sched.cancel_job(schedule.id)
            # Add all the circuit schedules again
            self.sched.add(evc)
            # Save EVC to the storehouse
            self.storehouse.save_evc(evc)

            result = "Schedule removed"
            status = 200
        else:
            result = {'response': f'schedule_id {schedule_id} not found'}
            status = 404

        return jsonify(result), status

    def is_duplicated_evc(self, evc):
        """Verify if the circuit given is duplicated with the stored evcs.

        Args:
            evc (EVC): circuit to be analysed.

        Returns:
            boolean: True if the circuit is duplicated, otherwise False.

        """
        for circuit_dict in self.storehouse.get_data().values():
            try:
                circuit = self.evc_from_dict(circuit_dict)
            except ValueError as exception:
                log.error(exception)
                continue

            if not evc.archived and circuit == evc:
                return True

        return False

    @listen_to('kytos/topology.link_up')
    def handle_link_up(self, event):
        """Change circuit when link is up or end_maintenance."""
        evc = None

        for data in self.storehouse.get_data().values():
            try:
                evc = self.evc_from_dict(data)
            except ValueError as _exception:
                log.error(_exception)
                log.debug(f'{data.get("id")} can not be provisioning yet.')
                continue

            if evc.is_enabled() and not evc.archived:
                evc.handle_link_up(event.content['link'])

    @listen_to('kytos/topology.link_down')
    def handle_link_down(self, event):
        """Change circuit when link is down or under_mantenance."""
        evc = None

        for data in self.storehouse.get_data().values():
            try:
                evc = self.evc_from_dict(data)
            except ValueError as _exception:
                log.debug(f'{data.get("id")} can not be provisioned yet.')
                continue

            if evc.is_affected_by_link(event.content['link']):
                log.info('handling evc %s' % evc)
                evc.handle_link_down()

    def evc_from_dict(self, evc_dict):
        """Convert some dict values to instance of EVC classes.

        This method will convert: [UNI, Link]
        """
        data = evc_dict.copy()  # Do not modify the original dict

        for attribute, value in data.items():

            if 'uni' in attribute:
                try:
                    data[attribute] = self.uni_from_dict(value)
                except ValueError as exc:
                    raise ValueError(f'Error creating UNI: {exc}')

            if attribute == 'circuit_scheduler':
                data[attribute] = []
                for schedule in value:
                    data[attribute].append(CircuitSchedule.from_dict(schedule))

            if 'link' in attribute:
                if value:
                    data[attribute] = self.link_from_dict(value)

            if 'path' in attribute and attribute != 'dynamic_backup_path':
                if value:
                    data[attribute] = [self.link_from_dict(link)
                                       for link in value]

        return EVC(self.controller, **data)

    def uni_from_dict(self, uni_dict):
        """Return a UNI object from python dict."""
        if uni_dict is None:
            return False

        interface_id = uni_dict.get("interface_id")
        interface = self.controller.get_interface_by_id(interface_id)
        if interface is None:
            raise ValueError(f'Could not instantiate interface {interface_id}')

        tag_dict = uni_dict.get("tag")
        tag = TAG.from_dict(tag_dict)
        if tag is False:
            raise ValueError(f'Could not instantiate tag from dict {tag_dict}')

        uni = UNI(interface, tag)

        return uni

    def link_from_dict(self, link_dict):
        """Return a Link object from python dict."""
        id_a = link_dict.get('endpoint_a').get('id')
        id_b = link_dict.get('endpoint_b').get('id')

        endpoint_a = self.controller.get_interface_by_id(id_a)
        endpoint_b = self.controller.get_interface_by_id(id_b)

        link = Link(endpoint_a, endpoint_b)
        if 'metadata' in link_dict:
            link.extend_metadata(link_dict.get('metadata'))

        s_vlan = link.get_metadata('s_vlan')
        if s_vlan:
            tag = TAG.from_dict(s_vlan)
            if tag is False:
                error_msg = f'Could not instantiate tag from dict {s_vlan}'
                raise ValueError(error_msg)
            link.update_metadata('s_vlan', tag)
        return link