1 files changed, 310 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-M1-final/java/sca/core/src/test/java/org/apache/tuscany/core/system/context/AutowireTestCase.java b/sca-java-1.x/tags/java-M1-final/java/sca/core/src/test/java/org/apache/tuscany/core/system/context/AutowireTestCase.java
new file mode 100644
index 0000000000..6316fe3a67
--- /dev/null
+++ b/sca-java-1.x/tags/java-M1-final/java/sca/core/src/test/java/org/apache/tuscany/core/system/context/AutowireTestCase.java
@@ -0,0 +1,310 @@
+/**
+ *
+ * Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ * Licensed 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.core.system.context;
+
+import junit.framework.TestCase;
+import org.apache.tuscany.core.context.CompositeContext;
+import org.apache.tuscany.core.context.SystemCompositeContext;
+import org.apache.tuscany.core.context.impl.CompositeContextImpl;
+import org.apache.tuscany.core.context.event.ModuleStop;
+import org.apache.tuscany.core.context.event.ModuleStart;
+import org.apache.tuscany.core.mock.MockFactory;
+import org.apache.tuscany.core.mock.component.AutowireSourceImpl;
+import org.apache.tuscany.core.mock.component.Source;
+import org.apache.tuscany.core.mock.component.Target;
+import org.apache.tuscany.core.mock.component.TargetImpl;
+import org.apache.tuscany.core.runtime.RuntimeContext;
+import org.apache.tuscany.core.system.assembly.SystemAssemblyFactory;
+import org.apache.tuscany.core.system.assembly.impl.SystemAssemblyFactoryImpl;
+import org.apache.tuscany.core.config.ConfigurationLoadException;
+import org.apache.tuscany.model.assembly.AssemblyContext;
+import org.apache.tuscany.model.assembly.Component;
+import org.apache.tuscany.model.assembly.EntryPoint;
+import org.apache.tuscany.model.assembly.Module;
+import org.apache.tuscany.model.assembly.ModuleComponent;
+import org.apache.tuscany.model.assembly.Scope;
+import org.apache.tuscany.model.assembly.Service;
+import org.apache.tuscany.model.assembly.impl.AssemblyContextImpl;
+
+/**
+ * Tests autowiring for serveral scenarios according to the following runtime scheme:
+ * 
+ * <code>
+ *       tuscany.runtime
+ *        |
+ *        + tuscany.system
+ *        |   |
+ *        |   + system1
+ *        |   |   |
+ *        |   |   + system1a
+ *        |   |
+ *        |   + system2
+ *        |
+ *        + tuscany.root
+ *            |
+ *            + app1
+ *                |
+ *                + app1a
+ *                |
+ *                + app1b
+ * </code>
+ * 
+ * @version $Rev$ $Date$
+ */
+public class AutowireTestCase extends TestCase {
+
+    private static SystemAssemblyFactory systemFactory = new SystemAssemblyFactoryImpl();
+
+    /**
+     * Covers the case where a component in app1a requests autowire, which is resolved by the runtime to a service
+     * exposed on an entry point in tuscany.system. The entry point is wired to an entry point on system1, which itself
+     * is wired to a component in system1
+     */
+    public void testScenario1() throws Exception {
+        RuntimeContext runtime = createScenario1Runtime();
+        CompositeContext root = runtime.getRootContext();
+        SystemCompositeContext system = runtime.getSystemContext();
+        CompositeContext system1 = (CompositeContext) system.getContext("system1");
+        system1.publish(new ModuleStart(this));
+        Target target = (Target) system.getContext("target.system.ep").getInstance(null);
+        assertNotNull(target);
+        CompositeContext app1 = (CompositeContext) root.getContext("app1");
+        app1.publish(new ModuleStart(this));
+        CompositeContext app1a = (CompositeContext) app1.getContext("app1a");
+        app1a.publish(new ModuleStart(this));
+        app1a.publish(new ModuleStop(this));
+        app1.publish(new ModuleStop(this));
+        Source source = (Source) app1a.getContext("source").getInstance(null);
+        assertEquals(target, source.getTarget());
+        source.getTarget().getString();
+        runtime.stop();
+    }
+
+    /**
+     * Covers the case where a component in app1a requests autowire, which is resolved to service exposed as an entry
+     * point on app1b. The entry point is wired to a component in app1b.
+     */
+    public void testScenario2() throws Exception {
+        RuntimeContext runtime = createScenario2Runtime();
+        CompositeContext root = runtime.getRootContext();
+        CompositeContext app1 = (CompositeContext) root.getContext("app1");
+        app1.publish(new ModuleStart(this));
+        CompositeContext app1b = (CompositeContext) app1.getContext("app1b");
+        app1b.publish(new ModuleStart(this));
+        CompositeContext app1a = (CompositeContext) app1.getContext("app1a");
+        app1a.publish(new ModuleStart(this));
+        Target target = (Target) app1b.getContext("target.ep").getInstance(null);
+        assertNotNull(target);
+        Source source = (Source) app1a.getContext("source").getInstance(null);
+        assertEquals(target, source.getTarget());
+        source.getTarget().getString();
+        runtime.stop();
+    }
+
+    /**
+     * Covers the case where a component in system1a requests autowire, which is resolved to an entry point exposed on
+     * system2. The entry point is wired to a component in system2.
+     */
+    public void testScenario3() throws Exception {
+        RuntimeContext runtime = createScenario3Runtime();
+        SystemCompositeContext system = runtime.getSystemContext();
+
+        CompositeContext system2 = (CompositeContext) system.getContext("system2");
+        system2.publish(new ModuleStart(this));
+        Target target = (Target) system2.getContext("target.ep").getInstance(null);
+        assertNotNull(target);
+
+        CompositeContext system1 = (CompositeContext) system.getContext("system1");
+        system1.publish(new ModuleStart(this));
+        CompositeContext system1a = (CompositeContext) system1.getContext("system1a");
+        system1a.publish(new ModuleStart(this));
+
+        Source source = (Source) system1a.getContext("source").getInstance(null);
+        assertEquals(target, source.getTarget());
+        source.getTarget().getString();
+        runtime.stop();
+    }
+
+    /**
+     * Covers the case where a component in system1a requests autowire, which is resolved to component in its parent,
+     * system1.
+     */
+    public void testScenario4() throws Exception {
+        RuntimeContext runtime = createScenario4Runtime();
+        SystemCompositeContext system = runtime.getSystemContext();
+        CompositeContext system1 = (CompositeContext) system.getContext("system1");
+        system1.publish(new ModuleStart(this));
+        Target target = (Target) system1.getContext("target").getInstance(null);
+        assertNotNull(target);
+        CompositeContext system1a = (CompositeContext) system1.getContext("system1a");
+        system1a.publish(new ModuleStart(this));
+
+        Source source = (Source) system1a.getContext("source").getInstance(null);
+        assertEquals(target, source.getTarget());
+        source.getTarget().getString();
+        runtime.stop();
+    }
+
+    /**
+     * Covers the case where a component in system1a requests autowire, which is resolved to component in the parent of
+     * its parent (grandparent), system.
+     */
+    public void testScenario5() throws Exception {
+        RuntimeContext runtime = createScenario5Runtime();
+        SystemCompositeContext system = runtime.getSystemContext();
+        CompositeContext system1 = (CompositeContext) system.getContext("system1");
+        system1.publish(new ModuleStart(this));
+        Target target = (Target) system.getContext("target").getInstance(null);
+        assertNotNull(target);
+        CompositeContext system1a = (CompositeContext) system1.getContext("system1a");
+        system1a.publish(new ModuleStart(this));
+
+        Source source = (Source) system1a.getContext("source").getInstance(null);
+        assertEquals(target, source.getTarget());
+        source.getTarget().getString();
+        runtime.stop();
+    }
+
+    private RuntimeContext createScenario1Runtime() throws Exception {
+        RuntimeContext runtime = MockFactory.createCoreRuntime();
+        runtime.start();
+        SystemCompositeContext system = runtime.getSystemContext();
+        ModuleComponent system1Component = MockFactory.createSystemCompositeComponent("system1");
+        ModuleComponent system1aComponent = MockFactory.createSystemCompositeComponent("system1a");
+        system1Component.getImplementation().getComponents().add(system1aComponent);
+        Component target = MockFactory.createSystemComponent("target", Target.class, TargetImpl.class, Scope.MODULE);
+        system1Component.getImplementation().getComponents().add(target);
+
+        EntryPoint ep = MockFactory.createEPSystemBinding("target.ep", Target.class, "target", target);
+        system1Component.getImplementation().getEntryPoints().add(ep);
+        system.registerModelObject(system1Component);
+        EntryPoint systemEp = MockFactory.createEPSystemBinding("target.system.ep", Target.class, "ref");
+
+        systemEp.getBindings().add(systemFactory.createSystemBinding());
+        Service service = systemFactory.createService();
+        service.setName("system1/target.ep");
+        (systemEp.getConfiguredReference().getTargetConfiguredServices().get(0)).setPort(service);
+
+        system.registerModelObject(systemEp);
+        ModuleComponent app1Component = createAppModuleComponent("app1");
+        ModuleComponent app1aComponent = createAppModuleComponent("app1a");
+        Component source = MockFactory.createSystemComponent("source", Source.class, AutowireSourceImpl.class, Scope.MODULE);
+        app1aComponent.getImplementation().getComponents().add(source);
+        app1Component.getImplementation().getComponents().add(app1aComponent);
+        CompositeContext root = runtime.getRootContext();
+        root.registerModelObject(app1Component);
+        system.publish(new ModuleStart(this));
+        return runtime;
+    }
+
+    private RuntimeContext createScenario2Runtime() throws Exception {
+        RuntimeContext runtime = MockFactory.createCoreRuntime();
+        runtime.start();
+
+        ModuleComponent app1Component = createAppModuleComponent("app1");
+        ModuleComponent app1aComponent = createAppModuleComponent("app1a");
+        ModuleComponent app1bComponent = createAppModuleComponent("app1b");
+        Component source = MockFactory.createSystemComponent("source", Source.class, AutowireSourceImpl.class, Scope.MODULE);
+        app1aComponent.getImplementation().getComponents().add(source);
+        app1Component.getImplementation().getComponents().add(app1aComponent);
+        app1Component.getImplementation().getComponents().add(app1bComponent);
+
+        Component target = MockFactory.createSystemComponent("target", Target.class, TargetImpl.class, Scope.MODULE);
+        app1bComponent.getImplementation().getComponents().add(target);
+
+        EntryPoint ep = MockFactory.createEPSystemBinding("target.ep", Target.class, "target", target);
+        ep.getBindings().add(systemFactory.createSystemBinding());
+        Service service = systemFactory.createService();
+        service.setName("target.ep");
+        ep.getConfiguredReference().getTargetConfiguredServices().get(0).setPort(service);
+        app1bComponent.getImplementation().getEntryPoints().add(ep);
+
+        CompositeContext root = runtime.getRootContext();
+        root.registerModelObject(app1Component);
+        return runtime;
+    }
+
+    private RuntimeContext createScenario3Runtime() throws Exception {
+        RuntimeContext runtime = MockFactory.createCoreRuntime();
+        runtime.start();
+        SystemCompositeContext system = runtime.getSystemContext();
+        ModuleComponent system1Component = MockFactory.createSystemCompositeComponent("system1");
+        ModuleComponent system2Component = MockFactory.createSystemCompositeComponent("system2");
+        ModuleComponent system1aComponent = MockFactory.createSystemCompositeComponent("system1a");
+        system1Component.getImplementation().getComponents().add(system1aComponent);
+
+        Component target = MockFactory.createSystemComponent("target", Target.class, TargetImpl.class, Scope.MODULE);
+        system2Component.getImplementation().getComponents().add(target);
+        EntryPoint ep = MockFactory.createEPSystemBinding("target.ep", Target.class, "target", target);
+        system2Component.getImplementation().getEntryPoints().add(ep);
+        system.registerModelObject(system2Component);
+
+        Component source = MockFactory.createSystemComponent("source", Source.class, AutowireSourceImpl.class, Scope.MODULE);
+        system1aComponent.getImplementation().getComponents().add(source);
+        system.registerModelObject(system1Component);
+        system.publish(new ModuleStart(this));
+        return runtime;
+    }
+
+    private RuntimeContext createScenario4Runtime() throws Exception {
+        RuntimeContext runtime = MockFactory.createCoreRuntime();
+        runtime.start();
+        SystemCompositeContext system = runtime.getSystemContext();
+        ModuleComponent system1Component = MockFactory.createSystemCompositeComponent("system1");
+        ModuleComponent system1aComponent = MockFactory.createSystemCompositeComponent("system1a");
+        system1Component.getImplementation().getComponents().add(system1aComponent);
+
+        Component target = MockFactory.createSystemComponent("target", Target.class, TargetImpl.class, Scope.MODULE);
+        system1Component.getImplementation().getComponents().add(target);
+
+        Component source = MockFactory.createSystemComponent("source", Source.class, AutowireSourceImpl.class, Scope.MODULE);
+        system1aComponent.getImplementation().getComponents().add(source);
+        system.registerModelObject(system1Component);
+        system.publish(new ModuleStart(this));
+        return runtime;
+    }
+
+    private RuntimeContext createScenario5Runtime() throws Exception {
+        RuntimeContext runtime = MockFactory.createCoreRuntime();
+        runtime.start();
+        SystemCompositeContext system = runtime.getSystemContext();
+        ModuleComponent system1Component = MockFactory.createSystemCompositeComponent("system1");
+        ModuleComponent system1aComponent = MockFactory.createSystemCompositeComponent("system1a");
+        system1Component.getImplementation().getComponents().add(system1aComponent);
+
+        Component target = MockFactory.createSystemComponent("target", Target.class, TargetImpl.class, Scope.MODULE);
+        system.registerModelObject(target);
+
+        Component source = MockFactory.createSystemComponent("source", Source.class, AutowireSourceImpl.class, Scope.MODULE);
+        system1aComponent.getImplementation().getComponents().add(source);
+        system.registerModelObject(system1Component);
+        system.publish(new ModuleStart(this));
+        return runtime;
+    }
+
+    private ModuleComponent createAppModuleComponent(String name) throws ConfigurationLoadException {
+        AssemblyContext assemblyContext = new AssemblyContextImpl(systemFactory, null, null);
+        ModuleComponent mc = systemFactory.createModuleComponent();
+        mc.setName(name);
+        Module module = systemFactory.createModule();
+        module.setImplementationClass(CompositeContextImpl.class);
+        module.setComponentType(MockFactory.getComponentType());
+        module.setName(name);
+        module.initialize(assemblyContext);
+        mc.setImplementation(module);
+        return mc;
+    }
+
+}