feat: get user/staff profile

internal/accessor/staff/get_by_email.go

@@ -12,7 +12,7 @@ func (sr *StaffRepository) GetStaffByEmail(email string) (*authdomain.Staff, err
 	var staff authdomain.Staff
 
 	if email == "" {
-		return nil, errors.New("email is empty")
+		return nil, errors.New("email is required")
 	}
 
 	if err := sr.DB.Where("email = ?", email).First(&staff).Error; err != nil {

internal/accessor/staff/get_by_id.go

@@ -0,0 +1,25 @@
+package staffrepository
+
+import (
+	"errors"
+	authdomain "legalgo-BE-go/internal/domain/auth"
+
+	"gorm.io/gorm"
+)
+
+func (sr *StaffRepository) GetStaffByID(ID string) (*authdomain.Staff, error) {
+	var staff authdomain.Staff
+
+	if ID == "" {
+		return nil, errors.New("id is required")
+	}
+
+	if err := sr.DB.Where("id = ? ", ID).First(&staff).Error; err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return nil, errors.New("staff not found")
+		}
+		return nil, err
+	}
+
+	return &staff, nil
+}

internal/accessor/staff/impl.go

@@ -11,7 +11,9 @@ type StaffRepository struct {
 
 type StaffIntf interface {
 	GetStaffByEmail(string) (*authdomain.Staff, error)
+	GetStaffByID(string) (*authdomain.Staff, error)
 	Create(*authdomain.Staff) (*authdomain.Staff, error)
+	Update(authdomain.Staff) error
 }
 
 func New(db *database.DB) StaffIntf {

internal/accessor/staff/update.go

@@ -1,7 +1,19 @@
 package staffrepository
 
-func (ur *StaffRepository) Update() error {
-	// if err := ur.DB.Update(column string, value interface{})
+import (
+	authdomain "legalgo-BE-go/internal/domain/auth"
+	"legalgo-BE-go/internal/utilities/utils"
+)
+
+func (ur *StaffRepository) Update(spec authdomain.Staff) error {
+	val, err := utils.StructToMap(spec)
+	if err != nil {
+		return err
+	}
+
+	if err := ur.DB.Model(&authdomain.Staff{}).Where("id = ?", spec.ID).Updates(val).Error; err != nil {
+		return err
+	}
 
 	return nil
 }

internal/accessor/user_repository/get_user_by_id.go

@@ -0,0 +1,30 @@
+package userrepository
+
+import (
+	"errors"
+
+	authdomain "legalgo-BE-go/internal/domain/auth"
+
+	"gorm.io/gorm"
+)
+
+func (ur *UserRepository) GetUserByID(email string) (*authdomain.UserProfile, error) {
+	var users []authdomain.UserProfile
+
+	if email == "" {
+		return nil, errors.New("email is empty")
+	}
+
+	if err := ur.DB.Table("users u").
+		Select("u.email, u.id, s.status as subscribe_status, sp.code as subscribe_plan_code, sp.name as subscribe_plan_name").
+		Joins("join subscribes s on s.id = u.subscribe_id").
+		Joins("join subscribe_plans sp on s.subscribe_plan_id = sp.id").
+		Scan(&users).Error; err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return nil, errors.New("user not found")
+		}
+		return nil, err
+	}
+
+	return &users[0], nil
+}

internal/accessor/user_repository/impl.go

@@ -11,6 +11,7 @@ type UserRepository struct {
 
 type UserIntf interface {
 	GetUserByEmail(string) (*authdomain.User, error)
+	GetUserByID(string) (*authdomain.UserProfile, error)
 	CreateUser(*authdomain.User) (*authdomain.User, error)
 }
 

internal/api/http/auth/module.go

@@ -8,5 +8,8 @@ var Module = fx.Module("auth-api",
 		LoginUser,
 		RegisterUser,
 		RegisterStaff,
+		UpdateStaff,
+		GetStaffProfile,
+		GetUserProfile,
 	),
 )

internal/api/http/auth/profile.go

@@ -0,0 +1,82 @@
+package authhttp
+
+import (
+	"errors"
+	authsvc "legalgo-BE-go/internal/services/auth"
+	"legalgo-BE-go/internal/utilities/response"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+)
+
+func GetStaffProfile(
+	router chi.Router,
+	authSvc authsvc.AuthIntf,
+) {
+	router.Get("/staff/{id}/profile", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+		id := chi.URLParam(r, "id")
+		if id == "" {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				errors.New("provided id is empty"),
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"required params is not provided",
+			)
+			return
+		}
+
+		staffProfile, err := authSvc.GetStaffProfile(id)
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, staffProfile)
+	})
+}
+
+func GetUserProfile(
+	router chi.Router,
+	authSvc authsvc.AuthIntf,
+) {
+	router.Get("/user/{id}/profile", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+		id := chi.URLParam(r, "id")
+		if id == "" {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				errors.New("provided id is empty"),
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"required params is not provided",
+			)
+			return
+		}
+
+		userProfile, err := authSvc.GetUserProfile(id)
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, userProfile)
+	})
+}

internal/api/http/auth/update.go

