feat: add classification fields to episode service

internal/episodes/service/service.go

@@ -4,6 +4,7 @@ package service
 import (
 	"context"
 	"fmt"
+	"sync"
 	"time"
 
 	"mal/integrations/jikan"
@@ -23,13 +24,15 @@ type realClock struct{}
 func (realClock) Now() time.Time { return time.Now() }
 
 type EpisodeService struct {
-	queries   *db.Queries
-	jikan     *jikan.Client
-	providers []domain.EpisodeAvailabilityProvider
-	titles    domain.EpisodeTitleProvider
-	clock     Clock
-	enabled   bool
-	titleLoad singleflight.Group
+	queries            *db.Queries
+	jikan              *jikan.Client
+	providers          []domain.EpisodeAvailabilityProvider
+	titles             domain.EpisodeTitleProvider
+	clock              Clock
+	enabled            bool
+	titleLoad          singleflight.Group
+	classificationLoad singleflight.Group
+	cacheMu            sync.Mutex
 }
 
 func NewEpisodeService(queries *db.Queries, jikanClient *jikan.Client, providers []domain.EpisodeAvailabilityProvider, titles domain.EpisodeTitleProvider, enabled bool) domain.EpisodeService {

internal/episodes/service/titles.go

@@ -50,6 +50,9 @@ func (s *EpisodeService) loadEpisodeTitles(ctx context.Context, anime domain.Ani
 		return domain.CanonicalEpisodeList{}, err
 	}
 
+	s.cacheMu.Lock()
+	defer s.cacheMu.Unlock()
+
 	payload, row, ok := s.cachedEpisodePayload(ctx, anime)
 	if !ok {
 		return domain.CanonicalEpisodeList{}, errors.New("episode titles: episode availability cache disappeared")
@@ -59,7 +62,7 @@ func (s *EpisodeService) loadEpisodeTitles(ctx context.Context, anime domain.Ani
 	if !changed {
 		return payload, nil
 	}
-	if err := s.storeEnrichedTitles(ctx, row, payload); err != nil {
+	if err := s.storeEnrichedPayload(ctx, row, payload); err != nil {
 		return domain.CanonicalEpisodeList{}, err
 	}
 
@@ -88,10 +91,10 @@ func (s *EpisodeService) cachedEpisodePayload(ctx context.Context, anime domain.
 	return enrichCachedPayload(payload, row), row, true
 }
 
-func (s *EpisodeService) storeEnrichedTitles(ctx context.Context, row db.EpisodeAvailabilityCache, payload domain.CanonicalEpisodeList) error {
+func (s *EpisodeService) storeEnrichedPayload(ctx context.Context, row db.EpisodeAvailabilityCache, payload domain.CanonicalEpisodeList) error {
 	body, err := json.Marshal(payload)
 	if err != nil {
-		return fmt.Errorf("episode titles: encode cache: %w", err)
+		return fmt.Errorf("episode metadata: encode cache: %w", err)
 	}
 	err = s.queries.UpsertEpisodeAvailabilityCache(ctx, db.UpsertEpisodeAvailabilityCacheParams{
 		AnimeID:       row.AnimeID,
@@ -104,7 +107,7 @@ func (s *EpisodeService) storeEnrichedTitles(ctx context.Context, row db.Episode
 		LastError:     row.LastError,
 	})
 	if err != nil {
-		return fmt.Errorf("episode titles: update cache: %w", err)
+		return fmt.Errorf("episode metadata: update cache: %w", err)
 	}
 	return nil
 }