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

chore: formatting

Browse Source
This commit is contained in:
mkelvers
2026-05-26 22:51:50 +02:00
parent 509ce93904
commit eb9e682b75
5 changed files with 31 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
internal/anime/handler/handler.go
View File

@@ -426,10 +426,10 @@ func (h *AnimeHandler) HandleBrowse(c *gin.Context) {
if c.GetHeader("HX-Request") == "true" && page > 1 { if c.GetHeader("HX-Request") == "true" && page > 1 {
c.HTML(http.StatusOK, "browse.gohtml", gin.H{ c.HTML(http.StatusOK, "browse.gohtml", gin.H{
"_fragment": "anime_card_scroll", "_fragment": "anime_card_scroll",
"Animes": animes, "Animes": animes,
"NextPage": page + 1, "NextPage": page + 1,
"HasNextPage": res.HasNextPage, "HasNextPage": res.HasNextPage,
"Query": q, "Query": q,
"Type": animeType, "Type": animeType,
"Status": status, "Status": status,
@@ -459,9 +459,9 @@ func (h *AnimeHandler) HandleBrowse(c *gin.Context) {
"Studio": studioID, "Studio": studioID,
"StudioName": studioName, "StudioName": studioName,
"SFW": sfw, "SFW": sfw,
"GenresList": genresList, "GenresList": genresList,
"Animes": animes, "Animes": animes,
"HasNextPage": res.HasNextPage, "HasNextPage": res.HasNextPage,
"NextPage": page + 1, "NextPage": page + 1,
"User": user, "User": user,
"WatchlistMap": watchlistMap, "WatchlistMap": watchlistMap,
@@ -481,8 +481,8 @@ func (h *AnimeHandler) HandleBrowse(c *gin.Context) {
"StudioName": studioName, "StudioName": studioName,
"SFW": sfw, "SFW": sfw,
"GenresList": genresList, "GenresList": genresList,
"Animes": animes, "Animes": animes,
"HasNextPage": res.HasNextPage, "HasNextPage": res.HasNextPage,
"NextPage": page + 1, "NextPage": page + 1,
"User": user, "User": user,
"WatchlistMap": watchlistMap, "WatchlistMap": watchlistMap,

12
internal/anime/service/service.go
View File

@@ -255,7 +255,7 @@ func (s *animeService) GetAiringSchedule(ctx context.Context, userID string) ([]
return fetchErr return fetchErr
} }
mu.Lock() mu.Lock()
animes = append(animes, domain.Anime{Anime: anime}) animes = append(animes, domain.Anime{Anime: anime})
mu.Unlock() mu.Unlock()
return nil return nil
}) })
@@ -362,12 +362,12 @@ func (s *animeService) GetRandomAnime(ctx context.Context) (domain.Anime, error)
s.jikan.GetSeasonsUpcoming, s.jikan.GetSeasonsUpcoming,
} { } {
res, fallbackErr := fallback(ctx, 1) res, fallbackErr := fallback(ctx, 1)
if fallbackErr != nil || len(res.Animes) == 0 { if fallbackErr != nil || len(res.Animes) == 0 {
continue continue
}
r := rand.New(rand.NewSource(time.Now().UnixNano()))
return domain.Anime{Anime: res.Animes[r.Intn(len(res.Animes))]}, nil
} }
r := rand.New(rand.NewSource(time.Now().UnixNano()))
return domain.Anime{Anime: res.Animes[r.Intn(len(res.Animes))]}, nil
}
return domain.Anime{}, err return domain.Anime{}, err
} }

10
internal/episodes/module.go
View File

@@ -19,12 +19,12 @@ func episodeAvailabilityEnabled(cfg config.Config) bool {
var Module = fx.Options( var Module = fx.Options(
fx.Provide( fx.Provide(
episodeAvailabilityEnabled, episodeAvailabilityEnabled,
fx.Annotate( fx.Annotate(
func(queries *db.Queries, jikanClient *jikan.Client, providers []domain.EpisodeAvailabilityProvider, enabled bool, metrics *observability.Metrics) domain.EpisodeService { func(queries *db.Queries, jikanClient *jikan.Client, providers []domain.EpisodeAvailabilityProvider, enabled bool, metrics *observability.Metrics) domain.EpisodeService {
return episodeService.NewEpisodeService(queries, jikanClient, providers, enabled, metrics) return episodeService.NewEpisodeService(queries, jikanClient, providers, enabled, metrics)
}, },
),
), ),
),
fx.Provide(func(p *allanime.AllAnimeProvider) []domain.EpisodeAvailabilityProvider { fx.Provide(func(p *allanime.AllAnimeProvider) []domain.EpisodeAvailabilityProvider {
return []domain.EpisodeAvailabilityProvider{p} return []domain.EpisodeAvailabilityProvider{p}
}), }),

10
internal/playback/module.go
View File

@@ -20,11 +20,11 @@ func provideProxyTokenKey(cfg config.Config) service.ProxyTokenKey {
var Module = fx.Options( var Module = fx.Options(
fx.Provide( fx.Provide(
repository.NewPlaybackRepository, repository.NewPlaybackRepository,
fx.Annotate( fx.Annotate(
func(repo domain.PlaybackRepository, providers []domain.Provider, jikan *jikan.Client, episodeSvc domain.EpisodeService, auditSvc domain.AuditService, proxyTokenKey service.ProxyTokenKey) domain.PlaybackService { func(repo domain.PlaybackRepository, providers []domain.Provider, jikan *jikan.Client, episodeSvc domain.EpisodeService, auditSvc domain.AuditService, proxyTokenKey service.ProxyTokenKey) domain.PlaybackService {
return service.NewPlaybackService(repo, providers, jikan, episodeSvc, auditSvc, proxyTokenKey) return service.NewPlaybackService(repo, providers, jikan, episodeSvc, auditSvc, proxyTokenKey)
}, },
), ),
func(svc domain.PlaybackService, animeSvc domain.AnimeService) *handler.PlaybackHandler { func(svc domain.PlaybackService, animeSvc domain.AnimeService) *handler.PlaybackHandler {
return handler.NewPlaybackHandler(svc, animeSvc) return handler.NewPlaybackHandler(svc, animeSvc)
}, },

12
internal/playback/service/service.go
View File

@@ -289,12 +289,12 @@ func (s *playbackService) BuildWatchData(ctx context.Context, animeID int, title
Segments: segments, Segments: segments,
} }
return domain.WatchPageData{ return domain.WatchPageData{
WatchData: watchData, WatchData: watchData,
Anime: domain.Anime{Anime: anime}, Anime: domain.Anime{Anime: anime},
Episodes: canonicalEpisodes.Episodes, Episodes: canonicalEpisodes.Episodes,
CurrentEpID: episode, CurrentEpID: episode,
WatchlistStatus: watchlistStatus, WatchlistStatus: watchlistStatus,
WatchlistIDs: watchlistIDs, WatchlistIDs: watchlistIDs,
Seasons: seasons, Seasons: seasons,
}, nil }, nil