adk-rust-mcp-composer 0.5.0

MCP server for composite media generation (GIFs, shorts, memes, presentations, podcasts)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

//! Meme generation: Gemini image + text overlay.

use adk_rust_mcp_common::Config;
use base64::{Engine as _, engine::general_purpose::STANDARD as BASE64};
use schemars::JsonSchema;
use serde::Deserialize;
use std::path::Path;
use tempfile::TempDir;
use tokio::process::Command;
use tracing::info;

#[derive(Debug, Deserialize, JsonSchema)]
pub struct MemeGenerateParams {
    /// Image description (what the meme image should show)
    pub prompt: String,
    /// Top text
    #[serde(default)]
    pub top_text: Option<String>,
    /// Bottom text
    #[serde(default)]
    pub bottom_text: Option<String>,
    /// Font size
    #[serde(default = "default_font_size")]
    pub font_size: u32,
    /// Output file path
    #[serde(default)]
    pub output_file: Option<String>,
}

fn default_font_size() -> u32 { 48 }

pub async fn generate(config: &Config, params: MemeGenerateParams) -> Result<String, String> {
    let api_key = config.gemini_api_key.as_deref().ok_or("GEMINI_API_KEY required")?;
    let output_path = params.output_file.clone().unwrap_or_else(|| "meme.png".to_string());

    // Build prompt that includes meme text instructions
    let mut prompt = format!("Generate a meme image of: {}", params.prompt);
    if let Some(ref top) = params.top_text {
        prompt.push_str(&format!(". Add bold white text with black outline at the TOP of the image saying: \"{}\"", top));
    }
    if let Some(ref bottom) = params.bottom_text {
        prompt.push_str(&format!(". Add bold white text with black outline at the BOTTOM of the image saying: \"{}\"", bottom));
    }
    if params.top_text.is_some() || params.bottom_text.is_some() {
        prompt.push_str(". Use classic meme style Impact font.");
    }

    // Generate image with Gemini (text baked in)
    info!(prompt = %prompt, "Generating meme");
    let model = "gemini-2.5-flash-image";
    let url = format!("{}/models/{}:generateContent", config.gemini_base_url(), model);

    let client = reqwest::Client::new();
    let body = serde_json::json!({
        "contents": [{"parts": [{"text": prompt}]}],
        "generationConfig": {
            "responseModalities": ["IMAGE", "TEXT"],
            "imageConfig": {"aspectRatio": "1:1"}
        }
    });

    let resp = client.post(&url)
        .header("x-goog-api-key", api_key)
        .json(&body).send().await.map_err(|e| e.to_string())?;

    if !resp.status().is_success() {
        return Err(format!("Gemini API error: {}", resp.text().await.unwrap_or_default()));
    }

    let response: serde_json::Value = resp.json().await.map_err(|e| e.to_string())?;

    // Extract image data
    let image_data = response.pointer("/candidates/0/content/parts")
        .and_then(|parts| parts.as_array())
        .and_then(|parts| parts.iter().find_map(|p| p.pointer("/inlineData/data").and_then(|d| d.as_str())))
        .ok_or("No image in response")?;

    let image_bytes = BASE64.decode(image_data).map_err(|e| e.to_string())?;

    if let Some(parent) = Path::new(&output_path).parent() {
        if !parent.as_os_str().is_empty() { tokio::fs::create_dir_all(parent).await.ok(); }
    }
    tokio::fs::write(&output_path, &image_bytes).await.map_err(|e| e.to_string())?;

    info!(path = %output_path, "Meme generated");
    Ok(format!("Meme saved to: {}", output_path))
}