Moving 1.x trunk

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

2 files changed, 296 insertions, 0 deletions

diff --git a/sca-java-1.x/trunk/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/WorkspaceManager.java b/sca-java-1.x/trunk/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/WorkspaceManager.java
new file mode 100644
index 0000000000..0ea82f8e86
--- /dev/null
+++ b/sca-java-1.x/trunk/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/WorkspaceManager.java
@@ -0,0 +1,106 @@
+/*
+ * 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.workspace.manager;
+
+import org.apache.tuscany.sca.contribution.Contribution;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.workspace.Workspace;
+import org.apache.tuscany.sca.workspace.manager.impl.WorkspaceManagerImpl;
+import org.osoa.sca.ServiceRuntimeException;
+
+/**
+ * This workspace manager class provides an SPI for firing up the Tuscany runtime 
+ * and for providing access to the Tuscany ExtensionPointRegsitry. With a reference to the
+ * registry you can add new extension points programmatically before starting the runtime.
+ * Once the runtime is started you can read contributions, create a workspace, populate it
+ * and then resolve it. 
+ * 
+ * A workspace is a collection of contributions. A workspace populated
+ * with one or more contribution models can be resolved to ensure
+ * that all referenced artifacts are located. When more than one contribution
+ * model is present resolution takes into account the import and export relationships 
+ * between contributions.  
+ */
+public abstract class WorkspaceManager {
+    
+    /**
+     * Get a new instance of the WorkspaceManager. Each call will create a 
+     * distinct instance.
+     * 
+     * @return workspace manager 
+     */
+    public static WorkspaceManager newInstance() throws ServiceRuntimeException{
+        try {
+            // replace with service discovery lookup?
+            return new WorkspaceManagerImpl();
+        } catch(Exception ex){
+            throw new ServiceRuntimeException(ex);
+        }
+    }    
+		
+	/**
+	 * If you want to add new extensions to the extension point
+	 * registry and have the runtime take notice of them you need
+	 * to do this before calling start
+	 */
+	public abstract ExtensionPointRegistry getRegistry();
+	
+	/**
+	 * Starting the runtime creates the extensible model processors and 
+	 * resolvers based on the extension points currently found in the
+	 * extension point registry. 
+	 */
+	public abstract void start() throws ServiceRuntimeException;
+
+	/**
+	 * Remove any resources being held by the runtime 
+	 */
+	public abstract void stop() throws ServiceRuntimeException;
+	
+    /**
+     * Create an empty workspace
+     * 
+     * @return workspace
+     */
+	public abstract Workspace createWorkspace() throws ServiceRuntimeException;
+			
+	/**
+	 * Create a contribution model by reading from the specified location URL
+	 * 
+	 * @param name the URI that's given to the contribution
+	 * @param location the URL of the contribution to be read
+	 */
+	public abstract Contribution readContribution(String name, String location) throws ServiceRuntimeException;
+	
+	/**
+	 * Add a contribution to a workspace
+	 * 
+	 * @param workspace the workspace to be extended
+	 * @param contribution the contribution to be added
+	 */
+	public abstract void addContributionToWorkspace(Workspace workspace, Contribution contribution) throws ServiceRuntimeException;
+	
+	/**
+	 * Resolve all of the contributions in the workspace
+	 * 
+	 * @param workspace
+	 */
+	public abstract void resolveWorkspace(Workspace workspace) throws ServiceRuntimeException;
+}
diff --git a/sca-java-1.x/trunk/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/impl/WorkspaceManagerImpl.java b/sca-java-1.x/trunk/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/impl/WorkspaceManagerImpl.java
new file mode 100644
index 0000000000..f95f74ab2c
--- /dev/null
+++ b/sca-java-1.x/trunk/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/impl/WorkspaceManagerImpl.java
@@ -0,0 +1,190 @@
+/*
+ * 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.workspace.manager.impl;
+
+import java.io.File;
+import java.net.URI;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+import org.apache.tuscany.sca.contribution.Contribution;
+import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
+import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessorExtensionPoint;
+import org.apache.tuscany.sca.contribution.resolver.ExtensibleModelResolver;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
+import org.apache.tuscany.sca.host.embedded.impl.ReallySmallRuntime;
+import org.apache.tuscany.sca.monitor.Monitor;
+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.workspace.Workspace;
+import org.apache.tuscany.sca.workspace.WorkspaceFactory;
+import org.apache.tuscany.sca.workspace.builder.ContributionDependencyBuilder;
+import org.apache.tuscany.sca.workspace.builder.impl.ContributionDependencyBuilderImpl;
+import org.apache.tuscany.sca.workspace.manager.WorkspaceManager;
+import org.osoa.sca.ServiceRuntimeException;
+
+/**
+ * This workspace manager class provides an SPI for firing up the Tuscany runtime 
+ * and for providing access to the Tuscany ExtensionPointRegsitry. With a reference to the
+ * registry you can add new extension points programmatically before starting the runtime.
+ * Once the runtime is started you can read contributions, create a workspace, populate it
+ * and then resolve it. 
+ * 
+ * A workspace is a collection of contributions. A workspace populated
+ * with one or more contribution models can be resolved to ensure
+ * that all referenced artifacts are located. When more than one contribution
+ * model is present resolution takes into account the import and export relationships 
+ * between contributions.  
+ */
+public class WorkspaceManagerImpl extends WorkspaceManager {
+    
+    private ReallySmallRuntime runtime;
+    
+    private ModelFactoryExtensionPoint modelFactories;
+    private URLArtifactProcessorExtensionPoint artifactProcessorExtensions;
+    private UtilityExtensionPoint utilities;
+    
+    private WorkspaceFactory workspaceFactory;
+    private URLArtifactProcessor<Contribution> contributionProcessor;
+    private ContributionDependencyBuilder contributionDependencyBuilder;
+    private MonitorFactory monitorFactory;
+    private Monitor monitor;
+		
+	public WorkspaceManagerImpl() throws ServiceRuntimeException{
+        try {
+            runtime = new ReallySmallRuntime(Thread.currentThread().getContextClassLoader());  
+            
+            ExtensionPointRegistry registry = getRegistry();
+            
+            modelFactories = registry.getExtensionPoint(ModelFactoryExtensionPoint.class);  
+            artifactProcessorExtensions = registry.getExtensionPoint(URLArtifactProcessorExtensionPoint.class);
+            utilities = registry.getExtensionPoint(UtilityExtensionPoint.class);
+            
+            workspaceFactory = modelFactories.getFactory(WorkspaceFactory.class);
+            contributionProcessor = artifactProcessorExtensions.getProcessor(Contribution.class);
+            monitorFactory = utilities.getUtility(MonitorFactory.class);
+            monitor = monitorFactory.createMonitor(); 
+            
+            contributionDependencyBuilder = new ContributionDependencyBuilderImpl(monitor);
+            
+        } catch(Exception ex) {
+            throw new ServiceRuntimeException(ex);
+        }	    
+	}
+	
+	public ExtensionPointRegistry getRegistry(){
+	    return runtime.getExtensionPointRegistry();
+	}
+	
+	public void start() throws ServiceRuntimeException {
+       try {
+            runtime.start();
+        } catch(Exception ex) {
+            throw new ServiceRuntimeException(ex);
+        }
+	}
+
+	public void stop() throws ServiceRuntimeException{
+        try {
+            runtime.stop();
+        } catch(Exception ex) {
+            throw new ServiceRuntimeException(ex);
+        }	    
+	}
+	
+	public Workspace createWorkspace(){
+        Workspace workspace = workspaceFactory.createWorkspace();
+        
+        workspace.setModelResolver(new ExtensibleModelResolver(workspace, getRegistry()));
+        
+        return workspace;	    
+	}
+	
+
+    public Contribution readContribution(String name, String location) throws ServiceRuntimeException{
+        try {
+            Contribution returnContribution = 
+                contributionProcessor.read(null, 
+                                           URI.create(name), 
+                                           new File(location).toURI().toURL());
+            
+            analyzeProblems();
+            
+            return returnContribution;
+            
+        } catch (Exception ex) {
+            throw new ServiceRuntimeException(ex);
+        }
+    }
+	    
+    public void addContributionToWorkspace(Workspace workspace, Contribution contribution) throws ServiceRuntimeException{
+        try {
+            
+            workspace.getContributions().add(contribution);
+
+            
+        } catch (Exception ex) {
+            throw new ServiceRuntimeException(ex);
+        }
+    }
+    
+    public void resolveWorkspace(Workspace workspace) throws ServiceRuntimeException {
+        try {
+            // an algorithm to resolve contributions given their dependencies
+            // need to look at the one from 2.x as this one expects contributions
+            // to be presented in the right order
+            Set<Contribution> resolved = new HashSet<Contribution>();
+            for (Contribution contribution: workspace.getContributions()) {
+                List<Contribution> dependencies = contributionDependencyBuilder.buildContributionDependencies(contribution, workspace);
+                
+                // Resolve contributions
+                for (Contribution dependency: dependencies) {
+                    if (!resolved.contains(dependency)) {
+                        resolved.add(dependency);
+                        contributionProcessor.resolve(contribution, workspace.getModelResolver());
+                    }
+                }
+            }
+            
+            analyzeProblems();
+            
+        } catch (Exception ex) {
+            throw new ServiceRuntimeException(ex);
+        }
+    }
+    
+    private void analyzeProblems() throws Exception {
+
+        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());
+                }
+            }
+        }
+    }
+
+}