path: root/docs/apex/APEX-PCVS-Example.rst

.. This work is licensed under a Creative Commons Attribution 4.0 International License.
.. http://creativecommons.org/licenses/by/4.0

.. _apex-PCVSExample:

Policy-controlled Video Streaming (pcvs) with APEX
**************************************************

.. contents::
    :depth: 3

Introduction
^^^^^^^^^^^^

      .. container:: sectionbody

           .. container:: paragraph

                  This module contains several demos for
                  Policy-controlled Video Streaming (PCVS). Each demo
                  defines a policy using AVRO and Javascript (or other
                  scripting languages for the policy logic). To run the
                  demo, a vanilla Ubuntu server with some extra software
                  packages is required:

               .. container:: ulist

                  -  Mininet as network simulator

                  -  Floodlight as SDN controller

                  -  Kafka as messaging system

                  -  Zookeeper for Kafka configuration

                  -  APEX for policy control

Install Ubuntu Server and SW
^^^^^^^^^^^^^^^^^^^^^^^^^^^^

          .. container:: sect1

            .. rubric:: Install Demo
               :name: install_demo

            .. container:: sectionbody

               .. container:: paragraph

                  Requirements:

               .. container:: ulist

                  -  Ubuntu server: 1.4 GB

                  -  Ubuntu with Xubuntu Desktop, git, Firefox: 2.3 GB

                  -  Ubuntu with all, system updated: 3 GB

                  -  With ZK, Kafka, VLC, Mininet, Floodlight, Python:
                     4.4 GB

                  -  APEX Build (M2 and built): M2 ~ 2 GB, APEX ~3.5 GB

                  -  APEX install (not build locally): ~ 300 MB

               .. container:: paragraph

                  On a Ubuntu OS (install a stable or LTS server first)

               .. container:: listingblock

                  .. container:: content

                     ::

                        # pre for Ubuntu, tools and X
                        sudo apt-get  -y install --no-install-recommends software-properties-common
                        sudo apt-get  -y install --no-install-recommends build-essential
                        sudo apt-get  -y install --no-install-recommends git
                        sudo aptitude -y install --no-install-recommends xubuntu-desktop
                        sudo apt-get  -y install --no-install-recommends firefox


                        # install Java
                        sudo add-apt-repository ppa:webupd8team/java
                        sudo apt-get update
                        sudo apt-get -y install --no-install-recommends oracle-java8-installer
                        java -version


                        # reboot system, run system update, then continue

                        # if VBox additions are needed, install and reboot
                        sudo (cd /usr/local/share; wget https://www.virtualbox.org/download/testcase/VBoxGuestAdditions_5.2.7-120528.iso)
                        sudo mount /usr/local/share/VBoxGuestAdditions_5.2.7-120528.iso /media/cdrom
                        sudo (cd /media/cdrom;VBoxLinuxAdditions.run)


                        # update apt-get DB
                        sudo apt-get update

                        # if APEX is build from source, install maven and rpm
                        sudo apt-get install maven rpm

                        # install ZooKeeper
                        sudo apt-get install zookeeperd

                        # install Kafka
                        (cd /tmp;wget http://ftp.heanet.ie/mirrors/www.apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.tgz --show-progress)
                        sudo mkdir /opt/Kafka
                        sudo tar -xvf /tmp/kafka_2.12-1.0.0.tgz -C /opt/Kafka/

                        # install mininet
                        cd /usr/local/src
                        sudo git clone https://github.com/mininet/mininet.git
                        (cd mininet;util/install.sh -a)

                        # install floodlight, requires ant
                        sudo apt-get install ant
                        cd /usr/local/src
                        sudo wget --no-check-certificate https://github.com/floodlight/floodlight/archive/master.zip
                        sudo unzip master.zip
                        cd floodlight-master
                        sudo ant
                        sudo mkdir /var/lib/floodlight
                        sudo chmod 777 /var/lib/floodlight

                        # install python pip
                        sudo apt-get install python-pip

                        # install kafka-python (need newer version from github)
                        cd /usr/local/src
                        sudo git clone https://github.com/dpkp/kafka-python
                        sudo pip install ./kafka-python

                        # install vlc
                        sudo apt-get install vlc

               .. container:: paragraph

                  Install APEX either from source or from a distribution
                  package. See the APEX documentation for details. We
                  assume that APEX is installed in
                  ``/opt/ericsson/apex/apex``

               .. container:: paragraph

                  Copy the LinkMonitor file to Kafka-Python

               .. container:: listingblock

                  .. container:: content

                     ::

                        sudo cp /opt/ericsson/apex/apex/examples/scripts/pcvs/vpnsla/LinkMonitor.py /usr/local/src/kafka-python

               .. container:: paragraph

                  Change the Logback configuration in APEX to logic
                  logging

               .. container:: listingblock

                  .. container:: content

                     ::

                        (cd /opt/ericsson/apex/apex/etc; sudo cp logback-logic.xml logback.xml)

         .. container:: sect1

            .. rubric:: Get the Demo Video
               :name: get_the_demo_video

            .. container:: sectionbody

               .. container:: ulist

                  -  For all download options of the movie please visit
                     http://bbb3d.renderfarming.net/download.html

                  -  For lower-res downloads and mirrors see
                     https://peach.blender.org/download

               .. container:: listingblock

                  .. container:: content

                     ::

                        sudo mkdir /usr/local/src/videos

               .. container:: paragraph

                  Standard 720p (recommended)

               .. container:: listingblock

                  .. container:: content

                     ::

                        (cd /usr/local/src/videos; sudo curl -o big_buck_bunny_480p_surround.avi http://download.blender.org/peach/bigbuckbunny_movies/big_buck_bunny_480p_surround-fix.avi)

               .. container:: paragraph

                  Full HD video

               .. container:: listingblock

                  .. container:: content

                     ::

                        (cd videos; sudo curl -o bbb_sunflower_1080p_60fps_normal.mp4 http://distribution.bbb3d.renderfarming.net/video/mp4/bbb_sunflower_1080p_60fps_normal.mp4)



VPN SLA Demo
^^^^^^^^^^^^^

          .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  This demo uses a network with several central office
                  and core switches, over which two VPNs are run. A
                  customer ``A`` has two location ``A1`` and ``A2`` and
                  a VPN between them. A customer ``B`` has two location
                  ``B1`` and ``B2`` and a VPN between them.

               .. container:: imageblock

                  .. container:: content

                     |VPN SLA Architecture|

               .. container:: paragraph

                  The architecture above shows the scenario. The
                  components are realized in this demo as follows:

               .. container:: ulist

                  -  *CEP / Analytics* - a simple Python script taking
                     events from Kafka and sending them to APEX

                  -  *APEX / Policy* - the APEX engine running the VPA
                     SLA policy

                  -  *Controller* - A vanilla Floodlight controller
                     taking events from the Link Monitor and configuring
                     Mininet

                  -  *Network* - A network created using Mininet

               .. container:: paragraph

                  The demo requires to start some software (detailed
                  below). To show actual video streams, we use ``VLC``.
                  If you do not want to show video streams, but only the
                  policy, skip the ``VLC`` section.

               .. container:: paragraph

                  All shown scripts are available in a full APEX
                  installation in
                  ``$APEX_HOME/examples/scripts/pcvs/vpnsla``.

               .. container:: sect2

                  .. rubric:: Start all Software
                     :name: start_all_software

                  .. container:: paragraph

                     Create environment variables in a file, say
                     ``env.sh``. In each new Xterm

                  .. container:: ulist

                     -  Source these environment settings, e.g.
                        ``. ./env.sh``

                     -  Run the commands below as root (``sudo`` per
                        command or ``sudo -i`` for interactive mode as
                        shown below)

                  .. container:: listingblock

                     .. container:: content

                        ::

                           #!/usr/bin/env bash

                           export src_dir=/usr/local/src
                           export APEX_HOME=/opt/ericsson/apex/apex
                           export APEX_USER=apexuser

                  .. container:: paragraph

                     In a new Xterm, start Floodlight

                  .. container:: listingblock

                     .. container:: content

                        ::

                           sudo -i
                           . ./env.sh
                           cd $src_dir/floodlight-master && java -jar target/floodlight.jar

                  .. container:: paragraph

                     In a new Xterm start Mininet

                  .. container:: listingblock

                     .. container:: content

                        ::

                           sudo -i
                           . ./env.sh
                           mn -c && python $APEX_HOME/examples/scripts/pcvs/vpnsla/MininetTopology.py

                  .. container:: paragraph

                     In a new Xterm, start Kafka

                  .. container:: listingblock

                     .. container:: content

                        ::

                           sudo -i
                           . ./env.sh
                           /opt/Kafka/kafka_2.12-1.0.0/bin/kafka-server-start.sh /opt/Kafka/kafka_2.12-1.0.0/config/server.properties

                  .. container:: paragraph

                     In a new Xerm start APEX with the Kafka
                     configuration for this demo

                  .. container:: listingblock

                     .. container:: content

                        ::

                           cd $APEX_HOME
                           ./bin/apexApps.sh engine -c examples/config/pcvs/vpnsla/kafka2kafka.json

                  .. container:: paragraph

                     In a new Xterm start the Link Monitor. The Link
                     Monitor has a 30 second sleep to slow down the
                     demonstration. So the first action of it comes 30
                     seconds after start. Every new action in 30 second
                     intervals.

                  .. container:: listingblock

                     .. container:: content

                        ::

                           sudo -i
                           . ./env.sh
                           cd $src_dir
                           xterm -hold -e 'python3 $src_dir/kafka-python/LinkMonitor.py' &

                  .. container:: paragraph

                     Now all software should be started and the demo is
                     running. The Link Monitor will send link up events,
                     picked up by APEX which triggers the policy. Since
                     there is no problem, the policy will do nothing.

               .. container:: sect2

                  .. rubric:: Create 2 Video Streams with VLC
                     :name: create_2_video_streams_with_vlc

                  .. container:: paragraph

                     In the Mininet console, type ``xterm A1 A2`` and
                     ``xterm B1 B2`` to open terminals on these nodes.

                  .. container:: paragraph

                     ``A2`` and ``B2`` are the receiving nodes. In these
                     terminals, run ``vlc-wrapper``. In each opened VLC
                     window do

                  .. container:: ulist

                     -  Click Media → Open Network Stream

                     -  Give the URL as ``rtp://@:5004``

                  .. container:: paragraph

                     ``A1`` and ``B1`` are the sending nodes (sending
                     the video stream) In these terminals, run
                     ``vlc-wrapper``. In each opened VLC window do

                  .. container:: ulist

                     -  Click Media → Stream

                     -  Add the video (from ``/usr/local/src/videos``)

                     -  Click ``Stream``

                     -  Click ``Next``

                     -  Change the destination
                        ``RTP / MPEG Transport Stream`` and click
                        ``Add``

                     -  Change the address and type to ``10.0.0.2`` in
                        ``A1`` and to ``10.0.0.4`` in ``B1``

                     -  Turn off ``Active Transcoding`` (this is
                        important to minimize CPU load)

                     -  Click ``Next``

                     -  Click ``Stream``

                  .. container:: paragraph

                     The video should be streaming across the network
                     from ``A1`` to ``A2`` and from ``B1`` to ``B2``. If
                     the video streams a slow or interrupted the CPU
                     load is too high. In these cases either try a
                     better machine or use a different (lower quality)
                     video stream.

               .. container:: sect2

                  .. rubric:: Take out L09 and let the Policy do it’s
                     Magic
                     :name: take_out_l09_and_let_the_policy_do_it_s_magic

                  .. container:: paragraph

                     Now it is time to take out the link ``L09``. This
                     will be picked up by the Link Monitor, which sends
                     a new event (L09 DOWN) to the policy. The policy
                     then will calculate which customer should be
                     impeded (throttled). This will continue, until SLAs
                     are violated, then a priority calculation will kick
                     in (Customer ``A`` is prioritized in the setup).

                  .. container:: paragraph

                     To initiate this, simply type ``link s5 s6 down``
                     in the Mininet console followed by ``exit``.

                  .. container:: paragraph

                     If you have the video streams running, you will see
                     one or the other struggeling, depending on the
                     policy decision.

               .. container:: sect2

                  .. rubric:: Reset the Demo
                     :name: reset_the_demo

                  .. container:: paragraph

                     If you want to reset the demo, simple stop (in this
                     order) the following process

                  .. container:: ulist

                     -  Link Monitor

                     -  APEX

                     -  Mininet

                     -  Floodlight

                  .. container:: paragraph

                     Then restart them in this order

                  .. container:: ulist

                     -  Floodlight

                     -  Mininet

                     -  APEX

                     -  Link Monitor

               .. container:: sect2

                  .. rubric:: Monitor the Demo
                     :name: monitor_the_demo

                  .. container:: paragraph

                     Floodlight and APEX provide REST interfaces for
                     monitoring.

                  .. container:: ulist

                     -  Floodlight: see `Floodlight
                        Docs <https://floodlight.atlassian.net/wiki/spaces/floodlightcontroller/pages/40403023/Web+GUI>`__
                        for details on how to access the monitoring. In
                        a standard installation as we use here, pointing
                        browser to the URL
                        ``http://localhost:8080/ui/pages/index.html``
                        should work on the same host

                     -  APEX please see the APEX documentation for
                        `Monitoring
                        Client <https://ericsson.github.io/apex-docs/user-manual/engine-apps/um-engapps-eng-monitoring.html>`__
                        or `Full
                        Client <https://ericsson.github.io/apex-docs/user-manual/engine-apps/um-engapps-full-client.html>`__
                        for details on how to monitor APEX.


VPN SLA Policy
^^^^^^^^^^^^^^

            .. container:: sectionbody

               .. container:: paragraph

                  The VPN SLA policy is designed as a MEDA policy. The
                  first state (M = Match) takes the trigger event (a
                  link up or down) and checks if this is a change to the
                  known topology. The second state (E = Establish) takes
                  all available information (trigger event, local
                  context) and defines what situation we have. The third
                  state (D = Decide) takes the situation and selects
                  which algorithm is best to process it. This state can
                  select between ``none`` (nothing to do), ``solved`` (a
                  problem is solved now), ``sla`` (compare the current
                  customer SLA situation and select one to impede), and
                  ``priority`` (impede non-priority customers). The
                  fourth and final state (A = Act) selects the right
                  action for the taken decision and creates the response
                  event sent to the orchestrator.

               .. container:: paragraph

                  We have added three more policies to set the local
                  context: one for adding nodes, one for adding edges
                  (links), and one for adding customers. These policies
                  do not realize any action, they are only here for
                  updating the local context. This mechanism is the
                  fasted way to update local context, and it is
                  independent of any context plugin.

               .. container:: paragraph

                  The policy uses data defined in Avro, so we have a
                  number of Avro schema definitions.

Context Schemas
---------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The context schemas are for the local context. We
                  model edges and nodes for the topology, customers, and
                  problems with all information on detected problems.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "type" : "record",
                            "name" : "TopologyEdges",
                            "fields" : [
                                {"name": "name",   "type": "string",  "doc": "Name of the Edge, typically a link name"},
                                {"name": "start",  "type": "string",  "doc": "Edge endpoint: start - a node name"},
                                {"name": "end",    "type": "string",  "doc": "Edge endpoint: end - a node name"},
                                {"name": "active", "type": "boolean", "doc": "Flag for active/inactive edges, inactive means a link is down"}
                            ]
                        }

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "type" : "record",
                            "name" : "TopologyNodes",
                            "fields" : [
                                {"name" : "name",   "type" : "string", "doc": "The name of the node"},
                                {"name" : "mnname", "type" : "string", "doc": "The name of the node in Mininet"}
                            ]
                        }

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "type" : "record",
                            "name" : "Customer",
                            "fields" : [
                                {"name" : "customerName", "type" : "string"},
                                {"name" : "dtSLA"       , "type" : "int"},
                                {"name" : "dtYTD"       , "type" : "int"},
                                {"name" : "priority"    , "type" : "boolean"},
                                {"name" : "satisfaction", "type" : "int"},
                                {
                                    "name": "links",
                                    "doc": "Links used by this customer",
                                    "type": {"type"  : "array", "items" : "string"}
                                }
                            ]
                        }


Trigger Schemas
---------------

        .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The trigger event provides a status as ``UP`` or
                  ``DOWN``. To avoid tests for these strings in the
                  logic, we defined an Avro schema for an enumeration.
                  This does not impact the trigger system (it can still
                  send the strings), but makes the task logic simpler.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "type": "enum",
                            "name": "Status",
                            "symbols" : [
                                "UP",
                                "DOWN"
                            ]
                        }

