adk-server 0.5.0

use adk_core::{Part, Result};
use base64::{Engine as _, engine::general_purpose};
use serde_json::{Map, Value};

pub fn adk_parts_to_a2a(
    parts: &[Part],
    long_running_ids: &[String],
) -> Result<Vec<crate::a2a::Part>> {
    parts
        .iter()
        .map(|part| match part {
            Part::Text { text } => Ok(crate::a2a::Part::text(text.clone())),
            Part::InlineData { mime_type, data } => {
                let encoded = general_purpose::STANDARD.encode(data);
                Ok(crate::a2a::Part::file(crate::a2a::FileContent {
                    name: None,
                    mime_type: Some(mime_type.clone()),
                    bytes: Some(encoded),
                    uri: None,
                }))
            }
            Part::FileData { mime_type, file_uri } => {
                // FileData contains a URI reference to a file
                Ok(crate::a2a::Part::file(crate::a2a::FileContent {
                    name: None,
                    mime_type: Some(mime_type.clone()),
                    bytes: None,
                    uri: Some(file_uri.clone()),
                }))
            }
            Part::FunctionCall { name, args, id, .. } => {
                let is_long_running = long_running_ids.contains(name);
                let mut data = Map::new();
                let mut call_data = Map::new();
                call_data.insert("name".to_string(), Value::String(name.clone()));
                call_data.insert("args".to_string(), args.clone());
                if let Some(call_id) = id {
                    call_data.insert("id".to_string(), Value::String(call_id.clone()));
                }
                data.insert("function_call".to_string(), Value::Object(call_data));

                let mut metadata = Map::new();
                metadata.insert("long_running".to_string(), Value::Bool(is_long_running));

                Ok(crate::a2a::Part::Data { data, metadata: Some(metadata) })
            }
            Part::Thinking { thinking, .. } => {
                // Convert thinking traces to text for A2A protocol
                Ok(crate::a2a::Part::text(thinking.clone()))
            }
            Part::FunctionResponse { function_response, id } => {
                let mut data = Map::new();
                let mut resp_data = Map::new();
                resp_data.insert("name".to_string(), Value::String(function_response.name.clone()));
                resp_data.insert("response".to_string(), function_response.response.clone());
                if let Some(resp_id) = id {
                    resp_data.insert("id".to_string(), Value::String(resp_id.clone()));
                }
                data.insert("function_response".to_string(), Value::Object(resp_data));

                Ok(crate::a2a::Part::Data { data, metadata: None })
            }
            Part::ServerToolCall { server_tool_call } => {
                let mut data = Map::new();
                data.insert("server_tool_call".to_string(), server_tool_call.clone());
                Ok(crate::a2a::Part::Data { data, metadata: None })
            }
            Part::ServerToolResponse { server_tool_response } => {
                let mut data = Map::new();
                data.insert("server_tool_response".to_string(), server_tool_response.clone());
                Ok(crate::a2a::Part::Data { data, metadata: None })
            }
        })
        .collect()
}

pub fn a2a_parts_to_adk(parts: &[crate::a2a::Part]) -> Result<Vec<Part>> {
    parts
        .iter()
        .map(|part| match part {
            crate::a2a::Part::Text { text, .. } => Ok(Part::Text { text: text.clone() }),
            crate::a2a::Part::File { file, .. } => {
                if let Some(bytes) = &file.bytes {
                    let data = general_purpose::STANDARD.decode(bytes).map_err(|e| {
                        adk_core::AdkError::agent(format!("Base64 decode error: {}", e))
                    })?;
                    Ok(Part::InlineData {
                        mime_type: file.mime_type.clone().unwrap_or_default(),
                        data,
                    })
                } else {
                    Err(adk_core::AdkError::agent("File part with URI not supported"))
                }
            }
            crate::a2a::Part::Data { data, .. } => {
                if let Some(call) = data.get("function_call") {
                    let name = call
                        .get("name")
                        .and_then(|v| v.as_str())
                        .ok_or_else(|| adk_core::AdkError::agent("Missing function name"))?
                        .to_string();
                    let args = call.get("args").cloned().unwrap_or(Value::Object(Map::new()));
                    let id = call.get("id").and_then(|v| v.as_str()).map(String::from);
                    Ok(Part::FunctionCall { name, args, id, thought_signature: None })
                } else if let Some(resp) = data.get("function_response") {
                    let name = resp
                        .get("name")
                        .and_then(|v| v.as_str())
                        .ok_or_else(|| adk_core::AdkError::agent("Missing function name"))?
                        .to_string();
                    let response =
                        resp.get("response").cloned().unwrap_or(Value::Object(Map::new()));
                    let id = resp.get("id").and_then(|v| v.as_str()).map(String::from);
                    Ok(Part::FunctionResponse {
                        function_response: adk_core::FunctionResponseData { name, response },
                        id,
                    })
                } else {
                    Err(adk_core::AdkError::agent("Unknown data part format"))
                }
            }
        })
        .collect()
}

#[cfg(test)]
mod tests {
    use super::*;
    use serde_json::json;

    #[test]
    fn test_text_conversion() {
        let adk_parts = vec![Part::Text { text: "Hello".to_string() }];
        let a2a_parts = adk_parts_to_a2a(&adk_parts, &[]).unwrap();
        assert_eq!(a2a_parts.len(), 1);

        let back = a2a_parts_to_adk(&a2a_parts).unwrap();
        assert_eq!(back.len(), 1);
    }

    #[test]
    fn test_function_call_conversion() {
        let adk_parts = vec![Part::FunctionCall {
            name: "test".to_string(),
            args: json!({"key": "value"}),
            id: Some("call_123".to_string()),
            thought_signature: None,
        }];
        let a2a_parts = adk_parts_to_a2a(&adk_parts, &[]).unwrap();
        assert_eq!(a2a_parts.len(), 1);

        let back = a2a_parts_to_adk(&a2a_parts).unwrap();
        assert_eq!(back.len(), 1);
    }
}