1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
package ytdlp
import (
"bytes"
"context"
"database/sql/driver"
"fmt"
"io"
"os"
"os/exec"
"path/filepath"
"time"
"within.website/x/internal"
)
const dateFormat = "20060102"
type VideoMetadata struct {
ID string `json:"id"`
Title string `json:"title"`
Thumbnail string `json:"thumbnail"`
DurationString string `json:"duration_string"`
UploadDate Date `json:"upload_date"`
URL string `json:"url" gorm:"uniqueIndex"`
}
type Date struct {
time.Time
}
func (d *Date) MarshalJSON() ([]byte, error) {
result := d.Format(dateFormat)
return []byte(fmt.Sprintf("%q", result)), nil
}
func (d *Date) UnmarshalJSON(data []byte) error {
str := string(data)
str = str[1 : len(str)-1]
parsedTime, err := time.Parse(dateFormat, str)
if err != nil {
return err
}
d.Time = parsedTime
return nil
}
// Value implements the driver.Valuer interface
func (d Date) Value() (driver.Value, error) {
return d.Format(dateFormat), nil
}
// Scan implements the sql.Scanner interface
func (d *Date) Scan(value interface{}) error {
if value == nil {
*d = Date{Time: time.Time{}}
return nil
}
switch v := value.(type) {
case time.Time:
*d = Date{Time: v}
case []byte:
parsedTime, err := time.Parse(dateFormat, string(v))
if err != nil {
return err
}
*d = Date{Time: parsedTime}
case string:
parsedTime, err := time.Parse(dateFormat, v)
if err != nil {
return err
}
*d = Date{Time: parsedTime}
default:
return fmt.Errorf("cannot scan type %T into Date", value)
}
return nil
}
func Metadata(ctx context.Context, url string) (*VideoMetadata, error) {
result, err := internal.RunJSON[VideoMetadata](ctx, "yt-dlp", "--dump-json", url)
if err != nil {
return nil, err
}
return &result, nil
}
func Download(ctx context.Context, url, to string) error {
exePath, err := exec.LookPath("yt-dlp")
if err != nil {
return fmt.Errorf("can't find yt-dlp: %w", err)
}
cmd := exec.CommandContext(ctx, exePath, "-o", filepath.Join(to, "%(id)s.%(ext)s"), "--write-info-json", url)
var stdout, stderr bytes.Buffer
cmd.Stdout = io.MultiWriter(&stdout, os.Stdout)
cmd.Stderr = io.MultiWriter(&stderr, os.Stderr)
if err := cmd.Run(); err != nil {
// TODO(Xe): return stdout/err?
return fmt.Errorf("can't download %s: %w", url, err)
}
return nil
}
|