Context Logic Nodes
--------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The node context logic simply takes the trigger event
                  (for context) and creates a new node in the local
                  context topology.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var ifNodeName = executor.inFields["nodeName"];
                        var ifMininetName = executor.inFields["mininetName"];

                        var albumTopoNodes = executor.getContextAlbum("albumTopoNodes");

                        logger.trace("-- got infields, testing existing node");

                        var ctxtNode = albumTopoNodes.get(ifNodeName);
                        if (ctxtNode != null) {
                            albumTopoNodes.remove(ifNodeName);
                            logger.trace("-- removed node: <" + ifNodeName + ">");
                        }

                        logger.trace("-- creating node: <" + ifNodeName + ">");
                        ctxtNode = "{name:" + ifNodeName + ", mnname:" + ifMininetName + "}";
                        albumTopoNodes.put(ifNodeName, ctxtNode);

                        if (logger.isTraceEnabled()) {
                            logger.trace("   >> *** Nodes ***");
                            if (albumTopoNodes != null) {
                                for (var i = 0; i < albumTopoNodes.values().size(); i++) {
                                    logger.trace("   >> >> " + albumTopoNodes.values().get(i).get("name") + " : "
                                            + albumTopoNodes.values().get(i).get("mnname"));
                                }
                            } else {
                                logger.trace("   >> >> node album is null");
                            }
                        }

                        executor.outFields["report"] = "node ctxt :: added node " + ifNodeName;

                        logger.info("vpnsla: ctxt added node " + ifNodeName);

                        var returnValueType = Java.type("java.lang.Boolean");
                        var returnValue = new returnValueType(true);
                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".");

Context Logic Edges
--------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The edge context logic simply takes the trigger event
                  (for context) and creates a new edge in the local
                  context topology.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var ifEdgeName = executor.inFields["edgeName"];
                        var ifEdgeStatus = executor.inFields["status"];

                        var albumTopoEdges = executor.getContextAlbum("albumTopoEdges");

                        logger.trace("-- got infields, testing existing edge");

                        var ctxtEdge = albumTopoEdges.get(ifEdgeName);
                        if (ctxtEdge != null) {
                            albumTopoEdges.remove(ifEdgeName);
                            logger.trace("-- removed edge: <" + ifEdgeName + ">");
                        }

                        logger.trace("-- creating edge: <" + ifEdgeName + ">");
                        ctxtEdge = "{name:" + ifEdgeName + ", start:" + executor.inFields["start"] + ", end:" + executor.inFields["end"]
                                + ", active:" + ifEdgeStatus + "}";
                        albumTopoEdges.put(ifEdgeName, ctxtEdge);

                        if (logger.isTraceEnabled()) {
                            logger.trace("   >> *** Edges ***");
                            if (albumTopoEdges != null) {
                                for (var i = 0; i < albumTopoEdges.values().size(); i++) {
                                    logger.trace("   >> >> " + albumTopoEdges.values().get(i).get("name") + " \t "
                                            + albumTopoEdges.values().get(i).get("start") + " --> " + albumTopoEdges.values().get(i).get("end")
                                            + " \t " + albumTopoEdges.values().get(i).get("active"));
                                }
                            } else {
                                logger.trace("   >> >> edge album is null");
                            }
                        }

                        executor.outFields["report"] = "edge ctxt :: added edge " + ifEdgeName;

                        logger.info("vpnsla: ctxt added edge " + ifEdgeName);

                        var returnValueType = Java.type("java.lang.Boolean");
                        var returnValue = new returnValueType(true);
                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".");

