Author: gnodet
Date: Mon Jul 28 02:05:48 2008
New Revision: 680295
URL: http://svn.apache.org/viewvc?rev=680295&view=rev
Log:
SMX4-78: Add a mojo to the features-maven-plugin to help generate a m2
repository for the kernel
Added:
servicemix/maven-plugins/features-maven-plugin/trunk/src/main/java/org/apache/servicemix/tooling/features/AddFeaturesToRepoMojo.java
Removed:
servicemix/maven-plugins/features-maven-plugin/trunk/src/main/java/org/apache/servicemix/tooling/features/GenerateDependsFileMojo.java
Added:
servicemix/maven-plugins/features-maven-plugin/trunk/src/main/java/org/apache/servicemix/tooling/features/AddFeaturesToRepoMojo.java
URL:
http://svn.apache.org/viewvc/servicemix/maven-plugins/features-maven-plugin/trunk/src/main/java/org/apache/servicemix/tooling/features/AddFeaturesToRepoMojo.java?rev=680295&view=auto
==============================================================================
---
servicemix/maven-plugins/features-maven-plugin/trunk/src/main/java/org/apache/servicemix/tooling/features/AddFeaturesToRepoMojo.java
(added)
+++
servicemix/maven-plugins/features-maven-plugin/trunk/src/main/java/org/apache/servicemix/tooling/features/AddFeaturesToRepoMojo.java
Mon Jul 28 02:05:48 2008
@@ -0,0 +1,309 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.servicemix.tooling.features;
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Properties;
+import java.util.Hashtable;
+import java.util.Set;
+import java.util.HashSet;
+import java.io.File;
+import java.io.IOException;
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+import java.io.BufferedOutputStream;
+import java.io.FileOutputStream;
+import java.io.FileInputStream;
+import java.net.URI;
+import java.net.URL;
+
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+
+import org.w3c.dom.*;
+
+import org.apache.maven.plugin.MojoExecutionException;
+import org.apache.maven.plugin.MojoFailureException;
+import org.apache.maven.artifact.Artifact;
+import org.apache.maven.artifact.DefaultArtifact;
+import org.apache.maven.artifact.handler.DefaultArtifactHandler;
+import org.apache.maven.artifact.versioning.VersionRange;
+import org.xml.sax.SAXException;
+
+/**
+ * Generates the features XML file
+ *
+ * @version $Revision: 1.1 $
+ * @goal add-features-to-repo
+ * @phase compile
+ * @execute phase="compile"
+ * @requiresDependencyResolution runtime
+ * @inheritByDefault true
+ * @description Add the features to the repository
+ */
+public class AddFeaturesToRepoMojo extends MojoSupport {
+
+ /**
+ * @parameter
+ */
+ private List<String> descriptors;
+
+ /**
+ * @parameter
+ */
+ private List<String> features;
+
+ /**
+ * @parameter
+ */
+ private File repository;
+
+ public void execute() throws MojoExecutionException, MojoFailureException {
+ try {
+ Map<String, Feature> featuresMap = new HashMap<String, Feature>();
+ for (String uri : descriptors) {
+ Repository repo = new
Repository(URI.create(translateFromMaven(uri)));
+ for (Feature f : repo.getFeatures()) {
+ featuresMap.put(f.getName(), f);
+ }
+ }
+ Set<String> transitiveFeatures = new HashSet<String>();
+ addFeatures(features, transitiveFeatures, featuresMap);
+ Set<String> bundles = new HashSet<String>();
+ for (String feature : transitiveFeatures) {
+ bundles.addAll(featuresMap.get(feature).getBundles());
+ }
+ System.out.println("Base repo: " + localRepo.getUrl());
+ for (String bundle : bundles) {
+ if (!bundle.startsWith("mvn:")) {
+ throw new MojoExecutionException("Bundle url is not a
maven url: " + bundle);
+ }
+ String[] parts = bundle.substring("mvn:".length()).split("/");
+ String groupId = parts[0];
+ String artifactId = parts[1];
+ String version = null;
+ String classifier = null;
+ String type = "jar";
+ if (parts.length > 2) {
+ version = parts[2];
+ if (parts.length > 3) {
+ classifier = parts[3];
+ if (parts.length > 4) {
+ type = parts[4];
+ }
+ }
+ }
+ String dir = groupId.replace('.', '/') + "/" + artifactId +
"/" + version + "/";
+ String name = artifactId + "-" + version + (classifier != null
? "-" + classifier : "") + "." + type;
+ System.out.println("Copy: " + dir + name);
+ copy(new URL(localRepo.getUrl() + "/" + dir +
name).openStream(),
+ repository,
+ name,
+ dir,
+ new byte[8192]);
+
+ }
+ } catch (MojoExecutionException e) {
+ throw e;
+ } catch (MojoFailureException e) {
+ throw e;
+ } catch (Exception e) {
+ throw new MojoExecutionException("Error populating repository", e);
+ }
+ }
+
+ private String translateFromMaven(String uri) {
+ if (uri.startsWith("mvn:")) {
+ String[] parts = uri.substring("mvn:".length()).split("/");
+ String groupId = parts[0];
+ String artifactId = parts[1];
+ String version = null;
+ String classifier = null;
+ String type = "jar";
+ if (parts.length > 2) {
+ version = parts[2];
+ if (parts.length > 3) {
+ type = parts[3];
+ if (parts.length > 4) {
+ classifier = parts[4];
+ }
+ }
+ }
+ String dir = groupId.replace('.', '/') + "/" + artifactId + "/" +
version + "/";
+ String name = artifactId + "-" + version + (classifier != null ?
"-" + classifier : "") + "." + type;
+ return localRepo.getUrl() + "/" + dir + name;
+ }
+ return uri;
+ }
+
+ private void addFeatures(List<String> features, Set<String>
transitiveFeatures, Map<String, Feature> featuresMap) {
+ for (String feature : features) {
+ Feature f = featuresMap.get(feature);
+ transitiveFeatures.add(feature);
+ addFeatures(f.getDependencies(), transitiveFeatures, featuresMap);
+ }
+ }
+
+ public static void copy(
+ InputStream is, File dir, String destName, String destDir, byte[]
buffer)
+ throws IOException
+ {
+ if (destDir == null)
+ {
+ destDir = "";
+ }
+
+ // Make sure the target directory exists and
+ // that is actually a directory.
+ File targetDir = new File(dir, destDir);
+ if (!targetDir.exists())
+ {
+ if (!targetDir.mkdirs())
+ {
+ throw new IOException("Unable to create target directory: "
+ + targetDir);
+ }
+ }
+ else if (!targetDir.isDirectory())
+ {
+ throw new IOException("Target is not a directory: "
+ + targetDir);
+ }
+
+ BufferedOutputStream bos = new BufferedOutputStream(
+ new FileOutputStream(new File(targetDir, destName)));
+ int count = 0;
+ while ((count = is.read(buffer)) > 0)
+ {
+ bos.write(buffer, 0, count);
+ }
+ bos.close();
+ }
+
+ public static class Feature {
+
+ private String name;
+ private List<String> dependencies = new ArrayList<String>();
+ private List<String> bundles = new ArrayList<String>();
+ private Map<String, Map<String,String>> configs = new HashMap<String,
Map<String,String>>();
+
+ public Feature(String name) {
+ this.name = name;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public List<String> getDependencies() {
+ return dependencies;
+ }
+
+ public List<String> getBundles() {
+ return bundles;
+ }
+
+ public Map<String, Map<String, String>> getConfigurations() {
+ return configs;
+ }
+
+ public void addDependency(String dependency) {
+ dependencies.add(dependency);
+ }
+
+ public void addBundle(String bundle) {
+ bundles.add(bundle);
+ }
+
+ public void addConfig(String name, Map<String,String> properties) {
+ configs.put(name, properties);
+ }
+ }
+
+ public static class Repository {
+
+ private URI uri;
+ private List<Feature> features;
+
+ public Repository(URI uri) {
+ this.uri = uri;
+ }
+
+ public URI getURI() {
+ return uri;
+ }
+
+ public Feature[] getFeatures() throws Exception {
+ if (features == null) {
+ load();
+ }
+ return features.toArray(new Feature[features.size()]);
+ }
+
+ public void load() throws IOException {
+ try {
+ features = new ArrayList<Feature>();
+ DocumentBuilderFactory factory =
DocumentBuilderFactory.newInstance();
+ Document doc =
factory.newDocumentBuilder().parse(uri.toURL().openStream());
+ NodeList nodes = doc.getDocumentElement().getChildNodes();
+ for (int i = 0; i < nodes.getLength(); i++) {
+ org.w3c.dom.Node node = nodes.item(i);
+ if (!(node instanceof Element) ||
!"feature".equals(node.getNodeName())) {
+ continue;
+ }
+ Element e = (Element) nodes.item(i);
+ String name = e.getAttribute("name");
+ Feature f = new Feature(name);
+ NodeList featureNodes = e.getElementsByTagName("feature");
+ for (int j = 0; j < featureNodes.getLength(); j++) {
+ Element b = (Element) featureNodes.item(j);
+ f.addDependency(b.getTextContent());
+ }
+ NodeList configNodes = e.getElementsByTagName("config");
+ for (int j = 0; j < configNodes.getLength(); j++) {
+ Element c = (Element) configNodes.item(j);
+ String cfgName = c.getAttribute("name");
+ String data = c.getTextContent();
+ Properties properties = new Properties();
+ properties.load(new
ByteArrayInputStream(data.getBytes()));
+ Map<String, String> hashtable = new Hashtable<String,
String>();
+ for (Object key : properties.keySet()) {
+ String n = key.toString();
+ hashtable.put(n, properties.getProperty(n));
+ }
+ f.addConfig(cfgName, hashtable);
+ }
+ NodeList bundleNodes = e.getElementsByTagName("bundle");
+ for (int j = 0; j < bundleNodes.getLength(); j++) {
+ Element b = (Element) bundleNodes.item(j);
+ f.addBundle(b.getTextContent());
+ }
+ features.add(f);
+ }
+ } catch (SAXException e) {
+ throw (IOException) new IOException().initCause(e);
+ } catch (ParserConfigurationException e) {
+ throw (IOException) new IOException().initCause(e);
+ }
+ }
+
+ }
+}
