diff options
Diffstat (limited to 'vfwsim')
| -rw-r--r-- | vfwsim/pom.xml | 80 | ||||
| -rw-r--r-- | vfwsim/src/main/java/org/openecomp/policy/sim/vfw/AppcResponseEvent.java | 97 | ||||
| -rw-r--r-- | vfwsim/src/main/java/org/openecomp/policy/sim/vfw/OnsetEvent.java | 257 | ||||
| -rw-r--r-- | vfwsim/src/main/resources/META-INF/kmodule.xml | 27 | ||||
| -rw-r--r-- | vfwsim/src/main/resources/vFWsim.drl | 69 |
5 files changed, 530 insertions, 0 deletions
diff --git a/vfwsim/pom.xml b/vfwsim/pom.xml new file mode 100644 index 000000000..e95b6f761 --- /dev/null +++ b/vfwsim/pom.xml @@ -0,0 +1,80 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + ============LICENSE_START======================================================= + Drools PDP Application Models + ================================================================================ + 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========================================================= + --> + +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> + <modelVersion>4.0.0</modelVersion> + + <parent> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>drools-pdp-apps</artifactId> + <version>1.0.0-SNAPSHOT</version> + </parent> + + <artifactId>vfwsim</artifactId> + + <name>vFW simulator</name> + <description>Drools Application implementing vFW simulation</description> + + <properties> + <maven.compiler.source>1.8</maven.compiler.source> + <maven.compiler.target>1.8</maven.compiler.target> + </properties> + + <dependencies> + <dependency> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>demo</artifactId> + <version>1.0.0-SNAPSHOT</version> + </dependency> + <dependency> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>controlloop</artifactId> + <version>1.0.0-SNAPSHOT</version> + </dependency> + <dependency> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>rest</artifactId> + <version>1.0.0-SNAPSHOT</version> + </dependency> + <dependency> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>appc</artifactId> + <version>1.0.0-SNAPSHOT</version> + </dependency> + <dependency> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>aai</artifactId> + <version>1.0.0-SNAPSHOT</version> + </dependency> + <dependency> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>mso</artifactId> + <version>1.0.0-SNAPSHOT</version> + </dependency> + <dependency> + <groupId>org.openecomp.policy.drools-applications</groupId> + <artifactId>trafficgenerator</artifactId> + <version>1.0.0-SNAPSHOT</version> + </dependency> + </dependencies> +</project> + 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 new file mode 100644 index 000000000..d135e79bc --- /dev/null +++ b/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/AppcResponseEvent.java @@ -0,0 +1,97 @@ +/*- + * ============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 new file mode 100644 index 000000000..5c371316e --- /dev/null +++ b/vfwsim/src/main/java/org/openecomp/policy/sim/vfw/OnsetEvent.java @@ -0,0 +1,257 @@ +/*- + * ============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 new file mode 100644 index 000000000..0f1e22fef --- /dev/null +++ b/vfwsim/src/main/resources/META-INF/kmodule.xml @@ -0,0 +1,27 @@ +<?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 new file mode 100644 index 000000000..cb303b674 --- /dev/null +++ b/vfwsim/src/main/resources/vFWsim.drl @@ -0,0 +1,69 @@ +/*- + * ============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 |