Context Logic Customer
----------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The customer context logic simply takes the trigger
                  event (for context) and creates a new customer in the
                  local context topology.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var ifCustomerName = executor.inFields["customerName"];
                        var ifLinks = executor.inFields["links"];

                        logger.trace("-- got infields, testing existing customer");
                        var ctxtCustomer = executor.getContextAlbum("albumCustomerMap").get(ifCustomerName);
                        if (ctxtCustomer != null) {
                            executor.getContextAlbum("albumCustomerMap").remove(ifCustomerName);
                            logger.trace("-- removed customer: <" + ifCustomerName + ">");
                        }

                        logger.trace("-- creating customer: <" + ifCustomerName + ">");
                        var links = new Array();
                        for (var i = 0; i < ifLinks.split(" ").length; i++) {
                            var link = executor.getContextAlbum("albumTopoEdges").get(ifLinks.split(" ")[i]);
                            if (link != null) {
                                logger.trace("-- link: <" + ifLinks.split(" ")[i] + ">");
                                links.push(ifLinks.split(" ")[i]);
                            } else {
                                logger.trace("-- unknown link: <" + ifLinks.split(" ")[i] + "> for customer <" + ifCustomerName + ">");
                            }
                        }
                        logger.trace("-- links: <" + links + ">");
                        ctxtCustomer = "{customerName:" + ifCustomerName + ", dtSLA:" + executor.inFields["dtSLA"] + ", dtYTD:"
                                + executor.inFields["dtYTD"] + ", priority:" + executor.inFields["priority"] + ", satisfaction:"
                                + executor.inFields["satisfaction"] + ", links:[" + links + "]}";

                        executor.getContextAlbum("albumCustomerMap").put(ifCustomerName, ctxtCustomer);

                        if (logger.isTraceEnabled()) {
                            logger.trace("   >> *** Customers ***");
                            if (executor.getContextAlbum("albumCustomerMap") != null) {
                                for (var i = 0; i < executor.getContextAlbum("albumCustomerMap").values().size(); i++) {
                                    logger.trace("   >> >> " + executor.getContextAlbum("albumCustomerMap").values().get(i).get("customerName")
                                            + " : " + "dtSLA=" + executor.getContextAlbum("albumCustomerMap").values().get(i).get("dtSLA")
                                            + " : " + "dtYTD=" + executor.getContextAlbum("albumCustomerMap").values().get(i).get("dtYTD")
                                            + " : " + "links=" + executor.getContextAlbum("albumCustomerMap").values().get(i).get("links")
                                            + " : " + "priority="
                                            + executor.getContextAlbum("albumCustomerMap").values().get(i).get("priority") + " : "
                                            + "satisfaction="
                                            + executor.getContextAlbum("albumCustomerMap").values().get(i).get("satisfaction"));
                                }
                            } else {
                                logger.trace("   >> >> customer album is null");
                            }
                        }

                        executor.outFields["report"] = "customer ctxt :: added customer: " + ifCustomerName;

                        logger.info("vpnsla: ctxt added customer " + ifCustomerName);

                        var returnValueType = Java.type("java.lang.Boolean");
                        var returnValue = new returnValueType(true);
                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".");

Logic: Match
------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  This is the logic for the match state. It is kept very
                  simple. Beside taking the trigger event, it also
                  creates a timestamp. This timestamp is later used for
                  SLA and downtime calculations as well as for some
                  performance information of the policy.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");

                        var now = new Date().getTime();
                        executor.outFields["matchStart"] = now;

                        importClass(org.slf4j.LoggerFactory);

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);

                        var ifEdgeName = executor.inFields["edgeName"];
                        var ifLinkStatus = executor.inFields["status"];

                        var albumTopoEdges = executor.getContextAlbum("albumTopoEdges");

                        logger.trace("-- got infields, checking albumTopoEdges changes");

                        var active = false;
                        switch (ifLinkStatus.toString()) {
                        case "UP":
                            active = true;
                            break;
                        case "DOWN":
                            active = false;
                            break;
                        default:
                            active = false;
                            logger.error("-- trigger sent unknown link status <" + ifLinkStatus + "> for link <" + ifEdgeName + ">");
                            rootLogger.error(executor.subject.id + " " + "-- trigger sent unknown link status <" + ifLinkStatus
                                    + "> for link <" + ifEdgeName + ">");
                        }

                        var link = albumTopoEdges.get(ifEdgeName);
                        if (link == null) {
                            logger.trace("-- link <" + ifEdgeName + "> not in albumTopoEdges");
                        } else {
                            logger.trace("-- found link <" + link + "> in albumTopoEdges");
                            logger.trace("-- active <" + active + "> : link.active <" + link.get("active") + ">");
                            if (active != link.get("active")) {
                                link.put("active", active);
                                logger.trace("-- link <" + ifEdgeName + "> status changed to <active:" + link.get("active") + ">");
                                executor.outFields["hasChanged"] = true;
                            } else {
                                logger.trace("-- link <" + ifEdgeName + "> status not changed <active:" + link.get("active") + ">");
                                executor.outFields["hasChanged"] = false;
                            }
                        }

                        executor.outFields["edgeName"] = ifEdgeName;
                        executor.outFields["status"] = ifLinkStatus;

                        logger.info("vpnsla: detected " + ifEdgeName + " as " + ifLinkStatus);

                        var returnValueType = Java.type("java.lang.Boolean");
                        var returnValue = new returnValueType(true);
                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".m");


Logic: Policy Establish State
-----------------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  This is the logic for the establish state. It is the
                  most complicated logic, since establishing a situation
                  for a decision is the most important part of any
                  policy. First, the policy describes what we find (the
                  switch block), in terms of 8 normal situations and 1
                  extreme error case.

               .. container:: paragraph

                  If required, it creates local context information for
                  the problem (if it is new) or updates it (if the
                  problem still exists). It also calculates customer SLA
                  downtime and checks for any SLA violations. Finally,
                  it creates a situation object.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");
                        importClass(org.slf4j.LoggerFactory);

                        importClass(java.util.ArrayList);

                        importClass(org.apache.avro.generic.GenericData.Array);
                        importClass(org.apache.avro.generic.GenericRecord);
                        importClass(org.apache.avro.Schema);

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);

                        var ifEdgeName = executor.inFields["edgeName"];
                        var ifEdgeStatus = executor.inFields["status"].toString();
                        var ifhasChanged = executor.inFields["hasChanged"];
                        var ifMatchStart = executor.inFields["matchStart"];

                        var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
                        var albumProblemMap = executor.getContextAlbum("albumProblemMap");

                        var linkProblem = albumProblemMap.get(ifEdgeName);

                        // create outfiled for situation
                        var situation = executor.subject.getOutFieldSchemaHelper("situation").createNewInstance();
                        situation.put("violatedSLAs", new ArrayList());

                        // create a string as states+hasChanged+linkProblem and switch over it
                        var switchTest = ifEdgeStatus + ":" + ifhasChanged + ":" + (linkProblem == null ? "no" : "yes");
                        switch (switchTest) {
                        case "UP:false:no":
                            logger.trace("-- edge <" + ifEdgeName + "> UP:false:no => everything ok");
                            logger.info("vpnsla: everything ok");
                            situation.put("problemID", "NONE");
                            break;
                        case "UP:false:yes":
                            logger.trace("-- edge <" + ifEdgeName + "> UP:false:yes ==> did we miss earlier up?, removing problem");
                            albumProblemMap.remove(ifEdgeName);
                            linkProblem = null;
                            situation.put("problemID", "NONE");
                            break;
                        case "UP:true:no":
                            logger.trace("-- edge <" + ifEdgeName + "> UP:true:no ==> did we miss the earlier down?, creating new problem");
                            situation.put("problemID", ifEdgeName);
                            break;
                        case "UP:true:yes":
                            logger.trace("-- edge <" + ifEdgeName + "> UP:true:yes ==> detected solution, link up again");
                            logger.info("vpnsla: problem solved");
                            linkProblem.put("endTime", ifMatchStart);
                            linkProblem.put("status", "SOLVED");
                            situation.put("problemID", "NONE");
                            break;
                        case "DOWN:false:no":
                            logger.trace("-- edge <" + ifEdgeName + "> DOWN:false:no ==> did we miss an earlier down?, creating new problem");
                            situation.put("problemID", ifEdgeName);
                            break;
                        case "DOWN:false:yes":
                            logger.trace("-- edge <" + ifEdgeName + "> DOWN:false:yes ==> problem STILL exists");
                            logger.info("vpnsla: problem still exists");
                            linkProblem.put("status", "STILL");
                            situation.put("problemID", ifEdgeName);
                            break;
                        case "DOWN:true:no":
                            logger.trace("-- edge <" + ifEdgeName + "> DOWN:true:no ==> found NEW problem");
                            logger.info("vpnsla: this is a new problem");
                            situation.put("problemID", ifEdgeName);
                            break;
                        case "DOWN:true:yes":
                            logger.trace("-- edge <" + ifEdgeName
                                    + "> DOWN:true:yes ==> did we miss to remove an earlier problem?, remove and create new problem");
                            linkProblem = null;
                            situation.put("problemID", ifEdgeName);
                            break;

                        default:
                            logger.error("-- input wrong for edge" + ifEdgeName + ": edge status <" + ifEdgeStatus
                                    + "> unknown or null on hasChanged <" + ifhasChanged + ">");
                            rootLogger.error("-- input wrong for edge" + ifEdgeName + ": edge status <" + ifEdgeStatus
                                    + "> unknown or null on hasChanged <" + ifhasChanged + ">");
                        }

                        // create new problem if situation requires it
                        if (situation.get("problemID").equals(ifEdgeName) && linkProblem == null) {
                            logger.trace("-- edge <" + ifEdgeName + "> creating new problem");
                            linkProblem = albumProblemMap.getSchemaHelper().createNewInstance();
                            linkProblem.put("edge", ifEdgeName);
                            linkProblem.put("startTime", ifMatchStart);
                            linkProblem.put("lastUpdate", ifMatchStart);
                            linkProblem.put("endTime", 0);
                            linkProblem.put("status", "NEW");
                            linkProblem.put("edgeUsedBy", new ArrayList());
                            linkProblem.put("impededLast", new ArrayList());

                            for (var i = 0; i < albumCustomerMap.values().size(); i++) {
                                var customer = albumCustomerMap.values().get(i);
                                var customerLinks = albumCustomerMap.values().get(i).get("links");
                                for (var k = 0; k < customerLinks.size(); k++) {
                                    if (customerLinks.get(k) == ifEdgeName) {
                                        linkProblem.get("edgeUsedBy").add(customer.get("customerName"));
                                    }
                                }
                            }
                            albumProblemMap.put(ifEdgeName, linkProblem);
                            logger.trace("-- edge <" + ifEdgeName + "> problem created as <" + linkProblem + ">");
                        }

                        // set dtYTD if situation requires it
                        if (linkProblem != null && (linkProblem.get("status") == "STILL" || linkProblem.get("status") == "SOLVED")) {
                            var linkDownTimeinSecs = (ifMatchStart - linkProblem.get("lastUpdate")) / 1000;
                            logger.trace("-- edge <" + ifEdgeName + "> down time: " + linkDownTimeinSecs + " s");
                            for (var k = 0; k < linkProblem.get("impededLast").size(); k++) {
                                for (var i = 0; i < albumCustomerMap.values().size(); i++) {
                                    var customer = albumCustomerMap.values().get(i);
                                    if (customer.get("customerName").equals(linkProblem.get("impededLast").get(k))) {
                                        logger.info("-- vpnsla: customer " + customer.get("customerName") + " YDT downtime increased from "
                                                + customer.get("dtYTD") + " to " + (customer.get("dtYTD") + linkDownTimeinSecs));
                                        customer.put("dtYTD", (customer.get("dtYTD") + linkDownTimeinSecs))
                                    }
                                }
                            }
                            // set lastUpdate to this policy execution for next execution calculation
                            linkProblem.put("lastUpdate", ifMatchStart);
                        }

                        // check SLA violations if situation requires it
                        if (linkProblem != null && linkProblem.get("status") != "SOLVED") {
                            logger.info(">e> customer\tDT SLA\tDT YTD\tviolation");
                            for (var i = 0; i < albumCustomerMap.values().size(); i++) {
                                var customer = albumCustomerMap.values().get(i);
                                if (customer.get("dtYTD") > customer.get("dtSLA")) {
                                    situation.get("violatedSLAs").add(customer.get("customerName"));
                                    logger.info(">e> " + customer.get("customerName") + "\t\t" + customer.get("dtSLA") + "s\t"
                                            + customer.get("dtYTD") + "s\t" + "!!");
                                } else {
                                    logger.info(">e> " + customer.get("customerName") + "\t\t" + customer.get("dtSLA") + "s\t"
                                            + customer.get("dtYTD") + "s");
                                }
                            }
                        }

                        executor.outFields["situation"] = situation;

                        logger.trace("-- out fields <" + executor.outFields + ">");

                        var returnValueType = Java.type("java.lang.Boolean");
                        var returnValue = new returnValueType(true);
                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".e");

