web/notify.moe
Code Issues Pull Requests Activity

Removed retries

Browse Source
This commit is contained in:
Eduard Urbach 2017-11-13 21:38:16 +01:00
parent 732faa341a
commit 84ac0583d1
2 changed files with 24 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
jobs/sync-jikan-anime/sync-jikan-anime.go
View File

@ -10,8 +10,6 @@ import (
"github.com/fatih/color" "github.com/fatih/color"
) )
const maxRetries = 3
var jikanDB = arn.Node.Namespace("jikan") var jikanDB = arn.Node.Namespace("jikan")
func main() { func main() {
@ -38,23 +36,17 @@ func main() {
func sync(anime *arn.Anime, malID string) { func sync(anime *arn.Anime, malID string) {
fmt.Printf("%s %s (MAL: %s)\n", anime.ID, anime.Title.Canonical, malID) fmt.Printf("%s %s (MAL: %s)\n", anime.ID, anime.Title.Canonical, malID)
if !jikanDB.Exists("Anime", malID) { if jikanDB.Exists("Anime", malID) {
var anime *jikan.Anime return
var err error
for try := 1; try <= maxRetries; try++ {
time.Sleep(time.Second)
anime, err = jikan.GetAnime(malID)
if err == nil {
jikanDB.Set("Anime", malID, anime)
return
}
fmt.Printf("Error fetching %s on try %d: %v", malID, try, err)
// Wait an additional second
time.Sleep(time.Second)
}
} }
time.Sleep(time.Second)
jikanAnime, err := jikan.GetAnime(malID)
if err == nil {
jikanDB.Set("Anime", malID, jikanAnime)
return
}
fmt.Printf("Error fetching %s: %v", malID, err)
} }

32
jobs/sync-jikan-characters/sync-jikan-characters.go
View File

@ -10,8 +10,6 @@ import (
"github.com/fatih/color" "github.com/fatih/color"
) )
const maxRetries = 3
var jikanDB = arn.Node.Namespace("jikan") var jikanDB = arn.Node.Namespace("jikan")
func main() { func main() {
@ -49,23 +47,17 @@ func main() {
func fetchCharacter(malCharacterID string) { func fetchCharacter(malCharacterID string) {
fmt.Printf("Fetching character ID %s\n", malCharacterID) fmt.Printf("Fetching character ID %s\n", malCharacterID)
if !jikanDB.Exists("Character", malCharacterID) { if jikanDB.Exists("Character", malCharacterID) {
var character *jikan.Character return
var err error
for try := 1; try <= maxRetries; try++ {
time.Sleep(time.Second)
character, err = jikan.GetCharacter(malCharacterID)
if err == nil {
jikanDB.Set("Character", malCharacterID, character)
return
}
fmt.Printf("Error fetching %s on try %d: %v", malCharacterID, try, err)
// Wait an additional second
time.Sleep(time.Second)
}
} }
time.Sleep(time.Second)
character, err := jikan.GetCharacter(malCharacterID)
if err == nil {
jikanDB.Set("Character", malCharacterID, character)
return
}
fmt.Printf("Error fetching %s: %v", malCharacterID, err)
} }