package com.sun.xml.internal.ws.wsdl.parser;
import com.sun.xml.internal.ws.api.addressing.AddressingVersion;
import com.sun.xml.internal.ws.api.model.wsdl.WSDLFeaturedObject;
import static com.sun.xml.internal.ws.api.model.wsdl.WSDLBoundOperation.ANONYMOUS;
import com.sun.xml.internal.ws.api.model.wsdl.editable.*;
import com.sun.xml.internal.ws.api.wsdl.parser.WSDLParserExtension;
import com.sun.xml.internal.ws.api.wsdl.parser.WSDLParserExtensionContext;
import com.sun.xml.internal.ws.streaming.XMLStreamReaderUtil;
import javax.xml.namespace.QName;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamReader;
import javax.xml.ws.WebServiceException;
import javax.xml.ws.soap.AddressingFeature;
public class W3CAddressingWSDLParserExtension extends WSDLParserExtension {
@Override
public boolean bindingElements(EditableWSDLBoundPortType binding, XMLStreamReader reader) {
return addressibleElement(reader, binding);
}
@Override
public boolean portElements(EditableWSDLPort port, XMLStreamReader reader) {
return addressibleElement(reader, port);
}
private boolean addressibleElement(XMLStreamReader reader, WSDLFeaturedObject binding) {
QName ua = reader.getName();
if (ua.equals(AddressingVersion.W3C.wsdlExtensionTag)) {
String required = reader.getAttributeValue(WSDLConstants.NS_WSDL, "required");
binding.addFeature(new AddressingFeature(true, Boolean.parseBoolean(required)));
XMLStreamReaderUtil.skipElement(reader);
return true;
}
return false;
}
@Override
public boolean bindingOperationElements(EditableWSDLBoundOperation operation, XMLStreamReader reader) {
EditableWSDLBoundOperation edit = (EditableWSDLBoundOperation) operation;
QName anon = reader.getName();
if (anon.equals(AddressingVersion.W3C.wsdlAnonymousTag)) {
try {
String value = reader.getElementText();
if (value == null || value.trim().equals("")) {
throw new WebServiceException("Null values not permitted in wsaw:Anonymous.");
} else if (value.equals("optional")) {
edit.setAnonymous(ANONYMOUS.optional);
} else if (value.equals("required")) {
edit.setAnonymous(ANONYMOUS.required);
} else if (value.equals("prohibited")) {
edit.setAnonymous(ANONYMOUS.prohibited);
} else {
throw new WebServiceException("wsaw:Anonymous value \"" + value + "\" not understood.");
}
} catch (XMLStreamException e) {
throw new WebServiceException(e);
}
return true;
}
return false;
}
public void portTypeOperationInputAttributes(EditableWSDLInput input, XMLStreamReader reader) {
String action = ParserUtil.getAttribute(reader, getWsdlActionTag());
if (action != null) {
input.setAction(action);
input.setDefaultAction(false);
}
}
public void portTypeOperationOutputAttributes(EditableWSDLOutput output, XMLStreamReader reader) {
String action = ParserUtil.getAttribute(reader, getWsdlActionTag());
if (action != null) {
output.setAction(action);
output.setDefaultAction(false);
}
}
public void portTypeOperationFaultAttributes(EditableWSDLFault fault, XMLStreamReader reader) {
String action = ParserUtil.getAttribute(reader, getWsdlActionTag());
if (action != null) {
fault.setAction(action);
fault.setDefaultAction(false);
}
}
@Override
public void finished(WSDLParserExtensionContext context) {
EditableWSDLModel model = context.getWSDLModel();
for (EditableWSDLService service : model.getServices().values()) {
for (EditableWSDLPort port : service.getPorts()) {
EditableWSDLBoundPortType binding = port.getBinding();
populateActions(binding);
patchAnonymousDefault(binding);
}
}
}
protected String getNamespaceURI() {
return AddressingVersion.W3C.wsdlNsUri;
}
protected QName getWsdlActionTag() {
return AddressingVersion.W3C.wsdlActionTag;
}
private void populateActions(EditableWSDLBoundPortType binding) {
EditableWSDLPortType porttype = binding.getPortType();
for (EditableWSDLOperation o : porttype.getOperations()) {
EditableWSDLBoundOperation wboi = binding.get(o.getName());
if (wboi == null) {
o.getInput().setAction(defaultInputAction(o));
continue;
}
String soapAction = wboi.getSOAPAction();
if (o.getInput().getAction() == null || o.getInput().getAction().equals("")) {
if (soapAction != null && !soapAction.equals("")) {
o.getInput().setAction(soapAction);
} else {
o.getInput().setAction(defaultInputAction(o));
}
}
if (o.getOutput() == null)
continue;
if (o.getOutput().getAction() == null || o.getOutput().getAction().equals("")) {
o.getOutput().setAction(defaultOutputAction(o));
}
if (o.getFaults() == null || !o.getFaults().iterator().hasNext())
continue;
for (EditableWSDLFault f : o.getFaults()) {
if (f.getAction() == null || f.getAction().equals("")) {
f.setAction(defaultFaultAction(f.getName(), o));
}
}
}
}
protected void patchAnonymousDefault(EditableWSDLBoundPortType binding) {
for (EditableWSDLBoundOperation wbo : binding.getBindingOperations()) {
if (wbo.getAnonymous() == null)
wbo.setAnonymous(ANONYMOUS.optional);
}
}
private String defaultInputAction(EditableWSDLOperation o) {
return buildAction(o.getInput().getName(), o, false);
}
private String defaultOutputAction(EditableWSDLOperation o) {
return buildAction(o.getOutput().getName(), o, false);
}
private String defaultFaultAction(String name, EditableWSDLOperation o) {
return buildAction(name, o, true);
}
protected static final String buildAction(String name, EditableWSDLOperation o, boolean isFault) {
String tns = o.getName().getNamespaceURI();
String delim = SLASH_DELIMITER;
if (!tns.startsWith("http"))
delim = COLON_DELIMITER;
if (tns.endsWith(delim))
tns = tns.substring(0, tns.length()-1);
if (o.getPortTypeName() == null)
throw new WebServiceException("\"" + o.getName() + "\" operation's owning portType name is null.");
return tns +
delim +
o.getPortTypeName().getLocalPart() +
delim +
(isFault ? o.getName().getLocalPart() + delim + "Fault" + delim : "") +
name;
}
protected static final String COLON_DELIMITER = ":";
protected static final String SLASH_DELIMITER = "/";
}