Teste de Felipe Coimbra

.dockerignore

@@ -0,0 +1 @@
+volumes/

.env.example

@@ -0,0 +1,15 @@
+# Postgres configuration
+POSTGRES_HOST=gss-postgres-db
+POSTGRES_PORT=5432
+POSTGRES_USER=root
+POSTGRES_PASSWORD=root
+POSTGRES_DB=gss-db
+
+# Fiber configuration
+FIBER_PORT=3000
+
+# SMTP configuration
+SMTP_HOST=smtp.gmail.com
+SMTP_PORT=587
+SMTP_EMAIL=
+SMTP_PASSWORD=

.gitignore

@@ -0,0 +1,3 @@
+.env
+.env.production
+volumes/

Dockerfile

@@ -0,0 +1,23 @@
+# Setting up my base image
+FROM golang:1.24.1-alpine
+
+# Set the Current Working Directory inside the container
+WORKDIR /app
+
+# Copy go mod and sum files
+COPY go.mod go.sum ./
+
+# Get all dependencies
+RUN go mod download
+
+# Copy source code
+COPY . .
+
+# Build the Go app
+RUN go build -o gss-backend ./cmd
+
+# Expose port 3001
+EXPOSE 3001
+
+# Run the application
+CMD ["./gss-backend"]

api/dtos/user_dto.go

@@ -0,0 +1,8 @@
+package dtos
+
+type CreateUserDTO struct {
+	FullName string `json:"full_name"`
+	Email string `json:"email"`
+	PhoneNumber string `json:"phone_number"`
+	ReferrerCode string `json:"referrer_code"`
+}

api/handlers/user.go

@@ -0,0 +1,76 @@
+package handlers
+
+import (
+	"errors"
+	"gss-backend/api/dtos"
+	"gss-backend/api/presenters"
+	services "gss-backend/pkg/services/user"
+	"strconv"
+
+	"github.com/gofiber/fiber/v2"
+)
+
+func CreateUser(user_service services.IUserService) fiber.Handler {
+	return func(c *fiber.Ctx) error {
+		var requestBody dtos.CreateUserDTO
+
+		err := c.BodyParser(&requestBody)
+
+		if err != nil {
+			c.Status(fiber.StatusBadRequest)
+			return c.JSON(presenters.UserErrorResponse(err))
+		}
+
+		if requestBody.FullName == "" || requestBody.Email == "" || requestBody.PhoneNumber == "" {
+			c.Status(fiber.StatusBadRequest)
+			return c.JSON(presenters.UserErrorResponse(errors.New(
+				"Full Name, Email, and Phone Number are required",
+			)))
+		}
+
+		result, err := user_service.Create(&requestBody)
+
+		if err != nil {
+			c.Status(fiber.StatusInternalServerError)
+			return c.JSON(presenters.UserErrorResponse(err))
+		}
+
+		return c.JSON(presenters.UserSuccessResponse(result))
+
+	}
+}
+
+func FindAllUsers(user_service services.IUserService) fiber.Handler {
+	return func(c *fiber.Ctx) error {
+		result, err := user_service.FindAll()
+
+		if err != nil {
+			c.Status(fiber.StatusInternalServerError)
+			return c.JSON(presenters.UserErrorResponse(err))
+		}
+
+		return c.JSON(presenters.UsersSuccessResponse(result))
+	}
+}
+
+func FindUserByID(user_service services.IUserService) fiber.Handler {
+	return func(c *fiber.Ctx) error {
+		idStr := c.Params("id")
+
+		id, err := strconv.ParseUint(idStr, 10, 32)
+
+		if err != nil {
+			c.Status(fiber.StatusBadRequest)
+			return c.JSON(presenters.UserErrorResponse(err))
+		}
+
+		result, err := user_service.FindByID(uint(id))
+
+		if err != nil {
+			c.Status(fiber.StatusInternalServerError)
+			return c.JSON(presenters.UserErrorResponse(err))
+		}
+
+		return c.JSON(presenters.UserSuccessResponse(result))
+	}
+}

api/handlers/user_referral.go

@@ -0,0 +1,23 @@
+package handlers
+
+import (
+	"gss-backend/api/presenters"
+	services "gss-backend/pkg/services/user_referral"
+
+	"github.com/gofiber/fiber/v2"
+)
+
+
+func FindLeaderboardScores(userReferralService services.IUserReferralService) fiber.Handler {
+	return func(c *fiber.Ctx) error {
+		result, err := userReferralService.FindLeaderboardScores()
+
+		if err != nil {
+			c.Status(fiber.StatusInternalServerError)
+			return c.JSON(presenters.UserReferralErrorResponse(err))
+		}
+
+		return c.JSON(presenters.LeaderboardScoreSuceessResponse(result))
+	}
+}
+

api/presenters/user.go

@@ -0,0 +1,57 @@
+package presenters
+
+import (
+	"gss-backend/pkg/models"
+
+	"github.com/gofiber/fiber/v2"
+)
+
+// UserPresenter is a struct that is going to be used to present the user data in a controlled way
+// As a minor "business logic", I opted to not return the phone number and the email of the user
+type UserPresenter struct {
+	ID	   uint   `json:"id"`
+	FullName   string `json:"full_name"`
+	ReferralCode string `json:"referral_code"`
+}
+
+// Functions to transform the user 'raw' data to presenters
+func UserSuccessResponse(data *models.User) *fiber.Map {
+	user := UserPresenter{
+		ID:        data.ID,
+		FullName:  data.FullName,
+		ReferralCode: data.ReferralCode,
+
+	}
+
+	return &fiber.Map{
+		"status": "success",
+		"data":   user,
+		"error":  nil,
+	}
+}
+
+func UsersSuccessResponse(data *[]models.User) *fiber.Map {
+	var users []UserPresenter
+
+	for _, user := range *data {
+		users = append(users, UserPresenter{
+			ID:        user.ID,
+			FullName:  user.FullName,
+			ReferralCode: user.ReferralCode,
+		})
+	}
+
+	return &fiber.Map{
+		"status": "success",
+		"data":   users,
+		"error":  nil,
+	}
+}
+
+func UserErrorResponse(err error) *fiber.Map {
+	return &fiber.Map{
+		"status": "error",
+		"data":   nil,
+		"error":  err.Error(),
+	}
+}