Logic: Policy Decide State
--------------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The decide state can select between different
                  algorithms depending on the situation. So it needs a
                  Task Selection Logic (TSL). This TSL select a task in
                  the current policy execution (i.e. potentially a
                  different one per execution).

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");
                        importClass(org.slf4j.LoggerFactory);

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id + " - TSL");

                        var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);

                        var ifSituation = executor.inFields["situation"];

                        var albumProblemMap = executor.getContextAlbum("albumProblemMap");

                        var returnValueType = Java.type("java.lang.Boolean");
                        if (ifSituation.get("problemID") == "NONE") {
                            logger.trace("-- situation has no problem, selecting <VpnSlaPolicyDecideNoneTask>");
                            executor.subject.getTaskKey("VpnSlaPolicyDecideNoneTask").copyTo(executor.selectedTask);
                            var returnValue = new returnValueType(true);
                        } else if (albumProblemMap.get(ifSituation.get("problemID")).get("status") == "SOLVED") {
                            logger.trace("-- situation is solved, selecting <VpnSlaPolicyDecideSolvedTask>");
                            executor.subject.getTaskKey("VpnSlaPolicyDecideSolvedTask").copyTo(executor.selectedTask);
                            var returnValue = new returnValueType(true);
                        } else if (ifSituation.get("violatedSLAs") != null && ifSituation.get("violatedSLAs").size() > 0) {
                            logger.trace("-- situation is problem with violations, selecting <VpnSlaPolicyDecidePriorityTask>");
                            executor.subject.getTaskKey("VpnSlaPolicyDecidePriorityTask").copyTo(executor.selectedTask);
                            var returnValue = new returnValueType(true);
                        } else if (ifSituation.get("violatedSLAs") != null && ifSituation.get("violatedSLAs").size() == 0) {
                            logger.trace("-- situation is problem without violations, selecting <VpnSlaPolicyDecideSlaTask>");
                            executor.subject.getTaskKey("VpnSlaPolicyDecideSlaTask").copyTo(executor.selectedTask);
                            var returnValue = new returnValueType(true);
                        } else {
                            logger.error("-- detected unknown decision for situation <" + ifSituation.get("problemID") + ">");
                            rootLogger.error(executor.subject.id + " " + "-- detected unknown decision for situation <"
                                    + ifSituation.get("problemID") + ">");
                            var returnValue = new returnValueType(false);
                        }

                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".d-tsl");

               .. container:: paragraph

                  The actual task logic are then ``none``, ``solved``,
                  ``sla``, and ``priority``.

Logic: Decide None
-------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");
                        importClass(org.slf4j.LoggerFactory);

                        importClass(java.util.ArrayList);

                        importClass(org.apache.avro.generic.GenericData.Array);
                        importClass(org.apache.avro.generic.GenericRecord);
                        importClass(org.apache.avro.Schema);

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);

                        var ifSituation = executor.inFields["situation"];

                        // create outfiled for decision
                        var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
                        decision.put("description", "None, everything is ok");
                        decision.put("decision", "NONE");
                        decision.put("customers", new ArrayList());

                        var returnValueType = Java.type("java.lang.Boolean");
                        if (ifSituation.get("problemID") == "NONE") {
                            logger.trace("-- no problem, everything ok");
                            var returnValue = new returnValueType(true);
                        } else {
                            logger.trace("-- wrong problemID <" + problemID + "> for NONE task, we should not be here");
                            rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + problemID
                                    + "> for NONE task, we should not be here");
                            var returnValue = new returnValueType(false);
                        }

                        executor.outFields["decision"] = decision;

                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".d-non");

Logic: Decide Solved
---------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");
                        importClass(org.slf4j.LoggerFactory);

                        importClass(java.util.ArrayList);

                        importClass(org.apache.avro.generic.GenericData.Array);
                        importClass(org.apache.avro.generic.GenericRecord);
                        importClass(org.apache.avro.Schema);

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);

                        var ifSituation = executor.inFields["situation"];

                        var albumProblemMap = executor.getContextAlbum("albumProblemMap");

                        // create outfiled for decision
                        var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
                        decision.put("description", "None, everything is ok");
                        decision.put("decision", "REBUILD");
                        decision.put("customers", new ArrayList());
                        decision.put("problemID", ifSituation.get("problemID"));

                        var returnValueType = Java.type("java.lang.Boolean");
                        if (albumProblemMap.get(ifSituation.get("problemID")).get("status") == "SOLVED") {
                            logger.trace("-- problem solved");
                            var returnValue = new returnValueType(true);
                        } else {
                            logger.trace("-- wrong problemID <" + problemID + "> for SOLVED task, we should not be here");
                            rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + problemID
                                    + "> for SOLVED task, we should not be here");
                            var returnValue = new returnValueType(false);
                        }

                        executor.outFields["decision"] = decision;

                        logger.info("vpnsla: sla solved, problem solved");

                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".d-non");

Logic: Decide SLA
------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");
                        importClass(org.slf4j.LoggerFactory);

                        importClass(java.util.ArrayList);

                        importClass(org.apache.avro.generic.GenericData.Array);
                        importClass(org.apache.avro.generic.GenericRecord);
                        importClass(org.apache.avro.Schema);

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);

                        var ifSituation = executor.inFields["situation"];

                        var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
                        var albumProblemMap = executor.getContextAlbum("albumProblemMap");

                        // create outfiled for decision
                        var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
                        decision.put("description", "Impede given customers selected based on maximum SLA delta");
                        decision.put("decision", "IMPEDE");
                        decision.put("problemID", ifSituation.get("problemID"));
                        decision.put("customers", new ArrayList());

                        var problem = albumProblemMap.get(ifSituation.get("problemID"));
                        var returnValueType = Java.type("java.lang.Boolean");
                        if (problem != null && ifSituation.get("violatedSLAs").size() == 0) {
                            logger.trace("-- impede by maximum SLA");
                            var customer = "";
                            var customerSla = 0;
                            for (var i = 0; i < problem.get("edgeUsedBy").size(); i++) {
                                customerCtxt = albumCustomerMap.get(problem.get("edgeUsedBy").get(i).toString());
                                if (customerSla == 0) {
                                    customerSla = customerCtxt.get("dtSLA") - customerCtxt.get("dtYTD");
                                }
                                if ((customerCtxt.get("dtSLA") - customerCtxt.get("dtYTD")) >= customerSla) {
                                    customer = customerCtxt.get("customerName");
                                    customerSla = (customerCtxt.get("dtSLA") - customerCtxt.get("dtYTD"));
                                }
                            }
                            decision.get("customers").add(customer);
                            var returnValue = new returnValueType(true);
                        } else {
                            logger.trace("-- wrong problemID <" + ifSituation.get("problemID") + "> for SLA task, we should not be here");
                            rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + ifSituation.get("problemID")
                                    + "> for SLA task, we should not be here");
                            var returnValue = new returnValueType(false);
                        }

                        // set impededLast to decision[customers]
                        problem.get("impededLast").clear();
                        problem.get("impededLast").addAll(decision.get("customers"));

                        executor.outFields["decision"] = decision;
                        logger.trace("-- decision: " + decision);

                        logger.info("vpnsla: sla balance, impeding customers " + decision.get("customers"));

                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".d-sla");

Logic: Decide Priority
----------------------

         .. container:: sect2

            .. container:: listingblock

               .. container:: content

                  .. code:: CodeRay

                     /*
                      * ============LICENSE_START=======================================================
                      *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                      * ================================================================================
                      * 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.
                      *
                      * SPDX-License-Identifier: Apache-2.0
                      * ============LICENSE_END=========================================================
                      */

                     load("nashorn:mozilla_compat.js");
                     importClass(org.slf4j.LoggerFactory);

                     importClass(java.util.ArrayList);

                     importClass(org.apache.avro.generic.GenericData.Array);
                     importClass(org.apache.avro.generic.GenericRecord);
                     importClass(org.apache.avro.Schema);

                     var logger = executor.logger;
                     logger.trace("start: " + executor.subject.id);
                     logger.trace("-- infields: " + executor.inFields);

                     var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);

                     var ifSituation = executor.inFields["situation"];

                     var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
                     var albumProblemMap = executor.getContextAlbum("albumProblemMap");

                     // create outfiled for decision
                     var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
                     decision.put("description", "None, everything is ok");
                     decision.put("decision", "IMPEDE");
                     decision.put("problemID", ifSituation.get("problemID"));
                     decision.put("customers", new ArrayList());

                     var problem = albumProblemMap.get(ifSituation.get("problemID"));
                     var returnValueType = Java.type("java.lang.Boolean");
                     if (problem != null && ifSituation.get("violatedSLAs").size() > 0) {
                         logger.trace("-- impede by priority");
                         for (var i = 0; i < problem.get("edgeUsedBy").size(); i++) {
                             customerCtxt = albumCustomerMap.get(problem.get("edgeUsedBy").get(i).toString());
                             if (customerCtxt.get("priority") == false) {
                                 decision.get("customers").add(customerCtxt.get("customerName"));
                             }
                         }
                         var returnValue = new returnValueType(true);
                     } else {
                         logger.trace("-- wrong problemID <" + ifSituation.get("problemID") + "> for PRIORITY task, we should not be here");
                         rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + ifSituation.get("problemID")
                                 + "> for PRIORITY task, we should not be here");
                         var returnValue = new returnValueType(false);
                     }

                     // set impededLast to decision[customers]
                     problem.get("impededLast").clear();
                     problem.get("impededLast").addAll(decision.get("customers"));

                     executor.outFields["decision"] = decision;
                     logger.trace("-- decision: " + decision);

                     logger.info("vpnsla: priority, impeding customers " + decision.get("customers"));

                     logger.trace("finished: " + executor.subject.id);
                     logger.debug(".d-pri");

