controllers/event_controller.go

package controllers

import (
	"errors"
	"net/http"
	"strconv"
	"time"

	"abdanhafidz.com/go-boilerplate/models/dto"
	entity "abdanhafidz.com/go-boilerplate/models/entity"
	http_error "abdanhafidz.com/go-boilerplate/models/error"
	"abdanhafidz.com/go-boilerplate/services"
	"abdanhafidz.com/go-boilerplate/utils"
	"github.com/gin-gonic/gin"
)

type EventController interface {
	List(ctx *gin.Context)
	DetailBySlug(ctx *gin.Context)
	Join(ctx *gin.Context)
}

type eventController struct {
	eventService services.EventService
}

func NewEventController(eventService services.EventService) EventController {
	return &eventController{eventService: eventService}
}

// Event List godoc
// @Summary      List Events
// @Description  Retrieve a paginated list of events with optional filters
// @Tags         Event
// @Accept       json
// @Produce      json
// @Param        limit           query     int     false  "Number of items per page"            default(10)
// @Param        page            query     int     false  "Page number"                         default(1)
// @Param        search          query     string  false  "Search term for event titles"
// @Param        sortBy          query     string  false  "Field to sort by (e.g., 'date', 'title')"
// @Param        order           query     string  false  "Sort order ('asc' or 'desc')"
// @Param        registerStatus  query     int     false  "Filter by registration status"
// @Param        status          query     string  false  "Filter by event status (upcoming, ongoing, ended)"
// @Success	  	 200  {object}  dto.SuccessResponse[[]entity.Events]
// @Failure      400  {object}  dto.ErrorResponse
// @Router       /api/v1/events [get]
func (c *eventController) List(ctx *gin.Context) {
	limit, _ := strconv.Atoi(ctx.DefaultQuery("limit", "10"))
	page, _ := strconv.Atoi(ctx.DefaultQuery("page", "1"))
	search := ctx.DefaultQuery("search", "")
	sortBy := ctx.DefaultQuery("sortBy", "")
	order := ctx.DefaultQuery("order", "")

	var registerStatus *int
	if val := ctx.Query("registerStatus"); val != "" {
		if i, err := strconv.Atoi(val); err == nil {
			registerStatus = &i
		}
	}

	var status *string

	if val := ctx.Query("status"); val != "" {
		if val == entity.EventStatusUpcoming || val == entity.EventStatusOngoing || val == entity.EventStatusEnded {
			status = &val
		}
	}
	if limit < 1 {
		limit = 10
	} else if limit > 50 {
		limit = 50
	}
	if page < 1 {
		page = 1
	}

	offset := (page - 1) * limit
	p := entity.Pagination{Limit: limit, Offset: offset, Search: search, SortBy: sortBy, Order: order, RegisterStatus: registerStatus, Status: status}

	accountId := ParseAccountId(ctx)

	list, total, err := c.eventService.List(ctx.Request.Context(), accountId, p)
	var totalPages int
	if total == 0 {
		totalPages = 1
	} else {
		totalPages = int((total + int64(limit) - 1) / int64(limit))
	}
	if page > totalPages {
		page = totalPages
		offset = (page - 1) * limit
		p.Offset = offset
		list, total, err = c.eventService.List(ctx.Request.Context(), accountId, p)
	}
	meta := gin.H{
		"totalItems":  total,
		"totalPages":  totalPages,
		"currentPage": page,
	}

	ResponseJSON(ctx, meta, list, err)
}

// Event Detail By Slug godoc
// @Summary      Get Event Detail by Slug
// @Description  Retrieve detailed information about a specific event using its slug
// @Tags         Event
// @Accept       json
// @Produce      json
// @Param        event_slug  path      string  true  "Event Slug"
// @Success      200         {object}  dto.SuccessResponse[dto.EventDetailResponse]
// @Failure      400         {object}  dto.ErrorResponse
// @Router       /api/v1/events/{event_slug} [get]
func (c *eventController) DetailBySlug(ctx *gin.Context) {
	slug := ctx.Param("event_slug")
	accountId := ParseAccountId(ctx)
	res, err := c.eventService.DetailBySlug(ctx.Request.Context(), slug, accountId)
	ResponseJSON(ctx, gin.H{"event_slug": slug, "id_account": accountId}, res, err)
}

// Join Event godoc
// @Summary      Join Event
// @Description  Register the authenticated user for an event using an event code
// @Tags         Event
// @Accept       json
// @Produce      json
// @Param        request  body      dto.JoinEventRequest  true  "Join Event Request"
// @Success      200      {object}  dto.SuccessResponse[dto.EventDetailResponse]
// @Failure      400      {object}  dto.ErrorResponse
// @Failure      402      {object}  dto.RegisterEventPaymentActionRequiredResponse
// @Security     BearerAuth
// @Router       /api/v1/events/register-event [post]
func (c *eventController) Join(ctx *gin.Context) {
	req := RequestJSON[dto.JoinEventRequest](ctx)

	if err := utils.ValidateCode(req.EventCode); err != nil {
		ResponseJSON(ctx, req, gin.H{}, err)
		return
	}

	accountId := ParseAccountId(ctx)
	res, err := c.eventService.JoinByCode(ctx.Request.Context(), accountId, req.EventCode)

	if errors.Is(err, http_error.PAYMENT_REQUIRED) {
		ctx.JSON(http.StatusPaymentRequired, dto.RegisterEventPaymentActionRequiredResponse{
			Data: dto.RegisterEventPaymentActionRequiredData{
				AccountID:          res.EventPayment.AccountId.String(),
				Amount:             res.EventPayment.Amount,
				EventID:            res.EventPayment.EventId.String(),
				ExpiredAt:          res.EventPayment.ExpiredAt.Format(time.RFC3339),
				ID:                 res.EventPayment.Id.String(),
				InvoiceID:          res.EventPayment.InvoiceId,
				InvoiceURL:         res.EventPayment.InvoiceUrl,
				Status:             res.EventPayment.Status,
				TransactionAt:      res.EventPayment.TransactionAt.Format(time.RFC3339),
				MayarTransactionID: res.EventPayment.ExternalId,
			},
			Message:  http_error.PAYMENT_REQUIRED.Error(),
			MetaData: req.EventCode,
			Status:   "action_required",
		})
		return
	}

	ResponseJSON(ctx, req, res, err)
}