user.go 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. package handler
  2. import (
  3. "github.com/gin-gonic/gin"
  4. "github.com/go-nunu/nunu-layout-advanced/internal/pkg/request"
  5. "github.com/go-nunu/nunu-layout-advanced/internal/service"
  6. "github.com/go-nunu/nunu-layout-advanced/pkg/helper/resp"
  7. "github.com/pkg/errors"
  8. "net/http"
  9. )
  10. type UserHandler interface {
  11. Register(ctx *gin.Context)
  12. Login(ctx *gin.Context)
  13. GetProfile(ctx *gin.Context)
  14. UpdateProfile(ctx *gin.Context)
  15. }
  16. type userHandler struct {
  17. *Handler
  18. userService service.UserService
  19. }
  20. func NewUserHandler(handler *Handler, userService service.UserService) UserHandler {
  21. return &userHandler{
  22. Handler: handler,
  23. userService: userService,
  24. }
  25. }
  26. func (h *userHandler) Register(ctx *gin.Context) {
  27. req := new(request.RegisterRequest)
  28. if err := ctx.ShouldBindJSON(req); err != nil {
  29. resp.HandleError(ctx, http.StatusBadRequest, 1, errors.Wrap(err, "invalid request").Error(), nil)
  30. return
  31. }
  32. if err := h.userService.Register(ctx, req); err != nil {
  33. resp.HandleError(ctx, http.StatusBadRequest, 1, errors.Wrap(err, "invalid request").Error(), nil)
  34. return
  35. }
  36. resp.HandleSuccess(ctx, nil)
  37. }
  38. func (h *userHandler) Login(ctx *gin.Context) {
  39. var req request.LoginRequest
  40. if err := ctx.ShouldBindJSON(&req); err != nil {
  41. resp.HandleError(ctx, http.StatusBadRequest, 1, errors.Wrap(err, "invalid request").Error(), nil)
  42. return
  43. }
  44. token, err := h.userService.Login(ctx, &req)
  45. if err != nil {
  46. resp.HandleError(ctx, http.StatusUnauthorized, 1, err.Error(), nil)
  47. return
  48. }
  49. resp.HandleSuccess(ctx, gin.H{
  50. "accessToken": token,
  51. })
  52. }
  53. func (h *userHandler) GetProfile(ctx *gin.Context) {
  54. userId := GetUserIdFromCtx(ctx)
  55. if userId == "" {
  56. resp.HandleError(ctx, http.StatusUnauthorized, 1, "unauthorized", nil)
  57. return
  58. }
  59. user, err := h.userService.GetProfile(ctx, userId)
  60. if err != nil {
  61. resp.HandleError(ctx, http.StatusBadRequest, 1, err.Error(), nil)
  62. return
  63. }
  64. resp.HandleSuccess(ctx, user)
  65. }
  66. func (h *userHandler) UpdateProfile(ctx *gin.Context) {
  67. userId := GetUserIdFromCtx(ctx)
  68. var req request.UpdateProfileRequest
  69. if err := ctx.ShouldBindJSON(&req); err != nil {
  70. resp.HandleError(ctx, http.StatusBadRequest, 1, errors.Wrap(err, "invalid request").Error(), nil)
  71. return
  72. }
  73. if err := h.userService.UpdateProfile(ctx, userId, &req); err != nil {
  74. resp.HandleError(ctx, http.StatusBadRequest, 1, err.Error(), nil)
  75. return
  76. }
  77. resp.HandleSuccess(ctx, nil)
  78. }