Adds error output for WebTorrent
This commit is contained in:
@@ -54,7 +54,7 @@ func Init() {
|
|||||||
if log.Debug().Enabled() {
|
if log.Debug().Enabled() {
|
||||||
srv.Listen(func(msg interface{}) {
|
srv.Listen(func(msg interface{}) {
|
||||||
switch msg.(type) {
|
switch msg.(type) {
|
||||||
case string:
|
case string, error:
|
||||||
log.Debug().Msgf("[webtorrent] %s", msg)
|
log.Debug().Msgf("[webtorrent] %s", msg)
|
||||||
case *webtorrent.Message:
|
case *webtorrent.Message:
|
||||||
log.Trace().Any("msg", msg).Msgf("[webtorrent]")
|
log.Trace().Any("msg", msg).Msgf("[webtorrent]")
|
||||||
|
|||||||
@@ -130,23 +130,29 @@ func (s *Server) reader(ws *websocket.Conn, peerID string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
s.Fire("new offer: " + v.OfferId)
|
||||||
|
|
||||||
cipher, err := NewCipher(share.name, share.pwd, v.OfferId)
|
cipher, err := NewCipher(share.name, share.pwd, v.OfferId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
s.Fire(err)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
enc, err := base64.StdEncoding.DecodeString(v.Offer.SDP)
|
enc, err := base64.StdEncoding.DecodeString(v.Offer.SDP)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
s.Fire(err)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
offer, err := cipher.Decrypt(enc)
|
offer, err := cipher.Decrypt(enc)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
s.Fire(err)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
answer, err := s.Exchange(share.src, string(offer))
|
answer, err := s.Exchange(share.src, string(offer))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
s.Fire(err)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user