added seasons list

2026-02-01 13:25:11 +11:00
parent 96d534f045
commit 81d4ceb354
17 changed files with 660 additions and 679 deletions
--- a/internal/handlers/seasons.go
+++ b/internal/handlers/seasons.go
@@ -0,0 +1,128 @@
+package handlers
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"strconv"
+	"time"
+
+	"git.haelnorr.com/h/golib/hws"
+	"git.haelnorr.com/h/oslstats/internal/db"
+	"git.haelnorr.com/h/oslstats/internal/view/page"
+	"github.com/pkg/errors"
+	"github.com/uptrace/bun"
+)
+
+func SeasonsPage(
+	s *hws.Server,
+	conn *bun.DB,
+) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		ctx, cancel := context.WithTimeout(r.Context(), 15*time.Second)
+		defer cancel()
+		tx, err := conn.BeginTx(ctx, nil)
+		if err != nil {
+			throwInternalServiceError(s, w, r, "Database error", errors.Wrap(err, "conn.BeginTx"))
+			return
+		}
+		defer tx.Rollback()
+		var pageNum, perPage int
+		var order bun.Order
+		var orderBy string
+		if pageStr := r.URL.Query().Get("page"); pageStr != "" {
+			pageNum, err = strconv.Atoi(pageStr)
+			if err != nil {
+				throwBadRequest(s, w, r, "Invalid page number", err)
+				return
+			}
+		}
+		if perPageStr := r.URL.Query().Get("per_page"); perPageStr != "" {
+			perPage, err = strconv.Atoi(perPageStr)
+			if err != nil {
+				throwBadRequest(s, w, r, "Invalid per_page number", err)
+				return
+			}
+		}
+		order = bun.Order(r.URL.Query().Get("order"))
+		orderBy = r.URL.Query().Get("order_by")
+		pageOpts := &db.PageOpts{
+			Page:    pageNum,
+			PerPage: perPage,
+			Order:   order,
+			OrderBy: orderBy,
+		}
+		seasons, err := db.ListSeasons(ctx, tx, pageOpts)
+		if err != nil {
+			throwInternalServiceError(s, w, r, "Database error", errors.Wrap(err, "db.ListSeasons"))
+			return
+		}
+		tx.Commit()
+		page.SeasonsPage(seasons).Render(r.Context(), w)
+	})
+}
+
+func SeasonsList(
+	s *hws.Server,
+	conn *bun.DB,
+) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		ctx, cancel := context.WithTimeout(r.Context(), 15*time.Second)
+		defer cancel()
+
+		// Parse form values
+		if err := r.ParseForm(); err != nil {
+			throwBadRequest(s, w, r, "Invalid form data", err)
+			return
+		}
+
+		// Extract pagination/sort params from form
+		var pageNum, perPage int
+		var order bun.Order
+		var orderBy string
+		var err error
+
+		if pageStr := r.FormValue("page"); pageStr != "" {
+			pageNum, err = strconv.Atoi(pageStr)
+			if err != nil {
+				throwBadRequest(s, w, r, "Invalid page number", err)
+				return
+			}
+		}
+		if perPageStr := r.FormValue("per_page"); perPageStr != "" {
+			perPage, err = strconv.Atoi(perPageStr)
+			if err != nil {
+				throwBadRequest(s, w, r, "Invalid per_page number", err)
+				return
+			}
+		}
+		order = bun.Order(r.FormValue("order"))
+		orderBy = r.FormValue("order_by")
+
+		pageOpts := &db.PageOpts{
+			Page:    pageNum,
+			PerPage: perPage,
+			Order:   order,
+			OrderBy: orderBy,
+		}
+		fmt.Println(pageOpts)
+
+		// Database query
+		tx, err := conn.BeginTx(ctx, nil)
+		if err != nil {
+			throwInternalServiceError(s, w, r, "Database error", errors.Wrap(err, "conn.BeginTx"))
+			return
+		}
+		defer tx.Rollback()
+
+		seasons, err := db.ListSeasons(ctx, tx, pageOpts)
+		if err != nil {
+			throwInternalServiceError(s, w, r, "Database error", errors.Wrap(err, "db.ListSeasons"))
+			return
+		}
+		tx.Commit()
+
+		// Return only the list component (hx-push-url handles URL update client-side)
+		page.SeasonsList(seasons).Render(r.Context(), w)
+	})
+}