refactor: move watchlist handler from subdirectory

internal/watchlist/handler.go

@@ -0,0 +1,148 @@
+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) {
+	user, _ := c.Get("User")
+	userID := ""
+	if u, ok := user.(*domain.User); ok {
+		userID = u.ID
+	}
+
+	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) {
+	user, _ := c.Get("User")
+	userID := ""
+	if u, ok := user.(*domain.User); ok {
+		userID = u.ID
+	}
+
+	animeID, err := strconv.ParseInt(c.Param("id"), 10, 64)
+
+	if err != nil || animeID <= 0 {
+		server.RespondHTMLOrJSONError(c, http.StatusBadRequest, "invalid anime id")
+		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) {
+	user, _ := c.Get("User")
+	userID := ""
+	if u, ok := user.(*domain.User); ok {
+		userID = u.ID
+	}
+
+	animeID, err := strconv.ParseInt(c.Param("id"), 10, 64)
+
+	if err != nil || animeID <= 0 {
+		server.RespondHTMLOrJSONError(c, http.StatusBadRequest, "invalid anime id")
+		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 (h *WatchlistHandler) HandleGetWatchlist(c *gin.Context) {
+	user, _ := c.Get("User")
+	userID := ""
+	if u, ok := user.(*domain.User); ok {
+		userID = u.ID
+	}
+
+	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,
+	})
+}