141 lines
3.2 KiB
Go
141 lines
3.2 KiB
Go
// Package watchlist manages user watchlist entries and related operations.
|
|
package watchlist
|
|
|
|
import (
|
|
"mal/internal/domain"
|
|
"mal/internal/server"
|
|
"net/http"
|
|
"strconv"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
)
|
|
|
|
type WatchlistHandler struct {
|
|
svc domain.WatchlistService
|
|
}
|
|
|
|
func NewWatchlistHandler(svc domain.WatchlistService) *WatchlistHandler {
|
|
return &WatchlistHandler{svc: svc}
|
|
}
|
|
|
|
func (h *WatchlistHandler) Register(r *gin.Engine) {
|
|
r.POST("/api/watchlist", h.HandleUpdateWatchlist)
|
|
r.DELETE("/api/watchlist/:id", h.HandleDeleteWatchlist)
|
|
r.DELETE("/api/continue-watching/:id", h.HandleDeleteContinueWatching)
|
|
r.GET("/watchlist", h.HandleGetWatchlist)
|
|
}
|
|
|
|
func (h *WatchlistHandler) HandleUpdateWatchlist(c *gin.Context) {
|
|
userID := server.CurrentUserID(c)
|
|
|
|
var body struct {
|
|
AnimeID int64 `json:"animeId"`
|
|
Status string `json:"status"`
|
|
}
|
|
if err := c.ShouldBindJSON(&body); err != nil || body.AnimeID <= 0 || body.Status == "" {
|
|
server.RespondHTMLOrJSONError(c, http.StatusBadRequest, "invalid request body")
|
|
return
|
|
}
|
|
|
|
err := h.svc.UpdateEntry(c.Request.Context(), userID, body.AnimeID, body.Status)
|
|
if err != nil {
|
|
server.RespondError(
|
|
c,
|
|
http.StatusInternalServerError,
|
|
"watchlist_update_failed",
|
|
"watchlist",
|
|
"failed to update watchlist entry",
|
|
map[string]any{"user_id": userID, "anime_id": body.AnimeID, "status": body.Status},
|
|
err,
|
|
)
|
|
return
|
|
}
|
|
|
|
c.Status(http.StatusOK)
|
|
}
|
|
|
|
func (h *WatchlistHandler) HandleDeleteWatchlist(c *gin.Context) {
|
|
userID := server.CurrentUserID(c)
|
|
|
|
animeID, ok := parseAnimeIDParam(c)
|
|
if !ok {
|
|
return
|
|
}
|
|
|
|
err := h.svc.RemoveEntry(c.Request.Context(), userID, animeID)
|
|
if err != nil {
|
|
server.RespondError(
|
|
c,
|
|
http.StatusInternalServerError,
|
|
"watchlist_remove_failed",
|
|
"watchlist",
|
|
"failed to remove watchlist entry",
|
|
map[string]any{"user_id": userID, "anime_id": animeID},
|
|
err,
|
|
)
|
|
return
|
|
}
|
|
|
|
c.Status(http.StatusOK)
|
|
}
|
|
|
|
func (h *WatchlistHandler) HandleDeleteContinueWatching(c *gin.Context) {
|
|
userID := server.CurrentUserID(c)
|
|
|
|
animeID, ok := parseAnimeIDParam(c)
|
|
if !ok {
|
|
return
|
|
}
|
|
|
|
err := h.svc.DeleteContinueWatching(c.Request.Context(), userID, animeID)
|
|
if err != nil {
|
|
server.RespondError(
|
|
c,
|
|
http.StatusInternalServerError,
|
|
"continue_watching_delete_failed",
|
|
"watchlist",
|
|
"failed to delete continue watching entry",
|
|
map[string]any{"user_id": userID, "anime_id": animeID},
|
|
err,
|
|
)
|
|
return
|
|
}
|
|
|
|
c.Status(http.StatusOK)
|
|
}
|
|
|
|
func parseAnimeIDParam(c *gin.Context) (int64, bool) {
|
|
animeID, err := strconv.ParseInt(c.Param("id"), 10, 64)
|
|
if err != nil || animeID <= 0 {
|
|
server.RespondHTMLOrJSONError(c, http.StatusBadRequest, "invalid anime id")
|
|
return 0, false
|
|
}
|
|
|
|
return animeID, true
|
|
}
|
|
|
|
func (h *WatchlistHandler) HandleGetWatchlist(c *gin.Context) {
|
|
user := server.CurrentUser(c)
|
|
userID := server.CurrentUserID(c)
|
|
|
|
entries, err := h.svc.GetWatchlist(c.Request.Context(), userID)
|
|
if err != nil {
|
|
server.RespondError(
|
|
c,
|
|
http.StatusInternalServerError,
|
|
"watchlist_load_failed",
|
|
"watchlist",
|
|
"failed to load watchlist",
|
|
map[string]any{"user_id": userID},
|
|
err,
|
|
)
|
|
return
|
|
}
|
|
|
|
c.HTML(http.StatusOK, "watchlist.gohtml", gin.H{
|
|
"AllEntries": entries,
|
|
"CurrentPath": "/watchlist",
|
|
"User": user,
|
|
})
|
|
}
|