139 lines
2.2 KiB
Go
Raw Normal View History

2018-03-08 23:07:48 +00:00
package main
import (
2018-10-29 23:59:35 +00:00
"compress/gzip"
2018-03-08 23:07:48 +00:00
"errors"
"fmt"
"os"
2018-04-12 17:05:05 +00:00
"path"
2018-03-08 23:07:48 +00:00
"path/filepath"
"strings"
2018-04-12 09:05:55 +00:00
"github.com/animenotifier/mal"
2018-03-09 03:32:31 +00:00
"github.com/animenotifier/arn"
2018-03-08 23:07:48 +00:00
"github.com/animenotifier/mal/parser"
2018-03-16 23:28:36 +00:00
"github.com/fatih/color"
2018-03-08 23:07:48 +00:00
)
func main() {
2018-04-12 11:39:58 +00:00
color.Yellow("Parsing MAL files")
2018-03-16 23:28:36 +00:00
defer color.Green("Finished.")
2018-03-21 04:15:03 +00:00
defer arn.Node.Close()
2018-03-08 23:07:48 +00:00
2018-04-12 17:05:05 +00:00
// Invoke via parameters
if InvokeShellArgs() {
return
}
2018-03-08 23:07:48 +00:00
2018-04-24 01:41:27 +00:00
filepath.Walk(path.Join(arn.Root, "jobs/mal-download/anime"), func(name string, info os.FileInfo, err error) error {
2018-03-08 23:07:48 +00:00
if err != nil {
fmt.Println(err)
return err
}
if info.IsDir() {
return nil
}
2018-10-29 23:59:35 +00:00
if !strings.HasSuffix(name, ".html.gz") {
2018-03-08 23:07:48 +00:00
return nil
}
2018-10-30 03:01:42 +00:00
return readAnimeFile(name)
2018-03-08 23:07:48 +00:00
})
}
2018-10-30 03:01:42 +00:00
func readAnimeFile(name string) error {
2018-03-08 23:07:48 +00:00
file, err := os.Open(name)
if err != nil {
fmt.Println(err)
return err
}
2018-04-25 23:14:23 +00:00
defer file.Close()
2018-10-29 23:59:35 +00:00
reader, err := gzip.NewReader(file)
if err != nil {
fmt.Println(err)
return err
}
anime, characters, err := malparser.ParseAnime(reader)
2018-03-08 23:07:48 +00:00
if err != nil {
fmt.Println(err)
return err
}
if anime.ID == "" {
return errors.New("Empty ID")
}
2018-04-12 09:05:55 +00:00
for _, character := range characters {
obj, err := arn.MAL.Get("Character", character.ID)
if err != nil {
arn.MAL.Set("Character", character.ID, character)
continue
}
existing := obj.(*mal.Character)
modified := false
if existing.Name != character.Name {
existing.Name = character.Name
modified = true
}
2018-10-30 03:01:42 +00:00
if existing.Image != character.Image {
existing.Image = character.Image
2018-04-12 09:05:55 +00:00
modified = true
}
if modified {
arn.MAL.Set("Character", existing.ID, existing)
}
}
2018-04-12 09:11:02 +00:00
fmt.Println(anime.ID, anime.Title)
2018-03-09 03:32:31 +00:00
arn.MAL.Set("Anime", anime.ID, anime)
2018-03-08 23:07:48 +00:00
return nil
}
2018-10-30 03:01:42 +00:00
func readCharacterFile(name string) error {
file, err := os.Open(name)
if err != nil {
fmt.Println(err)
return err
}
defer file.Close()
reader, err := gzip.NewReader(file)
if err != nil {
fmt.Println(err)
return err
}
character, err := malparser.ParseCharacter(reader)
if err != nil {
fmt.Println(err)
return err
}
if character.ID == "" {
return errors.New("Empty ID")
}
fmt.Println(character.ID, character.Name)
arn.MAL.Set("Character", character.ID, character)
return nil
}