RicezioneContenutiApplicativiInternalErrorGenerator.java

/*
 * GovWay - A customizable API Gateway 
 * https://govway.org
 * 
 * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
 * 
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 3, as published by
 * the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
package org.openspcoop2.pdd.services.error;

import java.util.List;

import org.openspcoop2.core.constants.TipoPdD;
import org.openspcoop2.core.eccezione.details.DettaglioEccezione;
import org.openspcoop2.core.id.IDSoggetto;
import org.openspcoop2.message.OpenSPCoop2Message;
import org.openspcoop2.message.OpenSPCoop2MessageFactory;
import org.openspcoop2.message.config.ConfigurationRFC7807;
import org.openspcoop2.message.config.IntegrationErrorReturnConfiguration;
import org.openspcoop2.message.constants.IntegrationError;
import org.openspcoop2.message.constants.MessageType;
import org.openspcoop2.message.exception.ParseException;
import org.openspcoop2.protocol.engine.builder.ErroreApplicativoBuilder;
import org.openspcoop2.protocol.sdk.Context;
import org.openspcoop2.protocol.sdk.Eccezione;
import org.openspcoop2.protocol.sdk.ProtocolException;
import org.openspcoop2.protocol.sdk.builder.ProprietaErroreApplicativo;
import org.openspcoop2.protocol.sdk.constants.ErroreIntegrazione;
import org.openspcoop2.protocol.sdk.constants.IntegrationFunctionError;
import org.openspcoop2.protocol.sdk.state.RequestInfo;
import org.slf4j.Logger;

/**
 * RicezioneContenutiApplicativiInternalErrorGenerator
 *
 * @author Poli Andrea (apoli@link.it)
 * @author $Author$
 * @version $Rev$, $Date$
 */
public class RicezioneContenutiApplicativiInternalErrorGenerator extends AbstractErrorGenerator {

    private ProprietaErroreApplicativo proprietaErroreAppl = null;

    public RicezioneContenutiApplicativiInternalErrorGenerator(Logger log, String idModulo, RequestInfo requestInfo) throws ProtocolException{
        
        super(log, idModulo, requestInfo, TipoPdD.DELEGATA, true);
        
        this.proprietaErroreAppl = this.openspcoopProperties.getProprietaGestioneErrorePD(this.protocolFactory.createProtocolManager());
        this.proprietaErroreAppl.setDominio(this.identitaPdD.getCodicePorta());
        this.proprietaErroreAppl.setIdModulo(this.idModulo);
        
    }
    
    public ProprietaErroreApplicativo getProprietaErroreAppl() {
        return this.proprietaErroreAppl;
    }
    
    public void updateProprietaErroreApplicativo(ProprietaErroreApplicativo proprietaErroreApplicativo){
        this.proprietaErroreAppl = proprietaErroreApplicativo;
    }
        
    @Override
    public void updateDominio(IDSoggetto identitaPdD){
        super.updateDominio(identitaPdD);
        this.proprietaErroreAppl.setDominio(this.identitaPdD.getCodicePorta());
    }
    
    public ErroreApplicativoBuilder getErroreApplicativoBuilderForAddDetailInSoapFault(Context context, MessageType messageTypeError, IntegrationFunctionError integrationFunctionError) throws ProtocolException{
        IntegrationError integrationError = convertToIntegrationError(integrationFunctionError);
        ConfigurationRFC7807 rfc7807 = this.getRfc7807ForErrorSafeMode(integrationError); 
        IntegrationErrorReturnConfiguration returnConfig = this.getReturnConfigForError(integrationError);
        return this.getErroreApplicativoBuilder(context, messageTypeError, rfc7807, returnConfig, integrationFunctionError);
    }
    public ErroreApplicativoBuilder getErroreApplicativoBuilder(Context context, MessageType messageTypeError, 
            ConfigurationRFC7807 rfc7807, IntegrationErrorReturnConfiguration returnConfig, IntegrationFunctionError integrationFunctionError) throws ProtocolException{
        ErroreApplicativoBuilder erroreApplicativoBuilder = new ErroreApplicativoBuilder(this.log, this.protocolFactory, 
                this.identitaPdD, this.mittente, this.idServizio, 
                this.idModulo, 
                this.proprietaErroreAppl, 
                messageTypeError, rfc7807, returnConfig, integrationFunctionError, this.getInterfaceName(),
                this.tipoPdD, this.servizioApplicativo,
                this.requestInfo.getIdTransazione(), context);
        return erroreApplicativoBuilder;
    }
    
    
    
