add stream url
This commit is contained in:
parent
12d7a04ba1
commit
6907794858
@ -309,6 +309,12 @@ func HandleAddJob(db *gorm.DB) http.HandlerFunc {
|
|||||||
|
|
||||||
// Enregistre chaque lien comme un job "en attente"
|
// Enregistre chaque lien comme un job "en attente"
|
||||||
for _, l := range links {
|
for _, l := range links {
|
||||||
|
streamInfo, err := client.GetTranscode(ctx, l.ID)
|
||||||
|
if err != nil {
|
||||||
|
log.Println("Erreur GetTranscode:", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
job := &download.DownloadJob{
|
job := &download.DownloadJob{
|
||||||
ID: l.ID,
|
ID: l.ID,
|
||||||
Link: l.DownloadURL,
|
Link: l.DownloadURL,
|
||||||
@ -318,7 +324,7 @@ func HandleAddJob(db *gorm.DB) http.HandlerFunc {
|
|||||||
Size: l.Size,
|
Size: l.Size,
|
||||||
Host: l.Host,
|
Host: l.Host,
|
||||||
Progress: 0, // obligatoire si valeur attendue
|
Progress: 0, // obligatoire si valeur attendue
|
||||||
StreamURL: "", // vide par défaut
|
StreamURL: streamInfo.StreamURL, // vide par défaut
|
||||||
}
|
}
|
||||||
if err := download.RegisterJobWithDB(job, db); err != nil {
|
if err := download.RegisterJobWithDB(job, db); err != nil {
|
||||||
log.Printf("[ERROR] Job non enregistré : %v\n", err)
|
log.Printf("[ERROR] Job non enregistré : %v\n", err)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user