Skip to content

Commit 5992585

Browse files
committed
Client progress
Signed-off-by: Emmanuel Hugonnet <[email protected]>
1 parent cd3d25d commit 5992585

File tree

9 files changed

+484
-614
lines changed

9 files changed

+484
-614
lines changed

client/transport/jsonrpc/pom.xml

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,21 @@
3737
<groupId>${project.groupId}</groupId>
3838
<artifactId>a2a-java-sdk-spec-grpc</artifactId>
3939
</dependency>
40+
<dependency>
41+
<groupId>com.google.code.gson</groupId>
42+
<artifactId>gson</artifactId>
43+
<scope>provided</scope>
44+
</dependency>
45+
<dependency>
46+
<groupId>com.google.protobuf</groupId>
47+
<artifactId>protobuf-java-util</artifactId>
48+
<scope>provided</scope>
49+
</dependency>
50+
<dependency>
51+
<groupId>com.google.protobuf</groupId>
52+
<artifactId>protobuf-java</artifactId>
53+
<scope>provided</scope>
54+
</dependency>
4055
<dependency>
4156
<groupId>org.junit.jupiter</groupId>
4257
<artifactId>junit-jupiter-api</artifactId>

client/transport/jsonrpc/src/main/java/io/a2a/client/transport/jsonrpc/JSONRPCTransport.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,7 @@ public AgentCard getAgentCard(@Nullable ClientCallContext context) throws A2ACli
326326
.build(); // id will be randomly generated
327327

328328
PayloadAndHeaders payloadAndHeaders = applyInterceptors(GetAuthenticatedExtendedCardRequest.METHOD,
329-
getExtendedAgentCardRequest, agentCard, context);
329+
ProtoUtils.ToProto.extendedAgentCard(getExtendedAgentCardRequest), agentCard, context);
330330

331331
try {
332332
String httpResponseBody = sendPostRequest(payloadAndHeaders,GetAuthenticatedExtendedCardRequest.METHOD);
@@ -373,7 +373,7 @@ private A2AHttpClient.PostBuilder createPostBuilder(PayloadAndHeaders payloadAnd
373373
A2AHttpClient.PostBuilder postBuilder = httpClient.createPost()
374374
.url(agentUrl)
375375
.addHeader("Content-Type", "application/json")
376-
.body(JSONRPCUtils.toJsonRPCString(null, method, (MessageOrBuilder) payloadAndHeaders.getPayload()));
376+
.body(JSONRPCUtils.toJsonRPCRequest(null, method, (MessageOrBuilder) payloadAndHeaders.getPayload()));
377377

378378
if (payloadAndHeaders.getHeaders() != null) {
379379
for (Map.Entry<String, String> entry : payloadAndHeaders.getHeaders().entrySet()) {

client/transport/jsonrpc/src/test/java/io/a2a/client/transport/jsonrpc/JSONRPCTransportTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -212,7 +212,7 @@ public void testA2AClientSendMessageWithError() throws Exception {
212212
client.sendMessage(params, null);
213213
fail(); // should not reach here
214214
} catch (A2AClientException e) {
215-
assertTrue(e.getMessage().contains("Invalid parameters: Hello world"));
215+
assertTrue(e.getMessage().contains("Invalid parameters: \"Hello world\""),e.getMessage());
216216
}
217217
}
218218

@@ -562,7 +562,9 @@ public void testA2AClientSendMessageWithFilePart() throws Exception {
562562
Part<?> part = artifact.parts().get(0);
563563
assertEquals(Part.Kind.TEXT, part.getKind());
564564
assertEquals("This is an image of a cat sitting on a windowsill.", ((TextPart) part).getText());
565-
assertTrue(task.getMetadata().isEmpty());
565+
assertFalse(task.getMetadata().isEmpty());
566+
assertEquals(1, task.getMetadata().size());
567+
assertEquals("metadata-test", task.getMetadata().get("test"));
566568
}
567569

568570
@Test

0 commit comments

Comments
 (0)