/**
 * 
 */
package at.knowcenter.wag.egov.egiz.sig.connectors.moa;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.util.Properties;
import java.util.Vector;

import javax.xml.namespace.QName;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.rpc.Call;
import javax.xml.rpc.Service;
import javax.xml.rpc.ServiceFactory;

import org.apache.axis.message.SOAPBodyElement;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.xml.serialize.OutputFormat;
import org.apache.xml.serialize.XMLSerializer;
import org.w3c.dom.Document;

import at.knowcenter.wag.egov.egiz.exceptions.WebException;
import at.knowcenter.wag.egov.egiz.sig.connectors.bku.BKUPostConnection;

/**
 * @author wprinz
 * 
 */
public final class MOASoapConnection
{
  /**
   * MOA siganture verification mode
   */
  public static final String SERVICE_VERIFY = "SignatureVerification"; //$NON-NLS-1$

  /**
   * MOA siganture creation mode
   */
  public static final String SERVICE_SIGN = "SignatureCreation"; //$NON-NLS-1$

  /**
   * The log.
   */
  private static Log log = LogFactory.getLog(MOASoapConnection.class);

  /**
   * This method connects the moa server getting the requestString, the given
   * serviseMode and the endpointUrl. The requestString is the envelope of the
   * SOAP Message send and recieve by the AXIS module. The Response SOAP message
   * of the MOA server is parsed by AXIS and the message envelope is send back
   * to the calling method.
   * 
   * @param requestString
   *          the request string (XML) to send.
   * @param serviceMode
   *          the mode which connect to MOA
   * @param endpointURL
   *          the URL which the MOA server is running
   * @return the response string (XML) of the MOA server
   * @throws WebException
   */
  public static Properties connectMOA(String requestString, String serviceMode,
      String endpointURL) throws WebException
  {
    try
    {
      if (log.isInfoEnabled())
      {
        log.info(serviceMode);
        log.info(endpointURL);
      }
      // Parser/DOMBuilder instanzieren
      DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
      factory.setNamespaceAware(true);
      DocumentBuilder builder = factory.newDocumentBuilder();

      // XML Datei in einen DOM-Baum umwandeln
      ByteArrayInputStream bais = new ByteArrayInputStream(requestString.getBytes("UTF-8")); //$NON-NLS-1$
      Document xmlRequest = builder.parse(bais);

      // Call öffnen
      Call call = null;

      // Neues BodyElement anlegen und mit dem DOM-Baum füllen
      SOAPBodyElement body = new SOAPBodyElement(xmlRequest.getDocumentElement());
      SOAPBodyElement[] params = new SOAPBodyElement[] { body };

      // AXIS-Server instanzieren
      Service service = ServiceFactory.newInstance().createService(new QName(serviceMode));
      call = service.createCall();
      call.setTargetEndpointAddress(endpointURL);

      // Call auslösen und die Antworten speichern
      log.debug("Calling MOA: " + endpointURL); //$NON-NLS-1$
      Vector responses = (Vector) call.invoke(params);

      // Erstes Body Element auslesen
      SOAPBodyElement response = (SOAPBodyElement) responses.get(0);

      // Aus der Response den DOM-Baum lesen
      Document root_response = response.getAsDocument();
      log.debug("Return from MOA: " + serviceMode); //$NON-NLS-1$

      // XML-Formatierung konfiguieren
      OutputFormat format = new OutputFormat((Document) root_response);
      format.setLineSeparator("\n"); //$NON-NLS-1$
      format.setIndenting(false);
      format.setPreserveSpace(true);
      format.setOmitXMLDeclaration(false);
      format.setEncoding("UTF-8"); //$NON-NLS-1$

      // Ausgabe der Webservice-Antwort auf die Konsole
      // XMLSerializer conSerializer = new XMLSerializer(System.out, format);
      // conSerializer.serialize(root_response);

      // Ausgabe der Webservice-Antwort in Datei
      ByteArrayOutputStream baos = new ByteArrayOutputStream();
      XMLSerializer response_serializer = new XMLSerializer(baos, format);
      response_serializer.serialize(root_response);
      String response_string = baos.toString("UTF-8"); //$NON-NLS-1$

      Properties response_properties = new Properties();
      response_properties.setProperty(BKUPostConnection.RESPONSE_STRING_KEY, response_string);

      return response_properties;
    }
    catch (Exception e)
    {
      throw new WebException(330, e);
    }
    // serialize signature only

    // if
    // (root_response.getDocumentElement().getLocalName().equals("CreateXMLSignatureResponse"))
    // {
    // Element signature = (Element)
    // root_response.getElementsByTagNameNS("http://www.w3.org/2000/09/xmldsig#",
    // "Signature").item(0);
    // String signatureFile = getProperty(mode + "Request").substring(0,
    // getProperty(mode +
    // "Request").lastIndexOf('.')) + ".Signature.xml";
    // fileSerializer = new XMLSerializer(new FileOutputStream(signatureFile),
    // format);
    // fileSerializer.serialize(signature);
    // }

  }

}