]> git.argeo.org Git - gpl/argeo-slc.git/blobdiff - org.argeo.slc.build/src/org/argeo/slc/build/A2Factory.java
Finalise TP distribution.
[gpl/argeo-slc.git] / org.argeo.slc.build / src / org / argeo / slc / build / A2Factory.java
index 7af1d1c83280920b66130b8857a59d3c48b0ca97..dcf706299eeb842ca31727547cd0975e86248ca0 100644 (file)
@@ -1,6 +1,10 @@
 package org.argeo.slc.build;
 
+import static java.lang.System.Logger.Level.DEBUG;
 import static org.argeo.slc.ManifestConstants.BUNDLE_LICENSE;
+import static org.argeo.slc.ManifestConstants.BUNDLE_SYMBOLICNAME;
+import static org.argeo.slc.ManifestConstants.BUNDLE_VERSION;
+import static org.argeo.slc.ManifestConstants.EXPORT_PACKAGE;
 import static org.argeo.slc.ManifestConstants.SLC_ORIGIN_M2;
 
 import java.io.FileNotFoundException;
@@ -26,9 +30,11 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Properties;
+import java.util.TreeMap;
 import java.util.jar.Attributes;
 import java.util.jar.JarEntry;
 import java.util.jar.JarInputStream;
+import java.util.jar.JarOutputStream;
 import java.util.jar.Manifest;
 
 import org.argeo.slc.DefaultNameVersion;
@@ -37,6 +43,9 @@ import org.argeo.slc.NameVersion;
 import org.argeo.slc.build.m2.DefaultArtifact;
 import org.argeo.slc.build.m2.MavenConventionsUtils;
 
