feat(gateway): address review comments for multimodal inbound

Author: ijbhxhu

gateway/src/adapters/line.rs

@@ -107,9 +107,9 @@ pub async fn webhook(
         let mut attachments = Vec::new();
         if is_image || is_audio {
             if let Some(ref access_token) = state.line_access_token {
-                let client = reqwest::Client::new();
+                let client = &state.client;
                 let att_type = if is_image { "image" } else { "audio" };
-                if let Some(att) = download_line_media(&client, access_token, &msg.id, att_type).await {
+                if let Some(att) = download_line_media(client, access_token, &msg.id, att_type).await {
                     attachments.push(att);
                 }
             } else {
@@ -321,7 +321,7 @@ async fn download_line_media(
         .headers()
         .get(reqwest::header::CONTENT_TYPE)
         .and_then(|h| h.to_str().ok())
-        .unwrap_or(if attachment_type == "image" { "image/jpeg" } else { "audio/x-m4a" })
+        .unwrap_or(if attachment_type == "image" { "image/jpeg" } else { "audio/mp4" })
         .to_string();
 
     let bytes = resp.bytes().await.ok()?;
@@ -346,6 +346,7 @@ async fn download_line_media(
 
     use base64::Engine;
     let b64_data = base64::engine::general_purpose::STANDARD.encode(&data_bytes);
+    info!(message_id, size = data_bytes.len(), "LINE {} download successful", attachment_type);
 
     Some(Attachment {
         attachment_type: attachment_type.into(),

gateway/src/adapters/telegram.rs

@@ -122,29 +122,29 @@ pub async fn webhook(
     let mut attachments = Vec::new();
     if is_photo || is_document || is_voice || is_audio {
         if let Some(ref token) = state.telegram_bot_token {
-            let client = reqwest::Client::new();
+            let client = &state.client;
             if is_photo {
                 // Take the largest photo
                 if let Some(largest) = msg.photo.iter().max_by_key(|p| p.width * p.height) {
                     if let Some(att) =
-                        download_telegram_media(&client, token, &largest.file_id, "image").await
+                        download_telegram_media(client, token, &largest.file_id, "image").await
                     {
                         attachments.push(att);
                     }
                 }
             } else if let Some(doc) = msg.document {
                 let file_name = doc.file_name.unwrap_or_else(|| "unknown.txt".to_string());
                 if let Some(att) =
-                    download_telegram_document(&client, token, &doc.file_id, &file_name).await
+                    download_telegram_document(client, token, &doc.file_id, &file_name).await
                 {
                     attachments.push(att);
                 }
             } else if let Some(voice) = msg.voice {
-                if let Some(att) = download_telegram_media(&client, token, &voice.file_id, "audio").await {
+                if let Some(att) = download_telegram_media(client, token, &voice.file_id, "audio").await {
                     attachments.push(att);
                 }
             } else if let Some(audio) = msg.audio {
-                if let Some(att) = download_telegram_media(&client, token, &audio.file_id, "audio").await {
+                if let Some(att) = download_telegram_media(client, token, &audio.file_id, "audio").await {
                     attachments.push(att);
                 }
             }
@@ -409,6 +409,7 @@ async fn download_telegram_media(
 
     use base64::Engine;
     let b64_data = base64::engine::general_purpose::STANDARD.encode(&data_bytes);
+    info!(file_id, size = data_bytes.len(), "Telegram {} download successful", attachment_type);
 
     Some(Attachment {
         attachment_type: attachment_type.into(),
@@ -482,6 +483,7 @@ async fn download_telegram_document(
     let text = String::from_utf8_lossy(&bytes);
     use base64::Engine;
     let data = base64::engine::general_purpose::STANDARD.encode(text.as_bytes());
+    info!(file_id, file_name, size = bytes.len(), "Telegram document download successful");
 
     Some(Attachment {
         attachment_type: "text_file".into(),

gateway/src/main.rs

@@ -61,8 +61,11 @@ pub struct AppState {
     /// the first client to `remove()` a token wins the free Reply API call;
     /// other clients for the same event naturally fall back to Push API.
     pub reply_token_cache: ReplyTokenCache,
+    /// Shared HTTP client for media downloads and API calls
+    pub client: reqwest::Client,
 }
 
+
 // --- WebSocket handler (OAB connects here) ---
 
 async fn ws_handler(
@@ -356,6 +359,10 @@ async fn main() -> Result<()> {
         warn!("no adapters configured — set TELEGRAM_BOT_TOKEN, LINE_CHANNEL_ACCESS_TOKEN, TEAMS_APP_ID + TEAMS_APP_SECRET, FEISHU_APP_ID + FEISHU_APP_SECRET, GOOGLE_CHAT_ENABLED=true, and/or WECOM_CORP_ID + WECOM_SECRET + WECOM_TOKEN + WECOM_ENCODING_AES_KEY + WECOM_AGENT_ID");
     }
 
+    let client = reqwest::Client::builder()
+        .timeout(std::time::Duration::from_secs(30))
+        .build()?;
+
     let state = Arc::new(AppState {
         telegram_bot_token,
         telegram_secret_token,
@@ -369,6 +376,7 @@ async fn main() -> Result<()> {
         ws_token,
         event_tx,
         reply_token_cache,
+        client,
     });
 
     // Background task: sweep expired reply tokens every REPLY_TOKEN_TTL_SECS