WIP: Temporary commit

pkg/agent/loop.go

@@ -571,7 +571,7 @@ func (al *AgentLoop) processSystemMessage(
 		UserMessage:     fmt.Sprintf("[System: %s] %s", msg.SenderID, msg.Content),
 		DefaultResponse: "Background task completed.",
 		EnableSummary:   false,
-		SendResponse:    true,
+		SendResponse:    false,  // Prevent duplicate responses caused by system message processing
 	})
 }
 

pkg/channels/qq/qq.go

@@ -31,6 +31,8 @@ type QQChannel struct {
 	processedIDs   map[string]bool
 	mu             sync.RWMutex
 }
+	chatTypeMap     map[string]string  // Track whether a ChatID is group or C2C
+	chatTypeMu      sync.RWMutex       // Protects chatTypeMap
 
 func NewQQChannel(cfg config.QQConfig, messageBus *bus.MessageBus) (*QQChannel, error) {
 	base := channels.NewBaseChannel("qq", cfg, messageBus, cfg.AllowFrom,

pkg/tools/subagent.go

@@ -20,6 +20,7 @@ type SubagentTask struct {
 	Status        string
 	Result        string
 	Created       int64
+	announcedOnce sync.Once  // Ensures the completion announcement is sent only once
 }
 
 type SubagentManager struct {