-
Notifications
You must be signed in to change notification settings - Fork 295
/
producer.go
59 lines (48 loc) · 1.36 KB
/
producer.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
package webrtc
import (
"github.com/AlexxIT/go2rtc/pkg/core"
"github.com/pion/webrtc/v3"
)
func (c *Conn) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error) {
core.Assert(media.Direction == core.DirectionRecvonly)
for _, track := range c.receivers {
if track.Codec == codec {
return track, nil
}
}
switch c.Mode {
case core.ModePassiveConsumer: // backchannel from browser
// set codec for consumer recv track so remote peer should send media with this codec
params := webrtc.RTPCodecParameters{
RTPCodecCapability: webrtc.RTPCodecCapability{
MimeType: MimeType(codec),
ClockRate: codec.ClockRate,
Channels: codec.Channels,
},
PayloadType: 0, // don't know if this necessary
}
tr := c.getTranseiver(media.ID)
_ = tr.SetCodecPreferences([]webrtc.RTPCodecParameters{params})
case core.ModePassiveProducer, core.ModeActiveProducer:
// Passive producers: OBS Studio via WHIP or Browser
// Active producers: go2rtc as WebRTC client or WebTorrent
default:
panic(core.Caller())
}
track := core.NewReceiver(media, codec)
c.receivers = append(c.receivers, track)
return track, nil
}
func (c *Conn) Start() error {
c.closed.Wait()
return nil
}
func (c *Conn) Stop() error {
for _, receiver := range c.receivers {
receiver.Close()
}
for _, sender := range c.senders {
sender.Close()
}
return c.pc.Close()
}