qwe

Author: kaspernielsen

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/ScTest2.java

@@ -15,14 +15,18 @@
  */
 package app.packed.concurrent.job;
 
+import java.io.IOException;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicLong;
 
 import app.packed.application.App;
 import app.packed.application.ApplicationMirror;
 import app.packed.assembly.BaseAssembly;
 import app.packed.concurrent.DaemonJob;
 import app.packed.concurrent.DaemonJobContext;
 import app.packed.lifecycle.Stop;
+import app.packed.web.HttpContext;
+import app.packed.web.WebGet;
 
 /**
  *
@@ -38,7 +42,7 @@ public static void main(String[] args) throws Exception {
 //        });
 
         App app = App.start(new ScTest2());
-        Thread.sleep(3000);
+        Thread.sleep(30000);
         app.stop();
         Thread.sleep(1000);
         System.out.println(app.state());
@@ -55,10 +59,18 @@ protected void build() {
 
     public static class MuB {
 
+        private final AtomicLong al = new AtomicLong();
+
+        @WebGet(url = "/json")
+        public void json(HttpContext ctx) throws IOException {
+            ctx.response().write("{\"status\":\"" + al.get()+ "\"}", "application/json");
+        }
+
         @DaemonJob
         public void dae(ApplicationMirror am, DaemonJobContext sc) throws Exception {
             while (sc.awaitShutdown(1, TimeUnit.SECONDS)) {
                 IO.println("Daemon " + am.allOperations().count());
+                al.incrementAndGet();
             }
         }
 

modules/packed-incubator/packed-incubator-web/pom.xml

@@ -22,4 +22,19 @@
     </dependency>
   </dependencies>
 
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <configuration>
+          <compilerArgs>
+            <arg>--add-modules</arg>
+            <arg>jdk.httpserver</arg>
+          </compilerArgs>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+
 </project>

modules/packed-incubator/packed-incubator-web/src/main/java/app/packed/web/HttpContext.java

@@ -15,11 +15,29 @@
  */
 package app.packed.web;
 
+import app.packed.bean.BeanTrigger.AutoInject;
+import app.packed.binding.Key;
 import app.packed.context.Context;
-
+import internal.app.packed.bean.scanning.IntrospectorOnContextService;
+import internal.app.packed.extension.base.BaseExtensionBeanIntrospector;
 /**
- *
+ * Context providing access to the HTTP request and response.
  */
+@AutoInject(introspector = HttpContextBeanIntrospector.class, requiresContext = HttpContext.class)
 public interface HttpContext extends Context<WebExtension> {
 
+    /** Returns the current HTTP request. */
+    HttpRequest request();
+
+    /** Returns the current HTTP response. */
+    HttpResponse response();
+}
+
+final class HttpContextBeanIntrospector extends BaseExtensionBeanIntrospector {
+
+    /** {@inheritDoc} */
+    @Override
+    public void onExtensionService(Key<?> key, IntrospectorOnContextService service) {
+        service.binder().bindContext(HttpContext.class);
+    }
 }

modules/packed-incubator/packed-incubator-web/src/main/java/app/packed/web/HttpRequest.java

@@ -15,10 +15,47 @@
  */
 package app.packed.web;
 
+import java.io.IOException;
+import java.net.URI;
+
+import com.sun.net.httpserver.Headers;
+
+import app.packed.bean.BeanTrigger.AutoInject;
+import app.packed.binding.Key;
+import app.packed.operation.Op1;
+import internal.app.packed.bean.scanning.IntrospectorOnContextService;
+import internal.app.packed.extension.base.BaseExtensionBeanIntrospector;
+
 /**
- *
+ * Represents an HTTP request.
  */
