Compare commits
4 Commits
v1.0.2
...
8c010665e1
| Author | SHA1 | Date | |
|---|---|---|---|
|
8c010665e1
|
|||
|
916d3004de
|
|||
|
7edf4ed9c5
|
|||
|
93d262d293
|
@@ -2,7 +2,6 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/base64"
|
"encoding/base64"
|
||||||
"encoding/json"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
@@ -12,38 +11,6 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
func processInputFile(inputFile string) error {
|
|
||||||
jsonFile, err := os.Open(inputFile)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("error opening file %s: %v", inputFile, err)
|
|
||||||
}
|
|
||||||
defer jsonFile.Close()
|
|
||||||
|
|
||||||
byteValue, err := io.ReadAll(jsonFile)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("error reading file %s: %v", inputFile, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
byteValue = removeBOM(byteValue)
|
|
||||||
|
|
||||||
var items Items
|
|
||||||
err = json.Unmarshal(byteValue, &items)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("error unmarshaling JSON: %v", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
for i, item := range items.Items {
|
|
||||||
updateProgress(filepath.Base(inputFile), float64(i)/float64(len(items.Items))*100, item.Filename)
|
|
||||||
err := downloadFile(item)
|
|
||||||
if err != nil {
|
|
||||||
fmt.Printf("Error downloading file: %v\n", err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
updateProgress(filepath.Base(inputFile), 100, "")
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func removeBOM(input []byte) []byte {
|
func removeBOM(input []byte) []byte {
|
||||||
if len(input) >= 3 && input[0] == 0xEF && input[1] == 0xBB && input[2] == 0xBF {
|
if len(input) >= 3 && input[0] == 0xEF && input[1] == 0xBB && input[2] == 0xBF {
|
||||||
return input[3:]
|
return input[3:]
|
||||||
|
|||||||
59
handlers.go
59
handlers.go
@@ -7,7 +7,6 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func handleRoot(w http.ResponseWriter, r *http.Request) {
|
func handleRoot(w http.ResponseWriter, r *http.Request) {
|
||||||
@@ -37,29 +36,71 @@ func handleUpload(w http.ResponseWriter, r *http.Request) {
|
|||||||
}
|
}
|
||||||
defer file.Close()
|
defer file.Close()
|
||||||
|
|
||||||
filename := fmt.Sprintf("%d_%s", time.Now().UnixNano(), header.Filename)
|
tempFile, err := os.CreateTemp(uploadDir, header.Filename)
|
||||||
filepath := filepath.Join(uploadDir, filename)
|
|
||||||
|
|
||||||
newFile, err := os.Create(filepath)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer newFile.Close()
|
defer tempFile.Close()
|
||||||
|
|
||||||
_, err = io.Copy(newFile, file)
|
_, err = io.Copy(tempFile, file)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
tempFilename := filepath.Base(tempFile.Name())
|
||||||
|
|
||||||
|
_, err = parseInputFile(tempFile.Name())
|
||||||
|
if err != nil {
|
||||||
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
http.Redirect(w, r, "/select?filename="+tempFilename, http.StatusSeeOther)
|
||||||
|
}
|
||||||
|
|
||||||
|
func handleSelect(w http.ResponseWriter, r *http.Request) {
|
||||||
|
filename := r.URL.Query().Get("filename")
|
||||||
|
items, err := parseInputFile(filepath.Join(uploadDir, filename))
|
||||||
|
if err != nil {
|
||||||
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
groupedItems := groupItemsBySeason(items)
|
||||||
|
|
||||||
|
err = templates.ExecuteTemplate(w, "select", struct {
|
||||||
|
Filename string
|
||||||
|
Items map[string][]Item
|
||||||
|
}{
|
||||||
|
Filename: filename,
|
||||||
|
Items: groupedItems,
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func handleProcess(w http.ResponseWriter, r *http.Request) {
|
||||||
|
filename := r.FormValue("filename")
|
||||||
|
selectedItems := r.Form["items"]
|
||||||
|
|
||||||
|
items, err := parseInputFile(filepath.Join(uploadDir, filename))
|
||||||
|
if err != nil {
|
||||||
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
filteredItems := filterSelectedItems(items, selectedItems)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
err := processInputFile(filepath)
|
err := processItems(filename, filteredItems)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("Error processing file: %v\n", err)
|
fmt.Printf("Error processing file: %v\n", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
os.Remove(filepath)
|
os.Remove(filepath.Join(uploadDir, filename))
|
||||||
}()
|
}()
|
||||||
|
|
||||||
http.Redirect(w, r, "/progress?filename="+filename, http.StatusSeeOther)
|
http.Redirect(w, r, "/progress?filename="+filename, http.StatusSeeOther)
|
||||||
|
|||||||
9
main.go
9
main.go
@@ -63,13 +63,20 @@ func main() {
|
|||||||
if *inputFile == "" {
|
if *inputFile == "" {
|
||||||
startWebServer()
|
startWebServer()
|
||||||
} else {
|
} else {
|
||||||
processInputFile(*inputFile)
|
items, err := parseInputFile(*inputFile)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Printf("Error parsing input file: %v\n", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
processItems(*inputFile, items)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func startWebServer() {
|
func startWebServer() {
|
||||||
http.HandleFunc("/", handleRoot)
|
http.HandleFunc("/", handleRoot)
|
||||||
http.HandleFunc("/upload", handleUpload)
|
http.HandleFunc("/upload", handleUpload)
|
||||||
|
http.HandleFunc("/select", handleSelect)
|
||||||
|
http.HandleFunc("/process", handleProcess)
|
||||||
http.HandleFunc("/progress", handleProgress)
|
http.HandleFunc("/progress", handleProgress)
|
||||||
|
|
||||||
fmt.Println("Starting web server on http://0.0.0.0:8080")
|
fmt.Println("Starting web server on http://0.0.0.0:8080")
|
||||||
|
|||||||
@@ -1,5 +1,91 @@
|
|||||||
<!DOCTYPE html>
|
<!DOCTYPE html>
|
||||||
<html>
|
<html lang="en">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||||
|
<title>Simple Downloader</title>
|
||||||
|
<style>
|
||||||
|
body {
|
||||||
|
font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, Helvetica, Arial, sans-serif;
|
||||||
|
background-color: #1e1e1e;
|
||||||
|
color: #d4d4d4;
|
||||||
|
line-height: 1.6;
|
||||||
|
padding: 20px;
|
||||||
|
max-width: 800px;
|
||||||
|
margin: 0 auto;
|
||||||
|
box-sizing: border-box;
|
||||||
|
}
|
||||||
|
h1, h2 {
|
||||||
|
border-bottom: 1px solid #333;
|
||||||
|
padding-bottom: 10px;
|
||||||
|
word-wrap: break-word;
|
||||||
|
}
|
||||||
|
form {
|
||||||
|
margin-bottom: 20px;
|
||||||
|
display: flex;
|
||||||
|
flex-direction: column;
|
||||||
|
}
|
||||||
|
input[type="file"], input[type="submit"] {
|
||||||
|
background-color: #2d2d2d;
|
||||||
|
color: #d4d4d4;
|
||||||
|
border: 1px solid #444;
|
||||||
|
padding: 8px 12px;
|
||||||
|
border-radius: 4px;
|
||||||
|
margin-bottom: 10px;
|
||||||
|
max-width: 100%;
|
||||||
|
}
|
||||||
|
input[type="submit"] {
|
||||||
|
cursor: pointer;
|
||||||
|
background-color: #4CAF50;
|
||||||
|
color: white;
|
||||||
|
}
|
||||||
|
input[type="submit"]:hover {
|
||||||
|
background-color: #45a049;
|
||||||
|
}
|
||||||
|
ul {
|
||||||
|
list-style-type: none;
|
||||||
|
padding: 0;
|
||||||
|
}
|
||||||
|
li {
|
||||||
|
background-color: #2d2d2d;
|
||||||
|
margin-bottom: 10px;
|
||||||
|
padding: 10px;
|
||||||
|
border-radius: 4px;
|
||||||
|
word-wrap: break-word;
|
||||||
|
}
|
||||||
|
.job-title {
|
||||||
|
font-size: 1.1em;
|
||||||
|
font-weight: bold;
|
||||||
|
margin-bottom: 5px;
|
||||||
|
}
|
||||||
|
.job-title a {
|
||||||
|
color: #58a6ff;
|
||||||
|
text-decoration: none;
|
||||||
|
}
|
||||||
|
.job-title a:hover {
|
||||||
|
text-decoration: underline;
|
||||||
|
}
|
||||||
|
.job-info {
|
||||||
|
font-size: 0.9em;
|
||||||
|
color: #a0a0a0;
|
||||||
|
}
|
||||||
|
.progress-text {
|
||||||
|
display: inline-block;
|
||||||
|
width: 5em;
|
||||||
|
}
|
||||||
|
@media (max-width: 600px) {
|
||||||
|
body {
|
||||||
|
padding: 10px;
|
||||||
|
}
|
||||||
|
h1, h2 {
|
||||||
|
font-size: 1.5em;
|
||||||
|
}
|
||||||
|
input[type="file"], input[type="submit"] {
|
||||||
|
font-size: 16px;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
</style>
|
||||||
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<h1>Simple Downloader</h1>
|
<h1>Simple Downloader</h1>
|
||||||
<form action="/upload" method="post" enctype="multipart/form-data">
|
<form action="/upload" method="post" enctype="multipart/form-data">
|
||||||
@@ -10,9 +96,12 @@
|
|||||||
<ul>
|
<ul>
|
||||||
{{range $filename, $info := .Jobs}}
|
{{range $filename, $info := .Jobs}}
|
||||||
<li>
|
<li>
|
||||||
<a href="/progress?filename={{$filename}}">{{$filename}}</a>:
|
<div class="job-title">
|
||||||
{{printf "%.2f%%" $info.Percentage}}
|
<a href="/progress?filename={{$filename}}">{{$filename}}</a>
|
||||||
(Current file: {{$info.CurrentFile}})
|
</div>
|
||||||
|
<div class="job-info">
|
||||||
|
Progress: <span class="progress-text">{{printf "%5.1f%%" $info.Percentage}}</span> Current file: {{$info.CurrentFile}}
|
||||||
|
</div>
|
||||||
</li>
|
</li>
|
||||||
{{else}}
|
{{else}}
|
||||||
<li>No active jobs</li>
|
<li>No active jobs</li>
|
||||||
|
|||||||
@@ -1,9 +1,89 @@
|
|||||||
<!DOCTYPE html>
|
<!DOCTYPE html>
|
||||||
<html>
|
<html lang="en">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||||
|
<title>Processing {{.Filename}}</title>
|
||||||
|
<style>
|
||||||
|
body {
|
||||||
|
font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, Helvetica, Arial, sans-serif;
|
||||||
|
background-color: #1e1e1e;
|
||||||
|
color: #d4d4d4;
|
||||||
|
line-height: 1.6;
|
||||||
|
padding: 20px;
|
||||||
|
max-width: 800px;
|
||||||
|
margin: 0 auto;
|
||||||
|
box-sizing: border-box;
|
||||||
|
}
|
||||||
|
h1 {
|
||||||
|
border-bottom: 1px solid #333;
|
||||||
|
padding-bottom: 10px;
|
||||||
|
word-wrap: break-word;
|
||||||
|
}
|
||||||
|
#progress-container {
|
||||||
|
background-color: #2d2d2d;
|
||||||
|
border-radius: 4px;
|
||||||
|
margin-bottom: 20px;
|
||||||
|
padding: 20px;
|
||||||
|
}
|
||||||
|
#progress-bar-container {
|
||||||
|
background-color: #444;
|
||||||
|
height: 20px;
|
||||||
|
border-radius: 10px;
|
||||||
|
overflow: hidden;
|
||||||
|
margin-bottom: 10px;
|
||||||
|
position: relative;
|
||||||
|
}
|
||||||
|
#progress-bar {
|
||||||
|
background-color: #4CAF50;
|
||||||
|
height: 100%;
|
||||||
|
width: 0;
|
||||||
|
transition: width 0.5s ease-in-out;
|
||||||
|
}
|
||||||
|
#progress-text {
|
||||||
|
position: absolute;
|
||||||
|
top: 50%;
|
||||||
|
left: 0;
|
||||||
|
right: 0;
|
||||||
|
transform: translateY(-50%);
|
||||||
|
text-align: center;
|
||||||
|
color: #fff;
|
||||||
|
font-weight: bold;
|
||||||
|
text-shadow: 1px 1px 2px rgba(0,0,0,0.5);
|
||||||
|
line-height: 20px;
|
||||||
|
}
|
||||||
|
#currentFile {
|
||||||
|
margin-top: 10px;
|
||||||
|
word-wrap: break-word;
|
||||||
|
}
|
||||||
|
@media (max-width: 600px) {
|
||||||
|
body {
|
||||||
|
padding: 10px;
|
||||||
|
}
|
||||||
|
h1 {
|
||||||
|
font-size: 1.5em;
|
||||||
|
}
|
||||||
|
#progress-container {
|
||||||
|
padding: 10px;
|
||||||
|
}
|
||||||
|
#progress-bar-container {
|
||||||
|
height: 15px;
|
||||||
|
}
|
||||||
|
#progress-text {
|
||||||
|
font-size: 0.9em;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
</style>
|
||||||
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<h1>Processing {{.Filename}}</h1>
|
<h1>Processing {{.Filename}}</h1>
|
||||||
<div id="progress">0%</div>
|
<div id="progress-container">
|
||||||
<div id="currentFile"></div>
|
<div id="progress-bar-container">
|
||||||
|
<div id="progress-bar"></div>
|
||||||
|
<div id="progress-text">0%</div>
|
||||||
|
</div>
|
||||||
|
<div id="currentFile"></div>
|
||||||
|
</div>
|
||||||
<script>
|
<script>
|
||||||
function updateProgress() {
|
function updateProgress() {
|
||||||
fetch('/progress?filename={{.Filename}}', {
|
fetch('/progress?filename={{.Filename}}', {
|
||||||
@@ -14,7 +94,8 @@
|
|||||||
.then(response => response.json())
|
.then(response => response.json())
|
||||||
.then(data => {
|
.then(data => {
|
||||||
const progress = Math.round(data.Percentage);
|
const progress = Math.round(data.Percentage);
|
||||||
document.getElementById('progress').innerText = progress + '%';
|
document.getElementById('progress-bar').style.width = progress + '%';
|
||||||
|
document.getElementById('progress-text').innerText = progress + '%';
|
||||||
document.getElementById('currentFile').innerText = 'Current file: ' + (data.CurrentFile || 'None');
|
document.getElementById('currentFile').innerText = 'Current file: ' + (data.CurrentFile || 'None');
|
||||||
if (progress < 100) {
|
if (progress < 100) {
|
||||||
setTimeout(updateProgress, 1000);
|
setTimeout(updateProgress, 1000);
|
||||||
|
|||||||
102
templates/select
Normal file
102
templates/select
Normal file
@@ -0,0 +1,102 @@
|
|||||||
|
<!DOCTYPE html>
|
||||||
|
<html lang="en">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||||
|
<title>Select Items to Download</title>
|
||||||
|
<style>
|
||||||
|
body {
|
||||||
|
font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, Helvetica, Arial, sans-serif;
|
||||||
|
background-color: #1e1e1e;
|
||||||
|
color: #d4d4d4;
|
||||||
|
line-height: 1.6;
|
||||||
|
padding: 20px;
|
||||||
|
max-width: 800px;
|
||||||
|
margin: 0 auto;
|
||||||
|
box-sizing: border-box;
|
||||||
|
}
|
||||||
|
h1 {
|
||||||
|
border-bottom: 1px solid #333;
|
||||||
|
padding-bottom: 10px;
|
||||||
|
}
|
||||||
|
.season {
|
||||||
|
margin-bottom: 20px;
|
||||||
|
background-color: #2d2d2d;
|
||||||
|
padding: 10px;
|
||||||
|
border-radius: 4px;
|
||||||
|
}
|
||||||
|
.season-title {
|
||||||
|
font-size: 1.2em;
|
||||||
|
font-weight: bold;
|
||||||
|
margin-bottom: 10px;
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
}
|
||||||
|
.season-checkbox {
|
||||||
|
margin-right: 10px;
|
||||||
|
}
|
||||||
|
.item {
|
||||||
|
margin-left: 20px;
|
||||||
|
}
|
||||||
|
button, input[type="submit"] {
|
||||||
|
background-color: #4CAF50;
|
||||||
|
color: white;
|
||||||
|
border: none;
|
||||||
|
padding: 10px 15px;
|
||||||
|
margin: 5px;
|
||||||
|
border-radius: 4px;
|
||||||
|
cursor: pointer;
|
||||||
|
}
|
||||||
|
button:hover, input[type="submit"]:hover {
|
||||||
|
background-color: #45a049;
|
||||||
|
}
|
||||||
|
</style>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<h1>Select Items to Download</h1>
|
||||||
|
<form action="/process" method="post">
|
||||||
|
<input type="hidden" name="filename" value="{{.Filename}}">
|
||||||
|
{{range $season, $items := .Items}}
|
||||||
|
<div class="season">
|
||||||
|
<div class="season-title">
|
||||||
|
<input type="checkbox" class="season-checkbox" id="season-{{$season}}" checked onchange="toggleSeason('{{$season}}')">
|
||||||
|
<label for="season-{{$season}}">{{$season}}</label>
|
||||||
|
</div>
|
||||||
|
{{range $item := $items}}
|
||||||
|
<div class="item">
|
||||||
|
<label>
|
||||||
|
<input type="checkbox" name="items" value="{{$item.Filename}}" checked class="episode-{{$season}}">
|
||||||
|
{{$item.Filename}}
|
||||||
|
</label>
|
||||||
|
</div>
|
||||||
|
{{end}}
|
||||||
|
</div>
|
||||||
|
{{end}}
|
||||||
|
<div>
|
||||||
|
<button type="button" onclick="selectAll(true)">Select All</button>
|
||||||
|
<button type="button" onclick="selectAll(false)">Select None</button>
|
||||||
|
<input type="submit" value="Start Download">
|
||||||
|
</div>
|
||||||
|
</form>
|
||||||
|
<script>
|
||||||
|
function selectAll(checked) {
|
||||||
|
var checkboxes = document.getElementsByName('items');
|
||||||
|
for (var i = 0; i < checkboxes.length; i++) {
|
||||||
|
checkboxes[i].checked = checked;
|
||||||
|
}
|
||||||
|
var seasonCheckboxes = document.getElementsByClassName('season-checkbox');
|
||||||
|
for (var i = 0; i < seasonCheckboxes.length; i++) {
|
||||||
|
seasonCheckboxes[i].checked = checked;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function toggleSeason(season) {
|
||||||
|
var seasonCheckbox = document.getElementById('season-' + season);
|
||||||
|
var episodeCheckboxes = document.getElementsByClassName('episode-' + season);
|
||||||
|
for (var i = 0; i < episodeCheckboxes.length; i++) {
|
||||||
|
episodeCheckboxes[i].checked = seasonCheckbox.checked;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
</script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
65
utils.go
65
utils.go
@@ -1,8 +1,11 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"io"
|
||||||
"net/url"
|
"net/url"
|
||||||
|
"os"
|
||||||
"regexp"
|
"regexp"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
@@ -118,3 +121,65 @@ func findOrCreateSegmentTimeline(adaptationSet *etree.Element) *etree.Element {
|
|||||||
segmentTemplate := representation.CreateElement("SegmentTemplate")
|
segmentTemplate := representation.CreateElement("SegmentTemplate")
|
||||||
return segmentTemplate.CreateElement("SegmentTimeline")
|
return segmentTemplate.CreateElement("SegmentTimeline")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func parseInputFile(inputFile string) ([]Item, error) {
|
||||||
|
jsonFile, err := os.Open(inputFile)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("error opening file %s: %v", inputFile, err)
|
||||||
|
}
|
||||||
|
defer jsonFile.Close()
|
||||||
|
|
||||||
|
byteValue, err := io.ReadAll(jsonFile)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("error reading file %s: %v", inputFile, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
byteValue = removeBOM(byteValue)
|
||||||
|
|
||||||
|
var items Items
|
||||||
|
err = json.Unmarshal(byteValue, &items)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("error unmarshaling JSON: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return items.Items, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func groupItemsBySeason(items []Item) map[string][]Item {
|
||||||
|
grouped := make(map[string][]Item)
|
||||||
|
for _, item := range items {
|
||||||
|
metadata := parseMetadata(item.Metadata)
|
||||||
|
if metadata.Type == "serie" {
|
||||||
|
key := fmt.Sprintf("%s - %s", metadata.Title, metadata.Season)
|
||||||
|
grouped[key] = append(grouped[key], item)
|
||||||
|
} else {
|
||||||
|
grouped["Movies"] = append(grouped["Movies"], item)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return grouped
|
||||||
|
}
|
||||||
|
|
||||||
|
func filterSelectedItems(items []Item, selectedItems []string) []Item {
|
||||||
|
var filtered []Item
|
||||||
|
for _, item := range items {
|
||||||
|
for _, selected := range selectedItems {
|
||||||
|
if item.Filename == selected {
|
||||||
|
filtered = append(filtered, item)
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return filtered
|
||||||
|
}
|
||||||
|
|
||||||
|
func processItems(filename string, items []Item) error {
|
||||||
|
for i, item := range items {
|
||||||
|
updateProgress(filename, float64(i)/float64(len(items))*100, item.Filename)
|
||||||
|
err := downloadFile(item)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Printf("Error downloading file: %v\n", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
updateProgress(filename, 100, "")
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user