added FTP archive implementations

Author: janithb

pom.xml

@@ -31,7 +31,7 @@
 	</scm>
 	<developers>
 		<developer>
-			<id>janith</id>
+			<id>janithb</id>
 			<name>Janith Bandara</name>
 			<organization>Audit4j</organization>
 			<organizationUrl>http://audit4j.org</organizationUrl>
@@ -57,11 +57,22 @@
 			<version>4.11</version>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.mockito</groupId>
+			<artifactId>mockito-core</artifactId>
+			<version>1.10.19</version>
+			<scope>test</scope>
+		</dependency>
 		<dependency>
 			<groupId>org.apache.commons</groupId>
 			<artifactId>commons-lang3</artifactId>
 			<version>3.3.2</version>
 		</dependency>
+		<dependency>
+			<groupId>commons-net</groupId>
+			<artifactId>commons-net</artifactId>
+			<version>3.3</version>
+		</dependency>
 		<dependency>
 			<groupId>com.esotericsoftware.yamlbeans</groupId>
 			<artifactId>yamlbeans</artifactId>

src/main/java/org/audit4j/core/ConcurrentConfigurationContext.java

@@ -26,14 +26,17 @@
 import org.audit4j.core.filter.AuditEventFilter;
 import org.audit4j.core.handler.Handler;
 import org.audit4j.core.layout.Layout;
+import org.audit4j.core.util.annotation.ThreadSafe;
 
 import com.gs.collections.impl.map.mutable.ConcurrentHashMap;
 
 /**
  * Configuration item store. All configuration items which are used by the
  * running components store here. Items loaded by the context.
  * 
- * <p>Below Items store here:</p>
+ * <p>
+ * Below Items store here:
+ * </p>
  * <ul>
  * <li>Available handlers.</li>
  * <li>Audit event filters.</li>
@@ -42,10 +45,9 @@
  * <li>Additional configuration properties.</li>
  * </ul>
  * 
- * <p> #ThreadSafe# </p>
- * 
  * @author <a href="mailto:[email protected]">Janith Bandara</a>
  */
