Improve nested OSGi runtimes

[lgpl/argeo-commons.git] / org.argeo.init / src / org / argeo / init / osgi / ForeignBundleConnectContent.java

diff --git a/org.argeo.init/src/org/argeo/init/osgi/ForeignBundleConnectContent.java b/org.argeo.init/src/org/argeo/init/osgi/ForeignBundleConnectContent.java
new file mode 100644 (file)
index 0000000..aa1d780
--- /dev/null
+++ b/org.argeo.init/src/org/argeo/init/osgi/ForeignBundleConnectContent.java
@@ -0,0 +1,106 @@
+package org.argeo.init.osgi;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
+import java.util.Collections;
+import java.util.Dictionary;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+import org.osgi.framework.Bundle;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.connect.ConnectContent;
+
+/**
+ * A {@link ConnectContent} based on a {@link Bundle} from another OSGi runtime.
+ */
+class ForeignBundleConnectContent implements ConnectContent {
+       private final Bundle foreignBundle;
+       private final ClassLoader classLoader;
+
+       public ForeignBundleConnectContent(BundleContext localBundleContext, Bundle foreignBundle) {
+               this.foreignBundle = foreignBundle;
+               this.classLoader = new ForeignBundleClassLoader(localBundleContext, foreignBundle);
+       }
+
+       @Override
+       public Optional<Map<String, String>> getHeaders() {
+               Dictionary<String, String> dict = foreignBundle.getHeaders();
+               List<String> keys = Collections.list(dict.keys());
+               Map<String, String> dictCopy = keys.stream().collect(Collectors.toMap(Function.identity(), dict::get));
+               return Optional.of(dictCopy);
+       }
+
+       @Override
+       public Iterable<String> getEntries() throws IOException {
+               List<String> lst = Collections.list(foreignBundle.findEntries("", "*", true)).stream().map((u) -> u.getPath())
+                               .toList();
+               return lst;
+       }
+
+       @Override
+       public Optional<ConnectEntry> getEntry(String path) {
+               URL u = foreignBundle.getEntry(path);
+               if (u == null) {
+                       u = foreignBundle.getEntry("bin/" + path);
+                       // System.err.println(u2);
+               }
+               if (u == null) {
+                       if ("plugin.xml".equals(path))
+                               return Optional.empty();
+                       if (path.startsWith("META-INF/versions/"))
+                               return Optional.empty();
+                       System.err.println(foreignBundle.getSymbolicName() + " " + path + " not found");
+                       return Optional.empty();
+               }
+               URL url = u;
+               ConnectEntry urlConnectEntry = new ConnectEntry() {
+
+                       @Override
+                       public String getName() {
+                               return path;
+                       }
+
+                       @Override
+                       public long getLastModified() {
+                               return foreignBundle.getLastModified();
+                       }
+
+                       @Override
+                       public InputStream getInputStream() throws IOException {
+                               return url.openStream();
+                       }
+
+                       @Override
+                       public long getContentLength() {
+                               return -1;
+                       }
+               };
+               return Optional.of(urlConnectEntry);
+       }
+
+       @Override
+       public Optional<ClassLoader> getClassLoader() {
+               ClassLoader cl;
+               // cl = bundle.adapt(BundleWiring.class).getClassLoader();
+
+               // cl = subFrameworkClassLoader;
+               cl = classLoader;
+               return Optional.of(cl);
+//                     return Optional.empty();
+       }
+
+       @Override
+       public void open() throws IOException {
+       }
+
+       @Override
+       public void close() throws IOException {
+
+       }
+
+}