Merge pull request #65 from banana-framework-lab/banana-patch-1

U In version 1.19, ffmpeg in the current directory cannot be used aut…

node.go

@@ -10,11 +10,12 @@ import (
 )
 
 type Stream struct {
-	Node     *Node
+	Node       *Node
-	Label    Label
+	Label      Label
-	Selector Selector
+	Selector   Selector
-	Type     string
+	Type       string
-	Context  context.Context
+	FfmpegPath string
+	Context    context.Context
 }
 
 type RunHook struct {
@@ -27,11 +28,12 @@ type RunHook struct {
 
 func NewStream(node *Node, streamType string, label Label, selector Selector) *Stream {
 	return &Stream{
-		Node:     node,
+		Node:       node,
-		Label:    label,
+		Label:      label,
-		Selector: selector,
+		Selector:   selector,
-		Type:     streamType,
+		Type:       streamType,
-		Context:  context.Background(),
+		FfmpegPath: "ffmpeg",
+		Context:    context.Background(),
 	}
 }
 

run.go

@@ -248,10 +248,15 @@ func SeparateProcessGroup() CompilationOption {
 	}
 }
 
+func (s *Stream) SetFfmpegPath(path string) *Stream {
+	s.FfmpegPath = path
+	return s
+}
+
 // for test
 func (s *Stream) Compile(options ...CompilationOption) *exec.Cmd {
 	args := s.GetArgs()
-	cmd := exec.CommandContext(s.Context, "ffmpeg", args...)
+	cmd := exec.CommandContext(s.Context, s.FfmpegPath, args...)
 	if a, ok := s.Context.Value("Stdin").(io.Reader); ok {
 		cmd.Stdin = a
 	}