+@ThreadSafe
 public final class ConcurrentConfigurationContext {
 
     /** The handlers. */
@@ -59,7 +61,7 @@ public final class ConcurrentConfigurationContext {
 
     /** The Constant filters. */
     private final List<AuditAnnotationFilter> annotationFilters = new CopyOnWriteArrayList<AuditAnnotationFilter>();
-    
+
     /** The layout. */
     private Layout layout;
 
@@ -166,10 +168,9 @@ public void addFilter(AuditEventFilter filter) {
         filters.add(filter);
     }
 
-    
     /**
      * Gets the annotation filters.
-     *
+     * 
      * @return the annotation filters
      */
     public List<AuditAnnotationFilter> getAnnotationFilters() {
@@ -178,12 +179,14 @@ public List<AuditAnnotationFilter> getAnnotationFilters() {
 
     /**
      * Adds the annotation filter.
-     *
-     * @param annotationFilter the annotation filter
+     * 
+     * @param annotationFilter
+     *            the annotation filter
      */
-    public void addAnnotationFilter(AuditAnnotationFilter annotationFilter){
+    public void addAnnotationFilter(AuditAnnotationFilter annotationFilter) {
         annotationFilters.add(annotationFilter);
     }
+
     /**
      * Gets the run status.
      * 

src/main/java/org/audit4j/core/CoreConstants.java

@@ -41,6 +41,9 @@ public final class CoreConstants {
 
     /** The Constant AUDIT_EXTENTION. */
     public static final String AUDIT_EXTENTION = ".audit";
+    
+    /** The Constant AUDIT_ARCHIVE_EXTENTION. */
+    public static final String AUDIT_ARCHIVE_EXTENTION = ".auditarchive";
 
     /** The Constant SITE_URL. */
     public static final String SITE_URL = "http://audit4j.org";

src/main/java/org/audit4j/core/PreConfigurationContext.java

@@ -30,7 +30,7 @@
 
 /**
  * Registry for internal initial resource configurations.
- *
+ * 
  * @author <a href="mailto:[email protected]">Janith Bandara</a>
  * 
  * @since 2.3.0
@@ -50,14 +50,16 @@ public final class PreConfigurationContext {
     private static final List<AuditAnnotationFilter> preAnnotationFilters = new ArrayList<AuditAnnotationFilter>();
 
     static {
-        options.add("-scanAnnotated");
-        commands.put("-scanAnnotated", new ScanAnnotatedCommand());
+        ScanAnnotatedCommand scanAnnotated = new ScanAnnotatedCommand();
+        options.add(scanAnnotated.getCommand());
+        commands.put(scanAnnotated.getCommand(), scanAnnotated);
     }
 
     /**
      * Gets the command by option name.
-     *
-     * @param optionName the option name
+     * 
+     * @param optionName
+     *            the option name
      * @return the command by option name
      */
     public static AbstractCommand getCommandByOptionName(String optionName) {
@@ -66,7 +68,7 @@ public static AbstractCommand getCommandByOptionName(String optionName) {
 
     /**
      * Gets the options.
-     *
+     * 
      * @return the options
      */
     public static List<String> getOptions() {
@@ -75,7 +77,7 @@ public static List<String> getOptions() {
 
     /**
      * Gets the commands.
-     *
+     * 
      * @return the commands
      */
     public static Map<String, AbstractCommand> getCommands() {
@@ -84,7 +86,7 @@ public static Map<String, AbstractCommand> getCommands() {
 
     /**
      * Gets the prefilters.
-     *
+     * 
      * @return the prefilters
      */
     public static List<AuditEventFilter> getPrefilters() {
@@ -93,25 +95,27 @@ public static List<AuditEventFilter> getPrefilters() {
 
     /**
      * Adds the filter.
-     *
-     * @param filter the filter
+     * 
+     * @param filter
+     *            the filter
      */
     public static void addFilter(AuditEventFilter filter) {
         preFilters.add(filter);
     }
 
     /**
      * Adds the annotation filter.
-     *
-     * @param filter the filter
+     * 
+     * @param filter
+     *            the filter
      */
     public static void addAnnotationFilter(AuditAnnotationFilter filter) {
         preAnnotationFilters.add(filter);
     }
 
     /**
      * Gets the preannotationfilters.
-     *
+     * 
      * @return the preannotationfilters
      */
     public static List<AuditAnnotationFilter> getPreannotationfilters() {

src/main/java/org/audit4j/core/command/AbstractCommand.java

@@ -48,12 +48,33 @@ public Map<String, String> getOptions() {
      *
      * @param options the options
      */
-    public void setOptions(Map<String, String> options) {
+    void setOptions(Map<String, String> options) {
         this.options = options;
     }
 
     /**
      * Execute.
      */
     public abstract void execute();
+    
+    /**
+     * Gets the command.
+     *
+     * @return the command
+     */
+    public abstract String getCommand();
+    
+    /**
+     * Gets the command name.
+     *
+     * @return the command name
+     */
+    public abstract String getCommandName();
+    
+    /**
+     * Gets the command description.
+     *
+     * @return the command description
+     */
+    public abstract String getCommandDescription();
 }

src/main/java/org/audit4j/core/command/CommandProcessor.java

@@ -51,7 +51,7 @@ public void process(Map<String, String> options) {
                 try {
                     command.init();
                 } catch (InitializationException e) {
-                    Log.error("There is a problem in the : option you configured: ", entry.getKey(),
+                    Log.error("There is a problem in the option you configured: ", entry.getKey(),
                             ErrorGuide.getGuide(ErrorGuide.OPTION_ERROR));
                 }
                 command.execute();

src/main/java/org/audit4j/core/command/impl/ScanAnnotatedCommand.java

@@ -31,8 +31,11 @@
 import org.audit4j.core.filter.impl.ScanAnnotatedFilter;
 
 /**
- * The Class ScanAnnotatedCommand.
- *
+ * Scan Annotated Command.
+ * 
+ * Scan annotations in initialization time and store the information. These
+ * information will use later to speedup the event processing.
+ * 
  * @author <a href="mailto:[email protected]">Janith Bandara</a>
  * 
  * @since 2.3.0
@@ -42,12 +45,30 @@ public class ScanAnnotatedCommand extends AbstractCommand {
     /** The db. */
     AnnotationDB db;
 
-    /* (non-Javadoc)
+    @Override
+    public String getCommand() {
+        return "-scanAnnotated";
+    }
+
+    @Override
+    public String getCommandName() {
+        return "Scan Annotated Command";
+    }
+
+    @Override
+    public String getCommandDescription() {
+        return "Scan annotations in initialization time and store the information. "
+                + "These information will use later to speedup the event processing";
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
      * @see org.audit4j.core.Initializable#init()
      */
     @Override
     public void init() {
-        String packageName = getOptions().get("-scanAnnotated");
+        String packageName = getOptions().get(getCommand());
 
         ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
 
@@ -77,7 +98,9 @@ public void init() {
 
     }
 
-    /* (non-Javadoc)
+    /*
+     * (non-Javadoc)
+     * 
      * @see org.audit4j.core.command.AbstractCommand#execute()
      */
     @Override
@@ -95,12 +118,13 @@ public void execute() {
         PreConfigurationContext.addAnnotationFilter(filter);
     }
 
-    /* (non-Javadoc)
+    /*
+     * (non-Javadoc)
+     * 
      * @see org.audit4j.core.Initializable#stop()
      */
     @Override
     public void stop() {
         db = null;
     }
-
 }

src/main/java/org/audit4j/core/filter/AuditEventFilter.java

@@ -31,6 +31,8 @@
  */
 public interface AuditEventFilter extends Serializable {
 
+    public POJOQuery<AuditEvent> query = new POJOQuery<>();
+    
     /**
      * Accepts.
      *

src/main/java/org/audit4j/core/filter/POJOQuery.java

@@ -308,6 +308,7 @@ public boolean operaterProceed() {
 		 * @return true, if successful
 		 */
 		public boolean evaluate() {
+		    atQuery = null;
 			return result;
 		}
 	}