mirror of
https://github.com/MeshCore-Beacon/beacon-server.git
synced 2026-10-22 10:22:30 +00:00
MrAlders0n
d788e82ab4
Top advertisers ranked by flood + direct, so chatty companions with few flood adverts topped the list. sort=flood|direct is now required and applied before the limit; client floors raised to app 1.0.0 / web 2.0.4.
44 lines
1.3 KiB
Go
44 lines
1.3 KiB
Go
// Copyright 2026 Beacon Contributors
|
|
// SPDX-License-Identifier: AGPL-3.0-or-later
|
|
|
|
package cache
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/MeshCore-Beacon/beacon-server/internal/api"
|
|
)
|
|
|
|
type topAdvertisersReader struct {
|
|
api.Reader
|
|
calls int64
|
|
}
|
|
|
|
func (r *topAdvertisersReader) GetStatsTopAdvertisers(_ context.Context, _ []string, _ time.Time, _ int32, sort api.AdvertiserSort) ([]api.TopAdvertiser, error) {
|
|
r.calls++
|
|
return []api.TopAdvertiser{{PublicKey: string(sort), AdvertCount: r.calls}}, nil
|
|
}
|
|
|
|
func (r *topAdvertisersReader) AnalyticsRevision(context.Context) (int64, error) { return 0, nil }
|
|
|
|
func TestTopAdvertisersCacheSeparatesSorts(t *testing.T) {
|
|
c, _ := newTestClient(t)
|
|
inner := &topAdvertisersReader{}
|
|
reader := NewCachedReader(inner, c, CacheTTLs{Stats: time.Hour})
|
|
since := time.UnixMilli(3600000)
|
|
for _, sort := range []api.AdvertiserSort{api.AdvertiserSortFlood, api.AdvertiserSortDirect, api.AdvertiserSortFlood, api.AdvertiserSortDirect} {
|
|
rows, err := reader.GetStatsTopAdvertisers(context.Background(), nil, since, 10, sort)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if len(rows) != 1 || rows[0].PublicKey != string(sort) {
|
|
t.Fatalf("sort %s served %+v", sort, rows)
|
|
}
|
|
}
|
|
if inner.calls != 2 {
|
|
t.Fatalf("underlying calls = %d, want 2", inner.calls)
|
|
}
|
|
}
|