Project structure created and Creating the necessary files

Author: soheilkhaledabdi

.gitignore

@@ -0,0 +1,26 @@
+# If you prefer the allow list template instead of the deny list, see community template:
+# https://github.com/github/gitignore/blob/main/community/Golang/Go.AllowList.gitignore
+#
+# Binaries for programs and plugins
+*.exe
+*.exe~
+*.dll
+*.so
+*.dylib
+
+# Test binary, built with `go test -c`
+*.test
+
+# Output of the go coverage tool, specifically when used with LiteIDE
+*.out
+
+# Dependency directories (remove the comment below to include it)
+# vendor/
+
+# Go workspace file
+go.work
+*.DS_store
+*.log
+*.log.gz
+__debug_bin
+*/cmd/uploads

api/api.go

@@ -0,0 +1,21 @@
+package api
+
+import (
+	"fmt"
+
+	"github.com/Asrez/GoAPIBlog/config"
+	"github.com/gin-gonic/gin"
+)
+
+func InitServer(){
+	config := config.GetConfig()
+	r := gin.New()
+	r.Use(gin.Logger()  ,gin.Recovery())
+
+	// v1 := r.Group("api/v1")
+	// {
+		
+	// }
+
+	r.Run(fmt.Sprintf(":%s", config.Server.InternalPort))
+}

api/dto/auth.go

@@ -0,0 +1,21 @@
+package dto
+
+type TokenDetail struct {
+	AccessToken            string `json:"accessToken"`
+	RefreshToken           string `json:"refreshToken"`
+	AccessTokenExpireTime  int64  `json:"accessTokenExpireTime"`
+	RefreshTokenExpireTime int64  `json:"refreshTokenExpireTime"`
+}
+
+type RegisterUserByUsernameRequest struct {
+	FirstName string `json:"firstName" binding:"required,min=3"`
+	LastName  string `json:"lastName" binding:"required,min=6"`
+	Username  string `json:"username" binding:"required,min=5"`
+	Email     string `json:"email" binding:"min=6,email"`
+	Password  string `json:"password" binding:"required,password,min=6"`
+}
+
+type LoginByUsernameRequest struct {
+	Username string `json:"username" binding:"required,min=5"`
+	Password string `json:"password" binding:"required,min=6"`
+}

api/helpers/base_response.go

@@ -0,0 +1,46 @@
+package helper
+
+import (
+	validation "github.com/Asrez/GoAPIBlog/api/validations"
+)
+
+
+type BaseHttpResponse struct {
+	Result           any                           `json:"result"`
+	Success          bool                          `json:"success"`
+	ResultCode       ResultCode                           `json:"resultCode"`
+	ValidationErrors *[]validation.ValidationError `json:"validationErrors"`
+	Error            any                           `json:"error"`
+}
+
+func GenerateBaseResponse(result any, success bool, resultCode ResultCode) *BaseHttpResponse {
+	return &BaseHttpResponse{Result: result,
+		Success:    success,
+		ResultCode: resultCode,
+	}
+}
+
+func GenerateBaseResponseWithError(result any, success bool, resultCode ResultCode, err error) *BaseHttpResponse {
+	return &BaseHttpResponse{Result: result,
+		Success:    success,
+		ResultCode: resultCode,
+		Error:      err.Error(),
+	}
+
+}
+
+func GenerateBaseResponseWithAnyError(result any, success bool, resultCode ResultCode, err any) *BaseHttpResponse {
+	return &BaseHttpResponse{Result: result,
+		Success:    success,
+		ResultCode: resultCode,
+		Error:      err,
+	}
+}
+
+func GenerateBaseResponseWithValidationError(result any, success bool, resultCode ResultCode, err error) *BaseHttpResponse {
+	return &BaseHttpResponse{Result: result,
+		Success:          success,
+		ResultCode:       resultCode,
+		ValidationErrors: validation.GetValidationErrors(err),
+	}
+}

api/helpers/result_code.go

@@ -0,0 +1,15 @@
+package helper
+
+type ResultCode int
+
+const (
+	Success         ResultCode = 0
+	ValidationError ResultCode = 40001
+	AuthError       ResultCode = 40101
+	ForbiddenError       ResultCode = 40301
+	NotFoundError ResultCode = 40401
+	LimiterError    ResultCode = 42901
+	OtpLimiterError ResultCode = 42902
+	CustomRecovery  ResultCode = 50001
+	InternalError   ResultCode = 50002
+)

api/helpers/status_code_mapping.go

