Function TestWorkingMemoryManager_TTL

pkg/memory/working_test.go:176–217

(t *testing.T)

}

func TestWorkingMemoryManager_TTL(t *testing.T) {
	ctx := context.Background()
	backend := backends.NewStateBackend()

	// 创建带 TTL 的管理器（1 秒过期）
	manager, err := NewWorkingMemoryManager(&WorkingMemoryConfig{
		Backend:    backend,
		BasePath:   "/working_memory/",
		Scope:      ScopeThread,
		DefaultTTL: 1 * time.Second,
	})
	if err != nil {
		t.Fatalf("create manager: %v", err)
	}

	threadID := "test-thread"
	resourceID := "test-resource"

	// 更新内容
	err = manager.Update(ctx, threadID, resourceID, "Temporary content")
	if err != nil {
		t.Fatalf("update: %v", err)
	}

	// 立即读取应该成功
	content, _ := manager.Get(ctx, threadID, resourceID)
	if content == "" {
		t.Error("expected content immediately after update")
	}

	// 等待过期
	time.Sleep(2 * time.Second)

	// 过期后应该返回空
	content, err = manager.Get(ctx, threadID, resourceID)
	if err != nil {
		t.Fatalf("get after expiry: %v", err)
	}
	if content != "" {
		t.Errorf("expected empty content after expiry, got: %s", content)
	}
}

func TestWorkingMemoryManager_Schema(t *testing.T) {
	ctx := context.Background()