for _, peer := range m.sw.GetPeers().List() {
xPub := &chainkd.XPub{}
if err := xPub.UnmarshalText([]byte(peer.Key)); err != nil {
- log.Error(err)
+ log.WithFields(log.Fields{"xpub": peer.Key}).Error("unmarshal xpub")
continue
}
publicKey := xPub.PublicKey().String()
connMap[publicKey] = true
if err := m.processConnectedPeer(publicKeyMap[publicKey], peer); err != nil {
- log.Error(err)
+ log.WithFields(log.Fields{
+ "peer publicKey": publicKey,
+ "err": err,
+ }).Error("processConnectedPeer")
}
}
}
if err := m.processOfflinePeer(ormNode); err != nil {
- log.Error(err)
+ log.WithFields(log.Fields{
+ "peer publicKey": ormNode.PublicKey,
+ "err": err,
+ }).Error("processOfflinePeer")
}
}
for _, peerInfo := range peerInfos {
dbTx := m.db.Begin()
if err := m.processPeerInfo(dbTx, peerInfo); err != nil {
- log.Error(err)
+ log.WithFields(log.Fields{
+ "peerInfo": peerInfo,
+ "err": err,
+ }).Error("processPeerInfo")
dbTx.Rollback()
} else {
dbTx.Commit()