Fixed the input/output pipes

ffmpeg/ffmpeg.go

@@ -27,8 +27,6 @@ type Transcoder struct {
 	outputOptions    [][]string
 	metadata         transcoder.Metadata
 	inputPipeReader  *io.ReadCloser
-	outputPipeReader *io.ReadCloser
-	inputPipeWriter  *io.WriteCloser
 	outputPipeWriter *io.WriteCloser
 	commandContext   *context.Context
 }
@@ -105,7 +103,7 @@ func (t *Transcoder) Start() (<-chan transcoder.Progress, error) {
 	if t.config.ProgressEnabled && !t.config.Verbose {
 		stderrIn, err = cmd.StderrPipe()
 		if err != nil {
-			return nil, fmt.Errorf("Failed getting transcoding progress (%s) with args (%s) with error %s", t.config.FfmpegBinPath, args, err)
+			return nil, fmt.Errorf("failed getting transcoding progress (%s) with args (%s) with error %s", t.config.FfmpegBinPath, args, err)
 		}
 	}
 
@@ -116,7 +114,7 @@ func (t *Transcoder) Start() (<-chan transcoder.Progress, error) {
 	// Start process
 	err = cmd.Start()
 	if err != nil {
-		return nil, fmt.Errorf("Failed starting transcoding (%s) with args (%s) with error %s", t.config.FfmpegBinPath, args, err)
+		return nil, fmt.Errorf("failed starting transcoding (%s) with args (%s) with error %s", t.config.FfmpegBinPath, args, err)
 	}
 
 	if t.config.ProgressEnabled && !t.config.Verbose {
@@ -148,20 +146,16 @@ func (t *Transcoder) Output(arg string) transcoder.Transcoder {
 }
 
 // InputPipe ...
-func (t *Transcoder) InputPipe(w *io.WriteCloser, r *io.ReadCloser) transcoder.Transcoder {
-	if &t.input == nil {
-		t.inputPipeWriter = w
-		t.inputPipeReader = r
-	}
+func (t *Transcoder) InputPipe(r *io.ReadCloser) transcoder.Transcoder {
+	t.input = "pipe:"
+	t.inputPipeReader = r
 	return t
 }
 
 // OutputPipe ...
-func (t *Transcoder) OutputPipe(w *io.WriteCloser, r *io.ReadCloser) transcoder.Transcoder {
-	if &t.output == nil {
-		t.outputPipeWriter = w
-		t.outputPipeReader = r
-	}
+func (t *Transcoder) OutputPipe(w *io.WriteCloser) transcoder.Transcoder {
+	t.output = []string{}
+	t.outputPipeWriter = w
 	return t
 }
 
@@ -235,16 +229,14 @@ func (t *Transcoder) GetMetadata() (transcoder.Metadata, error) {
 		var outb, errb bytes.Buffer
 
 		input := t.input
-
-		if t.inputPipeReader != nil {
-			input = "pipe:"
-		}
-
 		args := []string{"-i", input, "-print_format", "json", "-show_format", "-show_streams", "-show_error"}
 
 		cmd := exec.Command(t.config.FfprobeBinPath, args...)
 		cmd.Stdout = &outb
 		cmd.Stderr = &errb
+		if t.inputPipeReader != nil {
+			cmd.Stdin = *t.inputPipeReader
+		}
 
 		err := cmd.Run()
 		if err != nil {
@@ -256,7 +248,6 @@ func (t *Transcoder) GetMetadata() (transcoder.Metadata, error) {
 		if err = json.Unmarshal([]byte(outb.String()), &metadata); err != nil {
 			return nil, err
 		}
-
 		t.metadata = metadata
 
 		return metadata, nil