Logic: Policy Act State
------------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  This is the logic for the act state. It is simply
                  selecting an action, and creating the repsonse event
                  for the orchestrator (the output of the policy).

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        /*
                         * ============LICENSE_START=======================================================
                         *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                         * ================================================================================
                         * 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.
                         *
                         * SPDX-License-Identifier: Apache-2.0
                         * ============LICENSE_END=========================================================
                         */

                        load("nashorn:mozilla_compat.js");

                        var logger = executor.logger;
                        logger.trace("start: " + executor.subject.id);
                        logger.trace("-- infields: " + executor.inFields);

                        var ifDecision = executor.inFields["decision"];
                        var ifMatchStart = executor.inFields["matchStart"];

                        var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
                        var albumProblemMap = executor.getContextAlbum("albumProblemMap");

                        switch (ifDecision.get("decision").toString()) {
                        case "NONE":
                            executor.outFields["edgeName"] = "";
                            executor.outFields["action"] = "";
                            break;
                        case "IMPEDE":
                            for (var i = 0; i < ifDecision.get("customers").size(); i++) {
                                customer = albumCustomerMap.get(ifDecision.get("customers").get(i).toString());
                                executor.outFields["edgeName"] = customer.get("links").get(0);
                                executor.outFields["action"] = "firewall";
                            }
                            break;
                        case "REBUILD":
                            // finally solved, remove problem
                            albumProblemMap.remove(ifDecision.get("problemID"));
                            executor.outFields["edgeName"] = "L10"; // this is ###static###
                            executor.outFields["action"] = "rebuild"; // this is ###static###
                            break;
                        default:

                        }

                        var returnValueType = Java.type("java.lang.Boolean");
                        var returnValue = new returnValueType(true);

                        if (executor.outFields["action"] != "") {
                            logger.info("vpnsla: action is to " + executor.outFields["action"] + " " + executor.outFields["edgeName"]);
                        } else {
                            logger.info("vpnsla: no action required");
                        }

                        logger.trace("-- outfields: " + executor.outFields);
                        logger.trace("finished: " + executor.subject.id);
                        logger.debug(".a");

                        var now = new Date().getTime();
                        logger.info("VPN SLA finished in " + (now - ifMatchStart) + " ms");

