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

refactor: inline single-use getcached wrapper

Browse Source
This commit is contained in:
mkelvers
2026-06-23 17:16:56 +02:00
parent c777de9f06
commit f6ed2c673d
2 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/episodes/service/cache_store.go
View File

@@ -131,10 +131,6 @@ func (s *EpisodeService) markFailure(ctx context.Context, anime domain.Anime, ca
)
}
func (s *EpisodeService) getCached(ctx context.Context, anime domain.Anime) (domain.CanonicalEpisodeList, bool) {
return s.getDecodedCached(ctx, anime)
}
func (s *EpisodeService) getFreshCached(ctx context.Context, anime domain.Anime) (domain.CanonicalEpisodeList, bool) {
row, err := s.queries.GetEpisodeAvailabilityCache(ctx, int64(anime.MalID))
if err != nil {

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

@@ -141,7 +141,7 @@ func (s *EpisodeService) refresh(ctx context.Context, anime domain.Anime) (domai
providerAvailability, source, providerErr := s.fetchProviderAvailability(ctx, anime)
if providerErr != nil {
s.markFailure(ctx, anime, providerErr)
if cached, ok := s.getCached(ctx, anime); ok {
if cached, ok := s.getDecodedCached(ctx, anime); ok {
observability.Warn(
"episodes_provider_failed_serving_stale_cache",
"episodes",