diff options
Diffstat (limited to 'ncomp-sirius-manager-drools')
12 files changed, 998 insertions, 0 deletions
diff --git a/ncomp-sirius-manager-drools/.classpath b/ncomp-sirius-manager-drools/.classpath new file mode 100644 index 0000000..c220c0b --- /dev/null +++ b/ncomp-sirius-manager-drools/.classpath @@ -0,0 +1,27 @@ +<?xml version="1.0" encoding="UTF-8"?> +<classpath> + <classpathentry kind="src" output="target/classes" path="src/main/java"> + <attributes> + <attribute name="optional" value="true"/> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="src" output="target/test-classes" path="src/test/java"> + <attributes> + <attribute name="optional" value="true"/> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/> + <classpathentry kind="output" path="target/classes"/> +</classpath> diff --git a/ncomp-sirius-manager-drools/.gitignore b/ncomp-sirius-manager-drools/.gitignore new file mode 100644 index 0000000..b83d222 --- /dev/null +++ b/ncomp-sirius-manager-drools/.gitignore @@ -0,0 +1 @@ +/target/ diff --git a/ncomp-sirius-manager-drools/.project b/ncomp-sirius-manager-drools/.project new file mode 100644 index 0000000..7b6a8cf --- /dev/null +++ b/ncomp-sirius-manager-drools/.project @@ -0,0 +1,34 @@ +<?xml version="1.0" encoding="UTF-8"?> +<projectDescription> + <name>ncomp-sirius-manager-drools</name> + <comment></comment> + <projects> + </projects> + <buildSpec> + <buildCommand> + <name>org.eclipse.jdt.core.javabuilder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>org.eclipse.pde.ManifestBuilder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>org.eclipse.pde.SchemaBuilder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>org.eclipse.m2e.core.maven2Builder</name> + <arguments> + </arguments> + </buildCommand> + </buildSpec> + <natures> + <nature>org.eclipse.jdt.core.javanature</nature> + <nature>org.eclipse.m2e.core.maven2Nature</nature> + <nature>org.eclipse.pde.PluginNature</nature> + </natures> +</projectDescription> diff --git a/ncomp-sirius-manager-drools/.settings/org.eclipse.core.resources.prefs b/ncomp-sirius-manager-drools/.settings/org.eclipse.core.resources.prefs new file mode 100644 index 0000000..f9fe345 --- /dev/null +++ b/ncomp-sirius-manager-drools/.settings/org.eclipse.core.resources.prefs @@ -0,0 +1,4 @@ +eclipse.preferences.version=1 +encoding//src/main/java=UTF-8 +encoding//src/test/java=UTF-8 +encoding/<project>=UTF-8 diff --git a/ncomp-sirius-manager-drools/.settings/org.eclipse.jdt.core.prefs b/ncomp-sirius-manager-drools/.settings/org.eclipse.jdt.core.prefs new file mode 100644 index 0000000..443e085 --- /dev/null +++ b/ncomp-sirius-manager-drools/.settings/org.eclipse.jdt.core.prefs @@ -0,0 +1,8 @@ +eclipse.preferences.version=1 +org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled +org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7 +org.eclipse.jdt.core.compiler.compliance=1.7 +org.eclipse.jdt.core.compiler.problem.assertIdentifier=error +org.eclipse.jdt.core.compiler.problem.enumIdentifier=error +org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning +org.eclipse.jdt.core.compiler.source=1.7 diff --git a/ncomp-sirius-manager-drools/.settings/org.eclipse.m2e.core.prefs b/ncomp-sirius-manager-drools/.settings/org.eclipse.m2e.core.prefs new file mode 100644 index 0000000..f897a7f --- /dev/null +++ b/ncomp-sirius-manager-drools/.settings/org.eclipse.m2e.core.prefs @@ -0,0 +1,4 @@ +activeProfiles= +eclipse.preferences.version=1 +resolveWorkspaceProjects=true +version=1 diff --git a/ncomp-sirius-manager-drools/LICENSE.txt b/ncomp-sirius-manager-drools/LICENSE.txt new file mode 100644 index 0000000..30471b5 --- /dev/null +++ b/ncomp-sirius-manager-drools/LICENSE.txt @@ -0,0 +1,22 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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============================================ + */ + +ECOMP and OpenECOMP are trademarks and service marks of AT&T Intellectual Property. diff --git a/ncomp-sirius-manager-drools/META-INF/MANIFEST.MF b/ncomp-sirius-manager-drools/META-INF/MANIFEST.MF new file mode 100644 index 0000000..a80a85a --- /dev/null +++ b/ncomp-sirius-manager-drools/META-INF/MANIFEST.MF @@ -0,0 +1,8 @@ +Manifest-Version: 1.0 +Bundle-ManifestVersion: 2 +Bundle-Name: %pluginName +Bundle-SymbolicName: ncomp-sirius-manager-drools +Bundle-Version: 0.1.0.qualifier +Export-Package: org.openecomp.ncomp.sirius.manager.drools +Bundle-Vendor: %providerName +Bundle-RequiredExecutionEnvironment: JavaSE-1.7 diff --git a/ncomp-sirius-manager-drools/build.properties b/ncomp-sirius-manager-drools/build.properties new file mode 100644 index 0000000..a1ec8c4 --- /dev/null +++ b/ncomp-sirius-manager-drools/build.properties @@ -0,0 +1,3 @@ +source.. = src/main/java/ +bin.includes = META-INF/,\ + . diff --git a/ncomp-sirius-manager-drools/pom.xml b/ncomp-sirius-manager-drools/pom.xml new file mode 100644 index 0000000..86720c3 --- /dev/null +++ b/ncomp-sirius-manager-drools/pom.xml @@ -0,0 +1,148 @@ +<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> + <groupId>org.openecomp.ncomp.sirius.manager</groupId> + <artifactId>ncomp-sirius-manager-drools</artifactId> + <version>0.1.0-SNAPSHOT</version> + + <properties> + <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> + <maven.compiler.target>1.7</maven.compiler.target> + <maven.compiler.source>1.7</maven.compiler.source> + </properties> + + + <pluginRepositories> + <!-- Black Duck plugin dependencies --> + <pluginRepository> + <id>JCenter</id> + <name>JCenter Repository</name> + <url>http://jcenter.bintray.com</url> + </pluginRepository> + + <pluginRepository> + <id>Restlet</id> + <name>Restlet Repository</name> + <url>http://maven.restlet.com</url> + </pluginRepository> + </pluginRepositories> +<build> + <plugins> + <!-- blackduck maven plugin --> + <plugin> + <groupId>com.blackducksoftware.integration</groupId> + <artifactId>hub-maven-plugin</artifactId> + <version>1.4.0</version> + <inherited>false</inherited> + <configuration> + <hubProjectName>${project.name}</hubProjectName> + <outputDirectory>${project.basedir}</outputDirectory> + </configuration> + <executions> + <execution> + <id>create-bdio-file</id> + <phase>package</phase> + <goals> + <goal>createHubOutput</goal> + </goals> + </execution> + </executions> + </plugin> + <!-- site maven plugin --> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-site-plugin</artifactId> + <version>3.6</version> + <dependencies> + <dependency> + <groupId>org.apache.maven.wagon</groupId> + <artifactId>wagon-webdav-jackrabbit</artifactId> + <version>2.10</version> + </dependency> + </dependencies> + </plugin> + + <plugin> + <artifactId>maven-compiler-plugin</artifactId> + <version>3.1</version> + <configuration> + <source /> + <target /> + </configuration> + </plugin> + </plugins> + </build> + + <dependencies> + <dependency> + <groupId>log4j</groupId> + <artifactId>log4j</artifactId> + <version>1.2.17</version> + </dependency> + <dependency> + <groupId>org.eclipse.emf</groupId> + <artifactId>org.eclipse.emf.ecore</artifactId> + <version>2.11.0-v20150123-0347</version> + </dependency> + <dependency> + <groupId>org.eclipse.emf</groupId> + <artifactId>org.eclipse.emf.common</artifactId> + <version>2.11.0-v20150123-0347</version> + </dependency> + <dependency> + <groupId>org.eclipse.xtext</groupId> + <artifactId>org.eclipse.xtext.xbase.lib</artifactId> + <version>2.8.2</version> + </dependency> + <dependency> + <groupId>org.kie</groupId> + <artifactId>kie-api</artifactId> + <version>6.3.0.Final</version> + </dependency> + <dependency> + <groupId>org.drools</groupId> + <artifactId>drools-core</artifactId> + <version>6.3.0.Final</version> + </dependency> + </dependencies> + + + <distributionManagement> + <repository> + <id>osecomp-nexus-releases</id> + <name>OSECOMP Release Repository</name> + <url>${openecomp.nexus.releases}</url> + </repository> + <snapshotRepository> + <id>osecomp-nexus-snapshots</id> + <name>OSECOMP Snapshot Repository</name> + <url>${openecomp.nexus.snapshots}</url> + </snapshotRepository> + <site> + <id>dcae-javadoc</id> + <url>${site.urlroot}/${project.artifactId}/${project.version}/</url> + </site> + </distributionManagement> + + <reporting> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-javadoc-plugin</artifactId> + <version>2.10.4</version> + <configuration> + <failOnError>false</failOnError> + <doclet>org.umlgraph.doclet.UmlGraphDoc</doclet> + <docletArtifact> + <groupId>org.umlgraph</groupId> + <artifactId>umlgraph</artifactId> + <version>5.6</version> + </docletArtifact> + <additionalparam>-views</additionalparam> + <useStandardDocletOptions>true</useStandardDocletOptions> + </configuration> + </plugin> + </plugins> + </reporting> + + +</project> diff --git a/ncomp-sirius-manager-drools/src/main/java/org/openecomp/ncomp/sirius/manager/drools/DroolsEventListener.java b/ncomp-sirius-manager-drools/src/main/java/org/openecomp/ncomp/sirius/manager/drools/DroolsEventListener.java new file mode 100644 index 0000000..d542573 --- /dev/null +++ b/ncomp-sirius-manager-drools/src/main/java/org/openecomp/ncomp/sirius/manager/drools/DroolsEventListener.java @@ -0,0 +1,29 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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.ncomp.sirius.manager.drools; + +public interface DroolsEventListener { + public void recordPolicyFire(String ruleName); + public void recordPolicyObjectInserted(Object o); + public void recordPolicyObjectDeleted(Object o); + public void recordPolicyObjectUpdated(Object o); +} diff --git a/ncomp-sirius-manager-drools/src/main/java/org/openecomp/ncomp/sirius/manager/drools/DroolsRuntime.java b/ncomp-sirius-manager-drools/src/main/java/org/openecomp/ncomp/sirius/manager/drools/DroolsRuntime.java new file mode 100644 index 0000000..7b4ce13 --- /dev/null +++ b/ncomp-sirius-manager-drools/src/main/java/org/openecomp/ncomp/sirius/manager/drools/DroolsRuntime.java @@ -0,0 +1,710 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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============================================ + */ + +/* + * Copyright 2010 JBoss Inc + * + * 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. + */ + +package org.openecomp.ncomp.sirius.manager.drools; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map.Entry; +import java.util.concurrent.TimeUnit; + +import org.apache.log4j.Logger; +import org.eclipse.emf.common.util.EList; +import org.eclipse.emf.ecore.EAttribute; +import org.eclipse.emf.ecore.EObject; +import org.eclipse.emf.ecore.EReference; +import org.eclipse.emf.ecore.EStructuralFeature; +import org.eclipse.emf.common.notify.Notification; +import org.eclipse.emf.ecore.util.EContentAdapter; +import org.kie.api.KieServices; +import org.kie.api.runtime.KieSession; +import org.kie.api.runtime.KieContainer; +import org.kie.api.runtime.rule.FactHandle; +import org.kie.api.runtime.rule.Match; +import org.kie.api.time.SessionClock; +import org.kie.api.logger.KieRuntimeLogger; +import org.kie.api.builder.KieScanner; +import org.kie.api.builder.ReleaseId; +//import org.kie.api.event.process.ProcessCompletedEvent; +//import org.kie.api.event.process.ProcessEventListener; +//import org.kie.api.event.process.ProcessNodeLeftEvent; +//import org.kie.api.event.process.ProcessNodeTriggeredEvent; +//import org.kie.api.event.process.ProcessStartedEvent; +//import org.kie.api.event.process.ProcessVariableChangedEvent; +import org.kie.api.event.rule.AfterMatchFiredEvent; +import org.kie.api.event.rule.AgendaEventListener; +//import java.util.Calendar; +//import org.kie.api.event.KieRuntimeEventManager; +//import org.kie.api.event.rule.DebugAgendaEventListener; +//import org.kie.api.event.rule.DebugRuleRuntimeEventListener; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; +import org.kie.api.event.rule.AgendaGroupPoppedEvent; +import org.kie.api.event.rule.AgendaGroupPushedEvent; +import org.kie.api.event.rule.BeforeMatchFiredEvent; +import org.kie.api.event.rule.MatchCancelledEvent; +import org.kie.api.event.rule.MatchCreatedEvent; +import org.kie.api.event.rule.ObjectDeletedEvent; +import org.kie.api.event.rule.ObjectInsertedEvent; +import org.kie.api.event.rule.ObjectUpdatedEvent; +import org.kie.api.event.rule.RuleFlowGroupActivatedEvent; +import org.kie.api.event.rule.RuleFlowGroupDeactivatedEvent; +import org.kie.api.event.rule.RuleRuntimeEventListener; + +public class DroolsRuntime { + private static final Logger logger = Logger.getLogger(DroolsRuntime.class); + private static final Logger logevents = Logger.getLogger("org.openecomp.ncomp.sirius.manager.drools.events"); + + private final KieServices ks; + private final ReleaseId releaseId; + private final KieContainer kContainer; + private final KieScanner kieScanner; + private KieRuntimeLogger kLogger; + private KieSession kSession; + private final ArrayList<EObject> rootList; + private final HashMap<Object,FactHandle> factmap; + private final HashMap<String,Object> globalmap; + private long fireInterval = 1000L; + private Thread fireThread = null; + + private final DroolsEventListener listener; + + // copied from org.openecomp.ncomp.sirius.manager.ManagementServer + // except didn't use artificial id counter for final return case + private static String ecoreId(EObject oo) { + EStructuralFeature f = oo.eClass().getEStructuralFeature("name"); + if (f instanceof EAttribute) { + EAttribute attr = (EAttribute) f; + return (String) oo.eGet(attr); + } + if (oo.eContainer() != null) { + if (oo.eContainmentFeature().isMany()) { + @SuppressWarnings("unchecked") + EList<EObject> l = (EList<EObject>) oo.eContainer().eGet(oo.eContainmentFeature()); + return Integer.toString(l.indexOf(oo)); + } else { + return oo.eContainmentFeature().getName(); + } + } +// WAS return "id" + id++; + return "idXXXXXX"; + } + + // copied from org.openecomp.ncomp.sirius.manager.ManagementServer + private static String object2ref(EObject oo) { + if (oo.eContainer() == null) { + return ""; + } + EReference ref = (EReference) oo.eContainingFeature(); + StringBuffer b = new StringBuffer(); + b.append(object2ref(oo.eContainer())); + b.append("/"); + b.append(ref.getName()); + if (ref.isMany()) { + b.append("/"); + b.append(ecoreId(oo)); + } + return b.toString(); + } + + private static String describeObject (Object o) { + if (o instanceof EObject) { + try { + String s = object2ref((EObject) o); + if (s != "") return s; + } catch (Exception e) { + } + } + return "object:" + o.getClass().getName(); + } + + private static String describeObject (Object parent, Object o) { + StringBuffer b = new StringBuffer(); + b.append(object2ref((EObject)parent)); + b.append("/"); + if (o instanceof EObject) { + EObject oo = (EObject) o; + EReference ref = (EReference) oo.eContainingFeature(); + if (ref == null) { + b.append("NullRef"); + } else { + b.append(ref.getName()); + if (ref.isMany()) { + b.append("/"); + b.append(ecoreId(oo)); + } + } + } else { + b.append("child"); + } + return b.toString(); + } + + private static String describeFact (FactHandle f) { + String s = f.toExternalForm(); + int i = s.indexOf(' '); + if (i >= 0) return s.substring(0,i-1); + else return s; + } + + private class DroolsAgendaListener implements AgendaEventListener { + private void logMatch (Logger log, String label, Match m) { + log.info(label + ": rule " + m.getRule().getName()); + for (int i=0; i<m.getDeclarationIds().size(); ++i) { + log.info(label + ": declaration " + m.getDeclarationIds().get(i) + + " fact " + describeFact(m.getFactHandles().get(i)) + + " object " + describeObject(m.getObjects().get(i))); + } +// for (String d : m.getDeclarationIds()) { +// log.info(label + ": declaration " + d + " value " + describeObject(m.getDeclarationValue(d))); +// } +// for (FactHandle f : m.getFactHandles()) { +// log.info(label + ": fact " + f.toExternalForm()); +// } +// for (Object o : m.getObjects()) { +// log.info(label + ": object " + o.toString()); +// } +// log.info(label + ": match " + m.toString()); + } + + @Override + public void afterMatchFired(AfterMatchFiredEvent e) { + logMatch(logevents,"agenda afterMatchFired", e.getMatch()); + if (listener != null) + listener.recordPolicyFire(e.getMatch().getRule().getName()); + } + + @Override + public void afterRuleFlowGroupActivated(RuleFlowGroupActivatedEvent e) { + logevents.info("agenda afterRuleFlowGroupActivated: " + e.getRuleFlowGroup().getName()); + } + + @Override + public void afterRuleFlowGroupDeactivated(RuleFlowGroupDeactivatedEvent e) { + logevents.info("agenda afterRuleFlowGroupDeactivated: " + e.getRuleFlowGroup().getName()); + } + + @Override + public void agendaGroupPopped(AgendaGroupPoppedEvent e) { + logevents.info("agenda agendaGroupPopped: " + e.getAgendaGroup().getName()); + } + + @Override + public void agendaGroupPushed(AgendaGroupPushedEvent e) { + logevents.info("agenda agendaGroupPushed: " + e.getAgendaGroup().getName()); + } + + @Override + public void beforeMatchFired(BeforeMatchFiredEvent e) { + logMatch(logevents,"agenda beforeMatchFired:", e.getMatch()); + } + + @Override + public void beforeRuleFlowGroupActivated(RuleFlowGroupActivatedEvent e) { + logevents.info("agenda beforeRuleFlowGroupActivated: " + e.getRuleFlowGroup().getName()); + } + + @Override + public void beforeRuleFlowGroupDeactivated(RuleFlowGroupDeactivatedEvent e) { + logevents.info("agenda beforeRuleFlowGroupDeactivated: " + e.getRuleFlowGroup().getName()); + } + + @Override + public void matchCancelled(MatchCancelledEvent e) { + logMatch(logevents,"agenda matchCancelled", e.getMatch()); + logevents.info("agenda matchCancelled: cause " + e.getCause().toString()); + } + + @Override + public void matchCreated(MatchCreatedEvent e) { + logMatch(logevents,"agenda matchCreated", e.getMatch()); + } + } + + private class DroolsRuntimeListener implements RuleRuntimeEventListener { + @Override + public void objectDeleted(ObjectDeletedEvent e) { + logevents.info("runtime objectDeleted: fact " + describeFact(e.getFactHandle()) + " o " + describeObject(e.getOldObject())); + if (e.getRule() != null) logevents.info("runtime objectDeleted: by rule " + e.getRule().getName()); + if (listener != null) + listener.recordPolicyObjectDeleted(e.getOldObject()); + } + + @Override + public void objectInserted(ObjectInsertedEvent e) { + logevents.info("runtime objectInserted: fact " + describeFact(e.getFactHandle()) + + " o " + describeObject(e.getObject()) + + " time " + getCurrentTime()); + if (e.getRule() != null) logevents.info("runtime objectInserted: by rule " + e.getRule().getName()); + if (listener != null) + listener.recordPolicyObjectInserted(e.getObject()); + } + + @Override + public void objectUpdated(ObjectUpdatedEvent e) { + logevents.info("runtime objectUpdated: fact " + describeFact(e.getFactHandle()) + " o " + describeObject(e.getObject())); + if (e.getRule() != null) logevents.info("runtime objectUpdated: by rule " + e.getRule().getName()); + if (listener != null) + listener.recordPolicyObjectUpdated(e.getObject()); + } + } + +// private class DroolsProcessListener implements ProcessEventListener { +// @Override +// public void afterNodeLeft(ProcessNodeLeftEvent e) { +// logevents.info("process afterNodeLeft: " + e.toString()); +// } +// +// @Override +// public void afterNodeTriggered(ProcessNodeTriggeredEvent e) { +// logevents.info("process afterNodeTriggered: " + e.toString()); +// } +// +// @Override +// public void afterProcessCompleted(ProcessCompletedEvent e) { +// logevents.info("process afterProcessCompleted: " + e.toString()); +// } +// +// @Override +// public void afterProcessStarted(ProcessStartedEvent e) { +// logevents.info("process afterProcessStarted: " + e.toString()); +// } +// +// @Override +// public void afterVariableChanged(ProcessVariableChangedEvent e) { +// logevents.info("process afterVariableChanged: " + e.toString()); +// } +// +// @Override +// public void beforeNodeLeft(ProcessNodeLeftEvent e) { +// logevents.info("process beforeNodeLeft: " + e.toString()); +// } +// +// @Override +// public void beforeNodeTriggered(ProcessNodeTriggeredEvent e) { +// logevents.info("process beforeNodeTriggered: " + e.toString()); +// } +// +// @Override +// public void beforeProcessCompleted(ProcessCompletedEvent e) { +// logevents.info("process beforeProcessCompleted: " + e.toString()); +// } +// +// @Override +// public void beforeProcessStarted(ProcessStartedEvent e) { +// logevents.info("process beforeProcessStarted: " + e.toString()); +// } +// +// @Override +// public void beforeVariableChanged(ProcessVariableChangedEvent e) { +// logevents.info("process beforeVariableChanged: " + e.toString()); +// } +// } + + private class UpdateDroolsContentAdapter extends EContentAdapter { + public void notifyChanged(Notification n) { + super.notifyChanged(n); // the superclass handles adding/removing this Adapter to children + logger.debug("received change notification, type " + n.getEventType() + ": " + n.toString()); +// logger.info("notification feature: " + (n.getFeature() == null ? "NULL" : n.getFeature().toString()) + " notifier: " + (n.getNotifier() == null ? "NULL" : n.getNotifier().toString())); + if (kSession == null) return; + switch (n.getEventType()) { + case Notification.ADD: { + Object o = n.getFeature(); + if (o instanceof EReference) { + EReference er = (EReference) o; + if (er.isMany()) { + @SuppressWarnings("rawtypes") + EList l = (EList) ((EObject) n.getNotifier()).eGet(er); + Object o2 = l.get(n.getPosition()); + logger.debug("inserting (1) into kSession: " + describeObject(o2)); + FactHandle fh = kSession.insert(o2); + factmap.put (o2, fh); + } else { + Object o2 = ((EObject) n.getNotifier()).eGet(er); + logger.debug("inserting (2) into kSession: " + describeObject(o2)); + FactHandle fh = kSession.insert(o2); + factmap.put (o2, fh); + } + } else { + logger.debug("inserting (3) into kSession: " + describeObject(o)); + FactHandle fh = kSession.insert(o); + factmap.put (o, fh); + } + break; + } + case Notification.REMOVE_MANY: { + Object o = n.getFeature(); + if (!(o instanceof EReference)) { + logger.error("remove_many, but feature is not EReference"); + return; + } + EReference er = (EReference) o; + if (!er.isMany()) { + logger.error("remove_many, but reference is not many"); + return; + } + @SuppressWarnings("unchecked") + List<Object> l = (List<Object>) n.getOldValue(); + int[] positions = (int []) n.getNewValue(); + for (int i=0; i<positions.length; ++i) { + Object o2 = l.get(positions[i]); + logger.debug("removing (4) from kSession: " + describeObject(n.getNotifier(),o2)); + FactHandle fh = factmap.get(o2); + if (fh == null) { + logger.error ("remove, but no FactHandle for kSession object " + describeObject(n.getNotifier(),o2)); + continue; + } + kSession.delete(fh); + factmap.remove(o); + } + break; + } + case Notification.REMOVE: { +// Object o = n.getFeature(); +// if (o instanceof EReference) { +// EReference er = (EReference) o; +// if (er.isMany()) { +// @SuppressWarnings("rawtypes") +// EList l = (EList) ((EObject) n.getNotifier()).eGet(er); +// logger.info("removing (1) position " + n.getPosition() + " list size " + l.size()); +// Object o2 = l.get(n.getPosition()); +// logger.info("removing (1) from kSession: " + describeObject(o2)); +// FactHandle fh = factmap.get(o2); +// if (fh == null) { +// logger.error ("remove, but no FactHandle for kSession object " + describeObject(o2)); +// return; +// } +// kSession.delete(fh); +// factmap.remove(o); +// } else { +// Object o2 = ((EObject) n.getNotifier()).eGet(er); +// logger.info("removing (2) from kSession: " + describeObject(o2)); +// FactHandle fh = factmap.get(o2); +// if (fh == null) { +// logger.error ("remove, but no FactHandle for kSession object " + describeObject(o2)); +// return; +// } +// kSession.delete(fh); +// factmap.remove(o); +// } +// } else { +// logger.info("removing (3) from kSession: " + describeObject(o)); +// FactHandle fh = factmap.get(o); +// if (fh == null) { +// logger.error ("remove, but no FactHandle for kSession object " + describeObject(o)); +// return; +// } +// kSession.delete(fh); +// factmap.remove(o); +// } + Object o = n.getOldValue(); + logger.debug("removing (5) from kSession: " + describeObject(o)); + FactHandle fh = factmap.get(o); + if (fh == null) { + logger.error ("remove, but no FactHandle for kSession object " + describeObject(o)); + return; + } + kSession.delete(fh); + factmap.remove(o); + break; + } + case Notification.SET: + case Notification.UNSET: { + Object o = n.getNotifier(); + logger.debug("updating in kSession: " + describeObject(o)); + Object f = n.getFeature(); + if (f instanceof EReference) { + EReference er = (EReference) f; + if (er.isContainer() && n.getNewValue() == null) { + logger.debug("changing container to null, ignoring update"); + return; + } + } + FactHandle fh = factmap.get(o); + if (fh == null) { + logger.debug ("update, but no FactHandle for kSession object " + describeObject(o)); + return; + } + kSession.update(fh, o); + break; + } + case Notification.REMOVING_ADAPTER: + // no action seems to be needed + break; + default: { + logger.warn("received change notification, unknown event type " + n.getEventType() + ": " + n.toString()); + break; + } + } + } + } + + public DroolsRuntime (long fireInterval, String groupId, String artifactId, String version, + DroolsEventListener listener) { + this.listener = listener; + + // Load up the knowledge base. + // Interface from where it possible to access all the Kie building and runtime facilities: + ks = KieServices.Factory.get(); + + // KieContainer reads the files to be built from the classpath. In this way all the Java + // sources and the Kie resources are compiled and deployed into the KieContainer which makes + // its contents available for use at runtime. + //KieContainer kContainer = ks.getKieClasspathContainer(); + releaseId = ks.newReleaseId( groupId, artifactId, version ); + kContainer = ks.newKieContainer(releaseId); + + // If the KieScanner finds in the Maven repository an updated version of the Kie project used + // by that KieContainer it automatically downloads the new version and triggers an incremental + // build of the new project. From this moment all the new KieBases and KieSessions created from + // that KieContainer will use the new project version. + kieScanner = ks.newKieScanner(kContainer); + logger.debug("got kieScanner, class " + kieScanner.getClass().getName()); + + kSession = null; + kLogger = null; + + rootList = new ArrayList<EObject>(); + factmap = new HashMap<Object,FactHandle>(); + globalmap = new HashMap<String,Object>(); + + this.fireInterval = fireInterval; + } + + public void addObjectTree (EObject o) { + o.eAdapters().add(new UpdateDroolsContentAdapter()); + rootList.add(o); + if (kSession != null) { + insertRecursively (o); + } + } + + public void addEvents(EList<? extends EObject> l) { + for (EObject o : l) { + addEvent(o); + } + } + + public void addEvent (EObject o) { + logger.debug("inserting event into kSession: " + describeObject(o)); + logger.debug("insert event class: " + o.getClass()); + try { + kSession.insert(o); + } catch (Exception e) { + logger.error("kSession insert failed inserting " + o.toString(), e); + } + } + + public void setGlobal (String s, Object o) { + globalmap.put(s, o); + } + + private void insertRecursively (EObject o) { + logger.debug("inserting (recursively) into kSession: " + describeObject(o)); + FactHandle fh = kSession.insert(o); + factmap.put (o, fh); + for (EReference ref : o.eClass().getEAllContainments()) { + if (ref.isMany()) { + @SuppressWarnings("unchecked") + EList<EObject> l = (EList<EObject>) o.eGet(ref); + for (EObject o1 : l) { + insertRecursively(o1); + } + } else { + EObject o1 = (EObject) o.eGet(ref); + if (o1 != null) + insertRecursively(o1); + } + } + } + + public void startSession() { + logger.info("starting kie session"); +// specifying TimedRuleExectionOption here appears to override any values from kmodules.xml +// KieSessionConfiguration ksconf = ks.newKieSessionConfiguration(); +// ksconf.setOption(TimedRuleExectionOption.YES); +// kSession = kContainer.newKieSession("ksession-rules", ksconf); + kSession = kContainer.newKieSession("ksession-rules"); + if (kSession == null) logger.error("Unable to start kie session"); + kSession.addEventListener (new DroolsAgendaListener() ); + kSession.addEventListener (new DroolsRuntimeListener() ); +// kSession.addEventListener (new DroolsProcessListener() ); + //logger = KieServices.Factory.get().getLoggers().newConsoleLogger(kSession); + //kLogger = ks.getLoggers().newFileLogger( kSession, "./logs/audit" ); + + for (Entry<String,Object> e : globalmap.entrySet()) { + try { + kSession.setGlobal(e.getKey(), e.getValue()); + } catch (RuntimeException re) { + logger.warn("Unable to set global " + e.getKey() + ": " + re.getMessage()); + } + } + + for (EObject o : rootList) { + insertRecursively (o); + } + + fireThread = new Thread("rule-firing-thread") { + public void run() { + while (!isInterrupted()) { + logger.debug("firing all rules..."); + try { +// fireAllRules(); + fireUntilHalt(); + } catch (Exception e) { + logger.error("fireAllRules() threw exception", e); + } + + try { + Thread.sleep(fireInterval); + } catch(InterruptedException ex) { + logger.info("rule firing thread interruped"); + Thread.currentThread().interrupt(); + } + } + logger.info("rule firing thread returning"); + } + }; + fireThread.start(); + } + + public void stopSession() { + logger.info("stopping session"); + logger.info("stopping rule firing thread"); + fireThread.interrupt(); + try { + fireThread.join(); + } catch (InterruptedException e) { + logger.warn("Interruped while waiting for fireThread.join()"); + Thread.currentThread().interrupt(); + } + fireThread = null; + if (kSession != null) kSession.dispose(); + if (kLogger != null) kLogger.close(); + kSession = null; + kLogger = null; + factmap.clear(); + } + + public void startScanner (long interval) { + kieScanner.start (interval); + } + public void doScan () { + kieScanner.scanNow (); + } + public void stopScanner () { + kieScanner.stop (); + } + + public void renewSession () { + stopSession(); + startSession(); + } + + public void fireAllRules() { + if (kSession != null) + kSession.fireAllRules(); + } + + public void fireUntilHalt() { + if (kSession != null) { + kSession.fireUntilHalt(); + } else { + logger.warn("fireUntilHalt but null kSession"); + } + } + + public long getCurrentTime() { + return kSession.getSessionClock().getCurrentTime(); + } + + public long advanceTime(long delta, TimeUnit unit) { + SessionClock clock = kSession.getSessionClock(); +// if (kSession.getSessionConfiguration().getOption(ClockTypeOption.class).getClockType() == "pseudo") { +// org.drools.core.time.SessionPseudoClock clock = kSession.getSessionClock(); +// clock.advanceTime(delta, unit); +// } + if (clock instanceof org.drools.core.time.SessionPseudoClock) { + ((org.drools.core.time.SessionPseudoClock) clock).advanceTime(delta, unit); + } else { + logger.error("Attempted to advanceTime, but session clock is not pesudoclock"); + } + return clock.getCurrentTime(); + } + + +// public static void main(String[] args) throws Exception { +// ServiceController s = ServiceFactory.eINSTANCE.createServiceController(); +// +// Enodeb e = ServiceFactory.eINSTANCE.createEnodeb(); +// s.getENodeBs().add(e); +// e.setGain1("foo"); +// Enodeb e2 = ServiceFactory.eINSTANCE.createEnodeb(); +// s.getENodeBs().add(e2); +// e2.setGain1("foo"); +// +// DroolsRuntime drools = new DroolsRuntime (1000L, "org.openecomp.ncomp.test", "pol", "1.1.1-SNAPSHOT"); +// +// drools.addObjectTree(s); +// +// // Start the KieScanner polling the Maven repository every 10 seconds +// drools.startScanner( 10000L ); +// +// drools.startSession(); +// +// EnodebTcpLossAnomalyList anomalylist = ServiceFactory.eINSTANCE.createEnodebTcpLossAnomalyList(); +// drools.addObjectTree(anomalylist); +// EnodebTcpLossAnomaly a = ServiceFactory.eINSTANCE.createEnodebTcpLossAnomaly(); +// a.setNewEvent(true); +// Date d = new Date(); +// a.setStartTime(new Date(d.getTime() - 30000)); +// a.setEndTime(d); +// anomalylist.getAnomalies().add(a); +// +// while (true) { +// drools.fireAllRules(); +// +// try { +// Thread.sleep(10000L); // In milliseconds for looping. +// } catch(InterruptedException ex) { +// Thread.currentThread().interrupt(); +// } +// drools.renewSession(); +// } +// } +} |