GitHub/olcrtc
1
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcrtc.git synced 2026-05-26 07:08:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(jitsi): extract openBridgeWS and openBridgeSCTP helpers

Browse Source
This commit is contained in:
zarazaex69
2026-05-25 11:39:22 +03:00
parent 628bb2e19d
commit e64ed167cc
1 changed files with 34 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
internal/engine/jitsi/jitsi.go
View File

@@ -289,7 +289,7 @@ func (s *Session) Connect(ctx context.Context) error {
return nil
}
func (s *Session) joinAndOpenBridge(ctx context.Context) (*j.Session, error) {
func (s *Session) joinAndOpenBridge(ctx context.Context) (*j.Session, error) { //nolint:cyclop // sequential setup steps
logger.Infof("jitsi: joining %s/%s as %s …", s.host, s.room, s.name)
jSess, err := j.Join(ctx, j.Config{
Host: s.host,
@@ -305,18 +305,11 @@ func (s *Session) joinAndOpenBridge(ctx context.Context) (*j.Session, error) {
needBridge := s.onData != nil || s.onPeerData != nil
sctpBridge := needBridge && jSess.ColibriWS == ""
if needBridge && jSess.ColibriWS != "" {
bctx, bcancel := context.WithTimeout(ctx, bridgeOpenTimeout)
err := jSess.OpenBridge(bctx)
bcancel()
if err != nil {
if needBridge && !sctpBridge {
if err := s.openBridgeWS(ctx, jSess); err != nil {
_ = jSess.Close()
return nil, fmt.Errorf("open bridge: %w", err)
return nil, err
}
s.peerEndpoint.Store(nil)
s.peerVideoSSRC.Store(0)
s.bridgeReady.Store(true)
logger.Infof("jitsi: bridge open colibri-ws (endpoints=%v)", jSess.Endpoints())
}
if s.shouldNegotiatePC() {
@@ -327,20 +320,41 @@ func (s *Session) joinAndOpenBridge(ctx context.Context) (*j.Session, error) {
}
if sctpBridge {
if err := s.openBridgeSCTP(ctx, jSess); err != nil {
_ = jSess.Close()
return nil, err
}
}
return jSess, nil
}
func (s *Session) openBridgeWS(ctx context.Context, jSess *j.Session) error {
bctx, bcancel := context.WithTimeout(ctx, bridgeOpenTimeout)
err := jSess.OpenBridge(bctx)
bcancel()
if err != nil {
return fmt.Errorf("open bridge: %w", err)
}
s.peerEndpoint.Store(nil)
s.peerVideoSSRC.Store(0)
s.bridgeReady.Store(true)
logger.Infof("jitsi: bridge open colibri-ws (endpoints=%v)", jSess.Endpoints())
return nil
}
func (s *Session) openBridgeSCTP(ctx context.Context, jSess *j.Session) error {
bctx, bcancel := context.WithTimeout(ctx, bridgeOpenTimeout)
err := jSess.WaitBridgeSCTP(bctx)
bcancel()
if err != nil {
_ = jSess.Close()
return nil, fmt.Errorf("open bridge sctp: %w", err)
return fmt.Errorf("open bridge sctp: %w", err)
}
s.peerEndpoint.Store(nil)
s.peerVideoSSRC.Store(0)
s.bridgeReady.Store(true)
logger.Infof("jitsi: bridge open sctp (endpoints=%v)", jSess.Endpoints())
}
return jSess, nil
return nil
}
func (s *Session) shouldNegotiatePC() bool {