summaryrefslogtreecommitdiffstats
path: root/asdctool
diff options
context:
space:
mode:
authorhekeguang <hekeguang@chinamobile.com>2020-09-07 16:51:51 +0800
committerJulien Bertozzi <julien.bertozzi@intl.att.com>2020-09-07 10:03:01 +0000
commit81c04901ba03a1b696c5198ec84cda767101aa3c (patch)
tree14281e3644c89997d6c380468488efd4f02990b9 /asdctool
parent112016eab1cb5d4ff925c2b75a1f3696e7097707 (diff)
Template design (NSSTs) for slice sub-nets (RAN, Core, Transport).
Issue-ID: SDC-3086 Change-Id: Ib70da9e03d6dd152d901344c60f8ba47f38450fe Signed-off-by: hekeguang <hekeguang@chinamobile.com>
Diffstat (limited to 'asdctool')
-rw-r--r--asdctool/src/main/resources/config/dataTypes.yml418
1 files changed, 418 insertions, 0 deletions
diff --git a/asdctool/src/main/resources/config/dataTypes.yml b/asdctool/src/main/resources/config/dataTypes.yml
index 7198260f29..2c65c8fc04 100644
--- a/asdctool/src/main/resources/config/dataTypes.yml
+++ b/asdctool/src/main/resources/config/dataTypes.yml
@@ -990,6 +990,424 @@ org.openecomp.datatypes.network.MacAssignments:
required: true
description: identifies the number of MAC addresses to assign to the CP from the plan
+org.openecomp.datatypes.CSProperties:
+ derived_from: org.openecomp.datatypes.Root
+ properties:
+ sNSSAI:
+ type: string
+ required: true
+ description: sNSSAI
+ maxNumberofUEs:
+ type: integer
+ required: true
+ default: 1000
+ description: maxNumberofUEs
+ latency:
+ type: integer
+ required: true
+ default: 30
+ description: latency
+ expDataRateDL:
+ type: integer
+ required: false
+ description: expDataRateDL
+ expDataRateUL:
+ type: integer
+ required: false
+ description: expDataRateUL
+ coverageAreaList:
+ type: string
+ required: true
+ description: coverageAreaList
+ uEMobilityLevel:
+ type: string
+ constraints:
+ - valid_values: ["stationary", "nomadic","restricted mobility","fully mobility"]
+ required: false
+ description: uEMobilityLevel
+ useInterval:
+ type: string
+ required: true
+ description: useInterval
+ resourceSharingLevel:
+ type: string
+ required: true
+ default: "Shared"
+ constraints:
+ - valid_values: ["Shared", "Non-shared"]
+ description: resourceSharingLevel
+
+org.openecomp.datatypes.NSCapabilities:
+ derived_from: org.openecomp.datatypes.Root
+ properties:
+ pLMNIdList:
+ type: string
+ required: true
+ description: pLMNIdList
+ maxNumberofUEs:
+ type: integer
+ required: true
+ default: 1000
+ description: maxNumberofUEs
+ latency:
+ type: integer
+ required: true
+ default: 30
+ description: latency
+ uEMobilityLevel:
+ type: string
+ constraints:
+ - valid_values: ["stationary", "nomadic","restricted mobility","fully mobility"]
+ required: false
+ description: uEMobilityLevel
+ resourceSharingLevel:
+ type: string
+ required: true
+ default: "Shared"
+ constraints:
+ - valid_values: ["Shared", "Non-shared"]
+ description: resourceSharingLevel
+ sST:
+ type: string
+ required: true
+ default: "eMBB"
+ constraints:
+ - valid_values: ["eMBB", "uRLLC", "mIot"]
+ description: sST
+ availability:
+ type: float
+ required: false
+ description: availability
+ dLThptPerUE:
+ type: integer
+ required: false
+ description: dLThptPerUE
+ uLThptPerUE:
+ type: integer
+ required: false
+ description: uLThptPerUE
+ maxPktSize:
+ type: integer
+ required: false
+ description: maxPktSize
+ termDensity:
+ type: integer
+ required: false
+ description: termDensity
+ activityFactor:
+ type: integer
+ required: false
+ description: activityFactor
+ jitter:
+ type: integer
+ required: false
+ description: jitter
+ survivalTime:
+ type: string
+ required: false
+ description: survivalTime
+ reliability:
+ type: string
+ required: false
+ description: reliability
+ dLThptPerSlice:
+ type: integer
+ required: false
+ description: dLThptPerSlice
+ uLThptPerSlice:
+ type: integer
+ required: false
+ description: uLThptPerSlice
+ maxNumberofConns:
+ type: integer
+ required: false
+ description: maxNumberofConns
+
+org.openecomp.datatypes.NSSCapabilities:
+ derived_from: org.openecomp.datatypes.Root
+ properties:
+ pLMNIdList:
+ type: string
+ required: true
+ description: pLMNIdList
+ maxNumberofUEs:
+ type: integer
+ required: true
+ default: 10000
+ description: maxNumberofUEs
+ latency:
+ type: integer
+ required: true
+ default: 30
+ description: latency
+ uEMobilityLevel:
+ type: string
+ constraints:
+ - valid_values: ["stationary", "nomadic","restricted mobility","fully mobility"]
+ required: false
+ description: uEMobilityLevel
+ resourceSharingLevel:
+ type: string
+ required: true
+ default: "Shared"
+ constraints:
+ - valid_values: ["Shared", "Non-shared"]
+ description: resourceSharingLevel
+ sST:
+ type: string
+ required: true
+ default: "eMBB"
+ constraints:
+ - valid_values: ["eMBB", "uRLLC", "mIot"]
+ description: sST
+ expDataRateDL:
+ type: integer
+ required: false
+ description: expDataRateDL
+ expDataRateUL:
+ type: integer
+ required: false
+ description: expDataRateUL
+ areaTrafficCapDL:
+ type: integer
+ required: false
+ description: areaTrafficCapDL
+ areaTrafficCapUL:
+ type: integer
+ required: false
+ description: areaTrafficCapUL
+ overallUserDensity:
+ type: integer
+ required: false
+ description: overallUserDensity
+ activityFactor:
+ type: integer
+ required: false
+ description: activityFactor
+ cSAvailabilityTarget:
+ type: float
+ required: false
+ description: cSAvailabilityTarget
+ cSReliabilityMeanTime:
+ type: string
+ required: false
+ description: cSReliabilityMeanTime
+ expDataRate:
+ type: integer
+ required: false
+ description: expDataRate
+ msgSizeByte:
+ type: string
+ required: false
+ description: msgSizeByte
+ transferIntervalTarget:
+ type: string
+ required: false
+ description: transferIntervalTarget
+ survivalTime:
+ type: string
+ required: false
+ description: survivalTime
+ maxNumberofPDUSession:
+ type: integer
+ required: false
+ description: maxNumberofPDUSession
+
+org.openecomp.datatypes.ServiceProfile:
+ derived_from: org.openecomp.datatypes.Root
+ properties:
+ sNSSAI:
+ type: string
+ required: true
+ description: sNSSAI
+ pLMNIdList:
+ type: string
+ required: true
+ description: pLMNIdList
+ maxNumberofUEs:
+ type: integer
+ required: true
+ default: 1000
+ description: maxNumberofUEs
+ latency:
+ type: integer
+ required: true
+ default: 30
+ description: latency
+ activityFactor:
+ type: integer
+ constraints:
+ - in_range: [0,100]
+ required: false
+ default: 20
+ description: activityFactor
+ coverageAreaTAList:
+ type: string
+ required: false
+ description: coverageAreaTAList
+ uEMobilityLevel:
+ type: string
+ constraints:
+ - valid_values: ["stationary", "nomadic","restricted mobility","fully mobility"]
+ required: false
+ description: uEMobilityLevel
+ resourceSharingLevel:
+ type: string
+ required: true
+ default: "Shared"
+ constraints:
+ - valid_values: ["Shared", "Non-shared"]
+ description: resourceSharingLevel
+ sST:
+ type: string
+ required: true
+ default: "eMBB"
+ constraints:
+ - valid_values: ["eMBB", "uRLLC", "mIot"]
+ description: sST
+ availability:
+ type: float
+ required: false
+ description: availability
+ reliability:
+ type: string
+ required: false
+ description: reliability
+ dLThptPerUE:
+ type: integer
+ required: false
+ description: dLThptPerUE
+ uLThptPerUE:
+ type: integer
+ required: false
+ description: uLThptPerUE
+ maxPktSize:
+ type: integer
+ required: false
+ description: maxPktSize
+ termDensity:
+ type: integer
+ required: false
+ description: termDensity
+ jitter:
+ type: integer
+ required: false
+ description: jitter
+ survivalTime:
+ type: string
+ required: false
+ description: survivalTime
+ dLThptPerSlice:
+ type: integer
+ required: false
+ description: dLThptPerSlice
+ uLThptPerSlice:
+ type: integer
+ required: false
+ description: uLThptPerSlice
+ maxNumberofConns:
+ type: integer
+ required: false
+ description: maxNumberofConns
+
+org.openecomp.datatypes.SliceProfile:
+ derived_from: org.openecomp.datatypes.Root
+ properties:
+ sNSSAI:
+ type: string
+ required: true
+ description: sNSSAI
+ pLMNIdList:
+ type: string
+ required: true
+ description: pLMNIdList
+ maxNumberofUEs:
+ type: integer
+ required: true
+ default: 1000
+ description: maxNumberofUEs
+ latency:
+ type: integer
+ required: true
+ default: 30
+ description: latency
+ expDataRateDL:
+ type: integer
+ required: false
+ description: expDataRateDL
+ expDataRateUL:
+ type: integer
+ required: false
+ description: expDataRateUL
+ areaTrafficCapDL:
+ type: integer
+ required: false
+ description: areaTrafficCapDL
+ areaTrafficCapUL:
+ type: integer
+ required: false
+ description: areaTrafficCapUL
+ overallUserDensity:
+ type: integer
+ required: false
+ description: overallUserDensity
+ activityFactor:
+ type: integer
+ required: false
+ description: activityFactor
+ coverageAreaTAList:
+ type: string
+ required: false
+ description: coverageAreaTAList
+ uEMobilityLevel:
+ type: string
+ constraints:
+ - valid_values: ["stationary", "nomadic","restricted mobility","fully mobility"]
+ required: false
+ description: uEMobilityLevel
+ resourceSharingLevel:
+ type: string
+ required: true
+ default: "Shared"
+ constraints:
+ - valid_values: ["Shared", "Non-shared"]
+ description: resourceSharingLevel
+ sST:
+ type: string
+ required: true
+ default: "eMBB"
+ constraints:
+ - valid_values: ["eMBB", "uRLLC", "mIot"]
+ description: sST
+ cSAvailabilityTarget:
+ type: float
+ required: false
+ description: cSAvailabilityTarget
+ cSReliabilityMeanTime:
+ type: string
+ required: false
+ description: cSReliabilityMeanTime
+ expDataRate:
+ type: integer
+ required: false
+ description: expDataRate
+ msgSizeByte:
+ type: string
+ required: false
+ description: msgSizeByte
+ transferIntervalTarget:
+ type: string
+ required: false
+ description: transferIntervalTarget
+ survivalTime:
+ type: string
+ required: false
+ description: survivalTime
+ maxNumberofPDUSession:
+ type: integer
+ required: false
+ description: maxNumberofPDUSession
+
org.openecomp.datatypes.EcompHoming:
derived_from: org.openecomp.datatypes.Root
properties:
eight: bold } /* Keyword.Reserved */ .highlight .kt { color: #888888; font-weight: bold } /* Keyword.Type */ .highlight .m { color: #0000DD; font-weight: bold } /* Literal.Number */ .highlight .s { color: #dd2200; background-color: #fff0f0 } /* Literal.String */ .highlight .na { color: #336699 } /* Name.Attribute */ .highlight .nb { color: #003388 } /* Name.Builtin */ .highlight .nc { color: #bb0066; font-weight: bold } /* Name.Class */ .highlight .no { color: #003366; font-weight: bold } /* Name.Constant */ .highlight .nd { color: #555555 } /* Name.Decorator */ .highlight .ne { color: #bb0066; font-weight: bold } /* Name.Exception */ .highlight .nf { color: #0066bb; font-weight: bold } /* Name.Function */ .highlight .nl { color: #336699; font-style: italic } /* Name.Label */ .highlight .nn { color: #bb0066; font-weight: bold } /* Name.Namespace */ .highlight .py { color: #336699; font-weight: bold } /* Name.Property */ .highlight .nt { color: #bb0066; font-weight: bold } /* Name.Tag */ .highlight .nv { color: #336699 } /* Name.Variable */ .highlight .ow { color: #008800 } /* Operator.Word */ .highlight .w { color: #bbbbbb } /* Text.Whitespace */ .highlight .mb { color: #0000DD; font-weight: bold } /* Literal.Number.Bin */ .highlight .mf { color: #0000DD; font-weight: bold } /* Literal.Number.Float */ .highlight .mh { color: #0000DD; font-weight: bold } /* Literal.Number.Hex */ .highlight .mi { color: #0000DD; font-weight: bold } /* Literal.Number.Integer */ .highlight .mo { color: #0000DD; font-weight: bold } /* Literal.Number.Oct */ .highlight .sa { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Affix */ .highlight .sb { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Backtick */ .highlight .sc { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Char */ .highlight .dl { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Delimiter */ .highlight .sd { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Doc */ .highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */ .highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */ .highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */ .highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */ .highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */ .highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */ .highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */ .highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */ .highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */ .highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */ .highlight .vc { color: #336699 } /* Name.Variable.Class */ .highlight .vg { color: #dd7700 } /* Name.Variable.Global */ .highlight .vi { color: #3333bb } /* Name.Variable.Instance */ .highlight .vm { color: #336699 } /* Name.Variable.Magic */ .highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */ } 
/*-
 * ============LICENSE_START=======================================================
 * PROJECT
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. 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.
 * ============LICENSE_END=========================================================
 */

package org.onap.dcae.commonFunction;

import java.text.DecimalFormat;
import org.json.JSONArray;
import org.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ConfigProcessors {

	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");
	}



	private String evaluate(String str) {
		String value = str;
		if (str.startsWith("$")) {
			value = (String) getEventObjectVal(str.substring(1));

		}
		return value;
	}


	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");
	}


	private 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 (!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);
	}

	private 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");
	}


	private 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), "JArray");
				} 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 if (fieldType.equals("JArray"))
			((JSONArray) keySeriesObj).put(value);
		else
			((JSONObject) keySeriesObj).put(keySet[keySet.length - 1], value);

	}

	private JSONObject event = new JSONObject();
}