Function TestWorkingMemoryScope

examples/memory-working/verify_test.go:50–98

TestWorkingMemoryScope 验证作用域隔离

(t *testing.T)

// TestWorkingMemoryScope 验证作用域隔离
func TestWorkingMemoryScope(t *testing.T) {
	ctx := context.Background()
	backend := backends.NewStateBackend()

	threadManager, _ := memory.NewWorkingMemoryManager(&memory.WorkingMemoryConfig{
		Backend:  backend,
		BasePath: "/working_memory/",
		Scope:    memory.ScopeThread,
	})

	resourceManager, _ := memory.NewWorkingMemoryManager(&memory.WorkingMemoryConfig{
		Backend:  backend,
		BasePath: "/working_memory/",
		Scope:    memory.ScopeResource,
	})

	thread1 := "thread-1"
	thread2 := "thread-2"
	resource := "resource-1"

	// Thread scope - 不同 thread 应该隔离
	if err := threadManager.Update(ctx, thread1, resource, "Thread 1 content"); err != nil {
		t.Fatalf("Failed to update thread1: %v", err)
	}
	if err := threadManager.Update(ctx, thread2, resource, "Thread 2 content"); err != nil {
		t.Fatalf("Failed to update thread2: %v", err)
	}

	content1, _ := threadManager.Get(ctx, thread1, resource)
	content2, _ := threadManager.Get(ctx, thread2, resource)

	if content1 == content2 {
		t.Error("thread scope should isolate different threads")
	}

	// Resource scope - 相同 resource 应该共享
	if err := resourceManager.Update(ctx, thread1, resource, "Shared content"); err != nil {
		t.Fatalf("Failed to update resource: %v", err)
	}

	contentFromThread1, _ := resourceManager.Get(ctx, thread1, resource)
	contentFromThread2, _ := resourceManager.Get(ctx, thread2, resource)

	if contentFromThread1 != contentFromThread2 {
		t.Error("resource scope should share content across threads")
	}

	t.Log("✓ Working Memory 作用域隔离验证通过")
}

// TestWorkingMemorySchema 验证 Schema 验证
func TestWorkingMemorySchema(t *testing.T) {