<extension

       id="metadataRepository"

       point="org.eclipse.equinox.p2.metadata.repository.metadataRepositories">

    <factory

          class="org.eclipse.equinox.internal.p2.engine.repo.ProfileMetadataRepositoryFactory">

    </factory>

    <filter

          suffix="profile">

    </filter>

 </extension>

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

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

 *     IBM Corporation - initial API and implementation

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

package org.eclipse.equinox.internal.p2.engine.repo;

import java.net.URL;

import java.util.Map;

import org.eclipse.core.runtime.*;

import org.eclipse.equinox.internal.provisional.p2.core.ProvisionException;

import org.eclipse.equinox.internal.provisional.p2.metadata.repository.IMetadataRepository;

import org.eclipse.equinox.internal.provisional.spi.p2.metadata.repository.IMetadataRepositoryFactory;

public class ProfileMetadataRepositoryFactory implements IMetadataRepositoryFactory {

	/* (non-Javadoc)

	 * @see org.eclipse.equinox.internal.provisional.spi.p2.metadata.repository.IMetadataRepositoryFactory#create(java.net.URL, java.lang.String, java.lang.String, java.util.Map)

	 */

	public IMetadataRepository create(URL location, String name, String type, Map properties) {

		return null;

	}

	/*

	 * (non-Javadoc)

	 * @see org.eclipse.equinox.internal.provisional.spi.p2.metadata.repository.IMetadataRepositoryFactory#validate(java.net.URL, org.eclipse.core.runtime.IProgressMonitor)

	 */

	public IStatus validate(URL location, IProgressMonitor monitor) {

		try {

			ProfileMetadataRepository.validate(location, monitor);

		} catch (ProvisionException e) {

			return e.getStatus();

		}

		return Status.OK_STATUS;

	}

	/* (non-Javadoc)

	 * @see org.eclipse.equinox.internal.provisional.spi.p2.metadata.repository.IMetadataRepositoryFactory#load(java.net.URL, org.eclipse.core.runtime.IProgressMonitor)

	 */

	public IMetadataRepository load(URL location, IProgressMonitor monitor) throws ProvisionException {

		return new ProfileMetadataRepository(location, monitor);

	}

}

package org.eclipse.equinox.internal.p2.engine.repo;

import java.io.File;

import java.net.MalformedURLException;

import java.net.URL;

import java.util.*;

import org.eclipse.core.runtime.*;

import org.eclipse.equinox.internal.p2.core.helpers.LogHelper;

import org.eclipse.equinox.internal.p2.core.helpers.ServiceHelper;

import org.eclipse.equinox.internal.p2.engine.EngineActivator;

import org.eclipse.equinox.internal.p2.engine.SimpleProfileRegistry;

import org.eclipse.equinox.internal.provisional.p2.core.ProvisionException;

import org.eclipse.equinox.internal.provisional.p2.core.eventbus.IProvisioningEventBus;

import org.eclipse.equinox.internal.provisional.p2.core.repository.IRepository;

import org.eclipse.equinox.internal.provisional.p2.core.repository.RepositoryEvent;

import org.eclipse.equinox.internal.provisional.p2.engine.IProfile;

import org.eclipse.equinox.internal.provisional.p2.query.Collector;

import org.eclipse.equinox.internal.provisional.p2.query.Query;

import org.eclipse.equinox.internal.provisional.spi.p2.metadata.repository.AbstractMetadataRepository;

public class ProfileMetadataRepository extends AbstractMetadataRepository {

	public static final String TYPE = "org.eclipse.equinox.p2.engine.repo.metadataRepository"; //$NON-NLS-1$

	public static final Integer VERSION = new Integer(1);

	private IProfile profile;

	public ProfileMetadataRepository(URL location, IProgressMonitor monitor) throws ProvisionException {

		super(location.toExternalForm(), TYPE, VERSION.toString(), location, null, null, null);

		try {

			profile = getProfile(location);

		} catch (RuntimeException e) {

			throw new ProvisionException(new Status(IStatus.ERROR, EngineActivator.ID, ProvisionException.REPOSITORY_FAILED_READ, e.getMessage(), e));

		}

		publishArtifactRepos();

	}

