rtmp: move implementation to gortmplib

docs/4-other/4-specifications.md

@@ -4,10 +4,7 @@
 | ------------------------------------------------------------------------------------------------------------- | -------------- |
 | [RTSP / RTP / RTCP specifications](https://github.com/bluenviron/gortsplib#specifications)                    | RTSP           |
 | [HLS specifications](https://github.com/bluenviron/gohlslib#specifications)                                   | HLS            |
-| [Action Message Format - AMF 0](https://veovera.org/docs/legacy/amf0-file-format-spec.pdf)                    | RTMP           |
-| [FLV](https://veovera.org/docs/legacy/video-file-format-v10-1-spec.pdf)                                       | RTMP           |
-| [RTMP](https://veovera.org/docs/legacy/rtmp-v1-0-spec.pdf)                                                    | RTMP           |
-| [Enhanced RTMP v2](https://veovera.org/docs/enhanced/enhanced-rtmp-v2.pdf)                                    | RTMP           |
+| [RTMP specifications](https://github.com/bluenviron/gortmplib#specifications)                                 | RTMP           |
 | [WebRTC: Real-Time Communication in Browsers](https://www.w3.org/TR/webrtc/)                                  | WebRTC         |
 | [RFC8835, Transports for WebRTC](https://datatracker.ietf.org/doc/html/rfc8835)                               | WebRTC         |
 | [RFC7742, WebRTC Video Processing and Codec Requirements](https://datatracker.ietf.org/doc/html/rfc7742)      | WebRTC         |

docs/4-other/5-related-projects.md

@@ -2,6 +2,7 @@
 
 - [gortsplib (RTSP library used internally)](https://github.com/bluenviron/gortsplib)
 - [gohlslib (HLS library used internally)](https://github.com/bluenviron/gohlslib)
+- [gortmplib (RTMP library used internally)](https://github.com/bluenviron/gortmplib)
 - [mediacommon (codecs and formats library used internally)](https://github.com/bluenviron/mediacommon)
 - [mediamtx-rpicamera (Raspberry Pi Camera component)](https://github.com/bluenviron/mediamtx-rpicamera)
 - [datarhei/gosrt (SRT library used internally)](https://github.com/datarhei/gosrt)

go.mod

@@ -10,6 +10,7 @@ require (
 	github.com/alecthomas/kong v1.12.1
 	github.com/asticode/go-astits v1.13.0
 	github.com/bluenviron/gohlslib/v2 v2.2.2
+	github.com/bluenviron/gortmplib v0.0.0-20250913092258-91acda098766
 	github.com/bluenviron/gortsplib/v4 v4.16.2
 	github.com/bluenviron/mediacommon/v2 v2.4.2-0.20250909112826-017d0bbe41db
 	github.com/datarhei/gosrt v0.9.0

go.sum

@@ -33,6 +33,8 @@ github.com/benburkert/openpgp v0.0.0-20160410205803-c2471f86866c h1:8XZeJrs4+ZYh
 github.com/benburkert/openpgp v0.0.0-20160410205803-c2471f86866c/go.mod h1:x1vxHcL/9AVzuk5HOloOEPrtJY0MaalYr78afXZ+pWI=
 github.com/bluenviron/gohlslib/v2 v2.2.2 h1:Q86VloPjwONKF8pu6jSEh9ENm4UzdMl5SzYvtjneL5k=
 github.com/bluenviron/gohlslib/v2 v2.2.2/go.mod h1:3Lby/VMDD/cN0B3uJPd3bEEiJZ34LqXs71FEvN/fq2k=
+github.com/bluenviron/gortmplib v0.0.0-20250913092258-91acda098766 h1:i3Bu0Ou34hbxEyrmldAudvDm7T6qDCkaC0TrECVxXQM=
+github.com/bluenviron/gortmplib v0.0.0-20250913092258-91acda098766/go.mod h1:FyreWlRZNHSzCG7TkVT66+9n31w1uUBFgWg0G86YCfk=
 github.com/bluenviron/gortsplib/v4 v4.16.2 h1:10HaMsorjW13gscLp3R7Oj41ck2i1EHIUYCNWD2wpkI=
 github.com/bluenviron/gortsplib/v4 v4.16.2/go.mod h1:Vm07yUMys9XKnuZJLfTT8zluAN2n9ZOtz40Xb8RKh+8=
 github.com/bluenviron/mediacommon/v2 v2.4.2-0.20250909112826-017d0bbe41db h1:yBxx462HsYC14/vKr5BF/Hlpso6WmyHzjwoE/W0td5s=

internal/core/api_test.go

@@ -14,6 +14,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/bluenviron/gortmplib"
 	"github.com/bluenviron/gortsplib/v4"
 	"github.com/bluenviron/gortsplib/v4/pkg/description"
 	"github.com/bluenviron/gortsplib/v4/pkg/format"
@@ -24,7 +25,6 @@ import (
 	pwebrtc "github.com/pion/webrtc/v4"
 	"github.com/stretchr/testify/require"
 
-	"github.com/bluenviron/mediamtx/internal/protocols/rtmp"
 	"github.com/bluenviron/mediamtx/internal/protocols/webrtc"
 	"github.com/bluenviron/mediamtx/internal/protocols/whip"
 	"github.com/bluenviron/mediamtx/internal/test"
@@ -432,7 +432,7 @@ func TestAPIProtocolListGet(t *testing.T) {
 				u, err = url.Parse(rawURL)
 				require.NoError(t, err)
 
-				conn := &rtmp.Client{
+				conn := &gortmplib.Client{
 					URL:       u,
 					TLSConfig: &tls.Config{InsecureSkipVerify: true},
 					Publish:   true,
@@ -441,7 +441,7 @@ func TestAPIProtocolListGet(t *testing.T) {
 				require.NoError(t, err)
 				defer conn.Close()
 
-				w := &rtmp.Writer{
+				w := &gortmplib.Writer{
 					Conn:   conn,
 					Tracks: []format.Format{test.FormatH264},
 				}
@@ -1026,15 +1026,15 @@ func TestAPIProtocolKick(t *testing.T) {
 				u, err = url.Parse("rtmp://localhost:1935/mypath")
 				require.NoError(t, err)
 
-				conn := &rtmp.Client{
+				conn := &gortmplib.Client{
 					URL:     u,
 					Publish: true,
 				}
 				err = conn.Initialize(context.Background())
 				require.NoError(t, err)
 				defer conn.Close()
 
-				w := &rtmp.Writer{
+				w := &gortmplib.Writer{
 					Conn:   conn,
 					Tracks: []format.Format{test.FormatH264},
 				}

internal/core/metrics_test.go

@@ -12,6 +12,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/bluenviron/gortmplib"
 	"github.com/bluenviron/gortsplib/v4"
 	"github.com/bluenviron/gortsplib/v4/pkg/description"
 	"github.com/bluenviron/gortsplib/v4/pkg/format"
@@ -21,7 +22,6 @@ import (
 	pwebrtc "github.com/pion/webrtc/v4"
 	"github.com/stretchr/testify/require"
 
-	"github.com/bluenviron/mediamtx/internal/protocols/rtmp"
 	"github.com/bluenviron/mediamtx/internal/protocols/webrtc"
 	"github.com/bluenviron/mediamtx/internal/protocols/whip"
 	"github.com/bluenviron/mediamtx/internal/test"
@@ -209,15 +209,15 @@ webrtc_sessions_rtcp_packets_sent 0
 			u, err2 := url.Parse("rtmp://localhost:1935/rtmp_path")
 			require.NoError(t, err2)
 
-			conn := &rtmp.Client{
+			conn := &gortmplib.Client{
 				URL:     u,
 				Publish: true,
 			}
 			err2 = conn.Initialize(context.Background())
 			require.NoError(t, err2)
 			defer conn.Close()
 
-			w := &rtmp.Writer{
+			w := &gortmplib.Writer{
 				Conn:   conn,
 				Tracks: []format.Format{test.FormatH264},
 			}
@@ -236,7 +236,7 @@ webrtc_sessions_rtcp_packets_sent 0
 			u, err2 := url.Parse("rtmps://localhost:1936/rtmps_path")
 			require.NoError(t, err2)
 
-			conn := &rtmp.Client{
+			conn := &gortmplib.Client{
 				URL:       u,
 				TLSConfig: &tls.Config{InsecureSkipVerify: true},
 				Publish:   true,
@@ -245,7 +245,7 @@ webrtc_sessions_rtcp_packets_sent 0
 			require.NoError(t, err2)
 			defer conn.Close()
 
-			w := &rtmp.Writer{
+			w := &gortmplib.Writer{
 				Conn:   conn,
 				Tracks: []format.Format{test.FormatH264},
 			}

internal/core/path_test.go

@@ -14,6 +14,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/bluenviron/gortmplib"
 	"github.com/bluenviron/gortsplib/v4"
 	"github.com/bluenviron/gortsplib/v4/pkg/base"
 	"github.com/bluenviron/gortsplib/v4/pkg/description"
@@ -24,7 +25,6 @@ import (
 	"github.com/stretchr/testify/require"
 
 	"github.com/bluenviron/mediamtx/internal/defs"
-	"github.com/bluenviron/mediamtx/internal/protocols/rtmp"
 	"github.com/bluenviron/mediamtx/internal/protocols/whip"
 	"github.com/bluenviron/mediamtx/internal/test"
 )
@@ -216,7 +216,7 @@ func TestPathRunOnConnect(t *testing.T) {
 					u, err = url.Parse("rtmp://127.0.0.1:1935/test")
 					require.NoError(t, err)
 
-					conn := &rtmp.Client{
+					conn := &gortmplib.Client{
 						URL:     u,
 						Publish: true,
 					}
@@ -231,7 +231,7 @@ func TestPathRunOnConnect(t *testing.T) {
 					u, err = url.Parse("rtmps://127.0.0.1:1936/test")
 					require.NoError(t, err)
 
-					conn := &rtmp.Client{
+					conn := &gortmplib.Client{
 						URL:       u,
 						Publish:   true,
 						TLSConfig: &tls.Config{InsecureSkipVerify: true},
@@ -458,15 +458,15 @@ func TestPathRunOnRead(t *testing.T) {
 					u, err = url.Parse("rtmp://127.0.0.1:1935/test?query=value")
 					require.NoError(t, err)
 
-					conn := &rtmp.Client{
+					conn := &gortmplib.Client{
 						URL:     u,
 						Publish: false,
 					}
 					err = conn.Initialize(context.Background())
 					require.NoError(t, err)
 					defer conn.Close()
 
-					r := &rtmp.Reader{
+					r := &gortmplib.Reader{
 						Conn: conn,
 					}
 					err = r.Initialize()
@@ -477,7 +477,7 @@ func TestPathRunOnRead(t *testing.T) {
 					u, err = url.Parse("rtmps://127.0.0.1:1936/test?query=value")
 					require.NoError(t, err)
 
-					conn := &rtmp.Client{
+					conn := &gortmplib.Client{
 						URL:       u,
 						Publish:   false,
 						TLSConfig: &tls.Config{InsecureSkipVerify: true},
@@ -503,7 +503,7 @@ func TestPathRunOnRead(t *testing.T) {
 						}
 					}()
 
-					r := &rtmp.Reader{
+					r := &gortmplib.Reader{
 						Conn: conn,
 					}
 					err = r.Initialize()