NTA-89: Add a keyword filter

core/src/main/java/io/narayana/nta/Configuration.java

@@ -23,6 +23,7 @@
 package io.narayana.nta;
 
 import io.narayana.nta.logparsing.as8.filters.PackageFilter;
+import io.narayana.nta.logparsing.as8.filters.KeywordFilter;
 import io.narayana.nta.logparsing.as8.handlers.*;
 
 import java.io.File;
@@ -80,6 +81,7 @@ public final class Configuration {
 
     public static final Class[] LOG_FILTERS = new Class[]{
             PackageFilter.class,
+            KeywordFilter.class,
     };
 
     /**

core/src/main/java/io/narayana/nta/logparsing/as8/filters/GetFilterKeywords.java

@@ -0,0 +1,45 @@
+package io.narayana.nta.logparsing.as8.filters;
+
+import org.apache.log4j.Logger;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+public class GetFilterKeywords {
+    private String filterKeywords;
+    private static final Logger logger = Logger.getLogger(GetFilterKeywords.class.getName());
+
+    private static class GetFilterKeywordsHolder {
+        private static final GetFilterKeywords INSTANCE = new GetFilterKeywords();
+    }
+
+    public static final GetFilterKeywords getInstance() {
+        return GetFilterKeywordsHolder.INSTANCE;
+    }
+
+    private GetFilterKeywords() {
+        try {
+            InputStream in;
+            Properties prop = new Properties();
+
+            String propFileName = "filter.properties";
+            in = getClass().getClassLoader().getResourceAsStream(File.separator + propFileName);
+            if (in != null) {
+                prop.load(in);
+                filterKeywords = prop.getProperty("keywords");
+                in.close();
+            } else {
+                logger.error("Oops: the " + propFileName + " file does not exist!", new FileNotFoundException(propFileName + "not found!"));
+            }
+        } catch (IOException ex) {
+            logger.error("the filter keyword list init error!", ex);
+        }
+    }
+
+    public String getFilterKeywords() {
+        return filterKeywords;
+    }
+}

core/src/main/java/io/narayana/nta/logparsing/as8/filters/KeywordFilter.java

@@ -0,0 +1,48 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2016, Red Hat, Inc., and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package io.narayana.nta.logparsing.as8.filters;
+
+import io.narayana.nta.logparsing.common.Filter;
+
+/**
+ * @author huyuan
+ */
+public class KeywordFilter implements Filter {
+
+    @Override
+    public boolean matches(String line) throws IndexOutOfBoundsException {
+        String keywordList = GetFilterKeywords.getInstance().getFilterKeywords();
+        if (keywordList != null) {
+            if ("".equals(keywordList))
+                return true;
+        } else {
+            return true;
+        }
+        String[] keywords = keywordList.split(",");
+        for (String keyword : keywords) {
+            if (line.contains(keyword))
+                return true;
+        }
+        return false;
+    }
+}

core/src/main/resources/filter.properties

@@ -0,0 +1,2 @@
+keywords=TransactionImple,Periodic Recovery,TransactionSynchronizationRegistryImple
+

core/src/test/java/io/narayana/nta/test/CentralisedAS8IntegrationTest.java

@@ -76,6 +76,7 @@ public static WebArchive createDeployment() {
                 .addAsWebInfResource(new FileAsset(new File("src/test/resources/persistence.xml")),
                         "classes/META-INF/persistence.xml")
                 .addAsManifestResource(new FileAsset(new File("src/test/resources/nta-test-ds.xml")), "nta-test-ds.xml")
+                .addAsManifestResource("filter.properties")
                         //.addAsManifestResource(new FileAsset(new File("src/test/resources/nta-test-mysql-ds.xml")), "nta-test-mysql-ds.xml")
                 .addAsLibraries(libs)
                 .setManifest(new StringAsset(ManifestMF));

core/src/test/java/io/narayana/nta/test/GenericDAOTest.java

@@ -63,6 +63,7 @@ public static WebArchive createDeployment() {
                 .addAsWebInfResource(new FileAsset(new File("src/test/resources/persistence.xml")),
                         "classes/META-INF/persistence.xml")
                 .addAsManifestResource(new FileAsset(new File("src/test/resources/nta-test-ds.xml")), "nta-test-ds.xml")
+                .addAsManifestResource("filter.properties")
                 .setManifest(new StringAsset(ManifestMF));
     }
 

core/src/test/java/io/narayana/nta/test/HandlerServiceTest.java

@@ -79,6 +79,7 @@ public static WebArchive createDeployment() {
                 .addAsWebInfResource(new FileAsset(new File("src/test/resources/persistence.xml")),
                         "classes/META-INF/persistence.xml")
                 .addAsManifestResource(new FileAsset(new File("src/test/resources/nta-test-ds.xml")), "nta-test-ds.xml")
+                .addAsManifestResource("filter.properties")
                 .addAsLibraries(libs)
                 .setManifest(new StringAsset(ManifestMF));
     }

core/src/test/java/io/narayana/nta/test/TransactionDAOTest.java

@@ -63,6 +63,7 @@ public static WebArchive createDeployment() {
                 .addAsWebInfResource(new FileAsset(new File("src/test/resources/persistence.xml")),
                         "classes/META-INF/persistence.xml")
                 .addAsManifestResource(new FileAsset(new File("src/test/resources/nta-test-ds.xml")), "nta-test-ds.xml")
+                .addAsManifestResource("filter.properties")
                 .setManifest(new StringAsset(ManifestMF));
     }
 

core/src/test/resources/filter.properties

@@ -0,0 +1,2 @@
+keywords=TransactionImple,Periodic Recovery,TransactionSynchronizationRegistryImple
+