Remove unused imports

kabir · kabir · commit 81b2038e4071 · 2025-11-19T15:43:40.000Z
diff --git a/boms/test-utils/src/main/java/io/a2a/bom/test/DynamicBomVerifier.java b/boms/test-utils/src/main/java/io/a2a/bom/test/DynamicBomVerifier.java
@@ -7,7 +7,6 @@
 import java.util.*;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
-import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 /**
diff --git a/client/base/src/main/java/io/a2a/A2A.java b/client/base/src/main/java/io/a2a/A2A.java
@@ -3,7 +3,6 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
-import java.util.UUID;
 
 import io.a2a.client.http.A2ACardResolver;
 import io.a2a.client.http.A2AHttpClient;
diff --git a/client/transport/rest/src/main/java/io/a2a/client/transport/rest/sse/RestSSEEventListener.java b/client/transport/rest/src/main/java/io/a2a/client/transport/rest/sse/RestSSEEventListener.java
@@ -1,10 +1,5 @@
 package io.a2a.client.transport.rest.sse;
 
-import static io.a2a.grpc.StreamResponse.PayloadCase.ARTIFACT_UPDATE;
-import static io.a2a.grpc.StreamResponse.PayloadCase.MSG;
-import static io.a2a.grpc.StreamResponse.PayloadCase.STATUS_UPDATE;
-import static io.a2a.grpc.StreamResponse.PayloadCase.TASK;
-
 import java.util.concurrent.Future;
 import java.util.function.Consumer;
 import java.util.logging.Logger;
@@ -62,7 +57,8 @@ private void handleMessage(StreamResponse response) {
                 event = ProtoUtils.FromProto.taskArtifactUpdateEvent(response.getArtifactUpdate());
             default -> {
                 log.warning("Invalid stream response " + response.getPayloadCase());
-                errorHandler.accept(new IllegalStateException("Invalid stream response from server: " + response.getPayloadCase()));
+                errorHandler.accept(
+                        new IllegalStateException("Invalid stream response from server: " + response.getPayloadCase()));
                 return;
             }
         }
diff --git a/examples/helloworld/client/src/main/java/io/a2a/examples/helloworld/HelloWorldClient.java b/examples/helloworld/client/src/main/java/io/a2a/examples/helloworld/HelloWorldClient.java
@@ -12,7 +12,6 @@
 import io.a2a.A2A;
 
 import io.a2a.client.Client;
-import io.a2a.client.ClientBuilder;
 import io.a2a.client.ClientEvent;
 import io.a2a.client.MessageEvent;
 import io.a2a.client.http.A2ACardResolver;
diff --git a/extras/task-store-database-jpa/src/main/java/io/a2a/extras/taskstore/database/jpa/JpaDatabaseTaskStore.java b/extras/task-store-database-jpa/src/main/java/io/a2a/extras/taskstore/database/jpa/JpaDatabaseTaskStore.java
@@ -3,9 +3,7 @@
 import java.time.Duration;
 import java.time.Instant;
 import java.util.ArrayList;
-import java.util.Comparator;
 import java.util.List;
-import java.util.stream.Stream;
 
 import jakarta.annotation.Priority;
 import jakarta.enterprise.context.ApplicationScoped;
diff --git a/reference/rest/src/test/java/io/a2a/server/rest/quarkus/A2ATestRoutes.java b/reference/rest/src/test/java/io/a2a/server/rest/quarkus/A2ATestRoutes.java
@@ -1,7 +1,5 @@
 package io.a2a.server.rest.quarkus;
 
-import io.a2a.server.rest.quarkus.A2AServerRoutes;
-
 import static io.vertx.core.http.HttpHeaders.CONTENT_TYPE;
 import static jakarta.ws.rs.core.MediaType.APPLICATION_JSON;
 import static jakarta.ws.rs.core.MediaType.TEXT_PLAIN;
@@ -41,28 +39,29 @@ public void init() {
         A2AServerRoutes.setStreamingMultiSseSupportSubscribedRunnable(() -> streamingSubscribedCount.incrementAndGet());
     }
 
-
-    @Route(path = "/test/task", methods = {Route.HttpMethod.POST}, consumes = {APPLICATION_JSON}, type = Route.HandlerType.BLOCKING)
+    @Route(path = "/test/task", methods = { Route.HttpMethod.POST }, consumes = {
+            APPLICATION_JSON }, type = Route.HandlerType.BLOCKING)
     public void saveTask(@Body String body, RoutingContext rc) {
         try {
             Task task = Utils.OBJECT_MAPPER.readValue(body, Task.class);
             testUtilsBean.saveTask(task);
             rc.response()
-                .setStatusCode(200)
-                .end();
+                    .setStatusCode(200)
+                    .end();
         } catch (Throwable t) {
             errorResponse(t, rc);
         }
     }
 
-    @Route(path = "/test/task/:taskId", methods = {Route.HttpMethod.GET}, produces = {APPLICATION_JSON}, type = Route.HandlerType.BLOCKING)
-    public void getTask(@Param String taskId,  RoutingContext rc) {
+    @Route(path = "/test/task/:taskId", methods = { Route.HttpMethod.GET }, produces = {
+            APPLICATION_JSON }, type = Route.HandlerType.BLOCKING)
+    public void getTask(@Param String taskId, RoutingContext rc) {
         try {
             Task task = testUtilsBean.getTask(taskId);
             if (task == null) {
                 rc.response()
-                    .setStatusCode(404)
-                    .end();
+                        .setStatusCode(404)
+                        .end();
                 return;
             }
             rc.response()
@@ -75,7 +74,7 @@ public void getTask(@Param String taskId,  RoutingContext rc) {
         }
     }
 
-    @Route(path = "/test/task/:taskId", methods = {Route.HttpMethod.DELETE}, type = Route.HandlerType.BLOCKING)
+    @Route(path = "/test/task/:taskId", methods = { Route.HttpMethod.DELETE }, type = Route.HandlerType.BLOCKING)
     public void deleteTask(@Param String taskId, RoutingContext rc) {
         try {
             Task task = testUtilsBean.getTask(taskId);
@@ -94,7 +93,7 @@ public void deleteTask(@Param String taskId, RoutingContext rc) {
         }
     }
 
-    @Route(path = "/test/queue/ensure/:taskId", methods = {Route.HttpMethod.POST})
+    @Route(path = "/test/queue/ensure/:taskId", methods = { Route.HttpMethod.POST })
     public void ensureTaskQueue(@Param String taskId, RoutingContext rc) {
         try {
             testUtilsBean.ensureQueue(taskId);
@@ -106,7 +105,7 @@ public void ensureTaskQueue(@Param String taskId, RoutingContext rc) {
         }
     }
 
-    @Route(path = "/test/queue/enqueueTaskStatusUpdateEvent/:taskId", methods = {Route.HttpMethod.POST})
+    @Route(path = "/test/queue/enqueueTaskStatusUpdateEvent/:taskId", methods = { Route.HttpMethod.POST })
     public void enqueueTaskStatusUpdateEvent(@Param String taskId, @Body String body, RoutingContext rc) {
 
         try {
@@ -120,7 +119,7 @@ public void enqueueTaskStatusUpdateEvent(@Param String taskId, @Body String body
         }
     }
 
-    @Route(path = "/test/queue/enqueueTaskArtifactUpdateEvent/:taskId", methods = {Route.HttpMethod.POST})
+    @Route(path = "/test/queue/enqueueTaskArtifactUpdateEvent/:taskId", methods = { Route.HttpMethod.POST })
     public void enqueueTaskArtifactUpdateEvent(@Param String taskId, @Body String body, RoutingContext rc) {
 
         try {
@@ -134,22 +133,23 @@ public void enqueueTaskArtifactUpdateEvent(@Param String taskId, @Body String bo
         }
     }
 
-    @Route(path = "/test/streamingSubscribedCount", methods = {Route.HttpMethod.GET}, produces = {TEXT_PLAIN})
+    @Route(path = "/test/streamingSubscribedCount", methods = { Route.HttpMethod.GET }, produces = { TEXT_PLAIN })
     public void getStreamingSubscribedCount(RoutingContext rc) {
         rc.response()
                 .setStatusCode(200)
                 .end(String.valueOf(streamingSubscribedCount.get()));
     }
 
-    @Route(path = "/test/queue/childCount/:taskId", methods = {Route.HttpMethod.GET}, produces = {TEXT_PLAIN})
+    @Route(path = "/test/queue/childCount/:taskId", methods = { Route.HttpMethod.GET }, produces = { TEXT_PLAIN })
     public void getChildQueueCount(@Param String taskId, RoutingContext rc) {
         int count = testUtilsBean.getChildQueueCount(taskId);
         rc.response()
                 .setStatusCode(200)
                 .end(String.valueOf(count));
     }
 
-    @Route(path = "/test/task/:taskId/config/:configId", methods = {Route.HttpMethod.DELETE}, type = Route.HandlerType.BLOCKING)
+    @Route(path = "/test/task/:taskId/config/:configId", methods = {
+            Route.HttpMethod.DELETE }, type = Route.HandlerType.BLOCKING)
     public void deleteTaskPushNotificationConfig(@Param String taskId, @Param String configId, RoutingContext rc) {
         try {
             Task task = testUtilsBean.getTask(taskId);
@@ -168,10 +168,11 @@ public void deleteTaskPushNotificationConfig(@Param String taskId, @Param String
         }
     }
 
-    @Route(path = "/test/task/:taskId", methods = {Route.HttpMethod.POST}, type = Route.HandlerType.BLOCKING)
+    @Route(path = "/test/task/:taskId", methods = { Route.HttpMethod.POST }, type = Route.HandlerType.BLOCKING)
     public void saveTaskPushNotificationConfig(@Param String taskId, @Body String body, RoutingContext rc) {
         try {
-            PushNotificationConfig notificationConfig = Utils.OBJECT_MAPPER.readValue(body, PushNotificationConfig.class);
+            PushNotificationConfig notificationConfig = Utils.OBJECT_MAPPER.readValue(body,
+                    PushNotificationConfig.class);
             if (notificationConfig == null) {
                 rc.response()
                         .setStatusCode(404)
diff --git a/server-common/src/main/java/io/a2a/server/TransportMetadata.java b/server-common/src/main/java/io/a2a/server/TransportMetadata.java
@@ -1,6 +1,5 @@
 package io.a2a.server;
 
-import io.a2a.spec.TransportProtocol;
 
 /**
  * Interface for transport endpoint implementations to provide metadata about their transport.
diff --git a/server-common/src/main/java/io/a2a/server/extensions/A2AExtensions.java b/server-common/src/main/java/io/a2a/server/extensions/A2AExtensions.java
@@ -4,7 +4,6 @@
 import java.util.List;
 import java.util.Set;
 
-import io.a2a.common.A2AHeaders;
 import io.a2a.spec.AgentCard;
 import io.a2a.spec.AgentExtension;
 
diff --git a/server-common/src/main/java/io/a2a/server/tasks/InMemoryTaskStore.java b/server-common/src/main/java/io/a2a/server/tasks/InMemoryTaskStore.java
@@ -1,12 +1,9 @@
 package io.a2a.server.tasks;
 
-import java.util.ArrayList;
-import java.util.Collections;
 import java.util.Comparator;
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
-import java.util.stream.Stream;
 
 import jakarta.enterprise.context.ApplicationScoped;
 
diff --git a/server-common/src/main/java/io/a2a/server/tasks/ResultAggregator.java b/server-common/src/main/java/io/a2a/server/tasks/ResultAggregator.java
@@ -16,7 +16,6 @@
 import io.a2a.spec.A2AServerException;
 import io.a2a.spec.Event;
 import io.a2a.spec.EventKind;
-import io.a2a.spec.InternalError;
 import io.a2a.spec.JSONRPCError;
 import io.a2a.spec.Message;
 import io.a2a.spec.Task;
diff --git a/server-common/src/main/java/io/a2a/server/tasks/TaskManager.java b/server-common/src/main/java/io/a2a/server/tasks/TaskManager.java
@@ -10,11 +10,9 @@
 import java.util.Map;
 
 import io.a2a.spec.A2AServerException;
-import io.a2a.spec.Artifact;
 import io.a2a.spec.Event;
 import io.a2a.spec.InvalidParamsError;
 import io.a2a.spec.Message;
-import io.a2a.spec.Part;
 import io.a2a.spec.Task;
 import io.a2a.spec.TaskArtifactUpdateEvent;
 import io.a2a.spec.TaskStatus;
diff --git a/server-common/src/test/java/io/a2a/server/tasks/ResultAggregatorTest.java b/server-common/src/test/java/io/a2a/server/tasks/ResultAggregatorTest.java
@@ -5,7 +5,6 @@
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.Mockito.atLeast;
 import static org.mockito.Mockito.atMost;
-import static org.mockito.Mockito.reset;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.verifyNoInteractions;
@@ -31,10 +30,12 @@
 
 /**
  * Comprehensive tests for ResultAggregator based on Python test patterns.
- * This is not a strict backport of the Python test, but it implements the same testing patterns
+ * This is not a strict backport of the Python test, but it implements the same
+ * testing patterns
  * adapted for Java's reactive streams and concurrency model.
  *
- * Note: This simplified version focuses on the core functionality without complex reactive stream testing
+ * Note: This simplified version focuses on the core functionality without
+ * complex reactive stream testing
  * that was causing issues with the original implementation.
  */
 public class ResultAggregatorTest {
@@ -70,7 +71,6 @@ private Task createSampleTask(String taskId, TaskState statusState, String conte
                 .build();
     }
 
-
     // Basic functionality tests
 
     @Test
@@ -184,7 +184,8 @@ void testGetCurrentResultWithMessageTakesPrecedence() {
         Message message = createSampleMessage("priority message", "pri1", Message.Role.USER);
         ResultAggregator messageAggregator = new ResultAggregator(mockTaskManager, message, testExecutor);
 
-        // Even if we set up the task manager to return something, message should take precedence
+        // Even if we set up the task manager to return something, message should take
+        // precedence
         Task task = createSampleTask("should_not_be_returned", TaskState.WORKING, "ctx1");
         when(mockTaskManager.getTask()).thenReturn(task);
 
@@ -204,28 +205,26 @@ void testConsumeAndBreakNonBlocking() throws Exception {
         when(mockTaskManager.getTask()).thenReturn(firstEvent);
 
         // Create an event queue using QueueManager (which has access to builder)
-        InMemoryQueueManager queueManager =
-            new InMemoryQueueManager(new MockTaskStateProvider());
+        InMemoryQueueManager queueManager = new InMemoryQueueManager(new MockTaskStateProvider());
 
         EventQueue queue = queueManager.getEventQueueBuilder("test-task").build();
         queue.enqueueEvent(firstEvent);
 
         // Create real EventConsumer with the queue
-        EventConsumer eventConsumer =
-            new EventConsumer(queue);
+        EventConsumer eventConsumer = new EventConsumer(queue);
 
         // Close queue after first event to simulate stream ending after processing
         queue.close();
 
-        ResultAggregator.EventTypeAndInterrupt result =
-            aggregator.consumeAndBreakOnInterrupt(eventConsumer, false);
+        ResultAggregator.EventTypeAndInterrupt result = aggregator.consumeAndBreakOnInterrupt(eventConsumer, false);
 
         assertEquals(firstEvent, result.eventType());
         assertTrue(result.interrupted());
         verify(mockTaskManager).process(firstEvent);
         // getTask() is called at least once for the return value (line 255)
         // May be called once more if debug logging executes in time (line 209)
-        // The async consumer may or may not execute before verification, so we accept 1-2 calls
+        // The async consumer may or may not execute before verification, so we accept
+        // 1-2 calls
         verify(mockTaskManager, atLeast(1)).getTask();
         verify(mockTaskManager, atMost(2)).getTask();
     }
diff --git a/server-common/src/test/java/io/a2a/server/tasks/TaskManagerTest.java b/server-common/src/test/java/io/a2a/server/tasks/TaskManagerTest.java
diff --git a/spec-grpc/src/main/java/io/a2a/grpc/utils/ProtoUtils.java b/spec-grpc/src/main/java/io/a2a/grpc/utils/ProtoUtils.java
diff --git a/spec/src/main/java/io/a2a/spec/SendMessageResponse.java b/spec/src/main/java/io/a2a/spec/SendMessageResponse.java
