/*******************************************************************************
 *******************************************************************************/
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);
		}
		
	}
}