1 files changed, 152 insertions, 0 deletions
diff --git a/sandbox/old/contrib/binding-celtix/binding/src/test/java/org/apache/tuscany/binding/celtix/CeltixServiceTestCase.java b/sandbox/old/contrib/binding-celtix/binding/src/test/java/org/apache/tuscany/binding/celtix/CeltixServiceTestCase.java
new file mode 100644
index 0000000000..c667ed2ba2
--- /dev/null
+++ b/sandbox/old/contrib/binding-celtix/binding/src/test/java/org/apache/tuscany/binding/celtix/CeltixServiceTestCase.java
@@ -0,0 +1,152 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.binding.celtix;
+
+import java.lang.reflect.Type;
+import java.net.URL;
+import java.util.HashMap;
+import java.util.Map;
+import javax.wsdl.Definition;
+import javax.wsdl.Port;
+import javax.wsdl.Service;
+import javax.wsdl.factory.WSDLFactory;
+import javax.wsdl.xml.WSDLReader;
+import javax.xml.namespace.QName;
+
+import org.xml.sax.InputSource;
+
+import org.apache.tuscany.spi.idl.java.JavaServiceContract;
+import org.apache.tuscany.spi.model.Operation;
+import org.apache.tuscany.spi.wire.InboundInvocationChain;
+import org.apache.tuscany.spi.wire.InboundWire;
+import org.apache.tuscany.spi.wire.Interceptor;
+import org.apache.tuscany.spi.wire.Message;
+import org.apache.tuscany.spi.wire.MessageImpl;
+import org.apache.tuscany.spi.wire.WireService;
+
+import junit.framework.TestCase;
+import org.easymock.classextension.EasyMock;
+import org.objectweb.celtix.Bus;
+import org.objectweb.celtix.bindings.BindingManager;
+import static org.objectweb.celtix.bindings.DataBindingCallback.Mode.PARTS;
+import org.objectweb.celtix.bindings.ServerBindingEndpointCallback;
+import org.objectweb.celtix.bindings.ServerDataBindingCallback;
+import org.objectweb.celtix.bus.bindings.soap.SOAPBindingFactory;
+import org.objectweb.celtix.bus.bindings.soap.SOAPServerBinding;
+import org.objectweb.celtix.context.ObjectMessageContextImpl;
+import org.objectweb.celtix.ws.addressing.EndpointReferenceType;
+
+/**
+ * @version $Rev$ $Date$
+ */
+public class CeltixServiceTestCase extends TestCase {
+
+    public void testGetDataBindingCallback() throws Exception {
+        CeltixServiceBinding celtixService = createCeltixService();
+        Message msg = new MessageImpl();
+        msg.setBody("Hello Celtix");
+        Interceptor interceptor = EasyMock.createMock(Interceptor.class);
+        EasyMock.expect(interceptor.invoke(EasyMock.isA(Message.class))).andReturn(msg);
+        EasyMock.replay(interceptor);
+        InboundInvocationChain chain = EasyMock.createMock(InboundInvocationChain.class);
+        EasyMock.expect(chain.getHeadInterceptor()).andReturn(interceptor);
+        EasyMock.replay(chain);
+        Map<Operation<?>, InboundInvocationChain> chains = new HashMap<Operation<?>, InboundInvocationChain>();
+        Operation<?> op = new Operation<Type>("greetMe", null, null, null);
+        chains.put(op, chain);
+        InboundWire wire = EasyMock.createMock(InboundWire.class);
+        EasyMock.expect(wire.getInvocationChains()).andReturn(chains);
+        EasyMock.replay(wire);
+        celtixService.setInboundWire(wire);
+        QName operationName = new QName("greetMe");
+        ObjectMessageContextImpl ctx = new ObjectMessageContextImpl();
+        ctx.setMessageObjects(new String[]{"Celtix"});
+        ServerDataBindingCallback callback1 = celtixService.getDataBindingCallback(operationName, ctx, PARTS);
+        assertNotNull(callback1);
+
+        callback1.invoke(ctx);
+        Message rtn = (Message) ctx.getReturn();
+        assertEquals("Hello Celtix", rtn.getBody());
+
+    }
+
+    @SuppressWarnings({"unchecked"})
+    private CeltixServiceBinding createCeltixService() throws Exception {
+        //Make following call to return a mocked SOAPClientBinding:
+        //bus.getBindingManager().getBindingFactory(bindingId).createClientBinding(reference)
+        SOAPServerBinding serverBinding = EasyMock.createMock(SOAPServerBinding.class);
+        serverBinding.activate();
+        EasyMock.replay(serverBinding);
+
+        //ServerBindingEndpointCallback callback = EasyMock.createNiceMock(ServerBindingEndpointCallback.class);
+
+        SOAPBindingFactory bindingFactory = EasyMock.createNiceMock(SOAPBindingFactory.class);
+        bindingFactory.createServerBinding(EasyMock.isA(EndpointReferenceType.class),
+            EasyMock.isA(ServerBindingEndpointCallback.class));
+        EasyMock.expectLastCall().andReturn(serverBinding);
+        EasyMock.replay(bindingFactory);
+
+        BindingManager bindingManager = EasyMock.createNiceMock(BindingManager.class);
+        String bindingId = "http://schemas.xmlsoap.org/wsdl/soap/";
+        bindingManager.getBindingFactory(bindingId);
+        EasyMock.expectLastCall().andReturn(bindingFactory);
+
+        Bus bus = EasyMock.createNiceMock(Bus.class);
+        bus.getBindingManager();
+        EasyMock.expectLastCall().andReturn(bindingManager);
+        EasyMock.replay(bindingManager);
+        EasyMock.replay(bus);
+
+        //Create WSDL Definition
+        String wsdlLocation = "/wsdl/hello_world_doc_lit.wsdl";
+        URL url = getClass().getResource(wsdlLocation);
+        assertNotNull("Could not find wsdl " + url.toString(), url);
+
+        WSDLFactory factory = WSDLFactory.newInstance();
+        WSDLReader reader = factory.newWSDLReader();
+        reader.setFeature("javax.wsdl.verbose", false);
+        InputSource input = new InputSource(url.openStream());
+        Definition wsdlDef = reader.readWSDL(url.toString(), input);
+        Service wsdlService = wsdlDef.getService(new QName("http://objectweb.org/hello_world_soap_http",
+            "SOAPService"));
+        Port port = wsdlService.getPort("SoapPort");
+
+        WebServiceBindingDefinition wsBinding = new WebServiceBindingDefinition(wsdlDef, port, "uri", "portURI", wsdlService);
+
+        //Create mocked InboundWire, for ServiceBindingExtension.getInterface()
+        InboundWire inboundWire = EasyMock.createNiceMock(InboundWire.class);
+        JavaServiceContract contract = new JavaServiceContract(Greeter.class);
+        EasyMock.expect(inboundWire.getServiceContract()).andReturn(contract).anyTimes();
+        EasyMock.replay(inboundWire);
+
+        //Create mocked WireService, for ServiceBindingExtension.getServiceInstance()
+        WireService wireService = EasyMock.createNiceMock(WireService.class);
+        wireService.createProxy(EasyMock.isA(Class.class), EasyMock.isA(InboundWire.class));
+        EasyMock.expectLastCall().andReturn(new GreeterImpl()).anyTimes();
+        EasyMock.replay(wireService);
+
+        CeltixServiceBinding celtixService = new CeltixServiceBinding("name", null, wsBinding, bus, null);
+        //Not sure how InboundWire is set to CeltixServiceBinding, is the following way correct?
+        celtixService.setInboundWire(inboundWire);
+        celtixService.start();
+
+        return celtixService;
+    }
+
+}