+import aQute.bnd.osgi.Analyzer;
+import aQute.bnd.osgi.Jar;
+
 public class A2Factory {
        private final static Logger logger = System.getLogger(A2Factory.class.getName());
 
@@ -60,6 +69,50 @@ public class A2Factory {
                mirrors.put("http://www.eclipse.org/downloads", eclipseMirrors);
        }
 
+       public void processCategory(Path targetCategoryBase) {
+               try {
+                       DirectoryStream<Path> bnds = Files.newDirectoryStream(targetCategoryBase,
+                                       (p) -> p.getFileName().toString().endsWith(".bnd")
+                                                       && !p.getFileName().toString().equals(COMMON_BND));
+                       for (Path p : bnds) {
+                               processSingleM2ArtifactDistributionUnit(p);
+                       }
+
+                       DirectoryStream<Path> dus = Files.newDirectoryStream(targetCategoryBase, (p) -> Files.isDirectory(p));
+                       for (Path duDir : dus) {
+                               processM2BasedDistributionUnit(duDir);
+                       }
+               } catch (IOException e) {
+                       throw new RuntimeException("Cannot process category " + targetCategoryBase, e);
+               }
+       }
+
+       public void processSingleM2ArtifactDistributionUnit(Path bndFile) {
+               try {
+                       String category = bndFile.getParent().getFileName().toString();
+                       Path targetCategoryBase = factoryBase.resolve(category);
+                       Properties fileProps = new Properties();
+                       try (InputStream in = Files.newInputStream(bndFile)) {
+                               fileProps.load(in);
+                       }
+
+                       String m2Coordinates = fileProps.getProperty(SLC_ORIGIN_M2.toString());
+                       if (m2Coordinates == null)
+                               throw new IllegalArgumentException("No M2 coordinates available for " + bndFile);
+                       DefaultArtifact artifact = new DefaultArtifact(m2Coordinates);
+                       URL url = MavenConventionsUtils.mavenCentralUrl(artifact);
+                       Path downloaded = download(url, originBase, artifact.toM2Coordinates() + ".jar");
+
+                       Path targetBundleDir = processBndJar(downloaded, targetCategoryBase, fileProps, artifact);
+
+                       downloadAndProcessM2Sources(artifact, targetBundleDir);
+
+                       createJar(targetBundleDir);
+               } catch (Exception e) {
+                       throw new RuntimeException("Cannot process " + bndFile, e);
+               }
+       }
+
        public void processM2BasedDistributionUnit(Path duDir) {
                try {
                        String category = duDir.getParent().getFileName().toString();
@@ -99,7 +152,7 @@ public class A2Factory {
                                                        String value = fileProps.getProperty(key.toString());
                                                        writer.write(key + ": " + value + '\n');
                                                }
-                                               logger.log(Level.DEBUG, () -> "Migrated  " + p);
+                                               logger.log(DEBUG, () -> "Migrated  " + p);
                                        }
                                }
 
@@ -108,30 +161,31 @@ public class A2Factory {
                                Path downloaded = download(url, originBase, artifact.toM2Coordinates() + ".jar");
 
                                // prepare manifest entries
-                               Map<String, String> entries = new HashMap<>();
-                               for (Object key : commonProps.keySet()) {
-                                       entries.put(key.toString(), commonProps.getProperty(key.toString()));
-                               }
+                               Properties mergeProps = new Properties();
+                               mergeProps.putAll(commonProps);
+
+                               // Map<String, String> entries = new HashMap<>();
+//                             for (Object key : commonProps.keySet()) {
+//                                     entries.put(key.toString(), commonProps.getProperty(key.toString()));
+//                             }
                                fileEntries: for (Object key : fileProps.keySet()) {
                                        if (ManifestConstants.SLC_ORIGIN_M2.toString().equals(key))
                                                continue fileEntries;
                                        String value = fileProps.getProperty(key.toString());
-                                       String previousValue = entries.put(key.toString(), value);
+                                       Object previousValue = mergeProps.put(key.toString(), value);
                                        if (previousValue != null) {
                                                logger.log(Level.WARNING,
                                                                downloaded + ": " + key + " was " + previousValue + ", overridden with " + value);
                                        }
                                }
-                               entries.put(ManifestConstants.SLC_ORIGIN_M2.toString(), artifact.toM2Coordinates());
-                               Path targetBundleDir = processBundleJar(downloaded, targetCategoryBase, entries);
-                               logger.log(Level.DEBUG, () -> "Processed " + downloaded);
+                               mergeProps.put(ManifestConstants.SLC_ORIGIN_M2.toString(), artifact.toM2Coordinates());
+                               Path targetBundleDir = processBndJar(downloaded, targetCategoryBase, mergeProps, artifact);
+//                             logger.log(Level.DEBUG, () -> "Processed " + downloaded);
 
                                // sources
-                               DefaultArtifact sourcesArtifact = new DefaultArtifact(artifact.toM2Coordinates(), "sources");
-                               URL sourcesUrl = MavenConventionsUtils.mavenCentralUrl(sourcesArtifact);
-                               Path sourcesDownloaded = download(sourcesUrl, originBase, artifact.toM2Coordinates() + ".sources.jar");
-                               processM2SourceJar(sourcesDownloaded, targetBundleDir);
-                               logger.log(Level.DEBUG, () -> "Processed " + sourcesDownloaded);
+                               downloadAndProcessM2Sources(artifact, targetBundleDir);
+
+                               createJar(targetBundleDir);
                        }
                } catch (IOException e) {
                        throw new RuntimeException("Cannot process " + duDir, e);
@@ -139,6 +193,90 @@ public class A2Factory {
 
        }
 
+       protected void downloadAndProcessM2Sources(DefaultArtifact artifact, Path targetBundleDir) throws IOException {
+               DefaultArtifact sourcesArtifact = new DefaultArtifact(artifact.toM2Coordinates(), "sources");
+               URL sourcesUrl = MavenConventionsUtils.mavenCentralUrl(sourcesArtifact);
+               Path sourcesDownloaded = download(sourcesUrl, originBase, artifact.toM2Coordinates() + ".sources.jar");
+               processM2SourceJar(sourcesDownloaded, targetBundleDir);
+               logger.log(Level.DEBUG, () -> "Processed source " + sourcesDownloaded);
+
+       }
+
+       protected Path processBndJar(Path downloaded, Path targetCategoryBase, Properties fileProps,
+                       DefaultArtifact artifact) {
+
+               try {
+                       Map<String, String> additionalEntries = new TreeMap<>();
+                       boolean doNotModify = Boolean.parseBoolean(fileProps
+                                       .getOrDefault(ManifestConstants.SLC_ORIGIN_MANIFEST_NOT_MODIFIED.toString(), "false").toString());
+
+                       if (doNotModify) {
+                               fileEntries: for (Object key : fileProps.keySet()) {
+                                       if (ManifestConstants.SLC_ORIGIN_M2.toString().equals(key))
+                                               continue fileEntries;
+                                       String value = fileProps.getProperty(key.toString());
+                                       additionalEntries.put(key.toString(), value);
+                               }
+                       } else {
+                               if (artifact != null) {
+                                       if (!fileProps.containsKey(BUNDLE_SYMBOLICNAME.toString())) {
+                                               fileProps.put(BUNDLE_SYMBOLICNAME.toString(), artifact.getName());
+                                       }
+                                       if (!fileProps.containsKey(BUNDLE_VERSION.toString())) {
+                                               fileProps.put(BUNDLE_VERSION.toString(), artifact.getVersion());
+                                       }
+                               }
+
+                               if (!fileProps.containsKey(EXPORT_PACKAGE.toString())) {
+                                       fileProps.put(EXPORT_PACKAGE.toString(),
+                                                       "*;version=\"" + fileProps.getProperty(BUNDLE_VERSION.toString()) + "\"");
+                               }
+//                             if (!fileProps.contains(IMPORT_PACKAGE.toString())) {
+//                                     fileProps.put(IMPORT_PACKAGE.toString(), "*");
+//                             }
+
+                               try (Analyzer bndAnalyzer = new Analyzer()) {
+                                       bndAnalyzer.setProperties(fileProps);
+                                       Jar jar = new Jar(downloaded.toFile());
+                                       bndAnalyzer.setJar(jar);
+                                       Manifest manifest = bndAnalyzer.calcManifest();
+
+                                       keys: for (Object key : manifest.getMainAttributes().keySet()) {
+                                               Object value = manifest.getMainAttributes().get(key);
+
+                                               switch (key.toString()) {
+                                               case "Tool":
+                                               case "Bnd-LastModified":
+                                               case "Created-By":
+                                                       continue keys;
+                                               }
+                                               if("Require-Capability".equals(key.toString()) && value.toString().equals("osgi.ee;filter:=\"(&(osgi.ee=JavaSE)(version=1.1))\""))
+                                                       continue keys;// hack for very old classes
+                                               additionalEntries.put(key.toString(), value.toString());
+                                               logger.log(DEBUG, () -> key + "=" + value);
+
+                                       }
+                               }
+
+//                             try (Builder bndBuilder = new Builder()) {
+//                                     Jar jar = new Jar(downloaded.toFile());
+//                                     bndBuilder.addClasspath(jar);
+//                                     Path targetBundleDir = targetCategoryBase.resolve(artifact.getName() + "." + artifact.getBranch());
+//
+//                                     Jar target = new Jar(targetBundleDir.toFile());
+//                                     bndBuilder.setJar(target);
+//                                     return targetBundleDir;
+//                             }
+                       }
+                       Path targetBundleDir = processBundleJar(downloaded, targetCategoryBase, additionalEntries);
+                       logger.log(Level.DEBUG, () -> "Processed " + downloaded);
+                       return targetBundleDir;
+               } catch (Exception e) {
+                       throw new RuntimeException("Cannot BND process " + downloaded, e);
+               }
+
+       }
+
        protected void processM2SourceJar(Path file, Path targetBundleDir) throws IOException {
                try (JarInputStream jarIn = new JarInputStream(Files.newInputStream(file), false)) {
                        Path targetSourceDir = targetBundleDir.resolve("OSGI-OPT/src");
@@ -221,19 +359,54 @@ public class A2Factory {
                                        return super.visitFile(file, attrs);
                                }
                        });
+
+                       DirectoryStream<Path> dirs = Files.newDirectoryStream(targetCategoryBase, (p) -> Files.isDirectory(p));
+                       for (Path dir : dirs) {
+                               createJar(dir);
+                       }
                } catch (IOException e) {
                        throw new RuntimeException("Cannot process " + duDir, e);
                }
 
        }
 
