WebRTC Open Source: A Comprehensive Guide for Developers

1// Create peer connection
2const peerConnection = new RTCPeerConnection(configuration);
3
4// Add tracks from local stream
5localStream.getTracks().forEach(track => {
6  peerConnection.addTrack(track, localStream);
7});
8
9// Handle incoming tracks
10peerConnection.ontrack = event => {
11  remoteVideoElement.srcObject = event.streams[0];
12};
13
14// Create and send offer
15peerConnection.createOffer()
16  .then(offer => peerConnection.setLocalDescription(offer))
17  .then(() => {
18    // Send offer to remote peer via signaling server
19    sendSignalingMessage(peerConnection.localDescription);
20  });
21

1package main
2
3import (
4  "fmt"
5  "github.com/pion/webrtc/v3"
6)
7
8func main() {
9  // Create a MediaEngine object to configure the supported codecs
10  m := &webrtc.MediaEngine{}
11
12  // Setup the codecs you want to use.  You can specify the options below, or use the default
13  //  m.RegisterCodec(webrtc.RTPCodecParameters{RTPCodecType: webrtc.RTPCodecTypeVideo, MimeType: webrtc.MimeTypeVP8, PayloadType: 96, ClockRate: 90000}, webrtc.RTPCodecCapability{});
14
15  // Create the API object with the MediaEngine
16  api := webrtc.NewAPI(webrtc.WithMediaEngine(m))
17
18  // Prepare the configuration
19  config := webrtc.Configuration{
20    ICEServers: []webrtc.ICEServer{{
21      URLs: []string{"stun:stun.l.google.com:19302"},
22    }},
23  }
24
25  // Create a new RTCPeerConnection
26  peerConnection, err := api.NewPeerConnection(config)
27  if err != nil {
28    panic(err)
29  }
30
31  fmt.Println("Peer Connection Created")
32  defer peerConnection.Close()
33}
34

1const mediasoup = require('mediasoup');
2
3// Worker settings
4const worker = await mediasoup.createWorker({
5  logLevel: 'warn',
6  logTags: [
7    'info',
8    'ice',
9    'dtls',
10    'rtp',
11    'srtp',
12    'rtcp',
13    'rtx',
14    'bwe',
15    'score',
16    'simulcast',
17    'svc',
18    'sctp'
19  ],
20  rtcMinPort: 40000,
21  rtcMaxPort: 49999,
22});
23
24// Router settings
25const router = await worker.createRouter({
26  mediaCodecs: [
27    {
28      kind: 'audio',
29      mimeType: 'audio/opus',
30      clockRate: 48000,
31      channels: 2
32    },
33    {
34      kind: 'video',
35      mimeType: 'video/VP8',
36      clockRate: 90000,
37      parameters: {
38        'x-google-start-bitrate': 1000
39      }
40    }
41  ]
42});
43

1const io = require('socket.io')(3000, {
2  cors: { origin: '*' }
3});
4
5io.on('connection', socket => {
6  socket.on('join-room', (roomId, userId) => {
7    socket.join(roomId);
8    socket.to(roomId).emit('user-connected', userId);
9
10    socket.on('disconnect', () => {
11      socket.to(roomId).emit('user-disconnected', userId);
12    });
13  });
14});
15

1const socket = io('http://localhost:3000');
2const roomId = ROOM_ID; // Replace with your room ID
3const userId = generateUserId(); // Replace with your user ID generation
4
5socket.emit('join-room', roomId, userId);
6
7socket.on('user-connected', userId => {
8  console.log('User connected:', userId);
9  connectToNewUser(userId, stream);
10});
11
12socket.on('user-disconnected', userId => {
13  console.log('User disconnected:', userId);
14  if (peers[userId]) peers[userId].close();
15});
16
17function connectToNewUser(userId, stream) {
18  const call = peer.call(userId, stream);
19  call.on('stream', userVideoStream => {
20    addVideoStream(userVideoStream);
21  });
22  call.on('close', () => {
23    videoGrid.remove();
24  });
25
26  peers[userId] = call;
27}
28