package org.apache.tuscany.binding.axis2.handler;

import java.io.IOException;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.ListIterator;

import javax.wsdl.Part;
import javax.xml.namespace.QName;
import javax.xml.stream.XMLStreamException;

import org.apache.axis2.AxisFault;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.OperationContext;
import org.apache.axis2.description.AxisOperation;
import org.apache.axis2.engine.MessageReceiver;
import org.apache.axis2.om.OMAbstractFactory;
import org.apache.axis2.om.OMDocument;
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMFactory;
import org.apache.axis2.om.OMNamespace;
import org.apache.axis2.receivers.AbstractInOutSyncMessageReceiver;
import org.apache.axis2.soap.SOAPBody;
import org.apache.axis2.soap.SOAPEnvelope;
import org.apache.axis2.soap.SOAPFactory;
import org.apache.tuscany.binding.axis2.util.AxiomHelper;
import org.apache.tuscany.core.context.AggregateContext;
import org.apache.tuscany.core.context.EntryPointContext;
import org.apache.tuscany.core.context.InstanceContext;
import org.apache.tuscany.model.assembly.EntryPoint;
import org.apache.tuscany.sdo.helper.TypeHelperImpl;
import org.apache.tuscany.sdo.util.SDOUtil;
import org.apache.wsdl.WSDLConstants;
import org.eclipse.emf.common.util.UniqueEList;

import commonj.sdo.DataObject;
import commonj.sdo.Property;
import commonj.sdo.Sequence;
import commonj.sdo.Type;
import commonj.sdo.helper.TypeHelper;

public class WebServiceEntryPointInOutSyncMessageReceiver extends AbstractInOutSyncMessageReceiver {
    // public static final String MEP_URL = "http://www.w3.org/2004/08/wsdl/tuscany/in-out";
    public static final String MEP_URL = WSDLConstants.MEP_URI_OUT_IN;

    protected final AggregateContext moduleContext;

    protected final EntryPoint entryPoint;
    protected final EntryPointContext entryPointContext;

    private final WebServicePortMetaData wsdlPortInfo;

    /**
     * Field log
     */

    /**
     * Constructor WebServiceEntryPointInOutSyncMessageReceiver
     * 
     * @param entryPoint
     * @param moduleContext
     * @param context 
     * @param wsdlPortInfo 
     */
    public WebServiceEntryPointInOutSyncMessageReceiver(AggregateContext moduleContext, EntryPoint entryPoint, EntryPointContext context, WebServicePortMetaData wsdlPortInfo) {
        this.moduleContext = moduleContext;
        this.entryPoint = entryPoint;
        this.entryPointContext= context;
        this.wsdlPortInfo = wsdlPortInfo;
    }

    public void invokeBusinessLogic(MessageContext msgContext, MessageContext outMsgContext) throws AxisFault {
        
        ClassLoader ccl=Thread.currentThread().getContextClassLoader();
        try {
            Thread.currentThread().setContextClassLoader(entryPoint.getAggregate().getAssemblyModelContext().getApplicationResourceLoader().getClassLoader());
            
            AxisOperation axisOperation = msgContext.getAxisOperation();
            String axisOperationName= axisOperation.getName().getLocalPart();
            
            TypeHelper typeHelper=entryPoint.getAggregate().getAssemblyModelContext().getTypeHelper();

            OMElement requestOM = msgContext.getEnvelope().getBody().getFirstElement();
            DataObject msgdo = AxiomHelper.toDataObject(typeHelper, requestOM);
           // Sequence parmSeq = msgdo.getSequence("mixed");
            
             requestOM = msgContext.getEnvelope().getBody().getFirstElement();
            Object[] args = AxiomHelper.toObjects(typeHelper, requestOM);
            
            
            
            
//            ArrayList parms = new ArrayList(parmSeq.size());
//            for (int i = 0; i < parmSeq.size(); ++i) {
//                Object parmDO = (Object) parmSeq.getValue(i);// parm element
//                if (parmDO instanceof DataObject) {
//
//                    Sequence nn = ((DataObject) parmDO).getSequence("mixed");
//
//                    for (int j = 0; j < nn.size(); j++) {
//
//                        Object valueDO = (Object) nn.getValue(j); // data array s
//                        if (valueDO instanceof DataObject) {
//
//                            Sequence seqVal = ((DataObject) valueDO).getSequence("mixed");
//                            Object seqDO = seqVal.getValue(0);
//                            if (seqDO instanceof String) {
//                                parms.add(seqDO);
//                            } else {
//                                parms.add(valueDO); // no sure if this is right?
//
//                            }
//                        }
//                    }
//                }
//            }
//            Object[] args= parms.toArray(new Object[parms.size()]);
            Class[] argsClazz= new Class[args.length];
            for(int i= args.length -1; i> -1; --i){
                argsClazz[i]= args[i].getClass();
                
            }
            Class clazz = entryPoint.getConfiguredService().getService().getServiceContract().getInterface();
            Method operationMethod= clazz.getMethod(axisOperationName, argsClazz);
            
             
            InvocationHandler handler = (InvocationHandler) entryPointContext.getImplementationInstance();
           
         
            Object response = handler.invoke(null, operationMethod,  args);
           
          
            SOAPFactory fac = getSOAPFactory(msgContext);
           SOAPEnvelope soapenv = fac.getDefaultEnvelope();
            SOAPBody soapbody = soapenv.getBody();
             //new SDO way....
            QName responseTypeQN = getResponseTypeName(operationMethod.getName());
            OMElement responseOM = AxiomHelper.toOMElement(typeHelper, new Object[] {response}, responseTypeQN);
            soapbody.addChild(responseOM);
            
            

            //Endof new SDO way
            
            
            
            
            
            // se.addChild(sf.createText(response, true));
            outMsgContext.setEnvelope(soapenv);
            // outMsgContext.setAxisOperation(axisOperation);
            // outMsgContext.setAxisService(msgContext.getAxisService());
         

        } catch (Exception e) {
            e.printStackTrace();
            throw new AxisFault("Error creating DataObject from Soapenvelope. " + e.getClass() + " " + e.getMessage(), e);

        } catch (Throwable e) {
            
            e.printStackTrace();
            throw new AxisFault("Error creating DataObject from Soapenvelope. " + e.getClass() + " " + e.getMessage(), e);
        } finally {
            Thread.currentThread().setContextClassLoader(ccl);
        }

    }
    protected QName getResponseTypeName(String operationName) {
        WebServiceOperationMetaData op = wsdlPortInfo.getOperationMetaData(operationName);
        Part part =  op.getOutputPart(0);
        QName elementName = part.getElementName();
        return elementName;
    }


}