Support manually requesting reencode (#1411)

Signed-off-by: Max Holland <max@livepeer.org>

Author: mjh1

handlers/schemas/UploadVOD.yaml

@@ -124,6 +124,8 @@ properties:
       additionalProperties: false
       required:
       -  "name"
+  reencode_segmentation:
+    type: "boolean"
 required:
   - "url"
   - "callback_url"

handlers/upload.go

@@ -56,6 +56,8 @@ type UploadVODRequest struct {
 
 	// Forwarded to clipping stage:
 	ClipStrategy video.ClipStrategy `json:"clip_strategy"`
+
+	ReencodeSegmentation bool `json:"reencode_segmentation"`
 }
 
 type UploadVODResponse struct {
@@ -314,6 +316,7 @@ func (d *CatalystAPIHandlersCollection) handleUploadVOD(w http.ResponseWriter, r
 		SourceCopy:            uploadVODRequest.getSourceCopyEnabled(),
 		ClipStrategy:          uploadVODRequest.ClipStrategy,
 		C2PA:                  uploadVODRequest.C2PA,
+		ReencodeSegmentation:  uploadVODRequest.ReencodeSegmentation,
 	})
 
 	respBytes, err := json.Marshal(UploadVODResponse{RequestID: requestID})

pipeline/ffmpeg.go

@@ -50,6 +50,10 @@ func (f *ffmpeg) Name() string {
 }
 
 func (f *ffmpeg) HandleStartUploadJob(job *JobInfo) (*HandlerOutput, error) {
+	if job.ReencodeSegmentation {
+		return f.handleStartUploadJob(job, true)
+	}
+
 	// First attempt: try cheap "copy" based segmenting.
 	out, err := f.handleStartUploadJob(job, false)
 	if err != nil && errors.Is(err, ErrKeyframe) {