From 137456d41f6e72a5437c8eeb3c3f94f28a7ab349 Mon Sep 17 00:00:00 2001
From: Giuseppe Coviello <gco@nec-labs.com>
Date: Wed, 31 Jan 2024 16:03:15 -0500
Subject: [PATCH] Opening http, https and rtsp streams

---
 go.mod   |  6 +++++-
 go.sum   | 10 ++++++++++
 video.go | 10 ++++++++--
 3 files changed, 23 insertions(+), 3 deletions(-)

diff --git a/go.mod b/go.mod
index 9da1150..ad5be7a 100644
--- a/go.mod
+++ b/go.mod
@@ -1,3 +1,7 @@
 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
diff --git a/go.sum b/go.sum
index e69de29..eea0c80 100644
--- a/go.sum
+++ b/go.sum
@@ -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=
diff --git a/video.go b/video.go
index df76528..36dd3b1 100644
--- a/video.go
+++ b/video.go
@@ -29,7 +29,7 @@ type Video struct {
 	cmd         *exec.Cmd         // ffmpeg command.
 
 	closeCleanupChan chan struct{} // exit from cleanup goroutine to avoid chan and goroutine leak
-	cleanupClosed bool
+	cleanupClosed    bool
 }
 
 func (video *Video) FileName() string {
@@ -110,9 +110,15 @@ func NewVideo(filename string) (*Video, error) {
 	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.
 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)
 	}
 	// Check if ffmpeg and ffprobe are installed on the users machine.