bundles/org.eclipse.jst.ws.consumption/src/org/eclipse/jst/ws/internal/consumption/command/common/CreateMonitorCommand.java

/*******************************************************************************
 * Copyright (c) 2004 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.jst.ws.internal.consumption.command.common;

import java.util.Iterator;
import java.util.List;

import org.eclipse.core.runtime.CoreException;
import org.eclipse.jst.ws.internal.consumption.plugin.WebServiceConsumptionPlugin;
import org.eclipse.jst.ws.internal.data.TypeRuntimeServer;
import org.eclipse.wst.command.env.core.SimpleCommand;
import org.eclipse.wst.command.env.core.common.Environment;
import org.eclipse.wst.command.env.core.common.MessageUtils;
import org.eclipse.wst.command.env.core.common.SimpleStatus;
import org.eclipse.wst.command.env.core.common.Status;
import org.eclipse.wst.server.core.IMonitoredServerPort;
import org.eclipse.wst.server.core.IServer;
import org.eclipse.wst.server.core.IServerMonitorManager;
import org.eclipse.wst.server.core.ServerCore;
import org.eclipse.wst.server.core.model.IMonitorableServer;
import org.eclipse.wst.server.core.model.IServerDelegate;
import org.eclipse.wst.server.core.model.IServerPort;

public class CreateMonitorCommand extends SimpleCommand
{
  private static final String WEB_SERVICES = "Web services";
  private Boolean monitorService;
  private String serviceServerInstanceId;
  private Integer monitoredPort;

  public CreateMonitorCommand()
  {
    super("org.eclipse.jst.ws.internal.consumption.command.common.CreateMonitorCommand", "org.eclipse.jst.ws.internal.consumption.command.common.CreateMonitorCommand");
  }

  public Status execute(Environment env)
  {
    if (monitorService != null && monitorService.booleanValue())
    {
      IServer server = ServerCore.getResourceManager().getServer(serviceServerInstanceId);
      if (server != null)
      {
        IServerDelegate serverDelegate = server.getDelegate();
        if (serverDelegate instanceof IMonitorableServer)
        {
          IMonitorableServer monitorableServer = (IMonitorableServer) serverDelegate;
          List ports = monitorableServer.getServerPorts();
          IServerPort port = null;
          for (Iterator it = ports.iterator(); it.hasNext();)
          {
            IServerPort p = (IServerPort) it.next();
            String protocol = p.getProtocol();
            if (protocol != null && protocol.trim().toLowerCase().equals("http"))
            {
              port = p;
              break;
            }
          }
          if (port != null)
          {
            IServerMonitorManager serverMonitorManager = ServerCore.getServerMonitorManager();
            List monitoredPorts = serverMonitorManager.getMonitoredPorts(server);
            for (Iterator it2 = monitoredPorts.iterator(); it2.hasNext();)
            {
              IMonitoredServerPort imsPort = (IMonitoredServerPort)it2.next();
              if (port.getPort() == imsPort.getServerPort().getPort() && hasContentWebServices(imsPort)) // port already being monitored
              {
                if (!imsPort.isStarted())
                {
                  try
                  {
                    serverMonitorManager.startMonitor(imsPort);
                  }
                  catch (CoreException ce)
                  {
                    MessageUtils msgUtils = new MessageUtils(WebServiceConsumptionPlugin.ID + ".plugin", this);
                    Status error = new SimpleStatus(WebServiceConsumptionPlugin.ID, msgUtils.getMessage("MSG_ERROR_UNABLE_TO_START_MONITOR", new Object[] {String.valueOf(port.getPort()), server.getName()}), Status.ERROR, ce);
                    env.getStatusHandler().reportError(error);
                    return error;
                  }
                }
                monitoredPort = new Integer(imsPort.getMonitorPort());
                return new SimpleStatus("");
              }
            }
            try
            {
              IMonitoredServerPort imsPort = serverMonitorManager.createMonitor(server, port, -1, new String[] {WEB_SERVICES});
              serverMonitorManager.startMonitor(imsPort);
              monitoredPort = new Integer(imsPort.getMonitorPort());
              return new SimpleStatus("");
            }
            catch (CoreException ce)
            {
              MessageUtils msgUtils = new MessageUtils(WebServiceConsumptionPlugin.ID + ".plugin", this);
              Status error = new SimpleStatus(WebServiceConsumptionPlugin.ID, msgUtils.getMessage("MSG_ERROR_UNABLE_TO_START_MONITOR", new Object[] {String.valueOf(port.getPort()), server.getName()}), Status.ERROR, ce);
              env.getStatusHandler().reportError(error);
              return error;
            }
          }
        }
        else
        {
          MessageUtils msgUtils = new MessageUtils(WebServiceConsumptionPlugin.ID + ".plugin", this);
          Status info = new SimpleStatus(WebServiceConsumptionPlugin.ID, msgUtils.getMessage("MSG_INFO_MONITORING_NOT_SUPPORTED", new Object[] {server.getName()}), Status.INFO);
          env.getStatusHandler().reportInfo(info);
          return info;
        }
      }
    }
    return new SimpleStatus("");
  }
  
  private boolean hasContentWebServices(IMonitoredServerPort imsPort)
  {
    String[] contents = imsPort.getContentTypes();
    for (int i = 0; i < contents.length; i++)
      if (WEB_SERVICES.equals(contents[i]))
        return true;
    return false;
  }

  public void setServiceTypeRuntimeServer(TypeRuntimeServer typeRuntimeServer)
  {
    this.serviceServerInstanceId = typeRuntimeServer.getServerInstanceId();
  }
  
  public void setServiceServerInstanceId(String serviceServerInstanceId)
  {
    this.serviceServerInstanceId = serviceServerInstanceId;
  }

  public Integer getMonitoredPort()
  {
    return monitoredPort;
  }

  public void setMonitorService(Boolean value)
  {
    monitorService = value;
  }
}