diff options
Diffstat (limited to 'sandbox/old/contrib/implementation-spring/container/src/main/java/org/apache/tuscany/container/spring/loader')
2 files changed, 331 insertions, 0 deletions
diff --git a/sandbox/old/contrib/implementation-spring/container/src/main/java/org/apache/tuscany/container/spring/loader/SpringImplementationLoader.java b/sandbox/old/contrib/implementation-spring/container/src/main/java/org/apache/tuscany/container/spring/loader/SpringImplementationLoader.java new file mode 100644 index 0000000000..150440cdf9 --- /dev/null +++ b/sandbox/old/contrib/implementation-spring/container/src/main/java/org/apache/tuscany/container/spring/loader/SpringImplementationLoader.java @@ -0,0 +1,203 @@ +/* + * 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.container.spring.loader; + +import java.io.File; +import java.io.FileInputStream; +import java.io.IOException; +import java.net.MalformedURLException; +import java.net.URI; +import java.net.URL; +import java.util.jar.Attributes; +import java.util.jar.JarEntry; +import java.util.jar.JarFile; +import java.util.jar.Manifest; +import javax.xml.namespace.QName; +import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; +import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; +import javax.xml.stream.XMLStreamException; +import javax.xml.stream.XMLStreamReader; + +import org.osoa.sca.Constants; +import org.osoa.sca.annotations.Reference; + +import org.apache.tuscany.spi.deployer.DeploymentContext; +import org.apache.tuscany.spi.extension.LoaderExtension; +import org.apache.tuscany.spi.loader.LoaderException; +import org.apache.tuscany.spi.loader.LoaderRegistry; +import org.apache.tuscany.spi.loader.MissingResourceException; +import org.apache.tuscany.spi.model.ModelObject; +import org.apache.tuscany.spi.model.ReferenceDefinition; +import org.apache.tuscany.spi.model.ServiceDefinition; + +import org.apache.tuscany.container.spring.model.SpringComponentType; +import org.apache.tuscany.container.spring.model.SpringImplementation; +import org.apache.tuscany.host.RuntimeInfo; +import org.apache.tuscany.runtime.webapp.WebappRuntimeInfo; +import org.springframework.core.io.Resource; +import org.springframework.core.io.UrlResource; + +/** + * Loader for handling Spring <implementation.spring> elements. + * + * @version $Rev$ $Date$ + */ +public class SpringImplementationLoader extends LoaderExtension<SpringImplementation> { + private static final QName IMPLEMENTATION_SPRING = new QName("http://www.osoa.org/xmlns/sca/1.0", + "implementation.spring"); + private static final String APPLICATION_CONTEXT = "applicationContext.xml"; + private static final QName SERVICE_ELEMENT = new QName(Constants.SCA_NS, "service"); + private static final QName REFERENCE_ELEMENT = new QName(Constants.SCA_NS, "reference"); + + private final RuntimeInfo runtimeInfo; + + public SpringImplementationLoader(@Reference LoaderRegistry registry, @Reference RuntimeInfo runtimeInfo) { + super(registry); + this.runtimeInfo = runtimeInfo; + } + + public QName getXMLType() { + return IMPLEMENTATION_SPRING; + } + + @SuppressWarnings("unchecked") + public SpringImplementation load( + ModelObject object, XMLStreamReader reader, + DeploymentContext deploymentContext) + throws XMLStreamException, LoaderException { + + String locationAttr = reader.getAttributeValue(null, "location"); + if (locationAttr == null) { + throw new MissingResourceException("No location supplied"); + } + + ClassLoader classLoader = deploymentContext.getClassLoader(); + SpringImplementation implementation = new SpringImplementation(classLoader); + implementation.setApplicationResource(getApplicationContextResource(locationAttr, classLoader)); + registry.loadComponentType(implementation, deploymentContext); + SpringComponentType type = implementation.getComponentType(); + while (true) { + switch (reader.next()) { + case START_ELEMENT: + QName qname = reader.getName(); + if (SERVICE_ELEMENT.equals(qname)) { + ServiceDefinition service = + (ServiceDefinition) registry.load(null, reader, deploymentContext); + if (!type.isExposeAllBeans()) { + URI name = service.getUri(); + if (!type.getServiceDeclarations().containsKey(name)) { + throw new LoaderException("No service defined in Spring context for ", name.toString()); + } + } + type.getDeclaredServices().put(service.getUri(), service); + } else if (REFERENCE_ELEMENT.equals(qname)) { + ReferenceDefinition reference = + (ReferenceDefinition) registry.load(null, reader, deploymentContext); + type.getDeclaredReferences().put(reference.getUri(), reference); + } + break; + case END_ELEMENT: + if (IMPLEMENTATION_SPRING.equals(reader.getName())) { + return implementation; + } + } + } + } + + protected Resource getApplicationContextResource(String locationAttr, ClassLoader cl) throws LoaderException { + assert runtimeInfo != null; + File manifestFile = null; + File appXmlFile; + File locationFile = new File(locationAttr); + +// if (!locationFile.isAbsolute()) { +// locationFile = new File(runtimeInfo.getApplicationRootDirectory(), locationAttr); +// } + if (!locationFile.exists()) { + // FIXME hack + URL url; + if (runtimeInfo instanceof WebappRuntimeInfo) { + try { + url = ((WebappRuntimeInfo) runtimeInfo).getServletContext().getResource(locationAttr); + } catch (MalformedURLException e) { + throw new LoaderException(e); + } + } else { + url = cl.getResource(locationAttr); + } + if (url != null) { + return new UrlResource(url); + } + throw new MissingResourceException(locationFile.toString()); + } + + if (locationFile.isDirectory()) { + try { + manifestFile = new File(locationFile, "META-INF/MANIFEST.MF"); + if (manifestFile.exists()) { + Manifest mf = new Manifest(new FileInputStream(manifestFile)); + Attributes mainAttrs = mf.getMainAttributes(); + String appCtxPath = mainAttrs.getValue("Spring-Context"); + if (appCtxPath != null) { + appXmlFile = new File(locationFile, appCtxPath); + if (appXmlFile.exists()) { + return new UrlResource(appXmlFile.toURL()); + } + } + } + // no manifest-specified Spring context, use default + appXmlFile = new File(locationFile, APPLICATION_CONTEXT); + if (appXmlFile.exists()) { + return new UrlResource(appXmlFile.toURL()); + } + } catch (IOException e) { + throw new LoaderException("Error reading manifest " + manifestFile); + } + } else { + try { + JarFile jf = new JarFile(locationFile); + JarEntry je; + Manifest mf = jf.getManifest(); + if (mf != null) { + Attributes mainAttrs = mf.getMainAttributes(); + String appCtxPath = mainAttrs.getValue("Spring-Context"); + if (appCtxPath != null) { + je = jf.getJarEntry(appCtxPath); + if (je != null) { + // TODO return a Spring specific Resouce type for jars + return new UrlResource(new URL("jar:" + locationFile.toURL() + "!/" + appCtxPath)); + } + } + } + je = jf.getJarEntry(APPLICATION_CONTEXT); + if (je != null) { + return new UrlResource(new URL("jar:" + locationFile.toURI().toURL() + "!" + APPLICATION_CONTEXT)); + } + } catch (IOException e) { + // bad archive + // TODO: create a more appropriate exception type + throw new MissingResourceException(locationAttr, e); + } + } + + throw new + + MissingResourceException(APPLICATION_CONTEXT); + } +} diff --git a/sandbox/old/contrib/implementation-spring/container/src/main/java/org/apache/tuscany/container/spring/loader/SpringXMLComponentTypeLoader.java b/sandbox/old/contrib/implementation-spring/container/src/main/java/org/apache/tuscany/container/spring/loader/SpringXMLComponentTypeLoader.java new file mode 100644 index 0000000000..21fb5b7b5b --- /dev/null +++ b/sandbox/old/contrib/implementation-spring/container/src/main/java/org/apache/tuscany/container/spring/loader/SpringXMLComponentTypeLoader.java @@ -0,0 +1,128 @@ +/* + * 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.container.spring.loader; + +import java.io.IOException; +import javax.xml.namespace.QName; +import javax.xml.stream.XMLInputFactory; +import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; +import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; +import javax.xml.stream.XMLStreamException; +import javax.xml.stream.XMLStreamReader; + +import org.osoa.sca.annotations.Reference; + +import org.apache.tuscany.spi.deployer.DeploymentContext; +import org.apache.tuscany.spi.extension.ComponentTypeLoaderExtension; +import org.apache.tuscany.spi.loader.LoaderException; +import org.apache.tuscany.spi.loader.LoaderRegistry; +import org.apache.tuscany.spi.loader.MissingResourceException; +import org.apache.tuscany.spi.model.Property; + +import org.apache.tuscany.container.spring.model.ReferenceDeclaration; +import org.apache.tuscany.container.spring.model.ServiceDeclaration; +import org.apache.tuscany.container.spring.model.SpringComponentType; +import org.apache.tuscany.container.spring.model.SpringImplementation; +import org.springframework.core.io.Resource; + +/** + * Introspects a Spring XML configuration file for its component type information. Other loader implementations may + * support alternative Spring configuration mechanisms. + * + * @version $Rev$ $Date$ + */ +public class SpringXMLComponentTypeLoader extends ComponentTypeLoaderExtension<SpringImplementation> { + private static final String SCA_NS = "http://www.springframework.org/schema/sca"; + private static final QName SERVICE_ELEMENT = new QName(SCA_NS, "service"); + private static final QName REFERENCE_ELEMENT = new QName(SCA_NS, "reference"); + private static final QName BEANS_ELEMENT = new QName("http://www.springframework.org/schema/beans", "beans"); + + public SpringXMLComponentTypeLoader(@Reference LoaderRegistry loaderRegistry) { + super(loaderRegistry); + } + + @Override + protected Class<SpringImplementation> getImplementationClass() { + return SpringImplementation.class; + } + + public void load( + SpringImplementation implementation, + DeploymentContext context) throws LoaderException { + if (implementation.getComponentType() != null) { + // FIXME hack since the builder registry loads the implementation type and the Spring implementation + // loader needs to as well. The second call is done by the builder registry and we just ignore it. + return; + } + SpringComponentType<Property<?>> type = new SpringComponentType<Property<?>>(); + Resource resource = implementation.getApplicationResource(); + loadFromXML(type, resource, context); + implementation.setComponentType(type); + } + + private void loadFromXML(SpringComponentType<Property<?>> type, Resource resource, DeploymentContext context) + throws LoaderException { + XMLStreamReader reader; + try { + XMLInputFactory factory = context.getXmlFactory(); + ClassLoader cl = context.getClassLoader(); + reader = factory.createXMLStreamReader(resource.getInputStream()); + boolean exposeAllBeans = true; + while (true) { + switch (reader.next()) { + case START_ELEMENT: + QName qname = reader.getName(); + if (SERVICE_ELEMENT.equals(qname)) { + exposeAllBeans = false; + String name = reader.getAttributeValue(SCA_NS, "name"); + Class<?> serviceType; + try { + serviceType = cl.loadClass(reader.getAttributeValue(SCA_NS, "type")); + } catch (ClassNotFoundException e) { + throw new MissingResourceException("Error loading service class", name, e); + } + String target = reader.getAttributeValue(SCA_NS, "target"); + type.addServiceDeclaration(new ServiceDeclaration(name, serviceType, target)); + } else if (REFERENCE_ELEMENT.equals(qname)) { + String name = reader.getAttributeValue(SCA_NS, "name"); + Class<?> serviceType; + try { + serviceType = cl.loadClass(reader.getAttributeValue(SCA_NS, "type")); + } catch (ClassNotFoundException e) { + throw new MissingResourceException("Error loading service class", name, e); + } + type.addReferenceDeclaration(new ReferenceDeclaration(name, serviceType)); + } + break; + case END_ELEMENT: + if (BEANS_ELEMENT.equals(reader.getName())) { + type.setExposeAllBeans(exposeAllBeans); + return; + } + } + } + + } catch (IOException e) { + throw new LoaderException(e); + } catch (XMLStreamException e) { + throw new LoaderException(e); + } + + } +}
\ No newline at end of file |