    public OpenSPCoop2Message build(Context context, IntegrationFunctionError integrationFunctionError, Eccezione ecc, IDSoggetto idSoggettoProduceEccezione, ParseException parseException) {
        return build(context, integrationFunctionError, ecc, idSoggettoProduceEccezione, null, parseException);
    }
    public OpenSPCoop2Message build(Context context, IntegrationFunctionError integrationFunctionError, Eccezione ecc, IDSoggetto idSoggettoProduceEccezione, DettaglioEccezione dettaglioEccezione, ParseException parseException) {
        
        IntegrationError integrationError = convertToIntegrationError(integrationFunctionError);
        MessageType msgTypeErrorResponse = this.getMessageTypeForErrorSafeMode(integrationError);
        ConfigurationRFC7807 rfc7807 = this.getRfc7807ForErrorSafeMode(integrationError);
        boolean useProblemRFC7807 = rfc7807!=null;
        try{
            IntegrationErrorReturnConfiguration returnConfig = this.getReturnConfigForError(integrationError);
            ErroreApplicativoBuilder erroreApplicativoBuilder = getErroreApplicativoBuilder(context, msgTypeErrorResponse,rfc7807, returnConfig, integrationFunctionError);
            OpenSPCoop2Message msg = erroreApplicativoBuilder.toMessage(ecc,idSoggettoProduceEccezione,dettaglioEccezione,parseException);  
            return msg;
        }catch(Exception e){
            this.log.error("Errore durante la costruzione del messaggio di eccezione integrazione",e);
            return OpenSPCoop2MessageFactory.getDefaultMessageFactory().createFaultMessage(msgTypeErrorResponse,useProblemRFC7807, e);
        }
    }
    
    public OpenSPCoop2Message build(Context context, IntegrationFunctionError integrationFunctionError, ErroreIntegrazione erroreIntegrazione, Throwable eProcessamento, ParseException parseException) {
        
        IntegrationError integrationError = convertToIntegrationError(integrationFunctionError);
        MessageType msgTypeErrorResponse = this.getMessageTypeForErrorSafeMode(integrationError);
        ConfigurationRFC7807 rfc7807 = this.getRfc7807ForErrorSafeMode(integrationError);
        boolean useProblemRFC7807 = rfc7807!=null;
        try{
            IntegrationErrorReturnConfiguration returnConfig = this.getReturnConfigForError(integrationError);
            ErroreApplicativoBuilder erroreApplicativoBuilder = getErroreApplicativoBuilder(context, msgTypeErrorResponse,rfc7807, returnConfig, integrationFunctionError);
            OpenSPCoop2Message msg = erroreApplicativoBuilder.toMessage(erroreIntegrazione,eProcessamento,parseException);
            return msg;
        }catch(Exception e){
            this.log.error("Errore durante la costruzione del messaggio di eccezione integrazione",e);
            return OpenSPCoop2MessageFactory.getDefaultMessageFactory().createFaultMessage(msgTypeErrorResponse,useProblemRFC7807, e);
        }
    }
    
    public byte[] buildAsByteArray(Context context, IntegrationFunctionError integrationFunctionError, ErroreIntegrazione erroreIntegrazione, List<Integer> returnCode) {
        
        IntegrationError integrationError = convertToIntegrationError(integrationFunctionError);
        MessageType msgTypeErrorResponse = this.getMessageTypeForErrorSafeMode(integrationError);
        ConfigurationRFC7807 rfc7807 = this.getRfc7807ForErrorSafeMode(integrationError);
        boolean useProblemRFC7807 = rfc7807!=null;
        try{
            IntegrationErrorReturnConfiguration returnConfig = this.getReturnConfigForError(integrationError);
            ErroreApplicativoBuilder erroreApplicativoBuilder = getErroreApplicativoBuilder(context, msgTypeErrorResponse,rfc7807, returnConfig, integrationFunctionError);
            byte[] bytes = erroreApplicativoBuilder.toByteArray(erroreIntegrazione);
            returnCode.add(returnConfig.getHttpReturnCode());
            return bytes;
        }catch(Exception e){
            this.log.error("Errore durante la costruzione del messaggio di eccezione integrazione",e);
            try{
                OpenSPCoop2Message msgError = OpenSPCoop2MessageFactory.getDefaultMessageFactory().createFaultMessage(msgTypeErrorResponse,useProblemRFC7807, e);
                java.io.ByteArrayOutputStream bout = new java.io.ByteArrayOutputStream();
                msgError.writeTo(bout,true);
                bout.flush();
                bout.close();
                return  bout.toByteArray();
            }catch(Exception eInternal){
                throw new RuntimeException(eInternal.getMessage(),eInternal); // non dovrebbe mai accadere
            }
        }
    }
    
}