/*******************************************************************************
 * Copyright (c) 2010, 2011 Obeo.
 * 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:
 *     Obeo - initial API and implementation
 *******************************************************************************/
package org.eclipse.mylyn.docs.intent.client.synchronizer;

import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.Set;

import org.eclipse.emf.common.util.URI;
import org.eclipse.emf.ecore.EObject;
import org.eclipse.mylyn.docs.intent.client.synchronizer.listeners.GeneratedElementListener;
import org.eclipse.mylyn.docs.intent.collab.common.query.CompilationStatusQuery;
import org.eclipse.mylyn.docs.intent.collab.common.query.TraceabilityInformationsQuery;
import org.eclipse.mylyn.docs.intent.collab.handlers.RepositoryObjectHandler;
import org.eclipse.mylyn.docs.intent.collab.handlers.adapters.ReadOnlyException;
import org.eclipse.mylyn.docs.intent.collab.handlers.adapters.RepositoryAdapter;
import org.eclipse.mylyn.docs.intent.collab.handlers.impl.ReadWriteRepositoryObjectHandlerImpl;
import org.eclipse.mylyn.docs.intent.collab.handlers.impl.notification.elementList.ElementListAdapter;
import org.eclipse.mylyn.docs.intent.collab.handlers.impl.notification.elementList.ElementListNotificator;
import org.eclipse.mylyn.docs.intent.collab.handlers.notification.Notificator;
import org.eclipse.mylyn.docs.intent.collab.repository.Repository;
import org.eclipse.mylyn.docs.intent.collab.repository.RepositoryConnectionException;
import org.eclipse.mylyn.docs.intent.core.compiler.CompilationStatusManager;
import org.eclipse.mylyn.docs.intent.core.compiler.TraceabilityIndex;
import org.eclipse.mylyn.docs.intent.core.compiler.TraceabilityIndexEntry;

/**
 * Creates a Synchronizer client.
 * 
 * @author <a href="mailto:alex.lagarde@obeo.fr">Alex Lagarde</a>
 */
public final class SynchronizerCreator {

	/**
	 * SynchronizerCreator constructor.
	 */
	private SynchronizerCreator() {

	}

	/**
	 * Creates a Synchronizer client.
	 * 
	 * @param repository
	 *            is the repository containing the generated models to synchronize
	 * @param generatedElementListener
	 *            a listener on the generated elements
	 * @return the created Synchronizer client
	 * @throws RepositoryConnectionException
	 *             if a connection to the given repository cannot be established
	 * @throws ReadOnlyException
	 *             if no sufficient rights to write on the repository
	 */
	public static SynchronizerRepositoryClient createSynchronizer(Repository repository,
			GeneratedElementListener generatedElementListener) throws RepositoryConnectionException,
			ReadOnlyException {

		// Step 1 : we initialize the listened elements
		final RepositoryAdapter repositoryAdapter = repository.createRepositoryAdapter();
		Set<EObject> listenedElements = new LinkedHashSet<EObject>();

		repositoryAdapter.openSaveContext();
		TraceabilityIndex traceabilityIndex = new TraceabilityInformationsQuery(repositoryAdapter)
				.getOrCreateTraceabilityIndex();
		CompilationStatusManager statusManager = new CompilationStatusQuery(repositoryAdapter)
				.getOrCreateCompilationStatusManager();

		listenedElements.add(traceabilityIndex);
		// Step 2 : create the adapter and the handler for these types

		RepositoryObjectHandler handler = new ReadWriteRepositoryObjectHandlerImpl(repositoryAdapter);

		ElementListAdapter adapter = new ElementListAdapter();

		Notificator listenedElementsNotificator = new ElementListNotificator(listenedElements, adapter,
				repositoryAdapter);
		handler.addNotificator(listenedElementsNotificator);

		// Step 3 : create the synchronizer
		SynchronizerRepositoryClient synchronizerClient = new SynchronizerRepositoryClient(traceabilityIndex,
				statusManager, repository);
		synchronizerClient.addRepositoryObjectHandler(handler);
		synchronizerClient.setGeneratedElementListener(generatedElementListener);

		// Step 4 : we ask the generatedElementListener to listen to all generated resources
		Iterator<TraceabilityIndexEntry> indexEntryIterator = ((TraceabilityIndex)traceabilityIndex)
				.getEntries().iterator();
		while (indexEntryIterator.hasNext()) {
			TraceabilityIndexEntry indexEntry = indexEntryIterator.next();
			if (indexEntry.getResourceDeclaration() != null
					&& indexEntry.getResourceDeclaration().getUri() != null) {
				String resourceURI = indexEntry.getResourceDeclaration().getUri().toString();
				synchronizerClient.getSynchronizer().updateSynchronizedElementsListeners(
						URI.createURI(resourceURI.replace("\"", "")));
			}
		}
		return synchronizerClient;

	}
}