fix: handle db errors in watchlist update entry

This commit is contained in:
2026-06-16 10:08:15 +02:00
committed by Milas Holsting
parent f4486655d1
commit f39fcacadc

View File

@@ -3,6 +3,7 @@ package watchlist
import ( import (
"context" "context"
"database/sql" "database/sql"
"mal/integrations/jikan" "mal/integrations/jikan"
"mal/internal/db" "mal/internal/db"
"mal/internal/domain" "mal/internal/domain"
@@ -47,10 +48,13 @@ func (s *watchlistService) UpdateEntry(ctx context.Context, userID string, anime
} }
} }
existing, _ := repo.GetWatchListEntry(txCtx, db.GetWatchListEntryParams{ existing, err := repo.GetWatchListEntry(txCtx, db.GetWatchListEntryParams{
UserID: userID, UserID: userID,
AnimeID: animeID, AnimeID: animeID,
}) })
if err != nil && err != sql.ErrNoRows {
return err
}
_, err = repo.UpsertWatchListEntry(txCtx, db.UpsertWatchListEntryParams{ _, err = repo.UpsertWatchListEntry(txCtx, db.UpsertWatchListEntryParams{
ID: uuid.New().String(), ID: uuid.New().String(),