Skip to content

Commit

Permalink
wip: improve logging
Browse files Browse the repository at this point in the history
  • Loading branch information
hdevalence committed Mar 23, 2023
1 parent 069c132 commit 8caa3cc
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions relayer/chains/penumbra/tx.go
Original file line number Diff line number Diff line change
Expand Up @@ -313,7 +313,6 @@ func parseEventsFromABCIResponse(resp abci.ResponseDeliverTx) []provider.Relayer
}

func (cc *PenumbraProvider) sendMessagesInner(ctx context.Context, msgs []provider.RelayerMessage, _memo string) (*coretypes.ResultBroadcastTx, error) {
cc.log.Info("sending messages", zap.String("msgs", fmt.Sprintf("%+v", msgs)))
cc.log.Info("got here 0")

// TODO: fee estimation, fee payments
Expand Down Expand Up @@ -348,7 +347,7 @@ func (cc *PenumbraProvider) sendMessagesInner(ctx context.Context, msgs []provid
}
cc.log.Info("got here 3")

cc.log.Info("broadcasting penumbra tx", zap.String("tx", fmt.Sprintf("%+v", tx)))
cc.log.Info("broadcasting penumbra tx")
txBytes, err := cosmosproto.Marshal(tx)
if err != nil {
return nil, err
Expand Down Expand Up @@ -2301,7 +2300,7 @@ func (cc *PenumbraProvider) MsgSubmitQueryResponse(chainID string, queryID provi
}

func (cc *PenumbraProvider) SendMessagesToMempool(ctx context.Context, msgs []provider.RelayerMessage, memo string, asyncCtx context.Context, asyncCallback func(*provider.RelayerTxResponse, error)) error {
fmt.Printf("sending messages to mempool: %+v\n", msgs)
_, err := cc.sendMessagesInner(ctx, msgs, memo)
sendRsp, err := cc.sendMessagesInner(ctx, msgs, memo)
cc.log.Info("send messages response", zap.Any("response", sendRsp), zap.Error(err))
return err
}

0 comments on commit 8caa3cc

Please sign in to comment.