Refactor project to remove Redis support, implement MongoDB integration, and restructure session management; update configuration, repository, and service layers.

Programmer-RD-AI · Programmer-RD-AI · commit 8dd1b87c2f32 · 2025-07-20T00:32:44.000+05:30
diff --git a/.example.env b/.example.env
@@ -1,4 +1 @@
-REDIS_HOST=localhost
-REDIS_PORT=6379
-REDIS_PASSWORD=
-REDIS_DATABASE=0
+MONGODB_URI=mongodb://localhost:27017
diff --git a/README.md: b/README.md:
diff --git a/config/config_loader.go b/config/config_loader.go
@@ -15,8 +15,6 @@ func LoadConfig() *Config {
 	return config
 }
 
-
-
 func loadMongoConfig() MongoConfig {
 	uri, _ := GetEnv("MONGODB_URI", "mongodb://localhost:27017")
 	return MongoConfig{
diff --git a/go.mod b/go.mod
@@ -7,10 +7,12 @@ require github.com/joho/godotenv v1.5.1
 require (
 	github.com/golang/snappy v1.0.0 // indirect
 	github.com/klauspost/compress v1.16.7 // indirect
+	github.com/montanaflynn/stats v0.7.1 // indirect
 	github.com/xdg-go/pbkdf2 v1.0.0 // indirect
 	github.com/xdg-go/scram v1.1.2 // indirect
 	github.com/xdg-go/stringprep v1.0.4 // indirect
 	github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 // indirect
+	go.mongodb.org/mongo-driver v1.17.4 // indirect
 	go.mongodb.org/mongo-driver/v2 v2.2.2 // indirect
 	golang.org/x/crypto v0.33.0 // indirect
 	golang.org/x/sync v0.11.0 // indirect
diff --git a/go.sum b/go.sum
@@ -4,6 +4,8 @@ github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/klauspost/compress v1.16.7 h1:2mk3MPGNzKyxErAw8YaohYh69+pa4sIQSC0fPGCFR9I=
 github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE=
+github.com/montanaflynn/stats v0.7.1 h1:etflOAAHORrCC44V+aR6Ftzort912ZU+YLiSTuV8eaE=
+github.com/montanaflynn/stats v0.7.1/go.mod h1:etXPPgVO6n31NxCd9KQUMvCM+ve0ruNzt6R8Bnaayow=
 github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
 github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
 github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY=
@@ -13,6 +15,8 @@ github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gi
 github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 h1:ilQV1hzziu+LLM3zUTJ0trRztfwgjqKnBWNtSRkbmwM=
 github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78/go.mod h1:aL8wCCfTfSfmXjznFBSZNN13rSJjlIOI1fUNAtF7rmI=
 github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
+go.mongodb.org/mongo-driver v1.17.4 h1:jUorfmVzljjr0FLzYQsGP8cgN/qzzxlY9Vh0C9KFXVw=
+go.mongodb.org/mongo-driver v1.17.4/go.mod h1:Hy04i7O2kC4RS06ZrhPRqj/u4DTYkFDAAccj+rVKqgQ=
 go.mongodb.org/mongo-driver/v2 v2.2.2 h1:9cYuS3fl1Xhqwpfazso10V7BHQD58kCgtzhfAmJYz9c=
 go.mongodb.org/mongo-driver/v2 v2.2.2/go.mod h1:qQkDMhCGWl3FN509DfdPd4GRBLU/41zqF/k8eTRceps=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
diff --git a/internal/model/session.go b/internal/model/session.go
@@ -16,5 +16,3 @@ type SessionValue struct {
 	UserID   string
 	Metadata Metadata
 }
-
-
diff --git a/internal/repository/base_repository.go b/internal/repository/base_repository.go
@@ -0,0 +1,8 @@
+package store
+
+type BaseRepository interface {
+	Create()
+	Read()
+	Update()
+	Delete()
+}
diff --git a/internal/repository/mongodb_repository.go b/internal/repository/mongodb_repository.go
@@ -0,0 +1,38 @@
+package store
+
+import (
+	"context"
+
+	"github.com/Programmer-RD-AI/auth-forge/internal/util"
+	"go.mongodb.org/mongo-driver/mongo"
+)
+
+type MongoDBStore struct {
+	coll  *mongo.Collection
+	model any
+}
+
+func HealthCheck(ctx context.Context, client *mongo.Client) bool {
+	if err := client.Ping(ctx, nil); err != nil {
+		return false
+	}
+	return true
+}
+
+func GetCollection(databaseName string, collectionName string, client *mongo.Client) *mongo.Collection {
+	return client.Database(databaseName).Collection(collectionName)
+}
+
+func (m *MongoDBStore) Create(ctx context.Context) (interface{}, error) {
+	res, err := m.coll.InsertOne(ctx, m.model)
+	if err != nil {
+		return nil, err
+	}
+	return res.InsertedID, nil
+}
+
+func (m *MongoDBStore) Read(ctx context.Context, searchQuery map[string]string, readAll *bool) ([]any, error) {
+	var final_res []any
+	filter := util.ConvertToBSON(searchQuery)
+	
+}
diff --git a/internal/session/repository.go b/internal/session/repository.go
@@ -2,12 +2,8 @@ package session
 
 import "github.com/Programmer-RD-AI/auth-forge/internal/model"
 
-type SessionRepository struct {
-	store model.BaseStore
-}
-
-func NewSessionRepository(store model.BaseStore) SessionRepository {
-	return SessionRepository{
-		store: nil,
-	}
+type SessionRepository interface {
+	GetByUserId() *model.Session
+	GetBySessionId() *model.SessionValue
+	DeleteSessionId() bool
 }
diff --git a/internal/session/service.go b/internal/session/service.go
@@ -1,17 +1,5 @@
 package session
 
-
 type SessionService struct {
-	sessionRepository *SessionRepository
-}
-
-func NewSessionService(repo *SessionRepository) SessionService{
-	return SessionService{
-		sessionRepository: repo,
-	}
-}
-
-
-func (s *SessionService) CreateSession(){
-	
+	sessionRepository SessionRepository
 }
diff --git a/internal/store/base_store.go b/internal/store/base_store.go
diff --git a/internal/store/mongodb.go b/internal/store/mongodb.go
diff --git a/internal/util/bson.go b/internal/util/bson.go
@@ -0,0 +1,13 @@
+package util
+
+import (
+	"go.mongodb.org/mongo-driver/bson"
+)
+
+func ConvertToBSON(search map[string]string) bson.D {
+	filter := bson.D{}
+	for k, v := range search {
+		filter = append(filter, bson.E{Key: k, Value: v})
+	}
+	return filter
+}
diff --git a/internal/util/helper.go b/internal/util/helper.go
diff --git a/pkg/authforge/session.go b/pkg/authforge/session.go
@@ -6,4 +6,4 @@ func CreateOrExpireToken(userId string) string {
 
 func SessionValidation(sessionId string) bool { return true }
 
-func RevokeSession() (bool, error) { return true, nil }
+func RevokeSession(sessionId string) (bool, error) { return true, nil }
diff --git a/pkg/authforge/setup.go b/pkg/authforge/setup.go
@@ -0,0 +1,18 @@
+package authforge
+
+import (
+	"context"
+
+	"github.com/Programmer-RD-AI/auth-forge/config"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+func SetupMongoDB(ctx context.Context, config *config.MongoConfig) (*mongo.Client, error){
+client, err := mongo.Connect(ctx, options.Client().
+		ApplyURI(config.Uri))
+		if err != nil {
+			return nil, err
+		}
+		return client, nil
+}

Original file line number	Diff line number	Diff line change
`@@ -15,8 +15,6 @@ func LoadConfig() *Config {`
`15`	`15`	`return config`
`16`	`16`	`}`
`17`	`17`
`18`		`-`
`19`		`-`
`20`	`18`	`func loadMongoConfig() MongoConfig {`
`21`	`19`	`uri, _ := GetEnv("MONGODB_URI", "mongodb://localhost:27017")`
`22`	`20`	`return MongoConfig{`
Original file line number	Diff line number	Diff line change
`@@ -16,5 +16,3 @@ type SessionValue struct {`
`16`	`16`	`UserID string`
`17`	`17`	`Metadata Metadata`
`18`	`18`	`}`
`19`		`-`
`20`		`-`