From 5a09e907ec686b55f2c2ad8b65e61d0ecd192f6b Mon Sep 17 00:00:00 2001
From: dexter <178529795@qq.com>
Date: Thu, 17 Nov 2022 17:03:48 +0800
Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20FIX:=20=E5=A4=96=E6=8E=A8?=
 =?UTF-8?q?=E6=97=B6streamPath=E8=AE=BE=E5=AE=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 client.go | 5 +++--
 server.go | 4 ++++
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/client.go b/client.go
index 1f6e103..886123f 100644
--- a/client.go
+++ b/client.go
@@ -102,7 +102,8 @@ func (pusher *RTMPPusher) Push() error {
 				if response, ok := msg.MsgData.(*ResponseCreateStreamMessage); ok {
 					pusher.StreamID = response.StreamId
 					URL, _ := url.Parse(pusher.RemoteURL)
-					ps := strings.Split(URL.Path, "/")
+					_, streamPath, _ := strings.Cut(URL.Path, "/")
+					_, streamPath, _ = strings.Cut(streamPath, "/")
 					pusher.Args = URL.Query()
 					pusher.SendMessage(RTMP_MSG_AMF0_COMMAND, &PublishMessage{
 						CURDStreamMessage{
@@ -112,7 +113,7 @@ func (pusher *RTMPPusher) Push() error {
 							},
 							response.StreamId,
 						},
-						ps[len(ps)-1],
+						streamPath,
 						"live",
 					})
 				} else if response, ok := msg.MsgData.(*ResponsePublishMessage); ok {
diff --git a/server.go b/server.go
index dc85301..9a88bfe 100644
--- a/server.go
+++ b/server.go
@@ -166,10 +166,14 @@ func (config *RTMPConfig) ServeTCP(conn *net.TCPConn) {
 			case RTMP_MSG_AUDIO:
 				if r, ok := receivers[msg.MessageStreamID]; ok {
 					r.ReceiveAudio(msg)
+				} else {
+					RTMPPlugin.Warn("ReceiveAudio", zap.Uint32("MessageStreamID", msg.MessageStreamID))
 				}
 			case RTMP_MSG_VIDEO:
 				if r, ok := receivers[msg.MessageStreamID]; ok {
 					r.ReceiveVideo(msg)
+				} else {
+					RTMPPlugin.Warn("ReceiveVideo", zap.Uint32("MessageStreamID", msg.MessageStreamID))
 				}
 			}
 		} else {