users.go 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161
  1. package handlers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "net/http"
  6. "github.com/go-chi/chi/v5"
  7. "github.com/photoplaces/backend/internal/middleware"
  8. "github.com/photoplaces/backend/internal/models"
  9. "github.com/photoplaces/backend/internal/repository"
  10. "github.com/photoplaces/backend/internal/validator"
  11. )
  12. type UserHandler struct {
  13. userRepo *repository.UserRepo
  14. }
  15. func NewUserHandler(userRepo *repository.UserRepo) *UserHandler {
  16. return &UserHandler{userRepo: userRepo}
  17. }
  18. func (h *UserHandler) GetProfile(w http.ResponseWriter, r *http.Request) {
  19. userID := chi.URLParam(r, "id")
  20. if userID == "" {
  21. userID = middleware.GetUserID(r.Context())
  22. }
  23. user, err := h.userRepo.GetByID(r.Context(), userID)
  24. if err != nil {
  25. writeError(w, http.StatusInternalServerError, err.Error())
  26. return
  27. }
  28. if user == nil {
  29. writeError(w, http.StatusNotFound, "user not found")
  30. return
  31. }
  32. writeJSON(w, http.StatusOK, user)
  33. }
  34. type updateMeRequest struct {
  35. Name *string `json:"name" validate:"omitempty,max=255"`
  36. Phone *string `json:"phone" validate:"omitempty,max=20"`
  37. Bio *string `json:"bio" validate:"omitempty,max=2000"`
  38. AvatarURL *string `json:"avatar_url" validate:"omitempty,url,max=500"`
  39. Country *string `json:"country" validate:"omitempty,len=2"`
  40. }
  41. func (h *UserHandler) UpdateMe(w http.ResponseWriter, r *http.Request) {
  42. userID := middleware.GetUserID(r.Context())
  43. user, err := h.userRepo.GetByID(r.Context(), userID)
  44. if err != nil {
  45. writeError(w, http.StatusInternalServerError, err.Error())
  46. return
  47. }
  48. var req updateMeRequest
  49. if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
  50. writeError(w, http.StatusBadRequest, "invalid request body")
  51. return
  52. }
  53. if err := validator.Validate(req); err != nil {
  54. writeValidationError(w, err)
  55. return
  56. }
  57. if req.Name != nil { user.Name = req.Name }
  58. if req.Phone != nil { user.Phone = req.Phone }
  59. if req.Bio != nil { user.Bio = req.Bio }
  60. if req.AvatarURL != nil { user.AvatarURL = req.AvatarURL }
  61. if req.Country != nil { user.Country = req.Country }
  62. if err := h.userRepo.Update(r.Context(), user); err != nil {
  63. writeError(w, http.StatusInternalServerError, err.Error())
  64. return
  65. }
  66. writeJSON(w, http.StatusOK, user)
  67. }
  68. // Admin endpoints
  69. type adminUpdateUserRequest struct {
  70. Role *string `json:"role" validate:"omitempty,user_role"`
  71. Status *string `json:"status" validate:"omitempty,user_status"`
  72. }
  73. func (h *UserHandler) AdminUpdateUser(w http.ResponseWriter, r *http.Request) {
  74. id := chi.URLParam(r, "id")
  75. var req adminUpdateUserRequest
  76. if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
  77. writeError(w, http.StatusBadRequest, "invalid request body")
  78. return
  79. }
  80. if err := validator.Validate(req); err != nil {
  81. writeValidationError(w, err)
  82. return
  83. }
  84. if req.Role != nil {
  85. if err := h.userRepo.UpdateRole(r.Context(), id, *req.Role); err != nil {
  86. writeError(w, http.StatusInternalServerError, err.Error())
  87. return
  88. }
  89. }
  90. if req.Status != nil {
  91. if err := h.userRepo.UpdateStatus(r.Context(), id, *req.Status); err != nil {
  92. writeError(w, http.StatusInternalServerError, err.Error())
  93. return
  94. }
  95. }
  96. user, err := h.userRepo.GetByID(r.Context(), id)
  97. if err != nil {
  98. writeError(w, http.StatusInternalServerError, err.Error())
  99. return
  100. }
  101. writeJSON(w, http.StatusOK, user)
  102. }
  103. func (h *UserHandler) AdminListUsers(w http.ResponseWriter, r *http.Request) {
  104. filter := models.UserFilter{
  105. Role: r.URL.Query().Get("role"),
  106. Status: r.URL.Query().Get("status"),
  107. }
  108. if limit := r.URL.Query().Get("limit"); limit != "" {
  109. if v, err := parseInt(limit); err == nil {
  110. filter.Limit_ = v
  111. }
  112. }
  113. users, err := h.userRepo.List(r.Context(), filter)
  114. if err != nil {
  115. writeError(w, http.StatusInternalServerError, err.Error())
  116. return
  117. }
  118. if users == nil {
  119. users = []*models.User{}
  120. }
  121. writeJSON(w, http.StatusOK, map[string]interface{}{"data": users})
  122. }
  123. func parseInt(s string) (int, error) {
  124. var n int
  125. for _, c := range s {
  126. if c < '0' || c > '9' {
  127. return 0, fmt.Errorf("not a number")
  128. }
  129. n = n*10 + int(c-'0')
  130. }
  131. return n, nil
  132. }