Refactor Redis repository and add environment variable utility functions

Author: Programmer-RD-AI

docker-compose.yml

@@ -0,0 +1,13 @@
+package errors
+
+import "fmt"
+
+type dbHealthCheckFail struct {
+	message  string
+	provider string
+}
+
+func (e *dbHealthCheckFail) Error() string {
+	return fmt.Sprintf("[%s] %s", e.provider, e.message);
+}
+

helper.go

@@ -0,0 +1,26 @@
+package util
+
+import (
+	"os"
+	"strconv"
+)
+
+func GetEnv[T string | int](key string, defaultVal T) (T, error) {
+	rawEnv, ok := os.LookupEnv(key)
+	if !ok {
+		return defaultVal, nil
+	}
+	var ret any
+	switch any(defaultVal).(type) {
+	case string:
+		ret = rawEnv
+	case int:
+		intVal, err := strconv.Atoi(rawEnv)
+		if err != nil {
+			return defaultVal, err
+		}
+		ret = intVal
+
+	}
+	return ret.(T), nil
+}

internal/errors.go

@@ -1,29 +1,71 @@
 package repository
 
-import "github.com/go-redis/redis/v9"
+import (
+	"context"
+	"fmt"
+	"github.com/Programmer-RD-AI/auth-forge/internal/errors"
+	"github.com/Programmer-RD-AI/auth-forge/pkg/util"
+	"github.com/redis/go-redis/v9"
+)
 
 type RedisConfiguration struct {
-	Host     string 
+	Host     string
 	Port     int
 	Password string
 	Database int
 }
 
 type RedisRepository struct {
+	BaseRepository	
 	config RedisConfiguration
 	client *redis.Client
 }
 
-func CreateRedisConfiguration(host *string, port *int, password *string, database *int){}
+func CreateRedisConfiguration(host *string, port *int, password *string, database *int) RedisConfiguration {
+	if host == nil {
+		h, _ := util.GetEnv[string]("REDIS_HOST", "localhost")
+		host = &h
+	}
+	if port == nil {
+		p, _ := util.GetEnv[int]("REDIS_PORT", 6379)
+		port = &p
+	}
+	if password == nil {
+		pass, _ := util.GetEnv[string]("REDIS_PASSWORD", "")
+		password = &pass
+	}
+	if database == nil {
+		db, _ := util.GetEnv[int]("REDIS_DATABASE", 0)
+		database = &db
+	}
+	return RedisConfiguration{
+		Host:     *host,
+		Port:     *port,
+		Password: *password,
+		Database: *database,
+	}
+}
+
+func (r *RedisRepository) Connect() (*redis.Client, context.Context) {
+	redisClient := redis.NewClient(createRedisOption(&r.config))
+	initCtx := context.Background()
+	return redisClient, initCtx
+}
 
-func (r *RedisReppository) Connect(){
-	return redis.NewClient(createRedisOption(r.config));
+func (r *RedisRepository) HealthCheck(ctx context.Context, client *redis.Client) (bool, error) {
+	if err := client.Ping(ctx).Err(); err != nil {
+		return false, errors.dbHealthCheckFail{message: err.Error(), provider: r.BaseRepository.providerName}
+	}	
+	return true, nil
 }
 
+func (r *RedisRepository) Read(client *redis.Client, ctx context.Context, key *string){
+	val, err := client.Get(ctx, *key).Result()
+}
 func createRedisOption(redisConfig *RedisConfiguration) *redis.Options {
 	return &redis.Options{
-		Addr: fmt.Sprintf("%s:%d", redisConfig.Host, redisConfig.Port)
-		Password: redisConfig.Password
-		DB: redisConfig.Database
+		Addr:     fmt.Sprintf("%s:%d", redisConfig.Host, redisConfig.Port),
+		Password: redisConfig.Password,
+		DB:       redisConfig.Database,
 	}
 }

pkg/util/helper.go

@@ -7,5 +7,9 @@ type Repository interface {
 	Update(id string, data any) (any, error)
 	Delete(id string) error
 	Close() error
+	HealthCheck() (bool, error)
 }
 
+type BaseRepository struct {
+	providerName string
+}