From 8d904649bd6d1899004a8dd80b037040faeb77c2 Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Mon, 4 Nov 2024 19:26:01 -0600 Subject: [PATCH] add extra logging --- .../token/application/token_handle_prover_join.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/node/execution/intrinsics/token/application/token_handle_prover_join.go b/node/execution/intrinsics/token/application/token_handle_prover_join.go index 244e288..71851c1 100644 --- a/node/execution/intrinsics/token/application/token_handle_prover_join.go +++ b/node/execution/intrinsics/token/application/token_handle_prover_join.go @@ -5,6 +5,7 @@ import ( "github.com/iden3/go-iden3-crypto/poseidon" "github.com/pkg/errors" + "go.uber.org/zap" "source.quilibrium.com/quilibrium/monorepo/node/protobufs" ) @@ -33,6 +34,8 @@ func (a *TokenApplication) handleDataAnnounceProverJoin( payload := []byte("join") if t == nil || t.PublicKeySignatureEd448 == nil { + a.Logger.Debug("invalid data for join") + return nil, errors.Wrap(ErrInvalidStateTransition, "handle join") } @@ -41,11 +44,20 @@ func (a *TokenApplication) handleDataAnnounceProverJoin( t.PublicKeySignatureEd448.PublicKey.KeyValue == nil || t.Filter == nil || len(t.Filter) != 32 || t.FrameNumber < currentFrameNumber-1 || t.FrameNumber > currentFrameNumber { + a.Logger.Debug( + "bad payload", + zap.Uint64("given_frame_number", t.FrameNumber), + zap.Uint64("current_frame_number", currentFrameNumber), + zap.Int("filter_length", len(t.Filter)), + ) + return nil, errors.Wrap(ErrInvalidStateTransition, "handle join") } if _, touched := lockMap[string( t.PublicKeySignatureEd448.PublicKey.KeyValue, )]; touched { + a.Logger.Debug("already attempted join") + return nil, errors.Wrap(ErrInvalidStateTransition, "handle join") } payload = binary.BigEndian.AppendUint64(payload, t.FrameNumber) @@ -54,16 +66,19 @@ func (a *TokenApplication) handleDataAnnounceProverJoin( if err := t.PublicKeySignatureEd448.Verify( t.PublicKeySignatureEd448.PublicKey.KeyValue, ); err != nil { + a.Logger.Debug("can't verify signature") return nil, errors.Wrap(ErrInvalidStateTransition, "handle join") } address, err := a.getAddressFromSignature(t.PublicKeySignatureEd448) if err != nil { + a.Logger.Debug("can't get address from signature") return nil, errors.Wrap(err, "handle join") } for _, t := range a.Tries { if t.Contains(address) { + a.Logger.Debug("prover already in trie", zap.Binary("address", address)) return nil, errors.Wrap(ErrInvalidStateTransition, "handle join") } }