-//@OnExtensionServiceBeanTrigger(extension = WebExtension.class, requiresContext = HttpContext.class)
+@AutoInject(introspector = HttpRequestBeanIntrospector.class, requiresContext = HttpContext.class)
 public interface HttpRequest {
 
+    /** Returns the request URI. */
+    URI uri();
+
+    /** Returns the request method (GET, POST, etc.). */
+    String method();
+
+    /** Returns a request header value. */
+    String header(String name);
+
+    /** Returns all request headers. */
+    Headers headers();
+
+    /** Returns a query parameter value. */
+    String queryParam(String name);
+
+    /** Returns the request body as a string. */
+    String body() throws IOException;
+}
+
+final class HttpRequestBeanIntrospector extends BaseExtensionBeanIntrospector {
+
+    /** {@inheritDoc} */
+    @Override
+    public void onExtensionService(Key<?> key, IntrospectorOnContextService service) {
+        service.binder().bindOp(new Op1<HttpContext, HttpRequest>(f->f.request()) {});
+    }
 }

modules/packed-incubator/packed-incubator-web/src/main/java/app/packed/web/HttpResponse.java

@@ -15,10 +15,38 @@
  */
 package app.packed.web;
 
+import java.io.IOException;
+
+import app.packed.bean.BeanTrigger.AutoInject;
+import app.packed.binding.Key;
+import app.packed.operation.Op1;
+import internal.app.packed.bean.scanning.IntrospectorOnContextService;
+import internal.app.packed.extension.base.BaseExtensionBeanIntrospector;
+
 /**
- *
+ * Represents an HTTP response.
  */
-//@OnExtensionServiceBeanTrigger(extension = WebExtension.class, requiresContext = HttpContext.class)
+@AutoInject(introspector = HttpResponseBeanIntrospector.class, requiresContext = HttpContext.class)
 public interface HttpResponse {
 
+    /** Sets a response header. */
+    void header(String name, String value);
+
+    /** Sets the response status code. */
+    void status(int code);
+
+    /** Writes the response body. */
+    void write(String body) throws IOException;
+
+    /** Writes the response body with a specific content type. */
+    void write(String body, String contentType) throws IOException;
 }
+
+final class HttpResponseBeanIntrospector extends BaseExtensionBeanIntrospector {
+
+    /** {@inheritDoc} */
+    @Override
+    public void onExtensionService(Key<?> key, IntrospectorOnContextService service) {
+        service.binder().bindOp(new Op1<HttpContext, HttpResponse>(f->f.response()) {});
+    }
+}

modules/packed-incubator/packed-incubator-web/src/main/java/app/packed/web/WebGet.java

@@ -24,6 +24,7 @@
 import app.packed.bean.BeanIntrospector;
 import app.packed.bean.BeanTrigger.OnAnnotatedMethod;
 import internal.app.packed.extension.base.BaseExtensionBeanIntrospector;
+import internal.app.packed.web.WebGetOperationHandle;
 
 @Target(ElementType.METHOD)
 @Retention(RetentionPolicy.RUNTIME)
@@ -38,7 +39,7 @@ final class WebGetBeanIntrospector extends BaseExtensionBeanIntrospector {
     /** {@inheritDoc} */
     @Override
     public void onAnnotatedMethod(Annotation annotation, BeanIntrospector.OnMethod method) {
-        //TODO
+        WebGetOperationHandle.onWebGetAnnotation(this, method, (WebGet) annotation);
     }
 }
 

modules/packed-incubator/packed-incubator-web/src/main/java/app/packed/web/WebTest.java

@@ -0,0 +1,51 @@
+/*
+ * Copyright (c) 2026 Kasper Nielsen.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package app.packed.web;
+
+import java.io.IOException;
+
+import app.packed.application.App;
+import app.packed.assembly.BaseAssembly;
+
+/**
+ * Demo test for the web server functionality.
+ */
+public class WebTest extends BaseAssembly {
+
+    public static void main(String[] args) throws Exception {
+        App app = App.start(new WebTest());
+
+        System.out.println("Server running on http://localhost:8080");
+        System.out.println("Try: curl http://localhost:8080/json");
+        System.out.println("Press Enter to stop...");
+
+        System.in.read();
+        app.stop();
+    }
+
+    @Override
+    protected void build() {
+        install(Handlers.class);
+    }
+
+    public static class Handlers {
+
+        @WebGet(url = "/json")
+        public void json(HttpResponse ctx) throws IOException {
+            ctx.write("{\"status\":\"ok\"}", "application/json");
+        }
+    }
+}