event_handler.go 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package handlers
  2. import (
  3. "net/http"
  4. "cmr-backend/internal/apperr"
  5. "cmr-backend/internal/httpapi/middleware"
  6. "cmr-backend/internal/httpx"
  7. "cmr-backend/internal/service"
  8. )
  9. type EventHandler struct {
  10. eventService *service.EventService
  11. }
  12. func NewEventHandler(eventService *service.EventService) *EventHandler {
  13. return &EventHandler{eventService: eventService}
  14. }
  15. func (h *EventHandler) GetDetail(w http.ResponseWriter, r *http.Request) {
  16. eventPublicID := r.PathValue("eventPublicID")
  17. result, err := h.eventService.GetEventDetail(r.Context(), eventPublicID)
  18. if err != nil {
  19. httpx.WriteError(w, err)
  20. return
  21. }
  22. httpx.WriteJSON(w, http.StatusOK, map[string]any{"data": result})
  23. }
  24. func (h *EventHandler) Launch(w http.ResponseWriter, r *http.Request) {
  25. auth := middleware.GetAuthContext(r.Context())
  26. if auth == nil {
  27. httpx.WriteError(w, apperr.New(http.StatusUnauthorized, "unauthorized", "missing auth context"))
  28. return
  29. }
  30. var req service.LaunchEventInput
  31. if err := httpx.DecodeJSON(r, &req); err != nil {
  32. httpx.WriteError(w, apperr.New(http.StatusBadRequest, "invalid_json", "invalid request body"))
  33. return
  34. }
  35. req.EventPublicID = r.PathValue("eventPublicID")
  36. req.UserID = auth.UserID
  37. result, err := h.eventService.LaunchEvent(r.Context(), req)
  38. if err != nil {
  39. httpx.WriteError(w, err)
  40. return
  41. }
  42. httpx.WriteJSON(w, http.StatusOK, map[string]any{"data": result})
  43. }