+++ /dev/null
-package org.argeo.osgi.boot;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.net.URL;
-import java.nio.file.DirectoryStream;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.PathMatcher;
-import java.nio.file.Paths;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.SortedMap;
-import java.util.StringTokenizer;
-import java.util.TreeMap;
-import java.util.jar.JarEntry;
-import java.util.jar.JarInputStream;
-import java.util.jar.Manifest;
-
-import org.osgi.framework.Constants;
-import org.osgi.framework.Version;
-
-/**
- * A distribution bundle is a bundle within a maven-like distribution
- * groupId:Bundle-SymbolicName:Bundle-Version which references others OSGi
- * bundle. It is not required to be OSGi complete also it will generally be
- * expected that it is. The root of the repository is computed based on the file
- * name of the URL and of the content of the index.
- */
-public class DistributionBundle {
- private final static String INDEX_FILE_NAME = "modularDistribution.csv";
-
- private final String url;
-
- private Manifest manifest;
- private String symbolicName;
- private String version;
-
- /** can be null */
- private String baseUrl;
- /** can be null */
- private String relativeUrl;
- private String localCache;
-
- private List<OsgiArtifact> artifacts;
-
- private String separator = ",";
-
- public DistributionBundle(String url) {
- this.url = url;
- }
-
- public DistributionBundle(String baseUrl, String relativeUrl, String localCache) {
- if (baseUrl == null || !baseUrl.endsWith("/"))
- throw new OsgiBootException("Base url " + baseUrl + " badly formatted");
- if (relativeUrl.startsWith("http") || relativeUrl.startsWith("file:"))
- throw new OsgiBootException("Relative URL " + relativeUrl + " badly formatted");
- this.url = constructUrl(baseUrl, relativeUrl);
- this.baseUrl = baseUrl;
- this.relativeUrl = relativeUrl;
- this.localCache = localCache;
- }
-
- protected String constructUrl(String baseUrl, String relativeUrl) {
- try {
- if (relativeUrl.indexOf('*') >= 0) {
- if (!baseUrl.startsWith("file:"))
- throw new IllegalArgumentException(
- "Wildcard support only for file:, badly formatted " + baseUrl + " and " + relativeUrl);
- Path basePath = Paths.get(new URI(baseUrl));
- // Path basePath = Paths.get(new URI(baseUrl));
- // int li = relativeUrl.lastIndexOf('/');
- // String relativeDir = relativeUrl.substring(0, li);
- // String relativeFile = relativeUrl.substring(li,
- // relativeUrl.length());
- String pattern = "glob:" + basePath + '/' + relativeUrl;
- PathMatcher pm = basePath.getFileSystem().getPathMatcher(pattern);
- SortedMap<Version, Path> res = new TreeMap<>();
- checkDir(basePath, pm, res);
- if (res.size() == 0)
- throw new OsgiBootException("No file matching " + relativeUrl + " found in " + baseUrl);
- return res.get(res.firstKey()).toUri().toString();
- } else {
- return baseUrl + relativeUrl;
- }
- } catch (Exception e) {
- throw new OsgiBootException("Cannot build URL from " + baseUrl + " and " + relativeUrl, e);
- }
- }
-
- private void checkDir(Path dir, PathMatcher pm, SortedMap<Version, Path> res) throws IOException {
- try (DirectoryStream<Path> ds = Files.newDirectoryStream(dir)) {
- for (Path path : ds) {
- if (Files.isDirectory(path))
- checkDir(path, pm, res);
- else if (pm.matches(path)) {
- String fileName = path.getFileName().toString();
- fileName = fileName.substring(0, fileName.lastIndexOf('.'));
- if (fileName.endsWith("-SNAPSHOT"))
- fileName = fileName.substring(0, fileName.lastIndexOf('-')) + ".SNAPSHOT";
- fileName = fileName.substring(fileName.lastIndexOf('-') + 1);
- Version version = new Version(fileName);
- res.put(version, path);
- }
- }
- }
- }
-
- public void processUrl() {
- JarInputStream jarIn = null;
- try {
- URL u = new URL(url);
-
- // local cache
- URI localUri = new URI(localCache + relativeUrl);
- Path localPath = Paths.get(localUri);
- if (Files.exists(localPath))
- u = localUri.toURL();
- jarIn = new JarInputStream(u.openStream());
-
- // meta data
- manifest = jarIn.getManifest();
- symbolicName = manifest.getMainAttributes().getValue(Constants.BUNDLE_SYMBOLICNAME);
- version = manifest.getMainAttributes().getValue(Constants.BUNDLE_VERSION);
-
- JarEntry indexEntry;
- while ((indexEntry = jarIn.getNextJarEntry()) != null) {
- String entryName = indexEntry.getName();
- if (entryName.equals(INDEX_FILE_NAME)) {
- break;
- }
- jarIn.closeEntry();
- }
-
- // list artifacts
- if (indexEntry == null)
- throw new OsgiBootException("No index " + INDEX_FILE_NAME + " in " + url);
- artifacts = listArtifacts(jarIn);
- jarIn.closeEntry();
-
- // find base URL
- // won't work if distribution artifact is not listed
- for (int i = 0; i < artifacts.size(); i++) {
- OsgiArtifact osgiArtifact = (OsgiArtifact) artifacts.get(i);
- if (osgiArtifact.getSymbolicName().equals(symbolicName) && osgiArtifact.getVersion().equals(version)) {
- String relativeUrl = osgiArtifact.getRelativeUrl();
- if (url.endsWith(relativeUrl)) {
- baseUrl = url.substring(0, url.length() - osgiArtifact.getRelativeUrl().length());
- break;
- }
- }
- }
- } catch (Exception e) {
- throw new OsgiBootException("Cannot list URLs from " + url, e);
- } finally {
- if (jarIn != null)
- try {
- jarIn.close();
- } catch (IOException e) {
- // silent
- }
- }
- }
-
- protected List<OsgiArtifact> listArtifacts(InputStream in) {
- List<OsgiArtifact> osgiArtifacts = new ArrayList<OsgiArtifact>();
- BufferedReader reader = null;
- try {
- reader = new BufferedReader(new InputStreamReader(in));
- String line = null;
- lines: while ((line = reader.readLine()) != null) {
- StringTokenizer st = new StringTokenizer(line, separator);
- String moduleName = st.nextToken();
- String moduleVersion = st.nextToken();
- String relativeUrl = st.nextToken();
- if (relativeUrl.endsWith(".pom"))
- continue lines;
- osgiArtifacts.add(new OsgiArtifact(moduleName, moduleVersion, relativeUrl));
- }
- } catch (Exception e) {
- throw new OsgiBootException("Cannot list artifacts", e);
- }
- return osgiArtifacts;
- }
-
- /** Convenience method */
- public static DistributionBundle processUrl(String baseUrl, String relativeUrl, String localCache) {
- DistributionBundle distributionBundle = new DistributionBundle(baseUrl, relativeUrl, localCache);
- distributionBundle.processUrl();
- return distributionBundle;
- }
-
- /**
- * List full URLs of the bundles, based on base URL, usable directly for
- * download.
- */
- public List<String> listUrls() {
- if (baseUrl == null)
- throw new OsgiBootException("Base URL is not set");
-
- if (artifacts == null)
- throw new OsgiBootException("Artifact list not initialized");
-
- List<String> urls = new ArrayList<String>();
- for (int i = 0; i < artifacts.size(); i++) {
- OsgiArtifact osgiArtifact = (OsgiArtifact) artifacts.get(i);
- // local cache
- URI localUri;
- try {
- localUri = new URI(localCache + relativeUrl);
- } catch (URISyntaxException e) {
- OsgiBootUtils.warn(e.getMessage());
- localUri = null;
- }
- Version version = new Version(osgiArtifact.getVersion());
- if (localUri != null && Files.exists(Paths.get(localUri)) && version.getQualifier() != null
- && version.getQualifier().startsWith("SNAPSHOT")) {
- urls.add(localCache + osgiArtifact.getRelativeUrl());
- } else {
- urls.add(baseUrl + osgiArtifact.getRelativeUrl());
- }
- }
- return urls;
- }
-
- public void setBaseUrl(String baseUrl) {
- this.baseUrl = baseUrl;
- }
-
- /** Separator used to parse the tabular file */
- public void setSeparator(String modulesUrlSeparator) {
- this.separator = modulesUrlSeparator;
- }
-
- public String getRelativeUrl() {
- return relativeUrl;
- }
-
- /** One of the listed artifact */
- protected static class OsgiArtifact {
- private final String symbolicName;
- private final String version;
- private final String relativeUrl;
-
- public OsgiArtifact(String symbolicName, String version, String relativeUrl) {
- super();
- this.symbolicName = symbolicName;
- this.version = version;
- this.relativeUrl = relativeUrl;
- }
-
- public String getSymbolicName() {
- return symbolicName;
- }
-
- public String getVersion() {
- return version;
- }
-
- public String getRelativeUrl() {
- return relativeUrl;
- }
-
- }
-}
projects / lgpl / argeo-commons.git / blobdiff