rules/ccvnp-rule.drl

   1 package org.onap.holmes.ccvpn;
   2
   3 dialect "java"
   4
   5 import org.onap.holmes.common.api.stat.VesAlarm;
   6 import org.onap.holmes.common.api.stat.AlarmAdditionalField;
   7 import org.onap.holmes.common.aai.AaiQuery4Ccvpn;
   8 import org.onap.holmes.common.exception.CorrelationException;
   9 import org.onap.holmes.common.dmaap.entity.PolicyMsg;
  10 import org.onap.holmes.common.dmaap.DmaapService;
  11 import org.onap.holmes.common.utils.DroolsLog;
  12 import org.onap.holmes.common.dropwizard.ioc.utils.ServiceLocatorHolder;
  13
  14 import com.alibaba.fastjson.JSONArray;
  15 import com.alibaba.fastjson.JSONObject;
  16
  17 import java.util.List;
  18 import java.util.Map;
  19 import java.util.ArrayList;
  20 import java.util.HashMap;
  21 import java.util.UUID;
  22
  23 function String getAdditionalField(VesAlarm a, String field) {
  24         List<AlarmAdditionalField> fields = a.getAlarmAdditionalInformation();
  25         for (AlarmAdditionalField f : fields) {
  26                 if (f.getName().equals(field)) {
  27                         return f.getValue();
  28                 }
  29         }
  30         return null;
  31 }
  32
  33 function String getLogicLink(VesAlarm alarm) {
  34         AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
  35         return aai.getLogicLink(
  36                 getAdditionalField(alarm, "networkId"),
  37                 getAdditionalField(alarm, "node"),
  38                 getAdditionalField(alarm, "tp-id"),
  39                 getAdditionalField(alarm, "oper-status")
  40         );
  41 }
  42
  43 function boolean isCorrelated(VesAlarm a, VesAlarm b) {
  44         String logicLinkA = getLogicLink(a);
  45         if (logicLinkA == null) {
  46                 return false;
  47         }
  48
  49         String logicLinkB = getLogicLink(b);
  50         if (logicLinkB == null) {
  51                 return false;
  52         }
  53
  54         return logicLinkA.equals(logicLinkB);
  55 }
  56
  57 function void updateAaiLinkStatus(String linkName, String status) {
  58         AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
  59         Map<String, Object> body = new HashMap<String, Object>(){
  60                 {
  61                         put("operational-status", status);
  62                 }
  63         };
  64         aai.updateLogicLinkStatus(linkName, body);
  65 }
  66
  67 function void updateAaiTpStatus(String networkId, String pnfName, String ifName, String status) {
  68         AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
  69         Map<String, Object> body = new HashMap<String, Object>(){
  70                 {
  71                         put("operational-status", status);
  72                 }
  73         };
  74         aai.updateTerminalPointStatus(networkId, pnfName, ifName, body);
  75 }
  76
  77 function Map<String, Object> getAdditionalResourceInfo(String networkId, String pnfName, String ifName, String status) {
  78         AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
  79         JSONArray instances = aai.getServiceInstances(networkId, pnfName, ifName, status);
  80
  81         Map<String, Object> ret = new HashMap<String, Object>();
  82
  83         StringBuilder sbn = new StringBuilder();
  84         StringBuilder sbi = new StringBuilder();
  85         for(int i = 0; i < instances.size(); ++i) {
  86                 JSONObject o = instances.getJSONObject(i);
  87                 String name = o.getString("service-instance-name");
  88                 String id = o.getString("service-instance-id");
  89                 ret.put(id + ".input-parameters", o.getString("input-parameters"));
  90                 sbn.append(name).append(",");
  91                 sbi.append(id).append(",");
  92         }
  93         ret.put("service-instance.service-instance-name", sbn.substring(0, sbn.length() -1).toString());
  94         ret.put("service-instance.service-instance-id", sbi.substring(0, sbi.length() -1).toString());
  95         ret.put("vserver.vserver-name", "TBD");
  96         ret.put("globalSubscriberId", instances.getJSONObject(0).getString("globalSubscriberId"));
  97         ret.put("serviceType", instances.getJSONObject(0).getString("serviceType"));
  98
  99         return ret;
 100 }
 101
 102 function PolicyMsg createPolicyMsg(VesAlarm alarm) {
 103         PolicyMsg m = new PolicyMsg();
 104         m.setPolicyVersion("1.0.0.5");
 105         m.setPolicyName("CCVPN");
 106         m.setPolicyScope("service=SOTNService,type=SampleType,closedLoopControlName=CL-CCVPN-d925ed73-8231-4d02-9545-db4e101f88f8");
 107         m.setClosedLoopControlName(DmaapService.loopControlNames.get("org.onap.holmes.ccvpn"));
 108         m.setRequestID(UUID.randomUUID().toString());
 109         m.setClosedLoopAlarmStart(alarm.getStartEpochMicrosec());
 110         m.setClosedLoopAlarmEnd(alarm.getLastEpochMicrosec());
 111         m.setTarget("vserver.vserver-name");
 112         m.setAai(getAdditionalResourceInfo(
 113                 getAdditionalField(alarm, "networkId"),
 114                 getAdditionalField(alarm, "node"),
 115                 getAdditionalField(alarm, "tp-id"),
 116                 getAdditionalField(alarm, "oper-status")
 117         ));
 118
 119         DmaapService.alarmUniqueRequestID.put(alarm.getEventId(), m.getRequestID());
 120
 121         return m;
 122 }
 123
 124 rule "Update AAI Information"
 125         no-loop true
 126         salience 300
 127         when
 128                 $a: VesAlarm(eventName.indexOf("Fault_Route_Status") != -1)
 129         then
 130                 updateAaiTpStatus (
 131                         getAdditionalField($a, "networkId"),
 132                         getAdditionalField($a, "node"),
 133                         getAdditionalField($a, "tp-id"),
 134                         getAdditionalField($a, "oper-status")
 135                 );
 136 end
 137
 138 rule "Set Up Correlation"
 139         no-loop true
 140         salience 200
 141         when
 142                 $a: VesAlarm($id: eventId,
 143                                                 $start: startEpochMicrosec,
 144                                                 eventName.indexOf("Fault_Route_Status") != -1)
 145                 $b: VesAlarm(eventId != $id,
 146                                                 eventName.indexOf("Fault_Route_Status") != -1,
 147                                                 Math.abs(startEpochMicrosec - $start) < 60000)
 148         then
 149                 String status = "down";
 150                 if (status.equalsIgnoreCase(getAdditionalField($a, "oper-status"))
 151                                 && status.equalsIgnoreCase(getAdditionalField($b, "oper-status"))) {
 152                     if (isCorrelated($a, $b)){
 153                         // If any of the alarms have been marked as root, a policy message has ever been created and sent. Do NOT send it again.
 154                         if ($a.getRootFlag() != 1 && $b.getRootFlag() != 1) {
 155                                 PolicyMsg msg = createPolicyMsg($a);
 156                                 DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);
 157                                 dmaapService.publishPolicyMsg(msg, "unauthenticated.DCAE_CL_OUTPUT");
 158                                 updateAaiLinkStatus(getLogicLink($a), status);
 159                         }
 160                         $a.setRootFlag(1);
 161                         $b.setRootFlag(1);
 162                         update($a);
 163                         update($b);
 164                     }
 165             }
 166 end
 167
 168 rule "Clear Alarms"
 169         no-loop true
 170         salience 100
 171         when
 172                 $a: VesAlarm(eventName.indexOf("Fault_Route_Status") != -1)
 173         then
 174                 if ("up".equalsIgnoreCase(getAdditionalField($a, "oper-status"))) {
 175                         if (DmaapService.alarmUniqueRequestID.containsKey($a.getEventId())) {
 176                                 DmaapService.alarmUniqueRequestID.remove($a.getEventId());
 177                         }
 178
 179                         //TODO: send alarm clearing message to Policy - for now it's not needed.
 180                 //...
 181
 182                         retract($a);
 183                 }
 184 end