Skip to content

Commit 587195f

Browse files
kabirkabir
committed
Align with a2a-java main.
The biggest change is the package rename
1 parent a1cf9c9 commit 587195f

File tree

23 files changed

+252
-232
lines changed

23 files changed

+252
-232
lines changed

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

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -7,28 +7,28 @@
77
import java.util.concurrent.TimeUnit;
88
import java.util.function.BiConsumer;
99

10-
import io.a2a.A2A;
11-
import io.a2a.client.Client;
12-
import io.a2a.client.ClientBuilder;
13-
import io.a2a.client.ClientEvent;
14-
import io.a2a.client.TaskEvent;
15-
import io.a2a.client.config.ClientConfig;
16-
import io.a2a.client.http.A2ACardResolver;
17-
import io.a2a.client.transport.grpc.GrpcTransport;
18-
import io.a2a.client.transport.grpc.GrpcTransportConfigBuilder;
19-
import io.a2a.client.transport.jsonrpc.JSONRPCTransport;
20-
import io.a2a.client.transport.jsonrpc.JSONRPCTransportConfigBuilder;
21-
import io.a2a.client.transport.rest.RestTransport;
22-
import io.a2a.client.transport.rest.RestTransportConfigBuilder;
23-
import io.a2a.spec.A2AClientError;
24-
import io.a2a.spec.A2AClientException;
25-
import io.a2a.spec.AgentCard;
26-
import io.a2a.spec.Artifact;
27-
import io.a2a.spec.Message;
28-
import io.a2a.spec.Part;
29-
import io.a2a.spec.Task;
30-
import io.a2a.spec.TextPart;
31-
import io.a2a.spec.TransportProtocol;
10+
import org.a2aproject.sdk.A2A;
11+
import org.a2aproject.sdk.client.Client;
12+
import org.a2aproject.sdk.client.ClientBuilder;
13+
import org.a2aproject.sdk.client.ClientEvent;
14+
import org.a2aproject.sdk.client.TaskEvent;
15+
import org.a2aproject.sdk.client.config.ClientConfig;
16+
import org.a2aproject.sdk.client.http.A2ACardResolver;
17+
import org.a2aproject.sdk.client.transport.grpc.GrpcTransport;
18+
import org.a2aproject.sdk.client.transport.grpc.GrpcTransportConfigBuilder;
19+
import org.a2aproject.sdk.client.transport.jsonrpc.JSONRPCTransport;
20+
import org.a2aproject.sdk.client.transport.jsonrpc.JSONRPCTransportConfigBuilder;
21+
import org.a2aproject.sdk.client.transport.rest.RestTransport;
22+
import org.a2aproject.sdk.client.transport.rest.RestTransportConfigBuilder;
23+
import org.a2aproject.sdk.spec.A2AClientError;
24+
import org.a2aproject.sdk.spec.A2AClientException;
25+
import org.a2aproject.sdk.spec.AgentCard;
26+
import org.a2aproject.sdk.spec.Artifact;
27+
import org.a2aproject.sdk.spec.Message;
28+
import org.a2aproject.sdk.spec.Part;
29+
import org.a2aproject.sdk.spec.Task;
30+
import org.a2aproject.sdk.spec.TextPart;
31+
import org.a2aproject.sdk.spec.TransportProtocol;
3232
import io.grpc.ManagedChannelBuilder;
3333

