web/notify.moe
Code Issues Pull Requests Activity

Improved twist.moe job

Browse Source
This commit is contained in:
Eduard Urbach 2017-07-11 13:12:10 +02:00
parent b4ba7c3b4d
commit 06fddad8bd
1 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
jobs/twist/twist.go
View File

@ -15,27 +15,25 @@ var rateLimiter = time.NewTicker(500 * time.Millisecond)
func main() { func main() {
// Replace this with ID list from twist.moe later // Replace this with ID list from twist.moe later
currentAnime, err := arn.FilterAnime(func(anime *arn.Anime) bool { twistAnime, err := twist.GetAnimeIndex()
return anime.Status == "current"
})
arn.PanicOnError(err) arn.PanicOnError(err)
idList := twistAnime.KitsuIDs()
color.Yellow("Refreshing twist.moe links for %d anime", len(currentAnime)) color.Yellow("Refreshing twist.moe links for %d anime", len(idList))
for count, anime := range currentAnime { for count, animeID := range idList {
// Wait for rate limiter // Wait for rate limiter
<-rateLimiter.C <-rateLimiter.C
// anime, animeErr := arn.GetAnime(animeID) anime, animeErr := arn.GetAnime(animeID)
// if animeErr != nil { if animeErr != nil {
// color.Red("Error fetching anime from the database with ID %s: %v", animeID, animeErr) color.Red("Error fetching anime from the database with ID %s: %v", animeID, animeErr)
// continue continue
// } }
animeID := anime.ID
// Log // Log
fmt.Fprintf(os.Stdout, "[%d / %d] ", count+1, len(currentAnime)) fmt.Fprintf(os.Stdout, "[%d / %d] ", count+1, len(idList))
// Get twist.moe feed // Get twist.moe feed
feed, err := twist.GetFeedByKitsuID(animeID) feed, err := twist.GetFeedByKitsuID(animeID)