| /* |
| * 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.netbeans.modules.maven.jaxws.nodes; |
| |
| import java.awt.Image; |
| import java.beans.PropertyVetoException; |
| import java.io.File; |
| import java.io.IOException; |
| import java.io.UnsupportedEncodingException; |
| import java.net.URLEncoder; |
| import java.util.ArrayList; |
| import java.util.Arrays; |
| import java.util.Collections; |
| import java.util.List; |
| import java.util.Map; |
| import java.util.Map.Entry; |
| import java.util.logging.Level; |
| import java.util.logging.Logger; |
| import javax.lang.model.element.AnnotationMirror; |
| import javax.lang.model.element.AnnotationValue; |
| import javax.lang.model.element.ExecutableElement; |
| import javax.lang.model.element.TypeElement; |
| import javax.swing.Action; |
| import javax.swing.JEditorPane; |
| import javax.swing.SwingUtilities; |
| import org.netbeans.api.java.source.CancellableTask; |
| import org.netbeans.api.java.source.CompilationController; |
| import org.netbeans.api.java.source.JavaSource; |
| import org.netbeans.api.java.source.JavaSource.Phase; |
| import org.netbeans.api.project.FileOwnerQuery; |
| import org.netbeans.api.project.Project; |
| import org.netbeans.modules.j2ee.deployment.common.api.ConfigurationException; |
| import org.netbeans.modules.j2ee.deployment.devmodules.api.Deployment; |
| import org.netbeans.modules.j2ee.deployment.devmodules.api.InstanceRemovedException; |
| import org.netbeans.modules.j2ee.deployment.devmodules.api.J2eeModule; |
| import org.netbeans.modules.j2ee.deployment.devmodules.api.ServerInstance; |
| import org.netbeans.modules.j2ee.deployment.devmodules.spi.J2eeModuleProvider; |
| import org.netbeans.modules.j2ee.deployment.plugins.api.InstanceProperties; |
| import org.netbeans.modules.javaee.specs.support.api.JaxWs; |
| import org.netbeans.modules.maven.jaxws.MavenModelUtils; |
| import org.netbeans.modules.maven.jaxws.ServerType; |
| import org.netbeans.modules.maven.jaxws.WSStackUtils; |
| import org.netbeans.modules.maven.jaxws.WSUtils; |
| import org.netbeans.modules.maven.jaxws._RetoucheUtil; |
| import org.netbeans.modules.maven.jaxws.actions.AddOperationAction; |
| import org.netbeans.modules.maven.jaxws.actions.WSEditAttributesAction; |
| import org.netbeans.modules.maven.jaxws.actions.WsTesterPageAction; |
| import org.netbeans.modules.maven.jaxws.wseditor.EditWSAttributesCookieImpl; |
| import org.netbeans.modules.maven.model.ModelOperation; |
| import org.netbeans.modules.maven.model.Utilities; |
| import org.netbeans.modules.maven.model.pom.POMModel; |
| import org.netbeans.modules.websvc.api.jaxws.project.config.Handler; |
| import org.netbeans.modules.websvc.api.jaxws.project.config.HandlerChain; |
| import org.netbeans.modules.websvc.api.jaxws.project.config.HandlerChains; |
| import org.netbeans.modules.websvc.api.jaxws.project.config.HandlerChainsProvider; |
| import org.netbeans.modules.websvc.api.support.ConfigureHandlerCookie; |
| import org.netbeans.modules.websvc.api.support.java.SourceUtils; |
| import org.netbeans.modules.websvc.jaxws.light.api.JAXWSLightSupport; |
| import org.netbeans.modules.websvc.jaxws.light.api.JaxWsService; |
| import org.netbeans.modules.websvc.spi.support.ConfigureHandlerAction; |
| import org.netbeans.modules.websvc.spi.support.MessageHandlerPanel; |
| import org.netbeans.modules.websvc.wsstack.api.WSStack; |
| import org.openide.DialogDescriptor; |
| import org.openide.DialogDisplayer; |
| import org.openide.NotifyDescriptor; |
| import org.openide.actions.DeleteAction; |
| import org.openide.actions.OpenAction; |
| import org.openide.actions.PropertiesAction; |
| import org.openide.cookies.EditorCookie; |
| import org.openide.cookies.OpenCookie; |
| import org.openide.filesystems.FileChangeAdapter; |
| import org.openide.filesystems.FileEvent; |
| import org.openide.filesystems.FileObject; |
| import org.openide.filesystems.FileUtil; |
| import org.openide.loaders.DataObject; |
| import org.openide.loaders.DataObjectNotFoundException; |
| import org.openide.nodes.AbstractNode; |
| import org.openide.util.HelpCtx; |
| import org.openide.util.ImageUtilities; |
| import org.openide.util.NbBundle; |
| import org.openide.util.actions.SystemAction; |
| import org.openide.util.lookup.AbstractLookup; |
| import org.openide.util.lookup.InstanceContent; |
| import org.openide.util.Lookup; |
| import org.openide.util.RequestProcessor; |
| import org.openide.util.lookup.Lookups; |
| |
| public class JaxWsNode extends AbstractNode implements ConfigureHandlerCookie { |
| |
| JaxWsService service; |
| FileObject srcRoot; |
| private FileObject implBeanClass; |
| InstanceContent content; |
| Project project; |
| |
| private static final Logger LOG = Logger.getLogger(JaxWsNode.class.getCanonicalName()); |
| |
| public JaxWsNode(JaxWsService service, FileObject srcRoot, FileObject implBeanClass) { |
| this(service, srcRoot, implBeanClass, new InstanceContent()); |
| } |
| |
| private JaxWsNode(JaxWsService service, FileObject srcRoot, FileObject implBeanClass, InstanceContent content) { |
| super(new JaxWsChildren(service, srcRoot, implBeanClass), new AbstractLookup(content)); |
| this.service = service; |
| this.srcRoot = srcRoot; |
| this.content = content; |
| this.implBeanClass = implBeanClass; |
| project = FileOwnerQuery.getOwner(srcRoot); |
| |
| if (service.isServiceProvider() && |
| implBeanClass.getAttribute("jax-ws-service") == null) |
| // isServiceProvider() means class is WS not a client |
| /*|| service.isServiceProvider() && |
| implBeanClass.getAttribute("jax-ws-service-provider") == null) // NOI18N*/ |
| { |
| try { |
| implBeanClass.setAttribute("jax-ws-service", Boolean.TRUE); |
| } |
| catch(IOException e ){ |
| LOG.log( Level.WARNING, null , e); |
| } |
| Runnable runnable = new Runnable() { |
| |
| @Override |
| public void run() { |
| try { |
| EditorCookie cookie = getDataObject().getCookie(EditorCookie.class); |
| JEditorPane[] panes = cookie.getOpenedPanes(); |
| getDataObject().setValid(false); |
| if ( panes != null && panes.length >0 ){ |
| getDataObject().getCookie(EditorCookie.class).open(); |
| } |
| } |
| catch (PropertyVetoException ex) { |
| LOG.log( Level.WARNING, null , ex); |
| } |
| } |
| }; |
| if ( SwingUtilities.isEventDispatchThread() ){ |
| runnable.run(); |
| } |
| else { |
| SwingUtilities.invokeLater( runnable ); |
| } |
| |
| } |
| |
| String serviceName = service.getServiceName(); |
| setName(serviceName); |
| content.add(this); |
| content.add(service); |
| content.add(implBeanClass); |
| OpenCookie cookie = new OpenCookie() { |
| |
| @Override |
| public void open() { |
| OpenCookie oc = getOpenCookie(); |
| if (oc != null) { |
| oc.open(); |
| } |
| } |
| }; |
| content.add(cookie); |
| setServiceUrl(); |
| content.add(new EditWSAttributesCookieImpl(this)); |
| attachFileChangeListener(); |
| |
| } |
| |
| private boolean isWebProject() { |
| J2eeModuleProvider provider = project.getLookup().lookup(J2eeModuleProvider.class); |
| if (provider != null) { |
| J2eeModule.Type moduleType = provider.getJ2eeModule().getType(); |
| if (J2eeModule.Type.WAR.equals(moduleType)) { |
| return true; |
| } |
| } |
| return false; |
| } |
| |
| @Override |
| public String getDisplayName() { |
| return service.getServiceName(); |
| } |
| |
| /*@Override |
| public String getShortDescription() { |
| return getWsdlURL(); |
| }*/ |
| |
| private static final String WAITING_BADGE = "org/netbeans/modules/maven/jaxws/resources/waiting.png"; // NOI18N |
| private static final String ERROR_BADGE = "org/netbeans/modules/maven/jaxws/resources/error-badge.gif"; //NOI18N |
| private static final String SERVICE_BADGE = "org/netbeans/modules/maven/jaxws/resources/XMLServiceDataIcon.png"; //NOI18N |
| private java.awt.Image cachedWaitingBadge; |
| private java.awt.Image cachedErrorBadge; |
| private java.awt.Image cachedServiceBadge; |
| |
| @Override |
| public java.awt.Image getIcon(int type) { |
| return getServiceImage(); |
| } |
| |
| private java.awt.Image getServiceImage() { |
| if (cachedServiceBadge == null) { |
| cachedServiceBadge = ImageUtilities.loadImage(SERVICE_BADGE); |
| } |
| return cachedServiceBadge; |
| } |
| |
| private java.awt.Image getErrorBadge() { |
| if (cachedErrorBadge == null) { |
| cachedErrorBadge = ImageUtilities.loadImage(ERROR_BADGE); |
| } |
| return cachedErrorBadge; |
| } |
| |
| private java.awt.Image getWaitingBadge() { |
| if (cachedWaitingBadge == null) { |
| cachedWaitingBadge = ImageUtilities.loadImage(WAITING_BADGE); |
| } |
| return cachedWaitingBadge; |
| } |
| |
| void changeIcon() { |
| fireIconChange(); |
| } |
| |
| @Override |
| public Image getOpenedIcon(int type) { |
| return getIcon(type); |
| } |
| |
| private DataObject getDataObject() { |
| FileObject f = getImplBean(); |
| if (f != null) { |
| try { |
| return DataObject.find(f); |
| } catch (DataObjectNotFoundException de) { |
| LOG.log( Level.INFO, null , de); |
| } |
| } |
| return null; |
| } |
| |
| private OpenCookie getOpenCookie() { |
| OpenCookie oc = null; |
| FileObject f = getImplBean(); |
| if (f != null) { |
| try { |
| DataObject d = DataObject.find(f); |
| oc = d.getCookie(OpenCookie.class); |
| } catch (DataObjectNotFoundException de) { |
| LOG.log( Level.INFO, null , de); |
| } |
| } |
| return oc; |
| } |
| |
| @Override |
| public Action getPreferredAction() { |
| return SystemAction.get(OpenAction.class); |
| } |
| |
| // Create the popup menu: |
| @Override |
| public Action[] getActions(boolean context) { |
| ArrayList<Action> actions = new ArrayList<Action>(Arrays.asList( |
| SystemAction.get(OpenAction.class), |
| // SystemAction.get(JaxWsRefreshAction.class), |
| // null, |
| SystemAction.get(AddOperationAction.class), |
| null, |
| SystemAction.get(WsTesterPageAction.class), |
| // null, |
| SystemAction.get(WSEditAttributesAction.class), |
| SystemAction.get(ConfigureHandlerAction.class), |
| // null, |
| // SystemAction.get(JaxWsGenWSDLAction.class), |
| // null, |
| // SystemAction.get(ConvertToRestAction.class), |
| null, |
| SystemAction.get(DeleteAction.class), |
| null, |
| SystemAction.get(PropertiesAction.class))); |
| addFromLayers(actions, "WebServices/Services/Actions"); |
| return actions.toArray(new Action[actions.size()]); |
| } |
| |
| private void addFromLayers(List<Action> actions, String path) { |
| Lookup look = Lookups.forPath(path); |
| for (Object next : look.lookupAll(Object.class)) { |
| if (next instanceof Action) { |
| actions.add((Action) next); |
| } else if (next instanceof javax.swing.JSeparator) { |
| actions.add(null); |
| } |
| } |
| } |
| |
| @Override |
| public HelpCtx getHelpCtx() { |
| return HelpCtx.DEFAULT_HELP; |
| } |
| |
| // Handle deleting: |
| @Override |
| public boolean canDestroy() { |
| return true; |
| } |
| |
| /** |
| * get URL for Web Service WSDL file |
| */ |
| private String getWebServiceURL() { |
| |
| ServerContextInfo serverContextInfo = getServerContextInfo(); |
| String contextRoot = serverContextInfo.getContextRoot(); |
| return "http://" + serverContextInfo.getHost() + ":" + serverContextInfo.getPort() + "/" + //NOI18N |
| getServiceUri(contextRoot); |
| } |
| |
| private String getNameFromPackageName(String packageName) { |
| int index = packageName.lastIndexOf("."); //NOI18N |
| return index >= 0 ? packageName.substring(index + 1) : packageName; |
| } |
| |
| public String getWsdlURL() { |
| String wsdlUrl = getWebServiceURL(); |
| return wsdlUrl.length() == 0 ? "" : wsdlUrl + "?wsdl"; //NOI18N |
| } |
| |
| /** |
| * get URL for Web Service Tester Page |
| */ |
| public String getTesterPageURL() { |
| |
| ServerContextInfo serverContextInfo = getServerContextInfo(); |
| ServiceInfo serviceInfo = getServiceInfo(); |
| WSStackUtils stackUtils = new WSStackUtils(project); |
| // boolean isJsr109Supported = stackUtils.isJsr109Supported(); |
| WSStack<JaxWs> jaxWsStack = stackUtils.getWsStack(JaxWs.class); |
| if (jaxWsStack != null) { |
| JaxWs.UriDescriptor uriDescriptor = jaxWsStack.get().getWsUriDescriptor(); |
| if (uriDescriptor != null) { |
| return uriDescriptor.getTesterPageUri(serverContextInfo.getHost(), serverContextInfo.getPort(), serverContextInfo.getContextRoot(), serviceInfo.getServiceName(), serviceInfo.getPortName(), serviceInfo.isEjb()); |
| } |
| } |
| return getWebServiceURL(); //NOI18N |
| } |
| |
| @Override |
| public void destroy() throws java.io.IOException { |
| |
| if (service.getLocalWsdl() != null) { |
| final String serviceId = service.getId(); |
| |
| // remove execution from pom file |
| ModelOperation<POMModel> oper = new ModelOperation<POMModel>() { |
| @Override |
| public void performOperation(POMModel model) { |
| MavenModelUtils.removeWsimportExecution(model, serviceId); |
| } |
| }; |
| FileObject pom = project.getProjectDirectory().getFileObject("pom.xml"); //NOI18N |
| Utilities.performPOMModelOperations(pom, Collections.singletonList(oper)); |
| |
| // remove stale file |
| try { |
| removeStaleFile(serviceId); |
| } catch (IOException ex) { |
| Logger.getLogger(JaxWsClientNode.class.getName()).log( |
| Level.FINE, "Cannot remove stale file", ex); //NOI18N |
| } |
| //remove wsdl file |
| FileObject wsdlFileObject = getLocalWsdl(); |
| JAXWSLightSupport jaxWsSupport = JAXWSLightSupport.getJAXWSLightSupport(implBeanClass); |
| if (wsdlFileObject != null && jaxWsSupport != null) { |
| // check if there are other clients/services with the same wsdl |
| boolean hasOtherServices = false; |
| List<JaxWsService> services = jaxWsSupport.getServices(); |
| for (JaxWsService s : services) { |
| if (serviceId != null && !serviceId.equals(s.getId()) && service.getLocalWsdl().equals(s.getLocalWsdl())) { |
| hasOtherServices = true; |
| break; |
| } |
| } |
| if (!hasOtherServices) { |
| // remove wsdl file |
| wsdlFileObject.delete(); |
| } |
| } |
| } |
| |
| WSUtils.removeImplClass(project, service.getImplementationClass()); |
| } |
| |
| private FileObject getImplBean() { |
| String implBean = service.getImplementationClass(); |
| if (implBean != null) { |
| return srcRoot.getFileObject(implBean.replace('.', '/') + ".java"); |
| } |
| return null; |
| } |
| |
| private FileObject getLocalWsdl() { |
| JAXWSLightSupport jaxWsSupport = JAXWSLightSupport.getJAXWSLightSupport(implBeanClass); |
| if (jaxWsSupport != null) { |
| FileObject localWsdlocalFolder = jaxWsSupport.getWsdlFolder(false); |
| if (localWsdlocalFolder!=null) { |
| String relativePath = service.getLocalWsdl(); |
| if (relativePath != null) { |
| return localWsdlocalFolder.getFileObject(relativePath); |
| } |
| } |
| } |
| return null; |
| } |
| |
| private JavaSource getImplBeanJavaSource() { |
| FileObject implBean = getImplBean(); |
| if (implBean != null) { |
| return JavaSource.forFileObject(implBean); |
| } |
| return null; |
| } |
| |
| @Override |
| public boolean canCopy() { |
| return true; |
| } |
| |
| @Override |
| public boolean canCut() { |
| return true; |
| } |
| |
| /** Old way to obtain port number from server instance (using instance properties) |
| * |
| * @param instanceProperties |
| * @return port number |
| */ |
| private String getPortNumber(InstanceProperties instanceProperties) { |
| String portNumber = instanceProperties.getProperty(InstanceProperties.HTTP_PORT_NUMBER); |
| if (portNumber == null || portNumber.equals("")) { //NOI18N |
| return "8080"; //NOI18N |
| } else { |
| return portNumber; |
| } |
| } |
| |
| /** Old way to obtain host name from server instance (using instance properties) |
| * |
| * @param instanceProperties |
| * @return host name |
| */ |
| private String getHostName(InstanceProperties instanceProperties) { |
| String serverUrl = instanceProperties.getProperty(InstanceProperties.URL_ATTR); |
| String hostName = "localhost"; //NOI18N |
| if (serverUrl != null && serverUrl.indexOf("::") > 0) { //NOI18N |
| //NOI18N |
| int index1 = serverUrl.indexOf("::"); //NOI18N |
| int index2 = serverUrl.lastIndexOf(":"); //NOI18N |
| if (index2 > index1 + 2) { |
| hostName = serverUrl.substring(index1 + 2, index2); |
| } |
| } |
| return hostName; |
| } |
| |
| void setServiceUrl() { |
| new RequestProcessor(JaxWsNode.class).post(new Runnable() { |
| |
| @Override |
| public void run() { |
| JaxWsNode.this.setValue("wsdl-url", getWsdlURL()); // NOI18N |
| fireShortDescriptionChange(); |
| } |
| }); |
| } |
| |
| protected void fireShortDescriptionChange() { |
| setShortDescription(getWsdlURL()); |
| } |
| |
| private void attachFileChangeListener() { |
| implBeanClass.addFileChangeListener(new FileChangeAdapter() { |
| |
| @Override |
| public void fileChanged(final FileEvent fe) { |
| SwingUtilities.invokeLater(new Runnable() { |
| @Override |
| public void run() { |
| String oldServiceName = service.getServiceName(); |
| final String[] newServiceName = new String[1]; |
| JavaSource javaSource = JavaSource.forFileObject(fe.getFile()); |
| if (javaSource!=null) { |
| |
| CancellableTask<CompilationController> task = |
| new CancellableTask<CompilationController>() |
| { |
| @Override |
| public void run(CompilationController controller) |
| throws IOException |
| { |
| controller.toPhase(Phase.ELEMENTS_RESOLVED); |
| TypeElement typeElement = SourceUtils. |
| getPublicTopLevelElement(controller); |
| if (typeElement!=null) { |
| // check service name |
| newServiceName[0] = getServiceName( |
| controller, typeElement); |
| } |
| } |
| @Override |
| public void cancel() {} |
| }; |
| |
| try { |
| javaSource.runUserActionTask(task, true); |
| } catch (IOException ex) { |
| LOG.log( Level.WARNING, null , ex); |
| } |
| |
| if (newServiceName[0] == null) { |
| newServiceName[0] = fe.getFile().getName()+"Service"; // defaultName |
| } |
| |
| if (!newServiceName[0].equals(oldServiceName)) { |
| FileObject implBean = getImplBean(); |
| if (getImplBean() != null) { // check if service wasn't removed already |
| service.setServiceName(newServiceName[0]); |
| fireDisplayNameChange(oldServiceName, newServiceName[0]); |
| fireNameChange(oldServiceName, newServiceName[0]); |
| fireShortDescriptionChange(); |
| |
| // replace nonJSR109 entries |
| if (!WSUtils.isJsr109Supported(project) ) { |
| JAXWSLightSupport jaxWsSupport = JAXWSLightSupport |
| .getJAXWSLightSupport(implBean); |
| FileObject ddFolder = jaxWsSupport |
| .getDeploymentDescriptorFolder(); |
| if ( ddFolder != null ) { |
| try { |
| WSUtils.replaceSunJaxWsEntries( |
| ddFolder, |
| oldServiceName, |
| newServiceName[0]); |
| } |
| catch (IOException ex) { |
| Logger.getLogger( |
| JaxWsNode.class |
| .getName()) |
| .log(Level.WARNING, |
| "Cannot modify endpoint in sun-jaxws.xml file", |
| ex); // NOI18N |
| } |
| } |
| try { |
| WSUtils.replaceServiceEntriesFromDD( |
| project, oldServiceName, |
| newServiceName[0]); |
| } |
| catch (IOException ex) { |
| Logger.getLogger( |
| JaxWsNode.class.getName()) |
| .log(Level.WARNING, |
| "Cannot modify web.xml file", |
| ex); // NOI18N |
| } |
| } |
| } |
| } |
| |
| } |
| } |
| }); |
| } |
| |
| }); |
| } |
| |
| private String getServiceName(CompilationController controller, TypeElement classElement) { |
| // check service name |
| AnnotationMirror anMirror = _RetoucheUtil.getAnnotation(controller, |
| classElement, "javax.jws.WebService"); // NOI18N |
| if ( anMirror == null ){ |
| return null; |
| } |
| java.util.Map<? extends ExecutableElement, ? extends AnnotationValue> expressions = |
| anMirror.getElementValues(); |
| for (java.util.Map.Entry<? extends ExecutableElement, |
| ? extends AnnotationValue> entry : expressions.entrySet()) |
| { |
| if (entry.getKey().getSimpleName().contentEquals("serviceName")) { // NOI18N |
| return (String) expressions.get(entry.getKey()).getValue(); |
| } |
| } |
| return null; |
| } |
| |
| @Override |
| public void configureHandler() { |
| FileObject implBeanFo = getImplBean(); |
| List<String> handlerClasses = new ArrayList<String>(); |
| FileObject handlerFO = null; |
| HandlerChains handlerChains = null; |
| //obtain the handler config file, if any from annotation in implbean |
| final String[] handlerFileName = new String[1]; |
| final boolean[] isNew = new boolean[]{true}; |
| JavaSource implBeanJavaSrc = JavaSource.forFileObject(implBeanFo); |
| CancellableTask<CompilationController> task = new CancellableTask<CompilationController>() { |
| |
| @Override |
| public void run(CompilationController controller) throws IOException { |
| controller.toPhase(Phase.ELEMENTS_RESOLVED); |
| TypeElement typeElement = SourceUtils.getPublicTopLevelElement(controller); |
| AnnotationMirror handlerAnnotation = _RetoucheUtil. |
| getAnnotation(controller, typeElement, "javax.jws.HandlerChain"); //NOI18N |
| if (handlerAnnotation != null) { |
| isNew[0] = false; |
| Map<? extends ExecutableElement, ? extends AnnotationValue> |
| expressions = handlerAnnotation.getElementValues(); |
| for (Entry<? extends ExecutableElement, |
| ? extends AnnotationValue> entry: expressions.entrySet()) |
| { |
| ExecutableElement ex = entry.getKey(); |
| AnnotationValue annotation = entry.getValue(); |
| if (ex.getSimpleName().contentEquals("file")) { //NOI18N |
| handlerFileName[0] = (String) annotation.getValue(); |
| break; |
| } |
| } |
| } |
| } |
| |
| @Override |
| public void cancel() { |
| } |
| }; |
| try { |
| implBeanJavaSrc.runUserActionTask(task, true); |
| } catch (IOException ex) { |
| LOG.log( Level.WARNING, null , ex); |
| } |
| |
| if (!isNew[0] && handlerFileName[0] != null) { |
| try { |
| // look for handlerFile |
| FileObject parent = implBeanFo.getParent(); |
| File parentFile = FileUtil.toFile(parent); |
| |
| File file = new File(parentFile, handlerFileName[0]); |
| if (file.exists()) { |
| file = file.getCanonicalFile(); |
| handlerFO = FileUtil.toFileObject(file); |
| } |
| if (handlerFO != null) { |
| try { |
| handlerChains = HandlerChainsProvider.getDefault().getHandlerChains(handlerFO); |
| } catch (Exception e) { |
| LOG.log( Level.WARNING, null , e); |
| return; //TODO handle this |
| } |
| HandlerChain[] handlerChainArray = handlerChains.getHandlerChains(); |
| //there is always only one, so get the first one |
| HandlerChain chain = handlerChainArray[0]; |
| Handler[] handlers = chain.getHandlers(); |
| for (int i = 0; i < handlers.length; i++) { |
| handlerClasses.add(handlers[i].getHandlerClass()); |
| } |
| } else { |
| //unable to find the handler file, display a warning |
| NotifyDescriptor.Message dialogDesc = new NotifyDescriptor.Message(NbBundle.getMessage(JaxWsNode.class, "MSG_HANDLER_FILE_NOT_FOUND", handlerFileName), NotifyDescriptor.INFORMATION_MESSAGE); |
| DialogDisplayer.getDefault().notify(dialogDesc); |
| } |
| } catch (IOException ex) { |
| LOG.log( Level.WARNING, null , ex); |
| } |
| } |
| final MessageHandlerPanel panel = new MessageHandlerPanel(project, handlerClasses, true, service.getServiceName()); |
| String title = NbBundle.getMessage(JaxWsNode.class, "TTL_MessageHandlerPanel"); |
| DialogDescriptor dialogDesc = new DialogDescriptor(panel, title); |
| dialogDesc.setButtonListener(new HandlerButtonListener(panel, handlerChains, handlerFO, implBeanFo, service, isNew[0])); |
| DialogDisplayer.getDefault().notify(dialogDesc); |
| } |
| |
| private void removeStaleFile(String name) throws IOException { |
| FileObject staleFile = project.getProjectDirectory().getFileObject("target/jaxws/stale/"+name+".stale"); |
| if (staleFile != null) { |
| staleFile.delete(); |
| } |
| } |
| |
| private String getServiceUri(String contextRoot) { |
| J2eeModuleProvider provider = project.getLookup().lookup(J2eeModuleProvider.class); |
| J2eeModule.Type moduleType = provider.getJ2eeModule().getType(); |
| // need to compute from annotations |
| String wsURI = null; |
| |
| WSStackUtils stackUtils = new WSStackUtils(project); |
| try { |
| |
| ServiceInfo serviceInfo = new ServiceInfo(); |
| boolean isEjb = J2eeModule.Type.EJB.equals(moduleType); |
| resolveServiceInfo(serviceInfo, isEjb); |
| |
| boolean fromStack = false; |
| WSStack<JaxWs> jaxWsStack = stackUtils.getWsStack(JaxWs.class); |
| if (jaxWsStack != null) { |
| JaxWs.UriDescriptor uriDescriptor = jaxWsStack.get().getWsUriDescriptor(); |
| if (uriDescriptor != null) { |
| fromStack = true; |
| |
| wsURI = uriDescriptor.getServiceUri(contextRoot, |
| serviceInfo.getServiceName(), serviceInfo.getPortName(), |
| serviceInfo.isEjb()); |
| } |
| } |
| |
| if (!fromStack) { |
| // default service URI |
| String portName = serviceInfo.getPortName(); |
| wsURI = (contextRoot == null ? "" : contextRoot+"/")+ |
| serviceInfo.getServiceName()+ (portName == null ? "" : "/"+portName); |
| } |
| |
| } catch (UnsupportedEncodingException ex) { |
| // this shouldn't happen' |
| } |
| |
| return wsURI; |
| } |
| |
| private ServerContextInfo getServerContextInfo() { |
| String portNumber = "8080"; //NOI18N |
| String hostName = "localhost"; //NOI18N |
| |
| J2eeModuleProvider provider = project.getLookup().lookup(J2eeModuleProvider.class); |
| String serverInstanceID = provider.getServerInstanceID(); |
| if (serverInstanceID == null) { |
| Logger.getLogger(JaxWsNode.class.getName()).log(Level.INFO, |
| "Can not detect target J2EE server"); //NOI18N |
| } |
| // getting port and host name |
| ServerInstance serverInstance = Deployment.getDefault(). |
| getServerInstance(serverInstanceID); |
| try { |
| ServerInstance.Descriptor instanceDescriptor = null; |
| if ( serverInstance != null ){ |
| instanceDescriptor = serverInstance.getDescriptor(); |
| } |
| if (instanceDescriptor != null) { |
| int port = instanceDescriptor.getHttpPort(); |
| portNumber = port == 0 ? "8080" : String.valueOf(port); //NOI18N |
| String hstName = instanceDescriptor.getHostname(); |
| if (hstName != null) { |
| hostName = hstName; |
| } |
| } else { |
| // using the old way to obtain port name and host name |
| // should be removed if ServerInstance.Descriptor is implemented in server plugins |
| InstanceProperties instanceProperties = provider.getInstanceProperties(); |
| if (instanceProperties == null) { |
| DialogDisplayer.getDefault().notify(new NotifyDescriptor.Message(NbBundle.getMessage(JaxWsNode.class, "MSG_MissingServer"), NotifyDescriptor.ERROR_MESSAGE)); |
| } else { |
| portNumber = getPortNumber(instanceProperties); |
| hostName = getHostName(instanceProperties); |
| } |
| } |
| } catch (InstanceRemovedException ex) { |
| Logger.getLogger(getClass().getName()).log(Level.INFO, "Removed ServerInstance", ex); //NOI18N |
| } |
| |
| String contextRoot = ""; //NOI18N |
| J2eeModule.Type moduleType = provider.getJ2eeModule().getType(); |
| |
| WSStackUtils stackUtils = new WSStackUtils(project); |
| if (J2eeModule.Type.WAR.equals(moduleType)) { |
| J2eeModuleProvider.ConfigSupport configSupport = provider.getConfigSupport(); |
| try { |
| contextRoot = configSupport.getWebContextRoot(); |
| } catch (ConfigurationException e) { |
| // TODO the context root value could not be read, let the user know about it |
| } |
| if (contextRoot != null && contextRoot.startsWith("/")) { |
| //NOI18N |
| contextRoot = contextRoot.substring(1); |
| } |
| } else if (J2eeModule.Type.EJB.equals(moduleType) && ServerType.JBOSS == stackUtils.getServerType()) { |
| // JBoss type |
| contextRoot = project.getProjectDirectory().getName(); |
| } |
| |
| /* |
| * Fix for BZ#190164 - NullPointerException at |
| * org.netbeans.modules.websvc.wsstack.jaxws.glassfish.v3.GlassFishV3JaxWsStack$1.getServiceUri |
| * |
| * It could happen at least with wrong sun-web.xml file . So |
| * this check is really needed. |
| */ |
| if ( contextRoot == null ){ |
| contextRoot = ""; |
| } |
| |
| return new ServerContextInfo(hostName, portNumber, contextRoot); |
| } |
| |
| private ServiceInfo getServiceInfo() { |
| ServiceInfo serviceInfo = new ServiceInfo(); |
| J2eeModuleProvider provider = project.getLookup().lookup(J2eeModuleProvider.class); |
| boolean isEjb = J2eeModule.Type.EJB.equals(provider.getJ2eeModule().getType()); |
| try { |
| resolveServiceInfo(serviceInfo, isEjb); |
| } catch (UnsupportedEncodingException ex) {} |
| return serviceInfo; |
| } |
| |
| private void resolveServiceInfo(final ServiceInfo serviceInfo, final boolean inEjbProject) throws UnsupportedEncodingException { |
| final String[] serviceName = new String[1]; |
| final String[] name = new String[1]; |
| final boolean[] isProvider = {false}; |
| serviceInfo.setEjb(inEjbProject); |
| JavaSource javaSource = getImplBeanJavaSource(); |
| if (javaSource != null) { |
| CancellableTask<CompilationController> task = new CancellableTask<CompilationController>() { |
| |
| @Override |
| public void run(CompilationController controller) throws IOException { |
| controller.toPhase(Phase.ELEMENTS_RESOLVED); |
| TypeElement typeElement = SourceUtils.getPublicTopLevelElement(controller); |
| if ( typeElement == null ){ |
| return; |
| } |
| boolean foundWsAnnotation = resolveServiceUrl(controller, |
| typeElement, serviceName, name); |
| if (!foundWsAnnotation) { |
| isProvider[0] = _RetoucheUtil.getAnnotation(controller, |
| typeElement, "javax.xml.ws.WebServiceProvider")!=null;//NOI18N |
| } |
| if (!inEjbProject) { |
| serviceInfo.setEjb(isStatelessEjb(controller, typeElement)); |
| } |
| } |
| |
| @Override |
| public void cancel() { |
| } |
| }; |
| try { |
| javaSource.runUserActionTask(task, true); |
| } catch (IOException ex) { |
| LOG.log( Level.WARNING, null , ex); |
| } |
| } |
| |
| String qualifiedImplClassName = service.getImplementationClass(); |
| String implClassName = getNameFromPackageName(qualifiedImplClassName); |
| if (serviceName[0] == null) { |
| serviceName[0] = URLEncoder.encode(implClassName + "Service", "UTF-8"); //NOI18N |
| } |
| serviceInfo.setServiceName(serviceName[0]); |
| if (name[0] == null) { |
| if (isProvider[0]) { |
| //per JSR 109, use qualified impl class name for EJB |
| name[0] = qualifiedImplClassName; |
| } else { |
| name[0] = implClassName; |
| } |
| name[0] = URLEncoder.encode(name[0], "UTF-8"); //NOI18N |
| } |
| serviceInfo.setPortName(name[0]); |
| } |
| |
| private boolean isStatelessEjb(CompilationController controller, |
| TypeElement targetElement) |
| { |
| return _RetoucheUtil.getAnnotation(controller, targetElement, |
| "javax.ejb.Stateless") !=null; |
| } |
| |
| private boolean resolveServiceUrl(CompilationController controller, |
| TypeElement targetElement, String[] serviceName, |
| String[] name) throws IOException |
| { |
| boolean foundWsAnnotation = false; |
| AnnotationMirror anMirror = _RetoucheUtil.getAnnotation(controller, |
| targetElement, "javax.jws.WebService"); // NOI18N |
| if ( anMirror == null ){ |
| return false; |
| } |
| Map<? extends ExecutableElement, ? extends AnnotationValue> expressions = |
| anMirror.getElementValues(); |
| for (Map.Entry<? extends ExecutableElement, ? extends AnnotationValue> entry : |
| expressions.entrySet()) |
| { |
| if (entry.getKey().getSimpleName().contentEquals("serviceName")) { //NOI18N |
| serviceName[0] = (String) expressions.get(entry.getKey()).getValue(); |
| if (serviceName[0] != null) { |
| serviceName[0] = URLEncoder.encode(serviceName[0], "UTF-8"); //NOI18N |
| } |
| } else if (entry.getKey().getSimpleName().contentEquals("name")) { //NOI18N |
| name[0] = (String) expressions.get(entry.getKey()).getValue(); |
| if (name[0] != null) { |
| name[0] = URLEncoder.encode(name[0], "UTF-8"); //NOI18N |
| } |
| } |
| if (serviceName[0] != null && name[0] != null) { |
| break; |
| } |
| } |
| return true; |
| } |
| |
| private static class ServerContextInfo { |
| private String host, port, contextRoot; |
| |
| public ServerContextInfo(String host, String port, String contextRoot) { |
| this.host = host; |
| this.port = port; |
| this.contextRoot = contextRoot; |
| } |
| |
| |
| public String getHost() { |
| return host; |
| } |
| |
| public String getPort() { |
| return port; |
| } |
| |
| public String getContextRoot() { |
| return contextRoot; |
| } |
| } |
| |
| private static class ServiceInfo { |
| private String serviceName, portName; |
| private boolean ejb; |
| |
| public void setEjb(boolean ejb) { |
| this.ejb = ejb; |
| } |
| |
| public void setPortName(String portName) { |
| this.portName = portName; |
| } |
| |
| public void setServiceName(String serviceName) { |
| this.serviceName = serviceName; |
| } |
| |
| public boolean isEjb() { |
| return ejb; |
| } |
| |
| public String getPortName() { |
| return portName; |
| } |
| |
| public String getServiceName() { |
| return serviceName; |
| } |
| } |
| |
| } |