	private void publishArtifactRepos() {

		List artifactRepos = new ArrayList();

		String bundlePool = profile.getProperty(IProfile.PROP_CACHE);

		if (bundlePool != null) {

			try {

				artifactRepos.add(new File(bundlePool).toURL().toExternalForm());

			} catch (MalformedURLException e) {

				LogHelper.log(new Status(IStatus.WARNING, EngineActivator.ID, "invalid repo reference with location: " + bundlePool, e)); //$NON-NLS-1$

			}

		}

		String sharedBundlePool = profile.getProperty(IProfile.PROP_SHARED_CACHE);

		if (sharedBundlePool != null) {

			try {

				artifactRepos.add(new File(sharedBundlePool).toURL().toExternalForm());

			} catch (MalformedURLException e) {

				LogHelper.log(new Status(IStatus.WARNING, EngineActivator.ID, "invalid repo reference with location: " + sharedBundlePool, e)); //$NON-NLS-1$

			}

		}

		String dropinRepositories = profile.getProperty("org.eclipse.equinox.p2.cache.extensions");

		if (dropinRepositories != null) {

			StringTokenizer tokenizer = new StringTokenizer(dropinRepositories, "|");

			while (tokenizer.hasMoreTokens()) {

				artifactRepos.add(tokenizer.nextToken());

			}

		}

		IProvisioningEventBus bus = (IProvisioningEventBus) ServiceHelper.getService(EngineActivator.getContext(), IProvisioningEventBus.SERVICE_NAME);

		if (bus == null)

			return;

		for (Iterator it = artifactRepos.iterator(); it.hasNext();) {

			String repo = (String) it.next();

			try {

				URL artifactRepo = new URL(repo);

				bus.publishEvent(new RepositoryEvent(artifactRepo, IRepository.TYPE_ARTIFACT, RepositoryEvent.DISCOVERED, true));

			} catch (MalformedURLException e) {

				LogHelper.log(new Status(IStatus.WARNING, EngineActivator.ID, "invalid repo reference with location: " + repo, e)); //$NON-NLS-1$

			}

		}

	}

	public void initialize(RepositoryState state) {

		// nothing to do

	}

	public Collector query(Query query, Collector collector, IProgressMonitor monitor) {

		return profile.query(query, collector, monitor);

	}

	public static void validate(URL location, IProgressMonitor monitor) throws ProvisionException {

		try {

			getProfile(location);

		} catch (RuntimeException e) {

			throw new ProvisionException(new Status(IStatus.ERROR, "org.eclipse.equinox.p2.engine", ProvisionException.REPOSITORY_FAILED_READ, e.getMessage(), e));

		}

	}

	private static IProfile getProfile(URL location) {

		if (!"file".equalsIgnoreCase(location.getProtocol()))

			throw new IllegalArgumentException("Profile Registry must use 'file' protocol.");

		File registryDirectory = new File(location.getPath());

		if (!registryDirectory.isDirectory())

			throw new IllegalArgumentException("Profile Registry not found. " + registryDirectory + " is not a directory.");

		String query = location.getQuery();

		//expect profileid=xyz

		if (query == null || query.indexOf("profileid=") == -1)

			throw new IllegalArgumentException("'profileid' query parameter not specified.");

		String profileid = query.substring(query.indexOf("profileid=") + "profileid=".length());

		if (profileid == null || profileid.length() == 0 || profileid.indexOf('&') != -1)

			throw new IllegalArgumentException("bad 'profileid' query parameter: " + profileid);

		SimpleProfileRegistry profileRegistry = new SimpleProfileRegistry(registryDirectory, null, false);

		IProfile profile = profileRegistry.getProfile(profileid);

		if (profile == null)

			throw new IllegalArgumentException("No profile found for : " + profileid);

		return profile;

	}

}