added GetCurrentlyWatchingAnimesContext

This commit is contained in:
milarin 2023-01-16 15:04:56 +01:00
parent d266f73152
commit 8b4651fad4

View File

@ -19,13 +19,17 @@ func GetAnimeListByAnimeID() (map[anilist.MediaID]*anilist.MediaList, error) {
}
func GetCurrentlyWatchingAnimes() (<-chan *anilist.MediaList, error) {
return GetCurrentlyWatchingAnimesContext(context.Background())
}
func GetCurrentlyWatchingAnimesContext(ctx context.Context) (<-chan *anilist.MediaList, error) {
token, err := GetAnilistAccessToken()
if err != nil {
return nil, ErrAnimeListNotObtainable.Wrap(err, "access token acquisition failed")
}
media := channel.Map(channel.Of(AnimeStatuses...), func(status anilist.MediaListStatus) <-chan *anilist.MediaList {
return anilist.NewApi(token).GetMediaList(context.Background(), anilist.MediaListQuery{
return anilist.NewApi(token).GetMediaList(ctx, anilist.MediaListQuery{
UserName: AnilistUsername,
Type: anilist.MediaTypeAnime,
Status: status,