Added priority queues to episode refresh

jobs/refresh-episodes/refresh-episodes.go

@@ -12,7 +12,32 @@ import (
 func main() {
 	color.Yellow("Refreshing episode information for each anime.")
 
+	highPriority := []*arn.Anime{}
+	lowPriority := []*arn.Anime{}
+
 	for anime := range arn.MustStreamAnime() {
+		if anime.GetMapping("shoboi/anime") == "" {
+			continue
+		}
+
+		if anime.Status == "current" || anime.Status == "upcoming" {
+			highPriority = append(highPriority, anime)
+		} else {
+			lowPriority = append(lowPriority, anime)
+		}
+	}
+
+	color.Cyan("High priority queue:")
+	refresh(highPriority)
+
+	color.Cyan("Low priority queue:")
+	refresh(lowPriority)
+
+	color.Green("Finished.")
+}
+
+func refresh(queue []*arn.Anime) {
+	for _, anime := range queue {
 		episodeCount := len(anime.Episodes)
 
 		err := anime.RefreshEpisodes()
@@ -27,6 +52,4 @@ func main() {
 			fmt.Println(anime.ID, "|", anime.Title.Canonical, "+"+strconv.Itoa(len(anime.Episodes)-episodeCount))
 		}
 	}
-
-	color.Green("Finished.")
 }