fix: proper edit_message handling — finalize via send_message for draft path

- edit_message with reply_to='draft': route to sendRichMessageDraft (rich)
  or silently drop (non-rich). Never attempt editMessageText on dummy ref.
- edit_message with real message_id: perform actual editMessageText for
  legacy streaming placeholder updates.
- Stream finalization: when placeholder is dummy 'draft' ref, send final
  content as new message (send_message) so it gets persisted. This ensures
  rich path uses sendRichMessage for the final reply, not just a draft.

Addresses 擺渡法師's 🔴 #2 — streaming finalization must persist.

Author: chaodu-agent

gateway/src/adapters/telegram.rs

@@ -417,27 +417,41 @@ pub async fn handle_reply(
         return;
     }
 
-    // Handle edit_message → stream via sendRichMessageDraft
+    // Handle edit_message
     if reply.command.as_deref() == Some("edit_message") {
-        if !rich_messages {
-            // Without rich messages, "draft" placeholder has no real message_id to edit.
-            // Silently drop — the final reply will be sent as a new message via send_message.
-            return;
-        }
-        // Skip short updates — let thinking animation show until meaningful content arrives
-        if reply.content.text.len() < 30 {
+        if reply.reply_to == "draft" {
+            // Dummy "draft" ref from streaming without placeholder.
+            if rich_messages {
+                // Skip short updates — let thinking animation show until meaningful content arrives
+                if reply.content.text.len() < 30 {
+                    return;
+                }
+                let text = if reply.content.text.len() > 32768 {
+                    &reply.content.text[..reply.content.text.floor_char_boundary(32768)]
+                } else {
+                    &reply.content.text
+                };
+                // Combine channel + thread to avoid draft_id collision in forum topics
+                let chan: i64 = reply.channel.id.parse::<i64>().unwrap_or(1).abs();
+                let tid: i64 = reply.channel.thread_id.as_deref().and_then(|t| t.parse::<i64>().ok()).unwrap_or(0).abs();
+                let draft_id: i64 = (chan.wrapping_add(tid)) % 1_000_000 + 1;
+                let _ = send_rich_message_draft(client, bot_token, &reply.channel.id, &reply.channel.thread_id, draft_id, text).await;
+            }
+            // else: rich_messages=false with dummy ref — silently drop (no real msg to edit)
             return;
         }
-        let text = if reply.content.text.len() > 32768 {
-            &reply.content.text[..reply.content.text.floor_char_boundary(32768)]
-        } else {
-            &reply.content.text
-        };
-        // Combine channel + thread to avoid draft_id collision in forum topics
-        let chan: i64 = reply.channel.id.parse::<i64>().unwrap_or(1).abs();
-        let tid: i64 = reply.channel.thread_id.as_deref().and_then(|t| t.parse::<i64>().ok()).unwrap_or(0).abs();
-        let draft_id: i64 = (chan.wrapping_add(tid)) % 1_000_000 + 1;
-        let _ = send_rich_message_draft(client, bot_token, &reply.channel.id, &reply.channel.thread_id, draft_id, text).await;
+        // Real message_id — perform actual editMessageText (legacy streaming path)
+        let url = format!("{TELEGRAM_API_BASE}/bot{bot_token}/editMessageText");
+        let _ = client
+            .post(&url)
+            .json(&serde_json::json!({
+                "chat_id": reply.channel.id,
+                "message_id": reply.reply_to,
+                "text": &reply.content.text,
+                "parse_mode": "Markdown",
+            }))
+            .send()
+            .await;
         return;
     }
 

src/adapter.rs

@@ -714,12 +714,20 @@ impl AdapterRouter {
                                 }
                             }
                         } else {
-                            // Normal streaming: edit first chunk into placeholder, send rest
-                            if let Some(first) = chunks.first() {
-                                let _ = adapter.edit_message(&msg, first).await;
-                            }
-                            for chunk in chunks.iter().skip(1) {
-                                let _ = adapter.send_message(&thread_channel, chunk).await;
+                            // Normal streaming: edit first chunk into placeholder, send rest.
+                            // If placeholder is a dummy "draft" ref (no real message), send as
+                            // new message instead — the gateway will persist via sendRichMessage.
+                            if msg.message_id == "draft" {
+                                for chunk in &chunks {
+                                    let _ = adapter.send_message(&thread_channel, chunk).await;
+                                }
+                            } else {
+                                if let Some(first) = chunks.first() {
+                                    let _ = adapter.edit_message(&msg, first).await;
+                                }
+                                for chunk in chunks.iter().skip(1) {
+                                    let _ = adapter.send_message(&thread_channel, chunk).await;
+                                }
                             }
                         }
                     } else {