[Bug]:Agent As Tool + A2A形式调用远程子智能体时，Msg中的metadata信息丢失。

[yisheng13]

Agent As Tool + A2A形式调用远程子智能体时，Msg中的metadata信息丢失。但如果客户端直接A2A调用时，Msg中的metadata信息可以正确传输。
客户端代码
Agent As Tool + A2A形式调用

        Toolkit toolkit = new Toolkit();
        toolkit.registration()
                .subAgent(() -> A2aAgent.builder()
                        .name("timeExpert")
                        .agentCardResolver(resolver)
                        .build())
                .apply();
        ReActAgent mainAgent = ReActAgent.builder()
                .name("Coordinator")
                .sysPrompt("你叫 Tom ，是一个智能助手。当遇到时间相关问题时，调用 call_timeexpert 工具咨询 Jarvis。")
                .model(model)
                .memory(new InMemoryMemory())
                .toolkit(toolkit)
                .build();
        Msg userMsg = Msg.builder()
                .textContent("请告诉我今天的日期。")
                .metadata(Map.of("useriId", "1234567890"))
                .build();
        Msg response = mainAgent.call(userMsg).block();

服务端收到的请求中metadata无内容

如果客户端直接A2A调用

        A2aAgent agent = A2aAgent.builder()
                .name("remote-agent")
                .agentCardResolver(resolver)
                .build();
        Msg msg = Msg.builder()
                .textContent("今天的日期是什么？")
                .metadata(Map.of("userId", "1234567890"))
                .build();
         Msg response = agent.call(msg).block();

这导致在主智能体调用远程子智能体时，无法通过Msg传输一些特定参数。

[AlbumenJ]

@KomachiSion PTAL

[KomachiSion]

在parts里的metadata里，因为A2A的message是单个的， 而AgentScope的Msg是一个list， 无法直接放在message的metadata中

[yisheng13]

在parts里的metadata里，因为A2A的message是单个的， 而AgentScope的Msg是一个list， 无法直接放在message的metadata中

@KomachiSion 您好。我在parts的metadata中没有找到我Msg中的metadata信息（"userId": "1234567890"这一条）。

完整信息如下：

{
  "jsonrpc" : "2.0",
  "id" : "738aa20a-b897-4244-9e93-8ae70277422f",
  "method" : "message/stream",
  "params" : {
    "message" : {
      "role" : "user",
      "parts" : [ {
        "text" : "今天的日期是什么？",
        "metadata" : {
          "_agentscope_msg_id" : "63b451ce-9f4c-4cb5-809e-d62c9d7c5af6",
          "_agentscope_block_type" : "text",
          "_agentscope_msg_source" : null
        },
        "kind" : "text"
      } ],
      "messageId" : "b0d02569-476a-4606-a051-9ff6b9b09e2f",
      "metadata" : { },
      "kind" : "message"
    },
    "configuration" : {
      "acceptedOutputModes" : [ ],
      "blocking" : true
    },
    "metadata" : { }
  }
}

[KomachiSion]

我看看， 你用的版本是哪个？

[yisheng13]

我看看， 你用的版本是哪个？

@KomachiSion 您好。我用的是1.0.8版本。

以下是我的相关代码：
客户端代码以Agent As Tool + A2A形式调用

        Toolkit toolkit = new Toolkit();
        toolkit.registration()
                .subAgent(() -> A2aAgent.builder()
                        .name("timeExpert")
                        .agentCardResolver(resolver)
                        .build())
                .apply();
        ReActAgent mainAgent = ReActAgent.builder()
                .name("Coordinator")
                .sysPrompt("你叫 Tom ，是一个智能助手。当遇到时间相关问题时，调用 call_timeexpert 工具咨询 Jarvis。")
                .model(model)
                .memory(new InMemoryMemory())
                .toolkit(toolkit)
                .build();
        Msg userMsg = Msg.builder()
                .textContent("请告诉我今天的日期。")
                .metadata(Map.of("useriId", "1234567890"))
                .build();
        Msg response = mainAgent.call(userMsg).block();

服务端代码通过手动方式创建A2A 服务

    @PostMapping(value = "/jsonrpc",
            consumes = MediaType.APPLICATION_JSON_VALUE,
            produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public ResponseEntity<SseEmitter> handleJsonRpcRequest(
            @RequestBody String body,
            @RequestHeader Map<String, String> headers) throws JsonProcessingException {

        JsonRpcTransportWrapper transportWrapper =
                agentScopeA2aServer.getTransportWrapper("JSONRPC", JsonRpcTransportWrapper.class);

        Map<String, Object> metadata = new HashMap<>();

        Object result = transportWrapper.handleRequest(body, headers, metadata);
        SseEmitter emitter = new SseEmitter(Long.MAX_VALUE);

        reactor.core.publisher.Flux<?> flux = (reactor.core.publisher.Flux<?>) result;

        flux.subscribe(
                item -> {
                    try {
                        String data = objectMapper.writeValueAsString(item);
                        emitter.send(SseEmitter.event()
                                .data(data)
                                .name("data"));
                    } catch (Exception e) {
                        emitter.completeWithError(e);
                    }
                },
                error -> emitter.completeWithError(error),
                () -> {
                    try {
                        emitter.send(SseEmitter.event()
                                .data("{\"type\":\"complete\"}")
                                .name("complete"));
                        emitter.complete();
                    } catch (Exception e) {
                        emitter.completeWithError(e);
                    }
                }
        );

        return ResponseEntity.ok()
                .contentType(MediaType.TEXT_EVENT_STREAM)
                .body(emitter);

    @Bean
    public AgentScopeA2aServer agentScopeA2aServer() {
        // 配置Agent Card
        ConfigurableAgentCard agentCard = new ConfigurableAgentCard.Builder()
                .name("Simple QA Agent")
                .description("A simple question answering agent that responds to queries using AI.")
                .url("http://localhost:8081/.well-known/agent-card.json")
                .provider(new AgentProvider("Organization", "contact@org.com"))
                .version("1.0.0")
                .build();

        // 配置传输协议
        TransportProperties transportProps = TransportProperties.builder(TransportProtocol.JSONRPC.asString())
                .host("localhost")
                .port(8081)
                .path("/jsonrpc")
                .build();

        // 配置部署属性
        DeploymentProperties deploymentProps = new DeploymentProperties.Builder()
                .port(8081)
                .host("localhost")
                .build();

        // 构建A2A服务器
        return AgentScopeA2aServer.builder(ReActAgent.builder()
                        .name("my-assistant")
                        .model(model)
                        .sysPrompt("你是一个智能助手。"))
                .agentCard(agentCard)
                .withTransport(transportProps)
                .deploymentProperties(deploymentProps)
                .build();
    }