package org.onap.dcae.commonFunction;
+import java.text.DecimalFormat;
import org.json.JSONArray;
import org.json.JSONObject;
import org.slf4j.Logger;
public class ConfigProcessors {
- private static final Logger LOG = LoggerFactory.getLogger(ConfigProcessors.class);
- private static final String FIELD = "field";
- private static final String OLD_FIELD = "oldField";
- private static final String FILTER = "filter";
- private static final String VALUE = "value";
- private static final String REGEX = "\\[\\]";
- private static final String OBJECT_NOT_FOUND = "ObjectNotFound";
-
-
- public ConfigProcessors(JSONObject eventJson) {
- event = eventJson;
- }
-
- /**
- *
- * @param j json object
- */
- public void getValue(JSONObject j) {
- //log.info("addAttribute");
- final String field = j.getString(FIELD);
- //final String value = J.getString(VALUE);
- final JSONObject filter = j.optJSONObject(FILTER);
- if (filter == null || isFilterMet(filter)) {
- //log.info("field ==" + field);
- //log.info("value ==" + value);
- getEventObjectVal(field);
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- * @param j json object
- */
- public void setValue(JSONObject j) {
- //log.info("addAttribute");
- final String field = j.getString(FIELD);
- final String value = j.getString(VALUE);
- final JSONObject filter = j.optJSONObject(FILTER);
- if (filter == null || isFilterMet(filter)) {
- //log.info("field ==" + field);
- //log.info("value ==" + value);
- setEventObjectVal(field, value);
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- * @param j json object
- */
- public void addAttribute(JSONObject j) {
- //log.info("addAttribute");
- final String field = j.getString(FIELD);
- final String value = j.getString(VALUE);
- final JSONObject filter = j.optJSONObject(FILTER);
- if (filter == null || isFilterMet(filter)) {
- //log.info("field ==" + field);
- //log.info("value ==" + value);
- setEventObjectVal(field, value);
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- * @param j json object
- */
- public void updateAttribute(JSONObject j) {
- //log.info("updateAttribute");
- final String field = j.getString(FIELD);
- final String value = j.getString(VALUE);
- final JSONObject filter = j.optJSONObject(FILTER);
- if (filter == null || isFilterMet(filter)) {
- //log.info("field ==" + field);
- //log.info("value ==" + value);
- setEventObjectVal(field, value);
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- * @param j json object
- */
- public void removeAttribute(JSONObject j) {
- //log.info("removeAttribute");
- final String field = j.getString(FIELD);
- final JSONObject filter = j.optJSONObject(FILTER);
-
- if (filter == null || isFilterMet(filter)) {
- removeEventKey(field);
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- * @param j json object
- */
- public void renameArrayInArray(JSONObject j) { //map
-
- LOG.info("renameArrayInArray");
- final String field = j.getString(FIELD);
- final String oldField = j.getString(OLD_FIELD);
- final JSONObject filter = j.optJSONObject(FILTER);
- //String value = "";
- if (filter == null || isFilterMet(filter)) {
- //log.info("field ==" + field);
- final String[] fsplit = field.split(REGEX, field.length());
- final String[] oldfsplit = oldField.split(REGEX, oldField.length());
- /*for (int i=0; i< oldfsplit.length; i++ )
- {
+ private static Logger LOG = LoggerFactory.getLogger(ConfigProcessors.class);
+ private static final String FIELD = "field";
+ private static final String OLD_FIELD = "oldField";
+ private static final String FILTER = "filter";
+ private static final String VALUE = "value";
+ private static final String REGEX = "\\[\\]";
+ private static final String OBJECT_NOT_FOUND = "ObjectNotFound";
+
+ public ConfigProcessors(JSONObject eventJson)
+ {
+ event = eventJson;
+ }
+
+ /**
+ *
+ */
+ public void getValue(JSONObject J)
+ {
+ //log.info("addAttribute");
+ final String field = J.getString(FIELD);
+ //final String value = J.getString(VALUE);
+ final JSONObject filter = J.optJSONObject(FILTER);
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("field ==" + field);
+ //log.info("value ==" + value);
+ getEventObjectVal(field);
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ public void setValue(JSONObject J)
+ {
+ //log.info("addAttribute");
+ final String field = J.getString(FIELD);
+ final String value = J.getString(VALUE);
+ final JSONObject filter = J.optJSONObject(FILTER);
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("field ==" + field);
+ //log.info("value ==" + value);
+ setEventObjectVal(field, value);
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ public String evaluate(String str)
+ {
+ String value = str;
+ if (str.startsWith("$"))
+ {
+ value = (String) getEventObjectVal(str.substring(1));
+
+ }
+ return value;
+ }
+
+ /**
+ * { "functionName":"suppressEvent",
+ "args":{}
+ }
+ */
+ public void suppressEvent(JSONObject J)
+ {
+ //log.info("addAttribute");
+ final JSONObject filter = J.optJSONObject(FILTER);
+
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("field ==" + field);
+ //log.info("value ==" + value);
+ setEventObjectVal("suppressEvent", "true");
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ public void addAttribute(JSONObject J)
+ {
+ //log.info("addAttribute begin");
+ final String field = J.getString(FIELD);
+ final String value = evaluate(J.getString(VALUE));
+ final JSONObject filter = J.optJSONObject(FILTER);
+ final String fieldType = J.optString("fieldType", "string").toLowerCase();
+
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("field ==" + field);
+ //log.info("value ==" + value);
+ setEventObjectVal(field, value, fieldType);
+ }
+ else
+ LOG.info("Filter not met");
+ //log.info("addAttribute End");
+ }
+
+ /**
+ *
+ */
+ public void updateAttribute(JSONObject J)
+ {
+ //log.info("updateAttribute");
+ final String field = J.getString(FIELD);
+ final String value = evaluate(J.getString(VALUE));
+ final JSONObject filter = J.optJSONObject(FILTER);
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("field ==" + field);
+ //log.info("value ==" + value);
+ setEventObjectVal(field, value);
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ public void removeAttribute(JSONObject J)
+ {
+ //log.info("removeAttribute");
+ final String field = J.getString(FIELD);
+ final JSONObject filter = J.optJSONObject(FILTER);
+
+ if (filter == null || isFilterMet(filter))
+ {
+ removeEventKey(field);
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ public void renameArrayInArray(JSONObject J) //map
+ {
+ LOG.info("renameArrayInArray");
+ final String field = J.getString(FIELD);
+ final String oldField = J.getString(OLD_FIELD);
+ final JSONObject filter = J.optJSONObject(FILTER);
+ //String value = "";
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("field ==" + field);
+ final String[] fsplit = field.split(REGEX, field.length());
+ final String[] oldfsplit = oldField.split(REGEX, oldField.length());
+ /*for (int i=0; i< oldfsplit.length; i++ )
+ {
log.info( "renameArrayInArray " + i + " ==" + oldfsplit[i]);
}*/
-
- final String oldValue = getEventObjectVal(oldfsplit[0]).toString();
- if (!OBJECT_NOT_FOUND.equals(oldValue)) {
- final String oldArrayName = oldfsplit[1].substring(1);
- final String newArrayName = fsplit[1].substring(1);
- final String value = oldValue.replaceAll(oldArrayName, newArrayName);
- //log.info("oldArrayName ==" + oldArrayName);
- //log.info("newArrayName ==" + newArrayName);
- LOG.info("oldValue ==" + oldValue);
- LOG.info("value ==" + value);
- JSONArray ja = new JSONArray(value);
- removeEventKey(oldfsplit[0]);
- setEventObjectVal(fsplit[0], ja);
- }
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- * @param j json object
- */
- public void map(JSONObject j) {
- //log.info("mapAttribute");
- final String field = j.getString(FIELD);
- if (field.contains("[]")) {
- if (field.matches(".*\\[\\]\\..*\\[\\]")) {
- renameArrayInArray(j);
- } else {
- mapToJArray(j);
- }
- } else {
- mapAttribute(j);
- }
- }
-
- /**
- *
- * @param operation operation
- * @param value kb value
- * @return value
- */
- public String performOperation(String operation, String value) {
- LOG.info("performOperation");
- if (operation != null && "convertMBtoKB".equals(operation)) {
- float kbValue = Float.parseFloat(value) * 1024;
- value = String.valueOf(kbValue);
- }
- return value;
- }
-
- //public void mapAttributeToArrayAttribute(JSONObject J)
-
- /**
- *
- * @param j json object
- */
- public void mapAttribute(JSONObject j) {
- //log.info("mapAttribute");
- final String field = j.getString(FIELD);
- final String oldField = j.getString(OLD_FIELD);
- final JSONObject filter = j.optJSONObject(FILTER);
- final String operation = j.optString("operation");
- String value = "";
- if (filter == null || isFilterMet(filter)) {
- //log.info("field ==" + field);
-
- value = getEventObjectVal(oldField).toString();
- if (!OBJECT_NOT_FOUND.equals(value)) {
- if (operation != null && !operation.isEmpty()) {
- value = performOperation(operation, value);
- }
- //log.info("value ==" + value);
- setEventObjectVal(field, value);
-
- removeEventKey(oldField);
- }
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- * @param j json object
- */
- public void mapToJArray(JSONObject j) {
- LOG.info("mapToJArray");
- String field = j.getString(FIELD);
- String oldField = j.getString(OLD_FIELD);
- final JSONObject filter = j.optJSONObject(FILTER);
- final JSONObject attrMap = j.optJSONObject("attrMap");
- oldField = oldField.replaceAll(REGEX, "");
- field = field.replaceAll(REGEX, "");
-
- //log.info("oldField ==" + field);
- if (filter == null || isFilterMet(filter)) {
- //log.info("oldField ==" + field);
- String value = getEventObjectVal(oldField).toString();
- if (!OBJECT_NOT_FOUND.equals(value)) {
- LOG.info("old value ==" + value);
- //update old value based on attrMap
- if (attrMap != null) {
- //loop thru attrMap and update attribute name to new name
- for (String key : attrMap.keySet()) {
- //log.info("attr key==" + key + " value==" + attrMap.getString(key));
- value = value.replaceAll(key, attrMap.getString(key));
- }
- }
-
- LOG.info("new value ==" + value);
- char c = value.charAt(0);
- if (c != '[') {
- //oldfield is JsonObject
- JSONObject valueJO = new JSONObject(value);
- // if the array already exists
-
- String existingValue = getEventObjectVal(field).toString();
- if (!OBJECT_NOT_FOUND.equals(existingValue)) {
- JSONArray ja = new JSONArray(existingValue);
- JSONObject jo = ja.optJSONObject(0);
- if (jo != null) {
- for (String key : valueJO.keySet()) {
- jo.put(key, valueJO.get(key));
-
- }
- ja.put(0, jo);
- //log.info("jarray== " + ja.toString());
- setEventObjectVal(field, ja);
- }
- } else //if new array
- {
- setEventObjectVal(field + "[0]", new JSONObject(value));
- }
- } else //oldfield is jsonArray
- {
- setEventObjectVal(field, new JSONArray(value));
- }
-
- removeEventKey(oldField);
- }
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /*
- * example -
- {
- "functionName": "concatenateValue",
- "args":{
- "filter": {"event.commonEventHeader.event":"heartbeat"},
- "field":"event.commonEventHeader.eventName",
- "concatenate": ["event.commonEventHeader.domain","event.commonEventHeader.eventType","event.commonEventHeader.alarmCondition"],
- "delimiter":"_"
- }
- }
- **/
-
- /**
- *
- * @param j json object
- */
- public void concatenateValue(JSONObject j) {
- //log.info("concatenateValue");
- final String field = j.getString(FIELD);
- final String delimiter = j.getString("delimiter");
- final JSONArray values = j.getJSONArray("concatenate");
- final JSONObject filter = j.optJSONObject(FILTER);
- if (filter == null || isFilterMet(filter)) {
- StringBuilder value = new StringBuilder("");
- for (int i = 0; i < values.length(); i++) {
- //log.info(values.getString(i));
- String tempVal = getEventObjectVal(values.getString(i)).toString();
- if (!OBJECT_NOT_FOUND.equals(tempVal)) {
- if (i == 0) {
- value.append(getEventObjectVal(values.getString(i)));
- } else {
- value.append(delimiter).append(getEventObjectVal(values.getString(i)));
- }
- }
- }
- //log.info("value ==" + value);
- setEventObjectVal(field, value.toString());
- } else {
- LOG.info("Filter not met");
- }
- }
-
- /**
- *
- */
- private void removeEventKey(String field) {
- String[] keySet = field.split("\\.", field.length());
- JSONObject keySeries = event;
- for (int i = 0; i < (keySet.length - 1); i++) {
- //log.info( i + " ==" + keySet[i]);
- keySeries = keySeries.getJSONObject(keySet[i]);
- }
- //log.info(keySet[keySet.length -1]);
-
- keySeries.remove(keySet[keySet.length - 1]);
-
- }
-
- /**
- *
- */
- private boolean checkFilter(JSONObject jo, String key, String logicKey) {
- String filterValue = jo.getString(key);
- boolean retVal = true;
-
- if (filterValue.contains(":")) {
- String[] splitVal = filterValue.split(":");
- //log.info(splitVal[0] + " " + splitVal[1]);
- if ("matches".equals(splitVal[0])) {
- if ("not".equals(logicKey)) {
- //log.info("not");
- //log.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "split1==" + splitVal[1]);
- if (getEventObjectVal(key).toString().matches(splitVal[1])) {
- loggerForCheckFilter(filterValue, key);
- return false;
- }
- } else {
- if (!getEventObjectVal(key).toString().matches(splitVal[1])) {
- loggerForCheckFilter(filterValue, key);
- return false;
- }
- }
-
- }
- if ("contains".equals(splitVal[0])) {
- if ("not".equals(logicKey)) {
- //log.info("not");
- //log.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "split1==" + splitVal[1]);
- if (getEventObjectVal(key).toString().contains(splitVal[1])) {
- loggerForCheckFilter(filterValue, key);
- return false;
- }
- } else {
- if (!getEventObjectVal(key).toString().contains(splitVal[1])) {
- loggerForCheckFilter(filterValue, key);
- return false;
- }
- }
-
- }
- } else {
- if ("not".equals(logicKey)) {
- if (getEventObjectVal(key).toString().equals(filterValue)) {
- loggerForCheckFilter(filterValue, key);
- return false;
- }
- } else {
- if (!getEventObjectVal(key).toString().equals(filterValue)) {
- loggerForCheckFilter(filterValue, key);
- return false;
- }
- }
- }
- return retVal;
- }
-
- /**
- *
- * @param jo json object
- * @return true/false
- */
- public boolean isFilterMet(JSONObject jo) {
- boolean retval;
- //log.info("Filter==" + jo.toString());
- for (String key : jo.keySet()) {
- if ("not".equals(key)) {
- JSONObject njo = jo.getJSONObject(key);
- for (String njoKey : njo.keySet()) {
- //log.info(njoKey);
- retval = checkFilter(njo, njoKey, key);
- if (!retval) {
- return retval;
- }
- }
- } else {
- //log.info(key);
- //final String filterKey = key;
- retval = checkFilter(jo, key, key);
- if (!retval) {
- return retval;
- }
- }
- }
- return true;
- }
-
- /**
- * returns a string or JSONObject or JSONArray
- *
- * @param keySeriesStr key series string
- * @return key string updated object
- **/
- public Object getEventObjectVal(String keySeriesStr) {
- keySeriesStr = keySeriesStr.replaceAll("\\[", ".");
- keySeriesStr = keySeriesStr.replaceAll("\\]", ".");
- if (keySeriesStr.contains("..")) {
- keySeriesStr = keySeriesStr.replaceAll("\\.\\.", ".");
- }
- //log.info(Integer.toString(keySeriesStr.lastIndexOf(".")));
- //log.info(Integer.toString(keySeriesStr.length() -1));
- if (keySeriesStr.lastIndexOf('.') == keySeriesStr.length() - 1) {
- keySeriesStr = keySeriesStr.substring(0, keySeriesStr.length() - 1);
- }
- String[] keySet = keySeriesStr.split("\\.", keySeriesStr.length());
- Object keySeriesObj = event;
- for (int i = 0; i < keySet.length; i++) {
- //log.info( "getEventObject " + i + " ==" + keySet[i]);
- if (keySeriesObj != null) {
- if (keySeriesObj instanceof String) {
- //keySeriesObj = keySeriesObj.get(keySet[i]);
- LOG.info("STRING==" + keySeriesObj);
- } else if (keySeriesObj instanceof JSONArray) {
- keySeriesObj = ((JSONArray) keySeriesObj)
- .optJSONObject(Integer.parseInt(keySet[i]));
- //log.info("ARRAY==" + keySeriesObj);
- } else if (keySeriesObj instanceof JSONObject) {
- keySeriesObj = ((JSONObject) keySeriesObj).opt(keySet[i]);
- //log.info("JSONObject==" + keySeriesObj);
- } else {
- LOG.info("unknown object==" + keySeriesObj);
- }
- }
- }
-
- if (keySeriesObj == null) {
- return "ObjectNotFound";
- }
- return keySeriesObj;
- }
-
- /**
- * returns a string or JSONObject or JSONArray
- *
- * @param keySeriesStr key series string
- * @param value value object
- **/
- public void setEventObjectVal(String keySeriesStr, Object value) {
- keySeriesStr = keySeriesStr.replaceAll("\\[", ".");
- keySeriesStr = keySeriesStr.replaceAll("\\]", ".");
- if (keySeriesStr.contains("..")) {
- keySeriesStr = keySeriesStr.replaceAll("\\.\\.", ".");
- }
- //log.info(Integer.toString(keySeriesStr.lastIndexOf(".")));
- //log.info(Integer.toString(keySeriesStr.length() -1));
- if (keySeriesStr.lastIndexOf('.') == keySeriesStr.length() - 1) {
- keySeriesStr = keySeriesStr.substring(0, keySeriesStr.length() - 1);
- }
- String[] keySet = keySeriesStr.split("\\.", keySeriesStr.length());
- Object keySeriesObj = event;
- for (int i = 0; i < (keySet.length - 1); i++) {
- //log.info( "setEventObject " + i + " ==" + keySet[i]);
- if (keySeriesObj instanceof JSONArray) {
- //keySeriesObj = ((JSONArray) keySeriesObj).optJSONObject(Integer.parseInt(keySet[i]));
- if (((JSONArray) keySeriesObj).optJSONObject(Integer.parseInt(keySet[i]))
- == null) //if the object is not there then add it
- {
- LOG.info("Object is null, must add it");
- if (keySet[i + 1].matches("[0-9]*")) // if index then array
- {
- ((JSONArray) keySeriesObj)
- .put(Integer.parseInt(keySet[i]), new JSONArray());
- } else {
- ((JSONArray) keySeriesObj)
- .put(Integer.parseInt(keySet[i]), new JSONObject());
- }
- }
- keySeriesObj = ((JSONArray) keySeriesObj)
- .optJSONObject(Integer.parseInt(keySet[i]));
- //log.info("ARRAY==" + keySeriesObj);
- } else if (keySeriesObj instanceof JSONObject) {
- if (((JSONObject) keySeriesObj).opt(keySet[i])
- == null) //if the object is not there then add it
- {
- if (keySet[i + 1].matches("[0-9]*")) // if index then array
- {
- ((JSONObject) keySeriesObj).put(keySet[i], new JSONArray());
- } else {
- ((JSONObject) keySeriesObj).put(keySet[i], new JSONObject());
- }
- LOG.info("Object is null, must add it");
- }
- keySeriesObj = ((JSONObject) keySeriesObj).opt(keySet[i]);
- //log.info("JSONObject==" + keySeriesObj);
- } else {
- LOG.info("unknown object==" + keySeriesObj);
- }
- }
-
- ((JSONObject) keySeriesObj).put(keySet[keySet.length - 1], value);
- }
-
- private JSONObject event = new JSONObject();
-
- private void loggerForCheckFilter(String filterValue, String key) {
- LOG.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "==false");
- }
+
+ final String oldValue = getEventObjectVal(oldfsplit[0]).toString();
+ if (!oldValue.equals(OBJECT_NOT_FOUND)){
+ final String oldArrayName = oldfsplit[1].substring(1);
+ final String newArrayName = fsplit[1].substring(1);
+ final String value = oldValue.replaceAll(oldArrayName, newArrayName);
+ //log.info("oldArrayName ==" + oldArrayName);
+ //log.info("newArrayName ==" + newArrayName);
+ LOG.info("oldValue ==" + oldValue);
+ LOG.info("value ==" + value);
+ JSONArray ja = new JSONArray(value);
+ removeEventKey(oldfsplit[0]);
+ setEventObjectVal(fsplit[0], ja);
+ }
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ public void map(JSONObject J)
+ {
+ //log.info("mapAttribute");
+ final String field = J.getString(FIELD);
+ if (field.contains("[]"))
+ {
+ if (field.matches(".*\\[\\]\\..*\\[\\]"))
+ renameArrayInArray(J);
+ else
+ mapToJArray(J);
+ }
+ else
+ mapAttribute(J);
+ }
+
+ /**
+ *
+ */
+ public String performOperation(String operation, String value)
+ {
+ LOG.info("performOperation");
+ if (operation != null)
+ {
+ if (operation.equals("convertMBtoKB"))
+ {
+ float kbValue = Float.parseFloat(value) * 1024;
+ value = String.valueOf(kbValue);
+ }
+ }
+ return value;
+ }
+
+ /**
+ *
+ */
+ //public void mapAttributeToArrayAttribute(JSONObject J)
+ public void mapAttribute(JSONObject J)
+ {
+ //log.info("mapAttribute");
+ final String field = J.getString(FIELD);
+ final String oldField = J.getString(OLD_FIELD);
+ final JSONObject filter = J.optJSONObject(FILTER);
+ final String operation = J.optString("operation");
+ String value = "";
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("field ==" + field);
+
+ value = getEventObjectVal(oldField).toString();
+ if (!value.equals(OBJECT_NOT_FOUND))
+ {
+ if (operation != null && !operation.equals(""))
+ value = performOperation(operation, value);
+ //log.info("value ==" + value);
+ setEventObjectVal(field, value);
+
+ removeEventKey(oldField);
+ }
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ public void mapToJArray(JSONObject J)
+ {
+ LOG.info("mapToJArray");
+ String field = J.getString(FIELD);
+ String oldField = J.getString(OLD_FIELD);
+ final JSONObject filter = J.optJSONObject(FILTER);
+ final JSONObject attrMap = J.optJSONObject("attrMap");
+ oldField = oldField.replaceAll(REGEX, "");
+ field = field.replaceAll(REGEX, "");
+
+ //log.info("oldField ==" + field);
+ if (filter == null || isFilterMet(filter))
+ {
+ //log.info("oldField ==" + field);
+ String value = getEventObjectVal(oldField).toString();
+ if (!value.equals(OBJECT_NOT_FOUND))
+ {
+ LOG.info("old value ==" + value.toString());
+ //update old value based on attrMap
+ if (attrMap != null)
+ {
+ //loop thru attrMap and update attribute name to new name
+ for (String key : attrMap.keySet())
+ {
+ //log.info("attr key==" + key + " value==" + attrMap.getString(key));
+ value = value.replaceAll(key, attrMap.getString(key));
+ }
+ }
+
+ LOG.info("new value ==" + value);
+ char c = value.charAt(0);
+ if (c != '[')
+ {
+ //oldfield is JsonObject
+ JSONObject valueJO = new JSONObject(value);
+ // if the array already exists
+
+ String existingValue = getEventObjectVal(field).toString();
+ if (!existingValue.equals(OBJECT_NOT_FOUND))
+ {
+ JSONArray ja = new JSONArray(existingValue);
+ JSONObject jo = ja.optJSONObject(0);
+ if (jo != null)
+ {
+ for (String key : valueJO.keySet())
+ {
+ jo.put(key, valueJO.get(key));
+
+ }
+ ja.put(0, jo);
+ //log.info("jarray== " + ja.toString());
+ setEventObjectVal(field,ja);
+ }
+ }
+ else //if new array
+ setEventObjectVal(field + "[0]", new JSONObject(value));
+ }
+ else //oldfield is jsonArray
+ setEventObjectVal(field, new JSONArray(value));
+
+ removeEventKey(oldField);
+ }
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ * example -
+ {
+ "functionName": "concatenateValue",
+ "args":{
+ "filter": {"event.commonEventHeader.event":"heartbeat"},
+ FIELD:"event.commonEventHeader.eventName",
+ "concatenate": ["event.commonEventHeader.domain","event.commonEventHeader.eventType","event.commonEventHeader.alarmCondition"],
+ "delimiter":"_"
+ }
+ }
+ **/
+ public void concatenateValue(JSONObject J)
+ {
+ //log.info("concatenateValue");
+ final String field = J.getString(FIELD);
+ final String delimiter = J.getString("delimiter");
+ final JSONArray values = J.getJSONArray("concatenate");
+ final JSONObject filter = J.optJSONObject(FILTER);
+ if (filter == null || isFilterMet(filter))
+ {
+ String value = "";
+ for (int i=0; i < values.length(); i++)
+ {
+ //log.info(values.getString(i));
+ String tempVal = evaluate(values.getString(i));
+ if (!tempVal.equals(OBJECT_NOT_FOUND))
+ {
+ if (i ==0)
+ value = value + tempVal;
+ else
+ value = value + delimiter + tempVal;
+ }
+ }
+ //log.info("value ==" + value);
+ setEventObjectVal(field, value);
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ public void subtractValue(JSONObject J)
+ {
+ //log.info("concatenateValue");
+ final String field = J.getString(FIELD);
+ final JSONArray values = J.getJSONArray("subtract");
+ final JSONObject filter = J.optJSONObject(FILTER);
+ if (filter == null || isFilterMet(filter))
+ {
+ float value = 0;
+ for (int i=0; i < values.length(); i++)
+ {
+ LOG.info(values.getString(i));
+ String tempVal = evaluate(values.getString(i));
+ LOG.info("tempVal==" + tempVal);
+ if (!tempVal.equals(OBJECT_NOT_FOUND))
+ {
+ if (i ==0)
+ value = value + Float.valueOf(tempVal);
+ else
+ value = value - Float.valueOf(tempVal);
+ }
+ }
+ LOG.info("value ==" + value );
+ setEventObjectVal(field, value, "number");
+ }
+ else
+ LOG.info("Filter not met");
+ }
+
+ /**
+ *
+ */
+ private void removeEventKey(String field)
+ {
+ String[] keySet = field.split("\\.",field.length());
+ JSONObject keySeries = event;
+ for (int i=0; i<(keySet.length -1); i++ )
+ {
+ //log.info( i + " ==" + keySet[i]);
+ keySeries = keySeries.getJSONObject(keySet[i]);
+ }
+ //log.info(keySet[keySet.length -1]);
+
+ keySeries.remove(keySet[keySet.length -1]);
+
+ }
+
+ /**
+ *
+ */
+ private boolean checkFilter(JSONObject jo, String key, String logicKey)
+ {
+ String filterValue = jo.getString(key);
+ boolean retVal = true;
+
+ if(filterValue.contains(":"))
+ {
+ String[] splitVal = filterValue.split(":");
+ //log.info(splitVal[0] + " " + splitVal[1]);
+ if (splitVal[0].equals("matches"))
+ {
+ if (logicKey.equals("not"))
+ {
+ //log.info("not");
+ //log.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "split1==" + splitVal[1]);
+ if (getEventObjectVal(key).toString().matches(splitVal[1]))
+ {
+ LOG.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "==false");
+ return false;
+ }
+ }
+ else
+ {
+ if (!(getEventObjectVal(key).toString().matches(splitVal[1])))
+ {
+ LOG.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "==false");
+ return false;
+ }
+ }
+
+ }
+ if (splitVal[0].equals("contains"))
+ {
+ if (logicKey.equals("not"))
+ {
+ //log.info("not");
+ //log.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "split1==" + splitVal[1]);
+ if (getEventObjectVal(key).toString().contains(splitVal[1]))
+ {
+ LOG.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "==false");
+ return false;
+ }
+ }
+ else
+ {
+ if (!(getEventObjectVal(key).toString().contains(splitVal[1])))
+ {
+ LOG.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "==false");
+ return false;
+ }
+ }
+
+ }
+ }
+ else
+ {
+ if (logicKey.equals("not"))
+ {
+ if(getEventObjectVal(key).toString().equals(filterValue))
+ {
+ LOG.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "==false");
+ return false;
+ }
+ }
+ else
+ {
+ if(!(getEventObjectVal(key).toString().equals(filterValue)))
+ {
+ LOG.info(filterValue + "==" + key + "==" + getEventObjectVal(key) + "==false");
+ return false;
+ }
+ }
+ }
+ return retVal;
+ }
+ /**
+ *
+ */
+ public boolean isFilterMet(JSONObject jo)
+ {
+ boolean retval = true;
+ //log.info("Filter==" + jo.toString());
+ for (String key : jo.keySet())
+ {
+ if (key.equals("not"))
+ {
+ JSONObject njo = jo.getJSONObject(key);
+ for (String njoKey : njo.keySet())
+ {
+ //log.info(njoKey);
+ retval = checkFilter(njo, njoKey, key);
+ if (retval == false)
+ return retval;
+ }
+ }
+ else
+ {
+ //log.info(key);
+ //final String filterKey = key;
+ retval = checkFilter(jo, key, key);
+ if (retval == false)
+ return retval;
+ }
+ }
+ return true;
+ }
+
+ /**
+ * returns a string or JSONObject or JSONArray
+ **/
+ public Object getEventObjectVal(String keySeriesStr)
+ {
+ keySeriesStr = keySeriesStr.replaceAll("\\[", ".");
+ keySeriesStr = keySeriesStr.replaceAll("\\]", ".");
+ if (keySeriesStr.contains(".."))
+ {
+ keySeriesStr = keySeriesStr.replaceAll("\\.\\.", ".");
+ }
+ //log.info(Integer.toString(keySeriesStr.lastIndexOf(".")));
+ //log.info(Integer.toString(keySeriesStr.length() -1));
+ if (keySeriesStr.lastIndexOf(".") == keySeriesStr.length() -1 )
+ keySeriesStr = keySeriesStr.substring(0,keySeriesStr.length()-1 );
+ String[] keySet = keySeriesStr.split("\\.", keySeriesStr.length());
+ Object keySeriesObj = event;
+ for (int i=0; i<(keySet.length); i++ )
+ {
+ //log.info( "getEventObject " + i + " ==" + keySet[i]);
+ if (keySeriesObj != null)
+ {
+ if (keySeriesObj instanceof String)
+ {
+ //keySeriesObj = keySeriesObj.get(keySet[i]);
+ LOG.info("STRING==" + keySeriesObj);
+ }
+ else if (keySeriesObj instanceof JSONArray) {
+ keySeriesObj = ((JSONArray) keySeriesObj).optJSONObject(Integer.parseInt(keySet[i]));
+ //log.info("ARRAY==" + keySeriesObj);
+ }
+ else if (keySeriesObj instanceof JSONObject) {
+ keySeriesObj = ( (JSONObject) keySeriesObj).opt(keySet[i]);
+ //log.info("JSONObject==" + keySeriesObj);
+ }
+ else
+ {
+ LOG.info("unknown object==" + keySeriesObj);
+ }
+ }
+ }
+
+ if (keySeriesObj == null)
+ return OBJECT_NOT_FOUND;
+ return keySeriesObj;
+ }
+
+ public void setEventObjectVal(String keySeriesStr, Object value)
+ {
+ setEventObjectVal(keySeriesStr, value, "string");
+ }
+
+ /**
+ * returns a string or JSONObject or JSONArray
+ **/
+ public void setEventObjectVal(String keySeriesStr, Object value, String fieldType)
+ {
+ keySeriesStr = keySeriesStr.replaceAll("\\[", ".");
+ keySeriesStr = keySeriesStr.replaceAll("\\]", ".");
+ if (keySeriesStr.contains(".."))
+ {
+ keySeriesStr = keySeriesStr.replaceAll("\\.\\.", ".");
+ }
+ LOG.info("fieldType==" + fieldType);
+ //log.info(Integer.toString(keySeriesStr.lastIndexOf(".")));
+ //log.info(Integer.toString(keySeriesStr.length() -1));
+ if (keySeriesStr.lastIndexOf(".") == keySeriesStr.length() -1 )
+ keySeriesStr = keySeriesStr.substring(0,keySeriesStr.length()-1 );
+ String[] keySet = keySeriesStr.split("\\.", keySeriesStr.length());
+ Object keySeriesObj = event;
+ for (int i=0; i<(keySet.length -1); i++ )
+ {
+ //log.info( "setEventObject " + i + " ==" + keySet[i]);
+ if (keySeriesObj instanceof JSONArray) {
+ //keySeriesObj = ((JSONArray) keySeriesObj).optJSONObject(Integer.parseInt(keySet[i]));
+ if (((JSONArray) keySeriesObj).optJSONObject(Integer.parseInt(keySet[i])) == null) //if the object is not there then add it
+ {
+ LOG.info("Object is null, must add it");
+ if (keySet[i+1].matches("[0-9]*")) // if index then array
+ ((JSONArray) keySeriesObj).put(Integer.parseInt(keySet[i]), new JSONArray());
+ else
+ ((JSONArray) keySeriesObj).put(Integer.parseInt(keySet[i]), new JSONObject());
+ }
+ keySeriesObj = ((JSONArray) keySeriesObj).optJSONObject(Integer.parseInt(keySet[i]));
+ //log.info("ARRAY==" + keySeriesObj);
+ }
+ else if (keySeriesObj instanceof JSONObject) {
+ if (( (JSONObject) keySeriesObj).opt(keySet[i]) == null) //if the object is not there then add it
+ {
+ if (keySet[i+1].matches("[0-9]*")) // if index then array
+ ((JSONObject) keySeriesObj).put(keySet[i], new JSONArray());
+ else
+ ((JSONObject) keySeriesObj).put(keySet[i], new JSONObject());
+ LOG.info("Object is null, must add it");
+ }
+ keySeriesObj = ( (JSONObject) keySeriesObj).opt(keySet[i]);
+ //log.info("JSONObject==" + keySeriesObj);
+ }
+ else
+ {
+ LOG.info("unknown object==" + keySeriesObj);
+ }
+ }
+ if (fieldType.equals("number") )
+ {
+ DecimalFormat df = new DecimalFormat("#.0");
+ if (value instanceof String)
+ ((JSONObject)keySeriesObj).put(keySet[keySet.length -1], Float.valueOf(df.format(Float.valueOf((String) value))));
+ else
+ ((JSONObject)keySeriesObj).put(keySet[keySet.length -1], Float.valueOf(df.format(value)));
+ }
+ else if (fieldType.equals("integer") && value instanceof String)
+ ((JSONObject)keySeriesObj).put(keySet[keySet.length -1], Integer.valueOf((String) value));
+ else
+ ((JSONObject)keySeriesObj).put(keySet[keySet.length -1], value);
+ }
+ private JSONObject event = new JSONObject();
}
+
Code Review / dcaegen2 / collectors / ves.git / commitdiff