api/presenters/user_referral.go

@@ -0,0 +1,43 @@
+package presenters
+
+import (
+	repo "gss-backend/pkg/repositories/user_referral"
+
+	"github.com/gofiber/fiber/v2"
+)
+
+type PointsPresenter struct {
+	ID        uint   `json:"id"`
+	Points   uint   `json:"points"`
+}
+
+type LeaderboardScorePresenter struct {
+	ReferrerId uint   `json:"referrer_id"`
+	FullName   string `json:"full_name"`
+	ReferralsCount uint `json:"referrals_count"`
+}
+
+func LeaderboardScoreSuceessResponse(data *[]repo.LeaderboardScore) *fiber.Map {
+	var leaderboardScores []LeaderboardScorePresenter
+
+	for _, score := range *data {
+		leaderboardScores = append(leaderboardScores, LeaderboardScorePresenter{
+			ReferrerId: score.ReferrerId,
+			FullName:   score.FullName,
+			ReferralsCount: score.ReferralsCount,
+		})
+	}
+	return &fiber.Map{
+		"status": "success",
+		"data":   leaderboardScores,
+		"error":  nil,
+	}
+}
+
+func UserReferralErrorResponse(err error) *fiber.Map {
+	return &fiber.Map{
+		"status": "error",
+		"data":   nil,
+		"error":  err.Error(),
+	}
+}

api/routes/user.go

@@ -0,0 +1,15 @@
+package routes
+
+import (
+	"gss-backend/api/handlers"
+	services "gss-backend/pkg/services/user"
+
+	"github.com/gofiber/fiber/v2"
+)
+
+// UserRouter is a function created to define User related routes
+func UserRouter(app fiber.Router, user_service services.IUserService) {
+	app.Post("/users", handlers.CreateUser(user_service))
+	app.Get("/users", handlers.FindAllUsers(user_service))
+	app.Get("/users/:id", handlers.FindUserByID(user_service))
+}

api/routes/user_referral.go

@@ -0,0 +1,13 @@
+package routes
+
+import (
+	"gss-backend/api/handlers"
+	services "gss-backend/pkg/services/user_referral"
+
+	"github.com/gofiber/fiber/v2"
+)
+
+
+func UserReferralRouter(app fiber.Router, user_referral_service services.IUserReferralService) {
+	app.Get("/leaderboard", handlers.FindLeaderboardScores(user_referral_service))
+}

cmd/main.go

@@ -0,0 +1,91 @@
+package main
+
+import (
+	"fmt"
+	"gss-backend/api/routes"
+	"gss-backend/pkg/config"
+	"gss-backend/pkg/models"
+	emailService "gss-backend/pkg/services/email"
+	"log"
+
+	"github.com/gofiber/fiber/v2"
+	"github.com/gofiber/fiber/v2/middleware/cors"
+	"gorm.io/driver/postgres"
+	"gorm.io/gorm"
+)
+
+func main() {
+	// Loading configuration
+	log.Println("Loading configuration...")
+	config, err := config.NewConfig()
+
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	log.Println("Configuration loaded!")
+
+	// Setting up Postgres DSN
+	dsn := fmt.Sprintf((
+		"host=%s port=%d user=%s password=%s dbname=%s sslmode=disable TimeZone=UTC"),
+		config.POSTGRES_HOST,
+		config.POSTGRES_PORT,
+		config.POSTGRES_USER,
+		config.POSTGRES_PASSWORD,
+		config.POSTGRES_DB,
+	)
+
+	// Connecting to the database
+	log.Println("Connecting to the database...")
+
+	db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
+
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	log.Println("Connected to the database!")
+
+	// Setting up Migrations
+	log.Println("Running migrations...")
+
+	err = db.AutoMigrate(&models.User{}, &models.UserReferral{})
+
+	if err != nil {
+		log.Fatal("Error running migrations", err)
+	}
+
+	log.Println("Migrations complete!")
+
+	// Setting up Fiber
+	app := fiber.New()
+	app.Use(cors.New())
+
+	app.Get("/", func(c *fiber.Ctx) error {
+		return c.SendString("GSS Gateway API is up and running! 🚀")
+	})
+
+	// Instatiating Repositories
+	repoContainer := NewRepositoryContainer(db)
+
+
+	// Instatiating Services
+	emailConfig := emailService.EmailConfig{
+		SMTPHost: config.SMTP_HOST,
+		SMTPPort: config.SMTP_PORT,
+		SMTPEmail: config.SMTP_EMAIL,
+		SMTPPassword: config.SMTP_PASSWORD,
+	}
+	serviceContainer := NewServiceContainer(repoContainer, emailConfig)
+
+	// Setting up routes
+	api := app.Group("/api")
+	routes.UserRouter(api, serviceContainer.UserService)
+	routes.UserReferralRouter(api, serviceContainer.UserReferralService)
+
+	// Starting the server
+	port := fmt.Sprintf(":%s", config.FIBER_PORT) 
+	log.Fatal(app.Listen(port))
+
+
+}