gerrit.onap Code Review - policy/apex-pdp.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
   4  *  Modifications Copyright (C) 2020 Nordix Foundation.
   5  * ================================================================================
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  * SPDX-License-Identifier: Apache-2.0
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 var now = new Date().getTime();
  23 executor.outFields["matchStart"] = now;
  24
  25 importClass(org.slf4j.LoggerFactory);
  26
  27 var logger = executor.logger;
  28 logger.trace("start: " + executor.subject.id);
  29 logger.trace("-- infields: " + executor.inFields);
  30
  31 var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
  32
  33 var ifEdgeName = executor.inFields["edgeName"];
  34 var ifLinkStatus = executor.inFields["status"];
  35
  36 var albumTopoEdges = executor.getContextAlbum("albumTopoEdges");
  37
  38 logger.trace("-- got infields, checking albumTopoEdges changes");
  39
  40 var active = false;
  41 switch (ifLinkStatus.toString()) {
  42 case "UP":
  43     active = true;
  44     break;
  45 case "DOWN":
  46     active = false;
  47     break;
  48 default:
  49     active = false;
  50     logger.error("-- trigger sent unknown link status <" + ifLinkStatus + "> for link <" + ifEdgeName + ">");
  51     rootLogger.error(executor.subject.id + " " + "-- trigger sent unknown link status <" + ifLinkStatus
  52             + "> for link <" + ifEdgeName + ">");
  53 }
  54
  55 var link = albumTopoEdges.get(ifEdgeName);
  56 if (link == null) {
  57     logger.trace("-- link <" + ifEdgeName + "> not in albumTopoEdges");
  58 } else {
  59     logger.trace("-- found link <" + link + "> in albumTopoEdges");
  60     logger.trace("-- active <" + active + "> : link.active <" + link.get("active") + ">");
  61     if (active != link.get("active")) {
  62         link.put("active", active);
  63         logger.trace("-- link <" + ifEdgeName + "> status changed to <active:" + link.get("active") + ">");
  64         executor.outFields["hasChanged"] = true;
  65     } else {
  66         logger.trace("-- link <" + ifEdgeName + "> status not changed <active:" + link.get("active") + ">");
  67         executor.outFields["hasChanged"] = false;
  68     }
  69 }
  70
  71 executor.outFields["edgeName"] = ifEdgeName;
  72 executor.outFields["status"] = ifLinkStatus;
  73
  74 logger.info("vpnsla: detected " + ifEdgeName + " as " + ifLinkStatus);
  75
  76 logger.trace("finished: " + executor.subject.id);
  77 logger.debug(".m");
  78
  79 true;