1 files changed, 185 insertions, 0 deletions
diff --git a/sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/builder/BuilderRegistryImpl.java b/sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/builder/BuilderRegistryImpl.java
new file mode 100644
index 0000000000..33dd2175f9
--- /dev/null
+++ b/sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/builder/BuilderRegistryImpl.java
@@ -0,0 +1,185 @@
+/*
+ * 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.core.builder;
+
+import java.net.URI;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.osoa.sca.annotations.EagerInit;
+
+import org.apache.tuscany.spi.builder.BindingBuilder;
+import org.apache.tuscany.spi.builder.BuilderException;
+import org.apache.tuscany.spi.builder.BuilderRegistry;
+import org.apache.tuscany.spi.builder.ComponentBuilder;
+import org.apache.tuscany.spi.builder.ScopeNotFoundException;
+import org.apache.tuscany.spi.component.Component;
+import org.apache.tuscany.spi.component.Reference;
+import org.apache.tuscany.spi.component.ReferenceBinding;
+import org.apache.tuscany.spi.component.ScopeContainer;
+import org.apache.tuscany.spi.component.ScopeRegistry;
+import org.apache.tuscany.spi.component.Service;
+import org.apache.tuscany.spi.component.ServiceBinding;
+import org.apache.tuscany.spi.deployer.DeploymentContext;
+import org.apache.tuscany.spi.model.BindingDefinition;
+import org.apache.tuscany.spi.model.ComponentDefinition;
+import org.apache.tuscany.spi.model.ComponentType;
+import org.apache.tuscany.spi.model.Implementation;
+import org.apache.tuscany.spi.model.ReferenceDefinition;
+import org.apache.tuscany.spi.model.Scope;
+import org.apache.tuscany.spi.model.ServiceContract;
+import org.apache.tuscany.spi.model.ServiceDefinition;
+
+import org.apache.tuscany.core.binding.local.LocalBindingDefinition;
+import org.apache.tuscany.core.implementation.composite.ReferenceImpl;
+import org.apache.tuscany.core.implementation.composite.ServiceImpl;
+
+/**
+ * The default builder registry in the runtime
+ *
+ * @version $Rev$ $Date$
+ */
+@EagerInit
+public class BuilderRegistryImpl implements BuilderRegistry {
+    private ScopeRegistry scopeRegistry;
+
+    private final Map<Class<? extends Implementation<?>>, ComponentBuilder<? extends Implementation<?>>> componentBuilders = 
+        new HashMap<Class<? extends Implementation<?>>, ComponentBuilder<? extends Implementation<?>>>();
+    private final Map<Class<? extends BindingDefinition>, BindingBuilder<? extends BindingDefinition>> bindingBuilders =
+        new HashMap<Class<? extends BindingDefinition>, BindingBuilder<? extends BindingDefinition>>();
+
+    public BuilderRegistryImpl(@org.osoa.sca.annotations.Reference ScopeRegistry scopeRegistry) {
+        this.scopeRegistry = scopeRegistry;
+    }
+
+    public <I extends Implementation<?>> void register(Class<I> implClass, ComponentBuilder<I> builder) {
+        componentBuilders.put(implClass, builder);
+    }
+
+    public <I extends Implementation<?>> void unregister(Class<I> implClass) {
+        componentBuilders.remove(implClass);
+    }
+
+    public <B extends BindingDefinition> void register(Class<B> implClass, BindingBuilder<B> builder) {
+        bindingBuilders.put(implClass, builder);
+    }
+
+    @SuppressWarnings("unchecked")
+    public <I extends Implementation<?>> Component build(
+        ComponentDefinition<I> componentDefinition,
+        DeploymentContext context) throws BuilderException {
+        Class<?> implClass = componentDefinition.getImplementation().getClass();
+        // noinspection SuspiciousMethodCalls
+        ComponentBuilder<I> componentBuilder = (ComponentBuilder<I>) componentBuilders.get(implClass);
+        if (componentBuilder == null) {
+            String name = implClass.getName();
+            throw new NoRegisteredBuilderException("No builder registered for implementation", name);
+        }
+        Component component = componentBuilder.build(componentDefinition, context);
+        assert component != null;
+        component.setDefaultPropertyValues(componentDefinition.getPropertyValues());
+        Scope scope = componentDefinition.getImplementation().getComponentType().getImplementationScope();
+        if (scope == Scope.SYSTEM || scope == Scope.COMPOSITE) {
+            component.setScopeContainer(context.getCompositeScope());
+        } else {
+            // Check for conversational contract if conversational scope
+            if (scope == Scope.CONVERSATION) {
+                boolean hasConversationalContract = false;
+                ComponentType<ServiceDefinition, ReferenceDefinition, ?> componentType =
+                    componentDefinition.getImplementation().getComponentType();
+                Map<String, ServiceDefinition> services = componentType.getServices();
+                for (ServiceDefinition serviceDef : services.values()) {
+                    ServiceContract<?> contract = serviceDef.getServiceContract();
+                    if (contract.isConversational()) {
+                        hasConversationalContract = true;
+                        break;
+                    }
+                }
+                if (!hasConversationalContract) {
+                    String name = implClass.getName();
+                    throw new NoConversationalContractException(
+                        "No conversational contract for conversational implementation", name);
+                }
+            }
+            // Now it's ok to set the scope container
+            ScopeContainer scopeContainer = scopeRegistry.getScopeContainer(scope);
+            if (scopeContainer == null) {
+                throw new ScopeNotFoundException(scope.toString());
+            }
+            component.setScopeContainer(scopeContainer);
+        }
+        context.getComponents().put(component.getUri(), component);
+        ComponentType<?, ?, ?> componentType = componentDefinition.getImplementation().getComponentType();
+        assert componentType != null : "Component type must be set";
+        return component;
+    }
+
+    @SuppressWarnings({"unchecked"})
+    public Service build(ServiceDefinition serviceDefinition, DeploymentContext context) throws BuilderException {
+        URI uri = serviceDefinition.getUri();
+        ServiceContract<?> serviceContract = serviceDefinition.getServiceContract();
+        if (serviceDefinition.getBindings().isEmpty()) {
+            // if no bindings are configured, default to the local binding.
+            // this should be changed to allow runtime selection
+            if (serviceDefinition.getBindings().isEmpty()) {
+                // TODO JFM implement capability for the runtime to choose a binding
+                serviceDefinition.addBinding(new LocalBindingDefinition());
+            }
+        }
+        URI targetUri = serviceDefinition.getTarget();
+        Service service = new ServiceImpl(uri, serviceContract, targetUri);
+        for (BindingDefinition definition : serviceDefinition.getBindings()) {
+            Class<?> bindingClass = definition.getClass();
+            // noinspection SuspiciousMethodCalls
+            BindingBuilder bindingBuilder = bindingBuilders.get(bindingClass);
+            if (bindingBuilder == null) {
+                throw new NoRegisteredBuilderException("No builder registered for type", bindingClass.getName());
+            }
+            ServiceBinding binding = bindingBuilder.build(serviceDefinition, definition, context);
+            service.addServiceBinding(binding);
+        }
+        return service;
+    }
+
+    @SuppressWarnings("unchecked")
+    public Reference build(ReferenceDefinition referenceDefinition, DeploymentContext context) throws BuilderException {
+        URI uri = referenceDefinition.getUri();
+        ServiceContract<?> contract = referenceDefinition.getServiceContract();
+        if (referenceDefinition.getBindings().isEmpty()) {
+            // if no bindings are configured, default to the local binding.
+            // this should be changed to allow runtime selection
+            if (referenceDefinition.getBindings().isEmpty()) {
+                // TODO JFM implement capability for the runtime to choose a binding
+                referenceDefinition.addBinding(new LocalBindingDefinition());
+            }
+        }
+
+        Reference reference = new ReferenceImpl(uri, contract);
+        for (BindingDefinition bindingDefinition : referenceDefinition.getBindings()) {
+            Class<?> bindingClass = bindingDefinition.getClass();
+            // noinspection SuspiciousMethodCalls
+            BindingBuilder bindingBuilder = bindingBuilders.get(bindingClass);
+            ReferenceBinding binding = bindingBuilder.build(referenceDefinition, bindingDefinition, context);
+            reference.addReferenceBinding(binding);
+
+        }
+        return reference;
+    }
+
+}