org.eclipse.mylyn.tasks.core/src/org/eclipse/mylyn/internal/tasks/core/util/RepositoryConnectorExtensionReader.java - mylyn/org.eclipse.mylyn.tasks - Git at Google

 /*******************************************************************************
  * Copyright (c) 2013 Tasktop Technologies and others.
  *
  * This program and the accompanying materials are made available under the
  * terms of the Eclipse Public License v. 2.0 which is available at
  * https://www.eclipse.org/legal/epl-2.0
  *
  * SPDX-License-Identifier: EPL-2.0
  *
  * Contributors:
  *     Tasktop Technologies - initial API and implementation
  *******************************************************************************/

 package org.eclipse.mylyn.internal.tasks.core.util;

 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;

 import org.eclipse.core.runtime.Assert;
 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.ISafeRunnable;
 import org.eclipse.core.runtime.IStatus;
 import org.eclipse.core.runtime.MultiStatus;
 import org.eclipse.core.runtime.Platform;
 import org.eclipse.core.runtime.SafeRunner;
 import org.eclipse.core.runtime.Status;
 import org.eclipse.mylyn.commons.core.StatusHandler;
 import org.eclipse.mylyn.internal.tasks.core.ITasksCoreConstants;
 import org.eclipse.mylyn.internal.tasks.core.TaskRepositoryManager;
 import org.eclipse.mylyn.internal.tasks.core.externalization.TaskListExternalizer;
 import org.eclipse.mylyn.tasks.core.AbstractRepositoryConnector;
 import org.eclipse.mylyn.tasks.core.AbstractRepositoryMigrator;
 import org.eclipse.mylyn.tasks.core.spi.RepositoryConnectorContributor;
 import org.eclipse.mylyn.tasks.core.spi.RepositoryConnectorDescriptor;
 import org.eclipse.osgi.util.NLS;

 public class RepositoryConnectorExtensionReader {

 	public static final String ELMNT_REPOSITORY_MIGRATOR = "repositoryMigrator"; //$NON-NLS-1$

 	public static final String ELMNT_REPOSITORY_CONNECTOR = "connectorCore"; //$NON-NLS-1$

 	public static final String ATTR_ID = "id"; //$NON-NLS-1$

 	public static final String ATTR_CLASS = "class"; //$NON-NLS-1$

 	private static final String EXTENSION_CONTRIBUTORS = ITasksCoreConstants.ID_PLUGIN
 			+ ".repositoryConnectorContributor"; //$NON-NLS-1$

 	private static final String EXTENSION_REPOSITORIES = ITasksCoreConstants.ID_PLUGIN + ".repositories"; //$NON-NLS-1$

 	private static class ConnectorFactory {

 		private AbstractRepositoryConnector connector;

 		private AbstractRepositoryMigrator repositoryMigrator;

 		private final RepositoryConnectorDescriptor descriptor;

 		private final String pluginId;

 		public ConnectorFactory(RepositoryConnectorDescriptor descriptor, String pluginId) {
 			Assert.isNotNull(pluginId);
 			Assert.isNotNull(pluginId);
 			this.descriptor = descriptor;
 			this.pluginId = pluginId;
 		}

 		public String getConnectorKind() {
 			return (getConnector() != null) ? getConnector().getConnectorKind() : null;
 		}

 		public AbstractRepositoryConnector getConnector() {
 			return connector;
 		}

 		public String getPluginId() {
 			return pluginId;
 		}

 		public AbstractRepositoryMigrator getRepositoryMigrator() {
 			return repositoryMigrator;
 		}

 		public IStatus createConnector() {
 			Assert.isTrue(connector == null);
 			try {
 				connector = descriptor.createRepositoryConnector();
 				if (connector != null) {
 					return Status.OK_STATUS;
 				} else {
 					return new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,
 							NLS.bind("Could not load connector core contributed by ''{0}''", getPluginId())); //$NON-NLS-1$
 				}
 			} catch (Throwable e) {
 				return new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,
 						NLS.bind("Could not load connector core contributed by ''{0}''", getPluginId()), e); //$NON-NLS-1$
 			}
 		}

 		public IStatus createRepositoryMigrator() {
 			Assert.isTrue(repositoryMigrator == null);
 			try {
 				repositoryMigrator = descriptor.createRepositoryMigrator();
 				if (repositoryMigrator != null) {
 					return Status.OK_STATUS;
 				} else {
 					return Status.CANCEL_STATUS;
 				}
 			} catch (Throwable e) {
 				return new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,
 						NLS.bind("Could not load repository migrator extension contributed by ''{0}''", getPluginId()), //$NON-NLS-1$
 						e);
 			}
 		}

 	}

 	private static class ExtensionPointBasedConnectorDescriptor extends RepositoryConnectorDescriptor {

 		IConfigurationElement element;

 		IConfigurationElement repositoryMigratorElement;

 		public ExtensionPointBasedConnectorDescriptor(IConfigurationElement element) {
 			this.element = element;
 		}

 		@Override
 		public AbstractRepositoryConnector createRepositoryConnector() {
 			try {
 				return (AbstractRepositoryConnector) element.createExecutableExtension(ATTR_CLASS);
 			} catch (CoreException e) {
 				throw new RuntimeException(e);
 			}
 		}

 		@Override
 		public AbstractRepositoryMigrator createRepositoryMigrator() {
 			if (repositoryMigratorElement == null) {
 				return null;
 			}
 			try {
 				return (AbstractRepositoryMigrator) repositoryMigratorElement.createExecutableExtension(ATTR_CLASS);
 			} catch (CoreException e) {
 				throw new RuntimeException(e);
 			}
 		}

 		public String getPluginId() {
 			return element.getContributor().getName();
 		}

 		public String getId() {
 			return element.getAttribute(ATTR_ID);
 		}

 	}

 	private final ContributorBlackList blackList = new ContributorBlackList();

 	private final TaskRepositoryManager repositoryManager;

 	private final List<ConnectorFactory> factories = new ArrayList<ConnectorFactory>();

 	private final List<RepositoryConnectorDescriptor> descriptors = new ArrayList<RepositoryConnectorDescriptor>();

 	private final MultiStatus result;

 	public RepositoryConnectorExtensionReader(TaskListExternalizer taskListExternalizer,
 			TaskRepositoryManager repositoryManager) {
 		this.repositoryManager = repositoryManager;
 		this.result = new MultiStatus(ITasksCoreConstants.ID_PLUGIN, 0, "Repository connectors failed to load.", null); //$NON-NLS-1$
 	}

 	public void loadConnectors(IExtensionPoint repositoriesExtensionPoint) {
 		Map<String, List<ConnectorFactory>> factoryById = readFromRepositoriesExtensionPoint(
 				repositoriesExtensionPoint);
 		checkForConflicts(factoryById);
 	}

 	public void loadConnectorsFromRepositoriesExtension() {
 		loadConnectors(Platform.getExtensionRegistry().getExtensionPoint(EXTENSION_REPOSITORIES));
 	}

 	public void loadConnectorsFromContributors() {
 		readFromContributorsExtensionPoint();
 	}

 	public void registerConnectors() {
 		Map<String, List<ConnectorFactory>> factoryByConnectorKind = createConnectorInstances();
 		checkForConflicts(factoryByConnectorKind);

 		registerConnectorInstances();

 		if (!result.isOK()) {
 			StatusHandler.log(result);
 		}
 	}

 	private void readFromContributorsExtensionPoint() {
 		IExtensionPoint repositoriesExtensionPoint = Platform.getExtensionRegistry()
 				.getExtensionPoint(EXTENSION_CONTRIBUTORS);
 		IExtension[] extensions = repositoriesExtensionPoint.getExtensions();
 		for (IExtension extension : extensions) {
 			IConfigurationElement[] elements = extension.getConfigurationElements();
 			for (IConfigurationElement element : elements) {
 				addDescriptorsFromContributor(element);
 			}
 		}
 	}

 	private void addDescriptorsFromContributor(final IConfigurationElement element) {
 		SafeRunner.run(new ISafeRunnable() {

 			@Override
 			public void run() throws Exception {
 				RepositoryConnectorContributor contributor = (RepositoryConnectorContributor) element
 						.createExecutableExtension(ATTR_CLASS);
 				Collection<RepositoryConnectorDescriptor> descriptors = contributor.getDescriptors();
 				if (descriptors == null) {
 					result.add(new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN, NLS.bind(
 							"Could not load connectors contributed by ''{0}''", element.getContributor().getName()))); //$NON-NLS-1$
 					return;
 				}
 				for (RepositoryConnectorDescriptor descriptor : descriptors) {
 					if (descriptor != null) {
 						factories.add(new ConnectorFactory(descriptor, element.getContributor().getName()));
 					}
 				}
 				RepositoryConnectorExtensionReader.this.descriptors.addAll(descriptors);
 			}

 			@Override
 			public void handleException(Throwable exception) {
 				// ignore

 			}
 		});
 	}

 	public Map<String, List<ConnectorFactory>> createConnectorInstances() {
 		Map<String, List<ConnectorFactory>> factoryByConnectorKind = new LinkedHashMap<String, List<ConnectorFactory>>();
 		for (ConnectorFactory descriptor : factories) {
 			IStatus status = descriptor.createConnector();
 			if (status.isOK() && descriptor.getConnector() != null) {
 				add(factoryByConnectorKind, descriptor.getConnectorKind(), descriptor);
 			} else {
 				result.add(status);
 			}
 		}
 		return factoryByConnectorKind;
 	}

 	private void registerConnectorInstances() {
 		List<AbstractRepositoryMigrator> repositoryMigrators = new ArrayList<AbstractRepositoryMigrator>();

 		for (ConnectorFactory descriptor : factories) {
 			if (descriptor.getConnector() != null) {
 				repositoryManager.addRepositoryConnector(descriptor.getConnector());

 				IStatus status = descriptor.createRepositoryMigrator();
 				if (status.isOK() && descriptor.getRepositoryMigrator() != null) {
 					repositoryMigrators.add(descriptor.getRepositoryMigrator());
 				} else if (status.getSeverity() == IStatus.CANCEL) {
 					// ignore
 				} else {
 					result.add(status);
 				}
 			}
 		}

 		repositoryManager.initialize(repositoryMigrators);
 	}

 	private Map<String, List<ConnectorFactory>> readFromRepositoriesExtensionPoint(
 			IExtensionPoint repositoriesExtensionPoint) {
 		// read core and migrator extensions to check for id conflicts
 		Map<String, List<ConnectorFactory>> factoryById = new LinkedHashMap<String, List<ConnectorFactory>>();

 		IExtension[] repositoryExtensions = repositoriesExtensionPoint.getExtensions();
 		for (IExtension repositoryExtension : repositoryExtensions) {
 			IConfigurationElement[] elements = repositoryExtension.getConfigurationElements();
 			ExtensionPointBasedConnectorDescriptor descriptor = null;
 			IConfigurationElement repositoryMigratorElement = null;
 			for (IConfigurationElement element : elements) {
 				if (element.getName().equals(ELMNT_REPOSITORY_CONNECTOR)) {
 					descriptor = new ExtensionPointBasedConnectorDescriptor(element);
 				} else if (element.getName().equals(ELMNT_REPOSITORY_MIGRATOR)) {
 					repositoryMigratorElement = element;
 				}
 			}
 			if (descriptor != null) {
 				descriptor.repositoryMigratorElement = repositoryMigratorElement;
 				ConnectorFactory factory = new ConnectorFactory(descriptor, descriptor.getPluginId());
 				factories.add(factory);
 				if (descriptor.getId() != null) {
 					add(factoryById, descriptor.getId(), factory);
 				}
 			}
 		}
 		return factoryById;
 	}

 	private void checkForConflicts(Map<String, List<ConnectorFactory>> descriptorById) {
 		for (Map.Entry<String, List<ConnectorFactory>> entry : descriptorById.entrySet()) {
 			if (entry.getValue().size() > 1) {
 				MultiStatus status = new MultiStatus(ITasksCoreConstants.ID_PLUGIN, 0,
 						NLS.bind("Connector ''{0}'' registered by multiple extensions.", entry.getKey()), null); //$NON-NLS-1$
 				for (ConnectorFactory factory : entry.getValue()) {
 					status.add(new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN, NLS.bind(
 							"All extensions contributed by ''{0}'' have been disabled.", factory.getPluginId()), null)); //$NON-NLS-1$
 					blackList.disableContributor(factory.getPluginId());
 					factories.remove(factory);
 				}
 				result.add(status);
 			}
 		}
 	}

 	private void add(Map<String, List<ConnectorFactory>> descriptorById, String id, ConnectorFactory descriptor) {
 		List<ConnectorFactory> list = descriptorById.get(id);
 		if (list == null) {
 			list = new ArrayList<ConnectorFactory>();
 			descriptorById.put(id, list);
 		}
 		list.add(descriptor);
 	}

 	public List<RepositoryConnectorDescriptor> getDescriptors() {
 		return new ArrayList<RepositoryConnectorDescriptor>(descriptors);
 	}

 	public ContributorBlackList getBlackList() {
 		return blackList;
 	}

 	public IStatus getResult() {
 		return result;
 	}

 }
	/*******************************************************************************
	* Copyright (c) 2013 Tasktop Technologies and others.
	*
	* This program and the accompanying materials are made available under the
	* terms of the Eclipse Public License v. 2.0 which is available at
	* https://www.eclipse.org/legal/epl-2.0
	*
	* SPDX-License-Identifier: EPL-2.0
	*
	* Contributors:
	* Tasktop Technologies - initial API and implementation
	*******************************************************************************/

	package org.eclipse.mylyn.internal.tasks.core.util;

	import java.util.ArrayList;
	import java.util.Collection;
	import java.util.LinkedHashMap;
	import java.util.List;
	import java.util.Map;

	import org.eclipse.core.runtime.Assert;
	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.ISafeRunnable;
	import org.eclipse.core.runtime.IStatus;
	import org.eclipse.core.runtime.MultiStatus;
	import org.eclipse.core.runtime.Platform;
	import org.eclipse.core.runtime.SafeRunner;
	import org.eclipse.core.runtime.Status;
	import org.eclipse.mylyn.commons.core.StatusHandler;
	import org.eclipse.mylyn.internal.tasks.core.ITasksCoreConstants;
	import org.eclipse.mylyn.internal.tasks.core.TaskRepositoryManager;
	import org.eclipse.mylyn.internal.tasks.core.externalization.TaskListExternalizer;
	import org.eclipse.mylyn.tasks.core.AbstractRepositoryConnector;
	import org.eclipse.mylyn.tasks.core.AbstractRepositoryMigrator;
	import org.eclipse.mylyn.tasks.core.spi.RepositoryConnectorContributor;
	import org.eclipse.mylyn.tasks.core.spi.RepositoryConnectorDescriptor;
	import org.eclipse.osgi.util.NLS;

	public class RepositoryConnectorExtensionReader {

	public static final String ELMNT_REPOSITORY_MIGRATOR = "repositoryMigrator"; //$NON-NLS-1$

	public static final String ELMNT_REPOSITORY_CONNECTOR = "connectorCore"; //$NON-NLS-1$

	public static final String ATTR_ID = "id"; //$NON-NLS-1$

	public static final String ATTR_CLASS = "class"; //$NON-NLS-1$

	private static final String EXTENSION_CONTRIBUTORS = ITasksCoreConstants.ID_PLUGIN
	+ ".repositoryConnectorContributor"; //$NON-NLS-1$

	private static final String EXTENSION_REPOSITORIES = ITasksCoreConstants.ID_PLUGIN + ".repositories"; //$NON-NLS-1$

	private static class ConnectorFactory {

	private AbstractRepositoryConnector connector;

	private AbstractRepositoryMigrator repositoryMigrator;

	private final RepositoryConnectorDescriptor descriptor;

	private final String pluginId;

	public ConnectorFactory(RepositoryConnectorDescriptor descriptor, String pluginId) {
	Assert.isNotNull(pluginId);
	Assert.isNotNull(pluginId);
	this.descriptor = descriptor;
	this.pluginId = pluginId;
	}

	public String getConnectorKind() {
	return (getConnector() != null) ? getConnector().getConnectorKind() : null;
	}

	public AbstractRepositoryConnector getConnector() {
	return connector;
	}

	public String getPluginId() {
	return pluginId;
	}

	public AbstractRepositoryMigrator getRepositoryMigrator() {
	return repositoryMigrator;
	}

	public IStatus createConnector() {
	Assert.isTrue(connector == null);
	try {
	connector = descriptor.createRepositoryConnector();
	if (connector != null) {
	return Status.OK_STATUS;
	} else {
	return new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,
	NLS.bind("Could not load connector core contributed by ''{0}''", getPluginId())); //$NON-NLS-1$
	}
	} catch (Throwable e) {
	return new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,
	NLS.bind("Could not load connector core contributed by ''{0}''", getPluginId()), e); //$NON-NLS-1$
	}
	}

	public IStatus createRepositoryMigrator() {
	Assert.isTrue(repositoryMigrator == null);
	try {
	repositoryMigrator = descriptor.createRepositoryMigrator();
	if (repositoryMigrator != null) {
	return Status.OK_STATUS;
	} else {
	return Status.CANCEL_STATUS;
	}
	} catch (Throwable e) {
	return new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,
	NLS.bind("Could not load repository migrator extension contributed by ''{0}''", getPluginId()), //$NON-NLS-1$
	e);
	}
	}

	}

	private static class ExtensionPointBasedConnectorDescriptor extends RepositoryConnectorDescriptor {

	IConfigurationElement element;

	IConfigurationElement repositoryMigratorElement;

	public ExtensionPointBasedConnectorDescriptor(IConfigurationElement element) {
	this.element = element;
	}

	@Override
	public AbstractRepositoryConnector createRepositoryConnector() {
	try {
	return (AbstractRepositoryConnector) element.createExecutableExtension(ATTR_CLASS);
	} catch (CoreException e) {
	throw new RuntimeException(e);
	}
	}

	@Override
	public AbstractRepositoryMigrator createRepositoryMigrator() {
	if (repositoryMigratorElement == null) {
	return null;
	}
	try {
	return (AbstractRepositoryMigrator) repositoryMigratorElement.createExecutableExtension(ATTR_CLASS);
	} catch (CoreException e) {
	throw new RuntimeException(e);
	}
	}

	public String getPluginId() {
	return element.getContributor().getName();
	}

	public String getId() {
	return element.getAttribute(ATTR_ID);
	}

	}

	private final ContributorBlackList blackList = new ContributorBlackList();

	private final TaskRepositoryManager repositoryManager;

	private final List<ConnectorFactory> factories = new ArrayList<ConnectorFactory>();

	private final List<RepositoryConnectorDescriptor> descriptors = new ArrayList<RepositoryConnectorDescriptor>();

	private final MultiStatus result;

	public RepositoryConnectorExtensionReader(TaskListExternalizer taskListExternalizer,
	TaskRepositoryManager repositoryManager) {
	this.repositoryManager = repositoryManager;
	this.result = new MultiStatus(ITasksCoreConstants.ID_PLUGIN, 0, "Repository connectors failed to load.", null); //$NON-NLS-1$
	}

	public void loadConnectors(IExtensionPoint repositoriesExtensionPoint) {
	Map<String, List<ConnectorFactory>> factoryById = readFromRepositoriesExtensionPoint(
	repositoriesExtensionPoint);
	checkForConflicts(factoryById);
	}

	public void loadConnectorsFromRepositoriesExtension() {
	loadConnectors(Platform.getExtensionRegistry().getExtensionPoint(EXTENSION_REPOSITORIES));
	}

	public void loadConnectorsFromContributors() {
	readFromContributorsExtensionPoint();
	}

	public void registerConnectors() {
	Map<String, List<ConnectorFactory>> factoryByConnectorKind = createConnectorInstances();
	checkForConflicts(factoryByConnectorKind);

	registerConnectorInstances();

	if (!result.isOK()) {
	StatusHandler.log(result);
	}
	}

	private void readFromContributorsExtensionPoint() {
	IExtensionPoint repositoriesExtensionPoint = Platform.getExtensionRegistry()
	.getExtensionPoint(EXTENSION_CONTRIBUTORS);
	IExtension[] extensions = repositoriesExtensionPoint.getExtensions();
	for (IExtension extension : extensions) {
	IConfigurationElement[] elements = extension.getConfigurationElements();
	for (IConfigurationElement element : elements) {
	addDescriptorsFromContributor(element);
	}
	}
	}

	private void addDescriptorsFromContributor(final IConfigurationElement element) {
	SafeRunner.run(new ISafeRunnable() {

	@Override
	public void run() throws Exception {
	RepositoryConnectorContributor contributor = (RepositoryConnectorContributor) element
	.createExecutableExtension(ATTR_CLASS);
	Collection<RepositoryConnectorDescriptor> descriptors = contributor.getDescriptors();
	if (descriptors == null) {
	result.add(new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN, NLS.bind(
	"Could not load connectors contributed by ''{0}''", element.getContributor().getName()))); //$NON-NLS-1$
	return;
	}
	for (RepositoryConnectorDescriptor descriptor : descriptors) {
	if (descriptor != null) {
	factories.add(new ConnectorFactory(descriptor, element.getContributor().getName()));
	}
	}
	RepositoryConnectorExtensionReader.this.descriptors.addAll(descriptors);
	}

	@Override
	public void handleException(Throwable exception) {
	// ignore

	}
	});
	}

	public Map<String, List<ConnectorFactory>> createConnectorInstances() {
	Map<String, List<ConnectorFactory>> factoryByConnectorKind = new LinkedHashMap<String, List<ConnectorFactory>>();
	for (ConnectorFactory descriptor : factories) {
	IStatus status = descriptor.createConnector();
	if (status.isOK() && descriptor.getConnector() != null) {
	add(factoryByConnectorKind, descriptor.getConnectorKind(), descriptor);
	} else {
	result.add(status);
	}
	}
	return factoryByConnectorKind;
	}

	private void registerConnectorInstances() {
	List<AbstractRepositoryMigrator> repositoryMigrators = new ArrayList<AbstractRepositoryMigrator>();

	for (ConnectorFactory descriptor : factories) {
	if (descriptor.getConnector() != null) {
	repositoryManager.addRepositoryConnector(descriptor.getConnector());

	IStatus status = descriptor.createRepositoryMigrator();
	if (status.isOK() && descriptor.getRepositoryMigrator() != null) {
	repositoryMigrators.add(descriptor.getRepositoryMigrator());
	} else if (status.getSeverity() == IStatus.CANCEL) {
	// ignore
	} else {
	result.add(status);
	}
	}
	}

	repositoryManager.initialize(repositoryMigrators);
	}

	private Map<String, List<ConnectorFactory>> readFromRepositoriesExtensionPoint(
	IExtensionPoint repositoriesExtensionPoint) {
	// read core and migrator extensions to check for id conflicts
	Map<String, List<ConnectorFactory>> factoryById = new LinkedHashMap<String, List<ConnectorFactory>>();

	IExtension[] repositoryExtensions = repositoriesExtensionPoint.getExtensions();
	for (IExtension repositoryExtension : repositoryExtensions) {
	IConfigurationElement[] elements = repositoryExtension.getConfigurationElements();
	ExtensionPointBasedConnectorDescriptor descriptor = null;
	IConfigurationElement repositoryMigratorElement = null;
	for (IConfigurationElement element : elements) {
	if (element.getName().equals(ELMNT_REPOSITORY_CONNECTOR)) {
	descriptor = new ExtensionPointBasedConnectorDescriptor(element);
	} else if (element.getName().equals(ELMNT_REPOSITORY_MIGRATOR)) {
	repositoryMigratorElement = element;
	}
	}
	if (descriptor != null) {
	descriptor.repositoryMigratorElement = repositoryMigratorElement;
	ConnectorFactory factory = new ConnectorFactory(descriptor, descriptor.getPluginId());
	factories.add(factory);
	if (descriptor.getId() != null) {
	add(factoryById, descriptor.getId(), factory);
	}
	}
	}
	return factoryById;
	}

	private void checkForConflicts(Map<String, List<ConnectorFactory>> descriptorById) {
	for (Map.Entry<String, List<ConnectorFactory>> entry : descriptorById.entrySet()) {
	if (entry.getValue().size() > 1) {
	MultiStatus status = new MultiStatus(ITasksCoreConstants.ID_PLUGIN, 0,
	NLS.bind("Connector ''{0}'' registered by multiple extensions.", entry.getKey()), null); //$NON-NLS-1$
	for (ConnectorFactory factory : entry.getValue()) {
	status.add(new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN, NLS.bind(
	"All extensions contributed by ''{0}'' have been disabled.", factory.getPluginId()), null)); //$NON-NLS-1$
	blackList.disableContributor(factory.getPluginId());
	factories.remove(factory);
	}
	result.add(status);
	}
	}
	}

	private void add(Map<String, List<ConnectorFactory>> descriptorById, String id, ConnectorFactory descriptor) {
	List<ConnectorFactory> list = descriptorById.get(id);
	if (list == null) {
	list = new ArrayList<ConnectorFactory>();
	descriptorById.put(id, list);
	}
	list.add(descriptor);
	}

	public List<RepositoryConnectorDescriptor> getDescriptors() {
	return new ArrayList<RepositoryConnectorDescriptor>(descriptors);
	}

	public ContributorBlackList getBlackList() {
	return blackList;
	}

	public IStatus getResult() {
	return result;
	}

	}