package webx

import (
	"gitee.com/xungen/goweb/utils"
	"github.com/go-redis/redis"
	"sync"
)

var redismap sync.Map

func GetRedis(ctx *Context, name ...interface{}) (*redis.Client, error) {
	var key = utils.Sprint(name...)
	if conn, ok := redismap.Load(key); ok {
		return conn.(*redis.Client), nil
	}

	var open = func(cfg *RedisConfig) (*redis.Client, error) {
		conn := redis.NewClient(&redis.Options{
			Addr:     cfg.String(),
			Password: cfg.Password,
		})
		redismap.Store(key, conn)
		return conn, nil
	}

	if key == "" {
		if cfg := &GetConfig().Redis; cfg.Host == "" {
			return nil, utils.NOTFOUND.Copy("redis config missing")
		} else {
			return open(cfg)
		}
	} else if node := confignode.Child("redis." + key); node != nil {
		cfg := &RedisConfig{}
		node.Object(cfg, true)
		return open(cfg)
	} else {
		return nil, utils.NOTFOUND.Copy("redis config missing")
	}
}