Fix reprocess button
This commit is contained in:
33
handlers.go
33
handlers.go
@@ -556,7 +556,7 @@ func processOriginal(originalID uint) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
} else {
|
} else {
|
||||||
fmt.Println("No original video or audio found in processOriginal")
|
log.Errorf("No original video or audio for %d found in processOriginal", originalID)
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -804,7 +804,7 @@ func videoRestartHandler(c echo.Context) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func deleteTranscodes(originalID int) {
|
func deleteTranscodes(originalID int) {
|
||||||
fmt.Println("Delete Transcode entries for Original", originalID)
|
log.Debugln("Delete Transcode entries for Original", originalID)
|
||||||
db.Delete(&Transcode{}, "original_id = ?", originalID)
|
db.Delete(&Transcode{}, "original_id = ?", originalID)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -813,13 +813,13 @@ func deleteTranscodedVideos(originalID int) {
|
|||||||
db.Where("original_id = ?", originalID).Where("source = ?", "transcode").Find(&videos)
|
db.Where("original_id = ?", originalID).Where("source = ?", "transcode").Find(&videos)
|
||||||
for _, video := range videos {
|
for _, video := range videos {
|
||||||
path := filepath.Join(getDataDir(), video.Filename)
|
path := filepath.Join(getDataDir(), video.Filename)
|
||||||
log.Debugln("remove", path)
|
log.Debugln("remove video", path)
|
||||||
err := os.Remove(path)
|
err := os.Remove(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Errorln("error removing", path, err)
|
log.Errorln("error removing", path, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
db.Delete(&Video{}, "original_id = ?", originalID)
|
db.Delete(&Video{}, "original_id = ? AND source = ?", originalID, "transcode")
|
||||||
}
|
}
|
||||||
|
|
||||||
func deleteOriginalVideos(originalID int) {
|
func deleteOriginalVideos(originalID int) {
|
||||||
@@ -833,7 +833,7 @@ func deleteOriginalVideos(originalID int) {
|
|||||||
fmt.Println("error removing", path, err)
|
fmt.Println("error removing", path, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
db.Delete(&Video{}, "original_id = ?", originalID)
|
db.Delete(&Video{}, "original_id = ? AND source = ?", originalID, "original")
|
||||||
}
|
}
|
||||||
|
|
||||||
func deleteAudios(originalID int) {
|
func deleteAudios(originalID int) {
|
||||||
@@ -841,7 +841,7 @@ func deleteAudios(originalID int) {
|
|||||||
db.Where("original_id = ?", originalID).Find(&audios)
|
db.Where("original_id = ?", originalID).Find(&audios)
|
||||||
for _, audio := range audios {
|
for _, audio := range audios {
|
||||||
path := filepath.Join(getDataDir(), audio.Filename)
|
path := filepath.Join(getDataDir(), audio.Filename)
|
||||||
log.Debugln("remove", path)
|
log.Debugln("remove audio", path)
|
||||||
err := os.Remove(path)
|
err := os.Remove(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Errorln("error removing", path, err)
|
log.Errorln("error removing", path, err)
|
||||||
@@ -877,12 +877,19 @@ func tempHandler(c echo.Context) error {
|
|||||||
return c.File(tempURL.FilePath)
|
return c.File(tempURL.FilePath)
|
||||||
}
|
}
|
||||||
|
|
||||||
// func processHandler(c echo.Context) error {
|
func processHandler(c echo.Context) error {
|
||||||
// id, _ := strconv.Atoi(c.Param("id"))
|
id, _ := strconv.Atoi(c.Param("id")) // FIXME: strconv.ParseUint?
|
||||||
|
|
||||||
// deleteTranscodes(id)
|
deleteTranscodes(id)
|
||||||
// deleteAudios(id)
|
deleteAudios(id)
|
||||||
// deleteTranscodedVideos(id)
|
deleteTranscodedVideos(id)
|
||||||
|
|
||||||
// processOriginal(id)
|
err := SetOriginalStatus(uint(id), DownloadCompleted)
|
||||||
// }
|
if err != nil {
|
||||||
|
log.Errorf("error while setting original %d status: %v", id, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
processOriginal(uint(id))
|
||||||
|
|
||||||
|
return c.Redirect(http.StatusSeeOther, "/videos")
|
||||||
|
}
|
||||||
|
1
main.go
1
main.go
@@ -122,6 +122,7 @@ func main() {
|
|||||||
e.POST("/video/:id/restart", videoRestartHandler, authMiddleware)
|
e.POST("/video/:id/restart", videoRestartHandler, authMiddleware)
|
||||||
e.POST("/video/:id/delete", videoDeleteHandler, authMiddleware)
|
e.POST("/video/:id/delete", videoDeleteHandler, authMiddleware)
|
||||||
e.GET("/temp/:token", tempHandler)
|
e.GET("/temp/:token", tempHandler)
|
||||||
|
e.POST("/video/:id/process", processHandler, authMiddleware)
|
||||||
|
|
||||||
dataGroup := e.Group("/data")
|
dataGroup := e.Group("/data")
|
||||||
dataGroup.Use(authMiddleware)
|
dataGroup.Use(authMiddleware)
|
||||||
|
@@ -38,7 +38,7 @@
|
|||||||
<div class="video-options">
|
<div class="video-options">
|
||||||
{{if eq .Status "completed"}}
|
{{if eq .Status "completed"}}
|
||||||
<form action="/video/{{.ID}}/process" method="post" style="display:inline;">
|
<form action="/video/{{.ID}}/process" method="post" style="display:inline;">
|
||||||
<button type="submit">Redo Processing</button>
|
<button type="submit">Reprocess</button>
|
||||||
</form>
|
</form>
|
||||||
{{else if eq .Status "failed"}}
|
{{else if eq .Status "failed"}}
|
||||||
<form action="/video/{{.ID}}/restart" method="post" style="display:inline;">
|
<form action="/video/{{.ID}}/restart" method="post" style="display:inline;">
|
||||||
|
Reference in New Issue
Block a user