返回 DeepSeek-Reasonix
interrupted_tool_recovery_test.go
根目录 / internal / control / interrupted_tool_recovery_test.go
1 package control
2
3 import (
4 "testing"
5
6 "reasonix/internal/provider"
7 )
8
9 func TestInterruptedRecoveryPrefersLedgerFactOverPlaceholder(t *testing.T) {
10 recovery := &provider.InterruptedTurnRecovery{Pending: true}
11 msgs := []provider.Message{
12 {Role: provider.RoleAssistant, ToolCalls: []provider.ToolCall{{ID: "write-1", Name: "write_file", Arguments: `{}`}}},
13 {Role: provider.RoleTool, ToolCallID: "write-1", Name: "write_file", Content: "[no result: the previous turn was interrupted before this tool call completed]"},
14 }
15 evidence := &interruptedTailEvidence{turnID: "turn-1", states: map[string]provider.ToolRunState{"write-1": provider.ToolRunUnknown}}
16 recordInterruptedAssistantRecovery(recovery, msgs, 0, evidence)
17 if len(recovery.UnknownTools) != 1 || recovery.RequiresUserDecision {
18 t.Fatalf("recovery=%+v, want one fact-only unknown call", recovery)
19 }
20 if len(recovery.ToolCalls) != 1 || recovery.ToolCalls[0].State != provider.ToolRunUnknown {
21 t.Fatalf("tool records=%+v, want ledger-proven unknown state", recovery.ToolCalls)
22 }
23 }
24
25 func TestInterruptedRecoveryUsesCancelledForUnstartedLedgerCall(t *testing.T) {
26 recovery := &provider.InterruptedTurnRecovery{Pending: true}
27 msgs := []provider.Message{{Role: provider.RoleAssistant, ToolCalls: []provider.ToolCall{{ID: "read-1", Name: "read_file", Arguments: `{}`}}}, {Role: provider.RoleTool, ToolCallID: "read-1", Name: "read_file", Content: "[no result: the previous turn was interrupted before this tool call completed]"}}
28 evidence := &interruptedTailEvidence{turnID: "turn-2", states: map[string]provider.ToolRunState{"read-1": provider.ToolRunCancelled}}
29 recordInterruptedAssistantRecovery(recovery, msgs, 0, evidence)
30 if len(recovery.NotStartedTools) != 1 || len(recovery.UnknownTools) != 0 {
31 t.Fatalf("recovery=%+v, want cancelled call outside unknown bucket", recovery)
32 }
33 }
34
34 lines GO