diff options
| author | lresende <lresende@13f79535-47bb-0310-9956-ffa450edef68> | 2009-11-11 23:13:23 +0000 |
|---|---|---|
| committer | lresende <lresende@13f79535-47bb-0310-9956-ffa450edef68> | 2009-11-11 23:13:23 +0000 |
| commit | 6d0e93c68d3aeaeb4bb6d96ac0460eec40ef786e (patch) | |
| tree | a956ed510e14a5509b8ef49fae42cfd439629825 /branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java | |
| parent | 3ac2d800d840f03618fc364090d786effde84b1f (diff) | |
Moving 1.x branches
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@835143 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java')
25 files changed, 0 insertions, 3705 deletions
diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponent.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponent.java deleted file mode 100644 index 9872788a05..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponent.java +++ /dev/null @@ -1,120 +0,0 @@ -/* - * 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.javascript; - -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.apache.tuscany.spi.ObjectCreationException; -import org.apache.tuscany.spi.component.CompositeComponent; -import org.apache.tuscany.spi.component.ScopeContainer; -import org.apache.tuscany.spi.component.TargetException; -import org.apache.tuscany.spi.component.WorkContext; -import org.apache.tuscany.spi.extension.AtomicComponentExtension; -import org.apache.tuscany.spi.model.Operation; -import org.apache.tuscany.spi.wire.InboundWire; -import org.apache.tuscany.spi.wire.OutboundWire; -import org.apache.tuscany.spi.wire.TargetInvoker; -import org.apache.tuscany.spi.wire.WireService; - -import org.apache.tuscany.container.javascript.rhino.RhinoScript; -import org.apache.tuscany.container.javascript.rhino.RhinoScriptInstance; - -/** - * The JavaScript component implementation. - */ -public class JavaScriptComponent extends AtomicComponentExtension { - - private final List<Class<?>> services; - - private final Map<String, Object> properties; - - private RhinoScript rhinoScript; - - public JavaScriptComponent(String name, RhinoScript rhinoScript, Map<String, Object> properties, List<Class<?>> services, - CompositeComponent parent, ScopeContainer scopeContainer, WireService wireService, - WorkContext workContext) { - super(name, parent, scopeContainer, wireService, workContext, null, 0); - - this.rhinoScript = rhinoScript; - this.services = services; - this.scope = scopeContainer.getScope(); - this.properties = properties; - } - - public Object createInstance() throws ObjectCreationException { - - Map<String, Object> context = new HashMap<String, Object>(getProperties()); - - for (List<OutboundWire> referenceWires : getOutboundWires().values()) { - for (OutboundWire wire : referenceWires) { - Object wireProxy = wireService.createProxy(wire); - //since all types that may be used in the reference interface may not be known to Rhino - //using the wireProxy as is will fail result in type conversion exceptions in cases where - //Rhino does not know enough of the tpypes used. Hence introduce a interceptor proxy, - //with weak typing (java.lang.Object) so that Rhino's call to the proxy succeeds. Then - //within this interceptor proxy perform data mediations required to correctly call the - //referenced service. - Class<?> businessInterface = wire.getServiceContract().getInterfaceClass(); - JavaScriptReferenceProxy interceptingProxy = - new JavaScriptReferenceProxy(businessInterface, - wireProxy, - rhinoScript.createInstanceScope(context)); - context.put(wire.getReferenceName(), interceptingProxy.createProxy()); - - } - } - - return rhinoScript.createRhinoScriptInstance(context); - } - - public TargetInvoker createTargetInvoker(String targetName, Operation operation) { - return new JavaScriptInvoker(operation.getName(), (Class)operation.getOutputType().getLogical(), this); - } - - // TODO: move all the following up to AtomicComponentExtension? - - public List<Class<?>> getServiceInterfaces() { - return services; - } - - public Map<String, Object> getProperties() { - return properties; - } - - public RhinoScriptInstance getTargetInstance() throws TargetException { - return (RhinoScriptInstance) scopeContainer.getInstance(this); - } - - public Object getServiceInstance() throws TargetException { - return getServiceInstance(null); - } - - public Object getServiceInstance(String service) throws TargetException { - InboundWire wire = getInboundWire(service); - if (wire == null) { - TargetException e = new TargetException("ServiceDefinition not found"); // TODO better error message - e.setIdentifier(service); - throw e; - } - return wireService.createProxy(wire); - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentBuilder.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentBuilder.java deleted file mode 100644 index 1987026e59..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentBuilder.java +++ /dev/null @@ -1,152 +0,0 @@ -/* - * 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.javascript; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.apache.tuscany.container.javascript.rhino.RhinoScript; -import org.apache.tuscany.container.javascript.utils.xmlfromxsd.XmlInstanceRegistry; -import org.apache.tuscany.spi.annotation.Autowire; -import org.apache.tuscany.spi.builder.BuilderConfigException; -import org.apache.tuscany.spi.component.Component; -import org.apache.tuscany.spi.component.CompositeComponent; -import org.apache.tuscany.spi.component.ScopeContainer; -import org.apache.tuscany.spi.deployer.DeploymentContext; -import org.apache.tuscany.spi.extension.ComponentBuilderExtension; -import org.apache.tuscany.spi.model.ComponentDefinition; -import org.apache.tuscany.spi.model.PropertyValue; -import org.apache.tuscany.spi.model.Scope; -import org.apache.tuscany.spi.model.ServiceDefinition; -import org.apache.xmlbeans.XmlObject; -import org.osoa.sca.annotations.Constructor; - -/** - * Extension point for creating {@link JavaScriptComponent}s from an assembly configuration - */ -public class JavaScriptComponentBuilder extends ComponentBuilderExtension<JavaScriptImplementation> { - - private static String head = "var xmlInstanceMap = new Array();"; - - private static String part1 = "xmlInstanceMap[\""; - - private static String part2 = "\"] = "; - - private static String part3 = ";"; - - private static String getXmlObjectFunction = - "function getXmlObject(xmlElementNamespace, xmlElementName){\n" + - "return xmlInstanceMap[xmlElementNamespace + \"#\" + xmlElementName];\n}"; - - XmlInstanceRegistry xmlInstRegistry; - - @Constructor({"xmlInstRegistry"}) - public JavaScriptComponentBuilder(@Autowire XmlInstanceRegistry reg) { - this.xmlInstRegistry = reg; - } - - protected Class<JavaScriptImplementation> getImplementationType() { - return JavaScriptImplementation.class; - } - - @SuppressWarnings("unchecked") - public Component build(CompositeComponent parent, ComponentDefinition<JavaScriptImplementation> componentDefinition, - DeploymentContext deploymentContext) throws BuilderConfigException { - - String name = componentDefinition.getName(); - JavaScriptImplementation implementation = componentDefinition.getImplementation(); - JavaScriptComponentType componentType = implementation.getComponentType(); - - // get list of services provided by this component - Collection<ServiceDefinition> collection = componentType.getServices().values(); - List<Class<?>> services = new ArrayList<Class<?>>(collection.size()); - for (ServiceDefinition serviceDefinition : collection) { - services.add(serviceDefinition.getServiceContract().getInterfaceClass()); - //do this for the set of references also - enhanceRhinoScript(serviceDefinition, implementation); - } - - // get the properties for the component - Collection<PropertyValue<?>> propertyValues = componentDefinition.getPropertyValues().values(); - Map<String, Object> properties = new HashMap<String, Object>(); - for (PropertyValue propertyValue : propertyValues) { - properties.put(propertyValue.getName(), propertyValue.getValueFactory().getInstance()); - } - - RhinoScript rhinoScript = implementation.getRhinoScript(); - - // TODO: have ComponentBuilderExtension pass ScopeContainer in on build method? - ScopeContainer scopeContainer; - Scope scope = componentType.getLifecycleScope(); - if (Scope.MODULE == scope) { - scopeContainer = deploymentContext.getModuleScope(); - } else { - scopeContainer = scopeRegistry.getScopeContainer(scope); - } - - return new JavaScriptComponent(name, rhinoScript, properties, services, parent, scopeContainer, wireService, workContext); - } - - private void enhanceRhinoScript(ServiceDefinition serviceDefn, JavaScriptImplementation implementation) throws BuilderConfigException { - //if the service interface of the component is a wsdl get the wsdl interface and generate - //xml instances for the elements in it. Add these xml instances to the rhinoscript. - //TODO : when interface.wsdl and wsdl registry is integrated remove this hardcoding and - //obtain wsdl from the interface.wsdl or wsdl registry - String wsdlPath = "org/apache/tuscany/container/javascript/rhino/helloworld.wsdl"; - - //this if block is a tempfix to get other testcases working. Again when a the interface.wsdl - //extension is in place this will be deleted. Right now this is the only way we know that - //a js has to do with an interface that is wsdl. - if (!implementation.getRhinoScript().getScriptName().endsWith("e4x.js")) { - return; - } - - try { - Map<String, XmlObject> xmlInstanceMap = xmlInstRegistry.getXmlInstance(wsdlPath); - StringBuffer sb = new StringBuffer(); - - sb.append(head); - sb.append("\n"); - for (String xmlInstanceKey : xmlInstanceMap.keySet()) { - sb.append(part1); - sb.append(xmlInstanceKey); - sb.append(part2); - sb.append(xmlInstanceMap.get(xmlInstanceKey).toString()); - sb.append(part3); - sb.append("\n"); - } - // System.out.println(" **** - " + sb.toString()); - - sb.append(getXmlObjectFunction); - - RhinoScript rhinoScript = implementation.getRhinoScript(); - sb.append(rhinoScript.getScript()); - rhinoScript.setScript(sb.toString()); - rhinoScript.initScriptScope(rhinoScript.getScriptName(), sb.toString(), null, rhinoScript.getClassLoader()); - implementation.setRhinoScript(rhinoScript); - - } catch (Exception e) { - throw new BuilderConfigException(e); - } - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentType.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentType.java deleted file mode 100644 index 31a4db14b6..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentType.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * 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.javascript; - -import org.apache.tuscany.spi.model.ComponentType; -import org.apache.tuscany.spi.model.Property; -import org.apache.tuscany.spi.model.ReferenceDefinition; -import org.apache.tuscany.spi.model.Scope; -import org.apache.tuscany.spi.model.ServiceDefinition; - -public class JavaScriptComponentType extends ComponentType<ServiceDefinition, ReferenceDefinition, Property<?>> { - - private Scope lifecycleScope = Scope.MODULE; - - public JavaScriptComponentType() { - } - - @SuppressWarnings("unchecked") - public JavaScriptComponentType(ComponentType ct) { - // TODO: A bit hacky but this is so the non-JavaScript .componentType side file can be used for now - setInitLevel(ct.getInitLevel()); - for (Object property : ct.getProperties().values()) { - add((Property)property); - } - for (Object reference : ct.getReferences().values()) { - add((ReferenceDefinition)reference); - } - for (Object service : ct.getServices().values()) { - add((ServiceDefinition)service); - } - } - - public Scope getLifecycleScope() { - return lifecycleScope; - } - - public void setLifecycleScope(Scope lifecycleScope) { - this.lifecycleScope = lifecycleScope; - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentTypeLoader.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentTypeLoader.java deleted file mode 100644 index e28daeceb0..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptComponentTypeLoader.java +++ /dev/null @@ -1,113 +0,0 @@ -/* - * 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.javascript; - -import java.net.URL; - -import org.apache.tuscany.spi.annotation.Autowire; -import org.apache.tuscany.spi.component.CompositeComponent; -import org.apache.tuscany.spi.deployer.DeploymentContext; -import org.apache.tuscany.spi.extension.ComponentTypeLoaderExtension; -import org.apache.tuscany.spi.idl.InvalidServiceContractException; -import org.apache.tuscany.spi.idl.java.JavaInterfaceProcessorRegistry; -import org.apache.tuscany.spi.loader.LoaderException; -import org.apache.tuscany.spi.loader.MissingResourceException; -import org.apache.tuscany.spi.model.ComponentType; - -import org.apache.tuscany.container.javascript.rhino.RhinoSCAConfig; -import org.apache.tuscany.container.javascript.rhino.RhinoScript; - -/** - * @version $Rev$ $Date$ - */ -public class JavaScriptComponentTypeLoader extends ComponentTypeLoaderExtension<JavaScriptImplementation> { - - private JavaInterfaceProcessorRegistry processorRegistry; - - public JavaScriptComponentTypeLoader(@Autowire JavaInterfaceProcessorRegistry processorRegistry) { - this.processorRegistry = processorRegistry; - } - - @Override - protected Class<JavaScriptImplementation> getImplementationClass() { - return JavaScriptImplementation.class; - } - - protected JavaScriptComponentType loadByIntrospection(CompositeComponent parent, - JavaScriptImplementation implementation, - DeploymentContext deploymentContext) throws - MissingResourceException, - InvalidServiceContractException { - - RhinoScript rhinoScript = implementation.getRhinoScript(); - RhinoSCAConfig scaConfig = rhinoScript.getSCAConfig(); - if (!scaConfig.hasSCAConfig()) { - throw new IllegalArgumentException( - "must use either .componentType side file or JS SCA varriable definition"); - } - - // FIXME this should be a system service, not instantiated here - JavaScriptComponentType componentType = new JavaScriptIntrospector(null, processorRegistry) - .introspectScript(scaConfig, rhinoScript.getClassLoader()); - - return componentType; - } - - protected String getResourceName(JavaScriptImplementation implementation) { - return implementation.getRhinoScript().getScriptName(); - } - - // TODO: must be possible to move all the following up in to ComponentTypeLoaderExtension - - public void load(CompositeComponent parent, JavaScriptImplementation implementation, - DeploymentContext deploymentContext) - throws LoaderException { - - URL resource = implementation.getRhinoScript().getClassLoader().getResource(getSideFileName(implementation)); - JavaScriptComponentType componentType; - if (resource == null) { - try { - componentType = loadByIntrospection(parent, implementation, deploymentContext); - } catch (InvalidServiceContractException e) { - throw new LoaderException("Invalid service contract", e); - } - } else { - componentType = loadFromSidefile(resource, deploymentContext); - } - - implementation.setComponentType(componentType); - } - - protected JavaScriptComponentType loadFromSidefile(URL url, DeploymentContext deploymentContext) - throws LoaderException { - ComponentType ct = loaderRegistry.load(null, url, ComponentType.class, deploymentContext); - JavaScriptComponentType jsct = new JavaScriptComponentType(ct); - return jsct; - } - - private String getSideFileName(JavaScriptImplementation implementation) { - String baseName = getResourceName(implementation); - int lastDot = baseName.lastIndexOf('.'); - if (lastDot != -1) { - baseName = baseName.substring(0, lastDot); - } - return baseName + ".componentType"; - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptImplementation.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptImplementation.java deleted file mode 100644 index 7de479f096..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptImplementation.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * 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.javascript; - -import org.apache.tuscany.container.javascript.rhino.RhinoScript; -import org.apache.tuscany.spi.model.AtomicImplementation; - -/** - * Model object for a JavaScript implementation. - */ -public class JavaScriptImplementation extends AtomicImplementation<JavaScriptComponentType> { - - private RhinoScript rhinoScript; - - public RhinoScript getRhinoScript() { - return rhinoScript; - } - - public void setRhinoScript(RhinoScript rhinoScript) { - this.rhinoScript = rhinoScript; - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptImplementationLoader.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptImplementationLoader.java deleted file mode 100644 index 67cc35afc2..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptImplementationLoader.java +++ /dev/null @@ -1,111 +0,0 @@ -/* - * 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.javascript; - -import java.io.IOException; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.io.Reader; -import java.net.URL; -import javax.xml.namespace.QName; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamReader; - -import org.apache.tuscany.container.javascript.rhino.RhinoScript; -import org.apache.tuscany.spi.annotation.Autowire; -import org.apache.tuscany.spi.component.CompositeComponent; -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.LoaderUtil; -import org.apache.tuscany.spi.loader.MissingResourceException; -import org.osoa.sca.annotations.Constructor; - -/** - * Loader for handling JavaScript <js:implementation.js> elements. - */ -public class JavaScriptImplementationLoader extends LoaderExtension<JavaScriptImplementation> { - private static final QName IMPLEMENTATION_JAVASCRIPT = - new QName("http://incubator.apache.org/tuscany/xmlns/container/js/1.0-incubator-M2", "implementation.js"); - - @Constructor({"registry"}) - public JavaScriptImplementationLoader(@Autowire LoaderRegistry registry) { - super(registry); - } - - public QName getXMLType() { - return IMPLEMENTATION_JAVASCRIPT; - } - - public JavaScriptImplementation load(CompositeComponent parent, XMLStreamReader reader, DeploymentContext deploymentContext) - throws XMLStreamException, LoaderException { - - String script = reader.getAttributeValue(null, "script"); - if (script == null) { - throw new MissingResourceException("No script supplied"); - } - - ClassLoader cl = deploymentContext.getClassLoader(); - String source = loadSource(cl, script); - - LoaderUtil.skipToEndElement(reader); - - JavaScriptImplementation implementation = new JavaScriptImplementation(); - RhinoScript rhinoScript = new RhinoScript(script, source, null, cl); - implementation.setRhinoScript(rhinoScript); - registry.loadComponentType(parent, implementation, deploymentContext); - return implementation; - } - - protected String loadSource(ClassLoader cl, String resource) throws LoaderException { - URL url = cl.getResource(resource); - if (url == null) { - throw new MissingResourceException(resource); - } - InputStream is; - try { - is = url.openStream(); - } catch (IOException e) { - MissingResourceException mre = new MissingResourceException(resource, e); - mre.setIdentifier(resource); - throw mre; - } - try { - Reader reader = new InputStreamReader(is, "UTF-8"); - char[] buffer = new char[1024]; - StringBuilder source = new StringBuilder(); - int count; - while ((count = reader.read(buffer)) > 0) { - source.append(buffer, 0, count); - } - return source.toString(); - } catch (IOException e) { - LoaderException le = new LoaderException(e); - le.setIdentifier(resource); - throw le; - } finally { - try { - is.close(); - } catch (IOException e) { - // ignore - } - } - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptIntrospector.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptIntrospector.java deleted file mode 100644 index 542504b62e..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptIntrospector.java +++ /dev/null @@ -1,173 +0,0 @@ -/* - * 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.javascript; - -import java.util.Iterator; -import java.util.Map; -import javax.wsdl.Definition; -import javax.wsdl.PortType; -import javax.wsdl.WSDLException; -import javax.wsdl.factory.WSDLFactory; -import javax.wsdl.xml.WSDLReader; -import javax.xml.namespace.QName; - -import org.apache.tuscany.spi.annotation.Autowire; -import org.apache.tuscany.spi.idl.InvalidServiceContractException; -import org.apache.tuscany.spi.idl.java.JavaInterfaceProcessorRegistry; -import org.apache.tuscany.spi.loader.MissingResourceException; -import org.apache.tuscany.spi.model.ComponentType; -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.container.javascript.rhino.RhinoSCAConfig; -import org.apache.tuscany.idl.wsdl.WSDLDefinitionRegistry; -import org.apache.tuscany.idl.wsdl.WSDLServiceContract; - -/** - * Introspects JavaScript files for SCA configuration - */ -public class JavaScriptIntrospector { - - private WSDLDefinitionRegistry wsdlRegistry; - private JavaInterfaceProcessorRegistry processorRegistry; - - public JavaScriptIntrospector(@Autowire WSDLDefinitionRegistry wsdlRegistry, - @Autowire JavaInterfaceProcessorRegistry processorRegistry) { - this.wsdlRegistry = wsdlRegistry; - this.processorRegistry = processorRegistry; - } - - public JavaScriptComponentType introspectScript(RhinoSCAConfig scaConfig, ClassLoader cl) - throws MissingResourceException, InvalidServiceContractException { - JavaScriptComponentType componentType = new JavaScriptComponentType(); - introspectJavaInterface(componentType, cl, scaConfig.getJavaInterface()); - introspectWSDLInterface(componentType, cl, scaConfig.getWSDLNamespace(), scaConfig.getWSDLPortType(), - scaConfig.getWSDLLocation()); - introspectReferences(componentType, cl, scaConfig.getReferences()); - introspectProperties(componentType, cl, scaConfig.getProperties()); - introspectScope(componentType, scaConfig.getScope()); - return componentType; - } - - private void introspectScope(JavaScriptComponentType componentType, Scope scope) { - if (scope != null) { - componentType.setLifecycleScope(scope); - } - } - - @SuppressWarnings("unchecked") - private void introspectJavaInterface(ComponentType componentType, ClassLoader cl, String serviceClass) - throws MissingResourceException, InvalidServiceContractException { - if (serviceClass != null) { - ServiceDefinition service = new ServiceDefinition(); - try { - ServiceContract<?> sc = processorRegistry.introspect(Class.forName(serviceClass)); - service.setServiceContract(sc); - componentType.add(service); - } catch (ClassNotFoundException e) { - throw new MissingResourceException("Interface not found", e); - } - } - } - - @SuppressWarnings("unchecked") - private void introspectWSDLInterface(ComponentType componentType, ClassLoader cl, String wsdlNamespace, - String wsdlPortType, String wsdlLocation) { - if (wsdlNamespace == null && wsdlPortType == null && wsdlLocation == null) { - return; - } - - PortType portType = null; - if (wsdlLocation != null) { - portType = readWSDLPortType(wsdlNamespace, wsdlPortType, wsdlLocation, portType); - } else { - portType = getPortType(wsdlNamespace, wsdlPortType); - } - - ServiceDefinition service = new ServiceDefinition(); - WSDLServiceContract wsdlSC = new WSDLServiceContract(); - wsdlSC.setPortType(portType); - service.setServiceContract(wsdlSC); - componentType.add(service); - } - - private PortType readWSDLPortType(String wsdlNamespace, String wsdlPortType, String wsdlLocation, - PortType portType) { - Definition wsdlDefinition; - try { - WSDLReader reader = WSDLFactory.newInstance().newWSDLReader(); - reader.setFeature("javax.wsdl.verbose", false); - wsdlDefinition = reader.readWSDL(wsdlLocation.toString()); - } catch (WSDLException e) { - throw new RuntimeException(e); - - } - Map portTypes = wsdlDefinition.getPortTypes(); - for (Iterator i = portTypes.keySet().iterator(); i.hasNext();) { - QName portTypeQN = (QName) i.next(); - if (wsdlNamespace != null) { - if (!portTypeQN.getNamespaceURI().equals(wsdlNamespace)) { - continue; - } - } - if (wsdlPortType != null) { - if (!portTypeQN.getLocalPart().equals(wsdlPortType)) { - continue; - } - } - if (portType != null) { - throw new RuntimeException("multiple matching portTypes in wsdl: " + wsdlLocation); - } - portType = (PortType) portTypes.get(portTypeQN); - } - if (portType == null) { - throw new RuntimeException("portType not found in wsdl: " + wsdlLocation); - } - return portType; - } - - private PortType getPortType(String wsdlNamespace, String wsdlPortType) { - if (wsdlPortType == null) { - throw new IllegalArgumentException("must specify the wsdlPortType in script SCA config"); - } - PortType portType = null; - if (wsdlNamespace != null) { - QName portTypeQN = new QName(wsdlNamespace.toString(), wsdlPortType.toString()); - portType = wsdlRegistry.getPortType(portTypeQN); - if (portType == null) { - throw new IllegalArgumentException("no WSDL registered for portType: " + portTypeQN); - } - } else { - // wsdlRegistry.getPortType(wsdlPortType.toString()); - if (portType == null) { - throw new IllegalArgumentException("no WSDL registered for portType:" + wsdlPortType); - } - } - return portType; - } - - - private void introspectProperties(ComponentType componentType, ClassLoader cl, Map properties) { - } - - private void introspectReferences(ComponentType componentType, ClassLoader cl, Map references) { - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptInvoker.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptInvoker.java deleted file mode 100644 index 281b417d64..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptInvoker.java +++ /dev/null @@ -1,53 +0,0 @@ -/* - * 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.javascript; - -import java.lang.reflect.InvocationTargetException; - -import org.apache.tuscany.container.javascript.rhino.RhinoScriptInstance; -import org.apache.tuscany.spi.extension.TargetInvokerExtension; - -/** - * Dispatches to a JavaScript implementation instance - * - * @version $$Rev$$ $$Date$$ - */ -public class JavaScriptInvoker extends TargetInvokerExtension { - - private JavaScriptComponent context; - - private String functionName; - - private Class responseClass; - - public JavaScriptInvoker(String functionName, Class respClass, JavaScriptComponent context) { - this.functionName = functionName; - this.context = context; - this.responseClass = respClass; - } - - /** - * Invokes a function on a script instance - */ - public Object invokeTarget(final Object payload) throws InvocationTargetException { - RhinoScriptInstance target = context.getTargetInstance(); - return target.invokeFunction(functionName, (Object[]) payload, responseClass); - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptRefInvocInterceptor.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptRefInvocInterceptor.java deleted file mode 100644 index f8c978f833..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptRefInvocInterceptor.java +++ /dev/null @@ -1,132 +0,0 @@ -/* - * 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.javascript; - -import java.io.ByteArrayInputStream; -import java.lang.reflect.InvocationHandler; -import java.lang.reflect.Method; - -import javax.xml.stream.XMLStreamReader; - -import org.apache.axiom.om.OMAbstractFactory; -import org.apache.axiom.om.OMElement; -import org.apache.axiom.om.impl.builder.StAXOMBuilder; -import org.apache.axiom.om.util.StAXUtils; -import org.apache.xmlbeans.XmlObject; -import org.mozilla.javascript.Context; -import org.mozilla.javascript.Scriptable; -import org.mozilla.javascript.ScriptableObject; -import org.mozilla.javascript.Wrapper; -import org.mozilla.javascript.xml.XMLObject; - -/** - * This Interceptor encasulates the data mediation required by the JavaScriptReferenceProxy. The - * invocation handler of this class traps the javascript reference calls, performs data mediation - * and calls then calls the actual referred service. This classes implementation is subject to - * review and change when the DataMediation infrastructure of Tuscany is ready. - * - */ -public class JavaScriptRefInvocInterceptor implements InvocationHandler { - private Object actualProxy; - - private Class wireInterface; - - private Scriptable instanceScope; - - JavaScriptRefInvocInterceptor(Object wireProxy, Class wireIfc, Scriptable instScope) { - this.actualProxy = wireProxy; - this.wireInterface = wireIfc; - this.instanceScope = instScope; - } - - public Object invoke(Object arg0, Method method, Object[] args) throws Throwable { - // TODO Auto-generated method stub - Context cx = Context.enter(); - try { - Method invokedMethod = getInvokedMethod(method.getName()); - Object[] tranformedArgs = new Object[args.length]; - for (int count = 0; count < args.length; ++count) { - tranformedArgs[count] = fromJavaScript(invokedMethod.getParameterTypes()[count], args[count]); - } - - Object response = invokedMethod.invoke(actualProxy, tranformedArgs); - response = toJavaScript(response, instanceScope, cx); - return response; - } finally { - Context.exit(); - } - } - - private Method getInvokedMethod(String methodName) { - Method[] methods = wireInterface.getMethods(); - - for (int count = 0; count < methods.length; ++count) { - if (methods[count].getName().equals(methodName)) { - return methods[count]; - } - } - throw new RuntimeException("Unable to find invocation method"); - } - - protected Object fromJavaScript(Class reqArgType, Object jsArg) throws Exception { - Object javaArg; - if (Context.getUndefinedValue().equals(jsArg)) { - javaArg = null; - } else if (jsArg instanceof XMLObject) { - // TODO: E4X Bug? Shouldn't need this copy, but without it the outer element gets lost??? - Scriptable jsXML = (Scriptable) ScriptableObject.callMethod((Scriptable) jsArg, "copy", new Object[0]); - Wrapper wrapper = (Wrapper) ScriptableObject.callMethod(jsXML, "getXmlObject", new Object[0]); - javaArg = wrapper.unwrap(); - - XMLStreamReader xmlReader = StAXUtils.createXMLStreamReader(new ByteArrayInputStream(javaArg.toString().getBytes())); - StAXOMBuilder staxOMBuilder = new StAXOMBuilder(OMAbstractFactory.getOMFactory(), xmlReader); - javaArg = staxOMBuilder.getDocumentElement(); - } else if (jsArg instanceof Wrapper) { - javaArg = ((Wrapper) jsArg).unwrap(); - } else { - if (reqArgType != null) { - javaArg = Context.jsToJava(jsArg, reqArgType); - } else { - javaArg = Context.jsToJava(jsArg, String.class); - } - } - - return javaArg; - } - - protected Object toJavaScript(Object retVal, Scriptable scope, Context cx) throws RuntimeException { - Object jsRetVal; - if (retVal instanceof OMElement) { - try { - XmlObject xmlObject = XmlObject.Factory.parse(retVal.toString()); - Object jsXML = cx.getWrapFactory().wrap(cx, scope, xmlObject, XmlObject.class); - jsRetVal = cx.newObject(scope, "XML", new Object[] { jsXML }); - } catch (Exception e) { - throw new RuntimeException(e); - } - } else if (retVal instanceof XmlObject) { - Object jsXML = cx.getWrapFactory().wrap(cx, scope, (XmlObject) retVal, XmlObject.class); - jsRetVal = cx.newObject(scope, "XML", new Object[] { jsXML }); - } else { - jsRetVal = Context.toObject(retVal, scope); - } - - return jsRetVal; - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptReferenceProxy.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptReferenceProxy.java deleted file mode 100644 index 8b432872b8..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/JavaScriptReferenceProxy.java +++ /dev/null @@ -1,132 +0,0 @@ -/* - * 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.javascript; - -import java.lang.reflect.InvocationHandler; -import java.lang.reflect.Method; -import java.lang.reflect.Proxy; - -import net.sf.cglib.asm.ClassWriter; -import net.sf.cglib.asm.CodeVisitor; -import net.sf.cglib.asm.Constants; -import net.sf.cglib.asm.Type; - -import org.apache.tuscany.spi.wire.WireInvocationHandler; -import org.mozilla.javascript.Context; -import org.mozilla.javascript.Scriptable; -import org.mozilla.javascript.ScriptableObject; -import org.mozilla.javascript.Wrapper; -import org.mozilla.javascript.xml.XMLObject; - -/** - * This is a proxy that will mediate reference calls from the JavaScript. The mediation code here will be reviewed when the DataMediation - * infrastructure is ready. This proxy assmes that there is no verloading of service methods on the reference interface i.e. there are no two service - * methods that have the same method name or operation name. - */ -public class JavaScriptReferenceProxy { - - private Class interfaze; - - private Object wireProxy; - - private Scriptable instanceScope; - - public JavaScriptReferenceProxy(Class interfaze, Object wireProxy, Scriptable instScope) { - this.interfaze = interfaze; - this.wireProxy = wireProxy; - this.instanceScope = instScope; - } - - public Object createProxy() { - try { - GenericProxyClassLoader classloader = new GenericProxyClassLoader(); - final byte[] byteCode = generateGenericInterface(interfaze); - - Class genericInterface = classloader.defineClass(byteCode); - InvocationHandler proxyHandler = new JavaScriptRefInvocInterceptor(wireProxy, - interfaze, instanceScope); - // return genericInterface.cast(Proxy.newProxyInstance(classloader, new Class[]{genericInterface}, proxyHandler)); - return Proxy.newProxyInstance(classloader, - new Class[]{genericInterface}, - proxyHandler); - } catch (Exception e) { - return null; - } - } - - private static byte[] generateGenericInterface(Class serviceInterface) { - String interfazeName = serviceInterface.getCanonicalName(); - ClassWriter cw = new ClassWriter(false); - - cw.visit(Constants.V1_5, - Constants.ACC_PUBLIC + Constants.ACC_ABSTRACT + Constants.ACC_INTERFACE, - interfazeName.replace('.', - '/'), - "java/lang/Object", - null, - serviceInterface.getSimpleName() + ".java"); - - StringBuffer argsAndReturn = new StringBuffer("("); - Method[] methods = serviceInterface.getMethods(); - for (int count = 0; count < methods.length; ++count) { - argsAndReturn = new StringBuffer("("); - Class[] paramTypes = methods[count].getParameterTypes(); - Class returnType = methods[count].getReturnType(); - - for (int paramCount = 0; paramCount < paramTypes.length; ++paramCount) { - argsAndReturn.append(Type.getType(Object.class)); - } - argsAndReturn.append(")"); - argsAndReturn.append(Type.getType(Object.class)); - - Class[] exceptionTypes = methods[count].getExceptionTypes(); - String[] exceptions = new String[exceptionTypes.length]; - for (int excCount = 0; excCount < exceptionTypes.length; ++excCount) { - exceptions[excCount] = exceptionTypes[excCount].getName(); - exceptions[excCount] = exceptions[excCount].replace('.', - '/'); - } - - CodeVisitor cv = cw.visitMethod(Constants.ACC_PUBLIC + Constants.ACC_ABSTRACT, - methods[count].getName(), - argsAndReturn.toString(), - exceptions, - null); - cw.visitEnd(); - } - - cw.visitEnd(); - - return cw.toByteArray(); - } - - private class GenericProxyClassLoader extends ClassLoader { - public Class defineClass(byte[] byteArray) { - try { - return defineClass(null, - byteArray, - 0, - byteArray.length); - } catch (Throwable e) { - return null; - } - } - - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoFunctionInvoker.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoFunctionInvoker.java deleted file mode 100644 index b2064f9110..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoFunctionInvoker.java +++ /dev/null @@ -1,123 +0,0 @@ -/* - * 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.javascript.rhino; - -import java.io.ByteArrayInputStream; - -import javax.xml.stream.XMLStreamReader; - -import org.apache.axiom.om.OMAbstractFactory; -import org.apache.axiom.om.OMElement; -import org.apache.axiom.om.impl.builder.StAXOMBuilder; -import org.apache.axiom.om.util.StAXUtils; -import org.apache.xmlbeans.XmlObject; -import org.mozilla.javascript.Context; -import org.mozilla.javascript.Function; -import org.mozilla.javascript.Scriptable; -import org.mozilla.javascript.ScriptableObject; -import org.mozilla.javascript.Wrapper; -import org.mozilla.javascript.xml.XMLObject; - -/** - * An invoker for a specific function in a JavaScript script - */ -public class RhinoFunctionInvoker { - - private Scriptable instanceScope; - - private Function function; - - private Class responseClass; - - public RhinoFunctionInvoker(Scriptable instanceScope, Function function, Class responseClass) { - this.instanceScope = instanceScope; - this.function = function; - this.responseClass = responseClass; - } - - public Object invoke(Object[] args) { - Context cx = Context.enter(); - try { - - Object[] jsArgs = toJavaScript(args, instanceScope, cx); - Object jsResponse = function.call(cx, instanceScope, instanceScope, jsArgs); - Object response = fromJavaScript(jsResponse); - return response; - - } catch ( Exception e ) { - throw new RuntimeException(e); - } - finally { - Context.exit(); - } - } - - protected Object[] toJavaScript(Object[] arg, Scriptable scope, Context cx) throws RuntimeException { - Object[] jsArgs; - if (arg == null) { - jsArgs = new Object[0]; - } else if (arg.length == 1 && arg[0] instanceof OMElement) { - try { - XmlObject xmlObject = XmlObject.Factory.parse(arg[0].toString()); - Object jsXML = cx.getWrapFactory().wrap(cx, scope, xmlObject, XmlObject.class); - jsArgs = new Object[] { cx.newObject(scope, "XML", new Object[] { jsXML }) }; - } catch ( Exception e ) { - throw new RuntimeException(e); - } - } else if (arg.length == 1 && arg[0] instanceof XmlObject) { - Object jsXML = cx.getWrapFactory().wrap(cx, scope, (XmlObject)arg[0], XmlObject.class); - jsArgs = new Object[] { cx.newObject(scope, "XML", new Object[] { jsXML }) }; - } else { - jsArgs = new Object[arg.length]; - for (int i = 0; i < jsArgs.length; i++) { - jsArgs[i] = Context.toObject(arg[i], scope); - } - } - - return jsArgs; - } - - protected Object fromJavaScript(Object o) throws Exception { - Object response; - if (Context.getUndefinedValue().equals(o)) { - response = null; - } else if (o instanceof XMLObject) { - // TODO: E4X Bug? Shouldn't need this copy, but without it the outer element gets lost??? - Scriptable jsXML = (Scriptable) ScriptableObject.callMethod((Scriptable) o, "copy", new Object[0]); - Wrapper wrapper = (Wrapper) ScriptableObject.callMethod(jsXML, "getXmlObject", new Object[0]); - response = wrapper.unwrap(); - - XMLStreamReader xmlReader = - StAXUtils.createXMLStreamReader(new ByteArrayInputStream(response.toString().getBytes())); - StAXOMBuilder staxOMBuilder = new StAXOMBuilder(OMAbstractFactory.getOMFactory(), xmlReader); - response = staxOMBuilder.getDocumentElement(); - - } else if (o instanceof Wrapper) { - response = ((Wrapper) o).unwrap(); - } else { - if (responseClass != null) { - response = Context.jsToJava(o, responseClass); - } else { - response = Context.jsToJava(o, String.class); - } - } - return response; - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoSCAConfig.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoSCAConfig.java deleted file mode 100644 index af27403c03..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoSCAConfig.java +++ /dev/null @@ -1,157 +0,0 @@ -/* - * 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.javascript.rhino; - -import java.util.HashMap; -import java.util.Map; - -import org.apache.tuscany.spi.model.Scope; -import org.mozilla.javascript.Scriptable; -import org.mozilla.javascript.UniqueTag; - -/** - * Represents the variable defining the SCA aspects of the script - * <code> - * SCA = { - * javaInterface : "my.pkg.ClassName", - * wsdlPortType : "wsdlPortTypeName", - * wsdlNameSpace : "http://my.namespace.com", - * wsdlLocation : "\wsdl\mywsdl.txt", - * properties : { "foo" : ["java.lang.String", "defaultValue"],}, - * references : {}, - * scope : 'stateless'|'request'|'conversational'|'composite', - * } - * </code> - * The config must define the service with either javaInterface or wsdl. When - * using wsdl the three parameters are optional. If wsdlLocation is used that is the - * WSDL document used, and the namespace and portType parameters are only required if - * the WSDL definition defines multiple portTypes. - */ -public class RhinoSCAConfig { - - private boolean hasSCAConfig; - - private String javaInterface; - - private String wsdlLocation; - - private String wsdlNamespace; - - private String wsdlPortType; - - private Map properties; - - private Map references; - - private Scope scope; - - public RhinoSCAConfig(Scriptable scriptScope) { - Object o = scriptScope.get("SCA", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - hasSCAConfig = true; - Scriptable scaVar = (Scriptable) o; - o = scaVar.get("javaInterface", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - this.javaInterface = o.toString(); - } - o = scaVar.get("wsdlLocation", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - this.wsdlLocation = o.toString(); - } - o = scaVar.get("wsdlPortType", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - this.wsdlPortType = o.toString(); - } - o = scaVar.get("wsdlNamespace", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - this.wsdlNamespace = o.toString(); - } - if (javaInterface != null) { - if (wsdlLocation != null || wsdlPortType != null || wsdlNamespace != null) { - throw new IllegalArgumentException("script SCA config defines both Java and WSDL service interface"); - } - } else { - if (wsdlLocation == null && wsdlPortType == null && wsdlNamespace == null) { - throw new IllegalArgumentException("script SCA config must define either Java or WSDL service interface"); - } - } - - this.properties = new HashMap(); - o = scaVar.get("properties", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - // TODO parse properties - } - - this.references = new HashMap(); - o = scaVar.get("references", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - // TODO parse references - } - - o = scaVar.get("scope", scriptScope); - if (o != null && UniqueTag.NOT_FOUND != o) { - if ("stateless".equalsIgnoreCase(String.valueOf(o))) { - this.scope = Scope.STATELESS; - } else if ("request".equalsIgnoreCase(String.valueOf(o))) { - this.scope = Scope.REQUEST; - } else if ("conversational".equalsIgnoreCase(String.valueOf(o))) { - this.scope = Scope.SESSION; // TODO: where's CONVERSATIONAL? - } else if ("composite".equalsIgnoreCase(String.valueOf(o))) { - this.scope = Scope.MODULE; // TODO: composite = MODULE for now? - } else { - throw new IllegalArgumentException("invalid scope value: " + o); - } - } - - } - } - - public boolean hasSCAConfig() { - return hasSCAConfig; - } - - public String getJavaInterface() { - return javaInterface; - } - - public Map getProperties() { - return properties; - } - - public Map getReferences() { - return references; - } - - public String getWSDLLocation() { - return wsdlLocation; - } - - public String getWSDLNamespace() { - return wsdlNamespace; - } - - public String getWSDLPortType() { - return wsdlPortType; - } - - public Scope getScope() { - return scope; - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoScript.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoScript.java deleted file mode 100644 index 3552372223..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoScript.java +++ /dev/null @@ -1,210 +0,0 @@ -/* - * 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.javascript.rhino; - -import java.util.HashMap; -import java.util.Iterator; -import java.util.Map; - -import org.mozilla.javascript.Context; -import org.mozilla.javascript.ContextFactory; -import org.mozilla.javascript.ImporterTopLevel; -import org.mozilla.javascript.Script; -import org.mozilla.javascript.Scriptable; - -/** - * A RhinoScript represents a compiled JavaScript script - */ -public class RhinoScript { - - protected String scriptName; - - protected String script; - - protected Scriptable scriptScope; - - protected Map<String, Class> responseClasses; - - protected ClassLoader classLoader; - - /* - * Enable dynamic scopes so a script can be used concurrently with a global shared scope and individual execution scopes. See - * http://www.mozilla.org/rhino/scopes.html - */ - private static class MyFactory extends ContextFactory { - protected boolean hasFeature(Context cx, int featureIndex) { - if (featureIndex == Context.FEATURE_DYNAMIC_SCOPE) { - return true; - } - return super.hasFeature(cx, featureIndex); - } - } - - static { - ContextFactory.initGlobal(new MyFactory()); - } - - /** - * Create a new RhinoScript. - * - * @param scriptName - * the name of the script. Can be anything, only used in messages to identify the script - * @param script - * the complete script - */ - public RhinoScript(String scriptName, String script) { - this(scriptName, script, (Map) null, null); - } - - /** - * Create a new RhinoInvoker. - * - * @param scriptName - * the name of the script. Can be anything, only used in messages to identify the script - * @param script - * the complete script - * @param context - * name-value pairs that are added in to the scope where the script is compiled. May be null. The value objects are made available to - * the script by using a variable with the name. - * @param classLoader - * the ClassLoader Rhino should use to locate any user Java classes used in the script - */ - public RhinoScript(String scriptName, String script, Map context, ClassLoader classLoader) { - this.scriptName = scriptName; - this.script = script; - this.responseClasses = new HashMap<String, Class>(); - this.classLoader = classLoader; - initScriptScope(scriptName, script, context, classLoader); - } - - /** - * Create a new invokeable instance of the script - * - * @return a RhinoScriptInstance - */ - public RhinoScriptInstance createRhinoScriptInstance() { - return createRhinoScriptInstance(null); - } - - /** - * Create a new invokeable instance of the script - * - * @param context - * objects to add to scope of the script instance - * @return a RhinoScriptInstance - */ - public RhinoScriptInstance createRhinoScriptInstance(Map<String, Object> context) { - Scriptable instanceScope = createInstanceScope(context); - RhinoScriptInstance rsi = new RhinoScriptInstance(scriptScope, instanceScope, context, responseClasses); - return rsi; - } - - /** - * Initialize the Rhino Scope for this script instance - */ - public Scriptable createInstanceScope(Map<String, Object> context) { - Context cx = Context.enter(); - try { - - Scriptable instanceScope = cx.newObject(scriptScope); - instanceScope.setPrototype(scriptScope); - instanceScope.setParentScope(null); - - addContexts(instanceScope, context); - - return instanceScope; - - } finally { - Context.exit(); - } - } - - /** - * Create a Rhino scope and compile the script into it - */ - public void initScriptScope(String fileName, String scriptCode, Map context, ClassLoader cl) { - Context cx = Context.enter(); - try { - if (cl != null) { - // TODO: broken with the way the tuscany launcher now uses class loaders - // cx.setApplicationClassLoader(cl); - } - this.scriptScope = new ImporterTopLevel(cx, true); - Script compiledScript = cx.compileString(scriptCode, fileName, 1, null); - compiledScript.exec(cx, scriptScope); - addContexts(scriptScope, context); - - } finally { - Context.exit(); - } - } - - /** - * Add the context to the scope. This will make the objects available to a script by using the name it was added with. - */ - protected void addContexts(Scriptable scope, Map contexts) { - if (contexts != null) { - for (Iterator i = contexts.keySet().iterator(); i.hasNext();) { - String name = (String) i.next(); - Object value = contexts.get(name); - if (value != null) { - scope.put(name, scope, Context.toObject(value, scope)); - } - } - } - } - - public String getScript() { - return script; - } - - public String getScriptName() { - return scriptName; - } - - public Scriptable getScriptScope() { - return scriptScope; - } - - public Map<String, Class> getResponseClasses() { - return responseClasses; - } - - public ClassLoader getClassLoader() { - return classLoader; - } - - /** - * Set the Java type of a response value. JavaScript is dynamically typed so Rhino cannot always work out what the intended Java type of a - * response should be, for example should the statement "return 42" be a Java int, or Integer or Double etc. When Rhino can't determine the type - * it will default to returning a String, using this method enables overriding the Rhino default to use a specific Java type. - */ - public void setResponseClass(String functionName, Class responseClasses) { - this.responseClasses.put(functionName, responseClasses); - } - - public RhinoSCAConfig getSCAConfig() { - return new RhinoSCAConfig(getScriptScope()); - } - - public void setScript(String script) { - this.script = script; - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoScriptInstance.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoScriptInstance.java deleted file mode 100644 index 508bc2a90a..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/rhino/RhinoScriptInstance.java +++ /dev/null @@ -1,109 +0,0 @@ -/* - * 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.javascript.rhino; - -import java.util.HashMap; -import java.util.Iterator; -import java.util.Map; - -import org.mozilla.javascript.Context; -import org.mozilla.javascript.Function; -import org.mozilla.javascript.Scriptable; -import org.mozilla.javascript.UniqueTag; - -/** - * An invokeable instance of a JavaScript script. - */ -public class RhinoScriptInstance { - - private Scriptable scriptScope; - - private Scriptable instanceScope; - - private Map<String, Class> responseClasses; - - public RhinoScriptInstance(Scriptable scriptScope, Scriptable instanceScope, Map<String, Object> context, Map<String, Class> responseClasses) { - this.scriptScope = scriptScope; - this.instanceScope = instanceScope; - this.responseClasses = responseClasses; - if (this.responseClasses == null) { - this.responseClasses = new HashMap<String, Class>(); - } - addContexts(instanceScope, context); - } - - public Object invokeFunction(String functionName, Object[] args) { - return invokeFunction(functionName, args, null); - } - - public Object invokeFunction(String functionName, Object[] args, Class respClass) { - RhinoFunctionInvoker invoker = createRhinoFunctionInvoker(functionName, respClass); - return invoker.invoke(args); - } - - public RhinoFunctionInvoker createRhinoFunctionInvoker(String functionName) { - return createRhinoFunctionInvoker(functionName, null); - } - - - public RhinoFunctionInvoker createRhinoFunctionInvoker(String functionName, Class responseClass) { - Function function = getFunction(functionName); - //Class responseClass = responseClasses.get(functionName); - RhinoFunctionInvoker invoker = new RhinoFunctionInvoker(instanceScope, function, responseClass); - return invoker; - } - - /** - * Add the context to the scope. This will make the objects available to a script by using the name it was added with. - */ - protected void addContexts(Scriptable scope, Map contexts) { - if (contexts != null) { - Context.enter(); - try { - for (Iterator i = contexts.keySet().iterator(); i.hasNext();) { - String name = (String) i.next(); - Object value = contexts.get(name); - if (value != null) { - scope.put(name, scope, Context.toObject(value, scope)); - } - } - } finally { - Context.exit(); - } - } - } - - /** - * Get the Rhino Function object for the named script function - */ - protected Function getFunction(String functionName) { - - Object handleObj = scriptScope.get(functionName, instanceScope); - if (UniqueTag.NOT_FOUND.equals(handleObj)) { - // Bit of a hack so E4X scripts don't need to define a function for every operation - handleObj = scriptScope.get("process", instanceScope); - } - if (!(handleObj instanceof Function)) { - throw new RuntimeException("script function '" + functionName + "' is undefined or not a function"); - } - - return (Function) handleObj; - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/CmdLineArgsHandler.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/CmdLineArgsHandler.java deleted file mode 100644 index b724b33ac3..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/CmdLineArgsHandler.java +++ /dev/null @@ -1,28 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -/** - * This interface is to be implemented by classes that wish to - * handle commandline arguments. - * - */ -public interface CmdLineArgsHandler { - public void handleArgument(String optionFlag, String argValue) throws IllegalArgumentException; -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/CmdLineArgsProcessor.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/CmdLineArgsProcessor.java deleted file mode 100644 index 914f1d03f2..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/CmdLineArgsProcessor.java +++ /dev/null @@ -1,79 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -/** - * This class provides a generic command line arguments processing utility. The processArgs - * method of this class processes the command line arguments that could contain option flags, - * options and values and calls a ArgumentHanlder instance for handling the agruments. - * - */ -public class CmdLineArgsProcessor { - private String printUsageMessage = "No hints available on Usage!"; - - private CmdLineArgsHandler argsHandler = null; - - public static final String HYPEN = "-"; - - public void processArgs(String[] args) { - try { - if (args.length == 0) { - printUsage(); - } else { - parseAndHandleArgs(args); - } - } catch (Exception e) { - System.out.println("Exception in processing argument - " + e); - printUsage(); - } - - } - - public void parseAndHandleArgs(String[] args) throws Exception { - int index = 0; - while (index < args.length - 1) { - if (args[index].startsWith(HYPEN) && !args[index + 1].startsWith(HYPEN)) { - argsHandler.handleArgument(args[index].substring(1), args[index + 1]); - index = index + 2; - } else { - throw new IllegalArgumentException("Wrong Usage of options!"); - } - } - } - - protected void printUsage() { - - } - - public CmdLineArgsHandler getArgsHandler() { - return argsHandler; - } - - public void setArgsHandler(CmdLineArgsHandler argsHandler) { - this.argsHandler = argsHandler; - } - - public String getPrintUsageMessage() { - return printUsageMessage; - } - - public void setPrintUsageMessage(String printUsageMessage) { - this.printUsageMessage = printUsageMessage; - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/TuscanySampleXmlUtil.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/TuscanySampleXmlUtil.java deleted file mode 100644 index a0155c76e6..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/TuscanySampleXmlUtil.java +++ /dev/null @@ -1,1097 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -import org.apache.xmlbeans.SchemaType; -import org.apache.xmlbeans.XmlCursor; -import org.apache.xmlbeans.SchemaParticle; -import org.apache.xmlbeans.SchemaLocalElement; -import org.apache.xmlbeans.SchemaProperty; -import org.apache.xmlbeans.GDuration; -import org.apache.xmlbeans.GDurationBuilder; -import org.apache.xmlbeans.GDate; -import org.apache.xmlbeans.GDateBuilder; -import org.apache.xmlbeans.XmlAnySimpleType; -import org.apache.xmlbeans.SimpleValue; -import org.apache.xmlbeans.XmlOptions; -import org.apache.xmlbeans.XmlObject; -import org.apache.xmlbeans.XmlInteger; -import org.apache.xmlbeans.XmlDate; -import org.apache.xmlbeans.XmlDateTime; -import org.apache.xmlbeans.XmlTime; -import org.apache.xmlbeans.XmlGYear; -import org.apache.xmlbeans.XmlGYearMonth; -import org.apache.xmlbeans.XmlGMonth; -import org.apache.xmlbeans.XmlGMonthDay; -import org.apache.xmlbeans.XmlGDay; -import org.apache.xmlbeans.XmlDecimal; -import org.apache.xmlbeans.XmlDuration; -import org.apache.xmlbeans.soap.SchemaWSDLArrayType; -import org.apache.xmlbeans.soap.SOAPArrayType; -import org.apache.xmlbeans.impl.util.Base64; -import org.apache.xmlbeans.impl.util.HexBin; - -import java.math.BigDecimal; -import java.math.BigInteger; -import java.util.ArrayList; -import java.util.Calendar; -import java.util.Date; -import java.util.Random; -import java.util.Set; -import java.util.HashSet; -import java.util.Arrays; - -import javax.xml.namespace.QName; - -/** - * This class is a replication of the XMLBeans SampleXMLutil class. This replication - * is required to overide the XMLBeans behaviour of this class in certain places. Since - * most methods of the XMLBeans implementation of this class is private, no overiding - * has been possible using inheritance. Hence this replication. - * - */ -public class TuscanySampleXmlUtil { - private static final String BLANK_STRING = " "; - - private boolean generate_sample_data = false; - - private boolean _soapEnc; - - private static final int MAX_ELEMENTS = 1000; - - private int _nElements; - - boolean flag = true; - - private TuscanySampleXmlUtil(boolean soapEnc) { - _soapEnc = soapEnc; - } - - public TuscanySampleXmlUtil() { - this(false); - } - - public String createSampleForType(SchemaType sType) { - XmlObject object = XmlObject.Factory.newInstance(); - XmlCursor cursor = object.newCursor(); - // Skip the document node - cursor.toNextToken(); - // Using the type and the cursor, call the utility method to get a - // sample XML payload for that Schema element - createSampleForType(sType, cursor); - // Cursor now contains the sample payload - // Pretty print the result. Note that the cursor is positioned at the - // end of the doc so we use the original xml object that the cursor was - // created upon to do the xmlText() against. - XmlOptions options = new XmlOptions(); - options.put(XmlOptions.SAVE_PRETTY_PRINT); - options.put(XmlOptions.SAVE_PRETTY_PRINT_INDENT, 2); - options.put(XmlOptions.SAVE_AGGRESSIVE_NAMESPACES); - String result = object.xmlText(options); - return result; - } - - Random _picker = new Random(1); - - /** - * Cursor position - * Before: - * <theElement>^</theElement> - * After: - * <theElement><lots of stuff/>^</theElement> - */ - private void createSampleForType(SchemaType stype, XmlCursor xmlc) { - if (_typeStack.contains(stype)) - //if ( !flag ) - return; - //else - // flag = false; - - _typeStack.add(stype); - - try { - if (stype.isSimpleType() || stype.isURType()) { - processSimpleType(stype, xmlc); - return; - } - - // complex Type - // <theElement>^</theElement> - processAttributes(stype, xmlc); - - // <theElement attri1="string">^</theElement> - switch (stype.getContentType()) { - case SchemaType.NOT_COMPLEX_TYPE: - case SchemaType.EMPTY_CONTENT: - // noop - break; - case SchemaType.SIMPLE_CONTENT: { - processSimpleType(stype, xmlc); - } - break; - case SchemaType.MIXED_CONTENT: - if (isGenerate_sample_data()) - xmlc.insertChars(pick(WORDS) + " "); - if (stype.getContentModel() != null) { - processParticle(stype.getContentModel(), xmlc, true); - } - if (isGenerate_sample_data()) - xmlc.insertChars(pick(WORDS)); - - break; - case SchemaType.ELEMENT_CONTENT: - if (stype.getContentModel() != null) { - processParticle(stype.getContentModel(), xmlc, false); - } - break; - } - } finally { - _typeStack.remove(_typeStack.size() - 1); - } - } - - private void processSimpleType(SchemaType stype, XmlCursor xmlc) { - String sample = sampleDataForSimpleType(stype); - xmlc.insertChars(sample); - - } - - private String sampleDataForSimpleType(SchemaType sType) { - if (isGenerate_sample_data()) { - return generateSampleDataForSimpleType(sType); - } else { - return BLANK_STRING; - } - } - - private String generateSampleDataForSimpleType(SchemaType sType) { - if (XmlObject.type.equals(sType)) - return "anyType"; - - if (XmlAnySimpleType.type.equals(sType)) - return "anySimpleType"; - - if (sType.getSimpleVariety() == SchemaType.LIST) { - SchemaType itemType = sType.getListItemType(); - StringBuffer sb = new StringBuffer(); - int length = pickLength(sType); - if (length > 0) - sb.append(sampleDataForSimpleType(itemType)); - for (int i = 1; i < length; i += 1) { - sb.append(' '); - sb.append(sampleDataForSimpleType(itemType)); - } - return sb.toString(); - } - - if (sType.getSimpleVariety() == SchemaType.UNION) { - SchemaType[] possibleTypes = sType.getUnionConstituentTypes(); - if (possibleTypes.length == 0) - return ""; - return sampleDataForSimpleType(possibleTypes[pick(possibleTypes.length)]); - } - - XmlAnySimpleType[] enumValues = sType.getEnumerationValues(); - if (enumValues != null && enumValues.length > 0) { - return enumValues[pick(enumValues.length)].getStringValue(); - } - - switch (sType.getPrimitiveType().getBuiltinTypeCode()) { - default: - case SchemaType.BTC_NOT_BUILTIN: - return ""; - - case SchemaType.BTC_ANY_TYPE: - case SchemaType.BTC_ANY_SIMPLE: - return "anything"; - - case SchemaType.BTC_BOOLEAN: - return pick(2) == 0 ? "true" : "false"; - - case SchemaType.BTC_BASE_64_BINARY: { - String result = null; - try { - result = new String(Base64.encode(formatToLength(pick(WORDS), sType).getBytes("utf-8"))); - } catch (java.io.UnsupportedEncodingException e) { /* Can't possibly happen */ - } - return result; - } - - case SchemaType.BTC_HEX_BINARY: - return HexBin.encode(formatToLength(pick(WORDS), sType)); - - case SchemaType.BTC_ANY_URI: - return formatToLength("http://www." + pick(DNS1) + "." + pick(DNS2) + "/" + pick(WORDS) + "/" + pick(WORDS), sType); - - case SchemaType.BTC_QNAME: - return formatToLength("qname", sType); - - case SchemaType.BTC_NOTATION: - return formatToLength("notation", sType); - - case SchemaType.BTC_FLOAT: - return "1.5E2"; - case SchemaType.BTC_DOUBLE: - return "1.051732E7"; - case SchemaType.BTC_DECIMAL: - switch (closestBuiltin(sType).getBuiltinTypeCode()) { - case SchemaType.BTC_SHORT: - return formatDecimal("1", sType); - case SchemaType.BTC_UNSIGNED_SHORT: - return formatDecimal("5", sType); - case SchemaType.BTC_BYTE: - return formatDecimal("2", sType); - case SchemaType.BTC_UNSIGNED_BYTE: - return formatDecimal("6", sType); - case SchemaType.BTC_INT: - return formatDecimal("3", sType); - case SchemaType.BTC_UNSIGNED_INT: - return formatDecimal("7", sType); - case SchemaType.BTC_LONG: - return formatDecimal("10", sType); - case SchemaType.BTC_UNSIGNED_LONG: - return formatDecimal("11", sType); - case SchemaType.BTC_INTEGER: - return formatDecimal("100", sType); - case SchemaType.BTC_NON_POSITIVE_INTEGER: - return formatDecimal("-200", sType); - case SchemaType.BTC_NEGATIVE_INTEGER: - return formatDecimal("-201", sType); - case SchemaType.BTC_NON_NEGATIVE_INTEGER: - return formatDecimal("200", sType); - case SchemaType.BTC_POSITIVE_INTEGER: - return formatDecimal("201", sType); - default: - case SchemaType.BTC_DECIMAL: - return formatDecimal("1000.00", sType); - } - - case SchemaType.BTC_STRING: { - String result; - switch (closestBuiltin(sType).getBuiltinTypeCode()) { - case SchemaType.BTC_STRING: - case SchemaType.BTC_NORMALIZED_STRING: - result = "string"; - break; - - case SchemaType.BTC_TOKEN: - result = "token"; - break; - - default: - result = "string"; - break; - } - - return formatToLength(result, sType); - } - - case SchemaType.BTC_DURATION: - return formatDuration(sType); - - case SchemaType.BTC_DATE_TIME: - case SchemaType.BTC_TIME: - case SchemaType.BTC_DATE: - case SchemaType.BTC_G_YEAR_MONTH: - case SchemaType.BTC_G_YEAR: - case SchemaType.BTC_G_MONTH_DAY: - case SchemaType.BTC_G_DAY: - case SchemaType.BTC_G_MONTH: - return formatDate(sType); - } - } - - // a bit from the Aenid - public static final String[] WORDS = new String[] { "ipsa", "iovis", "rapidum", "iaculata", "e", "nubibus", "ignem", "disiecitque", "rates", - "evertitque", "aequora", "ventis", "illum", "exspirantem", "transfixo", "pectore", "flammas", "turbine", "corripuit", "scopuloque", - "infixit", "acuto", "ast", "ego", "quae", "divum", "incedo", "regina", "iovisque", "et", "soror", "et", "coniunx", "una", "cum", "gente", - "tot", "annos", "bella", "gero", "et", "quisquam", "numen", "iunonis", "adorat", "praeterea", "aut", "supplex", "aris", "imponet", - "honorem", "talia", "flammato", "secum", "dea", "corde", "volutans", "nimborum", "in", "patriam", "loca", "feta", "furentibus", - "austris", "aeoliam", "venit", "hic", "vasto", "rex", "aeolus", "antro", "luctantis", "ventos", "tempestatesque", "sonoras", "imperio", - "premit", "ac", "vinclis", "et", "carcere", "frenat", "illi", "indignantes", "magno", "cum", "murmure", "montis", "circum", "claustra", - "fremunt", "celsa", "sedet", "aeolus", "arce", "sceptra", "tenens", "mollitque", "animos", "et", "temperat", "iras", "ni", "faciat", - "maria", "ac", "terras", "caelumque", "profundum", "quippe", "ferant", "rapidi", "secum", "verrantque", "per", "auras", "sed", "pater", - "omnipotens", "speluncis", "abdidit", "atris", "hoc", "metuens", "molemque", "et", "montis", "insuper", "altos", "imposuit", "regemque", - "dedit", "qui", "foedere", "certo", "et", "premere", "et", "laxas", "sciret", "dare", "iussus", "habenas", }; - - private static final String[] DNS1 = new String[] { "corp", "your", "my", "sample", "company", "test", "any" }; - - private static final String[] DNS2 = new String[] { "com", "org", "com", "gov", "org", "com", "org", "com", "edu" }; - - private int pick(int n) { - return _picker.nextInt(n); - } - - private String pick(String[] a) { - return a[pick(a.length)]; - } - - private String pick(String[] a, int count) { - if (count <= 0) - return ""; - - int i = pick(a.length); - StringBuffer sb = new StringBuffer(a[i]); - while (count-- > 0) { - i += 1; - if (i >= a.length) - i = 0; - sb.append(' '); - sb.append(a[i]); - } - return sb.toString(); - } - - private String pickDigits(int digits) { - StringBuffer sb = new StringBuffer(); - while (digits-- > 0) - sb.append(Integer.toString(pick(10))); - return sb.toString(); - } - - private int pickLength(SchemaType sType) { - XmlInteger length = (XmlInteger) sType.getFacet(SchemaType.FACET_LENGTH); - if (length != null) - return length.getBigIntegerValue().intValue(); - XmlInteger min = (XmlInteger) sType.getFacet(SchemaType.FACET_MIN_LENGTH); - XmlInteger max = (XmlInteger) sType.getFacet(SchemaType.FACET_MAX_LENGTH); - int minInt, maxInt; - if (min == null) - minInt = 0; - else - minInt = min.getBigIntegerValue().intValue(); - if (max == null) - maxInt = Integer.MAX_VALUE; - else - maxInt = max.getBigIntegerValue().intValue(); - // We try to keep the length of the array within reasonable limits, - // at least 1 item and at most 3 if possible - if (minInt == 0 && maxInt >= 1) - minInt = 1; - if (maxInt > minInt + 2) - maxInt = minInt + 2; - if (maxInt < minInt) - maxInt = minInt; - return minInt + pick(maxInt - minInt); - } - - /** - * Formats a given string to the required length, using the following operations: - * - append the source string to itself as necessary to pass the minLength; - * - truncate the result of previous step, if necessary, to keep it within minLength. - */ - private String formatToLength(String s, SchemaType sType) { - String result = s; - try { - SimpleValue min = (SimpleValue) sType.getFacet(SchemaType.FACET_LENGTH); - if (min == null) - min = (SimpleValue) sType.getFacet(SchemaType.FACET_MIN_LENGTH); - if (min != null) { - int len = min.getIntValue(); - while (result.length() < len) - result = result + result; - } - SimpleValue max = (SimpleValue) sType.getFacet(SchemaType.FACET_LENGTH); - if (max == null) - max = (SimpleValue) sType.getFacet(SchemaType.FACET_MAX_LENGTH); - if (max != null) { - int len = max.getIntValue(); - if (result.length() > len) - result = result.substring(0, len); - } - } catch (Exception e) // intValue can be out of range - { - } - return result; - } - - private String formatDecimal(String start, SchemaType sType) { - BigDecimal result = new BigDecimal(start); - XmlDecimal xmlD; - xmlD = (XmlDecimal) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - BigDecimal min = xmlD != null ? xmlD.getBigDecimalValue() : null; - xmlD = (XmlDecimal) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - BigDecimal max = xmlD != null ? xmlD.getBigDecimalValue() : null; - boolean minInclusive = true, maxInclusive = true; - xmlD = (XmlDecimal) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (xmlD != null) { - BigDecimal minExcl = xmlD.getBigDecimalValue(); - if (min == null || min.compareTo(minExcl) < 0) { - min = minExcl; - minInclusive = false; - } - } - xmlD = (XmlDecimal) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (xmlD != null) { - BigDecimal maxExcl = xmlD.getBigDecimalValue(); - if (max == null || max.compareTo(maxExcl) > 0) { - max = maxExcl; - maxInclusive = false; - } - } - xmlD = (XmlDecimal) sType.getFacet(SchemaType.FACET_TOTAL_DIGITS); - int totalDigits = -1; - if (xmlD != null) { - totalDigits = xmlD.getBigDecimalValue().intValue(); - - StringBuffer sb = new StringBuffer(totalDigits); - for (int i = 0; i < totalDigits; i++) - sb.append('9'); - BigDecimal digitsLimit = new BigDecimal(sb.toString()); - if (max != null && max.compareTo(digitsLimit) > 0) { - max = digitsLimit; - maxInclusive = true; - } - digitsLimit = digitsLimit.negate(); - if (min != null && min.compareTo(digitsLimit) < 0) { - min = digitsLimit; - minInclusive = true; - } - } - - int sigMin = min == null ? 1 : result.compareTo(min); - int sigMax = max == null ? -1 : result.compareTo(max); - boolean minOk = sigMin > 0 || sigMin == 0 && minInclusive; - boolean maxOk = sigMax < 0 || sigMax == 0 && maxInclusive; - - // Compute the minimum increment - xmlD = (XmlDecimal) sType.getFacet(SchemaType.FACET_FRACTION_DIGITS); - int fractionDigits = -1; - BigDecimal increment; - if (xmlD == null) - increment = new BigDecimal(1); - else { - fractionDigits = xmlD.getBigDecimalValue().intValue(); - if (fractionDigits > 0) { - StringBuffer sb = new StringBuffer("0."); - for (int i = 1; i < fractionDigits; i++) - sb.append('0'); - sb.append('1'); - increment = new BigDecimal(sb.toString()); - } else - increment = new BigDecimal(1.0); - } - - if (minOk && maxOk) { - // OK - } else if (minOk && !maxOk) { - // TOO BIG - if (maxInclusive) - result = max; - else - result = max.subtract(increment); - } else if (!minOk && maxOk) { - // TOO SMALL - if (minInclusive) - result = min; - else - result = min.add(increment); - } else { - // MIN > MAX!! - } - - // We have the number - // Adjust the scale according to the totalDigits and fractionDigits - int digits = 0; - BigDecimal ONE = new BigDecimal(BigInteger.ONE); - for (BigDecimal n = result; n.abs().compareTo(ONE) >= 0; digits++) - n = n.movePointLeft(1); - - if (fractionDigits > 0) - if (totalDigits >= 0) - result.setScale(Math.max(fractionDigits, totalDigits - digits)); - else - result.setScale(fractionDigits); - else if (fractionDigits == 0) - result.setScale(0); - - return result.toString(); - } - - private String formatDuration(SchemaType sType) { - XmlDuration d = (XmlDuration) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - GDuration minInclusive = null; - if (d != null) - minInclusive = d.getGDurationValue(); - - d = (XmlDuration) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - GDuration maxInclusive = null; - if (d != null) - maxInclusive = d.getGDurationValue(); - - d = (XmlDuration) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - GDuration minExclusive = null; - if (d != null) - minExclusive = d.getGDurationValue(); - - d = (XmlDuration) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - GDuration maxExclusive = null; - if (d != null) - maxExclusive = d.getGDurationValue(); - - GDurationBuilder gdurb = new GDurationBuilder(); - BigInteger min, max; - - gdurb.setSecond(pick(800000)); - gdurb.setMonth(pick(20)); - - // Years - // Months - // Days - // Hours - // Minutes - // Seconds - // Fractions - if (minInclusive != null) { - if (gdurb.getYear() < minInclusive.getYear()) - gdurb.setYear(minInclusive.getYear()); - if (gdurb.getMonth() < minInclusive.getMonth()) - gdurb.setMonth(minInclusive.getMonth()); - if (gdurb.getDay() < minInclusive.getDay()) - gdurb.setDay(minInclusive.getDay()); - if (gdurb.getHour() < minInclusive.getHour()) - gdurb.setHour(minInclusive.getHour()); - if (gdurb.getMinute() < minInclusive.getMinute()) - gdurb.setMinute(minInclusive.getMinute()); - if (gdurb.getSecond() < minInclusive.getSecond()) - gdurb.setSecond(minInclusive.getSecond()); - if (gdurb.getFraction().compareTo(minInclusive.getFraction()) < 0) - gdurb.setFraction(minInclusive.getFraction()); - } - - if (maxInclusive != null) { - if (gdurb.getYear() > maxInclusive.getYear()) - gdurb.setYear(maxInclusive.getYear()); - if (gdurb.getMonth() > maxInclusive.getMonth()) - gdurb.setMonth(maxInclusive.getMonth()); - if (gdurb.getDay() > maxInclusive.getDay()) - gdurb.setDay(maxInclusive.getDay()); - if (gdurb.getHour() > maxInclusive.getHour()) - gdurb.setHour(maxInclusive.getHour()); - if (gdurb.getMinute() > maxInclusive.getMinute()) - gdurb.setMinute(maxInclusive.getMinute()); - if (gdurb.getSecond() > maxInclusive.getSecond()) - gdurb.setSecond(maxInclusive.getSecond()); - if (gdurb.getFraction().compareTo(maxInclusive.getFraction()) > 0) - gdurb.setFraction(maxInclusive.getFraction()); - } - - if (minExclusive != null) { - if (gdurb.getYear() <= minExclusive.getYear()) - gdurb.setYear(minExclusive.getYear() + 1); - if (gdurb.getMonth() <= minExclusive.getMonth()) - gdurb.setMonth(minExclusive.getMonth() + 1); - if (gdurb.getDay() <= minExclusive.getDay()) - gdurb.setDay(minExclusive.getDay() + 1); - if (gdurb.getHour() <= minExclusive.getHour()) - gdurb.setHour(minExclusive.getHour() + 1); - if (gdurb.getMinute() <= minExclusive.getMinute()) - gdurb.setMinute(minExclusive.getMinute() + 1); - if (gdurb.getSecond() <= minExclusive.getSecond()) - gdurb.setSecond(minExclusive.getSecond() + 1); - if (gdurb.getFraction().compareTo(minExclusive.getFraction()) <= 0) - gdurb.setFraction(minExclusive.getFraction().add(new BigDecimal(0.001))); - } - - if (maxExclusive != null) { - if (gdurb.getYear() > maxExclusive.getYear()) - gdurb.setYear(maxExclusive.getYear()); - if (gdurb.getMonth() > maxExclusive.getMonth()) - gdurb.setMonth(maxExclusive.getMonth()); - if (gdurb.getDay() > maxExclusive.getDay()) - gdurb.setDay(maxExclusive.getDay()); - if (gdurb.getHour() > maxExclusive.getHour()) - gdurb.setHour(maxExclusive.getHour()); - if (gdurb.getMinute() > maxExclusive.getMinute()) - gdurb.setMinute(maxExclusive.getMinute()); - if (gdurb.getSecond() > maxExclusive.getSecond()) - gdurb.setSecond(maxExclusive.getSecond()); - if (gdurb.getFraction().compareTo(maxExclusive.getFraction()) > 0) - gdurb.setFraction(maxExclusive.getFraction()); - } - - gdurb.normalize(); - return gdurb.toString(); - } - - private String formatDate(SchemaType sType) { - GDateBuilder gdateb = new GDateBuilder(new Date(1000L * pick(365 * 24 * 60 * 60) + (30L + pick(20)) * 365 * 24 * 60 * 60 * 1000)); - GDate min = null, max = null; - GDate temp; - - // Find the min and the max according to the type - switch (sType.getPrimitiveType().getBuiltinTypeCode()) { - case SchemaType.BTC_DATE_TIME: { - XmlDateTime x = (XmlDateTime) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlDateTime) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlDateTime) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlDateTime) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - case SchemaType.BTC_TIME: { - XmlTime x = (XmlTime) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlTime) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlTime) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlTime) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - case SchemaType.BTC_DATE: { - XmlDate x = (XmlDate) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlDate) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlDate) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlDate) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - case SchemaType.BTC_G_YEAR_MONTH: { - XmlGYearMonth x = (XmlGYearMonth) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlGYearMonth) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlGYearMonth) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlGYearMonth) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - case SchemaType.BTC_G_YEAR: { - XmlGYear x = (XmlGYear) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlGYear) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlGYear) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlGYear) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - case SchemaType.BTC_G_MONTH_DAY: { - XmlGMonthDay x = (XmlGMonthDay) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlGMonthDay) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlGMonthDay) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlGMonthDay) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - case SchemaType.BTC_G_DAY: { - XmlGDay x = (XmlGDay) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlGDay) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlGDay) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlGDay) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - case SchemaType.BTC_G_MONTH: { - XmlGMonth x = (XmlGMonth) sType.getFacet(SchemaType.FACET_MIN_INCLUSIVE); - if (x != null) - min = x.getGDateValue(); - x = (XmlGMonth) sType.getFacet(SchemaType.FACET_MIN_EXCLUSIVE); - if (x != null) - if (min == null || min.compareToGDate(x.getGDateValue()) <= 0) - min = x.getGDateValue(); - - x = (XmlGMonth) sType.getFacet(SchemaType.FACET_MAX_INCLUSIVE); - if (x != null) - max = x.getGDateValue(); - x = (XmlGMonth) sType.getFacet(SchemaType.FACET_MAX_EXCLUSIVE); - if (x != null) - if (max == null || max.compareToGDate(x.getGDateValue()) >= 0) - max = x.getGDateValue(); - break; - } - } - - if (min != null && max == null) { - if (min.compareToGDate(gdateb) >= 0) { - // Reset the date to min + (1-8) hours - Calendar c = gdateb.getCalendar(); - c.add(Calendar.HOUR_OF_DAY, pick(8)); - gdateb = new GDateBuilder(c); - } - } else if (min == null && max != null) { - if (max.compareToGDate(gdateb) <= 0) { - // Reset the date to max - (1-8) hours - Calendar c = gdateb.getCalendar(); - c.add(Calendar.HOUR_OF_DAY, 0 - pick(8)); - gdateb = new GDateBuilder(c); - } - } else if (min != null && max != null) { - if (min.compareToGDate(gdateb) >= 0 || max.compareToGDate(gdateb) <= 0) { - // Find a date between the two - Calendar c = min.getCalendar(); - Calendar cmax = max.getCalendar(); - c.add(Calendar.HOUR_OF_DAY, 1); - if (c.after(cmax)) { - c.add(Calendar.HOUR_OF_DAY, -1); - c.add(Calendar.MINUTE, 1); - if (c.after(cmax)) { - c.add(Calendar.MINUTE, -1); - c.add(Calendar.SECOND, 1); - if (c.after(cmax)) { - c.add(Calendar.SECOND, -1); - c.add(Calendar.MILLISECOND, 1); - if (c.after(cmax)) - c.add(Calendar.MILLISECOND, -1); - } - } - } - gdateb = new GDateBuilder(c); - } - } - - gdateb.setBuiltinTypeCode(sType.getPrimitiveType().getBuiltinTypeCode()); - if (pick(2) == 0) - gdateb.clearTimeZone(); - return gdateb.toString(); - } - - private SchemaType closestBuiltin(SchemaType sType) { - while (!sType.isBuiltinType()) - sType = sType.getBaseType(); - return sType; - } - - /** - * Cracks a combined QName of the form URL:localname - */ - public static QName crackQName(String qName) { - String ns; - String name; - - int index = qName.lastIndexOf(':'); - if (index >= 0) { - ns = qName.substring(0, index); - name = qName.substring(index + 1); - } else { - ns = ""; - name = qName; - } - - return new QName(ns, name); - } - - /** - * Cursor position: - * Before this call: - * <outer><foo/>^</outer> (cursor at the ^) - * After this call: - * <<outer><foo/><bar/>som text<etc/>^</outer> - */ - private void processParticle(SchemaParticle sp, XmlCursor xmlc, boolean mixed) { - int loop = determineMinMaxForSample(sp, xmlc); - - while (loop-- > 0) { - switch (sp.getParticleType()) { - case (SchemaParticle.ELEMENT): - processElement(sp, xmlc, mixed); - break; - case (SchemaParticle.SEQUENCE): - processSequence(sp, xmlc, mixed); - break; - case (SchemaParticle.CHOICE): - processChoice(sp, xmlc, mixed); - break; - case (SchemaParticle.ALL): - processAll(sp, xmlc, mixed); - break; - case (SchemaParticle.WILDCARD): - processWildCard(sp, xmlc, mixed); - break; - default: - // throw new Exception("No Match on Schema Particle Type: " + String.valueOf(sp.getParticleType())); - } - } - } - - private int determineMinMaxForSample(SchemaParticle sp, XmlCursor xmlc) { - int minOccurs = sp.getIntMinOccurs(); - int maxOccurs = sp.getIntMaxOccurs(); - - if (minOccurs == maxOccurs) - return minOccurs; - - int result = minOccurs; - if (result == 0 && _nElements < MAX_ELEMENTS) - result = 1; - - if (sp.getParticleType() != SchemaParticle.ELEMENT) - return result; - - // it probably only makes sense to put comments in front of individual elements that repeat - - if (sp.getMaxOccurs() == null) { - // xmlc.insertComment("The next " + getItemNameOrType(sp, xmlc) + " may be repeated " + minOccurs + " or more times"); - if (minOccurs == 0) - xmlc.insertComment("Zero or more repetitions:"); - else - xmlc.insertComment(minOccurs + " or more repetitions:"); - } else if (sp.getIntMaxOccurs() > 1) { - xmlc.insertComment(minOccurs + " to " + String.valueOf(sp.getMaxOccurs()) + " repetitions:"); - } else { - xmlc.insertComment("Optional:"); - } - return result; - } - - /* - Return a name for the element or the particle type to use in the comment for minoccurs, max occurs - */ - private String getItemNameOrType(SchemaParticle sp, XmlCursor xmlc) { - String elementOrTypeName = null; - if (sp.getParticleType() == SchemaParticle.ELEMENT) { - elementOrTypeName = "Element (" + sp.getName().getLocalPart() + ")"; - } else { - elementOrTypeName = printParticleType(sp.getParticleType()); - } - return elementOrTypeName; - } - - private void processElement(SchemaParticle sp, XmlCursor xmlc, boolean mixed) { - // cast as schema local element - SchemaLocalElement element = (SchemaLocalElement) sp; - /// ^ -> <elemenname></elem>^ - if (_soapEnc) - xmlc.insertElement(element.getName().getLocalPart()); // soap encoded? drop namespaces. - else - xmlc.insertElement(element.getName().getLocalPart(), element.getName().getNamespaceURI()); - _nElements++; - /// -> <elem>^</elem> - xmlc.toPrevToken(); - // -> <elem>stuff^</elem> - createSampleForType(element.getType(), xmlc); - // -> <elem>stuff</elem>^ - xmlc.toNextToken(); - - } - - private void moveToken(int numToMove, XmlCursor xmlc) { - for (int i = 0; i < Math.abs(numToMove); i++) { - if (numToMove < 0) { - xmlc.toPrevToken(); - } else { - xmlc.toNextToken(); - } - } - } - - private static final String formatQName(XmlCursor xmlc, QName qName) { - XmlCursor parent = xmlc.newCursor(); - parent.toParent(); - String prefix = parent.prefixForNamespace(qName.getNamespaceURI()); - parent.dispose(); - String name; - if (prefix == null || prefix.length() == 0) - name = qName.getLocalPart(); - else - name = prefix + ":" + qName.getLocalPart(); - return name; - } - - private static final QName HREF = new QName("href"); - - private static final QName ID = new QName("id"); - - private static final QName XSI_TYPE = new QName("http://www.w3.org/2001/XMLSchema-instance", "type"); - - private static final QName ENC_ARRAYTYPE = new QName("http://schemas.xmlsoap.org/soap/encoding/", "arrayType"); - - private static final QName ENC_OFFSET = new QName("http://schemas.xmlsoap.org/soap/encoding/", "offset"); - - private static final Set SKIPPED_SOAP_ATTRS = new HashSet(Arrays.asList(new QName[] { HREF, ID, ENC_OFFSET })); - - private void processAttributes(SchemaType stype, XmlCursor xmlc) { - if (_soapEnc) { - QName typeName = stype.getName(); - if (typeName != null) { - xmlc.insertAttributeWithValue(XSI_TYPE, formatQName(xmlc, typeName)); - } - } - - SchemaProperty[] attrProps = stype.getAttributeProperties(); - for (int i = 0; i < attrProps.length; i++) { - SchemaProperty attr = attrProps[i]; - if (_soapEnc) { - if (SKIPPED_SOAP_ATTRS.contains(attr.getName())) - continue; - if (ENC_ARRAYTYPE.equals(attr.getName())) { - SOAPArrayType arrayType = ((SchemaWSDLArrayType) stype.getAttributeModel().getAttribute(attr.getName())).getWSDLArrayType(); - if (arrayType != null) - xmlc.insertAttributeWithValue(attr.getName(), formatQName(xmlc, arrayType.getQName()) + arrayType.soap11DimensionString()); - continue; - } - } - String defaultValue = attr.getDefaultText(); - xmlc.insertAttributeWithValue(attr.getName(), defaultValue == null ? sampleDataForSimpleType(attr.getType()) : defaultValue); - } - } - - private void processSequence(SchemaParticle sp, XmlCursor xmlc, boolean mixed) { - SchemaParticle[] spc = sp.getParticleChildren(); - for (int i = 0; i < spc.length; i++) { - /// <parent>maybestuff^</parent> - processParticle(spc[i], xmlc, mixed); - //<parent>maybestuff...morestuff^</parent> - if (mixed && i < spc.length - 1) { - if (isGenerate_sample_data()) { - xmlc.insertChars(pick(WORDS)); - } else { - xmlc.insertChars(""); - } - } - } - } - - private void processChoice(SchemaParticle sp, XmlCursor xmlc, boolean mixed) { - SchemaParticle[] spc = sp.getParticleChildren(); - xmlc.insertComment("You have a CHOICE of the next " + String.valueOf(spc.length) + " items at this level"); - for (int i = 0; i < spc.length; i++) { - processParticle(spc[i], xmlc, mixed); - } - } - - private void processAll(SchemaParticle sp, XmlCursor xmlc, boolean mixed) { - SchemaParticle[] spc = sp.getParticleChildren(); - // xmlc.insertComment("You may enter the following " + String.valueOf(spc.length) + " items in any order"); - for (int i = 0; i < spc.length; i++) { - processParticle(spc[i], xmlc, mixed); - if (mixed && i < spc.length - 1) - xmlc.insertChars(pick(WORDS)); - } - } - - private void processWildCard(SchemaParticle sp, XmlCursor xmlc, boolean mixed) { - xmlc.insertComment("You may enter ANY elements at this point"); - xmlc.insertElement("AnyElement"); - } - - /** - * This method will get the base type for the schema type - */ - - private static QName getClosestName(SchemaType sType) { - while (sType.getName() == null) - sType = sType.getBaseType(); - - return sType.getName(); - } - - private String printParticleType(int particleType) { - StringBuffer returnParticleType = new StringBuffer(); - returnParticleType.append("Schema Particle Type: "); - - switch (particleType) { - case SchemaParticle.ALL: - returnParticleType.append("ALL\n"); - break; - case SchemaParticle.CHOICE: - returnParticleType.append("CHOICE\n"); - break; - case SchemaParticle.ELEMENT: - returnParticleType.append("ELEMENT\n"); - break; - case SchemaParticle.SEQUENCE: - returnParticleType.append("SEQUENCE\n"); - break; - case SchemaParticle.WILDCARD: - returnParticleType.append("WILDCARD\n"); - break; - default: - returnParticleType.append("Schema Particle Type Unknown"); - break; - } - - return returnParticleType.toString(); - } - - private ArrayList _typeStack = new ArrayList(); - - public boolean isGenerate_sample_data() { - return generate_sample_data; - } - - public void setGenerate_sample_data(boolean generate_sample_data) { - this.generate_sample_data = generate_sample_data; - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XBbasedXMLGenerator.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XBbasedXMLGenerator.java deleted file mode 100644 index 128d65cecd..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XBbasedXMLGenerator.java +++ /dev/null @@ -1,253 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -import java.io.ByteArrayInputStream; -import java.io.InputStream; -import java.util.ArrayList; -import java.util.Collection; -import java.util.Hashtable; -import java.util.Iterator; -import java.util.List; - -import javax.wsdl.Definition; -import javax.wsdl.WSDLException; -import javax.wsdl.extensions.schema.Schema; -import javax.wsdl.factory.WSDLFactory; -import javax.wsdl.xml.WSDLReader; -import javax.xml.namespace.QName; - -import org.apache.xmlbeans.SchemaGlobalElement; -import org.apache.xmlbeans.SchemaType; -import org.apache.xmlbeans.SchemaTypeSystem; -import org.apache.xmlbeans.XmlBeans; -import org.apache.xmlbeans.XmlException; -import org.apache.xmlbeans.XmlObject; -import org.apache.xmlbeans.XmlOptions; -import org.apache.xmlbeans.impl.xsd2inst.SchemaInstanceGenerator; -import org.xml.sax.InputSource; - -import com.ibm.wsdl.util.xml.DOM2Writer; - -public class XBbasedXMLGenerator extends SchemaInstanceGenerator implements XMLGenerator { - private XMLfromXSDConfiguration config = null; - - public static final String QNAME_SEPARATOR = "#"; - - public XBbasedXMLGenerator(XMLfromXSDConfiguration config) { - this.config = config; - // config.setXsdInputStream(getClass().getResource(conf).openStream()); - } - - public Hashtable<String, XmlObject> generateXmlAll() throws Exception { - Hashtable<String, XmlObject> xmlInstances = new Hashtable<String, XmlObject>(); - TuscanySampleXmlUtil xmlUtil = new TuscanySampleXmlUtil(); - xmlUtil.setGenerate_sample_data(config.isGenerateSampleData()); - SchemaTypeSystem sts = processXSDSources(); - SchemaType elementType = null; - for (SchemaGlobalElement globalElement : sts.globalElements()) { - elementType = getRootElementSchemaType(sts, globalElement.getName().getNamespaceURI(), globalElement.getName().getLocalPart()); - xmlInstances.put(makeQName(globalElement.getName()), XmlObject.Factory.parse(xmlUtil.createSampleForType(elementType))); - } - - return xmlInstances; - } - - public String generateXMLAsString() throws Exception { - SchemaTypeSystem sts = processXSDSources(); - SchemaType rootElementType = getRootElementSchemaType(sts, config.getSchemaTypeNamespaceURI(), config.getSchemaTypeName()); - String result = ""; - if (rootElementType != null) { - TuscanySampleXmlUtil xmlUtil = new TuscanySampleXmlUtil(); - xmlUtil.setGenerate_sample_data(config.isGenerateSampleData()); - result = xmlUtil.createSampleForType(rootElementType); - } else { - System.out.println("Could not find a global element with name \"" + config.getRootElementLocalName() + "\""); - } - return result; - } - - public void generateXMLIntoOutputStream() throws Exception { - config.getXmlOutputStream().write(generateXMLAsString().getBytes()); - } - - public void generateXML() throws Exception { - SchemaTypeSystem sts = processXSDSources(); - - SchemaType rootElementType = getRootElementSchemaType(sts, config.getSchemaTypeNamespaceURI(), config.getSchemaTypeName()); - - if (rootElementType != null) { - TuscanySampleXmlUtil xmlUtil = new TuscanySampleXmlUtil(); - xmlUtil.setGenerate_sample_data(config.isGenerateSampleData()); - String result = xmlUtil.createSampleForType(rootElementType); - config.getXmlOutputStream().write(result.getBytes()); - // System.out.println(result); - } else { - System.out.println("Could not find a global element with name \"" + config.getRootElementLocalName() + "\""); - } - } - - protected SchemaType getRootElementSchemaType(SchemaTypeSystem sts, String schemaNamespace, String schemaTypeName) { - SchemaType schemaType = null; - - if (sts == null) { - System.out.println("No Schemas to process."); - } else { - // first check in the global types - SchemaType[] globalTypes = sts.globalTypes(); - for (int i = 0; i < globalTypes.length; i++) { - if (schemaNamespace.equals(globalTypes[i].getName().getNamespaceURI()) - && schemaTypeName.equals(globalTypes[i].getName().getLocalPart())) { - schemaType = globalTypes[i]; - break; - } - } - - // next check for anonymous types defined inline within elements - if (schemaType == null) { - SchemaType[] globalElems = sts.documentTypes(); - for (int i = 0; i < globalElems.length; i++) { - if (schemaNamespace.equals(globalElems[i].getDocumentElementName().getNamespaceURI()) - && schemaTypeName.equals(globalElems[i].getDocumentElementName().getLocalPart())) { - schemaType = globalElems[i]; - break; - } - } - } - } - return schemaType; - } - - public void generateXML(XMLfromXSDConfiguration config) throws Exception { - this.config = config; - generateXML(); - } - - public XMLfromXSDConfiguration getConfig() { - return config; - } - - public void setConfig(XMLfromXSDConfiguration config) { - this.config = config; - } - - private Definition readInTheWSDLFile(InputStream wsdlStream) throws WSDLException { - WSDLReader reader = WSDLFactory.newInstance().newWSDLReader(); - reader.setFeature("javax.wsdl.importDocuments", true); - - /* - * File file = new File(uri); String baseURI; - * - * if (uri.startsWith("http://")){ baseURI = uri; } else{ if(file.getParentFile() == null){ try { baseURI = new - * File(".").getCanonicalFile().toURI().toString(); } catch (IOException e) { throw new RuntimeException(e); } } else { baseURI = - * file.getParentFile().toURI().toString(); } } - */ - // Document doc; - InputSource inputSource; - try { - - // doc = XMLUtils.newDocument(wsdlStream); - inputSource = new InputSource(wsdlStream); - /* - * } catch (ParserConfigurationException e) { throw new WSDLException(WSDLException.PARSER_ERROR, "Parser Configuration Error", e); } - * catch (SAXException e) { throw new WSDLException(WSDLException.PARSER_ERROR, "Parser SAX Error", e); - */ - } catch (Exception e) { - throw new WSDLException(WSDLException.INVALID_WSDL, "IO Error", e); - } - - // return reader.readWSDL(config.getRootElementNamespaceURI(), doc); - return reader.readWSDL(config.getRootElementNamespaceURI(), inputSource); - } - - protected InputStream[] getXSDsFromWSDL(InputStream xsdInputStream) throws Exception { - Definition defn = readInTheWSDLFile(xsdInputStream); - List list = defn.getTypes().getExtensibilityElements(); - - InputStream[] xsdFragments = new InputStream[list.size()]; - - Iterator iterator = list.iterator(); - Schema schemaElement = null; - - for (int count = 0; count < list.size(); ++count) { - schemaElement = (Schema) iterator.next(); - // System.out.println(" *** - " + element.getElementType().getNamespaceURI()); - // System.out.println(" **** - " + element + " & " + element.getClass().getPackage().getName()); - // System.out.println(DOM2Writer.nodeToString(element.getElement())); - xsdFragments[count] = new ByteArrayInputStream(DOM2Writer.nodeToString(schemaElement.getElement()).getBytes()); - } - - return xsdFragments; - } - - protected SchemaTypeSystem processXSDSources() throws Exception { - SchemaTypeSystem sts = null; - if (config.getXsdFileName().endsWith(XSD_FILE)) { - sts = processXSDs(new InputStream[] { config.getXsdInputStream() }); - } else if (config.getXsdFileName().endsWith(WSDL_FILE)) { - sts = processXSDs(getXSDsFromWSDL(config.getXsdInputStream())); - } - return sts; - } - - protected SchemaTypeSystem processXSDs(InputStream[] inputStreams) { - List sdocs = new ArrayList(); - for (int i = 0; i < inputStreams.length; i++) { - try { - sdocs.add(XmlObject.Factory.parse(inputStreams[i], (new XmlOptions()).setLoadLineNumbers().setLoadMessageDigest())); - } catch (Exception e) { - System.err.println("Can not load schema file: " + inputStreams[i] + ": "); - e.printStackTrace(); - } - } - - XmlObject[] schemas = (XmlObject[]) sdocs.toArray(new XmlObject[sdocs.size()]); - - SchemaTypeSystem sts = null; - if (schemas.length > 0) { - Collection errors = new ArrayList(); - XmlOptions compileOptions = new XmlOptions(); - /* - * if (dl) compileOptions.setCompileDownloadUrls(); if (nopvr) compileOptions.setCompileNoPvrRule(); if (noupa) - * compileOptions.setCompileNoUpaRule(); - */ - try { - sts = XmlBeans.compileXsd(schemas, XmlBeans.getBuiltinTypeSystem(), compileOptions); - } catch (Exception e) { - if (errors.isEmpty() || !(e instanceof XmlException)) - e.printStackTrace(); - - System.out.println("Schema compilation errors: "); - for (Iterator i = errors.iterator(); i.hasNext();) - System.out.println(i.next()); - } - } - - return sts; - } - - private String makeQName(String nameSpace, String localName) { - return nameSpace + QNAME_SEPARATOR + localName; - } - - private String makeQName(QName qName) { - return qName.getNamespaceURI() + QNAME_SEPARATOR + qName.getLocalPart(); - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLGenerator.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLGenerator.java deleted file mode 100644 index 15848158e6..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLGenerator.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -import java.util.Hashtable; - -import org.apache.xmlbeans.XmlObject; - -/** - * This is the XMLGenerator Interface that will be implemented by various - * types of Generators (SDO based, XMLBeans based etc.) - * - */ -public interface XMLGenerator { - public static final int SDO_BASED = 1; - - public static final int XMLBEANS_BASED = 2; - - public static final String XSD_FILE = ".xsd"; - - public static final String WSDL_FILE = ".wsdl"; - - public void generateXML() throws Exception; - - public void generateXML(XMLfromXSDConfiguration config) throws Exception; - - public void generateXMLIntoOutputStream() throws Exception; - - public String generateXMLAsString() throws Exception; - - public Hashtable<String, XmlObject> generateXmlAll() throws Exception; - - public XMLfromXSDConfiguration getConfig(); - - public void setConfig(XMLfromXSDConfiguration config); -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLGeneratorFactory.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLGeneratorFactory.java deleted file mode 100644 index e4075557e8..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLGeneratorFactory.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -/** - * This is a factory for creating XML Generators. The types of XML Generators - * are enumerated in the XMLGenerator interface. - * - */ -public class XMLGeneratorFactory { - private static XMLGeneratorFactory factory = null; - - protected XMLGeneratorFactory() { - - } - - public static XMLGeneratorFactory getInstance() { - if (factory == null) { - factory = new XMLGeneratorFactory(); - } - return factory; - } - - public XMLGenerator createGenerator(int generatorType) { - XMLGenerator generator = null; - switch (generatorType) { - case XMLGenerator.SDO_BASED: { - // generator = new SDObasedXMLGenerator(new XMLfromXSDConfiguration()); - break; - } - case XMLGenerator.XMLBEANS_BASED: { - generator = new XBbasedXMLGenerator(new XMLfromXSDConfiguration()); - break; - } - } - - return generator; - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLfromXSDConfiguration.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLfromXSDConfiguration.java deleted file mode 100644 index 76f6b711bd..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLfromXSDConfiguration.java +++ /dev/null @@ -1,246 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -import java.io.File; -import java.io.FileInputStream; -import java.io.FileOutputStream; -import java.io.IOException; -import java.io.InputStream; -import java.io.OutputStream; -import java.net.URL; - -/** - * This class encapsulates the configuration settings for the "XML From XSD" generation. - * Presently it contains settings like the XSD to be use, the schematype for which and - * xml instance is to be created, the destination for the output etc. All of these - * settings are used by the 'generator' classes during the genation of the xml instance. - * - */ -public class XMLfromXSDConfiguration implements CmdLineArgsHandler { - private static int fileCount = 0; - - public static final String DEFAULT_XML_OUTPUT_FILENAME = "XML_FROM_XSD_" + (++fileCount) + ".xml"; - - public static final String XSD_FILE_URL_OPTION = "xsd"; - - public static final String XML_OUTPUT_LOCATION_OPTION = "o"; - - public static final String XML_OUTPUT_FILENAME_OPTION = "of"; - - public static final String ROOT_ELEMENT_NAMESPACE_URI_OPTION = "rns"; - - public static final String ROOT_ELEMENT_LOCALNAME_OPTION = "rn"; - - public static final String SCHEMA_TYPE_NAME = "st"; - - public static final String SCHEMA_TYPE_NAMESPACE_URI = "stn"; - - public static final String GENERATE_SAMPLE_DATA = "sd"; - - protected String xmlOutputLocation = null; - - protected File xmlOutputDirectory = null; - - protected String xsdFileName = null; - - protected String xmlFileName = null; - - protected InputStream xsdInputStream = null; - - protected OutputStream xmlOutputStream = null; - - protected String rootElementNamespaceURI = null; - - protected String rootElementLocalName = null; - - protected String schemaTypeName = null; - - protected String schemaTypeNamespaceURI = null; - - protected boolean generateSampleData = false; - - private void handleXSDInputFileOption(String xsdFileUrl) throws Exception { - xsdFileName = xsdFileUrl; - // xsdInputStream = new FileInputStream(new File(xsdFileName)); - URL resourceUrl = Thread.currentThread().getContextClassLoader().getResource(xsdFileName); - if (resourceUrl != null) { - xsdInputStream = resourceUrl.openStream(); - } else { - File inFile = new File(xsdFileName); - xsdFileName = inFile.getName(); - xsdInputStream = new FileInputStream(inFile); - } - } - - private void handleXMLOutputLocationOption(String outputLocation) throws Exception { - xmlOutputLocation = outputLocation; - xmlOutputDirectory = new File(xmlOutputLocation); - if (!xmlOutputDirectory.exists()) { - xmlOutputDirectory.mkdirs(); - } else if (!xmlOutputDirectory.isDirectory()) { - throw new IllegalArgumentException("The input location for the xml output " + outputLocation + "is not a folder"); - } - } - - private void handleOutputFilenameOption(String outputFileName) throws Exception { - xmlFileName = outputFileName; - - // first create a file in the given location - File outputFile = new File(xmlOutputDirectory, xmlFileName); - - try { - if (!outputFile.exists()) { - outputFile.createNewFile(); - } - xmlOutputStream = new FileOutputStream(outputFile); - } catch (IOException e) { - throw new Exception(e); - } - } - - public void handleArgument(String optionFlag, String argValue) throws IllegalArgumentException { - try { - if (XSD_FILE_URL_OPTION.equalsIgnoreCase(optionFlag)) { - handleXSDInputFileOption(argValue); - } else if (XML_OUTPUT_LOCATION_OPTION.equalsIgnoreCase(optionFlag)) { - handleXMLOutputLocationOption(argValue); - } else if (XML_OUTPUT_FILENAME_OPTION.equalsIgnoreCase(optionFlag)) { - handleOutputFilenameOption(argValue); - } else if (ROOT_ELEMENT_NAMESPACE_URI_OPTION.equalsIgnoreCase(optionFlag)) { - setRootElementNamespaceURI(argValue); - } else if (ROOT_ELEMENT_LOCALNAME_OPTION.equalsIgnoreCase(optionFlag)) { - setRootElementLocalName(argValue); - } else if (SCHEMA_TYPE_NAME.equalsIgnoreCase(optionFlag)) { - setSchemaTypeName(argValue); - } else if (SCHEMA_TYPE_NAMESPACE_URI.equalsIgnoreCase(optionFlag)) { - setSchemaTypeNamespaceURI(argValue); - } else if (GENERATE_SAMPLE_DATA.equalsIgnoreCase(optionFlag)) { - setGenerateSampleData(true); - } - } catch (Exception e) { - throw new IllegalArgumentException("Exception due to - " + e); - } - } - - public String getRootElementLocalName() { - if (rootElementLocalName == null) { - rootElementLocalName = schemaTypeName.toLowerCase(); - } - return rootElementLocalName; - } - - public void setRootElementLocalName(String rootElementLocalName) { - this.rootElementLocalName = rootElementLocalName; - } - - public String getRootElementNamespaceURI() { - if (rootElementNamespaceURI == null) { - rootElementNamespaceURI = schemaTypeNamespaceURI; - } - return rootElementNamespaceURI; - } - - public void setRootElementNamespaceURI(String rootElementNamespaceURI) { - this.rootElementNamespaceURI = rootElementNamespaceURI; - } - - public String getXmlFileName() { - if (xmlFileName == null) { - xmlFileName = getXsdFileName() + ".xml"; - } - return xmlFileName; - } - - public void setXmlFileName(String xmlFileName) { - this.xmlFileName = xmlFileName; - } - - public File getXmlOutputLocation() { - return xmlOutputDirectory; - } - - public void setXmlOutputLocation(File xmlOutputLocation) { - this.xmlOutputDirectory = xmlOutputLocation; - } - - public OutputStream getXmlOutputStream() throws Exception { - if (xmlOutputStream == null) { - if (xmlOutputDirectory == null) { - handleXMLOutputLocationOption(System.getProperty("user.dir")); - } - handleOutputFilenameOption(getXmlFileName()); - } - return xmlOutputStream; - } - - public void setXmlOutputStream(OutputStream xmlOutputStream) { - this.xmlOutputStream = xmlOutputStream; - } - - public String getXsdFileName() { - return xsdFileName; - } - - public void setXsdFileName(String xsdFileName) throws Exception { - this.xsdFileName = xsdFileName; - handleXSDInputFileOption(xsdFileName); - } - - public InputStream getXsdInputStream() throws Exception { - if (xsdInputStream == null) { - throw new IllegalArgumentException("XSD Input Source not set....!"); - } - return xsdInputStream; - } - - public void setXsdInputStream(InputStream xsdInputStream) { - this.xsdInputStream = xsdInputStream; - } - - public String getSchemaTypeName() { - return schemaTypeName; - } - - public void setSchemaTypeName(String schemaTypeName) { - this.schemaTypeName = schemaTypeName; - } - - public String getSchemaTypeNamespaceURI() { - return schemaTypeNamespaceURI; - } - - public void setSchemaTypeNamespaceURI(String schemaTypeNamespaceURI) { - this.schemaTypeNamespaceURI = schemaTypeNamespaceURI; - } - - public void setXmlOutputLocation(String xmlOutputLocation) throws Exception { - this.xmlOutputLocation = xmlOutputLocation; - handleXMLOutputLocationOption(xmlOutputLocation); - } - - public boolean isGenerateSampleData() { - return generateSampleData; - } - - public void setGenerateSampleData(boolean generateSampleData) { - this.generateSampleData = generateSampleData; - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLfromXSDGenerator.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLfromXSDGenerator.java deleted file mode 100644 index 357d4203fe..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XMLfromXSDGenerator.java +++ /dev/null @@ -1,82 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -/** - * This class provides a command line tooling functinality for creating an XML - * instance from an input XSD. - */ -public class XMLfromXSDGenerator { - public static int generatorType = XMLGenerator.XMLBEANS_BASED; - - /** - * @param args - */ - public static void main(String[] args) { - try { - new XMLfromXSDGenerator().generateXMLInstance(args); - } catch (Exception e) { - e.printStackTrace(); - System.out.println(getPrintUsageMessage()); - } - } - - public void generateXMLInstance(String args[]) throws Exception { - // create a configuration object to hold settings for this generation - XMLfromXSDConfiguration config = new XMLfromXSDConfiguration(); - - // create an argument processor to process the input arguments - CmdLineArgsProcessor argsProcessor = new CmdLineArgsProcessor(); - - // configure the args processor with the 'config' object that must be populated - // with values from the proecessed input arguments - argsProcessor.setArgsHandler(config); - - // set the usage message to be output by the args processor if input arguments are not proper - argsProcessor.setPrintUsageMessage(getPrintUsageMessage()); - - // start processing the arguments - argsProcessor.processArgs(args); - - // now that the configuration settings are populated from the input arguments - // instantiate the xmlfromsdogenerator with this config object - - XMLGenerator generator = new XMLGeneratorFactory().createGenerator(generatorType); - // XBbasedXMLGenerator generator = new XBbasedXMLGenerator(config); - - // generate the xml instance - generator.generateXML(config); - } - - protected static String getPrintUsageMessage() { - StringBuffer strBuffer = new StringBuffer(); - strBuffer.append("Usage arguments:\n"); - strBuffer.append(" [ -rns <root element namespace URI> ]\n"); - strBuffer.append(" [ -rn <root element name> ]\n"); - strBuffer.append(" [ -xsd <xsd file> ]\n"); - strBuffer.append(" [ -of <output xml filename> ]\n"); - strBuffer.append(" [ -o <output location> ]\n"); - strBuffer.append(" [ -st <name of the schema type to be instantiated as xml> ]\n"); - strBuffer.append(" [ -stn <namespace URI of the schema type> ]\n"); - strBuffer.append(" [ -sd (provide this flag if sample data is to be generated)\n"); - - return strBuffer.toString(); - } - -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceCreationException.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceCreationException.java deleted file mode 100644 index 140d3efdb4..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceCreationException.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -/** - * The Exception wrapper class for encasulating exceptions that occur during xml instance creation - * - */ -public class XmlInstanceCreationException extends Exception { - - public XmlInstanceCreationException(String message) { - super(message); - } - - public XmlInstanceCreationException(Exception e) { - super(e); - } -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceRegistry.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceRegistry.java deleted file mode 100644 index 15f0fcfb73..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceRegistry.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -import java.util.Map; - -import org.apache.xmlbeans.XmlObject; - -/** - * Interface for system registry of xml instances - * - */ -public interface XmlInstanceRegistry { - public Map<String, XmlObject> getXmlInstance(String wsdlPath) throws XmlInstanceCreationException; -} diff --git a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceRegistryImpl.java b/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceRegistryImpl.java deleted file mode 100644 index 73b7232eae..0000000000 --- a/branches/sca-java-M2/sca/services/containers/container.javascript/src/main/java/org/apache/tuscany/container/javascript/utils/xmlfromxsd/XmlInstanceRegistryImpl.java +++ /dev/null @@ -1,68 +0,0 @@ -/* - * 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.javascript.utils.xmlfromxsd; - -import java.util.Hashtable; -import java.util.Map; - -import org.apache.xmlbeans.XmlObject; -import org.osoa.sca.annotations.Init; -import org.osoa.sca.annotations.Scope; - -/** - * An implementation for the XMLInstnaceRegistry - * - */ -@Scope("MODULE") -public class XmlInstanceRegistryImpl implements XmlInstanceRegistry { - - private Hashtable<String, Map<String, XmlObject>> wsdlXmlInstances; - - private XMLGenerator xmlGenerator; - - public XmlInstanceRegistryImpl() { - wsdlXmlInstances = new Hashtable<String, Map<String, XmlObject>>(); - - XMLfromXSDConfiguration generationConfig = new XMLfromXSDConfiguration(); - xmlGenerator = XMLGeneratorFactory.getInstance().createGenerator(XMLGenerator.XMLBEANS_BASED); - xmlGenerator.setConfig(generationConfig); - } - - @Init(eager = true) - public void init() { - } - - /* (non-Javadoc) - * @see org.apache.tuscany.container.javascript.XmlInstanceRegistry#getXmlInstance(java.lang.String, java.lang.String, java.lang.String) - */ - public Map<String, XmlObject> getXmlInstance(String wsdlPath) throws XmlInstanceCreationException { - Map<String, XmlObject> xmlInstanceMap = null; - if ((xmlInstanceMap = wsdlXmlInstances.get(wsdlPath)) == null) { - try { - xmlGenerator.getConfig().setXsdFileName(wsdlPath); - xmlInstanceMap = xmlGenerator.generateXmlAll(); - wsdlXmlInstances.put(wsdlPath, xmlInstanceMap); - } catch (Exception e) { - throw new XmlInstanceCreationException(e); - } - } - return xmlInstanceMap; - } - -} |