r82 - in trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2: . interceptor - Nuiton-web-commits

4 Jul 2011

Author: tchemit
Date: 2011-07-04 22:54:39 +0200 (Mon, 04 Jul 2011)
New Revision: 82

Url: http://nuiton.org/repositories/revision/nuiton-web/82

Log:
add new interceptor which deals with opening and closing Topia transaction

Added:
   trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/interceptor/TopiaTransactionInterceptor.java
Modified:
   trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/TopiaTransactionAware.java

Modified: trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/TopiaTransactionAware.java
===================================================================

--- trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/TopiaTransactionAware.java	2011-07-04 14:47:25 UTC (rev 81)
+++ trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/TopiaTransactionAware.java	2011-07-04 20:54:39 UTC (rev 82)
@@ -45,4 +45,6 @@
      * @return the current transaction (can be null or closed...).
      */
     TopiaContext getTransaction();
+    
+    void setTransaction(TopiaContext transaction);
 }

Added: trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/interceptor/TopiaTransactionInterceptor.java
===================================================================
--- trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/interceptor/TopiaTransactionInterceptor.java	                        (rev 0)
+++ trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/interceptor/TopiaTransactionInterceptor.java	2011-07-04 20:54:39 UTC (rev 82)
@@ -0,0 +1,130 @@
+package org.nuiton.web.struts2.interceptor;
+
+import com.opensymphony.xwork2.ActionInvocation;
+import com.opensymphony.xwork2.interceptor.AbstractInterceptor;
+import com.opensymphony.xwork2.util.TextParseUtil;
+import org.nuiton.topia.TopiaContext;
+import org.nuiton.topia.TopiaException;
+import org.nuiton.web.struts2.TopiaTransactionAware;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/**
+ * To deal with topia transaction .
+ *
+ * @author tchemit <chemit@codelutin.com>
+ * @since 1.2
+ */
+public abstract class TopiaTransactionInterceptor extends AbstractInterceptor {
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String[] DEFAULT_EXCLUDE_METHODS = {
+            "beginTransaction",
+            "closeContext",
+            "clear"
+    };
+
+    protected Set<String> excludeMethods;
+
+    public Set<String> getExcludeMethods() {
+        return excludeMethods;
+    }
+
+    public void setExcludeMethods(String excludeMethods) {
+        this.excludeMethods = TextParseUtil.commaDelimitedStringToSet(excludeMethods);
+    }
+
+    protected abstract TopiaContext beginTransaction() throws TopiaException;
+
+    @Override
+    public void init() {
+        super.init();
+
+        if (getExcludeMethods() == null) {
+
+            // use default exclude methods
+            excludeMethods = new HashSet<String>(
+                    Arrays.asList(DEFAULT_EXCLUDE_METHODS)
+            );
+        }
+    }
+
+    @Override
+    public String intercept(ActionInvocation invocation) throws Exception {
+
+        TopiaTransactionAware transactionAware = null;
+
+        Object action = invocation.getProxy().getAction();
+
+        if (action instanceof TopiaTransactionAware) {
+            transactionAware = (TopiaTransactionAware) action;
+        }
+
+        TopiaContext transaction = null;
+        if (transactionAware != null) {
+
+            // action need a transaction
+            transaction = beginTransaction();
+
+            // creates a proxy
+            TopiaContext proxy = (TopiaContext) Proxy.newProxyInstance(
+                    getClass().getClassLoader(),
+                    new Class<?>[]{TopiaContext.class},
+                    new TopiaTransaction()
+            );
+
+            // set the transaction in the action
+            transactionAware.setTransaction(proxy);
+        }
+        try {
+            return invocation.invoke();
+        } finally {
+
+            if (transactionAware != null) {
+
+                // we are on a action with a internal topia transaction
+
+                if (transaction != null && !transaction.isClosed()) {
+
+                    // close the opened transaction
+                    transaction.closeContext();
+                }
+            }
+        }
+    }
+
+    /**
+     * Un proxy pour interdire d'utiliser les méthodes définies dans
+     * {@link #excludeMethods}.
+     */
+    class TopiaTransaction implements InvocationHandler {
+
+        @Override
+        public Object invoke(Object proxy,
+                             Method method,
+                             Object[] args) throws Throwable {
+
+            String methodName = method.getName();
+
+            if (getExcludeMethods().contains(methodName)) {
+
+                // not authorized
+                throw new IllegalAccessException(
+                        "Not allowed to access method " + methodName + " on " +
+                        proxy);
+            }
+
+            // any other methods are fine
+            Object result = method.invoke(args);
+
+            return result;
+        }
+    }
+
+}
\ No newline at end of file


Property changes on: trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2/interceptor/TopiaTransactionInterceptor.java
___________________________________________________________________
Added: svn:keywords
   + Author Date Id Revision
Added: svn:eol-style
   + native

    

r82 - in trunk/nuiton-struts2/src/main/java/org/nuiton/web/struts2: . interceptor

tchemit＠users.nuiton.org

tags

participants (1)