1 files changed, 97 insertions, 0 deletions
diff --git a/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/controller/AbstractProcessEngineSignalController.java b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/controller/AbstractProcessEngineSignalController.java
new file mode 100644
index 00000000..a4a86ca2
--- /dev/null
+++ b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/controller/AbstractProcessEngineSignalController.java
@@ -0,0 +1,97 @@
+/*******************************************************************************
+ *******************************************************************************/
+package at.gv.egiz.eaaf.core.impl.idp.controller;
+
+import java.io.IOException;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.commons.text.StringEscapeUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import at.gv.egiz.eaaf.core.api.IRequest;
+import at.gv.egiz.eaaf.core.api.IStatusMessager;
+import at.gv.egiz.eaaf.core.api.data.EAAFConstants;
+import at.gv.egiz.eaaf.core.api.idp.process.ProcessEngine;
+import at.gv.egiz.eaaf.core.exceptions.EAAFException;
+import at.gv.egiz.eaaf.core.exceptions.EAAFIllegalStateException;
+import at.gv.egiz.eaaf.core.impl.utils.TransactionIDUtils;
+
+/**
+ * Servlet that resumes a suspended process (in case of asynchronous tasks).
+ * 
+ * @author tknall
+ * 
+ */
+public abstract class AbstractProcessEngineSignalController extends AbstractController {
+	private static final Logger log = LoggerFactory.getLogger(AbstractProcessEngineSignalController.class);	
+	
+	@Autowired protected ProcessEngine processEngine;
+	
+	protected void signalProcessManagement(HttpServletRequest req, HttpServletResponse resp) throws IOException {
+		String pendingRequestID = StringEscapeUtils.escapeHtml4(getPendingRequestId(req));
+		IRequest pendingReq = null;
+		try {	
+			if (pendingRequestID == null) {
+				new EAAFException(
+						IStatusMessager.CODES_INTERNAL_ERROR_AUTH_NOPENDIGREQID, 
+						null, 
+						"NO PendingRequestId found" 
+					);
+				
+			}
+			
+			pendingReq = requestStorage.getPendingRequest(pendingRequestID);
+			if (pendingReq == null) {
+				log.info("No PendingRequest with Id: " + pendingRequestID + " Maybe, a transaction timeout occure.");
+				throw new EAAFException(IStatusMessager.CODES_INTERNAL_ERROR_AUTH_TIMEOUT, new Object[]{pendingRequestID},
+						"No PendingRequest with Id: \" + pendingRequestID + \" Maybe, a transaction timeout occure.\"");
+				
+			}
+			
+			//change pending-request ID
+			requestStorage.changePendingRequestID(pendingReq);
+			pendingRequestID = pendingReq.getPendingRequestId();
+						
+			// process instance is mandatory
+			if (pendingReq.getProcessInstanceId() == null) {
+				throw new EAAFIllegalStateException(new Object[]{"MOA session does not provide process instance id."},
+						"No execution environemnt found for this pending request");
+				
+			}
+
+			// wake up next task
+			processEngine.signal(pendingReq);
+			
+		} catch (Exception ex) {		
+			handleError(null, ex, req, resp, pendingReq);
+			
+		} finally {
+			//MOASessionDBUtils.closeSession();
+			TransactionIDUtils.removeAllLoggingVariables();
+			
+		}
+		
+		
+	}
+	
+	/**
+	 * Retrieves the current pending-request id from the HttpServletRequest parameter
+	 * 
+	 * <p/>
+	 * Note that this class/method can be overwritten by modules providing their own strategy of retrieving the
+	 * respective pending-request id.
+	 * 
+	 * @param request
+	 *            The unterlying HttpServletRequest.
+	 * @return The current pending-request id.
+	 */
+	public String getPendingRequestId(HttpServletRequest request) {
+		return StringEscapeUtils.escapeHtml4(request.getParameter(EAAFConstants.PARAM_HTTP_TARGET_PENDINGREQUESTID));
+		
+	}
+
+}