Merge pull request #31 from ehsavoie/simple_example_rest

fix: Adding simple example for HTTP+JSON/REST

Author: kabir

.github/workflows/build-and-test.yml

@@ -106,6 +106,31 @@ jobs:
             echo "Actual: $CLIENT_OUTPUT"
             exit 1
           fi
+      - name: Test HTTP+JSON/REST simple example
+        run: |
+          # Build the server with rest
+          mvn -B clean package -pl examples/simple/server -Prest -Dversion.sdk=${SDK_VERSION}
+          
+          # Start server and wait
+          mvn -B wildfly:start -pl examples/simple/server -Dstartup-timeout=120
+          
+          # Run the client and capture output
+          CLIENT_OUTPUT=$(mvn -B exec:java -pl examples/simple/client -Prun-rest -Duser.name="CI Run" -q 2>&1)
+          
+          # Stop server
+          mvn -B wildfly:shutdown -pl examples/simple/server
+          
+          # Validate output
+          EXPECTED="Agent responds: Hello CI Run"
+          if [[ "$CLIENT_OUTPUT" == *"$EXPECTED"* ]]; then
+            echo "✅ HTTP+JSON/REST example test passed"
+            echo "Output: $CLIENT_OUTPUT"
+          else
+            echo "❌ HTTP+JSON/REST example test failed"
+            echo "Expected: $EXPECTED"
+            echo "Actual: $CLIENT_OUTPUT"
+            exit 1
+          fi
       - name: Upload WildFly logs on test failure
         if: failure()
         uses: actions/upload-artifact@v4

examples/simple/README.md

@@ -88,5 +88,26 @@ mvn clean install -Pgrpc -f server/pom.xml
 mvn exec:java -f client/pom.xml -Prun-grpc -Duser.name=Kabir
 ````
 
-You should see the output: `Agent responds: Hello kabir`
+You should see the output: `Agent responds: Hello Kabir`
+
+### HTTP+JSON/REST
+
+1. Build the server
+````shell
+mvn clean install -Prest -f server/pom.xml
+````
+
+2. Start the server
+
+````shell
+./server/target/wildfly/bin/standalone.sh --stability=preview
+````
+
+3. Run the client
+
+````shell
+mvn exec:java -f client/pom.xml -Prun-rest -Duser.name=Kabir
+````
+
+You should see the output: `Agent responds: Hello Kabir`
 

examples/simple/client/pom.xml

@@ -13,9 +13,9 @@
 
     <artifactId>a2a-java-sdk-jakarta-example-simple-client</artifactId>
 
-    <packaging>war</packaging>
+    <packaging>jar</packaging>
 
-    <name>WildFly Extras - Java A2A SDK for Jakarta - Example - Simple</name>
+    <name>WildFly Extras - Java A2A SDK for Jakarta - Example - Simple Client</name>
     <description>Java SDK for the Agent2Agent Protocol (A2A) - SDK - Jakarta - TCK - WildFly Jar</description>
 
     <properties>
@@ -34,7 +34,11 @@
         </dependency>
         <dependency>
             <groupId>io.github.a2asdk</groupId>
-            <artifactId>a2a-java-sdk-client-transport-grpc</artifactId>
+            <artifactId>a2a-java-sdk-client-transport-jsonrpc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.github.a2asdk</groupId>
+            <artifactId>a2a-java-sdk-client-transport-rest</artifactId>
         </dependency>
 
         <!-- Dependencies needed for gRPC -->
@@ -57,7 +61,6 @@
             <plugin>
                 <groupId>org.codehaus.mojo</groupId>
                 <artifactId>exec-maven-plugin</artifactId>
-                <version>3.1.0</version>
                 <configuration>
                     <mainClass>org.wildfly.extras.a2a.examples.simple.client.SimpleExampleClient</mainClass>
                 </configuration>
@@ -100,5 +103,22 @@
                 </plugins>
             </build>
         </profile>
+        <profile>
+            <id>run-rest</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.codehaus.mojo</groupId>
+                        <artifactId>exec-maven-plugin</artifactId>
+                        <configuration>
+                            <arguments>
+                                <argument>HTTP+JSON</argument>
+                                <argument>${user.name}</argument>
+                            </arguments>
+                        </configuration>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
     </profiles>
 </project>

examples/simple/client/src/main/java/org/wildfly/extras/a2a/examples/simple/client/SimpleExampleClient.java

@@ -1,14 +1,10 @@
 package org.wildfly.extras.a2a.examples.simple.client;
 
-import java.io.Closeable;
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.BiConsumer;
 
 import io.a2a.A2A;
@@ -22,6 +18,8 @@
 import io.a2a.client.transport.grpc.GrpcTransportConfigBuilder;
 import io.a2a.client.transport.jsonrpc.JSONRPCTransport;
 import io.a2a.client.transport.jsonrpc.JSONRPCTransportConfigBuilder;
+import io.a2a.client.transport.rest.RestTransport;
+import io.a2a.client.transport.rest.RestTransportConfigBuilder;
 import io.a2a.spec.A2AClientError;
 import io.a2a.spec.A2AClientException;
 import io.a2a.spec.AgentCard;
@@ -41,16 +39,17 @@ public SimpleExampleClient(String protocol) throws A2AClientError, A2AClientExce
 
         ClientConfig config = new ClientConfig.Builder()
                 .setAcceptedOutputModes(List.of("text"))
