zZebrahzandGitHub
96bae2f346
* fix(library): clean orphaned provisional items * test(metadata): use item not found sentinel in fake repo * fix(library): preserve abs references during orphan cleanup * fix(library): avoid dropped abs cleanup tables * fix(library): harden provisional orphan cleanup * fix(library): preserve home dismissal series orphans * fix(library): Delete matched items created after the first orphan sweep
42 lines
1.6 KiB
Go
42 lines
1.6 KiB
Go
package migrations
|
|
|
|
import (
|
|
"strings"
|
|
"testing"
|
|
)
|
|
|
|
func TestCleanupOrphanedProvisionalItemsPreservesDurableReferences(t *testing.T) {
|
|
migrationBytes, err := FS.ReadFile("sql/20260607220000_cleanup_orphaned_provisional_items.sql")
|
|
if err != nil {
|
|
t.Fatalf("read migration: %v", err)
|
|
}
|
|
migration := normalizeSQL(string(migrationBytes))
|
|
for _, want := range []string{
|
|
"public.abs_bookmarks ab WHERE ab.library_item_id = mi.content_id",
|
|
"public.abs_playback_sessions aps WHERE aps.content_id = mi.content_id",
|
|
"public.abs_rss_feeds arf WHERE arf.library_item_id = mi.content_id",
|
|
"public.episodes e WHERE e.series_id = mi.content_id",
|
|
"public.podcast_feeds pf WHERE pf.media_item_id = mi.content_id",
|
|
"public.seasons s WHERE s.series_id = mi.content_id",
|
|
"public.user_audio_preferences uap WHERE uap.series_id = mi.content_id",
|
|
"public.user_home_item_dismissals uhid WHERE uhid.media_item_id = mi.content_id",
|
|
"public.user_home_item_dismissals uhid_series WHERE uhid_series.series_id = mi.content_id",
|
|
"public.user_personal_collection_items upci WHERE upci.media_item_id = mi.content_id",
|
|
"public.user_series_playback_preferences uspp WHERE uspp.series_id = mi.content_id",
|
|
"public.user_subtitle_preferences usp WHERE usp.series_id = mi.content_id",
|
|
} {
|
|
if !strings.Contains(migration, normalizeSQL(want)) {
|
|
t.Fatalf("cleanup migration missing durable reference guard %q", want)
|
|
}
|
|
}
|
|
for _, droppedTable := range []string{
|
|
"abs_collection_items",
|
|
"abs_playlist_items",
|
|
"abs_playlists",
|
|
} {
|
|
if strings.Contains(migration, droppedTable) {
|
|
t.Fatalf("cleanup migration references dropped table %q", droppedTable)
|
|
}
|
|
}
|
|
}
|