sulthan
01301805fb
Adds favorite, latest_chapter and latest_chapter_num to the bookmark record, with an idempotent ALTER TABLE migration so the already-deployed database picks them up. updated_at now moves only when a bookmark is new or last_chapter_num changes. Clients order their list by updated_at, so favoriting a series or recording a newly published chapter must not disturb that order. Upsert consequently returns the row as stored and the handler echoes that rather than the request payload, since the candidate timestamp it sends is often discarded. Scanning also tolerates NULL in the optional columns, which a database created before this code can legitimately contain. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
98 lines
2.5 KiB
Go
98 lines
2.5 KiB
Go
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"log"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
type bookmarkHandler struct {
|
|
store *Store
|
|
}
|
|
|
|
func writeJSON(w http.ResponseWriter, status int, v any) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(status)
|
|
if v != nil {
|
|
if err := json.NewEncoder(w).Encode(v); err != nil {
|
|
log.Printf("encode response: %v", err)
|
|
}
|
|
}
|
|
}
|
|
|
|
// list returns all bookmarks. GET /bookmarks
|
|
func (h *bookmarkHandler) list(w http.ResponseWriter, r *http.Request) {
|
|
items, err := h.store.List()
|
|
if err != nil {
|
|
log.Printf("list: %v", err)
|
|
http.Error(w, "internal error", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
writeJSON(w, http.StatusOK, items)
|
|
}
|
|
|
|
// put upserts one bookmark. PUT /bookmarks/{key}
|
|
func (h *bookmarkHandler) put(w http.ResponseWriter, r *http.Request) {
|
|
key := r.PathValue("key")
|
|
if key == "" {
|
|
http.Error(w, "missing key", http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
var b Bookmark
|
|
if err := json.NewDecoder(http.MaxBytesReader(w, r.Body, 1<<16)).Decode(&b); err != nil {
|
|
http.Error(w, "invalid JSON body", http.StatusBadRequest)
|
|
return
|
|
}
|
|
|
|
// Path key is authoritative; derive site/series_id from it when the body
|
|
// omits them so the stored row is always self-consistent.
|
|
b.Key = key
|
|
if b.Site == "" || b.SeriesID == "" {
|
|
if site, series, ok := strings.Cut(key, ":"); ok {
|
|
if b.Site == "" {
|
|
b.Site = site
|
|
}
|
|
if b.SeriesID == "" {
|
|
b.SeriesID = series
|
|
}
|
|
}
|
|
}
|
|
// Candidate timestamp, not a decision: Upsert keeps the stored one unless
|
|
// reading progress actually moved. Any client value is ignored.
|
|
b.UpdatedAt = time.Now().UnixMilli()
|
|
|
|
stored, err := h.store.Upsert(b)
|
|
if err != nil {
|
|
log.Printf("upsert: %v", err)
|
|
http.Error(w, "internal error", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
// Echo the stored row: clients adopt this as their cached copy, so it must
|
|
// carry the authoritative updated_at rather than the candidate above.
|
|
writeJSON(w, http.StatusOK, stored)
|
|
}
|
|
|
|
// delete removes one bookmark. DELETE /bookmarks/{key}
|
|
func (h *bookmarkHandler) delete(w http.ResponseWriter, r *http.Request) {
|
|
key := r.PathValue("key")
|
|
if key == "" {
|
|
http.Error(w, "missing key", http.StatusBadRequest)
|
|
return
|
|
}
|
|
if err := h.store.Delete(key); err != nil {
|
|
log.Printf("delete: %v", err)
|
|
http.Error(w, "internal error", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
w.WriteHeader(http.StatusNoContent)
|
|
}
|
|
|
|
func healthz(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "text/plain")
|
|
w.WriteHeader(http.StatusOK)
|
|
_, _ = w.Write([]byte("ok"))
|
|
}
|