From 09c06786a48f54b36c4d82eb7091e01f08ed6a5b Mon Sep 17 00:00:00 2001 From: lpf Date: Wed, 4 Mar 2026 14:16:48 +0800 Subject: [PATCH] fix: harden telegram streaming finalize and resolve session lock-copy vet issue --- pkg/agent/loop.go | 3 ++- pkg/channels/telegram.go | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/agent/loop.go b/pkg/agent/loop.go index 6121fc8..51b8408 100644 --- a/pkg/agent/loop.go +++ b/pkg/agent/loop.go @@ -1760,7 +1760,8 @@ func rewriteSystemMessageContent(content, template string) string { func alSessionListForTool(sm *session.SessionManager, limit int) []tools.SessionInfo { items := sm.List(limit) out := make([]tools.SessionInfo, 0, len(items)) - for _, s := range items { + for i := range items { + s := &items[i] out = append(out, tools.SessionInfo{ Key: s.Key, Kind: s.Kind, diff --git a/pkg/channels/telegram.go b/pkg/channels/telegram.go index 668946f..7bae6a7 100644 --- a/pkg/channels/telegram.go +++ b/pkg/channels/telegram.go @@ -1068,7 +1068,7 @@ func (c *TelegramChannel) deleteTelegramMessageWithRetry(ctx context.Context, ch func (c *TelegramChannel) handleAction(ctx context.Context, chatID int64, action string, msg bus.OutboundMessage) error { messageID, ok := parseTelegramMessageID(msg.MessageID) - if !ok && action != "send" && action != "stream" { + if !ok && action != "send" && action != "stream" && action != "finalize" { return fmt.Errorf("message_id required for action=%s", action) } switch action {