From 04806bffe3df969d14ecacf23e968dc86cd56334 Mon Sep 17 00:00:00 2001 From: Aditya Kalro Date: Mon, 23 Feb 2026 15:50:55 -0800 Subject: [PATCH] Moving logging from INFO to DEBUG for messages Removing extrnaeous comments about mutex in loop.go Made-with: Cursor --- pkg/agent/loop.go | 2 +- pkg/channels/whatsapp_native.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/agent/loop.go b/pkg/agent/loop.go index fc87c6fe5..aacc28093 100644 --- a/pkg/agent/loop.go +++ b/pkg/agent/loop.go @@ -218,6 +218,7 @@ func (al *AgentLoop) Run(ctx context.Context) error { } else { logger.DebugCF("agent", "Skipped outbound (message tool already sent)", map[string]any{"channel": msg.Channel}) } + } }() } } @@ -315,7 +316,6 @@ func (al *AgentLoop) ProcessDirectWithChannel( // ProcessHeartbeat processes a heartbeat request without session history. // Each heartbeat is independent and doesn't accumulate context. -// It uses the same mutex as processMessage so heartbeat and user messages never run concurrently. func (al *AgentLoop) ProcessHeartbeat(ctx context.Context, content, channel, chatID string) (string, error) { agent := al.registry.GetDefaultAgent() if agent == nil { diff --git a/pkg/channels/whatsapp_native.go b/pkg/channels/whatsapp_native.go index 3099afdcc..b9ab2c188 100644 --- a/pkg/channels/whatsapp_native.go +++ b/pkg/channels/whatsapp_native.go @@ -267,7 +267,7 @@ func (c *WhatsAppNativeChannel) handleIncoming(evt *events.Message) { metadata["peer_id"] = senderID } - logger.InfoCF("channels", "WhatsApp message received", map[string]any{"sender_id": senderID, "content_preview": utils.Truncate(content, 50)}) + logger.DebugCF("channels", "WhatsApp message received", map[string]any{"sender_id": senderID, "content_preview": utils.Truncate(content, 50)}) c.HandleMessage(senderID, chatID, content, mediaPaths, metadata) }