Method GetRecentEvents

server/handlers/dashboard.go:313–384

GetRecentEvents returns recent events from the timeline

(c *gin.Context)

// GetRecentEvents returns recent events from the timeline
func (h *DashboardHandler) GetRecentEvents(c *gin.Context) {
	ctx := c.Request.Context()

	// 检查 Registry 是否可用
	if h.registry == nil {
		c.JSON(http.StatusOK, gin.H{
			"success": true,
			"data": gin.H{
				"events":  []gin.H{},
				"cursor":  int64(0),
				"message": "Registry not available, real-time events disabled",
			},
		})
		return
	}

	limitStr := c.DefaultQuery("limit", "100")
	limit, err := strconv.Atoi(limitStr)
	if err != nil || limit <= 0 {
		limit = 100
	}
	if limit > 1000 {
		limit = 1000
	}

	// 从所有 Agent 的 EventBus 聚合事件
	var allEvents []types.AgentEventEnvelope
	for _, eb := range h.registry.GetEventBuses() {
		if eb != nil {
			evts := eb.GetTimelineRange(0, limit)
			allEvents = append(allEvents, evts...)
		}
	}

	// 按时间戳排序（最新的在前）
	sort.Slice(allEvents, func(i, j int) bool {
		return allEvents[i].Bookmark.Timestamp > allEvents[j].Bookmark.Timestamp
	})

	// 限制数量
	if len(allEvents) > limit {
		allEvents = allEvents[:limit]
	}

	// 转换为响应格式
	result := make([]gin.H, 0, len(allEvents))
	for _, env := range allEvents {
		result = append(result, gin.H{
			"cursor":    env.Cursor,
			"timestamp": time.UnixMilli(env.Bookmark.Timestamp),
			"event":     env.Event,
		})
	}

	logging.Info(ctx, "dashboard.events.list", map[string]any{
		"count": len(result),
	})