update

admpub · admpub · commit 1e5198117688 · 2022-02-11T20:34:41.000+08:00
diff --git a/ffmpeg/ffmpeg.go b/ffmpeg/ffmpeg.go
@@ -132,7 +132,9 @@ func (t *Transcoder) Start(opts transcoder.Options) (<-chan transcoder.Progress,
 			defer close(out)
 			err = cmd.Wait()
 			if err != nil {
-				log.Printf("failed to transcoding (%s) with args (%s) with error %v", t.config.FfmpegBinPath, args, err)
+				err = fmt.Errorf("failed to transcoding (%s) with args (%s) with error %w", t.config.FfmpegBinPath, args, err)
+				log.Println(err)
+				out <- &Progress{Error: err}
 			}
 		}()
 	} else {
diff --git a/ffmpeg/progress.go b/ffmpeg/progress.go
@@ -7,6 +7,7 @@ type Progress struct {
 	CurrentBitrate  string
 	Progress        float64
 	Speed           string
+	Error           error
 }
 
 // GetFramesProcessed ...
@@ -33,3 +34,8 @@ func (p Progress) GetProgress() float64 {
 func (p Progress) GetSpeed() string {
 	return p.Speed
 }
+
+// GetError ...
+func (p Progress) GetError() error {
+	return p.Error
+}
diff --git a/progress.go b/progress.go
@@ -7,4 +7,5 @@ type Progress interface {
 	GetCurrentBitrate() string
 	GetProgress() float64
 	GetSpeed() string
+	GetError() error
 }