@@ -0,0 +1,22 @@
+package helper
+
+import (
+	"net/http"
+	"github.com/Asrez/GoAPIBlog/pkg/service_errors"
+)
+
+var StatusCodeMapping = map[string]int{
+	// User
+	service_errors.EmailExists:      409,
+	service_errors.UsernameExists:   409,
+	service_errors.RecordNotFound:   404,
+	service_errors.PermissionDenied: 403,
+}
+
+func TranslateErrorToStatusCode(err error) int {
+	value, ok := StatusCodeMapping[err.Error()]
+	if !ok {
+		return http.StatusInternalServerError
+	}
+	return value
+}

api/middlewares/auth.go

@@ -0,0 +1,52 @@
+package middlewares
+
+import (
+	"net/http"
+	"strings"
+	helper "github.com/Asrez/GoAPIBlog/api/helpers"
+	"github.com/Asrez/GoAPIBlog/config"
+	"github.com/Asrez/GoAPIBlog/constants"
+	"github.com/Asrez/GoAPIBlog/pkg/service_errors"
+	"github.com/Asrez/GoAPIBlog/services"
+	"github.com/gin-gonic/gin"
+	"github.com/golang-jwt/jwt"
+)
+
+func Authentication(cfg *config.Config) gin.HandlerFunc {
+	var tokenService = services.NewTokenService(cfg)
+
+	return func(c *gin.Context) {
+		var err error
+		claimMap := map[string]interface{}{}
+		auth := c.GetHeader(constants.AuthorizationHeaderKey)
+		token := strings.Split(auth, " ")
+		if auth == "" {
+			err = &service_errors.ServiceError{EndUserMessage: service_errors.TokenRequired}
+		} else {
+			claimMap, err = tokenService.GetClaims(token[1])
+			if err != nil {
+				switch err.(*jwt.ValidationError).Errors {
+				case jwt.ValidationErrorExpired:
+					err = &service_errors.ServiceError{EndUserMessage: service_errors.TokenExpired}
+				default:
+					err = &service_errors.ServiceError{EndUserMessage: service_errors.TokenInvalid}
+				}
+			}
+		}
+		if err != nil {
+			c.AbortWithStatusJSON(http.StatusUnauthorized, helper.GenerateBaseResponseWithError(
+				nil, false, helper.AuthError, err,
+			))
+			return
+		}
+
+		c.Set(constants.UserIdKey, claimMap[constants.UserIdKey])
+		c.Set(constants.FirstNameKey, claimMap[constants.FirstNameKey])
+		c.Set(constants.LastNameKey, claimMap[constants.LastNameKey])
+		c.Set(constants.UsernameKey, claimMap[constants.UsernameKey])
+		c.Set(constants.EmailKey, claimMap[constants.EmailKey])
+		c.Set(constants.ExpireTimeKey, claimMap[constants.ExpireTimeKey])
+
+		c.Next()
+	}
+}

api/validations/custom.go

@@ -0,0 +1,29 @@
+package validation
+
+import (
+	"errors"
+	"github.com/go-playground/validator/v10"
+)
+
+type ValidationError struct {
+	Property string `json:"property"`
+	Tag      string `json:"tag"`
+	Value    string `json:"value"`
+	Message  string `json:"message"`
+}
+
+func GetValidationErrors(err error) *[]ValidationError {
+	var validationErrors []ValidationError
+	var ve validator.ValidationErrors
+	if errors.As(err,&ve){
+		for _, err := range err.(validator.ValidationErrors){
+			var el ValidationError
+			el.Property = err.Field()
+			el.Tag = err.Tag()
+			el.Value = err.Param()
+			validationErrors = append(validationErrors, el)
+		}
+		return &validationErrors
+	}
+	return nil
+}

api/validations/passwod.go

@@ -0,0 +1,16 @@
+package validation
+
+import (
+	"github.com/Asrez/GoAPIBlog/common"
+	"github.com/go-playground/validator/v10"
+)
+
+func PasswordValidator(fld validator.FieldLevel) bool {
+	value, ok := fld.Field().Interface().(string)
+	if !ok {
+		fld.Param()
+		return false
+	}
+
+	return common.CheckPassword(value)
+}

cmd/main.go

@@ -0,0 +1,23 @@
+package main
+
+import (
+	"github.com/Asrez/GoAPIBlog/api"
+	"github.com/Asrez/GoAPIBlog/config"
+	"github.com/Asrez/GoAPIBlog/data/db"
+	"github.com/Asrez/GoAPIBlog/data/migration"
+	"github.com/Asrez/GoAPIBlog/pkg/logging"
+)
+
+func main(){
+	cfg := config.GetConfig()
+	logger := logging.NewLogger(cfg)
+	err := db.InitDb(cfg)
+	defer db.CloseDb()
+
+	if err != nil {
+		logger.Fatal(logging.Postgres , logging.Startup , err.Error(),nil)
+	}
+
+	migration.Up()
+	api.InitServer()
+}