package locator import ( "encoding/json" "encoding/xml" "fmt" "io/ioutil" "log" "net/http" "sort" "strconv" "strings" "git.linuxrocker.com/mattburchett/Housekeeper/pkg/config" "git.linuxrocker.com/mattburchett/Housekeeper/pkg/model" "git.linuxrocker.com/mattburchett/Housekeeper/pkg/util" ) func GetCount(config config.Config, sectionID int) int { countURL := fmt.Sprintf("%s%s%s%s%s%d", config.BaseURL, config.PlexPyContext, "/api/v2?apikey=", config.PlexPyAPIKey, "&cmd=get_library§ion_id=", sectionID) req, err := http.NewRequest(http.MethodGet, countURL, nil) if err != nil { log.Fatal(err) } httpClient := http.Client{} req.Header.Set("User-Agent", "Housekeeper") res, getErr := httpClient.Do(req) if getErr != nil { log.Fatal(getErr) } body, readErr := ioutil.ReadAll(res.Body) if readErr != nil { log.Fatal(readErr) } countModel := model.PlexPyLibraryInfo{} jsonErr := json.Unmarshal(body, &countModel) if jsonErr != nil { log.Fatal(jsonErr) } count := countModel.Response.Data.Count return count } // GetTitles will gather a list of information from the media in the library, based on the previous count. func GetTitles(config config.Config, sectionID int, days int) { count := GetCount(config, sectionID) titlesURL := fmt.Sprintf("%s%s%s%s%s%d%s%d", config.BaseURL, config.PlexPyContext, "/api/v2?apikey=", config.PlexPyAPIKey, "&cmd=get_library_media_info§ion_id=", sectionID, "&order_column=last_played&refresh=true&order_dir=asc&length=", count) req, err := http.NewRequest(http.MethodGet, titlesURL, nil) if err != nil { log.Fatal(err) } httpClient := http.Client{} req.Header.Set("User-Agent", "Housekeeper") res, getErr := httpClient.Do(req) if getErr != nil { log.Fatal(getErr) } body, readErr := ioutil.ReadAll(res.Body) if readErr != nil { log.Fatal(readErr) } titleModel := model.PlexPyMediaInfo{} jsonErr := json.Unmarshal(body, &titleModel) if jsonErr != nil { log.Fatal(jsonErr) } data := titleModel.Response.Data.Data titles := make([]string, 0) ids := make([]int, 0) epoch := util.SubtractedEpoch(days) for _, i := range data { if i.LastPlayed < epoch { titles = append(titles, i.Title) strirk, err := strconv.Atoi(i.RatingKey) if err != nil { log.Fatal(err) } ids = append(ids, strirk) } if i.LastPlayed < 0 { stri, err := strconv.Atoi(i.AddedAt) if err != nil { log.Fatal(err) } if int64(stri) < epoch { titles = append(titles, i.Title) strirk, err := strconv.Atoi(i.RatingKey) if err != nil { log.Fatal(err) } ids = append(ids, strirk) } } } sort.Strings(titles) LookupFileLocation(config, ids) return } func LookupFileLocation(config config.Config, ids []int) { // fileLocations := make([]string, 0) for _, i := range ids { plexURL := fmt.Sprintf("%s:%d%s%d%s%s", config.PlexHost, config.PlexPort, "/library/metadata/", i, "/?X-Plex-Token=", config.PlexToken) req, err := http.NewRequest(http.MethodGet, plexURL, nil) if err != nil { log.Fatal(err) } httpClient := http.Client{} req.Header.Set("User-Agent", "Housekeeper") res, getErr := httpClient.Do(req) if getErr != nil { log.Fatal(getErr) } body, readErr := ioutil.ReadAll(res.Body) if readErr != nil { log.Fatal(readErr) } if err != nil { log.Fatal(err) } plexModel := model.XMLPlexAPI{} xml.Unmarshal(body, &plexModel) fileList := strings.Split(plexModel.Video.Media.Part.File, "/") fmt.Printf("/%v/%v/%v/%v/%v\n", fileList[1], fileList[2], fileList[3], fileList[4], fileList[5]) } // http://172.19.0.105:32400/library/metadata/9/?X-Plex-Token=K1WCALqRK5HVzSQ1J3bM }