fix(redis): umarshal err override

decorator.go

@@ -260,7 +260,10 @@ checkCache:
 
 	// 3.1 check if marshal needed
 	if hasCache && c.cacheMap.NeedMarshal() {
-		err = json.Unmarshal(value.([]byte), &retv)
+		err2 := json.Unmarshal(value.([]byte), &retv)
+		if err == nil {
+			err = err2
+		}
 		return retv, err
 	}
 

examples/decorator-redis-err_test.go

@@ -0,0 +1,56 @@
+package examples
+
+import (
+	"errors"
+	"testing"
+	"time"
+
+	"github.com/ahuigo/gofnext"
+)
+
+func TestRedisCacheClientPanic(t *testing.T) {
+	defer func() {
+		r := recover() //r.(string)
+		if r==nil{
+			t.Error("should panic")
+		}
+	}()
+	gofnext.NewCacheRedis("")
+
+}
+
+func TestRedisCacheFuncErr(t *testing.T) {
+	// Original function
+	executeCount := 0
+	getUserScore := func(more int) (int, error) {
+		executeCount++
+		return 98 + more, errors.New("db error")
+	}
+
+	// Cacheable Function
+	getUserScoreFromDbWithCache := gofnext.CacheFn1Err(getUserScore, &gofnext.Config{
+		TTL:      500*time.Second,
+		CacheMap: gofnext.NewCacheRedis("redis-cache-key").ClearAll(),
+	})
+
+	// Parallel invocation of multiple functions.
+	for i := 0; i < 10; i++ {
+		score, err := getUserScoreFromDbWithCache(1)
+		if err == nil {
+			t.Errorf("should be error, but get nil")
+		}
+		if score != 99 {
+			t.Errorf("score should be 99, but get %d", score)
+		}
+		score, _ = getUserScoreFromDbWithCache(2)
+		if score != 100 {
+			t.Fatalf("score should be 100, but get %d", score)
+		}
+		getUserScoreFromDbWithCache(3)
+		getUserScoreFromDbWithCache(3)
+	}
+
+	if executeCount != 3 {
+		t.Errorf("executeCount should be 1, but get %d", executeCount)
+	}
+}

examples/decorator-redis_test.go

@@ -24,6 +24,7 @@ func TestRedisCacheClient(t *testing.T) {
 	cache.SetRedisUniversalOpts(&redis.UniversalOptions{
 		Addrs: []string{"localhost:6379"},
 	})
+	cache.SetMaxHashKeyLen(0)
 	cache.SetMaxHashKeyLen(100)
 }
 

version

@@ -1 +1 @@
-v0.0.14
+v0.0.15