fix: add global option for transcode

This commit is contained in:
banshan
2024-10-11 09:02:06 +08:00
parent 3d25c08aa1
commit 68ab05dfa5
3 changed files with 68 additions and 61 deletions

View File

@@ -269,7 +269,10 @@ func (t *TranscodePlugin) Launch(ctx context.Context, transReq *pb.TransRequest)
if transReq.Scale != "" {
transReq.Scale = fmt.Sprintf(" -s %s ", transReq.Scale)
}
conf = strings.Join(inputs, " -i ") + fmt.Sprintf(" %s ", transReq.LogLevel) + fmt.Sprintf(" %s ", filterStr) + transReq.Scale + transReq.Decodec
if transReq.GlobalOptions != "" {
transReq.GlobalOptions = fmt.Sprintf(" %s ", transReq.GlobalOptions)
}
conf = strings.Join(inputs, " -i ") + fmt.Sprintf(" %s ", filterStr) + transReq.Scale + transReq.Encodec
cfg.Output = []config.TransfromOutput{
{
@@ -278,6 +281,10 @@ func (t *TranscodePlugin) Launch(ctx context.Context, transReq *pb.TransRequest)
Conf: conf,
},
}
cfg.Input = map[string]any{
"args": transReq.GlobalOptions,
"codec": transReq.Decodec,
}
t.Transform(transReq.SrcStream, cfg)
return