返回 DeepSeek-Reasonix
session_reserved_test.go
根目录 / internal / control / session_reserved_test.go
1 package control
2
3 import (
4 "path/filepath"
5 "reasonix/internal/agent"
6 "reasonix/internal/event"
7 "reasonix/internal/session"
8 "reasonix/internal/tool"
9 "testing"
10 )
11
12 func TestReservedSessionUsesOrdinaryCreationPromptOnce(t *testing.T) {
13 service, err := session.NewService("desktop", session.NewFilesystemPersistence(filepath.Join(t.TempDir(), "sessions")))
14 if err != nil {
15 t.Fatal(err)
16 }
17 reserved, err := service.Create(t.Context(), session.CreateOptions{SessionID: "reserved"})
18 if err != nil {
19 t.Fatal(err)
20 }
21 executor := agent.New(nil, tool.NewRegistry(), agent.NewSession("system fixture"), agent.Options{}, event.Discard)
22 controller := newOwnedTestController(t, Options{Executor: executor, Sink: event.Discard, SessionService: service, SessionRuntime: reserved, ExclusiveSession: true})
23 if err := controller.InitializeReservedSession(t.Context(), reserved.Ref()); err != nil {
24 t.Fatal(err)
25 }
26 snapshot := reserved.Session().ExecutionSnapshot()
27 if err := controller.InitializeReservedSession(t.Context(), reserved.Ref()); err != nil {
28 t.Fatal(err)
29 }
30 if len(reserved.Session().ExecutionSnapshot().Projection.ModelMessages) != len(snapshot.Projection.ModelMessages) {
31 t.Fatal("retry reseeded prompt")
32 }
33 ordinary, err := controller.BindFreshSession(t.Context(), "ordinary")
34 if err != nil {
35 t.Fatal(err)
36 }
37 other, err := service.Query().Snapshot(t.Context(), ordinary)
38 if err != nil {
39 t.Fatal(err)
40 }
41 if len(snapshot.Projection.ModelMessages) != len(other.Projection.ModelMessages) {
42 t.Fatal("different initial message count")
43 }
44 for i, message := range snapshot.Projection.ModelMessages {
45 if message.Role != other.Projection.ModelMessages[i].Role || message.Content != other.Projection.ModelMessages[i].Content {
46 t.Fatal("reserved creation changed provider-visible initial prompt")
47 }
48 }
49 }
50
50 lines GO