@@ -0,0 +1,75 @@
+package authhttp
+
+import (
+	"errors"
+	authdomain "legalgo-BE-go/internal/domain/auth"
+	authsvc "legalgo-BE-go/internal/services/auth"
+	"legalgo-BE-go/internal/utilities/response"
+	"legalgo-BE-go/internal/utilities/utils"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+)
+
+func UpdateStaff(
+	router chi.Router,
+	authSvc authsvc.AuthIntf,
+) {
+	router.Patch("/staff/{id}/update", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+
+		id := chi.URLParam(r, "id")
+		if id == "" {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				errors.New("provided id is empty"),
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"required params is not provided",
+			)
+			return
+		}
+
+		var spec authdomain.RegisterStaffReq
+
+		if err := utils.UnmarshalBody(r, &spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"failed to unmarshal request",
+			)
+			return
+		}
+
+		staff := authdomain.Staff{
+			ID:       id,
+			Email:    spec.Email,
+			Password: spec.Password,
+			Username: spec.Username,
+		}
+
+		if err := authSvc.UpdateStaff(staff); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		responsePayload := struct{
+			Message string
+		} {
+			Message: "update staff success",
+		}
+
+		response.RespondJsonSuccess(ctx, w, responsePayload)
+	})
+}

internal/domain/auth/login.go

@@ -13,4 +13,19 @@ type LoginRepoResponse struct {
 	ID       string `json:"id"`
 	Email    string `json:"email"`
 	Password string `json:"password"`
+	Username string `json:"username"`
+}
+
+type StaffProfile struct {
+	ID       string `json:"id"`
+	Email    string `json:"email"`
+	Username string `json:"username"`
+}
+
+type UserProfile struct {
+	ID                string `json:"id"`
+	Email             string `json:"email"`
+	SubscribePlanCode string `json:"subscribe_plan_code"`
+	SubscribePlanName string `json:"subscribe_plan_name"`
+	SubscribeStatus   string `json:"subscribe_status"`
 }

internal/domain/auth/register.go

@@ -21,6 +21,12 @@ type RegisterStaffReq struct {
 	Username string `json:"username" validate:"required"`
 }
 
+type UpdateStaffReq struct {
+	Email    string `json:"email"`
+	Password string `json:"password"`
+	Username string `json:"username"`
+}
+
 type Staff struct {
 	ID       string `json:"id"`
 	Email    string `json:"email"`

internal/services/auth/get_staff.go

@@ -0,0 +1,18 @@
+package authsvc
+
+import authdomain "legalgo-BE-go/internal/domain/auth"
+
+func (as *AuthSvc) GetStaffProfile(id string) (*authdomain.StaffProfile, error) {
+	staff, err := as.staffRepo.GetStaffByID(id)
+	if err != nil {
+		return nil, err
+	}
+
+	profile := &authdomain.StaffProfile{
+		ID:       staff.ID,
+		Username: staff.Username,
+		Email:    staff.Email,
+	}
+
+	return profile, nil
+}

internal/services/auth/get_user.go

@@ -0,0 +1,12 @@
+package authsvc
+
+import authdomain "legalgo-BE-go/internal/domain/auth"
+
+func (as *AuthSvc) GetUserProfile(id string) (*authdomain.UserProfile, error) {
+	user, err := as.userRepo.GetUserByID(id)
+	if err != nil {
+		return nil, err
+	}
+
+	return user, nil
+}

internal/services/auth/impl.go

@@ -17,9 +17,13 @@ type AuthSvc struct {
 
 type AuthIntf interface {
 	LoginAsStaff(authdomain.LoginReq) (string, error)
-	LoginAsUser(authdomain.LoginReq) (string, error)
 	RegisterUser(authdomain.RegisterUserReq) (string, error)
+	GetUserProfile(string) (*authdomain.UserProfile, error)
+
+	LoginAsUser(authdomain.LoginReq) (string, error)
 	RegisterStaff(authdomain.RegisterStaffReq) (string, error)
+	UpdateStaff(authdomain.Staff) error
+	GetStaffProfile(string) (*authdomain.StaffProfile, error)
 }
 
 func New(

internal/services/auth/register_staff.go

@@ -23,6 +23,7 @@ func (a *AuthSvc) RegisterStaff(spec authdomain.RegisterStaffReq) (string, error
 		ID:       uuid.NewString(),
 		Email:    spec.Email,
 		Password: hashedPwd,
+		Username: spec.Username,
 	}
 
 	_, err = a.staffRepo.Create(&user)

internal/services/auth/update_staff.go

@@ -0,0 +1,15 @@
+package authsvc
+
+import authdomain "legalgo-BE-go/internal/domain/auth"
+
+func (as *AuthSvc) UpdateStaff(spec authdomain.Staff) error {
+	if _, err := as.staffRepo.GetStaffByID(spec.ID); err != nil {
+		return err
+	}
+
+	if err := as.staffRepo.Update(spec); err != nil {
+		return err
+	}
+
+	return nil
+}

internal/utilities/utils/struct_to_map.go

@@ -0,0 +1,29 @@
+package utils
+
+import (
+	"errors"
+	"reflect"
+)
+
+func StructToMap(s any) (map[string]any, error) {
+	result := make(map[string]any)
+
+	val := reflect.ValueOf(s)
+
+	if val.Kind() != reflect.Struct {
+		return nil, errors.New("provided value is not struct")
+	}
+
+	for i := range val.NumField() {
+		field := val.Type().Field(i)
+		value := val.Field(i)
+
+		if value.IsZero() || value.IsNil() {
+			continue
+		}
+
+		result[field.Name] = value.Interface()
+	}
+
+	return result, nil
+}