More data transfer logging (#226)

aarshkshah1992 · web-flow · commit 1d44c41e7071 · 2021-07-29T15:09:50.000+05:30
* data-transfer logging

* data-transfer logging
diff --git a/channels/channels.go b/channels/channels.go
@@ -179,8 +179,10 @@ func (c *Channels) CreateNew(selfPeer peer.ID, tid datatransfer.TransferID, base
 		Status: datatransfer.Requested,
 	})
 	if err != nil {
+		log.Errorw("failed to create new tracking channel for data-transfer", "channelID", chid, "err", err)
 		return datatransfer.ChannelID{}, err
 	}
+	log.Debugw("created tracking channel for data-transfer, emitting channel Open event", "channelID", chid)
 	return chid, c.stateMachines.Send(chid, datatransfer.Open)
 }
 
diff --git a/impl/events.go b/impl/events.go
@@ -376,10 +376,13 @@ func (m *manager) acceptRequest(chid datatransfer.ChannelID, incoming datatransf
 		dataReceiver = m.peerID
 	}
 
+	log.Infow("data-transfer request validated, will create & start tracking channel", "channelID", chid, "payloadCid", incoming.BaseCid())
 	_, err = m.channels.CreateNew(m.peerID, incoming.TransferID(), incoming.BaseCid(), stor, voucher, chid.Initiator, dataSender, dataReceiver)
 	if err != nil {
+		log.Errorw("failed to create and start tracking channel", "channelID", chid, "err", err)
 		return result, err
 	}
+	log.Debugw("successfully created and started tracking channel", "channelID", chid)
 	if result != nil {
 		err := m.channels.NewVoucherResult(chid, result)
 		if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -179,8 +179,10 @@ func (c *Channels) CreateNew(selfPeer peer.ID, tid datatransfer.TransferID, base`
`179`	`179`	`Status: datatransfer.Requested,`
`180`	`180`	`})`
`181`	`181`	`if err != nil {`
	`182`	`+ log.Errorw("failed to create new tracking channel for data-transfer", "channelID", chid, "err", err)`
`182`	`183`	`return datatransfer.ChannelID{}, err`
`183`	`184`	`}`
	`185`	`+ log.Debugw("created tracking channel for data-transfer, emitting channel Open event", "channelID", chid)`
`184`	`186`	`return chid, c.stateMachines.Send(chid, datatransfer.Open)`
`185`	`187`	`}`
`186`	`188`
Original file line number	Diff line number	Diff line change
`@@ -376,10 +376,13 @@ func (m *manager) acceptRequest(chid datatransfer.ChannelID, incoming datatransf`
`376`	`376`	`dataReceiver = m.peerID`
`377`	`377`	`}`
`378`	`378`
	`379`	`+ log.Infow("data-transfer request validated, will create & start tracking channel", "channelID", chid, "payloadCid", incoming.BaseCid())`
`379`	`380`	`_, err = m.channels.CreateNew(m.peerID, incoming.TransferID(), incoming.BaseCid(), stor, voucher, chid.Initiator, dataSender, dataReceiver)`
`380`	`381`	`if err != nil {`
	`382`	`+ log.Errorw("failed to create and start tracking channel", "channelID", chid, "err", err)`
`381`	`383`	`return result, err`
`382`	`384`	`}`
	`385`	`+ log.Debugw("successfully created and started tracking channel", "channelID", chid)`
`383`	`386`	`if result != nil {`
`384`	`387`	`err := m.channels.NewVoucherResult(chid, result)`
`385`	`388`	`if err != nil {`