Improved jobs

jobs/jobs.go

@@ -25,7 +25,7 @@ var colorPool = []*color.Color{
 
 var jobs = map[string]time.Duration{
 	"anime-ratings": 10 * time.Minute,
-	// "test":             1 * time.Hour,
+	"test":          1 * time.Hour,
 	"twist":         4 * time.Hour,
 	// "refresh-episodes": 10 * time.Hour,
 	// "refresh-osu":      12 * time.Hour,

jobs/kitsu-import-anime/kitsu-import-anime.go

@@ -11,8 +11,8 @@ import (
 func main() {
 	color.Yellow("Importing Kitsu anime")
 
-	defer arn.Node.Close()
 	defer color.Green("Finished.")
+	defer arn.Node.Close()
 
 	// In case we refresh only one anime
 	if InvokeShellArgs() {

jobs/kitsu-import-mappings/kitsu-import-mappings.go

@@ -11,8 +11,8 @@ import (
 func main() {
 	color.Yellow("Importing Kitsu mappings")
 
-	defer arn.Node.Close()
 	defer color.Green("Finished.")
+	defer arn.Node.Close()
 
 	// Iterate over all mappings
 	for mapping := range kitsu.StreamMappings() {

jobs/mal-import/mal-import.go

@@ -16,8 +16,8 @@ import (
 func main() {
 	color.Yellow("Importing MAL anime")
 
-	defer arn.Node.Close()
 	defer color.Green("Finished.")
+	defer arn.Node.Close()
 
 	// readFile("../mal-download/files/anime-31240.html")
 

jobs/refresh-osu/refresh-osu.go

@@ -7,26 +7,34 @@ import (
 	"github.com/fatih/color"
 )
 
+var ticker = time.NewTicker(500 * time.Millisecond)
+
 func main() {
 	color.Yellow("Refreshing osu information")
+
+	defer color.Green("Finished.")
 	defer arn.Node.Close()
 
-	ticker := time.NewTicker(500 * time.Millisecond)
-
 	for user := range arn.StreamUsers() {
-		// Get osu info
-		if user.RefreshOsuInfo() == nil {
+		if user.Accounts.Osu.Nick == "" {
+			continue
+		}
+
+		// Fetch new info
+		err := user.RefreshOsuInfo()
+
+		if err != nil {
+			color.Red(err.Error())
+			continue
+		}
+
+		// Log it
 		arn.PrettyPrint(user.Accounts.Osu)
 
-			// Fetch user again to prevent writing old data
-			updatedUser, _ := arn.GetUser(user.ID)
-			updatedUser.Accounts.Osu = user.Accounts.Osu
-			updatedUser.Save()
-		}
+		// Save in database
+		user.Save()
 
 		// Wait for rate limiter
 		<-ticker.C
 	}
-
-	color.Green("Finished.")
 }

jobs/sync-shoboi/sync-shoboi.go

@@ -116,5 +116,5 @@ func search(anime *arn.Anime, title string) {
 	}
 
 	// This will start a goroutine that saves the anime
-	anime.SetMapping("shoboi/anime", shoboi.TID, "")
+	anime.SetMapping("shoboi/anime", shoboi.TID)
 }

patches/refresh-anime-average-color/refresh-anime-average-color.go

@@ -16,8 +16,8 @@ import (
 func main() {
 	color.Yellow("Updating anime image average colors")
 
-	defer arn.Node.Close()
 	defer color.Green("Finished.")
+	defer arn.Node.Close()
 
 	// Parse flags
 	var animeID string

patches/refresh-anime-thumbnails/refresh-anime-thumbnails.go

@@ -14,8 +14,8 @@ import (
 func main() {
 	color.Yellow("Updating anime thumbnails")
 
-	defer arn.Node.Close()
 	defer color.Green("Finished.")
+	defer arn.Node.Close()
 
 	// Parse flags
 	var animeID string