message_crosschain_ack_request.go

package types

import (
	sdk "github.com/cosmos/cosmos-sdk/types"
	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
	proto "github.com/gogo/protobuf/proto"
	attestationTypes "github.com/router-protocol/sdk-go/routerchain/attestation/types"
	multichainTypes "github.com/router-protocol/sdk-go/routerchain/multichain/types"
	"github.com/tendermint/tendermint/crypto/tmhash"
)

const TypeMsgCrosschainAckRequest = "crosschain_ack_request"

var _ sdk.Msg = &MsgCrosschainAckRequest{}

func NewMsgCrosschainAckRequest(orchestrator string, ackSrcChainType multichainTypes.ChainType,
	ackSrcChainId string, contract string, ackRequestIdentifier uint64, blockHeight uint64, destTxHash string, relayerRouterAddress string, ackDestChainType multichainTypes.ChainType, ackDestChainId string, requestSender string, requestIdentifier uint64, feeConsumed uint64, execData []byte, execStatus bool) *MsgCrosschainAckRequest {
	return &MsgCrosschainAckRequest{
		Orchestrator:         orchestrator,
		AckSrcChainId:        ackSrcChainId,
		Contract:             contract,
		AckSrcChainType:      ackSrcChainType,
		AckRequestIdentifier: ackRequestIdentifier,
		BlockHeight:          blockHeight,
		DestTxHash:           destTxHash,
		RelayerRouterAddress: relayerRouterAddress,
		AckDestChainId:       ackDestChainId,
		AckDestChainType:     ackDestChainType,
		RequestIdentifier:    requestIdentifier,
		RequestSender:        requestSender,
		FeeConsumed:          feeConsumed,
		ExecData:             execData,
		ExecStatus:           execStatus,
	}
}

func (msg *MsgCrosschainAckRequest) Route() string {
	return RouterKey
}

func (msg *MsgCrosschainAckRequest) Type() string {
	return TypeMsgCrosschainAckRequest
}

func (msg *MsgCrosschainAckRequest) GetSigners() []sdk.AccAddress {
	orchestrator, err := sdk.AccAddressFromBech32(msg.Orchestrator)
	if err != nil {
		panic(err)
	}
	return []sdk.AccAddress{orchestrator}
}

func (msg *MsgCrosschainAckRequest) GetSignBytes() []byte {
	bz := ModuleCdc.MustMarshalJSON(msg)
	return sdk.MustSortJSON(bz)
}

func (msg *MsgCrosschainAckRequest) ValidateBasic() error {
	_, err := sdk.AccAddressFromBech32(msg.Orchestrator)
	if err != nil {
		return sdkerrors.Wrapf(sdkerrors.ErrInvalidAddress, "invalid orchestrator address (%s)", err)
	}
	return nil
}

func (msg *MsgCrosschainAckRequest) GetChainId() string {
	return msg.AckSrcChainId
}

func (msg *MsgCrosschainAckRequest) GetEventNonce() uint64 {
	return msg.AckRequestIdentifier
}

/////////////////////////////
//     Implement Claim     //
/////////////////////////////

// GetType returns the type of the claim
func (msg *MsgCrosschainAckRequest) GetType() attestationTypes.ClaimType {
	return attestationTypes.CLAIM_TYPE_CROSSCHAIN_ACK_REQUEST
}

// Hash implements MsgCrosschainRequest.Hash
// modify this with care as it is security sensitive. If an element of the claim is not in this hash a single hostile validator
// could engineer a hash collision and execute a version of the claim with any unhashed data changed to benefit them.
// note that the Orchestrator is the only field excluded from this hash, this is because that value is used higher up in the store
// structure for who has made what claim and is verified by the msg ante-handler for signatures
func (msg *MsgCrosschainAckRequest) ClaimHash() ([]byte, error) {
	crosschainAckRequestClaimHash := NewCrosschainAckRequestClaimHash(
		msg.AckSrcChainId,
		msg.Contract,
		msg.AckRequestIdentifier,
		msg.BlockHeight,
		msg.DestTxHash,
		msg.RelayerRouterAddress,
		msg.AckDestChainId,
		msg.RequestSender,
		msg.RequestIdentifier,
		msg.AckSrcChainType,
		msg.AckDestChainType,
		msg.FeeConsumed,
		msg.ExecData,
		msg.ExecStatus,
	)

	out, err := proto.Marshal(crosschainAckRequestClaimHash)
	return tmhash.Sum([]byte(out)), err
}

func (msg MsgCrosschainAckRequest) GetClaimer() sdk.AccAddress {
	err := msg.ValidateBasic()
	if err != nil {
		panic("MsgCrosschainRequest failed ValidateBasic! Should have been handled earlier")
	}

	val, _ := sdk.AccAddressFromBech32(msg.Orchestrator)
	return val
}