/*
 * Copyright (c) 2022.
 *
 * Juergen Key. Alle Rechte vorbehalten.
 *
 * Weiterverbreitung und Verwendung in nichtkompilierter oder kompilierter Form,
 * mit oder ohne Veraenderung, sind unter den folgenden Bedingungen zulaessig:
 *
 *    1. Weiterverbreitete nichtkompilierte Exemplare muessen das obige Copyright,
 * die Liste der Bedingungen und den folgenden Haftungsausschluss im Quelltext
 * enthalten.
 *    2. Weiterverbreitete kompilierte Exemplare muessen das obige Copyright,
 * die Liste der Bedingungen und den folgenden Haftungsausschluss in der
 * Dokumentation und/oder anderen Materialien, die mit dem Exemplar verbreitet
 * werden, enthalten.
 *    3. Weder der Name des Autors noch die Namen der Beitragsleistenden
 * duerfen zum Kennzeichnen oder Bewerben von Produkten, die von dieser Software
 * abgeleitet wurden, ohne spezielle vorherige schriftliche Genehmigung verwendet
 * werden.
 *
 * DIESE SOFTWARE WIRD VOM AUTOR UND DEN BEITRAGSLEISTENDEN OHNE
 * JEGLICHE SPEZIELLE ODER IMPLIZIERTE GARANTIEN ZUR VERFUEGUNG GESTELLT, DIE
 * UNTER ANDEREM EINSCHLIESSEN: DIE IMPLIZIERTE GARANTIE DER VERWENDBARKEIT DER
 * SOFTWARE FUER EINEN BESTIMMTEN ZWECK. AUF KEINEN FALL IST DER AUTOR
 * ODER DIE BEITRAGSLEISTENDEN FUER IRGENDWELCHE DIREKTEN, INDIREKTEN,
 * ZUFAELLIGEN, SPEZIELLEN, BEISPIELHAFTEN ODER FOLGENDEN SCHAEDEN (UNTER ANDEREM
 * VERSCHAFFEN VON ERSATZGUETERN ODER -DIENSTLEISTUNGEN; EINSCHRAENKUNG DER
 * NUTZUNGSFAEHIGKEIT; VERLUST VON NUTZUNGSFAEHIGKEIT; DATEN; PROFIT ODER
 * GESCHAEFTSUNTERBRECHUNG), WIE AUCH IMMER VERURSACHT UND UNTER WELCHER
 * VERPFLICHTUNG AUCH IMMER, OB IN VERTRAG, STRIKTER VERPFLICHTUNG ODER
 * UNERLAUBTE HANDLUNG (INKLUSIVE FAHRLAESSIGKEIT) VERANTWORTLICH, AUF WELCHEM
 * WEG SIE AUCH IMMER DURCH DIE BENUTZUNG DIESER SOFTWARE ENTSTANDEN SIND, SOGAR,
 * WENN SIE AUF DIE MOEGLICHKEIT EINES SOLCHEN SCHADENS HINGEWIESEN WORDEN SIND.
 *
 */
import javax.xml.transform.*;
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;
import java.beans.XMLEncoder;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class BeanTransformer
{
	private static final DefaultEncoderProvider defaultEncoderProvider=new DefaultEncoderProvider();

	protected BeanTransformer()
	{
		super();
	}
	public interface EncoderProvider
	{
		XMLEncoder create(PipedOutputStream pipedOutputStream);
	}
	static class DefaultEncoderProvider extends java.lang.Object implements EncoderProvider
	{
		@Override
		public XMLEncoder create(PipedOutputStream pipedOutputStream)
		{
			return new XMLEncoder( pipedOutputStream );
		}
	}
	public static void transformSerialize(java.lang.Object toSerialize, java.io.OutputStream os, java.io.InputStream template) throws IOException, TransformerException
	{
		transformSerialize(defaultEncoderProvider,toSerialize,os,template);
	}
	public static void transformSerialize(java.lang.Object toSerialize, javax.xml.transform.Result result, javax.xml.transform.Source template) throws IOException, TransformerException
	{
		transformSerialize(defaultEncoderProvider,toSerialize,result,template);
	}
	public static void transformSerialize(EncoderProvider encoderProvider,java.lang.Object toSerialize, java.io.OutputStream os, java.io.InputStream template) throws IOException, TransformerException
	{
		StreamSource xslsource = new StreamSource(template);
		StreamResult xmlresult = new StreamResult( os );
		transformSerialize(encoderProvider,toSerialize,xmlresult,xslsource);
		os.close();
		template.close();
	}
	public static void transformSerialize(EncoderProvider encoderProvider,java.lang.Object toSerialize, javax.xml.transform.Result result, javax.xml.transform.Source template) throws IOException, TransformerException
	{
		PipedInputStream inpipe = new PipedInputStream();
		PipedOutputStream outpipe = new PipedOutputStream( inpipe );
		XMLEncoder enc=encoderProvider.create(outpipe);
		enc.writeObject(toSerialize);
		enc.flush();
		enc.close();
		TransformerFactory tFactory = TransformerFactory.newInstance();
		Transformer transformer = tFactory.newTransformer( template );
		StreamSource xmlsource = new StreamSource( inpipe );
		transformer.transform( xmlsource, result );
	}
	public static java.lang.Object transformDeserialize(java.io.InputStream is, java.io.InputStream template) throws IOException, TransformerException
	{
		StreamSource xmlsource = new StreamSource(is);
		StreamSource xslsource = new StreamSource(template);
		java.lang.Object rv=transformDeserialize(xmlsource,xslsource);
		is.close();
		template.close();
		return rv;
	}
	public static java.lang.Object transformDeserialize(javax.xml.transform.Source input, javax.xml.transform.Source template) throws IOException, TransformerException
	{
		PipedInputStream inpipe=startDeserializatioThread(input,template);
		java.beans.XMLDecoder dec=new java.beans.XMLDecoder(inpipe);
		java.lang.Object rv=dec.readObject();
		dec.close();
		inpipe.close();
		return rv;
	}

	protected static PipedInputStream startDeserializatioThread(Source input, Source template) throws IOException
	{
		PipedOutputStream outpipe = new PipedOutputStream( );
		PipedInputStream inpipe = new PipedInputStream(outpipe);
		new Thread()
		{
			public void run()
			{
				TransformerFactory tFactory = TransformerFactory.newInstance();
				Transformer transformer = null;
				try
				{
					transformer = tFactory.newTransformer(template);
					StreamResult xmlresult = new StreamResult(outpipe);
					transformer.transform(input, xmlresult);
					outpipe.close();
				} catch (TransformerConfigurationException e)
				{
					e.printStackTrace();
				} catch (TransformerException e)
				{
					e.printStackTrace();
				} catch (IOException e)
				{
					e.printStackTrace();
				}
			}
		}.start();
		return inpipe;
	}
}