From bdd0a41aed7edf21ec2a65cfa17a86af2ef8c48a Mon Sep 17 00:00:00 2001 From: dims Date: Tue, 17 Jun 2008 00:23:01 +0000 Subject: Move Tuscany from Incubator to top level. git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@668359 13f79535-47bb-0310-9956-ffa450edef68 --- sandbox/container.ruby/pom.xml | 55 +++++++ .../extension/config/AbstractContextFactory.java | 143 ++++++++++++++++++ .../context/AbstractComponentContext.java | 114 +++++++++++++++ .../loader/AbstractImplementationLoader.java | 160 +++++++++++++++++++++ .../ruby/assembly/RubyImplementation.java | 64 +++++++++ .../ruby/builder/RubyContextFactoryBuilder.java | 39 +++++ .../ruby/builder/RubyTargetWireBuilder.java | 47 ++++++ .../container/ruby/config/RubyContextFactory.java | 55 +++++++ .../ruby/context/RubyComponentContext.java | 56 ++++++++ .../container/ruby/invoker/RubyInvoker.java | 108 ++++++++++++++ .../tuscany/container/ruby/invoker/RubyScript.java | 101 +++++++++++++ .../ruby/loader/RubyImplementationLoader.java | 97 +++++++++++++ .../org/apache/tuscany/samples/ruby/Greeting.java | 6 + .../tuscany/samples/ruby/GreetingClient.java | 63 ++++++++ .../container.ruby/src/main/resources/Greetings.rb | 9 ++ .../src/main/resources/greetings.componentType | 9 ++ .../src/main/resources/logging.properties | 27 ++++ .../container.ruby/src/main/resources/sca.module | 31 ++++ .../src/main/resources/system.fragment | 32 +++++ 19 files changed, 1216 insertions(+) create mode 100644 sandbox/container.ruby/pom.xml create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/config/AbstractContextFactory.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/context/AbstractComponentContext.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/loader/AbstractImplementationLoader.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/assembly/RubyImplementation.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyContextFactoryBuilder.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyTargetWireBuilder.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/config/RubyContextFactory.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/context/RubyComponentContext.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyInvoker.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyScript.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/loader/RubyImplementationLoader.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/Greeting.java create mode 100644 sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/GreetingClient.java create mode 100644 sandbox/container.ruby/src/main/resources/Greetings.rb create mode 100644 sandbox/container.ruby/src/main/resources/greetings.componentType create mode 100644 sandbox/container.ruby/src/main/resources/logging.properties create mode 100644 sandbox/container.ruby/src/main/resources/sca.module create mode 100644 sandbox/container.ruby/src/main/resources/system.fragment (limited to 'sandbox/container.ruby') diff --git a/sandbox/container.ruby/pom.xml b/sandbox/container.ruby/pom.xml new file mode 100644 index 0000000000..d0fd0a8620 --- /dev/null +++ b/sandbox/container.ruby/pom.xml @@ -0,0 +1,55 @@ + + + + + + org.apache.tuscany.sca.containers + tuscany-sca-containers + incubating-M1 + + + 4.0.0 + tuscany-container-ruby + Tuscany Ruby Container + Tuscany Ruby Container + SNAPSHOT + + + + org.apache.tuscany + tuscany-core + incubating-M1 + compile + + + + + jruby + jruby + 0.8.3 + provided + + + + bsf + bsf + 2.3.0 + provided + + + + diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/config/AbstractContextFactory.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/config/AbstractContextFactory.java new file mode 100644 index 0000000000..d6f000095d --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/config/AbstractContextFactory.java @@ -0,0 +1,143 @@ +/** + * + * 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.container.extension.config; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import org.apache.tuscany.core.builder.ContextFactory; +import org.apache.tuscany.core.context.AtomicContext; +import org.apache.tuscany.core.context.CompositeContext; +import org.apache.tuscany.core.wire.SourceWireFactory; +import org.apache.tuscany.core.wire.TargetWireFactory; +import org.apache.tuscany.model.assembly.Scope; + +/** + * Abstract context factory. + */ +public abstract class AbstractContextFactory implements ContextFactory { + + // Context scope + private Scope scope; + + // Context name + private String name; + + // SOurce proxy factories + private List sourceProxyFactories = new ArrayList(); + + // Target proxy factories + private Map targetProxyFactories = new HashMap(); + + /** + * Initializes the context factory. + * + * @param name Context name. + * @param scope Context scope. + * @param rubyScript Ruby script to run. + */ + public AbstractContextFactory(String name, Scope scope) { + this.name = name; + this.scope = scope; + } + + /** + * Returns the context scope. + * @return Context scope. + */ + public final Scope getScope() { + return scope; + } + + /** + * Returns the context name. + * @return Context name. + */ + public final String getName() { + return name; + } + + /** + * Adds a property. + * + * @param propertyName Property name. + * @param value Property value. + */ + public final void addProperty(String propertyName, Object value) { + } + + /** + * Adds a target proxy factory. + * + * @param serviceName Service name. + * @param factory Target proxy factory. + */ + public final void addTargetWireFactory(String serviceName, TargetWireFactory factory) { + targetProxyFactories.put(serviceName, factory); + } + + /** + * Gets a target proxy factory by name. + * + * @param serviceName Service name. + * @return Target wire factory for the specified service. + */ + public final TargetWireFactory getTargetWireFactory(String serviceName) { + return targetProxyFactories.get(serviceName); + } + + /** + * Returns all the target wire factories. + * @return All the target wire factories for the context. + */ + public final Map getTargetWireFactories() { + return targetProxyFactories; + } + + /** + * Adds a source wire factory. + * + * @param referenceName Reference name. + * @param factory SOurce wire factory. + */ + public final void addSourceWireFactory(String referenceName, SourceWireFactory factory) { + sourceProxyFactories.add(factory); + } + + /** + * Adds all source wire factories. + */ + public final void addSourceWireFactories(String referenceName, Class referenceInterface, List factory, boolean multiplicity) { + sourceProxyFactories.addAll(factory); + } + + /** + * Returns all the source wire factories. + */ + public final List getSourceWireFactories() { + return sourceProxyFactories; + } + + /** + * Notification that the parent factory has been activated. + */ + public final void prepare(CompositeContext parent) { + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/context/AbstractComponentContext.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/context/AbstractComponentContext.java new file mode 100644 index 0000000000..866a233c66 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/context/AbstractComponentContext.java @@ -0,0 +1,114 @@ +/** + * + * 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.container.extension.context; + +import java.util.Map; + +import org.apache.tuscany.core.context.AtomicContext; +import org.apache.tuscany.core.context.CoreRuntimeException; +import org.apache.tuscany.core.context.QualifiedName; +import org.apache.tuscany.core.context.TargetException; +import org.apache.tuscany.core.context.event.InstanceCreated; +import org.apache.tuscany.core.context.impl.AbstractContext; +import org.apache.tuscany.core.wire.ProxyCreationException; +import org.apache.tuscany.core.wire.TargetWireFactory; +import org.apache.tuscany.core.wire.WireFactory; + +/** + * Abstract component context. + * + */ +public abstract class AbstractComponentContext extends AbstractContext implements AtomicContext { + + private Map targetProxyFactories; + + public AbstractComponentContext(String name, Map targetProxyFactories) { + super(name); + this.targetProxyFactories = targetProxyFactories; + } + + public Object getInstance(QualifiedName qName) throws TargetException { + return getInstance(qName, true); + } + + /** + * Init method. + */ + public void init() throws TargetException { + } + + /** + * Detsroy method. + */ + public void destroy() throws TargetException { + } + + private synchronized Object getInstance(QualifiedName qName, boolean notify) throws TargetException { + String portName = qName.getPortName(); + WireFactory targetFactory; + if (portName != null) { + targetFactory = targetProxyFactories.get(portName); + } else { + targetFactory = targetProxyFactories.values().iterator().next(); + } + if (targetFactory == null) { + TargetException e = new TargetException("Target service not found"); + e.setIdentifier(qName.getPortName()); + e.addContextName(getName()); + throw e; + } + try { + Object proxy = targetFactory.createProxy(); + if (notify) { + publish(new InstanceCreated(this)); + } + return proxy; + } catch (ProxyCreationException e) { + TargetException te = new TargetException("Error returning target", e); + e.setIdentifier(qName.getPortName()); + e.addContextName(getName()); + throw te; + } + } + + /** + * Whether this context supports eager init. + */ + public boolean isEagerInit() { + return false; + } + + /** + * Whether this context is destroyable. + */ + public boolean isDestroyable() { + return false; + } + + /** + * Starts the context. + */ + public void start() throws CoreRuntimeException { + } + + /** + * Stops the context. + */ + public void stop() throws CoreRuntimeException { + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/loader/AbstractImplementationLoader.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/loader/AbstractImplementationLoader.java new file mode 100644 index 0000000000..f5115a5b41 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/extension/loader/AbstractImplementationLoader.java @@ -0,0 +1,160 @@ +/** + * + * 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.container.extension.loader; + +import java.io.IOException; +import java.io.InputStream; +import java.net.URL; + +import javax.xml.stream.XMLInputFactory; +import javax.xml.stream.XMLStreamException; +import javax.xml.stream.XMLStreamReader; + +import org.apache.tuscany.core.config.ConfigurationLoadException; +import org.apache.tuscany.core.config.InvalidRootElementException; +import org.apache.tuscany.core.config.MissingResourceException; +import org.apache.tuscany.core.config.SidefileLoadException; +import org.apache.tuscany.core.loader.LoaderContext; +import org.apache.tuscany.core.loader.StAXElementLoader; +import org.apache.tuscany.core.loader.StAXLoaderRegistry; +import org.apache.tuscany.core.loader.assembly.AssemblyConstants; +import org.apache.tuscany.core.system.annotation.Autowire; +import org.apache.tuscany.model.assembly.ComponentType; +import org.apache.tuscany.model.assembly.Implementation; +import org.osoa.sca.annotations.Scope; + +/** + * Abstract implementation loader. + * + */ +@Scope("MODULE") +public abstract class AbstractImplementationLoader implements StAXElementLoader { + + // Injected Stax loader registry. + protected StAXLoaderRegistry registry; + + // XML input factory. + protected XMLInputFactory xmlFactory; + + /** + * Initializes the XML input factory. + * + */ + public AbstractImplementationLoader() { + xmlFactory = XMLInputFactory.newInstance(); + } + + /** + * Injection method for Stax loader registry. + * @param registry Stax loader registry. + */ + @Autowire + public void setRegistry(StAXLoaderRegistry registry) { + this.registry = registry; + } + + /** + * Loads the Ruby implementation. + * + * @param Stax XML stream reader. + * @param loaderContext Loader context. + * @return Ruby implementation. + */ + public T load(XMLStreamReader reader, LoaderContext loaderContext) throws XMLStreamException, ConfigurationLoadException { + + T assemblyObject = getAssemblyObject(reader, loaderContext); + + URL componentTypeFile = getSideFile(reader, loaderContext); + ComponentType componentType = loadComponentType(componentTypeFile, loaderContext); + + assemblyObject.setComponentType(componentType); + + return assemblyObject; + + } + + /** + * Required to be implemented by the concrete classes. + * @return Implementation object. + */ + protected abstract T getAssemblyObject(XMLStreamReader reader, LoaderContext loaderContext); + + /** + * Gets the side file. + * + * @param reader Reader for the module file. + * @param loaderContext Loader context. + * @return Side file Url. + * @throws MissingResourceException + */ + protected abstract URL getSideFile(XMLStreamReader reader, LoaderContext loaderContext) throws MissingResourceException; + + /** + * Loads the SIDE file to get the component information. + * + * @param scriptFile SCript file name. + * @param loaderContext Loader context. + * @return Component information. + * @throws SidefileLoadException + * @throws MissingResourceException + */ + private ComponentType loadComponentType(URL componentTypeFile, LoaderContext loaderContext) throws SidefileLoadException, MissingResourceException{ + + XMLStreamReader reader = null; + InputStream is = null; + + try { + is = componentTypeFile.openStream(); + reader = xmlFactory.createXMLStreamReader(is); + reader.nextTag(); + if (!AssemblyConstants.COMPONENT_TYPE.equals(reader.getName())) { + InvalidRootElementException e = new InvalidRootElementException(AssemblyConstants.COMPONENT_TYPE, reader.getName()); + e.setResourceURI(componentTypeFile.toString()); + throw e; + } + return (ComponentType) registry.load(reader, loaderContext); + } catch (IOException e) { + SidefileLoadException sfe = new SidefileLoadException(e.getMessage()); + sfe.setResourceURI(componentTypeFile.toString()); + throw sfe; + } catch (XMLStreamException e) { + SidefileLoadException sfe = new SidefileLoadException(e.getMessage()); + sfe.setResourceURI(componentTypeFile.toString()); + throw sfe; + } catch (ConfigurationLoadException e) { + SidefileLoadException sfe = new SidefileLoadException(e.getMessage()); + sfe.setResourceURI(componentTypeFile.toString()); + throw sfe; + } finally { + try { + if(reader != null) { + reader.close(); + } + } catch (XMLStreamException e) { + // ignore + } + try { + if(is != null) { + is.close(); + } + } catch (IOException e) { + // ignore + } + } + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/assembly/RubyImplementation.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/assembly/RubyImplementation.java new file mode 100644 index 0000000000..4fd6652495 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/assembly/RubyImplementation.java @@ -0,0 +1,64 @@ +/** + * + * 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.container.ruby.assembly; + +import org.apache.tuscany.common.resource.ResourceLoader; +import org.apache.tuscany.model.assembly.impl.AtomicImplementationImpl; + +/** + * Meta-information for the Ruby implementation. + * + */ +public class RubyImplementation extends AtomicImplementationImpl { + + // Full path of the script file to be executed + private String script; + + // Resource loader for accessing classpath resources + private ResourceLoader resourceLoader; + + /** + * Gets the full path of the script file to be executed. + * @return Full path of the script file to be executed. + */ + public String getScript() { + return script; + } + + /** + * Sets the full path of the script file to be executed. + * @param script Full path of the script file to be executed. + */ + public void setScript(String script) { + this.script = script; + } + + /** + * Gets the resource loader for accessing classpath resources. + * @return Resource loader. + */ + public ResourceLoader getResourceLoader() { return resourceLoader; } + + /** + * Sets the resource loader for accessing classpath resources. + * @param resourceLoader Resource loader. + */ + public void setResourceLoader(ResourceLoader resourceLoader) { + this.resourceLoader = resourceLoader; + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyContextFactoryBuilder.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyContextFactoryBuilder.java new file mode 100644 index 0000000000..77f202f5d3 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyContextFactoryBuilder.java @@ -0,0 +1,39 @@ +/** + * + * 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.container.ruby.builder; + +import org.apache.tuscany.container.ruby.assembly.RubyImplementation; +import org.apache.tuscany.container.ruby.config.RubyContextFactory; +import org.apache.tuscany.container.ruby.invoker.RubyScript; +import org.apache.tuscany.core.builder.ContextFactory; +import org.apache.tuscany.core.extension.ContextFactoryBuilderSupport; +import org.apache.tuscany.model.assembly.Scope; + +/** + * Ruby context factory builder. + * + */ +@org.osoa.sca.annotations.Scope("MODULE") +public class RubyContextFactoryBuilder extends ContextFactoryBuilderSupport { + + @Override + protected ContextFactory createContextFactory(String componentName, RubyImplementation implementation, Scope scope) { + RubyScript rubyScript = new RubyScript(implementation.getScript()); + return new RubyContextFactory(componentName, scope, rubyScript); + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyTargetWireBuilder.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyTargetWireBuilder.java new file mode 100644 index 0000000000..4f7fa6cb03 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/builder/RubyTargetWireBuilder.java @@ -0,0 +1,47 @@ +/** + * + * 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.container.ruby.builder; + +import org.apache.tuscany.container.ruby.config.RubyContextFactory; +import org.apache.tuscany.container.ruby.invoker.RubyInvoker; +import org.apache.tuscany.core.context.QualifiedName; +import org.apache.tuscany.core.context.ScopeContext; +import org.apache.tuscany.core.extension.WireBuilderSupport; +import org.apache.tuscany.core.wire.TargetInvoker; +import org.osoa.sca.annotations.Scope; + +import java.lang.reflect.Method; + +/** + * Ruby target wire builder. + */ +@Scope("MODULE") +public class RubyTargetWireBuilder extends WireBuilderSupport { + + /** + * Created the invoker for Ruby. + * + * @param targetName Target component name. + * @param method Method invoked on the proxy. + * @param context Scope context. + * @param downScope Flag for down scope. + */ + protected TargetInvoker createInvoker(QualifiedName targetName, Method method, ScopeContext context, boolean downScope) { + String serviceName = targetName.getPartName(); + return new RubyInvoker(context, serviceName, method.getName()); + } +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/config/RubyContextFactory.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/config/RubyContextFactory.java new file mode 100644 index 0000000000..e39faca6a3 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/config/RubyContextFactory.java @@ -0,0 +1,55 @@ +/** + * + * 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.container.ruby.config; + +import org.apache.tuscany.container.extension.config.AbstractContextFactory; +import org.apache.tuscany.container.ruby.context.RubyComponentContext; +import org.apache.tuscany.container.ruby.invoker.RubyScript; +import org.apache.tuscany.core.builder.ContextCreationException; +import org.apache.tuscany.model.assembly.Scope; + +/** + * Ruby context factory. + */ +public class RubyContextFactory extends AbstractContextFactory { + + // Ruby script to run + private RubyScript rubyScript; + + /** + * Initializes the context factory. + * + * @param name Context name. + * @param scope Context scope. + * @param rubyScript Ruby script to run. + */ + public RubyContextFactory(String name, Scope scope, RubyScript rubyScript) { + super(name, scope); + this.rubyScript = rubyScript; + } + + /** + * Creates the Ruby component context. + */ + public RubyComponentContext createContext() throws ContextCreationException { + return new RubyComponentContext( + getName(), + getTargetWireFactories(), + rubyScript); + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/context/RubyComponentContext.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/context/RubyComponentContext.java new file mode 100644 index 0000000000..232f184c95 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/context/RubyComponentContext.java @@ -0,0 +1,56 @@ +/** + * + * 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.container.ruby.context; + +import java.util.Map; + +import org.apache.tuscany.container.extension.context.AbstractComponentContext; +import org.apache.tuscany.container.ruby.invoker.RubyScript; +import org.apache.tuscany.core.context.TargetException; +import org.apache.tuscany.core.wire.TargetWireFactory; + +/** + * Ruby component context. + * + */ +public class RubyComponentContext extends AbstractComponentContext { + + // Ruby script. + private RubyScript rubyScript; + + /** + * Initializes the context. + * + * @param name Component name. + * @param targetProxyFactories Target wire factories. + * @param rubyScript Ruby script. + */ + public RubyComponentContext(String name, + Map targetProxyFactories, + RubyScript rubyScript) { + super(name, targetProxyFactories); + this.rubyScript = rubyScript; + } + + /** + * Gets the target invocation instance. + */ + public Object getTargetInstance() throws TargetException { + return rubyScript; + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyInvoker.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyInvoker.java new file mode 100644 index 0000000000..6e1ba28c5d --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyInvoker.java @@ -0,0 +1,108 @@ +/** + * + * 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.container.ruby.invoker; + +import java.lang.reflect.InvocationTargetException; + +import org.apache.tuscany.core.context.AtomicContext; +import org.apache.tuscany.core.context.ScopeContext; +import org.apache.tuscany.core.message.Message; +import org.apache.tuscany.core.wire.Interceptor; +import org.apache.tuscany.core.wire.TargetInvoker; + +/** + * Ruby target invoker. + * + */ +public class RubyInvoker implements TargetInvoker, Cloneable { + + // SCope context + private ScopeContext scopeContext; + + // Srevice name + private String serviceName; + + // Method name + private String methodName; + + /** + * Initializes the invoker. + * + * @param scopeContext SCope context. + * @param serviceName Service name. + * @param methodName Method name. + */ + public RubyInvoker(ScopeContext scopeContext, String serviceName, String methodName) { + this.scopeContext = scopeContext; + this.serviceName = serviceName; + this.methodName = methodName; + } + + /** + * Invokes the target. + */ + public Object invokeTarget(Object payload) throws InvocationTargetException { + + AtomicContext atomicContext = (AtomicContext)scopeContext.getContext(serviceName); + RubyScript rubyScript = (RubyScript)atomicContext.getTargetInstance(); + + Object[] args = (Object[])payload; + + try { + return rubyScript.runScript(methodName, args); + } catch(Exception ex) { + throw new InvocationTargetException(ex); + } + + } + + /** + * Whether the invoker is cacheable. + */ + public boolean isCacheable() { + return false; + } + + /** + * Invokes the servce. + */ + public Message invoke(Message msg) { + try { + Object resp = invokeTarget(msg.getBody()); + msg.setBody(resp); + } catch (InvocationTargetException e) { + msg.setBody(e.getCause()); + } catch (Throwable e) { + msg.setBody(e); + } + return msg; + } + + /** + * Sets interceptor. + */ + public void setNext(Interceptor next) { + } + + /** + * Implementations must support deep cloning + */ + public Object clone() { + return new RubyInvoker(scopeContext, serviceName, methodName); + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyScript.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyScript.java new file mode 100644 index 0000000000..ac66a13806 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/invoker/RubyScript.java @@ -0,0 +1,101 @@ +/** + * + * 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.container.ruby.invoker; + +import java.io.InputStream; +import java.io.InputStreamReader; +import java.lang.reflect.Method; +import org.eclipse.emf.common.util.URI; + +import org.apache.bsf.BSFManager; +import org.apache.bsf.util.IOUtils; +import org.jruby.RubyObject; + + +/** + * Models a Ruby script. + */ +public class RubyScript { + + // Script to run. + private String script; + private BSFManager bsfManager; + + /** + * Initializes the script name. + * @param script Full path to the script. + */ + public RubyScript(String script) { + this.script = script; + + // Register the BSF Engine + BSFManager.registerScriptingEngine("ruby", "org.jruby.javasupport.bsf.JRubyEngine", + new String[] { "rb" }); + bsfManager = new BSFManager(); + } + + /** + * Executes the script. + * @param methodName Name of the method to be executed. + * @param args Arguments to the method. + * @return Result of invocation. + * @throws CompilationFailedException + * @throws InstantiationException + * @throws IllegalAccessException + */ + public Object runScript(String methodName, Object[] args) throws InstantiationException, IllegalAccessException { + + ClassLoader classLoader = getClass().getClassLoader(); + + try { + // Get the Ruby Class + Object rubyClass = getRubyClass(classLoader, script); + Method rubyMethod = findFunction(rubyClass, methodName); + Object result = null; + if(rubyMethod != null) { + result = rubyMethod.invoke(rubyClass, args); + } + return result; + } catch(Exception ex) { + ex.printStackTrace(); + } + + return null; + + } + + // Gives the Ruby class for the corresponding script + // Can optimize in future by caching the instance + private Object getRubyClass(ClassLoader classLoader, String rubyScriptName) throws Exception { + // Load the ruby script + InputStream inputStream = classLoader.getResourceAsStream(rubyScriptName); + String script = IOUtils.getStringFromReader(new InputStreamReader(inputStream)); + bsfManager.exec("ruby", "(java)", 1, 1, script); + + // Get the Ruby class + String rubyClassName=URI.createURI(rubyScriptName).trimFileExtension().lastSegment(); + Object rubyClass = bsfManager.eval("ruby", "(java)", 1, 1, rubyClassName+".new"); + return rubyClass; + } + + // Find whether a particular method exists + private Method findFunction(Object rubyClass, String functionName) throws Exception { + Class[] parameterTypes = new Class[]{String.class}; + Method method = rubyClass.getClass().getMethod(functionName, parameterTypes); + return method; + } +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/loader/RubyImplementationLoader.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/loader/RubyImplementationLoader.java new file mode 100644 index 0000000000..647a57507d --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/container/ruby/loader/RubyImplementationLoader.java @@ -0,0 +1,97 @@ +/** + * + * 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.container.ruby.loader; + +import java.net.URL; + +import javax.xml.namespace.QName; +import javax.xml.stream.XMLStreamReader; + +import org.apache.tuscany.container.extension.loader.AbstractImplementationLoader; +import org.apache.tuscany.container.ruby.assembly.RubyImplementation; +import org.apache.tuscany.core.config.MissingResourceException; +import org.apache.tuscany.core.loader.LoaderContext; +import org.osoa.sca.annotations.Destroy; +import org.osoa.sca.annotations.Init; +import org.osoa.sca.annotations.Scope; + +/** + * Ruby implementation loader. + * + */ +@Scope("MODULE") +public class RubyImplementationLoader extends AbstractImplementationLoader { + + // Qualified name for the Ruby implementation. + public static final QName NAME = new QName("http://org.apache.tuscany/xmlns/ruby/0.9", "implementation.ruby"); + + /** + * Lifecycle method registers the implementation loader. + * + */ + @Init(eager = true) + public void start() { + registry.registerLoader(NAME, this); + } + + /** + * Lifecycle method deregisters the implementation loader. + * + */ + @Destroy + public void stop() { + registry.unregisterLoader(NAME, this); + } + + /** + * Required to be implemented by the concrete classes. + * @return Implementation object. + */ + protected RubyImplementation getAssemblyObject(XMLStreamReader reader, LoaderContext loaderContext) { + + RubyImplementation rubyImplementation = new RubyImplementation(); + String script = reader.getAttributeValue(null, "script"); + + rubyImplementation.setScript(script); + rubyImplementation.setResourceLoader(loaderContext.getResourceLoader()); + + return rubyImplementation; + + } + + /** + * Gets the side file. + * + * @param reader Reader for the module file. + * @param loaderContext Loader context. + * @return Side file Url. + * @throws MissingResourceException + */ + protected URL getSideFile(XMLStreamReader reader, LoaderContext loaderContext) + throws MissingResourceException { + + String script = reader.getAttributeValue(null, "script"); + String sidefile = script.substring(0, script.lastIndexOf('.')) + ".componentType"; + URL componentTypeFile = loaderContext.getResourceLoader().getResource(sidefile); + if (componentTypeFile == null) { + throw new MissingResourceException(sidefile); + } + return componentTypeFile; + + } + +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/Greeting.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/Greeting.java new file mode 100644 index 0000000000..a5923af074 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/Greeting.java @@ -0,0 +1,6 @@ +package org.apache.tuscany.samples.ruby; + +public interface Greeting { + + void greet(String name); +} diff --git a/sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/GreetingClient.java b/sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/GreetingClient.java new file mode 100644 index 0000000000..bf9d95fbc0 --- /dev/null +++ b/sandbox/container.ruby/src/main/java/org/apache/tuscany/samples/ruby/GreetingClient.java @@ -0,0 +1,63 @@ +/** + * + * 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.samples.ruby; + +import java.util.logging.Level; +import java.util.logging.LogManager; +import java.util.Properties; + +import org.osoa.sca.CurrentModuleContext; +import org.osoa.sca.ModuleContext; + +import org.apache.tuscany.core.client.TuscanyRuntime; +import org.apache.tuscany.common.monitor.MonitorFactory; +import org.apache.tuscany.common.monitor.impl.JavaLoggingMonitorFactory; + +/** + * This client program shows how to create an SCA runtime, start it, + * locate a simple ruby service component and invoke it. + */ +public class GreetingClient { + + public static final void main(String[] args) throws Exception { + + // Setup Tuscany monitoring to use java.util.logging + LogManager.getLogManager().readConfiguration(GreetingClient.class.getResourceAsStream("/logging.properties")); + Properties levels = new Properties(); + MonitorFactory monitorFactory = new JavaLoggingMonitorFactory(levels, Level.FINEST, "MonitorMessages"); + + // Obtain Tuscany runtime + TuscanyRuntime tuscany = new TuscanyRuntime("greeting", null, monitorFactory); + + // Associate the application module component with this thread + tuscany.start(); + + // Obtain SCA module context. + ModuleContext moduleContext = CurrentModuleContext.getContext(); + + Greeting greeting = (Greeting) moduleContext.locateService("GreetingComponent"); + greeting.greet("World"); + + System.err.flush(); + + // Disassociate the application module component + tuscany.stop(); + + // Shut down the runtime + tuscany.shutdown(); + } +} diff --git a/sandbox/container.ruby/src/main/resources/Greetings.rb b/sandbox/container.ruby/src/main/resources/Greetings.rb new file mode 100644 index 0000000000..c1743e9af9 --- /dev/null +++ b/sandbox/container.ruby/src/main/resources/Greetings.rb @@ -0,0 +1,9 @@ +require 'java' + +include_class 'org.apache.tuscany.samples.ruby.Greeting' + +class Greetings < Greeting + def greet(name) + puts "RUBY : Hello " + name.to_s + end +end \ No newline at end of file diff --git a/sandbox/container.ruby/src/main/resources/greetings.componentType b/sandbox/container.ruby/src/main/resources/greetings.componentType new file mode 100644 index 0000000000..57d1be88a9 --- /dev/null +++ b/sandbox/container.ruby/src/main/resources/greetings.componentType @@ -0,0 +1,9 @@ + + + + + + + + + \ No newline at end of file diff --git a/sandbox/container.ruby/src/main/resources/logging.properties b/sandbox/container.ruby/src/main/resources/logging.properties new file mode 100644 index 0000000000..7ac00ca3f3 --- /dev/null +++ b/sandbox/container.ruby/src/main/resources/logging.properties @@ -0,0 +1,27 @@ +# Copyright (c) 2006 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. +# +# $Rev$ $Date$ +# + +# Custom logging configuration for Tuscany samples +# By default, only INFO level logging is enabled and ALL messages get sent to the console +# For more messages from the runtime, uncomment specific settings at the end of this file +handlers = java.util.logging.ConsoleHandler +java.util.logging.ConsoleHandler.level = ALL +java.util.logging.ConsoleHandler.formatter = java.util.logging.SimpleFormatter +.level=INFO + +# Uncomment the next setting to get all Tuscany messages (this will be a lot) +#org.apache.tuscany.level=FINEST \ No newline at end of file diff --git a/sandbox/container.ruby/src/main/resources/sca.module b/sandbox/container.ruby/src/main/resources/sca.module new file mode 100644 index 0000000000..ced4232094 --- /dev/null +++ b/sandbox/container.ruby/src/main/resources/sca.module @@ -0,0 +1,31 @@ + + + + + + + + + + diff --git a/sandbox/container.ruby/src/main/resources/system.fragment b/sandbox/container.ruby/src/main/resources/system.fragment new file mode 100644 index 0000000000..19176e6c72 --- /dev/null +++ b/sandbox/container.ruby/src/main/resources/system.fragment @@ -0,0 +1,32 @@ + + + + + + + + + + + + + + + + -- cgit v1.2.3