Function TestGetTimelineRange

pkg/events/bus_test.go:167–199

TestGetTimelineRange 测试分页获取时间线

(t *testing.T)

// TestGetTimelineRange 测试分页获取时间线
func TestGetTimelineRange(t *testing.T) {
	eb := NewEventBus()
	defer eb.Close()

	// 添加 10 个事件
	for i := range 10 {
		eb.EmitProgress(&types.ProgressTextChunkEvent{Step: i, Delta: "test"})
	}

	// 测试获取前 5 个
	events := eb.GetTimelineRange(0, 5)
	if len(events) != 5 {
		t.Errorf("expected 5 events, got %d", len(events))
	}

	// 测试获取后 5 个
	events = eb.GetTimelineRange(5, 5)
	if len(events) != 5 {
		t.Errorf("expected 5 events, got %d", len(events))
	}

	// 测试超出范围
	events = eb.GetTimelineRange(8, 10)
	if len(events) != 2 {
		t.Errorf("expected 2 events, got %d", len(events))
	}

	// 测试负数起始
	events = eb.GetTimelineRange(-5, 3)
	if len(events) != 3 {
		t.Errorf("expected 3 events, got %d", len(events))
	}
}

// TestGetTimelineSince 测试从指定 cursor 后获取事件
func TestGetTimelineSince(t *testing.T) {