CLI Spec
--------

         .. container:: sect1

            .. rubric:: Complete Policy Definition
               :name: complete_policy_definition

            .. container:: sectionbody

               .. container:: paragraph

                  The complete policy definition is realized using the
                  APEX CLI Editor. The script below shows the actual
                  policy specification. All logic and schemas are
                  included (as macro file).

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        #-------------------------------------------------------------------------------
                        # ============LICENSE_START=======================================================
                        #  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                        # ================================================================================
                        # 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.
                        #
                        # SPDX-License-Identifier: Apache-2.0
                        # ============LICENSE_END=========================================================
                        #-------------------------------------------------------------------------------

                        # ============LICENSE_START=======================================================
                        #  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                        # ================================================================================
                        # 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.
                        #
                        # SPDX-License-Identifier: Apache-2.0
                        # ============LICENSE_END=========================================================

                        model create name=PCVS-VpnSla version=1.0.0 description="Policies-Controlled Video Streaming, VPN SLA Policy Model"



                        schema create name=reportDecl version=1.0.0 description="Report of activities of a policy/task" flavour=Java schema=java.lang.String
                        event create name=ReportOut version=1.0.0 description="Report of a policy (issued by a task)" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="APEX" target="CtxtManagement"
                        event parameter create name=ReportOut version=1.0.0 parName=report schemaName=reportDecl schemaVersion=1.0.0

                        schema create name=timestampDecl version=1.0.0 description="Timestamp" flavour=Java schema=java.lang.Long



                        schema create name=ctxtEdgeNameDecl version=1.0.0 description="Topology Edges: edge (link) name" flavour=Java schema=java.lang.String
                        schema create name=ctxtEdgeStartDecl version=1.0.0 description="Topology Edges: edge endpoint (start)" flavour=Java schema=java.lang.String
                        schema create name=ctxtEdgeEndDecl version=1.0.0 description="Topology Edges: edge endpoint (end)" flavour=Java schema=java.lang.String
                        schema create name=ctxtEdgeStatusDecl version=1.0.0 description="Topology Edges: edge status as up (true) or down (false)" flavour=Java schema=java.lang.Boolean

                        schema create name=ctxtTopologyEdgesDecl version=1.0.0 description="Topology Edges Context Map" flavour=Avro schema=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/topology-edges.avsc"
                        LE
                        album create name=albumTopoEdges scope=global writable=true schemaName=ctxtTopologyEdgesDecl


                        task create name=EdgeContextTask version=1.0.0 description="This task adds event context to edge context"
                        task inputfield create name=EdgeContextTask version=1.0.0 fieldName=edgeName schemaName=ctxtEdgeNameDecl schemaVersion=1.0.0
                        task inputfield create name=EdgeContextTask version=1.0.0 fieldName=start schemaName=ctxtEdgeStartDecl schemaVersion=1.0.0
                        task inputfield create name=EdgeContextTask version=1.0.0 fieldName=end schemaName=ctxtEdgeEndDecl schemaVersion=1.0.0
                        task inputfield create name=EdgeContextTask version=1.0.0 fieldName=status schemaName=ctxtEdgeStatusDecl schemaVersion=1.0.0
                        task outputfield create name=EdgeContextTask version=1.0.0 fieldName=report schemaName=reportDecl schemaVersion=1.0.0
                        task contextref create name=EdgeContextTask albumName=albumTopoEdges
                        task logic create name=EdgeContextTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-edges.js"
                        LE

                        event create name=EdgeContextEventIn version=1.0.0 description="Event to add an Edge to engine Context" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="CtxtManagement" target="APEX"
                        event parameter create name=EdgeContextEventIn version=1.0.0 parName=edgeName schemaName=ctxtEdgeNameDecl schemaVersion=1.0.0
                        event parameter create name=EdgeContextEventIn version=1.0.0 parName=start schemaName=ctxtEdgeStartDecl schemaVersion=1.0.0
                        event parameter create name=EdgeContextEventIn version=1.0.0 parName=end schemaName=ctxtEdgeEndDecl schemaVersion=1.0.0
                        event parameter create name=EdgeContextEventIn version=1.0.0 parName=status schemaName=ctxtEdgeStatusDecl schemaVersion=1.0.0

                        policy create name=EdgeContextPolicy version=1.0.0 description="Policy that adds an edge to context" template=FREEFORM firstState=EdgeContextState
                        policy state create name=EdgeContextPolicy version=1.0.0 stateName=EdgeContextState triggerName=EdgeContextEventIn triggerVersion=1.0.0 defaultTaskName=EdgeContextTask defaultTaskVersion=1.0.0
                        policy state output create name=EdgeContextPolicy version=1.0.0 stateName=EdgeContextState outputName=EdgeContextState_Output_Direct eventName=ReportOut eventVersion=1.0.0 nextState=NULL
                        policy state taskref create name=EdgeContextPolicy version=1.0.0 stateName=EdgeContextState taskLocalName=doContext taskName=EdgeContextTask taskVersion=1.0.0 outputType=DIRECT outputName=EdgeContextState_Output_Direct



                        schema create name=ctxtNodeNameDecl version=1.0.0 description="Topology Nodes: node name" flavour=Java schema=java.lang.String
                        schema create name=ctxtNodeMininetNameDecl version=1.0.0 description="Topology Nodes: node name in Mininet" flavour=Java schema=java.lang.String

                        schema create name=ctxtTopologyNodesDecl version=1.0.0 description="Topology Nodes Context Map" flavour=Avro schema=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/topology-nodes.avsc"
                        LE
                        album create name=albumTopoNodes scope=global writable=true schemaName=ctxtTopologyNodesDecl

                        task create name=NodeContextTask version=1.0.0 description="This task adds event context to node context"
                        task inputfield create name=NodeContextTask version=1.0.0 fieldName=nodeName schemaName=ctxtNodeNameDecl schemaVersion=1.0.0
                        task inputfield create name=NodeContextTask version=1.0.0 fieldName=mininetName schemaName=ctxtNodeMininetNameDecl schemaVersion=1.0.0
                        task outputfield create name=NodeContextTask version=1.0.0 fieldName=report schemaName=reportDecl schemaVersion=1.0.0
                        task contextref create name=NodeContextTask albumName=albumTopoNodes
                        task logic create name=NodeContextTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-nodes.js"
                        LE

                        event create name=NodeContextEventIn version=1.0.0 description="Event to add Node to engine Context" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="CtxtManagement" target="APEX"
                        event parameter create name=NodeContextEventIn version=1.0.0 parName=nodeName schemaName=ctxtNodeNameDecl schemaVersion=1.0.0
                        event parameter create name=NodeContextEventIn version=1.0.0 parName=mininetName schemaName=ctxtNodeMininetNameDecl schemaVersion=1.0.0

                        policy create name=NodeContextPolicy version=1.0.0 description="Policy that adds an node to context" template=FREEFORM firstState=NodeContextState
                        policy state create name=NodeContextPolicy version=1.0.0 stateName=NodeContextState triggerName=NodeContextEventIn triggerVersion=1.0.0 defaultTaskName=NodeContextTask defaultTaskVersion=1.0.0
                        policy state output create name=NodeContextPolicy version=1.0.0 stateName=NodeContextState outputName=NodeContextState_Output_Direct eventName=ReportOut eventVersion=1.0.0 nextState=NULL
                        policy state taskref create name=NodeContextPolicy version=1.0.0 stateName=NodeContextState taskLocalName=doContext taskName=NodeContextTask taskVersion=1.0.0 outputType=DIRECT outputName=NodeContextState_Output_Direct




                        schema create name=ctxtCustomerNameDecl version=1.0.0 description="Customer Context: customer name" flavour=Java schema=java.lang.String
                        schema create name=ctxtCustomerPriorityDecl version=1.0.0 description="Customer Context: priority flag" flavour=Java schema=java.lang.Boolean
                        schema create name=ctxtCustomerSatisfactionDecl version=1.0.0 description="Customer Context: satisfaction in percent" flavour=Java schema=java.lang.Integer
                        schema create name=ctxtCustomerDowntimeSLADecl version=1.0.0 description="Customer Context: contracted downtime as per SLA" flavour=Java schema=java.lang.Integer
                        schema create name=ctxtCustomerDowntimeYTDDecl version=1.0.0 description="Customer Context: year-to-date downtime experienced" flavour=Java schema=java.lang.Integer
                        schema create name=ctxtCustomerLinksDecl version=1.0.0 description="Customer Context: links a customer uses (for events/task)" flavour=Java schema=java.lang.String

                        schema create name=ctxtCustomerMapDecl version=1.0.0 description="Map of customers with all known information" flavour=Avro schema=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/customers.avsc"
                        LE
                        album create name=albumCustomerMap scope=global writable=true schemaName=ctxtCustomerMapDecl

                        task create name=CustomerContextTask version=1.0.0 description="This task adds event context to customer context"
                        task inputfield create name=CustomerContextTask version=1.0.0 fieldName=customerName schemaName=ctxtCustomerNameDecl schemaVersion=1.0.0
                        task inputfield create name=CustomerContextTask version=1.0.0 fieldName=priority schemaName=ctxtCustomerPriorityDecl schemaVersion=1.0.0
                        task inputfield create name=CustomerContextTask version=1.0.0 fieldName=satisfaction schemaName=ctxtCustomerSatisfactionDecl schemaVersion=1.0.0
                        task inputfield create name=CustomerContextTask version=1.0.0 fieldName=dtSLA schemaName=ctxtCustomerDowntimeSLADecl schemaVersion=1.0.0
                        task inputfield create name=CustomerContextTask version=1.0.0 fieldName=dtYTD schemaName=ctxtCustomerDowntimeYTDDecl schemaVersion=1.0.0
                        task inputfield create name=CustomerContextTask version=1.0.0 fieldName=links schemaName=ctxtCustomerLinksDecl schemaVersion=1.0.0
                        task outputfield create name=CustomerContextTask version=1.0.0 fieldName=report schemaName=reportDecl schemaVersion=1.0.0
                        task contextref create name=CustomerContextTask albumName=albumCustomerMap
                        task contextref create name=CustomerContextTask albumName=albumTopoEdges
                        task logic create name=CustomerContextTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-customer.js"
                        LE

                        event create name=CustomerContextEventIn version=1.0.0 description="Event to add Customers to engine Context" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="CtxtManagement" target="APEX"
                        event parameter create name=CustomerContextEventIn version=1.0.0 parName=customerName schemaName=ctxtCustomerNameDecl schemaVersion=1.0.0
                        event parameter create name=CustomerContextEventIn version=1.0.0 parName=priority schemaName=ctxtCustomerPriorityDecl schemaVersion=1.0.0
                        event parameter create name=CustomerContextEventIn version=1.0.0 parName=satisfaction schemaName=ctxtCustomerSatisfactionDecl schemaVersion=1.0.0
                        event parameter create name=CustomerContextEventIn version=1.0.0 parName=dtSLA schemaName=ctxtCustomerDowntimeSLADecl schemaVersion=1.0.0
                        event parameter create name=CustomerContextEventIn version=1.0.0 parName=dtYTD schemaName=ctxtCustomerDowntimeYTDDecl schemaVersion=1.0.0
                        event parameter create name=CustomerContextEventIn version=1.0.0 parName=links schemaName=ctxtCustomerLinksDecl schemaVersion=1.0.0

                        policy create name=CustomerContextPolicy version=1.0.0 description="Policy that adds Customer information to engine context" template=FREEFORM firstState=CustomerContextState
                        policy state create name=CustomerContextPolicy version=1.0.0 stateName=CustomerContextState triggerName=CustomerContextEventIn triggerVersion=1.0.0 defaultTaskName=CustomerContextTask defaultTaskVersion=1.0.0
                        policy state output create name=CustomerContextPolicy version=1.0.0 stateName=CustomerContextState outputName=CustomerContextState_Output_Direct eventName=ReportOut eventVersion=1.0.0 nextState=NULL
                        policy state taskref create name=CustomerContextPolicy version=1.0.0 stateName=CustomerContextState taskLocalName=doContext taskName=CustomerContextTask taskVersion=1.0.0 outputType=DIRECT outputName=CustomerContextState_Output_Direct




                        schema create name=edgeNameDecl version=1.0.0 description="Edge name" flavour=Java schema=java.lang.String
                        schema create name=edgeStatusDecl version=1.0.0 description="Statuf of the edge (UP, DOWN)" flavour=Avro schema=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/link-status.avsc"
                        LE
                        schema create name=edgeChangedDecl version=1.0.0 description="Status Change (true:change, false:no change)" flavour=Java schema=java.lang.Boolean

                        task create name=VpnSlaPolicyMatchTask version=1.0.0 description="Pre-process an edge event"
                        task inputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=hasChanged schemaName=edgeChangedDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task contextref create name=VpnSlaPolicyMatchTask albumName=albumTopoEdges
                        task logic create name=VpnSlaPolicyMatchTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-match.js"
                        LE




                        schema create name=problemMapDecl version=1.0.0 description="Map of problems with all known Information" flavour=Avro schema=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/problems.avsc"
                        LE
                        album create name=albumProblemMap scope=global writable=true schemaName=problemMapDecl

                        schema create name=establishSituationDecl version=1.0.0 description="Establish: the situation that was established" flavour=Avro schema=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/situation.avsc"
                        LE

                        task create name=VpnSlaPolicyEstablishTask version=1.0.0 description="Task taking a match event and establishing a situation"
                        task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=hasChanged schemaName=edgeChangedDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task contextref create name=VpnSlaPolicyEstablishTask albumName=albumProblemMap
                        task contextref create name=VpnSlaPolicyEstablishTask albumName=albumCustomerMap
                        task logic create name=VpnSlaPolicyEstablishTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-establish.js"
                        LE




                        schema create name=decideDecisionDecl version=1.0.0 description="Decide: the taken decision" flavour=Avro schema=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/decision.avsc"
                        LE

                        task create name=VpnSlaPolicyDecideNoneTask version=1.0.0 description="Decide task for a 'none' problem"
                        task inputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task logic create name=VpnSlaPolicyDecideNoneTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-none.js"
                        LE


                        task create name=VpnSlaPolicyDecideSlaTask version=1.0.0 description="Decide task solving the problem by balancing SLAs"
                        task inputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task contextref create name=VpnSlaPolicyDecideSlaTask albumName=albumCustomerMap
                        task contextref create name=VpnSlaPolicyDecideSlaTask albumName=albumProblemMap
                        task logic create name=VpnSlaPolicyDecideSlaTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-sla.js"
                        LE


                        task create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 description="Decide task solving the problem by using customer priorities"
                        task inputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task contextref create name=VpnSlaPolicyDecidePriorityTask albumName=albumCustomerMap
                        task contextref create name=VpnSlaPolicyDecidePriorityTask albumName=albumProblemMap
                        task logic create name=VpnSlaPolicyDecidePriorityTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-priority.js"
                        LE


                        task create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 description="Decide task solving the problem by using customer priorities"
                        task inputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task contextref create name=VpnSlaPolicyDecideSolvedTask albumName=albumProblemMap
                        task logic create name=VpnSlaPolicyDecideSolvedTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-solved.js"
                        LE




                        schema create name=actionDecl version=1.0.0 description="An action for the actioning system" flavour=Java schema=java.lang.String

                        task create name=VpnSlaPolicyActTask version=1.0.0 description="Task issueing an action for taken decision"
                        task inputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
                        task inputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
                        task outputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=action schemaName=actionDecl schemaVersion=1.0.0
                        task contextref create name=VpnSlaPolicyActTask albumName=albumCustomerMap
                        task contextref create name=VpnSlaPolicyActTask albumName=albumProblemMap
                        task logic create name=VpnSlaPolicyActTask logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-act.js"
                        LE







                        event create name=VpnSlaTrigger version=1.0.0 description="Event triggering the VPN SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="TriggerSys" target="VpnSlaMatch"
                        event parameter create name=VpnSlaTrigger version=1.0.0 parName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
                        event parameter create name=VpnSlaTrigger version=1.0.0 parName=status schemaName=edgeStatusDecl schemaVersion=1.0.0

                        event create name=VpnSlaMatchOut version=1.0.0 description="Event with matched trigger for the VPN SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="VpnSlaMatch" target="VpnSlaEstablish"
                        event parameter create name=VpnSlaMatchOut version=1.0.0 parName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
                        event parameter create name=VpnSlaMatchOut version=1.0.0 parName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
                        event parameter create name=VpnSlaMatchOut version=1.0.0 parName=hasChanged schemaName=edgeChangedDecl schemaVersion=1.0.0
                        event parameter create name=VpnSlaMatchOut version=1.0.0 parName=matchStart schemaName=timestampDecl schemaVersion=1.0.0

                        event create name=VpnSlaEstablishOut version=1.0.0 description="Event with situation for the SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="SlaEstablish" target="SlaDecide"
                        event parameter create name=VpnSlaEstablishOut version=1.0.0 parName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
                        event parameter create name=VpnSlaEstablishOut version=1.0.0 parName=matchStart schemaName=timestampDecl schemaVersion=1.0.0

                        event create name=VpnSlaDecideOut version=1.0.0 description="Event with a decision for the SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="SlaDecide" target="SlaAct"
                        event parameter create name=VpnSlaDecideOut version=1.0.0 parName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
                        event parameter create name=VpnSlaDecideOut version=1.0.0 parName=matchStart schemaName=timestampDecl schemaVersion=1.0.0

                        event create name=VpnSlaActOut version=1.0.0 description="Event action" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="SlaAct" target="ActioningSystem"
                        event parameter create name=VpnSlaActOut version=1.0.0 parName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
                        event parameter create name=VpnSlaActOut version=1.0.0 parName=action schemaName=actionDecl schemaVersion=1.0.0


                        policy create name=VpnSlaPolicy version=1.0.0 description="Policy deciding customer treatment based on SLAs as MEDA policy" template=FREEFORM firstState=VpnSlaPolicyMatchState

                        policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyActState triggerName=VpnSlaDecideOut triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyActTask defaultTaskVersion=1.0.0
                        policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyActState outputName=SlaPolicyAct_Output_Direct eventName=VpnSlaActOut eventVersion=1.0.0 nextState=NULL
                        policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyActState taskLocalName=act taskName=VpnSlaPolicyActTask taskVersion=1.0.0 outputType=DIRECT outputName=SlaPolicyAct_Output_Direct

                        policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState triggerName=VpnSlaEstablishOut triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyDecideSlaTask defaultTaskVersion=1.0.0
                        policy state contextref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState albumName=albumProblemMap
                        policy state selecttasklogic create name=VpnSlaPolicy stateName=VpnSlaPolicyDecideState logicFlavour=JAVASCRIPT logic=LS
                        #MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/tsl-decide.js"
                        LE
                        policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState outputName=VpnSlaPolicyDecide_Output_Direct eventName=VpnSlaDecideOut eventVersion=1.0.0 nextState=VpnSlaPolicyActState
                        policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decideNone taskName=VpnSlaPolicyDecideNoneTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct
                        policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decideNone taskName=VpnSlaPolicyDecideSolvedTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct
                        policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decideSla taskName=VpnSlaPolicyDecideSlaTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct
                        policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decidePriority taskName=VpnSlaPolicyDecidePriorityTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct

                        policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpmSlaPolicyEstablishState triggerName=VpnSlaMatchOut triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyEstablishTask defaultTaskVersion=1.0.0
                        policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpmSlaPolicyEstablishState outputName=VpnSlaPolicyEstablish_Output_Direct eventName=VpnSlaEstablishOut eventVersion=1.0.0 nextState=VpnSlaPolicyDecideState
                        policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpmSlaPolicyEstablishState taskLocalName=establish taskName=VpnSlaPolicyEstablishTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyEstablish_Output_Direct

                        policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyMatchState triggerName=VpnSlaTrigger triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyMatchTask defaultTaskVersion=1.0.0
                        policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyMatchState outputName=VpnSlaPolicyMatch_Output_Direct eventName=VpnSlaMatchOut eventVersion=1.0.0 nextState=VpmSlaPolicyEstablishState
                        policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyMatchState taskLocalName=match taskName=VpnSlaPolicyMatchTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyMatch_Output_Direct



                        validate
                        quit

