Compare commits

..

No commits in common. "master" and "v0.0" have entirely different histories.
master ... v0.0

9 changed files with 51 additions and 190 deletions

1
.gitignore vendored
View File

@ -1,4 +1,3 @@
ytubeSpdrun ytubeSpdrun
**/*.sw* **/*.sw*
exec-*
youtuber youtuber

View File

@ -1,15 +0,0 @@
FROM frolvlad/alpine-glibc:alpine-3.9_glibc-2.29
RUN apk update && apk add --no-cache ca-certificates
RUN mkdir -p /var/log
WORKDIR /main
COPY . .
RUN test -e /main/exec-youtuber
ENV GOPATH=""
ENV MNT="/mnt/"
ENTRYPOINT ["/main/exec-youtuber"]
CMD []

58
config/config.go Executable file → Normal file
View File

@ -1,50 +1,20 @@
package config package config
import (
"local/args"
"local/sandbox/contact/contact"
"os"
"time"
)
var ( var (
Feed string Feed = "https://www.youtube.com/feeds/videos.xml?channel_id=UCwX0AEx-qIhQ9kgtlNhyIXw"
Root string Root = "/tmp"
To string
Subject string
Emailer *contact.Emailer
Interval time.Duration
) )
func init() { /*
os.Setenv("LC_ALL", "C.UTF-8") config = {
"path" : "../TV/Shepherds_Chapel" ,
as := args.NewArgSet() "rss" : "https://www.youtube.com/feeds/videos.xml?channel_id=UCwX0AEx-qIhQ9kgtlNhyIXw" ,
"last" : 0 ,
as.Append(args.STRING, "to", "message recipient", "squeaky2x3@gmail.com") "lasttime" : datetime.datetime(1999,1,1) ,
as.Append(args.STRING, "subject", "message subject", "youtuber error") "onlynew" : False ,
as.Append(args.STRING, "from", "message sender", "breellocaldev@gmail.com") "delay" : 12 ,
as.Append(args.STRING, "password", "message sender password", "ML3WQRFSqe9rQ8qNkm") "clear" : False ,
as.Append(args.STRING, "smtp", "smtp server:port", "smtp.gmail.com:465") "logloc" : "./log" ,
as.Append(args.STRING, "pop3", "pop3 server:port", "pop.gmail.com:995") "idle" : False ,
as.Append(args.STRING, "feed", "feed URL", "https://www.youtube.com/feeds/videos.xml?channel_id=UCwX0AEx-qIhQ9kgtlNhyIXw")
as.Append(args.STRING, "root", "root to save videos", "/tmp")
as.Append(args.DURATION, "interval", "check interval", time.Hour)
if err := as.Parse(); err != nil {
panic(err)
}
Feed = as.Get("feed").GetString()
Root = as.Get("root").GetString()
To = as.Get("to").GetString()
Subject = as.Get("subject").GetString()
Emailer = &contact.Emailer{
From: as.Get("from").GetString(),
SMTP: as.Get("smtp").GetString(),
POP3: as.Get("pop3").GetString(),
Password: as.Get("password").GetString(),
}
Interval = as.GetDuration("interval")
} }
*/

0
feed/feed.go Executable file → Normal file
View File

0
feed/item.go Executable file → Normal file
View File

58
main.go Executable file → Normal file
View File

@ -1,7 +1,6 @@
package main package main
import ( import (
"errors"
"fmt" "fmt"
"local/youtuber/config" "local/youtuber/config"
"local/youtuber/feed" "local/youtuber/feed"
@ -10,58 +9,33 @@ import (
"os" "os"
"path" "path"
"strings" "strings"
"time"
) )
func main() { func main() {
client, err := youtubedl.New() os.Setenv("LC_ALL", "C.UTF-8")
results, err := feed.Fetch(config.Feed)
if err != nil { if err != nil {
panic(err) panic(err)
} }
interval := config.Interval log.Println(results)
for true {
err := do(client)
if err != nil {
log.Println(err)
if err := config.Emailer.Send(
config.To,
config.Subject,
fmt.Sprintf("error getting youtuber: %v", err),
); err != nil {
panic(err)
}
}
log.Printf("sleeping until %v", time.Now().Add(interval))
time.Sleep(interval)
}
}
func do(client *youtubedl.Client) error { youtubedl, err := youtubedl.New()
errs := ""
results, err := feed.Fetch(config.Feed)
if err != nil { if err != nil {
return err panic(err)
} }
for _, result := range results { for _, result := range results {
seasonNumber := fmt.Sprintf("%02d%02d", result.Date.Year()-2000, result.Date.Month()) target := fmt.Sprintf(
episodeNumber := fmt.Sprintf("%02d", result.Date.Day()) "s%02d%02de%02d_%s.%%(ext)s",
season := fmt.Sprintf("Season_%s", seasonNumber) result.Date.Year()-2000,
episode := fmt.Sprintf("Episode_%s_-_%s", episodeNumber, strings.Join(strings.Split(result.Title, " ")[2:], "_")) result.Date.Month(),
target := fmt.Sprintf("%s/%s.%%(ext)s", season, episode) result.Date.Day(),
target = path.Join(config.Root, target) strings.Join(strings.Split(result.Title, " ")[2:], "_"),
if _, err := os.Stat(strings.ReplaceAll(target, "%(ext)s", "mp4")); !os.IsNotExist(err) { )
log.Printf("already exists: %s", target) if err := youtubedl.Download(result.Link, path.Join(config.Root, target)); err != nil {
continue panic(err)
}
os.MkdirAll(path.Dir(target), os.ModePerm)
if err := client.Download(result.Link, target); err != nil {
errs += ", " + err.Error()
} }
return
} }
if errs != "" { log.Println(youtubedl)
return errors.New(errs)
}
return nil
} }

Binary file not shown.

55
youtubedl/client.go Executable file → Normal file
View File

@ -3,7 +3,6 @@ package youtubedl
import ( import (
"fmt" "fmt"
"log" "log"
"os"
"os/exec" "os/exec"
"path" "path"
) )
@ -16,55 +15,15 @@ func New() (*Client, error) {
} }
func (c *Client) Download(video, local string) error { func (c *Client) Download(video, local string) error {
if _, ok := os.LookupEnv("TEST"); ok { cmd := exec.Command("youtube-dl", "-f", "22", "-o", local, "--write-sub", "--write-auto-sub", "--sub-format", "srt", video)
log.Println("youtube-dl download", video, local) log.Println(cmd.Path, cmd.Args)
return nil out, err := cmd.CombinedOutput()
} if err != nil {
errs := []error{} err = fmt.Errorf("%v: %s", err, out)
for _, extras := range [][]string{
[]string{"--add-metadata", "--metadata-from-title", ".*[0-9]/[0-9][0-9] (?P<title>.+)"},
[]string{},
} {
args := append([]string{
"/tmp/yt-dlp",
"-f",
"22",
"-o",
local,
"--write-sub",
"--write-auto-sub",
"--sub-format",
"srt",
"--no-check-certificate",
}, extras...)
args = append(args, video)
cmd := exec.Command(args[0], args[1:]...)
log.Println(cmd.Path, cmd.Args)
out, err := cmd.CombinedOutput()
if err != nil {
log.Printf("failed with %v: %s", err, out)
errs = append(errs, fmt.Errorf("%v: %s", err, out))
} else {
log.Printf("passed with %s", out)
errs = nil
break
}
}
if len(errs) > 0 {
err := fmt.Errorf("%v", errs)
return err return err
} }
cmd := exec.Command( cmd = exec.Command("python3", "-m", "vtt_to_srt", path.Dir(local))
"/bin/sh", out, err = cmd.CombinedOutput()
"-c",
fmt.Sprintf(
"true; python3 -m vtt_to_srt %q || python3 /usr/bin/vtt_to_srt.py %q || vtt_to_srt %q",
path.Dir(local),
path.Dir(local),
path.Dir(local),
),
)
out, err := cmd.CombinedOutput()
if err != nil { if err != nil {
err = fmt.Errorf("%v: %s", err, out) err = fmt.Errorf("%v: %s", err, out)
return err return err

54
youtubedl/install.go Executable file → Normal file
View File

@ -2,17 +2,11 @@ package youtubedl
import ( import (
"errors" "errors"
"fmt"
"log"
"os"
"os/exec" "os/exec"
) )
func install() error { func install() error {
if _, ok := os.LookupEnv("TEST"); ok { if err := installPyPip3(); err != nil {
return nil
}
if err := installPyPip3FFMPEG(); err != nil {
return err return err
} }
if err := installYtdl(); err != nil { if err := installYtdl(); err != nil {
@ -24,59 +18,39 @@ func install() error {
return nil return nil
} }
func installPyPip3FFMPEG() error { func installPyPip3() error {
hasPy := exec.Command("python3", "--version") hasPy := exec.Command("python3", "--version")
hasPip := exec.Command("pip3", "--version") hasPip := exec.Command("pip3", "--version")
hasFFMPEG := exec.Command("which", "ffmpeg")
if err := hasPy.Run(); err != nil { if err := hasPy.Run(); err != nil {
} else if err := hasPip.Run(); err != nil { } else if err := hasPip.Run(); err != nil {
} else if err := hasFFMPEG.Run(); err != nil {
} else { } else {
return nil return nil
} }
for _, combo := range [][]string{ for _, combo := range [][]string{
[]string{"sudo", "apt", "install", "python3", "pip3", "ffmpeg"}, []string{"sudo", "apt", "install", "python3", "pip3"},
[]string{"apt", "install", "python3", "pip3", "ffmpeg"}, []string{"apt", "install", "python3", "pip3"},
[]string{"apk", "add", "python3", "py3-pip", "ffmpeg"}, []string{"apk", "add", "python3", "py3-pip"},
[]string{"sudo", "apk", "add", "python3", "py3-pip", "ffmpeg"}, []string{"sudo", "apk", "add", "python3", "py3-pip"},
[]string{"/sbin/apk", "add", "python3", "py3-pip", "ffmpeg"},
[]string{"sudo", "/sbin/apk", "add", "python3", "py3-pip", "ffmpeg"},
} { } {
cmd := exec.Command(combo[0], combo[1:]...) cmd := exec.Command(combo[0], combo[1:]...)
err := cmd.Run() if err := cmd.Run(); err == nil {
if err == nil {
return nil return nil
} }
log.Printf("%v: %v", err, combo)
} }
return errors.New("cannot get python3 and pip3 and ffmpeg") return errors.New("cannot get python3 and pip3")
} }
func installYtdl() error { func installYtdl() error {
cmd := exec.Command("/tmp/yt-dlp", "--version") cmd := exec.Command("youtube-dl", "--version")
if err := cmd.Run(); err == nil { if err := cmd.Run(); err == nil {
return err return err
} }
os.Remove("/tmp/yt-dlp") cmd = exec.Command("sudo", "pip3", "install", "youtube-dl")
cmd = exec.Command(
"wget",
"https://github.com/yt-dlp/yt-dlp/releases/latest/download/yt-dlp",
"--no-check-certificate",
"-O",
"/tmp/yt-dlp",
)
if err := cmd.Run(); err != nil { if err := cmd.Run(); err != nil {
o, _ := cmd.CombinedOutput() cmd = exec.Command("pip3", "install", "youtube-dl")
return fmt.Errorf("failed wget yt-dlp: %v: %s", err, o) if err := cmd.Run(); err != nil {
} return err
cmd = exec.Command( }
"chmod",
"a+rx",
"/tmp/yt-dlp",
)
if err := cmd.Run(); err != nil {
o, _ := cmd.CombinedOutput()
return fmt.Errorf("failed chmod yt-dlp: %v: %s", err, o)
} }
return nil return nil
} }