// Copyright 2025 FishGoddess. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package cachego

import (
	"io"
	"testing"
	"time"
)

const (
	testCacheName       = "test"
	testCacheType       = lru
	testCacheShardings  = 16
	testCacheGCDuration = 10 * time.Minute
)

func newTestReportableCache() (*reportableCache, *Reporter) {
	conf := newDefaultConfig()
	conf.cacheName = testCacheName
	conf.cacheType = testCacheType
	conf.shardings = testCacheShardings
	conf.gcDuration = testCacheGCDuration
	conf.maxEntries = maxTestEntries

	cache, reporter := report(conf, newStandardCache(conf))
	return cache.(*reportableCache), reporter
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReportableCache$
func TestReportableCache(t *testing.T) {
	cache, _ := newTestReportableCache()
	testCacheImplement(t, cache)
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReportableCacheReportMissed$
func TestReportableCacheReportMissed(t *testing.T) {
	cache, reporter := newTestReportableCache()
	cache.Set("key", 666, NoTTL)

	checked := false
	cache.reportMissed = func(reporter *Reporter, key string) {
		if key == "key" {
			t.Fatal("key == \"key\"")
		}

		if key != "missed" {
			t.Fatalf("key %s != \"missed\"", key)
		}

		checked = true
	}

	cache.Get("key")
	cache.Get("missed")

	if !checked {
		t.Fatal("reportMissed not checked")
	}

	if reporter.CountMissed() != 1 {
		t.Fatalf("CountMissed %d is wrong", reporter.CountMissed())
	}

	missedRate := reporter.MissedRate()
	if missedRate < 0.499 || missedRate > 0.501 {
		t.Fatalf("missedRate %.3f is wrong", missedRate)
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReportableCacheReportHit$
func TestReportableCacheReportHit(t *testing.T) {
	cache, reporter := newTestReportableCache()
	cache.Set("key", 666, NoTTL)

	checked := false
	cache.reportHit = func(reporter *Reporter, key string, value interface{}) {
		if key == "missed" {
			t.Fatal("key == \"missed\"")
		}

		if key != "key" {
			t.Fatalf("key %s != \"key\"", key)
		}

		if value.(int) != 666 {
			t.Fatalf("value.(int) %d is wrong", value.(int))
		}

		checked = true
	}

	cache.Get("key")
	cache.Get("missed")

	if !checked {
		t.Fatal("reportHit not checked")
	}

	if reporter.CountHit() != 1 {
		t.Fatalf("CountHit %d is wrong", reporter.CountHit())
	}

	hitRate := reporter.HitRate()
	if hitRate < 0.499 || hitRate > 0.501 {
		t.Fatalf("hitRate %.3f is wrong", hitRate)
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReportableCacheReportGC$
func TestReportableCacheReportGC(t *testing.T) {
	cache, reporter := newTestReportableCache()
	cache.Set("key1", 1, time.Millisecond)
	cache.Set("key2", 2, time.Millisecond)
	cache.Set("key3", 3, time.Millisecond)
	cache.Set("key4", 4, time.Second)
	cache.Set("key5", 5, time.Second)

	gcCount := uint64(0)
	checked := false

	cache.reportGC = func(reporter *Reporter, cost time.Duration, cleans int) {
		if cost <= 0 {
			t.Fatalf("cost %d <= 0", cost)
		}

		if cleans != 3 {
			t.Fatalf("cleans %d is wrong", cleans)
		}

		gcCount++
		checked = true
	}

	time.Sleep(10 * time.Millisecond)

	cleans := cache.GC()
	if cleans != 3 {
		t.Fatalf("cleans %d is wrong", cleans)
	}

	if !checked {
		t.Fatal("reportHit not checked")
	}

	if reporter.CountGC() != gcCount {
		t.Fatalf("CountGC %d is wrong", reporter.CountGC())
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReportableCacheReportLoad$
func TestReportableCacheReportLoad(t *testing.T) {
	cache, reporter := newTestReportableCache()

	loadCount := uint64(0)
	checked := false

	cache.reportLoad = func(reporter *Reporter, key string, value interface{}, ttl time.Duration, err error) {
		if key != "load" {
			t.Fatalf("key %s is wrong", key)
		}

		if value.(int) != 999 {
			t.Fatalf("value.(int) %d is wrong", value.(int))
		}

		if ttl != time.Second {
			t.Fatalf("ttl %s is wrong", ttl)
		}

		if err != io.EOF {
			t.Fatalf("err %+v is wrong", err)
		}

		loadCount++
		checked = true
	}

	value, err := cache.Load("load", time.Second, func() (value interface{}, err error) {
		return 999, io.EOF
	})

	if value.(int) != 999 {
		t.Fatalf("value.(int) %d is wrong", value.(int))
	}

	if err != io.EOF {
		t.Fatalf("err %+v is wrong", err)
	}

	if !checked {
		t.Fatal("reportLoad not checked")
	}

	if reporter.CountLoad() != loadCount {
		t.Fatalf("CountLoad %d is wrong", reporter.CountLoad())
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReporterCacheName$
func TestReporterCacheName(t *testing.T) {
	_, reporter := newTestReportableCache()
	if reporter.CacheName() != reporter.conf.cacheName {
		t.Fatalf("CacheName %s is wrong compared with conf", reporter.CacheName())
	}

	if reporter.CacheName() != testCacheName {
		t.Fatalf("CacheName %s is wrong", reporter.CacheName())
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReporterCacheType$
func TestReporterCacheType(t *testing.T) {
	_, reporter := newTestReportableCache()
	if reporter.CacheType() != reporter.conf.cacheType {
		t.Fatalf("CacheType %s is wrong compared with conf", reporter.CacheType())
	}

	if reporter.CacheType() != testCacheType {
		t.Fatalf("CacheType %s is wrong", reporter.CacheType())
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReporterCacheShardings$
func TestReporterCacheShardings(t *testing.T) {
	_, reporter := newTestReportableCache()
	if reporter.CacheShardings() != reporter.conf.shardings {
		t.Fatalf("CacheShardings %d is wrong compared with conf", reporter.CacheShardings())
	}

	if reporter.CacheShardings() != testCacheShardings {
		t.Fatalf("CacheShardings %d is wrong", reporter.CacheShardings())
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReporterCacheGC$
func TestReporterCacheGC(t *testing.T) {
	_, reporter := newTestReportableCache()
	if reporter.CacheGC() != reporter.conf.gcDuration {
		t.Fatalf("CacheGC %d is wrong compared with conf", reporter.CacheGC())
	}

	if reporter.CacheGC() != testCacheGCDuration {
		t.Fatalf("CacheGC %d is wrong", reporter.CacheGC())
	}
}

// go test -v -cover -count=1 -test.cpu=1 -run=^TestReporterCacheSize$
func TestReporterCacheSize(t *testing.T) {
	cache, reporter := newTestReportableCache()
	cache.Set("key1", 1, time.Millisecond)
	cache.Set("key2", 2, time.Millisecond)
	cache.Set("key3", 3, time.Millisecond)
	cache.Set("key4", 4, time.Second)
	cache.Set("key5", 5, time.Second)

	if reporter.CacheSize() != 5 {
		t.Fatalf("CacheSize %d is wrong", reporter.CacheSize())
	}

	time.Sleep(100 * time.Millisecond)
	cache.GC()

	if reporter.CacheSize() != 2 {
		t.Fatalf("CacheSize %d is wrong", reporter.CacheSize())
	}
}