From af173327b8fa76fdc5b12ba9127151b691a64052 Mon Sep 17 00:00:00 2001 From: Zack Scholl Date: Wed, 13 Nov 2019 09:12:56 -0800 Subject: [PATCH] log ice state --- src/croc/croc.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/src/croc/croc.go b/src/croc/croc.go index 5418fdc..1cb54b6 100644 --- a/src/croc/croc.go +++ b/src/croc/croc.go @@ -404,6 +404,8 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection break } } + msg, _ := box.Bundle(fstat.Size(), c.Key) + sendData([]byte(msg)) if pos == 0 { log.Debug("transfering file") } @@ -452,6 +454,7 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection sendMoreCh <- struct{}{} }) + var fileSize int64 // Register the OnMessage to handle incoming messages dc.OnMessage(func(dcMsg webrtc.DataChannelMessage) { var fd FileData @@ -478,6 +481,14 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection readyToEnd = true return } + if fileSize == 0 { + err = box.Unbundle(string(dcMsg.Data), c.Key, &fileSize) + if err != nil { + fileSize = 0 + } else { + log.Debugf("receiving file sized %d", fileSize) + } + } err = box.Unbundle(string(dcMsg.Data), c.Key, &fd) if err == nil { // log.Debug(fd.Position)