Author: mriou
Date: Thu Sep 28 16:38:47 2006
New Revision: 451060
URL: http://svn.apache.org/viewvc?view=rev&rev=451060
Log:
Unfortunately some people like to have several documents imported in the same
namespace...
Modified:
incubator/ode/trunk/bpel-compiler/src/main/java/org/apache/ode/bpel/compiler/WSDLRegistry.java
Modified:
incubator/ode/trunk/bpel-compiler/src/main/java/org/apache/ode/bpel/compiler/WSDLRegistry.java
URL:
http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-compiler/src/main/java/org/apache/ode/bpel/compiler/WSDLRegistry.java?view=diff&rev=451060&r1=451059&r2=451060
==============================================================================
---
incubator/ode/trunk/bpel-compiler/src/main/java/org/apache/ode/bpel/compiler/WSDLRegistry.java
(original)
+++
incubator/ode/trunk/bpel-compiler/src/main/java/org/apache/ode/bpel/compiler/WSDLRegistry.java
Thu Sep 28 16:38:47 2006
@@ -44,238 +44,236 @@
* A parsed collection of WSDL definitions, including BPEL-specific extensions.
*/
class WSDLRegistry {
- private static final Log __log = LogFactory.getLog(WSDLRegistry.class);
+ private static final Log __log = LogFactory.getLog(WSDLRegistry.class);
- private static final CommonCompilationMessages __cmsgs =
- MessageBundle.getMessages(CommonCompilationMessages.class);
+ private static final CommonCompilationMessages __cmsgs =
+ MessageBundle.getMessages(CommonCompilationMessages.class);
- private final HashSet<String> _loadedDefinitions = new HashSet<String>();
+ private final HashMap<String, ArrayList<Definition4BPEL>> _definitions =
new HashMap<String, ArrayList<Definition4BPEL>>();
- private final HashMap<String, Definition4BPEL> _definitions = new
HashMap<String, Definition4BPEL>();
-
- private final Map<URI, byte[]> _schemas = new HashMap<URI,byte[]>();
-
- private SchemaModel _model;
-
- private XMLEntityResolver _resolver;
- private CompilerContext _ctx;
-
-
- WSDLRegistry(WsdlFinder finder, CompilerContext cc) {
- // bogus schema to force schema creation
- _schemas.put(URI.create("http://fivesight.com/bogus/namespace";),
- ("<xsd:schema xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\"";
- + " targetNamespace=\"http://fivesight.com/bogus/namespace\";>"
- + "<xsd:simpleType name=\"__bogusType__\">"
- + "<xsd:restriction base=\"xsd:normalizedString\"/>"
- + "</xsd:simpleType>" + "</xsd:schema>").getBytes());
- if (finder != null)
- _resolver = new WsdlFinderXMLEntityResolver(finder);
-
- _ctx = cc;
- }
-
-
- /**
- * Obtains an WSDL definition based on its target namespace.
- *
- * @param targetNamespace
- *
- * @return WSDL definition or <code>null</code> if unavailable.
- */
- public Definition4BPEL getDefinition(String targetNamespace) {
- return _definitions.get(targetNamespace);
- }
-
- public Definition4BPEL[] getDefinitions(){
- return _definitions.values().toArray(new
Definition4BPEL[_definitions.size()]);
- }
-
-
- /**
- * Get the schema model (XML Schema).
- *
- * @return schema model
- */
- public SchemaModel getSchemaModel() {
- if (_model == null) {
- _model = SchemaModelImpl.newModel(_schemas);
- }
-
- assert _model != null;
-
- return _model;
- }
-
- /**
- * Adds a WSDL definition for use in resolving MessageType, PortType,
- * Operation and BPEL properties and property aliases
- *
- * @param def WSDL definition
- *
- * @throws WSDLException
- */
- @SuppressWarnings("unchecked")
- public void addDefinition(Definition4BPEL def) throws CompilationException {
- if (def == null)
- throw new NullPointerException("def=null");
-
- if (__log.isDebugEnabled()) {
- __log.debug("addDefinition(" + def.getTargetNamespace() + " from " +
def.getDocumentBaseURI() + ")");
- }
-
- // Do not load the same definition twice.
- if (_loadedDefinitions.contains(def.getDocumentBaseURI())) {
- if (__log.isDebugEnabled()) {
- __log.debug("WSDL at " + def.getDocumentBaseURI() + " will not be
imported (duplicate import).");
- }
- return;
- }
-
- if (_definitions.containsKey(def.getTargetNamespace())) {
- // This indicates that we imported a WSDL with the same namespace from
- // two different locations. This is not an error, but should be a
warning.
- if (__log.isDebugEnabled()) {
- __log.debug("WSDL at " + def.getDocumentBaseURI() + " will not be
imported (duplicate import ).");
- }
- return;
- }
-
- _definitions.put(def.getTargetNamespace(), def);
- _loadedDefinitions.add(def.getDocumentBaseURI());
-
-
- captureSchemas(def);
-
- if (__log.isDebugEnabled())
- __log.debug("Processing <imports> in " + def.getDocumentBaseURI());
-
- for (List<Import> imports : ((Map<String,
List<Import>>)def.getImports()).values()) {
- HashSet<String> imported = new HashSet<String>();
-
- for (int i = 0; i < imports.size(); ++i) {
- Import im = imports.get(i);
-
- // If there are several imports in the same WSDL all importing the
same namespace
- // that is a sure sign of programmer error.
- if (imported.contains(im.getNamespaceURI())) {
- CompilationException ce =
- new
CompilationException(__cmsgs.errDuplicateWSDLImport(im.getNamespaceURI(),im.getLocationURI()).setSource(def.getDocumentBaseURI()));
- if (_ctx == null)
- throw ce;
- else
-
_ctx.recoveredFromError(def.getDocumentBaseURI(),ce);
-
- continue;
- }
-
- Definition4BPEL importDef = (Definition4BPEL) im.getDefinition();
-
- // The assumption here is that if the definition is not set on the
- // import object then there was some problem parsing the thing,
- // although it would have been nice to actually get the parse
- // error.
- if (importDef == null) {
- CompilationException ce = new CompilationException(
- __cmsgs.errWsdlImportNotFound(im.getNamespaceURI(),
- im.getLocationURI()).setSource(def.getDocumentBaseURI()));
- if (_ctx == null)
- throw ce;
- else
- _ctx.recoveredFromError(def.getDocumentBaseURI(),ce);
-
- continue;
- }
-
- imported.add(im.getNamespaceURI());
- addDefinition((Definition4BPEL) im.getDefinition());
- }
- }
- }
-
- @SuppressWarnings("unchecked")
- private void captureSchemas(Definition def) throws CompilationException {
- assert def != null;
-
- if (__log.isDebugEnabled())
- __log.debug("Processing XSD schemas in " + def.getDocumentBaseURI());
-
- Types types = def.getTypes();
-
- if (types != null) {
- for (Iterator<ExtensibilityElement> iter =
-
((List<ExtensibilityElement>)def.getTypes().getExtensibilityElements()).iterator();
- iter.hasNext();) {
- ExtensibilityElement ee = iter.next();
-
- if (ee instanceof XMLSchemaType) {
- String schema = ((XMLSchemaType)ee).getXMLSchema();
- Map<URI, byte[]> capture = null;
- URI docuri;
- try {
- docuri = new
URI(def.getDocumentBaseURI());
- } catch (URISyntaxException e) {
- // This is really quite
unexpected..
- __log.fatal("Internal Error:
WSDL Base URI is invalid.",e);
- throw new RuntimeException(e);
- }
-
- try {
- capture = XSUtils.captureSchema(docuri, schema, _resolver);
-
- // Add new schemas to our list.
- _schemas.putAll(capture);
-
- } catch (XsdException xsde) {
- __log.debug("captureSchemas: capture failed for " + docuri,xsde);
-
- LinkedList<XsdException> exceptions = new
LinkedList<XsdException>();
- while (xsde != null) {
- exceptions.addFirst(xsde);
- xsde = xsde.getPrevious();
+ private final Map<URI, byte[]> _schemas = new HashMap<URI,byte[]>();
+
+ private SchemaModel _model;
+
+ private XMLEntityResolver _resolver;
+ private CompilerContext _ctx;
+
+
+ WSDLRegistry(WsdlFinder finder, CompilerContext cc) {
+ // bogus schema to force schema creation
+ _schemas.put(URI.create("http://fivesight.com/bogus/namespace";),
+ ("<xsd:schema xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\"";
+ + "
targetNamespace=\"http://fivesight.com/bogus/namespace\";>"
+ + "<xsd:simpleType name=\"__bogusType__\">"
+ + "<xsd:restriction base=\"xsd:normalizedString\"/>"
+ + "</xsd:simpleType>" + "</xsd:schema>").getBytes());
+ if (finder != null)
+ _resolver = new WsdlFinderXMLEntityResolver(finder);
+
+ _ctx = cc;
+ }
+
+ public Definition4BPEL[] getDefinitions(){
+ ArrayList<Definition4BPEL> result = new ArrayList<Definition4BPEL>();
+ for (ArrayList<Definition4BPEL> definition4BPELs :
_definitions.values()) {
+ for (Definition4BPEL definition4BPEL : definition4BPELs) {
+ result.add(definition4BPEL);
+ }
+ }
+ return result.toArray(new Definition4BPEL[result.size()]);
+ }
+
+ /**
+ * Get the schema model (XML Schema).
+ *
+ * @return schema model
+ */
+ public SchemaModel getSchemaModel() {
+ if (_model == null) {
+ _model = SchemaModelImpl.newModel(_schemas);
+ }
+ assert _model != null;
+ return _model;
+ }
+
+ /**
+ * Adds a WSDL definition for use in resolving MessageType, PortType,
+ * Operation and BPEL properties and property aliases
+ *
+ * @param def WSDL definition
+ */
+ @SuppressWarnings("unchecked")
+ public void addDefinition(Definition4BPEL def) throws CompilationException
{
+ if (def == null)
+ throw new NullPointerException("def=null");
+
+ if (__log.isDebugEnabled()) {
+ __log.debug("addDefinition(" + def.getTargetNamespace() + " from "
+ def.getDocumentBaseURI() + ")");
+ }
+
+ if (_definitions.containsKey(def.getTargetNamespace())) {
+ // This indicates that we imported a WSDL with the same namespace
from
+ // two different locations. This is not an error, but should be a
warning.
+ if (__log.isInfoEnabled()) {
+ __log.info("WSDL at " + def.getDocumentBaseURI() + " is a
duplicate import, your documents " +
+ "should all be in different namespaces (its's not nice
but will still work).");
+ }
+ }
+
+ ArrayList<Definition4BPEL> defs = null;
+ if (_definitions.get(def.getTargetNamespace()) == null) defs = new
ArrayList<Definition4BPEL>();
+ else defs = _definitions.get(def.getTargetNamespace());
+
+ defs.add(def);
+ _definitions.put(def.getTargetNamespace(), defs);
+
+ captureSchemas(def);
+
+ if (__log.isDebugEnabled())
+ __log.debug("Processing <imports> in " + def.getDocumentBaseURI());
+
+ for (List<Import> imports : ((Map<String,
List<Import>>)def.getImports()).values()) {
+ HashSet<String> imported = new HashSet<String>();
+
+ for (Import im : imports) {
+ // If there are several imports in the same WSDL all importing
the same namespace
+ // that is a sure sign of programmer error.
+ if (imported.contains(im.getNamespaceURI())) {
+ if (__log.isInfoEnabled()) {
+ __log.info("WSDL at " + im.getLocationURI() + "
imports several documents in the same " +
+ "namespace (" + im.getNamespaceURI() + "),
your documents should all be in different " +
+ "namespaces (its's not nice but will still
work).");
+ }
+ }
+
+ Definition4BPEL importDef = (Definition4BPEL)
im.getDefinition();
+
+ // The assumption here is that if the definition is not set on
the
+ // import object then there was some problem parsing the thing,
+ // although it would have been nice to actually get the parse
+ // error.
+ if (importDef == null) {
+ CompilationException ce = new CompilationException(
+ __cmsgs.errWsdlImportNotFound(im.getNamespaceURI(),
+
im.getLocationURI()).setSource(def.getDocumentBaseURI()));
+ if (_ctx == null)
+ throw ce;
+ else
+ _ctx.recoveredFromError(def.getDocumentBaseURI(), ce);
+
+ continue;
+ }
+
+ imported.add(im.getNamespaceURI());
+ addDefinition((Definition4BPEL) im.getDefinition());
}
-
- for (XsdException ex : exceptions) {
- // TODO: the line number here is going to be wrong for the
in-line schema.
- String location = ex.getSystemId() + ":" + ex.getLineNumber();
- CompilationException ce = new CompilationException(
-
__cmsgs.errSchemaError(ex.getDetailMessage()).setSource(location));
- if (_ctx != null)
- _ctx.recoveredFromError(location,ce);
- else
- throw ce;
+ }
+ }
+
+ @SuppressWarnings("unchecked")
+ private void captureSchemas(Definition def) throws CompilationException {
+ assert def != null;
+
+ if (__log.isDebugEnabled())
+ __log.debug("Processing XSD schemas in " +
def.getDocumentBaseURI());
+
+ Types types = def.getTypes();
+
+ if (types != null) {
+ for (Iterator<ExtensibilityElement> iter =
+
((List<ExtensibilityElement>)def.getTypes().getExtensibilityElements()).iterator();
+ iter.hasNext();) {
+ ExtensibilityElement ee = iter.next();
+
+ if (ee instanceof XMLSchemaType) {
+ String schema = ((XMLSchemaType)ee).getXMLSchema();
+ Map<URI, byte[]> capture = null;
+ URI docuri;
+ try {
+ docuri = new URI(def.getDocumentBaseURI());
+ } catch (URISyntaxException e) {
+ // This is really quite unexpected..
+ __log.fatal("Internal Error: WSDL Base URI is
invalid.",e);
+ throw new RuntimeException(e);
+ }
+
+ try {
+ capture = XSUtils.captureSchema(docuri, schema,
_resolver);
+
+ // Add new schemas to our list.
+ _schemas.putAll(capture);
+
+ } catch (XsdException xsde) {
+ __log.debug("captureSchemas: capture failed for " +
docuri,xsde);
+
+ LinkedList<XsdException> exceptions = new
LinkedList<XsdException>();
+ while (xsde != null) {
+ exceptions.addFirst(xsde);
+ xsde = xsde.getPrevious();
+ }
+
+ for (XsdException ex : exceptions) {
+ // TODO: the line number here is going to be wrong
for the in-line schema.
+ String location = ex.getSystemId() + ":" +
ex.getLineNumber();
+ CompilationException ce = new CompilationException(
+
__cmsgs.errSchemaError(ex.getDetailMessage()).setSource(location));
+ if (_ctx != null)
+ _ctx.recoveredFromError(location,ce);
+ else
+ throw ce;
+ }
+ }
+ // invalidate model
+ _model = null;
+
+ }
}
- }
- // invalidate model
- _model = null;
-
- }
- }
- }
- }
-
- public Property getProperty(QName name) {
- Definition4BPEL declaringDef = getDefinition(name.getNamespaceURI());
- if (declaringDef == null) return null;
- return declaringDef.getProperty(name);
- }
-
- public PropertyAlias getPropertyAlias(QName propertyName, QName messageType)
{
- Definition4BPEL declaringDef =
getDefinition(propertyName.getNamespaceURI());
- if (declaringDef == null) return null;
- return declaringDef.getPropertyAlias(propertyName, messageType);
- }
-
- public PartnerLinkType getPartnerLinkType(QName partnerLinkType) {
- Definition4BPEL declaringDef =
getDefinition(partnerLinkType.getNamespaceURI());
- if (declaringDef == null) return null;
- return declaringDef.getPartnerLinkType(partnerLinkType);
- }
-
- public PortType getPortType(QName portType) {
- Definition4BPEL declaringDef = getDefinition(portType.getNamespaceURI());
- if (declaringDef == null) return null;
- return declaringDef.getPortType(portType);
- }
-
+ }
+ }
+
+ public Property getProperty(QName name) {
+ ArrayList<Definition4BPEL> defs =
_definitions.get(name.getNamespaceURI());
+ for (Definition4BPEL definition4BPEL : defs) {
+ if (definition4BPEL != null && definition4BPEL.getProperty(name)
!= null)
+ return definition4BPEL.getProperty(name);
+ }
+ return null;
+ }
+
+ public PropertyAlias getPropertyAlias(QName propertyName, QName
messageType) {
+ ArrayList<Definition4BPEL> defs =
_definitions.get(propertyName.getNamespaceURI());
+ for (Definition4BPEL definition4BPEL : defs) {
+ if (definition4BPEL != null &&
definition4BPEL.getPropertyAlias(propertyName, messageType) != null)
+ return definition4BPEL.getPropertyAlias(propertyName,
messageType);
+ }
+ return null;
+ }
+
+ public PartnerLinkType getPartnerLinkType(QName partnerLinkType) {
+ ArrayList<Definition4BPEL> defs =
_definitions.get(partnerLinkType.getNamespaceURI());
+ for (Definition4BPEL definition4BPEL : defs) {
+ if (definition4BPEL != null &&
definition4BPEL.getPartnerLinkType(partnerLinkType) != null)
+ return definition4BPEL.getPartnerLinkType(partnerLinkType);
+ }
+ return null;
+ }
+
+ public PortType getPortType(QName portType) {
+ ArrayList<Definition4BPEL> defs =
_definitions.get(portType.getNamespaceURI());
+ for (Definition4BPEL definition4BPEL : defs) {
+ if (definition4BPEL != null &&
definition4BPEL.getPortType(portType) != null)
+ return definition4BPEL.getPortType(portType);
+ }
+ return null;
+ }
+
+ public Message getMessage(QName msgType) {
+ ArrayList<Definition4BPEL> defs =
_definitions.get(msgType.getNamespaceURI());
+ for (Definition4BPEL definition4BPEL : defs) {
+ if (definition4BPEL != null && definition4BPEL.getMessage(msgType)
!= null)
+ return definition4BPEL.getMessage(msgType);
+ }
+ return null;
+ }
+
}
