Snider
adaa4131f9
- Fix remaining 187 pkg/ files referencing core/cli → core/go - Move SDK library code from internal/cmd/sdk/ → pkg/sdk/ (new package) - Create pkg/rag/helpers.go with convenience functions from internal/cmd/rag/ - Fix pkg/mcp/tools_rag.go to use pkg/rag instead of internal/cmd/rag - Fix pkg/build/buildcmd/cmd_sdk.go and pkg/release/sdk.go to use pkg/sdk - Remove all non-library content: main.go, internal/, cmd/, docker/, scripts/, tasks/, tools/, .core/, .forgejo/, .woodpecker/, Taskfile.yml - Run go mod tidy to trim unused dependencies core/go is now a pure Go package suite (library only). Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> Co-authored-by: Claude <developers@lethean.io> Reviewed-on: #3
104 lines
2.3 KiB
Go
104 lines
2.3 KiB
Go
package cache_test
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"forge.lthn.ai/core/go/pkg/cache"
|
|
"forge.lthn.ai/core/go/pkg/io"
|
|
)
|
|
|
|
func TestCache(t *testing.T) {
|
|
m := io.NewMockMedium()
|
|
// Use a path that MockMedium will understand
|
|
baseDir := "/tmp/cache"
|
|
c, err := cache.New(m, baseDir, 1*time.Minute)
|
|
if err != nil {
|
|
t.Fatalf("failed to create cache: %v", err)
|
|
}
|
|
|
|
key := "test-key"
|
|
data := map[string]string{"foo": "bar"}
|
|
|
|
// Test Set
|
|
if err := c.Set(key, data); err != nil {
|
|
t.Errorf("Set failed: %v", err)
|
|
}
|
|
|
|
// Test Get
|
|
var retrieved map[string]string
|
|
found, err := c.Get(key, &retrieved)
|
|
if err != nil {
|
|
t.Errorf("Get failed: %v", err)
|
|
}
|
|
if !found {
|
|
t.Error("expected to find cached item")
|
|
}
|
|
if retrieved["foo"] != "bar" {
|
|
t.Errorf("expected foo=bar, got %v", retrieved["foo"])
|
|
}
|
|
|
|
// Test Age
|
|
age := c.Age(key)
|
|
if age < 0 {
|
|
t.Error("expected age >= 0")
|
|
}
|
|
|
|
// Test Delete
|
|
if err := c.Delete(key); err != nil {
|
|
t.Errorf("Delete failed: %v", err)
|
|
}
|
|
found, err = c.Get(key, &retrieved)
|
|
if err != nil {
|
|
t.Errorf("Get after delete returned an unexpected error: %v", err)
|
|
}
|
|
if found {
|
|
t.Error("expected item to be deleted")
|
|
}
|
|
|
|
// Test Expiry
|
|
cshort, err := cache.New(m, "/tmp/cache-short", 10*time.Millisecond)
|
|
if err != nil {
|
|
t.Fatalf("failed to create short-lived cache: %v", err)
|
|
}
|
|
if err := cshort.Set(key, data); err != nil {
|
|
t.Fatalf("Set for expiry test failed: %v", err)
|
|
}
|
|
time.Sleep(50 * time.Millisecond)
|
|
found, err = cshort.Get(key, &retrieved)
|
|
if err != nil {
|
|
t.Errorf("Get for expired item returned an unexpected error: %v", err)
|
|
}
|
|
if found {
|
|
t.Error("expected item to be expired")
|
|
}
|
|
|
|
// Test Clear
|
|
if err := c.Set("key1", data); err != nil {
|
|
t.Fatalf("Set for clear test failed for key1: %v", err)
|
|
}
|
|
if err := c.Set("key2", data); err != nil {
|
|
t.Fatalf("Set for clear test failed for key2: %v", err)
|
|
}
|
|
if err := c.Clear(); err != nil {
|
|
t.Errorf("Clear failed: %v", err)
|
|
}
|
|
found, err = c.Get("key1", &retrieved)
|
|
if err != nil {
|
|
t.Errorf("Get after clear returned an unexpected error: %v", err)
|
|
}
|
|
if found {
|
|
t.Error("expected key1 to be cleared")
|
|
}
|
|
}
|
|
|
|
func TestCacheDefaults(t *testing.T) {
|
|
// Test default Medium (io.Local) and default TTL
|
|
c, err := cache.New(nil, "", 0)
|
|
if err != nil {
|
|
t.Fatalf("failed to create cache with defaults: %v", err)
|
|
}
|
|
if c == nil {
|
|
t.Fatal("expected cache instance")
|
|
}
|
|
}
|