users.go 4.1 KB

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