fix 5m period, fix websocket not responding on no data

This commit is contained in:
yusing 2025-02-14 01:57:26 +08:00
parent 40c4344f73
commit f84bd6a1e8
2 changed files with 1 additions and 3 deletions

View file

@ -71,9 +71,6 @@ func (p *Poller[T, AggregateT]) getRespData(r *http.Request) (any, error) {
return nil, errors.New("invalid period") return nil, errors.New("invalid period")
} }
rangeData := p.Get(periodFilter) rangeData := p.Get(periodFilter)
if len(rangeData) == 0 {
return nil, nil
}
if p.aggregator != nil { if p.aggregator != nil {
total, aggregated := p.aggregator(rangeData, query) total, aggregated := p.aggregator(rangeData, query)
return map[string]any{ return map[string]any{

View file

@ -38,6 +38,7 @@ func (p *Period[T]) Add(info *T) {
p.mu.Lock() p.mu.Lock()
defer p.mu.Unlock() defer p.mu.Unlock()
now := time.Now() now := time.Now()
p.FiveMinutes.Add(now, info)
p.FifteenMinutes.Add(now, info) p.FifteenMinutes.Add(now, info)
p.OneHour.Add(now, info) p.OneHour.Add(now, info)
p.OneDay.Add(now, info) p.OneDay.Add(now, info)