summaryrefslogtreecommitdiffstats
path: root/vfwsim/src
diff options
context:
space:
mode:
authorGao, Chenfei (cg287m) <cgao@research.att.com>2017-06-22 14:48:41 -0400
committerPamela Dragosh <pdragosh@research.att.com>2017-06-29 12:50:23 -0400
commit68377161605e39c8c74ea77d0b504177480788f3 (patch)
treefb0fb8a27178da607866e1850f73ac056e046ee8 /vfwsim/src
parentf0c29b57e132e6335f0fa7bbad885d403e4c85df (diff)
[POLICY-22] Reorganizing drools-apps
Change-Id: I5f9bb3908f8d55c466dd847ae5e01a424e9ba364 Signed-off-by: Gao, Chenfei (cg287m) <chenfei.gao11@gmail.com> Signed-off-by: Pamela Dragosh <pdragosh@research.att.com>
Diffstat (limited to 'vfwsim/src')
-rw-r--r--vfwsim/src/main/java/org/openecomp/policy/sim/vfw/AppcResponseEvent.java97
-rw-r--r--vfwsim/src/main/java/org/openecomp/policy/sim/vfw/OnsetEvent.java257
-rw-r--r--vfwsim/src/main/resources/META-INF/kmodule.xml27
-rw-r--r--vfwsim/src/main/resources/vFWsim.drl69
4 files changed, 0 insertions, 450 deletions
diff --git a/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/AppcResponseEvent.java b/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/AppcResponseEvent.java
deleted file mode 100644
index d135e79bc..000000000
--- a/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/AppcResponseEvent.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * vFW simulator
- * ================================================================================
- * 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.openecomp.policy.sim.vfw;
-
-import java.io.Serializable;
-import java.util.UUID;
-
-import org.openecomp.policy.appc.CommonHeader;
-import org.openecomp.policy.appc.Response;
-import org.openecomp.policy.appc.ResponseStatus;
-
-public class AppcResponseEvent implements Serializable {
-
- private static final long serialVersionUID = 6661836261200950007L;
-
- public final String requestID;
- public final String appcTopic;
- public final int code;
-
- public AppcResponseEvent(String requestID, String appcTopic, int code) {
- this.requestID = requestID;
- this.appcTopic = appcTopic;
- this.code = code;
- }
-
- @Override
- public int hashCode() {
- final int prime = 31;
- int result = 1;
- result = prime * result + ((appcTopic == null) ? 0 : appcTopic.hashCode());
- result = prime * result + code;
- result = prime * result + ((requestID == null) ? 0 : requestID.hashCode());
- return result;
- }
-
- @Override
- public boolean equals(Object obj) {
- if (this == obj)
- return true;
- if (obj == null)
- return false;
- if (getClass() != obj.getClass())
- return false;
- AppcResponseEvent other = (AppcResponseEvent) obj;
- if (appcTopic == null) {
- if (other.appcTopic != null)
- return false;
- } else if (!appcTopic.equals(other.appcTopic))
- return false;
- if (code != other.code)
- return false;
- if (requestID == null) {
- if (other.requestID != null)
- return false;
- } else if (!requestID.equals(other.requestID))
- return false;
- return true;
- }
-
- @Override
- public String toString() {
- return "AppcResponseEvent [requestID=" + requestID + ", appcTopic=" + appcTopic + ", code=" + code + "]";
- }
-
- public static Response toResponse(String requestId, int code) {
- Response response = new Response();
-
- CommonHeader commonHeader = new CommonHeader();
- commonHeader.RequestID = UUID.fromString(requestId);
- response.CommonHeader = commonHeader;
-
- ResponseStatus responseStatus = new ResponseStatus();
- responseStatus.Code = responseStatus.Code = code;
- response.Status = responseStatus;
-
- return response;
- }
-
-}
diff --git a/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/OnsetEvent.java b/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/OnsetEvent.java
deleted file mode 100644
index 5c371316e..000000000
--- a/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/OnsetEvent.java
+++ /dev/null
@@ -1,257 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * vFW simulator
- * ================================================================================
- * 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.openecomp.policy.sim.vfw;
-
-import java.io.Serializable;
-import java.time.Instant;
-import java.util.HashMap;
-import java.util.UUID;
-
-import org.openecomp.policy.controlloop.ControlLoopEventStatus;
-import org.openecomp.policy.controlloop.ControlLoopTargetType;
-import org.openecomp.policy.controlloop.VirtualControlLoopEvent;
-
-public class OnsetEvent implements Serializable {
-
- private static final long serialVersionUID = -7904064194557621526L;
-
- public static String DEFAULT_CLOSEDLOOP_CONTROL_NAME = "CL-FRWL-LOW-TRAFFIC-SIG-d925ed73-8231-4d02-9545-db4e101f88f8";
- public static String DEFAULT_CLOSEDLOOP_EVENT_CLIENT = "tca.instance00001";
- public static String DEFAULT_REQUEST_ID = "664be3d2-6c12-4f4b-a3e7-c349acced200";
- public static String DEFAULT_TARGET = "generic-vnf.vnf-id";
- public static String DEFAULT_TARGET_TYPE = "VF";
- public static String DEFAULT_FROM = "DCAE";
-
- public static String DEFAULT_AAI_VNF_ID_NAME = DEFAULT_TARGET;
- public static String DEFAULT_AAI_VNF_ID_VALUE = "fw0001vm001fw001";
-
- public static String DEFAULT_AAI_VSERVER_NAME = "vserver.vserver-name";
- public static String DEFAULT_AAI_VSERVER_VALUE = "vserver-name-16102016-aai3255-data-11-1";
-
- public String closedLoopControlName = DEFAULT_CLOSEDLOOP_CONTROL_NAME;
- public String closedLoopEventClient = DEFAULT_CLOSEDLOOP_EVENT_CLIENT;
- public String requestID = UUID.randomUUID().toString();
- public String target = DEFAULT_TARGET;
- public String targetType = DEFAULT_TARGET_TYPE;
- public String aaIVnfId = DEFAULT_AAI_VNF_ID_VALUE;
- public String aaIServerName = DEFAULT_AAI_VSERVER_VALUE;
- public String from = "DCAE";
-
- public String dcaeTopic = "DCAE-CL-EVENT";
- public String appcTopic = "APPC-CL";
- public int appcResponseCode = 100;
-
- public OnsetEvent() {
- super();
- }
-
- public OnsetEvent(String closedLoopControlName) {
- super();
-
- if (closedLoopControlName != null && !closedLoopControlName.isEmpty())
- this.closedLoopControlName = closedLoopControlName;
- }
-
- public OnsetEvent(String closedLoopControlName, String dcaeTopic, String appcTopic, int code) {
- super();
-
- if (closedLoopControlName != null && !closedLoopControlName.isEmpty())
- this.closedLoopControlName = closedLoopControlName;
-
- if (dcaeTopic != null && !dcaeTopic.isEmpty())
- this.dcaeTopic = dcaeTopic;
-
- if (appcTopic != null && !appcTopic.isEmpty())
- this.appcTopic = appcTopic;
-
- this.appcResponseCode = code;
- }
-
- public OnsetEvent(String closedLoopControlName, String requestID, String dcaeTopic, String appcTopic, int code) {
- super();
-
- if (closedLoopControlName != null && !closedLoopControlName.isEmpty())
- this.closedLoopControlName = closedLoopControlName;
-
- if (requestID != null)
- this.requestID = requestID;
-
- if (dcaeTopic != null && !dcaeTopic.isEmpty())
- this.dcaeTopic = dcaeTopic;
-
- if (appcTopic != null && !appcTopic.isEmpty())
- this.appcTopic = appcTopic;
-
- this.appcResponseCode = code;
- }
-
- public OnsetEvent(String closedLoopControlName, String closedLoopEventClient,
- String requestID, String target,
- String targetType, String aaIVnfId,
- String aaIServerName, String from,
- String dcaeTopic, String appcTopic,
- int code) {
- super();
-
- if (closedLoopControlName != null && !closedLoopControlName.isEmpty())
- this.closedLoopControlName = closedLoopControlName;
-
- if (closedLoopEventClient != null && !closedLoopEventClient.isEmpty())
- this.closedLoopEventClient = closedLoopEventClient;
-
- if (requestID != null)
- this.requestID = requestID;
-
- if (target != null && !target.isEmpty())
- this.target = target;
-
- if (targetType != null && !targetType.isEmpty())
- this.targetType = targetType;
-
- if (aaIVnfId != null && !aaIVnfId.isEmpty())
- this.aaIVnfId = aaIVnfId;
-
- if (aaIServerName != null && !aaIServerName.isEmpty())
- this.aaIServerName = aaIServerName;
-
- if (from != null && !from.isEmpty())
- this.from = from;
-
- if (dcaeTopic != null && !dcaeTopic.isEmpty())
- this.dcaeTopic = dcaeTopic;
-
- if (appcTopic != null && !appcTopic.isEmpty())
- this.appcTopic = appcTopic;
-
- this.appcResponseCode = code;
- }
-
- public VirtualControlLoopEvent toDcaeOnset() {
-
- VirtualControlLoopEvent onsetEvent = new VirtualControlLoopEvent();
-
- onsetEvent.closedLoopControlName = this.closedLoopControlName;
- onsetEvent.requestID = UUID.fromString(this.requestID);
- onsetEvent.closedLoopEventClient = this.closedLoopEventClient;
- onsetEvent.target_type = ControlLoopTargetType.valueOf(this.targetType);
- onsetEvent.target = this.target;
- onsetEvent.from = this.from;
- onsetEvent.closedLoopAlarmStart = Instant.now();
- onsetEvent.AAI = new HashMap<String, String>();
- onsetEvent.AAI.put(this.target, this.aaIVnfId);
- onsetEvent.AAI.put(DEFAULT_AAI_VSERVER_NAME, "vserver-name-16102016-aai3255-data-11-1");
- onsetEvent.closedLoopEventStatus = ControlLoopEventStatus.ONSET;
-
- return onsetEvent;
- }
-
- @Override
- public int hashCode() {
- final int prime = 31;
- int result = 1;
- result = prime * result + ((aaIServerName == null) ? 0 : aaIServerName.hashCode());
- result = prime * result + ((aaIVnfId == null) ? 0 : aaIVnfId.hashCode());
- result = prime * result + appcResponseCode;
- result = prime * result + ((appcTopic == null) ? 0 : appcTopic.hashCode());
- result = prime * result + ((closedLoopControlName == null) ? 0 : closedLoopControlName.hashCode());
- result = prime * result + ((closedLoopEventClient == null) ? 0 : closedLoopEventClient.hashCode());
- result = prime * result + ((dcaeTopic == null) ? 0 : dcaeTopic.hashCode());
- result = prime * result + ((from == null) ? 0 : from.hashCode());
- result = prime * result + ((requestID == null) ? 0 : requestID.hashCode());
- result = prime * result + ((target == null) ? 0 : target.hashCode());
- result = prime * result + ((targetType == null) ? 0 : targetType.hashCode());
- return result;
- }
-
- @Override
- public boolean equals(Object obj) {
- if (this == obj)
- return true;
- if (obj == null)
- return false;
- if (getClass() != obj.getClass())
- return false;
- OnsetEvent other = (OnsetEvent) obj;
- if (aaIServerName == null) {
- if (other.aaIServerName != null)
- return false;
- } else if (!aaIServerName.equals(other.aaIServerName))
- return false;
- if (aaIVnfId == null) {
- if (other.aaIVnfId != null)
- return false;
- } else if (!aaIVnfId.equals(other.aaIVnfId))
- return false;
- if (appcResponseCode != other.appcResponseCode)
- return false;
- if (appcTopic == null) {
- if (other.appcTopic != null)
- return false;
- } else if (!appcTopic.equals(other.appcTopic))
- return false;
- if (closedLoopControlName == null) {
- if (other.closedLoopControlName != null)
- return false;
- } else if (!closedLoopControlName.equals(other.closedLoopControlName))
- return false;
- if (closedLoopEventClient == null) {
- if (other.closedLoopEventClient != null)
- return false;
- } else if (!closedLoopEventClient.equals(other.closedLoopEventClient))
- return false;
- if (dcaeTopic == null) {
- if (other.dcaeTopic != null)
- return false;
- } else if (!dcaeTopic.equals(other.dcaeTopic))
- return false;
- if (from == null) {
- if (other.from != null)
- return false;
- } else if (!from.equals(other.from))
- return false;
- if (requestID == null) {
- if (other.requestID != null)
- return false;
- } else if (!requestID.equals(other.requestID))
- return false;
- if (target == null) {
- if (other.target != null)
- return false;
- } else if (!target.equals(other.target))
- return false;
- if (targetType == null) {
- if (other.targetType != null)
- return false;
- } else if (!targetType.equals(other.targetType))
- return false;
- return true;
- }
-
- @Override
- public String toString() {
- return "OnsetEvent [closedLoopControlName=" + closedLoopControlName + ", closedLoopEventClient="
- + closedLoopEventClient + ", requestID=" + requestID + ", target=" + target + ", targetType="
- + targetType + ", aaIVnfId=" + aaIVnfId + ", aaIServerName=" + aaIServerName + ", from=" + from
- + ", dcaeTopic=" + dcaeTopic + ", appcTopic=" + appcTopic + ", appcResponseCode=" + appcResponseCode
- + "]";
- }
-
-}
diff --git a/vfwsim/src/main/resources/META-INF/kmodule.xml b/vfwsim/src/main/resources/META-INF/kmodule.xml
deleted file mode 100644
index 0f1e22fef..000000000
--- a/vfwsim/src/main/resources/META-INF/kmodule.xml
+++ /dev/null
@@ -1,27 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ============LICENSE_START=======================================================
- vFW simulator
- ================================================================================
- 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=========================================================
- -->
-
-<kmodule xmlns="http://jboss.org/kie/6.0.0/kmodule">
- <kbase name="KBvFWsim">
- <ksession name="vFWsim"/>
- </kbase>
-</kmodule>
-
diff --git a/vfwsim/src/main/resources/vFWsim.drl b/vfwsim/src/main/resources/vFWsim.drl
deleted file mode 100644
index cb303b674..000000000
--- a/vfwsim/src/main/resources/vFWsim.drl
+++ /dev/null
@@ -1,69 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * vFW simulator
- * ================================================================================
- * 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.openecomp.policy.sim.vfw;
-
-import org.openecomp.policy.appc.Request;
-
-import org.openecomp.policy.controlloop.ControlLoopEventStatus;
-import org.openecomp.policy.controlloop.ControlLoopTargetType;
-import org.openecomp.policy.controlloop.VirtualControlLoopEvent;
-
-import org.openecomp.policy.drools.system.PolicyEngine;
-
-rule "vFWsim.ONSET"
-when
- $onset : OnsetEvent()
-then
- String WHERE = drools.getRule().getPackage() + "." + drools.getRule().getName();
-
- try {
- System.out.println(WHERE + ": " + "DCAE[ONSET|" + $onset.requestID + "|" +
- $onset.dcaeTopic + "] -> PDP-D" );
- PolicyEngine.manager.deliver($onset.dcaeTopic, $onset.toDcaeOnset());
- insert(new AppcResponseEvent($onset.requestID.toString(), $onset.appcTopic, $onset.appcResponseCode));
- } catch (Exception e) {
- e.printStackTrace();
- } finally {
- retract($onset);
- }
-end
-
-rule "vFWsim.APPC.RESPONSE"
-when
- $appcResponse : AppcResponseEvent( code > 0 )
- $request : Request( getCommonHeader().RequestID.toString() == $appcResponse.requestID )
-then
- String WHERE = drools.getRule().getPackage() + "." + drools.getRule().getName();
-
- try {
- System.out.println(WHERE + ": " + "APPC[" + $appcResponse.code + "|" + $appcResponse.requestID + "|" +
- $appcResponse.appcTopic + "] -> PDP-D" );
-
- PolicyEngine.manager.deliver($appcResponse.appcTopic,
- AppcResponseEvent.toResponse($appcResponse.requestID, $appcResponse.code));
- } catch (Exception e) {
- e.printStackTrace();
- } finally {
- retract($appcResponse);
- retract($request);
- }
-end