+                .setUseClientPreference(true)
                 .build();
 
         ClientBuilder clientBuilder = Client.builder(agentCard)
                 .clientConfig(config);
 
-        if (protocol.equals(TransportProtocol.JSONRPC.name())) {
-            clientBuilder.withTransport(JSONRPCTransport.class, new JSONRPCTransportConfigBuilder());
-        } else {
-            // 'target' comes from the AgentCard, and is populated by a2a-java
-            clientBuilder.withTransport(
+        TransportProtocol prot = TransportProtocol.fromString(protocol);
+        switch (prot) {
+            case JSONRPC -> clientBuilder.withTransport(JSONRPCTransport.class, new JSONRPCTransportConfigBuilder());
+            case HTTP_JSON -> clientBuilder.withTransport(RestTransport.class, new RestTransportConfigBuilder());
+            case GRPC -> clientBuilder.withTransport(
                     GrpcTransport.class,
                     new GrpcTransportConfigBuilder().channelFactory(
                             target -> {

examples/simple/server/pom.xml

@@ -15,8 +15,8 @@
 
     <packaging>war</packaging>
 
-    <name>WildFly Extras - Java A2A SDK for Jakarta - Example - Simple</name>
-    <description>Java SDK for the Agent2Agent Protocol (A2A) - SDK - Jakarta - TCK - WildFly Jar</description>
+    <name>WildFly Extras - Java A2A SDK for Jakarta - Example - Simple Server</name>
+    <description>Java SDK for the Agent2Agent Protocol (A2A) - SDK - Jakarta - Example - Simple</description>
 
     <properties>
         <!--
@@ -40,8 +40,8 @@
         </dependency>
 
         <!--
-            The core a2a-java server dependency. Default scope since it, and
-            a lot of its dependencies should be included in the war.  -->
+        The core a2a-java server dependency. Default scope since it, and
+        a lot of its dependencies should be included in the war.  -->
         <dependency>
             <groupId>io.github.a2asdk</groupId>
             <artifactId>a2a-java-sdk-server-common</artifactId>
@@ -79,7 +79,7 @@
                 <groupId>org.wildfly.plugins</groupId>
                 <artifactId>wildfly-maven-plugin</artifactId>
                 <configuration>
-                     <feature-packs>
+                    <feature-packs>
                         <feature-pack>
                             <groupId>org.wildfly</groupId>
                             <artifactId>wildfly-galleon-pack</artifactId>
@@ -157,10 +157,10 @@
                 </dependency>
 
                 <!--
-                    gRPC needs JSONRPC to get the agent card.
-                    This is likely to change in the future. So for now include the
-                    JSONRCP dependencies here.
-                 -->
+                   gRPC needs JSONRPC to get the agent card.
+                   This is likely to change in the future. So for now include the
+                   JSONRCP dependencies here.
+                -->
                 <dependency>
                     <groupId>${project.groupId}</groupId>
                     <artifactId>a2a-java-sdk-jakarta-jsonrpc</artifactId>
@@ -174,7 +174,7 @@
                         <groupId>org.wildfly.plugins</groupId>
                         <artifactId>wildfly-maven-plugin</artifactId>
                         <configuration>
-                             <feature-packs>
+                            <feature-packs>
                                 <!--
                                     Still include the main WildFly feature pack, so we are not stuck
                                     to the version used by the gRPC feature pack
@@ -184,7 +184,7 @@
                                     <artifactId>wildfly-galleon-pack</artifactId>
                                     <version>${version.wildfly}</version>
                                 </feature-pack>
-                                 <!-- Add the gRPC feature pack -->
+                                <!-- Add the gRPC feature pack -->
                                 <feature-pack>
                                     <groupId>org.wildfly.extras.grpc</groupId>
                                     <artifactId>wildfly-grpc-feature-pack</artifactId>
@@ -231,9 +231,16 @@
                     <artifactId>a2a-java-sdk-jakarta-rest</artifactId>
                     <version>${project.version}</version>
                 </dependency>
+
+                <!--
+                   gRPC needs JSONRPC to get the agent card.
+                   This is likely to change in the future. So for now include the
+                   JSONRCP dependencies here.
+                -->
                 <dependency>
-                    <groupId>com.google.protobuf</groupId>
-                    <artifactId>protobuf-java-util</artifactId>
+                    <groupId>${project.groupId}</groupId>
+                    <artifactId>a2a-java-sdk-jakarta-jsonrpc</artifactId>
+                    <version>${project.version}</version>
                 </dependency>
             </dependencies>
         </profile>

examples/simple/server/src/main/java/org/wildfly/extras/a2a/examples/simple/SimpleExampleAgentCardProducer.java

@@ -27,7 +27,11 @@ public AgentCard createAgentCard() {
         interfaces.add(
                 new AgentInterface(
                         TransportProtocol.JSONRPC.asString(), jsonRpcUrl));
-
+        if(isRest()) {
+        interfaces.add(
+                new AgentInterface(
+                        TransportProtocol.HTTP_JSON.asString(), jsonRpcUrl));
+        }
         if (isGrpcEnabled()) {
             interfaces.add(
                     new AgentInterface(
@@ -63,4 +67,13 @@ private boolean isGrpcEnabled() {
             return false;
         }
     }
+
+    private boolean isRest() {
+        try {
+            Class.forName("org.wildfly.extras.a2a.server.apps.rest.WildflyRestTransportMetadata");
+            return true;
+        } catch (Throwable t) {
+            return false;
+        }
+    }
 }