more code

pkg/locator/locator.go

@@ -2,11 +2,14 @@ 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"
@@ -45,7 +48,7 @@ func GetCount(config config.Config, sectionID int) int {
 }
 
 // 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) string {
+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&section_id=", sectionID, "&order_column=last_played&refresh=true&order_dir=asc&length=", count)
@@ -75,13 +78,19 @@ func GetTitles(config config.Config, sectionID int, days int) string {
 	}
 
 	data := titleModel.Response.Data.Data
-	// titles := make([]string, 0)
+	titles := make([]string, 0)
+	ids := make([]int, 0)
 
 	epoch := util.SubtractedEpoch(days)
 
 	for _, i := range data {
 		if i.LastPlayed < epoch {
-			fmt.Println(i.Title)
+			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)
@@ -89,11 +98,57 @@ func GetTitles(config config.Config, sectionID int, days int) string {
 				log.Fatal(err)
 			}
 			if int64(stri) < epoch {
-				fmt.Println(i.Title)
+				titles = append(titles, i.Title)
+				strirk, err := strconv.Atoi(i.RatingKey)
+				if err != nil {
+					log.Fatal(err)
+				}
+				ids = append(ids, strirk)
 			}
 		}
 	}
+	sort.Strings(titles)
 
-	return string(epoch)
+	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
 
 }