Minor changes

jobs/mal-download/mal-download.go

@@ -14,7 +14,7 @@ import (
 const (
 	// The maximum age of files we accept until we force a refresh.
 	maxAge               = 7 * 24 * time.Hour
-	delayBetweenRequests = 1000 * time.Millisecond
+	delayBetweenRequests = 1100 * time.Millisecond
 	userAgent            = "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/64.0.3282.166 Safari/537.36"
 )
 

patches/kitsu-anilist/kitsu-anilist.go

@@ -0,0 +1,61 @@
+package main
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/animenotifier/arn"
+	"github.com/fatih/color"
+)
+
+func main() {
+	color.Yellow("Checking Kitsu for anilist mappings")
+	defer arn.Node.Close()
+
+	confirmed := 0
+	added := 0
+	conflicted := 0
+
+	for mapping := range arn.StreamKitsuMappings() {
+		if mapping.Relationships.Item.Data.Type != "anime" {
+			continue
+		}
+
+		if mapping.Attributes.ExternalSite != "anilist" {
+			continue
+		}
+
+		externalID := mapping.Attributes.ExternalID
+
+		if strings.HasPrefix(externalID, "anime/") {
+			externalID = externalID[len("anime/"):]
+		}
+
+		anime, _ := arn.GetAnime(mapping.Relationships.Item.Data.ID)
+
+		if anime == nil {
+			continue
+		}
+
+		currentID := anime.GetMapping("anilist/anime")
+
+		if currentID == "" {
+			added++
+			// color.Yellow("Added: %s (%v) on %s is %s", anime.ID, anime, mapping.Attributes.ExternalSite, externalID)
+			// color.Yellow("Added:\n * https://notify.moe/anime/%s\n * https://anilist.co/anime/%s\n\n", anime.ID, externalID)
+		} else {
+			if currentID == externalID {
+				confirmed++
+				// color.Green("Confirmed: %s (%v) on %s is %s", anime.ID, anime, mapping.Attributes.ExternalSite, externalID)
+			} else if currentID != externalID {
+				conflicted++
+				// color.Red("Conflict: %s (%v) on %s is %s but current value is %s", anime.ID, anime, mapping.Attributes.ExternalSite, externalID, currentID)
+				color.Red("Conflict (#%d):\n * https://notify.moe/anime/%s\n * https://anilist.co/anime/%s (current)\n * https://anilist.co/anime/%s (suggested)\n\n", conflicted, anime.ID, externalID, currentID)
+			}
+		}
+
+		// anime.SetMapping("anilist/anime", externalID)
+	}
+
+	fmt.Printf("%d confirmed, %d added, %d conflicted\n", confirmed, added, conflicted)
+}