Merge pull request #3 from Programmer-RD-AI/feat/register-user

Programmer-RD-AI · web-flow · commit 4af84476a75a · 2025-07-12T23:22:05.000+05:30
Add initial project structure with Redis repository implementation an…
diff --git a/.example.env b/.example.env
@@ -0,0 +1,4 @@
+REDIS_HOST=localhost
+REDIS_PORT=6379
+REDIS_PASSWORD=
+REDIS_DATABASE=0
diff --git a/LICENSE b/LICENSE
diff --git a/Makefile b/Makefile
@@ -1,8 +1,12 @@
-name := auth-forge
-version := 0.1.0
-
-sync:
-	go mod tidy
-
-run:
-	go run ./cmd/main.go
+name := auth-forge
+version := 0.1.0
+
+sync:
+	go mod tidy
+
+run:
+	start-redis
+	go run ./cmd/main.go
+
+start-redis:
+	docker compose up -d
diff --git a/README.md b/README.md
@@ -1,3 +1,3 @@
-# auth-forge
-
-A self-hosted, provider-agnostic authentication library offering email/password and anonymous login flows, JWT issuance &amp; rotation, session management, and role-based access control (RBAC). 
+# auth-forge
+
+A self-hosted, authentication library offering email/password and anonymous login flows, JWT issuance &amp; rotation, session management, and role-based access control (RBAC).
diff --git a/cmd/main.go b/cmd/main.go
@@ -1,3 +1,10 @@
-package main
-
-func main() {}
+package main
+
+import (
+	configLoader "github.com/Programmer-RD-AI/auth-forge/config_loader"
+)
+
+func main() {
+	config := configLoader.LoadConfig()
+
+}
diff --git a/config/config.go b/config/config.go
@@ -0,0 +1,12 @@
+package config
+
+type RedisConfig struct {
+	Host string
+	Port int
+	Password string
+	Database int
+}
+
+type Config struct {
+	RedisConfig	
+}
diff --git a/config/config_loader.go b/config/config_loader.go
@@ -0,0 +1,56 @@
+package config
+
+import (
+	"os"
+	"strconv"
+	"sync"
+
+	"github.com/joho/godotenv"
+)
+
+var (
+	config *Config
+	once   sync.Once
+)
+
+func LoadConfig() *Config {
+	once.Do(func() {
+		godotenv.Load()
+		config = &Config{
+			RedisConfig: loadRedisConfig(),
+		}
+	})
+	return config
+}
+
+func loadRedisConfig() RedisConfig {
+	h, _ := GetEnv("REDIS_HOST", "localhost")
+	p, _ := GetEnv("REDIS_PORT", 6379)
+	pass, _ := GetEnv("REDIS_PASSWORD", "")
+	db, _ := GetEnv("REDIS_DATABASE", 0)
+	return RedisConfig{
+		Host:     h,
+		Port:     p,
+		Password: pass,
+		Database: db,
+	}
+}
+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
+}
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -0,0 +1,13 @@
+version: "3.8"
+
+services:
+  redis:
+    image: redis:6-alphine
+    container_name: auth-redis
+    ports:
+      - "6379:6379"
+    volumes:
+      - redis-data:/data
+
+volumes:
+  redis-data: {}
diff --git a/go.mod b/go.mod
@@ -1,3 +1,10 @@
 module github.com/Programmer-RD-AI/auth-forge
 
 go 1.24.4
+
+require (
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	github.com/joho/godotenv v1.5.1 // indirect
+	github.com/redis/go-redis/v9 v9.11.0 // indirect
+)
diff --git a/go.sum b/go.sum
@@ -0,0 +1,8 @@
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
+github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
+github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
+github.com/redis/go-redis/v9 v9.11.0 h1:E3S08Gl/nJNn5vkxd2i78wZxWAPNZgUNTp8WIJUAiIs=
+github.com/redis/go-redis/v9 v9.11.0/go.mod h1:huWgSWd8mW6+m0VPhJjSSQ+d6Nh1VICQ6Q5lHuCH/Iw=
diff --git a/internal/repository/redis.go b/internal/repository/redis.go
@@ -0,0 +1,89 @@
+package repository
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/Programmer-RD-AI/auth-forge/config"
+	errors "github.com/Programmer-RD-AI/auth-forge/pkg/authforge/"
+	"github.com/redis/go-redis/v9"
+)
+
+type RedisRepository struct {
+	name   string
+	config config.RedisConfig
+	client *redis.Client
+	ctx    context.Context
+}
+
+func NewRedisRepository(config config.RedisConfig) *RedisRepository {
+	return &RedisRepository{
+		name:   "Redis",
+		config: config,
+		client: nil,
+		ctx:    nil,
+	}
+}
+
+func (r *RedisRepository) Connect() {
+	redisClient := redis.NewClient(createRedisOption(&r.config))
+	initCtx := context.Background()
+	r.client = redisClient
+	r.ctx = initCtx
+}
+
+func (r *RedisRepository) HealthCheck() (bool, error) {
+	if err := r.client.Ping(r.ctx).Err(); err != nil {
+		return false, errors.NewDbHealthCheckFail(r.name, fmt.Sprintf("Failed to connect to Redis: %v", err))
+	}
+	return true, nil
+}
+
+func (r *RedisRepository) Read(key string) (string, error) {
+	val, err := r.client.Get(r.ctx, key).Result()
+	if err == redis.Nil {
+		return "", &errors.KeyDoesNotExistError{key: key}
+	} else if err != nil {
+		return "", err
+	} else {
+		return val, nil
+	}
+}
+
+func (r *RedisRepository) Close() bool {
+	if err := r.client.Close(); err != nil {
+		return false
+	}
+	return true
+}
+
+func (r *RedisRepository) Create(key string, value string) bool {
+	if err := r.client.Set(r.ctx, key, &value, 0).Err(); err != nil {
+		fmt.Println("Error creating key:", err)
+		return true
+	}
+	return false
+}
+
+func (r *RedisRepository) Delete(key string) (int64, error) {
+	deleted, err := r.client.Del(r.ctx, key).Result()
+	if err != nil {
+		return 0, err
+	}
+	return deleted, nil
+}
+
+func (r *RedisRepository) Update(key string, value *any) bool {
+	if err := r.client.Set(r.ctx, key, value, 0).Err(); err != nil {
+		return false
+	}
+	return true
+}
+
+func createRedisOption(redisConfig *config.RedisConfig) *redis.Options {
+	return &redis.Options{
+		Addr:     fmt.Sprintf("%s:%d", redisConfig.Host, redisConfig.Port),
+		Password: redisConfig.Password,
+		DB:       redisConfig.Database,
+	}
+}
diff --git a/internal/util/helper.go b/internal/util/helper.go
@@ -0,0 +1,31 @@
+package util
+
+import (
+	"encoding/json"
+	"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
+}
+
+func MarshalBinary[T any](data T) ([]byte, error){
+	return json.Marshal(data)
+}
diff --git a/pkg/authforge/errors.go b/pkg/authforge/errors.go
@@ -0,0 +1,23 @@
+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)
+}
+func NewDbHealthCheckFail(provider, message string) error {
+	return &DbHealthCheckFail{provider: provider, message: message}
+}
+
+type KeyDoesNotExistError struct {
+	key string
+}
+
+func (k *KeyDoesNotExistError) Error() string {
+	return fmt.Sprintf("Key '%s' already exists in Redis", k.key)
+}