Context Events Nodes
--------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The following events create all nodes of the topology.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "A1",
                            "mininetName": "nn"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "A2",
                            "mininetName": "nn"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "B1",
                            "mininetName": "nn"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "B2",
                            "mininetName": "nn"
                        }


                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "A1CO",
                            "mininetName": "s1"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "A2CO",
                            "mininetName": "s2"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "B1CO",
                            "mininetName": "s3"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "B2CO",
                            "mininetName": "s4"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "BBL",
                            "mininetName": "s5"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "NodeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_NodeContext",
                            "nodeName": "BBR",
                            "mininetName": "s6"
                        }

Context Events Edges
--------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The following events create all edges of the topology.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L01",
                            "start": "A1",
                            "end": "A1CO",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L02",
                            "start": "B1",
                            "end": "B1CO",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L03",
                            "start": "A2",
                            "end": "A2CO",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L04",
                            "start": "B2",
                            "end": "B2CO",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L05",
                            "start": "A1CO",
                            "end": "BBL",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L06",
                            "start": "B1CO",
                            "end": "BBL",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L07",
                            "start": "A2CO",
                            "end": "BBR",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L08",
                            "start": "B2CO",
                            "end": "BBR",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L09",
                            "start": "BBL",
                            "end": "BBR",
                            "status": true
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "EdgeContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_EdgeContext",
                            "edgeName": "L10",
                            "start": "BBR",
                            "end": "BBL",
                            "status": true
                        }

Context Events Customers
------------------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The following events create all customers of the
                  topology.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "CustomerContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_CustomerContext",
                            "customerName": "A",
                            "links": "L01 L05 L09 L10",
                            "dtSLA": 180,
                            "dtYTD": 10,
                            "priority": false,
                            "satisfaction": 80
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "CustomerContextEventIn",
                            "version": "1.0.0",
                            "source": "CtxtManagement",
                            "target" : "VpnSlaPolicy_CustomerContext",
                            "customerName": "B",
                            "links": "L02 L07 L09 L10",
                            "dtSLA": 180,
                            "dtYTD": 120,
                            "priority": true,
                            "satisfaction": 99
                        }

Trigger Examples
----------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The following events are examples for trigger events

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "VpnSlaTrigger",
                            "version": "1.0.0",
                            "source": "ExampleEvents",
                            "target" : "VpnSlaPolicy",
                            "edgeName": "L09",
                            "status": "UP"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "VpnSlaTrigger",
                            "version": "1.0.0",
                            "source": "ExampleEvents",
                            "target" : "VpnSlaPolicy",
                            "edgeName": "L09",
                            "status": "UP"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "VpnSlaTrigger",
                            "version": "1.0.0",
                            "source": "ExampleEvents",
                            "target" : "VpnSlaPolicy",
                            "edgeName": "L09",
                            "status": "DOWN"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "VpnSlaTrigger",
                            "version": "1.0.0",
                            "source": "ExampleEvents",
                            "target" : "VpnSlaPolicy",
                            "edgeName": "L09",
                            "status": "DOWN"
                        }

                        {
                            "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
                            "name": "VpnSlaTrigger",
                            "version": "1.0.0",
                            "source": "ExampleEvents",
                            "target" : "VpnSlaPolicy",
                            "edgeName": "L09",
                            "status": "UP"
                        }

Link Monitor
------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The Link Monitor is a Python script. At startup, it
                  sends the context events to APEX to initialize the
                  topology and the customers. Then it takes events from
                  Kafka and sends them to APEX.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        # ============LICENSE_START=======================================================
                        #  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                        # ================================================================================
                        # 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.
                        #
                        # SPDX-License-Identifier: Apache-2.0
                        # ============LICENSE_END=========================================================

                        import http.client
                        import json
                        import time
                        from kafka import KafkaConsumer, KafkaProducer

                        class StaticFlowPusher(object):

                            def __init__(self, server):
                                self.server = server

                            def get(self, data):
                                ret = self.rest_call({}, 'GET')
                                return json.loads(ret[2])

                            def set(self, data):
                                ret = self.rest_call(data, 'POST')
                                return ret[0] == 200

                            def remove(self, objtype, data):
                                ret = self.rest_call(data, 'DELETE')
                                return ret[0] == 200

                            def getControllerSummary(self, data):
                                ret = self.rest_call_controller_summary({}, 'GET')
                                return json.loads(ret[2])

                            def getLinks(self, data):
                                ret = self.rest_call_links({}, 'GET')
                                return json.loads(ret[2].decode())

                            def rest_call(self, data, action):
                                path = '/wm/staticflowpusher/json'
                                headers = {
                                    'Content-type': 'application/json',
                                    'Accept': 'application/json',
                                    }
                                body = json.dumps(data)
                                conn = http.client.HTTPConnection(self.server, 8080)
                                conn.request(action, path, body, headers)
                                response = conn.getresponse()
                                ret = (response.status, response.reason, response.read())
                                print(ret)
                                conn.close()
                                return ret

                            def rest_call_controller_summary(self, data, action):
                                path = '/wm/core/controller/summary/json'
                                headers = {
                                    'Content-type': 'application/json',
                                    'Accept': 'application/json',
                                    }
                                body = json.dumps(data)
                                conn = http.client.HTTPConnection(self.server, 8080)
                                conn.request(action, path, body, headers)
                                response = conn.getresponse()
                                ret = (response.status, response.reason, response.read())
                                print(ret)
                                conn.close()
                                return ret

                            def rest_call_links(self, data, action):
                                path = '/wm/topology/links/json'
                                headers = {
                                    'Content-type': 'application/json',
                                    'Accept': 'application/json',
                                    }
                                body = json.dumps(data)
                                conn = http.client.HTTPConnection(self.server, 8080)
                                conn.request(action, path, body, headers)
                                response = conn.getresponse()
                                ret = (response.status, response.reason, response.read())
                                conn.close()
                                return ret

                        pusher = StaticFlowPusher('127.0.1.1')


                        def parseLinks(links):
                                #print("\n\n\n",links)
                                result = []
                                for link in links:
                                        list = []
                                        #print("\n\n\n",link)
                                        #print("\nsrc-switch : s", link['src-switch'][len(link['src-switch'])-1])
                                        #print("\ndst-switch : s", link['dst-switch'][len(link['dst-switch'])-1])
                                        list.append("s")
                                        list.append(link['src-switch'][len(link['src-switch'])-1])
                                        list.append("-s")
                                        list.append(link['dst-switch'][len(link['dst-switch'])-1])
                                        result.append(''.join(list))
                                #print(result, "\n")
                                return result



                        counter =0
                        healthyList = []
                        testableList = []
                        healthyLinks = ""
                        testableLinks = ""
                        producer = KafkaProducer(bootstrap_servers='localhost:9092')
                        while(True):
                                time.sleep(30)
                                switchLinks = pusher.getLinks({})
                                if counter == 0:
                                        healthyList = parseLinks(switchLinks)
                                        #Build All Links
                                        print("READING LINKS FROM MININET\n")
                                        for l in healthyList:
                                                link = ""
                                                #print(l, "\n")
                                                #Links between switches [s6-s7 is ignored so it matches VPN SCENARIO]
                                                if(l == "s1-s5"):
                                                        link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L05', 'start': 'A1CO','end': 'BBL'}"
                                                        producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                if(l == "s5-s6"):
                                                        link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L09', 'start': 'BBL','end': 'BBR'}"
                                                        producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                if(l == "s2-s6"):
                                                        link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L07', 'start': 'A2CO','end': 'BBR'}"
                                                        producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                if(l == "s5-s7"):
                                                        link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L10', 'start': 'BBR','end': 'BBL'}"
                                                        producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                if(l == "s3-s5"):
                                                        link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L06', 'start': 'B1CO','end': 'BBL'}"
                                                        producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                if(l == "s4-s6"):
                                                        link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L08', 'start': 'B2CO','end': 'BBR'}"
                                                        producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                        #Links between switches and hosts [NoT SENT IN FROM FLOODLIGHT]
                                        producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L01', 'start': 'A1','end': 'A1CO'}")
                                        producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L02', 'start': 'B1','end': 'B1CO'}")
                                        producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L03', 'start': 'A2','end': 'A2CO'}")
                                        producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L04', 'start': 'B2','end': 'B2CO'}")
                                        print("LINKS HAVE BEEN SENT TO APEX\n")

                                        #Build Customers
                                        print("BUILDING CUSTOMERS\n")
                                        producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'CustomerContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_CustomerContext','dtYTD': 10,'dtSLA': 180,'links': 'L01 L05 L09 L10','customerName': 'A', 'priority': true,'satisfaction': 80}")
                                        producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'CustomerContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_CustomerContext','dtYTD': 120,'dtSLA': 180,'links': 'L02 L07 L09 L10','customerName': 'B', 'priority': false,'satisfaction': 99}")
                                        print("CUSTOMERS HAVE BEEN SENT TO APEX\n")
                                        healthyLinks = switchLinks
                                        myfile = open('LinkInfo.json', 'a')
                                        myfile.write(str(healthyLinks))
                                        myfile.write('\n')
                                        myfile.close()
                                        print("We start off with", len(healthyLinks), "healthy Links!\n")
                                else:
                                        testableList = parseLinks(switchLinks)
                                        issueLink = "";
                                        for h in healthyList:
                                                issueLink = h
                                                for t in testableList:
                                                        if t == h:
                                                                issueLink = ""
                                                if issueLink != "":
                                                        print("There is an issue with the links! ", issueLink, " \n")
                                                        if(issueLink == "s1-s5"):
                                                                link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L05'}"
                                                                producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                        if(issueLink == "s5-s6"):
                                                                link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L09'}"
                                                                producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                        if(issueLink == "s2-s6"):
                                                                link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L07'}"
                                                                producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                        if(issueLink == "s5-s7"):
                                                                link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L10'}"
                                                                producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                        if(issueLink == "s3-s5"):
                                                                link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L06'}"
                                                                producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                        if(issueLink == "s4-s6"):
                                                                link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L08'}"
                                                                producer.send("apex-in-0", bytes(link, encoding="ascii"))
                                                        break
                                        if issueLink == "":
                                                print("All Links are working\n")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L01'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L02'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L03'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L04'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L05'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L06'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L07'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L08'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L09'}")
                                                producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L10'}")

                                        testableLinks = switchLinks
                                        myfile = open('LinkInfo.json', 'a')
                                        myfile.write(str(testableLinks))
                                        myfile.write('\n')
                                        myfile.close()
                                counter += 1

