Upgrade to 0.3.0.Final and get core code compiling

Author: kabir

impl/grpc/src/main/java/org/wildfly/extras/a2a/server/apps/grpc/WildFlyGrpcHandler.java

@@ -1,6 +1,11 @@
 package org.wildfly.extras.a2a.server.apps.grpc;
 
+import java.util.concurrent.Executor;
+
+import jakarta.inject.Inject;
+
 import io.a2a.server.requesthandlers.RequestHandler;
+import io.a2a.server.util.async.Internal;
 import io.a2a.spec.AgentCard;
 import io.a2a.transport.grpc.handler.CallContextFactory;
 import io.a2a.transport.grpc.handler.GrpcHandler;
@@ -21,6 +26,10 @@ public class WildFlyGrpcHandler extends GrpcHandler {
     private static volatile RequestHandler staticRequestHandler;
     private static volatile CallContextFactory staticCallContextFactory;
 
+    @Inject
+    @Internal
+    protected Executor executor;
+
     public WildFlyGrpcHandler() {
         // Default constructor - the only one used by WildFly gRPC subsystem
     }
@@ -55,4 +64,9 @@ protected AgentCard getAgentCard() {
     protected CallContextFactory getCallContextFactory() {
         return staticCallContextFactory; // Can be null if not configured
     }
+
+    @Override
+    protected Executor getExecutor() {
+        return executor;
+    }
 }

impl/jsonrpc/src/main/java/org/wildfly/extras/a2a/server/apps/jakarta/A2AServerResource.java

@@ -2,9 +2,12 @@
 
 import java.io.IOException;
 import java.io.PrintWriter;
+import java.util.ArrayList;
 import java.util.Enumeration;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executor;
 import java.util.concurrent.Flow;
@@ -31,10 +34,12 @@
 import com.fasterxml.jackson.core.JsonParseException;
 import com.fasterxml.jackson.databind.JsonMappingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import io.a2a.common.A2AHeaders;
 import io.a2a.server.ExtendedAgentCard;
 import io.a2a.server.ServerCallContext;
 import io.a2a.server.auth.UnauthenticatedUser;
 import io.a2a.server.auth.User;
+import io.a2a.server.extensions.A2AExtensions;
 import io.a2a.server.util.async.Internal;
 import io.a2a.spec.AgentCard;
 import io.a2a.spec.CancelTaskRequest;
@@ -333,7 +338,13 @@ public String getUsername() {
 
             state.put("headers", headers);
 
-            return new ServerCallContext(user, state);
+            Enumeration<String> en = request.getHeaders(A2AHeaders.X_A2A_EXTENSIONS);
+            List<String> extensionHeaderValues = new ArrayList<>();
+            while (en.hasMoreElements()) {
+                extensionHeaderValues.add(en.nextElement());
+            }
+            Set<String> requestedExtensions = A2AExtensions.getRequestedExtensions(extensionHeaderValues);
+            return new ServerCallContext(user, state, requestedExtensions);
         } else {
             CallContextFactory builder = callContextFactory.get();
             return builder.build(request);

impl/rest/src/main/java/org/wildfly/extras/a2a/server/apps/rest/A2ARestServerResource.java

@@ -5,9 +5,12 @@
 
 import java.io.IOException;
 import java.io.PrintWriter;
+import java.util.ArrayList;
 import java.util.Enumeration;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executor;
 import java.util.concurrent.Flow;
@@ -25,10 +28,13 @@
 import jakarta.ws.rs.core.MediaType;
 import jakarta.ws.rs.core.Response;
 import jakarta.ws.rs.core.SecurityContext;
+
+import io.a2a.common.A2AHeaders;
 import io.a2a.server.ExtendedAgentCard;
 import io.a2a.server.ServerCallContext;
 import io.a2a.server.auth.UnauthenticatedUser;
 import io.a2a.server.auth.User;
+import io.a2a.server.extensions.A2AExtensions;
 import io.a2a.server.util.async.Internal;
 import io.a2a.spec.AgentCard;
 import io.a2a.spec.InvalidParamsError;
@@ -344,7 +350,13 @@ public String getUsername() {
 
             state.put("headers", headers);
 
-            return new ServerCallContext(user, state);
+            Enumeration<String> en = request.getHeaders(A2AHeaders.X_A2A_EXTENSIONS);
+            List<String> extensionHeaderValues = new ArrayList<>();
+            while (en.hasMoreElements()) {
+                extensionHeaderValues.add(en.nextElement());
+            }
+            Set<String> requestedExtensions = A2AExtensions.getRequestedExtensions(extensionHeaderValues);
+            return new ServerCallContext(user, state, requestedExtensions);
         } else {
             CallContextFactory builder = callContextFactory.get();
             return builder.build(request);

pom.xml

@@ -44,8 +44,8 @@
 
     <properties>
         <jboss.home>${project.build.directory}${file.separator}wildfly</jboss.home>
-        <version.wildfly>36.0.1.Final</version.wildfly>
-        <version.sdk>0.3.0.Beta2-SNAPSHOT</version.sdk>
+        <version.wildfly>38.0.0.Final</version.wildfly>
+        <version.sdk>0.3.0.Final</version.sdk>
         <!-- This needs to be same version as used by the sdk -->
         <version.mutiny-zero>1.1.1</version.mutiny-zero>
         <!-- gRPC version matching the a2a-java-sdk -->