0819c8a51a
- 删除 account_today_stats_cache.go 中重复的 normalizeAccountIDList，统一使用 id_list_utils.go 的 normalizeInt64IDList - 新增 snapshot_cache_test.go：覆盖 snapshotCache、buildETagFromAny、parseBoolQueryWithDefault - 新增 id_list_utils_test.go：覆盖 normalizeInt64IDList、buildAccountTodayStatsBatchCacheKey - 新增 ops_query_mode_test.go：覆盖 shouldFallbackOpsPreagg、cloneOpsFilterWithMode
129 lines
3.2 KiB
Go
129 lines
3.2 KiB
Go
//go:build unit
|
|
|
|
package admin
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestSnapshotCache_SetAndGet(t *testing.T) {
|
|
c := newSnapshotCache(5 * time.Second)
|
|
|
|
entry := c.Set("key1", map[string]string{"hello": "world"})
|
|
require.NotEmpty(t, entry.ETag)
|
|
require.NotNil(t, entry.Payload)
|
|
|
|
got, ok := c.Get("key1")
|
|
require.True(t, ok)
|
|
require.Equal(t, entry.ETag, got.ETag)
|
|
}
|
|
|
|
func TestSnapshotCache_Expiration(t *testing.T) {
|
|
c := newSnapshotCache(1 * time.Millisecond)
|
|
|
|
c.Set("key1", "value")
|
|
time.Sleep(5 * time.Millisecond)
|
|
|
|
_, ok := c.Get("key1")
|
|
require.False(t, ok, "expired entry should not be returned")
|
|
}
|
|
|
|
func TestSnapshotCache_GetEmptyKey(t *testing.T) {
|
|
c := newSnapshotCache(5 * time.Second)
|
|
_, ok := c.Get("")
|
|
require.False(t, ok)
|
|
}
|
|
|
|
func TestSnapshotCache_GetMiss(t *testing.T) {
|
|
c := newSnapshotCache(5 * time.Second)
|
|
_, ok := c.Get("nonexistent")
|
|
require.False(t, ok)
|
|
}
|
|
|
|
func TestSnapshotCache_NilReceiver(t *testing.T) {
|
|
var c *snapshotCache
|
|
_, ok := c.Get("key")
|
|
require.False(t, ok)
|
|
|
|
entry := c.Set("key", "value")
|
|
require.Empty(t, entry.ETag)
|
|
}
|
|
|
|
func TestSnapshotCache_SetEmptyKey(t *testing.T) {
|
|
c := newSnapshotCache(5 * time.Second)
|
|
|
|
// Set with empty key should return entry but not store it
|
|
entry := c.Set("", "value")
|
|
require.NotEmpty(t, entry.ETag)
|
|
|
|
_, ok := c.Get("")
|
|
require.False(t, ok)
|
|
}
|
|
|
|
func TestSnapshotCache_DefaultTTL(t *testing.T) {
|
|
c := newSnapshotCache(0)
|
|
require.Equal(t, 30*time.Second, c.ttl)
|
|
|
|
c2 := newSnapshotCache(-1 * time.Second)
|
|
require.Equal(t, 30*time.Second, c2.ttl)
|
|
}
|
|
|
|
func TestSnapshotCache_ETagDeterministic(t *testing.T) {
|
|
c := newSnapshotCache(5 * time.Second)
|
|
payload := map[string]int{"a": 1, "b": 2}
|
|
|
|
entry1 := c.Set("k1", payload)
|
|
entry2 := c.Set("k2", payload)
|
|
require.Equal(t, entry1.ETag, entry2.ETag, "same payload should produce same ETag")
|
|
}
|
|
|
|
func TestSnapshotCache_ETagFormat(t *testing.T) {
|
|
c := newSnapshotCache(5 * time.Second)
|
|
entry := c.Set("k", "test")
|
|
// ETag should be quoted hex string: "abcdef..."
|
|
require.True(t, len(entry.ETag) > 2)
|
|
require.Equal(t, byte('"'), entry.ETag[0])
|
|
require.Equal(t, byte('"'), entry.ETag[len(entry.ETag)-1])
|
|
}
|
|
|
|
func TestBuildETagFromAny_UnmarshalablePayload(t *testing.T) {
|
|
// channels are not JSON-serializable
|
|
etag := buildETagFromAny(make(chan int))
|
|
require.Empty(t, etag)
|
|
}
|
|
|
|
func TestParseBoolQueryWithDefault(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
raw string
|
|
def bool
|
|
want bool
|
|
}{
|
|
{"empty returns default true", "", true, true},
|
|
{"empty returns default false", "", false, false},
|
|
{"1", "1", false, true},
|
|
{"true", "true", false, true},
|
|
{"TRUE", "TRUE", false, true},
|
|
{"yes", "yes", false, true},
|
|
{"on", "on", false, true},
|
|
{"0", "0", true, false},
|
|
{"false", "false", true, false},
|
|
{"FALSE", "FALSE", true, false},
|
|
{"no", "no", true, false},
|
|
{"off", "off", true, false},
|
|
{"whitespace trimmed", " true ", false, true},
|
|
{"unknown returns default true", "maybe", true, true},
|
|
{"unknown returns default false", "maybe", false, false},
|
|
}
|
|
|
|
for _, tc := range tests {
|
|
t.Run(tc.name, func(t *testing.T) {
|
|
got := parseBoolQueryWithDefault(tc.raw, tc.def)
|
|
require.Equal(t, tc.want, got)
|
|
})
|
|
}
|
|
}
|