blob: 5949284ad40a9465cdea6e628db1e68df22e599f [file] [log] [blame]
package org.eclipse.update.internal.core;
/*
* (c) Copyright IBM Corp. 2000, 2002.
* All Rights Reserved.
*/
import java.io.*;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.*;
import org.eclipse.core.boot.BootLoader;
import org.eclipse.core.boot.IPlatformConfiguration;
import org.eclipse.core.runtime.*;
import org.eclipse.update.configuration.*;
import org.eclipse.update.core.*;
import org.eclipse.update.core.model.*;
import org.eclipse.update.internal.model.ConfigurationActivityModel;
import org.eclipse.update.internal.model.InstallChangeParser;
/**
* This class manages the reconciliation.
*/
public class SiteReconciler extends ModelObject implements IWritable {
private SiteLocal siteLocal;
private List newFoundFeatures;
private Date date;
private static final String DEFAULT_INSTALL_CHANGE_NAME = "delta.xml";
//$NON-NLS-1$
/**
*
*/
public SiteReconciler(SiteLocal siteLocal) {
this.siteLocal = siteLocal;
}
/*
* Reconciliation is the comparison between the old preserved state and the new one from platform.cfg
*
* If the old state contained sites that are not in the new state, the old sites are not added to the state
* If the new state contains sites that were not in the old state, configure the site and configure all the found features
* If the sites are in both states, verify the features
* if the old site contained features that are not in the new site, the features are not added to the site
* if the new site contains feature that were not in the old site, configure the new feature
* if the feature is in both site (old and new), use old feature state
*
* When adding a feature to a site, we will check if the feature is broken or not.
* A feature is broken when at least one of its plugin is not installed on the site.
*
* At the end, go over all the site, get the configured features and make sure that if we find duplicates
* only one feature is configured
*
* returns true if new features have been found during a pessimistic reconcile
* otherwise returns false
*/
public boolean reconcile(boolean isOptimistic) throws CoreException {
IPlatformConfiguration platformConfig = BootLoader.getCurrentPlatformConfiguration();
IPlatformConfiguration.ISiteEntry[] newSiteEntries = platformConfig.getConfiguredSites();
IInstallConfiguration newDefaultConfiguration = siteLocal.cloneConfigurationSite(null, null, null);
IConfiguredSite[] oldConfiguredSites = new IConfiguredSite[0];
newFoundFeatures = new ArrayList();
// sites from the current configuration
if (siteLocal.getCurrentConfiguration() != null)
oldConfiguredSites = siteLocal.getCurrentConfiguration().getConfiguredSites();
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
for (int i = 0; i < oldConfiguredSites.length; i++) {
UpdateManagerPlugin.debug("Old Site :" + oldConfiguredSites[i].getSite().getURL());
}
}
// 16215
// 22913, if already optimistic, do not check
if (!isOptimistic)
isOptimistic = platformBaseChanged(oldConfiguredSites);
// check if sites from the platform are new sites or modified sites
// if they are new add them, if they are modified, compare them with the old
// one and add them
for (int siteIndex = 0; siteIndex < newSiteEntries.length; siteIndex++) {
IPlatformConfiguration.ISiteEntry currentSiteEntry = newSiteEntries[siteIndex];
URL resolvedURL = resolveSiteEntry(currentSiteEntry);
boolean found = false;
IConfiguredSite currentConfigurationSite = null;
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("New Site?:" + resolvedURL);
}
// check if SiteEntry has been possibly modified
// if it was part of the previously known configuredSite
for (int index = 0; index < oldConfiguredSites.length && !found; index++) {
currentConfigurationSite = oldConfiguredSites[index];
URL currentConfigURL = currentConfigurationSite.getSite().getURL();
if (UpdateManagerUtils.sameURL(resolvedURL, currentConfigURL)) {
found = true;
ConfiguredSite reconciledConfiguredSite = reconcile(currentConfigurationSite, isOptimistic);
reconciledConfiguredSite.setPreviousPluginPath(currentSiteEntry.getSitePolicy().getList());
newDefaultConfiguration.addConfiguredSite(reconciledConfiguredSite);
}
}
// old site not found, this is a new site, create it
if (!found) {
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Configured Site to create:" + resolvedURL);
}
ISite site = SiteManager.getSite(resolvedURL);
//site policy
IPlatformConfiguration.ISitePolicy sitePolicy = currentSiteEntry.getSitePolicy();
ConfiguredSite configSite = (ConfiguredSite) new BaseSiteLocalFactory().createConfigurationSiteModel((SiteModel) site, sitePolicy.getType());
configSite.setPlatformURLString(currentSiteEntry.getURL().toExternalForm());
configSite.setPreviousPluginPath(currentSiteEntry.getSitePolicy().getList());
// Add the features to the list of new found features
// and configure it based on reconciliation type
IFeatureReference[] newFeaturesRef = site.getFeatureReferences();
for (int i = 0; i < newFeaturesRef.length; i++) {
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
String reconciliationType = isOptimistic ? "enable (optimistic)" : "disable (pessimistic)";
UpdateManagerPlugin.debug("New Site:New Feature: " + newFeaturesRef[i].getURL() + " as " + reconciliationType);
}
if (isOptimistic) {
configSite.getConfigurationPolicy().configure(newFeaturesRef[i], true, false);
} else {
configSite.getConfigurationPolicy().unconfigure(newFeaturesRef[i], true, false);
newFoundFeatures.add(newFeaturesRef[i]);
}
}
newDefaultConfiguration.addConfiguredSite(configSite);
}
}
// verify we do not have 2 features with different version that
// are configured
checkConfiguredFeatures(newDefaultConfiguration);
// add Activity reconciliation
BaseSiteLocalFactory siteLocalFactory = new BaseSiteLocalFactory();
ConfigurationActivityModel activity = siteLocalFactory.createConfigurationAcivityModel();
activity.setAction(IActivity.ACTION_RECONCILIATION);
activity.setDate(new Date());
activity.setLabel(siteLocal.getLocationURLString());
((InstallConfiguration) newDefaultConfiguration).addActivityModel(activity);
// add the configuration as the currentConfig
siteLocal.addConfiguration(newDefaultConfiguration);
siteLocal.save();
return saveNewFeatures();
}
/**
*
*/
/*package */
URL resolveSiteEntry(IPlatformConfiguration.ISiteEntry newSiteEntry) throws CoreException {
URL resolvedURL = null;
try {
resolvedURL = Platform.resolve(newSiteEntry.getURL());
} catch (IOException e) {
throw Utilities.newCoreException(Policy.bind("SiteLocal.UnableToResolve", newSiteEntry.getURL().toExternalForm()), e);
//$NON-NLS-1$
}
return resolvedURL;
}
/**
* Compare the old state of ConfiguredSite with
* the 'real' features we found in Site
*
* getSite of ConfiguredSite contains the real features found
*
* So if ConfiguredSite.getPolicy has feature A and D as configured and C as unconfigured
* And if the Site contains features A,B and C
* We have to remove D and Configure B
*
* We copy the oldConfig without the Features
* Then we loop through the features we found on teh real site
* If they didn't exist before we add them as configured
* Otherwise we use the old policy and add them to teh new configuration site
*/
private ConfiguredSite reconcile(IConfiguredSite oldConfiguredSite, boolean isOptimistic) throws CoreException {
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Configured Site to reconfigure:" + oldConfiguredSite.getSite().getURL());
}
ConfiguredSite newConfiguredSite = createNewConfigSite(oldConfiguredSite);
ConfigurationPolicy newSitePolicy = newConfiguredSite.getConfigurationPolicy();
ConfigurationPolicy oldSitePolicy = ((ConfiguredSite) oldConfiguredSite).getConfigurationPolicy();
// check the Features that are still on the new version of the Config Site
// and the new one. Add the new Features as Configured
List toCheck = new ArrayList();
ISite site = oldConfiguredSite.getSite();
IFeatureReference[] foundFeatures = site.getFeatureReferences();
IFeatureReference[] oldConfiguredFeaturesRef = oldConfiguredSite.getFeatureReferences();
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
for (int i = 0; i < oldConfiguredFeaturesRef.length; i++) {
UpdateManagerPlugin.debug("Old feature :" + oldConfiguredFeaturesRef[i].getURL());
}
}
for (int i = 0; i < foundFeatures.length; i++) {
boolean newFeatureFound = true;
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Is this feature new? :" + foundFeatures[i].getURL());
}
// if it is an old feature, add it to the list of features to check
for (int j = 0; j < oldConfiguredFeaturesRef.length; j++) {
IFeatureReference oldFeatureRef = oldConfiguredFeaturesRef[j];
if (oldFeatureRef != null && oldFeatureRef.equals(foundFeatures[i])) {
toCheck.add(oldFeatureRef);
newFeatureFound = false;
}
}
// new feature found: add as configured if the policy is optimistic
// or [2.0.1] if the feature is optional by all the parents AND one exact parent
// (pointing to same version) is enable
if (newFeatureFound) {
configureNewFoundFeature(isOptimistic, newSitePolicy, oldSitePolicy, foundFeatures[i], oldConfiguredFeaturesRef);
}
}
// if a feature has been found in new and old state
// use old state (configured/unconfigured)
// pessimistic or optimistic
// do not call install handler as the configure/unconfigure already happened
Iterator featureIter = toCheck.iterator();
while (featureIter.hasNext()) {
IFeatureReference oldFeatureRef = (IFeatureReference) featureIter.next();
if (oldSitePolicy.isConfigured(oldFeatureRef)) {
newSitePolicy.configure(oldFeatureRef, false, false);
} else {
newSitePolicy.unconfigure(oldFeatureRef, false, false);
}
}
return newConfiguredSite;
}
/*
* Enable feature if:
* This is an optimistic reconciliation OR
* The feature is considered optional by ALL its parents AND at least one of them is enable
* Otherwise disable the feature.
*
* If all its parent consider the feature as optional but none are enable,
* do not add in the list of new found features. Just disable it.
*/
private void configureNewFoundFeature(boolean isOptimistic, ConfigurationPolicy newSitePolicy, ConfigurationPolicy oldSitePolicy, IFeatureReference foundFeature, IFeatureReference[] possibleParents) throws CoreException {
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
String reconciliationType = isOptimistic ? "enable (optimistic)" : "disable (pessimistic)";
UpdateManagerPlugin.debug("This feature is new: " + foundFeature.getURL() + " reconciled as " + reconciliationType);
}
if (isOptimistic) {
newSitePolicy.configure(foundFeature, true, false);
return;
}
IFeatureReference[] allOptionalParents = UpdateManagerUtils.getParentFeatures(foundFeature, possibleParents, true);
IFeatureReference[] allParents = UpdateManagerUtils.getParentFeatures(foundFeature, possibleParents, false);
// none of my parents consider me as optional OR I have no parents,
// consider as root feature
if (allOptionalParents.length == 0) {
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("There are no features who consider the feature as optional. Treat as root feature.");
}
newSitePolicy.unconfigure(foundFeature, true, false);
newFoundFeatures.add(foundFeature);
return;
}
//At least one of my parent considers me non optional
// consider root feature
if (allParents.length > allOptionalParents.length) {
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("At least one parent considers the feature as NON optional. Treat as root feature.");
}
newSitePolicy.unconfigure(foundFeature, true, false);
newFoundFeatures.add(foundFeature);
return;
}
for (int i = 0; i < allOptionalParents.length; i++) {
// one parent that consider me optional is enable, enable feature
if (oldSitePolicy.isConfigured(allOptionalParents[i])) {
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Found parent feature:" + allOptionalParents[i] + " as enable: Enable optional child feature:" + foundFeature);
}
newSitePolicy.configure(foundFeature, true, false);
return;
}
}
// found parent that consider me optional but they are all disable
// unconfigure feature without adding it to the list fo new found features
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("No parents are enable. Disable feature.");
}
newSitePolicy.unconfigure(foundFeature, true, false);
}
/**
* Validate we have only one configured feature per site
* even if we found multiples
*
* If we find 2 features, the one with a higher version is configured
* If they have the same version, the first feature is configured
*
* DO NOT check across sites [17980]
* If Feature1 is installed natively on Site A
* If Feature1 is installed on Site B
* If Feature1 from SiteA is removed...
*/
private void checkConfiguredFeatures(IInstallConfiguration newDefaultConfiguration) throws CoreException {
IConfiguredSite[] configuredSites = newDefaultConfiguration.getConfiguredSites();
// each configured site
for (int indexConfiguredSites = 0; indexConfiguredSites < configuredSites.length; indexConfiguredSites++) {
checkConfiguredFeatures(configuredSites[indexConfiguredSites]);
}
}
/**
* Validate we have only one configured feature of a specific id
* per configured site
*/
public static void checkConfiguredFeaturesOld(IConfiguredSite configuredSite) throws CoreException {
// NOT USED
ConfiguredSite cSite = (ConfiguredSite) configuredSite;
IFeatureReference[] configuredFeatures = cSite.getConfiguredFeatures();
ConfigurationPolicy cPolicy = cSite.getConfigurationPolicy();
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Compare features within :" + configuredSite.getSite().getURL());
}
for (int indexConfiguredFeatures = 0; indexConfiguredFeatures < configuredFeatures.length - 1; indexConfiguredFeatures++) {
IFeatureReference featureToCompare = configuredFeatures[indexConfiguredFeatures];
// within the configured site
// compare with the other configured features of this site
for (int restOfConfiguredFeatures = indexConfiguredFeatures + 1; restOfConfiguredFeatures < configuredFeatures.length; restOfConfiguredFeatures++) {
int result = compare(featureToCompare, configuredFeatures[restOfConfiguredFeatures]);
if (result != 0) {
if (result == 1) {
cPolicy.unconfigure(configuredFeatures[restOfConfiguredFeatures], true, false);
};
if (result == 2) {
cPolicy.unconfigure(featureToCompare, true, false);
}
}
}
}
}
/**
* compare two feature references
* returns 0 if the feature are different
* returns 1 if the version of feature 1 is greater than the version of feature 2
* returns 2 if opposite
*/
private static int compare(IFeatureReference featureRef1, IFeatureReference featureRef2) throws CoreException {
// TRACE
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Compare: " + featureRef1 + " && " + featureRef2);
}
if (featureRef1 == null)
return 0;
IFeature feature1 = null;
IFeature feature2 = null;
try {
feature1 = featureRef1.getFeature();
feature2 = featureRef2.getFeature();
} catch (CoreException e) {
UpdateManagerPlugin.warn(null, e);
return 0;
}
if (feature1 == null || feature2 == null) {
return 0;
}
VersionedIdentifier id1 = feature1.getVersionedIdentifier();
VersionedIdentifier id2 = feature2.getVersionedIdentifier();
if (id1 == null || id2 == null) {
return 0;
}
if (id1.getIdentifier() != null && id1.getIdentifier().equals(id2.getIdentifier())) {
PluginVersionIdentifier version1 = id1.getVersion();
PluginVersionIdentifier version2 = id2.getVersion();
if (version1 != null) {
if (version1.isGreaterThan(version2)) {
return 1;
} else {
return 2;
}
} else {
return 2;
}
}
return 0;
};
/*
*
*/
private ConfiguredSite createNewConfigSite(IConfiguredSite oldConfiguredSiteToReconcile) throws CoreException {
// create a copy of the ConfigSite based on old ConfigSite
// this is not a clone, do not copy any features
ConfiguredSite cSiteToReconcile = (ConfiguredSite) oldConfiguredSiteToReconcile;
SiteModel siteModel = cSiteToReconcile.getSiteModel();
int policy = cSiteToReconcile.getConfigurationPolicy().getPolicy();
// copy values of the old ConfigSite that should be preserved except Features
ConfiguredSite newConfigurationSite = (ConfiguredSite) new BaseSiteLocalFactory().createConfigurationSiteModel(siteModel, policy);
newConfigurationSite.isUpdatable(cSiteToReconcile.isUpdatable());
newConfigurationSite.setPlatformURLString(cSiteToReconcile.getPlatformURLString());
return newConfigurationSite;
}
/*
*
*/
private IFeatureReference[] getFeatureReferences() {
if (newFoundFeatures == null || newFoundFeatures.size() == 0)
return new IFeatureReference[0];
return (IFeatureReference[]) newFoundFeatures.toArray(arrayTypeFor(newFoundFeatures));
}
/*
*
*/
private boolean saveNewFeatures() throws CoreException {
if (getFeatureReferences().length == 0) {
UpdateManagerPlugin.warn("No new features found");
return false;
}
// recompute list of new features to only keep root features [16496]
IFeatureReference[] refs = getFeatureReferences();
newFoundFeatures = new ArrayList();
for (int i = 0; i < refs.length; i++) {
IFeatureReference[] parents = UpdateManagerUtils.getParentFeatures(refs[i], refs, false);
if (parents.length == 0)
newFoundFeatures.add(refs[i]);
}
if (getFeatureReferences().length == 0) {
UpdateManagerPlugin.warn("No root feature found when saving new features");
return false;
}
date = new Date();
String fileName = UpdateManagerUtils.getLocalRandomIdentifier(DEFAULT_INSTALL_CHANGE_NAME, date);
IPath path = UpdateManagerPlugin.getPlugin().getStateLocation();
IPath filePath = path.append(fileName);
File file = filePath.toFile();
// persist list of new features
try {
Writer writer = new Writer(file, "UTF8");
writer.write(this);
return true;
} catch (UnsupportedEncodingException e) {
throw Utilities.newCoreException(Policy.bind("SiteReconciler.UnableToEncodeConfiguration", file.getAbsolutePath()), e);
//$NON-NLS-1$
} catch (FileNotFoundException e) {
throw Utilities.newCoreException(Policy.bind("SiteReconciler.UnableToSaveStateIn", file.getAbsolutePath()), e);
//$NON-NLS-1$
}
}
/*
* @see IWritable#write(int, PrintWriter)
*/
public void write(int indent, PrintWriter w) {
String gap = ""; //$NON-NLS-1$
for (int i = 0; i < indent; i++)
gap += " "; //$NON-NLS-1$
String increment = ""; //$NON-NLS-1$
for (int i = 0; i < IWritable.INDENT; i++)
increment += " "; //$NON-NLS-1$
// CHANGE tag
w.print(gap + "<" + InstallChangeParser.CHANGE + " ");
//$NON-NLS-1$ //$NON-NLS-2$
long time = (date != null) ? date.getTime() : 0L;
w.println("date=\"" + time + "\" >"); //$NON-NLS-1$ //$NON-NLS-2$
// NEW FEATURE
w.println(gap + increment + "<" + InstallChangeParser.NEW_FEATURE + " >");
// FEATURE REF
IFeatureReference[] references = getFeatureReferences();
String URLFeatureString = null;
String URLSiteString = null;
if (references != null) {
for (int index = 0; index < references.length; index++) {
IFeatureReference ref = references[index];
if (ref.getURL() != null) {
ISite featureSite = ref.getSite();
URLFeatureString = UpdateManagerUtils.getURLAsString(featureSite.getURL(), ref.getURL());
w.print(gap + increment + increment + "<" + InstallChangeParser.REFERENCE + " ");
//$NON-NLS-1$
w.println("siteURL = \"" + Writer.xmlSafe(getURLSiteString(featureSite)) + "\" ");
//$NON-NLS-1$ //$NON-NLS-2$
w.println(gap + increment + increment + increment + "featureURL=\"" + Writer.xmlSafe(URLFeatureString) + "\" />");
//$NON-NLS-1$ //$NON-NLS-2$
}
w.println(""); //$NON-NLS-1$
}
}
// END NEW FEATURE
w.println(gap + increment + "</" + InstallChangeParser.NEW_FEATURE + " >");
// end
w.println(gap + "</" + InstallChangeParser.CHANGE + ">");
//$NON-NLS-1$ //$NON-NLS-2$
}
/*
* Returns the Site URL, attempting to replace it by platform: URL if needed
*/
private String getURLSiteString(ISite site) {
IConfiguredSite[] configSites = siteLocal.getCurrentConfiguration().getConfiguredSites();
for (int i = 0; i < configSites.length; i++) {
if (configSites[i] instanceof ConfiguredSite) {
ConfiguredSite cSite = (ConfiguredSite) configSites[i];
if (site.equals(cSite.getSite())) {
return cSite.getPlatformURLString();
}
}
}
return site.getURL().toExternalForm();
}
/*
* return true if the platformBase URL is not the same
* we thought it is. In this case we should reconcile in an optimistic way
*/
private boolean platformBaseChanged(IConfiguredSite[] oldConfiguredSites) {
if (oldConfiguredSites == null) {
UpdateManagerPlugin.warn("No previous configured sites. Optimistic reconciliation.");
return true;
}
String platformString = "platform:/base/";
URL platformURL = null;
try {
platformURL = new URL(platformString);
} catch (MalformedURLException e) {
UpdateManagerPlugin.warn("Unable to resolve platform:/base/. Check you are running a Platform", e);
return true;
}
URL resolvedCurrentBaseURL = null;
try {
resolvedCurrentBaseURL = Platform.resolve(platformURL);
} catch (IOException e) {
UpdateManagerPlugin.warn("Error while resolving platform:/base/. Check you are running a Platform", e);
return true;
}
// find the 'platform:/base/' configuredSite
int index = 0;
boolean found = false;
ConfiguredSite cSite = null;
while (!found && index < oldConfiguredSites.length) {
if (oldConfiguredSites[index] instanceof ConfiguredSite) {
cSite = (ConfiguredSite) oldConfiguredSites[index];
if (platformString.equalsIgnoreCase(cSite.getPlatformURLString())) {
found = true;
}
}
index++;
}
if (!found) {
UpdateManagerPlugin.warn("Unable to find an old consifured site with platform:/base/ as a platform URL");
return true;
}
if (cSite == null) {
UpdateManagerPlugin.warn("The configuredSite that contains the platform is null");
return true;
}
if (UpdateManagerUtils.sameURL(resolvedCurrentBaseURL, cSite.getSite().getURL())) {
UpdateManagerPlugin.warn("Platform URL found are the same:" + resolvedCurrentBaseURL + " : " + cSite.getSite().getURL());
return false;
}
UpdateManagerPlugin.warn("Platform URL found is different than the one previously saved. Reconcile optimistically:" + resolvedCurrentBaseURL + " : " + cSite.getSite().getURL());
return true;
}
/**
* Validate the list of configured features eliminating extra
* entries (if possible). Make sure we do not leave configured
* nested features with "holes" (ie. unconfigured children)
*/
public static void checkConfiguredFeatures(IConfiguredSite configuredSite) throws CoreException {
// Note: if we hit errors in the various computation
// methods and throw a CoreException, we will not catch it
// in this method. Consequently we will not attempt to
// unconfigure any "extra" features because we would
// likely get it wrong. The platform will run with extra features
// configured. The runtime will eliminate extra plugins based
// on runtime binding rules.
// determine "proposed" list of configured features
ConfiguredSite cSite = (ConfiguredSite) configuredSite;
// debug
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Validate configuration of site " + cSite.getSite().getURL());
}
IFeatureReference[] configuredRefs = cSite.getConfiguredFeatures();
ArrayList configuredFeatures = new ArrayList();
for (int i = 0; i < configuredRefs.length; i++) {
IFeature feature = configuredRefs[i].getFeature();
configuredFeatures.add(feature);
// debug
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug(" configured feature " + feature.getVersionedIdentifier().toString());
}
}
// find "unique" top level features (latest version)
ArrayList features = computeTopFeatures(configuredFeatures);
// expand features (compute full nesting structures).
features = expandFeatures(features);
// compute extra features
ArrayList extras = diff(configuredFeatures, features);
// unconfigure extra features
ConfigurationPolicy cPolicy = cSite.getConfigurationPolicy();
for (int i = 0; i < extras.size(); i++) {
IFeature feature = (IFeature) extras.get(i);
IFeatureReference ref = cSite.getSite().getFeatureReference(feature);
cPolicy.unconfigure(ref, true, false);
// debug
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Unconfiguring \"extra\" feature " + feature.getVersionedIdentifier().toString());
}
}
}
private static ArrayList computeTopFeatures(ArrayList features) throws CoreException {
// start with the features passed in
ArrayList result = new ArrayList();
result.addAll(features);
IFeature[] list = (IFeature[]) result.toArray(new IFeature[0]);
// remove all features that nest in some other feature
for (int i = 0; i < list.length; i++) {
IFeatureReference[] children = list[i].getIncludedFeatureReferences();
for (int j = 0; j < children.length; j++) {
IFeature child = null;
try {
children[j].getFeature();
result.remove(child);
} catch (CoreException e) {
// if optional, it may not exist, do not throw error for that
if (!children[j].isOptional())
throw e;
}
}
}
// debug
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Computed top-level features");
for (int i = 0; i < result.size(); i++) {
UpdateManagerPlugin.debug(" " + ((IFeature) result.get(i)).getVersionedIdentifier().toString());
}
}
// eliminate duplicate versions (keep latest)
list = (IFeature[]) result.toArray(new IFeature[0]);
for (int i = 0; i < list.length - 1; i++) {
IFeature left = list[i];
VersionedIdentifier leftVid = left.getVersionedIdentifier();
for (int j = i + 1; j < list.length; j++) {
IFeature right = list[j];
VersionedIdentifier rightVid = right.getVersionedIdentifier();
if (leftVid.getIdentifier().equals(rightVid.getIdentifier())) {
// duplicate versions ... keep latest
if (rightVid.getVersion().isGreaterOrEqualTo(leftVid.getVersion())) {
result.remove(left);
// debug
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Removing \"duplicate\" " + left.getVersionedIdentifier().toString());
}
break;
}
}
}
}
// return resulting top level features
return result;
}
private static ArrayList expandFeatures(ArrayList features) throws CoreException {
ArrayList result = new ArrayList();
// expand all top level features
for (int i = 0; i < features.size(); i++) {
expandFeature((IFeature) features.get(i), result);
}
return result;
}
private static void expandFeature(IFeature feature, ArrayList features) throws CoreException {
// add feature
if (!features.contains(feature)) {
features.add(feature);
// debug
if (UpdateManagerPlugin.DEBUG && UpdateManagerPlugin.DEBUG_SHOW_RECONCILER) {
UpdateManagerPlugin.debug("Retaining configured feature " + feature.getVersionedIdentifier().toString());
}
}
// add nested children to the list
IFeatureReference[] children = feature.getIncludedFeatureReferences();
for (int j = 0; j < children.length; j++) {
IFeature child = null;
try {
child = children[j].getFeature();
} catch (CoreException e) {
// the child may be missing, warn and return
if (children[j].isOptional()) {
UpdateManagerPlugin.warn("", e);
return;
}
throw e;
}
expandFeature(child, features);
}
}
private static ArrayList diff(ArrayList left, ArrayList right) {
ArrayList result = new ArrayList();
// determine difference (left "minus" right)
for (int i = 0; i < left.size(); i++) {
IFeature feature = (IFeature) left.get(i);
if (!right.contains(feature))
result.add(feature);
}
return result;
}
}