mirror of
https://github.com/AlexxIT/go2rtc.git
synced 2025-10-30 11:16:20 +08:00
Move ParseQuery from ffmpeg to streams module
This commit is contained in:
@@ -127,7 +127,7 @@ func parseArgs(s string) *ffmpeg.Args {
|
|||||||
|
|
||||||
var query url.Values
|
var query url.Values
|
||||||
if i := strings.IndexByte(s, '#'); i > 0 {
|
if i := strings.IndexByte(s, '#'); i > 0 {
|
||||||
query = parseQuery(s[i+1:])
|
query = streams.ParseQuery(s[i+1:])
|
||||||
args.Video = len(query["video"])
|
args.Video = len(query["video"])
|
||||||
args.Audio = len(query["audio"])
|
args.Audio = len(query["audio"])
|
||||||
s = s[:i]
|
s = s[:i]
|
||||||
@@ -278,16 +278,3 @@ func parseArgs(s string) *ffmpeg.Args {
|
|||||||
|
|
||||||
return args
|
return args
|
||||||
}
|
}
|
||||||
|
|
||||||
func parseQuery(s string) map[string][]string {
|
|
||||||
query := map[string][]string{}
|
|
||||||
for _, key := range strings.Split(s, "#") {
|
|
||||||
var value string
|
|
||||||
i := strings.IndexByte(key, '=')
|
|
||||||
if i > 0 {
|
|
||||||
key, value = key[:i], key[i+1:]
|
|
||||||
}
|
|
||||||
query[key] = append(query[key], value)
|
|
||||||
}
|
|
||||||
return query
|
|
||||||
}
|
|
||||||
|
|||||||
19
internal/streams/helpers.go
Normal file
19
internal/streams/helpers.go
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
package streams
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/url"
|
||||||
|
"strings"
|
||||||
|
)
|
||||||
|
|
||||||
|
func ParseQuery(s string) url.Values {
|
||||||
|
params := url.Values{}
|
||||||
|
for _, key := range strings.Split(s, "#") {
|
||||||
|
var value string
|
||||||
|
i := strings.IndexByte(key, '=')
|
||||||
|
if i > 0 {
|
||||||
|
key, value = key[:i], key[i+1:]
|
||||||
|
}
|
||||||
|
params[key] = append(params[key], value)
|
||||||
|
}
|
||||||
|
return params
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user