GitHub/olcrtc
1
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcrtc.git synced 2026-06-03 19:09:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(jazz): add protobuf-style packet encoding and decoding

Browse Source
This commit is contained in:
zarazaex69
2026-04-14 01:25:33 +03:00
parent 889ac3fb7d
commit dc6e876938
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/provider/jazz/peer.go
View File

@@ -186,6 +186,7 @@ func (p *Peer) sendJoin() error {
func (p *Peer) setupDataChannelHandlers(dcReady chan struct{}) {
p.dc.OnOpen(func() {
logger.Verbosef("[Jazz] Publisher DC opened: %s", p.dc.Label())
p.wg.Add(1)
go func() {
defer p.wg.Done()
@@ -195,13 +196,14 @@ func (p *Peer) setupDataChannelHandlers(dcReady chan struct{}) {
})
p.dc.OnClose(func() {
logger.Verbosef("[Jazz] Publisher DC closed")
if !p.closed.Load() {
p.queueReconnect()
}
})
p.dc.OnMessage(func(msg webrtc.DataChannelMessage) {
logger.Verbosef("[Jazz] Received %d bytes on DataChannel", len(msg.Data))
logger.Verbosef("[Jazz] Received %d bytes on publisher DC", len(msg.Data))
if p.onData != nil && len(msg.Data) > 0 {
p.onData(msg.Data)
}
@@ -209,8 +211,12 @@ func (p *Peer) setupDataChannelHandlers(dcReady chan struct{}) {
p.pcSub.OnDataChannel(func(dc *webrtc.DataChannel) {
logger.Verbosef("[Jazz] Received subscriber DataChannel: %s", dc.Label())
if dc.Label() != "_reliable" {
return
}
dc.OnMessage(func(msg webrtc.DataChannelMessage) {
logger.Verbosef("[Jazz] Received %d bytes on subscriber DC", len(msg.Data))
logger.Verbosef("[Jazz] Received %d bytes on subscriber DC (_reliable)", len(msg.Data))
if p.onData != nil && len(msg.Data) > 0 {
p.onData(msg.Data)
}