Merge pull request #338 from avaje/feature/alternate-serviceLoading

Use alternative to ServiceLoader to load Plugin and PropertyRequiresPlugin

Author: rbygrave

inject/src/main/java/io/avaje/inject/DBeanScopeBuilder.java

@@ -7,10 +7,14 @@
 import io.avaje.lang.Nullable;
 import jakarta.inject.Provider;
 
+import java.io.*;
 import java.lang.reflect.Type;
+import java.net.URL;
 import java.util.*;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 import static java.lang.System.Logger.Level.DEBUG;
 
@@ -187,7 +191,7 @@ private void initClassLoader() {
 
   private void initPropertyPlugin() {
     propertyRequiresPlugin =
-      ServiceLoader.load(PropertyRequiresPlugin.class, classLoader)
+      serviceLoad(PropertyRequiresPlugin.class)
         .findFirst()
         .orElse(defaultPropertyPlugin());
   }
@@ -214,7 +218,7 @@ public BeanScope build() {
       initPropertyPlugin();
     }
 
-    ServiceLoader.load(Plugin.class, classLoader).forEach(plugin -> plugin.apply(this));
+    serviceLoad(Plugin.class).forEach(plugin -> plugin.apply(this));
     // sort factories by dependsOn
     FactoryOrder factoryOrder = new FactoryOrder(parent, includeModules, !suppliedBeans.isEmpty());
     if (factoryOrder.isEmpty()) {
@@ -241,6 +245,32 @@ public BeanScope build() {
     return builder.build(shutdownHook, start);
   }
 
+  private <P> Stream<P> serviceLoad(Class<P> pluginClass) {
+      return classLoader
+        .resources("META-INF/services/" + pluginClass.getCanonicalName())
+        .flatMap(this::resourceLines)
+        .map(this::serviceInstance);
+  }
+
+  @SuppressWarnings("unchecked")
+  private <P> P serviceInstance(String className) {
+    try {
+      final var clazz = classLoader.loadClass(className);
+      return (P) clazz.getDeclaredConstructor().newInstance();
+    } catch (Throwable e) {
+      throw new RuntimeException(e);
+    }
+  }
+
+  private Stream<String> resourceLines(URL url) {
+    try (InputStream is = url.openStream()) {
+      final var reader = new LineNumberReader(new InputStreamReader(is));
+      return reader.lines().collect(Collectors.toList()).stream();
+    } catch (IOException e) {
+      throw new UncheckedIOException(e);
+    }
+  }
+
   /**
    * Return the type that we map the supplied bean to.
    */