1 files changed, 123 insertions, 0 deletions
diff --git a/sca-java-2.x/tags/2.0-Beta3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl.java b/sca-java-2.x/tags/2.0-Beta3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl.java
new file mode 100644
index 0000000000..7c4afb2660
--- /dev/null
+++ b/sca-java-2.x/tags/2.0-Beta3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl.java
@@ -0,0 +1,123 @@
+/*
+ * 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.client.impl;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Proxy;
+import java.net.URI;
+import java.security.AccessController;
+import java.security.PrivilegedAction;
+import java.util.List;
+
+import org.apache.tuscany.sca.assembly.Endpoint;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.ExtensionPointRegistryLocator;
+import org.apache.tuscany.sca.runtime.DomainRegistry;
+import org.apache.tuscany.sca.runtime.ExtensibleDomainRegistryFactory;
+import org.apache.tuscany.sca.runtime.RuntimeComponent;
+import org.oasisopen.sca.NoSuchDomainException;
+import org.oasisopen.sca.NoSuchServiceException;
+import org.oasisopen.sca.client.SCAClientFactory;
+import org.oasisopen.sca.client.SCAClientFactoryFinder;
+
+public class SCAClientFactoryImpl extends SCAClientFactory {
+
+    protected ExtensionPointRegistry extensionPointRegistry;
+    protected DomainRegistry domainRegistry;
+    protected boolean remoteClient;
+    
+    public static URI default_domainURI = URI.create("default");
+    
+    public static SCAClientFactoryFinder getSCAClientFactoryFinder() {
+        return SCAClientFactory.factoryFinder;
+    }
+
+    public static void setSCAClientFactoryFinder(SCAClientFactoryFinder factoryFinder) {
+        SCAClientFactory.factoryFinder = factoryFinder;
+    }
+
+    public SCAClientFactoryImpl(URI domainURI) throws NoSuchDomainException {
+        super(domainURI == null ? default_domainURI : domainURI);
+        findLocalRuntime();
+    }   
+    
+    protected void findLocalRuntime() throws NoSuchDomainException {
+        String domainURI = getDomainURI().toString();
+        for (ExtensionPointRegistry xpr : ExtensionPointRegistryLocator.getExtensionPointRegistries()) {
+            ExtensibleDomainRegistryFactory drf = ExtensibleDomainRegistryFactory.getInstance(xpr);
+            for (DomainRegistry epr : drf.getEndpointRegistries()) {
+                if (domainURI.equals(epr.getDomainName())) {
+                    this.extensionPointRegistry = xpr;
+                    this.domainRegistry = epr;
+                    return;
+                }
+            }
+        }
+
+        remoteClient = true;
+        extensionPointRegistry = RuntimeUtils.createExtensionPointRegistry();
+        domainRegistry = RuntimeUtils.getClientEndpointRegistry(extensionPointRegistry, domainURI);
+    }
+
+    @Override
+    public <T> T getService(Class<T> serviceInterface, String serviceURI) throws NoSuchServiceException, NoSuchDomainException {
+        
+        String serviceName = null;
+        if (serviceURI.contains("/")) {
+            int i = serviceURI.indexOf("/");
+            if (i < serviceURI.length() - 1) {
+                serviceName = serviceURI.substring(i + 1);
+            }
+        }
+        
+        // The service is a component in a local runtime
+        if (!remoteClient) {
+            List<Endpoint> endpoints = domainRegistry.findEndpoint(serviceURI);
+            if (endpoints.size() < 1) {
+                throw new NoSuchServiceException(serviceURI);
+            }
+            Endpoint ep = endpoints.get(0);
+            if (((RuntimeComponent)ep.getComponent()).getComponentContext() != null) {
+                return ((RuntimeComponent)ep.getComponent()).getServiceReference(serviceInterface, serviceName).getService();
+            }
+        }
+
+        InvocationHandler handler;
+        if (!remoteClient) {
+            // There is a local runtime but the service is a remote component
+            handler = new RemoteServiceInvocationHandler(extensionPointRegistry, domainRegistry, serviceURI, serviceInterface);
+        } else {
+            // no local runtime
+            handler = new RemoteServiceInvocationHandler(extensionPointRegistry, domainRegistry, getDomainURI().toString(), serviceURI, serviceInterface);
+        }
+        if (serviceInterface == null) {
+            serviceInterface = (Class<T>)((RemoteServiceInvocationHandler)handler).serviceInterface;
+        }
+
+        final Class _serviceInterface = serviceInterface;
+        ClassLoader cl = AccessController.doPrivileged(new PrivilegedAction<ClassLoader>() {
+            public ClassLoader run() {
+               return _serviceInterface.getClassLoader();
+            }
+        });
+
+        return (T)Proxy.newProxyInstance(cl, new Class[]{serviceInterface}, handler);
+    }    
+}