Mininet Topology
----------------

         .. container:: sect1

            .. container:: sectionbody

               .. container:: paragraph

                  The topology is realized using Mininet. The following
                  script is use to estalish the topology and to realize
                  network configurations.

               .. container:: listingblock

                  .. container:: content

                     .. code:: CodeRay

                        # ============LICENSE_START=======================================================
                        #  Copyright (C) 2016-2018 Ericsson. All rights reserved.
                        # ================================================================================
                        # 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.
                        #
                        # SPDX-License-Identifier: Apache-2.0
                        # ============LICENSE_END=========================================================

                        #Add Mininet to PATH
                        import sys
                        sys.path.insert(0, "/~/mininet")

                        #Kafka
                        import httplib
                        import json
                        import time
                        from kafka import KafkaConsumer, KafkaProducer

                        #Mininet
                        from mininet.clean import *
                        from mininet.cli import *
                        from mininet.link import *
                        from mininet.log import *
                        from mininet.net import *
                        from mininet.node import *
                        from mininet.nodelib import *
                        from mininet.topo import *
                        from mininet.topolib import *

                        class StaticFlowPusher(object):
                            def __init__(self, server):
                                self.server = server

                            def enableFirewall(self, data):
                                path = "/wm/firewall/module/enable/json"
                                headers = {'Content-Type': 'application/json','Accept': 'application/json',}
                                body = json.dumps(data)
                                conn = httplib.HTTPConnection(self.server, 8080)
                                conn.request("PUT", path, "")
                                response = conn.getresponse()
                                ret = (response.status, response.reason, response.read())
                                conn.close()
                                return ret

                            def addRule(self, data):
                                path = '/wm/firewall/rules/json'
                                headers = {'Content-Type': 'application/json','Accept': 'application/json',}
                                body = json.dumps(data)
                                conn = httplib.HTTPConnection(self.server, 8080)
                                conn.request('POST', path, body, headers)
                                response = conn.getresponse()
                                ret = (response.status, response.reason, response.read())
                                conn.close()
                                return ret

                            def deleteRule(self, data):
                                path = '/wm/firewall/rules/json'
                                headers = {'Content-Type': 'application/json','Accept': 'application/json',}
                                body = json.dumps(data)
                                conn = httplib.HTTPConnection(self.server, 8080)
                                conn.request('DELETE', path, body, headers)
                                response = conn.getresponse()
                                ret = (response.status, response.reason, response.read())
                                conn.close()
                                return ret

                        #Build Pusher(REST/IN)
                        pusher = StaticFlowPusher('127.0.0.1')

                        net = Mininet(link=TCLink)

                        #Create Customers
                        customerA1 = net.addHost( 'A1' )
                        customerA2 = net.addHost( 'A2' )
                        customerB1 = net.addHost( 'B1' )
                        customerB2 = net.addHost( 'B2' )

                        #Create Switches
                        switchA1CO = net.addSwitch( 's1' )
                        switchA2CO = net.addSwitch( 's2' )
                        switchB1CO = net.addSwitch( 's3' )
                        switchB2CO = net.addSwitch( 's4' )
                        switchBBL = net.addSwitch( 's5' )
                        switchBBR = net.addSwitch( 's6' )
                        # we need an extra switch here because Mininet does not allow two links between two switches
                        switchEx = net.addSwitch( 's7' )

                        #Create Links
                        net.addLink( customerA1, switchA1CO )
                        net.addLink( customerA2, switchA2CO )
                        net.addLink( customerB1, switchB1CO )
                        net.addLink( customerB2, switchB2CO )
                        net.addLink( switchA1CO, switchBBL )
                        net.addLink( switchB1CO, switchBBL )
                        net.addLink( switchA2CO, switchBBR )
                        net.addLink( switchB2CO, switchBBR )
                        net.addLink( switchBBL, switchBBR)
                        net.addLink( switchBBR, switchEx, bw=1.2 )
                        net.addLink( switchEx, switchBBL )

                        #Create Controller
                        floodlightController = net.addController(name='c0' , controller=RemoteController , ip='127.0.0.1', port=6653)

                        net.start()

                        if pusher.enableFirewall({})[0] == 200:
                            print("Firewall enabled!")

                        #print(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01"})[2])
                        s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01"})[2])['rule-id']
                        s2id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:02"})[2])['rule-id']
                        s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03"})[2])['rule-id']
                        s4id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:04"})[2])['rule-id']
                        s5id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:05"})[2])['rule-id']
                        s6id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:06"})[2])['rule-id']
                        s7id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:07"})[2])['rule-id']


                        result = 100
                        while result!=0:
                            result = net.pingAll(None)
                        print("Network Simulation Complete")

                        #Assume control and when finished "exit"
                        cli = CLI( net )

                        consumer = KafkaConsumer(bootstrap_servers='localhost:9092',auto_offset_reset='latest')
                        consumer.subscribe(['apex-out'])
                        print("Starting Message Loop")
                        for message in consumer:
                            myOutput = json.loads(message.value.decode())
                            action = ""
                            try:
                                print("Checking Message")
                                #print("SWITCHES= ",net.switches)
                                #print("LINKS= ",net.links)
                                #print("VALUES= ",net.values)
                                if myOutput['edgeName'] != '':
                                    print("Message Received: ",myOutput['edgeName'])
                                    pusher.deleteRule({"ruleid": s1id})
                                    pusher.deleteRule({"ruleid": s2id})
                                    pusher.deleteRule({"ruleid": s3id})
                                    pusher.deleteRule({"ruleid": s4id})
                                    pusher.deleteRule({"ruleid": s5id})
                                    pusher.deleteRule({"ruleid": s6id})
                                    pusher.deleteRule({"ruleid": s7id})
                                    s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01"})[2])['rule-id']
                                    s2id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:02"})[2])['rule-id']
                                    s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03"})[2])['rule-id']
                                    s4id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:04"})[2])['rule-id']
                                    s5id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:05"})[2])['rule-id']
                                    s6id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:06"})[2])['rule-id']
                                    s7id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:07"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L01":
                                        action = "link s1 s5 down"
                                        #net.configLinkStatus('s1', 's5', "down")
                                        pusher.deleteRule({"ruleid": s1id})
                                        s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L02":
                                        action = "link s3 s5 down"
                                        #net.configLinkStatus('s3', 's5', "down")
                                        pusher.deleteRule({"ruleid": s3id})
                                        s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L03":
                                        action = "link s2 s6 down"
                                        #net.configLinkStatus('s2', 's6', "down")
                                        pusher.deleteRule({"ruleid": s1id})
                                        s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L04":
                                        action = "link s4 s6 down"
                                        #net.configLinkStatus('s4', 's6', "down")
                                        pusher.deleteRule({"ruleid": s3id})
                                        s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L05":
                                        action = "link s1 s5 down"
                                        #net.configLinkStatus('s1', 's5', "down")
                                        pusher.deleteRule({"ruleid": s1id})
                                        s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L06":
                                        action = "link s3 s5 down"
                                        #net.configLinkStatus('s3', 's5', "down")
                                        pusher.deleteRule({"ruleid": s3id})
                                        s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L07":
                                        action = "link s2 s6 down"
                                        #net.configLinkStatus('s2', 's6', "down")
                                        pusher.deleteRule({"ruleid": s2id})
                                        s2id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:02", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L08":
                                        action = "link s4 s6 down"
                                        #net.configLinkStatus('s4', 's6', "down")
                                        pusher.deleteRule({"ruleid": s4id})
                                        s4id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:04", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L09":
                                        action = "link s5 s6 down"
                                        #net.configLinkStatus('s5', 's6', "down")
                                        pusher.deleteRule({"ruleid": s7id})
                                        s7id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:07", "action": "DENY"})[2])['rule-id']
                                    if myOutput['edgeName'] == "L10":
                                        print("L10")
                                    #print(action)
                                #print("3")
                            except KeyError:
                                print(myOutput)
                        print("HA")
                        net.stop()

   .. container::
      :name: footer-text

      2.3.0-SNAPSHOT
      Last updated 2020-04-03 16:04:24 IST


.. |ONAP| image:: ../../../images/logos.png
   :class: builtBy
   :target: http://www.onap.org/

.. |VPN SLA Architecture| image:: images/pcvs/vpnsla-arch.png