/*******************************************************************************
 *******************************************************************************/
package at.asitplus.eidas.specific.modules.authmodule_eIDASv2.tasks;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;

import at.asitplus.eidas.specific.connector.MSConnectorEventCodes;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.Constants;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.exception.eIDASAuthenticationException;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.service.eIDASAttributeRegistry;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.validator.eIDASResponseValidator;
import at.gv.egiz.eaaf.core.api.idp.IConfiguration;
import at.gv.egiz.eaaf.core.api.idp.process.ExecutionContext;
import at.gv.egiz.eaaf.core.exceptions.EAAFException;
import at.gv.egiz.eaaf.core.exceptions.TaskExecutionException;
import at.gv.egiz.eaaf.core.impl.idp.auth.data.AuthProcessDataWrapper;
import at.gv.egiz.eaaf.core.impl.idp.auth.modules.AbstractAuthServletTask;
import eu.eidas.auth.commons.light.ILightResponse;

@Component("ReceiveResponseFromeIDASNodeTask")
public class ReceiveAuthnResponseTask extends AbstractAuthServletTask {
	private static final Logger log = LoggerFactory.getLogger(ReceiveAuthnResponseTask.class);
	
	@Autowired private ApplicationContext context;
	@Autowired private IConfiguration basicConfig;
	@Autowired private eIDASAttributeRegistry attrRegistry;
		
	@Override 
	public void execute(ExecutionContext executionContext, HttpServletRequest request, HttpServletResponse response) throws TaskExecutionException {
		try{					    
			ILightResponse eIDASResponse = (ILightResponse) request.getAttribute(Constants.DATA_FULL_EIDAS_RESPONSE);
			if (eIDASResponse == null) {
				log.warn("NO eIDAS response-message found.");
				throw new eIDASAuthenticationException("eidas.01", null);
				
			}  
			
	    	log.debug("Receive eIDAS response with RespId:" + eIDASResponse.getId() + " for ReqId:" + eIDASResponse.getInResponseToId());
			revisionsLogger.logEvent(pendingReq, MSConnectorEventCodes.RESPONSE_FROM_EIDAS_NODE, eIDASResponse.getId());
	    	
	    	
			//check response StatusCode 
			if (!eIDASResponse.getStatus().getStatusCode().equals(Constants.SUCCESS_URI)) {
				log.info("Receice eIDAS Response with StatusCode:" + eIDASResponse.getStatus().getStatusCode()
				+ " Subcode:" + eIDASResponse.getStatus().getSubStatusCode() + " Msg:" + eIDASResponse.getStatus().getStatusMessage());
				throw new eIDASAuthenticationException("eidas.02", new Object[]{eIDASResponse.getStatus().getStatusCode(), eIDASResponse.getStatus().getStatusMessage()});
				
			}

			// extract all Attributes from response
			
			
			
			// **********************************************************
			// *******   MS-specificresponse validation   **********
			// **********************************************************
			String spCountry = basicConfig.getBasicConfiguration(Constants.CONIG_PROPS_EIDAS_NODE_COUNTRYCODE, "AT");
			eIDASResponseValidator.validateResponse(pendingReq, eIDASResponse, spCountry, attrRegistry);

			
			// **********************************************************
			// ******* Store resonse infos into session object **********
			// **********************************************************
			
			//update MOA-Session data with received information			
			log.debug("Store eIDAS response information into pending-request.");				
			AuthProcessDataWrapper authProcessData = pendingReq.getSessionData(AuthProcessDataWrapper.class);
			authProcessData.setQAALevel(eIDASResponse.getLevelOfAssurance());
			authProcessData.setGenericDataToSession(Constants.DATA_FULL_EIDAS_RESPONSE, eIDASResponse);
			
			//store MOA-session to database
			requestStoreage.storePendingRequest(pendingReq);
			
			revisionsLogger.logEvent(pendingReq, MSConnectorEventCodes.RESPONSE_FROM_EIDAS_NODE_VALID);
		
		} catch (EAAFException e) {
			revisionsLogger.logEvent(pendingReq, MSConnectorEventCodes.RESPONSE_FROM_EIDAS_NODE_NOT_VALID);
			throw new TaskExecutionException(pendingReq, "eIDAS Response processing FAILED.", e);
					
		} catch (Exception e) {
			log.warn("eIDAS Response processing FAILED.", e);
			revisionsLogger.logEvent(pendingReq, MSConnectorEventCodes.RESPONSE_FROM_EIDAS_NODE_NOT_VALID);
			throw new TaskExecutionException(pendingReq, e.getMessage(), 
					new eIDASAuthenticationException("eidas.05", new Object[]{e.getMessage()}, e));
			
		}	
		
	}

}