-       protected Path processBundleJar(Path file, Path targetBase, Map<String, String> additionalManifestEntries)
-                       throws IOException {
+       protected Path processBundleJar(Path file, Path targetBase, Map<String, String> entries) throws IOException {
                NameVersion nameVersion;
                Path targetBundleDir;
                try (JarInputStream jarIn = new JarInputStream(Files.newInputStream(file), false)) {
-                       Manifest manifest = jarIn.getManifest();
-                       nameVersion = nameVersionFromManifest(manifest);
+                       Manifest manifest = new Manifest(jarIn.getManifest());
+
+                       // remove problematic entries in MANIFEST
+                       manifest.getEntries().clear();
+//                     Set<String> entriesToDelete = new HashSet<>();
+//                     for (String key : manifest.getEntries().keySet()) {
+////                           logger.log(DEBUG, "## " + key);
+//                             Attributes attrs = manifest.getAttributes(key);
+//                             for (Object attrName : attrs.keySet()) {
+////                                   logger.log(DEBUG, attrName + "=" + attrs.get(attrName));
+//                                     if ("Specification-Version".equals(attrName.toString())
+//                                                     || "Implementation-Version".equals(attrName.toString())) {
+//                                             entriesToDelete.add(key);
+//
+//                                     }
+//                             }
+//                     }
+//                     for (String key : entriesToDelete) {
+//                             manifest.getEntries().remove(key);
+//                     }
+
+                       String symbolicNameFromEntries = entries.get(BUNDLE_SYMBOLICNAME.toString());
+                       String versionFromEntries = entries.get(BUNDLE_VERSION.toString());
+
+                       if (symbolicNameFromEntries != null && versionFromEntries != null) {
+                               nameVersion = new DefaultNameVersion(symbolicNameFromEntries, versionFromEntries);
+                       } else {
+                               nameVersion = nameVersionFromManifest(manifest);
+                               if (versionFromEntries != null && !nameVersion.getVersion().equals(versionFromEntries)) {
+                                       logger.log(Level.WARNING, "Original version is " + nameVersion.getVersion()
+                                                       + " while new version is " + versionFromEntries);
+                               }
+                       }
                        targetBundleDir = targetBase.resolve(nameVersion.getName() + "." + nameVersion.getBranch());
 
                        // TODO make it less dangerous?
@@ -246,6 +419,8 @@ public class A2Factory {
                        entries: while ((entry = jarIn.getNextJarEntry()) != null) {
                                if (entry.isDirectory())
                                        continue entries;
+                               if (entry.getName().endsWith(".RSA") || entry.getName().endsWith(".SF"))
+                                       continue entries;
                                Path target = targetBundleDir.resolve(entry.getName());
                                Files.createDirectories(target.getParent());
                                Files.copy(jarIn, target);
@@ -255,8 +430,8 @@ public class A2Factory {
                        // copy MANIFEST
                        Path manifestPath = targetBundleDir.resolve("META-INF/MANIFEST.MF");
                        Files.createDirectories(manifestPath.getParent());
-                       for (String key : additionalManifestEntries.keySet()) {
-                               String value = additionalManifestEntries.get(key);
+                        for (String key : entries.keySet()) {
+                               String value = entries.get(key);
                                Object previousValue = manifest.getMainAttributes().putValue(key, value);
                                if (previousValue != null && !previousValue.equals(value)) {
                                        logger.log(Level.WARNING,
@@ -339,6 +514,8 @@ public class A2Factory {
                Attributes attrs = manifest.getMainAttributes();
                // symbolic name
                String symbolicName = attrs.getValue(ManifestConstants.BUNDLE_SYMBOLICNAME.toString());
+               if (symbolicName == null)
+                       return null;
                // make sure there is no directive
                symbolicName = symbolicName.split(";")[0];
 
@@ -404,6 +581,32 @@ public class A2Factory {
                return dest;
        }
 
+       protected Path createJar(Path bundleDir) throws IOException {
+               Path jarPath = bundleDir.getParent().resolve(bundleDir.getFileName() + ".jar");
+               Path manifestPath = bundleDir.resolve("META-INF/MANIFEST.MF");
+               Manifest manifest;
+               try (InputStream in = Files.newInputStream(manifestPath)) {
+                       manifest = new Manifest(in);
+               }
+               try (JarOutputStream jarOut = new JarOutputStream(Files.newOutputStream(jarPath), manifest)) {
+                       Files.walkFileTree(bundleDir, new SimpleFileVisitor<Path>() {
+
+                               @Override
+                               public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {
+                                       if (file.getFileName().toString().equals("MANIFEST.MF"))
+                                               return super.visitFile(file, attrs);
+                                       JarEntry entry = new JarEntry(bundleDir.relativize(file).toString());
+                                       jarOut.putNextEntry(entry);
+                                       Files.copy(file, jarOut);
+                                       return super.visitFile(file, attrs);
+                               }
+
+                       });
+               }
+               deleteDirectory(bundleDir);
+               return jarPath;
+       }
+
        public static void main(String[] args) {
                Path originBase = Paths.get("../output/origin").toAbsolutePath().normalize();
                Path factoryBase = Paths.get("../output/a2").toAbsolutePath().normalize();
@@ -411,11 +614,21 @@ public class A2Factory {
 
                Path descriptorsBase = Paths.get("../tp").toAbsolutePath().normalize();
 
-//             factory.processEclipseArchive(
-//                             descriptorsBase.resolve("org.argeo.tp.eclipse.equinox").resolve("eclipse-equinox"));
-//             factory.processEclipseArchive(descriptorsBase.resolve("org.argeo.tp.eclipse.rap").resolve("eclipse-rap"));
-//             factory.processEclipseArchive(descriptorsBase.resolve("org.argeo.tp.eclipse.rcp").resolve("eclipse-rcp"));
-
-               factory.processM2BasedDistributionUnit(descriptorsBase.resolve("org.argeo.tp").resolve("jetty"));
+//             factory.processSingleM2ArtifactDistributionUnit(descriptorsBase.resolve("org.argeo.tp.apache").resolve("org.apache.xml.resolver.bnd"));
+//             factory.processM2BasedDistributionUnit(descriptorsBase.resolve("org.argeo.tp/slf4j"));
+//             System.exit(0);
+
+               // Eclipse
+               factory.processEclipseArchive(
+                               descriptorsBase.resolve("org.argeo.tp.eclipse.equinox").resolve("eclipse-equinox"));
+               factory.processEclipseArchive(descriptorsBase.resolve("org.argeo.tp.eclipse.rap").resolve("eclipse-rap"));
+               factory.processEclipseArchive(descriptorsBase.resolve("org.argeo.tp.eclipse.rcp").resolve("eclipse-rcp"));
+
+               // Maven
+               factory.processCategory(descriptorsBase.resolve("org.argeo.tp.sdk"));
+               factory.processCategory(descriptorsBase.resolve("org.argeo.tp"));
+               factory.processCategory(descriptorsBase.resolve("org.argeo.tp.apache"));
+               factory.processCategory(descriptorsBase.resolve("org.argeo.tp.jetty"));
+               factory.processCategory(descriptorsBase.resolve("org.argeo.tp.jcr"));
        }
 }