Add Snowflake Event Reporter for Peer Communication

This commit is contained in:
Shelikhoo 2021-12-13 14:25:41 +00:00
parent c3f09994da
commit 9a7fcdec03
No known key found for this signature in database
GPG key ID: C4D5E79D22B25316

View file

@ -191,6 +191,7 @@ func (c *WebRTCPeer) preparePeerConnection(config *webrtc.Configuration) error {
return err
}
dc.OnOpen(func() {
c.eventsLogger.OnNewSnowflakeEvent(&event.EventOnSnowflakeConnected{})
log.Println("WebRTC: DataChannel.OnOpen")
close(c.open)
})
@ -198,6 +199,9 @@ func (c *WebRTCPeer) preparePeerConnection(config *webrtc.Configuration) error {
log.Println("WebRTC: DataChannel.OnClose")
c.Close()
})
dc.OnError(func(err error) {
c.eventsLogger.OnNewSnowflakeEvent(&event.EventOnSnowflakeConnectionFailed{Error: err})
})
dc.OnMessage(func(msg webrtc.DataChannelMessage) {
if len(msg.Data) <= 0 {
log.Println("0 length message---")