Fix for TUSCANY-2409

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@675358 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 333 insertions, 145 deletions

diff --git a/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeFactoryImpl.java b/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeFactoryImpl.java
index a37009895c..b032a4fb9a 100644
--- a/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeFactoryImpl.java
+++ b/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeFactoryImpl.java
@@ -19,6 +19,7 @@
 
 package org.apache.tuscany.sca.node.impl;
 
+import org.apache.tuscany.sca.node.SCAContribution;
 import org.apache.tuscany.sca.node.SCANode2;
 import org.apache.tuscany.sca.node.SCANode2Factory;
 
@@ -28,12 +29,16 @@ import org.apache.tuscany.sca.node.SCANode2Factory;
  * @version $Rev$ $Date$
  */
 public class NodeFactoryImpl extends SCANode2Factory {
-    
     public NodeFactoryImpl() {
     }
+    
+    @Override
+    public SCANode2 createSCANodeFromClassLoader(String compositeURI, ClassLoader classLoader) {
+        return new NodeImpl(classLoader, compositeURI);
+    }
 
     @Override
-    public SCANode2 createSCANode(String configurationURI) {
+    public SCANode2 createSCANodeFromURL(String configurationURI) {
         return new NodeImpl(configurationURI);
     }
     
diff --git a/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java b/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java
index 201229b370..17aad5b106 100644
--- a/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java
+++ b/java/sca/modules/node2-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java
@@ -1,31 +1,36 @@
- /*
- * 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.    
- */
+/*
+* 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.sca.node.impl;
 
-import java.io.ByteArrayInputStream;
 import java.io.File;
+import java.io.IOException;
 import java.io.InputStream;
 import java.io.StringReader;
+import java.net.MalformedURLException;
 import java.net.URI;
 import java.net.URL;
 import java.net.URLClassLoader;
+import java.security.AccessController;
+import java.security.PrivilegedAction;
+import java.security.PrivilegedActionException;
+import java.security.PrivilegedExceptionAction;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -44,10 +49,12 @@ import org.apache.tuscany.sca.assembly.Composite;
 import org.apache.tuscany.sca.assembly.CompositeService;
 import org.apache.tuscany.sca.contribution.Contribution;
 import org.apache.tuscany.sca.contribution.ContributionFactory;
+import org.apache.tuscany.sca.contribution.ContributionMetadata;
 import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
 import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
 import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessorExtensionPoint;
 import org.apache.tuscany.sca.contribution.service.ContributionService;
+import org.apache.tuscany.sca.contribution.service.util.FileHelper;
 import org.apache.tuscany.sca.core.ExtensionPointRegistry;
 import org.apache.tuscany.sca.core.UtilityExtensionPoint;
 import org.apache.tuscany.sca.core.assembly.ActivationException;
@@ -60,8 +67,8 @@ import org.apache.tuscany.sca.monitor.MonitorFactory;
 import org.apache.tuscany.sca.monitor.Problem;
 import org.apache.tuscany.sca.monitor.Problem.Severity;
 import org.apache.tuscany.sca.node.SCAClient;
+import org.apache.tuscany.sca.node.SCAContribution;
 import org.apache.tuscany.sca.node.SCANode2;
-import org.apache.tuscany.sca.node.SCANode2Factory.SCAContribution;
 import org.apache.tuscany.sca.runtime.RuntimeComponent;
 import org.apache.tuscany.sca.runtime.RuntimeComponentContext;
 import org.osoa.sca.CallableReference;
@@ -74,12 +81,12 @@ import org.osoa.sca.ServiceRuntimeException;
  * @version $Rev$ $Date$
  */
 public class NodeImpl implements SCANode2, SCAClient {
-	
+
     private static final Logger logger = Logger.getLogger(NodeImpl.class.getName());
-	     
+
     // The node configuration name, used for logging
     private String configurationName;
-    
+
     // The Tuscany runtime that does the hard work
     private ReallySmallRuntime runtime;
     private CompositeActivator compositeActivator;
@@ -88,9 +95,11 @@ public class NodeImpl implements SCANode2, SCAClient {
     private StAXArtifactProcessorExtensionPoint artifactProcessors;
     private Monitor monitor;
 
+    private ContributionMetadata metadata;
+
     // The composite loaded into this node
-    private Composite composite; 
-    
+    private Composite composite;
+
     /** 
      * Constructs a new SCA node.
      *  
@@ -98,20 +107,20 @@ public class NodeImpl implements SCANode2, SCAClient {
      */
     NodeImpl(ConfiguredNodeImplementation configuration) {
         configurationName = configuration.getURI();
-        logger.log(Level.INFO, "Creating node: " + configuration.getURI());               
+        logger.log(Level.INFO, "Creating node: " + configuration.getURI());
 
         try {
             // Initialize the runtime
             initRuntime();
-            
+
             URL configurationURL = new URL(configuration.getURI());
 
             // Resolve contribution URLs
-            for (Contribution contribution: configuration.getContributions()) {
+            for (Contribution contribution : configuration.getContributions()) {
                 URL contributionURL = new URL(configurationURL, contribution.getLocation());
                 contribution.setLocation(contributionURL.toString());
             }
-            
+
             // Resolve composite URL
             URL compositeURL = new URL(configurationURL, configuration.getComposite().getURI());
             configuration.getComposite().setURI(compositeURL.toString());
@@ -121,7 +130,7 @@ public class NodeImpl implements SCANode2, SCAClient {
 
         } catch (Exception e) {
             throw new ServiceRuntimeException(e);
-        }        
+        }
     }
 
     /** 
@@ -131,27 +140,28 @@ public class NodeImpl implements SCANode2, SCAClient {
      */
     NodeImpl(String configurationURI) {
         configurationName = configurationURI;
-        logger.log(Level.INFO, "Creating node: " + configurationName);               
+        logger.log(Level.INFO, "Creating node: " + configurationName);
 
         try {
             // Initialize the runtime
             initRuntime();
-            
+
             // Read the node configuration feed
-            StAXArtifactProcessor<ConfiguredNodeImplementation> configurationProcessor = artifactProcessors.getProcessor(ConfiguredNodeImplementation.class);
+            StAXArtifactProcessor<ConfiguredNodeImplementation> configurationProcessor =
+                artifactProcessors.getProcessor(ConfiguredNodeImplementation.class);
             URL configurationURL = new URL(configurationURI);
             InputStream is = configurationURL.openStream();
             XMLStreamReader reader = inputFactory.createXMLStreamReader(is);
             reader.nextTag();
             ConfiguredNodeImplementation configuration = configurationProcessor.read(reader);
             is.close();
-            
+
             // Resolve contribution URLs
-            for (Contribution contribution: configuration.getContributions()) {
+            for (Contribution contribution : configuration.getContributions()) {
                 URL contributionURL = new URL(configurationURL, contribution.getLocation());
                 contribution.setLocation(contributionURL.toString());
             }
-            
+
             // Resolve composite URL
             URL compositeURL = new URL(configurationURL, configuration.getComposite().getURI());
             configuration.getComposite().setURI(compositeURL.toString());
@@ -161,9 +171,152 @@ public class NodeImpl implements SCANode2, SCAClient {
 
         } catch (Exception e) {
             throw new ServiceRuntimeException(e);
-        }        
+        }
+    }
+
+    NodeImpl(ClassLoader classLoader, String compositeURI) {
+        configurationName = compositeURI;
+        logger.log(Level.INFO, "Creating node: " + configurationName);
+
+        try {
+            // Initialize the runtime
+            initRuntime();
+
+            ConfiguredNodeImplementation config = findNodeConfiguration(compositeURI, classLoader);
+            configureNode(config);
+        } catch (Throwable e) {
+            throw new ServiceRuntimeException(e);
+        }
     }
-    
+
+    private ConfiguredNodeImplementation findNodeConfiguration(final String compositeURI, ClassLoader classLoader)
+        throws Exception {
+        NodeImplementationFactory nodeImplementationFactory =
+            modelFactories.getFactory(NodeImplementationFactory.class);
+        ConfiguredNodeImplementation config = nodeImplementationFactory.createConfiguredNodeImplementation();
+
+        if (classLoader == null) {
+            classLoader = Thread.currentThread().getContextClassLoader();
+        }
+        String contributionArtifactPath = compositeURI;
+        URL contributionArtifactURL = null;
+        if (compositeURI != null) {
+            contributionArtifactURL = getResource(classLoader, compositeURI);
+            if (contributionArtifactURL == null) {
+                throw new IllegalArgumentException("Composite not found: " + contributionArtifactPath);
+            }
+            composite = createComposite(contributionArtifactURL.toString());
+            config.setComposite(composite);
+        } else {
+
+            // Here the SCADomain was started without any reference to a composite file
+            // We are going to look for an sca-contribution.xml or sca-contribution-generated.xml
+
+            // Look for META-INF/sca-contribution.xml
+            contributionArtifactPath = Contribution.SCA_CONTRIBUTION_META;
+            contributionArtifactURL = getResource(classLoader, contributionArtifactPath);
+
+            // Look for META-INF/sca-contribution-generated.xml
+            if (contributionArtifactURL == null) {
+                contributionArtifactPath = Contribution.SCA_CONTRIBUTION_GENERATED_META;
+                contributionArtifactURL = getResource(classLoader, contributionArtifactPath);
+            }
+
+            // Look for META-INF/sca-deployables directory
+            if (contributionArtifactURL == null) {
+                contributionArtifactPath = Contribution.SCA_CONTRIBUTION_DEPLOYABLES;
+                contributionArtifactURL = getResource(classLoader, contributionArtifactPath);
+            } else {
+                StAXArtifactProcessor<ContributionMetadata> processor =
+                    artifactProcessors.getProcessor(ContributionMetadata.class);
+                XMLStreamReader reader = inputFactory.createXMLStreamReader(contributionArtifactURL.openStream());
+                metadata = processor.read(reader);
+                reader.close();
+                if (metadata.getDeployables().isEmpty()) {
+                    throw new IllegalArgumentException(
+                                                       "No deployable composite is declared in " + contributionArtifactPath);
+                }
+            }
+        }
+
+        if (contributionArtifactURL == null) {
+            throw new IllegalArgumentException(
+                                               "Can't determine contribution deployables. Either specify a composite file, or use an sca-contribution.xml file to specify the deployables.");
+        }
+
+        Contribution c = getContribution(contributionArtifactURL, contributionArtifactPath);
+        config.getContributions().add(c);
+
+        return config;
+    }
+
+    private Contribution getContribution(URL contributionArtifactURL, String contributionArtifactPath) {
+        URL contributionURL = getContributionURL(contributionArtifactURL, contributionArtifactPath);
+
+        ContributionFactory contributionFactory = modelFactories.getFactory(ContributionFactory.class);
+
+        SCAContribution contribution = new SCAContribution(contributionURL.toString(), contributionURL.toString());
+        Contribution c = createContribution(contributionFactory, contribution);
+        return c;
+    }
+
+    private URL getContributionURL(URL contributionArtifactURL, String contributionArtifactPath) {
+        URL contributionURL = null;
+        // "jar:file://....../something.jar!/a/b/c/app.composite"
+        try {
+            String url = contributionArtifactURL.toExternalForm();
+            String protocol = contributionArtifactURL.getProtocol();
+            if ("file".equals(protocol)) {
+                // directory contribution
+                if (url.endsWith(contributionArtifactPath)) {
+                    final String location = url.substring(0, url.lastIndexOf(contributionArtifactPath));
+                    // workaround from evil URL/URI form Maven
+                    // contributionURL = FileHelper.toFile(new URL(location)).toURI().toURL();
+                    // Allow privileged access to open URL stream. Add FilePermission to added to
+                    // security policy file.
+                    try {
+                        contributionURL = AccessController.doPrivileged(new PrivilegedExceptionAction<URL>() {
+                            public URL run() throws IOException {
+                                return FileHelper.toFile(new URL(location)).toURI().toURL();
+                            }
+                        });
+                    } catch (PrivilegedActionException e) {
+                        throw (MalformedURLException)e.getException();
+                    }
+                }
+
+            } else if ("jar".equals(protocol)) {
+                // jar contribution
+                String location = url.substring(4, url.lastIndexOf("!/"));
+                // workaround for evil URL/URI from Maven
+                contributionURL = FileHelper.toFile(new URL(location)).toURI().toURL();
+
+            } else if ("wsjar".equals(protocol)) {
+                // See https://issues.apache.org/jira/browse/TUSCANY-2219
+                // wsjar contribution 
+                String location = url.substring(6, url.lastIndexOf("!/"));
+                // workaround for evil url/uri from maven 
+                contributionURL = FileHelper.toFile(new URL(location)).toURI().toURL();
+
+            } else if (protocol != null && (protocol.equals("bundle") || protocol.equals("bundleresource"))) {
+                contributionURL =
+                    new URL(contributionArtifactURL.getProtocol(), contributionArtifactURL.getHost(),
+                            contributionArtifactURL.getPort(), "/");
+            }
+        } catch (MalformedURLException mfe) {
+            throw new IllegalArgumentException(mfe);
+        }
+        return contributionURL;
+    }
+
+    private static URL getResource(final ClassLoader classLoader, final String compositeURI) {
+        return AccessController.doPrivileged(new PrivilegedAction<URL>() {
+            public URL run() {
+                return classLoader.getResource(compositeURI);
+            }
+        });
+    }
+
     /** 
      * Constructs a new SCA node.
      *  
@@ -172,31 +325,31 @@ public class NodeImpl implements SCANode2, SCAClient {
      */
     NodeImpl(String compositeURI, SCAContribution[] contributions) {
         configurationName = compositeURI;
-        logger.log(Level.INFO, "Creating node: " + configurationName);               
+        logger.log(Level.INFO, "Creating node: " + configurationName);
 
         try {
             // Initialize the runtime
             initRuntime();
-            
-            // Create a node configuration
-            NodeImplementationFactory nodeImplementationFactory = modelFactories.getFactory(NodeImplementationFactory.class);
-            ConfiguredNodeImplementation configuration = nodeImplementationFactory.createConfiguredNodeImplementation();
-            
-            // Create composite model
-            AssemblyFactory assemblyFactory = modelFactories.getFactory(AssemblyFactory.class);
-            Composite composite = assemblyFactory.createComposite();
-            composite.setURI(compositeURI);
-            composite.setUnresolved(true);
-            configuration.setComposite(composite);
-            
-            // Create contribution models
-            ContributionFactory contributionFactory = modelFactories.getFactory(ContributionFactory.class);
-            for (SCAContribution c: contributions) {
-                Contribution contribution = contributionFactory.createContribution();
-                contribution.setURI(c.getURI());
-                contribution.setLocation(c.getLocation());
-                contribution.setUnresolved(true);
-                configuration.getContributions().add(contribution);
+
+            ConfiguredNodeImplementation configuration = null;
+            if (contributions == null || contributions.length == 0) {
+                configuration = findNodeConfiguration(compositeURI, null);
+            } else {
+
+                // Create a node configuration
+                NodeImplementationFactory nodeImplementationFactory =
+                    modelFactories.getFactory(NodeImplementationFactory.class);
+                configuration = nodeImplementationFactory.createConfiguredNodeImplementation();
+
+                Composite composite = createComposite(compositeURI);
+                configuration.setComposite(composite);
+
+                // Create contribution models
+                ContributionFactory contributionFactory = modelFactories.getFactory(ContributionFactory.class);
+                for (SCAContribution c : contributions) {
+                    Contribution contribution = createContribution(contributionFactory, c);
+                    configuration.getContributions().add(contribution);
+                }
             }
 
             // Configure the node
@@ -204,9 +357,18 @@ public class NodeImpl implements SCANode2, SCAClient {
 
         } catch (Exception e) {
             throw new ServiceRuntimeException(e);
-        }        
+        }
+    }
+
+    private Composite createComposite(String compositeURI) {
+        // Create composite model
+        AssemblyFactory assemblyFactory = modelFactories.getFactory(AssemblyFactory.class);
+        Composite composite = assemblyFactory.createComposite();
+        composite.setURI(compositeURI);
+        composite.setUnresolved(true);
+        return composite;
     }
-    
+
     /** 
      * Constructs a new SCA node.
      *  
@@ -216,33 +378,36 @@ public class NodeImpl implements SCANode2, SCAClient {
      */
     NodeImpl(String compositeURI, String compositeContent, SCAContribution[] contributions) {
         configurationName = compositeURI;
-        logger.log(Level.INFO, "Creating node: " + configurationName);               
+        logger.log(Level.INFO, "Creating node: " + configurationName);
 
         try {
             // Initialize the runtime
             initRuntime();
-            
-            // Create a node configuration
-            NodeImplementationFactory nodeImplementationFactory = modelFactories.getFactory(NodeImplementationFactory.class);
-            ConfiguredNodeImplementation configuration = nodeImplementationFactory.createConfiguredNodeImplementation();
-            
-            // Read the composite model
-            StAXArtifactProcessor<Composite> compositeProcessor = artifactProcessors.getProcessor(Composite.class);
-            URL compositeURL = new URL(compositeURI);
-            logger.log(Level.INFO, "Loading composite: " + compositeURL);
-            InputStream is = new ByteArrayInputStream(compositeContent.getBytes());
-            XMLStreamReader reader = inputFactory.createXMLStreamReader(new StringReader(compositeContent));
-            Composite composite = compositeProcessor.read(reader);
-            configuration.setComposite(composite);
-            
-            // Create contribution models
-            ContributionFactory contributionFactory = modelFactories.getFactory(ContributionFactory.class);
-            for (SCAContribution c: contributions) {
-                Contribution contribution = contributionFactory.createContribution();
-                contribution.setURI(c.getURI());
-                contribution.setLocation(c.getLocation());
-                contribution.setUnresolved(true);
-                configuration.getContributions().add(contribution);
+
+            ConfiguredNodeImplementation configuration = null;
+            if (contributions == null || contributions.length == 0) {
+                configuration = findNodeConfiguration(compositeURI, null);
+            } else {
+                // Create a node configuration
+                NodeImplementationFactory nodeImplementationFactory =
+                    modelFactories.getFactory(NodeImplementationFactory.class);
+                configuration = nodeImplementationFactory.createConfiguredNodeImplementation();
+
+                // Read the composite model
+                StAXArtifactProcessor<Composite> compositeProcessor = artifactProcessors.getProcessor(Composite.class);
+                URL compositeURL = new URL(compositeURI);
+                logger.log(Level.INFO, "Loading composite: " + compositeURL);
+                XMLStreamReader reader = inputFactory.createXMLStreamReader(new StringReader(compositeContent));
+                Composite composite = compositeProcessor.read(reader);
+                reader.close();
+                configuration.setComposite(composite);
+
+                // Create contribution models
+                ContributionFactory contributionFactory = modelFactories.getFactory(ContributionFactory.class);
+                for (SCAContribution c : contributions) {
+                    Contribution contribution = createContribution(contributionFactory, c);
+                    configuration.getContributions().add(contribution);
+                }
             }
 
             // Configure the node
@@ -250,9 +415,17 @@ public class NodeImpl implements SCANode2, SCAClient {
 
         } catch (Exception e) {
             throw new ServiceRuntimeException(e);
-        }        
+        }
     }
-    
+
+    private static Contribution createContribution(ContributionFactory contributionFactory, SCAContribution c) {
+        Contribution contribution = contributionFactory.createContribution();
+        contribution.setURI(c.getURI());
+        contribution.setLocation(c.getLocation());
+        contribution.setUnresolved(true);
+        return contribution;
+    }
+
     /**
      * Initialize the Tuscany runtime.
      * 
@@ -263,7 +436,7 @@ public class NodeImpl implements SCANode2, SCAClient {
         // Create a node runtime
         runtime = new ReallySmallRuntime(Thread.currentThread().getContextClassLoader());
         runtime.start();
-        
+
         // Get the various factories we need
         ExtensionPointRegistry registry = runtime.getExtensionPointRegistry();
         modelFactories = registry.getExtensionPoint(ModelFactoryExtensionPoint.class);
@@ -271,16 +444,16 @@ public class NodeImpl implements SCANode2, SCAClient {
 
         // Create the required artifact processors
         artifactProcessors = registry.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class);
-        
+
         // Save the composite activator
         compositeActivator = runtime.getCompositeActivator();
-        
+
         // save the monitor
         UtilityExtensionPoint utilities = registry.getExtensionPoint(UtilityExtensionPoint.class);
         MonitorFactory monitorFactory = utilities.getUtility(MonitorFactory.class);
         monitor = monitorFactory.createMonitor();
     }
-    
+
     private void configureNode(ConfiguredNodeImplementation configuration) throws Exception {
 
         // Find if any contribution JARs already available locally on the classpath
@@ -289,7 +462,7 @@ public class NodeImpl implements SCANode2, SCAClient {
         // Load the specified contributions
         ContributionService contributionService = runtime.getContributionService();
         List<Contribution> contributions = new ArrayList<Contribution>();
-        for (Contribution contribution: configuration.getContributions()) {
+        for (Contribution contribution : configuration.getContributions()) {
             URI uri = URI.create(contribution.getLocation());
             if (uri.getScheme() == null) {
                 uri = new File(contribution.getLocation()).toURI();
@@ -297,11 +470,11 @@ public class NodeImpl implements SCANode2, SCAClient {
             URL contributionURL = uri.toURL();
 
             // Extract contribution file name
-            String file =contributionURL.getPath();
+            String file = contributionURL.getPath();
             int i = file.lastIndexOf('/');
-            if (i != -1 && i < file.length() -1 ) {
-                file = file.substring(i +1);
-                
+            if (i != -1 && i < file.length() - 1) {
+                file = file.substring(i + 1);
+
                 // If we find the local contribution file on the classpath, use it in
                 // place of the original contribution URL
                 URL localContributionURL = localContributions.get(file);
@@ -309,13 +482,24 @@ public class NodeImpl implements SCANode2, SCAClient {
                     contributionURL = localContributionURL;
                 }
             }
-            
+
             // Load the contribution
             logger.log(Level.INFO, "Loading contribution: " + contributionURL);
             contributions.add(contributionService.contribute(contribution.getURI(), contributionURL, false));
             analyseProblems();
         }
         
+        // Resolve the metadata within the context of the first contribution
+        Contribution mainContribution = contributions.get(contributions.size() - 1);
+        if (metadata != null) {
+            StAXArtifactProcessor<ContributionMetadata> processor =
+                artifactProcessors.getProcessor(ContributionMetadata.class);
+            processor.resolve(metadata, mainContribution.getModelResolver());
+            List<Composite> composites = metadata.getDeployables();
+            configuration.setComposite(composites.get(0));
+        }
+
+
         // Load the specified composite
         StAXArtifactProcessor<Composite> compositeProcessor = artifactProcessors.getProcessor(Composite.class);
         if (configuration.getComposite().getName() == null) {
@@ -331,88 +515,86 @@ public class NodeImpl implements SCANode2, SCAClient {
         } else {
             composite = configuration.getComposite();
         }
-        
+
         analyseProblems();
-        
+
         // Resolve it within the context of the first contribution
-        Contribution mainContribution = contributions.get(contributions.size()-1);
         compositeProcessor.resolve(composite, mainContribution.getModelResolver());
-        
+
         analyseProblems();
-            
+
         // Create a top level composite to host our composite
         // This is temporary to make the activator happy
         AssemblyFactory assemblyFactory = runtime.getAssemblyFactory();
         Composite tempComposite = assemblyFactory.createComposite();
         tempComposite.setName(new QName("http://tempuri.org", "temp"));
         tempComposite.setURI("http://tempuri.org");
-        
+
         // Include the node composite in the top-level composite 
         tempComposite.getIncludes().add(composite);
-        
+
         // set the top level composite on the composite activator as 
         // logic in callable reference resolution relies on this being 
         // available
         compositeActivator.setDomainComposite(tempComposite);
-        
+
         // Build the composite
         runtime.buildComposite(composite);
-        
+
         analyseProblems();
     }
-    
+
     private void analyseProblems() throws Exception {
-        
-        for (Problem problem : monitor.getProblems()){
-            if ((problem.getSeverity() == Severity.ERROR) &&
-               (!problem.getMessageId().equals("SchemaError"))){
-                if (problem.getCause() != null){
+
+        for (Problem problem : monitor.getProblems()) {
+            if ((problem.getSeverity() == Severity.ERROR) && (!problem.getMessageId().equals("SchemaError"))) {
+                if (problem.getCause() != null) {
                     throw problem.getCause();
                 } else {
                     throw new ServiceRuntimeException(problem.toString());
-                }    
+                }
             }
         }
     }
-    
+
     public void start() {
-        logger.log(Level.INFO, "Starting node: " + configurationName);               
-        
+        logger.log(Level.INFO, "Starting node: " + configurationName);
+
         try {
-            
+
             // Activate the composite
             compositeActivator.activate(composite);
-            
+
             // Start the composite
             compositeActivator.start(composite);
-            
+
         } catch (ActivationException e) {
             throw new ServiceRuntimeException(e);
         }
     }
-    
+
     public void stop() {
-        logger.log(Level.INFO, "Stopping node: " + configurationName);               
-        
+        logger.log(Level.INFO, "Stopping node: " + configurationName);
+
         try {
-            
+
             // Stop the composite
             compositeActivator.stop(composite);
-            
+
             // Deactivate the composite
             compositeActivator.deactivate(composite);
-            
+
         } catch (ActivationException e) {
             throw new ServiceRuntimeException(e);
         }
     }
-    
+
     public <B, R extends CallableReference<B>> R cast(B target) throws IllegalArgumentException {
         return (R)runtime.getProxyFactory().cast(target);
     }
-    
+
     public <B> B getService(Class<B> businessInterface, String serviceName) {
-        
+
         ServiceReference<B> serviceReference = getServiceReference(businessInterface, serviceName);
         if (serviceReference == null) {
             throw new ServiceRuntimeException("Service not found: " + serviceName);
@@ -421,7 +603,7 @@ public class NodeImpl implements SCANode2, SCAClient {
     }
 
     public <B> ServiceReference<B> getServiceReference(Class<B> businessInterface, String name) {
-        
+
         // Extract the component name
         String componentName;
         String serviceName;
@@ -437,13 +619,13 @@ public class NodeImpl implements SCANode2, SCAClient {
 
         // Lookup the component 
         Component component = null;
-         
-        for (Component compositeComponent: composite.getComponents()) {
+
+        for (Component compositeComponent : composite.getComponents()) {
             if (compositeComponent.getName().equals(componentName)) {
                 component = compositeComponent;
             }
         }
-       
+
         if (component == null) {
             throw new ServiceRuntimeException("The service " + name + " has not been contributed to the domain");
         }
@@ -461,7 +643,8 @@ public class NodeImpl implements SCANode2, SCAClient {
                         }
                         componentContext =
                             ((RuntimeComponent)compositeService.getPromotedComponent()).getComponentContext();
-                        return componentContext.createSelfReference(businessInterface, compositeService.getPromotedService());
+                        return componentContext.createSelfReference(businessInterface, compositeService
+                            .getPromotedService());
                     }
                     break;
                 }
@@ -476,7 +659,7 @@ public class NodeImpl implements SCANode2, SCAClient {
                 return componentContext.createSelfReference(businessInterface);
             }
         }
-    }    
+    }
 
     /**
      * Returns the extension point registry used by this node.
@@ -486,7 +669,7 @@ public class NodeImpl implements SCANode2, SCAClient {
     public ExtensionPointRegistry getExtensionPointRegistry() {
         return runtime.getExtensionPointRegistry();
     }
-    
+
     /**
      * Returns the composite being run by this node.
      * 
@@ -494,19 +677,19 @@ public class NodeImpl implements SCANode2, SCAClient {
      */
     public Composite getComposite() {
         return composite;
-    }    
+    }
 
     /**
      * Returns contribution JARs available on the classpath.
      * 
      * @return
      */
-    private static Map<String, URL> localContributions () {
+    private static Map<String, URL> localContributions() {
         Map<String, URL> localContributions = new HashMap<String, URL>();
         collectJARs(localContributions, Thread.currentThread().getContextClassLoader());
         return localContributions;
     }
-    
+
     /**
      * Collect JARs on the classpath of a URLClassLoader
      * @param urls
@@ -516,22 +699,22 @@ public class NodeImpl implements SCANode2, SCAClient {
         if (cl == null) {
             return;
         }
-        
+
         // Collect JARs from the URLClassLoader's classpath
         if (cl instanceof URLClassLoader) {
             URL[] jarURLs = ((URLClassLoader)cl).getURLs();
             if (jarURLs != null) {
-                for (URL jarURL: jarURLs) {
-                    String file =jarURL.getPath();
+                for (URL jarURL : jarURLs) {
+                    String file = jarURL.getPath();
                     int i = file.lastIndexOf('/');
-                    if (i != -1 && i < file.length() -1 ) {
-                        file = file.substring(i +1);
+                    if (i != -1 && i < file.length() - 1) {
+                        file = file.substring(i + 1);
                         urls.put(file, jarURL);
                     }
                 }
             }
         }
-        
+
         // Collect JARs from the parent ClassLoader
         collectJARs(urls, cl.getParent());
     }