From bd38aca4c0c0ca970f9bf181928a4b889e60d133 Mon Sep 17 00:00:00 2001 From: Eduard Urbach Date: Sun, 24 Sep 2017 05:01:15 +0200 Subject: [PATCH] Improved episode refresh --- jobs/refresh-episodes/refresh-episodes.go | 12 ++++++++++-- jobs/sync-shoboi/sync-shoboi.go | 4 +++- 2 files changed, 13 insertions(+), 3 deletions(-) diff --git a/jobs/refresh-episodes/refresh-episodes.go b/jobs/refresh-episodes/refresh-episodes.go index b6e466b3..0f294e73 100644 --- a/jobs/refresh-episodes/refresh-episodes.go +++ b/jobs/refresh-episodes/refresh-episodes.go @@ -2,8 +2,8 @@ package main import ( "fmt" - "strconv" "strings" + "time" "github.com/animenotifier/arn" "github.com/fatih/color" @@ -50,6 +50,9 @@ func main() { func refreshQueue(queue []*arn.Anime) { for _, anime := range queue { refresh(anime) + + // Lower the request interval + time.Sleep(5 * time.Second) } } @@ -68,6 +71,11 @@ func refresh(anime *arn.Anime) { color.Red(err.Error()) } else { - fmt.Println("+"+strconv.Itoa(len(anime.Episodes().Items)-episodeCount)+" airing", "|", "+"+strconv.Itoa(anime.Episodes().AvailableCount()-availableEpisodeCount)+" available") + faint := color.New(color.Faint).SprintFunc() + episodes := anime.Episodes() + + fmt.Println(faint(episodes)) + fmt.Printf("+%d airing | +%d available (%d total)\n", len(episodes.Items), len(episodes.Items)-episodeCount, episodes.AvailableCount()-availableEpisodeCount) + println() } } diff --git a/jobs/sync-shoboi/sync-shoboi.go b/jobs/sync-shoboi/sync-shoboi.go index 341eb451..e0addec4 100644 --- a/jobs/sync-shoboi/sync-shoboi.go +++ b/jobs/sync-shoboi/sync-shoboi.go @@ -20,6 +20,9 @@ func main() { if sync(anime) { count++ } + + // Lower the request interval + time.Sleep(2 * time.Second) } // Log @@ -53,7 +56,6 @@ func sync(anime *arn.Anime) bool { // Did we get the ID? if anime.GetMapping("shoboi/anime") != "" { println(color.GreenString("✔")) - time.Sleep(2 * time.Second) return true }