From 3bd90a2212e4ba64a6a749475b44a5d684ccc09b Mon Sep 17 00:00:00 2001 From: Claude Date: Sun, 29 Mar 2026 16:11:22 +0000 Subject: [PATCH] fix: correct type mismatch in observe-only tests and wrap long line - Fix bus.Peer used where *routing.RoutePeer is expected in loop_test.go - Wrap 127-char ObserveGroupMessage call in telegram.go to satisfy golines https://claude.ai/code/session_01BEyzHEY8t2ghPnfr5WsSRB --- pkg/agent/loop_test.go | 2 +- pkg/channels/telegram/telegram.go | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/pkg/agent/loop_test.go b/pkg/agent/loop_test.go index db3466832..513176b60 100644 --- a/pkg/agent/loop_test.go +++ b/pkg/agent/loop_test.go @@ -3482,7 +3482,7 @@ func TestObserveOnlyMessage_DoesNotRespondEvenWithContinuation(t *testing.T) { // Confirm history accumulated route := al.registry.ResolveRoute(routing.RouteInput{ Channel: "slack", - Peer: bus.Peer{Kind: "channel", ID: "channel1"}, + Peer: &routing.RoutePeer{Kind: "channel", ID: "channel1"}, }) defaultAgent := al.registry.GetDefaultAgent() if defaultAgent == nil { diff --git a/pkg/channels/telegram/telegram.go b/pkg/channels/telegram/telegram.go index 8f74d8d8d..1b3bde0a1 100644 --- a/pkg/channels/telegram/telegram.go +++ b/pkg/channels/telegram/telegram.go @@ -715,7 +715,10 @@ func (c *TelegramChannel) handleMessage(ctx context.Context, message *telego.Mes "first_name": user.FirstName, "is_group": "true", } - c.ObserveGroupMessage(ctx, observePeer, messageIDStr, platformID, compositeChatID, content, mediaPaths, observeMeta, sender) + c.ObserveGroupMessage( + ctx, observePeer, messageIDStr, platformID, + compositeChatID, content, mediaPaths, observeMeta, sender, + ) return nil } content = cleaned