/*******************************************************************************
 * Copyright (c) 2005, 2009 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
 * yyyymmdd bug      Email and other contact information
 * -------- -------- -----------------------------------------------------------
 * 20060418   134322 rsinha@ca.ibm.com - Rupam Kuehner
 * 20060424   124368 kathy@ca.ibm.com - Kathy Chan
 * 20090312	  250984 mahutch@ca.ibm.com - Mark Hutchinson, Use another mechanism to wait for build to be completed
 * 20091201   296529 yenlu@ca.ibm.com - Yen Lu, Determination of when the sample JSP goes live is not robust.
 *******************************************************************************/

package org.eclipse.jst.ws.internal.consumption.ui.widgets.test.wssample;

import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

import org.eclipse.core.commands.ExecutionException;
import org.eclipse.core.resources.IProject;
import org.eclipse.core.runtime.IAdaptable;
import org.eclipse.core.runtime.IPath;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.core.runtime.Path;
import org.eclipse.core.runtime.Status;
import org.eclipse.jem.util.emf.workbench.ProjectUtilities;
import org.eclipse.jst.ws.internal.common.J2EEUtils;
import org.eclipse.jst.ws.internal.common.ServerUtils;
import org.eclipse.jst.ws.internal.consumption.command.common.BuildBeanCommand;
import org.eclipse.jst.ws.internal.consumption.ui.ConsumptionUIMessages;
import org.eclipse.jst.ws.internal.consumption.ui.command.StartServerCommand;
import org.eclipse.jst.ws.internal.consumption.ui.plugin.WebServiceConsumptionUIPlugin;
import org.eclipse.ui.PartInitException;
import org.eclipse.ui.browser.IWebBrowser;
import org.eclipse.ui.browser.IWorkbenchBrowserSupport;
import org.eclipse.wst.command.internal.env.core.common.StatusUtils;
import org.eclipse.wst.common.environment.IEnvironment;
import org.eclipse.wst.common.environment.ILog;
import org.eclipse.wst.common.environment.StatusException;
import org.eclipse.wst.common.frameworks.datamodel.AbstractDataModelOperation;
import org.eclipse.wst.ws.internal.wsrt.TestInfo;

public class GSTCLaunchCommand extends AbstractDataModelOperation
{

  public static String INPUT       = "Input.jsp";
  public static String TEST_CLIENT = "TestClient.jsp";
  public static String RESULT      = "Result.jsp";
  public static String METHOD      = "Method.jsp";
		
  private TestInfo testInfo;
  private String jspfolder;
  
  public GSTCLaunchCommand(TestInfo testInfo){
    this.testInfo = testInfo;
  }
		
  public IStatus execute( IProgressMonitor monitor, IAdaptable adaptable )
  {    
    IEnvironment env = getEnvironment();
    
    setJSPFolder();
    
	return launchSample(env, monitor);
  }
  private void setJSPFolder(){
	    //if the client is not a webcomponent then the 
		//sample must have been created, we must now factor in 
		//flexible projects  
		  
		IProject clientIProject = ProjectUtilities.getProject(testInfo.getClientProject());
	    if (clientIProject != null && !J2EEUtils.isWebComponent(clientIProject)){   
		  IProject project = ProjectUtilities.getProject(testInfo.getGenerationProject());
		  IPath path = J2EEUtils.getWebContentPath(project);
		  int index = testInfo.getJspFolder().lastIndexOf("/");
		  String jsp = testInfo.getJspFolder().substring(index + 1);
		  StringBuffer sb = new StringBuffer();	
		  sb.append("/").append(path.toString()).append("/").append(jsp);	  
		  jspfolder = sb.toString();
		} 
	    else
		  jspfolder = testInfo.getJspFolder();	
	  
	  
	  }
  
