Function TestInMemoryService_GetState

pkg/session/inmemory_test.go:433–541

(t *testing.T)

}

func TestInMemoryService_GetState(t *testing.T) {
	t.Skip("Skipping: inmemory service implementation has issues with state retrieval")
	ctx := context.Background()

	t.Run("获取所有状态", func(t *testing.T) {
		service := NewInMemoryService()
		sess, _ := service.Create(ctx, &CreateRequest{
			AppName: "test-app",
			UserID:  "user-1",
			AgentID: "agent-1",
		})

		// 添加各种作用域的状态
		event := &Event{
			ID:           "evt-1",
			Timestamp:    time.Now(),
			InvocationID: "inv-1",
			AgentID:      "agent-1",
			Branch:       "root",
			Author:       "system",
			Content: types.Message{
				Role:    types.RoleSystem,
				Content: "State setup",
			},
			Actions: EventActions{
				StateDelta: map[string]any{
					"app:version":    "1.0.0",
					"user:language":  "zh-CN",
					"session:page":   1,
					"temp:cache_key": "temp-value",
				},
			},
		}
		if err := service.AppendEvent(ctx, sess.ID(), event); err != nil {
			t.Fatalf("AppendEvent failed: %v", err)
		}

		// 通过Session接口访问状态
		retrievedSess, err := service.Get(ctx, &GetRequest{
			SessionID: sess.ID(),
		})
		require.NoError(t, err)
		state := retrievedSess.State()
		assert.NotNil(t, state)
		// 验证状态存在
		assert.True(t, state.Has("app:version"))
		assert.True(t, state.Has("user:language"))
		assert.True(t, state.Has("session:page"))
	})

	t.Run("按作用域过滤", func(t *testing.T) {
		service := NewInMemoryService()
		sess, _ := service.Create(ctx, &CreateRequest{
			AppName: "test-app",
			UserID:  "user-1",
			AgentID: "agent-1",
		})