package redisx

import (
	"allapp/conf"
	"context"
	"fmt"
	"sync"
	"time"

	"github.com/redis/go-redis/v9"
)

var (
	client *redis.Client
	once   sync.Once
)

// Init 初始化 Redis（只会执行一次）
func Init() *redis.Client {
	once.Do(func() {
		redisConfig := conf.GetConf().Redis

		addr := fmt.Sprintf("%s:%d", redisConfig.Host, redisConfig.Port)

		client = redis.NewClient(&redis.Options{
			Addr:     addr,
			Password: redisConfig.Password,
			DB:       redisConfig.Db,
		})

		// 启动时检测连接
		ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
		defer cancel()

		if err := client.Ping(ctx).Err(); err != nil {
			panic("redis 连接失败: " + err.Error())
		}
	})

	return client
}

// Client 获取 Redis 客户端
func Client() *redis.Client {
	if client == nil {
		panic("redis 尚未初始化")
	}
	return client
}