diff --git a/pkg/agent/agent_command.go b/pkg/agent/agent_command.go index 3f9e3cb99..6a0e6ade6 100644 --- a/pkg/agent/agent_command.go +++ b/pkg/agent/agent_command.go @@ -335,7 +335,7 @@ func (al *AgentLoop) buildCommandsRuntime( return al.contextManager.Clear(ctx, opts.SessionKey) } - rt.ResetSession = func(clear bool) (string, error) { + rt.ResetSession = func(clearOverride bool) (string, error) { if opts == nil { return "", fmt.Errorf("process options not available") } @@ -343,7 +343,7 @@ func (al *AgentLoop) buildCommandsRuntime( if routeSessionKey == "" { return "", fmt.Errorf("route session key not available") } - if clear { + if clearOverride { return "", al.clearSessionOverride(routeSessionKey) } diff --git a/pkg/agent/agent_message.go b/pkg/agent/agent_message.go index 5b82b25ff..ddc7b78cd 100644 --- a/pkg/agent/agent_message.go +++ b/pkg/agent/agent_message.go @@ -171,7 +171,15 @@ func (al *AgentLoop) processMessage(ctx context.Context, msg bus.InboundMessage) Dispatch: DispatchRequest{ RouteSessionKey: allocation.SessionKey, SessionKey: sessionKey, - SessionAliases: buildSessionAliases(sessionKey, sessionAliasCandidates(allocation.SessionKey, sessionKey, allocation.SessionAliases, msg.SessionKey)...), + SessionAliases: buildSessionAliases( + sessionKey, + sessionAliasCandidates( + allocation.SessionKey, + sessionKey, + allocation.SessionAliases, + msg.SessionKey, + )..., + ), InboundContext: cloneInboundContext(&msg.Context), RouteResult: cloneResolvedRoute(&route), SessionScope: session.CloneScope(&allocation.Scope), diff --git a/pkg/agent/agent_test.go b/pkg/agent/agent_test.go index 3343042b2..73de0150d 100644 --- a/pkg/agent/agent_test.go +++ b/pkg/agent/agent_test.go @@ -792,26 +792,26 @@ func TestProcessMessage_ResetClearRestoresDefaultSession(t *testing.T) { defaultAgent := al.GetRegistry().GetDefaultAgent() originalHistoryLen := len(defaultAgent.Sessions.GetHistory(routeSessionKey)) - if _, err := al.processMessage(context.Background(), testInboundMessage(bus.InboundMessage{ + if _, procErr := al.processMessage(context.Background(), testInboundMessage(bus.InboundMessage{ Channel: "telegram", SenderID: "telegram:123", ChatID: "chat-1", Content: "/reset", - })); err != nil { - t.Fatalf("reset processMessage() error = %v", err) + })); procErr != nil { + t.Fatalf("reset processMessage() error = %v", procErr) } overrideSessionKey := al.getSessionOverride(routeSessionKey) if overrideSessionKey == "" { t.Fatal("expected override session key after /reset") } - if _, err := al.processMessage(context.Background(), testInboundMessage(bus.InboundMessage{ + if _, procErr := al.processMessage(context.Background(), testInboundMessage(bus.InboundMessage{ Channel: "telegram", SenderID: "telegram:123", ChatID: "chat-1", Content: "during reset", - })); err != nil { - t.Fatalf("during-reset processMessage() error = %v", err) + })); procErr != nil { + t.Fatalf("during-reset processMessage() error = %v", procErr) } overrideHistoryLen := len(defaultAgent.Sessions.GetHistory(overrideSessionKey)) if overrideHistoryLen == 0 { @@ -849,7 +849,11 @@ func TestProcessMessage_ResetClearRestoresDefaultSession(t *testing.T) { } gotOverrideHistoryLen := len(defaultAgent.Sessions.GetHistory(overrideSessionKey)) if gotOverrideHistoryLen != overrideHistoryLen { - t.Fatalf("override history len = %d, want preserved len %d after reset clear", gotOverrideHistoryLen, overrideHistoryLen) + t.Fatalf( + "override history len = %d, want preserved len %d after reset clear", + gotOverrideHistoryLen, + overrideHistoryLen, + ) } } diff --git a/pkg/agent/session_reset.go b/pkg/agent/session_reset.go index 3880b7c6a..5a3d929c4 100644 --- a/pkg/agent/session_reset.go +++ b/pkg/agent/session_reset.go @@ -49,7 +49,11 @@ func (al *AgentLoop) resolveEffectiveSessionKey(routeSessionKey, msgSessionKey s return routeSessionKey } -func sessionAliasCandidates(routeSessionKey, effectiveSessionKey string, routeAliases []string, msgSessionKey string) []string { +func sessionAliasCandidates( + routeSessionKey, effectiveSessionKey string, + routeAliases []string, + msgSessionKey string, +) []string { if isExplicitSessionKey(msgSessionKey) { return []string{msgSessionKey} } diff --git a/pkg/commands/runtime.go b/pkg/commands/runtime.go index f8596c2e3..9ed2716fb 100644 --- a/pkg/commands/runtime.go +++ b/pkg/commands/runtime.go @@ -59,7 +59,7 @@ type Runtime struct { GetContextStats func() *ContextStats SwitchModel func(value string) (oldModel string, err error) SwitchChannel func(value string) error - ResetSession func(clear bool) (sessionKey string, err error) + ResetSession func(clearOverride bool) (sessionKey string, err error) ClearHistory func() error ReloadConfig func() error StopActiveTurn func() (StopResult, error)