e

s

Author: kaspernielsen

modules/packed-incubator/packed-incubator-cli/src/main/java/app/packed/cli/other/CliApp.java

@@ -67,7 +67,7 @@ public static void verify(Assembly assembly, String[] args) {
      */
     private static BootstrapApp<Void> bootstrap() {
         class ServiceLocatorBootstrap {
-            private static final BootstrapApp<Void> APP = BootstrapApp.of(ApplicationTemplate.of(Void.class, c -> {}));
+            private static final BootstrapApp<Void> APP = BootstrapApp.of(ApplicationTemplate.ofManaged(Void.class));
         }
         return ServiceLocatorBootstrap.APP;
     }

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/ScheduledOperationHandle.java

@@ -45,7 +45,7 @@ protected ScheduledOperationMirror newOperationMirror() {
     }
 
     @Override
-    protected void onClose() {
+    protected void onOperationClose() {
         /// Called from a code generation thread
         if (s == null) {
             throw new IllegalStateException("Operation " + this + " was never scheduled");

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/ThreadExtension.java

@@ -69,15 +69,13 @@ public class ThreadExtension extends FrameworkExtension<ThreadExtension> {
     }
 
     /** A context template. */
-    static final ContextTemplate SCHEDULING_CONTEXT_TEMPLATE = ContextTemplate.of(SchedulingContext.class, c -> {});
+    static final ContextTemplate SCHEDULING_CONTEXT_TEMPLATE = ContextTemplate.of(SchedulingContext.class);
 
-    static final ContextTemplate DAEMON_CONTEXT_TEMPLATE = ContextTemplate.of(DaemonContext.class, c -> {});
+    static final ContextTemplate DAEMON_CONTEXT_TEMPLATE = ContextTemplate.of(DaemonContext.class);
 
-    static final OperationTemplate SCHEDULING_OPERATION_TEMPLATE = OperationTemplate.defaults()
-            .reconfigure(c -> c.inContext(SCHEDULING_CONTEXT_TEMPLATE).returnIgnore());
+    static final OperationTemplate SCHEDULING_OPERATION_TEMPLATE = OperationTemplate.of(c -> c.inContext(SCHEDULING_CONTEXT_TEMPLATE).returnIgnore());
 
-    static final OperationTemplate DAEMON_OPERATION_TEMPLATE = OperationTemplate.defaults()
-            .reconfigure(c -> c.inContext(DAEMON_CONTEXT_TEMPLATE).returnIgnore());
+    static final OperationTemplate DAEMON_OPERATION_TEMPLATE = OperationTemplate.of(c -> c.inContext(DAEMON_CONTEXT_TEMPLATE).returnIgnore());
 
     /** Creates a new thread extension. */
 

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/ThreadNamespaceConfiguration.java

@@ -43,7 +43,6 @@ public final class ThreadNamespaceConfiguration extends NamespaceConfiguration<T
         this.handle = handle;
     }
 
-//Altssa Hvor brugbare er de her uden at man kan faa fat i andet en den context????
     public DaemonOperationConfiguration addDaemon(Consumer<DaemonContext> action) {
         throw new UnsupportedOperationException();
     }
@@ -58,13 +57,6 @@ public void register(ExecutorService scheduler, boolean shutdownOnExit) {
         handle.scheduler = new ExecutorConfiguration(scheduler, shutdownOnExit);
     }
 
-    // If ExecutorService a task will be executed with sleep. Don't use this unless
-    // Otherwise the
-
-    public void setScheduling(ExecutorService scheduler, boolean shutdownOnExit) {
-        handle.scheduler = new ExecutorConfiguration(scheduler, shutdownOnExit);
-    }
-
     Stream<ScheduledOperationConfiguration> scheduledOperations() {
         // All In Application -> No, that would break cross assembly conf
         // All In Assembly

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/ThreadNamespaceHandle.java

@@ -21,6 +21,7 @@
 import app.packed.namespace.NamespaceInstaller;
 import app.packed.namespace.NamespaceTemplate;
 import internal.app.packed.concurrent.ExecutorConfiguration;
+import internal.app.packed.concurrent.NewScheduledOperation;
 import internal.app.packed.concurrent.ScheduledDaemon;
 import internal.app.packed.concurrent.ScheduledOperation;
 
@@ -56,16 +57,23 @@ protected ThreadNamespaceMirror newNamespaceMirror() {
         return new ThreadNamespaceMirror(this);
     }
 
+    /** {@inheritDoc} */
     @Override
     protected void onNamespaceClose() {
         // Find all scheduling operations in the namespace.
-        ScheduledOperation[] so = operations(ScheduledOperationHandle.class).map(h -> new ScheduledOperation(h.s, h.methodHandle()))
+
+        @SuppressWarnings("unused")
+        NewScheduledOperation[] newSo = operations(ScheduledOperationHandle.class).map(h -> h.invokerAs(NewScheduledOperation.class, h.s))
+                .toArray(NewScheduledOperation[]::new);
+
+        ScheduledOperation[] so = operations(ScheduledOperationHandle.class).map(h -> new ScheduledOperation(h.s, h.invokerAsMethodHandle()))
                 .toArray(ScheduledOperation[]::new);
+
         // Find all daemon operations in the namespace.
-        ScheduledDaemon[] sd = operations(DaemonOperationHandle.class).map(h -> new ScheduledDaemon(h.useVirtual, h.methodHandle()))
+        ScheduledDaemon[] sd = operations(DaemonOperationHandle.class).map(h -> new ScheduledDaemon(h.useVirtual, h.invokerAsMethodHandle()))
                 .toArray(ScheduledDaemon[]::new);
 
-        // Install a scheduling bean if we have any operations.
+        // Install a scheduling bean if we have any scheduling or daemon operations.
         if (so.length > 0 || sd.length > 0) {
             BeanConfiguration b = rootExtension().newSchedulingBean();
             b.bindServiceInstance(ScheduledOperation[].class, so);

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/other/ScheduledJobExtension.java

@@ -63,9 +63,9 @@ protected ScheduledJobExtension(ExtensionHandle<ScheduledJobExtension> handle) {
         super(handle);
     }
 
-    private static final ContextTemplate CT = ContextTemplate.of(SchedulingContext.class, c -> c.implementationClass(PackedSchedulingContext.class));
+    private static final ContextTemplate CT = ContextTemplate.of(SchedulingContext.class).withImplementation(PackedSchedulingContext.class);
 
-    private static final OperationTemplate OT = OperationTemplate.defaults().reconfigure(c -> c.inContext(CT));
+    private static final OperationTemplate OT = OperationTemplate.of(c -> c.inContext(CT));
 
     // Creates a new instance on every invocation
 
@@ -81,7 +81,7 @@ public void onAnnotatedMethod(BeanMethod method, Annotation hook) {
                 OperationHandle<?> operation = method.newOperation(OT).install(OperationHandle::new);
 
                 InstanceBeanConfiguration<SchedulingBean> bean = lifetimeRoot().base().installIfAbsent(SchedulingBean.class, handle -> {
-                    handle.bindServiceInstance(MethodHandle.class, operation.methodHandle());
+                    handle.bindServiceInstance(MethodHandle.class, operation.invokerAsMethodHandle());
                 });
                 // bean, add scheduling +
                 // Manytons dur ikke direkte

modules/packed-incubator/packed-incubator-concurrent/src/main/java/internal/app/packed/concurrent/NewScheduledOperation.java

@@ -0,0 +1,18 @@
+package internal.app.packed.concurrent;
+
+import app.packed.extension.ExtensionContext;
+import internal.app.packed.ValueBased;
+
+/**
+*
+*/
+@ValueBased
+public abstract class NewScheduledOperation {
+    ScheduleImpl s;
+
+    public NewScheduledOperation(ScheduleImpl s) {
+        this.s = s;
+    }
+
+    public abstract void invoke(ExtensionContext context);
+}

modules/packed/src/main/java/app/packed/application/App.java

@@ -20,6 +20,7 @@
 import java.util.function.Consumer;
 
 import app.packed.assembly.Assembly;
+import app.packed.build.MirrorPrinter;
 import app.packed.container.Wirelet;
 import app.packed.runtime.RunState;
 import app.packed.runtime.StopOption;
@@ -143,6 +144,10 @@ static void print(Assembly assembly, Wirelet... wirelets) {
         mirrorOf(assembly, wirelets).print();
     }
 
+    static MirrorPrinter printer(Assembly assembly, Wirelet... wirelets) {
+        return mirrorOf(assembly, wirelets).printer();
+    }
+
     /**
      * Builds and executes an application from the specified assembly and optional wirelets.
      * <p>

modules/packed/src/main/java/app/packed/application/ApplicationInstaller.java

@@ -39,6 +39,7 @@ public sealed interface ApplicationInstaller<H extends ApplicationHandle<?, ?>>
      * @see ApplicationHandle#componentTag(String...)
      * @see ApplicationHandle#componentTags()
      */
+    // Still useful for Application Repository where the template is fixed
     ApplicationInstaller<H> componentTag(String... tags);
 
     /**

modules/packed/src/main/java/app/packed/application/ApplicationMirror.java

@@ -10,6 +10,8 @@
 import app.packed.assembly.AssemblyMirror;
 import app.packed.bean.BeanMirror;
 import app.packed.build.BuildGoal;
+import app.packed.build.Mirror;
+import app.packed.build.MirrorPrinter;
 import app.packed.component.ComponentMirror;
 import app.packed.component.ComponentPath;
 import app.packed.container.ContainerMirror;
@@ -117,10 +119,6 @@ public ComponentPath componentPath() {
         return handle.application.componentPath();
     }
 
-    // All mirrors "owned" by the user
-    public Stream<ComponentMirror> components() {
-        throw new UnsupportedOperationException();
-    }
 
     /**
      * {@return an immutable set of tags that have been set on the application}
@@ -236,6 +234,10 @@ public <T extends OperationMirror> Stream<T> operations(Class<T> operationType)
         return (Stream<T>) operations().filter(f -> operationType.isAssignableFrom(f.getClass()));
     }
 
+    public final void print(@SuppressWarnings("unchecked") Class<? extends Mirror>... mirrorTypes) {
+
+    }
+
     public void print() {
         // Maybe return ApplicationPrinter???
         // to(PrintStream ps);
@@ -293,8 +295,20 @@ public <E extends ExtensionMirror<?>> E use(Class<E> type) {
     public <E extends ExtensionMirror<?>> void useIfPresent(Class<E> type, Consumer<? super E> action) {
         throw new UnsupportedOperationException();
     }
+
+    /**
+     *
+     */
+    public MirrorPrinter printer() {
+        throw new UnsupportedOperationException();
+    }
 }
 
+//
+//// All mirrors "owned" by the user
+//public Stream<ComponentMirror> components() {
+//  throw new UnsupportedOperationException();
+//}
 //
 ///** {@return a mirror of the root assembly that defines the application.} */
 //// IDK if we want this or only assemblies