conference: add additional call invite logging

Author: daniel-abramov

pkg/conference/matrix.go

@@ -72,6 +72,7 @@ func (c *Conference) onNewParticipant(participantID ParticipantID, inviteEvent *
 	// Send the answer back to the remote peer.
 	recipient := participant.asMatrixRecipient()
 	streamMetadata := c.getAvailableStreamsFor(participantID)
+	participant.logger.WithField("sdpAnswer", sdpAnswer.SDP).Debug("Sending SDP answer")
 	c.signaling.SendSDPAnswer(recipient, streamMetadata, sdpAnswer.SDP)
 	return nil
 }

pkg/main.go

@@ -40,6 +40,9 @@ func main() {
 	// Initialize logging subsystem (formatting, global logging framework etc).
 	logrus.SetFormatter(&logrus.TextFormatter{FullTimestamp: true, ForceColors: true})
 
+	// Temporarily enable debug logging.
+	logrus.SetLevel(logrus.DebugLevel)
+
 	// Define functions that are called before exiting.
 	// This is useful to stop the profiler if it's enabled.
 	deferred_functions := []func(){}

pkg/peer/peer.go

@@ -165,6 +165,7 @@ func (p *Peer[ID]) ProcessSDPAnswer(sdpAnswer string) error {
 
 // Applies the sdp offer received from the remote peer and generates an SDP answer.
 func (p *Peer[ID]) ProcessSDPOffer(sdpOffer string) (*webrtc.SessionDescription, error) {
+	p.logger.WithField("sdpOffer", sdpOffer).Debug("processing SDP offer")
 	err := p.peerConnection.SetRemoteDescription(webrtc.SessionDescription{
 		Type: webrtc.SDPTypeOffer,
 		SDP:  sdpOffer,
@@ -185,8 +186,6 @@ func (p *Peer[ID]) ProcessSDPOffer(sdpOffer string) (*webrtc.SessionDescription,
 		return nil, ErrCantSetLocalDescription
 	}
 
-	// TODO: Do we really need to call `webrtc.GatheringCompletePromise` here?
-
 	sdpAnswer := p.peerConnection.LocalDescription()
 	if sdpAnswer == nil {
 		p.logger.WithError(err).Error("could not generate a local description")

pkg/router.go

@@ -95,26 +95,21 @@ func (r *Router) handleMatrixEvent(evt *event.Event) {
 	// Only ToDeviceCallInvite events are allowed to create a new conference, others
 	// are expected to operate on an existing conference that is running on the SFU.
 	if conference == nil && evt.Type.Type == event.ToDeviceCallInvite.Type {
-		if evt.Type.Type == event.ToDeviceCallInvite.Type {
-			logger.Infof("creating new conference %s", conferenceID)
-			conferenceSink, err := conf.StartConference(
-				conferenceID,
-				r.config,
-				r.matrix.CreateForConference(conferenceID),
-				createConferenceEndNotifier(conferenceID, r.channel),
-				evt.Sender,
-				evt.Content.AsCallInvite(),
-			)
-			if err != nil {
-				logger.WithError(err).Errorf("failed to start conference %s", conferenceID)
-				return
-			}
-
-			r.conferenceSinks[conferenceID] = conferenceSink
+		logger.Infof("creating new conference %s", conferenceID)
+		conferenceSink, err := conf.StartConference(
+			conferenceID,
+			r.config,
+			r.matrix.CreateForConference(conferenceID),
+			createConferenceEndNotifier(conferenceID, r.channel),
+			evt.Sender,
+			evt.Content.AsCallInvite(),
+		)
+		if err != nil {
+			logger.WithError(err).Errorf("failed to start conference %s", conferenceID)
 			return
 		}
 
-		logger.Warnf("ignoring %s since the conference is unknown", event.ToDeviceCallInvite.Type)
+		r.conferenceSinks[conferenceID] = conferenceSink
 		return
 	}