Deploy files from GitHub repository

services/health_check_service.go

@@ -5,7 +5,6 @@ import (
 	"api.qobiltu.id/repositories"
 	"api.qobiltu.id/response"
 	"context"
-	"gorm.io/gorm"
 )
 
 type HealthCheckService interface {
@@ -25,7 +24,7 @@ func NewHealthCheckService(healthCheckRepository repositories.HealthCheckReposit
 func (s *healthCheckService) Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error) {
 	res, err := s.healthCheckRepository.Check(ctx, req)
 	if err != nil {
-		return nil, response.HandleGormError(gorm.ErrDuplicatedKey, "Internal Server Error")
+		return nil, response.HandleGormError(err, "Internal Server Error")
 	}
 
 	return res, nil

space/.gitignore

@@ -6,3 +6,4 @@ README.md
 .error
 logs/
 .idea
+my-notes

space/controller/health_check/health_check_controller.go

@@ -3,29 +3,33 @@ package health_check_controller
 import (
 	"api.qobiltu.id/models"
 	"api.qobiltu.id/response"
-	"api.qobiltu.id/services/health_check_service"
+	"api.qobiltu.id/services"
 	"github.com/gin-gonic/gin"
 	"net/http"
 )
 
-type HealthCheckController struct {
-	healthCheckService *health_check_service.HealthCheckService
+type HealthCheckController interface {
+	Check(ctx *gin.Context)
 }
 
-func NewHealthCheckController(healthCheckService *health_check_service.HealthCheckService) *HealthCheckController {
-	return &HealthCheckController{
+type healthCheckController struct {
+	healthCheckService services.HealthCheckService
+}
+
+func NewHealthCheckController(healthCheckService services.HealthCheckService) HealthCheckController {
+	return &healthCheckController{
 		healthCheckService: healthCheckService,
 	}
 }
 
-func (h *HealthCheckController) Check(ctx *gin.Context) {
+func (c *healthCheckController) Check(ctx *gin.Context) {
 	req := models.HealthCheckRequest{}
 
-	res, err := h.healthCheckService.Check(ctx, &req)
+	res, err := c.healthCheckService.Check(ctx, &req)
 	if err != nil {
 		response.HandleError(ctx, err)
 		return
 	}
 
-	response.HandleSuccess(ctx, "Service is running", http.StatusOK, res, nil)
+	response.HandleSuccess(ctx, http.StatusOK, "Service OK", res, nil)
 }

space/main.go

@@ -6,7 +6,7 @@ import (
 	"api.qobiltu.id/mail"
 	"api.qobiltu.id/repositories"
 	"api.qobiltu.id/router"
-	"api.qobiltu.id/services/health_check_service"
+	"api.qobiltu.id/services"
 	"api.qobiltu.id/utils"
 	"api.qobiltu.id/worker"
 	"github.com/hibiken/asynq"
@@ -43,7 +43,7 @@ func main() {
 
 	// setup repo, service, and controller
 	healthCheckRepository := repositories.NewHealthCheckRepository(config.DB)
-	healthCheckService := health_check_service.NewHealthCheckService(healthCheckRepository)
+	healthCheckService := services.NewHealthCheckService(healthCheckRepository)
 	healthCheckController := health_check_controller.NewHealthCheckController(healthCheckService)
 
 	// start task processor

space/models/database_orm_model.go

@@ -1,207 +1,207 @@
-package models
-
-import (
-	"time"
-
-	uuid "github.com/satori/go.uuid"
-)
-
-type Account struct {
-	Id                uint       `gorm:"primaryKey" json:"id"`
-	UUID              uuid.UUID  `gorm:"type:uuid" json:"uuid" `
-	Email             string     `gorm:"uniqueIndex" json:"email"`
-	Password          string     `json:"password"`
-	IsEmailVerified   bool       `json:"is_email_verified"`
-	IsDetailCompleted bool       `json:"is_detail_completed"`
-	CreatedAt         time.Time  `json:"created_at"`
-	DeletedAt         *time.Time `json:"deleted_at" gorm:"default:null"`
-}
-
-type AccountDetails struct {
-	ID            uint       `gorm:"primaryKey" json:"id"`
-	AccountID     uint       `json:"account_id"`
-	InitialName   string     `json:"initial_name"`
-	FullName      *string    `json:"full_name"`
-	DateOfBirth   *time.Time `json:"date_of_birth"`
-	PlaceOfBirth  *string    `json:"place_of_birth"`
-	Domicile      *string    `json:"domicile"`
-	LastJob       *string    `json:"last_job"`
-	Gender        *bool      `json:"gender"`
-	LastEducation *string    `json:"last_education"`
-	MaritalStatus *string    `json:"marital_status"`
-	Avatar        *string    `json:"avatar"`
-	PhoneNumber   *string    `json:"phone_number"`
-}
-
-type EmailVerification struct {
-	ID        uint      `gorm:"primaryKey" json:"id"`
-	UUID      uuid.UUID `gorm:"type:uuid" json:"uuid" `
-	Token     uint      `json:"token"`
-	AccountID uint      `json:"account_id"`
-	IsExpired bool      `json:"is_expired"`
-	CreatedAt time.Time `json:"created_at"`
-	ExpiredAt time.Time `json:"expired_at"`
-}
-
-type ExternalAuth struct {
-	ID            uint      `gorm:"primaryKey" json:"id"`
-	UUID          uuid.UUID `gorm:"type:uuid" json:"uuid" `
-	OauthID       string    `json:"oauth_id"`
-	AccountID     uint      `json:"account_id"`
-	OauthProvider string    `json:"oauth_provider"`
-}
-
-type FCM struct {
-	ID        uint   `gorm:"primaryKey" json:"id"`
-	AccountID uint   `json:"account_id"`
-	FCMToken  string `json:"fcm_token"`
-}
-
-type ForgotPassword struct {
-	ID        uint      `gorm:"primaryKey" json:"id"`
-	UUID      uuid.UUID `gorm:"type:uuid" json:"uuid" `
-	Token     uint      `json:"token"`
-	AccountID uint      `json:"account_id"`
-	IsExpired bool      `json:"is_expired"`
-	CreatedAt time.Time `json:"created_at"`
-	ExpiredAt time.Time `json:"expired_at"`
-}
-
-type Academy struct {
-	ID                uint      `gorm:"primaryKey" json:"id"`
-	UUID              uuid.UUID `gorm:"type:uuid" json:"uuid"`
-	Title             string    `json:"title"`
-	Slug              string    `json:"slug" gorm:"uniqueIndex" `
-	TotalMaterial     int       `json:"total_material"`
-	CompletedMaterial int       `json:"completed_material"`
-	IsCompletedRead   bool      `json:"is_read"`
-	IsPassedExam      bool      `json:"is_exam"`
-	Description       string    `json:"description"`
-}
-
-type AcademyMaterial struct {
-	ID          uint      `gorm:"primaryKey" json:"id"`
-	UUID        uuid.UUID `gorm:"type:uuid" json:"uuid"`
-	AcademyID   uint      `json:"academy_id"`
-	Title       string    `json:"title"`
-	Slug        string    `json:"slug" gorm:"uniqueIndex"`
-	IsCompleted bool      `json:"is_completed"`
-	Description string    `json:"description"`
-}
-
-type AcademyContent struct {
-	ID                uint      `gorm:"primaryKey" json:"id"`
-	UUID              uuid.UUID `json:"uuid"`
-	Title             string    `json:"title"`
-	Order             uint      `json:"order"`
-	AcademyMaterialID uint      `json:"academy_material_id"`
-	Description       string    `json:"description"`
-}
-type OptionCategory struct {
-	ID         uint   `gorm:"primaryKey" json:"id"`
-	OptionName string `json:"option_name"`
-	OptionSlug string `json:"option_slug" gorm:"uniqueIndex"`
-}
-
-type OptionValues struct {
-	ID               uint   `gorm:"primaryKey" json:"id"`
-	OptionCategoryID uint   `json:"option_category_id"`
-	OptionValue      string `json:"option_value"`
-}
-type AcademyMaterialProgress struct {
-	ID                uint      `gorm:"primaryKey" json:"id"`
-	UUID              uuid.UUID `gorm:"type:uuid" json:"uuid"`
-	AccountID         uint      `json:"account_id"`
-	AcademyMaterialID uint      `json:"academy_material_id"`
-	Progress          uint      `json:"progress"`
-}
-
-type AcademyContentProgress struct {
-	ID        uint      `gorm:"primaryKey" json:"id"`
-	UUID      uuid.UUID `gorm:"type:uuid" json:"uuid"`
-	AccountID uint      `json:"account_id"`
-	AcademyID uint      `json:"academy_id"`
-}
-
-type RegionProvince struct {
-	ID   uint   `json:"id"`
-	Name string `json:"name"`
-	Code string `json:"code"`
-}
-
-type RegionCity struct {
-	ID         uint   `json:"id"`
-	Type       string `json:"type"`
-	Name       string `json:"name"`
-	Code       string `json:"code"`
-	FullCode   string `json:"full_code"`
-	ProvinceID uint   `json:"province_id"`
-}
-type Answer struct {
-	ID         uint   `gorm:"primaryKey" json:"id"`
-	QuestionID uint   `json:"question_id"`
-	Content    string `json:"content"`
-	IsCorrect  bool   `json:"-"`
-}
-type Question struct {
-	ID            uint   `gorm:"primaryKey"  json:"id"`
-	QuizID        uint   `json:"quiz_id"`
-	Content       string `json:"content"`
-	Order         int    `json:"order"`
-	CorrectAnswer uint   `json:"-"`
-}
-type Quiz struct {
-	ID           uint      `gorm:"primaryKey" json:"id"`
-	AcademyID    uint      `json:"academy_id"`
-	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"`
-}
-
-type QuizAttempt struct {
-	ID         uint       `gorm:"primaryKey" json:"id"`
-	AccountID  uint       `json:"user_id"`
-	QuizID     uint       `json:"quiz_id"`
-	StartedAt  time.Time  `json:"started_at"`
-	DueAt      time.Time  `json:"due_at"`
-	FinishedAt *time.Time `json:"finished_at"`
-	Score      float64    `json:"score"`
-}
-type UserAnswer struct {
-	ID             uint `gorm:"primaryKey" json:"id"`
-	QuizAttemptID  uint `json:"quiz_attempt_id"`
-	QuestionID     uint `json:"question_id"`
-	SelectedAnswer uint `json:"selected_answer"`
-	IsCorrect      bool `json:"is_correct"`
-}
-type QuizResult struct {
-	QuizAttemptID  uint    `gorm:"column:quiz_attempt_id" json:"quiz_attempt_id"`
-	TotalQuestions int     `gorm:"column:total_questions" json:"total_questions"`
-	CorrectAnswers int     `gorm:"column:correct_answers" json:"correct_answers"`
-	AverageScore   float64 `gorm:"column:average_score" json:"average_score"`
-}
-
-// Gorm table name settings
-func (Account) TableName() string                 { return "account" }
-func (AccountDetails) TableName() string          { return "account_details" }
-func (EmailVerification) TableName() string       { return "email_verifications" }
-func (ExternalAuth) TableName() string            { return "extern_auth" }
-func (FCM) TableName() string                     { return "fcm" }
-func (ForgotPassword) TableName() string          { return "forgot_password" }
-func (Academy) TableName() string                 { return "academy" }
-func (AcademyMaterial) TableName() string         { return "academy_materials" }
-func (AcademyContent) TableName() string          { return "academy_contents" }
-func (AcademyMaterialProgress) TableName() string { return "academy_materials_progress" }
-func (AcademyContentProgress) TableName() string  { return "academy_contents_progress" }
-func (RegionProvince) TableName() string          { return "region_provinces" }
-func (RegionCity) TableName() string              { return "region_cities" }
-func (Answer) TableName() string                  { return "answers" }
-func (Question) TableName() string                { return "questions" }
-func (Quiz) TableName() string                    { return "quizzes" }
-func (QuizAttempt) TableName() string             { return "quiz_attempts" }
-func (UserAnswer) TableName() string              { return "user_answers" }
-func (OptionCategory) TableName() string          { return "option_categories" }
-func (OptionValues) TableName() string            { return "option_values" }
+package models
+
+import (
+	"time"
+
+	uuid "github.com/satori/go.uuid"
+)
+
+type Account struct {
+	Id                uint       `gorm:"primaryKey" json:"id"`
+	UUID              uuid.UUID  `gorm:"type:uuid" json:"uuid" `
+	Email             string     `gorm:"uniqueIndex" json:"email"`
+	Password          string     `json:"password"`
+	IsEmailVerified   bool       `json:"is_email_verified"`
+	IsDetailCompleted bool       `json:"is_detail_completed"`
+	CreatedAt         time.Time  `json:"created_at"`
+	DeletedAt         *time.Time `json:"deleted_at" gorm:"default:null"`
+}
+
+type AccountDetails struct {
+	ID            uint64     `gorm:"primaryKey" json:"id"`
+	AccountID     uint       `json:"account_id"`
+	InitialName   string     `json:"initial_name"`
+	FullName      *string    `json:"full_name"`
+	DateOfBirth   *time.Time `json:"date_of_birth"`
+	PlaceOfBirth  *string    `json:"place_of_birth"`
+	Domicile      *string    `json:"domicile"`
+	LastJob       *string    `json:"last_job"`
+	Gender        *string    `json:"gender"`
+	LastEducation *string    `json:"last_education"`
+	MaritalStatus *string    `json:"marital_status"`
+	Avatar        *string    `json:"avatar"`
+	PhoneNumber   *string    `json:"phone_number"`
+}
+
+type EmailVerification struct {
+	ID        uint      `gorm:"primaryKey" json:"id"`
+	UUID      uuid.UUID `gorm:"type:uuid" json:"uuid" `
+	Token     uint      `json:"token"`
+	AccountID uint      `json:"account_id"`
+	IsExpired bool      `json:"is_expired"`
+	CreatedAt time.Time `json:"created_at"`
+	ExpiredAt time.Time `json:"expired_at"`
+}
+
+type ExternalAuth struct {
+	ID            uint      `gorm:"primaryKey" json:"id"`
+	UUID          uuid.UUID `gorm:"type:uuid" json:"uuid" `
+	OauthID       string    `json:"oauth_id"`
+	AccountID     uint      `json:"account_id"`
+	OauthProvider string    `json:"oauth_provider"`
+}
+
+type FCM struct {
+	ID        uint   `gorm:"primaryKey" json:"id"`
+	AccountID uint   `json:"account_id"`
+	FCMToken  string `json:"fcm_token"`
+}
+
+type ForgotPassword struct {
+	ID        uint      `gorm:"primaryKey" json:"id"`
+	UUID      uuid.UUID `gorm:"type:uuid" json:"uuid" `
+	Token     uint      `json:"token"`
+	AccountID uint      `json:"account_id"`
+	IsExpired bool      `json:"is_expired"`
+	CreatedAt time.Time `json:"created_at"`
+	ExpiredAt time.Time `json:"expired_at"`
+}
+
+type Academy struct {
+	ID                uint      `gorm:"primaryKey" json:"id"`
+	UUID              uuid.UUID `gorm:"type:uuid" json:"uuid"`
+	Title             string    `json:"title"`
+	Slug              string    `json:"slug" gorm:"uniqueIndex" `
+	TotalMaterial     int       `json:"total_material"`
+	CompletedMaterial int       `json:"completed_material"`
+	IsCompletedRead   bool      `json:"is_read"`
+	IsPassedExam      bool      `json:"is_exam"`
+	Description       string    `json:"description"`
+}
+
+type AcademyMaterial struct {
+	ID          uint      `gorm:"primaryKey" json:"id"`
+	UUID        uuid.UUID `gorm:"type:uuid" json:"uuid"`
+	AcademyID   uint      `json:"academy_id"`
+	Title       string    `json:"title"`
+	Slug        string    `json:"slug" gorm:"uniqueIndex"`
+	IsCompleted bool      `json:"is_completed"`
+	Description string    `json:"description"`
+}
+
+type AcademyContent struct {
+	ID                uint      `gorm:"primaryKey" json:"id"`
+	UUID              uuid.UUID `json:"uuid"`
+	Title             string    `json:"title"`
+	Order             uint      `json:"order"`
+	AcademyMaterialID uint      `json:"academy_material_id"`
+	Description       string    `json:"description"`
+}
+type OptionCategory struct {
+	ID         uint   `gorm:"primaryKey" json:"id"`
+	OptionName string `json:"option_name"`
+	OptionSlug string `json:"option_slug" gorm:"uniqueIndex"`
+}
+
+type OptionValues struct {
+	ID               uint   `gorm:"primaryKey" json:"id"`
+	OptionCategoryID uint   `json:"option_category_id"`
+	OptionValue      string `json:"option_value"`
+}
+type AcademyMaterialProgress struct {
+	ID                uint      `gorm:"primaryKey" json:"id"`
+	UUID              uuid.UUID `gorm:"type:uuid" json:"uuid"`
+	AccountID         uint      `json:"account_id"`
+	AcademyMaterialID uint      `json:"academy_material_id"`
+	Progress          uint      `json:"progress"`
+}
+
+type AcademyContentProgress struct {
+	ID        uint      `gorm:"primaryKey" json:"id"`
+	UUID      uuid.UUID `gorm:"type:uuid" json:"uuid"`
+	AccountID uint      `json:"account_id"`
+	AcademyID uint      `json:"academy_id"`
+}
+
+type RegionProvince struct {
+	ID   uint   `json:"id"`
+	Name string `json:"name"`
+	Code string `json:"code"`
+}
+
+type RegionCity struct {
+	ID         uint   `json:"id"`
+	Type       string `json:"type"`
+	Name       string `json:"name"`
+	Code       string `json:"code"`
+	FullCode   string `json:"full_code"`
+	ProvinceID uint   `json:"province_id"`
+}
+type Answer struct {
+	ID         uint   `gorm:"primaryKey" json:"id"`
+	QuestionID uint   `json:"question_id"`
+	Content    string `json:"content"`
+	IsCorrect  bool   `json:"-"`
+}
+type Question struct {
+	ID            uint   `gorm:"primaryKey"  json:"id"`
+	QuizID        uint   `json:"quiz_id"`
+	Content       string `json:"content"`
+	Order         int    `json:"order"`
+	CorrectAnswer uint   `json:"-"`
+}
+type Quiz struct {
+	ID           uint      `gorm:"primaryKey" json:"id"`
+	AcademyID    uint      `json:"academy_id"`
+	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"`
+}
+
+type QuizAttempt struct {
+	ID         uint       `gorm:"primaryKey" json:"id"`
+	AccountID  uint       `json:"user_id"`
+	QuizID     uint       `json:"quiz_id"`
+	StartedAt  time.Time  `json:"started_at"`
+	DueAt      time.Time  `json:"due_at"`
+	FinishedAt *time.Time `json:"finished_at"`
+	Score      float64    `json:"score"`
+}
+type UserAnswer struct {
+	ID             uint `gorm:"primaryKey" json:"id"`
+	QuizAttemptID  uint `json:"quiz_attempt_id"`
+	QuestionID     uint `json:"question_id"`
+	SelectedAnswer uint `json:"selected_answer"`
+	IsCorrect      bool `json:"is_correct"`
+}
+type QuizResult struct {
+	QuizAttemptID  uint    `gorm:"column:quiz_attempt_id" json:"quiz_attempt_id"`
+	TotalQuestions int     `gorm:"column:total_questions" json:"total_questions"`
+	CorrectAnswers int     `gorm:"column:correct_answers" json:"correct_answers"`
+	AverageScore   float64 `gorm:"column:average_score" json:"average_score"`
+}
+
+// Gorm table name settings
+func (Account) TableName() string                 { return "account" }
+func (AccountDetails) TableName() string          { return "account_details" }
+func (EmailVerification) TableName() string       { return "email_verifications" }
+func (ExternalAuth) TableName() string            { return "extern_auth" }
+func (FCM) TableName() string                     { return "fcm" }
+func (ForgotPassword) TableName() string          { return "forgot_password" }
+func (Academy) TableName() string                 { return "academy" }
+func (AcademyMaterial) TableName() string         { return "academy_materials" }
+func (AcademyContent) TableName() string          { return "academy_contents" }
+func (AcademyMaterialProgress) TableName() string { return "academy_materials_progress" }
+func (AcademyContentProgress) TableName() string  { return "academy_contents_progress" }
+func (RegionProvince) TableName() string          { return "region_provinces" }
+func (RegionCity) TableName() string              { return "region_cities" }
+func (Answer) TableName() string                  { return "answers" }
+func (Question) TableName() string                { return "questions" }
+func (Quiz) TableName() string                    { return "quizzes" }
+func (QuizAttempt) TableName() string             { return "quiz_attempts" }
+func (UserAnswer) TableName() string              { return "user_answers" }
+func (OptionCategory) TableName() string          { return "option_categories" }
+func (OptionValues) TableName() string            { return "option_values" }

space/models/exception_model.go

@@ -1,17 +1,23 @@
 package models
 
 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"`
-	Message               string `json:"message,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:"-"`
+}
+
+func (a Exception) Error() string {
+    return a.Err.Error()
 }

space/models/health_check_model.go

@@ -1,8 +1,6 @@
 package models
 
-type HealthCheckRequest struct {
-	ExampleCallback func() (string, string)
-}
+type HealthCheckRequest struct{}
 
 type HealthCheckResponse struct {
 	DatabaseStatus string `json:"database_status"`

space/repositories/health_check_repository.go

@@ -7,29 +7,25 @@ import (
 	"gorm.io/gorm"
 )
 
-type HealthCheckRepository struct {
+type HealthCheckRepository interface {
+	Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error)
+}
+
+type healthCheckRepository struct {
 	db *gorm.DB
 }
 
-func NewHealthCheckRepository(db *gorm.DB) *HealthCheckRepository {
-	return &HealthCheckRepository{
+func NewHealthCheckRepository(db *gorm.DB) HealthCheckRepository {
+	return &healthCheckRepository{
 		db: db,
 	}
 }
 
-func (r *HealthCheckRepository) Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error) {
-	res := &models.HealthCheckResponse{}
-
+func (r *healthCheckRepository) Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error) {
 	err := config.RunTx(ctx, r.db, func(tx *gorm.DB) error {
 		if err := tx.Exec("SELECT 1").Error; err != nil {
 			return err
 		}
-
-		// call logic from service if needed
-		// instead of writing the logic in the repository
-		// and make sure the param consist of the ctx and request
-		res.DatabaseStatus, res.RedisStatus = req.ExampleCallback()
-
 		return nil
 	})
 
@@ -37,5 +33,8 @@ func (r *HealthCheckRepository) Check(ctx context.Context, req *models.HealthChe
 		return nil, err
 	}
 
-	return res, nil
+	return &models.HealthCheckResponse{
+		DatabaseStatus: "OK",
+		RedisStatus:    "OK",
+	}, nil
 }

space/response/api_response_v2.go

@@ -0,0 +1,79 @@
+package response
+
+import (
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/utils"
+	"errors"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+)
+
+func HandleError(c *gin.Context, err error) {
+	var exception models.Exception
+
+	if errors.As(err, &exception) {
+		utils.LogError(exception.Err)
+
+		switch {
+		case exception.DataDuplicate:
+			responseError(c, http.StatusConflict, exception)
+		case exception.Unauthorized:
+			responseError(c, http.StatusUnauthorized, exception)
+		case exception.DataNotFound:
+			responseError(c, http.StatusNotFound, exception)
+		case exception.Forbidden:
+			responseError(c, http.StatusForbidden, exception)
+		case exception.BadRequest:
+			responseError(c, http.StatusBadRequest, exception)
+		case exception.InternalServerError:
+			responseError(c, http.StatusInternalServerError, exception)
+		case exception.QueryError:
+			responseError(c, http.StatusInternalServerError, exception)
+		case exception.InvalidPasswordLength:
+			responseError(c, http.StatusBadRequest, exception)
+		case exception.IsPassTheLimit:
+			responseError(c, http.StatusTooManyRequests, exception)
+		case exception.IsTimeOut:
+			responseError(c, http.StatusRequestTimeout, exception)
+		case exception.AttemptNotFound:
+			responseError(c, http.StatusNotFound, exception)
+		case exception.ValidationError:
+			responseError(c, http.StatusUnprocessableEntity, exception)
+		default:
+			responseError(c, http.StatusInternalServerError, exception)
+		}
+	} else {
+		utils.LogError(err)
+		responseError(c, http.StatusInternalServerError, models.Exception{
+			InternalServerError: true,
+			Message:             "Internal Server Error",
+		})
+	}
+}
+
+func HandleSuccess(c *gin.Context, status int, msg string, data any, metaData any) {
+	res := models.SuccessResponse{
+		Status:   "success",
+		Message:  msg,
+		Data:     data,
+		MetaData: metaData,
+	}
+
+	c.JSON(status, res)
+	return
+}
+
+func responseError(c *gin.Context, status int, exception models.Exception) {
+	message := exception.Message
+	exception.Message = ""
+
+	res := models.ErrorResponse{
+		Status:  "error",
+		Message: message,
+		Errors:  exception,
+	}
+
+	c.AbortWithStatusJSON(status, res)
+	return
+}

space/response/gorm.go

@@ -0,0 +1,62 @@
+package response
+
+import (
+	"api.qobiltu.id/models"
+	"errors"
+	"strings"
+
+	"gorm.io/gorm"
+)
+
+func HandleGormError(err error, fallbackMessage string) error {
+	if err == nil {
+		return nil
+	}
+
+	if errors.Is(err, gorm.ErrRecordNotFound) {
+		return models.Exception{
+			Message:      "Data not found",
+			DataNotFound: true,
+			Err:          err,
+		}
+	}
+
+	lowerErr := strings.ToLower(err.Error())
+	if strings.Contains(lowerErr, "duplicated key") || strings.Contains(lowerErr, "unique constraint") || strings.Contains(lowerErr, "duplicate entry") {
+		return models.Exception{
+			Message:       "Data already exists",
+			DataDuplicate: true,
+			Err:           err,
+		}
+	}
+
+	if strings.Contains(lowerErr, "password") && strings.Contains(lowerErr, "length") {
+		return models.Exception{
+			Message:               "Invalid password length",
+			InvalidPasswordLength: true,
+			Err:                   err,
+		}
+	}
+
+	if strings.Contains(lowerErr, "permission denied") || strings.Contains(lowerErr, "forbidden") {
+		return models.Exception{
+			Message:   "Access forbidden",
+			Forbidden: true,
+			Err:       err,
+		}
+	}
+
+	if errors.As(err, &gorm.ErrInvalidData) {
+		return models.Exception{
+			Message:    "Invalid data format",
+			BadRequest: true,
+			Err:        err,
+		}
+	}
+
+	return models.Exception{
+		Message:             fallbackMessage,
+		InternalServerError: true,
+		Err:                 err,
+	}
+}

space/router/server.go

@@ -7,11 +7,11 @@ import (
 
 type Server struct {
 	router                *gin.Engine
-	healthCheckController *health_check_controller.HealthCheckController
+	healthCheckController health_check_controller.HealthCheckController
 }
 
 func NewServer(
-	healthCheckController *health_check_controller.HealthCheckController,
+	healthCheckController health_check_controller.HealthCheckController,
 ) (*Server, error) {
 
 	router := gin.Default()

space/services/health_check_service.go

@@ -0,0 +1,32 @@
+package services
+
+import (
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/repositories"
+	"api.qobiltu.id/response"
+	"context"
+	"gorm.io/gorm"
+)
+
+type HealthCheckService interface {
+	Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error)
+}
+
+type healthCheckService struct {
+	healthCheckRepository repositories.HealthCheckRepository
+}
+
+func NewHealthCheckService(healthCheckRepository repositories.HealthCheckRepository) HealthCheckService {
+	return &healthCheckService{
+		healthCheckRepository: healthCheckRepository,
+	}
+}
+
+func (s *healthCheckService) Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error) {
+	res, err := s.healthCheckRepository.Check(ctx, req)
+	if err != nil {
+		return nil, response.HandleGormError(gorm.ErrDuplicatedKey, "Internal Server Error")
+	}
+
+	return res, nil
+}

space/services/user_profile_service.go

@@ -1,115 +1,115 @@
-package services
-
-import (
-	"regexp"
-	"strconv"
-	"strings"
-
-	"api.qobiltu.id/models"
-	"api.qobiltu.id/repositories"
-)
-
-type UserProfileService struct {
-	Service[models.AccountDetails, models.UserProfileResponse]
-}
-
-// SanitizePhoneNumber membersihkan dan menormalkan nomor telepon ke format +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
-}
-func (s *UserProfileService) Create() {
-	userProfile := repositories.CreateAccountDetails(s.Constructor)
-	s.Error = userProfile.RowsError
-	if userProfile.NoRecord {
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "There is no account with given credentials!"
-		return
-	}
-	s.Result = models.UserProfileResponse{
-		Account: repositories.GetAccountById(s.Constructor.AccountID).Result,
-		Details: userProfile.Result,
-	}
-}
-func (s *UserProfileService) Retrieve() {
-	userProfile := repositories.GetDetailAccountById(s.Constructor.AccountID)
-	s.Error = userProfile.RowsError
-	if userProfile.NoRecord {
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "There is no account with given credentials!"
-		return
-	}
-	s.Result = models.UserProfileResponse{
-		Account: repositories.GetAccountById(s.Constructor.AccountID).Result,
-		Details: userProfile.Result,
-	}
-	s.Result.Account.Password = "SECRET"
-}
-
-func (s *UserProfileService) Update() {
-	if s.Constructor.PhoneNumber != nil {
-		phoneNumber := *s.Constructor.PhoneNumber
-		*s.Constructor.PhoneNumber = SanitizePhoneNumber(phoneNumber)
-	}
-	usersCount := repositories.GetAllAccount().RowsCount
-	var initialName string
-	if s.Constructor.Gender != nil {
-		if *s.Constructor.Gender {
-			initialName = "IKH_"
-		} else {
-			initialName = "AKH_"
-		}
-	}
-
-	initialName += strconv.Itoa(usersCount)
-	s.Constructor.InitialName = initialName
-	userProfile := repositories.UpdateAccountDetails(s.Constructor)
-	s.Error = userProfile.RowsError
-	if userProfile.NoRecord {
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "There is no account with given credentials!"
-		return
-	}
-	account := repositories.GetAccountById(s.Constructor.AccountID)
-	account.Result.IsDetailCompleted = (userProfile.Result.InitialName != "" &&
-		userProfile.Result.FullName != nil &&
-		userProfile.Result.DateOfBirth != nil &&
-		userProfile.Result.PlaceOfBirth != nil &&
-		userProfile.Result.Domicile != nil &&
-		userProfile.Result.LastJob != nil &&
-		userProfile.Result.Gender != nil &&
-		userProfile.Result.LastEducation != nil &&
-		userProfile.Result.MaritalStatus != nil)
-	repositories.UpdateAccount(account.Result)
-	s.Result = models.UserProfileResponse{
-		Account: account.Result,
-		Details: userProfile.Result,
-	}
-	s.Result.Account.Password = "SECRET"
-}
+package services
+
+import (
+	"regexp"
+	"strconv"
+	"strings"
+
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/repositories"
+)
+
+type UserProfileService struct {
+	Service[models.AccountDetails, models.UserProfileResponse]
+}
+
+// SanitizePhoneNumber membersihkan dan menormalkan nomor telepon ke format +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
+}
+func (s *UserProfileService) Create() {
+	userProfile := repositories.CreateAccountDetails(s.Constructor)
+	s.Error = userProfile.RowsError
+	if userProfile.NoRecord {
+		s.Exception.DataNotFound = true
+		s.Exception.Message = "There is no account with given credentials!"
+		return
+	}
+	s.Result = models.UserProfileResponse{
+		Account: repositories.GetAccountById(s.Constructor.AccountID).Result,
+		Details: userProfile.Result,
+	}
+}
+func (s *UserProfileService) Retrieve() {
+	userProfile := repositories.GetDetailAccountById(s.Constructor.AccountID)
+	s.Error = userProfile.RowsError
+	if userProfile.NoRecord {
+		s.Exception.DataNotFound = true
+		s.Exception.Message = "There is no account with given credentials!"
+		return
+	}
+	s.Result = models.UserProfileResponse{
+		Account: repositories.GetAccountById(s.Constructor.AccountID).Result,
+		Details: userProfile.Result,
+	}
+	s.Result.Account.Password = "SECRET"
+}
+
+func (s *UserProfileService) Update() {
+	if s.Constructor.PhoneNumber != nil {
+		phoneNumber := *s.Constructor.PhoneNumber
+		*s.Constructor.PhoneNumber = SanitizePhoneNumber(phoneNumber)
+	}
+	usersCount := repositories.GetAllAccount().RowsCount
+	var initialName string
+	if s.Constructor.Gender != nil {
+		if strings.ToLower(*s.Constructor.Gender) == "laki-laki" {
+			initialName = "IKH_"
+		} else {
+			initialName = "AKH_"
+		}
+	}
+
+	initialName += strconv.Itoa(usersCount)
+	s.Constructor.InitialName = initialName
+	userProfile := repositories.UpdateAccountDetails(s.Constructor)
+	s.Error = userProfile.RowsError
+	if userProfile.NoRecord {
+		s.Exception.DataNotFound = true
+		s.Exception.Message = "There is no account with given credentials!"
+		return
+	}
+	account := repositories.GetAccountById(s.Constructor.AccountID)
+	account.Result.IsDetailCompleted = (userProfile.Result.InitialName != "" &&
+		userProfile.Result.FullName != nil &&
+		userProfile.Result.DateOfBirth != nil &&
+		userProfile.Result.PlaceOfBirth != nil &&
+		userProfile.Result.Domicile != nil &&
+		userProfile.Result.LastJob != nil &&
+		userProfile.Result.Gender != nil &&
+		userProfile.Result.LastEducation != nil &&
+		userProfile.Result.MaritalStatus != nil)
+	repositories.UpdateAccount(account.Result)
+	s.Result = models.UserProfileResponse{
+		Account: account.Result,
+		Details: userProfile.Result,
+	}
+	s.Result.Account.Password = "SECRET"
+}

space/space/Dockerfile

@@ -25,6 +25,12 @@ FROM alpine:latest
 # Set working directory
 WORKDIR /app
 
+# Install tzdata
+RUN apk update && apk add --no-cache tzdata
+
+# Set the timezone environment variable
+ENV TZ="Asia/Jakarta"
+
 # Copy hasil build dari builder ke image runtime
 COPY --from=builder /app/main .
 

space/space/space/.github/workflows/main.yml

@@ -25,4 +25,5 @@ jobs:
             git pull origin main
             docker-compose down -v
             docker-compose up --build -d
+            docker image prune -f
           EOF

space/space/space/apperror/apperror.go

@@ -0,0 +1,168 @@
+package apperror
+
+import (
+	"api.qobiltu.id/validation"
+	"fmt"
+)
+
+// AppError is a custom error type for the application.
+type AppError struct {
+	Code    string         // Optional: Error code for programmatic handling
+	Message string         // Human-readable error message
+	Err     error          // Underlying error, if any
+	Details map[string]any // Optional: Additional details about the error
+}
+
+func (e AppError) Error() string {
+	if e.Code != "" {
+		return fmt.Sprintf("[%s] %s", e.Code, e.Message)
+	}
+	return e.Message
+}
+
+// NewAppError creates a new AppError.
+func NewAppError(code, message string, err error, details map[string]any) error {
+	return &AppError{
+		Code:    code,
+		Message: message,
+		Err:     err,
+		Details: details,
+	}
+}
+
+// ValidationError represents errors related to data validation.
+type ValidationError struct {
+	Errors []validation.ErrorMessage // Structure to hold field and message of validation errors
+}
+
+func (e ValidationError) Error() string {
+	return fmt.Sprintf("validation failed: %+v", e.Errors)
+}
+
+// NewValidationError creates a new ValidationError.
+func NewValidationError(message string, errors []validation.ErrorMessage) error {
+	return &AppError{
+		Code:    "VALIDATION_ERROR",
+		Message: message,
+		Err:     ValidationError{Errors: errors},
+	}
+}
+
+// InternalError represents unexpected errors within the application.
+type InternalError struct {
+	Message string
+	Err     error
+}
+
+func (e InternalError) Error() string {
+	return fmt.Sprintf("internal server error: %v", e.Err)
+}
+
+// NewInternalError creates a new InternalError wrapped in AppError.
+func NewInternalError(message string, err error) error {
+	return &AppError{
+		Code:    "INTERNAL_ERROR",
+		Message: message,
+		Err:     InternalError{Message: message, Err: err},
+	}
+}
+
+// ConflictError represents errors due to a conflict with the current state.
+type ConflictError struct {
+	Message string
+	Err     error
+}
+
+func (e ConflictError) Error() string {
+	return fmt.Sprintf("conflict: %s", e.Err)
+}
+
+// NewConflictError creates a new ConflictError wrapped in AppError.
+func NewConflictError(message string, err error) error {
+	return &AppError{
+		Code:    "CONFLICT_ERROR",
+		Message: message,
+		Err:     ConflictError{Message: message, Err: err},
+	}
+}
+
+// NotFoundError represents errors when a resource is not found.
+type NotFoundError struct {
+	Message  string
+	Resource string
+	ID       any
+}
+
+func (e NotFoundError) Error() string {
+	return fmt.Sprintf("%s with ID '%v' not found", e.Resource, e.ID)
+}
+
+// NewNotFoundError creates a new NotFoundError wrapped in AppError.
+func NewNotFoundError(resource string, id any) error {
+	message := fmt.Sprintf("%s not found", resource)
+	return &AppError{
+		Code:    "NOT_FOUND_ERROR",
+		Message: fmt.Sprintf("%s not found", resource),
+		Err:     NotFoundError{Message: message, Resource: resource, ID: id},
+		Details: map[string]any{
+			"resource": resource,
+			"id":       id,
+		},
+	}
+}
+
+// UnauthorizedError represents errors when access is denied due to lack of credentials.
+type UnauthorizedError struct {
+	Message string
+	Err     error
+}
+
+func (e UnauthorizedError) Error() string {
+	return fmt.Sprintf("unauthorized: %s", e.Err)
+}
+
+// NewUnauthorizedError creates a new UnauthorizedError wrapped in AppError.
+func NewUnauthorizedError(message string, err error) error {
+	return &AppError{
+		Code:    "UNAUTHORIZED_ERROR",
+		Message: message,
+		Err:     UnauthorizedError{Message: message, Err: err},
+	}
+}
+
+// ForbiddenError represents errors when access is denied even with valid credentials.
+type ForbiddenError struct {
+	Message string
+	Err     error
+}
+
+func (e ForbiddenError) Error() string {
+	return fmt.Sprintf("forbidden: %s", e.Err)
+}
+
+// NewForbiddenError creates a new ForbiddenError wrapped in AppError.
+func NewForbiddenError(message string, err error) error {
+	return &AppError{
+		Code:    "FORBIDDEN_ERROR",
+		Message: message,
+		Err:     ForbiddenError{Message: message, Err: err},
+	}
+}
+
+// BadRequestError represents errors due to an invalid request.
+type BadRequestError struct {
+	Message string
+	Err     error
+}
+
+func (e BadRequestError) Error() string {
+	return fmt.Sprintf("bad request: %s", e.Err)
+}
+
+func NewBadRequestError(message string, err error) error {
+	return &AppError{
+		Code:    "BAD_REQUEST_ERROR",
+		Message: message,
+		Err:     BadRequestError{Message: message, Err: err},
+	}
+}

space/space/space/config/database_connection_config.go

@@ -1,79 +1,80 @@
-package config
-
-import (
-	"fmt"
-	"log"
-	"os"
-
-	"gorm.io/driver/postgres"
-	"gorm.io/gorm"
-	"gorm.io/gorm/logger"
-
-	"api.qobiltu.id/models"
-	"github.com/joho/godotenv"
-)
-
-var DB *gorm.DB
-var err error
-var Salt string
-
-func init() {
-	godotenv.Load()
-	if err != nil {
-		fmt.Println("Gagal membaca file .env")
-		return
-	}
-	os.Setenv("TZ", "Asia/Jakarta")
-	dbHost := os.Getenv("DB_HOST")
-	dbPort := os.Getenv("DB_PORT")
-	dbUser := os.Getenv("DB_USER")
-	dbPassword := os.Getenv("DB_PASSWORD")
-	dbName := os.Getenv("DB_NAME")
-	Salt := os.Getenv("SALT")
-	dsn := "host=" + dbHost + " user=" + dbUser + " password=" + dbPassword + " dbname=" + dbName + " port=" + dbPort + " sslmode=disable TimeZone=Asia/Jakarta"
-	DB, err = gorm.Open(postgres.Open(dsn), &gorm.Config{TranslateError: true})
-	if err != nil {
-		panic(err)
-	}
-	if Salt == "" {
-		Salt = "D3f4u|t"
-	}
-
-	// Call AutoMigrateAll to perform auto-migration
-	AutoMigrateAll(DB)
-}
-
-func AutoMigrateAll(db *gorm.DB) {
-	// Enable logger to see SQL logs
-	db.Logger.LogMode(logger.Info)
-
-	// Auto-migrate all models
-	err := db.AutoMigrate(
-		&models.Account{},
-		&models.AccountDetails{},
-		&models.EmailVerification{},
-		&models.ExternalAuth{},
-		&models.FCM{},
-		&models.ForgotPassword{},
-		&models.Academy{},
-		&models.AcademyMaterial{},
-		&models.AcademyContent{},
-		&models.AcademyMaterialProgress{},
-		&models.AcademyContentProgress{},
-		&models.RegionCity{},
-		&models.RegionProvince{},
-		&models.OptionCategory{},
-		&models.OptionValues{},
-		&models.Quiz{},
-		&models.QuizAttempt{},
-		&models.Question{},
-		&models.Answer{},
-		&models.UserAnswer{},
-	)
-
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	fmt.Println("Migration completed successfully.")
-}
+package config
+
+import (
+	"fmt"
+	"log"
+	"log/slog"
+	"os"
+
+	"gorm.io/driver/postgres"
+	"gorm.io/gorm"
+	"gorm.io/gorm/logger"
+
+	"api.qobiltu.id/models"
+	"github.com/joho/godotenv"
+)
+
+var DB *gorm.DB
+var err error
+var Salt string
+
+func init() {
+	godotenv.Load()
+	if err != nil {
+		fmt.Println("Gagal membaca file .env")
+		return
+	}
+	os.Setenv("TZ", "Asia/Jakarta")
+	dbHost := os.Getenv("DB_HOST")
+	dbPort := os.Getenv("DB_PORT")
+	dbUser := os.Getenv("DB_USER")
+	dbPassword := os.Getenv("DB_PASSWORD")
+	dbName := os.Getenv("DB_NAME")
+	Salt := os.Getenv("SALT")
+	dsn := "host=" + dbHost + " user=" + dbUser + " password=" + dbPassword + " dbname=" + dbName + " port=" + dbPort + " sslmode=disable TimeZone=Asia/Jakarta"
+	DB, err = gorm.Open(postgres.Open(dsn), &gorm.Config{TranslateError: true})
+	if err != nil {
+		panic(err)
+	}
+	if Salt == "" {
+		Salt = "D3f4u|t"
+	}
+
+	// Call AutoMigrateAll to perform auto-migration
+	AutoMigrateAll(DB)
+}
+
+func AutoMigrateAll(db *gorm.DB) {
+	// Enable logger to see SQL logs
+	db.Logger.LogMode(logger.Info)
+
+	// Auto-migrate all models
+	err := db.AutoMigrate(
+		&models.Account{},
+		&models.AccountDetails{},
+		&models.EmailVerification{},
+		&models.ExternalAuth{},
+		&models.FCM{},
+		&models.ForgotPassword{},
+		&models.Academy{},
+		&models.AcademyMaterial{},
+		&models.AcademyContent{},
+		&models.AcademyMaterialProgress{},
+		&models.AcademyContentProgress{},
+		&models.RegionCity{},
+		&models.RegionProvince{},
+		&models.OptionCategory{},
+		&models.OptionValues{},
+		&models.Quiz{},
+		&models.QuizAttempt{},
+		&models.Question{},
+		&models.Answer{},
+		&models.UserAnswer{},
+	)
+
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	slog.Info("Auto-migration completed successfully")
+}

space/space/space/config/tx.go

@@ -0,0 +1,34 @@
+package config
+
+import (
+	"context"
+	"fmt"
+	"gorm.io/gorm"
+)
+
+func RunTx(ctx context.Context, db *gorm.DB, fn func(tx *gorm.DB) error) error {
+	tx := db.WithContext(ctx).Begin()
+	if tx.Error != nil {
+		return fmt.Errorf("failed to begin transaction: %w", tx.Error)
+	}
+
+	defer func() {
+		if p := recover(); p != nil {
+			_ = tx.Rollback()
+			panic(p) // Re-throw panic setelah rollback
+		}
+	}()
+
+	if err := fn(tx); err != nil {
+		if rbErr := tx.Rollback().Error; rbErr != nil {
+			return fmt.Errorf("transaction error: %v, rollback error: %w", err, rbErr)
+		}
+		return err
+	}
+
+	if err := tx.Commit().Error; err != nil {
+		return fmt.Errorf("failed to commit transaction: %w", err)
+	}
+
+	return nil
+}

space/space/space/controller/health_check/health_check_controller.go

@@ -0,0 +1,31 @@
+package health_check_controller
+
+import (
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/response"
+	"api.qobiltu.id/services/health_check_service"
+	"github.com/gin-gonic/gin"
+	"net/http"
+)
+
+type HealthCheckController struct {
+	healthCheckService *health_check_service.HealthCheckService
+}
+
+func NewHealthCheckController(healthCheckService *health_check_service.HealthCheckService) *HealthCheckController {
+	return &HealthCheckController{
+		healthCheckService: healthCheckService,
+	}
+}
+
+func (h *HealthCheckController) Check(ctx *gin.Context) {
+	req := models.HealthCheckRequest{}
+
+	res, err := h.healthCheckService.Check(ctx, &req)
+	if err != nil {
+		response.HandleError(ctx, err)
+		return
+	}
+
+	response.HandleSuccess(ctx, "Service is running", http.StatusOK, res, nil)
+}

space/space/space/models/exception_model.go

@@ -1,15 +1,17 @@
-package models
-
-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"`
-	Message               string `json:"message,omitempty"`
-}
+package models
+
+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"`
+	Message               string `json:"message,omitempty"`
+}

space/space/space/models/health_check_model.go

@@ -0,0 +1,10 @@
+package models
+
+type HealthCheckRequest struct {
+	ExampleCallback func() (string, string)
+}
+
+type HealthCheckResponse struct {
+	DatabaseStatus string `json:"database_status"`
+	RedisStatus    string `json:"redis_status"`
+}

space/space/space/repositories/health_check_repository.go

@@ -0,0 +1,41 @@
+package repositories
+
+import (
+	"api.qobiltu.id/config"
+	"api.qobiltu.id/models"
+	"context"
+	"gorm.io/gorm"
+)
+
+type HealthCheckRepository struct {
+	db *gorm.DB
+}
+
+func NewHealthCheckRepository(db *gorm.DB) *HealthCheckRepository {
+	return &HealthCheckRepository{
+		db: db,
+	}
+}
+
+func (r *HealthCheckRepository) Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error) {
+	res := &models.HealthCheckResponse{}
+
+	err := config.RunTx(ctx, r.db, func(tx *gorm.DB) error {
+		if err := tx.Exec("SELECT 1").Error; err != nil {
+			return err
+		}
+
+		// call logic from service if needed
+		// instead of writing the logic in the repository
+		// and make sure the param consist of the ctx and request
+		res.DatabaseStatus, res.RedisStatus = req.ExampleCallback()
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return res, nil
+}

space/space/space/response/paging.go

@@ -0,0 +1,58 @@
+package response
+
+import (
+	"errors"
+	"fmt"
+)
+
+type PagingInfo struct {
+	HasPreviousPage        bool   `json:"has_previous_page"`
+	HasNextPage            bool   `json:"has_next_page"`
+	CurrentPage            int    `json:"current_page"`
+	PerPage                int    `json:"per_page"`
+	TotalData              int    `json:"total_data"`
+	LastPage               int    `json:"last_page"`
+	From                   int    `json:"from"`
+	To                     int    `json:"to"`
+	TotalDataInCurrentPage int    `json:"total_data_in_current_page"`
+	Label                  string `json:"label"`
+}
+
+var ErrPageInfo = errors.New("per_page harus lebih besar dari 0 dan offset tidak boleh negatif")
+
+func NewPagingInfo(currentPage, perPage, offset, totalData int) (*PagingInfo, error) {
+	if perPage <= 0 || offset < 0 {
+		return nil, ErrPageInfo
+	}
+
+	lastPage := totalData / perPage
+	if totalData%perPage != 0 {
+		lastPage++
+	}
+
+	to := min(offset+perPage, totalData)
+	from := int(0)
+	if to > offset {
+		from = offset + 1
+	}
+
+	if currentPage > lastPage {
+		currentPage = lastPage
+	}
+
+	totalDataInCurrentPage := to - offset
+	label := fmt.Sprintf("Menampilkan %d sampai %d dari %d data", from, to, totalData)
+
+	return &PagingInfo{
+		HasPreviousPage:        currentPage > 1,
+		HasNextPage:            currentPage < lastPage,
+		CurrentPage:            currentPage,
+		PerPage:                perPage,
+		TotalData:              totalData,
+		LastPage:               lastPage,
+		From:                   from,
+		To:                     to,
+		TotalDataInCurrentPage: totalDataInCurrentPage,
+		Label:                  label,
+	}, nil
+}

space/space/space/response/response.go

@@ -0,0 +1,152 @@
+package response
+
+import (
+	errors "api.qobiltu.id/apperror"
+	"api.qobiltu.id/models"
+	goErrors "errors"
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"github.com/go-playground/validator/v10"
+	"net/http"
+)
+
+type ErrorResponse struct {
+	Details          string            `json:"details"`
+	ValidationErrors []ValidationError `json:"validation_errors,omitempty"`
+	models.Exception
+}
+
+type API struct {
+	Status   string         `json:"status"`
+	Message  string         `json:"message,omitempty"`
+	Data     any            `json:"data,omitempty"`
+	MetaData any            `json:"meta_data"`
+	Error    *ErrorResponse `json:"errors,omitempty"`
+}
+
+type List struct {
+	List any `json:"list"`
+}
+
+type ValidationError struct {
+	Field   string `json:"field"`
+	Message string `json:"message"`
+}
+
+func HandleError(c *gin.Context, err error) {
+
+	apiResponse := API{
+		Status:  "error",
+		Message: "An error occurred, " + err.Error(),
+		Error: &ErrorResponse{
+			Exception: models.Exception{Message: ""},
+		},
+		MetaData: struct{}{},
+	}
+
+	var appErr *errors.AppError
+
+	if goErrors.As(err, &appErr) {
+		apiResponse.Error.Details = fmt.Sprintf("%v", appErr.Err)
+
+		switch specificErr := appErr.Err.(type) {
+		case errors.ValidationError:
+			validationError := make([]ValidationError, len(specificErr.Errors))
+			apiResponse.Message = "Validation Error"
+			apiResponse.Error.ValidationErrors = validationError
+			for i, ve := range specificErr.Errors {
+				apiResponse.Error.ValidationErrors[i] = ValidationError{
+					Field:   ve.Field,
+					Message: ve.Message,
+				}
+			}
+			c.JSON(http.StatusBadRequest, apiResponse)
+			return
+		case errors.ConflictError:
+			apiResponse.Message = specificErr.Message
+			apiResponse.Error.Details = specificErr.Error()
+			apiResponse.Error.Exception.DataDuplicate = true
+			c.JSON(http.StatusConflict, apiResponse)
+			return
+		case errors.InternalError:
+			apiResponse.Message = specificErr.Message
+			apiResponse.Error.Details = specificErr.Error()
+			apiResponse.Error.Exception.InternalServerError = true
+			c.JSON(http.StatusInternalServerError, apiResponse)
+			return
+		case errors.NotFoundError:
+			apiResponse.Message = specificErr.Message
+			apiResponse.Error.Details = specificErr.Error()
+			apiResponse.Error.Exception.DataNotFound = true
+			c.JSON(http.StatusNotFound, apiResponse)
+			return
+		case errors.UnauthorizedError:
+			apiResponse.Message = specificErr.Message
+			apiResponse.Error.Details = specificErr.Error()
+			apiResponse.Error.Exception.Unauthorized = true
+			c.JSON(http.StatusUnauthorized, apiResponse)
+			return
+		case errors.ForbiddenError:
+			apiResponse.Message = specificErr.Message
+			apiResponse.Error.Details = specificErr.Error()
+			apiResponse.Error.Exception.Forbidden = true
+			c.JSON(http.StatusForbidden, apiResponse)
+			return
+		case errors.BadRequestError:
+			apiResponse.Message = specificErr.Message
+			apiResponse.Error.Details = specificErr.Error()
+			apiResponse.Error.Exception.BadRequest = true
+			c.JSON(http.StatusBadRequest, apiResponse)
+			return
+		default:
+			apiResponse.Error.Details = "An unexpected error occurred."
+			apiResponse.Error.Exception.InternalServerError = true
+			c.JSON(http.StatusInternalServerError, apiResponse)
+			return
+		}
+	} else if validationErrors, ok := err.(validator.ValidationErrors); ok {
+		apiResponse.Error.Details = "Validation failed for the request."
+		apiResponse.Error.Exception.ValidationError = true
+		apiResponse.Error.ValidationErrors = make([]ValidationError, len(validationErrors))
+		for i, fe := range validationErrors {
+			apiResponse.Error.ValidationErrors[i] = ValidationError{
+				Field:   fe.Field(),
+				Message: fe.Translate(nil), // adjust if you use translator
+			}
+		}
+		c.JSON(http.StatusBadRequest, apiResponse)
+		return
+	}
+
+	c.JSON(http.StatusInternalServerError, apiResponse)
+	apiResponse.Error.Details = err.Error()
+}
+
+func HandleSuccess(c *gin.Context, message string, statusCode int, data any, metaData any) {
+	apiResponse := API{
+		Status:   "success",
+		Message:  message,
+		Data:     data,
+		MetaData: metaData,
+	}
+
+	if metaData == nil {
+		apiResponse.MetaData = struct{}{}
+	}
+
+	c.JSON(statusCode, apiResponse)
+}
+
+func HandleSuccessWithPaging(c *gin.Context, message string, content any, pagingInfo *PagingInfo) {
+
+	apiResponse := API{
+		Message: message,
+		Status:  "success",
+		Data: List{
+			List: content,
+		},
+		MetaData: pagingInfo,
+	}
+
+	c.JSON(http.StatusOK, apiResponse)
+}

space/space/space/router/health_check_route.go

@@ -0,0 +1,5 @@
+package router
+
+func (s *Server) HealthCheckRoute() {
+	s.router.GET("/api/v1/health-check", s.healthCheckController.Check)
+}

space/space/space/router/router.go

@@ -1,27 +1,20 @@
 package router
 
 import (
-	"log"
-
-	"api.qobiltu.id/config"
-	"api.qobiltu.id/controller"
-	"github.com/gin-gonic/gin"
+    "api.qobiltu.id/controller"
 )
 
-func StartService() {
-	router := gin.Default()
-	router.Use(gin.Recovery())
+func (s *Server) setupRoutes() {
+
+    s.router.GET("/", controller.HomeController)
 
-	router.GET("/", controller.HomeController)
-	AuthRoute(router)
-	UserRoute(router)
-	EmailRoute(router)
-	OptionsRoute(router)
-	AcademyRoute(router)
-	QuizRoute(router)
+    AuthRoute(s.router)
+    UserRoute(s.router)
+    EmailRoute(s.router)
+    OptionsRoute(s.router)
+    AcademyRoute(s.router)
+    QuizRoute(s.router)
 
-	err := router.Run(config.TCP_ADDRESS)
-	if err != nil {
-		log.Fatalf("Failed to run server: %v", err)
-	}
+    // another way to register routes
+    s.HealthCheckRoute()
 }

space/space/space/router/server.go

@@ -0,0 +1,32 @@
+package router
+
+import (
+	"api.qobiltu.id/controller/health_check"
+	"github.com/gin-gonic/gin"
+)
+
+type Server struct {
+	router                *gin.Engine
+	healthCheckController *health_check_controller.HealthCheckController
+}
+
+func NewServer(
+	healthCheckController *health_check_controller.HealthCheckController,
+) (*Server, error) {
+
+	router := gin.Default()
+	router.Use(gin.Recovery())
+
+	server := &Server{
+		healthCheckController: healthCheckController,
+		router:                router,
+	}
+
+	server.setupRoutes()
+
+	return server, nil
+}
+
+func (s *Server) Start(address string) error {
+	return s.router.Run(address)
+}

space/space/space/services/health_check_service/health_check_service.go

@@ -0,0 +1,15 @@
+package health_check_service
+
+import (
+	"api.qobiltu.id/repositories"
+)
+
+type HealthCheckService struct {
+	healthCheckRepository *repositories.HealthCheckRepository
+}
+
+func NewHealthCheckService(healthCheckRepository *repositories.HealthCheckRepository) *HealthCheckService {
+	return &HealthCheckService{
+		healthCheckRepository: healthCheckRepository,
+	}
+}

space/space/space/services/health_check_service/health_check_service_check.go

@@ -0,0 +1,21 @@
+package health_check_service
+
+import (
+	"api.qobiltu.id/apperror"
+	"api.qobiltu.id/models"
+	"context"
+)
+
+func (s *HealthCheckService) Check(ctx context.Context, req *models.HealthCheckRequest) (*models.HealthCheckResponse, error) {
+
+	req.ExampleCallback = func() (string, string) {
+		return "OK", "OK"
+	}
+
+	res, err := s.healthCheckRepository.Check(ctx, req)
+	if err != nil {
+		return nil, apperror.NewInternalError("Failed to check health", err)
+	}
+
+	return res, nil
+}

space/space/space/services/register_service.go

@@ -1,86 +1,86 @@
 package services
 
 import (
-    "errors"
-    "unicode"
+	"errors"
+	"unicode"
 
-    "api.qobiltu.id/models"
-    "api.qobiltu.id/repositories"
-    uuid "github.com/satori/go.uuid"
-    "gorm.io/gorm"
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/repositories"
+	uuid "github.com/satori/go.uuid"
+	"gorm.io/gorm"
 )
 
 type RegisterService struct {
-    Service[models.Account, models.Account]
+	Service[models.Account, models.Account]
 }
 
 func ValidatePassword(password string) models.Exception {
-    var (
-        hasMinLen = false
-        hasUpper  = false
-        hasLower  = false
-        hasNumber = false
-    )
+	var (
+		hasMinLen = false
+		hasUpper  = false
+		hasLower  = false
+		hasNumber = false
+	)
 
-    if len(password) >= 8 {
-        hasMinLen = true
-    }
+	if len(password) >= 8 {
+		hasMinLen = true
+	}
 
-    for _, char := range password {
-        switch {
-        case unicode.IsUpper(char):
-            hasUpper = true
-            break
-        case unicode.IsLower(char):
-            hasLower = true
-            break
-        case unicode.IsDigit(char):
-            hasNumber = true
-            break
-        }
-    }
-    approve := hasMinLen && hasUpper && hasLower && hasNumber
-    if !approve {
-        return models.Exception{
-            BadRequest: true,
-            Message:    "Password must contain at least 8 characters, including uppercase, lowercase, and number!",
-        }
-    }
-    return models.Exception{}
+	for _, char := range password {
+		switch {
+		case unicode.IsUpper(char):
+			hasUpper = true
+			break
+		case unicode.IsLower(char):
+			hasLower = true
+			break
+		case unicode.IsDigit(char):
+			hasNumber = true
+			break
+		}
+	}
+	approve := hasMinLen && hasUpper && hasLower && hasNumber
+	if !approve {
+		return models.Exception{
+			BadRequest: true,
+			Message:    "Password must contain at least 8 characters, including uppercase, lowercase, and number!",
+		}
+	}
+	return models.Exception{}
 }
 
 func (s *RegisterService) Create() {
-    validatePassword := ValidatePassword(s.Constructor.Password)
-    if validatePassword.BadRequest {
-        s.Exception = validatePassword
-        return
-    }
+	validatePassword := ValidatePassword(s.Constructor.Password)
+	if validatePassword.BadRequest {
+		s.Exception = validatePassword
+		return
+	}
 
-    hashedPassword, err := HashPassword(s.Constructor.Password)
-    s.Error = err
-    s.Constructor.Password = hashedPassword
-    s.Constructor.UUID = uuid.NewV4()
-    accountCreated := repositories.CreateAccount(s.Constructor)
+	hashedPassword, err := HashPassword(s.Constructor.Password)
+	s.Error = err
+	s.Constructor.Password = hashedPassword
+	s.Constructor.UUID = uuid.NewV4()
+	accountCreated := repositories.CreateAccount(s.Constructor)
 
-    if errors.Is(accountCreated.RowsError, gorm.ErrDuplicatedKey) {
-        s.Exception.DataDuplicate = true
-        s.Exception.Message = "Account with email " + s.Constructor.Email + " already exists!"
-        return
-    } else if errors.Is(accountCreated.RowsError, gorm.ErrModelAccessibleFieldsRequired) || errors.Is(accountCreated.RowsError, gorm.ErrInvalidData) || errors.Is(accountCreated.RowsError, gorm.ErrInvalidValue) || errors.Is(accountCreated.RowsError, gorm.ErrInvalidField) {
-        s.Exception.BadRequest = true
-        s.Exception.Message = "Bad request!"
-        return
-    }
+	if errors.Is(accountCreated.RowsError, gorm.ErrDuplicatedKey) {
+		s.Exception.DataDuplicate = true
+		s.Exception.Message = "Account with email " + s.Constructor.Email + " already exists!"
+		return
+	} else if errors.Is(accountCreated.RowsError, gorm.ErrModelAccessibleFieldsRequired) || errors.Is(accountCreated.RowsError, gorm.ErrInvalidData) || errors.Is(accountCreated.RowsError, gorm.ErrInvalidValue) || errors.Is(accountCreated.RowsError, gorm.ErrInvalidField) {
+		s.Exception.BadRequest = true
+		s.Exception.Message = "Bad request!"
+		return
+	}
 
-    userProfile := UserProfileService{}
-    userProfile.Constructor.AccountID = accountCreated.Result.Id
-    userProfile.Create()
-    if userProfile.Error != nil {
-        s.Error = userProfile.Error
-        return
-    }
+	userProfile := UserProfileService{}
+	userProfile.Constructor.AccountID = accountCreated.Result.Id
+	userProfile.Create()
+	if userProfile.Error != nil {
+		s.Error = userProfile.Error
+		return
+	}
 
-    s.Error = accountCreated.RowsError
-    s.Result = accountCreated.Result
-    s.Result.Password = "SECRET"
+	s.Error = accountCreated.RowsError
+	s.Result = accountCreated.Result
+	s.Result.Password = "SECRET"
 }

space/space/space/space/.gitignore

@@ -4,4 +4,5 @@ quzuu-be.exe
 README.md
 .qodo
 .error
-logs/
+logs/
+.idea

space/space/space/space/Makefile

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

space/space/space/space/assets/efs.go

@@ -0,0 +1,13 @@
+package assets
+
+import (
+	"embed"
+)
+
+//go:embed "emails"
+var EmbeddedFiles embed.FS
+
+const (
+	EmailConfirmationTemplatePath   = "emails/email-confirmation.tmpl"
+	EmailForgotPasswordTemplatePath = "emails/email-forgot-password.tmpl"
+)

space/space/space/space/assets/emails/email-confirmation.tmpl

@@ -0,0 +1,55 @@
+{{define "htmlBody"}}
+<!DOCTYPE html>
+<html>
+<head>
+  <meta charset="UTF-8">
+  <style>
+    body {
+      font-family: Arial, sans-serif;
+      background-color: #f4f4f4;
+      margin: 0;
+      padding: 0;
+    }
+    .container {
+      background-color: #ffffff;
+      max-width: 600px;
+      margin: 40px auto;
+      padding: 30px;
+      border-radius: 8px;
+      box-shadow: 0 4px 12px rgba(0,0,0,0.1);
+      color: #333;
+    }
+    .code-box {
+      font-size: 28px;
+      font-weight: bold;
+      letter-spacing: 8px;
+      background: #f0f8ff;
+      border: 2px dashed #007BFF;
+      padding: 15px 25px;
+      margin: 30px 0;
+      text-align: center;
+      border-radius: 6px;
+      color: #007BFF;
+    }
+    .footer {
+      font-size: 12px;
+      color: #aaa;
+      margin-top: 20px;
+      text-align: center;
+    }
+  </style>
+</head>
+<body>
+  <div class="container">
+    <p>Berikut adalah kode verifikasi Anda:</p>
+    <div class="code-box">{{.VerificationCode}}</div>
+    <p>Silakan masukkan kode ini untuk memverifikasi alamat email Anda. Kode ini akan kedaluwarsa dalam <strong>{{.ExpirationInMinutes}} menit</strong>.</p>
+    <p>Jika Anda tidak meminta ini, abaikan email ini.</p>
+    <p>Salam hormat,<br><strong>Tim Support Qobiltu Indonesia</strong></p>
+    <div class="footer">
+      Email ini dikirim otomatis oleh sistem. Jangan membalas email ini.
+    </div>
+  </div>
+</body>
+</html>
+{{end}}

space/space/space/space/assets/emails/email-forgot-password.tmpl

@@ -0,0 +1,56 @@
+{{define "htmlBody"}}
+<!DOCTYPE html>
+<html>
+<head>
+  <meta charset="UTF-8">
+  <style>
+    body {
+      font-family: Arial, sans-serif;
+      background-color: #f4f4f4;
+      margin: 0;
+      padding: 0;
+    }
+    .container {
+      background-color: #ffffff;
+      max-width: 600px;
+      margin: 40px auto;
+      padding: 30px;
+      border-radius: 8px;
+      box-shadow: 0 4px 12px rgba(0,0,0,0.1);
+      color: #333;
+    }
+    .code-box {
+      font-size: 28px;
+      font-weight: bold;
+      letter-spacing: 8px;
+      background: #f0f8ff;
+      border: 2px dashed #007BFF;
+      padding: 15px 25px;
+      margin: 30px 0;
+      text-align: center;
+      border-radius: 6px;
+      color: #007BFF;
+    }
+    .footer {
+      font-size: 12px;
+      color: #aaa;
+      margin-top: 20px;
+      text-align: center;
+    }
+  </style>
+</head>
+<body>
+  <div class="container">
+    <p>Anda menerima email ini karena ada permintaan untuk mengatur ulang kata sandi akun Anda.</p>
+    <p>Berikut adalah kode verifikasi Anda:</p>
+    <div class="code-box">{{.ResetToken}}</div>
+   <p>Tautan ini akan kedaluwarsa dalam <strong>{{.ExpirationInMinutes}} menit</strong>.</p>
+    <p>Jika Anda tidak meminta pengaturan ulang kata sandi ini, abaikan email ini. Tidak ada perubahan yang akan dilakukan pada akun Anda.</p>
+    <p>Salam hormat,<br><strong>Tim Support Qobiltu Indonesia</strong></p>
+    <div class="footer">
+      Email ini dikirim otomatis oleh sistem. Jangan membalas email ini.
+    </div>
+  </div>
+</body>
+</html>
+{{end}}

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

@@ -1,36 +1,63 @@
-package config
-
-import (
-	"os"
-	"strconv"
-
-	"github.com/joho/godotenv"
-)
-
-var ENV string
-var TCP_ADDRESS string
-var LOG_PATH string
-
-var HOST_ADDRESS string
-var HOST_PORT string
-var EMAIL_VERIFICATION_DURATION int
-
-var SMTP_SENDER_EMAIL string
-var SMTP_SENDER_PASSWORD string
-var SMTP_HOST string
-var SMTP_PORT string
-
-func init() {
-	godotenv.Load()
-	ENV = os.Getenv("ENV")
-	HOST_ADDRESS = os.Getenv("HOST_ADDRESS")
-	HOST_PORT = os.Getenv("HOST_PORT")
-	TCP_ADDRESS = HOST_ADDRESS + ":" + HOST_PORT
-	LOG_PATH = os.Getenv("LOG_PATH")
-	EMAIL_VERIFICATION_DURATION, _ = strconv.Atoi(os.Getenv("EMAIL_VERIFICATION_DURATION"))
-	SMTP_SENDER_EMAIL = os.Getenv("SMTP_SENDER_EMAIL")
-	SMTP_SENDER_PASSWORD = os.Getenv("SMTP_SENDER_PASSWORD")
-	SMTP_HOST = os.Getenv("SMTP_HOST")
-	SMTP_PORT = os.Getenv("SMTP_PORT")
-	// Menampilkan nilai variabel lingkungan
-}
+package config
+
+import (
+	"os"
+	"strconv"
+	"time"
+
+	"github.com/joho/godotenv"
+)
+
+var ENV string
+var TCP_ADDRESS string
+var LOG_PATH string
+
+var HOST_ADDRESS string
+var HOST_PORT string
+var EMAIL_VERIFICATION_DURATION int
+
+var SMTP_SENDER_EMAIL string
+var SMTP_SENDER_PASSWORD string
+var SMTP_HOST string
+var SMTP_PORT string
+
+var REDIS_HOST string
+var REDIS_PORT int
+var REDIS_PASSWORD string
+var REDIS_DB int
+var REDIS_MIN_IDLE_CONNS int
+var REDIS_POOL_SIZE int
+var REDIS_POOL_TIMEOUT time.Duration
+
+func init() {
+	godotenv.Load()
+	ENV = os.Getenv("ENV")
+	HOST_ADDRESS = os.Getenv("HOST_ADDRESS")
+	HOST_PORT = os.Getenv("HOST_PORT")
+	TCP_ADDRESS = HOST_ADDRESS + ":" + HOST_PORT
+	LOG_PATH = os.Getenv("LOG_PATH")
+	EMAIL_VERIFICATION_DURATION, _ = strconv.Atoi(os.Getenv("EMAIL_VERIFICATION_DURATION"))
+	SMTP_SENDER_EMAIL = os.Getenv("SMTP_SENDER_EMAIL")
+	SMTP_SENDER_PASSWORD = os.Getenv("SMTP_SENDER_PASSWORD")
+	SMTP_HOST = os.Getenv("SMTP_HOST")
+	SMTP_PORT = os.Getenv("SMTP_PORT")
+
+	REDIS_HOST = getValue(os.Getenv("REDIS_HOST"), "redis", func(s string) (string, error) { return s, nil })
+	REDIS_PORT = getValue(os.Getenv("REDIS_PORT"), 6379, func(s string) (int, error) { return strconv.Atoi(s) })
+	REDIS_PASSWORD = getValue(os.Getenv("REDIS_PASSWORD"), "qobiltu", func(s string) (string, error) { return s, nil })
+	REDIS_DB = getValue(os.Getenv("REDIS_DB"), 0, func(s string) (int, error) { return strconv.Atoi(s) })
+	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) })
+}
+
+func getValue[T any](value string, defaultValue T, convert func(string) (T, error)) T {
+	if value == "" {
+		return defaultValue
+	}
+	convertedValue, err := convert(value)
+	if err != nil {
+		return defaultValue
+	}
+	return convertedValue
+}

space/space/space/space/controller/api_response.go

@@ -0,0 +1,53 @@
+package controller
+
+import (
+	"net/http"
+	"reflect"
+
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/services"
+
+	"github.com/gin-gonic/gin"
+)
+
+func ResponseOK(c *gin.Context, data any) {
+	res := models.SuccessResponse{
+		Status:   "success",
+		Message:  "Data retrieved successfully!",
+		Data:     data,
+		MetaData: c.Request.Body,
+	}
+	c.JSON(http.StatusOK, res)
+	return
+}
+
+func ResponseFAIL(c *gin.Context, status int, exception models.Exception) {
+	message := exception.Message
+	exception.Message = ""
+	res := models.ErrorResponse{
+		Status:   "error",
+		Message:  message,
+		Errors:   exception,
+		MetaData: c.Request.Body,
+	}
+	c.AbortWithStatusJSON(status, res)
+	return
+}
+
+func SendResponse(c *gin.Context, data services.Service[any, any]) {
+	if reflect.ValueOf(data.Exception).IsNil() {
+		ResponseOK(c, data)
+	} else {
+		if data.Exception.Unauthorized {
+			ResponseFAIL(c, 401, data.Exception)
+		} else if data.Exception.BadRequest {
+			ResponseFAIL(c, 400, data.Exception)
+		} else if data.Exception.DataNotFound {
+			ResponseFAIL(c, 404, data.Exception)
+		} else if data.Exception.InternalServerError {
+			ResponseFAIL(c, 500, data.Exception)
+		} else {
+			ResponseFAIL(c, 403, data.Exception)
+		}
+	}
+}

space/space/space/space/controller/controller.go

@@ -1,65 +1,65 @@
-package controller
-
-import (
-	"api.qobiltu.id/models"
-	"api.qobiltu.id/services"
-	"api.qobiltu.id/utils"
-	"github.com/gin-gonic/gin"
-)
-
-type (
-	Controllers interface {
-		RequestJSON(c *gin.Context)
-		Response(c *gin.Context)
-	}
-	Controller[T1 any, T2 any, T3 any] struct {
-		AccountData models.AccountData
-		Request     T1
-		Service     *services.Service[T2, T3]
-	}
-)
-
-func (controller *Controller[T1, T2, T3]) HeaderParse(c *gin.Context, act func()) {
-	cParam, _ := c.Get("accountData")
-	if cParam != nil {
-		controller.AccountData = cParam.(models.AccountData)
-	}
-	act()
-}
-func (controller *Controller[T1, T2, T3]) RequestJSON(c *gin.Context, act func()) {
-	cParam, _ := c.Get("accountData")
-	if cParam != nil {
-		controller.AccountData = cParam.(models.AccountData)
-	}
-	errBinding := c.ShouldBindJSON(&controller.Request)
-	if errBinding != nil {
-		utils.ResponseFAIL(c, 400, models.Exception{
-			BadRequest: true,
-			Message:    "Invalid Request!, recheck your request, there's must be some problem about required parameter or type parameter",
-		})
-		return
-	} else {
-		act()
-		controller.Response(c)
-	}
-}
-func (controller *Controller[T1, T2, T3]) Response(c *gin.Context) {
-	switch {
-	case controller.Service.Error != nil:
-		utils.ResponseFAIL(c, 500, models.Exception{
-			InternalServerError: true,
-			Message:             "Internal Server Error",
-		})
-		utils.LogError(controller.Service.Error)
-	case controller.Service.Exception.DataDuplicate:
-		utils.ResponseFAIL(c, 400, controller.Service.Exception)
-	case controller.Service.Exception.Unauthorized:
-		utils.ResponseFAIL(c, 401, controller.Service.Exception)
-	case controller.Service.Exception.DataNotFound:
-		utils.ResponseFAIL(c, 404, controller.Service.Exception)
-	case controller.Service.Exception.Message != "":
-		utils.ResponseFAIL(c, 400, controller.Service.Exception)
-	default:
-		utils.ResponseOK(c, controller.Service.Result)
-	}
-}
+package controller
+
+import (
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/services"
+	"api.qobiltu.id/utils"
+	"github.com/gin-gonic/gin"
+)
+
+type (
+	Controllers interface {
+		RequestJSON(c *gin.Context)
+		Response(c *gin.Context)
+	}
+	Controller[T1 any, T2 any, T3 any] struct {
+		AccountData models.AccountData
+		Request     T1
+		Service     *services.Service[T2, T3]
+	}
+)
+
+func (controller *Controller[T1, T2, T3]) HeaderParse(c *gin.Context, act func()) {
+	cParam, _ := c.Get("accountData")
+	if cParam != nil {
+		controller.AccountData = cParam.(models.AccountData)
+	}
+	act()
+}
+func (controller *Controller[T1, T2, T3]) RequestJSON(c *gin.Context, act func()) {
+	cParam, _ := c.Get("accountData")
+	if cParam != nil {
+		controller.AccountData = cParam.(models.AccountData)
+	}
+	errBinding := c.ShouldBindJSON(&controller.Request)
+	if errBinding != nil {
+		ResponseFAIL(c, 400, models.Exception{
+			BadRequest: true,
+			Message:    "Invalid Request!, recheck your request, there's must be some problem about required parameter or type parameter",
+		})
+		return
+	} else {
+		act()
+		controller.Response(c)
+	}
+}
+func (controller *Controller[T1, T2, T3]) Response(c *gin.Context) {
+	switch {
+	case controller.Service.Error != nil:
+		utils.LogError(controller.Service.Error)
+		ResponseFAIL(c, 500, models.Exception{
+			InternalServerError: true,
+			Message:             "Internal Server Error",
+		})
+	case controller.Service.Exception.DataDuplicate:
+		ResponseFAIL(c, 400, controller.Service.Exception)
+	case controller.Service.Exception.Unauthorized:
+		ResponseFAIL(c, 401, controller.Service.Exception)
+	case controller.Service.Exception.DataNotFound:
+		ResponseFAIL(c, 404, controller.Service.Exception)
+	case controller.Service.Exception.Message != "":
+		ResponseFAIL(c, 400, controller.Service.Exception)
+	default:
+		ResponseOK(c, controller.Service.Result)
+	}
+}

space/space/space/space/controller/email/email_create_verification_controller.go

@@ -1,21 +1,21 @@
-package controller
-
-import (
-	"api.qobiltu.id/controller"
-	"api.qobiltu.id/models"
-	"api.qobiltu.id/services"
-	"github.com/gin-gonic/gin"
-)
-
-func CreateVerification(c *gin.Context) {
-	emailVerification := services.EmailVerificationService{}
-	emailVerificationController := controller.Controller[models.CreateVerifyEmailRequest, models.EmailVerification, models.EmailVerification]{
-		Service: &emailVerification.Service,
-	}
-	emailVerificationController.HeaderParse(c, func() {
-		emailVerificationController.Service.Constructor.AccountID = uint(emailVerificationController.AccountData.UserID)
-		emailVerification.Create()
-		emailVerificationController.Response(c)
-	})
-
-}
+package controller
+
+import (
+	"api.qobiltu.id/controller"
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/services"
+	"github.com/gin-gonic/gin"
+)
+
+func CreateVerification(c *gin.Context) {
+	emailVerification := services.EmailVerificationService{}
+	emailVerificationController := controller.Controller[models.CreateVerifyEmailRequest, models.EmailVerification, models.EmailVerification]{
+		Service: &emailVerification.Service,
+	}
+	emailVerificationController.HeaderParse(c, func() {
+		emailVerificationController.Service.Constructor.AccountID = emailVerificationController.AccountData.UserID
+		emailVerification.Create()
+		emailVerificationController.Response(c)
+	})
+
+}

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

@@ -0,0 +1,18 @@
+version: '3.8'
+
+services:
+  db:
+    image: postgres:15
+    container_name: postgres-db
+    environment:
+      POSTGRES_USER: ${DB_USER:-qobiltu}
+      POSTGRES_PASSWORD: ${DB_PASSWORD:-qobiltu}
+      POSTGRES_DB: ${DB_NAME:-qobiltu}
+    ports:
+      - "5432:5432"
+    volumes:
+      - db-data:/var/lib/postgresql/data
+    restart: always
+
+volumes:
+  db-data:

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

@@ -9,6 +9,8 @@ services:
     env_file: .env
     ports:
       - "8080:8080"
+    networks:
+      - qobiltu-network
     # volumes:
     #   - ./logs:/app/logs
     #   - /home/qobiltu/api-qobiltu:/app
@@ -25,7 +27,28 @@ services:
       - "5432:5432"
     volumes:
       - /home/qobiltu/postgres-data:/var/lib/postgresql/data
+    networks:
+      - qobiltu-network
     restart: always
 
+  redis:
+      image: redis/redis-stack:7.2.0-v11
+      container_name: redis-db
+      environment:
+          REDIS_ARGS: "--requirepass ${REDIS_PASSWORD:-qobiltu}"
+      ports:
+          - "8001:8001"
+          - "6379:6379"
+      volumes:
+          - /home/qobiltu/redis-data:/data
+      networks:
+          - qobiltu-network
+      restart: always
+
 volumes:
   db-data:
+  redis-data:
+
+networks:
+  qobiltu-network:
+    driver: bridge

space/space/space/space/go.mod

@@ -6,7 +6,10 @@ require (
 	github.com/gin-gonic/gin v1.10.0
 	github.com/golang-jwt/jwt/v5 v5.2.1
 	github.com/gosimple/slug v1.15.0
+	github.com/hibiken/asynq v0.25.1
 	github.com/joho/godotenv v1.5.1
+	github.com/jordan-wright/email v4.0.1-0.20210109023952-943e75fe5223+incompatible
+	github.com/redis/go-redis/v9 v9.7.0
 	github.com/satori/go.uuid v1.2.0
 	golang.org/x/crypto v0.36.0
 	google.golang.org/api v0.228.0
@@ -20,7 +23,9 @@ require (
 	cloud.google.com/go/compute/metadata v0.6.0 // indirect
 	github.com/bytedance/sonic v1.13.1 // indirect
 	github.com/bytedance/sonic/loader v0.2.4 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/cloudwego/base64x v0.1.5 // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/felixge/httpsnoop v1.0.4 // indirect
 	github.com/gabriel-vasile/mimetype v1.4.8 // indirect
 	github.com/gin-contrib/sse v1.0.0 // indirect
@@ -31,6 +36,7 @@ require (
 	github.com/go-playground/validator/v10 v10.25.0 // 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
@@ -47,6 +53,8 @@ require (
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/pelletier/go-toml/v2 v2.2.3 // indirect
+	github.com/robfig/cron/v3 v3.0.1 // indirect
+	github.com/spf13/cast v1.7.0 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.2.12 // indirect
 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
@@ -60,6 +68,7 @@ require (
 	golang.org/x/sync v0.12.0 // indirect
 	golang.org/x/sys v0.31.0 // indirect
 	golang.org/x/text v0.23.0 // indirect
+	golang.org/x/time v0.11.0 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250313205543-e70fdf4c4cb4 // indirect
 	google.golang.org/grpc v1.71.0 // indirect
 	google.golang.org/protobuf v1.36.6 // indirect

space/space/space/space/go.sum

@@ -4,19 +4,29 @@ cloud.google.com/go/auth/oauth2adapt v0.2.8 h1:keo8NaayQZ6wimpNSmW5OPc283g65QNIi
 cloud.google.com/go/auth/oauth2adapt v0.2.8/go.mod h1:XQ9y31RkqZCcwJWNSx2Xvric3RrU88hAYYbjDWYDL+c=
 cloud.google.com/go/compute/metadata v0.6.0 h1:A6hENjEsCDtC1k8byVsgwvVcioamEHvZ4j01OwKxG9I=
 cloud.google.com/go/compute/metadata v0.6.0/go.mod h1:FjyFAW1MW0C203CEOMDTu3Dk1FlqW3Rga40jzHL4hfg=
+github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
+github.com/bsm/ginkgo/v2 v2.12.0/go.mod h1:SwYbGRRDovPVboqFv0tPTcG1sN61LM1Z4ARdbAV9g4c=
+github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
+github.com/bsm/gomega v1.27.10/go.mod h1:JyEr/xRbxbtgWNi8tIEVPUYZ5Dzef52k01W3YH0H+O0=
 github.com/bytedance/sonic v1.13.1 h1:Jyd5CIvdFnkOWuKXr+wm4Nyk2h0yAFsr8ucJgEasO3g=
 github.com/bytedance/sonic v1.13.1/go.mod h1:o68xyaF9u2gvVBuGHPlUVCy+ZfmNNO5ETf1+KgkJhz4=
 github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
 github.com/bytedance/sonic/loader v0.2.4 h1:ZWCw4stuXUsn1/+zQDqeE7JKP+QO47tz7QCNan80NzY=
 github.com/bytedance/sonic/loader v0.2.4/go.mod h1:N8A3vUdtUebEY2/VQC0MyhYeKUFosQU6FxH2JmUe6VI=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/cloudwego/base64x v0.1.5 h1:XPciSp1xaq2VCSt6lF0phncD4koWyULpl5bUxbfCyP4=
 github.com/cloudwego/base64x v0.1.5/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w=
 github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
 github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
 github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
+github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
+github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=
 github.com/gabriel-vasile/mimetype v1.4.8 h1:FfZ3gj38NjllZIeJAmMhr+qKL8Wu+nOoI3GqacKw1NM=
 github.com/gabriel-vasile/mimetype v1.4.8/go.mod h1:ByKUIKGjh1ODkGM1asKUbQZOLGrPjydw3hYPU2YU9t8=
 github.com/gin-contrib/sse v1.0.0 h1:y3bT1mUWUxDpW4JLQg/HnTqV4rozuW4tC9eFKTxYI9E=
@@ -57,6 +67,8 @@ github.com/gosimple/slug v1.15.0 h1:wRZHsRrRcs6b0XnxMUBM6WK1U1Vg5B0R7VkIf1Xzobo=
 github.com/gosimple/slug v1.15.0/go.mod h1:UiRaFH+GEilHstLUmcBgWcI42viBN7mAb818JrYOeFQ=
 github.com/gosimple/unidecode v1.0.1 h1:hZzFTMMqSswvf0LBJZCZgThIZrpDHFXux9KeGmn6T/o=
 github.com/gosimple/unidecode v1.0.1/go.mod h1:CP0Cr1Y1kogOtx0bJblKzsVWrqYaqfNOnHzpgWw4Awc=
+github.com/hibiken/asynq v0.25.1 h1:phj028N0nm15n8O2ims+IvJ2gz4k2auvermngh9JhTw=
+github.com/hibiken/asynq v0.25.1/go.mod h1:pazWNOLBu0FEynQRBvHA26qdIKRSmfdIfUm4HdsLmXg=
 github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
 github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
 github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 h1:iCEnooe7UlwOQYpKFhBabPMi4aNAfoODPEFNiAnClxo=
@@ -71,6 +83,8 @@ github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
 github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
+github.com/jordan-wright/email v4.0.1-0.20210109023952-943e75fe5223+incompatible h1:jdpOPRN1zP63Td1hDQbZW73xKmzDvZHzVdNYxhnTMDA=
+github.com/jordan-wright/email v4.0.1-0.20210109023952-943e75fe5223+incompatible/go.mod h1:1c7szIrayyPPB/987hsnvNzLushdWf4o/79s3P08L8A=
 github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
 github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
@@ -94,10 +108,16 @@ github.com/pelletier/go-toml/v2 v2.2.3 h1:YmeHyLY8mFWbdkNWwpr+qIL2bEqT0o95WSdkNH
 github.com/pelletier/go-toml/v2 v2.2.3/go.mod h1:MfCQTFTvCcUyyvvwm1+G6H/jORL20Xlb6rzQu9GuUkc=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/redis/go-redis/v9 v9.7.0 h1:HhLSs+B6O021gwzl+locl0zEDnyNkxMtf/Z3NNBMa9E=
+github.com/redis/go-redis/v9 v9.7.0/go.mod h1:f6zhXITC7JUJIlPEiBOTXxJgPLdZcA93GewI7inzyWw=
+github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
+github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
 github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
 github.com/satori/go.uuid v1.2.0 h1:0uYX9dsZ2yD7q2RtLRtPSdGDWzjeM3TbMJP9utgA0ww=
 github.com/satori/go.uuid v1.2.0/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0=
+github.com/spf13/cast v1.7.0 h1:ntdiHjuueXFgm5nzDRdOS4yfT43P5Fnud6DH50rz/7w=
+github.com/spf13/cast v1.7.0/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
@@ -130,6 +150,8 @@ go.opentelemetry.io/otel/sdk/metric v1.34.0 h1:5CeK9ujjbFVL5c1PhLuStg1wxA7vQv7ce
 go.opentelemetry.io/otel/sdk/metric v1.34.0/go.mod h1:jQ/r8Ze28zRKoNRdkjCZxfs6YvBTG1+YIqyFVFYec5w=
 go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC8mh/k=
 go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE=
+go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
+go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
 golang.org/x/arch v0.15.0 h1:QtOrQd0bTUnhNVNndMpLHNWrDmYzZ2KDqSrEymqInZw=
 golang.org/x/arch v0.15.0/go.mod h1:JmwW7aLIoRUKgaTzhkiEFxvcEiQGyOg9BMonBJUS7EE=
 golang.org/x/crypto v0.36.0 h1:AnAEvhDddvBdpY+uR+MyHmuZzzNqXSe/GvuDeob5L34=

space/space/space/space/mail/sender.go

@@ -0,0 +1,8 @@
+package mail
+
+type Sender interface {
+	Send(recipient, subject string, htmlContent string, data any) error
+}
+
+// EmailSender is a global variable to hold the email sender
+var EmailSender Sender

space/space/space/space/mail/smtp.go

@@ -0,0 +1,71 @@
+package mail
+
+import (
+	"errors"
+	"fmt"
+	"github.com/jordan-wright/email"
+	"net/mail"
+	"net/smtp"
+)
+
+var (
+	ErrEmailEmpty   = errors.New("mail is empty")
+	ErrEmailInvalid = errors.New("invalid email")
+)
+
+// Config menyimpan pengaturan untuk koneksi SMTP.
+type Config struct {
+	Host     string
+	Port     string
+	Username string
+	Password string
+	From     string
+}
+
+// SMTP adalah implementasi Sender untuk mengirim mail melalui SMTP
+type SMTP struct {
+	name              string
+	fromEmailAddress  string
+	smtpServerAddress string
+	smtpAuthAddress   smtp.Auth
+}
+
+// New membuat instance baru SMTP dengan konfigurasi.
+func New(cfg *Config) (Sender, error) {
+	if err := validateEmail(cfg.From); err != nil {
+		return nil, fmt.Errorf("invalid from address: %w", err)
+	}
+
+	return &SMTP{
+		name:              cfg.From,
+		fromEmailAddress:  cfg.From,
+		smtpServerAddress: fmt.Sprintf("%s:%s", cfg.Host, cfg.Port),
+		smtpAuthAddress:   smtp.PlainAuth("", cfg.Username, cfg.Password, cfg.Host),
+	}, nil
+}
+
+// Send mengirim mail ke penerima dengan subjek, konten HTML, dan data lainnya.
+func (s *SMTP) Send(recipient, subject string, htmlContent string, data any) error {
+	e := email.NewEmail()
+	e.From = s.fromEmailAddress
+	e.To = []string{recipient}
+	e.Subject = subject
+	e.HTML = []byte(htmlContent)
+	return s.sendEmail(e)
+}
+
+func (s *SMTP) sendEmail(e *email.Email) error {
+	return e.Send(s.smtpServerAddress, s.smtpAuthAddress)
+}
+
+func validateEmail(email string) error {
+	if email == "" {
+		return ErrEmailEmpty
+	}
+
+	if _, err := mail.ParseAddress(email); err != nil {
+		return ErrEmailInvalid
+	}
+
+	return nil
+}

space/space/space/space/main.go

@@ -1,14 +1,62 @@
-package main
-
-import (
-	"fmt"
-
-	"api.qobiltu.id/config"
-	"api.qobiltu.id/router"
-)
-
-func main() {
-	fmt.Println("Server started on ", config.TCP_ADDRESS, ", port :", config.HOST_PORT)
-	router.StartService()
-
-}
+package main
+
+import (
+	"api.qobiltu.id/config"
+	"api.qobiltu.id/controller/health_check"
+	"api.qobiltu.id/mail"
+	"api.qobiltu.id/repositories"
+	"api.qobiltu.id/router"
+	"api.qobiltu.id/services/health_check_service"
+	"api.qobiltu.id/utils"
+	"api.qobiltu.id/worker"
+	"github.com/hibiken/asynq"
+	"log/slog"
+	"net"
+	"strconv"
+)
+
+func main() {
+
+	// setup email sender
+	emailConfig := mail.Config{
+		Host:     config.SMTP_HOST,
+		Port:     config.SMTP_PORT,
+		From:     config.SMTP_SENDER_EMAIL,
+		Username: config.SMTP_SENDER_EMAIL,
+		Password: config.SMTP_SENDER_PASSWORD,
+	}
+
+	emailSender, err := mail.New(&emailConfig)
+	utils.FatalIfErr("failed to setup email sender", err)
+	mail.EmailSender = emailSender
+
+	// setup redis task distributor and processor
+	asynqRedisOpt := asynq.RedisClientOpt{
+		Addr:     net.JoinHostPort(config.REDIS_HOST, strconv.Itoa(config.REDIS_PORT)),
+		Password: config.REDIS_PASSWORD,
+		DB:       config.REDIS_DB,
+	}
+
+	taskDistributor := worker.NewRedisTaskDistributor(asynqRedisOpt)
+	taskProcessor := worker.NewRedisTaskProcessor(asynqRedisOpt, emailSender)
+	worker.AsyncTaskDistributor = taskDistributor
+
+	// setup repo, service, and controller
+	healthCheckRepository := repositories.NewHealthCheckRepository(config.DB)
+	healthCheckService := health_check_service.NewHealthCheckService(healthCheckRepository)
+	healthCheckController := health_check_controller.NewHealthCheckController(healthCheckService)
+
+	// start task processor
+	err = taskProcessor.Start()
+	utils.FatalIfErr("failed to start task processor", err)
+	slog.Info("Task processor started")
+
+	// create server
+	s, err := router.NewServer(healthCheckController)
+	utils.FatalIfErr("failed to create server", err)
+
+	// run server
+	slog.Info("Starting server", "address", config.TCP_ADDRESS, "port", config.HOST_PORT)
+	err = s.Start(config.TCP_ADDRESS)
+	utils.FatalIfErr("failed to start server", err)
+}

space/space/space/space/middleware/authentication_middleware.go

@@ -1,37 +1,37 @@
-// auth/auth.go
-
-package middleware
-
-import (
-	"api.qobiltu.id/models"
-	"api.qobiltu.id/services"
-	"api.qobiltu.id/utils"
-	"github.com/gin-gonic/gin"
-)
-
-func AuthUser(c *gin.Context) {
-	var currAccData models.AccountData
-	if c.Request.Header["Authorization"] != nil {
-		token := c.Request.Header["Authorization"]
-
-		currAccData.UserID, currAccData.VerifyStatus, currAccData.ErrVerif = services.VerifyToken(token[0])
-
-		if currAccData.VerifyStatus == "invalid-token" || currAccData.VerifyStatus == "expired" {
-			currAccData.UserID = 0
-			utils.ResponseFAIL(c, 401, models.Exception{Unauthorized: true, Message: "Your session is expired, Please re-Login!"})
-			c.Abort()
-			return
-		} else {
-			c.Set("accountData", currAccData)
-			c.Next()
-		}
-	} else {
-		currAccData.UserID = 0
-		currAccData.VerifyStatus = "no-token"
-		currAccData.ErrVerif = nil
-		utils.ResponseFAIL(c, 401, models.Exception{Unauthorized: true, Message: "You have to login first!"})
-		c.Abort()
-		return
-	}
-
-}
+// auth/auth.go
+
+package middleware
+
+import (
+	"api.qobiltu.id/controller"
+	"api.qobiltu.id/models"
+	"api.qobiltu.id/services"
+	"github.com/gin-gonic/gin"
+)
+
+func AuthUser(c *gin.Context) {
+	var currAccData models.AccountData
+	if c.Request.Header["Authorization"] != nil {
+		token := c.Request.Header["Authorization"]
+
+		currAccData.UserID, currAccData.VerifyStatus, currAccData.ErrVerif = services.VerifyToken(token[0])
+
+		if currAccData.VerifyStatus == "invalid-token" || currAccData.VerifyStatus == "expired" {
+			currAccData.UserID = 0
+			controller.ResponseFAIL(c, 401, models.Exception{Unauthorized: true, Message: "Your session is expired, Please re-Login!"})
+			c.Abort()
+			return
+		} else {
+			c.Set("accountData", currAccData)
+			c.Next()
+		}
+	} else {
+		currAccData.UserID = 0
+		currAccData.VerifyStatus = "no-token"
+		currAccData.ErrVerif = nil
+		controller.ResponseFAIL(c, 401, models.Exception{Unauthorized: true, Message: "You have to login first!"})
+		c.Abort()
+		return
+	}
+
+}

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

@@ -1,24 +1,27 @@
-package router
-
-import (
-	"log"
-
-	"api.qobiltu.id/config"
-	"api.qobiltu.id/controller"
-	"github.com/gin-gonic/gin"
-)
-
-func StartService() {
-	router := gin.Default()
-	router.GET("/", controller.HomeController)
-	AuthRoute(router)
-	UserRoute(router)
-	EmailRoute(router)
-	OptionsRoute(router)
-	AcademyRoute(router)
-	QuizRoute(router)
-	err := router.Run(config.TCP_ADDRESS)
-	if err != nil {
-		log.Fatalf("Failed to run server: %v", err)
-	}
-}
+package router
+
+import (
+	"log"
+
+	"api.qobiltu.id/config"
+	"api.qobiltu.id/controller"
+	"github.com/gin-gonic/gin"
+)
+
+func StartService() {
+	router := gin.Default()
+	router.Use(gin.Recovery())
+
+	router.GET("/", controller.HomeController)
+	AuthRoute(router)
+	UserRoute(router)
+	EmailRoute(router)
+	OptionsRoute(router)
+	AcademyRoute(router)
+	QuizRoute(router)
+
+	err := router.Run(config.TCP_ADDRESS)
+	if err != nil {
+		log.Fatalf("Failed to run server: %v", err)
+	}
+}

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

@@ -1,181 +1,101 @@
-package services
-
-import (
-	"crypto/tls"
-	"fmt"
-	"log"
-	"math/rand/v2"
-	"net/smtp"
-	"time"
-
-	"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]
-}
-
-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
-	}
-
-	remainingTime := time.Duration(config.EMAIL_VERIFICATION_DURATION) * time.Hour
-	dueTime := CalculateDueTime(remainingTime)
-
-	token := uint(rand.IntN(999999-100000) + 100000)
-	s.Constructor.UUID = uuid.NewV4()
-
-	repo := repositories.CreateEmailVerification(s.Constructor.UUID, s.Constructor.AccountID, dueTime, token)
-
-	s.Error = repo.RowsError
-	s.Result = repo.Result
-
-	// ⬇ Kirim token ke email user menggunakan SMTP
-	go func(toEmail string, token uint) {
-		env := config.ENV
-		from := config.SMTP_SENDER_EMAIL
-		password := config.SMTP_SENDER_PASSWORD
-		smtpHost := config.SMTP_HOST
-		smtpPort := config.SMTP_PORT
-		to := []string{toEmail}
-
-		subject := "Verification token"
-		body := fmt.Sprintf("Your verification token is: %06d\nPlease use it before it expires.", token)
-
-		msg := []byte(fmt.Sprintf("From: %s\r\n", from) +
-			fmt.Sprintf("To: %s\r\n", toEmail) +
-			fmt.Sprintf("Subject: %s\r\n", subject) +
-			"\r\n" + body)
-
-		// 1. Connect to the server
-		conn, err := tls.Dial("tcp", fmt.Sprintf("[%s]:%s", smtpHost, smtpPort), &tls.Config{
-			InsecureSkipVerify: env != "production", // ⚠️ set false di production
-			ServerName:         smtpHost,
-		})
-
-		// conn, err := net.Dial("tcp", fmt.Sprintf("[%s]:%s", smtpHost, smtpPort))
-		if err != nil {
-			s.Error = err
-			log.Printf("Error sending verification email: %v", err)
-			return
-		}
-
-		c, err := smtp.NewClient(conn, smtpHost)
-		if err != nil {
-			s.Error = err
-			log.Printf("Error create new client mail: %v", err)
-			return
-		}
-
-		// 2. Auth
-		auth := smtp.PlainAuth("", from, password, smtpHost)
-		if err = c.Auth(auth); err != nil {
-			s.Error = err
-			log.Printf("Error auth mail: %v", err)
-			return
-		}
-
-		// 3. Set From and To
-		if err = c.Mail(from); err != nil {
-			s.Error = err
-			log.Printf("Error set mail from to: %v", err)
-			return
-		}
-
-		for _, addr := range to {
-			if err = c.Rcpt(addr); err != nil {
-				s.Error = err
-				log.Printf("Error receipt addr: %v", err)
-				return
-			}
-		}
-
-		// 4. Send message
-		wc, err := c.Data()
-		if err != nil {
-			s.Error = err
-			log.Printf("Error data Send Message: %v", err)
-			return
-		}
-
-		_, err = wc.Write(msg)
-		if err != nil {
-			s.Error = err
-			log.Printf("Error write Send Message: %v", err)
-			return
-		}
-
-		err = wc.Close()
-		if err != nil {
-			s.Error = err
-			log.Printf("Error close Send Message: %v", err)
-			return
-		}
-
-		c.Quit()
-		fmt.Println("Email sent successfully!")
-
-		// auth := smtp.PlainAuth("", from, password, smtpHost)
-
-		// subject := "Email Verification Token"
-		// body := fmt.Sprintf("Your verification token is: %06d\nPlease use it before it expires.", token)
-
-		// msg := []byte("To: " + toEmail + "\r\n" +
-		// 	"Subject: " + subject + "\r\n" +
-		// 	"\r\n" +
-		// 	body + "\r\n")
-
-		// err := smtp.SendMail(smtpHost+":"+smtpPort, auth, from, []string{toEmail}, msg)
-		// if err != nil {
-		// 	s.Error = err
-		// 	log.Printf("Error sending verification email: %v", err)
-		// 	return
-		// } else {
-		// 	log.Printf("Successfully sending verification email: %v", err)
-		// }
-	}(accountRepo.Result.Email, token)
-	// s.Result.Token = 0
-}
-
-func (s *EmailVerificationService) Validate() {
-	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.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
-}
-
-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
-}
+package services
+
+import (
+	"api.qobiltu.id/utils"
+	"api.qobiltu.id/worker"
+	"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"
+)
+
+type EmailVerificationService struct {
+	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
+	}
+
+	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
+	}
+
+	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
+
+	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
+
+	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
+}

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

@@ -1,113 +1,114 @@
-package services
-
-import (
-	"fmt"
-	"log"
-	"math/rand/v2"
-	"net/smtp"
-	"time"
-
-	"api.qobiltu.id/config"
-	"api.qobiltu.id/models"
-	"api.qobiltu.id/repositories"
-	uuid "github.com/satori/go.uuid"
-)
-
-type ForgotPasswordService struct {
-	Service[models.ForgotPassword, models.ForgotPassword]
-}
-
-func (s *ForgotPasswordService) Create(email string) {
-	if email == "" {
-		s.Exception.BadRequest = true
-		s.Exception.Message = "Email is required!"
-		return
-	}
-	accountRepo := repositories.GetAccountbyEmail(email)
-	if accountRepo.NoRecord {
-		s.Error = accountRepo.RowsError
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "There is no account data with given credentials!"
-		return
-	}
-
-	remainingTime := time.Duration(config.EMAIL_VERIFICATION_DURATION) * time.Hour
-	dueTime := CalculateDueTime(remainingTime)
-
-	token := uint(rand.IntN(999999-100000) + 100000)
-	s.Constructor.UUID = uuid.NewV4()
-	s.Constructor.ExpiredAt = dueTime
-	s.Constructor.AccountID = accountRepo.Result.Id
-	s.Constructor.Token = token
-	repo := repositories.CreateForgotPassword(s.Constructor)
-
-	s.Error = repo.RowsError
-	s.Result = repo.Result
-	// ⬇ Kirim token ke email user menggunakan SMTP
-	go func(toEmail string, token uint) {
-		from := config.SMTP_SENDER_EMAIL
-		password := config.SMTP_SENDER_PASSWORD
-		smtpHost := config.SMTP_HOST
-		smtpPort := config.SMTP_PORT
-
-		auth := smtp.PlainAuth("", from, password, smtpHost)
-
-		subject := "Forgot Password Token"
-		body := fmt.Sprintf("Your Forgot Password token is: %06d\nPlease use it before it expires.", token)
-
-		msg := []byte("To: " + toEmail + "\r\n" +
-			"Subject: " + subject + "\r\n" +
-			"\r\n" +
-			body + "\r\n")
-
-		err := smtp.SendMail(smtpHost+":"+smtpPort, auth, from, []string{toEmail}, msg)
-		if err != nil {
-			s.Error = err
-			log.Printf("Error sending verification email: %v", err)
-			return
-		}
-	}(accountRepo.Result.Email, token)
-	// s.Result.Token = 0
-}
-
-func (s *ForgotPasswordService) Validate(newPassword *string) {
-
-	fgPasswordRepo := repositories.GetForgotPasswordByToken(s.Constructor.Token)
-	s.Error = fgPasswordRepo.RowsError
-	if fgPasswordRepo.NoRecord {
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "There is no forgot password data with given credentials!"
-		return
-	}
-	if fgPasswordRepo.Result.ExpiredAt.Before(time.Now()) {
-		s.Exception.Unauthorized = true
-		s.Exception.Message = "Token has expired!"
-		return
-	}
-
-	accountRepo := repositories.GetAccountById(fgPasswordRepo.Result.AccountID)
-	if accountRepo.NoRecord {
-		s.Error = accountRepo.RowsError
-		s.Exception.DataNotFound = true
-		s.Exception.Message = "There is no account data with given credentials!"
-		return
-	}
-	s.Result = fgPasswordRepo.Result
-	if newPassword == nil {
-		return
-	}
-	// fmt.Println("Previous Account", accountRepo.Result)
-	// fmt.Println("New password", *newPassword)
-	hashed_password, _ := HashPassword(*newPassword)
-	accountRepo.Result.Password = hashed_password
-	changePassword := repositories.UpdateAccount(accountRepo.Result)
-	// fmt.Println("New Account", changePassword.Result)
-	if changePassword.RowsError != nil {
-		s.Error = changePassword.RowsError
-		s.Exception.QueryError = true
-		s.Exception.Message = "Failed to update password!"
-		return
-	}
-	// fgPasswordRepo.Result.Token = 0
-
-}
+package services
+
+import (
+	"api.qobiltu.id/utils"
+	"api.qobiltu.id/worker"
+	"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"
+)
+
+type ForgotPasswordService struct {
+	Service[models.ForgotPassword, models.ForgotPassword]
+}
+
+func (s *ForgotPasswordService) Create(email string) {
+	if email == "" {
+		s.Exception.BadRequest = true
+		s.Exception.Message = "Email is required!"
+		return
+	}
+	accountRepo := repositories.GetAccountbyEmail(email)
+	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
+	}
+
+	remainingTime := time.Duration(config.EMAIL_VERIFICATION_DURATION) * time.Hour
+	dueTime := CalculateDueTime(remainingTime)
+
+	s.Constructor.UUID = uuid.NewV4()
+	s.Constructor.ExpiredAt = dueTime
+	s.Constructor.AccountID = accountRepo.Result.Id
+	s.Constructor.Token = uint(token)
+	repo := repositories.CreateForgotPassword(s.Constructor)
+	s.Error = repo.RowsError
+	s.Result = repo.Result
+
+	err = worker.AsyncTaskDistributor.DistributeTaskSendForgotPasswordEmail(
+		context.Background(),
+		&worker.PayloadSendForgotPasswordEmail{
+			EmailAddress:        accountRepo.Result.Email,
+			ResetToken:          strconv.Itoa(int(token)),
+			ExpirationInMinutes: int(remainingTime.Minutes()),
+			Subject:             worker.TaskSendForgotPasswordEmailSubject,
+		},
+		[]asynq.Option{
+			asynq.MaxRetry(worker.TaskSendForgotPasswordEmailMaxRetry),
+			asynq.Queue(worker.Critical),
+		}...)
+	if err != nil {
+		s.Error = err
+		s.Exception.InternalServerError = true
+		s.Exception.Message = "failed to send email verification for forgot password request"
+		return
+	}
+}
+
+func (s *ForgotPasswordService) Validate(newPassword *string) {
+
+	fgPasswordRepo := repositories.GetForgotPasswordByToken(s.Constructor.Token)
+	s.Error = fgPasswordRepo.RowsError
+	if fgPasswordRepo.NoRecord {
+		s.Exception.DataNotFound = true
+		s.Exception.Message = "There is no forgot password data with given credentials!"
+		return
+	}
+	if fgPasswordRepo.Result.ExpiredAt.Before(time.Now()) {
+		s.Exception.Unauthorized = true
+		s.Exception.Message = "Token has expired!"
+		return
+	}
+
+	accountRepo := repositories.GetAccountById(fgPasswordRepo.Result.AccountID)
+	if accountRepo.NoRecord {
+		s.Error = accountRepo.RowsError
+		s.Exception.DataNotFound = true
+		s.Exception.Message = "There is no account data with given credentials!"
+		return
+	}
+	s.Result = fgPasswordRepo.Result
+	if newPassword == nil {
+		return
+	}
+	// fmt.Println("Previous Account", accountRepo.Result)
+	// fmt.Println("New password", *newPassword)
+	hashed_password, _ := HashPassword(*newPassword)
+	accountRepo.Result.Password = hashed_password
+	changePassword := repositories.UpdateAccount(accountRepo.Result)
+	// fmt.Println("New Account", changePassword.Result)
+	if changePassword.RowsError != nil {
+		s.Error = changePassword.RowsError
+		s.Exception.QueryError = true
+		s.Exception.Message = "Failed to update password!"
+		return
+	}
+	// fgPasswordRepo.Result.Token = 0
+
+}