Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,7 @@
* case FAILED -> System.err.println("Task failed: " +
* tue.getTask().status().message());
* }
*
*
* // Check for new artifacts
* if (tue.getUpdateEvent() instanceof TaskArtifactUpdateEvent update) {
* Artifact artifact = update.artifact();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -407,7 +407,7 @@ private ClientTransport wrap(ClientTransport transport, ClientTransportConfig<?
if (wrappers.isEmpty()) {
LOGGER.debug("No client transport wrappers found via ServiceLoader");
return transport;
}
}
LOGGER.debug(wrappers.size() + " client transport wrappers found via ServiceLoader");

// Reverse to apply lowest priority first (building stack with highest priority outermost)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,15 +18,15 @@
* client.addConsumer((event, agentCard) -> {
* if (event instanceof MessageEvent me) {
* Message msg = me.getMessage();
*
*
* // Extract text content
* String text = msg.parts().stream()
* .filter(p -> p instanceof TextPart)
* .map(p -> ((TextPart) p).text())
* .collect(Collectors.joining());
*
*
* System.out.println("Agent response: " + text);
*
*
* // Check for images
* msg.parts().stream()
* .filter(p -> p instanceof ImagePart)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
* client.addConsumer((event, agentCard) -> {
* if (event instanceof TaskEvent te) {
* Task task = te.getTask();
*
*
* // Check task state
* TaskState state = task.status().state();
* switch (state) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,12 +36,12 @@
* if (event instanceof TaskUpdateEvent tue) {
* Task currentTask = tue.getTask();
* UpdateEvent update = tue.getUpdateEvent();
*
*
* // Handle status changes
* if (update instanceof TaskStatusUpdateEvent statusUpdate) {
* TaskState newState = currentTask.status().state();
* System.out.println("Task " + currentTask.id() + " → " + newState);
*
*
* if (newState == TaskState.COMPLETED) {
* System.out.println("Final result: " +
* currentTask.artifact().parts());
Expand All @@ -50,12 +50,12 @@
* currentTask.status().message());
* }
* }
*
*
* // Handle new content
* if (update instanceof TaskArtifactUpdateEvent artifactUpdate) {
* Artifact newContent = artifactUpdate.artifact();
* System.out.println("New content received: " + newContent.parts());
*
*
* // For streaming text generation
* newContent.parts().stream()
* .filter(p -> p instanceof TextPart)
Expand Down
24 changes: 12 additions & 12 deletions client/base/src/test/java/org/a2aproject/sdk/A2ATest.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ public class A2ATest {
public void testToUserMessage() {
String text = "Hello, world!";
Message message = A2A.toUserMessage(text);

assertEquals(Message.Role.ROLE_USER, message.role());
assertEquals(1, message.parts().size());
assertEquals(text, ((TextPart) message.parts().get(0)).text());
Expand All @@ -33,7 +33,7 @@ public void testToUserMessageWithId() {
String text = "Hello, world!";
String messageId = "test-message-id";
Message message = A2A.toUserMessage(text, messageId);

assertEquals(Message.Role.ROLE_USER, message.role());
assertEquals(messageId, message.messageId());
}
Expand All @@ -42,7 +42,7 @@ public void testToUserMessageWithId() {
public void testToAgentMessage() {
String text = "Hello, I'm an agent!";
Message message = A2A.toAgentMessage(text);

assertEquals(Message.Role.ROLE_AGENT, message.role());
assertEquals(1, message.parts().size());
assertEquals(text, ((TextPart) message.parts().get(0)).text());
Expand All @@ -54,7 +54,7 @@ public void testToAgentMessageWithId() {
String text = "Hello, I'm an agent!";
String messageId = "agent-message-id";
Message message = A2A.toAgentMessage(text, messageId);

assertEquals(Message.Role.ROLE_AGENT, message.role());
assertEquals(messageId, message.messageId());
}
Expand All @@ -64,9 +64,9 @@ public void testCreateUserTextMessage() {
String text = "User message with context";
String contextId = "context-123";
String taskId = "task-456";

Message message = A2A.createUserTextMessage(text, contextId, taskId);

assertEquals(Message.Role.ROLE_USER, message.role());
assertEquals(contextId, message.contextId());
assertEquals(taskId, message.taskId());
Expand All @@ -80,9 +80,9 @@ public void testCreateUserTextMessage() {
@Test
public void testCreateUserTextMessageWithNullParams() {
String text = "Simple user message";

Message message = A2A.createUserTextMessage(text, null, null);

assertEquals(Message.Role.ROLE_USER, message.role());
assertNull(message.contextId());
assertNull(message.taskId());
Expand All @@ -95,9 +95,9 @@ public void testCreateAgentTextMessage() {
String text = "Agent message with context";
String contextId = "context-789";
String taskId = "task-012";

Message message = A2A.createAgentTextMessage(text, contextId, taskId);

assertEquals(Message.Role.ROLE_AGENT, message.role());
assertEquals(contextId, message.contextId());
assertEquals(taskId, message.taskId());
Expand All @@ -114,9 +114,9 @@ public void testCreateAgentPartsMessage() {
);
String contextId = "context-parts";
String taskId = "task-parts";

Message message = A2A.createAgentPartsMessage(parts, contextId, taskId);

assertEquals(Message.Role.ROLE_AGENT, message.role());
assertEquals(contextId, message.contextId());
assertEquals(taskId, message.taskId());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@
/**
* Tests for handling HTTP 401 (Unauthorized) and 403 (Forbidden) responses
* when the client sends streaming and non-streaming messages.
*
*
* These tests verify that the client properly fails when the server returns
* authentication or authorization errors.
*/
Expand All @@ -71,7 +71,7 @@ public void setUp() {
.contextId("context-1234")
.messageId("message-1234")
.build();

grpcServerName = InProcessServerBuilder.generateName();

agentCard = AgentCard.builder()
Expand Down
Loading
Loading