Pass everything from conference

Signed-off-by: Šimon Brandner <[email protected]>

Author: SimonBrandner

pkg/conference/matrix_message_processor.go

@@ -52,21 +52,25 @@ func (c *Conference) onNewParticipant(participantID ParticipantID, inviteEvent *
 	} else {
 		messageSink := common.NewMessageSink(participantID, c.peerMessages)
 
-		keepAliveDeadline := time.Duration(c.config.KeepAliveTimeout) * time.Second
 		pingInterval := time.Duration(c.config.PingInterval) * time.Second
+		keepAliveDeadline := time.Duration(c.config.KeepAliveTimeout) * time.Second
 		sendPing := func() {
 			participant.sendDataChannelMessage(event.Event{
 				Type:    event.FocusCallPing,
 				Content: event.Content{},
 			})
 		}
+		onDeadLine := func() {
+			messageSink.Send(peer.LeftTheCall{Reason: event.CallHangupKeepAliveTimeout})
+		}
 		peer, answer, err := peer.NewPeer(
 			inviteEvent.Offer.SDP,
 			messageSink,
 			logger,
 			pingInterval,
 			keepAliveDeadline,
 			sendPing,
+			onDeadLine,
 		)
 		if err != nil {
 			logger.WithError(err).Errorf("Failed to process SDP offer")

pkg/peer/peer.go

@@ -36,6 +36,7 @@ type Peer[ID comparable] struct {
 
 	pong              chan Pong
 	sendPing          func()
+	onDeadLine        func()
 	pingInterval      time.Duration
 	keepAliveDeadline time.Duration
 
@@ -51,6 +52,7 @@ func NewPeer[ID comparable](
 	pingInterval time.Duration,
 	keepAliveDeadline time.Duration,
 	sendPing func(),
+	onDeadLine func(),
 ) (*Peer[ID], *webrtc.SessionDescription, error) {
 	peerConnection, err := webrtc.NewPeerConnection(webrtc.Configuration{})
 	if err != nil {
@@ -67,6 +69,7 @@ func NewPeer[ID comparable](
 		pingInterval:      pingInterval,
 		keepAliveDeadline: keepAliveDeadline,
 		sendPing:          sendPing,
+		onDeadLine:        onDeadLine,
 	}
 
 	peerConnection.OnTrack(peer.onRtpTrackReceived)

pkg/peer/webrtc.go

@@ -139,7 +139,7 @@ func (p *Peer[ID]) onDataChannelReady(dc *webrtc.DataChannel) {
 			p.keepAliveDeadline,
 			p.pong,
 			p.sendPing,
-			func() { p.sink.Send(LeftTheCall{event.CallHangupKeepAliveTimeout}) },
+			p.onDeadLine,
 		)
 	})