package redis3

import (
	"crypto/tls"

	"github.com/go-redsync/redsync/v4"
	"github.com/go-redsync/redsync/v4/redis/goredis/v9"
	"github.com/redis/go-redis/v9"
	"github.com/seaweedfs/seaweedfs/weed/filer"
	"github.com/seaweedfs/seaweedfs/weed/filer/redis_conf"
	"github.com/seaweedfs/seaweedfs/weed/filer/redis_tls"
	"github.com/seaweedfs/seaweedfs/weed/util"
)

func init() {
	filer.Stores = append(filer.Stores, &Redis3SentinelStore{})
}

type Redis3SentinelStore struct {
	UniversalRedis3Store
}

func (store *Redis3SentinelStore) GetName() string {
	return "redis3_sentinel"
}

func (store *Redis3SentinelStore) Initialize(configuration util.Configuration, prefix string) (err error) {
	tlsConfig, err := redis_tls.Config(configuration, prefix)
	if err != nil {
		return err
	}
	return store.initialize(
		configuration.GetStringSlice(prefix+"addresses"),
		configuration.GetString(prefix+"masterName"),
		configuration.GetString(prefix+"username"),
		configuration.GetString(prefix+"password"),
		configuration.GetString(prefix+"sentinel_username"),
		configuration.GetString(prefix+"sentinel_password"),
		configuration.GetInt(prefix+"database"),
		tlsConfig,
		redis_conf.Read(configuration, prefix),
	)
}

func (store *Redis3SentinelStore) initialize(addresses []string, masterName string, username string, password string, sentinelUsername string, sentinelPassword string, database int, tlsConfig *tls.Config, settings redis_conf.Settings) (err error) {
	options := &redis.FailoverOptions{
		MasterName:       masterName,
		SentinelAddrs:    addresses,
		Username:         username,
		Password:         password,
		SentinelUsername: sentinelUsername,
		SentinelPassword: sentinelPassword,
		DB:               database,
		TLSConfig:        tlsConfig,
	}
	settings.ApplyToFailover(options)
	store.Client = redis.NewFailoverClient(options)
	store.redsync = redsync.New(goredis.NewPool(store.Client))
	return
}