Unsupported scheme on Describe with Lorex cameras

[ROBGBHSH]

Hi,

I am new to Go and to RTSP and this library. Any help would be very much appreciated. I searched for Lorex and Describe and did not find any topics.

I am trying to read the stream from a Lorex camera that is Dahua based. According to Lorex documentation and the camera settings itself, the rtsp format is: rtsp://Username:Password@IP:Port/cam/realmonitor?channel=1&subtype=1

I have used this format in VLC (actually copied the rtspURL value from debug) and can get a stream, but when I try to connect in GO to rtsp I get an unsupported scheme error during client.Describe

The code is here:

package main

import (
"fmt"
"log"
"net/http"
"os"
)

func main() {
// The main function starts the HTTP server and sets up the route for handling RTSP stream requests.
// The HTTP server listens on port 8080 on localhost and calls the handleStream function for any requests to the /stream endpoint.

fmt.Fprintf(os.Stderr, "Lorex Viewer Backend Starting...\n")

http.HandleFunc("/stream", handleStream)

if err := http.ListenAndServe(":8080", nil); err != nil {
	fmt.Fprintf(os.Stderr, "Error: Lorex Viewer Backend Failed to Start: %v\n", err)
	log.Fatalf("server failed to start: %v", err)
}

}

func handleStream(w http.ResponseWriter, r *http.Request) {
// The handleStream function processes incoming HTTP requests to connect to an RTSP stream.
// It extracts the necessary parameters (user, pass, ip, port, channel, subtype) from the query string of the request.
// If any required parameters are missing, it responds with a 400 Bad Request error.
// If all parameters are present, it calls the connectRTSP function to establish a connection to the RTSP stream.
// If the connection is successful, it responds with a message indicating the RTSP URL that was connected to.

user := r.URL.Query().Get("user")
pass := r.URL.Query().Get("pass")
ip := r.URL.Query().Get("ip")
port := r.URL.Query().Get("port")
subtype := r.URL.Query().Get("subtype")
channel := r.URL.Query().Get("channel")
if user == "" || pass == "" || ip == "" || port == "" || channel == "" || subtype == "" {
	fmt.Fprintf(os.Stderr, "Error: Missing required parameters\n")
	http.Error(w, "Missing required parameters", http.StatusBadRequest)
	return
}

client, rtspURL, err := connectRTSP(user, pass, ip, port, channel, subtype)
if err != nil {
	fmt.Fprintf(os.Stderr, "Error: Lorex Viewer Backend Failed to Connect to RTSP Stream: %v\n", err)
	http.Error(w, err.Error(), http.StatusInternalServerError)
	return
}
defer client.Close()

fmt.Fprintf(w, "Connected to RTSP stream at %s", rtspURL)

}

package main

import (
"fmt"
"net/url"
"os"

"github.com/bluenviron/gortsplib/v5"
"github.com/bluenviron/gortsplib/v5/pkg/base"
"github.com/bluenviron/gortsplib/v5/pkg/headers"

)

func connectRTSP(user string, pass string, ip, port, channel string, subtype string) (*gortsplib.Client, string, error) {
// connectRTSP connects to the RTSP stream and returns the client and the RTSP URL used.

userEnc := url.QueryEscape(user)
passEnc := url.QueryEscape(pass)

rtspURL := fmt.Sprintf("rtsp://%s:%s@%s:%s/cam/realmonitor?channel=%s&subtype=%s", userEnc, passEnc, ip, port, channel, subtype)

u, err := url.Parse(rtspURL)
if err != nil {
	fmt.Fprintf(os.Stderr, "Standard URL parse error: %v\n", err)
} else {
	fmt.Fprintf(os.Stderr, "Standard URL parse success: %v\n", u)
}

	client := &gortsplib.Client{}

if err := client.Start(); err != nil {
	fmt.Fprintf(os.Stderr, "Error: failed to start RTSP client: %v\n", err)
	return nil, "", fmt.Errorf("failed to start RTSP client: %w", err)
}

baseURL, err := base.ParseURL(rtspURL)
if err != nil {
	client.Close()
	fmt.Fprintf(os.Stderr, "Error: failed to parse RTSP URL: %v\n", err)
	return nil, "", fmt.Errorf("invalid RTSP URL: %w", err)
}

fmt.Fprintf(os.Stderr, "Attempting to describe RTSP URL: %s\n", rtspURL)

desc, _, err := client.Describe(baseURL)
if err != nil {
	client.Close()
	fmt.Fprintf(os.Stderr, "Error: failed to describe RTSP URL: %v\n", err)
	return nil, "", fmt.Errorf("failed to describe RTSP media: %w", err)
}

if err := client.SetupAll(desc.BaseURL, desc.Medias); err != nil {
	client.Close()
	fmt.Fprintf(os.Stderr, "Error: failed to setup RTSP media: %v\n", err)
	return nil, "", fmt.Errorf("failed to setup RTSP media: %w", err)
}

if _, err := client.Play(&headers.Range{}); err != nil {
	client.Close()
	fmt.Fprintf(os.Stderr, "Error: failed to play RTSP stream: %v\n", err)
	return nil, "", fmt.Errorf("failed to play RTSP stream: %w", err)
}

return client, rtspURL, nil

}