1 files changed, 119 insertions, 0 deletions
diff --git a/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/auth/RequestStorage.java b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/auth/RequestStorage.java
new file mode 100644
index 00000000..7e0d4cc7
--- /dev/null
+++ b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/auth/RequestStorage.java
@@ -0,0 +1,119 @@
+/*******************************************************************************
+ *******************************************************************************/
+package at.gv.egiz.eaaf.core.impl.idp.auth;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import at.gv.egiz.eaaf.core.api.IRequest;
+import at.gv.egiz.eaaf.core.api.IRequestStorage;
+import at.gv.egiz.eaaf.core.api.idp.process.ProcessInstanceStoreDAO;
+import at.gv.egiz.eaaf.core.api.storage.ITransactionStorage;
+import at.gv.egiz.eaaf.core.exceptions.EAAFException;
+import at.gv.egiz.eaaf.core.exceptions.EAAFStorageException;
+import at.gv.egiz.eaaf.core.impl.idp.controller.protocols.RequestImpl;
+import at.gv.egiz.eaaf.core.impl.utils.Random;
+import at.gv.egiz.eaaf.core.impl.utils.TransactionIDUtils;
+
+@Service("RequestStorage")
+public class RequestStorage implements IRequestStorage{
+	private static final Logger log = LoggerFactory.getLogger(RequestStorage.class);
+	
+	@Autowired ITransactionStorage transactionStorage;
+	@Autowired ProcessInstanceStoreDAO processInstanceStore;
+	
+	@Override
+	public IRequest getPendingRequest(String pendingReqID) {
+		
+		try {
+			IRequest pendingRequest = transactionStorage.get(pendingReqID, IRequest.class);
+			if (pendingRequest == null) {
+				log.info("No PendingRequst found with pendingRequestID " + pendingReqID);			
+				return null;
+				
+			}
+					
+			//set transactionID and sessionID to Logger
+			TransactionIDUtils.setAllLoggingVariables(pendingRequest);
+						
+			return pendingRequest;
+		
+		} catch (EAAFException | NullPointerException e) {
+			log.info("No PendingRequst found with pendingRequestID " + pendingReqID);			
+			return null;
+			
+		}
+	}
+
+	@Override
+	public void storePendingRequest(IRequest pendingRequest) throws EAAFException {
+		try {			
+			if (pendingRequest instanceof IRequest) 
+				transactionStorage.put(((IRequest)pendingRequest).getPendingRequestId(), pendingRequest, -1);
+												
+			else
+				throw new EAAFException("PendigRequest is NOT of type 'IRequest'", null);
+				
+			
+		} catch (EAAFException e) {
+			log.warn("PendingRequest with ID=" + ((IRequest)pendingRequest).getPendingRequestId() +
+					" can not stored.", e);
+			throw new EAAFStorageException("PendingRequest with Id: " + ((IRequest)pendingRequest).getPendingRequestId()
+					+ " can not be stored", e);
+			
+		}
+		
+	}
+	
+	@Override
+	public void removePendingRequest(String requestID) {
+		
+		if (requestID != null) {
+			
+			//remove process-management execution instance
+			try {
+				IRequest pendingReq = getPendingRequest(requestID);
+						
+				if (pendingReq != null && 
+						pendingReq.getProcessInstanceId() != null)
+					processInstanceStore.remove(pendingReq.getProcessInstanceId());
+					
+			} catch (EAAFException e) {
+				log.warn("Removing process associated with pending-request:" + requestID + " FAILED.", e);
+				
+			}
+				
+			transactionStorage.remove(requestID);
+			
+		}
+	}
+
+	/* (non-Javadoc)
+	 * @see at.gv.egovernment.moa.id.storage.IRequestStorage#changePendingRequestID(at.gv.egovernment.moa.id.moduls.IRequest)
+	 */
+	@Override
+	public String changePendingRequestID(IRequest pendingRequest) throws EAAFException {
+
+		if (pendingRequest instanceof RequestImpl) {
+			String newRequestID = Random.nextHexRandom32();
+			String oldRequestID = pendingRequest.getPendingRequestId();
+			
+			log.debug("Change pendingRequestID from " + pendingRequest.getPendingRequestId() 
+				+ " to " + newRequestID);
+			
+			((RequestImpl)pendingRequest).setPendingRequestId(newRequestID);			
+			transactionStorage.changeKey(oldRequestID, newRequestID, pendingRequest);
+			
+			//only delete oldRequestID, no change.			
+			
+			return newRequestID;
+						
+		} else {
+			log.error("PendingRequest object is not of type 'RequestImpl.class'");
+			throw new EAAFException("PendingRequest object is not of type 'RequestImpl.class'", null);
+		}
+		
+	}
+}