3434
public class SimpleExampleClient implements AutoCloseable {

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,12 +7,12 @@
77
import jakarta.enterprise.context.ApplicationScoped;
88
import jakarta.enterprise.inject.Produces;
99

10-
import io.a2a.server.PublicAgentCard;
11-
import io.a2a.spec.AgentCapabilities;
12-
import io.a2a.spec.AgentCard;
13-
import io.a2a.spec.AgentInterface;
14-
import io.a2a.spec.AgentSkill;
15-
import io.a2a.spec.TransportProtocol;
10+
import org.a2aproject.sdk.server.PublicAgentCard;
11+
import org.a2aproject.sdk.spec.AgentCapabilities;
12+
import org.a2aproject.sdk.spec.AgentCard;
13+
import org.a2aproject.sdk.spec.AgentInterface;
14+
import org.a2aproject.sdk.spec.AgentSkill;
15+
import org.a2aproject.sdk.spec.TransportProtocol;
1616

1717
@ApplicationScoped
1818
public class SimpleExampleAgentCardProducer {

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

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,13 +6,13 @@
66
import jakarta.enterprise.context.ApplicationScoped;
77
import jakarta.enterprise.inject.Produces;
88

9-
import io.a2a.server.agentexecution.AgentExecutor;
10-
import io.a2a.server.agentexecution.RequestContext;
11-
import io.a2a.server.tasks.AgentEmitter;
12-
import io.a2a.spec.A2AError;
13-
import io.a2a.spec.Part;
14-
import io.a2a.spec.TaskNotCancelableError;
15-
import io.a2a.spec.TextPart;
9+
import org.a2aproject.sdk.server.agentexecution.AgentExecutor;
10+
import org.a2aproject.sdk.server.agentexecution.RequestContext;
11+
import org.a2aproject.sdk.server.tasks.AgentEmitter;
12+
import org.a2aproject.sdk.spec.A2AError;
13+
import org.a2aproject.sdk.spec.Part;
14+
import org.a2aproject.sdk.spec.TaskNotCancelableError;
15+
import org.a2aproject.sdk.spec.TextPart;
1616

1717
@ApplicationScoped
1818
public class SimpleExampleAgentExecutorProducer {

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

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -9,12 +9,12 @@
99
import jakarta.enterprise.inject.Instance;
1010
import jakarta.inject.Inject;
1111

12-
import io.a2a.server.ExtendedAgentCard;
13-
import io.a2a.server.PublicAgentCard;
14-
import io.a2a.server.requesthandlers.RequestHandler;
15-
import io.a2a.server.util.async.Internal;
16-
import io.a2a.spec.AgentCard;
17-
import io.a2a.transport.grpc.handler.CallContextFactory;
12+
import org.a2aproject.sdk.server.ExtendedAgentCard;
13+
import org.a2aproject.sdk.server.PublicAgentCard;
14+
import org.a2aproject.sdk.server.requesthandlers.RequestHandler;
15+
import org.a2aproject.sdk.server.util.async.Internal;
16+
import org.a2aproject.sdk.spec.AgentCard;
17+
import org.a2aproject.sdk.transport.grpc.handler.CallContextFactory;
1818

1919
/**
2020
* Bean initializer that observes application startup events.
@@ -62,7 +62,7 @@ public void onStartup(@Observes @Initialized(ApplicationScoped.class) Object ini
6262
// Without this, if ClientBuilder loads earlier with the wrong TCCL, the static registry
6363
// won't contain the gRPC transport provider
6464
try {
65-
Class.forName("io.a2a.client.ClientBuilder", true, deploymentClassLoader);
65+
Class.forName("org.a2aproject.sdk.client.ClientBuilder", true, deploymentClassLoader);
6666
} catch (ClassNotFoundException e) {
6767
// ClientBuilder not in deployment, ignore
6868
}

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

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -3,26 +3,26 @@
33
import java.util.concurrent.Executor;
44
import java.util.concurrent.Flow;
55

6-
import io.a2a.jsonrpc.common.wrappers.ListTasksResult;
7-
import io.a2a.server.ServerCallContext;
8-
import io.a2a.server.requesthandlers.RequestHandler;
9-
import io.a2a.spec.A2AError;
10-
import io.a2a.spec.AgentCard;
11-
import io.a2a.spec.CancelTaskParams;
12-
import io.a2a.spec.DeleteTaskPushNotificationConfigParams;
13-
import io.a2a.spec.EventKind;
14-
import io.a2a.spec.GetTaskPushNotificationConfigParams;
15-
import io.a2a.spec.ListTaskPushNotificationConfigsParams;
16-
import io.a2a.spec.ListTaskPushNotificationConfigsResult;
17-
import io.a2a.spec.ListTasksParams;
18-
import io.a2a.spec.MessageSendParams;
19-
import io.a2a.spec.StreamingEventKind;
20-
import io.a2a.spec.Task;
21-
import io.a2a.spec.TaskIdParams;
22-
import io.a2a.spec.TaskPushNotificationConfig;
23-
import io.a2a.spec.TaskQueryParams;
24-
import io.a2a.transport.grpc.handler.CallContextFactory;
25-
import io.a2a.transport.grpc.handler.GrpcHandler;
6+
import org.a2aproject.sdk.jsonrpc.common.wrappers.ListTasksResult;
7+
import org.a2aproject.sdk.server.ServerCallContext;
8+
import org.a2aproject.sdk.server.requesthandlers.RequestHandler;
9+
import org.a2aproject.sdk.spec.A2AError;
10+
import org.a2aproject.sdk.spec.AgentCard;
11+
import org.a2aproject.sdk.spec.CancelTaskParams;
12+
import org.a2aproject.sdk.spec.DeleteTaskPushNotificationConfigParams;
13+
import org.a2aproject.sdk.spec.EventKind;
14+
import org.a2aproject.sdk.spec.GetTaskPushNotificationConfigParams;
15+
import org.a2aproject.sdk.spec.ListTaskPushNotificationConfigsParams;
16+
import org.a2aproject.sdk.spec.ListTaskPushNotificationConfigsResult;
17+
import org.a2aproject.sdk.spec.ListTasksParams;
18+
import org.a2aproject.sdk.spec.MessageSendParams;
19+
import org.a2aproject.sdk.spec.StreamingEventKind;
20+
import org.a2aproject.sdk.spec.Task;
21+
import org.a2aproject.sdk.spec.TaskIdParams;
22+
import org.a2aproject.sdk.spec.TaskPushNotificationConfig;
23+
import org.a2aproject.sdk.spec.TaskQueryParams;
24+
import org.a2aproject.sdk.transport.grpc.handler.CallContextFactory;
25+
import org.a2aproject.sdk.transport.grpc.handler.GrpcHandler;
2626

2727
/**
2828
* WildFly gRPC Handler that uses static cache for CDI beans.

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package org.wildfly.extras.a2a.server.apps.grpc;
22

3-
import io.a2a.server.TransportMetadata;
4-
import io.a2a.spec.TransportProtocol;
3+
import org.a2aproject.sdk.server.TransportMetadata;
4+
import org.a2aproject.sdk.spec.TransportProtocol;
55

66
public class WildFlyGrpcTransportMetadata implements TransportMetadata {
77
@Override

impl/grpc/src/main/resources/META-INF/services/io.a2a.server.TransportMetadata renamed to impl/grpc/src/main/resources/META-INF/services/org.a2aproject.sdk.server.TransportMetadata

File renamed without changes.

‎impl/jsonrpc/src/main/java/org/wildfly/extras/a2a/server/apps/jsonrpc/A2ARequestFilter.java‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
11
package org.wildfly.extras.a2a.server.apps.jsonrpc;
22

33

4-
import static io.a2a.spec.A2AMethods.CANCEL_TASK_METHOD;
5-
import static io.a2a.spec.A2AMethods.DELETE_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
6-
import static io.a2a.spec.A2AMethods.GET_EXTENDED_AGENT_CARD_METHOD;
7-
import static io.a2a.spec.A2AMethods.GET_TASK_METHOD;
8-
import static io.a2a.spec.A2AMethods.GET_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
9-
import static io.a2a.spec.A2AMethods.LIST_TASK_METHOD;
10-
import static io.a2a.spec.A2AMethods.LIST_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
11-
import static io.a2a.spec.A2AMethods.SEND_MESSAGE_METHOD;
12-
import static io.a2a.spec.A2AMethods.SEND_STREAMING_MESSAGE_METHOD;
13-
import static io.a2a.spec.A2AMethods.SET_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
4+
import static org.a2aproject.sdk.spec.A2AMethods.CANCEL_TASK_METHOD;
5+
import static org.a2aproject.sdk.spec.A2AMethods.DELETE_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
6+
import static org.a2aproject.sdk.spec.A2AMethods.GET_EXTENDED_AGENT_CARD_METHOD;
7+
import static org.a2aproject.sdk.spec.A2AMethods.GET_TASK_METHOD;
8+
import static org.a2aproject.sdk.spec.A2AMethods.GET_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
9+
import static org.a2aproject.sdk.spec.A2AMethods.LIST_TASK_METHOD;
10+
import static org.a2aproject.sdk.spec.A2AMethods.LIST_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
11+
import static org.a2aproject.sdk.spec.A2AMethods.SEND_MESSAGE_METHOD;
12+
import static org.a2aproject.sdk.spec.A2AMethods.SEND_STREAMING_MESSAGE_METHOD;
13+
import static org.a2aproject.sdk.spec.A2AMethods.SET_TASK_PUSH_NOTIFICATION_CONFIG_METHOD;
1414

1515
import java.io.ByteArrayInputStream;
1616
import java.io.IOException;
@@ -22,7 +22,7 @@
2222
import jakarta.ws.rs.core.MediaType;
2323
import jakarta.ws.rs.ext.Provider;
2424

25-
import io.a2a.spec.A2AMethods;
25+
import org.a2aproject.sdk.spec.A2AMethods;
2626
import org.slf4j.Logger;
2727
import org.slf4j.LoggerFactory;
2828

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

Lines changed: 58 additions & 55 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package org.wildfly.extras.a2a.server.apps.jsonrpc;
22

3-
import static io.a2a.server.ServerCallContext.TRANSPORT_KEY;
4-
import static io.a2a.transport.jsonrpc.context.JSONRPCContextKeys.HEADERS_KEY;
5-
import static io.a2a.transport.jsonrpc.context.JSONRPCContextKeys.TENANT_KEY;
3+
import static org.a2aproject.sdk.server.ServerCallContext.TRANSPORT_KEY;
4+
import static org.a2aproject.sdk.transport.jsonrpc.context.JSONRPCContextKeys.HEADERS_KEY;
5+
import static org.a2aproject.sdk.transport.jsonrpc.context.JSONRPCContextKeys.TENANT_KEY;
66

77
import java.io.IOException;
88
import java.io.PrintWriter;
@@ -36,47 +36,47 @@
3636
import jakarta.ws.rs.core.SecurityContext;
3737

3838
import com.google.gson.JsonSyntaxException;
39-
import io.a2a.common.A2AHeaders;
40-
import io.a2a.grpc.utils.JSONRPCUtils;
41-
import io.a2a.grpc.utils.ProtoUtils;
42-
import io.a2a.jsonrpc.common.json.IdJsonMappingException;
43-
import io.a2a.jsonrpc.common.json.InvalidParamsJsonMappingException;
44-
import io.a2a.jsonrpc.common.json.JsonMappingException;
45-
import io.a2a.jsonrpc.common.json.JsonProcessingException;
46-
import io.a2a.jsonrpc.common.json.MethodNotFoundJsonMappingException;
47-
import io.a2a.jsonrpc.common.wrappers.A2AErrorResponse;
48-
import io.a2a.jsonrpc.common.wrappers.A2ARequest;
49-
import io.a2a.jsonrpc.common.wrappers.A2AResponse;
50-
import io.a2a.jsonrpc.common.wrappers.CancelTaskRequest;
51-
import io.a2a.jsonrpc.common.wrappers.CreateTaskPushNotificationConfigRequest;
52-
import io.a2a.jsonrpc.common.wrappers.DeleteTaskPushNotificationConfigRequest;
53-
import io.a2a.jsonrpc.common.wrappers.GetExtendedAgentCardRequest;
54-
import io.a2a.jsonrpc.common.wrappers.GetTaskPushNotificationConfigRequest;
55-
import io.a2a.jsonrpc.common.wrappers.GetTaskRequest;
56-
import io.a2a.jsonrpc.common.wrappers.ListTaskPushNotificationConfigsRequest;
57-
import io.a2a.jsonrpc.common.wrappers.ListTasksRequest;
58-
import io.a2a.jsonrpc.common.wrappers.NonStreamingJSONRPCRequest;
59-
import io.a2a.jsonrpc.common.wrappers.SendMessageRequest;
60-
import io.a2a.jsonrpc.common.wrappers.SendStreamingMessageRequest;
61-
import io.a2a.jsonrpc.common.wrappers.StreamingJSONRPCRequest;
62-
import io.a2a.jsonrpc.common.wrappers.SubscribeToTaskRequest;
63-
import io.a2a.server.ExtendedAgentCard;
64-
import io.a2a.server.ServerCallContext;
65-
import io.a2a.server.auth.UnauthenticatedUser;
66-
import io.a2a.server.auth.User;
67-
import io.a2a.server.extensions.A2AExtensions;
68-
import io.a2a.server.util.async.Internal;
69-
import io.a2a.server.util.sse.SseFormatter;
70-
import io.a2a.spec.A2AError;
71-
import io.a2a.spec.AgentCard;
72-
import io.a2a.spec.InternalError;
73-
import io.a2a.spec.InvalidParamsError;
74-
import io.a2a.spec.InvalidRequestError;
75-
import io.a2a.spec.JSONParseError;
76-
import io.a2a.spec.MethodNotFoundError;
77-
import io.a2a.spec.TransportProtocol;
78-
import io.a2a.spec.UnsupportedOperationError;
79-
import io.a2a.transport.jsonrpc.handler.JSONRPCHandler;
39+
import org.a2aproject.sdk.common.A2AHeaders;
40+
import org.a2aproject.sdk.grpc.utils.JSONRPCUtils;
41+
import org.a2aproject.sdk.grpc.utils.ProtoUtils;
42+
import org.a2aproject.sdk.jsonrpc.common.json.IdJsonMappingException;
43+
import org.a2aproject.sdk.jsonrpc.common.json.InvalidParamsJsonMappingException;
44+
import org.a2aproject.sdk.jsonrpc.common.json.JsonMappingException;
45+
import org.a2aproject.sdk.jsonrpc.common.json.JsonProcessingException;
46+
import org.a2aproject.sdk.jsonrpc.common.json.MethodNotFoundJsonMappingException;
47+
import org.a2aproject.sdk.jsonrpc.common.wrappers.A2AErrorResponse;
48+
import org.a2aproject.sdk.jsonrpc.common.wrappers.A2ARequest;
49+
import org.a2aproject.sdk.jsonrpc.common.wrappers.A2AResponse;
50+
import org.a2aproject.sdk.jsonrpc.common.wrappers.CancelTaskRequest;
51+
import org.a2aproject.sdk.jsonrpc.common.wrappers.CreateTaskPushNotificationConfigRequest;
52+
import org.a2aproject.sdk.jsonrpc.common.wrappers.DeleteTaskPushNotificationConfigRequest;
53+
import org.a2aproject.sdk.jsonrpc.common.wrappers.GetExtendedAgentCardRequest;
54+
import org.a2aproject.sdk.jsonrpc.common.wrappers.GetTaskPushNotificationConfigRequest;
55+
import org.a2aproject.sdk.jsonrpc.common.wrappers.GetTaskRequest;
56+
import org.a2aproject.sdk.jsonrpc.common.wrappers.ListTaskPushNotificationConfigsRequest;
57+
import org.a2aproject.sdk.jsonrpc.common.wrappers.ListTasksRequest;
58+
import org.a2aproject.sdk.jsonrpc.common.wrappers.NonStreamingJSONRPCRequest;
59+
import org.a2aproject.sdk.jsonrpc.common.wrappers.SendMessageRequest;
60+
import org.a2aproject.sdk.jsonrpc.common.wrappers.SendStreamingMessageRequest;
61+
import org.a2aproject.sdk.jsonrpc.common.wrappers.StreamingJSONRPCRequest;
62+
import org.a2aproject.sdk.jsonrpc.common.wrappers.SubscribeToTaskRequest;
63+
import org.a2aproject.sdk.server.ExtendedAgentCard;
64+
import org.a2aproject.sdk.server.ServerCallContext;
65+
import org.a2aproject.sdk.server.auth.UnauthenticatedUser;
66+
import org.a2aproject.sdk.server.auth.User;
67+
import org.a2aproject.sdk.server.extensions.A2AExtensions;
68+
import org.a2aproject.sdk.server.util.async.Internal;
69+
import org.a2aproject.sdk.server.util.sse.SseFormatter;
70+
import org.a2aproject.sdk.spec.A2AError;
71+
import org.a2aproject.sdk.spec.AgentCard;
72+
import org.a2aproject.sdk.spec.InternalError;
73+
import org.a2aproject.sdk.spec.InvalidParamsError;
74+
import org.a2aproject.sdk.spec.InvalidRequestError;
75+
import org.a2aproject.sdk.spec.JSONParseError;
76+
import org.a2aproject.sdk.spec.MethodNotFoundError;
77+
import org.a2aproject.sdk.spec.TransportProtocol;
78+
import org.a2aproject.sdk.spec.UnsupportedOperationError;
79+
import org.a2aproject.sdk.transport.jsonrpc.handler.JSONRPCHandler;
8080
import org.slf4j.Logger;
8181
import org.slf4j.LoggerFactory;
8282

@@ -151,7 +151,7 @@ public Response handleNonStreamingRequests(
151151
// Serialize response using protobuf conversion
152152
String serialized = serializeResponse(response);
153153

154-
String contentType = io.a2a.common.MediaType.APPLICATION_JSON;
154+
String contentType = org.a2aproject.sdk.common.MediaType.APPLICATION_JSON;
155155

156156
// Return Response with explicit content-type header
157157
return Response.status(Response.Status.OK)
@@ -223,6 +223,9 @@ public void handleStreamingRequests(
223223
} catch (JsonProcessingException e) {
224224
LOGGER.warn("JSON processing error in streaming request: {}", e.getMessage());
225225
sendErrorSSE(response, null, new JSONParseError());
226+
} catch (A2AError e) {
227+
LOGGER.debug("A2AError in streaming request: {}", e.getMessage());
228+
sendErrorSSE(response, request != null ? request.getId() : null, e);
226229
} catch (Throwable e) {
227230
LOGGER.error("Unexpected error processing streaming request: {}", e.getMessage(), e);
228231
sendErrorSSE(response, null, new InternalError(e.getMessage()));
@@ -522,26 +525,26 @@ private static String serializeResponse(A2AResponse<?> response) {
522525
* Converts A2A response objects to their protobuf equivalents.
523526
*/
524527
private static com.google.protobuf.MessageOrBuilder convertToProto(A2AResponse<?> response) {
525-
if (response instanceof io.a2a.jsonrpc.common.wrappers.GetTaskResponse r) {
528+
if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.GetTaskResponse r) {
526529
return ProtoUtils.ToProto.task(r.getResult());
527-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.CancelTaskResponse r) {
530+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.CancelTaskResponse r) {
528531
return ProtoUtils.ToProto.task(r.getResult());
529-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.SendMessageResponse r) {
532+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.SendMessageResponse r) {
530533
return ProtoUtils.ToProto.taskOrMessage(r.getResult());
531-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.ListTasksResponse r) {
534+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.ListTasksResponse r) {
532535
return ProtoUtils.ToProto.listTasksResult(r.getResult());
533-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.CreateTaskPushNotificationConfigResponse r) {
536+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.CreateTaskPushNotificationConfigResponse r) {
534537
return ProtoUtils.ToProto.createTaskPushNotificationConfigResponse(r.getResult());
535-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.GetTaskPushNotificationConfigResponse r) {
538+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.GetTaskPushNotificationConfigResponse r) {
536539
return ProtoUtils.ToProto.getTaskPushNotificationConfigResponse(r.getResult());
537-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.ListTaskPushNotificationConfigsResponse r) {
540+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.ListTaskPushNotificationConfigsResponse r) {
538541
return ProtoUtils.ToProto.listTaskPushNotificationConfigsResponse(r.getResult());
539-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.DeleteTaskPushNotificationConfigResponse) {
542+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.DeleteTaskPushNotificationConfigResponse) {
540543
// DeleteTaskPushNotificationConfig has no result body, just return empty message
541544
return com.google.protobuf.Empty.getDefaultInstance();
542-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.GetExtendedAgentCardResponse r) {
545+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.GetExtendedAgentCardResponse r) {
543546
return ProtoUtils.ToProto.getExtendedCardResponse(r.getResult());
544-
} else if (response instanceof io.a2a.jsonrpc.common.wrappers.SendStreamingMessageResponse r) {
547+
} else if (response instanceof org.a2aproject.sdk.jsonrpc.common.wrappers.SendStreamingMessageResponse r) {
545548
return ProtoUtils.ToProto.taskOrMessageStream(r.getResult());
546549
} else {
547550
throw new IllegalArgumentException("Unknown response type: " + response.getClass().getName());

‎impl/jsonrpc/src/main/java/org/wildfly/extras/a2a/server/apps/jsonrpc/CallContextFactory.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33

44
import jakarta.servlet.http.HttpServletRequest;
55

6-
import io.a2a.server.ServerCallContext;
6+
import org.a2aproject.sdk.server.ServerCallContext;
77

88
public interface CallContextFactory {
99
ServerCallContext build(HttpServletRequest request);

0 commit comments

Comments
 (0)