| /* |
| * Copyright (c) 1997, 2013, Oracle and/or its affiliates. All rights reserved. |
| * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
| * |
| * This code is free software; you can redistribute it and/or modify it |
| * under the terms of the GNU General Public License version 2 only, as |
| * published by the Free Software Foundation. Oracle designates this |
| * particular file as subject to the "Classpath" exception as provided |
| * by Oracle in the LICENSE file that accompanied this code. |
| * |
| * This code is distributed in the hope that it will be useful, but WITHOUT |
| * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
| * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License |
| * version 2 for more details (a copy is included in the LICENSE file that |
| * accompanied this code). |
| * |
| * You should have received a copy of the GNU General Public License version |
| * 2 along with this work; if not, write to the Free Software Foundation, |
| * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. |
| * |
| * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
| * or visit www.oracle.com if you need additional information or have any |
| * questions. |
| */ |
| |
| package com.sun.xml.internal.ws.model.wsdl; |
| |
| import com.sun.istack.internal.NotNull; |
| import com.sun.xml.internal.ws.api.model.ParameterBinding; |
| import com.sun.xml.internal.ws.api.model.wsdl.WSDLMessage; |
| import com.sun.xml.internal.ws.api.model.wsdl.WSDLModel; |
| import com.sun.xml.internal.ws.api.model.wsdl.WSDLOperation; |
| import com.sun.xml.internal.ws.api.model.wsdl.WSDLPortType; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLBoundOperation; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLBoundPortType; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLMessage; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLModel; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLPart; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLPort; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLPortType; |
| import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLService; |
| import com.sun.xml.internal.ws.policy.PolicyMap; |
| |
| import javax.jws.WebParam.Mode; |
| import javax.xml.namespace.QName; |
| |
| import java.util.Collections; |
| import java.util.HashMap; |
| import java.util.LinkedHashMap; |
| import java.util.Map; |
| |
| /** |
| * Implementation of {@link WSDLModel} |
| * |
| * @author Vivek Pandey |
| */ |
| public final class WSDLModelImpl extends AbstractExtensibleImpl implements EditableWSDLModel { |
| private final Map<QName, EditableWSDLMessage> messages = new HashMap<QName, EditableWSDLMessage>(); |
| private final Map<QName, EditableWSDLPortType> portTypes = new HashMap<QName, EditableWSDLPortType>(); |
| private final Map<QName, EditableWSDLBoundPortType> bindings = new HashMap<QName, EditableWSDLBoundPortType>(); |
| private final Map<QName, EditableWSDLService> services = new LinkedHashMap<QName, EditableWSDLService>(); |
| |
| private PolicyMap policyMap; |
| private final Map<QName, EditableWSDLBoundPortType> unmBindings |
| = Collections.<QName, EditableWSDLBoundPortType>unmodifiableMap(bindings); |
| |
| |
| public WSDLModelImpl(@NotNull String systemId) { |
| super(systemId,-1); |
| } |
| |
| /** |
| * To create {@link WSDLModelImpl} from WSDL that doesn't have a system ID. |
| */ |
| public WSDLModelImpl() { |
| super(null,-1); |
| } |
| |
| public void addMessage(EditableWSDLMessage msg){ |
| messages.put(msg.getName(), msg); |
| } |
| |
| public EditableWSDLMessage getMessage(QName name){ |
| return messages.get(name); |
| } |
| |
| public void addPortType(EditableWSDLPortType pt){ |
| portTypes.put(pt.getName(), pt); |
| } |
| |
| public EditableWSDLPortType getPortType(QName name){ |
| return portTypes.get(name); |
| } |
| |
| public void addBinding(EditableWSDLBoundPortType boundPortType){ |
| assert !bindings.containsValue(boundPortType); |
| bindings.put(boundPortType.getName(), boundPortType); |
| } |
| |
| public EditableWSDLBoundPortType getBinding(QName name){ |
| return bindings.get(name); |
| } |
| |
| public void addService(EditableWSDLService svc){ |
| services.put(svc.getName(), svc); |
| } |
| |
| public EditableWSDLService getService(QName name){ |
| return services.get(name); |
| } |
| |
| public Map<QName, EditableWSDLMessage> getMessages() { |
| return messages; |
| } |
| |
| public @NotNull Map<QName, EditableWSDLPortType> getPortTypes() { |
| return portTypes; |
| } |
| |
| public @NotNull Map<QName, ? extends EditableWSDLBoundPortType> getBindings() { |
| return unmBindings; |
| } |
| |
| public @NotNull Map<QName, EditableWSDLService> getServices(){ |
| return services; |
| } |
| |
| /** |
| * Returns the first service QName from insertion order |
| */ |
| public QName getFirstServiceName(){ |
| if(services.isEmpty()) |
| return null; |
| return services.values().iterator().next().getName(); |
| } |
| |
| /** |
| * |
| * @param serviceName non-null service QName |
| * @param portName non-null port QName |
| * @return |
| * WSDLBoundOperation on success otherwise null. throws NPE if any of the parameters null |
| */ |
| public EditableWSDLBoundPortType getBinding(QName serviceName, QName portName){ |
| EditableWSDLService service = services.get(serviceName); |
| if(service != null){ |
| EditableWSDLPort port = service.get(portName); |
| if(port != null) |
| return port.getBinding(); |
| } |
| return null; |
| } |
| |
| public void finalizeRpcLitBinding(EditableWSDLBoundPortType boundPortType){ |
| assert(boundPortType != null); |
| QName portTypeName = boundPortType.getPortTypeName(); |
| if(portTypeName == null) |
| return; |
| WSDLPortType pt = portTypes.get(portTypeName); |
| if(pt == null) |
| return; |
| for (EditableWSDLBoundOperation bop : boundPortType.getBindingOperations()) { |
| WSDLOperation pto = pt.get(bop.getName().getLocalPart()); |
| WSDLMessage inMsgName = pto.getInput().getMessage(); |
| if(inMsgName == null) |
| continue; |
| EditableWSDLMessage inMsg = messages.get(inMsgName.getName()); |
| int bodyindex = 0; |
| if(inMsg != null){ |
| for(EditableWSDLPart part:inMsg.parts()){ |
| String name = part.getName(); |
| ParameterBinding pb = bop.getInputBinding(name); |
| if(pb.isBody()){ |
| part.setIndex(bodyindex++); |
| part.setBinding(pb); |
| bop.addPart(part, Mode.IN); |
| } |
| } |
| } |
| bodyindex=0; |
| if(pto.isOneWay()) |
| continue; |
| WSDLMessage outMsgName = pto.getOutput().getMessage(); |
| if(outMsgName == null) |
| continue; |
| EditableWSDLMessage outMsg = messages.get(outMsgName.getName()); |
| if(outMsg!= null){ |
| for(EditableWSDLPart part:outMsg.parts()){ |
| String name = part.getName(); |
| ParameterBinding pb = bop.getOutputBinding(name); |
| if(pb.isBody()){ |
| part.setIndex(bodyindex++); |
| part.setBinding(pb); |
| bop.addPart(part, Mode.OUT); |
| } |
| } |
| } |
| } |
| } |
| |
| /** |
| * Gives the PolicyMap associated with the WSDLModel |
| * |
| * @return PolicyMap |
| */ |
| public PolicyMap getPolicyMap() { |
| return policyMap; |
| } |
| |
| /** |
| * Set PolicyMap for the WSDLModel. |
| * @param policyMap |
| */ |
| public void setPolicyMap(PolicyMap policyMap) { |
| this.policyMap = policyMap; |
| } |
| |
| /** |
| * Invoked at the end of the model construction to fix up references, etc. |
| */ |
| public void freeze() { |
| for (EditableWSDLService service : services.values()) { |
| service.freeze(this); |
| } |
| for (EditableWSDLBoundPortType bp : bindings.values()) { |
| bp.freeze(); |
| } |
| // Enforce freeze all the portTypes referenced by this endpoints, see Bug8966673 for detail |
| for (EditableWSDLPortType pt : portTypes.values()) { |
| pt.freeze(); |
| } |
| } |
| } |
