Method GetEventsSince

server/handlers/dashboard.go:387–457

GetEventsSince returns events since a cursor

(c *gin.Context)

// GetEventsSince returns events since a cursor
func (h *DashboardHandler) GetEventsSince(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{},
				"next_cursor": int64(0),
				"message":     "Registry not available, real-time events disabled",
			},
		})
		return
	}

	cursorStr := c.Param("cursor")
	cursor, err := strconv.ParseInt(cursorStr, 10, 64)
	if err != nil {
		c.JSON(http.StatusBadRequest, gin.H{
			"success": false,
			"error": gin.H{
				"code":    "bad_request",
				"message": "Invalid cursor",
			},
		})
		return
	}

	// 从所有 Agent 的 EventBus 聚合事件
	var allEvents []types.AgentEventEnvelope
	maxCursor := cursor
	for _, eb := range h.registry.GetEventBuses() {
		if eb != nil {
			evts := eb.GetTimelineSince(cursor)
			allEvents = append(allEvents, evts...)
			// 更新最大 cursor
			if ebCursor := eb.GetCursor(); ebCursor > maxCursor {
				maxCursor = ebCursor
			}
		}
	}

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

	// 转换为响应格式
	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,
		})
	}