/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Andrew Eberbach (aeberbac@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.io.ByteArrayOutputStream;

import java.lang.reflect.InvocationTargetException;

import java.util.ArrayList;

import java.util.Collection;

import java.util.Iterator;

import java.util.List;

import javax.wsdl.WSDLException;

import javax.wsdl.factory.WSDLFactory;

import javax.wsdl.xml.WSDLReader;

import javax.wsdl.xml.WSDLWriter;

import javax.xml.namespace.QName;

import org.apache.muse.tools.generator.WsdlMerge;

import org.apache.muse.util.xml.XmlUtils;

import org.apache.muse.ws.addressing.soap.SoapFault;

import org.apache.muse.ws.notification.WsnConstants;

import org.apache.muse.ws.resource.metadata.MetadataDescriptor;

import org.apache.muse.ws.resource.metadata.WsrmdConstants;

import org.apache.muse.ws.resource.metadata.impl.SimpleMetadataDescriptor;

import org.apache.muse.ws.wsdl.WsdlUtils;

import org.eclipse.emf.common.util.URI;

import org.eclipse.tptp.wsdm.tooling.editor.capability.util.internal.MetaDataUtils;

import org.eclipse.tptp.wsdm.tooling.editor.internal.CapabilityDefinition;

import org.eclipse.tptp.wsdm.tooling.model.capabilities.Capability;

import org.eclipse.tptp.wsdm.tooling.model.manageableResourceType.ManageableResourceType;

import org.eclipse.tptp.wsdm.tooling.nls.messages.mrt.internal.Messages;

import org.eclipse.tptp.wsdm.tooling.util.internal.MrtUtils;

import org.w3c.dom.Document;

import org.w3c.dom.Element;

/**

 * This class provides the utility method for merging the MRT to get the smashed WSDL and RMD documents.

 *

 */

public class MrtMerge 

{

	private static WSDLReader _reader;

	private static WSDLWriter _writer;

	private static WSDLFactory _factory;

	/**

	 * Creates the smashed WSDL file for representing the resource type

	 * 

	 * @param mrtFile -

	 *            Manageable Resource Type file

	 * @throws Exception -

	 *             Throws exception while getting WSDL files and also while

	 *             merging them

	 */

	public static Document createMergedWSDL(ManageableResourceType mrt, String address)

			throws Exception

	{

		checkReadersWriters();

		List wsdlFiles = null;

		try

		{

			wsdlFiles = getWsdlFiles(mrt);

		}

		catch (Exception e)

		{

			throw new Exception(Messages.HOOKUP_WIZARD_ERROR_7, e);

		}

		String namespaceURI = mrt.getNamespace();

		Document[] wsdlFragments = (Document[])wsdlFiles.toArray(new Document[wsdlFiles.size()]);

		javax.wsdl.Definition def = WsdlMerge.merge(namespaceURI, wsdlFragments,

 				address);

		return _writer.getDocument(def);

	}

	private static void checkReadersWriters() throws InvocationTargetException

	{

		try

		{

			_factory = WSDLFactory.newInstance();

			_reader = _factory.newWSDLReader();

			_writer = _factory.newWSDLWriter();

		}

		catch (WSDLException e)

		{

			throw new InvocationTargetException(new Exception(

					Messages.HOOKUP_WIZARD_ERROR_3, e));

		}

	}

	/**

	 * Given an MRT file return a list of <code>Definition</code> objects that

	 * correspond to the WSDL files related to this MRT (that is, its

	 * Capabilities).

	 * 

	 * @param mrtFile

	 * @return

	 * @throws Exception

	 */

	private static List getWsdlFiles(ManageableResourceType mrt)

			throws Exception

	{

		//Get a list of all of the capabilities in this MRT 

		//This should just be a list of URIs

		List capabilityList = mrt.getImplements();		

		//Here is our list of clean WSDL documents

		//we are returning

		ArrayList wsdls = new ArrayList();	

		//Use an EclipseEnvironment to do the resolution of paths

		EclipseEnvironment eclipseEnv = new EclipseEnvironment();

		//Iterate over each capability and load it into a Definition

		for (Iterator i = capabilityList.iterator(); i.hasNext();) {

			String nextPath = i.next().toString();

			Document document = WsdlUtils.createWSDL(eclipseEnv, nextPath, true);

			//clean up imports

			//see the actual functions to understand how 

			//the removal is done

			Element cleanDocument = WsdlUtils.removeSchemaReferences(document.getDocumentElement());

			cleanDocument = WsdlUtils.removeWsdlReferences(cleanDocument);

			wsdls.add(cleanDocument.getOwnerDocument());

		}

		return wsdls;

	}

	/**

	 * Creates the merged RMD file for representing the manageable resource type

	 * 

	 * @param mrtFile -

	 *            Manageable Resource Type file

	 * @throws Exception -

	 *             Throws exception while getting capabilities defined in MRT and also while

	 *             merging their RMDs

	 */

	public static MetadataDescriptor createMergedRMD(ManageableResourceType mrt) throws Exception

	{

			List rmds = new ArrayList();

			Capability[] capabilities = MrtUtils.getCapabilities(mrt);

			List allTopicExpressions = new ArrayList();

			for(int i=0;i<capabilities.length;i++)

			{

				CapabilityDefinition capabilityDef = (CapabilityDefinition)capabilities[i].getWsdlDefinition();

				URI capabilityFileLocationURI = capabilityDef.getWSDLResourceProtocolURI();

				String metadataDescriptorLocation = capabilityDef.getMetadataDescriptorLocation();

				if(metadataDescriptorLocation == null || metadataDescriptorLocation.length() == 0)

					continue;

				URI rmdFileLocationURI = URI.createURI(capabilityFileLocationURI.trimSegments(1).toString()+ "/" + metadataDescriptorLocation);

				org.eclipse.tptp.wsdm.tooling.model.metadataDescriptor.DocumentRoot root = MetaDataUtils.getDocumentRoot(rmdFileLocationURI);

				ByteArrayOutputStream baos = MetaDataUtils.saveRMD(root, rmdFileLocationURI.toString(), null);

				String rmdXML = new String(baos.toByteArray());

				Element definitionElement = (Element) XmlUtils.createDocument(rmdXML).getFirstChild();

				Element metadataDescriptorElement = XmlUtils.getFirstElement(definitionElement);			

				MetadataDescriptor rmdDescriptor = new SimpleMetadataDescriptor(metadataDescriptorElement);				

				// Get all the topic expressions defined in different capabilities

				String[] topicExpressions = getTopicExpressions(rmdDescriptor);

				for(int j=0;j<topicExpressions.length;j++)

				{

					String prefix = topicExpressions[j].substring(0,topicExpressions[j].indexOf(':'));

					String namespace = (String)root.getXMLNSPrefixMap().get(prefix);

					String topicPath = topicExpressions[j].substring(topicExpressions[j].indexOf(':')+1);

					allTopicExpressions.add(new TopicExpression(namespace, topicPath));

				}				

				rmdDescriptor.removeProperty(WsnConstants.TOPIC_EXPRESSION_QNAME);

				rmds.add(rmdDescriptor);		

			}

			MetadataDescriptor[] descriptors = (MetadataDescriptor[]) rmds.toArray(new MetadataDescriptor[rmds.size()]);

			QName qname = new QName(mrt.getNamespace(), "PortType");

			// TODO Verify with Andrew that is it the way that MUSE creates the smashed wsdl by this name

			String name = mrt.getIdentifier()+".wsdl";

			MetadataDescriptor mergedRMD = WsdlMerge.merge(name, qname, descriptors);

			TopicExpression[] topicExpressions = (TopicExpression[]) allTopicExpressions.toArray(new TopicExpression[allTopicExpressions.size()]);

			// Merge all the topic expressions defined in different capabilities

			mergeTopicExpressions(mergedRMD, topicExpressions);

			return mergedRMD;		

	}

	private static String[] getTopicExpressions(MetadataDescriptor rmdDescriptor) throws SoapFault

	{

		if(rmdDescriptor.hasProperty(WsnConstants.TOPIC_EXPRESSION_QNAME))

		{

			Collection collection = rmdDescriptor.getInitialValues(WsnConstants.TOPIC_EXPRESSION_QNAME, String.class);

			return (String[])collection.toArray(new String[collection.size()]);

		}

		return new String[0];

	}

	private static void mergeTopicExpressions(MetadataDescriptor rmdDescriptor, TopicExpression[] topicExpressions) throws SoapFault

	{

		if(topicExpressions!=null && topicExpressions.length>0)

		{

			rmdDescriptor.addProperty(WsnConstants.TOPIC_EXPRESSION_QNAME, WsrmdConstants.READ_ONLY, WsrmdConstants.MUTABLE);

			List initValues = new ArrayList();

			Document doc = XmlUtils.createDocument();

			for(int i=0;i<topicExpressions.length;i++)

			{

				String namespace = topicExpressions[i].getTopicNamespace();

				String topicPath = topicExpressions[i].getTopicPath();

				String expression = "pfx:"+topicPath;

				Element propertyElement = XmlUtils.createElement(doc, WsnConstants.TOPIC_EXPRESSION_QNAME);

				propertyElement.setAttribute("xmlns:pfx", namespace);

				XmlUtils.setElementText(propertyElement, expression);

				initValues.add(propertyElement);

			}

			rmdDescriptor.setInitialValues(WsnConstants.TOPIC_EXPRESSION_QNAME, initValues);			

		}

	}

}

class TopicExpression

{

	private String _topicNamespace;

	private String _topicPath;

	TopicExpression(String topicNamespace, String topicPath)

	{

		_topicNamespace = topicNamespace;

		_topicPath = topicPath;

	}

	String getTopicNamespace()

	{

		return _topicNamespace;

	}

	String getTopicPath()

	{

		return _topicPath;

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.net.URL;

import org.eclipse.swt.SWT;

import org.eclipse.swt.browser.Browser;

import org.eclipse.swt.events.SelectionAdapter;

import org.eclipse.swt.events.SelectionEvent;

import org.eclipse.swt.layout.GridData;

import org.eclipse.swt.layout.GridLayout;

import org.eclipse.swt.widgets.Button;

import org.eclipse.swt.widgets.Display;

import org.eclipse.swt.widgets.Shell;

import org.eclipse.tptp.wsdm.tooling.editor.internal.Activator;

import org.eclipse.tptp.wsdm.tooling.nls.messages.mrt.internal.Messages;

import org.eclipse.tptp.wsdm.tooling.util.internal.WsdmToolingLog;

import org.osgi.framework.Bundle;

/**

 * This class is used to display the Axis-2 License. 

 */

public class Axis2LicenseDialog 

{

	private Shell _shell;

	private Browser _text;

	private Button _btnAgree;

	private Button _btnDecline;

	public static int AGREE = 0;

	public static int DECLINE = 1;

	private int _retInt = DECLINE;

	/**

	 * Constructor of the class. It initialises the UI for

	 * displaying the license

	 */

	public Axis2LicenseDialog()

	{

		initUI();

	}

	private void initUI()

	{

		_shell = new Shell(Display.getCurrent(), SWT.CLOSE | SWT.SYSTEM_MODAL | SWT.APPLICATION_MODAL | SWT.RESIZE);

		_shell.setLayout(new GridLayout(2, true));

		_shell.setText(Messages.AXIS2_LICENSE_LABEL);

		_shell.setSize(300, 300);

		_text = new Browser(_shell, SWT.BORDER | SWT.MULTI | SWT.WRAP);

		try 

		{

			_text.setText(readLicence());

		} 

		catch (Throwable e)

		{

			WsdmToolingLog.logError(e.getMessage(), e);

		}

		_btnAgree = new Button(_shell, SWT.PUSH);

		_btnAgree.setText(Messages.LICENSE_AGREE_TEXT);

		_btnAgree.addSelectionListener(new SelectionAdapter()

		{

			public void widgetSelected(SelectionEvent se)

			{

				_retInt = AGREE;

				_shell.dispose();

			}

		}

		);

		_btnDecline = new Button(_shell, SWT.PUSH);

		_btnDecline.setText(Messages.LICENSE_DECLINE_TEXT);

		_btnDecline.addSelectionListener(new SelectionAdapter()

		{

			public void widgetSelected(SelectionEvent se)

			{

				_retInt = DECLINE;

				_shell.dispose();

			}

		}

		);

		GridData gd = new GridData(GridData.FILL_BOTH);

		gd.horizontalSpan = 2;

		_text.setLayoutData(gd);

		gd = new GridData();

		gd.horizontalAlignment = SWT.RIGHT;

		_btnAgree.setLayoutData(gd);

		gd = new GridData();

		gd.horizontalAlignment = SWT.LEFT;

		_btnDecline.setLayoutData(gd);

	}

	/**

	 * Method  to show the Dialog that displays the Liscense

	 */

	public int showWindow()

	{

		_shell.open();

		while(!_shell.isDisposed())

		{

			if(!Display.getCurrent().readAndDispatch())

				Display.getCurrent().sleep();

		}

		return _retInt;

	}

	private String readLicence() throws Throwable

	{

		Bundle bundle = Activator.INSTANCE.getPlugin().getBundle();

		URL licenceURL = bundle.getEntry("licence/Licence.txt");

		BufferedReader in = new BufferedReader(new InputStreamReader(licenceURL.openStream()));

		StringBuffer buffer = new StringBuffer();

		String line = null;

		while ((line = in.readLine()) != null)

			buffer.append(line);

		return buffer.toString();

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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

 * $Id: CodeGenerationData.java,v 1.2 2007/05/07 09:15:10 dnsmith Exp $

 * 

 * Contributors:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import org.apache.muse.tools.generator.analyzer.Analyzer;

import org.apache.muse.tools.generator.projectizer.Projectizer;

import org.apache.muse.tools.generator.synthesizer.Synthesizer;

import org.eclipse.core.runtime.CoreException;

import org.eclipse.core.runtime.IConfigurationElement;

class CodeGenerationData {				

	private Analyzer _analyzer;

	private Synthesizer _synthesizer;

	private Projectizer _projectizer;

	private int _servicePort;

	private String _servicePath;

	private String _container;

	private String _platform;

	public CodeGenerationData(IConfigurationElement[] elements) {

		for (int i = 0; i < elements.length; i++)

		{

			String name = elements[i].getName();

			if(name.equals("description")) {

				extractDescription(elements[i]);

			} else if (name.equals("projectizer")) {

				extractProjectizer(elements[i]);

			} else if (name.equals("synthesizer")) {

				extractSynthesizer(elements[i]);

			} else if (name.equals("analyzer")) {

				extractAnalyzer(elements[i]);

			}

		}

	}

	private void extractDescription(IConfigurationElement configurationElement) {

		_container = configurationElement.getAttribute("container");

		_platform = configurationElement.getAttribute("platform");

	}

	private void extractProjectizer(IConfigurationElement configurationElement) {

		String port = configurationElement.getAttribute("servicePort");

		if(port != null && port.length() != 0) {

			_servicePort = Integer.parseInt(port);

		}

		_servicePath = configurationElement.getAttribute("servicePath");

		_projectizer = (Projectizer) createExecutable(configurationElement);

	}

	private void extractSynthesizer(IConfigurationElement configurationElement) {

		_synthesizer = (Synthesizer) createExecutable(configurationElement);			

	}

	private void extractAnalyzer(IConfigurationElement configurationElement) {

		_analyzer = (Analyzer) createExecutable(configurationElement);

	}	

	private Object createExecutable(IConfigurationElement configurationElement) {

		try {

			return configurationElement.createExecutableExtension("class");

		} catch (CoreException e) {

			throw new RuntimeException(configurationElement.getAttribute("class"));

		}

	}

	public Analyzer getAnalyzer() {

		return _analyzer;

	}

	public Synthesizer getSynthesizer() {

		return _synthesizer;

	}

	public Projectizer getProjectizer() {

		return _projectizer;

	}

	public int getServicePort() {

		return _servicePort;

	}

	public String getServicePath() {

		return _servicePath;

	}

	public String getContainer() {

		return _container;

	}

	public String getPlatform() {

		return _platform;

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Andrew Eberbach (aeberbac@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import org.eclipse.core.resources.IFile;

import org.eclipse.jface.action.IAction;

import org.eclipse.jface.viewers.ISelection;

import org.eclipse.jface.viewers.StructuredSelection;

import org.eclipse.jface.wizard.WizardDialog;

import org.eclipse.tptp.wsdm.tooling.util.internal.MrtUtils;

import org.eclipse.ui.IObjectActionDelegate;

import org.eclipse.ui.IWorkbenchPart;

/**

 * Access point code from the code generation option in popup

 */

public class Generation implements IObjectActionDelegate

{

	private IWorkbenchPart _targetPart;

	private StructuredSelection _selection;

	/**

	 * (non-Javadoc)

	 * @see org.eclipse.ui.IObjectActionDelegate#run(org.eclipse.jface.action.IAction)

	 */ 

	public void run(IAction action)

	{

		IFile mrtFile = (IFile) _selection.getFirstElement();

		MrtUtils.searchAndSaveMRTEditor(mrtFile);

		MRTCodeGenerationDelegate codeGenerationDelegate = new MRTCodeGenerationDelegate(

				mrtFile);

		NewProjectWizard npw = new NewProjectWizard(codeGenerationDelegate);

		WizardDialog wd = new WizardDialog(_targetPart.getSite().getShell(),

				npw);

		wd.open();

	}

	/**

	 * (non-Javadoc)

	 * @see org.eclipse.ui.IObjectActionDelegate#setActivePart(org.eclipse.jface.action.IAction, org.eclipse.ui.IWorkbenchPart)

	 */ 

	public void setActivePart(IAction action, IWorkbenchPart targetPart)

	{

		_targetPart = targetPart;

	}

	/**

	 * (non-Javadoc)

	 * @see org.eclipse.ui.IObjectActionDelegate#selectionChanged

	(org.eclipse.jface.action.IAction, org.eclipse.jface.viewers.ISelection)

	 */

	public void selectionChanged(IAction action, ISelection selection)

	{

		if (selection instanceof StructuredSelection)

		{

			_selection = (StructuredSelection) selection;

		}

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import org.eclipse.jface.preference.IPreferenceStore;

import org.eclipse.jface.wizard.WizardPage;

import org.eclipse.osgi.util.TextProcessor;

import org.eclipse.swt.SWT;

import org.eclipse.swt.events.ModifyEvent;

import org.eclipse.swt.events.ModifyListener;

import org.eclipse.swt.events.SelectionAdapter;

import org.eclipse.swt.events.SelectionEvent;

import org.eclipse.swt.layout.GridData;

import org.eclipse.swt.layout.GridLayout;

import org.eclipse.swt.widgets.Button;

import org.eclipse.swt.widgets.Composite;

import org.eclipse.swt.widgets.DirectoryDialog;

import org.eclipse.swt.widgets.Label;

import org.eclipse.swt.widgets.Text;

import org.eclipse.tptp.wsdm.tooling.editor.internal.Activator;

import org.eclipse.tptp.wsdm.tooling.nls.messages.mrt.internal.Messages;

import org.eclipse.tptp.wsdm.tooling.preferences.internal.Axis2ServerLocationPreferencePage;

import org.eclipse.tptp.wsdm.tooling.validation.util.internal.ValidationUtils;

/**

 * This is Wizard Page to show the Axis2 server location details

 *

 */

public class Axis2ServerLocationPage extends WizardPage

{

	protected Text _serverNameField;

	private Button _browseButton;

	private Button _preferenceUpdate;

	private TargetedFileList[] _filesToCopy;

	private String userDefinedLocation ="";

	/**

	 * Instantiates the class.

	 */

	public Axis2ServerLocationPage() 

	{

		super("wizardPage");

		setTitle(Messages.HOOKUP_WIZARD_TXT1);

		setDescription(Messages.HOOKUP_WIZARD_TXT2);

	}

	/**

	 *  Creates wizard controls.

	 */

	public void createControl(Composite parent) 

	{

		Composite page = new Composite(parent, SWT.NULL);

		GridLayout layout = new GridLayout(1, false);

		page.setLayout(layout);

		createPageControls(page);

		//dialogChanged();

		setControl(page);

	}

	private void createPageControls(Composite page) 

	{

		Composite column = new Composite(page, SWT.NULL);

		GridLayout layout = new GridLayout(2, false);

		column.setLayout(layout);

		createServerLocationColumn(column);

	}

	private void createServerLocationColumn(Composite parent) 

	{

		GridData data = new GridData(GridData.FILL_HORIZONTAL);

		data.horizontalSpan = 2;

        // new server location label

        Label serverLabel = new Label(parent, SWT.NONE);

        serverLabel.setText(Messages.CODE_GEN_AXIS2_LOCATION);

        serverLabel.setFont(parent.getFont());

        serverLabel.setLayoutData(data);

		// server location entry field

        data = new GridData(GridData.FILL_HORIZONTAL);

        data.widthHint = 350;

        data.horizontalSpan = 1;

        _serverNameField = new Text(parent, SWT.BORDER);

        _serverNameField.setLayoutData(data);

        _serverNameField.setFont(parent.getFont());

        _serverNameField.addModifyListener(new ModifyListener()

		{

			public void modifyText(ModifyEvent e)

			{

				boolean pageCompleted = true;

				userDefinedLocation = _serverNameField.getText();

				String errorMsg = validateLocation(); 

				if(errorMsg == null)

				{

					setErrorMessage(errorMsg);

					pageCompleted = true;

				}

				else

				{

					setErrorMessage(errorMsg);

					pageCompleted = false;

				}

				makePageComplete(pageCompleted);

			}

		});

    //    _serverNameField.setText(getPreferenceServerLocation());

        // browse button

		_browseButton = new Button(parent, SWT.PUSH);

		_browseButton.setText(Messages.HOOKUP_WIZARD_TXT5);

		_browseButton.addSelectionListener(new SelectionAdapter() 

		{

			public void widgetSelected(SelectionEvent event) 

			{

				handleLocationBrowseButtonPressed();

			}

		});

		// server location entry field

        data = new GridData(GridData.FILL_HORIZONTAL);

        //data.widthHint = 350;

        data.horizontalSpan = 2;

        _preferenceUpdate = new Button(parent, SWT.CHECK);

        _preferenceUpdate.setText(Messages.CODE_GEN_UPDATE_PREF);

        _preferenceUpdate.setLayoutData(data);

        _preferenceUpdate.setFont(parent.getFont());		

	}

	protected String getPreferenceServerLocation() 

	{

		IPreferenceStore store = Activator.getPlugin().getPreferenceStore();

		String location = store.getString(Axis2ServerLocationPreferencePage.SERVER_LOCATION_PREFERENCE_KEY).trim();

		if(location != null && !location.equals(""))

			return location;

		return "";

	}

	private void handleLocationBrowseButtonPressed() 

	{

		String selectedDirectory = null;

		DirectoryDialog dialog = new DirectoryDialog(_serverNameField.getShell());

		dialog.setMessage(Messages.CODE_GEN_DIR_LOCATION);

		//dialog.setFilterPath(dirName);

		selectedDirectory = dialog.open();

		if (selectedDirectory != null)

			updateLocationField(selectedDirectory);

	}

	private void updateLocationField(String selectedPath) 

	{

		_serverNameField.setText(TextProcessor.process(selectedPath));

	}

	/**

	 * Returns the server location.

	 * @return

	 */

	public String getServerLocation() 

	{

		return _serverNameField.getText();

	}

	/**

	 * Checks to see if Update Preferences checkbox is selected

	 * @return

	 */

	public boolean isUpdatePreference()

	{

		return _preferenceUpdate.getSelection();

	}

	private String validateLocation()

	{

		String serverHome = _serverNameField.getText();

		ISoapServerDependency axisValidators[] = ValidationUtils.getAllAxisValidators();

		for(int i = 0 ; i < axisValidators.length ; i++){

			ISoapServerDependency axis2Dependency = (Axis2ServerDependency)axisValidators[i];

			String errorMessage = axis2Dependency.validateSoapServerHome(serverHome);

			if(errorMessage!=null)

				return errorMessage;

			_filesToCopy = axis2Dependency.getFilesToCopy();

			if(_filesToCopy == null)

				_filesToCopy = new TargetedFileList[0];

		}

		return null;		

	}

	/**

	 * Returns the Axis2 files to copied to generated code

	 * @return

	 */

	public TargetedFileList[] getAxis2FilesToCopy()

	{

		return _filesToCopy;

	}

	/**

	 * Method to Set the Wizard page to complete state

	 * @param validPage 

	 */

	public synchronized void makePageComplete(boolean completePage)

	{

		if(completePage){

			setPageComplete(true);

		}

		else

			setPageComplete(false);		

	}

	protected String getUserDefinedLocation()

	{

		return userDefinedLocation;

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.io.File;

import java.io.InputStream;

import java.net.URI;

import java.net.URL;

import java.net.URLConnection;

import org.apache.muse.core.AbstractEnvironment;

import org.apache.muse.util.xml.XmlUtils;

import org.apache.muse.ws.addressing.EndpointReference;

import org.eclipse.core.resources.IFile;

import org.eclipse.core.resources.ResourcesPlugin;

import org.eclipse.core.runtime.FileLocator;

import org.eclipse.core.runtime.Path;

import org.eclipse.core.runtime.Platform;

import org.eclipse.tptp.wsdm.tooling.util.internal.EclipseUtils;

import org.eclipse.tptp.wsdm.tooling.util.internal.WsdmToolingLog;

import org.osgi.framework.Bundle;

import org.w3c.dom.Document;

public class EclipseEnvironment extends AbstractEnvironment

{

	public EndpointReference getDeploymentEPR()

	{

		// TODO Auto-generated method stub

		return null;

	}

	public File getRealDirectory()

	{

		// TODO Auto-generated method stub

		return null;

	}

	public Document getDocument(String path)

	{

		try

		{

			if(isHttpScheme(path))

			{

				URLConnection conn = new URL(path).openConnection();

				InputStream stream = conn.getInputStream();

				return XmlUtils.createDocument(stream);

			}			

		}

		catch(Exception e)

		{

			WsdmToolingLog.logError(e.getMessage(), e);

		}

		try

		{

			if (!isBuiltin(path))

			{

				IFile wsdlFile = EclipseUtils.getIFile(ResourcesPlugin

						.getWorkspace().getRoot(), path);

				return XmlUtils.createDocument(wsdlFile.getLocation().toFile()

						.getAbsoluteFile());

			}

			else

			{

				String substr = path.substring(path.indexOf("platform:/plugin/")+"platform:/plugin/".length());

				String contributorPlugin = substr.substring(0,substr.indexOf('/'));

				String relativePath = substr.substring(substr.indexOf('/')+1);

				Bundle bundle = Platform.getBundle(contributorPlugin);

				return XmlUtils.createDocument(FileLocator.openStream(bundle,

						new Path(relativePath), false));

			}

		}

		catch (Exception e)

		{

			WsdmToolingLog.logError(e.getMessage(), e);

		}

		return null;

	}

	/**

	 * Utility method to see if the path is referring to something in the

	 * plugins or in the workspace.

	 * 

	 * @param path

	 *            A path to examine

	 * @return true if the path starts with <code>"platform:/plugin"</code>

	 */

	private boolean isBuiltin(String path)

	{

		return path.startsWith("platform:/plugin");

	}

	private boolean isHttpScheme(String path)

	{

		try{

			URI uri = URI.create(path);		

			String scheme = uri.getScheme();

			if(scheme != null && uri.getScheme().equals("http"))

				return true;

		}catch(Exception e){

			// nuthing to do, just return false

		}

		return false;

	}

	public String createRelativePath(String original, String relative)

	{

		// If the relative path starts with "platform:/" then it

		// is an absolute path, so just return it instead.

		if (relative.startsWith("platform:/"))

		{

			return relative;

		}

		return super.createRelativePath(original, relative);

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.io.File;

import java.io.FileFilter;

import java.util.LinkedList;

import java.util.List;

import org.eclipse.osgi.util.NLS;

import org.eclipse.tptp.wsdm.tooling.nls.messages.mrt.internal.Messages;

/**

 * This class verifies the Axis2 Soap Library dependency. 

 */

public class Axis2ServerDependency extends SoapServerDependency implements ISoapServerDependency

{

	private List _filesToCopy = new LinkedList();

	/**

	 * @see ISoapServerDependency#validateSoapServerHome(String)

	 */

	public String validateSoapServerHome(String serverHome)

	{

		if(serverHome == null || serverHome.length() == 0)

			return Messages.CODE_GEN_AXIS2_PROJECT_DIR;

		File serverHomeDir = new File(serverHome);

		if(!serverHomeDir.exists()){

			return NLS.bind(Messages.CODE_GEN_AXIS2_LOCATION_ERROR_, serverHome);

		}

		TargetedFileList _jarFilesToCopy = new TargetedFileList("WEB-INF/lib/");

		TargetedFileList _marFilesToCopy = new TargetedFileList("WEB-INF/modules/");

		TargetedFileList _restFilesToCopy = new TargetedFileList("WEB-INF/");

		String[] relativeFilePaths = (String[]) _requiredFiles.toArray(new String[_requiredFiles.size()]);

		for(int i=0;i<relativeFilePaths.length;i++)

		{

			String parentDirectory = getParentDirectory(relativeFilePaths[i]);

			if(parentDirectory == null)

				parentDirectory = serverHome;

			else

				parentDirectory = serverHome+File.separatorChar+parentDirectory;

			String fileExtension = getFileExtension(relativeFilePaths[i]);

			if(fileExtension == null)

				fileExtension = "*";

			FileFilter filter = new CustomFileFilter(fileExtension);

			File parentDirectoryFile = new File(parentDirectory);

			if(!parentDirectoryFile.exists())

				return NLS.bind(Messages.CODE_GEN_AXIS2_LOCATION_ERROR_, parentDirectory);

			File[] allFiles = parentDirectoryFile.listFiles(filter);

			String fileName = getFileName(relativeFilePaths[i]);

			File matchedFile = getMatchedPatternFile(allFiles, fileName);

			if(matchedFile == null)

				return NLS.bind(Messages.CODE_GEN_ERROR_INVALID_AXIS_FILE, serverHome+File.separatorChar+relativeFilePaths[i]);

			String absolutePath = matchedFile.getAbsolutePath();

			if(absolutePath.endsWith("jar"))

				_jarFilesToCopy.add(absolutePath);

			else if(absolutePath.endsWith("mar"))

				_marFilesToCopy.add(absolutePath);

			else

				_restFilesToCopy.add(absolutePath);

		}

		_filesToCopy.add(_jarFilesToCopy);

		_filesToCopy.add(_marFilesToCopy);

		_filesToCopy.add(_restFilesToCopy);

		return null;

	}

	private String getParentDirectory(String relativePath)

	{

		if(relativePath.indexOf('/')==-1)

			return null;

		return relativePath.substring(0,relativePath.lastIndexOf('/'));		

	}

	private String getFileExtension(String relativePath)

	{

		if(relativePath.indexOf('.')==-1)

			return null;

		return relativePath.substring(relativePath.lastIndexOf('.')+1);

	}

	private String getFileName(String relativePath)

	{

		if(relativePath.indexOf('/')==-1)

		{

			if(relativePath.indexOf('.')==-1)

				return relativePath;

			else

				return relativePath.substring(0,relativePath.lastIndexOf('.'));

		}

		else

		{

			String fileNameWithExtn = relativePath.substring(relativePath.lastIndexOf('/')+1);

			if(fileNameWithExtn.indexOf('.')==-1)

				return fileNameWithExtn;

			else

				return fileNameWithExtn.substring(0,fileNameWithExtn.lastIndexOf('.'));

		}

	}

	private File getMatchedPatternFile(File[] allFiles, String pattern)

	{

		String strippedPattern = pattern.indexOf("-*")==-1?pattern:pattern.substring(0,pattern.lastIndexOf("-*"));

		for(int i=0;i<allFiles.length;i++)

		{

			if(allFiles[i].getName().startsWith(strippedPattern))

				return allFiles[i];

		}

		return null;

	}

	/**

	 * @see ISoapServerDependency#getFilesToCopy()

	 */

	public TargetedFileList[] getFilesToCopy()

	{

		return (TargetedFileList[])_filesToCopy.toArray(new TargetedFileList[_filesToCopy.size()]);

	}	

}

class CustomFileFilter implements FileFilter

{

	String fileExtension;

	CustomFileFilter(String extension)

	{

		fileExtension = extension;

	}

	public boolean accept(File pathname) 

	{

		if(!pathname.isFile())

			return false;

		if(fileExtension.equals("*"))

			return true;

		return pathname.getName().endsWith(fileExtension);		

 	}	

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

import javax.wsdl.Definition;

import org.apache.muse.ws.resource.metadata.MetadataDescriptor;

import org.apache.ws.muse.descriptor.DescriptorFactory;

import org.apache.ws.muse.descriptor.DocumentRoot;

import org.apache.ws.muse.descriptor.InitParamType;

import org.apache.ws.muse.descriptor.InitialInstancesType;

import org.apache.ws.muse.descriptor.ReferenceParametersType;

import org.apache.ws.muse.descriptor.ResourceTypeType;

import org.apache.ws.muse.descriptor.WsdlType;

import org.apache.ws.muse.descriptor.impl.CapabilityTypeImpl;

import org.apache.ws.muse.descriptor.impl.ResourceTypeTypeImpl;

import org.eclipse.core.resources.IFile;

import org.eclipse.core.runtime.CoreException;

import org.eclipse.core.runtime.IConfigurationElement;

import org.eclipse.core.runtime.IExtension;

import org.eclipse.core.runtime.IExtensionPoint;

import org.eclipse.core.runtime.Platform;

import org.eclipse.emf.common.util.EMap;

import org.eclipse.tptp.wsdm.tooling.model.capabilities.Capability;

import org.eclipse.tptp.wsdm.tooling.model.manageableResourceType.ManageableResourceType;

import org.eclipse.tptp.wsdm.tooling.nls.messages.dde.internal.Messages;

import org.eclipse.tptp.wsdm.tooling.util.internal.EclipseUtils;

import org.eclipse.tptp.wsdm.tooling.util.internal.MrtUtils;

import org.eclipse.tptp.wsdm.tooling.util.internal.WsdmConstants;

import org.eclipse.tptp.wsdm.tooling.util.internal.WsdmToolingLog;

/**

 * This class analyzes the given manageable resource type and provide a resource

 * type for muse descriptor.

 */

public class BasicMrtInspector implements MrtInspector

{

	private DocumentRoot _root;

	private ResourceTypeType _resourceType;

	private ManageableResourceType _mrt;

	/**

	 * Constructor of the class

	 * @param mrt

	 * @param root

	 */

	public BasicMrtInspector(ManageableResourceType mrt,DocumentRoot root)

	{

		_root = root;

		_mrt = mrt;

	}

	/**

	 *  Get the initial instance for this manageable resource type

	 *  @return InitialInstancesType - Array of the initial instances

	 */

	public InitialInstancesType[] getInitialInstances()

	{

		InitialInstancesType instance = DescriptorFactory.eINSTANCE

				.createInitialInstancesType();

		ResourceTypeType rtClone = MRTCodeGenerationDelegate

				.cloneResourceType(_resourceType);

		instance.setResourceType(rtClone);

		ReferenceParametersType refParam = DescriptorFactory.eINSTANCE

				.createReferenceParametersType();

		instance.setReferenceParameters(refParam);

		return new InitialInstancesType[] { instance };

	}

	/**

	 *  Create a new descriptor resource type for the given manageable resource

	 *  type

	 *  @param mrtCapabilities

	 *  @return {@link ResourceTypeType}

	 */

	public ResourceTypeType inspect(Capability[] mrtCapabilities)

	{

		Mrt2DescriptorResourceType mrt2dd = new Mrt2DescriptorResourceType(

				_root, _mrt, mrtCapabilities);

		_resourceType = mrt2dd.getResourceTypeType();

		return _resourceType;

	}

	public void setMrtParentDirectory(String mrtParentDir)

	{

	}

	public void persistArtifacts()

	{

	}

	public ManageableResourceType getExtraGeneratedMrt() 

	{

		return null;

	}

	public String getExtraGeneratedMrtPersistanceLocation() 

	{

		return null;

	}

	public void inspectMetadata(ManageableResourceType mrt,

			MetadataDescriptor rmd) 

	{

	}

}

class Mrt2DescriptorResourceType

{

	private ManageableResourceType _mrt;

	private DocumentRoot _root;

	private Capability[] _mrtCapabilities;

	Mrt2DescriptorResourceType(DocumentRoot root, ManageableResourceType mrt)

	{

		this(root, mrt, null);

	}

	Mrt2DescriptorResourceType(DocumentRoot root, ManageableResourceType mrt,

			Capability[] mrtCapabilities)

	{

		_mrt = mrt;

		_root = root;

		if (mrtCapabilities == null)

			try

			{

				_mrtCapabilities = MrtUtils.getCapabilities(mrt);

			}

			catch (Exception e)

			{

			}

		else

			_mrtCapabilities = mrtCapabilities;

	}

	ResourceTypeType getResourceTypeType()

	{

		ResourceTypeTypeImpl rtd = (ResourceTypeTypeImpl) DescriptorFactory.eINSTANCE

				.createResourceTypeType();

		rtd.setUseRouterPersistence(true);

		rtd.setContextPath("/" + _mrt.getIdentifier()); //$NON-NLS-1$

		rtd

				.setJavaIdFactoryClass(WsdmConstants.MUSE_RESOURCE_ID_FACTORY_CLASS); //$NON-NLS-1$

		rtd

				.setJavaResourceClass(WsdmConstants.MUSE_RESOURCE_CLASS); //$NON-NLS-1$

		rtd.getCapability().addAll(getCapabilitiesFromMRT());

		WsdlType wsdlType = DescriptorFactory.eINSTANCE.createWsdlType();

		String mrtFileLocation = getMrtFileWorkspaceLocation();

		if (mrtFileLocation == null)

			;

		// TODO Log error not resolved location of given mrt

		else

		{

			String mrtFilePathWithoutExtn = mrtFileLocation.substring(0,

					mrtFileLocation.lastIndexOf('.'));

			wsdlType.setWsdlFile(mrtFilePathWithoutExtn + ".wsdl");

		}

		String namespace = _mrt.getNamespace();

		String prefix = getOrCreatePrefix(_root, namespace);

		String localPart = Messages.DU_PORT_TYPE_LOCAL_PART; // Only

		// "PortType"

		// should come

		// with the

		// //$NON-NLS-1$

		// prefix.

		wsdlType.setWsdlPortType(prefix + ":" + localPart);

		rtd.setWsdl(wsdlType);

		// Fix for Bug 174792 Set "validate-wsrp-schema" to "false" for the dd file generated at the codegen from MRT

		// http://bugs.eclipse.org/bugs/show_bug.cgi?id=174792

		InitParamType noValidateParam = DescriptorFactory.eINSTANCE.createInitParamType();

		noValidateParam.setParamName("validate-wsrp-schema");

		noValidateParam.setParamValue("false");		

		rtd.getInitParam().add(noValidateParam);

		return rtd;

	}

	private static String getOrCreatePrefix(DocumentRoot root, String namespace)

	{

		String prefix = getPrefix(root, namespace);

		if (prefix != null)

			return prefix;

		String newPrefix = generateNewPrefix(root);

		root.getXMLNSPrefixMap().put(newPrefix, namespace);

		return newPrefix;

	}

	private static String generateNewPrefix(DocumentRoot root)

	{

		int count = 0;

		while (isPrefixExists(root, "pfx" + count)) //$NON-NLS-1$

			count++;

		return "pfx" + count; //$NON-NLS-1$

	}

	private static boolean isPrefixExists(DocumentRoot root, String prefix)

	{

		EMap map = root.getXMLNSPrefixMap();

		Iterator keyIt = map.keySet().iterator();

		while (keyIt.hasNext())

		{

			String pfx = (String) keyIt.next();

			if (pfx.equals(prefix))

				return true;

		}

		return false;

	}

	private static String getPrefix(DocumentRoot root, String namespace)

	{

		if (root == null)

			return null;

		if (namespace == null)

			return null;

		EMap map = root.getXMLNSPrefixMap();

		Iterator keyIt = map.keySet().iterator();

		Iterator valuesIt = map.values().iterator();

		while (valuesIt.hasNext())

		{

			String ns = (String) valuesIt.next();

			String prefix = (String) keyIt.next();

			if (ns.equals(namespace))

				return prefix;

		}

		return null;

	}

	private List getCapabilitiesFromMRT()

	{

		if (_mrt == null)

			return null;

		List capDataList = new ArrayList();

		for (int i = 0; i < _mrtCapabilities.length; i++)

		{

			Capability capability = _mrtCapabilities[i];

			String capNS = ""; //$NON-NLS-1$

			Definition def = capability.getWsdlDefinition().getDefinition();

			if (def != null)

			{

				capNS = capability.getWsdlDefinition().getNamespace(

						"capabilityURI");

				if (capNS == null)

					capNS = capability.getNamespace();

			}

			CapabilityTypeImpl ctype = (CapabilityTypeImpl) DescriptorFactory.eINSTANCE

					.createCapabilityType();

			ctype.setCapabilityUri(capNS);

			String className = getJavaCapabilityClass(capNS);

			ctype.setJavaCapabilityClass(className);

			boolean isValid = validateCapability(capDataList, ctype);

			if (isValid)

				capDataList.add(ctype);

		}

		return capDataList;

	}

	private boolean validateCapability(List capDataList,

			CapabilityTypeImpl ctype)

	{

		if (capDataList == null || capDataList.size() == 0)

		{

			capDataList = new ArrayList();

			return true;

		}

		for (int i = 0; i < capDataList.size(); i++)

		{

			CapabilityTypeImpl tmp = (CapabilityTypeImpl) capDataList.get(i);

			if (tmp.getCapabilityUri().trim().equals(

					ctype.getCapabilityUri().trim()))

				return false;

		}

		return true;

	}

	private String getMrtFileWorkspaceLocation()

	{

		try

		{

			IFile mrtFile = EclipseUtils.getIFile(_mrt.eResource().getURI()

					.toString());

			return mrtFile.getFullPath().toString();

		}

		catch (CoreException e)

		{

			WsdmToolingLog.logError(e.getLocalizedMessage(), e);

		}

		return null;

	}

	private String getJavaCapabilityClass(String uri)

	{

		String ns = "org.eclipse.tptp.wsdm.model";

		IExtensionPoint iep = Platform.getExtensionRegistry()

				.getExtensionPoint(ns, "mrCapability");

		if (iep != null)

		{

			IExtension[] extensions = iep.getExtensions();

			for (int i = 0; i < extensions.length; i++)

			{

				IConfigurationElement[] ice = extensions[i]

						.getConfigurationElements();

				for (int j = 0; j < ice.length; j++)

				{

					String capURI = ice[j].getAttribute("uri");

					if (uri.equals(capURI))

					{

						String className = ice[j]

								.getAttribute("implementingClass");

						return (className == null) ? "" : className;

					}

				}

			}

		}

		return "";

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.util.ArrayList;

import java.util.List;

import org.eclipse.core.runtime.CoreException;

import org.eclipse.core.runtime.IConfigurationElement;

/**

 * This class collects the relative paths of required Axis-2 files specified in extension point.

 * So if you are extending "axisValidator" extension point, you have to extend this class and implement

 * the interface ISoapServerDependency.

 */

public abstract class SoapServerDependency implements ISoapServerDependency 

{

	protected List _requiredFiles = new ArrayList();

	public void setInitializationData(IConfigurationElement config,

			String propertyName, Object data) throws CoreException 

	{

		if(config.getName()!=null && config.getName().equals("axisValidator"))

		{

			IConfigurationElement requiredFileConfig = config.getChildren()[0];

			IConfigurationElement[] relativePathConfig = requiredFileConfig.getChildren();

			for(int i=0;i<relativePathConfig.length;i++)

			{

				if(relativePathConfig[i].getName()!=null && relativePathConfig[i].getName().equals("relativeFilePath"))

				{

					String value = relativePathConfig[i].getValue();

					if(value!=null && !value.equals("null"))

						_requiredFiles.add(value);					

				}

			}

		}

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.io.ByteArrayInputStream;

import java.io.InputStream;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import javax.xml.namespace.QName;

import org.apache.muse.util.xml.XmlUtils;

import org.apache.muse.ws.addressing.soap.SoapFault;

import org.apache.muse.ws.resource.sg.WssgConstants;

import org.apache.ws.muse.descriptor.CapabilityType;

import org.apache.ws.muse.descriptor.DescriptorFactory;

import org.apache.ws.muse.descriptor.DocumentRoot;

import org.apache.ws.muse.descriptor.InitParamType;

import org.apache.ws.muse.descriptor.InitialInstancesType;

import org.apache.ws.muse.descriptor.ReferenceParametersType;

import org.apache.ws.muse.descriptor.ResourceTypeType;

import org.apache.ws.muse.descriptor.WsdlType;

import org.eclipse.core.resources.IFile;

import org.eclipse.core.runtime.NullProgressMonitor;

import org.eclipse.emf.common.util.URI;

import org.eclipse.emf.ecore.resource.Resource;

import org.eclipse.emf.ecore.resource.ResourceSet;

import org.eclipse.emf.ecore.resource.impl.ResourceSetImpl;

import org.eclipse.tptp.wsdm.tooling.editor.ui.internal.NewNameGenerator;

import org.eclipse.tptp.wsdm.tooling.model.capabilities.Capability;

import org.eclipse.tptp.wsdm.tooling.model.manageableResourceType.ManageableResourceType;

import org.eclipse.tptp.wsdm.tooling.model.manageableResourceType.ManageableResourceTypeFactory;

import org.eclipse.tptp.wsdm.tooling.model.manageableResourceType.MembershipContentRuleType;

import org.eclipse.tptp.wsdm.tooling.util.internal.CustomMrtResourceFactoryImpl;

import org.eclipse.tptp.wsdm.tooling.util.internal.EclipseUtils;

import org.eclipse.tptp.wsdm.tooling.util.internal.MrtUtils;

import org.eclipse.tptp.wsdm.tooling.util.internal.WsdmConstants;

import org.eclipse.tptp.wsdm.tooling.util.internal.WsdmToolingLog;

import org.w3c.dom.Document;

import org.w3c.dom.Element;

/**

 * This class analyzes the given manageable resource type and provide an extra

 * resource type for muse descriptor (ServiceGroupEntry), if manageable

 * resource type contains the ServiceGroupCapability and ServiceGroupRegistration capability.

 */

public class ServiceGroupInspector implements MrtInspector

{

	private String _mrtParentDirName;

	private DocumentRoot _root;

	private ResourceTypeType _serviceGroupEntryResorceType;

	private ManageableResourceType _serviceGroupEntrymrt;

	private HashMap _prefixNamespaceMap;

	/**

	 * Constructor for the ServiceGroupIspector class.

	 * @param mrt

	 * @param root

	 */

	public ServiceGroupInspector(ManageableResourceType mrt,DocumentRoot root)

	{

		_root = root;

	}

	/**

	 * Analyzes the given manageable resource type for ServiceGroupCapability and

	 * ServiceGroupRegistrationCapability and if the capabilities available then returns the muse

	 * resource type for ServiceGroupEntry  else returns the null.

	 */

	public ResourceTypeType inspect(Capability[] mrtCapabilities) 

	{

		if(hasServiceGroupCapabilities(mrtCapabilities))

			return createServiceGroupEntryResourceType();

		return null;

	}

	private boolean hasServiceGroupCapabilities(Capability[] mrtCapabilities)

	{

		boolean hasServiceGroupCapability = false;

		boolean hasServiceGroupRegistration = false;

		for(int i =0;i<mrtCapabilities.length;i++)

		{

			if(mrtCapabilities[i].getNamespace().equals(WsdmConstants.SERVICE_GROUP_NS))

					hasServiceGroupCapability = true;

			if(mrtCapabilities[i].getNamespace().equals(WsdmConstants.SERVICE_GROUP_REG_NS))

					hasServiceGroupRegistration = true;

		}

		return hasServiceGroupCapability && hasServiceGroupRegistration;

	}

	/**

	 * Returns the initial instances

	 * @return InitialInstancesType[]

	 */

	public InitialInstancesType[] getInitialInstances() {

		InitialInstancesType instance = DescriptorFactory.eINSTANCE

				.createInitialInstancesType();

		ResourceTypeType rtClone = MRTCodeGenerationDelegate

				.cloneResourceType(_serviceGroupEntryResorceType);

		instance.setResourceType(rtClone);

		ReferenceParametersType refParam = DescriptorFactory.eINSTANCE

				.createReferenceParametersType();

		instance.setReferenceParameters(refParam);

		return new InitialInstancesType[] { instance };

	}

	/**

	 * Sets the parent directory 

	 * @param mrtParentDir

	 */

	public void setMrtParentDirectory(String mrtParentDir) {

		_mrtParentDirName = mrtParentDir;

	}

	private ResourceTypeType createServiceGroupEntryResourceType()

	{

		createServiceGroupEntryMrt();

		_serviceGroupEntryResorceType = createServiceGroupEntryMuseResourceType();

		return _serviceGroupEntryResorceType;

	}

	private void createServiceGroupEntryMrt()

	{

		 org.eclipse.tptp.wsdm.tooling.model.manageableResourceType.DocumentRoot documentRoot = ManageableResourceTypeFactory.eINSTANCE.createDocumentRoot();

		 _serviceGroupEntrymrt = ManageableResourceTypeFactory.eINSTANCE.createManageableResourceType();

		 documentRoot.setManageableResource(_serviceGroupEntrymrt);

		_serviceGroupEntrymrt.setIdentifier("ServiceGroupEntry");

		_serviceGroupEntrymrt.setNamespace("http://docs.oasis-open.org/wsrf/sgw-2");

		_serviceGroupEntrymrt.getImplements().add(WsdmConstants.MEX_CAPABILITY_LOCATION);

		_serviceGroupEntrymrt.getImplements().add(WsdmConstants.GET_CAPABILITY_LOCATION);

		_serviceGroupEntrymrt.getImplements().add(WsdmConstants.SET_CAPABILITY_LOCATION);

		_serviceGroupEntrymrt.getImplements().add(WsdmConstants.QUERY_CAPABILITY_LOCATION);

		_serviceGroupEntrymrt.getImplements().add(WsdmConstants.IMMIDIATE_RESOURCE_TERMINATION_CAPABILITY_LOCATION);

		_serviceGroupEntrymrt.getImplements().add(WsdmConstants.SCHEDULED_RESOURCE_TERMINATION_CAPABILITY_LOCATION);

		_serviceGroupEntrymrt.getImplements().add(WsdmConstants.SERVICE_GROUP_ENTRY_CAPABILITY_LOCATION);

	}

	private ResourceTypeType createServiceGroupEntryMuseResourceType()

	{

		ResourceTypeType resourceType = DescriptorFactory.eINSTANCE.createResourceTypeType();

		resourceType.setContextPath("/ServiceGroupEntry");

		resourceType.setJavaIdFactoryClass("org.apache.muse.core.routing.CounterResourceIdFactory");

		resourceType.setJavaResourceClass("org.apache.muse.ws.resource.impl.SimpleWsResource");

		WsdlType wsdlType = DescriptorFactory.eINSTANCE.createWsdlType();

		wsdlType.setWsdlFile(_mrtParentDirName + "/" + "ServiceGroupEntry.wsdl");

		_root.getXMLNSPrefixMap().put("wsrf-sge","http://docs.oasis-open.org/wsrf/sgw-2");

		wsdlType.setWsdlPortType("wsrf-sge:PortType");

		resourceType.setWsdl(wsdlType);

		CapabilityType metadataExchange = DescriptorFactory.eINSTANCE.createCapabilityType();

		metadataExchange.setCapabilityUri(WsdmConstants.MEX_NS);

		metadataExchange.setJavaCapabilityClass("");

		CapabilityType getCapability = DescriptorFactory.eINSTANCE.createCapabilityType();

		getCapability.setCapabilityUri(WsdmConstants.GET_NS);

		getCapability.setJavaCapabilityClass("");

		CapabilityType setCapability = DescriptorFactory.eINSTANCE.createCapabilityType();

		setCapability.setCapabilityUri(WsdmConstants.SET_NS);

		setCapability.setJavaCapabilityClass("");

		CapabilityType queryCapability = DescriptorFactory.eINSTANCE.createCapabilityType();

		queryCapability.setCapabilityUri(WsdmConstants.QUERY_NS);

		queryCapability.setJavaCapabilityClass("");

		CapabilityType immediateDestruction = DescriptorFactory.eINSTANCE.createCapabilityType();

		immediateDestruction.setCapabilityUri(WsdmConstants.IMMIDIATE_TERM_NS);

		immediateDestruction.setJavaCapabilityClass("");

		CapabilityType scheduledDestruction = DescriptorFactory.eINSTANCE.createCapabilityType();

		scheduledDestruction.setCapabilityUri(WsdmConstants.SCHEDULDED_TERM_NS);

		scheduledDestruction.setJavaCapabilityClass("");

		CapabilityType serviceGroupEntry = DescriptorFactory.eINSTANCE.createCapabilityType();

		serviceGroupEntry.setCapabilityUri(WsdmConstants.SERVICE_GROUP_ENTRY_NS);

		serviceGroupEntry.setJavaCapabilityClass("");

		InitParamType noValidateParam = DescriptorFactory.eINSTANCE	.createInitParamType();

		noValidateParam.setParamName("validate-wsrp-schema");

		noValidateParam.setParamValue("false");

		resourceType.getCapability().add(metadataExchange);

		resourceType.getCapability().add(getCapability);

		resourceType.getCapability().add(setCapability);

		resourceType.getCapability().add(queryCapability);

		resourceType.getCapability().add(immediateDestruction);

		resourceType.getCapability().add(scheduledDestruction);

		resourceType.getCapability().add(serviceGroupEntry);

		resourceType.getInitParam().add(noValidateParam);

		return resourceType;

	}

	private String getNamespace(String contentElement)

	{

		return contentElement.substring(1,contentElement.lastIndexOf('}'));

	}

	private void preparePrfixNamespaceMap(String contentElement)

	{

		if(!_prefixNamespaceMap.containsKey(contentElement))

		{

			NewNameGenerator nameGenerator = new NewNameGenerator("pfx");

			String prefix = nameGenerator.getNextName();

			while (nameAlreadyExists(prefix)) 

			{

				prefix = nameGenerator.getNextName();

			}

			_prefixNamespaceMap.put(contentElement, prefix);

		}

	}

	private boolean nameAlreadyExists(String prefix)

	{

		if(_prefixNamespaceMap.containsValue(prefix))

			return true;

		return false;

	}

	private String getLocalName(String namespace)

	{

		return namespace.substring(namespace.lastIndexOf('}')+1);

	}

	/**

	 * This method will returns the extra generated ManageableResourceType object equivalent to ServiceGroupEntry.

	 */

	public ManageableResourceType getExtraGeneratedMrt() {

		return _serviceGroupEntrymrt;

	}

	/**

	 * This method should return the persistance location for extra generated ManageableResourceType object equivalent to ServiceGroupEntry.

	 */

	public String getExtraGeneratedMrtPersistanceLocation() 

	{

		return _mrtParentDirName + "/"+ "ServiceGroupEntry.mrt";

	}

	/**

	 * This method will persist the extra artifacts generated at the code generation time(ServiceGroupEntry). 

	 */

	public void persistArtifacts()

	{

		try{

			ResourceSet rs = new ResourceSetImpl();

			rs.getResourceFactoryRegistry().getExtensionToFactoryMap()

			.put(Resource.Factory.Registry.DEFAULT_EXTENSION, new CustomMrtResourceFactoryImpl());

			String serviceGroupMrt = _mrtParentDirName + "/"+ "ServiceGroupEntry.mrt";

			URI uri = URI.createPlatformResourceURI(serviceGroupMrt);

			byte[] rawNewMRT = MrtUtils.serializeMRT(_serviceGroupEntrymrt, rs, uri, true);

			InputStream stream = new ByteArrayInputStream(rawNewMRT);			

			IFile subManagerMrtFile = EclipseUtils.getIFile(serviceGroupMrt);

			if (subManagerMrtFile.exists())

			{

				subManagerMrtFile.setContents(stream, true, true,

				new NullProgressMonitor());

			}

			else

			{

				subManagerMrtFile.create(stream, true,

				new NullProgressMonitor());

			}

			stream.close();			

		}

		catch(Exception e)

		{

			e.printStackTrace();

		}

	}

	/**

	 * Inspects the given manageable resource type for servicegroup/relationship kind of resource type and update the given

	 * merged RMD document for it by having the rules/relationships in it. 

	 */

	public void inspectMetadata(ManageableResourceType mrt,

			org.apache.muse.ws.resource.metadata.MetadataDescriptor rmd) 

	{

		_prefixNamespaceMap  = new HashMap();

		Capability[] mrtCapabilities = new Capability[0];

		try 

		{

			mrtCapabilities = MrtUtils.getCapabilities(mrt);

		} 

		catch (Exception e)

		{

			WsdmToolingLog.logError(e.getMessage(), e);

		}

		if(hasServiceGroupCapabilities(mrtCapabilities))

		{

			List membershipContentRule = mrt.getMembershipContentRule();

			List initialValues = new ArrayList();

			for(int i=0;i<membershipContentRule.size();i++)

			{

				MembershipContentRuleType rule = (MembershipContentRuleType) membershipContentRule.get(i);

				Element value = createMembershipContentRuleElement(rule);

				initialValues.add(value);

			}

			if(!initialValues.isEmpty());

				try 

				{

					rmd.setInitialValues(new QName(WssgConstants.NAMESPACE_URI,"MembershipContentRule"), initialValues);

				} 

				catch (SoapFault e) 

				{

					WsdmToolingLog.logError(e.getMessage(), e);

				}

		}

	}

	private Element createMembershipContentRuleElement(MembershipContentRuleType rule)

	{

		Document document = XmlUtils.createDocument();

		Element membershipContentRuleElement = XmlUtils.createElement(document, new QName(WssgConstants.NAMESPACE_URI,"MembershipContentRule"));

		List contentElements = rule.getContentElements();

		String contentElementAttribute="";

		for(int i =0 ;i<contentElements.size();i++)

		{

			String contentElement = (String)contentElements.get(i);

			String tns = getNamespace(contentElement);

			String localName = getLocalName(contentElement);

			preparePrfixNamespaceMap(tns);

			if(contentElementAttribute.length() !=0)

				contentElementAttribute =  contentElementAttribute + " " + (String)_prefixNamespaceMap.get(tns)+":"+ localName;

			else

				contentElementAttribute =(String)_prefixNamespaceMap.get(tns)+":"+ localName;

			String  xmlns = "xmlns:" + _prefixNamespaceMap.get(tns);

			 membershipContentRuleElement.setAttribute(xmlns,tns );

		}

		membershipContentRuleElement.setAttribute("ContentElements",contentElementAttribute );

		return membershipContentRuleElement;

	}

}

/*******************************************************************************

 * Copyright (c) 2007 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:

 * 	Balan Subramanian (bsubram@us.ibm.com)

 *     IBM Corporation - initial API and implementation

 *******************************************************************************/

package org.eclipse.tptp.wsdm.tooling.codegen.mrt.provisional;

import java.io.File;

import java.lang.reflect.InvocationTargetException;

import org.apache.muse.tools.generator.analyzer.Analyzer;

import org.apache.muse.tools.generator.analyzer.SimpleAnalyzer;

import org.apache.muse.tools.generator.projectizer.Projectizer;

import org.apache.muse.tools.generator.synthesizer.ServerSynthesizer;

import org.apache.muse.tools.generator.synthesizer.Synthesizer;

import org.apache.muse.tools.generator.util.ConfigurationData;

import org.apache.muse.ws.resource.metadata.MetadataDescriptor;

import org.eclipse.core.filesystem.URIUtil;

import org.eclipse.core.resources.IWorkspaceRoot;

import org.eclipse.core.resources.ResourcesPlugin;

import org.eclipse.core.runtime.ILog;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.IStatus;

import org.eclipse.core.runtime.SubProgressMonitor;

import org.eclipse.emf.edit.ui.provider.ExtendedImageRegistry;

import org.eclipse.jface.operation.IRunnableWithProgress;

import org.eclipse.jface.preference.IPreferenceStore;

import org.eclipse.jface.resource.ImageDescriptor;

import org.eclipse.jface.viewers.IStructuredSelection;

import org.eclipse.jface.wizard.Wizard;

import org.eclipse.swt.graphics.Image;

import org.eclipse.tptp.wsdm.tooling.editor.internal.Activator;

import org.eclipse.tptp.wsdm.tooling.nls.messages.mrt.internal.Messages;

import org.eclipse.tptp.wsdm.tooling.preferences.internal.Axis2ServerLocationPreferencePage;

import org.eclipse.tptp.wsdm.tooling.util.internal.EclipseUtils;

import org.eclipse.tptp.wsdm.tooling.util.internal.WsdmToolingLog;

import org.eclipse.ui.INewWizard;

import org.eclipse.ui.IWorkbench;

import org.eclipse.ui.IWorkbenchPage;

import org.eclipse.ui.PartInitException;

import org.eclipse.ui.PlatformUI;

import org.eclipse.ui.part.ViewPart;

import org.w3c.dom.Document;

/**

 * This wizard accepts projectizer parameters, runtime environment and other