feat: add offer, user session expires at

Author: yrnThiago

.env.example

@@ -7,8 +7,10 @@ DB_NAME="name"
 
 # API
 PORT=3333
-COOKIE_NAME="Authorization"
+GO_ENV="local"
 SECRET_KEY="SecretKey"
+COOKIE_NAME="Authorization"
+COOKIE_EXPIRES_AT="1h"
 SKIP_AUTH=false
 
 # NATS
@@ -20,4 +22,5 @@ RDB_PASSWORD=""
 RDB_DB=0
 RATE_LIMIT=10
 RATE_LIMIT_WINDOW="1m"
-
+USER_SESSION_EXPIRES_AT="1h"
+OFFER_EXPIRES_AT="1h"

config/env.go

@@ -10,23 +10,25 @@ import (
 )
 
 type EnvVariables struct {
-	DBUsername      string
-	DBPassword      string
-	DBHost          string
-	DBPort          string
-	DBName          string
-	Port            string
-	GoEnv           GoEnv
-	SecretKey       string
-	SkipAuth        bool
-	CookieName      string
-	CookieExpiresAt time.Duration
-	NatsURL         string
-	RdbAddress      string
-	RdbPassword     string
-	RdbDB           int
-	RateLimit       int
-	RateLimitWindow time.Duration
+	DBUsername           string
+	DBPassword           string
+	DBHost               string
+	DBPort               string
+	DBName               string
+	Port                 string
+	GoEnv                GoEnv
+	SecretKey            string
+	SkipAuth             bool
+	CookieName           string
+	CookieExpiresAt      time.Duration
+	NatsURL              string
+	RdbAddress           string
+	RdbPassword          string
+	RdbDB                int
+	RateLimit            int
+	RateLimitWindow      time.Duration
+	UserSessionExpiresAt time.Duration
+	OfferExpiresAt       time.Duration
 }
 
 var Env EnvVariables
@@ -42,24 +44,28 @@ func Init() {
 	rateLimit, _ := strconv.Atoi(os.Getenv("RATE_LIMIT"))
 	rateLimitWindow, _ := time.ParseDuration(os.Getenv("RATE_LIMIT_WINDOW"))
 	cookieExpiresAt, _ := time.ParseDuration(os.Getenv("COOKIE_EXPIRES_AT"))
+	userSessionExpiresAt, _ := time.ParseDuration(os.Getenv("USER_SESSION_EXPIRES_AT"))
+	offerExpiresAt, _ := time.ParseDuration(os.Getenv("OFFER_EXPIRES_AT"))
 
 	Env = EnvVariables{
-		DBUsername:      os.Getenv("DB_USERNAME"),
-		DBPassword:      os.Getenv("DB_PASSWORD"),
-		DBHost:          os.Getenv("DB_HOST"),
-		DBPort:          os.Getenv("DB_PORT"),
-		DBName:          os.Getenv("DB_NAME"),
-		Port:            os.Getenv("PORT"),
-		GoEnv:           GoEnv(os.Getenv("GO_ENV")),
-		SecretKey:       os.Getenv("SECRET_KEY"),
-		SkipAuth:        skipAuth,
-		CookieName:      os.Getenv("COOKIE_NAME"),
-		CookieExpiresAt: cookieExpiresAt,
-		NatsURL:         os.Getenv("NATS_URL"),
-		RdbAddress:      os.Getenv("RDB_ADDRESS"),
-		RdbPassword:     os.Getenv("RDB_PASSWORD"),
-		RdbDB:           rdbDb,
-		RateLimit:       rateLimit,
-		RateLimitWindow: rateLimitWindow,
+		DBUsername:           os.Getenv("DB_USERNAME"),
+		DBPassword:           os.Getenv("DB_PASSWORD"),
+		DBHost:               os.Getenv("DB_HOST"),
+		DBPort:               os.Getenv("DB_PORT"),
+		DBName:               os.Getenv("DB_NAME"),
+		Port:                 os.Getenv("PORT"),
+		GoEnv:                GoEnv(os.Getenv("GO_ENV")),
+		SecretKey:            os.Getenv("SECRET_KEY"),
+		SkipAuth:             skipAuth,
+		CookieName:           os.Getenv("COOKIE_NAME"),
+		CookieExpiresAt:      cookieExpiresAt,
+		NatsURL:              os.Getenv("NATS_URL"),
+		RdbAddress:           os.Getenv("RDB_ADDRESS"),
+		RdbPassword:          os.Getenv("RDB_PASSWORD"),
+		RdbDB:                rdbDb,
+		RateLimit:            rateLimit,
+		RateLimitWindow:      rateLimitWindow,
+		UserSessionExpiresAt: userSessionExpiresAt,
+		OfferExpiresAt:       offerExpiresAt,
 	}
 }

internal/infra/nats/consumer.go

@@ -145,7 +145,7 @@ func (o *OffersConsumer) HandlingAccptedOffers() {
 		offer.Product.SetOfferPrice(offer.Price)
 		offerProductJson, _ := json.Marshal(offer.Product)
 
-		go redis.Redis.Set(context.Background(), "offer-"+offer.Buyer.ID+"-"+offer.Product.ID, string(offerProductJson), 0)
+		go redis.Redis.Set(context.Background(), "offer-"+offer.Buyer.ID+"-"+offer.Product.ID, string(offerProductJson), config.Env.OfferExpiresAt)
 
 		config.Logger.Info(
 			"order status updated to accepted",

internal/usecase/auth/auth.go

@@ -59,7 +59,7 @@ func (a *AuthUseCase) Login(input AuthInputDto) (string, *entity.User, error) {
 		return "", nil, err
 	}
 
-	infra.Redis.Set(context.Background(), "user-"+output.ID, string(userJson), 0)
+	infra.Redis.Set(context.Background(), "user-"+output.ID, string(userJson), config.Env.UserSessionExpiresAt)
 	return token, output, nil
 }