astra/Vidio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Opening http, https and rtsp streams

Browse source
This commit is contained in:
Giuseppe Coviello 2024-01-31 16:03:15 -05:00
parent afcc49ec6c
commit 137456d41f
3 changed files with 23 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
go.mod
View file

@ -1,3 +1,7 @@
module github.com/AlexEidt/Vidio module github.com/AlexEidt/Vidio
go 1.16 go 1.21.1
toolchain go1.21.4
require github.com/nla-is/datax-go/v2 v2.0.0-alpha.5 // indirect

10
go.sum
View file

@ -0,0 +1,10 @@
github.com/ebitengine/purego v0.5.0 h1:JrMGKfRIAM4/QVKaesIIT7m/UVjTj5GYhRSQYwfVdpo=
github.com/ebitengine/purego v0.5.0/go.mod h1:ah1In8AOtksoNK6yk5z1HTJeUkC1Ez4Wk2idgGslMwQ=
github.com/fxamacker/cbor/v2 v2.5.0 h1:oHsG0V/Q6E/wqTS2O1Cozzsy69nqCiguo5Q1a1ADivE=
github.com/fxamacker/cbor/v2 v2.5.0/go.mod h1:TA1xS00nchWmaBnEIxPSE5oHLuJBAVvqrtAnWBwBCVo=
github.com/nla-is/datax-go/v2 v2.0.0-alpha.5 h1:eTzwuQdlbta+YWIcrIM69JuaGMCfUMzl7OEmP0SnrRU=
github.com/nla-is/datax-go/v2 v2.0.0-alpha.5/go.mod h1:PcxU+Rc92jHGwoddnqIxQDXF1XYWTLgIAxhvIfFzQzM=
github.com/x448/float16 v0.8.4 h1:qLwI1I70+NjRFUR3zs1JPUCgaCXSh3SW62uAKT1mSBM=
github.com/x448/float16 v0.8.4/go.mod h1:14CWIYCyZA/cWjXOioeEpHeN/83MdbZDRQHoFcYsOfg=
golang.org/x/sys v0.7.0 h1:3jlCCIQZPdOYu1h8BkNvLz8Kgwtae2cagcG/VamtZRU=
golang.org/x/sys v0.7.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

10
video.go
View file

@ -29,7 +29,7 @@ type Video struct {
cmd *exec.Cmd // ffmpeg command. cmd *exec.Cmd // ffmpeg command.
closeCleanupChan chan struct{} // exit from cleanup goroutine to avoid chan and goroutine leak closeCleanupChan chan struct{} // exit from cleanup goroutine to avoid chan and goroutine leak
cleanupClosed bool cleanupClosed bool
} }
func (video *Video) FileName() string { func (video *Video) FileName() string {
@ -110,9 +110,15 @@ func NewVideo(filename string) (*Video, error) {
return streams[0], err return streams[0], err
} }
func isStream(url string) bool {
return strings.HasPrefix(url, "http://") ||
strings.HasPrefix(url, "https://") ||
strings.HasPrefix(url, "rtsp://")
}
// Read all video streams from the given file. // Read all video streams from the given file.
func NewVideoStreams(filename string) ([]*Video, error) { func NewVideoStreams(filename string) ([]*Video, error) {
if !exists(filename) { if !isStream(filename) && !exists(filename) {
return nil, fmt.Errorf("vidio: video file %s does not exist", filename) return nil, fmt.Errorf("vidio: video file %s does not exist", filename)
} }
// Check if ffmpeg and ffprobe are installed on the users machine. // Check if ffmpeg and ffprobe are installed on the users machine.