Method QueryEvents

internal/observe/query.go:17–49

QueryEvents returns cross-session event summaries ordered for CLI/API consumption.

(ctx context.Context, query store.EventSummaryQuery)

// QueryEvents returns cross-session event summaries ordered for CLI/API consumption.
func (o *Observer) QueryEvents(ctx context.Context, query store.EventSummaryQuery) ([]store.EventSummary, error) {
	if ctx == nil {
		return nil, errors.New("observe: query events context is required")
	}
	events, err := o.registry.ListEventSummaries(ctx, query)
	if err != nil {
		return nil, err
	}

	o.mu.RLock()
	memorySource := o.memoryEventSource
	o.mu.RUnlock()
	if memorySource == nil || strings.TrimSpace(query.SessionID) != "" {
		return events, nil
	}

	workspaces, err := o.memoryEventWorkspaces(ctx, query.WorkspaceID)
	if err != nil {
		return nil, err
	}
	memoryQuery, err := memoryEventQueryForWorkspaces(ctx, query, workspaces)
	if err != nil {
		return nil, err
	}
	memoryEvents, err := memorySource.ListMemoryEventSummaries(ctx, workspaces, memoryQuery)
	if err != nil {
		return nil, fmt.Errorf("observe: query memory events: %w", err)
	}

	events = append(filterRegistryMemoryEvents(events), memoryEvents...)
	sortEventSummaries(events)
	return clampEventSummaries(events, query.Limit), nil
}

// QueryTokenStats returns aggregated per-session token usage rows.
func (o *Observer) QueryTokenStats(ctx context.Context, query store.TokenStatsQuery) ([]store.TokenStats, error) {