@@ -153,7 +153,10 @@ func (ccq *ccqP2p) run(
153
153
if _ , found := ccq .allowedPeers [msg .GetFrom ().String ()]; found {
154
154
return true
155
155
}
156
- ccq .logger .Debug ("Dropping message from unknown peer" , zap .String ("fromPeerID" , from .String ()), zap .String ("msgPeerID" , msg .ReceivedFrom .String ()), zap .String ("msgFrom" , msg .GetFrom ().String ()))
156
+ ccq .logger .Debug ("Dropping message from unknown peer" ,
157
+ zap .String ("fromPeerID" , from .String ()),
158
+ zap .String ("msgPeerID" , msg .ReceivedFrom .String ()),
159
+ zap .String ("msgFrom" , msg .GetFrom ().String ()))
157
160
return false
158
161
})
159
162
if err != nil {
@@ -261,7 +264,6 @@ func (ccq *ccqP2p) publisher(ctx context.Context, gk *ecdsa.PrivateKey, queryRes
261
264
panic (err )
262
265
}
263
266
err = ccq .th_resp .Publish (ctx , b )
264
- ccqP2pMessagesSent .Inc ()
265
267
if err != nil {
266
268
ccq .logger .Error ("failed to publish query response" ,
267
269
zap .String ("requestSignature" , msg .Signature ()),
@@ -270,6 +272,7 @@ func (ccq *ccqP2p) publisher(ctx context.Context, gk *ecdsa.PrivateKey, queryRes
270
272
zap .Error (err ),
271
273
)
272
274
} else {
275
+ ccqP2pMessagesSent .Inc ()
273
276
ccq .logger .Info ("published signed query response" , //TODO: Change to Debug
274
277
zap .String ("requestSignature" , msg .Signature ()),
275
278
zap .Any ("query_response" , msg ),
0 commit comments