Deploy files from GitHub repository

controller/quiz/result_quiz_controller.go

@@ -0,0 +1,24 @@
+package controller
+
+import (
+	"strconv"
+
+	"api.qobiltu.id/controller"
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/services"
+	"github.com/gin-gonic/gin"
+)
+
+func Result(c *gin.Context) {
+	quizResult := services.QuizResultService{}
+	quizResultController := controller.Controller[any, models.QuizAttempt, []models.QuizResultResponse]{
+		Service: &quizResult.Service,
+	}
+	quizResultController.HeaderParse(c, func() {
+		academyId, _ := strconv.Atoi(c.Param("attempt_id"))
+		quizResult.Constructor.AccountID = uint(quizResultController.AccountData.UserID)
+		quizResult.Constructor.ID = uint(academyId) | 0
+		quizResult.Retrieve()
+		quizResultController.Response(c)
+	})
+}

controller/quiz/submit_quiz_controller.go

@@ -17,7 +17,8 @@ func Submit(c *gin.Context) {
 	submitQuizController.HeaderParse(c, func() {
 		quizId, _ := strconv.Atoi(c.Param("attempt_id"))
 		submitQuizController.Service.Constructor.ID = uint(quizId)
-		submitQuiz.Create(submitQuizController.AccountData.UserID)
+		submitQuizController.Service.Constructor.AccountID = uint(submitQuizController.AccountData.UserID)
+		submitQuiz.Create()
 		submitQuizController.Response(c)
 	})
 }

models/database_orm_model.go

