diff --git a/go.mod b/go.mod index 712406fd5..2b30b8c99 100644 --- a/go.mod +++ b/go.mod @@ -18,7 +18,7 @@ require ( github.com/jxskiss/base62 v1.1.0 github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1 github.com/livekit/mediatransportutil v0.0.0-20230130133657-96cfb115473a - github.com/livekit/protocol v1.4.3-0.20230303025609-c0705dbb696a + github.com/livekit/protocol v1.4.3-0.20230306094455-176d6d15b6c0 github.com/livekit/psrpc v0.2.10-0.20230303054701-5853a56b4643 github.com/mackerelio/go-osstat v0.2.3 github.com/magefile/mage v1.14.0 diff --git a/go.sum b/go.sum index 27e513609..9c1534031 100644 --- a/go.sum +++ b/go.sum @@ -232,8 +232,8 @@ github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1 h1:jm09419p0lqTkD github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1/go.mod h1:Rs3MhFwutWhGwmY1VQsygw28z5bWcnEYmS1OG9OxjOQ= github.com/livekit/mediatransportutil v0.0.0-20230130133657-96cfb115473a h1:5UkGQpskXp7HcBmyrCwWtO7ygDWbqtjN09Yva4l/nyE= github.com/livekit/mediatransportutil v0.0.0-20230130133657-96cfb115473a/go.mod h1:1Dlx20JPoIKGP45eo+yuj0HjeE25zmyeX/EWHiPCjFw= -github.com/livekit/protocol v1.4.3-0.20230303025609-c0705dbb696a h1:3yPLmATyLh6EJxXi80MYc2vapr6b5Y00nzg8Prvgha4= -github.com/livekit/protocol v1.4.3-0.20230303025609-c0705dbb696a/go.mod h1:hkK/G0wwFiLUGp9F5kxeQxq2CQuIzkmfBwKhTsc71us= +github.com/livekit/protocol v1.4.3-0.20230306094455-176d6d15b6c0 h1:GiHYcnREXQdA3Mt0c/asU6RaHFMIZ5avXVlnK/VE2k0= +github.com/livekit/protocol v1.4.3-0.20230306094455-176d6d15b6c0/go.mod h1:hkK/G0wwFiLUGp9F5kxeQxq2CQuIzkmfBwKhTsc71us= github.com/livekit/psrpc v0.2.10-0.20230303054701-5853a56b4643 h1:ftDwqesgXMu0hUXFxf4KWAqqDIXz8BBdNnit3xc6RQA= github.com/livekit/psrpc v0.2.10-0.20230303054701-5853a56b4643/go.mod h1:K0j8f1PgLShR7Lx80KbmwFkDH2BvOnycXGV0OSRURKc= github.com/mackerelio/go-osstat v0.2.3 h1:jAMXD5erlDE39kdX2CU7YwCGRcxIO33u/p8+Fhe5dJw= diff --git a/pkg/service/roommanager.go b/pkg/service/roommanager.go index 805616db5..3f7db4b1a 100644 --- a/pkg/service/roommanager.go +++ b/pkg/service/roommanager.go @@ -610,6 +610,7 @@ func (r *RoomManager) handleRTCMessage(ctx context.Context, roomName livekit.Roo up := &livekit.UserPacket{ Payload: rm.SendData.Data, DestinationSids: rm.SendData.DestinationSids, + Topic: rm.SendData.Topic, } room.SendDataPacket(up, rm.SendData.Kind) case *livekit.RTCNodeMessage_UpdateRoomMetadata: