conference: treat Publish and Unpublish equal (#69)

daniel-abramov · web-flow · commit 9679c7fb8b23 · 2022-12-10T11:29:07.000+01:00
Fixes #68.
diff --git a/pkg/conference/data_channel_message_processor.go b/pkg/conference/data_channel_message_processor.go
@@ -64,10 +64,6 @@ func (c *Conference) processPublishDCMessage(participant *Participant, msg event
 	})
 }
 
-func (c *Conference) processUnpublishDCMessage(participant *Participant) {
-	participant.logger.Info("Received unpublish over DC")
-}
-
 func (c *Conference) processAliveDCMessage(participant *Participant) {
 	participant.peer.ProcessHeartbeat()
 }
diff --git a/pkg/conference/peer_message_processor.go b/pkg/conference/peer_message_processor.go
@@ -88,10 +88,8 @@ func (c *Conference) processDataChannelMessage(participant *Participant, msg pee
 		c.processSelectDCMessage(participant, sfuMessage)
 	case event.SFUOperationAnswer:
 		c.processAnswerDCMessage(participant, sfuMessage)
-	case event.SFUOperationPublish:
+	case event.SFUOperationPublish, event.SFUOperationUnpublish:
 		c.processPublishDCMessage(participant, sfuMessage)
-	case event.SFUOperationUnpublish:
-		c.processUnpublishDCMessage(participant)
 	case event.SFUOperationAlive:
 		c.processAliveDCMessage(participant)
 	case event.SFUOperationMetadata:

Original file line number	Diff line number	Diff line change
`@@ -64,10 +64,6 @@ func (c Conference) processPublishDCMessage(participant Participant, msg event`
`64`	`64`	`})`
`65`	`65`	`}`
`66`	`66`
`67`		`-func (c Conference) processUnpublishDCMessage(participant Participant) {`
`68`		`- participant.logger.Info("Received unpublish over DC")`
`69`		`-}`
`70`		`-`
`71`	`67`	`func (c Conference) processAliveDCMessage(participant Participant) {`
`72`	`68`	`participant.peer.ProcessHeartbeat()`
`73`	`69`	`}`