  private IStatus launchSample (IEnvironment env, IProgressMonitor monitor ) {
    IStatus status = Status.OK_STATUS;
	IPath fDestinationFolderPath = new Path(jspfolder);
	fDestinationFolderPath = fDestinationFolderPath.makeAbsolute();    

	IProject sampleProject = ProjectUtilities.getProject(testInfo.getGenerationProject());
	
	BuildBeanCommand buildCommand = new BuildBeanCommand();
	buildCommand.setEnvironment(env);
	buildCommand.setProject(sampleProject);
	try {
		//ensure the sample project is built
		buildCommand.execute(monitor, null);
	} catch (ExecutionException e2) {
		//just ignore and see if we can move on
	}
	 
	StartServerCommand serverCommand = new StartServerCommand( true );
	serverCommand.setServerInstanceId( testInfo.getClientExistingServer().getId() );
	serverCommand.setEnvironment( env );
	
	status = serverCommand.execute(monitor, null);
	if (status.getSeverity() == Status.ERROR) return status;
	
	String   newPath = ServerUtils.getWebComponentURL(sampleProject, testInfo.getClientServerTypeID(),testInfo.getClientExistingServer());
	int count = J2EEUtils.getWebContentPath(sampleProject).segmentCount();
	
	newPath = newPath + "/" + fDestinationFolderPath.removeFirstSegments(count);
	StringBuffer urlString = new StringBuffer( newPath + "/" + TEST_CLIENT );
	if (testInfo.getEndpoint() != null && !testInfo.getEndpoint().isEmpty())
	{
	  urlString.append("?endpoint=");
	  urlString.append(testInfo.getEndpoint().get(0).toString());
	}
	    
	try{
	      URL url;
	      url = new URL(urlString.toString());
        
	      for( int retries = 0; retries < 20; retries++ )
	      {
	        try
	        {
	          // Test the URLs
	          URL sampleUrl = new URL(newPath + "/" + RESULT);
	          HttpURLConnection urlConn = (HttpURLConnection)sampleUrl.openConnection();
	          int responseCode = urlConn.getResponseCode();
	          //System.out.println(retries + ": result HTTP code = " + responseCode);
	          //dumpUrlContents(urlConn);	          
	          if (responseCode != HttpURLConnection.HTTP_OK)
	        	  throw new IOException();
	          
	          sampleUrl = new URL(newPath + "/" + METHOD);
	          urlConn = (HttpURLConnection)sampleUrl.openConnection();
	          responseCode = urlConn.getResponseCode();
	          //System.out.println(retries + ": method HTTP code = " + responseCode);
	          //dumpUrlContents(urlConn);	          
	          if (responseCode != HttpURLConnection.HTTP_OK)
	        	  throw new IOException();
	          
	          sampleUrl = new URL(newPath + "/" + INPUT);
	          urlConn = (HttpURLConnection)sampleUrl.openConnection();
	          responseCode = urlConn.getResponseCode();	          
	          //System.out.println(retries + ": input HTTP code = " + responseCode);
	          //dumpUrlContents(urlConn);	          
	          if (responseCode != HttpURLConnection.HTTP_OK)
	        	  throw new IOException();	
	          
	          sampleUrl = new URL(newPath + "/" + TEST_CLIENT);
	          urlConn = (HttpURLConnection)sampleUrl.openConnection();
	          responseCode = urlConn.getResponseCode();	          
	          //System.out.println(retries + ": test client HTTP code = " + responseCode);
	          //dumpUrlContents(urlConn);	          
	          if (responseCode != HttpURLConnection.HTTP_OK)
	        	  throw new IOException();	    
            
	          // Looks good, exit loop
	          break;
	        }
	        catch( IOException ioe )
	        {
	          try
	          {
	            Thread.sleep(1000);
	          }
	          catch (InterruptedException ie) {} 	  	          
	        }
	      }

			IWorkbenchBrowserSupport browserSupport = WebServiceConsumptionUIPlugin.getInstance().getWorkbench().getBrowserSupport();
			IWebBrowser browser = browserSupport.createBrowser(IWorkbenchBrowserSupport.LOCATION_BAR, null, null, null);
			browser.openURL(url);
	      return status;
		 }catch(PartInitException exc){
			env.getLog().log(ILog.ERROR, 5048, this, "launchSample", exc);
			status = StatusUtils.errorStatus(exc.getMessage(), exc);
			env.getStatusHandler().reportError(status);
	    	return status;
	    }catch(MalformedURLException exc){
	    	env.getLog().log(ILog.WARNING, 5048, this, "launchSample", exc);
			status = StatusUtils.warningStatus( ConsumptionUIMessages.MSG_ERROR_MALFORMED_URL, exc );
			try {
				env.getStatusHandler().report(status);
			} catch (StatusException e) {
				status = StatusUtils.errorStatus( ConsumptionUIMessages.MSG_ERROR_MALFORMED_URL, e );
			}
	    	return status;
	    }
     }
/*  
     private void dumpUrlContents(URLConnection conn)
     {    	 
    	 InputStream is = null;
    	 try
    	 {
    		 is = conn.getInputStream();
    		 BufferedReader br = new BufferedReader(new InputStreamReader(is));
    		 String s = null;
    		 while ((s = br.readLine()) != null)
    			 System.out.println(s);
    	 }
    	 catch (IOException e)
    	 {    		 
    	 }
    	 finally
    	 {
    		 if (is != null)
    		 {
    			 try
    			 {
    			   is.close();
    			 }
    			 catch (IOException e)
    			 {    				 
    			 }
    		 }
    	 }
     }
*/     
}