add VLC authentication workaround

client_read_test.go

@@ -975,7 +975,7 @@ func TestClientReadAutomaticProtocol(t *testing.T) {
 			require.NoError(t, err)
 			require.Equal(t, base.Describe, req.Method)
 
-			err = v.ValidateRequest(req, nil)
+			err = v.ValidateRequest(req)
 			require.NoError(t, err)
 
 			track, err := NewTrackH264(96, &TrackConfigH264{[]byte{0x01, 0x02, 0x03, 0x04}, []byte{0x01, 0x02, 0x03, 0x04}})
@@ -1063,7 +1063,7 @@ func TestClientReadAutomaticProtocol(t *testing.T) {
 			require.Equal(t, base.Setup, req.Method)
 			require.Equal(t, mustParseURL("rtsp://localhost:8554/teststream/trackID=0"), req.URL)
 
-			err = v.ValidateRequest(req, nil)
+			err = v.ValidateRequest(req)
 			require.NoError(t, err)
 
 			inTH = headers.Transport{}

client_test.go

@@ -146,7 +146,7 @@ func TestClientAuth(t *testing.T) {
 		require.NoError(t, err)
 		require.Equal(t, base.Describe, req.Method)
 
-		err = v.ValidateRequest(req, nil)
+		err = v.ValidateRequest(req)
 		require.NoError(t, err)
 
 		track, err := NewTrackH264(96, &TrackConfigH264{[]byte{0x01, 0x02, 0x03, 0x04}, []byte{0x01, 0x02, 0x03, 0x04}})

pkg/auth/package_test.go

@@ -77,7 +77,7 @@ func TestAuth(t *testing.T) {
 
 				req.URL = mustParseURL("rtsp://myhost/mypath")
 
-				err = va.ValidateRequest(req, nil)
+				err = va.ValidateRequest(req)
 
 				if conf != "nofail" {
 					require.Error(t, err)
@@ -110,14 +110,14 @@ func TestAuthVLC(t *testing.T) {
 		require.NoError(t, err)
 
 		req := &base.Request{
-			Method: base.Announce,
+			Method: base.Setup,
 			URL:    mustParseURL(ca.clientURL),
 		}
 		se.AddAuthorization(req)
 
 		req.URL = mustParseURL(ca.serverURL)
 
-		err = va.ValidateRequest(req, mustParseURL(ca.clientURL))
+		err = va.ValidateRequest(req)
 		require.NoError(t, err)
 	}
 }
@@ -154,7 +154,7 @@ func TestAuthHashed(t *testing.T) {
 			}
 			va.AddAuthorization(req)
 
-			err = se.ValidateRequest(req, nil)
+			err = se.ValidateRequest(req)
 
 			if conf != "nofail" {
 				require.Error(t, err)

pkg/auth/validator.go

@@ -10,6 +10,34 @@ import (
 	"github.com/aler9/gortsplib/pkg/headers"
 )
 
+func stringsReverseIndex(s, substr string) int {
+	for i := len(s) - 1 - len(substr); i >= 0; i-- {
+		if s[i:i+len(substr)] == substr {
+			return i
+		}
+	}
+	return -1
+}
+
+func generateAltURL(req *base.Request) (*base.URL, bool) {
+	if req.Method != base.Setup {
+		return nil, false
+	}
+
+	pathAndQuery, ok := req.URL.RTSPPathAndQuery()
+	if !ok {
+		return nil, false
+	}
+
+	i := stringsReverseIndex(pathAndQuery, "/trackID=")
+	if i < 0 {
+		return nil, false
+	}
+
+	ur, _ := base.ParseURL(req.URL.Scheme + "://" + req.URL.Host + "/" + pathAndQuery[:i+1])
+	return ur, true
+}
+
 // Validator allows to validate credentials generated by a Sender.
 type Validator struct {
 	user       string
@@ -84,8 +112,7 @@ func (va *Validator) Header() base.HeaderValue {
 }
 
 // ValidateRequest validates a request sent by a client.
-func (va *Validator) ValidateRequest(req *base.Request,
+func (va *Validator) ValidateRequest(req *base.Request) error {
-	altURL *base.URL) error {
 	var auth headers.Authorization
 	err := auth.Read(req.Header["Authorization"])
 	if err != nil {
@@ -150,8 +177,9 @@ func (va *Validator) ValidateRequest(req *base.Request,
 		ur := req.URL
 
 		if *auth.DigestValues.URI != ur.String() {
-			// do another try with the alternative URL
+			// in SETUP requests, VLC strips the control attribute.
-			if altURL != nil {
+			// try again with an alternative URL without the control attribute.
+			if altURL, ok := generateAltURL(req); ok {
 				ur = altURL
 
 				if *auth.DigestValues.URI != ur.String() {

pkg/auth/validator_test.go

@@ -64,7 +64,7 @@ func TestValidatorErrors(t *testing.T) {
 				Header: base.Header{
 					"Authorization": ca.hv,
 				},
-			}, nil)
+			})
 			require.Equal(t, ca.err, err.Error())
 		})
 	}

serverconn.go

@@ -19,15 +19,6 @@ const (
 	serverConnWriteBufferSize = 4096
 )
 
-func stringsReverseIndex(s, substr string) int {
-	for i := len(s) - 1 - len(substr); i >= 0; i-- {
-		if s[i:i+len(substr)] == substr {
-			return i
-		}
-	}
-	return -1
-}
-
 func getSessionID(header base.Header) string {
 	if h, ok := header["Session"]; ok && len(h) == 1 {
 		return h[0]

serversession.go

@@ -20,6 +20,15 @@ const (
 	serverSessionCheckStreamPeriod = 1 * time.Second
 )
 
+func stringsReverseIndex(s, substr string) int {
+	for i := len(s) - 1 - len(substr); i >= 0; i-- {
+		if s[i:i+len(substr)] == substr {
+			return i
+		}
+	}
+	return -1
+}
+
 func setupGetTrackIDPathQuery(
 	url *base.URL,
 	thMode *headers.TransportMode,