-
Notifications
You must be signed in to change notification settings - Fork 110
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
move code to validate outbound methods
- Loading branch information
Showing
3 changed files
with
96 additions
and
61 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,93 @@ | ||
| package keeper | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| sdk "github.com/cosmos/cosmos-sdk/types" | ||
| "github.com/zeta-chain/zetacore/x/crosschain/types" | ||
| observertypes "github.com/zeta-chain/zetacore/x/observer/types" | ||
| ) | ||
|
|
||
| func (k Keeper) ValidateOutboundZEVM(ctx sdk.Context, cctx *types.CrossChainTx, zevmError error, isContractReverted bool) (newCCTXStatus types.CctxStatus) { | ||
| _, commit := ctx.CacheContext() | ||
| if zevmError != nil && !isContractReverted { | ||
| // exceptional case; internal error; should abort CCTX | ||
| cctx.SetAbort(zevmError.Error()) | ||
| return types.CctxStatus_Aborted | ||
| } else if zevmError != nil && isContractReverted { | ||
| // contract call reverted; should refund via a revert tx | ||
| revertMessage := zevmError.Error() | ||
| senderChain := k.zetaObserverKeeper.GetSupportedChainFromChainID(ctx, cctx.InboundParams.SenderChainId) | ||
| if senderChain == nil { | ||
| cctx.SetAbort(fmt.Sprintf("invalid sender chain id %d", cctx.InboundParams.SenderChainId)) | ||
| return types.CctxStatus_Aborted | ||
| } | ||
| gasLimit, err := k.GetRevertGasLimit(ctx, *cctx) | ||
| if err != nil { | ||
| cctx.SetAbort(fmt.Sprintf("revert gas limit error: %s", err.Error())) | ||
| return types.CctxStatus_Aborted | ||
| } | ||
| if gasLimit == 0 { | ||
| // use same gas limit of outbound as a fallback -- should not be required | ||
| gasLimit = cctx.GetCurrentOutboundParam().GasLimit | ||
| } | ||
|
|
||
| err = cctx.AddRevertOutbound(gasLimit) | ||
| if err != nil { | ||
| cctx.SetAbort(fmt.Sprintf("revert outbound error: %s", err.Error())) | ||
| return types.CctxStatus_Aborted | ||
| } | ||
| // we create a new cached context, and we don't commit the previous one with EVM deposit | ||
| tmpCtxRevert, commitRevert := ctx.CacheContext() | ||
| err = func() error { | ||
| err := k.PayGasAndUpdateCctx( | ||
| tmpCtxRevert, | ||
| senderChain.ChainId, | ||
| cctx, | ||
| cctx.InboundParams.Amount, | ||
| false, | ||
| ) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| // Update nonce using senderchain id as this is a revert tx and would go back to the original sender | ||
| return k.UpdateNonce(tmpCtxRevert, senderChain.ChainId, cctx) | ||
| }() | ||
| if err != nil { | ||
| cctx.SetAbort(fmt.Sprintf("deposit revert message: %s err : %s", revertMessage, err.Error())) | ||
| return types.CctxStatus_Aborted | ||
| } | ||
| commitRevert() | ||
| cctx.SetPendingRevert(revertMessage) | ||
| return types.CctxStatus_PendingRevert | ||
| } | ||
| // successful HandleEVMDeposit; | ||
| commit() | ||
| cctx.SetOutBoundMined("Remote omnichain contract call completed") | ||
| return types.CctxStatus_OutboundMined | ||
| } | ||
|
|
||
| func (k Keeper) ValidateOutboundObservers(ctx sdk.Context, cctx *types.CrossChainTx, ballotStatus observertypes.BallotStatus, valueReceived string) error { | ||
| tmpCtx, commit := ctx.CacheContext() | ||
| err := func() error { | ||
| switch ballotStatus { | ||
| case observertypes.BallotStatus_BallotFinalized_SuccessObservation: | ||
| k.ProcessSuccessfulOutbound(tmpCtx, cctx, valueReceived) | ||
| case observertypes.BallotStatus_BallotFinalized_FailureObservation: | ||
| err := k.ProcessFailedOutbound(tmpCtx, cctx, valueReceived) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| } | ||
| return nil | ||
| }() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| err = cctx.Validate() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| commit() | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters