/* ModeShape (http://www.modeshape.org)" target="alexandria_uri">http://www.modeshape.org) 
      See the COPYRIGHT.txt file distributed with this work for information 
      regarding copyright ownership. Some portions may be licensed 
      to Red Hat, Inc. under one or more contributor license agreements. 
      See the AUTHORS.txt file in the distribution for a full listing of individual contributors.  
      ModeShape is free software. Unless otherwise indicated, all code in 
      ModeShape is licensed to you under the terms of the GNU Lesser General Public License as 
      published by the Free Software Foundation; either version 2.1 of 
      the License, or (at your option) any later version. 
     ModeShape is distributed in the hope that it will be useful, 
     but WITHOUT ANY WARRANTY; without even the implied warranty of 
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 
     Lesser General Public License for more details. 
     You should have received a copy of the GNU Lesser General Public 
     License along with this software; if not, write to the Free 
     Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 
     02110-1301 USA, or see the	FSF site: http://www.fsf.org. 
   */
  package org.modeshape.rhq.plugin;
  
  
  import java.io.File;
  import java.io.InputStream;
  import java.util.HashSet;
  import java.util.List;
  import java.util.Map;
  import java.util.Set;
  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.jboss.deployers.spi.management.ManagementView;
  import org.jboss.managed.api.ComponentType;
  import org.jboss.managed.api.ManagedComponent;
  import org.jboss.managed.api.ManagedProperty;
  import org.mc4j.ems.connection.EmsConnection;
  import org.modeshape.rhq.plugin.util.PluginConstants;
  import org.modeshape.rhq.plugin.util.ProfileServiceUtil;
  import org.rhq.core.domain.configuration.Configuration;
  import org.rhq.core.domain.configuration.ConfigurationUpdateStatus;
  import org.rhq.core.domain.configuration.definition.ConfigurationTemplate;
  import org.rhq.core.domain.content.PackageDetailsKey;
  import org.rhq.core.domain.content.PackageType;
  import org.rhq.core.domain.content.transfer.DeployPackageStep;
  import org.rhq.core.domain.content.transfer.DeployPackagesResponse;
  import org.rhq.core.domain.content.transfer.RemovePackagesResponse;
  import org.rhq.core.domain.content.transfer.ResourcePackageDetails;
  import org.rhq.core.domain.measurement.AvailabilityType;
  import org.rhq.core.domain.measurement.MeasurementReport;
  import org.rhq.core.domain.measurement.MeasurementScheduleRequest;
  import org.rhq.core.domain.resource.ResourceType;
  import org.rhq.core.pluginapi.configuration.ConfigurationFacet;
  import org.rhq.core.pluginapi.configuration.ConfigurationUpdateReport;
  import org.rhq.core.pluginapi.content.ContentFacet;
  import org.rhq.core.pluginapi.content.ContentServices;
  import org.rhq.core.pluginapi.content.version.PackageVersions;
  import org.rhq.core.pluginapi.inventory.CreateChildResourceFacet;
  import org.rhq.core.pluginapi.inventory.DeleteResourceFacet;
  import org.rhq.core.pluginapi.inventory.InvalidPluginConfigurationException;
  import org.rhq.core.pluginapi.inventory.ResourceComponent;
  import org.rhq.core.pluginapi.inventory.ResourceContext;
  import org.rhq.core.pluginapi.measurement.MeasurementFacet;
  import org.rhq.core.pluginapi.operation.OperationFacet;
  import org.rhq.core.pluginapi.operation.OperationResult;
  import org.rhq.plugins.jbossas5.ApplicationServerComponent;
  import org.rhq.plugins.jbossas5.ProfileServiceComponent;
  import org.rhq.plugins.jbossas5.connection.ProfileServiceConnection;
  
  /**
   * This class implements required RHQ interfaces and provides common logic used
   * by all MetaMatrix components.
   */
  @SuppressWarnings({ "unchecked" })
  public abstract class Facet implements ProfileServiceComponent<ResourceComponent>, MeasurementFacet,
  		OperationFacet, ConfigurationFacet, ContentFacet, DeleteResourceFacet,
  		CreateChildResourceFacet {
  
  	protected final Log LOG = LogFactory.getLog(PluginConstants.DEFAULT_LOGGER_CATEGORY);
  
  	/**
  	 * Represents the resource configuration of the custom product being
  	 * managed.
  	 */
  	protected Configuration resourceConfiguration;
  
  	/**
  	 * All AMPS plugins are stateful - this context contains information that
  	 * your resource component can use when performing its processing.
  	 */
  	protected ResourceContext<?> resourceContext;
  
  	protected String name;
  
  	private String identifier;
  
  	protected String componentType;
  
  	protected boolean isAvailable = false;
  
  	private final Log log = LogFactory.getLog(this.getClass());
 
 	/**
 	 * The name of the ManagedDeployment (e.g.:
 	 * C:/opt/jboss-5.0.0.GA/server/default/deploy/foo.vdb).
 	 */
 	protected String deploymentName;
 
 	private PackageVersions versions = null;
 
 	/**
 	 * Name of the backing package type that will be used when discovering
 	 * packages. This corresponds to the name of the package type defined in the
 	 * plugin descriptor. For simplicity, the package type for VDBs is called
 	 * "vdb". This is still unique within the context of the parent resource
 	 * type and lets this class use the same package type name in both cases.
 	 */
 	private static final String PKG_TYPE_VDB = "vdb";
 
 	/**
 	 * Architecture string used in describing discovered packages.
 	 */
 	private static final String ARCHITECTURE = "noarch";
 
 	abstract String getComponentType();
 
 	/**
 	 * This is called when your component has been started with the given
 	 * context. You normally initialize some internal state of your component as
 	 * well as attempt to make a stateful connection to your managed resource.
 	 * @param context 
 	 * 
 	 * @see ResourceComponent#start(ResourceContext)
 	 */
 	public void start(ResourceContext context) {
 		resourceContext = context;
 		deploymentName = context.getResourceKey();
 	}
 
 	/**
 	 * This is called when the component is being stopped, usually due to the
 	 * plugin container shutting down. You can perform some cleanup here; though
 	 * normally not much needs to be done here.
 	 * 
 	 * @see ResourceComponent#stop()
 	 */
 	public void stop() {
 		this.isAvailable = false;
 	}
 
 	/**
 	 * @return the resourceConfiguration
 	 */
 	public Configuration getResourceConfiguration() {
 		return resourceConfiguration;
 	}
 
 	/**
 	 * @param resourceConfiguration
 	 *            the resourceConfiguration to set
 	 */
 	public void setResourceConfiguration(Configuration resourceConfiguration) {
 		this.resourceConfiguration = resourceConfiguration;
 	}
 	
 	public String componentType() {
 		return name;
 	}
 
 	protected void setComponentName(String componentName) {
 		this.name = componentName;
 	}
 
 	public String getComponentIdentifier() {
 		return identifier;
 	}
 
 	protected void setComponentIdentifier(String identifier) {
 		this.identifier = identifier;
 	}
 
 	protected void setOperationArguments(String name,
 			Configuration configuration, Map<String, Object> argumentMap) {
 		// moved this logic up to the associated implemented class
 		throw new InvalidPluginConfigurationException(
 				"Not implemented on component type " + this.getComponentType()
 						+ " named " + this.name);
 
 	}
 
 	protected void setMetricArguments(String name, Configuration configuration,
 			Map<String, Object> argumentMap) {
 		// moved this logic up to the associated implemented class
 		throw new InvalidPluginConfigurationException(
 				"Not implemented on component type " + this.getComponentType()
 						+ " named " + this.name);
 
 	}
 
 //	protected void execute(final ExecutedResult result, final Map valueMap) {
 //		DQPManagementView dqp = new DQPManagementView();
 //
 //		dqp.executeOperation(result, valueMap);
 //
 //	}
 
 	/*
 	 * (non-Javadoc) This method is called by JON to check the availability of
 	 * the inventoried component on a time scheduled basis
 	 * 
 	 * @see org.rhq.core.pluginapi.inventory.ResourceComponent#getAvailability()
 	 */
 	public AvailabilityType getAvailability() {
 
 		LOG.debug("Checking availability of  " + identifier); //$NON-NLS-1$
 
 		return AvailabilityType.UP;
 	}
 
 	/**
 	 * Helper method that indicates the latest status based on the last
 	 * getAvailabilit() call.
 	 * 
 	 * @return true if the resource is available
 	 */
 	protected boolean isAvailable() {
 		return true;
 	}
 
 	/**
 	 * The plugin container will call this method when your resource component
 	 * has been scheduled to collect some measurements now. It is within this
 	 * method that you actually talk to the managed resource and collect the
 	 * measurement data that is has emitted.
 	 * 
 	 * @see MeasurementFacet#getValues(MeasurementReport, Set)
 	 */
 	public abstract void getValues(MeasurementReport arg0,
 			Set<MeasurementScheduleRequest> arg1) throws Exception;
 
 	/**
 	 * The plugin container will call this method when it wants to invoke an
 	 * operation on your managed resource. Your plugin will connect to the
 	 * managed resource and invoke the analogous operation in your own custom
 	 * way.
 	 * 
 	 * @see OperationFacet#invokeOperation(String, Configuration)
 	 */
 	public OperationResult invokeOperation(String name,
 			Configuration configuration) {
 //		Map valueMap = new HashMap();
 //
 //		Set operationDefinitionSet = this.resourceContext.getResourceType()
 //				.getOperationDefinitions();
 //
 //		ExecutedResult result = new ExecutedOperationResultImpl(this
 //				.getComponentType(), name, operationDefinitionSet);
 //
 //		setOperationArguments(name, configuration, valueMap);
 //
 //		execute(result, valueMap);
 
 		return null; //((ExecutedOperationResultImpl) result).getOperationResult();
 
 	}
 
 	/**
 	 * The plugin container will call this method and it needs to obtain the
 	 * current configuration of the managed resource. Your plugin will obtain
 	 * the managed resource's configuration in your own custom way and populate
 	 * the returned Configuration object with the managed resource's
 	 * configuration property values.
 	 * 
 	 * @see ConfigurationFacet#loadResourceConfiguration()
 	 */
 	public Configuration loadResourceConfiguration() {
 		// here we simulate the loading of the managed resource's configuration
 
 		if (resourceConfiguration == null) {
 			// for this example, we will create a simple dummy configuration to
 			// start with.
 			// note that it is empty, so we're assuming there are no required
 			// configs in the plugin descriptor.
 			resourceConfiguration = this.resourceContext
 					.getPluginConfiguration();
 		}
 
 		Configuration config = resourceConfiguration;
 
 		return config;
 	}
 
 	/**
 	 * The plugin container will call this method when it has a new
 	 * configuration for your managed resource. Your plugin will re-configure
 	 * the managed resource in your own custom way, setting its configuration
 	 * based on the new values of the given configuration.
 	 * 
 	 * @see ConfigurationFacet#updateResourceConfiguration(ConfigurationUpdateReport)
 	 */
 	public void updateResourceConfiguration(ConfigurationUpdateReport report) {
 
 		resourceConfiguration = report.getConfiguration().deepCopy();
 
 		Configuration resourceConfig = report.getConfiguration();
 		
 		ManagementView managementView = null; 
 		ComponentType componentType = null;
 //		if (this.getComponentType().equals(PluginConstants.ComponentType.VDB.NAME)) {
 //			componentType = new ComponentType(
 //					PluginConstants.ComponentType.VDB.TYPE,
 //					PluginConstants.ComponentType.VDB.SUBTYPE);
 //		} else {
 //			report.setStatus(ConfigurationUpdateStatus.FAILURE);
 //			report.setErrorMessage("Update not implemented for the component type.");
 //		}
 
 		ManagedComponent managedComponent = null;
 		report.setStatus(ConfigurationUpdateStatus.SUCCESS);
 		try {
 			
 			managementView = ProfileServiceUtil.getManagementView(
 				ProfileServiceUtil.getProfileService(), true);
 			managedComponent = managementView.getComponent(this.name, componentType);
 			Map<String, ManagedProperty> managedProperties = managedComponent
 					.getProperties();
 
 			ProfileServiceUtil.convertConfigurationToManagedProperties(
 					managedProperties, resourceConfig, resourceContext
 							.getResourceType());
 
 			try {
 				managementView.updateComponent(managedComponent);				
 			} catch (Exception e) {
 				LOG.error("Unable to update component ["
 						+ managedComponent.getName() + "] of type "
 						+ componentType + ".", e);
 				report.setStatus(ConfigurationUpdateStatus.FAILURE);
 				report.setErrorMessageFromThrowable(e);
 			}
 		} catch (Exception e) {
 			LOG.error("Unable to process update request", e);
 			report.setStatus(ConfigurationUpdateStatus.FAILURE);
 			report.setErrorMessageFromThrowable(e);
 		}
 	}
 
 	/**
 	 * @return Map<String, ManagedProperty>
 	 * @throws Exception
 	 */
 	protected Map<String, ManagedProperty> getManagedProperties()
 			throws Exception {
 		return null;
 	}
 
 	/**
 	 * @param managedComponent
 	 * @throws Exception
 	 */
 	protected void updateComponent(ManagedComponent managedComponent)
 			throws Exception {
 		log.trace("Updating " + this.name + " with component "
 				+ managedComponent.toString() + "...");
 		ManagementView managementView = ProfileServiceUtil.getManagementView(
 				ProfileServiceUtil.getProfileService(), false);
 		managementView.updateComponent(managedComponent);
 		
 	}
 
 	@Override
 	public void deleteResource() throws Exception {
 
 //		DeploymentManager deploymentManager = ProfileServiceUtil
 //				.getDeploymentManager();
 //
 //		log.debug("Stopping deployment [" + this.deploymentName + "]...");
 //		DeploymentProgress progress = deploymentManager
 //				.stop(this.deploymentName);
 //		DeploymentStatus stopStatus = DeploymentUtils.run(progress);
 //		if (stopStatus.isFailed()) {
 //			log.error("Failed to stop deployment '" + this.deploymentName
 //					+ "'.", stopStatus.getFailure());
 //			throw new Exception("Failed to stop deployment '"
 //					+ this.deploymentName + "' - cause: "
 //					+ stopStatus.getFailure());
 //		}
 //		log.debug("Removing deployment [" + this.deploymentName + "]...");
 //		progress = deploymentManager.remove(this.deploymentName);
 //		DeploymentStatus removeStatus = DeploymentUtils.run(progress);
 //		if (removeStatus.isFailed()) {
 //			log.error("Failed to remove deployment '" + this.deploymentName
 //					+ "'.", removeStatus.getFailure());
 //			throw new Exception("Failed to remove deployment '"
 //					+ this.deploymentName + "' - cause: "
 //					+ removeStatus.getFailure());
 //		}
 
 	}
 
 	@Override
 	public DeployPackagesResponse deployPackages(
 			Set<ResourcePackageDetails> packages,
 			ContentServices contentServices) {
 		return null;
 	}
 
 	@Override
 	public Set<ResourcePackageDetails> discoverDeployedPackages(PackageType arg0) {
 
 		File deploymentFile = null;
 
 		if (this.deploymentName != null) {
 			deploymentFile = new File(deploymentName.substring(7));
 		}
 
 		if (deploymentFile == null || !deploymentFile.exists())
 			throw new IllegalStateException("Deployment file '"
 					+ deploymentFile + "' for " + this.getComponentType()
 					+ " does not exist.");
 
 		String fileName = deploymentFile.getName();
 		org.rhq.core.pluginapi.content.version.PackageVersions packageVersions = loadPackageVersions();
 		String version = packageVersions.getVersion(fileName);
 		if (version == null) {
 			// This is either the first time we've discovered this VDB, or
 			// someone purged the PC's data dir.
 			version = "1.0";
 			packageVersions.putVersion(fileName, version);
 			packageVersions.saveToDisk();
 		}
 
 		// Package name is the deployment's file name (e.g. foo.ear).
 		PackageDetailsKey key = new PackageDetailsKey(fileName, version,
 				PKG_TYPE_VDB, ARCHITECTURE);
 		ResourcePackageDetails packageDetails = new ResourcePackageDetails(key);
 		packageDetails.setFileName(fileName);
 		packageDetails.setLocation(deploymentFile.getPath());
 		if (!deploymentFile.isDirectory())
 			packageDetails.setFileSize(deploymentFile.length());
 		packageDetails.setFileCreatedDate(null); 
 		Set<ResourcePackageDetails> packages = new HashSet<ResourcePackageDetails>();
 		packages.add(packageDetails);
 
 		return packages;
 	}
 
 	@Override
 	public List<DeployPackageStep> generateInstallationSteps(
 			ResourcePackageDetails arg0) {
 		return null;
 	}
 
 	@Override
 	public RemovePackagesResponse removePackages(
 			Set<ResourcePackageDetails> arg0) {
 		return null;
 	}
 
 	@Override
 	public InputStream retrievePackageBits(ResourcePackageDetails packageDetails) {
 		return null;
 	}
 
 	protected static Configuration getDefaultPluginConfiguration(
 			ResourceType resourceType) {
 		ConfigurationTemplate pluginConfigDefaultTemplate = resourceType
 				.getPluginConfigurationDefinition().getDefaultTemplate();
 		return (pluginConfigDefaultTemplate != null) ? pluginConfigDefaultTemplate
 				.createConfiguration()
 				: new Configuration();
 	}
 
 	/**
 	 * Returns an instantiated and loaded versions store access point.
 	 * 
 	 * @return will not be <code>null</code>
 	 */
 	private org.rhq.core.pluginapi.content.version.PackageVersions loadPackageVersions() {
 		if (this.versions == null) {
 			ResourceType resourceType = resourceContext.getResourceType();
 			String pluginName = resourceType.getPlugin();
 			File dataDirectoryFile = resourceContext.getDataDirectory();
 			dataDirectoryFile.mkdirs();
 			String dataDirectory = dataDirectoryFile.getAbsolutePath();
 			log.trace("Creating application versions store with plugin name ["
 					+ pluginName + "] and data directory [" + dataDirectory
 					+ "]");
 			this.versions = new PackageVersions(pluginName, dataDirectory);
 			this.versions.loadFromDisk();
 		}
 
 		return this.versions;
 	}
 	
 	public ProfileServiceConnection getConnection() {
 		return ((ApplicationServerComponent) this.resourceContext
 				.getParentResourceComponent()).getConnection();
 	}
 
 	public EmsConnection getEmsConnection() {
 		// TODO Auto-generated method stub
 		return null;
 	}
 
 }