Skip to content

Commit

Permalink
Improve evidence logging
Browse files Browse the repository at this point in the history
  • Loading branch information
dzmitryhil committed Feb 8, 2024
1 parent 2aed90c commit c4aabf5
Show file tree
Hide file tree
Showing 3 changed files with 23 additions and 14 deletions.
7 changes: 1 addition & 6 deletions relayer/client/bridge.go
Original file line number Diff line number Diff line change
Expand Up @@ -1139,12 +1139,7 @@ func (b *BridgeClient) autoFillSignSubmitAndAwaitXRPLTx(
return err
}

b.log.Info(
ctx,
"Submitting XRPL transaction",
zap.String("txHash", tx.GetHash().String()),
zap.Any("tx", tx),
)
b.log.Info(ctx, "Submitting XRPL transaction", zap.String("txHash", tx.GetHash().String()))
if err = b.xrplRPCClient.SubmitAndAwaitSuccess(ctx, tx); err != nil {
return err
}
Expand Down
10 changes: 10 additions & 0 deletions relayer/logger/yaml_console.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import (
"strings"
"time"

sdkmath "cosmossdk.io/math"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/pkg/errors"
"go.uber.org/zap"
Expand Down Expand Up @@ -450,6 +451,15 @@ func (c *yamlConsoleEncoder) appendCustomTypes(value interface{}) bool {
c.AppendString(addr.String())
return true
}
if intVal, ok := value.(sdk.Int); ok { //nolint:staticcheck //the type is deprecated by still used
c.AppendString(intVal.String())
return true
}
if intVal, ok := value.(sdkmath.Int); ok {
c.AppendString(intVal.String())
return true
}

return false
}

Expand Down
20 changes: 12 additions & 8 deletions relayer/processes/xrpl_to_coreum.go
Original file line number Diff line number Diff line change
Expand Up @@ -149,6 +149,7 @@ func (o *XRPLToCoreumProcess) processIncomingTx(ctx context.Context, tx rippleda

_, err = o.contractClient.SendXRPLToCoreumTransferEvidence(ctx, o.cfg.RelayerCoreumAddress, evidence)
if err == nil {
o.log.Info(ctx, "Successfully sent XRPL to Coreum transfer evidence", zap.Any("evidence", evidence))
return nil
}

Expand Down Expand Up @@ -240,7 +241,7 @@ func (o *XRPLToCoreumProcess) sendXRPLTicketsAllocationTransactionResultEvidence
evidence,
)

return o.handleEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
return o.handleOperationEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
}

func (o *XRPLToCoreumProcess) sendXRPLTrustSetTransactionResultEvidence(
Expand All @@ -265,7 +266,7 @@ func (o *XRPLToCoreumProcess) sendXRPLTrustSetTransactionResultEvidence(
evidence,
)

return o.handleEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
return o.handleOperationEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
}

func (o *XRPLToCoreumProcess) sendCoreumToXRPLTransferTransactionResultEvidence(
Expand All @@ -290,7 +291,7 @@ func (o *XRPLToCoreumProcess) sendCoreumToXRPLTransferTransactionResultEvidence(
evidence,
)

return o.handleEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
return o.handleOperationEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
}

func (o *XRPLToCoreumProcess) sendKeysRotationTransactionResultEvidence(
Expand Down Expand Up @@ -325,19 +326,22 @@ func (o *XRPLToCoreumProcess) sendKeysRotationTransactionResultEvidence(
evidence,
)

return o.handleEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
return o.handleOperationEvidenceSubmissionError(ctx, err, tx, evidence.XRPLTransactionResultEvidence)
}

func (o *XRPLToCoreumProcess) handleEvidenceSubmissionError(
func (o *XRPLToCoreumProcess) handleOperationEvidenceSubmissionError(
ctx context.Context,
err error,
tx rippledata.TransactionWithMetaData,
evidence coreum.XRPLTransactionResultEvidence,
) error {
if err == nil {
if evidence.TransactionResult != coreum.TransactionResultAccepted {
o.log.Info(ctx, "Transaction was rejected", zap.String("txResult", tx.MetaData.TransactionResult.String()))
}
o.log.Info(
ctx,
"Successfully sent operation evidence",
zap.String("txResult", tx.MetaData.TransactionResult.String()),
zap.Any("evidence", evidence),
)
return nil
}
if IsExpectedEvidenceSubmissionError(err) {
Expand Down

0 comments on commit c4aabf5

Please sign in to comment.