node/pkg/processor: add more log fields to message observations

Change-Id: I19d804b6668623943f798356a7ed81c1000fa377
This commit is contained in:
Leo 2021-10-01 08:48:36 +02:00 committed by Leopold Schabel
parent ef34c30049
commit 6ab0fe3855
2 changed files with 13 additions and 0 deletions

View File

@ -3,6 +3,7 @@ package processor
import (
"context"
"encoding/hex"
"github.com/mr-tron/base58"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promauto"
@ -81,7 +82,15 @@ func (p *Processor) handleMessage(ctx context.Context, k *common.MessagePublicat
p.logger.Info("observed and signed confirmed message publication",
zap.Stringer("source_chain", k.EmitterChain),
zap.Stringer("txhash", k.TxHash),
zap.String("txhash_b58", base58.Encode(k.TxHash.Bytes())),
zap.String("digest", hex.EncodeToString(digest.Bytes())),
zap.Uint32("nonce", k.Nonce),
zap.Uint64("sequence", k.Sequence),
zap.Stringer("emitter_chain", k.EmitterChain),
zap.Stringer("emitter_address", k.EmitterAddress),
zap.String("emitter_address_b58", base58.Encode(k.EmitterAddress.Bytes())),
zap.Uint8("consistency_level", k.ConsistencyLevel),
zap.String("message_id", v.MessageID()),
zap.String("signature", hex.EncodeToString(s)))
messagesSignedTotal.With(prometheus.Labels{

View File

@ -67,6 +67,10 @@ func (a Address) String() string {
return hex.EncodeToString(a[:])
}
func (a Address) Bytes() []byte {
return a[:]
}
func (a SignatureData) MarshalJSON() ([]byte, error) {
return []byte(fmt.Sprintf(`"%s"`, a)), nil
}