@@ -152,7 +152,8 @@ type Question struct {
 	QuizID        uint   `json:"quiz_id"`
 	Content       string `json:"content"`
 	Order         int    `json:"order"`
-	CorrectAnswer uint   `json:"-"`
+	CorrectAnswer uint   `json:"corrent_answer"`
+	Review        string `json:"reviews"`
 }
 type Quiz struct {
 	ID             uint      `gorm:"primaryKey" json:"id"`
@@ -160,7 +161,7 @@ type Quiz struct {
 	Slug           string    `json:"slug" gorm:"uniqueIndex" `
 	Title          string    `json:"title"`
 	Description    string    `json:"description"`
-	TotalQuestions string    `json:"total_questions"`
+	TotalQuestions int       `json:"total_questions"`
 	AttemptLimit   int       `json:"attempt_limit"`
 	TimeLimit      int       `json:"time_limit"`
 	MinScore       int       `json:"min_score"`

repositories/academy_repository.go

@@ -93,3 +93,13 @@ func GetAcademyByID(id uint) Repository[models.Academy, models.Academy] {
 	)
 	return *repo
 }
+
+func UpdateAcademyMaterialCompletedById(id_material uint) Repository[models.AcademyMaterial, models.AcademyMaterial] {
+	repo := Construct[models.AcademyMaterial, models.AcademyMaterial](
+		models.AcademyMaterial{ID: id_material, IsCompleted: true},
+	)
+	Update(repo)
+	return *repo
+}
+
+// func UpdateAcademyProgressById(id_academy uint)

repositories/quiz_repository.go

@@ -63,6 +63,18 @@ func GetAttemptByIdandUserId(attemptId uint, userId uint) Repository[models.Quiz
 	return *repo
 }
 
+func GetAttemptByUserId(userId uint) Repository[models.QuizAttempt, []models.QuizAttempt] {
+	repo := Construct[models.QuizAttempt, []models.QuizAttempt](
+		models.QuizAttempt{
+			AccountID: userId,
+		},
+	)
+	repo.Transactions(
+		WhereGivenConstructor[models.QuizAttempt, []models.QuizAttempt],
+		Find[models.QuizAttempt, []models.QuizAttempt],
+	)
+	return *repo
+}
 func CreateAttempt(quizAttempt models.QuizAttempt) Repository[models.QuizAttempt, models.QuizAttempt] {
 	repo := Construct[models.QuizAttempt, models.QuizAttempt](
 		quizAttempt,

router/quiz_route.go

@@ -13,6 +13,8 @@ func QuizRoute(router *gin.Engine) {
 		routerGroup.POST("/:academy_id/:quiz_id/attempt", middleware.AuthUser, QuizController.Attempt)
 		routerGroup.GET("/:academy_id/:quiz_id/question", middleware.AuthUser, QuizController.Question)
 		routerGroup.PUT("/:academy_id/:quiz_id/choose-answer", middleware.AuthUser, QuizController.Answer)
+		routerGroup.GET("result/:attempt_id", middleware.AuthUser, QuizController.Result)
+		routerGroup.GET("result/", middleware.AuthUser, QuizController.Result)
 		routerGroup.POST("/submit-attempt/:attempt_id", middleware.AuthUser, QuizController.Submit)
 	}
 }

services/academy_quiz_service.go

@@ -20,6 +20,10 @@ type QuizListService struct {
 	Service[models.Academy, []models.Quiz]
 }
 
+type QuizResultService struct {
+	Service[models.QuizAttempt, []models.QuizResultResponse]
+}
+
 func AuthorizeQuizwithAcademy(s *AttemptQuizService, next func()) {
 	academyRepo := repositories.GetAcademyByID(s.Constructor.AcademyID)
 	s.Error = academyRepo.RowsError
@@ -130,8 +134,8 @@ func (s *AttemptQuizService) Create(userID uint) {
 	})
 }
 
-func (s *SubmitQuizService) Create(userID uint) {
-	quizAttemptRepo := repositories.GetAttemptByIdandUserId(s.Constructor.ID, userID)
+func (s *SubmitQuizService) Create() {
+	quizAttemptRepo := repositories.GetAttemptByIdandUserId(s.Constructor.ID, s.Constructor.AccountID)
 	if quizAttemptRepo.NoRecord {
 		s.Exception.DataNotFound = true
 		s.Exception.Message = "There is no quiz attempt with given user!"
@@ -139,6 +143,10 @@ func (s *SubmitQuizService) Create(userID uint) {
 	}
 	s.Error = errors.Join(s.Error, quizAttemptRepo.RowsError)
 	countScoreRepo := repositories.CountUserAttemptScore(s.Constructor.ID)
+	if countScoreRepo.NoRecord {
+		s.Exception.DataNotFound = true
+		s.Exception.Message = "There is no quiz attempt with given user!"
+	}
 	s.Error = errors.Join(s.Error, countScoreRepo.RowsError)
 
 	if quizAttemptRepo.Result.FinishedAt == nil {
@@ -168,3 +176,57 @@ func (s *QuizListService) Retrieve() {
 	s.Result = quizRepo.Result
 	return
 }
+
+func (s *QuizResultService) Retrieve() {
+	if s.Constructor.ID != 0 {
+		attemptRepo := repositories.GetAttemptByIdandUserId(s.Constructor.ID, s.Constructor.AccountID)
+		s.Error = attemptRepo.RowsError
+		if attemptRepo.NoRecord {
+			s.Exception.DataNotFound = true
+			s.Exception.Message = "There is no attempt with given user id"
+			return
+		}
+		if attemptRepo.Result.FinishedAt == nil {
+			s.Exception.Forbidden = true
+			s.Exception.Message = "You have to submit the exam first to see the result!"
+			return
+		}
+		countScoreRepo := repositories.CountUserAttemptScore(s.Constructor.ID)
+		s.Error = errors.Join(s.Error, countScoreRepo.RowsError)
+		if countScoreRepo.NoRecord {
+			s.Exception.DataNotFound = true
+			s.Exception.Message = "There is no quiz attempt with given user!"
+		}
+		s.Result = []models.QuizResultResponse{
+			models.QuizResultResponse{
+				QuizAttempt: attemptRepo.Result,
+				Result:      countScoreRepo.Result,
+			},
+		}
+		return
+	} else {
+		allAttemptsRepo := repositories.GetAttemptByUserId(s.Constructor.AccountID)
+		if allAttemptsRepo.NoRecord {
+			s.Exception.DataNotFound = true
+			s.Exception.Message = "There is no attempt with given user id!"
+			return
+		}
+		s.Error = allAttemptsRepo.RowsError
+		var arrResult []models.QuizResultResponse
+		for _, attempt := range allAttemptsRepo.Result {
+			if attempt.FinishedAt != nil {
+				countScoreRepo := repositories.CountUserAttemptScore(attempt.ID)
+				s.Error = errors.Join(s.Error, countScoreRepo.RowsError)
+				if countScoreRepo.NoRecord {
+					continue
+				}
+				arrResult = append(arrResult, models.QuizResultResponse{
+					QuizAttempt: attempt,
+					Result:      countScoreRepo.Result,
+				})
+			}
+		}
+		s.Result = arrResult
+		return
+	}
+}

services/academy_service.go

@@ -25,6 +25,10 @@ type AcademyContentService struct {
 	Service[models.AcademyMaterial, models.AcademyContent]
 }
 
+type AcademyMarkReadService struct {
+	Service[models.AcademyMaterial, models.Academy]
+}
+
 func castAcademyMaterials(academyId uint) []models.AcademyMaterialResponse {
 	var ArrMaterials []models.AcademyMaterialResponse
 	academyMaterialsRepo := repositories.GetAllAcademyMaterialsByAcademyID(academyId)
@@ -135,3 +139,12 @@ func (s *AcademyContentService) Retrieve() {
 	}
 	s.Result = academyContentRepo.Result
 }
+
+func (s *AcademyMarkReadService) Update() {
+	markReadRepo := repositories.UpdateAcademyMaterialCompletedById(s.Constructor.ID)
+	if markReadRepo.NoRecord {
+		s.Exception.DataNotFound = true
+		s.Error = markReadRepo.RowsError
+		return
+	}
+}

space/.env.example

@@ -1,9 +1,26 @@
-DB_HOST =
-DB_USER =
-DB_PASSWORD =
-DB_PORT =
-DB_NAME =
-SALT =
-HOST_ADDRESS = 
-HOST_PORT = 
-LOG_PATH = logs
+APP_URL=https://api.qobiltu.id
+ENV=production
+
+DB_HOST=db
+DB_USER=qobiltu
+DB_PASSWORD=
+DB_PORT=
+DB_NAME=
+SALT=
+HOST_ADDRESS=
+HOST_PORT=
+LOG_PATH=logs
+
+SMTP_SENDER_EMAIL=
+SMTP_SENDER_PASSWORD=
+SMTP_HOST=
+SMTP_PORT=
+EMAIL_VERIFICATION_DURATION=
+
+REDIS_HOST=redis
+REDIS_PORT=6379
+REDIS_PASSWORD=
+REDIS_DB=0
+REDIS_MIN_IDLE_CONNS=10
+REDIS_POOL_SIZE=10
+REDIS_POOL_TIMEOUT=30s

space/space/pkg/validation/custom_rules.go

@@ -32,7 +32,7 @@ var inMemoryOptions = map[string][]string{
 	"body_shape":            {"Ideal", "Kurus", "Berisi", "Gemuk"},
 	"skin_color":            {"Putih", "Kuning Langsat", "Sawo Matang"},
 	"hair_type":             {"Lurus", "Bergelombang", "Keriting"},
-	"frequently":            {"Selalu", "Sering", "Kadang", "Jarang"},
+	"frequently":            {"Selalu", "Sering", "Kadang", "Jarang", "Tidak Pernah"},
 	"quran_reading_ability": {"Lancar", "Menengah", "Perlu Bimbingan"},
 }
 

space/space/space/services/cv_service.go

@@ -3,7 +3,6 @@ package services
 import (
 	"context"
 	"errors"
-	"fmt"
 	"math"
 	"strconv"
 
@@ -648,26 +647,25 @@ func calculateProgress(
 	achievementCV int,
 ) *models.ProgressResponse {
 
-	exists := func(data int) float64 {
+	// fullIfPresent returns 100 if the data is greater than 0, otherwise returns 0
+	fullIfPresent := func(data int) float64 {
 		if data > 0 {
 			return 100
 		}
 		return 0
 	}
 
-	fmt.Println("accountDetails", accountDetails.GetFilledFields())
-	fmt.Println("accountDetailsTotal", accountDetails.TotalFields())
-
 	accountDetailsPercentage := float64(len(accountDetails.GetFilledFields())) / float64(accountDetails.TotalFields()) * 100
 	personalityAndPreferenceCVPercentage := float64(len(personalityAndPreferenceCV.GetFilledFields())) / float64(personalityAndPreferenceCV.TotalFields()) * 100
 	physicalAndHealthCVPercentage := float64(len(physicalAndHealthCV.GetFilledFields())) / float64(physicalAndHealthCV.TotalFields()) * 100
 	worshipAndReligiousUnderstandingCVPercentage := float64(len(worshipAndReligiousUnderstandingCV.GetFilledFields())) / float64(worshipAndReligiousUnderstandingCV.TotalFields()) * 100
-	edicationCVPercentage := exists(educationCV)
-	familyMemberCVPercentage := exists(familyMemberCV)
-	jobCVPercentage := exists(jobCV)
-	achievementCVPercentage := exists(achievementCV)
 
-	overallProgress := (accountDetailsPercentage + personalityAndPreferenceCVPercentage + physicalAndHealthCVPercentage + worshipAndReligiousUnderstandingCVPercentage + edicationCVPercentage + familyMemberCVPercentage + jobCVPercentage + achievementCVPercentage) / 8
+	educationCVPercentage := fullIfPresent(educationCV)
+	familyMemberCVPercentage := fullIfPresent(familyMemberCV)
+	jobCVPercentage := fullIfPresent(jobCV)
+	achievementCVPercentage := fullIfPresent(achievementCV)
+
+	overallProgress := (accountDetailsPercentage + personalityAndPreferenceCVPercentage + physicalAndHealthCVPercentage + worshipAndReligiousUnderstandingCVPercentage + educationCVPercentage + familyMemberCVPercentage + jobCVPercentage + achievementCVPercentage) / 8
 
 	return &models.ProgressResponse{
 		AccountDetailsProgress:                     math.Round(accountDetailsPercentage*100) / 100,
@@ -675,9 +673,9 @@ func calculateProgress(
 		FamilyMemberCVProgress:                     math.Round(familyMemberCVPercentage*100) / 100,
 		PhysicalAndHealthCVProgress:                math.Round(physicalAndHealthCVPercentage*100) / 100,
 		WorshipAndReligiousUnderstandingCVProgress: math.Round(worshipAndReligiousUnderstandingCVPercentage*100) / 100,
-		EducationCVProgress:                        math.Round(edicationCVPercentage*100) / 100,
-		JobCVProgress:                              jobCVPercentage,
-		AchievementCVProgress:                      achievementCVPercentage,
+		EducationCVProgress:                        math.Round(educationCVPercentage*100) / 100,
+		JobCVProgress:                              math.Round(jobCVPercentage*100) / 100,
+		AchievementCVProgress:                      math.Round(achievementCVPercentage*100) / 100,
 		TotalProgress:                              math.Round(overallProgress*100) / 100,
 	}
 }

space/space/space/space/controller/cv/cv_controller.go

@@ -1,13 +1,14 @@
 package cv_controller
 
 import (
+	"net/http"
+	"strconv"
+
 	"api.qobiltu.id/middleware"
 	"api.qobiltu.id/models"
 	"api.qobiltu.id/response"
 	"api.qobiltu.id/services"
 	"github.com/gin-gonic/gin"
-	"net/http"
-	"strconv"
 )
 
 type CVController interface {
@@ -48,6 +49,7 @@ type CVController interface {
 	DeleteAchievement(ctx *gin.Context)
 
 	UploadProfileImage(ctx *gin.Context)
+	GetProgress(ctx *gin.Context)
 }
 
 type cvController struct {
@@ -573,3 +575,16 @@ func (c *cvController) UploadProfileImage(ctx *gin.Context) {
 
 	response.HandleSuccess(ctx, http.StatusOK, "Profile image uploaded successfully", res, nil)
 }
+
+func (c *cvController) GetProgress(ctx *gin.Context) {
+	accountData := middleware.GetAccountData(ctx)
+	accountID := int64(accountData.UserID)
+
+	res, err := c.cvService.GetProgress(ctx, accountID)
+	if err != nil {
+		response.HandleError(ctx, err)
+		return
+	}
+
+	response.HandleSuccess(ctx, http.StatusOK, "Progress retrieved successfully", res, nil)
+}

space/space/space/space/models/field_counter.go

@@ -0,0 +1,163 @@
+package models
+
+import (
+	"reflect"
+	"time"
+)
+
+// CounterGetter adalah interface yang menyediakan method untuk menghitung dan mendapatkan field
+type CounterGetter interface {
+	TotalFields() int
+	GetFilledFields() []string
+}
+
+// FieldCounter menyediakan fungsionalitas generik penghitungan dan pengecekan field
+// untuk diembed ke dalam struct lain
+type FieldCounter struct{}
+
+// shouldSkipField menentukan apakah field harus dilewati dalam penghitungan
+func shouldSkipField(field reflect.StructField) bool {
+	// Skip field dengan nama FieldCounter (embedded type)
+	if field.Name == "FieldCounter" {
+		return true
+	}
+
+	// Skip field yang berasal dari GORM atau standard fields
+	// seperti ID, timestamps, dan foreign keys
+	if field.Name == "ID" || field.Name == "CreatedAt" || field.Name == "UpdatedAt" || field.Name == "DeletedAt" ||
+		field.Name == "AccountID" || field.Name == "Account" {
+		return true
+	}
+
+	// Periksa tag gorm untuk auto fields
+	gormTag := field.Tag.Get("gorm")
+	if len(gormTag) > 0 {
+		// Skip kolom yang auto-increment atau auto-timestamp
+		if gormTag == "primaryKey" || gormTag == "autoIncrement" ||
+			gormTag == "autoCreateTime" || gormTag == "autoUpdateTime" {
+			return true
+		}
+	}
+
+	return false
+}
+
+// TotalFields menghitung jumlah total field dalam struct
+// dengan mengecualikan field internal, metadata, dan embedded FieldCounter
+func (fc FieldCounter) TotalFields(s any) int {
+	t := reflect.TypeOf(s)
+	count := 0
+
+	// Jika s adalah pointer, dapatkan elemen yang ditunjuknya
+	if t.Kind() == reflect.Ptr {
+		t = t.Elem()
+	}
+
+	// Pastikan kita berurusan dengan struct
+	if t.Kind() != reflect.Struct {
+		return 0
+	}
+
+	// Hitung field yang sesuai dengan kriteria
+	for i := 0; i < t.NumField(); i++ {
+		field := t.Field(i)
+
+		// Skip field yang memenuhi kriteria yang ditentukan
+		if shouldSkipField(field) {
+			continue
+		}
+
+		count++
+	}
+
+	return count
+}
+
+// GetFilledFields mengembalikan slice berisi nama field yang telah diisi dengan nilai
+// (tidak nil, string tidak kosong, int/float tidak 0, dll)
+func (fc FieldCounter) GetFilledFields(s any) []string {
+	var filledFields []string
+	v := reflect.ValueOf(s)
+
+	// Jika s adalah pointer, dapatkan elemen yang ditunjuknya
+	if v.Kind() == reflect.Ptr {
+		if v.IsNil() {
+			return filledFields
+		}
+		v = v.Elem()
+	}
+
+	// Pastikan kita berurusan dengan struct
+	if v.Kind() != reflect.Struct {
+		return filledFields
+	}
+
+	t := v.Type()
+
+	// Loop melalui semua field
+	for i := 0; i < v.NumField(); i++ {
+		field := v.Field(i)
+		fieldType := t.Field(i)
+		fieldName := fieldType.Name
+
+		// Skip field yang memenuhi kriteria yang ditentukan
+		if shouldSkipField(fieldType) {
+			continue
+		}
+
+		// Cek apakah field diisi berdasarkan tipenya
+		if isFieldFilled(field) {
+			filledFields = append(filledFields, fieldName)
+		}
+	}
+
+	return filledFields
+}
+
+// isFieldFilled memeriksa apakah field memiliki nilai non-zero
+func isFieldFilled(field reflect.Value) bool {
+	// Jika field tidak dapat di-address atau diakses, anggap kosong
+	if !field.IsValid() || !field.CanInterface() {
+		return false
+	}
+
+	// Handle untuk pointer
+	if field.Kind() == reflect.Ptr {
+		if field.IsNil() {
+			return false
+		}
+		// Untuk pointer, periksa nilai yang ditunjuk
+		return isFieldFilled(field.Elem())
+	}
+
+	// Cek berdasarkan tipe data
+	switch field.Kind() {
+	case reflect.String:
+		return field.String() != ""
+	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
+		return field.Int() != 0
+	case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return field.Uint() != 0
+	case reflect.Float32, reflect.Float64:
+		return field.Float() != 0
+	case reflect.Bool:
+		return field.Bool()
+	case reflect.Slice, reflect.Map, reflect.Array:
+		return !field.IsNil() && field.Len() > 0
+	case reflect.Struct:
+		// Perlakuan khusus untuk time.Time
+		if field.Type() == reflect.TypeOf(time.Time{}) {
+			// Anggap time.Time kosong jika zero value atau tahun sangat awal
+			timeVal := field.Interface().(time.Time)
+			return !timeVal.IsZero() && timeVal.Year() > 1
+		}
+
+		// Untuk struct lain, bandingkan dengan zero value
+		return !reflect.DeepEqual(field.Interface(), reflect.Zero(field.Type()).Interface())
+	case reflect.Interface:
+		return !field.IsNil()
+	default:
+		// Untuk tipe lain, gunakan perbandingan dengan zero value
+		return !field.IsZero()
+	}
+}

space/space/space/space/models/request_model.go

@@ -161,4 +161,16 @@ type (
 	UploadProfileImageResponse struct {
 		URL string `json:"url"`
 	}
+
+	ProgressResponse struct {
+		AccountDetailsProgress                     float64 `json:"account_details_progress"`
+		PersonalityAndPreferenceCVProgress         float64 `json:"personality_and_preference_cv_progress"`
+		FamilyMemberCVProgress                     float64 `json:"family_member_cv_progress"`
+		PhysicalAndHealthCVProgress                float64 `json:"physical_and_health_cv_progress"`
+		WorshipAndReligiousUnderstandingCVProgress float64 `json:"worship_and_religious_understanding_cv_progress"`
+		EducationCVProgress                        float64 `json:"education_cv_progress"`
+		JobCVProgress                              float64 `json:"job_cv_progress"`
+		AchievementCVProgress                      float64 `json:"achievement_cv_progress"`
+		TotalProgress                              float64 `json:"total_progress"`
+	}
 )

space/space/space/space/router/cv_route.go

@@ -41,5 +41,7 @@ func (s *Server) CVRoute() {
 		routerGroup.GET("/achievements/:id", s.cvController.GetAchievement)
 		routerGroup.PUT("/achievements/:id", s.cvController.UpdateAchievement)
 		routerGroup.DELETE("/achievements/:id", s.cvController.DeleteAchievement)
+
+		routerGroup.GET("/progress", s.cvController.GetProgress)
 	}
 }

space/space/space/space/services/cv_service.go

@@ -3,6 +3,8 @@ package services
 import (
 	"context"
 	"errors"
+	"fmt"
+	"math"
 	"strconv"
 
 	"api.qobiltu.id/models"
@@ -51,6 +53,7 @@ type CVService interface {
 	DeleteAchievement(ctx context.Context, id int64) error
 
 	UploadProfileImage(ctx context.Context, req *models.UploadProfileImageRequest) (*models.UploadProfileImageResponse, error)
+	GetProgress(ctx context.Context, accountID int64) (*models.ProgressResponse, error)
 }
 
 type cvService struct {
@@ -566,3 +569,115 @@ func (s *cvService) UploadProfileImage(ctx context.Context, req *models.UploadPr
 		URL: url,
 	}, nil
 }
+
+func (s *cvService) GetProgress(ctx context.Context, accountID int64) (*models.ProgressResponse, error) {
+	accountDetails, err := s.cvRepository.GetAccountDetailsByAccountID(ctx, accountID)
+	if err != nil {
+		if !errors.Is(err, gorm.ErrRecordNotFound) {
+			return nil, response.HandleGormError(err, "Internal Server Error")
+		}
+		accountDetails = &models.AccountDetails{}
+	}
+
+	personalityAndPreferenceCV, err := s.cvRepository.GetPersonalityAndPreferenceByAccountID(ctx, accountID)
+	if err != nil {
+		if !errors.Is(err, gorm.ErrRecordNotFound) {
+			return nil, response.HandleGormError(err, "Internal Server Error")
+		}
+		personalityAndPreferenceCV = &models.PersonalityAndPreferenceCV{}
+	}
+
+	physicalAndHealthCV, err := s.cvRepository.GetPhysicalAndHealthByAccountID(ctx, accountID)
+	if err != nil {
+		if !errors.Is(err, gorm.ErrRecordNotFound) {
+			return nil, response.HandleGormError(err, "Internal Server Error")
+		}
+		physicalAndHealthCV = &models.PhysicalAndHealthCV{}
+	}
+
+	worshipAndReligiousUnderstandingCV, err := s.cvRepository.GetWorshipAndReligiousUnderstandingByAccountID(ctx, accountID)
+	if err != nil {
+		if !errors.Is(err, gorm.ErrRecordNotFound) {
+			return nil, response.HandleGormError(err, "Internal Server Error")
+		}
+		worshipAndReligiousUnderstandingCV = &models.WorshipAndReligiousUnderstandingCV{}
+	}
+
+	educationCV, err := s.cvRepository.ListEducation(ctx, accountID)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	familyMemberCV, err := s.cvRepository.ListFamilyMember(ctx, accountID)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	jobCV, err := s.cvRepository.ListJob(ctx, accountID)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	achievementCV, err := s.cvRepository.ListAchievement(ctx, accountID)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	progressDetails := calculateProgress(
+		accountDetails,
+		personalityAndPreferenceCV,
+		physicalAndHealthCV,
+		worshipAndReligiousUnderstandingCV,
+		len(educationCV),
+		len(familyMemberCV),
+		len(jobCV),
+		len(achievementCV),
+	)
+
+	return progressDetails, nil
+}
+
+func calculateProgress(
+	accountDetails *models.AccountDetails,
+	personalityAndPreferenceCV *models.PersonalityAndPreferenceCV,
+	physicalAndHealthCV *models.PhysicalAndHealthCV,
+	worshipAndReligiousUnderstandingCV *models.WorshipAndReligiousUnderstandingCV,
+	educationCV int,
+	familyMemberCV int,
+	jobCV int,
+	achievementCV int,
+) *models.ProgressResponse {
+
+	exists := func(data int) float64 {
+		if data > 0 {
+			return 100
+		}
+		return 0
+	}
+
+	fmt.Println("accountDetails", accountDetails.GetFilledFields())
+	fmt.Println("accountDetailsTotal", accountDetails.TotalFields())
+
+	accountDetailsPercentage := float64(len(accountDetails.GetFilledFields())) / float64(accountDetails.TotalFields()) * 100
+	personalityAndPreferenceCVPercentage := float64(len(personalityAndPreferenceCV.GetFilledFields())) / float64(personalityAndPreferenceCV.TotalFields()) * 100
+	physicalAndHealthCVPercentage := float64(len(physicalAndHealthCV.GetFilledFields())) / float64(physicalAndHealthCV.TotalFields()) * 100
+	worshipAndReligiousUnderstandingCVPercentage := float64(len(worshipAndReligiousUnderstandingCV.GetFilledFields())) / float64(worshipAndReligiousUnderstandingCV.TotalFields()) * 100
+	edicationCVPercentage := exists(educationCV)
+	familyMemberCVPercentage := exists(familyMemberCV)
+	jobCVPercentage := exists(jobCV)
+	achievementCVPercentage := exists(achievementCV)
+
+	overallProgress := (accountDetailsPercentage + personalityAndPreferenceCVPercentage + physicalAndHealthCVPercentage + worshipAndReligiousUnderstandingCVPercentage + edicationCVPercentage + familyMemberCVPercentage + jobCVPercentage + achievementCVPercentage) / 8
+
+	return &models.ProgressResponse{
+		AccountDetailsProgress:                     math.Round(accountDetailsPercentage*100) / 100,
+		PersonalityAndPreferenceCVProgress:         math.Round(personalityAndPreferenceCVPercentage*100) / 100,
+		FamilyMemberCVProgress:                     math.Round(familyMemberCVPercentage*100) / 100,
+		PhysicalAndHealthCVProgress:                math.Round(physicalAndHealthCVPercentage*100) / 100,
+		WorshipAndReligiousUnderstandingCVProgress: math.Round(worshipAndReligiousUnderstandingCVPercentage*100) / 100,
+		EducationCVProgress:                        math.Round(edicationCVPercentage*100) / 100,
+		JobCVProgress:                              jobCVPercentage,
+		AchievementCVProgress:                      achievementCVPercentage,
+		TotalProgress:                              math.Round(overallProgress*100) / 100,
+	}
+}

space/space/space/space/space/models/database_orm_model.go

@@ -34,6 +34,7 @@ type AccountDetails struct {
 	PhoneNumber   *string    `gorm:"column:phone_number" json:"phone_number"`
 	CreatedAt     time.Time  `gorm:"column:created_at;autoCreateTime" json:"created_at"`
 	UpdatedAt     time.Time  `gorm:"column:updated_at;autoUpdateTime" json:"updated_at"`
+	FieldCounter
 }
 
 type EmailVerification struct {
@@ -154,15 +155,16 @@ type Question struct {
 	CorrectAnswer uint   `json:"-"`
 }
 type Quiz struct {
-	ID           uint      `gorm:"primaryKey" json:"id"`
-	AcademyID    uint      `json:"academy_id"`
-	Slug         string    `json:"slug" gorm:"uniqueIndex" `
-	Title        string    `json:"title"`
-	Description  string    `json:"description"`
-	AttemptLimit int       `json:"attempt_limit"`
-	TimeLimit    int       `json:"time_limit"`
-	MinScore     int       `json:"min_score"`
-	CreatedAt    time.Time `json:"created_at"`
+	ID             uint      `gorm:"primaryKey" json:"id"`
+	AcademyID      uint      `json:"academy_id"`
+	Slug           string    `json:"slug" gorm:"uniqueIndex" `
+	Title          string    `json:"title"`
+	Description    string    `json:"description"`
+	TotalQuestions string    `json:"total_questions"`
+	AttemptLimit   int       `json:"attempt_limit"`
+	TimeLimit      int       `json:"time_limit"`
+	MinScore       int       `json:"min_score"`
+	CreatedAt      time.Time `json:"created_at"`
 }
 
 type QuizAttempt struct {
@@ -209,6 +211,7 @@ type (
 		MonthlyExpenses       *string   `gorm:"column:monthly_expenses" json:"monthly_expenses"`                 // pengeluaran per bulan
 		CreatedAt             time.Time `gorm:"column:created_at;autoCreateTime" json:"created_at"`
 		UpdatedAt             time.Time `gorm:"column:updated_at;autoUpdateTime" json:"updated_at"`
+		FieldCounter
 	}
 
 	FamilyMemberCV struct {
@@ -223,6 +226,7 @@ type (
 		Age           *int      `gorm:"column:age" json:"age"`                       // Usia
 		CreatedAt     time.Time `gorm:"column:created_at;autoCreateTime" json:"created_at"`
 		UpdatedAt     time.Time `gorm:"column:updated_at;autoUpdateTime" json:"updated_at"`
+		FieldCounter
 	}
 
 	PhysicalAndHealthCV struct {
@@ -239,6 +243,7 @@ type (
 		PhysicalTraits   *string   `gorm:"column:physical_traits" json:"physical_traits"`      // Ciri khas fisik
 		CreatedAt        time.Time `gorm:"column:created_at;autoCreateTime" json:"created_at"` // Waktu data dibuat
 		UpdatedAt        time.Time `gorm:"column:updated_at;autoUpdateTime" json:"updated_at"` // Waktu data terakhir diperbarui
+		FieldCounter
 	}
 
 	WorshipAndReligiousUnderstandingCV struct {
@@ -262,6 +267,7 @@ type (
 		FollowedUstadz             *string        `gorm:"column:followed_ustadz" json:"followed_ustadz"`                               // ustadz_yang_diikuti
 		CreatedAt                  time.Time      `gorm:"column:created_at;autoCreateTime" json:"created_at"`
 		UpdatedAt                  time.Time      `gorm:"column:updated_at;autoUpdateTime" json:"updated_at"`
+		FieldCounter
 	}
 
 	EducationCV struct {
@@ -300,6 +306,38 @@ type (
 	}
 )
 
+func (a AccountDetails) TotalFields() int {
+	return a.FieldCounter.TotalFields(a)
+}
+
+func (a AccountDetails) GetFilledFields() []string {
+	return a.FieldCounter.GetFilledFields(a)
+}
+
+func (p PersonalityAndPreferenceCV) TotalFields() int {
+	return p.FieldCounter.TotalFields(p)
+}
+
+func (p PersonalityAndPreferenceCV) GetFilledFields() []string {
+	return p.FieldCounter.GetFilledFields(p)
+}
+
+func (p PhysicalAndHealthCV) TotalFields() int {
+	return p.FieldCounter.TotalFields(p)
+}
+
+func (p PhysicalAndHealthCV) GetFilledFields() []string {
+	return p.FieldCounter.GetFilledFields(p)
+}
+
+func (w WorshipAndReligiousUnderstandingCV) TotalFields() int {
+	return w.FieldCounter.TotalFields(w)
+}
+
+func (w WorshipAndReligiousUnderstandingCV) GetFilledFields() []string {
+	return w.FieldCounter.GetFilledFields(w)
+}
+
 // Gorm table name settings
 func (Account) TableName() string                    { return "account" }
 func (AccountDetails) TableName() string             { return "account_details" }

space/space/space/space/space/repositories/quiz_repository.go

@@ -49,9 +49,12 @@ func GetUserLastAttempt(userId uint, quizId uint) Repository[models.QuizAttempt,
 	return *repo
 }
 
-func GetAttemptById(attemptId uint) Repository[models.QuizAttempt, models.QuizAttempt] {
+func GetAttemptByIdandUserId(attemptId uint, userId uint) Repository[models.QuizAttempt, models.QuizAttempt] {
 	repo := Construct[models.QuizAttempt, models.QuizAttempt](
-		models.QuizAttempt{ID: attemptId},
+		models.QuizAttempt{
+			ID:        attemptId,
+			AccountID: userId,
+		},
 	)
 	repo.Transactions(
 		WhereGivenConstructor[models.QuizAttempt, models.QuizAttempt],

space/space/space/space/space/services/academy_quiz_service.go

@@ -131,7 +131,7 @@ func (s *AttemptQuizService) Create(userID uint) {
 }
 
 func (s *SubmitQuizService) Create(userID uint) {
-	quizAttemptRepo := repositories.GetAttemptById(s.Constructor.ID)
+	quizAttemptRepo := repositories.GetAttemptByIdandUserId(s.Constructor.ID, userID)
 	if quizAttemptRepo.NoRecord {
 		s.Exception.DataNotFound = true
 		s.Exception.Message = "There is no quiz attempt with given user!"

space/space/space/space/space/space/pkg/validation/custom_rules.go

@@ -1,6 +1,7 @@
 package validation
 
 import (
+	"regexp"
 	"strings"
 	"sync"
 
@@ -150,6 +151,11 @@ func (v *Validator) RegisterAllCustomRules(validate *v10.Validate) error {
 		return err
 	}
 
+	err = validate.RegisterValidation("phone_number", v.PhoneNumberRule)
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 
@@ -160,3 +166,39 @@ func (v *Validator) PasswordRule(fl v10.FieldLevel) bool {
 		strings.ContainsAny(password, "ABCDEFGHIJKLMNOPQRSTUVWXYZ") &&
 		strings.ContainsAny(password, "0123456789")
 }
+
+func (v *Validator) PhoneNumberRule(fl v10.FieldLevel) bool {
+	phone := SanitizePhoneNumber(fl.Field().String())
+	return strings.HasPrefix(phone, "+62")
+}
+
+func SanitizePhoneNumber(input string) string {
+	// Hilangkan semua spasi dan strip
+	input = strings.ReplaceAll(input, " ", "")
+	input = strings.ReplaceAll(input, "-", "")
+	input = strings.ReplaceAll(input, "(", "")
+	input = strings.ReplaceAll(input, ")", "")
+
+	// Hilangkan semua karakter non-digit kecuali +
+	re := regexp.MustCompile(`[^0-9\+]`)
+	input = re.ReplaceAllString(input, "")
+
+	// Handle nomor diawali 0 (contoh: 0812...) menjadi +62812...
+	if strings.HasPrefix(input, "0") {
+		input = "+62" + input[1:]
+	}
+
+	// Handle jika diawali dengan 62 tanpa + (contoh: 62812...)
+	if strings.HasPrefix(input, "62") && !strings.HasPrefix(input, "+62") {
+		input = "+" + input
+	}
+
+	// Handle jika tidak ada awalan +62 sama sekali (contoh: 8123456789)
+	if !strings.HasPrefix(input, "+62") {
+		if strings.HasPrefix(input, "8") {
+			input = "+62" + input
+		}
+	}
+
+	return input
+}

space/space/space/space/space/space/pkg/validation/validation.go

@@ -79,6 +79,7 @@ func setupValidations(validate *v10.Validate) error {
 	if err := rules.RegisterAllCustomRules(validate); err != nil {
 		return err
 	}
+
 	return nil
 }
 

space/space/space/space/space/space/space/Makefile

@@ -1,7 +1,15 @@
 up-dev:
 	docker compose -f docker-compose.dev.yml up -d
 
+down-dev:
+	docker compose -f docker-compose.dev.yml down
+
+up:
+	docker compose up -d --build
+down:
+	docker compose down
+
 run-dev:
 	go run main.go
 
-.PHONY : up-dev run-dev
+.PHONY : up-dev run-dev down-dev up down

space/space/space/space/space/space/space/config/config.go

@@ -29,6 +29,8 @@ var REDIS_MIN_IDLE_CONNS int
 var REDIS_POOL_SIZE int
 var REDIS_POOL_TIMEOUT time.Duration
 
+var APP_URL string
+
 func init() {
 	godotenv.Load()
 	ENV = os.Getenv("ENV")
@@ -49,6 +51,7 @@ func init() {
 	REDIS_POOL_SIZE = getValue(os.Getenv("REDIS_POOL_SIZE"), 10, func(s string) (int, error) { return strconv.Atoi(s) })
 	REDIS_MIN_IDLE_CONNS = getValue(os.Getenv("REDIS_MIN_IDLE_CONNS"), 10, func(s string) (int, error) { return strconv.Atoi(s) })
 	REDIS_POOL_TIMEOUT = getValue(os.Getenv("REDIS_POOL_TIMEOUT"), time.Second*30, func(s string) (time.Duration, error) { return time.ParseDuration(s) })
+	APP_URL = getValue(os.Getenv("APP_URL"), "http://localhost:3000", func(s string) (string, error) { return s, nil })
 }
 
 func getValue[T any](value string, defaultValue T, convert func(string) (T, error)) T {

space/space/space/space/space/space/space/controller/cv/cv_controller.go

@@ -46,6 +46,8 @@ type CVController interface {
 	ListAchievement(ctx *gin.Context)
 	GetAchievement(ctx *gin.Context)
 	DeleteAchievement(ctx *gin.Context)
+
+	UploadProfileImage(ctx *gin.Context)
 }
 
 type cvController struct {
@@ -553,3 +555,21 @@ func (c *cvController) DeleteAchievement(ctx *gin.Context) {
 
 	response.HandleSuccess(ctx, http.StatusOK, "Achievement deleted successfully", nil, nil)
 }
+
+func (c *cvController) UploadProfileImage(ctx *gin.Context) {
+	accountData := middleware.GetAccountData(ctx)
+
+	avatarFile, _ := ctx.FormFile("avatar")
+	req := models.UploadProfileImageRequest{
+		AccountID: int64(accountData.UserID),
+		File:      avatarFile,
+	}
+
+	res, err := c.cvService.UploadProfileImage(ctx, &req)
+	if err != nil {
+		response.HandleError(ctx, err)
+		return
+	}
+
+	response.HandleSuccess(ctx, http.StatusOK, "Profile image uploaded successfully", res, nil)
+}

space/space/space/space/space/space/space/docker-compose.yml

@@ -6,14 +6,15 @@ services:
     build: .
     depends_on:
       - db
+      - redis
     env_file: .env
     ports:
       - "8080:8080"
+    volumes:
+      - ./logs:/app/logs
+      - ./uploads:/app/uploads
     networks:
       - qobiltu-network
-    # volumes:
-    #   - ./logs:/app/logs
-    #   - /home/qobiltu/api-qobiltu:/app
     restart: unless-stopped
 
   db:
@@ -45,10 +46,6 @@ services:
           - qobiltu-network
       restart: always
 
-volumes:
-  db-data:
-  redis-data:
-
 networks:
   qobiltu-network:
     driver: bridge

space/space/space/space/space/space/space/go.mod

@@ -8,6 +8,7 @@ require (
 	github.com/go-playground/universal-translator v0.18.1
 	github.com/go-playground/validator/v10 v10.25.0
 	github.com/golang-jwt/jwt/v5 v5.2.1
+	github.com/google/uuid v1.6.0
 	github.com/gosimple/slug v1.15.0
 	github.com/hibiken/asynq v0.25.1
 	github.com/joho/godotenv v1.5.1
@@ -37,7 +38,6 @@ require (
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/goccy/go-json v0.10.5 // indirect
 	github.com/google/s2a-go v0.1.9 // indirect
-	github.com/google/uuid v1.6.0 // indirect
 	github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect
 	github.com/googleapis/gax-go/v2 v2.14.1 // indirect
 	github.com/gosimple/unidecode v1.0.1 // indirect

space/space/space/space/space/space/space/main.go

@@ -2,15 +2,16 @@ package main
 
 import (
 	"api.qobiltu.id/config"
-	cv_controller "api.qobiltu.id/controller/cv"
+	"api.qobiltu.id/controller/cv"
 	"api.qobiltu.id/controller/health_check"
 	"api.qobiltu.id/mail"
+	"api.qobiltu.id/pkg/storage"
+	"api.qobiltu.id/pkg/validation"
+	"api.qobiltu.id/pkg/worker"
 	"api.qobiltu.id/repositories"
 	"api.qobiltu.id/router"
 	"api.qobiltu.id/services"
 	"api.qobiltu.id/utils"
-	"api.qobiltu.id/validation"
-	"api.qobiltu.id/worker"
 	"github.com/hibiken/asynq"
 	"log/slog"
 	"net"
@@ -23,6 +24,9 @@ func main() {
 	err := validation.New(validation.LocaleID)
 	utils.FatalIfErr("failed to setup validator", err)
 
+	// setup storage
+	localStorage := storage.NewLocalStorage("uploads", config.APP_URL+"/storage/")
+
 	// setup email sender
 	emailConfig := mail.Config{
 		Host:     config.SMTP_HOST,
@@ -53,7 +57,7 @@ func main() {
 	healthCheckController := health_check_controller.NewHealthCheckController(healthCheckService)
 
 	cvRepository := repositories.NewCVRepository(config.DB)
-	cvService := services.NewCVService(cvRepository)
+	cvService := services.NewCVService(cvRepository, localStorage)
 	cvController := cv_controller.NewCVController(cvService)
 
 	// start task processor

space/space/space/space/space/space/space/models/exception_model.go

@@ -1,6 +1,8 @@
 package models
 
-import "api.qobiltu.id/validation"
+import (
+	"api.qobiltu.id/pkg/validation"
+)
 
 type Exception struct {
 	Unauthorized          bool `json:"unauthorized,omitempty"`

space/space/space/space/space/space/space/models/request_model.go

@@ -1,8 +1,10 @@
 package models
 
 import (
-	"github.com/lib/pq"
+	"mime/multipart"
 	"time"
+
+	"github.com/lib/pq"
 )
 
 type LoginRequest struct {
@@ -106,6 +108,7 @@ type (
 		MaritalStatus *string    `json:"marital_status" validate:"marital_status"`
 		LastEducation *string    `json:"last_education" validate:"last_education"`
 		LastJob       *string    `json:"last_job"`
+		PhoneNumber   *string    `json:"phone_number" validate:"phone_number"`
 	}
 
 	WorshipAndReligiousUnderstandingRequest struct {
@@ -149,4 +152,13 @@ type (
 		AccountID          int64   `json:"account_id"`
 		AchievementOrAward *string `json:"achievement_or_award"` // prestasi atau penghargaan
 	}
+
+	UploadProfileImageRequest struct {
+		AccountID int64
+		File      *multipart.FileHeader
+	}
+
+	UploadProfileImageResponse struct {
+		URL string `json:"url"`
+	}
 )

space/space/space/space/space/space/space/pkg/storage/local.go

@@ -0,0 +1,67 @@
+package storage
+
+import (
+    "context"
+    "fmt"
+    "io"
+    "os"
+    "path/filepath"
+    "strings"
+)
+
+type LocalStorage struct {
+    *BaseStorage
+    basePath string
+    baseURL  string
+}
+
+func NewLocalStorage(basePath, baseURL string) *LocalStorage {
+    return &LocalStorage{
+        BaseStorage: NewBaseStorage(),
+        basePath:    basePath,
+        baseURL:     baseURL,
+    }
+}
+
+func (s *LocalStorage) Upload(ctx context.Context, file io.ReadSeeker, path string) error {
+    fullPath := filepath.Join(s.basePath, path)
+
+    dir := filepath.Dir(fullPath)
+    if err := os.MkdirAll(dir, 0755); err != nil {
+        return err
+    }
+
+    dst, err := os.Create(fullPath)
+    if err != nil {
+        return err
+    }
+    defer dst.Close()
+
+    if _, err := io.Copy(dst, file); err != nil {
+        return err
+    }
+    return nil
+}
+
+func (s *LocalStorage) GetURL(path string) string {
+    return filepath.Join(s.baseURL, path)
+}
+
+func (s *LocalStorage) Delete(ctx context.Context, path string) error {
+    // Contoh input: "http://localhost:8080/storage/users/5/profile/filename.png"
+
+    // Ambil bagian setelah "/storage/"
+    const prefix = "/storage/"
+    idx := strings.Index(path, prefix)
+    if idx == -1 {
+        return os.ErrNotExist
+    }
+
+    relativePath := path[idx+len(prefix):]
+
+    // Gabungkan dengan basePath
+    fullPath := filepath.Join(s.basePath, relativePath)
+    fmt.Println(fullPath)
+
+    return os.Remove(fullPath)
+}

space/space/space/space/space/space/space/pkg/storage/storage.go

@@ -0,0 +1,71 @@
+package storage
+
+import (
+	"context"
+	"errors"
+	"github.com/google/uuid"
+	"io"
+	"path/filepath"
+)
+
+type FileType int
+
+const (
+	ProfileImage FileType = iota
+)
+
+var (
+	ErrInvalidFileType = errors.New("invalid file type")
+	ErrFileTooLarge    = errors.New("file too large")
+	ErrNoFileUploaded  = errors.New("no file uploaded")
+)
+
+type Storage interface {
+	Upload(ctx context.Context, file io.ReadSeeker, path string) error
+	GetURL(path string) string
+	Delete(ctx context.Context, path string) error
+
+	ValidateExtension(fileType FileType, filename string) bool
+	GenerateFilename(originalName string) string
+	GetPath(fileType FileType, identifier string, filename string) string
+}
+
+var (
+	_ Storage = (*LocalStorage)(nil)
+)
+
+type BaseStorage struct {
+	allowedExtensions map[FileType][]string
+}
+
+func NewBaseStorage() *BaseStorage {
+	return &BaseStorage{
+		allowedExtensions: map[FileType][]string{
+			ProfileImage: {".jpg", ".jpeg", ".png", ".webp"},
+		},
+	}
+}
+
+func (bs *BaseStorage) ValidateExtension(fileType FileType, filename string) bool {
+	ext := filepath.Ext(filename)
+	for _, allowed := range bs.allowedExtensions[fileType] {
+		if ext == allowed {
+			return true
+		}
+	}
+	return false
+}
+
+func (bs *BaseStorage) GenerateFilename(originalName string) string {
+	ext := filepath.Ext(originalName)
+	return uuid.New().String() + ext
+}
+
+func (bs *BaseStorage) GetPath(fileType FileType, identifier string, filename string) string {
+	switch fileType {
+	case ProfileImage:
+		return filepath.Join("users", identifier, "profile", filename)
+	default:
+		return filepath.Join("misc", filename)
+	}
+}

space/space/space/space/space/space/space/response/api_response_v2.go

@@ -2,8 +2,8 @@ package response
 
 import (
 	"api.qobiltu.id/models"
+	"api.qobiltu.id/pkg/validation"
 	"api.qobiltu.id/utils"
-	"api.qobiltu.id/validation"
 	"errors"
 	"net/http"
 

space/space/space/space/space/space/space/response/validation.go

@@ -2,7 +2,7 @@ package response
 
 import (
 	"api.qobiltu.id/models"
-	"api.qobiltu.id/validation"
+	"api.qobiltu.id/pkg/validation"
 )
 
 func HandleValidationError(validationErrors []validation.ErrorMessage) error {

space/space/space/space/space/space/space/router/cv_route.go

@@ -7,6 +7,7 @@ func (s *Server) CVRoute() {
 	{
 		routerGroup.POST("/account-details", s.cvController.SaveAccountDetails)
 		routerGroup.GET("/account-details", s.cvController.GetAccountDetails)
+		routerGroup.POST("/account-details/avatar", s.cvController.UploadProfileImage)
 
 		routerGroup.POST("/personality-and-preferences", s.cvController.SavePersonalityAndPreference)
 		routerGroup.GET("/personality-and-preferences", s.cvController.GetPersonalityAndPreference)

space/space/space/space/space/space/space/router/router.go

@@ -18,4 +18,5 @@ func (s *Server) setupRoutes() {
 	// another way to register routes
 	s.HealthCheckRoute()
 	s.CVRoute()
+	s.StorageRoute()
 }

space/space/space/space/space/space/space/router/storage_route.go

@@ -0,0 +1,24 @@
+package router
+
+import (
+	"api.qobiltu.id/middleware"
+	"github.com/gin-gonic/gin"
+	"net/http"
+	"strings"
+)
+
+func (s *Server) StorageRoute() {
+	s.router.GET("/storage/*filepath", func(ctx *gin.Context) {
+		filepath := ctx.Param("filepath")
+
+		// Prevent directory listing
+		if filepath == "" || strings.HasSuffix(filepath, "/") {
+			ctx.AbortWithStatus(http.StatusForbidden)
+			return
+		}
+
+		fs := http.Dir("uploads")
+
+		ctx.FileFromFS(filepath, fs)
+	}).Use(middleware.AuthUser)
+}

space/space/space/space/space/space/space/services/cv_service.go

@@ -1,485 +1,568 @@
 package services
 
 import (
-    "api.qobiltu.id/models"
-    "api.qobiltu.id/repositories"
-    "api.qobiltu.id/response"
-    "api.qobiltu.id/validation"
-    "context"
-    "errors"
-    "gorm.io/gorm"
+	"context"
+	"errors"
+	"strconv"
+
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/pkg/storage"
+	"api.qobiltu.id/pkg/validation"
+	"api.qobiltu.id/repositories"
+	"api.qobiltu.id/response"
+	"gorm.io/gorm"
 )
 
 type CVService interface {
-    SaveAccountDetails(ctx context.Context, req *models.AccountDetailsRequest) (*models.AccountDetails, error)
-    GetAccountDetails(ctx context.Context, id int64) (*models.AccountDetails, error)
-
-    SavePersonalityAndPreference(ctx context.Context, req *models.PersonalityAndPreferenceCVRequest) (*models.PersonalityAndPreferenceCV, error)
-    GetPersonalityAndPreference(ctx context.Context, id int64) (*models.PersonalityAndPreferenceCV, error)
-
-    CreateFamilyMember(ctx context.Context, req *models.FamilyMemberRequest) (*models.FamilyMemberCV, error)
-    UpdateFamilyMember(ctx context.Context, id int64, req *models.FamilyMemberRequest) (*models.FamilyMemberCV, error)
-    ListFamilyMember(ctx context.Context, accountID int64) ([]models.FamilyMemberCV, error)
-    GetFamilyMember(ctx context.Context, id int64) (*models.FamilyMemberCV, error)
-    DeleteFamilyMember(ctx context.Context, id int64) error
-
-    SavePhysicalAndHealth(ctx context.Context, req *models.PhysicalAndHealthRequest) (*models.PhysicalAndHealthCV, error)
-    GetPhysicalAndHealth(ctx context.Context, id int64) (*models.PhysicalAndHealthCV, error)
-
-    SaveWorshipAndReligiousUnderstanding(ctx context.Context, req *models.WorshipAndReligiousUnderstandingRequest) (*models.WorshipAndReligiousUnderstandingCV, error)
-    GetWorshipAndReligiousUnderstanding(ctx context.Context, id int64) (*models.WorshipAndReligiousUnderstandingCV, error)
-
-    CreateEducation(ctx context.Context, req *models.EducationRequest) (*models.EducationCV, error)
-    UpdateEducation(ctx context.Context, id int64, req *models.EducationRequest) (*models.EducationCV, error)
-    ListEducation(ctx context.Context, accountID int64) ([]models.EducationCV, error)
-    GetEducation(ctx context.Context, id int64) (*models.EducationCV, error)
-    DeleteEducation(ctx context.Context, id int64) error
-
-    CreateJob(ctx context.Context, req *models.JobRequest) (*models.JobCV, error)
-    UpdateJob(ctx context.Context, id int64, req *models.JobRequest) (*models.JobCV, error)
-    ListJob(ctx context.Context, accountID int64) ([]models.JobCV, error)
-    GetJob(ctx context.Context, id int64) (*models.JobCV, error)
-    DeleteJob(ctx context.Context, id int64) error
-
-    CreateAchievement(ctx context.Context, req *models.AchievementRequest) (*models.AchievementCV, error)
-    UpdateAchievement(ctx context.Context, id int64, req *models.AchievementRequest) (*models.AchievementCV, error)
-    ListAchievement(ctx context.Context, accountID int64) ([]models.AchievementCV, error)
-    GetAchievement(ctx context.Context, id int64) (*models.AchievementCV, error)
-    DeleteAchievement(ctx context.Context, id int64) error
+	SaveAccountDetails(ctx context.Context, req *models.AccountDetailsRequest) (*models.AccountDetails, error)
+	GetAccountDetails(ctx context.Context, id int64) (*models.AccountDetails, error)
+
+	SavePersonalityAndPreference(ctx context.Context, req *models.PersonalityAndPreferenceCVRequest) (*models.PersonalityAndPreferenceCV, error)
+	GetPersonalityAndPreference(ctx context.Context, id int64) (*models.PersonalityAndPreferenceCV, error)
+
+	CreateFamilyMember(ctx context.Context, req *models.FamilyMemberRequest) (*models.FamilyMemberCV, error)
+	UpdateFamilyMember(ctx context.Context, id int64, req *models.FamilyMemberRequest) (*models.FamilyMemberCV, error)
+	ListFamilyMember(ctx context.Context, accountID int64) ([]models.FamilyMemberCV, error)
+	GetFamilyMember(ctx context.Context, id int64) (*models.FamilyMemberCV, error)
+	DeleteFamilyMember(ctx context.Context, id int64) error
+
+	SavePhysicalAndHealth(ctx context.Context, req *models.PhysicalAndHealthRequest) (*models.PhysicalAndHealthCV, error)
+	GetPhysicalAndHealth(ctx context.Context, id int64) (*models.PhysicalAndHealthCV, error)
+
+	SaveWorshipAndReligiousUnderstanding(ctx context.Context, req *models.WorshipAndReligiousUnderstandingRequest) (*models.WorshipAndReligiousUnderstandingCV, error)
+	GetWorshipAndReligiousUnderstanding(ctx context.Context, id int64) (*models.WorshipAndReligiousUnderstandingCV, error)
+
+	CreateEducation(ctx context.Context, req *models.EducationRequest) (*models.EducationCV, error)
+	UpdateEducation(ctx context.Context, id int64, req *models.EducationRequest) (*models.EducationCV, error)
+	ListEducation(ctx context.Context, accountID int64) ([]models.EducationCV, error)
+	GetEducation(ctx context.Context, id int64) (*models.EducationCV, error)
+	DeleteEducation(ctx context.Context, id int64) error
+
+	CreateJob(ctx context.Context, req *models.JobRequest) (*models.JobCV, error)
+	UpdateJob(ctx context.Context, id int64, req *models.JobRequest) (*models.JobCV, error)
+	ListJob(ctx context.Context, accountID int64) ([]models.JobCV, error)
+	GetJob(ctx context.Context, id int64) (*models.JobCV, error)
+	DeleteJob(ctx context.Context, id int64) error
+
+	CreateAchievement(ctx context.Context, req *models.AchievementRequest) (*models.AchievementCV, error)
+	UpdateAchievement(ctx context.Context, id int64, req *models.AchievementRequest) (*models.AchievementCV, error)
+	ListAchievement(ctx context.Context, accountID int64) ([]models.AchievementCV, error)
+	GetAchievement(ctx context.Context, id int64) (*models.AchievementCV, error)
+	DeleteAchievement(ctx context.Context, id int64) error
+
+	UploadProfileImage(ctx context.Context, req *models.UploadProfileImageRequest) (*models.UploadProfileImageResponse, error)
 }
 
 type cvService struct {
-    cvRepository repositories.CVRepository
+	cvRepository repositories.CVRepository
+	storage      storage.Storage
 }
 
-func NewCVService(cvRepository repositories.CVRepository) CVService {
-    return &cvService{
-        cvRepository: cvRepository,
-    }
+func NewCVService(cvRepository repositories.CVRepository, storage storage.Storage) CVService {
+	return &cvService{
+		cvRepository: cvRepository,
+		storage:      storage,
+	}
 }
 
 func (s *cvService) SaveAccountDetails(ctx context.Context, req *models.AccountDetailsRequest) (*models.AccountDetails, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    // Ambil data lama jika ada
-    accountDetails, err := s.cvRepository.GetAccountDetailsByAccountID(ctx, req.AccountID)
-    if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
-        return nil, response.HandleGormError(err, "Internal Server Error")
-    }
-
-    // Apply perubahan
-    if accountDetails == nil {
-        accountDetails = &models.AccountDetails{}
-    }
-
-    accountDetails.AccountID = uint(req.AccountID)
-    accountDetails.FullName = req.FullName
-    accountDetails.Gender = req.Gender
-    accountDetails.DateOfBirth = req.DateOfBirth
-    accountDetails.PlaceOfBirth = req.PlaceOfBirth
-    accountDetails.Domicile = req.Domicile
-    accountDetails.MaritalStatus = req.MaritalStatus
-    accountDetails.LastEducation = req.LastEducation
-    accountDetails.LastJob = req.LastJob
-
-    // Simpan data
-    res, err := s.cvRepository.SaveAccountDetails(ctx, accountDetails)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Internal Server Error")
-    }
-
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	// Ambil data lama jika ada
+	accountDetails, err := s.cvRepository.GetAccountDetailsByAccountID(ctx, req.AccountID)
+	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	// Apply perubahan
+	if accountDetails == nil {
+		accountDetails = &models.AccountDetails{}
+	}
+
+	accountDetails.AccountID = uint(req.AccountID)
+	accountDetails.FullName = req.FullName
+	accountDetails.Gender = req.Gender
+	accountDetails.DateOfBirth = req.DateOfBirth
+	accountDetails.PlaceOfBirth = req.PlaceOfBirth
+	accountDetails.Domicile = req.Domicile
+	accountDetails.MaritalStatus = req.MaritalStatus
+	accountDetails.LastEducation = req.LastEducation
+	accountDetails.LastJob = req.LastJob
+
+	if req.PhoneNumber != nil {
+		sanitizedPhone := validation.SanitizePhoneNumber(*req.PhoneNumber)
+		accountDetails.PhoneNumber = &sanitizedPhone
+	}
+
+	// Simpan data
+	res, err := s.cvRepository.SaveAccountDetails(ctx, accountDetails)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	return res, nil
 }
 
 func (s *cvService) GetAccountDetails(ctx context.Context, id int64) (*models.AccountDetails, error) {
-    res, err := s.cvRepository.GetAccountDetailsByAccountID(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data diri tidak ditemukan")
-    }
-    return res, nil
+	res, err := s.cvRepository.GetAccountDetailsByAccountID(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data diri tidak ditemukan")
+	}
+	return res, nil
 }
 
 func (s *cvService) SavePersonalityAndPreference(ctx context.Context, req *models.PersonalityAndPreferenceCVRequest) (*models.PersonalityAndPreferenceCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    // Ambil data lama jika ada
-    personalityAndPreference, err := s.cvRepository.GetPersonalityAndPreferenceByAccountID(ctx, req.AccountID)
-    if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
-        return nil, response.HandleGormError(err, "Internal Server Error")
-    }
-
-    // Apply perubahan
-    if personalityAndPreference == nil {
-        personalityAndPreference = &models.PersonalityAndPreferenceCV{}
-    }
-
-    personalityAndPreference.AccountID = req.AccountID
-    personalityAndPreference.PositiveTraits = req.PositiveTraits
-    personalityAndPreference.NegativeTraits = req.NegativeTraits
-    personalityAndPreference.Hobbies = req.Hobbies
-    personalityAndPreference.LifeGoals = req.LifeGoals
-    personalityAndPreference.DailyActivities = req.DailyActivities
-    personalityAndPreference.LeisureActivities = req.LeisureActivities
-    personalityAndPreference.Likes = req.Likes
-    personalityAndPreference.Dislikes = req.Dislikes
-    personalityAndPreference.StressHandling = req.StressHandling
-    personalityAndPreference.AngerTriggers = req.AngerTriggers
-    personalityAndPreference.FavoriteFoodAndDrinks = req.FavoriteFoodAndDrinks
-    personalityAndPreference.CanCook = req.CanCook
-    personalityAndPreference.TypesOfDishesCooked = req.TypesOfDishesCooked
-    personalityAndPreference.MonthlyExpenses = req.MonthlyExpenses
-
-    res, err := s.cvRepository.SavePersonalityAndPreference(ctx, personalityAndPreference)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Internal Server Error")
-    }
-
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	// Ambil data lama jika ada
+	personalityAndPreference, err := s.cvRepository.GetPersonalityAndPreferenceByAccountID(ctx, req.AccountID)
+	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	// Apply perubahan
+	if personalityAndPreference == nil {
+		personalityAndPreference = &models.PersonalityAndPreferenceCV{}
+	}
+
+	personalityAndPreference.AccountID = req.AccountID
+	personalityAndPreference.PositiveTraits = req.PositiveTraits
+	personalityAndPreference.NegativeTraits = req.NegativeTraits
+	personalityAndPreference.Hobbies = req.Hobbies
+	personalityAndPreference.LifeGoals = req.LifeGoals
+	personalityAndPreference.DailyActivities = req.DailyActivities
+	personalityAndPreference.LeisureActivities = req.LeisureActivities
+	personalityAndPreference.Likes = req.Likes
+	personalityAndPreference.Dislikes = req.Dislikes
+	personalityAndPreference.StressHandling = req.StressHandling
+	personalityAndPreference.AngerTriggers = req.AngerTriggers
+	personalityAndPreference.FavoriteFoodAndDrinks = req.FavoriteFoodAndDrinks
+	personalityAndPreference.CanCook = req.CanCook
+	personalityAndPreference.TypesOfDishesCooked = req.TypesOfDishesCooked
+	personalityAndPreference.MonthlyExpenses = req.MonthlyExpenses
+
+	res, err := s.cvRepository.SavePersonalityAndPreference(ctx, personalityAndPreference)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	return res, nil
 }
 
 func (s *cvService) GetPersonalityAndPreference(ctx context.Context, id int64) (*models.PersonalityAndPreferenceCV, error) {
-    res, err := s.cvRepository.GetPersonalityAndPreferenceByAccountID(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Internal Server Error")
-    }
+	res, err := s.cvRepository.GetPersonalityAndPreferenceByAccountID(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
 
-    return res, nil
+	return res, nil
 }
 
 func (s *cvService) CreateFamilyMember(ctx context.Context, req *models.FamilyMemberRequest) (*models.FamilyMemberCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    // Mapping request ke model
-    familyMember := &models.FamilyMemberCV{
-        AccountID:     req.AccountID,
-        Role:          req.Role,
-        Status:        req.Status,
-        Religion:      req.Religion,
-        Job:           req.Job,
-        LastEducation: req.LastEducation,
-        Age:           req.Age,
-    }
-
-    // Simpan ke repository
-    res, err := s.cvRepository.SaveFamilyMember(ctx, familyMember)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal menyimpan anggota keluarga")
-    }
-
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	// Mapping request ke model
+	familyMember := &models.FamilyMemberCV{
+		AccountID:     req.AccountID,
+		Role:          req.Role,
+		Status:        req.Status,
+		Religion:      req.Religion,
+		Job:           req.Job,
+		LastEducation: req.LastEducation,
+		Age:           req.Age,
+	}
+
+	// Simpan ke repository
+	res, err := s.cvRepository.SaveFamilyMember(ctx, familyMember)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal menyimpan anggota keluarga")
+	}
+
+	return res, nil
 }
 
 func (s *cvService) ListFamilyMember(ctx context.Context, accountID int64) ([]models.FamilyMemberCV, error) {
-    list, err := s.cvRepository.ListFamilyMember(ctx, accountID)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal mengambil daftar anggota keluarga")
-    }
-    return list, nil
+	list, err := s.cvRepository.ListFamilyMember(ctx, accountID)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal mengambil daftar anggota keluarga")
+	}
+	return list, nil
 }
 
 func (s *cvService) GetFamilyMember(ctx context.Context, id int64) (*models.FamilyMemberCV, error) {
-    res, err := s.cvRepository.GetFamilyMember(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data anggota keluarga tidak ditemukan")
-    }
-    return res, nil
+	res, err := s.cvRepository.GetFamilyMember(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data anggota keluarga tidak ditemukan")
+	}
+	return res, nil
 }
 
 func (s *cvService) DeleteFamilyMember(ctx context.Context, id int64) error {
-    err := s.cvRepository.DeleteFamilyMember(ctx, id)
-    if err != nil {
-        return response.HandleGormError(err, "Gagal menghapus anggota keluarga")
-    }
-    return nil
+	err := s.cvRepository.DeleteFamilyMember(ctx, id)
+	if err != nil {
+		return response.HandleGormError(err, "Gagal menghapus anggota keluarga")
+	}
+	return nil
 }
 
 func (s *cvService) UpdateFamilyMember(ctx context.Context, id int64, req *models.FamilyMemberRequest) (*models.FamilyMemberCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    existing, err := s.cvRepository.GetFamilyMember(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data anggota keluarga tidak ditemukan")
-    }
-
-    existing.Role = req.Role
-    existing.Status = req.Status
-    existing.Religion = req.Religion
-    existing.Job = req.Job
-    existing.LastEducation = req.LastEducation
-    existing.Age = req.Age
-
-    updated, err := s.cvRepository.SaveFamilyMember(ctx, existing)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal memperbarui anggota keluarga")
-    }
-
-    return updated, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	existing, err := s.cvRepository.GetFamilyMember(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data anggota keluarga tidak ditemukan")
+	}
+
+	existing.Role = req.Role
+	existing.Status = req.Status
+	existing.Religion = req.Religion
+	existing.Job = req.Job
+	existing.LastEducation = req.LastEducation
+	existing.Age = req.Age
+
+	updated, err := s.cvRepository.SaveFamilyMember(ctx, existing)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal memperbarui anggota keluarga")
+	}
+
+	return updated, nil
 }
 
 func (s *cvService) SavePhysicalAndHealth(ctx context.Context, req *models.PhysicalAndHealthRequest) (*models.PhysicalAndHealthCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    // Cek apakah data sudah ada berdasarkan account_id
-    existing, err := s.cvRepository.GetPhysicalAndHealthByAccountID(ctx, req.AccountID)
-    if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
-        return nil, response.HandleGormError(err, "Terjadi kesalahan saat mengambil data fisik dan kesehatan")
-    }
-
-    // Jika belum ada, buat objek baru
-    if existing == nil {
-        existing = &models.PhysicalAndHealthCV{}
-    }
-
-    // Mapping field dari request
-    existing.AccountID = req.AccountID
-    existing.HeightInCm = req.HeightInCm
-    existing.WeightInKg = req.WeightInKg
-    existing.BodyShape = req.BodyShape
-    existing.SkinColor = req.SkinColor
-    existing.HairType = req.HairType
-    existing.MedicalHistory = req.MedicalHistory
-    existing.PhysicalDisorder = req.PhysicalDisorder
-    existing.PhysicalTraits = req.PhysicalTraits
-
-    // Simpan data
-    res, err := s.cvRepository.SavePhysicalAndHealth(ctx, existing)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal menyimpan data fisik dan kesehatan")
-    }
-
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	// Cek apakah data sudah ada berdasarkan account_id
+	existing, err := s.cvRepository.GetPhysicalAndHealthByAccountID(ctx, req.AccountID)
+	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
+		return nil, response.HandleGormError(err, "Terjadi kesalahan saat mengambil data fisik dan kesehatan")
+	}
+
+	// Jika belum ada, buat objek baru
+	if existing == nil {
+		existing = &models.PhysicalAndHealthCV{}
+	}
+
+	// Mapping field dari request
+	existing.AccountID = req.AccountID
+	existing.HeightInCm = req.HeightInCm
+	existing.WeightInKg = req.WeightInKg
+	existing.BodyShape = req.BodyShape
+	existing.SkinColor = req.SkinColor
+	existing.HairType = req.HairType
+	existing.MedicalHistory = req.MedicalHistory
+	existing.PhysicalDisorder = req.PhysicalDisorder
+	existing.PhysicalTraits = req.PhysicalTraits
+
+	// Simpan data
+	res, err := s.cvRepository.SavePhysicalAndHealth(ctx, existing)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal menyimpan data fisik dan kesehatan")
+	}
+
+	return res, nil
 }
 
 func (s *cvService) GetPhysicalAndHealth(ctx context.Context, id int64) (*models.PhysicalAndHealthCV, error) {
-    res, err := s.cvRepository.GetPhysicalAndHealthByAccountID(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data fisik dan kesehatan tidak ditemukan")
-    }
-    return res, nil
+	res, err := s.cvRepository.GetPhysicalAndHealthByAccountID(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data fisik dan kesehatan tidak ditemukan")
+	}
+	return res, nil
 }
 
 func (s *cvService) SaveWorshipAndReligiousUnderstanding(ctx context.Context, req *models.WorshipAndReligiousUnderstandingRequest) (*models.WorshipAndReligiousUnderstandingCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    // Cek apakah data sudah ada berdasarkan account_id
-    worshipAndReligiousUnderstanding, err := s.cvRepository.GetWorshipAndReligiousUnderstandingByAccountID(ctx, req.AccountID)
-    if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
-        return nil, response.HandleGormError(err, "Terjadi kesalahan saat mengambil data agama dan pemahaman agama")
-    }
-
-    // Jika belum ada, buat objek baru
-    if worshipAndReligiousUnderstanding == nil {
-        worshipAndReligiousUnderstanding = &models.WorshipAndReligiousUnderstandingCV{}
-    }
-
-    // Mapping field dari request
-    worshipAndReligiousUnderstanding.AccountID = req.AccountID
-    worshipAndReligiousUnderstanding.ObligatoryPrayer = req.ObligatoryPrayer
-    worshipAndReligiousUnderstanding.CongregationalPrayer = req.CongregationalPrayer
-    worshipAndReligiousUnderstanding.TahajjudPrayer = req.TahajjudPrayer
-    worshipAndReligiousUnderstanding.DhuhaPrayer = req.DhuhaPrayer
-    worshipAndReligiousUnderstanding.QuranMemorization = req.QuranMemorization
-    worshipAndReligiousUnderstanding.QuranReadingAbility = req.QuranReadingAbility
-    worshipAndReligiousUnderstanding.DaudFasting = req.DaudFasting
-    worshipAndReligiousUnderstanding.AyyamulBidhFasting = req.AyyamulBidhFasting
-    worshipAndReligiousUnderstanding.HajjOrUmrah = req.HajjOrUmrah
-    worshipAndReligiousUnderstanding.ListeningToMusic = req.ListeningToMusic
-    worshipAndReligiousUnderstanding.OpinionOnIkhtilat = req.OpinionOnIkhtilat
-    worshipAndReligiousUnderstanding.OpinionOnTouchingNonMahram = req.OpinionOnTouchingNonMahram
-    worshipAndReligiousUnderstanding.OpinionOnVeil = req.OpinionOnVeil
-    worshipAndReligiousUnderstanding.WeeklyReligiousStudies = req.WeeklyReligiousStudies
-    worshipAndReligiousUnderstanding.FollowedUstadz = req.FollowedUstadz
-
-    // Simpan data
-    res, err := s.cvRepository.SaveWorshipAndReligiousUnderstanding(ctx, worshipAndReligiousUnderstanding)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Internal Server Error")
-    }
-
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	// Cek apakah data sudah ada berdasarkan account_id
+	worshipAndReligiousUnderstanding, err := s.cvRepository.GetWorshipAndReligiousUnderstandingByAccountID(ctx, req.AccountID)
+	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
+		return nil, response.HandleGormError(err, "Terjadi kesalahan saat mengambil data agama dan pemahaman agama")
+	}
+
+	// Jika belum ada, buat objek baru
+	if worshipAndReligiousUnderstanding == nil {
+		worshipAndReligiousUnderstanding = &models.WorshipAndReligiousUnderstandingCV{}
+	}
+
+	// Mapping field dari request
+	worshipAndReligiousUnderstanding.AccountID = req.AccountID
+	worshipAndReligiousUnderstanding.ObligatoryPrayer = req.ObligatoryPrayer
+	worshipAndReligiousUnderstanding.CongregationalPrayer = req.CongregationalPrayer
+	worshipAndReligiousUnderstanding.TahajjudPrayer = req.TahajjudPrayer
+	worshipAndReligiousUnderstanding.DhuhaPrayer = req.DhuhaPrayer
+	worshipAndReligiousUnderstanding.QuranMemorization = req.QuranMemorization
+	worshipAndReligiousUnderstanding.QuranReadingAbility = req.QuranReadingAbility
+	worshipAndReligiousUnderstanding.DaudFasting = req.DaudFasting
+	worshipAndReligiousUnderstanding.AyyamulBidhFasting = req.AyyamulBidhFasting
+	worshipAndReligiousUnderstanding.HajjOrUmrah = req.HajjOrUmrah
+	worshipAndReligiousUnderstanding.ListeningToMusic = req.ListeningToMusic
+	worshipAndReligiousUnderstanding.OpinionOnIkhtilat = req.OpinionOnIkhtilat
+	worshipAndReligiousUnderstanding.OpinionOnTouchingNonMahram = req.OpinionOnTouchingNonMahram
+	worshipAndReligiousUnderstanding.OpinionOnVeil = req.OpinionOnVeil
+	worshipAndReligiousUnderstanding.WeeklyReligiousStudies = req.WeeklyReligiousStudies
+	worshipAndReligiousUnderstanding.FollowedUstadz = req.FollowedUstadz
+
+	// Simpan data
+	res, err := s.cvRepository.SaveWorshipAndReligiousUnderstanding(ctx, worshipAndReligiousUnderstanding)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	return res, nil
 }
 
 func (s *cvService) GetWorshipAndReligiousUnderstanding(ctx context.Context, id int64) (*models.WorshipAndReligiousUnderstandingCV, error) {
-    res, err := s.cvRepository.GetWorshipAndReligiousUnderstandingByAccountID(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data agama dan pemahaman agama tidak ditemukan")
-    }
-    return res, nil
+	res, err := s.cvRepository.GetWorshipAndReligiousUnderstandingByAccountID(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data agama dan pemahaman agama tidak ditemukan")
+	}
+	return res, nil
 }
 
 func (s *cvService) CreateEducation(ctx context.Context, req *models.EducationRequest) (*models.EducationCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    edu := &models.EducationCV{
-        AccountID:          req.AccountID,
-        LastEducation:      req.LastEducation,
-        EducationInstitute: req.EducationInstitute,
-        EducationMajor:     req.EducationMajor,
-        YearStart:          req.YearStart,
-        YearGraduate:       req.YearGraduate,
-    }
-
-    res, err := s.cvRepository.SaveEducation(ctx, edu)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal menambahkan data pendidikan")
-    }
-
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	edu := &models.EducationCV{
+		AccountID:          req.AccountID,
+		LastEducation:      req.LastEducation,
+		EducationInstitute: req.EducationInstitute,
+		EducationMajor:     req.EducationMajor,
+		YearStart:          req.YearStart,
+		YearGraduate:       req.YearGraduate,
+	}
+
+	res, err := s.cvRepository.SaveEducation(ctx, edu)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal menambahkan data pendidikan")
+	}
+
+	return res, nil
 }
 
 func (s *cvService) UpdateEducation(ctx context.Context, id int64, req *models.EducationRequest) (*models.EducationCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    edu, err := s.cvRepository.GetEducation(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data pendidikan tidak ditemukan")
-    }
-
-    edu.LastEducation = req.LastEducation
-    edu.EducationInstitute = req.EducationInstitute
-    edu.EducationMajor = req.EducationMajor
-    edu.YearStart = req.YearStart
-    edu.YearGraduate = req.YearGraduate
-
-    res, err := s.cvRepository.SaveEducation(ctx, edu)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal memperbarui data pendidikan")
-    }
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	edu, err := s.cvRepository.GetEducation(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data pendidikan tidak ditemukan")
+	}
+
+	edu.LastEducation = req.LastEducation
+	edu.EducationInstitute = req.EducationInstitute
+	edu.EducationMajor = req.EducationMajor
+	edu.YearStart = req.YearStart
+	edu.YearGraduate = req.YearGraduate
+
+	res, err := s.cvRepository.SaveEducation(ctx, edu)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal memperbarui data pendidikan")
+	}
+	return res, nil
 }
 
 func (s *cvService) ListEducation(ctx context.Context, accountID int64) ([]models.EducationCV, error) {
-    return s.cvRepository.ListEducation(ctx, accountID)
+	return s.cvRepository.ListEducation(ctx, accountID)
 }
 
 func (s *cvService) GetEducation(ctx context.Context, id int64) (*models.EducationCV, error) {
-    edu, err := s.cvRepository.GetEducation(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data pendidikan tidak ditemukan")
-    }
-    return edu, nil
+	edu, err := s.cvRepository.GetEducation(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data pendidikan tidak ditemukan")
+	}
+	return edu, nil
 }
 
 func (s *cvService) DeleteEducation(ctx context.Context, id int64) error {
-    return s.cvRepository.DeleteEducation(ctx, id)
+	return s.cvRepository.DeleteEducation(ctx, id)
 }
 
 func (s *cvService) CreateJob(ctx context.Context, req *models.JobRequest) (*models.JobCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    job := &models.JobCV{
-        AccountID:          req.AccountID,
-        InstitutionName:    req.InstitutionName,
-        CurrentJob:         req.CurrentJob,
-        YearStartedWorking: req.YearStartedWorking,
-        MonthlyIncome:      req.MonthlyIncome,
-        IncomeSources:      req.IncomeSources,
-    }
-    res, err := s.cvRepository.SaveJob(ctx, job)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal menambahkan data pekerjaan")
-    }
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	job := &models.JobCV{
+		AccountID:          req.AccountID,
+		InstitutionName:    req.InstitutionName,
+		CurrentJob:         req.CurrentJob,
+		YearStartedWorking: req.YearStartedWorking,
+		MonthlyIncome:      req.MonthlyIncome,
+		IncomeSources:      req.IncomeSources,
+	}
+	res, err := s.cvRepository.SaveJob(ctx, job)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal menambahkan data pekerjaan")
+	}
+	return res, nil
 }
 
 func (s *cvService) UpdateJob(ctx context.Context, id int64, req *models.JobRequest) (*models.JobCV, error) {
-    if err := validation.Validate(req); err != nil {
-        return nil, response.HandleValidationError(err)
-    }
-
-    job, err := s.cvRepository.GetJob(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data pekerjaan tidak ditemukan")
-    }
-
-    job.InstitutionName = req.InstitutionName
-    job.CurrentJob = req.CurrentJob
-    job.YearStartedWorking = req.YearStartedWorking
-    job.MonthlyIncome = req.MonthlyIncome
-    job.IncomeSources = req.IncomeSources
-
-    res, err := s.cvRepository.SaveJob(ctx, job)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal memperbarui data pekerjaan")
-    }
-    return res, nil
+	if err := validation.Validate(req); err != nil {
+		return nil, response.HandleValidationError(err)
+	}
+
+	job, err := s.cvRepository.GetJob(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data pekerjaan tidak ditemukan")
+	}
+
+	job.InstitutionName = req.InstitutionName
+	job.CurrentJob = req.CurrentJob
+	job.YearStartedWorking = req.YearStartedWorking
+	job.MonthlyIncome = req.MonthlyIncome
+	job.IncomeSources = req.IncomeSources
+
+	res, err := s.cvRepository.SaveJob(ctx, job)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal memperbarui data pekerjaan")
+	}
+	return res, nil
 }
 
 func (s *cvService) ListJob(ctx context.Context, accountID int64) ([]models.JobCV, error) {
-    return s.cvRepository.ListJob(ctx, accountID)
+	return s.cvRepository.ListJob(ctx, accountID)
 }
 
 func (s *cvService) GetJob(ctx context.Context, id int64) (*models.JobCV, error) {
-    job, err := s.cvRepository.GetJob(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data pekerjaan tidak ditemukan")
-    }
-    return job, nil
+	job, err := s.cvRepository.GetJob(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data pekerjaan tidak ditemukan")
+	}
+	return job, nil
 }
 
 func (s *cvService) DeleteJob(ctx context.Context, id int64) error {
-    return s.cvRepository.DeleteJob(ctx, id)
+	return s.cvRepository.DeleteJob(ctx, id)
 }
 
 func (s *cvService) CreateAchievement(ctx context.Context, req *models.AchievementRequest) (*models.AchievementCV, error) {
-    ach := &models.AchievementCV{
-        AccountID:          req.AccountID,
-        AchievementOrAward: req.AchievementOrAward,
-    }
-    res, err := s.cvRepository.SaveAchievement(ctx, ach)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal menambahkan data prestasi")
-    }
-
-    return res, nil
+	ach := &models.AchievementCV{
+		AccountID:          req.AccountID,
+		AchievementOrAward: req.AchievementOrAward,
+	}
+	res, err := s.cvRepository.SaveAchievement(ctx, ach)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal menambahkan data prestasi")
+	}
+
+	return res, nil
 }
 
 func (s *cvService) UpdateAchievement(ctx context.Context, id int64, req *models.AchievementRequest) (*models.AchievementCV, error) {
-    ach, err := s.cvRepository.GetAchievement(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data prestasi tidak ditemukan")
-    }
+	ach, err := s.cvRepository.GetAchievement(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data prestasi tidak ditemukan")
+	}
 
-    ach.AchievementOrAward = req.AchievementOrAward
+	ach.AchievementOrAward = req.AchievementOrAward
 
-    res, err := s.cvRepository.SaveAchievement(ctx, ach)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Gagal memperbarui data prestasi")
-    }
+	res, err := s.cvRepository.SaveAchievement(ctx, ach)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Gagal memperbarui data prestasi")
+	}
 
-    return res, nil
+	return res, nil
 }
 
 func (s *cvService) ListAchievement(ctx context.Context, accountID int64) ([]models.AchievementCV, error) {
-    return s.cvRepository.ListAchievement(ctx, accountID)
+	return s.cvRepository.ListAchievement(ctx, accountID)
 }
 
 func (s *cvService) GetAchievement(ctx context.Context, id int64) (*models.AchievementCV, error) {
-    ach, err := s.cvRepository.GetAchievement(ctx, id)
-    if err != nil {
-        return nil, response.HandleGormError(err, "Data prestasi tidak ditemukan")
-    }
-    return ach, nil
+	ach, err := s.cvRepository.GetAchievement(ctx, id)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Data prestasi tidak ditemukan")
+	}
+	return ach, nil
 }
 
 func (s *cvService) DeleteAchievement(ctx context.Context, id int64) error {
-    return s.cvRepository.DeleteAchievement(ctx, id)
+	return s.cvRepository.DeleteAchievement(ctx, id)
+}
+
+func (s *cvService) UploadProfileImage(ctx context.Context, req *models.UploadProfileImageRequest) (*models.UploadProfileImageResponse, error) {
+	if req.File == nil {
+		return nil, models.Exception{
+			BadRequest: true,
+			Message:    "No file uploaded",
+			Err:        storage.ErrNoFileUploaded,
+		}
+	}
+
+	var maxFileSize int64 = 5 << 20 // 5MB
+
+	if req.File.Size > maxFileSize {
+		return nil, models.Exception{
+			BadRequest: true,
+			Message:    "File too large, max size is 5MB",
+			Err:        storage.ErrFileTooLarge,
+		}
+	}
+
+	if !s.storage.ValidateExtension(storage.ProfileImage, req.File.Filename) {
+		return nil, models.Exception{
+			BadRequest: true,
+			Message:    "Invalid file extension",
+			Err:        storage.ErrInvalidFileType,
+		}
+	}
+
+	accountDetails, err := s.cvRepository.GetAccountDetailsByAccountID(ctx, req.AccountID)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	filename := s.storage.GenerateFilename(req.File.Filename)
+	path := s.storage.GetPath(storage.ProfileImage, strconv.Itoa(int(req.AccountID)), filename)
+
+	file, err := req.File.Open()
+	if err != nil {
+		return nil, models.Exception{
+			InternalServerError: true,
+			Message:             "Internal Server Error",
+			Err:                 err,
+		}
+	}
+	defer file.Close()
+
+	if err := s.storage.Upload(ctx, file, path); err != nil {
+		return nil, models.Exception{
+			InternalServerError: true,
+			Message:             "Internal Server Error",
+			Err:                 err,
+		}
+	}
+
+	// remove old avatar
+	if accountDetails.Avatar != nil {
+		s.storage.Delete(ctx, *accountDetails.Avatar)
+	}
+
+	url := s.storage.GetURL(path)
+	accountDetails.Avatar = &url
+
+	_, err = s.cvRepository.SaveAccountDetails(ctx, accountDetails)
+	if err != nil {
+		return nil, response.HandleGormError(err, "Internal Server Error")
+	}
+
+	return &models.UploadProfileImageResponse{
+		URL: url,
+	}, nil
 }

space/space/space/space/space/space/space/services/email_verification_service.go

@@ -1,101 +1,101 @@
 package services
 
 import (
-	"api.qobiltu.id/utils"
-	"api.qobiltu.id/worker"
-	"context"
-	"github.com/hibiken/asynq"
-	"strconv"
-	"time"
+    "api.qobiltu.id/pkg/worker"
+    "api.qobiltu.id/utils"
+    "context"
+    "github.com/hibiken/asynq"
+    "strconv"
+    "time"
 
-	"api.qobiltu.id/config"
-	"api.qobiltu.id/models"
-	"api.qobiltu.id/repositories"
-	uuid "github.com/satori/go.uuid"
+    "api.qobiltu.id/config"
+    "api.qobiltu.id/models"
+    "api.qobiltu.id/repositories"
+    uuid "github.com/satori/go.uuid"
 )
 
 type EmailVerificationService struct {
-	Service[models.EmailVerification, models.EmailVerification]
+    Service[models.EmailVerification, models.EmailVerification]
 }
 
 func (s *EmailVerificationService) Create() {
-	accountRepo := repositories.GetAccountById(s.Constructor.AccountID)
-	if accountRepo.NoRecord {
-		s.Error = accountRepo.RowsError
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "There is no account data with given credentials!"
-		return
-	}
+    accountRepo := repositories.GetAccountById(s.Constructor.AccountID)
+    if accountRepo.NoRecord {
+        s.Error = accountRepo.RowsError
+        s.Exception.DataNotFound = true
+        s.Exception.Message = "There is no account data with given credentials!"
+        return
+    }
 
-	token, err := utils.GenerateToken()
-	if err != nil {
-		s.Error = err
-		s.Exception.InternalServerError = true
-		s.Exception.Message = "failed to generate token for email verification"
-		return
-	}
+    token, err := utils.GenerateToken()
+    if err != nil {
+        s.Error = err
+        s.Exception.InternalServerError = true
+        s.Exception.Message = "failed to generate token for email verification"
+        return
+    }
 
-	remainingTime := time.Duration(config.EMAIL_VERIFICATION_DURATION) * time.Hour
-	dueTime := CalculateDueTime(remainingTime)
-	s.Constructor.UUID = uuid.NewV4()
-	repo := repositories.CreateEmailVerification(s.Constructor.UUID, s.Constructor.AccountID, dueTime, uint(token))
-	s.Error = repo.RowsError
-	s.Result = repo.Result
-	if s.Error != nil {
-		return
-	}
+    remainingTime := time.Duration(config.EMAIL_VERIFICATION_DURATION) * time.Hour
+    dueTime := CalculateDueTime(remainingTime)
+    s.Constructor.UUID = uuid.NewV4()
+    repo := repositories.CreateEmailVerification(s.Constructor.UUID, s.Constructor.AccountID, dueTime, uint(token))
+    s.Error = repo.RowsError
+    s.Result = repo.Result
+    if s.Error != nil {
+        return
+    }
 
-	err = worker.AsyncTaskDistributor.DistributeTaskSendVerifyEmail(
-		context.Background(),
-		&worker.PayloadSendVerifyEmail{
-			EmailAddress:        accountRepo.Result.Email,
-			VerificationCode:    strconv.Itoa(int(token)),
-			ExpirationInMinutes: int(remainingTime.Minutes()),
-			Subject:             worker.TaskSendVerifyEmailSubject,
-		},
-		[]asynq.Option{
-			asynq.MaxRetry(worker.TaskSendVerifyEmailMaxRetry),
-			asynq.Queue(worker.Critical),
-		}...)
-	if err != nil {
-		s.Error = err
-		s.Exception.InternalServerError = true
-		s.Exception.Message = "failed to send email verification"
-		return
-	}
+    err = worker.AsyncTaskDistributor.DistributeTaskSendVerifyEmail(
+        context.Background(),
+        &worker.PayloadSendVerifyEmail{
+            EmailAddress:        accountRepo.Result.Email,
+            VerificationCode:    strconv.Itoa(int(token)),
+            ExpirationInMinutes: int(remainingTime.Minutes()),
+            Subject:             worker.TaskSendVerifyEmailSubject,
+        },
+        []asynq.Option{
+            asynq.MaxRetry(worker.TaskSendVerifyEmailMaxRetry),
+            asynq.Queue(worker.Critical),
+        }...)
+    if err != nil {
+        s.Error = err
+        s.Exception.InternalServerError = true
+        s.Exception.Message = "failed to send email verification"
+        return
+    }
 }
 
 func (s *EmailVerificationService) Validate() {
-	repo := repositories.GetEmailVerification(s.Constructor.AccountID, s.Constructor.Token)
-	s.Error = repo.RowsError
+    repo := repositories.GetEmailVerification(s.Constructor.AccountID, s.Constructor.Token)
+    s.Error = repo.RowsError
 
-	if repo.NoRecord {
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "Invalid token!"
-		return
-	}
+    if repo.NoRecord {
+        s.Exception.DataNotFound = true
+        s.Exception.Message = "Invalid token!"
+        return
+    }
 
-	if repo.Result.ExpiredAt.Before(time.Now()) {
-		s.Exception.Unauthorized = true
-		s.Exception.Message = "Token has expired!"
-		repositories.UpdateExpiredEmailVerification(s.Constructor.UUID)
-		s.Delete()
-		return
-	}
-	account := repositories.GetAccountById(repo.Result.AccountID)
-	account.Result.IsEmailVerified = true
+    if repo.Result.ExpiredAt.Before(time.Now()) {
+        s.Exception.Unauthorized = true
+        s.Exception.Message = "Token has expired!"
+        repositories.UpdateExpiredEmailVerification(s.Constructor.UUID)
+        s.Delete()
+        return
+    }
+    account := repositories.GetAccountById(repo.Result.AccountID)
+    account.Result.IsEmailVerified = true
 
-	repositories.UpdateAccount(account.Result)
-	s.Result = repo.Result
+    repositories.UpdateAccount(account.Result)
+    s.Result = repo.Result
 }
 
 func (s *EmailVerificationService) Delete() {
-	repo := repositories.DeleteEmailVerification(s.Constructor.Token)
-	s.Error = repo.RowsError
-	if repo.NoRecord {
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "Invalid token!"
-		return
-	}
-	s.Result = repo.Result
+    repo := repositories.DeleteEmailVerification(s.Constructor.Token)
+    s.Error = repo.RowsError
+    if repo.NoRecord {
+        s.Exception.DataNotFound = true
+        s.Exception.Message = "Invalid token!"
+        return
+    }
+    s.Result = repo.Result
 }

space/space/space/space/space/space/space/services/forgot_password_service.go

@@ -1,8 +1,8 @@
 package services
 
 import (
+	"api.qobiltu.id/pkg/worker"
 	"api.qobiltu.id/utils"
-	"api.qobiltu.id/worker"
 	"context"
 	"github.com/hibiken/asynq"
 	"strconv"

space/space/space/space/space/space/space/space/.gitignore

@@ -7,3 +7,4 @@ README.md
 logs/
 .idea
 my-notes
+uploads

space/space/space/space/space/space/space/space/pkg/validation/custom_rules.go

@@ -0,0 +1,162 @@
+package validation
+
+import (
+	"strings"
+	"sync"
+
+	v10 "github.com/go-playground/validator/v10"
+	"gorm.io/gorm"
+)
+
+type ValidOptionSource interface {
+	GetValidOptions(key string) ([]string, error)
+	GetValidKeys() []string
+}
+
+// --------------------
+// InMemoryOptionSource
+// --------------------
+
+type InMemoryOptionSource struct{}
+
+var inMemoryOptions = map[string][]string{
+	"last_education":        {"SD", "SMP", "SMA", "D1", "D2", "D3", "D4", "D5", "S1", "S2", "S3"},
+	"marital_status":        {"Belum Menikah", "Duda", "Janda"},
+	"gender":                {"Laki-laki", "Perempuan"},
+	"monthly_expenses":      {"< 2 Juta", "2-5 Juta", "5-20 Juta", "> 10 Juta"},
+	"monthly_income":        {"< 3 Juta", "3-5 Juta", "5-10 Juta", "> 10 Juta"},
+	"religion":              {"Islam", "Non-Islam"},
+	"family_role":           {"Ayah", "Ibu", "Kakak", "Adik", "Anak"},
+	"life_status":           {"Hidup", "Wafat"},
+	"body_shape":            {"Ideal", "Kurus", "Berisi", "Gemuk"},
+	"skin_color":            {"Putih", "Kuning Langsat", "Sawo Matang"},
+	"hair_type":             {"Lurus", "Bergelombang", "Keriting"},
+	"frequently":            {"Selalu", "Sering", "Kadang", "Jarang"},
+	"quran_reading_ability": {"Lancar", "Menengah", "Perlu Bimbingan"},
+}
+
+func (s *InMemoryOptionSource) GetValidOptions(key string) ([]string, error) {
+	return inMemoryOptions[key], nil
+}
+
+func (s *InMemoryOptionSource) GetValidKeys() []string {
+	keys := make([]string, 0, len(inMemoryOptions))
+	for k := range inMemoryOptions {
+		keys = append(keys, k)
+	}
+	return keys
+}
+
+// --------------------
+// DBOptionSource
+// --------------------
+
+type DBOptionSource struct {
+	options map[string][]string
+	mu      sync.RWMutex
+}
+
+type (
+	OptionCategory struct {
+		ID         int64  `gorm:"primaryKey" json:"id"`
+		OptionName string `json:"option_name"`
+		OptionSlug string `json:"option_slug" gorm:"uniqueIndex"`
+	}
+
+	OptionValues struct {
+		ID               int64  `gorm:"primaryKey" json:"id"`
+		OptionCategoryID int64  `json:"option_category_id"`
+		OptionValue      string `json:"option_value"`
+	}
+)
+
+func NewDBOptionSource(db *gorm.DB) (*DBOptionSource, error) {
+	var categories []OptionCategory
+	if err := db.Find(&categories).Error; err != nil {
+		return nil, err
+	}
+
+	options := make(map[string][]string)
+	for _, cat := range categories {
+		var values []OptionValues
+		if err := db.Where("option_category_id = ?", cat.ID).Find(&values).Error; err != nil {
+			return nil, err
+		}
+		for _, val := range values {
+			options[cat.OptionSlug] = append(options[cat.OptionSlug], val.OptionValue)
+		}
+	}
+
+	return &DBOptionSource{options: options}, nil
+}
+
+func (s *DBOptionSource) GetValidOptions(key string) ([]string, error) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+	return s.options[key], nil
+}
+
+func (s *DBOptionSource) GetValidKeys() []string {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+	keys := make([]string, 0, len(s.options))
+	for k := range s.options {
+		keys = append(keys, k)
+	}
+	return keys
+}
+
+// --------------------
+// Validator
+// --------------------
+
+type Validator struct {
+	source ValidOptionSource
+}
+
+func NewValidatorRules(source ValidOptionSource) *Validator {
+	return &Validator{source: source}
+}
+
+func (v *Validator) GenericOptionRule(key string) func(fl v10.FieldLevel) bool {
+	return func(fl v10.FieldLevel) bool {
+		value := fl.Field().String()
+		if value == "" {
+			return true
+		}
+		validOptions, err := v.source.GetValidOptions(key)
+		if err != nil {
+			return false
+		}
+		for _, opt := range validOptions {
+			if opt == value {
+				return true
+			}
+		}
+		return false
+	}
+}
+
+func (v *Validator) RegisterAllCustomRules(validate *v10.Validate) error {
+	for _, key := range v.source.GetValidKeys() {
+		err := validate.RegisterValidation(key, v.GenericOptionRule(key))
+		if err != nil {
+			return err
+		}
+	}
+
+	err := validate.RegisterValidation("password", v.PasswordRule)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (v *Validator) PasswordRule(fl v10.FieldLevel) bool {
+	password := fl.Field().String()
+	return len(password) >= 8 &&
+		strings.ContainsAny(password, "abcdefghijklmnopqrstuvwxyz") &&
+		strings.ContainsAny(password, "ABCDEFGHIJKLMNOPQRSTUVWXYZ") &&
+		strings.ContainsAny(password, "0123456789")
+}

space/space/space/space/space/space/space/space/pkg/validation/validation.go

@@ -0,0 +1,164 @@
+package validation
+
+import (
+	"errors"
+	"fmt"
+	"strings"
+
+	"github.com/go-playground/locales/en"
+	"github.com/go-playground/locales/id"
+	ut "github.com/go-playground/universal-translator"
+	v10 "github.com/go-playground/validator/v10"
+	entranslations "github.com/go-playground/validator/v10/translations/en"
+	idtranslations "github.com/go-playground/validator/v10/translations/id"
+)
+
+// Constants for supported locales
+const (
+	LocaleID = "id"
+	LocaleEN = "en"
+)
+
+// ErrorMessage represents a validation error message
+type ErrorMessage struct {
+	Field   string `json:"field"`
+	Message string `json:"-"`
+}
+
+type validator struct {
+	validate   *v10.Validate
+	translator ut.Translator
+}
+
+// validatorInstance adalah instance global dari validator.
+var validatorInstance *validator
+
+// New creates a new validation instance with the specified locale
+// dan menginisialisasi instance global validatorInstance.
+func New(locale string) error {
+	v := &validator{}
+	parsedLocale := parseLocale(locale)
+
+	uni := ut.New(en.New(), id.New(), en.New())
+	translator, found := uni.GetTranslator(parsedLocale)
+	if !found {
+		return fmt.Errorf("translator not found for locale: %s", parsedLocale)
+	}
+
+	validate := v10.New()
+
+	if err := setupValidations(validate); err != nil {
+		return fmt.Errorf("failed to setup validations: %w", err)
+	}
+
+	if err := setupTranslations(validate, translator, parsedLocale); err != nil {
+		return fmt.Errorf("failed to setup translations for locale %s: %w", parsedLocale, err)
+	}
+
+	v.validate = validate
+	v.translator = translator
+
+	validatorInstance = v // Inisialisasi instance global
+	return nil
+}
+
+func parseLocale(locale string) string {
+	switch strings.ToLower(locale) {
+	case "id":
+		return LocaleID
+	case "en":
+		return LocaleEN
+	default:
+		return LocaleID // Default to Indonesian
+	}
+}
+
+// setupValidations configures custom validation rules.
+func setupValidations(validate *v10.Validate) error {
+	rules := NewValidatorRules(&InMemoryOptionSource{})
+	if err := rules.RegisterAllCustomRules(validate); err != nil {
+		return err
+	}
+	return nil
+}
+
+// setupTranslations configures translations for validation messages.
+func setupTranslations(validate *v10.Validate, translator ut.Translator, locale string) error {
+	// Register default translations based on locale
+	if err := registerDefaultTranslations(validate, translator, locale); err != nil {
+		return fmt.Errorf("failed to register default translations for locale %s: %w", locale, err)
+	}
+
+	// Register custom password validation translation
+	err := validate.RegisterTranslation("password", translator,
+		func(ut ut.Translator) error {
+			return ut.Add("password", "harus mengandung minimal 8 karakter, huruf besar, huruf kecil, dan angka.", true)
+		},
+		func(ut ut.Translator, fe v10.FieldError) string {
+			translated, err := ut.T(fe.Tag(), fe.Field())
+			if err != nil {
+				return fe.Field() + " is invalid"
+			}
+			return translated
+		},
+	)
+	if err != nil {
+		return fmt.Errorf("failed to register password translation: %w", err)
+	}
+
+	return nil
+}
+
+// registerDefaultTranslations sets up default translations for the specified locale.
+func registerDefaultTranslations(validate *v10.Validate, translator ut.Translator, locale string) error {
+	switch locale {
+	case LocaleID:
+		return idtranslations.RegisterDefaultTranslations(validate, translator)
+	case LocaleEN:
+		return entranslations.RegisterDefaultTranslations(validate, translator)
+	default:
+		// Fallback to English if the locale is not supported
+		return entranslations.RegisterDefaultTranslations(validate, translator)
+	}
+}
+
+// Validate validates a struct using the global validator instance
+// and returns a slice of ErrorMessage.
+func Validate(s any) []ErrorMessage {
+	if validatorInstance == nil {
+		return []ErrorMessage{{Field: "", Message: "Validator belum diinisialisasi. Panggil validation.New() terlebih dahulu."}}
+	}
+	err := validatorInstance.validate.Struct(s)
+	if err != nil {
+		return TranslateError(err)
+	}
+	return nil
+}
+
+// TranslateError takes a validation error and translates it using the global translator.
+func TranslateError(err error) []ErrorMessage {
+	if validatorInstance == nil {
+		return nil
+	}
+
+	var validationErrors v10.ValidationErrors
+	if !errors.As(err, &validationErrors) {
+		return nil
+	}
+
+	errorMessages := make([]ErrorMessage, 0, len(validationErrors))
+	for _, e := range validationErrors {
+		fieldLabel := e.Field()
+		msg, err := validatorInstance.translator.T(e.Tag(), fieldLabel)
+		if err != nil {
+			msg = fieldLabel + " is Invalid"
+		}
+
+		errorMessages = append(errorMessages, ErrorMessage{
+			Field:   e.Tag(),
+			Message: msg,
+		})
+	}
+
+	return errorMessages
+}

space/space/space/space/space/space/space/space/pkg/worker/distributor.go

@@ -0,0 +1,23 @@
+package worker
+
+import (
+	"context"
+	"github.com/hibiken/asynq"
+)
+
+type TaskDistributor interface {
+	DistributeTaskSendVerifyEmail(
+		ctx context.Context,
+		payload *PayloadSendVerifyEmail,
+		opts ...asynq.Option,
+	) error
+
+	DistributeTaskSendForgotPasswordEmail(
+		ctx context.Context,
+		payload *PayloadSendForgotPasswordEmail,
+		opts ...asynq.Option,
+	) error
+}
+
+// AsyncTaskDistributor is a global variable to hold the task distributor
+var AsyncTaskDistributor TaskDistributor

space/space/space/space/space/space/space/space/pkg/worker/logger.go

@@ -0,0 +1,37 @@
+package worker
+
+import (
+	"context"
+	"fmt"
+	"log/slog"
+)
+
+type Logger struct{}
+
+func NewLogger() *Logger {
+	return &Logger{}
+}
+
+func (logger *Logger) Printf(ctx context.Context, format string, v ...interface{}) {
+	slog.Info(fmt.Sprintf(format, v...))
+}
+
+func (logger *Logger) Debug(args ...interface{}) {
+	slog.Debug(fmt.Sprint(args...))
+}
+
+func (logger *Logger) Info(args ...interface{}) {
+	slog.Info(fmt.Sprint(args...))
+}
+
+func (logger *Logger) Warn(args ...interface{}) {
+	slog.Warn(fmt.Sprint(args...))
+}
+
+func (logger *Logger) Error(args ...interface{}) {
+	slog.Error(fmt.Sprint(args...))
+}
+
+func (logger *Logger) Fatal(args ...interface{}) {
+	slog.Error(fmt.Sprint(args...))
+}

space/space/space/space/space/space/space/space/pkg/worker/processor.go

@@ -0,0 +1,66 @@
+package worker
+
+import (
+	"api.qobiltu.id/mail"
+	"context"
+	"github.com/hibiken/asynq"
+	"github.com/redis/go-redis/v9"
+	"log/slog"
+)
+
+const (
+	Low      = "low"
+	Default  = "default"
+	Critical = "critical"
+)
+
+type TaskProcessor interface {
+	Start() error
+	Shutdown()
+	ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error
+	ProcessTaskSendForgotPasswordEmail(ctx context.Context, task *asynq.Task) error
+}
+
+type RedisTaskProcessor struct {
+	server      *asynq.Server
+	emailSender mail.Sender
+}
+
+func NewRedisTaskProcessor(redisOpt asynq.RedisClientOpt, emailSender mail.Sender) TaskProcessor {
+	logger := NewLogger()
+	redis.SetLogger(logger)
+
+	server := asynq.NewServer(
+		redisOpt,
+		asynq.Config{
+			// priority value. Keys are the names of the queues and values are associated priority value.
+			Queues: map[string]int{
+				Critical: 6,
+				Default:  3,
+				Low:      1,
+			},
+			ErrorHandler: asynq.ErrorHandlerFunc(func(ctx context.Context, task *asynq.Task, err error) {
+				slog.Error("process task failed", "error", err, "type", task.Type(), "payload", string(task.Payload()))
+			}),
+			// maximum number of concurrent processing of tasks.
+			Concurrency: 50,
+			Logger:      logger,
+		},
+	)
+
+	return &RedisTaskProcessor{
+		server:      server,
+		emailSender: emailSender,
+	}
+}
+
+func (p *RedisTaskProcessor) Start() error {
+	mux := asynq.NewServeMux()
+	mux.HandleFunc(TaskSendVerifyEmail, p.ProcessTaskSendVerifyEmail)
+	mux.HandleFunc(TaskSendForgotPasswordEmail, p.ProcessTaskSendForgotPasswordEmail)
+	return p.server.Start(mux)
+}
+
+func (p *RedisTaskProcessor) Shutdown() {
+	p.server.Shutdown()
+}

space/space/space/space/space/space/space/space/pkg/worker/redis_distributor.go

@@ -0,0 +1,16 @@
+package worker
+
+import (
+	"github.com/hibiken/asynq"
+)
+
+type RedisTaskDistributor struct {
+	client *asynq.Client
+}
+
+func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor {
+	client := asynq.NewClient(redisOpt)
+	return &RedisTaskDistributor{
+		client: client,
+	}
+}

space/space/space/space/space/space/space/space/pkg/worker/task_send_forgot_password_email.go

@@ -0,0 +1,75 @@
+package worker
+
+import (
+	"api.qobiltu.id/assets"
+	"bytes"
+	"context"
+	"encoding/json"
+	"fmt"
+	"github.com/hibiken/asynq"
+	"html/template"
+	"log/slog"
+)
+
+const (
+	TaskSendForgotPasswordEmailMaxRetry = 5
+	TaskSendForgotPasswordEmail         = "task:send_forgot_password_email"
+	TaskSendForgotPasswordEmailSubject  = "Permintaan Reset Password"
+)
+
+type PayloadSendForgotPasswordEmail struct {
+	EmailAddress        string `json:"email_address"`
+	ResetToken          string `json:"reset_token"`
+	ExpirationInMinutes int    `json:"expiration_in_minutes"`
+	Subject             string `json:"subject"`
+	AppName             string `json:"app_name"`
+}
+
+func (d *RedisTaskDistributor) DistributeTaskSendForgotPasswordEmail(
+	ctx context.Context,
+	payload *PayloadSendForgotPasswordEmail,
+	opts ...asynq.Option,
+) error {
+	jsonPayload, err := json.Marshal(payload)
+	if err != nil {
+		return fmt.Errorf("failed to marshal task payload: %w", err)
+	}
+
+	task := asynq.NewTask(TaskSendForgotPasswordEmail, jsonPayload, opts...)
+
+	_, err = d.client.EnqueueContext(ctx, task)
+	if err != nil {
+		return fmt.Errorf("failed to enqueue task: %w", err)
+	}
+
+	return nil
+}
+
+func (p *RedisTaskProcessor) ProcessTaskSendForgotPasswordEmail(ctx context.Context, task *asynq.Task) error {
+	var payload PayloadSendForgotPasswordEmail
+	if err := json.Unmarshal(task.Payload(), &payload); err != nil {
+		return fmt.Errorf("failed to unmarshal payload: %w", asynq.SkipRetry)
+	}
+
+	var tmpl *template.Template
+	tmpl, err := template.ParseFS(assets.EmbeddedFiles, assets.EmailForgotPasswordTemplatePath)
+	if err != nil {
+		return fmt.Errorf("failed to parse forgot password email template: %w", err)
+	}
+	var body bytes.Buffer
+	if err := tmpl.ExecuteTemplate(&body, "htmlBody", payload); err != nil {
+		return fmt.Errorf("failed to execute forgot password email template: %w", err)
+	}
+	htmlContent := body.String()
+
+	slog.Info("Sending forgot password email", slog.String("email", payload.EmailAddress))
+
+	err = p.emailSender.Send(payload.EmailAddress, payload.Subject, htmlContent, payload)
+	if err != nil {
+		return fmt.Errorf("failed to send forgot password email: %w", err)
+	}
+
+	slog.Info("Forgot password email sent successfully", slog.String("email", payload.EmailAddress))
+
+	return nil
+}

space/space/space/space/space/space/space/space/pkg/worker/task_send_verify_email.go

@@ -0,0 +1,75 @@
+package worker
+
+import (
+	"api.qobiltu.id/assets"
+	"bytes"
+	"context"
+	"encoding/json"
+	"fmt"
+	"github.com/hibiken/asynq"
+	"html/template"
+	"log/slog"
+)
+
+const (
+	TaskSendVerifyEmailMaxRetry = 3
+	TaskSendVerifyEmail         = "task:send_verify_email"
+	TaskSendVerifyEmailSubject  = "Verifikasi Email"
+)
+
+type PayloadSendVerifyEmail struct {
+	EmailAddress        string `json:"email_address"`
+	VerificationCode    string `json:"verification_code"`
+	ExpirationInMinutes int    `json:"expiration_in_minutes"`
+	Subject             string `json:"subject"`
+}
+
+func (d *RedisTaskDistributor) DistributeTaskSendVerifyEmail(
+	ctx context.Context,
+	payload *PayloadSendVerifyEmail,
+	opts ...asynq.Option,
+) error {
+	jsonPayload, err := json.Marshal(payload)
+	if err != nil {
+		return fmt.Errorf("failed to marshal task payload: %w", err)
+	}
+
+	task := asynq.NewTask(TaskSendVerifyEmail, jsonPayload, opts...)
+
+	_, err = d.client.EnqueueContext(ctx, task)
+	if err != nil {
+		return fmt.Errorf("failed to enqueue task: %w", err)
+	}
+
+	return nil
+}
+
+func (p *RedisTaskProcessor) ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error {
+	var payload PayloadSendVerifyEmail
+	if err := json.Unmarshal(task.Payload(), &payload); err != nil {
+		return fmt.Errorf("failed to unmarshal payload: %w", asynq.SkipRetry)
+	}
+
+	var tmpl *template.Template
+	tmpl, err := template.ParseFS(assets.EmbeddedFiles, assets.EmailConfirmationTemplatePath)
+	if err != nil {
+		return fmt.Errorf("failed to parse email template: %w", err)
+	}
+
+	var body bytes.Buffer
+	if err := tmpl.ExecuteTemplate(&body, "htmlBody", payload); err != nil {
+		return fmt.Errorf("failed to execute email template: %w", err)
+	}
+	htmlContent := body.String()
+
+	slog.Info("Sending verification email", slog.String("email", payload.EmailAddress))
+
+	err = p.emailSender.Send(payload.EmailAddress, payload.Subject, htmlContent, payload)
+	if err != nil {
+		return fmt.Errorf("failed to send verify email: %w", err)
+	}
+
+	slog.Info("Verification email sent successfully", slog.String("email", payload.EmailAddress))
+
+	return nil
+}

space/space/space/space/space/space/space/space/space/main.go

@@ -9,6 +9,7 @@ import (
 	"api.qobiltu.id/router"
 	"api.qobiltu.id/services"
 	"api.qobiltu.id/utils"
+	"api.qobiltu.id/validation"
 	"api.qobiltu.id/worker"
 	"github.com/hibiken/asynq"
 	"log/slog"
@@ -18,6 +19,10 @@ import (
 
 func main() {
 
+	// setup validation
+	err := validation.New(validation.LocaleID)
+	utils.FatalIfErr("failed to setup validator", err)
+
 	// setup email sender
 	emailConfig := mail.Config{
 		Host:     config.SMTP_HOST,

space/space/space/space/space/space/space/space/space/models/exception_model.go

@@ -1,23 +1,26 @@
 package models
 
+import "api.qobiltu.id/validation"
+
 type Exception struct {
-    Unauthorized          bool `json:"unauthorized,omitempty"`
-    BadRequest            bool `json:"bad_request,omitempty"`
-    DataNotFound          bool `json:"data_not_found,omitempty"`
-    InternalServerError   bool `json:"internal_server_error,omitempty"`
-    DataDuplicate         bool `json:"data_duplicate,omitempty"`
-    QueryError            bool `json:"query_error,omitempty"`
-    InvalidPasswordLength bool `json:"invalid_password_length,omitempty"`
-    IsPassTheLimit        bool `json:"is_pass_the_limit,omitempty"`
-    IsTimeOut             bool `json:"is_time_out,omitempty"`
-    AttemptNotFound       bool `json:"attempt_not_found,omitempty"`
-    Forbidden             bool `json:"forbidden,omitempty"`
-    ValidationError       bool `json:"validation_error,omitempty"`
+	Unauthorized          bool `json:"unauthorized,omitempty"`
+	BadRequest            bool `json:"bad_request,omitempty"`
+	DataNotFound          bool `json:"data_not_found,omitempty"`
+	InternalServerError   bool `json:"internal_server_error,omitempty"`
+	DataDuplicate         bool `json:"data_duplicate,omitempty"`
+	QueryError            bool `json:"query_error,omitempty"`
+	InvalidPasswordLength bool `json:"invalid_password_length,omitempty"`
+	IsPassTheLimit        bool `json:"is_pass_the_limit,omitempty"`
+	IsTimeOut             bool `json:"is_time_out,omitempty"`
+	AttemptNotFound       bool `json:"attempt_not_found,omitempty"`
+	Forbidden             bool `json:"forbidden,omitempty"`
+	ValidationError       bool `json:"validation_error,omitempty"`
 
-    Message string `json:"message,omitempty"`
-    Err     error  `json:"-"`
+	Message               string                    `json:"message,omitempty"`
+	Err                   error                     `json:"-"`
+	ValidationErrorFields []validation.ErrorMessage `json:"validation_error_fields,omitempty"`
 }
 
 func (a Exception) Error() string {
-    return a.Err.Error()
+	return a.Err.Error()
 }