chore: update config retrieve mechanism and sql base from sql to sqlx

Author: martinyonatann

cmd/main.go renamed to cmd/api/main.go

@@ -1,21 +1,21 @@
-server:
-  name: golang-clean-architecture
-  version: "v0.0.1"
-  rpc_port: 8080
-  rest_port: 9090
-  debug: false
-  env: local
-  read_time_out: 5s
-  write_time_out: 5s
+Server:
+  Name: golang-clean-architecture
+  Version: "v0.0.1"
+  RPCPort: 8080
+  RESTPort: 9090
+  Debug: false
+  Env: local
+  ReadTimeOut: 5s
+  WriteTimeOut: 5s
 
-database:
-  host: localhost
-  port: 3306
-  name: users
-  user: mysql
-  password: pwd
+Database:
+  Host: localhost
+  Port: 3306
+  Name: users
+  User: mysql
+  Password: pwd
 
-authentication:
-  key: DoWithLogic!@#
-  secret_key: s3cr#tK3y!@#v001
-  salt_key: s4ltK3y!@#ddv001
+Authentication:
+  Key: DoWithLogic!@#
+  SecretKey: s3cr#tK3y!@#v001
+  SaltKey: s4ltK3y!@#ddv001

cmd/scheduler/.keep

@@ -15,28 +15,28 @@ type (
 	}
 
 	DatabaseConfig struct {
-		Host     string `mapstructure:"host"`
-		Port     int    `mapstructure:"port"`
-		Name     string `mapstructure:"name"`
-		User     string `mapstructure:"user"`
-		Password string `mapstructure:"password"`
+		Host     string
+		Port     int
+		Name     string
+		User     string
+		Password string
 	}
 
 	ServerConfig struct {
-		Name         string        `mapstructure:"name"`
-		Version      string        `mapstructure:"version"`
-		RPCPort      string        `mapstructure:"rpc_port"`
-		RESTPort     string        `mapstructure:"rest_port"`
-		Debug        bool          `mapstructure:"debug"`
-		Environment  string        `mapstructure:"env"`
-		ReadTimeout  time.Duration `mapstructure:"read_time_out"`
-		WriteTimeout time.Duration `mapstructure:"write_time_out"`
+		Name         string
+		Version      string
+		RPCPort      string
+		RESTPort     string
+		Debug        bool
+		Environment  string
+		ReadTimeout  time.Duration
+		WriteTimeout time.Duration
 	}
 
 	AuthenticationConfig struct {
-		Key       string `mapstructure:"key"`
-		SecretKey string `mapstructure:"secret_key"`
-		SaltKey   string `mapstructure:"salt_key"`
+		Key       string
+		SecretKey string
+		SaltKey   string
 	}
 )
 

config/config-local.yaml.example

@@ -1,17 +1,24 @@
 package dtos
 
-import "github.com/invopop/validation"
+import (
+	"github.com/DoWithLogic/golang-clean-architecture/pkg/apperror"
+	"github.com/DoWithLogic/golang-clean-architecture/pkg/constant"
+	"github.com/invopop/validation"
+)
 
 type UpdateUserStatusRequest struct {
 	UserID   int64  `json:"-"`
-	Status   int    `json:"status"`
+	Status   string `json:"status"`
 	UpdateBy string `json:"-"`
 }
 
 func (ussp UpdateUserStatusRequest) Validate() error {
+	if ussp.Status != constant.UserInactive && ussp.Status != constant.UserActive {
+		return apperror.ErrStatusValue
+	}
+
 	return validation.ValidateStruct(&ussp,
 		validation.Field(&ussp.UserID, validation.NotNil),
 		validation.Field(&ussp.UpdateBy, validation.NotNil),
-		validation.Field(&ussp.Status, validation.Required),
 	)
 }

config/config.go

@@ -37,7 +37,7 @@ func NewRepository(c *sqlx.DB, l *zerolog.Logger) Repository {
 
 // Atomic implements vendor.Repository for transaction query
 func (r *repository) Atomic(ctx context.Context, opt *sql.TxOptions, repo func(tx Repository) error) error {
-	txConn, err := r.db.BeginTx(ctx, opt)
+	txConn, err := r.db.BeginTxx(ctx, opt)
 	if err != nil {
 		r.log.Z().Err(err).Msg("[repository]Atomic.BeginTxx")
 
@@ -122,8 +122,8 @@ func (repo *repository) GetUserByID(ctx context.Context, userID int64, options .
 		query += " FOR UPDATE"
 	}
 
-	if err = new(datasource.DataSource).QuerySQL(repo.conn.QueryContext(ctx, query, args...)).Scan(row); err != nil {
-		repo.log.Z().Err(err).Msg("[repository]GetUserByID.QueryContext")
+	if err = new(datasource.DataSource).QuerySQL(repo.conn.QueryxContext(ctx, query, args...)).Scan(row); err != nil {
+		repo.log.Z().Err(err).Msg("[repository]GetUserByID.QueryxContext")
 		return userData, err
 	}
 
@@ -159,9 +159,9 @@ func (repo *repository) IsUserExist(ctx context.Context, email string) bool {
 		}
 	}
 
-	err := new(datasource.DataSource).QuerySQL(repo.conn.QueryContext(ctx, repository_query.IsUserExist, args...)).Scan(row)
+	err := new(datasource.DataSource).QuerySQL(repo.conn.QueryxContext(ctx, repository_query.IsUserExist, args...)).Scan(row)
 	if err != nil {
-		repo.log.Z().Err(err).Msg("[repository]IsUserExist.QueryContext")
+		repo.log.Z().Err(err).Msg("[repository]IsUserExist.QueryxContext")
 
 		return false
 	}
@@ -182,9 +182,9 @@ func (repo *repository) GetUserByEmail(ctx context.Context, email string) (userD
 		}
 	}
 
-	err = new(datasource.DataSource).QuerySQL(repo.conn.QueryContext(ctx, repository_query.GetUserByEmail, args...)).Scan(row)
+	err = new(datasource.DataSource).QuerySQL(repo.conn.QueryxContext(ctx, repository_query.GetUserByEmail, args...)).Scan(row)
 	if err != nil {
-		repo.log.Z().Err(err).Msg("[repository]GetUserByID.QueryContext")
+		repo.log.Z().Err(err).Msg("[repository]GetUserByID.QueryxContext")
 		return entities.Users{}, err
 	}