melosh/mal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: episode refresh resilience and allanime fallback

Browse Source
This commit is contained in:
mkelvers
2026-05-29 21:12:53 +02:00
committed by Milas Holsting
parent 9383e132e7
commit 704b03655b
2 changed files with 35 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
integrations/playback/allanime/client.go
View File

@@ -220,6 +220,7 @@ func (c *AllAnimeProvider) GetEpisodeAvailabilityByProviderID(ctx context.Contex
func (c *AllAnimeProvider) resolveShowIDStrict(ctx context.Context, animeID int, titleCandidates []string, mode string) (string, error) { func (c *AllAnimeProvider) resolveShowIDStrict(ctx context.Context, animeID int, titleCandidates []string, mode string) (string, error) {
targetMalIDStr := strconv.Itoa(animeID) targetMalIDStr := strconv.Itoa(animeID)
var firstAvailableShowID string
for _, title := range titleCandidates { for _, title := range titleCandidates {
searchResults, err := c.Search(ctx, title, mode) searchResults, err := c.Search(ctx, title, mode)
if err != nil { if err != nil {
@@ -229,8 +230,14 @@ func (c *AllAnimeProvider) resolveShowIDStrict(ctx context.Context, animeID int,
if res.MalID == targetMalIDStr { if res.MalID == targetMalIDStr {
return res.ID, nil return res.ID, nil
} }
if firstAvailableShowID == "" {
firstAvailableShowID = res.ID
}
} }
} }
if firstAvailableShowID != "" {
return firstAvailableShowID, nil
}
return "", fmt.Errorf("allanime: no strict mal id match for %d", animeID) return "", fmt.Errorf("allanime: no strict mal id match for %d", animeID)
} }

31
internal/episodes/service/service.go
View File

@@ -80,7 +80,20 @@ func (s *EpisodeService) RefreshTrackedDue(ctx context.Context, limit int) error
return fmt.Errorf("get due tracked anime: %w", err) return fmt.Errorf("get due tracked anime: %w", err)
} }
for _, id := range ids { for i, id := range ids {
if ctx.Err() != nil {
observability.Warn(
"episodes_worker_tick_interrupted",
"episodes",
"",
map[string]any{
"anime_id": id,
"remaining": len(ids) - i,
},
ctx.Err(),
)
break
}
anime, err := s.jikan.GetAnimeByID(ctx, int(id)) anime, err := s.jikan.GetAnimeByID(ctx, int(id))
if err != nil { if err != nil {
observability.Warn( observability.Warn(
@@ -152,7 +165,13 @@ func (s *EpisodeService) refresh(ctx context.Context, anime domain.Anime) (domai
return cached, nil return cached, nil
} }
if jikanErr == nil { if jikanErr == nil {
return s.store(ctx, anime, jikanEpisodes, domain.EpisodeAvailability{}, "jikan_fallback", now, false) storeCtx := ctx
if ctx.Err() != nil {
var cancel context.CancelFunc
storeCtx, cancel = context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
}
return s.store(storeCtx, anime, jikanEpisodes, domain.EpisodeAvailability{}, "jikan_fallback", now, false)
} }
return domain.CanonicalEpisodeList{}, providerErr return domain.CanonicalEpisodeList{}, providerErr
} }
@@ -385,7 +404,13 @@ func (s *EpisodeService) markFailure(ctx context.Context, anime domain.Anime, ca
nextSQL = sql.NullTime{Time: next, Valid: true} nextSQL = sql.NullTime{Time: next, Valid: true}
} }
err := s.queries.MarkEpisodeAvailabilityRefreshFailed(ctx, db.MarkEpisodeAvailabilityRefreshFailedParams{ writeCtx := ctx
if ctx.Err() != nil {
var cancel context.CancelFunc
writeCtx, cancel = context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
}
err := s.queries.MarkEpisodeAvailabilityRefreshFailed(writeCtx, db.MarkEpisodeAvailabilityRefreshFailedParams{
LastAttemptAt: sql.NullTime{Time: now, Valid: true}, LastAttemptAt: sql.NullTime{Time: now, Valid: true},
LastError: truncate(cause.Error(), 400), LastError: truncate(cause.Error(), 400),
NextRefreshAt: nextSQL, NextRefreshAt: nextSQL,