Message1_1_FIX_Impl.java

/*
 * GovWay - A customizable API Gateway 
 * https://govway.org
 * 
 * Copyright (c) 2005-2024 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.message.soap;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Iterator;

import javax.xml.soap.AttachmentPart;
import javax.xml.soap.MimeHeaders;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPMessage;
import javax.xml.soap.SOAPPart;

import org.apache.commons.io.input.CountingInputStream;
import org.openspcoop2.message.OpenSPCoop2MessageFactory;
import org.openspcoop2.message.constants.MessageRole;
import org.openspcoop2.message.constants.MessageType;

import com.sun.xml.messaging.saaj.SOAPExceptionImpl;
import com.sun.xml.messaging.saaj.packaging.mime.internet.ContentType;
import com.sun.xml.messaging.saaj.packaging.mime.internet.MimeMultipart;

/**
 * Message1_1_FIX_Impl
 *
 *
 * @author Poli Andrea (apoli@link.it)
 * @author $Author$
 * @version $Rev$, $Date$
 */
public class Message1_1_FIX_Impl extends com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl {
	
	// La classe Message1_1Impl presenta un problema per il costruttore con SOAPMessage 
	// Non funziona in presenza di messaggi con attachment. 
	// C'e' un bug nell'implementazione della sun che non copia gli attachment
	// In particolare il parametro super.mimePart (protetto non accessibile).
	// Per questo motivo essite la classe 1_1 FIX che utilizza direttamente il messaggio fornito 
	
	private SOAPMessage msg; // messaggio fornito nel costruttore
	private CountingInputStream cis;
	
	
	// Costruttori
	
	public Message1_1_FIX_Impl() {
        super();
    }
    
    public Message1_1_FIX_Impl(boolean isFastInfoset, boolean acceptFastInfoset) {
        super(isFastInfoset, acceptFastInfoset);
    }

    // !!Costruttore che presenta il problema!!
    public Message1_1_FIX_Impl(SOAPMessage msg) {
    	try {
    		this.msg = (com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl) msg;
    	}catch(Throwable t) {
    		// Fix: java.lang.ClassCastException: com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl cannot be cast to com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl
    		// Versioni differenti tra saaj-impl nel software e quello nell'application server
    		if(t instanceof java.lang.ClassCastException) {
    			try {
	    			ByteArrayOutputStream bout = new ByteArrayOutputStream();
	        		msg.writeTo(bout);
	        		bout.flush();
	        		bout.close();
	        		this.msg = OpenSPCoop2MessageFactory.getDefaultMessageFactory().createMessage(MessageType.SOAP_11, MessageRole.NONE, 
	        				SoapUtils.getContentType(msg), bout.toByteArray(), null, null).getMessage_throwParseThrowable().castAsSoap().getSOAPMessage();
    			}catch(Throwable tNew) {
    				throw new RuntimeException(new org.openspcoop2.utils.UtilsMultiException(tNew, t));
    			}
    		}
    		else {
    			throw new RuntimeException(t);
    		}
    	}
    }

    public Message1_1_FIX_Impl(MimeHeaders headers, CountingInputStream in)
        throws IOException, SOAPExceptionImpl {
        super(headers, in);
        this.cis = in;
    }

    public Message1_1_FIX_Impl(MimeHeaders headers, ContentType ct, int stat, InputStream in)
        throws SOAPExceptionImpl {
        super(headers,ct,stat,in);
    }
	
    
    // CountingInputStream
    
	public CountingInputStream getCountingInputStream(){
		return this.cis;
	}

	// Wrapper
	
    public MimeMultipart getMimeMultipart(){
    	if (this.msg!= null) { 
    		if(this.msg instanceof Message1_1_FIX_Impl)
    			return ((Message1_1_FIX_Impl)this.msg).getMimeMultipart();
    		else
    			return super.mmp;
    	}
    	else return super.mmp;
    }
	
    // Metodi MessageImpl
    
    @Override
    public String getContentType() {
    	if (this.msg!= null) return _getContentType(this.msg);	
    	else return super.getContentType();
    }
    private String _getContentType(SOAPMessage soapMsg) {
    	try {
    		com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl msg = (com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl) soapMsg;
    		return msg.getContentType();
    	}catch(Throwable t) {
    		// Fix: java.lang.ClassCastException: com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl cannot be cast to com.sun.xml.messaging.saaj.soap.ver1_1.Message1_1Impl
    		// Versioni differenti tra saaj-impl nel software e quello nell'application server
    		return SoapUtils.getContentType(this.msg);
    	}
    }
    
    // Metodi SOAPMessage
    
    @Override
	public void addAttachmentPart(AttachmentPart attachment) {
		if (this.msg!= null) this.msg.addAttachmentPart(attachment);	
		else super.addAttachmentPart(attachment);
	}
	
	@Override
	public int countAttachments() {
		if (this.msg!= null) return this.msg.countAttachments();
		else return super.countAttachments();
	}
	
	@Override
	public AttachmentPart createAttachmentPart() {
		if (this.msg!= null) return this.msg.createAttachmentPart();
		else return super.createAttachmentPart();
	}
	
	@Override
	public AttachmentPart getAttachment(SOAPElement element) throws SOAPException {
		if (this.msg!= null) return this.msg.getAttachment(element);
		else return super.getAttachment(element);
	}
	
	@Override
	public Iterator<AttachmentPart> getAttachments() {
		if (this.msg!= null) return this.msg.getAttachments();
		else return super.getAttachments();
	}
	
	@Override
	public Iterator<AttachmentPart> getAttachments(MimeHeaders headers) {
		if (this.msg!= null) return this.msg.getAttachments(headers);
		else return super.getAttachments(headers);
	}
	
	@Override
	public String getContentDescription() {
		if (this.msg!= null) return this.msg.getContentDescription();
		else return super.getContentDescription();
	}
	
	@Override
	public MimeHeaders getMimeHeaders() {
		if (this.msg!= null) return this.msg.getMimeHeaders();
		else return super.getMimeHeaders();
	}
	
	@Override
	public SOAPPart getSOAPPart() {
		if (this.msg!= null) return this.msg.getSOAPPart();
		else return super.getSOAPPart();
	}
	
	@Override
	public void removeAllAttachments() {
		if (this.msg!= null) this.msg.removeAllAttachments();
		else super.removeAllAttachments();
	}
	
	@Override
	public void removeAttachments(MimeHeaders headers) {
		if (this.msg!= null) this.msg.removeAttachments(headers);
		else super.removeAttachments(headers);
	}
	
	@Override
	public void saveChanges() throws SOAPException {
		if (this.msg!= null) this.msg.saveChanges();
		else super.saveChanges();
	}
	
	@Override
	public boolean saveRequired() {
		if (this.msg!= null) return this.msg.saveRequired();
		else return super.saveRequired();
	}
	
	@Override
	public void setContentDescription(String description) {
		if (this.msg!= null) this.msg.setContentDescription(description);
		else super.setContentDescription(description);
	}
	
	@Override
	public void writeTo(OutputStream out) throws SOAPException, IOException {
		if (this.msg!= null) this.msg.writeTo(out);
		else super.writeTo(out);
	}
		
}