fix bug

pkg/agent/loop.go

@@ -800,6 +800,10 @@ func isAutonomySyntheticMessage(msg bus.InboundMessage) bool {
 	return strings.EqualFold(strings.TrimSpace(msg.Metadata["source"]), "autonomy")
 }
 
+func shouldHandleControlIntents(msg bus.InboundMessage) bool {
+	return !isSyntheticMessage(msg)
+}
+
 func (al *AgentLoop) ProcessDirect(ctx context.Context, content, sessionKey string) (string, error) {
 	msg := bus.InboundMessage{
 		Channel:    "cli",
@@ -827,18 +831,25 @@ func (al *AgentLoop) processMessage(ctx context.Context, msg bus.InboundMessage)
 		defer al.finishAutonomyRound(msg.SessionKey)
 	}
 
+	controlEligible := shouldHandleControlIntents(msg)
+
 	// Route system messages to processSystemMessage
 	if msg.Channel == "system" {
 		return al.processSystemMessage(ctx, msg)
 	}
 
 	// Built-in slash commands (deterministic, no LLM roundtrip)
+	if controlEligible {
 		if handled, result, err := al.handleSlashCommand(msg); handled {
 			return result, err
 		}
+	}
 
+	if controlEligible {
 		al.noteAutonomyUserActivity(msg)
+	}
 
+	if controlEligible {
 		if intent, ok := al.detectAutonomyIntent(ctx, msg.Content); ok {
 			switch intent.action {
 			case "start":
@@ -879,6 +890,7 @@ func (al *AgentLoop) processMessage(ctx context.Context, msg bus.InboundMessage)
 				return al.autoLearnerStatus(msg.SessionKey), nil
 			}
 		}
+	}
 
 	directives := parseTaskExecutionDirectives(msg.Content)
 	if inferred, ok := al.inferTaskExecutionDirectives(ctx, msg.Content); ok {
@@ -891,7 +903,7 @@ func (al *AgentLoop) processMessage(ctx context.Context, msg bus.InboundMessage)
 	if strings.TrimSpace(userPrompt) == "" {
 		userPrompt = msg.Content
 	}
-	if al.isAutonomyEnabled(msg.SessionKey) && !isSyntheticMessage(msg) {
+	if al.isAutonomyEnabled(msg.SessionKey) && controlEligible {
 		directives.stageReport = true
 		userPrompt = buildAutonomyTaskPrompt(userPrompt)
 	}

pkg/agent/loop_directive_test.go

@@ -3,6 +3,8 @@ package agent
 import (
 	"testing"
 	"time"
+
+	"clawgo/pkg/bus"
 )
 
 func TestParseTaskExecutionDirectives_RunCommand(t *testing.T) {
@@ -152,3 +154,36 @@ func TestExtractJSONObject_Invalid(t *testing.T) {
 		t.Fatalf("expected empty json, got: %q", raw)
 	}
 }
+
+func TestShouldHandleControlIntents_UserMessage(t *testing.T) {
+	msg := bus.InboundMessage{
+		SenderID: "user",
+		Content:  "请进入自主模式",
+	}
+	if !shouldHandleControlIntents(msg) {
+		t.Fatalf("expected user message to be control-eligible")
+	}
+}
+
+func TestShouldHandleControlIntents_AutonomySyntheticSender(t *testing.T) {
+	msg := bus.InboundMessage{
+		SenderID: "autonomy",
+		Content:  "自主模式第 1 轮推进",
+	}
+	if shouldHandleControlIntents(msg) {
+		t.Fatalf("expected autonomy synthetic message to be ignored for control intents")
+	}
+}
+
+func TestShouldHandleControlIntents_AutoLearnSyntheticMetadata(t *testing.T) {
+	msg := bus.InboundMessage{
+		SenderID: "gateway",
+		Content:  "自动学习第 1 轮",
+		Metadata: map[string]string{
+			"source": "autolearn",
+		},
+	}
+	if shouldHandleControlIntents(msg) {
+		t.Fatalf("expected autolearn synthetic metadata message to be ignored for control intents")
+	}
+}

pkg/channels/telegram.go

@@ -328,6 +328,12 @@ func (c *TelegramChannel) handleMessage(runCtx context.Context, message *telego.
 	if user == nil {
 		return
 	}
+	if user.IsBot {
+		logger.DebugCF("telegram", "Ignoring bot-originated message", map[string]interface{}{
+			"user_id": user.ID,
+		})
+		return
+	}
 
 	senderID := fmt.Sprintf("%d", user.ID)