+++ /dev/null
-package org.onap.holmes.ccvpn;
-
-dialect "java"
-
-import org.onap.holmes.common.api.stat.VesAlarm;
-import org.onap.holmes.common.api.stat.AlarmAdditionalField;
-import org.onap.holmes.common.aai.AaiQuery4Ccvpn;
-import org.onap.holmes.common.exception.CorrelationException;
-import org.onap.holmes.common.dmaap.entity.PolicyMsg;
-import org.onap.holmes.common.dmaap.DmaapService;
-import org.onap.holmes.common.utils.DroolsLog;
-import org.onap.holmes.common.dropwizard.ioc.utils.ServiceLocatorHolder;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-
-import java.util.List;
-import java.util.Map;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.UUID;
-
-function String getAdditionalField(VesAlarm a, String field) {
- List<AlarmAdditionalField> fields = a.getAlarmAdditionalInformation();
- for (AlarmAdditionalField f : fields) {
- if (f.getName().equals(field)) {
- return f.getValue();
- }
- }
- return null;
-}
-
-function String getLogicLink(VesAlarm alarm) {
- AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
- return aai.getLogicLink(
- getAdditionalField(alarm, "networkId"),
- getAdditionalField(alarm, "node"),
- getAdditionalField(alarm, "tp-id"),
- null
- );
-}
-
-function boolean isCorrelated(VesAlarm a, VesAlarm b) {
- String logicLinkA = getLogicLink(a);
- if (logicLinkA == null) {
- return false;
- }
-
- String logicLinkB = getLogicLink(b);
- if (logicLinkB == null) {
- return false;
- }
-
- return logicLinkA.equals(logicLinkB);
-}
-
-function void updateAaiLinkStatus(String linkName, String status) {
- AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
- Map<String, Object> body = new HashMap<String, Object>(){
- {
- put("operational-status", status);
- }
- };
- aai.updateLogicLinkStatus(linkName, body);
-}
-
-function void updateAaiTpStatus(String networkId, String pnfName, String ifName, String status) {
- AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
- Map<String, Object> body = new HashMap<String, Object>(){
- {
- put("operational-status", status);
- }
- };
- aai.updateTerminalPointStatus(networkId, pnfName, ifName, body);
-}
-
-function Map<String, Object> getAdditionalResourceInfo(String networkId, String pnfName, String ifName, String status) {
- AaiQuery4Ccvpn aai = AaiQuery4Ccvpn.newInstance();
- JSONArray instances = aai.getServiceInstances(networkId, pnfName, ifName, status);
-
- Map<String, Object> ret = new HashMap<String, Object>();
-
- StringBuilder sbn = new StringBuilder();
- StringBuilder sbi = new StringBuilder();
- for(int i = 0; i < instances.size(); ++i) {
- JSONObject o = instances.getJSONObject(i);
- String name = o.getString("service-instance-name");
- String id = o.getString("service-instance-id");
- ret.put(id + ".input-parameters", o.getString("input-parameters"));
- sbn.append(name).append(",");
- sbi.append(id).append(",");
- }
- ret.put("service-instance.service-instance-name", sbn.substring(0, sbn.length() -1).toString());
- ret.put("service-instance.service-instance-id", sbi.substring(0, sbi.length() -1).toString());
- ret.put("vserver.vserver-name", "TBD");
- ret.put("globalSubscriberId", instances.getJSONObject(0).getString("globalSubscriberId"));
- ret.put("serviceType", instances.getJSONObject(0).getString("serviceType"));
-
- return ret;
-}
-
-function PolicyMsg createPolicyMsg(VesAlarm alarm) {
- PolicyMsg m = new PolicyMsg();
- m.setPolicyVersion("1.0.0.5");
- m.setPolicyName("CCVPN");
- m.setPolicyScope("service=SOTNService,type=SampleType,closedLoopControlName=CL-CCVPN-d925ed73-8231-4d02-9545-db4e101f88f8");
- m.setClosedLoopControlName(DmaapService.loopControlNames.get("org.onap.holmes.ccvpn"));
- m.setRequestID(UUID.randomUUID().toString());
- m.setClosedLoopAlarmStart(alarm.getStartEpochMicrosec());
- m.setClosedLoopAlarmEnd(alarm.getLastEpochMicrosec());
- m.setTarget("vserver.vserver-name");
- m.setAai(getAdditionalResourceInfo(
- getAdditionalField(alarm, "networkId"),
- getAdditionalField(alarm, "node"),
- getAdditionalField(alarm, "tp-id"),
- getAdditionalField(alarm, "oper-status")
- ));
-
- DmaapService.alarmUniqueRequestID.put(alarm.getEventId(), m.getRequestID());
-
- return m;
-}
-
-rule "Update AAI Information"
- no-loop true
- salience 300
- when
- $a: VesAlarm(eventName.indexOf("Fault_Route_Status") != -1)
- then
- updateAaiTpStatus (
- getAdditionalField($a, "networkId"),
- getAdditionalField($a, "node"),
- getAdditionalField($a, "tp-id"),
- getAdditionalField($a, "oper-status")
- );
-end
-
-rule "Set Up Correlation"
- no-loop true
- salience 200
- when
- $a: VesAlarm($id: eventId,
- $start: startEpochMicrosec,
- eventName.indexOf("Fault_Route_Status") != -1)
- $b: VesAlarm(eventId != $id,
- eventName.indexOf("Fault_Route_Status") != -1,
- Math.abs(startEpochMicrosec - $start) < 60000)
- then
- String status = "down";
- if (status.equalsIgnoreCase(getAdditionalField($a, "oper-status"))
- && status.equalsIgnoreCase(getAdditionalField($b, "oper-status"))) {
- if (isCorrelated($a, $b)){
- // If any of the alarms have been marked as root, a policy message has ever been created and sent. Do NOT send it again.
- if ($a.getRootFlag() != 1 && $b.getRootFlag() != 1) {
- PolicyMsg msg = createPolicyMsg($a);
- DmaapService dmaapService = ServiceLocatorHolder.getLocator().getService(DmaapService.class);
- dmaapService.publishPolicyMsg(msg, "unauthenticated.DCAE_CL_OUTPUT");
- updateAaiLinkStatus(getLogicLink($a), status);
- }
- $a.setRootFlag(1);
- $b.setRootFlag(1);
- update($a);
- update($b);
- }
- }
-end
-
-rule "Clear Alarms"
- no-loop true
- salience 100
- when
- $a: VesAlarm(eventName.indexOf("Fault_Route_Status") != -1)
- then
- if ("up".equalsIgnoreCase(getAdditionalField($a, "oper-status"))) {
- if (DmaapService.alarmUniqueRequestID.containsKey($a.getEventId())) {
- DmaapService.alarmUniqueRequestID.remove($a.getEventId());
- }
-
- //TODO: send alarm clearing message to Policy - for now it's not needed.
- //...
-
- retract($a);
- }
-end
\ No newline at end of file
Code Review / holmes / rule-management.git / blobdiff