Rebase on new interface changes

ionorg · May 12, 2021 · d8b3da2 · d8b3da2
1 parent 2085194
commit d8b3da2
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/pkg/middlewares/datachannel/subscriberapi.go b/pkg/middlewares/datachannel/subscriberapi.go
@@ -70,7 +70,7 @@ func transformLayers(layers []string) ([]uint16, error) {
 	return res, nil
 }
 
-func sendMessage(streamID string, peer *sfu.Peer, layers []string, activeLayer int) {
+func sendMessage(streamID string, peer sfu.Peer, layers []string, activeLayer int) {
 	al, _ := layerIntToStr(activeLayer)
 	payload := activeLayerMessage{
 		StreamID:        streamID,

diff --git a/pkg/sfu/peer.go b/pkg/sfu/peer.go
@@ -30,6 +30,7 @@ type Peer interface {
 	Publisher() *Publisher
 	Subscriber() *Subscriber
 	Close() error
+	SendAPIChannelMessage(msg *[]byte) error
 }
 
 // JoinConfig allow adding more control to the peers joining a SessionLocal.
@@ -246,7 +247,7 @@ func (p *PeerLocal) Trickle(candidate webrtc.ICECandidateInit, target int) error
 	return nil
 }
 
-func (p *Peer) SendAPIChannelMessage(msg *[]byte) error {
+func (p *PeerLocal) SendAPIChannelMessage(msg *[]byte) error {
 	if p.subscriber == nil {
 		return fmt.Errorf("No subscriber for this peer")
 	}

diff --git a/pkg/sfu/session.go b/pkg/sfu/session.go
@@ -22,6 +22,7 @@ type Session interface {
 	GetDCMiddlewares() []*Datachannel
 	GetDataChannelLabels() []string
 	GetDataChannels(origin, label string) (dcs []*webrtc.DataChannel)
+	Peers() []Peer
 }
 
 type SessionLocal struct {